|
@@ -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_SEND:
|
|
|
+ if(_sr_events_list.net_data_send==0)
|
|
|
+ _sr_events_list.net_data_send = f;
|
|
|
+ else return -1;
|
|
|
+ break;
|
|
|
default:
|
|
|
return -1;
|
|
|
}
|
|
@@ -295,6 +300,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_SEND:
|
|
|
+ if(unlikely(_sr_events_list.net_data_send!=0))
|
|
|
+ {
|
|
|
+ ret = _sr_events_list.net_data_send(data);
|
|
|
+ return ret;
|
|
|
+ } else return 1;
|
|
|
default:
|
|
|
return -1;
|
|
|
}
|
|
@@ -332,6 +343,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_SEND:
|
|
|
+ return (_sr_events_list.net_data_send!=0)?1:0;
|
|
|
}
|
|
|
return 0;
|
|
|
}
|