Home
last modified time | relevance | path

Searched refs:monitor_stream (Results 1 – 10 of 10) sorted by relevance

/mOS-networking-stack/core/src/
H A Dtcp_stream.c184 stream = sock->monitor_stream->stream; in DisableBuf()
357 s->monitor_stream->socket = s; in AddMonitorStreamSockets()
358 s->monitor_stream->stream = stream; in AddMonitorStreamSockets()
365 s->monitor_stream->stree_dontcare = in AddMonitorStreamSockets()
367 s->monitor_stream->stree_pre_rcv = in AddMonitorStreamSockets()
369 s->monitor_stream->stree_post_snd = in AddMonitorStreamSockets()
371 if (s->monitor_stream->stree_dontcare) in AddMonitorStreamSockets()
373 if (s->monitor_stream->stree_pre_rcv) in AddMonitorStreamSockets()
375 if (s->monitor_stream->stree_post_snd) in AddMonitorStreamSockets()
378 InitEvP(&s->monitor_stream->dontcare_evp, in AddMonitorStreamSockets()
[all …]
H A Dmos_api.c204 socket->monitor_stream->uctx = uctx; in mtcp_set_uctx()
235 return socket->monitor_stream->uctx; in mtcp_get_uctx()
620 mstream = socket->monitor_stream; in RemoveMonitorEvents()
734 socket->monitor_stream->stream : in mtcp_cb_stop()
735 socket->monitor_stream->stream->pair_stream; in mtcp_cb_stop()
739 if (walk->monitor_stream->client_mon == 1) { in mtcp_cb_stop()
747 socket->monitor_stream->stream : in mtcp_cb_stop()
756 socket->monitor_stream->stream : in mtcp_cb_stop()
757 socket->monitor_stream->stream->pair_stream; in mtcp_cb_stop()
768 socket->monitor_stream->stream : in mtcp_cb_stop()
[all …]
H A Dapi.c246 return GetLastTimestamp(socket->monitor_stream->stream, in mtcp_getsockopt()
310 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
324 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
348 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
358 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
377 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
387 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
406 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
414 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
433 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
[all …]
H A Devent_callback.c451 evp = &socket->monitor_stream->dontcare_evp; in ModifyCallback()
452 evb = &socket->monitor_stream->monitor_listener->dontcare_evb; in ModifyCallback()
454 evp = &socket->monitor_stream->pre_tcp_evp; in ModifyCallback()
455 evb = &socket->monitor_stream->monitor_listener->pre_tcp_evb; in ModifyCallback()
457 evp = &socket->monitor_stream->post_tcp_evp; in ModifyCallback()
458 evb = &socket->monitor_stream->monitor_listener->post_tcp_evb; in ModifyCallback()
615 if (side == MOS_SIDE_CLI && socket->monitor_stream->client_mon == 0) in HandleCallback()
618 else if (side == MOS_SIDE_SVR && socket->monitor_stream->server_mon == 0) in HandleCallback()
621 #define MSTRM(sock) (sock)->monitor_stream in HandleCallback()
H A Dtcp.c152 bm = walk->monitor_stream->monitor_listener->server_buf_mgmt; in CreateMonitorStream()
156 if (walk->monitor_stream->monitor_listener->server_mon == 1) { in CreateMonitorStream()
163 bm = walk->monitor_stream->monitor_listener->client_buf_mgmt; in CreateMonitorStream()
167 if (walk->monitor_stream->monitor_listener->client_mon == 1) { in CreateMonitorStream()
H A Dscalable_event.c990 pstree = &socket->monitor_stream->stree_dontcare; in mtcp_register_callback()
992 pstree = &socket->monitor_stream->stree_pre_rcv; in mtcp_register_callback()
994 pstree = &socket->monitor_stream->stree_post_snd; in mtcp_register_callback()
1037 if (side == MOS_SIDE_CLI && socket->monitor_stream->client_mon == 0) in HandleCallback()
1040 else if (side == MOS_SIDE_SVR && socket->monitor_stream->server_mon == 0) in HandleCallback()
1043 #define MSTRM(sock) (sock)->monitor_stream in HandleCallback()
H A Dsocket.c44 struct mon_stream *mstream = socket->monitor_stream; in FreeMonStream()
H A Dtcp_in.c632 if (walk->monitor_stream->peek_offset[cur_stream->side] in ProcessTCPPayload()
639 if (walk->monitor_stream->peek_offset[cur_stream->side] in ProcessTCPPayload()
H A Dcore.c1175 mtcp->msmap[i].monitor_stream = calloc(1, sizeof(struct mon_stream)); in InitializeMTCPManager()
1176 if (!mtcp->msmap[i].monitor_stream) { in InitializeMTCPManager()
/mOS-networking-stack/core/src/include/
H A Dsocket.h119 struct mon_stream *monitor_stream; member