Home
last modified time | relevance | path

Searched refs:rate_limit (Results 1 – 25 of 26) sorted by relevance

12

/freebsd/contrib/ntp/sntp/libevent/
H A Dbufferevent_ratelim.c247 share = LIM(g->rate_limit) / g->n_members; in bufferevent_get_rlim_max_()
297 bev->rate_limiting->group->rate_limit.read_limit -= bytes; in bufferevent_decrement_read_buckets_()
299 if (bev->rate_limiting->group->rate_limit.read_limit <= 0) { in bufferevent_decrement_read_buckets_()
335 bev->rate_limiting->group->rate_limit.write_limit -= bytes; in bufferevent_decrement_write_buckets_()
337 if (bev->rate_limiting->group->rate_limit.write_limit <= 0) { in bufferevent_decrement_write_buckets_()
540 ev_token_bucket_update_(&g->rate_limit, &g->rate_limit_cfg, tick); in bev_group_refill_callback_()
543 (g->read_suspended && (g->rate_limit.read_limit >= g->min_share))) { in bev_group_refill_callback_()
547 (g->write_suspended && (g->rate_limit.write_limit >= g->min_share))){ in bev_group_refill_callback_()
654 ev_token_bucket_init_(&g->rate_limit, cfg, tick, 0); in bufferevent_rate_limit_group_new()
685 if (g->rate_limit.read_limit > (ev_ssize_t)cfg->read_maximum) in bufferevent_rate_limit_group_set_cfg()
[all …]
H A Dbufferevent-internal.h83 struct ev_token_bucket rate_limit; member
/freebsd/contrib/libevent/
H A Dbufferevent_ratelim.c247 share = LIM(g->rate_limit) / g->n_members; in bufferevent_get_rlim_max_()
297 bev->rate_limiting->group->rate_limit.read_limit -= bytes; in bufferevent_decrement_read_buckets_()
299 if (bev->rate_limiting->group->rate_limit.read_limit <= 0) { in bufferevent_decrement_read_buckets_()
335 bev->rate_limiting->group->rate_limit.write_limit -= bytes; in bufferevent_decrement_write_buckets_()
337 if (bev->rate_limiting->group->rate_limit.write_limit <= 0) { in bufferevent_decrement_write_buckets_()
540 ev_token_bucket_update_(&g->rate_limit, &g->rate_limit_cfg, tick); in bev_group_refill_callback_()
543 (g->read_suspended && (g->rate_limit.read_limit >= g->min_share))) { in bev_group_refill_callback_()
547 (g->write_suspended && (g->rate_limit.write_limit >= g->min_share))){ in bev_group_refill_callback_()
654 ev_token_bucket_init_(&g->rate_limit, cfg, tick, 0); in bufferevent_rate_limit_group_new()
685 if (g->rate_limit.read_limit > (ev_ssize_t)cfg->read_maximum) in bufferevent_rate_limit_group_set_cfg()
[all …]
H A Dbufferevent-internal.h83 struct ev_token_bucket rate_limit; member
/freebsd/sys/netinet/
H A Dtcp_ratelimit.c471 .rate_limit.hdr.type = IF_SND_TAG_TYPE_RATE_LIMIT, in rl_attach_txrtlmt()
472 .rate_limit.hdr.flowid = flowid, in rl_attach_txrtlmt()
473 .rate_limit.hdr.flowtype = flowtype, in rl_attach_txrtlmt()
474 .rate_limit.max_rate = cfg_rate, in rl_attach_txrtlmt()
475 .rate_limit.flags = M_NOWAIT, in rl_attach_txrtlmt()
1056 .rate_limit.hdr.type = IF_SND_TAG_TYPE_RATE_LIMIT, in rt_find_real_interface()
1057 .rate_limit.hdr.flowid = inp->inp_flowid, in rt_find_real_interface()
1058 .rate_limit.hdr.numa_domain = inp->inp_numa_domain, in rt_find_real_interface()
1059 .rate_limit.max_rate = COMMON_RATE, in rt_find_real_interface()
1060 .rate_limit.flags = M_NOWAIT, in rt_find_real_interface()
[all …]
H A Din_pcb.c3217 .rate_limit.max_rate = max_pacing_rate, in in_pcbmodify_txrtlmt()
3218 .rate_limit.flags = M_NOWAIT, in in_pcbmodify_txrtlmt()
3255 *p_max_pacing_rate = params.rate_limit.max_rate; in in_pcbquery_txrtlmt()
3280 *p_txqueue_level = params.rate_limit.queue_level; in in_pcbquery_txrlevel()
3294 .rate_limit.hdr.type = (max_pacing_rate == -1U) ? in in_pcbattach_txrtlmt()
3296 .rate_limit.hdr.flowid = flowid, in in_pcbattach_txrtlmt()
3297 .rate_limit.hdr.flowtype = flowtype, in in_pcbattach_txrtlmt()
3298 .rate_limit.hdr.numa_domain = inp->inp_numa_domain, in in_pcbattach_txrtlmt()
3299 .rate_limit.max_rate = max_pacing_rate, in in_pcbattach_txrtlmt()
3300 .rate_limit.flags = M_NOWAIT, in in_pcbattach_txrtlmt()
/freebsd/sys/dev/cxgbe/
H A Dt4_sched.c811 (params->rate_limit.max_rate * 8ULL / 1000), &schedcl); in cxgbe_rate_tag_alloc()
837 cst->max_rate = params->rate_limit.max_rate; in cxgbe_rate_tag_alloc()
870 (params->rate_limit.max_rate * 8ULL / 1000), &schedcl); in cxgbe_rate_tag_modify()
876 cst->max_rate = params->rate_limit.max_rate; in cxgbe_rate_tag_modify()
888 params->rate_limit.max_rate = cst->max_rate; in cxgbe_rate_tag_query()
891 params->rate_limit.queue_level = in cxgbe_rate_tag_query()
/freebsd/crypto/openssl/providers/fips/
H A Dself_test.c382 static TSAN_QUALIFIER unsigned int rate_limit = 0; in ossl_prov_is_running() local
387 if (tsan_counter(&rate_limit) < FIPS_ERROR_REPORTING_RATE_LIMIT) in ossl_prov_is_running()
/freebsd/sys/dev/mlx5/mlx5_en/
H A Dmlx5_en_rl.c1156 params->rate_limit.max_rate = channel->last_rate; in mlx5e_rl_query()
1157 params->rate_limit.queue_level = mlx5e_sq_queue_level(channel->sq); in mlx5e_rl_query()
1161 params->rate_limit.max_rate = channel->last_rate; in mlx5e_rl_query()
1162 params->rate_limit.queue_level = mlx5e_sq_queue_level(channel->sq); in mlx5e_rl_query()
1217 params->rate_limit.hdr.type != IF_SND_TAG_TYPE_RATE_LIMIT) in mlx5e_rl_snd_tag_alloc()
1221 rlw = priv->rl.workers + ((params->rate_limit.hdr.flowid % 128) % in mlx5e_rl_snd_tag_alloc()
1228 error = mlx5e_rl_modify(rlw, channel, params->rate_limit.max_rate); in mlx5e_rl_snd_tag_alloc()
1249 return (mlx5e_rl_modify(channel->worker, channel, params->rate_limit.max_rate)); in mlx5e_rl_snd_tag_modify()
H A Dmlx5_en_hw_tls.c489 rl_params.rate_limit.max_rate = params->tls_rate_limit.max_rate; in mlx5e_tls_snd_tag_alloc()
535 rl_params.rate_limit.max_rate = params->tls_rate_limit.max_rate; in mlx5e_tls_rl_snd_tag_modify()
/freebsd/tools/tools/netmap/
H A Dpkt-gen.c1397 int rate_limit = targ->g->tx_rate, tosend = 0; in ping_body() local
1415 if (rate_limit) { in ping_body()
1428 if (rate_limit && tosend <= 0) { in ping_body()
1434 limit = rate_limit ? tosend : targ->g->burst; in ping_body()
1462 if (rate_limit) in ping_body()
1688 int rate_limit = targ->g->tx_rate; in sender_body() local
1707 if (rate_limit) { in sender_body()
1776 if (rate_limit && tosend <= 0) { in sender_body()
1811 uint64_t limit = rate_limit ? tosend : targ->g->burst; in sender_body()
1838 if (rate_limit) { in sender_body()
[all …]
/freebsd/sys/net/
H A Dif_var.h274 struct if_snd_tag_alloc_rate_limit rate_limit; member
282 struct if_snd_tag_rate_limit_params rate_limit; member
289 struct if_snd_tag_rate_limit_params rate_limit; member
/freebsd/contrib/ofed/opensm/include/opensm/
H A Dosm_qos_policy.h113 uint8_t rate_limit; member
/freebsd/contrib/tnftp/src/
H A Dftp.c585 int rate_limit, int hash_interval) in copy_bytes() argument
595 if (rate_limit) in copy_bytes()
596 bufchunk = rate_limit; in copy_bytes()
601 if (rate_limit) { in copy_bytes()
630 if (rate_limit) { /* rate limited; wait if necessary */ in copy_bytes()
/freebsd/sys/dev/mlx5/mlx5_core/
H A Dmlx5_rl.c67 MLX5_SET(set_rate_limit_in, in, rate_limit, rate); in mlx5_set_rate_limit_cmd()
/freebsd/contrib/ofed/libibverbs/
H A Dcmd.c1434 if (cmd_size >= offsetof(struct ibv_modify_qp_ex, rate_limit) + in ibv_cmd_modify_qp_ex()
1435 sizeof(cmd->rate_limit)) in ibv_cmd_modify_qp_ex()
1436 cmd->rate_limit = attr->rate_limit; in ibv_cmd_modify_qp_ex()
H A Dkern-abi.h790 __u32 rate_limit; member
H A Dverbs.h910 uint32_t rate_limit; member
/freebsd/contrib/ofed/opensm/opensm/
H A Dosm_sa_multipath_record.c447 && (ib_path_compare_rates(rate, p_qos_level->rate_limit) > 0)) in mpr_rcv_get_path_parms()
448 rate = p_qos_level->rate_limit; in mpr_rcv_get_path_parms()
H A Dosm_sa_path_record.c461 && (ib_path_compare_rates(rate, p_qos_level->rate_limit) > 0)) in pr_rcv_get_path_parms()
462 rate = p_qos_level->rate_limit; in pr_rcv_get_path_parms()
H A Dosm_qos_parser_y.y1900 p_current_qos_level->rate_limit = (uint8_t)(*p_num);
/freebsd/sys/ofed/include/uapi/rdma/
H A Dib_user_verbs.h749 __u32 rate_limit; member
/freebsd/sys/kern/
H A Duipc_ktls.c1891 .rate_limit.max_rate = max_pacing_rate, in ktls_modify_txrtlmt()
1892 .rate_limit.flags = M_NOWAIT, in ktls_modify_txrtlmt()
/freebsd/sys/ofed/drivers/infiniband/core/
H A Dib_uverbs_cmd.c1896 attr->rate_limit = cmd->rate_limit; in modify_qp()
/freebsd/sys/ofed/include/rdma/
H A Dib_verbs.h1182 u32 rate_limit; member

12