Home
last modified time | relevance | path

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 Dmaster.lua93 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 Dslave.lua171 self.redis:hmset(slavekey, {id=tostring(id), max_subscribers=tostring(arg.subs)})
/dports/www/nginx-full/nchan-1.2.12/dev/bench/
H A Dbenchi.lua180 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 Dmod_muc_rai.lua5 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 Dipc-handlers.c799 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 Dnchan_types.h256 ngx_http_complex_value_t *max_subscribers; member
H A Dnchan_config_commands.c574 offsetof(nchan_loc_conf_t, group.max_subscribers),
H A Dnchan_module.c400 …set_group_num_limit(r, cf->group.max_subscribers, &limits->subscribers, ngx_atoi, "invalid nchan_g… in parse_group_limits()
H A Dnchan_setup.c456 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 Dha_ndbcluster_binlog.cc1286 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()