Lines Matching refs:stream
77 if (!socket->stream) { in GetSocketError()
82 cur_stream = socket->stream; in GetSocketError()
240 return GetTCPState(socket->monitor_stream->stream, MOS_SIDE_CLI, in mtcp_getsockopt()
243 return GetTCPState(socket->monitor_stream->stream, MOS_SIDE_SVR, in mtcp_getsockopt()
246 return GetLastTimestamp(socket->monitor_stream->stream, in mtcp_getsockopt()
309 rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_setsockopt()
310 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
311 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
323 rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_setsockopt()
324 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
325 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
347 rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_setsockopt()
348 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
349 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
357 rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_setsockopt()
358 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
359 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
376 rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_setsockopt()
377 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
378 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
386 rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_setsockopt()
387 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
388 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
405 rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_setsockopt()
406 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
407 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
413 rb = (socket->monitor_stream->stream->side == MOS_SIDE_CLI) ? in mtcp_setsockopt()
414 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
415 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
432 rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_setsockopt()
433 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
434 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
440 rb = (socket->monitor_stream->stream->side == MOS_SIDE_SVR) ? in mtcp_setsockopt()
441 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
442 socket->monitor_stream->stream->pair_stream->rcvvar->rcvbuf; in mtcp_setsockopt()
528 cur_stream = socket->stream; in mtcp_ioctl()
880 socket->stream = accepted; in mtcp_accept()
889 if (socket->stream->pair_stream != NULL) in mtcp_accept()
890 socket->stream->pair_stream->socket = socket; in mtcp_accept()
1035 if (socket->stream) { in mtcp_connect()
1037 if (socket->stream->state >= TCP_ST_ESTABLISHED) { in mtcp_connect()
1210 cur_stream = mtcp->smap[sockid].stream; in CloseStreamSocket()
1391 cur_stream = mtcp->smap[sockid].stream; in mtcp_abort()
1541 cur_stream = socket->stream; in mtcp_recv()
1653 cur_stream = socket->stream; in mtcp_readv()
1807 cur_stream = socket->stream; in mtcp_write()
1890 cur_stream = socket->stream; in mtcp_writev()