Lines Matching refs:buf

75 upcast_evbuffer(struct evbuffer *buf)  in upcast_evbuffer()  argument
77 if (!buf || !buf->is_overlapped) in upcast_evbuffer()
79 return EVUTIL_UPCAST(buf, struct evbuffer_overlapped, buffer); in upcast_evbuffer()
100 struct evbuffer_overlapped *buf = upcast_evbuffer(evbuf); in evbuffer_commit_read_() local
106 EVUTIL_ASSERT(buf->read_in_progress && !buf->write_in_progress); in evbuffer_commit_read_()
115 for (i = 0; remaining > 0 && i < (unsigned)buf->n_buffers; ++i) { in evbuffer_commit_read_()
117 len = buf->buffers[i].len; in evbuffer_commit_read_()
126 pin_release(buf, EVBUFFER_MEM_PINNED_R); in evbuffer_commit_read_()
128 buf->read_in_progress = 0; in evbuffer_commit_read_()
141 struct evbuffer_overlapped *buf = upcast_evbuffer(evbuf); in evbuffer_commit_write_() local
144 EVUTIL_ASSERT(buf->write_in_progress && !buf->read_in_progress); in evbuffer_commit_write_()
147 pin_release(buf,EVBUFFER_MEM_PINNED_W); in evbuffer_commit_write_()
148 buf->write_in_progress = 0; in evbuffer_commit_write_()
172 evbuffer_launch_write_(struct evbuffer *buf, ev_ssize_t at_most, in evbuffer_launch_write_() argument
175 struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf); in evbuffer_launch_write_()
181 if (!buf) { in evbuffer_launch_write_()
186 EVBUFFER_LOCK(buf); in evbuffer_launch_write_()
188 if (buf->freeze_start || buf_o->write_in_progress) in evbuffer_launch_write_()
190 if (!buf->total_len) { in evbuffer_launch_write_()
194 } else if (at_most < 0 || (size_t)at_most > buf->total_len) { in evbuffer_launch_write_()
195 at_most = buf->total_len; in evbuffer_launch_write_()
197 evbuffer_freeze(buf, 1); in evbuffer_launch_write_()
203 chain = buf_o->first_pinned = buf->first; in evbuffer_launch_write_()
207 b->buf = (char*)( chain->buffer + chain->misalign ); in evbuffer_launch_write_()
225 evbuffer_incref_(buf); in evbuffer_launch_write_()
232 evbuffer_unfreeze(buf, 1); in evbuffer_launch_write_()
233 evbuffer_free(buf); /* decref */ in evbuffer_launch_write_()
241 EVBUFFER_UNLOCK(buf); in evbuffer_launch_write_()
246 evbuffer_launch_read_(struct evbuffer *buf, size_t at_most, in evbuffer_launch_read_() argument
249 struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf); in evbuffer_launch_read_()
260 EVBUFFER_LOCK(buf); in evbuffer_launch_read_()
262 if (buf->freeze_end || buf_o->read_in_progress) in evbuffer_launch_read_()
269 if (evbuffer_expand_fast_(buf, at_most, MAX_WSABUFS) == -1) in evbuffer_launch_read_()
271 evbuffer_freeze(buf, 0); in evbuffer_launch_read_()
273 nvecs = evbuffer_read_setup_vecs_(buf, at_most, in evbuffer_launch_read_()
291 evbuffer_incref_(buf); in evbuffer_launch_read_()
298 evbuffer_unfreeze(buf, 0); in evbuffer_launch_read_()
299 evbuffer_free(buf); /* decref */ in evbuffer_launch_read_()
307 EVBUFFER_UNLOCK(buf); in evbuffer_launch_read_()
312 evbuffer_overlapped_get_fd_(struct evbuffer *buf) in evbuffer_overlapped_get_fd_() argument
314 struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf); in evbuffer_overlapped_get_fd_()
319 evbuffer_overlapped_set_fd_(struct evbuffer *buf, evutil_socket_t fd) in evbuffer_overlapped_set_fd_() argument
321 struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf); in evbuffer_overlapped_set_fd_()
322 EVBUFFER_LOCK(buf); in evbuffer_overlapped_set_fd_()
326 EVBUFFER_UNLOCK(buf); in evbuffer_overlapped_set_fd_()