Lines Matching refs:nconnections
402 nconnections = global->options.n_connections; in Cluster()
406 nconnections = global->conf->max_tps / connection_tps; in Cluster()
407 if(global->conf->max_tps % connection_tps) nconnections += 1; in Cluster()
409 assert(nconnections > 0); in Cluster()
418 cluster_id, pool->getPoolSize(), nconnections); in Cluster()
419 for(int i = pool->getPoolSize(); i < nconnections ; i ++) { in Cluster()
423 nconnections = i; in Cluster()
429 nconnections, nconnections == 1 ? "" : "s", cluster_id); in Cluster()
432 connections = new S::Connection * [nconnections]; in Cluster()
433 for(int i = 0; i < nconnections ; i++) { in Cluster()
443 for(int i = 0 ; i < nconnections; i++) { in startThreads()
453 for(int i = 0; i < nconnections ; i++) { in ~Cluster()
467 for(int c = 0 ; c < nconnections ; c++) { in add_stats()
495 id.conn = thd_id % cl->nconnections; // round-robin assignment in WorkerConnection()
581 n_workers = global->options.n_worker_threads / cluster.nconnections; in Connection()
582 if(n_total_workers % cluster.nconnections > id) n_workers += 1; in Connection()
586 instances.initial = (int) (total_ndb_objects / cluster.nconnections); in Connection()
599 if(instances.max > (global->options.max_clients / cluster.nconnections)) in Connection()
600 instances.max = global->options.max_clients / cluster.nconnections; in Connection()
764 for(int w = id; w < n_total_workers; w += cluster.nconnections) { in run_ndb_send_thread()