Merge pull request #5272 from richardkchapman/roxie-lookup-tracing

HPCC-10592 Roxie needs to cache dali lookups that fail to match

Reviewed-by: Gavin Halliday <ghalliday@hpccsystems.com>

roxie/ccd/ccddali.cpp

@@ -435,6 +435,8 @@ public:
         }
         else // Legacy mode - recently cloned files should have the extra info
         {
+            if (traceLevel > 1)
+                DBGLOG("checkClonedFromRemote: Resolving %s in legacy mode", _lfn);
             SocketEndpoint cloneFrom;
             cloneFrom.set(fdesc->queryProperties().queryProp("@cloneFrom"));
             if (cloneFrom.isNull())
@@ -488,6 +490,8 @@ public:
                 xpath.append(lcname.append(logicalName).toLowerCase());
                 writeCache(xpath.str(), xpath.str(), pt);
             }
+            if (traceLevel > 1)
+                DBGLOG("Dali lookup %s returned %d", logicalName, dfsFile != NULL);
             return dfsFile.getClear();
         }
         else

roxie/ccd/ccdstate.cpp

@@ -239,18 +239,25 @@ static Owned<KeptLowerCaseAtomTable> daliMisses;
 static void noteDaliMiss(const char *filename)
 {
     CriticalBlock b(daliMissesCrit);
+    if (traceLevel > 4)
+        DBGLOG("noteDaliMiss %s", filename);
     daliMisses->addAtom(filename);
 }
 
 static bool checkCachedDaliMiss(const char *filename)
 {
     CriticalBlock b(daliMissesCrit);
-    return daliMisses->find(filename) != NULL;
+    bool ret = daliMisses->find(filename) != NULL;
+    if (traceLevel > 4)
+        DBGLOG("checkCachedDaliMiss %s returns %d", filename, ret);
+    return ret;
 }
 
 static void clearDaliMisses()
 {
     CriticalBlock b(daliMissesCrit);
+    if (traceLevel)
+        DBGLOG("Clearing dali misses cache");
     daliMisses.setown(new KeptLowerCaseAtomTable);
 }
 

system/jlib/jthread.cpp

@@ -1602,6 +1602,7 @@ public:
         sigemptyset(&blockset);
         act.sa_mask = blockset;
         act.sa_handler = SIG_IGN;
+        act.sa_flags = 0;
         sigaction(SIGPIPE, &act, NULL);
     }