Lines Matching refs:stream

278 	struct tcp_stream *mstrm = sock->monitor_stream->stream;  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()
709 struct tcp_stream *stream; in mtcp_cb_stop() local
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()
738 SOCKQ_FOREACH_START(walk, &stream->msocks) { 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()
749 stream->status_mgmt = 0; 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()
759 SOCKQ_FOREACH_START(walk, &stream->msocks) { 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()
770 stream->status_mgmt = 0; in mtcp_cb_stop()
781 SendRSTPacketStandalone(mtcp_manager_t mtcp, struct tcp_stream *stream) { in SendRSTPacketStandalone() argument
783 stream->saddr, stream->sport, stream->daddr, stream->dport, in SendRSTPacketStandalone()
784 stream->snd_nxt, stream->rcv_nxt, 0, TCP_FLAG_RST | TCP_FLAG_ACK, in SendRSTPacketStandalone()
812 SendRSTPacketStandalone(mtcp, socket->monitor_stream->stream); in mtcp_reset_conn()
813 SendRSTPacketStandalone(mtcp, socket->monitor_stream->stream->pair_stream); in mtcp_reset_conn()
853 struct tcp_stream *stream; in mtcp_getpeername() local
881 stream = socket->monitor_stream->stream; in mtcp_getpeername()
882 if (stream == NULL) { in mtcp_getpeername()
894 sin->sin_addr.s_addr = (stream->side == side) ? in mtcp_getpeername()
895 stream->daddr : stream->saddr; in mtcp_getpeername()
896 sin->sin_port = (stream->side == side)? in mtcp_getpeername()
897 stream->dport : stream->sport; in mtcp_getpeername()
908 sin[MOS_SIDE_CLI].sin_addr.s_addr = (stream->side == MOS_SIDE_CLI) ? in mtcp_getpeername()
909 stream->daddr : stream->saddr; in mtcp_getpeername()
910 sin[MOS_SIDE_CLI].sin_port = stream->side == MOS_SIDE_CLI ? in mtcp_getpeername()
911 stream->dport : stream->sport; in mtcp_getpeername()
915 sin[MOS_SIDE_SVR].sin_addr.s_addr = (stream->side == MOS_SIDE_SVR) ? in mtcp_getpeername()
916 stream->daddr : stream->saddr; in mtcp_getpeername()
917 sin[MOS_SIDE_SVR].sin_port = stream->side == MOS_SIDE_SVR ? in mtcp_getpeername()
918 stream->dport : stream->sport; in mtcp_getpeername()
972 struct tcp_stream *mstrm = socket->monitor_stream->stream; in mtcp_setlastpkt()