added warning about objects that are delayDeleted and cannot be deleted by the CRCache

direct/src/distributed/CRCache.py

@@ -22,6 +22,10 @@ class CRCache:
         CRCache.notify.debug("Flushing the cache")
         for distObj in self.dict.values():
             distObj.deleteOrDelay()
+            if distObj.getDelayDeleteCount() != 0:
+                self.notify.warning(
+                    'CRCache.flush: could not delete %s (%s), delayDeleteCount=%s' %
+                    (safeRepr(distObj), itype(distObj), distObj.getDelayDeleteCount()))
         # Null out all references to the objects so they will get gcd
         self.dict = {}
         self.fifo = []

direct/src/distributed/DistributedObject.py

@@ -148,6 +148,9 @@ class DistributedObject(DistributedObjectBase):
         else:
             self.disableAnnounceAndDelete()
 
+    def getDelayDeleteCount(self):
+        return self.delayDeleteCount
+
     def delayDelete(self, flag):
         # Flag should be 0 or 1, meaning increment or decrement count
         # Also see DelayDelete.py