Home
last modified time | relevance | path

Searched refs:write_suspended (Results 1 – 6 of 6) sorted by relevance

/external/libevent/
Dbufferevent_ratelim.c207 (is_write ? (g)->write_suspended : (g)->read_suspended) in bufferevent_get_rlim_max_()
289 if (!(bev->write_suspended & BEV_SUSPEND_BW)) in bufferevent_decrement_read_buckets_()
326 } else if (bev->write_suspended & BEV_SUSPEND_BW) { in bufferevent_decrement_write_buckets_()
339 } else if (bev->rate_limiting->group->write_suspended) { in bufferevent_decrement_write_buckets_()
379 g->write_suspended = 1; in bev_group_suspend_writing_()
421 if ((bev->write_suspended & BEV_SUSPEND_BW)) { in bev_refill_callback_()
511 g->write_suspended = 0; in bev_group_unsuspend_writing_()
547 (g->write_suspended && (g->rate_limit.write_limit >= g->min_share))){ in bev_group_refill_callback_()
767 wsuspend = g->write_suspended; in bufferevent_add_to_rate_limit_group()
986 if (!(bevp->write_suspended & BEV_SUSPEND_BW)) in bufferevent_decrement_read_limit()
Dbufferevent.c93 if (!bufev_private->write_suspended) in bufferevent_suspend_write_()
95 bufev_private->write_suspended |= what; in bufferevent_suspend_write_()
104 bufev_private->write_suspended &= ~what; in bufferevent_unsuspend_write_()
105 if (!bufev_private->write_suspended && (bufev->enabled & EV_WRITE)) in bufferevent_unsuspend_write_()
491 if (bufev_private->write_suspended) in bufferevent_enable()
981 if ((enabled & EV_WRITE) && !bev_p->write_suspended && in bufferevent_generic_adj_timeouts_()
Dbufferevent-internal.h91 unsigned write_suspended : 1; member
187 bufferevent_suspend_flags write_suspended; member
Dbufferevent_sock.c139 !bufev_p->write_suspended) { in bufferevent_socket_outbuf_cb()
281 bufev_p->write_suspended) { in bufferevent_writecb()
290 if (bufev_p->write_suspended) in bufferevent_writecb()
Dbufferevent_openssl.c674 if (bev_ssl->bev.write_suspended) in do_write()
879 (! bev_ssl->bev.write_suspended) && in consider_writing()
895 } else if (bev_ssl->bev.write_suspended || in consider_writing()
Dbufferevent_async.c231 if (beva->bev.write_suspended) { in bev_async_consider_writing()