|
@@ -170,6 +170,11 @@ int sr_event_register_cb(int type, sr_event_cb_f f)
|
|
|
_sr_events_list.tcp_closed = f;
|
|
|
else return -1;
|
|
|
break;
|
|
|
+ case SREV_NET_DATA_RECV:
|
|
|
+ if(_sr_events_list.net_data_recv==0)
|
|
|
+ _sr_events_list.net_data_recv = f;
|
|
|
+ else return -1;
|
|
|
+ break;
|
|
|
case SREV_NET_DATA_SEND:
|
|
|
if(_sr_events_list.net_data_send==0)
|
|
|
_sr_events_list.net_data_send = f;
|
|
@@ -300,6 +305,12 @@ int sr_event_exec(int type, void *data)
|
|
|
ret = _sr_events_list.tcp_closed(data);
|
|
|
return ret;
|
|
|
} else return 1;
|
|
|
+ case SREV_NET_DATA_RECV:
|
|
|
+ if(unlikely(_sr_events_list.net_data_recv!=0))
|
|
|
+ {
|
|
|
+ ret = _sr_events_list.net_data_recv(data);
|
|
|
+ return ret;
|
|
|
+ } else return 1;
|
|
|
case SREV_NET_DATA_SEND:
|
|
|
if(unlikely(_sr_events_list.net_data_send!=0))
|
|
|
{
|
|
@@ -343,6 +354,8 @@ int sr_event_enabled(int type)
|
|
|
return (_sr_events_list.rcv_nosip!=0)?1:0;
|
|
|
case SREV_TCP_CLOSED:
|
|
|
return (_sr_events_list.tcp_closed!=0)?1:0;
|
|
|
+ case SREV_NET_DATA_RECV:
|
|
|
+ return (_sr_events_list.net_data_recv!=0)?1:0;
|
|
|
case SREV_NET_DATA_SEND:
|
|
|
return (_sr_events_list.net_data_send!=0)?1:0;
|
|
|
}
|