Home
last modified time | relevance | path

Searched refs:rcvbuf (Results 1 – 11 of 11) sorted by relevance

/mOS-networking-stack/core/src/
H A Dtcp_stream.c83 stream->rcvvar->rcvbuf != NULL) { in GetFragInfo()
84 tcprb_t *rcvbuf = stream->rcvvar->rcvbuf; in GetFragInfo() local
142 stream->rcvvar->rcvbuf != NULL) { in GetBufInfo()
143 tcprb_t *rcvbuf = stream->rcvvar->rcvbuf; in GetBufInfo() local
147 tbi->tcpbi_next_byte_expected = rcvbuf->pile + tcprb_cflen(rcvbuf); in GetBufInfo()
246 } else if (rcvvar->rcvbuf && tcprb_cflen(rcvvar->rcvbuf) > 0) { in RaiseReadEvent()
735 if (stream->rcvvar->rcvbuf) {
823 if (stream->rcvvar->rcvbuf) {
824 tcprb_del(stream->rcvvar->rcvbuf);
825 stream->rcvvar->rcvbuf = NULL;
[all …]
H A Dapi.c310 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
324 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
358 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
387 socket->monitor_stream->stream->rcvvar->rcvbuf : in mtcp_setsockopt()
534 rbuf = cur_stream->rcvvar->rcvbuf; in mtcp_ioctl()
1459 tcprb_t *rb = rcvvar->rcvbuf; in PeekForUser()
1474 tcprb_t *rb = rcvvar->rcvbuf; in CopyToUser()
1551 merged_len = tcprb_cflen(rcvvar->rcvbuf); in mtcp_recv()
1583 merged_len = tcprb_cflen(rcvvar->rcvbuf); in mtcp_recv()
1663 merged_len = tcprb_cflen(rcvvar->rcvbuf); in mtcp_readv()
[all …]
H A Dmos_api.c289 cur_stream->rcvvar->rcvbuf != NULL) { in mtcp_peek()
290 tcprb_t *rcvbuf = cur_stream->rcvvar->rcvbuf; in mtcp_peek() local
293 rc = tcprb_ppeek(rcvbuf, (uint8_t *)buf, len, *poff); in mtcp_peek()
295 if (*poff >= rcvbuf->head) { in mtcp_peek()
304 int missed = rcvbuf->head - *poff; in mtcp_peek()
305 *poff = rcvbuf->head; in mtcp_peek()
332 it = rcvbuf->fctx; in ExtractPayloadFromFrags()
341 rcvbuf->head + seq_num - rcvbuf->head_seq, in ExtractPayloadFromFrags()
407 cur_stream->rcvvar->rcvbuf != NULL) { in mtcp_ppeek()
408 tcprb_t *rcvbuf = cur_stream->rcvvar->rcvbuf; in mtcp_ppeek() local
[all …]
H A Dtcp.c468 if (cur_stream->rcvvar && cur_stream->rcvvar->rcvbuf) in ProcessInTCPPacket()
469 pctx->p.offset = (uint64_t)seq2loff(cur_stream->rcvvar->rcvbuf, in ProcessInTCPPacket()
H A Deventpoll.c216 if (rcvvar->rcvbuf && tcprb_cflen(rcvvar->rcvbuf) > 0) { in RaisePendingStreamEvents()
H A Dtcp_in.c587 if (!rcvvar->rcvbuf) { in ProcessTCPPayload()
588 rcvvar->rcvbuf = tcprb_new(mtcp->bufseg_pool, g_config.mos->rmem_size, cur_stream->buffer_mgmt); in ProcessTCPPayload()
589 if (!rcvvar->rcvbuf) { in ProcessTCPPayload()
612 tcprb_t *rb = rcvvar->rcvbuf; in ProcessTCPPayload()
H A Dtcp_out.c395 if (recvside_stream->rcvvar && recvside_stream->rcvvar->rcvbuf) in SendTCPPacket()
396 pctx.p.offset = (uint64_t)seq2loff(recvside_stream->rcvvar->rcvbuf, in SendTCPPacket()
744 if ((rb = cur_stream->rcvvar->rcvbuf) && in WriteTCPACKList()
H A Dcore.c442 cur_stream->rcvvar->rcvbuf != NULL) { in FlushMonitorReadEvents()
495 cur_stream->rcvvar->rcvbuf != NULL) { in FlushBufferedReadEvents()
H A Dtcp_rb.c903 && (rb = recvside_stream->rcvvar->rcvbuf) != NULL) { in tcp_rb_overlapchk()
/mOS-networking-stack/core/src/include/
H A Dtcp_ring_buffer.h82 RBDoesOverlap(rb_manager_t rbm, struct tcp_ring_buffer *rcvbuf,
H A Dtcp_stream.h135 tcprb_t *rcvbuf; member