Home
last modified time | relevance | path

Searched refs:pair_stream (Results 1 – 9 of 9) sorted by relevance

/mOS-networking-stack/core/src/
H A Dtcp_stream.c186 stream = stream->pair_stream; in DisableBuf()
211 stream->pair_stream->last_active_ts) in GetLastTimestamp()
629 cs->pair_stream = NULL;
664 cs->pair_stream = ss;
665 ss->pair_stream = cs;
841 if (stream->pair_stream == NULL)
845 if (stream->pair_stream != NULL) {
847 stream->pair_stream->pair_stream = NULL;
887 tcp_stream *pair_stream = stream->pair_stream; local
891 if (pair_stream)
[all …]
H A Dtcp.c125 stream->pair_stream->side = MOS_SIDE_SVR; in CreateMonitorStream()
138 assert(IS_STREAM_TYPE(stream->pair_stream, in CreateMonitorStream()
142 stream->pair_stream->buffer_mgmt = FALSE; in CreateMonitorStream()
161 stream->pair_stream->status_mgmt = 0; in CreateMonitorStream()
162 SOCKQ_FOREACH_START(walk, &stream->pair_stream->msocks) { in CreateMonitorStream()
164 if (bm > stream->pair_stream->buffer_mgmt) { in CreateMonitorStream()
165 stream->pair_stream->buffer_mgmt = bm; in CreateMonitorStream()
168 stream->pair_stream->status_mgmt = 1; in CreateMonitorStream()
383 recvside_stream = sendside_stream->pair_stream; in HandleMonitorStream()
476 HandleMonitorStream(mtcp, cur_stream, cur_stream->pair_stream, pctx); in ProcessInTCPPacket()
H A Dapi.c311 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
325 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
359 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
388 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
889 if (socket->stream->pair_stream != NULL) in mtcp_accept()
890 socket->stream->pair_stream->socket = socket; in mtcp_accept()
1129 if (cur_stream->pair_stream) { in mtcp_connect()
1130 cur_stream->pair_stream->side = MOS_SIDE_SVR; in mtcp_connect()
1138 cur_stream->pair_stream->buffer_mgmt = BUFMGMT_OFF; in mtcp_connect()
1142 if (bm > cur_stream->pair_stream->buffer_mgmt) { in mtcp_connect()
[all …]
H A Dmos_api.c279 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_peek()
396 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_ppeek()
499 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_getlastpkt()
735 socket->monitor_stream->stream->pair_stream; in mtcp_cb_stop()
748 socket->monitor_stream->stream->pair_stream; in mtcp_cb_stop()
757 socket->monitor_stream->stream->pair_stream; in mtcp_cb_stop()
769 socket->monitor_stream->stream->pair_stream; in mtcp_cb_stop()
813 SendRSTPacketStandalone(mtcp, socket->monitor_stream->stream->pair_stream); in mtcp_reset_conn()
973 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_setlastpkt()
H A Dtimer.c461 if ((walk->pair_stream != NULL) in CheckTimewaitExpire()
462 && (walk->pair_stream->state != TCP_ST_CLOSED_RSVD) in CheckTimewaitExpire()
463 && (walk->pair_stream->state != TCP_ST_TIME_WAIT)) in CheckTimewaitExpire()
513 TCPStateToString(walk->pair_stream)); in CheckConnectionTimeout()
H A Dtcp_in.c889 if (pctx->p.seq == cur_stream->pair_stream->sndvar->iss) { in Handle_TCP_ST_SYN_RCVD()
891 pctx->p.seq, cur_stream->pair_stream->sndvar->iss); in Handle_TCP_ST_SYN_RCVD()
914 if (pctx->p.seq == cur_stream->pair_stream->sndvar->iss) { in Handle_TCP_ST_ESTABLISHED()
916 pctx->p.seq, cur_stream->pair_stream->sndvar->iss); in Handle_TCP_ST_ESTABLISHED()
1324 if (pctx->p.seq == cur_stream->pair_stream->sndvar->fss) {
1326 pctx->p.seq, cur_stream->pair_stream->sndvar->fss);
H A Dcore.c572 if (stream->pair_stream != NULL) in HandleApplicationCalls()
573 stream->pair_stream->cb_events |= in HandleApplicationCalls()
H A Dtcp_out.c391 struct tcp_stream *recvside_stream = cur_stream->pair_stream; in SendTCPPacket()
/mOS-networking-stack/core/src/include/
H A Dtcp_stream.h277 struct tcp_stream *pair_stream; /* pair stream in case of monitor / proxy socket */ member