Changeset 6877 for trunk/ippTools/src/pztool.c

Timestamp:

Apr 17, 2006, 3:06:05 PM (20 years ago)

Author:

jhoblitt

Message:

misc changes

File:

• trunk/ippTools/src/pztool.c (modified) (5 diffs)

trunk/ippTools/src/pztool.c

@@ -6 +6 @@
 static bool pendingMode(pxConfig *config);
 static bool copydoneMode(pxConfig *config);
-bool summitExpPrint(FILE *stream, summitExpRow *summitExp);
-psArray *pzsearchPendingImfiles(pxConfig *config);
-bool pzsearchFlushPendingExp(pxConfig *config);
+static bool summitExpPrint(FILE *stream, summitExpRow *summitExp);
+static psArray *pzsearchPendingExp(pxConfig *config);
+static psArray *pzsearchPendingImfiles(pxConfig *config);
+static bool pzsearchFlushPendingExp(pxConfig *config);
 
 int main(int argc, char **argv)
@@ -151 +152 @@
 }
 
-bool summitExpPrint(FILE *stream, summitExpRow *summitExp)
+static bool summitExpPrint(FILE *stream, summitExpRow *summitExp)
 {
     PS_ASSERT_PTR_NON_NULL(stream, false);
@@ -167 +168 @@
 }
 
-psArray *pzsearchPendingImfiles(pxConfig *config)
+static psArray *pzsearchPendingExp(pxConfig *config)
+{
+    PS_ASSERT_PTR_NON_NULL(config, NULL);
+
+    psArray *exps = pzPendingExpSelectRowObjects(config->dbh,
+        config->where, MAX_ROWS);
+    if (!exps) {
+        psError(PS_ERR_UNKNOWN, false, "no pzPendingExp rows found");
+        return NULL;
+    }
+
+    return exps;
+}
+
+static psArray *pzsearchPendingImfiles(pxConfig *config)
 {
     PS_ASSERT_PTR_NON_NULL(config, NULL);
@@ -175 +190 @@
     if (!imfiles) {
         psError(PS_ERR_UNKNOWN, false, "no pzPendingImfile rows found");
-
         return NULL;
     }
@@ -182 +196 @@
 }
 
-bool pzsearchFlushPendingExp(pxConfig *config)
-{
-    PS_ASSERT_PTR_NON_NULL(config, false);
-
-    return true;
-}
+static bool pzsearchFlushPendingExp(pxConfig *config)
+{
+    PS_ASSERT_PTR_NON_NULL(config, false);
+
+    psArray *pending = pzsearchPendingExp(config);
+    if (!pending) {
+        psError(PS_ERR_UNKNOWN, false, "no pzPendingExps found");
+        return false;
+    }
+
+    for (long i = 0; i < pending->n; i++) {
+        pzPendingExpRow *pendingExp = pending->data[i];
+
+        psMetadata *where = psMetadataAlloc();
+        psMetadataAddStr(where, PS_LIST_TAIL, "exp_id", 0, "==",
+            pendingExp->exp_id);
+        psArray *pendingImfiles = pzPendingImfileSelectRowObjects(config->dbh, where, MAX_ROWS);
+        psFree(where);
+
+        if (!pendingImfiles) {
+            // exp has no coresponding imfiles
+
+            // XXX start transaction
+
+            psArray *nukeMe = psArrayAlloc(1);
+            nukeMe->n = 0;
+            psArrayAdd(nukeMe, 0, pendingExp);
+            bool status = pzPendingExpDeleteRowObjects(config->dbh, nukeMe, MAX_ROWS);
+            psFree(nukeMe);
+            if (!status) {
+                psError(PS_ERR_UNKNOWN, false, "dbh access failed");
+                // XXX rollback transaction
+                return false;
+            }
+
+            // XXX commit transaction
+        }
+    }
+
+    return true;
+}