kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-03-05 18:13:27 +00:00
Code Issues Projects Releases Wiki Activity

skypiax: changed audio i/o tcp socket size and timing constant on linux, for better compatibility with virtual machines

Browse Source 
git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@16330 d0543943-73ff-0310-b7d9-9358b9ac24b2
This commit is contained in:
Giovanni Maruzzelli 2010-01-16 17:15:12 +00:00
parent daab35e3d6
commit 7fa36e835d
1 changed files with 20 additions and 3 deletions

23
src/mod/endpoints/mod_skypiax/skypiax_protocol.c

@ -93,7 +93,11 @@ unsigned short start_port = 6001;
* use: * use:
* sockbufsize=SAMPLES_PER_FRAME * 8; * sockbufsize=SAMPLES_PER_FRAME * 8;
*/ */
#ifdef WIN32
sockbufsize=SAMPLES_PER_FRAME * 8 * 3; sockbufsize=SAMPLES_PER_FRAME * 8 * 3;
#else
sockbufsize=SAMPLES_PER_FRAME * 8;
#endif //WIN32
size = sizeof(int); size = sizeof(int);
setsockopt(s, SOL_SOCKET, SO_RCVBUF, (char *)&sockbufsize, size); setsockopt(s, SOL_SOCKET, SO_RCVBUF, (char *)&sockbufsize, size);
@ -106,7 +110,11 @@ unsigned short start_port = 6001;
* use: * use:
* sockbufsize=SAMPLES_PER_FRAME * 8; * sockbufsize=SAMPLES_PER_FRAME * 8;
*/ */
#ifdef WIN32
sockbufsize=SAMPLES_PER_FRAME * 8 * 3; sockbufsize=SAMPLES_PER_FRAME * 8 * 3;
#else
sockbufsize=SAMPLES_PER_FRAME * 8;
#endif //WIN32
size = sizeof(int); size = sizeof(int);
setsockopt(s, SOL_SOCKET, SO_SNDBUF, (char *)&sockbufsize, size); setsockopt(s, SOL_SOCKET, SO_SNDBUF, (char *)&sockbufsize, size);
@ -1028,7 +1036,11 @@ void *skypiax_do_tcp_cli_thread_func(void *obj)
//FIXME rt = select(fdselect + 1, NULL, &fs, NULL, &to); //FIXME rt = select(fdselect + 1, NULL, &fs, NULL, &to);
while(tech_pvt->flag_audio_cli == 0){ while(tech_pvt->flag_audio_cli == 0){
skypiax_sleep(100); //1 millisec #ifdef WIN32
skypiax_sleep(100); //0.1 millisec
#else
skypiax_sleep(1000); //1 millisec
#endif //WIN32
//WARNINGA("write now is 0\n", SKYPIAX_P_LOG); //WARNINGA("write now is 0\n", SKYPIAX_P_LOG);
} }
//ERRORA("write is now 1\n", SKYPIAX_P_LOG); //ERRORA("write is now 1\n", SKYPIAX_P_LOG);
@ -1134,9 +1146,14 @@ int skypiax_audio_read(private_t * tech_pvt)
unsigned int samples; unsigned int samples;
while(tech_pvt->flag_audio_srv == 0){ while(tech_pvt->flag_audio_srv == 0){
skypiax_sleep(100); //1 millisec #ifdef WIN32
skypiax_sleep(100); //0.1 millisec
#else
skypiax_sleep(1000); //1 millisec
#endif //WIN32
//WARNINGA("read now is 0\n", SKYPIAX_P_LOG); //WARNINGA("read now is 0\n", SKYPIAX_P_LOG);
} }
//ERRORA("read is now 1\n", SKYPIAX_P_LOG); //ERRORA("read is now 1\n", SKYPIAX_P_LOG);
//samples = skypiax_pipe_read(tech_pvt->audiopipe_srv[0], tech_pvt->read_frame.data, SAMPLES_PER_FRAME * sizeof(short)); //samples = skypiax_pipe_read(tech_pvt->audiopipe_srv[0], tech_pvt->read_frame.data, SAMPLES_PER_FRAME * sizeof(short));
samples = SAMPLES_PER_FRAME * sizeof(short); samples = SAMPLES_PER_FRAME * sizeof(short);