Searched refs:getBalancer (Results 1 – 7 of 7) sorted by relevance
133 this.writeBalancer = getBalancer(numWriteQueues); in RWQueueRpcExecutor()134 this.readBalancer = getBalancer(numReadQueues); in RWQueueRpcExecutor()135 this.scanBalancer = getBalancer(numScanQueues); in RWQueueRpcExecutor()
63 this.balancer = getBalancer(numQueues); in BalancedQueueRpcExecutor()
179 public static QueueBalancer getBalancer(int queueSize) { in getBalancer() method in RpcExecutor
82 const auto getBalancer = ServiceContext::declareDecoration<std::unique_ptr<Balancer>>(); variable174 invariant(!getBalancer(serviceContext)); in create()175 getBalancer(serviceContext) = stdx::make_unique<Balancer>(serviceContext); in create()179 return getBalancer(serviceContext).get(); in get()
210 this.assignmentManager.getBalancer().roundRobinAssignment(unrecordedReplicas, in handleEnableTable()228 this.assignmentManager.getBalancer().retainAssignment(regionsToAssign, onlineServers); in handleEnableTable()
435 assignmentManager.getBalancer().roundRobinAssignment(unrecordedReplicas, in markRegionsOnline()455 env.getMasterServices().getAssignmentManager().getBalancer() in markRegionsOnline()
4419 public LoadBalancer getBalancer() { in getBalancer() method in AssignmentManager