Home
last modified time | relevance | path

Searched refs:cur_stream (Results 1 – 17 of 17) sorted by relevance

/mOS-networking-stack/core/src/
H A Dtcp_in.c70 cur_stream->rcvvar->snd_wl1 = cur_stream->rcvvar->irs - 1; in HandleActiveOpen()
71 cur_stream->rcv_nxt = cur_stream->rcvvar->irs + 1; in HandleActiveOpen()
75 cur_stream->sndvar->cwnd = ((cur_stream->sndvar->cwnd == 1)? in HandleActiveOpen()
76 (cur_stream->sndvar->mss * 2): cur_stream->sndvar->mss); in HandleActiveOpen()
77 cur_stream->sndvar->ssthresh = cur_stream->sndvar->mss * 10; in HandleActiveOpen()
132 cur_stream->rcv_nxt + cur_stream->rcvvar->rcv_wnd)) { in ValidateSequence()
156 cur_stream->id, cur_stream->rcvvar->ts_tw_expire); in ValidateSequence()
184 cur_stream->id, TCPStateToString(cur_stream)); in ProcessRST()
818 cur_stream->snd_nxt = cur_stream->sndvar->iss; in Handle_TCP_ST_SYN_SENT()
844 cur_stream->rcv_nxt = cur_stream->rcvvar->irs + 1; in Handle_TCP_ST_SYN_RCVD()
[all …]
H A Dtimer.c188 cur_stream->id, cur_stream->sndvar->rto, TS_TO_MSEC(cur_stream->sndvar->rto), in HandleRTO()
248 cur_stream->id, cur_stream->sndvar->cwnd, cur_stream->sndvar->ssthresh); in HandleRTO()
253 cur_stream->sndvar->rstat.rto_bytes += (cur_stream->snd_nxt - cur_stream->sndvar->snd_una); in HandleRTO()
277 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
282 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
287 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
292 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
298 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
303 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
306 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
[all …]
H A Dtcp_out.c276 if (cur_stream->snd_nxt != cur_stream->sndvar->iss) { in SendTCPPacket()
279 cur_stream->snd_nxt, cur_stream->sndvar->iss); in SendTCPPacket()
282 cur_stream->id, cur_stream->snd_nxt, cur_stream->rcv_nxt); in SendTCPPacket()
297 cur_stream->snd_nxt - cur_stream->sndvar->snd_una); in SendTCPPacket()
303 cur_stream->id, cur_stream->closed); in SendTCPPacket()
308 cur_stream->id, cur_stream->snd_nxt, cur_stream->rcv_nxt); in SendTCPPacket()
449 cur_stream->id, TCPStateToString(cur_stream), in FlushTCPSendingBuffer()
662 cur_stream->id, TCPStateToString(cur_stream)); in WriteTCPDataList()
754 cur_stream->id, TCPStateToString(cur_stream), in WriteTCPACKList()
755 cur_stream->snd_nxt, cur_stream->rcv_nxt, in WriteTCPACKList()
[all …]
H A Dapi.c75 tcp_stream *cur_stream; in GetSocketError() local
529 if (!cur_stream) { in mtcp_ioctl()
996 cur_stream = NULL; in mtcp_connect()
1117 if (!cur_stream) { in mtcp_connect()
1126 cur_stream->sndvar->ssthresh = cur_stream->sndvar->mss * 10; in mtcp_connect()
1211 if (!cur_stream) { in CloseStreamSocket()
1231 cur_stream->id); in CloseStreamSocket()
1250 cur_stream->id, TCPStateToString(cur_stream)); in CloseStreamSocket()
1392 if (!cur_stream) { in mtcp_abort()
1542 if (!cur_stream || !cur_stream->rcvvar || !cur_stream->rcvvar->rcvbuf || in mtcp_recv()
[all …]
H A Dtcp_util.c15 ParseTCPOptions(tcp_stream *cur_stream, in ParseTCPOptions() argument
38 cur_stream->sndvar->eff_mss = cur_stream->sndvar->mss; in ParseTCPOptions()
45 cur_stream->sack_permit = TRUE; in ParseTCPOptions()
49 cur_stream->saw_timestamp = TRUE; in ParseTCPOptions()
96 ParseSACKOption(tcp_stream *cur_stream, in ParseSACKOption() argument
122 cur_stream->rcvvar->sack_table in ParseSACKOption()
124 cur_stream->rcvvar->sack_table in ParseSACKOption()
126 cur_stream->rcvvar->sacks++; in ParseSACKOption()
129 cur_stream->rstat->sack_cnt++; in ParseSACKOption()
134 cur_stream->rstat->tdp_sack_cnt++; in ParseSACKOption()
[all …]
H A Dtcp.c96 if (!cur_stream) { in CreateServerStream()
103 cur_stream->rcv_nxt = cur_stream->rcvvar->irs; in CreateServerStream()
108 return cur_stream; in CreateServerStream()
218 if (!cur_stream) { in CreateStream()
237 if (!cur_stream) { in CreateStream()
247 return cur_stream; in CreateStream()
449 if (!cur_stream) { in ProcessInTCPPacket()
461 if (!cur_stream) in ProcessInTCPPacket()
465 if (cur_stream) { in ProcessInTCPPacket()
468 if (cur_stream->rcvvar && cur_stream->rcvvar->rcvbuf) in ProcessInTCPPacket()
[all …]
H A Dmos_api.c247 struct tcp_stream *cur_stream; in mtcp_peek() local
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()
365 struct tcp_stream *cur_stream; in mtcp_ppeek() local
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()
490 struct tcp_stream *cur_stream; in mtcp_getlastpkt() local
501 cur_pkt_ctx = &cur_stream->last_pctx; in mtcp_getlastpkt()
[all …]
H A Dcore.c426 struct tcp_stream *cur_stream; in FlushMonitorReadEvents() local
436 cur_stream = in FlushMonitorReadEvents()
439 if (cur_stream != NULL && in FlushMonitorReadEvents()
441 if (cur_stream->rcvvar != NULL && in FlushMonitorReadEvents()
448 cur_stream->side, NULL, in FlushMonitorReadEvents()
454 cur_stream->side, NULL, in FlushMonitorReadEvents()
460 cur_stream->actions = 0; in FlushMonitorReadEvents()
475 struct tcp_stream *cur_stream; in FlushBufferedReadEvents() local
492 if (cur_stream != NULL && in FlushBufferedReadEvents()
494 if (cur_stream->rcvvar != NULL && in FlushBufferedReadEvents()
[all …]
H A Dtcp_stream.c585 tcp_stream *cur_stream, *paired_stream; local
588 cur_stream = CreateTCPStream(mtcp, socket, type,
590 if (cur_stream == NULL) {
598 DestroyTCPStream(mtcp, cur_stream);
603 cur_stream->pair_stream = paired_stream;
604 paired_stream->pair_stream = cur_stream;
606 SOCKQ_FOREACH_START(walk, &cur_stream->msocks) {
611 return cur_stream;
/mOS-networking-stack/core/src/include/
H A Dtimer.h39 AddtoRTOList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
42 RemoveFromRTOList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
45 AddtoTimewaitList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts);
48 RemoveFromTimewaitList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
51 AddtoTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
54 RemoveFromTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
57 UpdateTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
61 tcp_stream *cur_stream, uint32_t cur_ts);
H A Dtcp_out.h22 SendTCPPacket(struct mtcp_manager *mtcp, tcp_stream *cur_stream,
38 AddtoControlList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts);
41 AddtoSendList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
44 RemoveFromControlList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
47 RemoveFromSendList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
50 RemoveFromACKList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
54 tcp_stream *cur_stream, uint32_t cur_ts, uint8_t opt);
60 UpdatePassiveSendTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
H A Dtcp_in.h121 ParseTCPOptions(tcp_stream *cur_stream,
125 ProcessTCPUplink(mtcp_manager_t mtcp, uint32_t cur_ts, tcp_stream *cur_stream,
130 UpdateRecvTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
134 DoActionEndTCPPacket(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
141 UpdatePassiveRecvTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
H A Dtcp_util.h13 void ParseTCPOptions(tcp_stream *cur_stream,
17 ParseTCPTimestamp(tcp_stream *cur_stream,
22 ParseSACKOption(tcp_stream *cur_stream,
H A Dtcp.h13 tcp_stream *cur_stream, int cpu);
H A Dscalable_event.h26 SOCKQ_FOREACH_START(walk, &cur_stream->msocks) { \
H A Dtcp_ring_buffer.h75 int RBPut(rb_manager_t rbm, struct tcp_stream *cur_stream, void *data,
H A Dtcp_stream.h286 TCPStateToString(const tcp_stream *cur_stream);