File tree Expand file tree Collapse file tree 1 file changed +1
-20
lines changed
core/controller/src/main/scala/org/apache/openwhisk/core/loadBalancer Expand file tree Collapse file tree 1 file changed +1
-20
lines changed Original file line number Diff line number Diff line change @@ -297,7 +297,7 @@ class FPCPoolBalancer(config: WhiskConfig,
297
297
298
298
case _ =>
299
299
activationFeed ! MessageFeed .Processed
300
- logging.error (this , s " Unexpected Acknowledgment message received by loadbalancer: $raw" )
300
+ logging.warn (this , s " Unexpected Acknowledgment message received by loadbalancer: $raw" )
301
301
}
302
302
}
303
303
@@ -673,25 +673,6 @@ object FPCPoolBalancer extends LoadBalancerProvider {
673
673
*/
674
674
def rng (mod : Int ): Int = ThreadLocalRandom .current().nextInt(mod)
675
675
676
- /**
677
- * Assign an invoker to a message
678
- *
679
- * @param invokers Invoker pool
680
- * @param minMemory Minimum memory for all invokers
681
- * @return Assigned an invoker
682
- */
683
- // TODO add input/output example
684
- def schedule (invokers : IndexedSeq [InvokerHealth ], minMemory : ByteSize ): Option [InvokerInstanceId ] = {
685
- val availableInvokers = invokers.filter(i => i.status.isUsable && i.id.userMemory >= minMemory)
686
- val numInvokers = availableInvokers.size
687
- if (numInvokers > 0 ) {
688
- val invoker = availableInvokers(rng(numInvokers))
689
- Some (invoker.id)
690
- } else {
691
- None
692
- }
693
- }
694
-
695
676
/**
696
677
* Assign a scheduler to a message, return the scheduler which has least queues
697
678
*
You can’t perform that action at this time.
0 commit comments