Lines Matching defs:peer_b
113 struct bio_bio_st *b, *peer_b;
123 peer_b = b->peer->ptr;
124 assert(peer_b != NULL);
125 assert(peer_b->buf != NULL);
127 peer_b->request = 0; /* will be set in "retry_read" situation */
132 if (peer_b->len == 0) {
133 if (peer_b->closed)
137 if (size <= peer_b->size)
138 peer_b->request = size;
143 peer_b->request = peer_b->size;
149 if (peer_b->len < size)
150 size = peer_b->len;
160 assert(rest <= peer_b->len);
161 if (peer_b->offset + rest <= peer_b->size)
165 chunk = peer_b->size - peer_b->offset;
166 assert(peer_b->offset + chunk <= peer_b->size);
168 memcpy(buf, peer_b->buf + peer_b->offset, chunk);
170 peer_b->len -= chunk;
171 if (peer_b->len) {
172 peer_b->offset += chunk;
173 assert(peer_b->offset <= peer_b->size);
174 if (peer_b->offset == peer_b->size)
175 peer_b->offset = 0;
180 peer_b->offset = 0;
202 struct bio_bio_st *b, *peer_b;
213 peer_b = b->peer->ptr;
214 assert(peer_b != NULL);
215 assert(peer_b->buf != NULL);
217 peer_b->request = 0;
219 if (peer_b->len == 0) {
226 num = peer_b->len;
227 if (peer_b->size < peer_b->offset + num)
229 num = peer_b->size - peer_b->offset;
233 *buf = peer_b->buf + peer_b->offset;
239 struct bio_bio_st *b, *peer_b;
254 peer_b = b->peer->ptr;
256 peer_b->len -= num;
257 if (peer_b->len) {
258 peer_b->offset += num;
259 assert(peer_b->offset <= peer_b->size);
260 if (peer_b->offset == peer_b->size)
261 peer_b->offset = 0;
263 peer_b->offset = 0;
546 struct bio_bio_st *peer_b = b->peer->ptr;
548 ret = (long)peer_b->len;
584 struct bio_bio_st *peer_b = b->peer->ptr;
586 if (peer_b->len == 0 && peer_b->closed)
662 struct bio_bio_st *peer_b = peer_bio->ptr;
664 assert(peer_b != NULL);
665 assert(peer_b->peer == bio);
667 peer_b->peer = NULL;
669 assert(peer_b->buf != NULL);
670 peer_b->len = 0;
671 peer_b->offset = 0;