Home
last modified time | relevance | path

Searched refs:rb (Results 1 – 8 of 8) sorted by relevance

/mOS-networking-stack/core/src/
H A Dtcp_rb.c177 rb->corr += rb->len; in buf_try_resize()
208 rb->corr += rb->len; in buf_try_resize()
384 rb->len = rb->metalen = len; in tcprb_new()
414 if (!rb || new > (rb->head + rb->len) || new < rb->head) in tcprb_setpile()
421 assert(rb->pile == rb->head); in tcprb_setpile()
487 off < rb->head || off >= rb->pile + rb->metalen) in tcprb_fflen()
493 int ff = (off + len) - (rb->head + MIN(rb->len, rb->metalen)); in tcprb_fflen()
643 off < rb->head || off >= rb->pile + rb->metalen) in tcprb_pwrite()
654 if (rb->metalen > rb->len) in tcprb_pwrite()
766 assert(rb->metalen > rb->len); in tcprb_pwrite()
[all …]
H A Dapi.c265 tcprb_t *rb; in mtcp_setsockopt() local
312 if (rb == NULL) { in mtcp_setsockopt()
326 if (rb == NULL) { in mtcp_setsockopt()
350 if (rb) { in mtcp_setsockopt()
379 if (rb) { in mtcp_setsockopt()
408 if (rb) in mtcp_setsockopt()
416 if (rb->len == 0) in mtcp_setsockopt()
435 if (rb) in mtcp_setsockopt()
443 if (rb->len == 0) in mtcp_setsockopt()
1479 tcprb_setpile(rb, rb->pile + copylen); in CopyToUser()
[all …]
H A Dtcp_in.c612 tcprb_t *rb = rcvvar->rcvbuf; in ProcessTCPPayload() local
613 loff_t off = seq2loff(rb, pctx->p.seq, (rcvvar->irs + 1)); in ProcessTCPPayload()
617 tcprb_setpile(rb, rb->pile + tcprb_cflen(rb)); in ProcessTCPPayload()
625 int fflen = tcprb_fflen(rb, pctx->p.payload, pctx->p.payloadlen, off); in ProcessTCPPayload()
633 < rb->head + fflen) in ProcessTCPPayload()
640 < rb->head + fflen) in ProcessTCPPayload()
648 ret = tcprb_pwrite(rb, pctx->p.payload, pctx->p.payloadlen, off); in ProcessTCPPayload()
662 loff_t cftail = rb->pile + tcprb_cflen(rb); in ProcessTCPPayload()
666 tcprb_setpile(rb, cftail); in ProcessTCPPayload()
674 assert(cftail - rb->pile >= 0); in ProcessTCPPayload()
[all …]
H A Dtcp_out.c743 tcprb_t *rb; in WriteTCPACKList() local
744 if ((rb = cur_stream->rcvvar->rcvbuf) && in WriteTCPACKList()
746 (cur_stream->rcvvar->irs + 1) + rb->pile in WriteTCPACKList()
747 + tcprb_cflen(rb))) { in WriteTCPACKList()
/mOS-networking-stack/core/test/tcprb/
H A Dtest.c21 tcprb_t *rb = tcprb_new(10); in main() local
26 tcprb_printrb(rb); in main()
29 tcprb_printrb(rb); in main()
32 tcprb_printrb(rb); in main()
35 tcprb_printrb(rb); in main()
37 CALL(tcprb_setpile(rb, 2)); in main()
38 tcprb_printrb(rb); in main()
41 tcprb_printrb(rb); in main()
44 tcprb_printrb(rb); in main()
47 tcprb_printrb(rb); in main()
[all …]
/mOS-networking-stack/core/src/include/
H A Dtcp_rb.h84 tcprb_del(tcprb_t *rb);
87 tcprb_setpile(tcprb_t *rb, loff_t new);
90 tcprb_cflen(tcprb_t *rb);
93 tcprb_resize_meta(tcprb_t *rb, int len);
96 tcprb_resize(tcprb_t *rb, int len);
99 tcprb_ffhead(tcprb_t *rb, int len);
102 tcprb_fflen(tcprb_t *rb, uint8_t *buf, int len, loff_t off);
111 tcprb_printfrags(struct _tcprb_t *rb);
114 tcprb_printrb(struct _tcprb_t *rb);
117 seq2loff(tcprb_t *rb, uint32_t seq, uint32_t isn);
[all …]
/mOS-networking-stack/samples/lighttpd-1.4.32/src/
H A Dmod_fastcgi.c350 chunkqueue *rb; /* read queue */ member
505 hctx->rb = chunkqueue_init(); in handler_ctx_init()
518 chunkqueue_free(hctx->rb); in handler_ctx_free()
2397 if (!hctx->rb->first) return -1; in fastcgi_get_packet()
2407 for (c = hctx->rb->first; c; c = c->next) { in fastcgi_get_packet()
2514 chunk *cq_first = hctx->rb->first; in fcgi_demux_response()
2515 chunk *cq_last = hctx->rb->last; in fcgi_demux_response()
2525 buffer_free(hctx->rb->last->mem); in fcgi_demux_response()
2526 free(hctx->rb->last); in fcgi_demux_response()
2527 hctx->rb->first = cq_first; in fcgi_demux_response()
[all …]
H A Dmod_scgi.c309 read_buffer *rb; member
383 if (hctx->rb) { in handler_ctx_free()
384 if (hctx->rb->ptr) free(hctx->rb->ptr); in handler_ctx_free()
385 free(hctx->rb); in handler_ctx_free()