*/
#include "linphonecore_utils.h"
+#include "private.h"
+#include "mediastreamer2/msticker.h"
#include "mediastreamer2/mssndcard.h"
-#include "mediastreamer2/msvolume.h"
+#include "mediastreamer2/msaudiomixer.h"
+#include "mediastreamer2/mschanadapter.h"
+#include "mediastreamer2/msfileplayer.h"
+#include "mediastreamer2/msitc.h"
+static struct _MSSndCard *linphone_sound_daemon_get_proxy_card(LinphoneSoundDaemon *obj);
+
#define MAX_BRANCHES 10
MSFilter *player;
MSFilter *rateconv;
MSFilter *chanadapter;
- MSFilter *volumectl;
LsdEndOfPlayCallback eop_cb;
+ int mixer_pin;
void *user_data;
- bool_t loopmode;
+ bool_t loop;
+ bool_t pad[3];
};
struct _LinphoneSoundDaemon {
int out_nchans;
MSFilter *mixer;
MSFilter *soundout;
+ MSTicker *ticker;
+ MSSndCard *proxycard;
LsdPlayer branches[MAX_BRANCHES];
};
+static MSFilter *create_writer(MSSndCard *c){
+ LinphoneSoundDaemon *lsd=(LinphoneSoundDaemon*)c->data;
+ MSFilter *itcsink=ms_filter_new(MS_ITC_SINK_ID);
+ ms_filter_call_method(itcsink,MS_ITC_SINK_CONNECT,lsd->branches[0].player);
+ return itcsink;
+}
+
+static MSSndCardDesc proxycard={
+ "Linphone Sound Daemon",
+ /*detect*/ NULL,
+ /*init*/ NULL,
+ NULL,
+ NULL,
+ NULL,
+ NULL,
+ NULL,
+ /*create_reader*/ NULL,
+ create_writer,
+ /*uninit,*/
+};
LsdPlayer *linphone_sound_daemon_get_player(LinphoneSoundDaemon *obj){
int i;
- for(i=0;i<MAX_BRANCHES;++i){
+ for(i=1;i<MAX_BRANCHES;++i){
LsdPlayer *b=&obj->branches[i];
MSFilter *p=b->player;
int state;
ms_filter_call_method(p,MS_PLAYER_GET_STATE,&state);
if (state==MSPlayerClosed){
+ lsd_player_set_gain(b,1);
+ lsd_player_enable_loop (b,FALSE);
return b;
}
}
void linphone_sound_daemon_release_player(LinphoneSoundDaemon *obj, LsdPlayer * player){
int state;
- float gain=1;
ms_filter_call_method(player->player,MS_PLAYER_GET_STATE,&state);
if (state!=MSPlayerClosed){
ms_filter_call_method(player->player,MS_PLAYER_CLOSE,&state);
}
- ms_filter_call_method(player->volumectl,MS_VOLUME_SET_GAIN,&gain);
+}
+
+LinphoneSoundDaemon *lsd_player_get_daemon(const LsdPlayer *p){
+ return p->lsd;
}
int lsd_player_stop(LsdPlayer *p){
return 0;
}
-MSFilter *linphone_sound_daemon_get_proxy(LinphoneSoundDaemon *obj);
-void linphone_sound_daemon_destroy(LinphoneSoundDaemon *obj);
-
static void lsd_player_init(LsdPlayer *p, MSConnectionPoint mixer, MSFilterId playerid, LinphoneSoundDaemon *lsd){
MSConnectionHelper h;
p->player=ms_filter_new(playerid);
p->rateconv=ms_filter_new(MS_RESAMPLE_ID);
- p->chanadapter=NULL;
- p->volumectl=ms_filter_new(MS_VOLUME_ID);
-
+ p->chanadapter=ms_filter_new(MS_CHANNEL_ADAPTER_ID);
+
ms_connection_helper_start(&h);
ms_connection_helper_link(&h,p->player,-1,0);
ms_connection_helper_link(&h,p->rateconv,0,0);
ms_connection_helper_link(&h,p->chanadapter,0,0);
- ms_connection_helper_link(&h,p->volumectl,0,0);
ms_connection_helper_link(&h,mixer.filter,mixer.pin,-1);
+ p->mixer_pin=mixer.pin;
+ p->loop=FALSE;
p->lsd=lsd;
}
ms_connection_helper_unlink (&h,p->player,-1,0);
ms_connection_helper_unlink(&h,p->rateconv,0,0);
ms_connection_helper_unlink(&h,p->chanadapter,0,0);
- ms_connection_helper_unlink(&h,p->volumectl,0,0);
ms_connection_helper_unlink(&h,mixer.filter,mixer.pin,-1);
ms_filter_destroy(p->player);
ms_filter_destroy(p->rateconv);
ms_filter_destroy(p->chanadapter);
- ms_filter_destroy(p->volumectl);
}
void lsd_player_set_callback(LsdPlayer *p, LsdEndOfPlayCallback cb){
p->user_data=up;
}
-void *lsd_player_get_user_pointer(LsdPlayer *p){
+void *lsd_player_get_user_pointer(const LsdPlayer *p){
return p->user_data;
}
-static void lsd_player_on_eop(void * userdata, unsigned int id, void *arg){
+static void lsd_player_on_eop(void * userdata, MSFilter *f, unsigned int id, void *arg){
+ LsdPlayer *p=(LsdPlayer *)userdata;
+ if (p->eop_cb!=NULL)
+ p->eop_cb(p);
}
-int lsd_player_play(LsdPlayer *b, const char *filename ){
+static void lsd_player_configure(LsdPlayer *b){
int rate,chans;
- int state;
LinphoneSoundDaemon *lsd=b->lsd;
+
+ if (ms_filter_get_id(b->player)==MS_ITC_SOURCE_ID)
+ ms_message("Configuring branch coming from audio call...");
+
+ ms_filter_call_method(b->player,MS_FILTER_GET_SAMPLE_RATE,&rate);
+ ms_filter_call_method(b->player,MS_FILTER_GET_NCHANNELS,&chans);
+
+
+ ms_filter_call_method(b->rateconv,MS_FILTER_SET_SAMPLE_RATE,&rate);
+ ms_filter_call_method(b->rateconv,MS_FILTER_SET_NCHANNELS,&chans);
+ ms_filter_call_method(b->rateconv,MS_FILTER_SET_OUTPUT_SAMPLE_RATE,&lsd->out_rate);
+
+ ms_filter_call_method(b->chanadapter,MS_FILTER_SET_NCHANNELS,&chans);
+ ms_filter_call_method(b->chanadapter,MS_CHANNEL_ADAPTER_SET_OUTPUT_NCHANNELS,&lsd->out_nchans);
+ ms_message("player configured for rate=%i, channels=%i",rate,chans);
+}
+
+int lsd_player_play(LsdPlayer *b, const char *filename ){
+ int state;
ms_filter_call_method(b->player,MS_PLAYER_GET_STATE,&state);
if (state!=MSPlayerClosed){
}
if (ms_filter_call_method(b->player,MS_PLAYER_OPEN,(void*)filename)!=0){
+ ms_warning("Could not play %s",filename);
return -1;
}
- ms_filter_call_method(b->player,MS_FILTER_GET_SAMPLE_RATE,&rate);
- ms_filter_call_method(b->player,MS_FILTER_GET_NCHANNELS,&chans);
ms_filter_set_notify_callback (b->player,lsd_player_on_eop,b);
-
- ms_filter_call_method(b->rateconv,MS_FILTER_SET_SAMPLE_RATE,&rate);
- ms_filter_call_method(b->rateconv,MS_FILTER_SET_NCHANNELS,&chans);
- ms_filter_call_method(b->rateconv,MS_FILTER_SET_OUTPUT_SAMPLE_RATE,&lsd->out_rate);
-
- ms_filter_call_method(b->chanadapter,MS_FILTER_SET_NCHANNELS,&chans);
- ms_filter_call_method(b->chanadapter,MS_FILTER_SET_OUTPUT_NCHANNELS,&lsd->out_nchans);
+ lsd_player_configure(b);
+ ms_filter_call_method_noarg (b->player,MS_PLAYER_START);
return 0;
}
-int lsd_player_stop(LsdPlayer *p);
-void lsd_player_enable_loop(LsdPlayer *p, bool_t loopmode);
+void lsd_player_enable_loop(LsdPlayer *p, bool_t loopmode){
+ if (ms_filter_get_id(p->player)==MS_FILE_PLAYER_ID){
+ int arg=loopmode ? 0 : -1;
+ ms_filter_call_method(p->player,MS_FILE_PLAYER_LOOP,&arg);
+ p->loop=loopmode;
+ }
+}
+
+bool_t lsd_player_loop_enabled(const LsdPlayer *p){
+ return p->loop;
+}
+
+void lsd_player_set_gain(LsdPlayer *p, float gain){
+ MSAudioMixerCtl gainctl;
+ gainctl.pin=p->mixer_pin;
+ gainctl.param.gain=gain;
+ ms_filter_call_method(p->lsd->mixer,MS_AUDIO_MIXER_SET_INPUT_GAIN,&gainctl);
+}
-LinphoneSoundDaemon * linphone_sound_daemon_new(const char *cardname){
+LinphoneSoundDaemon * linphone_sound_daemon_new(const char *cardname, int rate, int nchannels){
int i;
MSConnectionPoint mp;
LinphoneSoundDaemon *lsd;
lsd=ms_new0(LinphoneSoundDaemon,1);
lsd->soundout=ms_snd_card_create_writer(card);
- lsd->out_rate=44100;
- lsd->out_nchans=2;
+ lsd->mixer=ms_filter_new(MS_AUDIO_MIXER_ID);
+ lsd->out_rate=rate;
+ lsd->out_nchans=nchannels;
ms_filter_call_method(lsd->soundout,MS_FILTER_SET_SAMPLE_RATE,&lsd->out_rate);
ms_filter_call_method(lsd->soundout,MS_FILTER_SET_NCHANNELS,&lsd->out_nchans);
+ ms_filter_call_method(lsd->mixer,MS_FILTER_SET_SAMPLE_RATE,&lsd->out_rate);
+ ms_filter_call_method(lsd->mixer,MS_FILTER_SET_NCHANNELS,&lsd->out_nchans);
- mp.filter=lsd->filter;
+ mp.filter=lsd->mixer;
mp.pin=0;
- lsd_player_init(&lsd->branches[0],mp,MS_ITC_SINK_ID,lsd);
+ lsd_player_init(&lsd->branches[0],mp,MS_ITC_SOURCE_ID,lsd);
+ ms_filter_set_notify_callback(lsd->branches[0].player,(MSFilterNotifyFunc)lsd_player_configure,&lsd->branches[0]);
for(i=1;i<MAX_BRANCHES;++i){
mp.pin=i;
- lsd_player_init(&lsd->branches[i],mp,MS_FILE_PLAYER_ID);
+ lsd_player_init(&lsd->branches[i],mp,MS_FILE_PLAYER_ID,lsd);
}
-
+ ms_filter_link(lsd->mixer,0,lsd->soundout,0);
+ lsd->ticker=ms_ticker_new();
+ ms_ticker_attach(lsd->ticker,lsd->soundout);
+
+ lsd->proxycard=ms_snd_card_new(&proxycard);
+ lsd->proxycard->data=lsd;
+ ms_message("LinphoneSoundDaemon started with rate=%i, nchannels=%i",rate,nchannels);
return lsd;
}
+void linphone_sound_daemon_stop_all_players(LinphoneSoundDaemon *obj){
+ int i;
+ for(i=1;i<MAX_BRANCHES;++i){
+ lsd_player_stop(&obj->branches[i]);
+ }
+}
+
+void linphone_sound_daemon_release_all_players(LinphoneSoundDaemon *obj){
+ int i;
+ for(i=1;i<MAX_BRANCHES;++i){
+ linphone_sound_daemon_release_player(obj,&obj->branches[i]);
+ }
+}
+
+void linphone_sound_daemon_destroy(LinphoneSoundDaemon *obj){
+ int i;
+ MSConnectionPoint mp;
+ ms_ticker_detach(obj->ticker,obj->soundout);
+ mp.filter=obj->mixer;
+ for(i=0;i<MAX_BRANCHES;++i){
+ mp.pin=i;
+ if (i!=0) linphone_sound_daemon_release_player(obj,&obj->branches[i]);
+ lsd_player_uninit (&obj->branches[i],mp);
+ }
+ ms_filter_unlink(obj->mixer,0,obj->soundout,0);
+ ms_ticker_destroy(obj->ticker);
+ ms_filter_destroy(obj->soundout);
+ ms_filter_destroy(obj->mixer);
+}
+
+MSSndCard *linphone_sound_daemon_get_proxy_card(LinphoneSoundDaemon *lsd){
+ return lsd->proxycard;
+}
-#endif
+void linphone_core_use_sound_daemon(LinphoneCore *lc, LinphoneSoundDaemon *lsd){
+ if (lsd!=NULL){
+ lc->sound_conf.lsd_card=linphone_sound_daemon_get_proxy_card (lsd);
+ }else {
+ lc->sound_conf.lsd_card=NULL;
+ }
+}
projects / linphone / blobdiff