Lines Matching refs:sendside_stream

284 UpdateMonitor(mtcp_manager_t mtcp, struct tcp_stream *sendside_stream,   in UpdateMonitor()  argument
294 ClonePacketCtx(&sendside_stream->last_pctx.p, in UpdateMonitor()
295 sendside_stream->last_pkt_data, &(pctx.p)); in UpdateMonitor()
299 if (sendside_stream->status_mgmt) { in UpdateMonitor()
300 sendside_stream->cb_events = MOS_ON_PKT_IN; in UpdateMonitor()
303 UpdatePassiveSendTCPContext(mtcp, sendside_stream, pctx); in UpdateMonitor()
305 sendside_stream->allow_pkt_modification = true; in UpdateMonitor()
307 if (sendside_stream->side == MOS_SIDE_CLI) { in UpdateMonitor()
308 SOCKQ_FOREACH_START(walk, &sendside_stream->msocks) { in UpdateMonitor()
309 HandleCallback(mtcp, MOS_HK_SND, walk, sendside_stream->side, in UpdateMonitor()
310 pctx, sendside_stream->cb_events); in UpdateMonitor()
313 SOCKQ_FOREACH_REVERSE(walk, &sendside_stream->msocks) { in UpdateMonitor()
314 HandleCallback(mtcp, MOS_HK_SND, walk, sendside_stream->side, in UpdateMonitor()
315 pctx, sendside_stream->cb_events); in UpdateMonitor()
318 sendside_stream->allow_pkt_modification = false; in UpdateMonitor()
323 assert(sendside_stream->side == MOS_SIDE_CLI); in UpdateMonitor()
324 if ((recvside_stream = AttachServerTCPStream(mtcp, sendside_stream, 0, in UpdateMonitor()
327 DestroyTCPStream(mtcp, sendside_stream); in UpdateMonitor()
342 PostSendTCPAction(mtcp, pctx, recvside_stream, sendside_stream); in UpdateMonitor()
374 sendside_stream->cb_events = 0; in UpdateMonitor()
378 HandleMonitorStream(mtcp_manager_t mtcp, struct tcp_stream *sendside_stream, in HandleMonitorStream() argument
381 UpdateMonitor(mtcp, sendside_stream, recvside_stream, pctx, true); in HandleMonitorStream()
383 recvside_stream = sendside_stream->pair_stream; in HandleMonitorStream()
392 if (recvside_stream->stream_type == sendside_stream->stream_type && in HandleMonitorStream()
398 ((sendside_stream->state == TCP_ST_TIME_WAIT && in HandleMonitorStream()
400 sendside_stream->state == TCP_ST_CLOSED_RSVD || in HandleMonitorStream()
401 !sendside_stream->status_mgmt)) in HandleMonitorStream()