Lines Matching refs:at_most
185 size_t at_most; in bev_async_consider_writing() local
199 at_most = evbuffer_get_length(bev->output); in bev_async_consider_writing()
204 if (at_most >= (size_t)limit && limit >= 0) in bev_async_consider_writing()
205 at_most = limit; in bev_async_consider_writing()
214 if (evbuffer_launch_write(bev->output, at_most, in bev_async_consider_writing()
220 beva->write_in_progress = at_most; in bev_async_consider_writing()
221 _bufferevent_decrement_write_buckets(&beva->bev, at_most); in bev_async_consider_writing()
231 size_t at_most; in bev_async_consider_reading() local
252 at_most = read_high - cur_size; in bev_async_consider_reading()
254 at_most = 16384; /* FIXME totally magic. */ in bev_async_consider_reading()
260 if (at_most >= (size_t)limit && limit >= 0) in bev_async_consider_reading()
261 at_most = limit; in bev_async_consider_reading()
269 if (evbuffer_launch_read(bev->input, at_most, &beva->read_overlapped)) { in bev_async_consider_reading()
274 beva->read_in_progress = at_most; in bev_async_consider_reading()
275 _bufferevent_decrement_read_buckets(&beva->bev, at_most); in bev_async_consider_reading()