Lines Matching refs:socket

202 	socket_map_t socket = &mtcp->msmap[msock];  in mtcp_set_uctx()  local
203 if (socket->socktype == MOS_SOCK_MONITOR_STREAM_ACTIVE) in mtcp_set_uctx()
204 socket->monitor_stream->uctx = uctx; in mtcp_set_uctx()
205 else if (socket->socktype == MOS_SOCK_MONITOR_STREAM || in mtcp_set_uctx()
206 socket->socktype == MOS_SOCK_MONITOR_RAW) in mtcp_set_uctx()
207 socket->monitor_listener->uctx = uctx; in mtcp_set_uctx()
233 socket_map_t socket = &mtcp->msmap[msock]; in mtcp_get_uctx() local
234 if (socket->socktype == MOS_SOCK_MONITOR_STREAM_ACTIVE) in mtcp_get_uctx()
235 return socket->monitor_stream->uctx; in mtcp_get_uctx()
236 else if (socket->socktype == MOS_SOCK_MONITOR_STREAM || in mtcp_get_uctx()
237 socket->socktype == MOS_SOCK_MONITOR_RAW) in mtcp_get_uctx()
238 return socket->monitor_listener->uctx; in mtcp_get_uctx()
456 socket_map_t socket; in mtcp_getlastpkt() local
472 socket = &mtcp->msmap[sock]; in mtcp_getlastpkt()
474 switch (socket->socktype) { in mtcp_getlastpkt()
491 if (socket->socktype == MOS_SOCK_MONITOR_STREAM_ACTIVE) { in mtcp_getlastpkt()
498 struct tcp_stream *mstrm = socket->monitor_stream->stream; in mtcp_getlastpkt()
506 } else if (socket->socktype == MOS_SOCK_MONITOR_RAW) { in mtcp_getlastpkt()
508 } else if (socket->socktype == MOS_SOCK_MONITOR_STREAM) { in mtcp_getlastpkt()
558 socket_map_t socket; in mtcp_sendpkt() local
573 socket = &mtcp->msmap[sock]; in mtcp_sendpkt()
581 if (socket->socktype == MOS_SOCK_MONITOR_STREAM_ACTIVE) { in mtcp_sendpkt()
588 socket->monitor_stream->stream->rcvvar->ts_recent, in mtcp_sendpkt()
589 socket->monitor_stream->stream->rcvvar->ts_lastack_rcvd, in mtcp_sendpkt()
607 RemoveMonitorEvents(mtcp_manager_t mtcp, socket_map_t socket, int side) in RemoveMonitorEvents() argument
618 switch (socket->socktype) { in RemoveMonitorEvents()
620 mstream = socket->monitor_stream; in RemoveMonitorEvents()
658 mlistener = socket->monitor_listener; in RemoveMonitorEvents()
708 socket_map_t socket; in mtcp_cb_stop() local
719 socket = &mtcp->msmap[sock]; in mtcp_cb_stop()
722 RemoveMonitorEvents(mtcp, socket, side); in mtcp_cb_stop()
725 if (socket->socktype == MOS_SOCK_MONITOR_STREAM) { in mtcp_cb_stop()
733 stream = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_cb_stop()
734 socket->monitor_stream->stream : in mtcp_cb_stop()
735 socket->monitor_stream->stream->pair_stream; in mtcp_cb_stop()
746 stream = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_cb_stop()
747 socket->monitor_stream->stream : in mtcp_cb_stop()
748 socket->monitor_stream->stream->pair_stream; in mtcp_cb_stop()
755 stream = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_cb_stop()
756 socket->monitor_stream->stream : in mtcp_cb_stop()
757 socket->monitor_stream->stream->pair_stream; in mtcp_cb_stop()
767 stream = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_cb_stop()
768 socket->monitor_stream->stream : in mtcp_cb_stop()
769 socket->monitor_stream->stream->pair_stream; in mtcp_cb_stop()
795 socket_map_t socket; in mtcp_reset_conn() local
803 socket = &mtcp->msmap[sock]; in mtcp_reset_conn()
806 if (socket->socktype == MOS_SOCK_MONITOR_STREAM) { in mtcp_reset_conn()
812 SendRSTPacketStandalone(mtcp, socket->monitor_stream->stream); in mtcp_reset_conn()
813 SendRSTPacketStandalone(mtcp, socket->monitor_stream->stream->pair_stream); in mtcp_reset_conn()
852 socket_map_t socket; in mtcp_getpeername() local
877 socket = &mtcp->msmap[sockfd]; in mtcp_getpeername()
881 stream = socket->monitor_stream->stream; in mtcp_getpeername()
943 socket_map_t socket; in mtcp_setlastpkt()
964 socket = &mtcp->msmap[sock]; in mtcp_setlastpkt()
965 if (socket->socktype == MOS_SOCK_MONITOR_STREAM_ACTIVE) { in mtcp_setlastpkt()
972 struct tcp_stream *mstrm = socket->monitor_stream->stream; in mtcp_setlastpkt()
977 } else if (socket->socktype != MOS_SOCK_MONITOR_RAW) { in mtcp_setlastpkt()