Skip to content

Commit eaf84fa

Browse files
author
Brendan Doyle
committed
fix bad merge
1 parent af107ed commit eaf84fa

File tree

3 files changed

+5
-3
lines changed

3 files changed

+5
-3
lines changed

core/invoker/src/main/scala/org/apache/openwhisk/core/containerpool/v2/FunctionPullingContainerPool.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ import org.apache.openwhisk.core.connector.{
2626
ContainerCreationAckMessage,
2727
ContainerCreationMessage,
2828
ContainerDeletionMessage,
29+
GetState,
2930
ResultMetadata
3031
}
3132
import org.apache.openwhisk.core.containerpool.{
@@ -76,7 +77,6 @@ case class DeletionContainer(deletionMessage: ContainerDeletionMessage)
7677
case object Remove
7778
case class Keep(timeout: FiniteDuration)
7879
case class PrewarmContainer(maxConcurrent: Int)
79-
case object GetState
8080

8181
/**
8282
* A pool managing containers to run actions on.

core/invoker/src/main/scala/org/apache/openwhisk/core/containerpool/v2/FunctionPullingContainerProxy.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -152,6 +152,7 @@ case class InitializedData(container: Container,
152152
override val clientProxy: ActorRef)
153153
extends ContainerAvailableData(container, invocationNamespace, action)
154154
with WithClient {
155+
override def getContainer = Some(container)
155156
def toReschedulingData(resumeRun: RunActivation) =
156157
ReschedulingData(container, invocationNamespace, action, clientProxy, resumeRun)
157158
}
@@ -164,6 +165,7 @@ case class WarmData(container: Container,
164165
override val clientProxy: ActorRef)
165166
extends ContainerAvailableData(container, invocationNamespace, action)
166167
with WithClient {
168+
override def getContainer = Some(container)
167169
def toReschedulingData(resumeRun: RunActivation) =
168170
ReschedulingData(container, invocationNamespace, action, clientProxy, resumeRun)
169171
}

core/invoker/src/main/scala/org/apache/openwhisk/core/invoker/FPCInvokerReactive.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ import org.apache.openwhisk.core.ack.{ActiveAck, HealthActionAck, MessagingActiv
3030
import org.apache.openwhisk.core.connector._
3131
import org.apache.openwhisk.core.containerpool._
3232
import org.apache.openwhisk.core.containerpool.logging.LogStoreProvider
33-
import org.apache.openwhisk.core.containerpool.v2.{GetState => GetPoolState, _}
33+
import org.apache.openwhisk.core.containerpool.v2._
3434
import org.apache.openwhisk.core.database._
3535
import org.apache.openwhisk.core.entity._
3636
import org.apache.openwhisk.core.etcd.EtcdKV.ContainerKeys.containerPrefix
@@ -390,7 +390,7 @@ class FPCInvokerReactive(config: WhiskConfig,
390390

391391
override def getPoolState(): Future[Either[NotSupportedPoolState, TotalContainerPoolState]] = {
392392
implicit val timeout: Timeout = 5.seconds
393-
(pool ? GetPoolState).mapTo[TotalContainerPoolState].map(Right(_))
393+
(pool ? GetState).mapTo[TotalContainerPoolState].map(Right(_))
394394
}
395395

396396
override def isEnabled(): String = {

0 commit comments

Comments
 (0)