style95 commented on code in PR #5332:
URL: https://github.com/apache/openwhisk/pull/5332#discussion_r990904769
##########
core/scheduler/src/main/scala/org/apache/openwhisk/core/scheduler/queue/QueueManager.scala:
##########
@@ -278,6 +308,62 @@ class QueueManager(
initRevisionMap.update(key, revision)
}
+ private def recreateQueue(action: FullyQualifiedEntityName,
+ msg: ActivationMessage,
+ actionMetaData: WhiskActionMetaData): Unit = {
+ logging.warn(this, s"recreate queue for ${msg.action}")(msg.transid)
+ val queue = createAndStartQueue(msg.user.namespace.name.asString, action,
msg.revision, actionMetaData)
+ queue ! msg
+ msg.transid.mark(this, LoggingMarkers.SCHEDULER_QUEUE_RECOVER)
+ if (isShuttingDown) {
+ queue ! GracefulShutdown
+ }
+ }
+
+ private def handleCycle(msg: ActivationMessage)(implicit transid:
TransactionId): Unit = {
+ val action = msg.action
+ QueuePool.keys.find(_.docInfo.id == action.toDocId) match {
Review Comment:
Now it tries to recover a queue iff there is no reference in `QueuePool`.
Previously, it always sent a `RecoverQueue` message whenever the sender of
an activation is itself even if there was already a new queue added to the
queue pool.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
