ExternalVendorCode/serval-dna
1
0
Fork 0
mirror of https://github.com/servalproject/serval-dna.git synced 2024-12-22 06:27:51 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

making a vomp call now requires a registerest listener to call

Browse Source 
state information.
when registering a listener you can also specify a list of codecs
that are supported.  These are included in the initial 3-way
call initiation process so that each party knows which codecs
the other supports.
This commit is contained in:
gardners 2012-04-23 13:30:22 +09:30
parent 801d55dc00
commit 0cff6b5abf
2 changed files with 56 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
serval.h
View File

@ -1182,6 +1182,9 @@ typedef struct overlay_mdp_vompevent {
unsigned char other_calls_states[VOMP_MAX_CALLS];
};
unsigned char audio_bytes[MDP_MTU-100];
/* list of codecs the registering party is willing to support
(for VOMPEVENT_REGISTERINTEREST) */
unsigned char supported_codecs[257];
};
} overlay_mdp_vompevent;
@ -1263,15 +1266,21 @@ typedef struct vomp_call_state {
int audio_started;
int last_sent_status;
int next_status_time;
unsigned char remote_codec_list[256];
} vomp_call_state;
#define VOMP_CODEC_NONE 0x00
#define VOMP_CODEC_CODEC2_2400 0x01
#define VOMP_CODEC_CODEC2_1400 0x02
#define VOMP_CODEC_GSM 0x03
#define VOMP_CODEC_GSMHALF 0x03
#define VOMP_CODEC_GSMFULL 0x04
#define VOMP_CODEC_16SIGNED 0x05
#define VOMP_CODEC_8ULAW 0x06
#define VOMP_CODEC_8ALAW 0x07
#define VOMP_CODEC_DTMF 0x80
#define VOMP_CODEC_ENGAGED 0x81
#define VOMP_CODEC_CALLERID 0x82
#define VOMP_CODEC_ONHOLD 0x82
#define VOMP_CODEC_CALLERID 0x83
#define VOMP_CODEC_CODECSISUPPORT 0xfe
#define VOMP_CODEC_CHANGEYOURCODECTO 0xff

41
vomp.c
View File

