Lines Matching refs:group
228 if (bev->rate_limiting->group) { in bufferevent_get_rlim_max_()
230 bev->rate_limiting->group; in bufferevent_get_rlim_max_()
295 if (bev->rate_limiting->group) { in bufferevent_decrement_read_buckets_()
296 LOCK_GROUP(bev->rate_limiting->group); in bufferevent_decrement_read_buckets_()
297 bev->rate_limiting->group->rate_limit.read_limit -= bytes; in bufferevent_decrement_read_buckets_()
298 bev->rate_limiting->group->total_read += bytes; in bufferevent_decrement_read_buckets_()
299 if (bev->rate_limiting->group->rate_limit.read_limit <= 0) { in bufferevent_decrement_read_buckets_()
300 bev_group_suspend_reading_(bev->rate_limiting->group); in bufferevent_decrement_read_buckets_()
301 } else if (bev->rate_limiting->group->read_suspended) { in bufferevent_decrement_read_buckets_()
302 bev_group_unsuspend_reading_(bev->rate_limiting->group); in bufferevent_decrement_read_buckets_()
304 UNLOCK_GROUP(bev->rate_limiting->group); in bufferevent_decrement_read_buckets_()
333 if (bev->rate_limiting->group) { in bufferevent_decrement_write_buckets_()
334 LOCK_GROUP(bev->rate_limiting->group); in bufferevent_decrement_write_buckets_()
335 bev->rate_limiting->group->rate_limit.write_limit -= bytes; in bufferevent_decrement_write_buckets_()
336 bev->rate_limiting->group->total_written += bytes; in bufferevent_decrement_write_buckets_()
337 if (bev->rate_limiting->group->rate_limit.write_limit <= 0) { in bufferevent_decrement_write_buckets_()
338 bev_group_suspend_writing_(bev->rate_limiting->group); in bufferevent_decrement_write_buckets_()
339 } else if (bev->rate_limiting->group->write_suspended) { in bufferevent_decrement_write_buckets_()
340 bev_group_unsuspend_writing_(bev->rate_limiting->group); in bufferevent_decrement_write_buckets_()
342 UNLOCK_GROUP(bev->rate_limiting->group); in bufferevent_decrement_write_buckets_()
446 bev_group_random_element_(struct bufferevent_rate_limit_group *group) in bev_group_random_element_() argument
453 if (!group->n_members) in bev_group_random_element_()
456 EVUTIL_ASSERT(! LIST_EMPTY(&group->members)); in bev_group_random_element_()
458 which = evutil_weakrand_range_(&group->weakrand_seed, group->n_members); in bev_group_random_element_()
460 bev = LIST_FIRST(&group->members); in bev_group_random_element_()
754 if (bevp->rate_limiting->group == g) { in bufferevent_add_to_rate_limit_group()
758 if (bevp->rate_limiting->group) in bufferevent_add_to_rate_limit_group()
762 bevp->rate_limiting->group = g; in bufferevent_add_to_rate_limit_group()
792 if (bevp->rate_limiting && bevp->rate_limiting->group) { in bufferevent_remove_from_rate_limit_group_internal_()
794 bevp->rate_limiting->group; in bufferevent_remove_from_rate_limit_group_internal_()
796 bevp->rate_limiting->group = NULL; in bufferevent_remove_from_rate_limit_group_internal_()