Lines Matching refs:cur_stream
247 struct tcp_stream *cur_stream; in mtcp_peek() local
279 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_peek()
281 if (!cur_stream || !cur_stream->buffer_mgmt) { in mtcp_peek()
288 if (cur_stream->rcvvar != NULL && in mtcp_peek()
289 cur_stream->rcvvar->rcvbuf != NULL) { in mtcp_peek()
290 tcprb_t *rcvbuf = cur_stream->rcvvar->rcvbuf; in mtcp_peek()
291 loff_t *poff = &sock->monitor_stream->peek_offset[cur_stream->side]; in mtcp_peek()
365 struct tcp_stream *cur_stream; in mtcp_ppeek() local
396 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_ppeek()
398 if (!cur_stream || !cur_stream->buffer_mgmt) { in mtcp_ppeek()
406 if (cur_stream->rcvvar != NULL && in mtcp_ppeek()
407 cur_stream->rcvvar->rcvbuf != NULL) { in mtcp_ppeek()
408 tcprb_t *rcvbuf = cur_stream->rcvvar->rcvbuf; in mtcp_ppeek()
490 struct tcp_stream *cur_stream; in mtcp_getlastpkt() local
499 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_getlastpkt()
501 cur_pkt_ctx = &cur_stream->last_pctx; in mtcp_getlastpkt()
944 struct tcp_stream *cur_stream; in mtcp_setlastpkt()
973 cur_stream = (side == mstrm->side) ? mstrm : mstrm->pair_stream; in mtcp_setlastpkt()
975 if (!cur_stream->allow_pkt_modification) in mtcp_setlastpkt()