rate_limit 70 opal/mca/event/libevent2022/libevent/bufferevent-internal.h struct ev_token_bucket rate_limit; rate_limit 249 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c share = LIM(g->rate_limit) / g->n_members; rate_limit 299 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group->rate_limit.read_limit -= bytes; rate_limit 301 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group->rate_limit.read_limit <= 0) { rate_limit 337 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group->rate_limit.write_limit -= bytes; rate_limit 339 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group->rate_limit.write_limit <= 0) { rate_limit 539 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_token_bucket_update(&g->rate_limit, &g->rate_limit_cfg, tick); rate_limit 542 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c (g->read_suspended && (g->rate_limit.read_limit >= g->min_share))) { rate_limit 546 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c (g->write_suspended && (g->rate_limit.write_limit >= g->min_share))){ rate_limit 654 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_token_bucket_init(&g->rate_limit, cfg, tick, 0); rate_limit 682 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (g->rate_limit.read_limit > (ev_ssize_t)cfg->read_maximum) rate_limit 683 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c g->rate_limit.read_limit = cfg->read_maximum; rate_limit 684 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (g->rate_limit.write_limit > (ev_ssize_t)cfg->write_maximum) rate_limit 685 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c g->rate_limit.write_limit = cfg->write_maximum; rate_limit 882 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = grp->rate_limit.read_limit; rate_limit 895 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c r = grp->rate_limit.write_limit; rate_limit 963 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c old_limit = grp->rate_limit.read_limit; rate_limit 964 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c new_limit = (grp->rate_limit.read_limit -= decr); rate_limit 983 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c old_limit = grp->rate_limit.write_limit; rate_limit 984 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c new_limit = (grp->rate_limit.write_limit -= decr);