Searched refs:recvbuf (Results 1 – 7 of 7) sorted by relevance
| /openthread-3.5.0/third_party/tcplp/bsdtcp/ |
| D | tcp_reass.c | 77 if (cbuf_reass_count_set(&tp->recvbuf, (size_t) offset, tp->reassbmp, tlen) >= (size_t) tlen) { in tcp_reass()
81 …written = cbuf_reass_write(&tp->recvbuf, (size_t) offset, data, data_offset, tlen, tp->reassbmp, &… in tcp_reass()
93 mergeable = cbuf_reass_count_set(&tp->recvbuf, 0, tp->reassbmp, (size_t) 0xFFFFFFFF); in tcp_reass()
94 usedbefore = cbuf_used_space(&tp->recvbuf); in tcp_reass()
98 …if (tp->reass_fin_index >= 0 && cbuf_reass_within_offset(&tp->recvbuf, mergeable, (size_t) tp->rea… in tcp_reass()
102 merged = cbuf_reass_merge(&tp->recvbuf, mergeable, tp->reassbmp); in tcp_reass()
105 cbuf_pop(&tp->recvbuf, merged); // So no data really enters the buffer in tcp_reass()
|
| D | tcp_var.h | 158 #define REASSBMP_SIZE(tp) BITS_TO_BYTES((tp)->recvbuf.size)
191 struct cbufhead recvbuf; member
|
| D | tcp_output.c | 493 recwin = cbuf_free_space(&tp->recvbuf); in tcp_output()
625 adv >= (long)cbuf_size(&tp->recvbuf) / 4) in tcp_output()
1138 if (recwin < (long)(cbuf_size(&tp->recvbuf) / 4) && in tcp_output()
1154 (min(cbuf_size(&tp->recvbuf), TCP_MAXWIN))); in tcp_output()
|
| D | tcp_subr.c | 312 win = cbuf_free_space(&tp->recvbuf); in tcp_respond()
|
| D | tcp_usrreq.c | 91 int sb_max = cbuf_free_space(&tp->recvbuf); // same as sendbuf in tcp6_connect()
|
| D | tcp_input.c | 843 tp->rcv_wnd = imin(imax(cbuf_free_space(&tp->recvbuf), 0), TCP_MAXWIN); in tcp_input()
1346 tlen <= cbuf_free_space(&tp->recvbuf)) { in tcp_do_segment()
1431 …cbuf_write(&tp->recvbuf, msg, otMessageGetOffset(msg) + drop_hdrlen, tlen, cbuf_copy_from_message); in tcp_do_segment()
1472 win = cbuf_free_space(&tp->recvbuf); in tcp_do_segment()
2587 …cbuf_write(&tp->recvbuf, msg, otMessageGetOffset(msg) + drop_hdrlen, tlen, cbuf_copy_from_message); in tcp_do_segment()
|
| /openthread-3.5.0/src/core/net/ |
| D | tcp6.cpp | 106 uint8_t *recvbuf = static_cast<uint8_t *>(aArgs.mReceiveBuffer); in Initialize() local
108 uint8_t *reassbmp = recvbuf + recvbuflen; in Initialize()
111 cbuf_init(&tp.recvbuf, recvbuf, recvbuflen); in Initialize()
257 cbuf_reference(&tp.recvbuf, &mReceiveLinks[0], &mReceiveLinks[1]); in ReceiveByReference()
267 cbuf_contiguify(&tp.recvbuf, tp.reassbmp); in ReceiveContiguify()
279 VerifyOrExit(cbuf_used_space(&tp.recvbuf) >= aNumBytes, error = kErrorFailed); in CommitReceive()
282 cbuf_pop(&tp.recvbuf, aNumBytes); in CommitReceive()
753 … aEndpoint.mReceiveAvailableCallback(&aEndpoint, cbuf_used_space(&aEndpoint.GetTcb().recvbuf), in ProcessSignals()
755 cbuf_free_space(&aEndpoint.GetTcb().recvbuf)); in ProcessSignals()
1111 cbuf_pop(&aTcb->recvbuf, cbuf_used_space(&aTcb->recvbuf)); in tcplp_sys_on_state_change()
|
