]> sjero.net Git - linphone/blob - coreapi/lsd.c
bugfixing in lsd.
[linphone] / coreapi / lsd.c
1 /*
2 linphone
3 Copyright (C) 2010 Simon MORLAT (simon.morlat@linphone.org)
4
5 This program is free software; you can redistribute it and/or
6 modify it under the terms of the GNU General Public License
7 as published by the Free Software Foundation; either version 2
8 of the License, or (at your option) any later version.
9
10 This program is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13 GNU General Public License for more details.
14
15 You should have received a copy of the GNU General Public License
16 along with this program; if not, write to the Free Software
17 Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
18 */
19
20 /* Linphone Sound Daemon: is a lightweight utility to play sounds to speaker during a conversation.
21  This is useful for embedded platforms, where sound apis are not performant enough to allow
22  simultaneous sound access.
23 */
24
25 #include "linphonecore_utils.h"
26 #include "private.h"
27 #include "mediastreamer2/msticker.h"
28 #include "mediastreamer2/mssndcard.h"
29 #include "mediastreamer2/msaudiomixer.h"
30 #include "mediastreamer2/mschanadapter.h"
31 #include "mediastreamer2/msfileplayer.h"
32 #include "mediastreamer2/msitc.h"
33
34
35 static struct _MSSndCard *linphone_sound_daemon_get_proxy_card(LinphoneSoundDaemon *obj);
36
37 #define MAX_BRANCHES 10
38
39
40 struct _LsdPlayer{
41         struct _LinphoneSoundDaemon *lsd;
42         MSFilter *player;
43         MSFilter *rateconv;
44         MSFilter *chanadapter;
45         LsdEndOfPlayCallback eop_cb;
46         int mixer_pin;
47         void *user_data;
48         bool_t loop;
49         bool_t pad[3];
50 };
51
52 struct _LinphoneSoundDaemon {
53         int out_rate;
54         int out_nchans;
55         MSFilter *mixer;
56         MSFilter *soundout;
57         MSFilter *itcsink;
58         MSTicker *ticker;
59         MSSndCard *proxycard;
60         LsdPlayer branches[MAX_BRANCHES];
61 };
62
63 static MSFilter *create_writer(MSSndCard *c){
64         LinphoneSoundDaemon *lsd=(LinphoneSoundDaemon*)c->data;
65         lsd->itcsink=ms_filter_new(MS_ITC_SINK_ID);
66         ms_filter_call_method(lsd->itcsink,MS_ITC_SINK_CONNECT,lsd->branches[0].player);
67         return lsd->itcsink;
68 }
69
70 static MSSndCardDesc proxycard={
71         "Linphone Sound Daemon",
72         /*detect*/ NULL,
73         /*init*/ NULL,
74         NULL,
75         NULL,
76         NULL,
77         NULL,
78         NULL,
79         /*create_reader*/ NULL,
80         create_writer,
81         /*uninit,*/
82 };
83
84 LsdPlayer *linphone_sound_daemon_get_player(LinphoneSoundDaemon *obj){
85         int i;
86         for(i=1;i<MAX_BRANCHES;++i){
87                 LsdPlayer *b=&obj->branches[i];
88                 MSFilter *p=b->player;
89                 int state;
90                 ms_filter_call_method(p,MS_PLAYER_GET_STATE,&state);
91                 if (state==MSPlayerClosed){
92                         lsd_player_set_gain(b,1);
93                         lsd_player_enable_loop (b,FALSE);
94                         return b;
95                 }
96         }
97         ms_warning("No more free players !");
98         return NULL;
99 }
100
101 void linphone_sound_daemon_release_player(LinphoneSoundDaemon *obj, LsdPlayer * player){
102         int state;
103         ms_filter_call_method(player->player,MS_PLAYER_GET_STATE,&state);
104         if (state!=MSPlayerClosed){
105                 ms_filter_call_method(player->player,MS_PLAYER_CLOSE,&state);
106         }
107 }
108
109 LinphoneSoundDaemon *lsd_player_get_daemon(const LsdPlayer *p){
110         return p->lsd;
111 }
112
113 int lsd_player_stop(LsdPlayer *p){
114         ms_filter_call_method_noarg(p->player,MS_PLAYER_PAUSE);
115         return 0;
116 }
117
118 static void lsd_player_init(LsdPlayer *p, MSConnectionPoint mixer, MSFilterId playerid, LinphoneSoundDaemon *lsd){
119         MSConnectionHelper h;
120         p->player=ms_filter_new(playerid);
121         p->rateconv=ms_filter_new(MS_RESAMPLE_ID);
122         p->chanadapter=ms_filter_new(MS_CHANNEL_ADAPTER_ID);
123         
124         ms_connection_helper_start(&h);
125         ms_connection_helper_link(&h,p->player,-1,0);
126         ms_connection_helper_link(&h,p->rateconv,0,0);
127         ms_connection_helper_link(&h,p->chanadapter,0,0);
128         ms_connection_helper_link(&h,mixer.filter,mixer.pin,-1);
129         p->mixer_pin=mixer.pin;
130         p->loop=FALSE;
131         p->lsd=lsd;
132 }
133
134 static void lsd_player_uninit(LsdPlayer *p, MSConnectionPoint mixer){
135         MSConnectionHelper h;
136
137         ms_connection_helper_start(&h);
138         ms_connection_helper_unlink (&h,p->player,-1,0);
139         ms_connection_helper_unlink(&h,p->rateconv,0,0);
140         ms_connection_helper_unlink(&h,p->chanadapter,0,0);
141         ms_connection_helper_unlink(&h,mixer.filter,mixer.pin,-1);
142
143         ms_filter_destroy(p->player);
144         ms_filter_destroy(p->rateconv);
145         ms_filter_destroy(p->chanadapter);
146 }
147
148 void lsd_player_set_callback(LsdPlayer *p, LsdEndOfPlayCallback cb){
149         p->eop_cb=cb;
150 }
151
152 void lsd_player_set_user_pointer(LsdPlayer *p, void *up){
153         p->user_data=up;
154 }
155
156 void *lsd_player_get_user_pointer(const LsdPlayer *p){
157         return p->user_data;
158 }
159
160 static void lsd_player_on_eop(void * userdata, unsigned int id, void *arg){
161         LsdPlayer *p=(LsdPlayer *)userdata;
162         if (p->eop_cb!=NULL)
163                 p->eop_cb(p);
164 }
165
166 int lsd_player_play(LsdPlayer *b, const char *filename ){
167         int rate,chans;
168         int state;
169         LinphoneSoundDaemon *lsd=b->lsd;
170         
171         ms_filter_call_method(b->player,MS_PLAYER_GET_STATE,&state);
172         if (state!=MSPlayerClosed){
173                 ms_filter_call_method_noarg(b->player,MS_PLAYER_CLOSE);
174         }
175         
176         if (ms_filter_call_method(b->player,MS_PLAYER_OPEN,(void*)filename)!=0){
177                 ms_warning("Could not play %s",filename);
178                 return -1;
179         }
180         ms_filter_call_method(b->player,MS_FILTER_GET_SAMPLE_RATE,&rate);
181         ms_filter_call_method(b->player,MS_FILTER_GET_NCHANNELS,&chans);
182         ms_filter_set_notify_callback (b->player,lsd_player_on_eop,b);
183         
184         ms_filter_call_method(b->rateconv,MS_FILTER_SET_SAMPLE_RATE,&rate);
185         ms_filter_call_method(b->rateconv,MS_FILTER_SET_NCHANNELS,&chans);
186         ms_filter_call_method(b->rateconv,MS_FILTER_SET_OUTPUT_SAMPLE_RATE,&lsd->out_rate);
187
188         ms_filter_call_method(b->chanadapter,MS_FILTER_SET_NCHANNELS,&chans);
189         ms_filter_call_method(b->chanadapter,MS_CHANNEL_ADAPTER_SET_OUTPUT_NCHANNELS,&lsd->out_nchans);
190         ms_filter_call_method_noarg (b->player,MS_PLAYER_START);
191         return 0;
192 }
193
194 void lsd_player_enable_loop(LsdPlayer *p, bool_t loopmode){
195         if (ms_filter_get_id(p->player)==MS_FILE_PLAYER_ID){
196                 int arg=loopmode ? 0 : -1;
197                 ms_filter_call_method(p->player,MS_FILE_PLAYER_LOOP,&arg);
198                 p->loop=loopmode;
199         }
200 }
201
202 bool_t lsd_player_loop_enabled(const LsdPlayer *p){
203         return p->loop;
204 }
205
206 void lsd_player_set_gain(LsdPlayer *p, float gain){
207         MSAudioMixerCtl gainctl;
208         gainctl.pin=p->mixer_pin;
209         gainctl.gain=gain;
210         ms_filter_call_method(p->lsd->mixer,MS_AUDIO_MIXER_SET_INPUT_GAIN,&gainctl);
211 }
212
213 LinphoneSoundDaemon * linphone_sound_daemon_new(const char *cardname){
214         int i;
215         MSConnectionPoint mp;
216         LinphoneSoundDaemon *lsd;
217         MSSndCard *card=ms_snd_card_manager_get_card(
218                                                      ms_snd_card_manager_get(),
219                                                      cardname);
220         if (card==NULL){
221                 card=ms_snd_card_manager_get_default_playback_card (
222                                                                     ms_snd_card_manager_get());
223                 if (card==NULL){
224                         ms_error("linphone_sound_daemon_new(): No playback soundcard available");
225                         return NULL;
226                 }
227         }
228         
229         lsd=ms_new0(LinphoneSoundDaemon,1);
230         lsd->soundout=ms_snd_card_create_writer(card);
231         lsd->mixer=ms_filter_new(MS_AUDIO_MIXER_ID);
232         lsd->itcsink=ms_filter_new(MS_ITC_SINK_ID);
233         lsd->out_rate=44100;
234         lsd->out_nchans=2;
235         ms_filter_call_method(lsd->soundout,MS_FILTER_SET_SAMPLE_RATE,&lsd->out_rate);
236         ms_filter_call_method(lsd->soundout,MS_FILTER_SET_NCHANNELS,&lsd->out_nchans);
237         ms_filter_call_method(lsd->mixer,MS_FILTER_SET_SAMPLE_RATE,&lsd->out_rate);
238         ms_filter_call_method(lsd->mixer,MS_FILTER_SET_NCHANNELS,&lsd->out_nchans);
239
240         mp.filter=lsd->mixer;
241         mp.pin=0;
242
243         lsd_player_init(&lsd->branches[0],mp,MS_ITC_SOURCE_ID,lsd);
244         for(i=1;i<MAX_BRANCHES;++i){
245                 mp.pin=i;
246                 lsd_player_init(&lsd->branches[i],mp,MS_FILE_PLAYER_ID,lsd);
247         }
248         ms_filter_link(lsd->mixer,0,lsd->soundout,0);
249         lsd->ticker=ms_ticker_new();
250         ms_ticker_attach(lsd->ticker,lsd->soundout);
251
252         lsd->proxycard=ms_snd_card_new(&proxycard);
253         lsd->proxycard->data=lsd;
254         
255         return lsd;
256 }
257
258 void linphone_sound_daemon_destroy(LinphoneSoundDaemon *obj){
259         int i;
260         MSConnectionPoint mp;
261         ms_ticker_detach(obj->ticker,obj->soundout);
262         mp.filter=obj->mixer;
263         for(i=0;i<MAX_BRANCHES;++i){
264                 mp.pin=i;
265                 lsd_player_uninit (&obj->branches[i],mp);
266         }
267         ms_filter_unlink(obj->mixer,0,obj->soundout,0);
268         ms_ticker_destroy(obj->ticker);
269         ms_filter_destroy(obj->soundout);
270         ms_filter_destroy(obj->mixer);
271         ms_filter_destroy(obj->itcsink);
272 }
273
274 MSSndCard *linphone_sound_daemon_get_proxy_card(LinphoneSoundDaemon *lsd){
275         return lsd->proxycard;
276 }
277
278 void linphone_core_use_sound_daemon(LinphoneCore *lc, LinphoneSoundDaemon *lsd){
279         lc->sound_conf.lsd_card=linphone_sound_daemon_get_proxy_card (lsd);
280 }