rr assignments

pull/10932/head
Craig Tiller 8 years ago
parent 1168e81478
commit b9b2cbfb71
  1. 2
      include/grpc++/server_builder.h
  2. 5
      src/core/lib/iomgr/ev_epoll1_linux.c

@ -195,7 +195,7 @@ class ServerBuilder {
struct SyncServerSettings {
SyncServerSettings()
: num_cqs(1), min_pollers(1), max_pollers(2), cq_timeout_msec(10000) {}
: num_cqs(GPR_MAX(1,gpr_cpu_num_cores())), min_pollers(1), max_pollers(2), cq_timeout_msec(10000) {}
// Number of server completion queues to create to listen to incoming RPCs.
int num_cqs;

@ -386,9 +386,12 @@ static void pollset_global_shutdown(void) {
}
static void pollset_init(grpc_pollset *pollset, gpr_mu **mu) {
static gpr_atm next_neighbourhood;
gpr_mu_init(&pollset->mu);
*mu = &pollset->mu;
pollset->neighbourhood = &g_neighbourhoods[gpr_cpu_current_cpu()];
pollset->neighbourhood = &g_neighbourhoods[(size_t)gpr_atm_no_barrier_fetch_add(&next_neighbourhood, 1) % g_num_neighbourhoods];
gpr_log(GPR_DEBUG, "nh=%d", (int)(pollset->neighbourhood - g_neighbourhoods));
pollset->seen_inactive = true;
pollset->next = pollset->prev = pollset;
}

Loading…
Cancel
Save