Lines Matching refs:cur_stream
75 tcp_stream *cur_stream; in GetSocketError() local
82 cur_stream = socket->stream; in GetSocketError()
83 if (cur_stream->state == TCP_ST_CLOSED_RSVD) { in GetSocketError()
84 if (cur_stream->close_reason == TCP_TIMEDOUT || in GetSocketError()
85 cur_stream->close_reason == TCP_CONN_FAIL || in GetSocketError()
86 cur_stream->close_reason == TCP_CONN_LOST) { in GetSocketError()
94 if (cur_stream->state == TCP_ST_CLOSE_WAIT || in GetSocketError()
95 cur_stream->state == TCP_ST_CLOSED_RSVD) { in GetSocketError()
96 if (cur_stream->close_reason == TCP_RESET) { in GetSocketError()
104 if (cur_stream->state == TCP_ST_SYN_SENT && in GetSocketError()
117 if (cur_stream->close_reason == TCP_NOT_CLOSED) { in GetSocketError()
525 tcp_stream *cur_stream; in mtcp_ioctl() local
528 cur_stream = socket->stream; in mtcp_ioctl()
529 if (!cur_stream) { in mtcp_ioctl()
534 rbuf = cur_stream->rcvvar->rcvbuf; in mtcp_ioctl()
986 tcp_stream *cur_stream; in mtcp_connect() local
996 cur_stream = NULL; in mtcp_connect()
1100 cur_stream = CreateClientTCPStream(mtcp, socket, in mtcp_connect()
1106 cur_stream = CreateDualTCPStream(mtcp, socket, in mtcp_connect()
1114 cur_stream = CreateTCPStream(mtcp, socket, STREAM_TYPE(MOS_SOCK_STREAM), in mtcp_connect()
1117 if (!cur_stream) { in mtcp_connect()
1124 cur_stream->is_bound_addr = TRUE; in mtcp_connect()
1125 cur_stream->sndvar->cwnd = 1; in mtcp_connect()
1126 cur_stream->sndvar->ssthresh = cur_stream->sndvar->mss * 10; in mtcp_connect()
1127 cur_stream->side = MOS_SIDE_CLI; in mtcp_connect()
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()
1140 SOCKQ_FOREACH_START(walk, &cur_stream->msocks) { in mtcp_connect()
1142 if (bm > cur_stream->pair_stream->buffer_mgmt) { in mtcp_connect()
1143 cur_stream->pair_stream->buffer_mgmt = bm; in mtcp_connect()
1149 cur_stream->state = TCP_ST_SYN_SENT; in mtcp_connect()
1150 cur_stream->cb_events |= MOS_ON_TCP_STATE_CHANGE; in mtcp_connect()
1152 TRACE_STATE("Stream %d: TCP_ST_SYN_SENT\n", cur_stream->id); in mtcp_connect()
1155 ret = StreamEnqueue(mtcp->connectq, cur_stream); in mtcp_connect()
1161 StreamEnqueue(mtcp->destroyq, cur_stream); in mtcp_connect()
1174 if (!cur_stream) { in mtcp_connect()
1179 if (cur_stream->state > TCP_ST_ESTABLISHED) { in mtcp_connect()
1181 sockid, TCPStateToString(cur_stream)); in mtcp_connect()
1187 if (cur_stream->state == TCP_ST_ESTABLISHED) { in mtcp_connect()
1201 tcp_stream *cur_stream; in CloseStreamSocket() local
1210 cur_stream = mtcp->smap[sockid].stream; in CloseStreamSocket()
1211 if (!cur_stream) { in CloseStreamSocket()
1217 if (cur_stream->closed) { in CloseStreamSocket()
1219 sockid, cur_stream->id); in CloseStreamSocket()
1222 cur_stream->closed = TRUE; in CloseStreamSocket()
1224 TRACE_API("Stream %d: closing the stream.\n", cur_stream->id); in CloseStreamSocket()
1227 cur_stream->socket = NULL; in CloseStreamSocket()
1229 if (cur_stream->state == TCP_ST_CLOSED_RSVD) { in CloseStreamSocket()
1231 cur_stream->id); in CloseStreamSocket()
1233 StreamEnqueue(mtcp->destroyq, cur_stream); in CloseStreamSocket()
1238 } else if (cur_stream->state == TCP_ST_SYN_SENT) { in CloseStreamSocket()
1241 StreamEnqueue(mtcp->destroyq, cur_stream); in CloseStreamSocket()
1247 } else if (cur_stream->state != TCP_ST_ESTABLISHED && in CloseStreamSocket()
1248 cur_stream->state != TCP_ST_CLOSE_WAIT) { in CloseStreamSocket()
1250 cur_stream->id, TCPStateToString(cur_stream)); in CloseStreamSocket()
1256 cur_stream->sndvar->on_closeq = TRUE; in CloseStreamSocket()
1257 ret = StreamEnqueue(mtcp->closeq, cur_stream); in CloseStreamSocket()
1364 tcp_stream *cur_stream; in mtcp_abort() local
1391 cur_stream = mtcp->smap[sockid].stream; in mtcp_abort()
1392 if (!cur_stream) { in mtcp_abort()
1401 cur_stream->socket = NULL; in mtcp_abort()
1403 if (cur_stream->state == TCP_ST_CLOSED_RSVD) { in mtcp_abort()
1407 } else if (cur_stream->state == TCP_ST_SYN_SENT) { in mtcp_abort()
1410 cur_stream->state = TCP_ST_CLOSED_RSVD; in mtcp_abort()
1411 cur_stream->close_reason = TCP_ACTIVE_CLOSE; in mtcp_abort()
1412 cur_stream->cb_events |= MOS_ON_TCP_STATE_CHANGE; in mtcp_abort()
1414 StreamEnqueue(mtcp->destroyq, cur_stream); in mtcp_abort()
1419 } else if (cur_stream->state == TCP_ST_CLOSING || in mtcp_abort()
1420 cur_stream->state == TCP_ST_LAST_ACK || in mtcp_abort()
1421 cur_stream->state == TCP_ST_TIME_WAIT) { in mtcp_abort()
1422 cur_stream->state = TCP_ST_CLOSED_RSVD; in mtcp_abort()
1423 cur_stream->close_reason = TCP_ACTIVE_CLOSE; in mtcp_abort()
1424 cur_stream->cb_events |= MOS_ON_TCP_STATE_CHANGE; in mtcp_abort()
1426 StreamEnqueue(mtcp->destroyq, cur_stream); in mtcp_abort()
1433 if (cur_stream->sndvar->on_resetq) { in mtcp_abort()
1440 cur_stream->sndvar->on_resetq = TRUE; in mtcp_abort()
1441 ret = StreamEnqueue(mtcp->resetq, cur_stream); in mtcp_abort()
1455 PeekForUser(mtcp_manager_t mtcp, tcp_stream *cur_stream, char *buf, int len) in PeekForUser() argument
1457 struct tcp_recv_vars *rcvvar = cur_stream->rcvvar; in PeekForUser()
1470 CopyToUser(mtcp_manager_t mtcp, tcp_stream *cur_stream, char *buf, int len) in CopyToUser() argument
1472 struct tcp_recv_vars *rcvvar = cur_stream->rcvvar; in CopyToUser()
1485 if (cur_stream->need_wnd_adv) { in CopyToUser()
1486 if (rcvvar->rcv_wnd > cur_stream->sndvar->eff_mss) { in CopyToUser()
1487 if (!cur_stream->sndvar->on_ackq) { in CopyToUser()
1489 cur_stream->sndvar->on_ackq = TRUE; in CopyToUser()
1490 StreamEnqueue(mtcp->ackq, cur_stream); /* this always success */ in CopyToUser()
1492 cur_stream->need_wnd_adv = FALSE; in CopyToUser()
1506 tcp_stream *cur_stream; in mtcp_recv() local
1541 cur_stream = socket->stream; in mtcp_recv()
1542 if (!cur_stream || !cur_stream->rcvvar || !cur_stream->rcvvar->rcvbuf || in mtcp_recv()
1543 !(cur_stream->state >= TCP_ST_ESTABLISHED && in mtcp_recv()
1544 cur_stream->state <= TCP_ST_CLOSE_WAIT)) { in mtcp_recv()
1549 rcvvar = cur_stream->rcvvar; in mtcp_recv()
1554 if (cur_stream->state == TCP_ST_CLOSE_WAIT) { in mtcp_recv()
1571 ret = CopyToUser(mtcp, cur_stream, buf, len); in mtcp_recv()
1574 ret = PeekForUser(mtcp, cur_stream, buf, len); in mtcp_recv()
1593 if (cur_stream->state == TCP_ST_CLOSE_WAIT && in mtcp_recv()
1607 TRACE_API("Stream %d: mtcp_recv() returning %d\n", cur_stream->id, ret); in mtcp_recv()
1622 tcp_stream *cur_stream; in mtcp_readv() local
1653 cur_stream = socket->stream; in mtcp_readv()
1654 if (!cur_stream || !cur_stream->rcvvar->rcvbuf || in mtcp_readv()
1655 !(cur_stream->state >= TCP_ST_ESTABLISHED && in mtcp_readv()
1656 cur_stream->state <= TCP_ST_CLOSE_WAIT)) { in mtcp_readv()
1661 rcvvar = cur_stream->rcvvar; in mtcp_readv()
1666 if (cur_stream->state == TCP_ST_CLOSE_WAIT) { in mtcp_readv()
1687 ret = CopyToUser(mtcp, cur_stream, iov[i].iov_base, iov[i].iov_len); in mtcp_readv()
1708 if (cur_stream->state == TCP_ST_CLOSE_WAIT && in mtcp_readv()
1723 cur_stream->id, bytes_read); in mtcp_readv()
1728 CopyFromUser(mtcp_manager_t mtcp, tcp_stream *cur_stream, const char *buf, int len) in CopyFromUser() argument
1730 struct tcp_send_vars *sndvar = cur_stream->sndvar; in CopyFromUser()
1744 cur_stream->close_reason = TCP_NO_MEM; in CopyFromUser()
1763 cur_stream->id, sndvar->snd_wnd); in CopyFromUser()
1774 tcp_stream *cur_stream; in mtcp_write() local
1807 cur_stream = socket->stream; in mtcp_write()
1808 if (!cur_stream || in mtcp_write()
1809 !(cur_stream->state == TCP_ST_ESTABLISHED || in mtcp_write()
1810 cur_stream->state == TCP_ST_CLOSE_WAIT)) { in mtcp_write()
1824 sndvar = cur_stream->sndvar; in mtcp_write()
1827 ret = CopyFromUser(mtcp, cur_stream, buf, len); in mtcp_write()
1834 StreamEnqueue(mtcp->sendq, cur_stream); /* this always success */ in mtcp_write()
1852 TRACE_API("Stream %d: mtcp_write() returning %d\n", cur_stream->id, ret); in mtcp_write()
1861 tcp_stream *cur_stream; in mtcp_writev() local
1890 cur_stream = socket->stream; in mtcp_writev()
1891 if (!cur_stream || in mtcp_writev()
1892 !(cur_stream->state == TCP_ST_ESTABLISHED || in mtcp_writev()
1893 cur_stream->state == TCP_ST_CLOSE_WAIT)) { in mtcp_writev()
1898 sndvar = cur_stream->sndvar; in mtcp_writev()
1907 ret = CopyFromUser(mtcp, cur_stream, iov[i].iov_base, iov[i].iov_len); in mtcp_writev()
1921 StreamEnqueue(mtcp->sendq, cur_stream); /* this always success */ in mtcp_writev()
1940 cur_stream->id, to_write); in mtcp_writev()