Lines Matching refs:monitor_stream

204 		socket->monitor_stream->uctx = uctx;  in mtcp_set_uctx()
235 return socket->monitor_stream->uctx; in mtcp_get_uctx()
278 struct tcp_stream *mstrm = sock->monitor_stream->stream; in mtcp_peek()
291 loff_t *poff = &sock->monitor_stream->peek_offset[cur_stream->side]; in mtcp_peek()
395 struct tcp_stream *mstrm = sock->monitor_stream->stream; in mtcp_ppeek()
498 struct tcp_stream *mstrm = socket->monitor_stream->stream; in mtcp_getlastpkt()
588 socket->monitor_stream->stream->rcvvar->ts_recent, in mtcp_sendpkt()
589 socket->monitor_stream->stream->rcvvar->ts_lastack_rcvd, in mtcp_sendpkt()
620 mstream = socket->monitor_stream; in RemoveMonitorEvents()
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()
739 if (walk->monitor_stream->client_mon == 1) { 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()
760 if (walk->monitor_stream->server_mon == 1) { 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()
812 SendRSTPacketStandalone(mtcp, socket->monitor_stream->stream); in mtcp_reset_conn()
813 SendRSTPacketStandalone(mtcp, socket->monitor_stream->stream->pair_stream); in mtcp_reset_conn()
881 stream = socket->monitor_stream->stream; in mtcp_getpeername()
972 struct tcp_stream *mstrm = socket->monitor_stream->stream; in mtcp_setlastpkt()