Lines Matching refs:grp
946 struct bufferevent_rate_limit_group *grp) in bufferevent_rate_limit_group_get_read_limit() argument
949 LOCK_GROUP(grp); in bufferevent_rate_limit_group_get_read_limit()
950 r = grp->rate_limit.read_limit; in bufferevent_rate_limit_group_get_read_limit()
951 UNLOCK_GROUP(grp); in bufferevent_rate_limit_group_get_read_limit()
959 struct bufferevent_rate_limit_group *grp) in bufferevent_rate_limit_group_get_write_limit() argument
962 LOCK_GROUP(grp); in bufferevent_rate_limit_group_get_write_limit()
963 r = grp->rate_limit.write_limit; in bufferevent_rate_limit_group_get_write_limit()
964 UNLOCK_GROUP(grp); in bufferevent_rate_limit_group_get_write_limit()
1026 struct bufferevent_rate_limit_group *grp, ev_ssize_t decr) in bufferevent_rate_limit_group_decrement_read() argument
1030 LOCK_GROUP(grp); in bufferevent_rate_limit_group_decrement_read()
1031 old_limit = grp->rate_limit.read_limit; in bufferevent_rate_limit_group_decrement_read()
1032 new_limit = (grp->rate_limit.read_limit -= decr); in bufferevent_rate_limit_group_decrement_read()
1035 bev_group_suspend_reading_(grp); in bufferevent_rate_limit_group_decrement_read()
1037 bev_group_unsuspend_reading_(grp); in bufferevent_rate_limit_group_decrement_read()
1040 UNLOCK_GROUP(grp); in bufferevent_rate_limit_group_decrement_read()
1046 struct bufferevent_rate_limit_group *grp, ev_ssize_t decr) in bufferevent_rate_limit_group_decrement_write() argument
1050 LOCK_GROUP(grp); in bufferevent_rate_limit_group_decrement_write()
1051 old_limit = grp->rate_limit.write_limit; in bufferevent_rate_limit_group_decrement_write()
1052 new_limit = (grp->rate_limit.write_limit -= decr); in bufferevent_rate_limit_group_decrement_write()
1055 bev_group_suspend_writing_(grp); in bufferevent_rate_limit_group_decrement_write()
1057 bev_group_unsuspend_writing_(grp); in bufferevent_rate_limit_group_decrement_write()
1060 UNLOCK_GROUP(grp); in bufferevent_rate_limit_group_decrement_write()
1065 bufferevent_rate_limit_group_get_totals(struct bufferevent_rate_limit_group *grp, in bufferevent_rate_limit_group_get_totals() argument
1068 EVUTIL_ASSERT(grp != NULL); in bufferevent_rate_limit_group_get_totals()
1070 *total_read_out = grp->total_read; in bufferevent_rate_limit_group_get_totals()
1072 *total_written_out = grp->total_written; in bufferevent_rate_limit_group_get_totals()
1076 bufferevent_rate_limit_group_reset_totals(struct bufferevent_rate_limit_group *grp) in bufferevent_rate_limit_group_reset_totals() argument
1078 grp->total_read = grp->total_written = 0; in bufferevent_rate_limit_group_reset_totals()