cfg 128 opal/mca/event/libevent2022/libevent/bufferevent-internal.h struct ev_token_bucket_cfg *cfg; cfg 50 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c const struct ev_token_bucket_cfg *cfg, cfg 60 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bucket->read_limit > (ev_int64_t) cfg->read_maximum) cfg 61 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bucket->read_limit = cfg->read_maximum; cfg 62 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bucket->write_limit > (ev_int64_t) cfg->write_maximum) cfg 63 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bucket->write_limit = cfg->write_maximum; cfg 65 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bucket->read_limit = cfg->read_rate; cfg 66 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bucket->write_limit = cfg->write_rate; cfg 74 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c const struct ev_token_bucket_cfg *cfg, cfg 95 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if ((cfg->read_maximum - bucket->read_limit) / n_ticks < cfg->read_rate) cfg 96 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bucket->read_limit = cfg->read_maximum; cfg 98 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bucket->read_limit += n_ticks * cfg->read_rate; cfg 101 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if ((cfg->write_maximum - bucket->write_limit) / n_ticks < cfg->write_rate) cfg 102 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bucket->write_limit = cfg->write_maximum; cfg 104 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bucket->write_limit += n_ticks * cfg->write_rate; cfg 119 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c tick = ev_token_bucket_get_tick(&now, bev->rate_limiting->cfg); cfg 122 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->cfg, tick); cfg 127 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c const struct ev_token_bucket_cfg *cfg) cfg 138 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c return (unsigned)(msec / cfg->msec_per_tick); cfg 175 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_token_bucket_cfg_free(struct ev_token_bucket_cfg *cfg) cfg 177 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c mm_free(cfg); cfg 226 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->cfg) { cfg 283 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->cfg) { cfg 288 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c &bev->rate_limiting->cfg->tick_timeout) < 0) cfg 321 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->cfg) { cfg 326 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c &bev->rate_limiting->cfg->tick_timeout) < 0) cfg 403 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (!bev->rate_limiting || !bev->rate_limiting->cfg) { cfg 411 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->cfg); cfg 413 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->cfg, cfg 438 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c &bev->rate_limiting->cfg->tick_timeout); cfg 560 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c struct ev_token_bucket_cfg *cfg) cfg 573 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (cfg == NULL) { cfg 576 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c rlim->cfg = NULL; cfg 587 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c tick = ev_token_bucket_get_tick(&now, cfg); cfg 589 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bevp->rate_limiting && bevp->rate_limiting->cfg == cfg) { cfg 602 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c reinit = rlim->cfg != NULL; cfg 604 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c rlim->cfg = cfg; cfg 605 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_token_bucket_init(&rlim->limit, cfg, tick, reinit); cfg 628 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c event_add(&rlim->refill_bucket_event, &cfg->tick_timeout); cfg 639 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c const struct ev_token_bucket_cfg *cfg) cfg 646 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c tick = ev_token_bucket_get_tick(&now, cfg); cfg 651 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c memcpy(&g->rate_limit_cfg, cfg, sizeof(g->rate_limit_cfg)); cfg 654 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c ev_token_bucket_init(&g->rate_limit, cfg, tick, 0); cfg 659 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c event_add(&g->master_refill_event, &cfg->tick_timeout); cfg 671 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c const struct ev_token_bucket_cfg *cfg) cfg 674 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (!g || !cfg) cfg 679 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c &g->rate_limit_cfg.tick_timeout, &cfg->tick_timeout, ==); cfg 680 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c memcpy(&g->rate_limit_cfg, cfg, sizeof(g->rate_limit_cfg)); cfg 682 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (g->rate_limit.read_limit > (ev_ssize_t)cfg->read_maximum) cfg 683 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c g->rate_limit.read_limit = cfg->read_maximum; cfg 684 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (g->rate_limit.write_limit > (ev_ssize_t)cfg->write_maximum) cfg 685 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c g->rate_limit.write_limit = cfg->write_maximum; cfg 689 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c event_add(&g->master_refill_event, &cfg->tick_timeout); cfg 824 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bevp->rate_limiting && bevp->rate_limiting->cfg) { cfg 843 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bevp->rate_limiting && bevp->rate_limiting->cfg) { cfg 908 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg); cfg 915 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c &bevp->rate_limiting->cfg->tick_timeout) < 0) cfg 937 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVUTIL_ASSERT(bevp->rate_limiting && bevp->rate_limiting->cfg); cfg 944 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c &bevp->rate_limiting->cfg->tick_timeout) < 0) cfg 452 opal/mca/event/libevent2022/libevent/event.c struct event_config *cfg = event_config_new(); cfg 453 opal/mca/event/libevent2022/libevent/event.c if (cfg) { cfg 454 opal/mca/event/libevent2022/libevent/event.c base = event_base_new_with_config(cfg); cfg 455 opal/mca/event/libevent2022/libevent/event.c event_config_free(cfg); cfg 463 opal/mca/event/libevent2022/libevent/event.c event_config_is_avoided_method(const struct event_config *cfg, cfg 468 opal/mca/event/libevent2022/libevent/event.c TAILQ_FOREACH(entry, &cfg->entries, next) { cfg 554 opal/mca/event/libevent2022/libevent/event.c event_base_new_with_config(const struct event_config *cfg) cfg 581 opal/mca/event/libevent2022/libevent/event.c if (cfg) cfg 582 opal/mca/event/libevent2022/libevent/event.c base->flags = cfg->flags; cfg 591 opal/mca/event/libevent2022/libevent/event.c !(cfg && (cfg->flags & EVENT_BASE_FLAG_IGNORE_ENV)); cfg 594 opal/mca/event/libevent2022/libevent/event.c if (cfg != NULL) { cfg 596 opal/mca/event/libevent2022/libevent/event.c if (event_config_is_avoided_method(cfg, cfg 599 opal/mca/event/libevent2022/libevent/event.c if ((ompi_eventops[i]->features & cfg->require_features) cfg 600 opal/mca/event/libevent2022/libevent/event.c != cfg->require_features) cfg 635 opal/mca/event/libevent2022/libevent/event.c (!cfg || !(cfg->flags & EVENT_BASE_FLAG_NOLOCK))) { cfg 651 opal/mca/event/libevent2022/libevent/event.c if (cfg && (cfg->flags & EVENT_BASE_FLAG_STARTUP_IOCP)) cfg 652 opal/mca/event/libevent2022/libevent/event.c event_base_start_iocp(base, cfg->n_cpus_hint); cfg 927 opal/mca/event/libevent2022/libevent/event.c struct event_config *cfg = mm_calloc(1, sizeof(*cfg)); cfg 929 opal/mca/event/libevent2022/libevent/event.c if (cfg == NULL) cfg 932 opal/mca/event/libevent2022/libevent/event.c TAILQ_INIT(&cfg->entries); cfg 934 opal/mca/event/libevent2022/libevent/event.c return (cfg); cfg 946 opal/mca/event/libevent2022/libevent/event.c event_config_free(struct event_config *cfg) cfg 950 opal/mca/event/libevent2022/libevent/event.c while ((entry = TAILQ_FIRST(&cfg->entries)) != NULL) { cfg 951 opal/mca/event/libevent2022/libevent/event.c TAILQ_REMOVE(&cfg->entries, entry, next); cfg 954 opal/mca/event/libevent2022/libevent/event.c mm_free(cfg); cfg 958 opal/mca/event/libevent2022/libevent/event.c event_config_set_flag(struct event_config *cfg, int flag) cfg 960 opal/mca/event/libevent2022/libevent/event.c if (!cfg) cfg 962 opal/mca/event/libevent2022/libevent/event.c cfg->flags |= flag; cfg 967 opal/mca/event/libevent2022/libevent/event.c event_config_avoid_method(struct event_config *cfg, const char *method) cfg 978 opal/mca/event/libevent2022/libevent/event.c TAILQ_INSERT_TAIL(&cfg->entries, entry, next); cfg 984 opal/mca/event/libevent2022/libevent/event.c event_config_require_features(struct event_config *cfg, cfg 987 opal/mca/event/libevent2022/libevent/event.c if (!cfg) cfg 989 opal/mca/event/libevent2022/libevent/event.c cfg->require_features = features; cfg 994 opal/mca/event/libevent2022/libevent/event.c event_config_set_num_cpus_hint(struct event_config *cfg, int cpus) cfg 996 opal/mca/event/libevent2022/libevent/event.c if (!cfg) cfg 998 opal/mca/event/libevent2022/libevent/event.c cfg->n_cpus_hint = cpus; cfg 413 opal/mca/event/libevent2022/libevent/include/event2/event.h void event_config_free(struct event_config *cfg); cfg 427 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_config_avoid_method(struct event_config *cfg, const char *method); cfg 526 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_config_require_features(struct event_config *cfg, int feature); cfg 534 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_config_set_flag(struct event_config *cfg, int flag); cfg 545 opal/mca/event/libevent2022/libevent/include/event2/event.h int event_config_set_num_cpus_hint(struct event_config *cfg, int cpus); cfg 69 opal/mca/event/libevent2022/libevent/ratelim-internal.h const struct ev_token_bucket_cfg *cfg, cfg 75 opal/mca/event/libevent2022/libevent/ratelim-internal.h const struct ev_token_bucket_cfg *cfg); cfg 83 opal/mca/event/libevent2022/libevent/ratelim-internal.h const struct ev_token_bucket_cfg *cfg, cfg 87 opal/mca/event/libevent2022/libevent/test/bench_http.c struct event_config *cfg = event_config_new(); cfg 142 opal/mca/event/libevent2022/libevent/test/bench_http.c event_config_set_flag(cfg,EVENT_BASE_FLAG_STARTUP_IOCP); cfg 151 opal/mca/event/libevent2022/libevent/test/bench_http.c base = event_base_new_with_config(cfg); cfg 1893 opal/mca/event/libevent2022/libevent/test/regress.c struct event_config *cfg = NULL; cfg 1907 opal/mca/event/libevent2022/libevent/test/regress.c cfg = event_config_new(); cfg 1908 opal/mca/event/libevent2022/libevent/test/regress.c assert(cfg != NULL); cfg 1910 opal/mca/event/libevent2022/libevent/test/regress.c tt_int_op(event_config_avoid_method(cfg, backend), ==, 0); cfg 1911 opal/mca/event/libevent2022/libevent/test/regress.c event_config_set_flag(cfg, EVENT_BASE_FLAG_IGNORE_ENV); cfg 1913 opal/mca/event/libevent2022/libevent/test/regress.c base = event_base_new_with_config(cfg); cfg 1924 opal/mca/event/libevent2022/libevent/test/regress.c if (cfg) cfg 1925 opal/mca/event/libevent2022/libevent/test/regress.c event_config_free(cfg); cfg 1955 opal/mca/event/libevent2022/libevent/test/regress.c struct event_config *cfg = NULL; cfg 1957 opal/mca/event/libevent2022/libevent/test/regress.c cfg = event_config_new(); cfg 1959 opal/mca/event/libevent2022/libevent/test/regress.c tt_assert(0 == event_config_require_features(cfg, EV_FEATURE_ET)); cfg 1961 opal/mca/event/libevent2022/libevent/test/regress.c base = event_base_new_with_config(cfg); cfg 1973 opal/mca/event/libevent2022/libevent/test/regress.c if (cfg) cfg 1974 opal/mca/event/libevent2022/libevent/test/regress.c event_config_free(cfg); cfg 2017 opal/mca/event/libevent2022/libevent/test/regress.c struct event_config *cfg = NULL; cfg 2063 opal/mca/event/libevent2022/libevent/test/regress.c cfg = event_config_new(); cfg 2064 opal/mca/event/libevent2022/libevent/test/regress.c base = event_base_new_with_config(cfg); cfg 2065 opal/mca/event/libevent2022/libevent/test/regress.c event_config_free(cfg); cfg 2066 opal/mca/event/libevent2022/libevent/test/regress.c cfg = NULL; cfg 2077 opal/mca/event/libevent2022/libevent/test/regress.c cfg = event_config_new(); cfg 2078 opal/mca/event/libevent2022/libevent/test/regress.c event_config_set_flag(cfg, EVENT_BASE_FLAG_IGNORE_ENV); cfg 2079 opal/mca/event/libevent2022/libevent/test/regress.c base = event_base_new_with_config(cfg); cfg 2089 opal/mca/event/libevent2022/libevent/test/regress.c if (cfg) cfg 2090 opal/mca/event/libevent2022/libevent/test/regress.c event_config_free(cfg); cfg 2314 opal/mca/event/libevent2022/libevent/test/regress.c struct event_config *cfg = NULL; cfg 2316 opal/mca/event/libevent2022/libevent/test/regress.c cfg = event_config_new(); cfg 2317 opal/mca/event/libevent2022/libevent/test/regress.c event_config_avoid_method(cfg, "Nonesuch"); cfg 2318 opal/mca/event/libevent2022/libevent/test/regress.c b = event_base_new_with_config(cfg); cfg 2322 opal/mca/event/libevent2022/libevent/test/regress.c if (cfg) cfg 2323 opal/mca/event/libevent2022/libevent/test/regress.c event_config_free(cfg);