Ver Fonte

msrp: updates for core events API changes

Daniel-Constantin Mierla há 8 anos atrás
pai
commit
a354ed2e96
2 ficheiros alterados com 10 adições e 6 exclusões
  1. 3 3
      src/modules/msrp/msrp_mod.c
  2. 7 3
      src/modules/msrp/msrp_netio.c

+ 3 - 3
src/modules/msrp/msrp_mod.c

@@ -69,7 +69,7 @@ int msrp_timer_interval = 60;
 str msrp_use_path_addr = { 0 };
 str msrp_use_path_addr = { 0 };
 int msrp_tls_module_loaded = 0;
 int msrp_tls_module_loaded = 0;
 
 
-static int msrp_frame_received(void *data);
+static int msrp_frame_received(sr_event_param_t *evp);
 sip_msg_t *msrp_fake_sipmsg(msrp_frame_t *mf);
 sip_msg_t *msrp_fake_sipmsg(msrp_frame_t *mf);
 
 
 static tr_export_t mod_trans[] = {
 static tr_export_t mod_trans[] = {
@@ -435,7 +435,7 @@ static int w_msrp_cmap_lookup(sip_msg_t* msg, char* str1, char* str2)
 /**
 /**
  *
  *
  */
  */
-static int msrp_frame_received(void *data)
+static int msrp_frame_received(sr_event_param_t *evp)
 {
 {
 	tcp_event_info_t *tev;
 	tcp_event_info_t *tev;
 	static msrp_frame_t mf;
 	static msrp_frame_t mf;
@@ -444,7 +444,7 @@ static int msrp_frame_received(void *data)
 	int rtb, rt;
 	int rtb, rt;
 
 
 
 
-	tev = (tcp_event_info_t*)data;
+	tev = (tcp_event_info_t*)evp->data;
 
 
 	if(tev==NULL || tev->buf==NULL || tev->len<=0)
 	if(tev==NULL || tev->buf==NULL || tev->len<=0)
 	{
 	{

+ 7 - 3
src/modules/msrp/msrp_netio.c

@@ -73,6 +73,7 @@ int msrp_relay(msrp_frame_t *mf)
 	char *p;
 	char *p;
 	char *l;
 	char *l;
 	int port;
 	int port;
+	sr_event_param_t evp = {0};
 
 
 	if(mf->buf.len>=MSRP_MAX_FRAME_SIZE-1)
 	if(mf->buf.len>=MSRP_MAX_FRAME_SIZE-1)
 		return -1;
 		return -1;
@@ -167,7 +168,8 @@ done:
 			wsev.buf = reqbuf;
 			wsev.buf = reqbuf;
 			wsev.len = p - reqbuf;
 			wsev.len = p - reqbuf;
 			wsev.id = con->id;
 			wsev.id = con->id;
-			return sr_event_exec(SREV_TCP_WS_FRAME_OUT, (void *) &wsev);
+			evp.data = (void *)&wsev;
+			return sr_event_exec(SREV_TCP_WS_FRAME_OUT, &evp);
 		}
 		}
 		else if (tcp_send(dst, 0, reqbuf, p - reqbuf) < 0) {
 		else if (tcp_send(dst, 0, reqbuf, p - reqbuf) < 0) {
 			LM_ERR("forwarding frame failed\n");
 			LM_ERR("forwarding frame failed\n");
@@ -192,6 +194,7 @@ int msrp_reply(msrp_frame_t *mf, str *code, str *text, str *xhdrs)
 	msrp_env_t *env;
 	msrp_env_t *env;
 	char *p;
 	char *p;
 	char *l;
 	char *l;
+	sr_event_param_t evp = {0};
 
 
 	/* no reply for a reply */
 	/* no reply for a reply */
 	if(mf->fline.msgtypeid==MSRP_REPLY)
 	if(mf->fline.msgtypeid==MSRP_REPLY)
@@ -297,9 +300,10 @@ int msrp_reply(msrp_frame_t *mf, str *code, str *text, str *xhdrs)
 		wsev.buf = rplbuf;
 		wsev.buf = rplbuf;
 		wsev.len = p - rplbuf;
 		wsev.len = p - rplbuf;
 		wsev.id = con->id;
 		wsev.id = con->id;
-		return sr_event_exec(SREV_TCP_WS_FRAME_OUT, (void *) &wsev);
+		evp.data = (void *)&wsev;
+		return sr_event_exec(SREV_TCP_WS_FRAME_OUT, &evp);
 	}
 	}
-	else 
+	else
 	if (tcp_send(&env->srcinfo, 0, rplbuf, p - rplbuf) < 0) {
 	if (tcp_send(&env->srcinfo, 0, rplbuf, p - rplbuf) < 0) {
 		LM_ERR("sending reply failed\n");
 		LM_ERR("sending reply failed\n");
 		return -1;
 		return -1;