@ -33,6 +33,9 @@ int vomp_call_count=0;
int vomp_active_call=-1;
vomp_call_state vomp_call_states[VOMP_MAX_CALLS];
/* which codecs we support (set by registered listener) */
unsigned char vomp_local_codec_list[256];
/* Now keep track of who wants to know what we are up to */
int vomp_interested_usock_count=0;
#define VOMP_MAX_INTERESTED 128
@ -158,6 +161,7 @@ vomp_call_state *vomp_find_or_create_call(unsigned char *remote_sid,
#define VOMP_TELLREMOTE (1<<1)
#define VOMP_NEWCALL (1<<2)
#define VOMP_FORCETELLREMOTE ((1<<3)|VOMP_TELLREMOTE)
#define VOMP_TELLCODECS (1<<4)
int vomp_send_status(vomp_call_state *call,int flags)
{
@ -193,6 +197,14 @@ int vomp_send_status(vomp_call_state *call,int flags)
mdp.out.payload_length=14;
if ((!call->remote.session)||(flags&VOMP_TELLCODECS)) {
/* Also include list of supported codecs */
int i;
for(i=0;i<256;i++)
if (vomp_local_codec_list[i]) mdp.out.payload[mdp.out.payload_length++]=i;
mdp.out.payload[mdp.out.payload_length++]=0;
}
overlay_mdp_send(&mdp,0,0);
call->local.sequence++;
@ -309,6 +321,7 @@ int vomp_call_destroy(vomp_call_state *call)
so that any old process cannot request a mesh call. Although, in fairness,
the user will know about the call because the call display will come up.
*/
int vomp_mdp_event(overlay_mdp_frame *mdp,
struct sockaddr_un *recvaddr,int recvaddrlen)
{
@ -323,7 +336,7 @@ int vomp_mdp_event(overlay_mdp_frame *mdp,
transported audio. In particular we inform when the call state changes,
including if any error has occurred.
*/
dump("vomp frame",mdp,256);
dump("vomp frame",(unsigned char *)mdp,256);
fprintf(stderr,"Flags=0x%x\n",mdp->vompevent.flags);
switch(mdp->vompevent.flags)
{
@ -360,6 +373,14 @@ int vomp_mdp_event(overlay_mdp_frame *mdp,
vomp_interested_usock_lengths[i]=recvaddrlen;
vomp_interested_expiries[i]=overlay_gettime_ms()+60000;
if (i==vomp_interested_usock_count) vomp_interested_usock_count++;
if (mdp->vompevent.supported_codecs[0]) {
/* Replace set of locally supported codecs */
for(i=0;i<256;i++) vomp_local_codec_list[i]=0;
for(i=0;(i<256)&&mdp->vompevent.supported_codecs[i];i++)
vomp_local_codec_list[mdp->vompevent.supported_codecs[i]]=1;
}
return overlay_mdp_reply_error
(mdp_named_socket,recvaddr,recvaddrlen,0,"Success");
} else {
@ -488,7 +509,7 @@ int vomp_mdp_event(overlay_mdp_frame *mdp,
(hopefully) at far end. */
vomp_send_status(call,VOMP_TELLREMOTE|VOMP_TELLINTERESTED);
WHY("sending MDP reply back");
dump("recvaddr",recvaddr,recvaddrlen);
dump("recvaddr",(unsigned char *)recvaddr,recvaddrlen);
int result= overlay_mdp_reply_error
(mdp_named_socket,recvaddr,recvaddrlen,0, "Success");
if (result) WHY("Failed to send MDP reply");
@ -520,6 +541,7 @@ int vomp_mdp_event(overlay_mdp_frame *mdp,
return overlay_mdp_reply_error
(mdp_named_socket,recvaddr,recvaddrlen,4006,
"No such call");
if (call->local.state==VOMP_STATE_RINGINGIN) {
call->local.state=VOMP_STATE_INCALL;
call->ringing=0;
/* state machine does job of starting audio stream, just tell everyone about
@ -527,6 +549,11 @@ int vomp_mdp_event(overlay_mdp_frame *mdp,
overlay_mdp_reply_error(mdp_named_socket,
recvaddr,recvaddrlen,0,"Success");
return vomp_send_status(call,VOMP_TELLREMOTE|VOMP_TELLINTERESTED);
} else {
overlay_mdp_reply_error(mdp_named_socket,
recvaddr,recvaddrlen,4009,
"Call is not RINGINGIN, so cannot be picked up");
}
}
break;
case VOMPEVENT_AUDIOSTREAMING: /* user supplying audio */
@ -593,7 +620,7 @@ int vomp_mdp_received(overlay_mdp_frame *mdp)
call->last_activity=overlay_gettime_ms();
call->remote.sequence=sender_seq;
call->remote.state=sender_state;
return vomp_send_status(call,VOMP_TELLREMOTE);
return vomp_send_status(call,VOMP_TELLREMOTE|VOMP_TELLCODECS);
} else {
WHY("recvr_session!=0, looking for existing call");
/* A VoMP packet for a call apparently already in progress */
@ -603,6 +630,14 @@ int vomp_mdp_received(overlay_mdp_frame *mdp)
if (!call) {
return WHY("VoMP frame does not correspond to an active call - stale traffic or replay attack?");
}
if (!vomp_interested_usock_count) {
/* No registered listener, so we cannot answer the call, so just reject
it. */
call->local.state=VOMP_STATE_CALLENDED;
return vomp_send_status(call,VOMP_TELLREMOTE);
}
/* Consider states: our actual state, sender state, what the sender thinks
our state is, and what we think the sender's state is. But largely it
breaks down to what we think our state is, and what they think their