IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Changeset 18573


Ignore:
Timestamp:
Jul 15, 2008, 4:16:16 PM (18 years ago)
Author:
Paul Price
Message:

Adding revert options, fault code handling.

Location:
trunk/ippTools
Files:
6 edited

Legend:

Unmodified
Added
Removed

  • trunk/ippTools/share/magictool_inputs.sql

    r18526 r18573  
    33-- Single skycells
    44SELECT
     5    magicRun.magic_id,
     6    magicRun.state,
    57    magicInputSkyfile.node,
    6     magicRun.state,
    78    diffSkyfile.uri,
    89    diffSkyfile.fault
    910FROM magicInputSkyfile
    1011JOIN diffSkyfile
    11     using(diff_id)
     12    USING(diff_id)
    1213JOIN magicRun
    1314    USING(magic_id)
    … …  
    1516-- Merged skycells
    1617SELECT
     18    magicRun.magic_id,
     19    magicRun.state,
    1720    magicTree.node,
    18     magicRun.state,
    1921    magicNodeResult.uri,
    2022    magicNodeResult.fault

  • trunk/ippTools/share/magictool_tomask.sql

    r15351 r18573  
    1010    magicRun.state = 'run'
    1111    AND magicNodeResult.node = 'root'
     12    AND magicNodeResult.fault = 0
    1213GROUP BY
    1314    magic_id

  • trunk/ippTools/share/magictool_toprocess_tree.sql

    r18524 r18573  
    33    -- convert magic_id into a boolean value (1 or 0)
    44    -- note that the type stays a 64 bit int
    5     magicNodeResult.magic_id IS TRUE as done
     5    magicNodeResult.magic_id IS TRUE as done,
     6    magicNodeResult.fault IS TRUE as bad
    67FROM magicTree
    78JOIN magicRun

  • trunk/ippTools/src/magictool.c

    r18571 r18573  
    3838static bool totreeMode(pxConfig *config);
    3939static bool inputtreeMode(pxConfig *config);
     40static bool reverttreeMode(pxConfig *config);
    4041static bool toprocessMode(pxConfig *config);
    4142static bool addresultMode(pxConfig *config);
     43static bool revertnodeMode(pxConfig *config);
    4244static bool inputsMode(pxConfig *config);
    4345static bool tomaskMode(pxConfig *config);
    4446static bool addmaskMode(pxConfig *config);
     47static bool revertmaskMode(pxConfig *config);
    4548static bool maskMode(pxConfig *config);
    4649
    … …  
    7376        MODECASE(MAGICTOOL_MODE_TOTREE,         totreeMode);
    7477        MODECASE(MAGICTOOL_MODE_INPUTTREE,      inputtreeMode);
     78        MODECASE(MAGICTOOL_MODE_REVERTTREE,     reverttreeMode);
    7579        MODECASE(MAGICTOOL_MODE_TOPROCESS,      toprocessMode);
    7680        MODECASE(MAGICTOOL_MODE_ADDRESULT,      addresultMode);
     81        MODECASE(MAGICTOOL_MODE_REVERTNODE,     revertnodeMode);
    7782        MODECASE(MAGICTOOL_MODE_INPUTS,         inputsMode);
    7883        MODECASE(MAGICTOOL_MODE_TOMASK,         tomaskMode);
    7984        MODECASE(MAGICTOOL_MODE_ADDMASK,        addmaskMode);
     85        MODECASE(MAGICTOOL_MODE_REVERTMASK,     revertmaskMode);
    8086        MODECASE(MAGICTOOL_MODE_MASK,           maskMode);
    8187        default:
    … …  
    512518
    513519    if (code > 0) {
    514         char *query = "UPDATE magicRun SET fault = %d WHERE magic_id = %" PRId64;
     520        char *query = "UPDATE magicRun SET fault = %d, state = 'stop' WHERE magic_id = %" PRId64;
    515521        if (!p_psDBRunQuery(config->dbh, query, code, magic_id)) {
    516522            psError(PS_ERR_UNKNOWN, false,
    … …  
    528534    return true;
    529535}
     536
     537static bool reverttreeMode(pxConfig *config)
     538{
     539    PS_ASSERT_PTR_NON_NULL(config, false);
     540
     541    psMetadata *where = psMetadataAlloc();
     542    PXOPT_COPY_S64(config->args, where, "-magic_id", "magic_id", "==");
     543    PXOPT_COPY_S16(config->args, where, "-code", "fault", "==");
     544
     545    psString query = psStringCopy("UPDATE magicRun SET fault = 0, state = 'run' WHERE fault != 0");
     546
     547    if (psListLength(where->list)) {
     548        psString whereClause = psDBGenerateWhereConditionSQL(where, NULL);
     549        psStringAppend(&query, " AND %s", whereClause);
     550        psFree(whereClause);
     551    }
     552    psFree(where);
     553
     554    if (!p_psDBRunQuery(config->dbh, query)) {
     555        psError(PS_ERR_UNKNOWN, false, "failed to revert");
     556        return false;
     557    }
     558    return true;
     559}
     560
    530561
    531562static bool inputsMode(pxConfig *config)
    … …  
    622653bool findReadyNodes(void *arg, pxNode *node)
    623654{
     655    if (!node) {
     656        // It's not there --- must have failed
     657        return false;
     658    }
     659
    624660    if (psMetadataLookupBool(NULL, node->data, "done")) {
    625661        // It's already done
    … …  
    632668        psMetadataRemoveKey(work, "dep");
    633669        psMetadataRemoveKey(work, "done");
    634 #if 0
    635         psMetadataRemoveKey(work, "uri");
    636 #endif
    637670        pxNode *child = NULL;
    638671        while ((child = psListGetAndIncrement(iter))) {
    … …  
    644677                psAbort("failed to lookup value for done column");
    645678            }
    646 
    647             if (!done) {
     679            psS16 bad = psMetadataLookupS16(&status, data, "bad");
     680            if (!status) {
     681                psAbort("failed to lookup value for bad column");
     682            }
     683
     684            if (!done || bad) {
    648685                // if a child isn't "done", give up on this node and continue
    649686                // to crawl the tree
    … …  
    652689                return true;
    653690            }
    654 #if 0
    655             char *uri = psMetadataLookupStr(&status, data, "uri");
    656             if (!status) {
    657                 psAbort("failed to lookup value for uri column");
    658             }
    659 
    660             psMetadataAddStr(work, PS_LIST_TAIL, "uri", PS_META_DUPLICATE_OK, NULL, uri);
    661 #endif
    662691        }
    663692        psFree(iter);
    … …  
    835864}
    836865
     866static bool revertnodeMode(pxConfig *config)
     867{
     868    PS_ASSERT_PTR_NON_NULL(config, false);
     869
     870    psMetadata *where = psMetadataAlloc();
     871    PXOPT_COPY_S64(config->args, where, "-magic_id", "magic_id", "==");
     872    PXOPT_COPY_STR(config->args, where, "-node", "node", "==");
     873    PXOPT_COPY_S16(config->args, where, "-code", "fault", "==");
     874
     875    psString query = psStringCopy("DELETE FROM magicNodeResult WHERE fault != 0");
     876
     877    if (psListLength(where->list)) {
     878        psString whereClause = psDBGenerateWhereConditionSQL(where, NULL);
     879        psStringAppend(&query, " AND %s", whereClause);
     880        psFree(whereClause);
     881    }
     882    psFree(where);
     883
     884    if (!p_psDBRunQuery(config->dbh, query)) {
     885        psError(PS_ERR_UNKNOWN, false, "failed to revert");
     886        return false;
     887    }
     888    return true;
     889}
     890
     891
    837892static bool tomaskMode(pxConfig *config)
    838893{
    … …  
    885940    if (psArrayLength(output)) {
    886941        // negative simple so the default is true
    887         if (!ippdbPrintMetadatas(stdout, output, "toprocess", !simple)) {
     942        if (!ippdbPrintMetadatas(stdout, output, "tomask", !simple)) {
    888943            psError(PS_ERR_UNKNOWN, false, "failed to print array");
    889944            psFree(output);
    … …  
    924979        )) {
    925980        psError(PS_ERR_UNKNOWN, false, "database error");
     981        if (!psDBRollback(config->dbh)) {
     982            psError(PS_ERR_UNKNOWN, false, "database error");
     983        }
    926984        return false;
    927985    }
    … …  
    931989    if (!query) {
    932990        psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     991        if (!psDBRollback(config->dbh)) {
     992            psError(PS_ERR_UNKNOWN, false, "database error");
     993        }
    933994        return false;
    934995    }
    … …  
    9401001        psError(PS_ERR_UNKNOWN, false, "database error");
    9411002        psFree(query);
     1003        if (!psDBRollback(config->dbh)) {
     1004            psError(PS_ERR_UNKNOWN, false, "database error");
     1005        }
    9421006        return false;
    9431007    }
    … …  
    9481012        return false;
    9491013    }
     1014
     1015    return true;
     1016}
     1017
     1018static bool revertmaskMode(pxConfig *config)
     1019{
     1020    PS_ASSERT_PTR_NON_NULL(config, false);
     1021
     1022    psMetadata *where = psMetadataAlloc();
     1023    PXOPT_COPY_S64(config->args, where, "-magic_id", "magic_id", "==");
     1024    PXOPT_COPY_S16(config->args, where, "-code", "fault", "==");
     1025
     1026    if (!psDBTransaction(config->dbh)) {
     1027        psError(PS_ERR_UNKNOWN, false, "database error");
     1028        return false;
     1029    }
     1030
     1031    // Set to "run"
     1032    {
     1033        psString query = psStringCopy("UPDATE magicRun JOIN magicMask USING(magic_id) "
     1034                                      "SET magicRun.state = 'run' WHERE magicMask.fault != 0");
     1035
     1036        if (psListLength(where->list)) {
     1037            psString whereClause = psDBGenerateWhereConditionSQL(where, "magicMask");
     1038            psStringAppend(&query, " AND %s", whereClause);
     1039            psFree(whereClause);
     1040        }
     1041
     1042        if (!p_psDBRunQuery(config->dbh, query)) {
     1043            psError(PS_ERR_UNKNOWN, false, "failed to revert");
     1044            if (!psDBRollback(config->dbh)) {
     1045                psError(PS_ERR_UNKNOWN, false, "database error");
     1046            }
     1047            return false;
     1048        }
     1049
     1050        psFree(query);
     1051    }
     1052
     1053    // Delete failed attempt at mask
     1054    {
     1055        psString query = psStringCopy("DELETE FROM magicMask WHERE fault != 0");
     1056
     1057        if (psListLength(where->list)) {
     1058            psString whereClause = psDBGenerateWhereConditionSQL(where, "magicMask");
     1059            psStringAppend(&query, " AND %s", whereClause);
     1060            psFree(whereClause);
     1061        }
     1062
     1063        if (!p_psDBRunQuery(config->dbh, query)) {
     1064            psError(PS_ERR_UNKNOWN, false, "failed to revert");
     1065            if (!psDBRollback(config->dbh)) {
     1066                psError(PS_ERR_UNKNOWN, false, "database error");
     1067            }
     1068            return false;
     1069        }
     1070
     1071        psFree(query);
     1072    }
     1073
     1074    if (!psDBCommit(config->dbh)) {
     1075        psError(PS_ERR_UNKNOWN, false, "database error");
     1076        return false;
     1077    }
     1078
     1079    psFree(where);
    9501080
    9511081    return true;
    … …  
    10121142    if (psArrayLength(output)) {
    10131143        // negative simple so the default is true
    1014         if (!ippdbPrintMetadatas(stdout, output, "magicNode", !simple)) {
     1144        if (!ippdbPrintMetadatas(stdout, output, "magicMask", !simple)) {
    10151145            psError(PS_ERR_UNKNOWN, false, "failed to print array");
    10161146            psFree(output);

  • trunk/ippTools/src/magictool.h

    r18526 r18573  
    3232    MAGICTOOL_MODE_TOTREE,
    3333    MAGICTOOL_MODE_INPUTTREE,
     34    MAGICTOOL_MODE_REVERTTREE,
    3435    MAGICTOOL_MODE_TOPROCESS,
    3536    MAGICTOOL_MODE_INPUTS,
    3637    MAGICTOOL_MODE_ADDRESULT,
     38    MAGICTOOL_MODE_REVERTNODE,
    3739    MAGICTOOL_MODE_TOMASK,
    3840    MAGICTOOL_MODE_ADDMASK,
     41    MAGICTOOL_MODE_REVERTMASK,
    3942    MAGICTOOL_MODE_MASK,
    4043} MAGICtoolMode;

  • trunk/ippTools/src/magictoolConfig.c

    r18571 r18573  
    9393    psMetadataAddS16(inputtreeArgs, PS_LIST_TAIL, "-code", 0, "set fault code", 0);
    9494
     95    // -reverttree
     96    psMetadata *reverttreeArgs = psMetadataAlloc();
     97    psMetadataAddS64(reverttreeArgs, PS_LIST_TAIL, "-magic_id", 0, "search by magictool ID", 0);
     98    psMetadataAddS16(reverttreeArgs, PS_LIST_TAIL, "-code", 0, "search by fault code", 0);
     99
    95100    // -inputs
    96101    psMetadata *inputsArgs = psMetadataAlloc();
    … …  
    110115    psMetadataAddS64(addresultArgs, PS_LIST_TAIL, "-magic_id", 0, "define magictool ID (required)", 0);
    111116    psMetadataAddStr(addresultArgs, PS_LIST_TAIL, "-node", 0, "define symbolic node name (required)", NULL);
    112     psMetadataAddStr(addresultArgs, PS_LIST_TAIL, "-uri", 0, "define URI (required)", NULL);
     117    psMetadataAddStr(addresultArgs, PS_LIST_TAIL, "-uri", 0, "define URI", NULL);
    113118    psMetadataAddS16(addresultArgs, PS_LIST_TAIL, "-code", 0, "set fault code", 0);
     119
     120    // -revertnode
     121    psMetadata *revertnodeArgs = psMetadataAlloc();
     122    psMetadataAddS64(revertnodeArgs, PS_LIST_TAIL, "-magic_id", 0, "search by magictool ID", 0);
     123    psMetadataAddStr(revertnodeArgs, PS_LIST_TAIL, "-node", 0, "search by node name", NULL);
     124    psMetadataAddS16(revertnodeArgs, PS_LIST_TAIL, "-code", 0, "search by fault code", 0);
    114125
    115126    // -tomask
    … …  
    124135    psMetadataAddS32(addmaskArgs, PS_LIST_TAIL, "-streaks", 0, "define number of streaks", 0);
    125136    psMetadataAddS16(addmaskArgs, PS_LIST_TAIL, "-code", 0, "set fault code", 0);
     137
     138    // -revertmask
     139    psMetadata *revertmaskArgs = psMetadataAlloc();
     140    psMetadataAddS64(revertmaskArgs, PS_LIST_TAIL, "-magic_id", 0, "search by magictool ID", 0);
     141    psMetadataAddS16(revertmaskArgs, PS_LIST_TAIL, "-code", 0, "search by fault code", 0);
    126142
    127143    // -mask
    … …  
    143159    PXOPT_ADD_MODE("-totree",          "", MAGICTOOL_MODE_TOTREE,          totreeArgs);
    144160    PXOPT_ADD_MODE("-inputtree",       "", MAGICTOOL_MODE_INPUTTREE,       inputtreeArgs);
     161    PXOPT_ADD_MODE("-reverttree",      "", MAGICTOOL_MODE_REVERTTREE,      reverttreeArgs);
    145162    PXOPT_ADD_MODE("-toprocess",       "", MAGICTOOL_MODE_TOPROCESS,       toprocessArgs);
    146163    PXOPT_ADD_MODE("-inputs",          "", MAGICTOOL_MODE_INPUTS,          inputsArgs);
    147164    PXOPT_ADD_MODE("-addresult",       "", MAGICTOOL_MODE_ADDRESULT,       addresultArgs);
     165    PXOPT_ADD_MODE("-revertnode",      "", MAGICTOOL_MODE_REVERTNODE,      revertnodeArgs);
    148166    PXOPT_ADD_MODE("-tomask",          "", MAGICTOOL_MODE_TOMASK,          tomaskArgs);
    149167    PXOPT_ADD_MODE("-addmask",         "", MAGICTOOL_MODE_ADDMASK,         addmaskArgs);
     168    PXOPT_ADD_MODE("-revertmask",      "", MAGICTOOL_MODE_REVERTMASK,      revertmaskArgs);
    150169    PXOPT_ADD_MODE("-mask",            "", MAGICTOOL_MODE_MASK,            maskArgs);
    151170
Note: See TracChangeset for help on using the changeset viewer.