Searched refs:max_subscribers (Results 1 – 10 of 10) sorted by relevance
/dports/www/nginx-full/nchan-1.2.12/dev/bench/bench/ |
H A D | master.lua | 93 local subs = cf.n > slave.max_subscribers and slave.max_subscribers or cf.n 96 print("slave", slave_id, slave.max_subscribers, subs, cf.n) 129 data.max_subscribers = tonumber(data.max_subscribers) 137 num_subs = slaves[slave_id].max_subscribers 140 num_subs = num_subs + data.max_subscribers
|
H A D | slave.lua | 171 self.redis:hmset(slavekey, {id=tostring(id), max_subscribers=tostring(arg.subs)})
|
/dports/www/nginx-full/nchan-1.2.12/dev/bench/ |
H A D | benchi.lua | 180 redis:send("hmset", subskey, {id=id, max_subscribers=arg.subs}) 220 local subs = n > slave.max_subscribers and slave.max_subscribers or n 252 d.max_subscribers = tonumber(d.max_subscribers) 260 num_subs = slaves[d.id].max_subscribers 263 num_subs = num_subs + d.max_subscribers
|
/dports/net-im/prosody-modules/Community-Modules-bb8459c220c9/mod_muc_rai/ |
H A D | mod_muc_rai.lua | 5 local max_subscribers = module:get_option_number("muc_rai_max_subscribers", 1024); 15 local subscribed_users = cache.new(max_subscribers, false); 169 …warn", "Subscriber limit (%d) reached, rejecting subscription from %s", max_subscribers, user_jid);
|
/dports/www/nginx-full/nchan-1.2.12/src/store/memory/ |
H A D | ipc-handlers.c | 799 ngx_int_t max_subscribers; member 815 data.max_subscribers = cf->max_channel_subscribers; in memstore_ipc_send_channel_existence_check() 833 else if(data->d.max_subscribers == 0) { in redis_receive_channel_auth_check_callback() 837 data->d.auth_ok = channel->subscribers < data->d.max_subscribers; in redis_receive_channel_auth_check_callback() 855 else if (d->max_subscribers == 0) { in receive_channel_auth_check() 860 d->auth_ok = head->shared->sub_count < (ngx_uint_t )d->max_subscribers; in receive_channel_auth_check()
|
/dports/www/nginx-full/nchan-1.2.12/src/ |
H A D | nchan_types.h | 256 ngx_http_complex_value_t *max_subscribers; member
|
H A D | nchan_config_commands.c | 574 offsetof(nchan_loc_conf_t, group.max_subscribers),
|
H A D | nchan_module.c | 400 …set_group_num_limit(r, cf->group.max_subscribers, &limits->subscribers, ngx_atoi, "invalid nchan_g… in parse_group_limits()
|
H A D | nchan_setup.c | 456 MERGE_CONF(conf, prev, group.max_subscribers); in nchan_merge_loc_conf()
|
/dports/databases/xtrabackup8/percona-xtrabackup-8.0.14/storage/ndb/plugin/ |
H A D | ha_ndbcluster_binlog.cc | 1286 Node_subscribers(uint max_subscribers) { in Node_subscribers() argument 1288 bitmap_init(&m_bitmap, nullptr, max_subscribers); in Node_subscribers() 1363 Uint32 max_subscribers = cluster_connection->max_api_nodeid() + 1; in init() local 1372 new Node_subscribers(max_subscribers)); in init() 1375 m_max_subscribers = max_subscribers; in init()
|