Bug 38122993 - [37850365->22.06.14] Assertion failed at com.tangosol.coherence.component.util.daemon.queueProcessor.service.grid.partitionedService.PartitionedCache$InvocationContext.lockEntries

[git-p4: depot-paths = "//dev/coherence-ce/release/coherence-ce-v22.06/": change = 117132]

Author: mgamanho

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/PartitionedCache.java

@@ -23317,38 +23317,39 @@ public boolean isReadOnlyRequest()
          */
         public Storage.EntryStatus[] lockEntries(Storage storage, com.tangosol.util.Binary[] aKeys, int cSize)
             {
-            // import com.tangosol.util.Binary;
-            // import com.tangosol.util.LiteMap;
-            // import java.util.Map;
-            
-            Map                  mapStorage   = getStorageStatusMap(); // <Storage, Map<BinKey, $EntryStatus>>
-            Map                  mapKeyStatus = (Map) mapStorage.get(storage);
-            PartitionedCache              service      = getService();
+            Map                                  mapStorage   = getStorageStatusMap(); // <Storage, Map<BinKey, $EntryStatus>>
+            Map                                  mapKeyStatus = (Map) mapStorage.get(storage);
+            PartitionedCache                     service      = getService();
             PartitionedCache.ResourceCoordinator coordinator  = service.getResourceCoordinator();
-            Storage.EntryStatus[]       aStatus      = new Storage.EntryStatus[cSize];
-            
+            List<Storage.EntryStatus>            lStatus      = new ArrayList<>();
+
             if (mapKeyStatus == null)
                 {
                 mapStorage.put(storage, mapKeyStatus = new LiteMap());
                 }
-            
+
             for (int i = 0; i < cSize; i++)
                 {
                 Binary binKey = aKeys[i];
 
                 service.lockKey(storage, binKey, false);
 
                 Storage.EntryStatus status = coordinator.getStatus(storage, binKey);
-                _assert(status != null && status.getBinaryEntry() == null);
-            
+                if (status == null || status.getBinaryEntry() != null)
+                    {
+                    _trace("Status invalid while locking entry; skipping key", 1);
+                    // skip, soft assert; this could happen during shutdown with concurrent requests
+                    continue;
+                    }
+
                 mapKeyStatus.put(binKey, status);
 
                 status.setBinaryEntry(storage.instantiateBinaryEntry(binKey, null, false));
-            
-                aStatus[i] = status;
+
+                lStatus.add(status);
                 }
 
-            return aStatus;
+            return lStatus.toArray(new Storage.EntryStatus[lStatus.size()]);
             }
 
         /**