IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Changeset 18571


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

Converting to use of psS64 for magic_id, diff_id. Cleaning up magictoolConfig.c. Adding error code into inputtree.

Location:
trunk/ippTools/src
Files:
2 edited

Legend:

Unmodified
Added
Removed

  • trunk/ippTools/src/magictool.c

    r18561 r18571  
    111111    // create warped skycells temp table
    112112    {
    113         psString query = pxDataGet("magictool_create_tmp_warpcomplete.sql");
    114         if (!query) {
    115             psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
    116             return false;
    117         }
    118 
    119         if (!p_psDBRunQuery(config->dbh, query)) {
    120             psError(PS_ERR_UNKNOWN, false, "database error");
    121             return false;
    122         }
     113        psString query = pxDataGet("magictool_create_tmp_warpcomplete.sql");
     114        if (!query) {
     115            psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     116            return false;
     117        }
     118
     119        if (!p_psDBRunQuery(config->dbh, query)) {
     120            psError(PS_ERR_UNKNOWN, false, "database error");
     121            return false;
     122        }
    123123    }
    124124
    125125    // find warped skycells
    126126    {
    127         psString query = pxDataGet("magictool_find_complete_warpruns.sql");
    128         if (!query) {
    129             psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
    130             return false;
    131         }
    132 
    133         if (!p_psDBRunQuery(config->dbh, query)) {
    134             psError(PS_ERR_UNKNOWN, false, "database error");
    135             psFree(query);
    136             return false;
    137         }
    138         psFree(query);
     127        psString query = pxDataGet("magictool_find_complete_warpruns.sql");
     128        if (!query) {
     129            psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     130            return false;
     131        }
     132
     133        if (!p_psDBRunQuery(config->dbh, query)) {
     134            psError(PS_ERR_UNKNOWN, false, "database error");
     135            psFree(query);
     136            return false;
     137        }
     138        psFree(query);
    139139    }
    140140
    141141    // find the diff_id's of the warped skycells
    142142    {
    143         psString query = pxDataGet("magictool_find_complete_diffed_exposures.sql");
    144         if (!query) {
    145             psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
    146             return false;
    147         }
    148 
    149         if (!p_psDBRunQuery(config->dbh, query)) {
    150             psError(PS_ERR_UNKNOWN, false, "database error");
    151             psFree(query);
    152             return false;
    153         }
    154         psFree(query);
     143        psString query = pxDataGet("magictool_find_complete_diffed_exposures.sql");
     144        if (!query) {
     145            psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     146            return false;
     147        }
     148
     149        if (!p_psDBRunQuery(config->dbh, query)) {
     150            psError(PS_ERR_UNKNOWN, false, "database error");
     151            psFree(query);
     152            return false;
     153        }
     154        psFree(query);
    155155    }
    156156    psArray *output = p_psDBFetchResult(config->dbh);
    … …  
    158158        psErrorCode err = psErrorCodeLast();
    159159        switch (err) {
    160           case PS_ERR_DB_CLIENT:
    161             psError(PXTOOLS_ERR_SYS, false, "database error");
    162           case PS_ERR_DB_SERVER:
    163             psError(PXTOOLS_ERR_PROG, false, "database error");
    164           default:
    165             psError(PXTOOLS_ERR_PROG, false, "unknown error");
     160          case PS_ERR_DB_CLIENT:
     161            psError(PXTOOLS_ERR_SYS, false, "database error");
     162          case PS_ERR_DB_SERVER:
     163            psError(PXTOOLS_ERR_PROG, false, "database error");
     164          default:
     165            psError(PXTOOLS_ERR_PROG, false, "unknown error");
    166166        }
    167167
    … …  
    211211        // create a new magicRun for this group
    212212        magicRunRow *run = magicRunRowAlloc(
    213             0,                          // ID
    214             "reg",                      // state
    215             workdir,                    // workdir
    216             "dirty",                    // workdir_state
    217             label,                      // label
    218             dvodb,                      // dvodb
    219             registered,                 // registered
    220             0                           // fault
    221             );
     213            0,                          // ID
     214            "reg",                      // state
     215            workdir,                    // workdir
     216            "dirty",                    // workdir_state
     217            label,                      // label
     218            dvodb,                      // dvodb
     219            registered,                 // registered
     220            0                           // fault
     221            );
    222222        if (!run) {
    223223            psAbort("failed to alloc magicRun object");
    … …  
    248248
    249249            if (!magicInputSkyfileInsert(config->dbh,
    250                                         magic_id,
    251                                         diff_id,
    252                                         node)) {
     250                                        magic_id,
     251                                        diff_id,
     252                                        node)) {
    253253                psError(PS_ERR_UNKNOWN, false, "database error");
    254254                psFree(grouped);
    … …  
    320320
    321321    // required
    322     PXOPT_LOOKUP_STR(magic_id, config->args, "-magic_id", true, false);
     322    PXOPT_LOOKUP_S64(magic_id, config->args, "-magic_id", true, false);
    323323    PXOPT_LOOKUP_STR(state, config->args, "-state", true, false);
    324324
    325325    if (state) {
    326326        // set detRun.state to state
    327         return setmagicRunState(config, (psS64)atoll(magic_id), state);
     327        return setmagicRunState(config, magic_id, state);
    328328    }
    329329
    … …  
    337337
    338338    // required
    339     PXOPT_LOOKUP_STR(magic_id, config->args, "-magic_id", true, false);
    340     PXOPT_LOOKUP_STR(diff_id, config->args, "-diff_id", true, false);
     339    PXOPT_LOOKUP_S64(magic_id, config->args, "-magic_id", true, false);
     340    PXOPT_LOOKUP_S64(diff_id, config->args, "-diff_id", true, false);
    341341    PXOPT_LOOKUP_STR(node, config->args, "-node", true, false);
    342342
    343343    magicInputSkyfileInsert(
    344344            config->dbh,
    345             (psS64)atoll(magic_id),
    346             (psS64)atoll(diff_id),
     345            magic_id,
     346            diff_id,
    347347            node
    348348    );
    … …  
    357357
    358358    psMetadata *where = psMetadataAlloc();
    359     PXOPT_COPY_STR(config->args, where, "-magic_id", "magic_id", "==");
    360     PXOPT_COPY_STR(config->args, where, "-diff_id", "diff_id", "==");
     359    PXOPT_COPY_S64(config->args, where, "-magic_id", "magic_id", "==");
     360    PXOPT_COPY_S64(config->args, where, "-diff_id", "diff_id", "==");
    361361    PXOPT_COPY_STR(config->args, where, "-node", "node", "==");
    362362
    … …  
    431431
    432432    psMetadata *where = psMetadataAlloc();
    433     PXOPT_COPY_STR(config->args, where, "-magic_id", "magicRun.magic_id", "==");
     433    PXOPT_COPY_S64(config->args, where, "-magic_id", "magicRun.magic_id", "==");
    434434
    435435    PXOPT_LOOKUP_U64(limit, config->args, "-limit", false, false);
    … …  
    503503
    504504    // required
    505     PXOPT_LOOKUP_STR(magic_id, config->args, "-magic_id", true, false);
    506     PXOPT_LOOKUP_STR(dep_file, config->args, "-dep_file", true, false);
    507 
    508     if (!parseAndInsertNodeDeps(config, (psS64)atoll(magic_id), dep_file)) {
     505    PXOPT_LOOKUP_S64(magic_id, config->args, "-magic_id", true, false);
     506
     507    // Optional values
     508    PXOPT_LOOKUP_STR(dep_file, config->args, "-dep_file", false, false);
     509
     510    // default values
     511    PXOPT_LOOKUP_S16(code, config->args, "-code", false, false);
     512
     513    if (code > 0) {
     514        char *query = "UPDATE magicRun SET fault = %d WHERE magic_id = %" PRId64;
     515        if (!p_psDBRunQuery(config->dbh, query, code, magic_id)) {
     516            psError(PS_ERR_UNKNOWN, false,
     517                    "failed to set fault for magic_id %" PRId64, magic_id);
     518            return false;
     519        }
     520        return true;
     521    }
     522
     523    if (!parseAndInsertNodeDeps(config, magic_id, dep_file)) {
    509524        psError(PS_ERR_UNKNOWN, false, "failed to parse file");
    510525        return false;
    … …  
    519534
    520535    psMetadata *where = psMetadataAlloc();
    521     PXOPT_COPY_STR(config->args, where, "-magic_id", "magic_id", "==");
     536    PXOPT_COPY_S64(config->args, where, "-magic_id", "magic_id", "==");
    522537    PXOPT_COPY_STR(config->args, where, "-node", "node", "==");
    523538
    … …  
    663678
    664679    psMetadata *where = psMetadataAlloc();
    665     PXOPT_COPY_STR(config->args, where, "-magic_id", "magic_id", "==");
     680    PXOPT_COPY_S64(config->args, where, "-magic_id", "magic_id", "==");
    666681
    667682    PXOPT_LOOKUP_BOOL(simple, config->args, "-simple", false);
    … …  
    678693        whereClause = psDBGenerateWhereSQL(where, NULL);
    679694        psStringAppend(&query, " %s", whereClause);
    680         psFree(whereClause);
     695        psFree(whereClause);
    681696    }
    682697    psFree(where);
    … …  
    705720    if (!psArrayLength(output)) {
    706721        psTrace("magictool", PS_LOG_INFO, "no rows found");
    707         // psFree(output);
     722        // psFree(output);
    708723        // return true;
    709724    }
    … …  
    798813
    799814    // required
    800     PXOPT_LOOKUP_STR(magic_id, config->args, "-magic_id", true, false);
     815    PXOPT_LOOKUP_S64(magic_id, config->args, "-magic_id", true, false);
    801816    PXOPT_LOOKUP_STR(node, config->args, "-node", true, false);
    802817
    … …  
    808823
    809824    if (!magicNodeResultInsert(config->dbh,
    810                                (psS64)atoll(magic_id),
     825                               magic_id,
    811826                               node,
    812827                               uri,
    … …  
    888903
    889904    // required
    890     PXOPT_LOOKUP_STR(magic_id, config->args, "-magic_id", true, false);
     905    PXOPT_LOOKUP_S64(magic_id, config->args, "-magic_id", true, false);
    891906
    892907    // optional
    … …  
    903918
    904919    if (!magicMaskInsert(config->dbh,
    905                          (psS64)atoll(magic_id),
     920                         magic_id,
    906921                         uri,
    907922                         streaks,
    … …  
    920935
    921936    // manually add constraint
    922     psStringAppend(&query, " AND magic_id = %s", magic_id);
     937    psStringAppend(&query, " AND magic_id = %" PRId64, magic_id);
    923938
    924939    if (!p_psDBRunQuery(config->dbh, query)) {
    … …  
    943958
    944959    psMetadata *where = psMetadataAlloc();
    945     PXOPT_COPY_STR(config->args, where, "-magic_id", "magicRun.magic_id", "==");
     960    PXOPT_COPY_S64(config->args, where, "-magic_id", "magicRun.magic_id", "==");
    946961
    947962    PXOPT_LOOKUP_U64(limit, config->args, "-limit", false, false);

  • trunk/ippTools/src/magictoolConfig.c

    r18561 r18571  
    5656    // -definerun
    5757    psMetadata *definerunArgs = psMetadataAlloc();
    58     psMetadataAddStr(definerunArgs, PS_LIST_TAIL, "-workdir", 0,            "define workdir (required)", NULL);
    59     psMetadataAddStr(definerunArgs, PS_LIST_TAIL, "-label", 0,            "define label", NULL);
    60     psMetadataAddStr(definerunArgs, PS_LIST_TAIL, "-dvodb", 0,            "define dvodb", NULL);
    61     psMetadataAddTime(definerunArgs, PS_LIST_TAIL, "-registered",  0,            "time detrend run was registered", now);
    62     psMetadataAddBool(definerunArgs, PS_LIST_TAIL, "-simple",  0,            "use the simple output format", false);
     58    psMetadataAddStr(definerunArgs, PS_LIST_TAIL, "-workdir", 0, "define workdir (required)", NULL);
     59    psMetadataAddStr(definerunArgs, PS_LIST_TAIL, "-label", 0, "define label", NULL);
     60    psMetadataAddStr(definerunArgs, PS_LIST_TAIL, "-dvodb", 0, "define dvodb", NULL);
     61    psMetadataAddTime(definerunArgs, PS_LIST_TAIL, "-registered", 0, "time detrend run was registered", now);
     62    psMetadataAddBool(definerunArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false);
    6363
    6464    // -updaterun
    6565    psMetadata *updaterunArgs = psMetadataAlloc();
    66     psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-magic_id", 0,            "define warptool ID (required)", NULL);
    67     psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-state", 0,            "set state (required)", NULL);
     66    psMetadataAddS64(updaterunArgs, PS_LIST_TAIL, "-magic_id", 0, "define magictool ID (required)", 0);
     67    psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-state", 0, "set state (required)", NULL);
    6868
    6969    // -addinputskyfile
    7070    psMetadata *addinputskyfileArgs = psMetadataAlloc();
    71     psMetadataAddStr(addinputskyfileArgs, PS_LIST_TAIL, "-magic_id", 0,            "define magictool ID (required)", NULL);
    72     psMetadataAddStr(addinputskyfileArgs, PS_LIST_TAIL, "-diff_id", 0,            "define difftool ID (required)", NULL);
    73     psMetadataAddStr(addinputskyfileArgs, PS_LIST_TAIL, "-node",  0,            "define symbolic node name (required)", NULL);
     71    psMetadataAddS64(addinputskyfileArgs, PS_LIST_TAIL, "-magic_id", 0, "define magictool ID (required)", 0);
     72    psMetadataAddS64(addinputskyfileArgs, PS_LIST_TAIL, "-diff_id", 0, "define difftool ID (required)", 0);
     73    psMetadataAddStr(addinputskyfileArgs, PS_LIST_TAIL, "-node", 0, "define symbolic node name (required)", NULL);
    7474
    7575    // -inputskyfile
    7676    psMetadata *inputskyfileArgs = psMetadataAlloc();
    77     psMetadataAddStr(inputskyfileArgs, PS_LIST_TAIL, "-magic_id", 0,            "search by magictool ID", NULL);
    78     psMetadataAddStr(inputskyfileArgs, PS_LIST_TAIL, "-diff_id", 0,            "search by difftool ID", NULL);
    79     psMetadataAddStr(inputskyfileArgs, PS_LIST_TAIL, "-node",  0,            "search by symbolic node name", NULL);
    80     psMetadataAddU64(inputskyfileArgs, PS_LIST_TAIL, "-limit",  0,            "limit result set to N items", 0);
    81     psMetadataAddBool(inputskyfileArgs, PS_LIST_TAIL, "-simple",  0,            "use the simple output format", false);
     77    psMetadataAddS64(inputskyfileArgs, PS_LIST_TAIL, "-magic_id", 0, "search by magictool ID", 0);
     78    psMetadataAddS64(inputskyfileArgs, PS_LIST_TAIL, "-diff_id", 0, "search by difftool ID", 0);
     79    psMetadataAddStr(inputskyfileArgs, PS_LIST_TAIL, "-node", 0, "search by symbolic node name", NULL);
     80    psMetadataAddU64(inputskyfileArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0);
     81    psMetadataAddBool(inputskyfileArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false);
    8282
    8383    // -totree
    8484    psMetadata *totreeArgs = psMetadataAlloc();
    85     psMetadataAddStr(totreeArgs, PS_LIST_TAIL, "-magic_id", 0, "search by magic ID", NULL);
     85    psMetadataAddS64(totreeArgs, PS_LIST_TAIL, "-magic_id", 0, "search by magic ID", 0);
    8686    psMetadataAddU64(totreeArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0);
    8787    psMetadataAddBool(totreeArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false);
    … …  
    8989    // -inputtree
    9090    psMetadata *inputtreeArgs = psMetadataAlloc();
    91     psMetadataAddStr(inputtreeArgs, PS_LIST_TAIL, "-magic_id", 0,            "define magictool ID (required)", NULL);
    92     psMetadataAddStr(inputtreeArgs, PS_LIST_TAIL, "-dep_file", 0,            "order of operations dep. file (required)", NULL);
    93     psMetadataAddS16(inputtreeArgs, PS_LIST_TAIL, "-code",  0, "set fault code", 0);
     91    psMetadataAddS64(inputtreeArgs, PS_LIST_TAIL, "-magic_id", 0, "define magictool ID (required)", 0);
     92    psMetadataAddStr(inputtreeArgs, PS_LIST_TAIL, "-dep_file", 0, "order of operations dep. file", NULL);
     93    psMetadataAddS16(inputtreeArgs, PS_LIST_TAIL, "-code", 0, "set fault code", 0);
    9494
    9595    // -inputs
    9696    psMetadata *inputsArgs = psMetadataAlloc();
    97     psMetadataAddStr(inputsArgs, PS_LIST_TAIL, "-magic_id", 0,            "search by magictool ID", NULL);
    98     psMetadataAddStr(inputsArgs, PS_LIST_TAIL, "-node",  0,            "search by symbolic node name", NULL);
    99     psMetadataAddU64(inputsArgs, PS_LIST_TAIL, "-limit",  0,            "limit result set to N items", 0);
    100     psMetadataAddBool(inputsArgs, PS_LIST_TAIL, "-simple",  0,            "use the simple output format", false);
     97    psMetadataAddS64(inputsArgs, PS_LIST_TAIL, "-magic_id", 0, "search by magictool ID", 0);
     98    psMetadataAddStr(inputsArgs, PS_LIST_TAIL, "-node", 0, "search by symbolic node name", NULL);
     99    psMetadataAddU64(inputsArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0);
     100    psMetadataAddBool(inputsArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false);
    101101
    102102    // -tooprocess
    103103    psMetadata *toprocessArgs = psMetadataAlloc();
    104     psMetadataAddStr(toprocessArgs, PS_LIST_TAIL, "-magic_id", 0,            "search by magic ID", NULL);
    105     psMetadataAddU64(toprocessArgs, PS_LIST_TAIL, "-limit",  0,            "limit result set to N items", 0);
    106     psMetadataAddBool(toprocessArgs, PS_LIST_TAIL, "-simple",  0,            "use the simple output format", false);
     104    psMetadataAddS64(toprocessArgs, PS_LIST_TAIL, "-magic_id", 0, "search by magic ID", 0);
     105    psMetadataAddU64(toprocessArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0);
     106    psMetadataAddBool(toprocessArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false);
    107107
    108108    // -addresult
    109109    psMetadata *addresultArgs = psMetadataAlloc();
    110     psMetadataAddStr(addresultArgs, PS_LIST_TAIL, "-magic_id", 0,            "define magictool ID (required)", NULL);
    111     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);
    113     psMetadataAddS16(addresultArgs, PS_LIST_TAIL, "-code",  0, "set fault code", 0);
     110    psMetadataAddS64(addresultArgs, PS_LIST_TAIL, "-magic_id", 0, "define magictool ID (required)", 0);
     111    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);
     113    psMetadataAddS16(addresultArgs, PS_LIST_TAIL, "-code", 0, "set fault code", 0);
    114114
    115115    // -tomask
    116116    psMetadata *tomaskArgs = psMetadataAlloc();
    117     psMetadataAddU64(tomaskArgs, PS_LIST_TAIL, "-limit",  0,            "limit result set to N items", 0);
    118     psMetadataAddBool(tomaskArgs, PS_LIST_TAIL, "-simple",  0,            "use the simple output format", false);
     117    psMetadataAddU64(tomaskArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0);
     118    psMetadataAddBool(tomaskArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false);
    119119
    120120    // -addmask
    121121    psMetadata *addmaskArgs = psMetadataAlloc();
    122     psMetadataAddStr(addmaskArgs, PS_LIST_TAIL, "-magic_id", 0,          "define magictool ID (required)", NULL);
    123     psMetadataAddStr(addmaskArgs, PS_LIST_TAIL, "-uri",  0, "define URI", NULL);
    124     psMetadataAddS32(addmaskArgs, PS_LIST_TAIL, "-streaks",  0, "define number of streaks", 0);
    125     psMetadataAddS16(addmaskArgs, PS_LIST_TAIL, "-code",  0, "set fault code", 0);
    126 
    127 # if (0)
    128     // -toskyfilemask
    129     psMetadata *toskyfilemaskArgs = psMetadataAlloc();
    130     psMetadataAddStr(toskyfilemaskArgs, PS_LIST_TAIL, "-magic_id", 0,            "search by magic ID", NULL);
    131     psMetadataAddU64(toskyfilemaskArgs, PS_LIST_TAIL, "-limit",  0,            "limit result set to N items", 0);
    132     psMetadataAddBool(toskyfilemaskArgs, PS_LIST_TAIL, "-simple",  0,            "use the simple output format", false);
    133 
    134     // -addskyfilemask
    135     psMetadata *addskyfilemaskArgs = psMetadataAlloc();
    136     psMetadataAddStr(addskyfilemaskArgs, PS_LIST_TAIL, "-magic_id", 0,            "define magictool ID (required)", NULL);
    137     psMetadataAddStr(addskyfilemaskArgs, PS_LIST_TAIL, "-diff_id",  0,            "define difftool ID (required)", NULL);
    138     psMetadataAddStr(addskyfilemaskArgs, PS_LIST_TAIL, "-uri",  0,            "define URI (required)", NULL);
    139 # endif
     122    psMetadataAddS64(addmaskArgs, PS_LIST_TAIL, "-magic_id", 0, "define magictool ID (required)", 0);
     123    psMetadataAddStr(addmaskArgs, PS_LIST_TAIL, "-uri", 0, "define URI", NULL);
     124    psMetadataAddS32(addmaskArgs, PS_LIST_TAIL, "-streaks", 0, "define number of streaks", 0);
     125    psMetadataAddS16(addmaskArgs, PS_LIST_TAIL, "-code", 0, "set fault code", 0);
    140126
    141127    // -mask
    142128    psMetadata *maskArgs = psMetadataAlloc();
    143     psMetadataAddStr(maskArgs, PS_LIST_TAIL, "-magic_id", 0, "define magictool ID", NULL);
     129    psMetadataAddS64(maskArgs, PS_LIST_TAIL, "-magic_id", 0, "define magictool ID", 0);
    144130    psMetadataAddU64(maskArgs, PS_LIST_TAIL, "-limit", 0, "limit result set to N items", 0);
    145131    psMetadataAddBool(maskArgs, PS_LIST_TAIL, "-simple", 0, "use the simple output format", false);
Note: See TracChangeset for help on using the changeset viewer.