Skip to content

Commit 1966d31

Browse files
Update common/scala/src/main/scala/org/apache/openwhisk/common/NestedSemaphore.scala
Co-authored-by: Markus Thömmes <[email protected]>
1 parent 5102361 commit 1966d31

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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)