Skip to content

Commit 6235e31

Browse files
Update common/scala/src/main/scala/org/apache/openwhisk/common/NestedSemaphore.scala
Co-authored-by: Markus Thömmes <markusthoemmes@me.com>
1 parent 91e87e7 commit 6235e31

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

common/scala/src/main/scala/org/apache/openwhisk/common/NestedSemaphore.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -101,7 +101,7 @@ class NestedSemaphore[T](memoryPermits: Int) extends ForcibleSemaphore(memoryPer
101101
super.release(memoryPermits)
102102
} else {
103103
//This map may be recreated (multiple times) due to cluster membership events, so don't assume the entry exists...
104-
actionConcurrentSlotsMap.get(actionid) match {
104+
actionConcurrentSlotsMap.get(actionid).foreach { concurrentSlots =>
105105
case Some(concurrentSlots) =>
106106
val (memoryRelease, actionRelease) = concurrentSlots.release(1, true)
107107
//concurrent slots

0 commit comments

Comments
 (0)