Lines Matching defs:inbuf
196 * inbuf::buf. We defer delete until all data are acked to
204 struct ringbuf inbuf;
603 pxtcp->inbuf.bufsize = 64 * 1024;
604 pxtcp->inbuf.buf = (char *)malloc(pxtcp->inbuf.bufsize);
605 if (pxtcp->inbuf.buf == NULL) {
609 pxtcp->inbuf.vacant = 0;
610 pxtcp->inbuf.unacked = 0;
611 pxtcp->inbuf.unsent = 0;
615 free(pxtcp->inbuf.buf);
686 if (pxtcp->inbuf.buf != NULL) {
687 free(pxtcp->inbuf.buf);
800 (int)pxtcp->inbuf.unacked,
801 (int)pxtcp->inbuf.unsent,
802 (int)pxtcp->inbuf.vacant,
1800 const size_t sz = pxtcp->inbuf.bufsize;
1805 beg = pxtcp->inbuf.vacant;
1806 IOVEC_SET_BASE(iov[0], &pxtcp->inbuf.buf[beg]);
1809 lim = pxtcp->inbuf.unacked;
1840 IOVEC_SET_BASE(iov[1], &pxtcp->inbuf.buf[0]);
1855 pxtcp->inbuf.vacant = wrnew;
2033 beg = pxtcp->inbuf.unsent; /* private to lwip thread */
2034 lim = pxtcp->inbuf.vacant;
2075 toeob = pxtcp->inbuf.bufsize - beg;
2090 error = tcp_write(pcb, &pxtcp->inbuf.buf[beg], toeob, maybemore);
2095 pxtcp->inbuf.unsent = 0; /* wrap */
2115 error = tcp_write(pcb, &pxtcp->inbuf.buf[beg], (u16_t)tolim, 0);
2120 pxtcp->inbuf.unsent = lim;
2124 if (pxtcp->inbound_close && pxtcp->inbuf.unsent == pxtcp->inbuf.vacant) {
2164 LWIP_ASSERT1(pxtcp->inbuf.unsent == pxtcp->inbuf.vacant);
2210 && pxtcp->inbuf.unacked == pxtcp->inbuf.unsent);
2217 * We can advance inbuf::unacked index, making more free space in the
2237 (int)pxtcp->inbuf.unacked,
2238 (int)pxtcp->inbuf.unsent,
2239 (int)pxtcp->inbuf.vacant));
2246 unacked = pxtcp->inbuf.unacked;
2253 unacked = pxtcp->inbuf.unacked + len;
2254 if (unacked > pxtcp->inbuf.bufsize) {
2255 unacked -= pxtcp->inbuf.bufsize;
2257 pxtcp->inbuf.unacked = unacked;
2309 && pxtcp->inbuf.unsent == pxtcp->inbuf.vacant /* all data is sent */
2310 && unacked == pxtcp->inbuf.unsent) /* ... and is acked */
2318 buf = pxtcp->inbuf.buf;
2319 pxtcp->inbuf.buf = NULL;
2412 (int)pxtcp->inbuf.unacked,
2413 (int)pxtcp->inbuf.unsent,
2414 (int)pxtcp->inbuf.vacant));