IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Changeset 19219


Ignore:
Timestamp:
Aug 26, 2008, 1:25:33 PM (18 years ago)
Author:
bills
Message:

add exp_id to pstampJob.
Rename -processedreq to -updatereq and -processedjob to -updatejob
to be clearer about what these modes do.
Fix handling of the various ids as S64 instead of strings

Location:
trunk/ippTools
Files:
6 edited

Legend:

Unmodified
Added
Removed

  • trunk/ippTools/share/pstamptool_addjob_otherjob.sql

    r18561 r19219  
    11INSERT INTO pstampJob
    2  (req_id, rownum, state, jobType, uri, outputBase, fault)
    3  VALUES( %s, '%s', '%s', '%s', '%s', '%s', %s)
     2 (req_id, rownum, state, jobType, uri, exp_id, outputBase, fault)
     3 VALUES( %lld, '%s', '%s', '%s', '%s', %lld, '%s', %s)

  • trunk/ippTools/share/pstamptool_addjob_stampjob.sql

    r18561 r19219  
    11INSERT INTO pstampJob
    2  (req_id, rownum, state, jobType, uri, outputBase, fault, args)
    3  VALUES( %s, '%s', '%s', '%s', '%s', '%s', %s, '%s')
     2 (req_id, rownum, state, jobType, uri, exp_id, outputBase, fault, args)
     3 VALUES( %lld, '%s', '%s', '%s', '%s', %lld, '%s', %s, '%s')

  • trunk/ippTools/share/pxadmin_create_tables.sql

    r19092 r19219  
    10151015        fault SMALLINT,
    10161016        uri VARCHAR(255),
     1017        exp_id BIGINT,
    10171018        outputBase VARCHAR(255),
    10181019        args VARCHAR(511),

  • trunk/ippTools/src/pstamptool.c

    r18974 r19219  
    3838static bool listReqMode(pxConfig *config);
    3939static bool pendingReqMode(pxConfig *config);
    40 static bool processedReqMode(pxConfig *config);
     40static bool updateReqMode(pxConfig *config);
    4141static bool revertReqMode(pxConfig *config);
    4242static bool addJobMode(pxConfig *config);
    4343static bool listJobMode(pxConfig *config);
    4444static bool pendingJobMode(pxConfig *config);
    45 static bool processedJobMode(pxConfig *config);
     45static bool updateJobMode(pxConfig *config);
    4646
    4747# define MODECASE(caseName, func) \
    … …  
    7171        MODECASE(PSTAMPTOOL_MODE_LISTREQ, listReqMode);
    7272        MODECASE(PSTAMPTOOL_MODE_PENDINGREQ, pendingReqMode);
    73         MODECASE(PSTAMPTOOL_MODE_PROCESSEDREQ, processedReqMode);
     73        MODECASE(PSTAMPTOOL_MODE_UPDATEREQ, updateReqMode);
    7474        MODECASE(PSTAMPTOOL_MODE_REVERTREQ, revertReqMode);
    7575        MODECASE(PSTAMPTOOL_MODE_ADDJOB, addJobMode);
    7676        MODECASE(PSTAMPTOOL_MODE_LISTJOB, listJobMode);
    7777        MODECASE(PSTAMPTOOL_MODE_PENDINGJOB, pendingJobMode);
    78         MODECASE(PSTAMPTOOL_MODE_PROCESSEDJOB, processedJobMode);
     78        MODECASE(PSTAMPTOOL_MODE_UPDATEJOB, updateJobMode);
    7979        default:
    8080            psAbort("invalid option (this should not happen)");
    … …  
    126126
    127127    psMetadata *where = psMetadataAlloc();
    128     PXOPT_COPY_STR(config->args, where, "-ds_id", "ds_id", "==");
     128    PXOPT_COPY_S64(config->args, where, "-ds_id", "ds_id", "==");
    129129
    130130    PXOPT_LOOKUP_BOOL(simple, config->args, "-simple", false);
    … …  
    174174    PS_ASSERT_PTR_NON_NULL(config, false);
    175175
    176     PXOPT_LOOKUP_STR(ds_id,       config->args, "-ds_id",         true, false);
     176    PXOPT_LOOKUP_S64(ds_id,       config->args, "-ds_id",         true, false);
    177177    PXOPT_LOOKUP_STR(lastFileset, config->args, "-last_fileset",  false, false);
    178178    PXOPT_LOOKUP_STR(state,       config->args, "-state",         false, false);
    … …  
    196196    }
    197197               
    198     psStringAppend(&query, " WHERE ds_id = '%s'", ds_id);
     198    psStringAppend(&query, " WHERE ds_id = %" PRId64, ds_id);
    199199
    200200    if (!p_psDBRunQuery(config->dbh, query)) {
    … …  
    220220    PXOPT_LOOKUP_STR(uri,         config->args, "-uri",           true, false);
    221221    // PXOPT_LOOKUP_STR(outFileset,  config->args, "-out_fileset",   true, false);
    222     PXOPT_LOOKUP_S32(ds_id,       config->args, "-ds_id",         false, false);
     222    PXOPT_LOOKUP_S64(ds_id,       config->args, "-ds_id",         false, false);
    223223
    224224    char *query ="INSERT INTO pstampRequest"
    … …  
    250250
    251251    psMetadata *where = psMetadataAlloc();
    252     PXOPT_COPY_STR(config->args, where, "-req_id", "req_id", "==");
     252    PXOPT_COPY_S64(config->args, where, "-req_id", "req_id", "==");
    253253
    254254    PXOPT_LOOKUP_U64(limit, config->args, "-limit", false, false);
    … …  
    309309    PS_ASSERT_PTR_NON_NULL(config, false);
    310310
    311     PXOPT_LOOKUP_STR(req_id,  config->args, "-req_id", true, false);
     311    PXOPT_LOOKUP_S64(req_id,  config->args, "-req_id", true, false);
    312312    PXOPT_LOOKUP_U64(limit,   config->args, "-limit",  false, false);
    313313    PXOPT_LOOKUP_BOOL(simple, config->args, "-simple", false);
    … …  
    405405}
    406406
    407 static bool processedReqMode(pxConfig *config)
    408 {
    409     PS_ASSERT_PTR_NON_NULL(config, false);
    410 
    411     PXOPT_LOOKUP_STR(req_id,     config->args, "-req_id",     true, false);
     407static bool updateReqMode(pxConfig *config)
     408{
     409    PS_ASSERT_PTR_NON_NULL(config, false);
     410
     411    PXOPT_LOOKUP_S64(req_id,     config->args, "-req_id",     true, false);
    412412    PXOPT_LOOKUP_STR(state,      config->args, "-state",      false, false);
    413413    PXOPT_LOOKUP_STR(outProduct, config->args, "-outProduct", false, false);
    … …  
    450450    }
    451451
    452     psStringAppend(&query, " WHERE req_id = '%s'", req_id);
     452    psStringAppend(&query, " WHERE req_id = %" PRId64, req_id);
    453453
    454454    if (!p_psDBRunQuery(config->dbh, query)) {
    … …  
    475475    PXOPT_LOOKUP_S64(req_id,     config->args, "-req_id",     true, false);
    476476
    477     printf("Revert request %" PRId64 "\n", req_id);
     477    // printf("Revert request %" PRId64 "\n", req_id);
    478478   
    479479    if (!p_psDBRunQuery(config->dbh, "DELETE FROM pstampJob where req_id = %" PRId64, req_id)) {
    … …  
    497497    PS_ASSERT_PTR_NON_NULL(config, false);
    498498
    499     PXOPT_LOOKUP_STR(uri,         config->args, "-uri",        true, false);
    500     PXOPT_LOOKUP_STR(req_id,      config->args, "-req_id",     true, false);
     499    PXOPT_LOOKUP_S64(uri,         config->args, "-uri",        true, false);
     500    PXOPT_LOOKUP_S64(req_id,      config->args, "-req_id",     true, false);
    501501    PXOPT_LOOKUP_STR(rownum,      config->args, "-rownum",     true, false);
    502502    PXOPT_LOOKUP_STR(job_type,    config->args, "-job_type",   false, false);
    … …  
    505505    PXOPT_LOOKUP_STR(stateString, config->args, "-state",      false, false);
    506506    PXOPT_LOOKUP_STR(fault,       config->args, "-fault",      false, false);
     507    PXOPT_LOOKUP_S64(exp_id,      config->args, "-exp_id",     false, false);
    507508
    508509    // default value for job_type is defined in pstamptoolConfig.c
    … …  
    531532    }
    532533
    533     if (!p_psDBRunQuery(config->dbh, query, req_id, rownum, stateString, job_type, uri, outputBase, fault, argString)) {
     534    if (!p_psDBRunQuery(config->dbh, query, req_id, rownum, stateString, job_type, uri, exp_id, outputBase, fault, argString)) {
    534535        psError(PS_ERR_UNKNOWN, false, "database error");
    535536        return false;
    … …  
    554555    PS_ASSERT_PTR_NON_NULL(config, false);
    555556
    556     PXOPT_LOOKUP_STR(req_id, config->args, "-req_id", false, false);
    557     PXOPT_LOOKUP_STR(job_id, config->args, "-job_id", false, false);
     557    PXOPT_LOOKUP_S64(req_id, config->args, "-req_id", false, false);
     558    PXOPT_LOOKUP_S64(job_id, config->args, "-job_id", false, false);
    558559
    559560    PXOPT_LOOKUP_U64(limit, config->args, "-limit", false, false);
    … …  
    572573                " *"
    573574                " FROM pstampJob"
    574                 " WHERE req_id = %s", req_id
     575                " WHERE req_id = %" PRId64, req_id
    575576            );
    576577    } else {
    … …  
    579580                " *"
    580581                " FROM pstampJob"
    581                 " WHERE job_id = %s", job_id
     582                " WHERE job_id = %" PRId64, job_id
    582583            );
    583584    }
    … …  
    627628
    628629    PXOPT_COPY_S64(config->args, where, "-job_id", "job_id", "==");
     630    PXOPT_COPY_S64(config->args, where, "-req_id", "req_id", "==");
    629631    PXOPT_LOOKUP_U64(limit, config->args, "-limit", false, false);
    630632    PXOPT_LOOKUP_BOOL(simple, config->args, "-simple", false);
    … …  
    681683}
    682684
    683 static bool processedJobMode(pxConfig *config)
    684 {
    685     PS_ASSERT_PTR_NON_NULL(config, false);
    686 
    687     PXOPT_LOOKUP_STR(job_id,    config->args, "-job_id", true, false);
     685static bool updateJobMode(pxConfig *config)
     686{
     687    PS_ASSERT_PTR_NON_NULL(config, false);
     688
     689    PXOPT_LOOKUP_S64(job_id,    config->args, "-job_id", true, false);
    688690    PXOPT_LOOKUP_STR(state,     config->args, "-state",  true, false);
    689691    PXOPT_LOOKUP_STR(fault,     config->args, "-fault",  false, false);
    … …  
    698700    char *query ="UPDATE pstampJob"
    699701        " SET state = '%s' %s"
    700         " WHERE job_id = '%s'";
     702        " WHERE job_id = %" PRId64;
    701703   
    702704    if (!p_psDBRunQuery(config->dbh, query, state, faultStr, job_id)) {

  • trunk/ippTools/src/pstamptool.h

    r18531 r19219  
    3232    PSTAMPTOOL_MODE_COMPLETEDREQ,
    3333    PSTAMPTOOL_MODE_PENDINGREQ,
    34     PSTAMPTOOL_MODE_PROCESSEDREQ,
     34    PSTAMPTOOL_MODE_UPDATEREQ,
    3535    PSTAMPTOOL_MODE_REVERTREQ,
    3636    PSTAMPTOOL_MODE_ADDJOB,
    … …  
    3838    PSTAMPTOOL_MODE_PENDINGJOB,
    3939    PSTAMPTOOL_MODE_JOBRESULT,
    40     PSTAMPTOOL_MODE_PROCESSEDJOB,
     40    PSTAMPTOOL_MODE_UPDATEJOB,
    4141} pstamptoolMode;
    4242

  • trunk/ippTools/src/pstamptoolConfig.c

    r18974 r19219  
    5252    // -datastore
    5353    psMetadata *datastoreArgs = psMetadataAlloc();
    54     psMetadataAddStr(datastoreArgs, PS_LIST_TAIL, "-ds_id", 0,            "define ds_id", NULL);
     54    psMetadataAddS64(datastoreArgs, PS_LIST_TAIL, "-ds_id", 0,            "define ds_id", 0);
    5555    psMetadataAddBool(datastoreArgs, PS_LIST_TAIL, "-simple", 0,            "use the simple output format", false);
    5656
    5757    // -moddatastore
    5858    psMetadata *moddatastoreArgs = psMetadataAlloc();
    59     psMetadataAddStr(moddatastoreArgs, PS_LIST_TAIL, "-ds_id", 0,            "define ds_id", "0");
     59    psMetadataAddS64(moddatastoreArgs, PS_LIST_TAIL, "-ds_id", 0,            "define ds_id", 0);
    6060    psMetadataAddStr(moddatastoreArgs, PS_LIST_TAIL, "-last_fileset", 0,            "define storage uri", NULL);
    6161    psMetadataAddStr(moddatastoreArgs, PS_LIST_TAIL, "-state", 0,            "define storage uri", NULL);
    … …  
    6464    psMetadata *addreqArgs = psMetadataAlloc();
    6565    psMetadataAddStr(addreqArgs, PS_LIST_TAIL, "-uri", 0,            "define request file uri", NULL);
    66     psMetadataAddS32(addreqArgs, PS_LIST_TAIL, "-ds_id", 0,            "define request ds_id", 0);
     66    psMetadataAddS64(addreqArgs, PS_LIST_TAIL, "-ds_id", 0,            "define request ds_id", 0);
    6767    // psMetadataAddStr(addreqArgs, PS_LIST_TAIL, "-out_fileset", 0,            "define request output_fileset", NULL);
    6868
    6969    // -pendingreq
    7070    psMetadata *pendingreqArgs = psMetadataAlloc();
    71     psMetadataAddStr(pendingreqArgs, PS_LIST_TAIL, "-req_id", 0,            "define req_id", NULL);
     71    psMetadataAddS64(pendingreqArgs, PS_LIST_TAIL, "-req_id", 0,            "define req_id", 0);
    7272    psMetadataAddU64(pendingreqArgs, PS_LIST_TAIL, "-limit",  0,            "limit result set to N items", 0);
    7373    psMetadataAddBool(pendingreqArgs, PS_LIST_TAIL, "-simple", 0,            "use the simple output format", false);
    … …  
    7575    // -listreq
    7676    psMetadata *listreqArgs = psMetadataAlloc();
    77     psMetadataAddStr(listreqArgs, PS_LIST_TAIL, "-req_id", 0,            "define req_id", NULL);
     77    psMetadataAddS64(listreqArgs, PS_LIST_TAIL, "-req_id", 0,            "define req_id", 0);
    7878    psMetadataAddU64(listreqArgs, PS_LIST_TAIL, "-limit",  0,            "limit result set to N items", 0);
    7979    psMetadataAddBool(listreqArgs, PS_LIST_TAIL, "-simple", 0,            "use the simple output format", false);
    … …  
    8484    psMetadataAddBool(completedreqArgs, PS_LIST_TAIL, "-simple", 0,            "use the simple output format", false);
    8585
    86     // -processedreq
    87     psMetadata *processedreqArgs = psMetadataAlloc();
    88     psMetadataAddStr(processedreqArgs, PS_LIST_TAIL, "-req_id", 0,            "req_id for which to change state", NULL);
    89     psMetadataAddStr(processedreqArgs, PS_LIST_TAIL, "-state", 0,            "new state", NULL);
    90     psMetadataAddStr(processedreqArgs, PS_LIST_TAIL, "-outProduct", 0,            "define request outProduct", NULL);
    91     psMetadataAddStr(processedreqArgs, PS_LIST_TAIL, "-fault", 0,            "define request fault code", NULL);
    92     psMetadataAddStr(processedreqArgs, PS_LIST_TAIL, "-uri", 0,            "define the uri", NULL);
    93     psMetadataAddStr(processedreqArgs, PS_LIST_TAIL, "-name", 0,            "define the name", NULL);
    94     psMetadataAddStr(processedreqArgs, PS_LIST_TAIL, "-reqType", 0,            "define the reqType", NULL);
     86    // -updatereq
     87    psMetadata *updatereqArgs = psMetadataAlloc();
     88    psMetadataAddS64(updatereqArgs, PS_LIST_TAIL, "-req_id", 0,            "req_id for which to change state", 0);
     89    psMetadataAddStr(updatereqArgs, PS_LIST_TAIL, "-state", 0,            "new state", NULL);
     90    psMetadataAddStr(updatereqArgs, PS_LIST_TAIL, "-outProduct", 0,            "define request outProduct", NULL);
     91    psMetadataAddStr(updatereqArgs, PS_LIST_TAIL, "-fault", 0,            "define request fault code", NULL);
     92    psMetadataAddStr(updatereqArgs, PS_LIST_TAIL, "-uri", 0,            "define the uri", NULL);
     93    psMetadataAddStr(updatereqArgs, PS_LIST_TAIL, "-name", 0,            "define the name", NULL);
     94    psMetadataAddStr(updatereqArgs, PS_LIST_TAIL, "-reqType", 0,            "define the reqType", NULL);
    9595
    9696    // -revertreq
    … …  
    101101    psMetadata *addjobArgs = psMetadataAlloc();
    102102    psMetadataAddStr(addjobArgs, PS_LIST_TAIL, "-uri", 0,            "define job file uri", NULL);
    103     psMetadataAddStr(addjobArgs, PS_LIST_TAIL, "-req_id", 0,            "define job req_id", NULL);
     103    psMetadataAddS64(addjobArgs, PS_LIST_TAIL, "-req_id", 0,            "define job req_id", 0);
    104104    psMetadataAddStr(addjobArgs, PS_LIST_TAIL, "-rownum", 0,            "define job rownum", NULL);
    105105    psMetadataAddStr(addjobArgs, PS_LIST_TAIL, "-job_type", 0,            "define job job_type", "stamp");
    … …  
    107107    psMetadataAddStr(addjobArgs, PS_LIST_TAIL, "-args", 0,            "define job args", NULL);
    108108    psMetadataAddStr(addjobArgs, PS_LIST_TAIL, "-state", 0,            "new state", "run");
    109     // psMetadataAddStr(addjobArgs, PS_LIST_TAIL, "-result", 0,            "new result", "0");
     109    psMetadataAddS64(addjobArgs, PS_LIST_TAIL, "-exp_id", 0,           "exposure id", 0);
    110110    psMetadataAddStr(addjobArgs, PS_LIST_TAIL, "-fault", 0,            "new result", NULL);
    111111
    112112    // -listjob
    113113    psMetadata *listjobArgs = psMetadataAlloc();
    114     psMetadataAddStr(listjobArgs, PS_LIST_TAIL, "-req_id", 0,            "define request", NULL);
    115     psMetadataAddStr(listjobArgs, PS_LIST_TAIL, "-job_id", 0,            "define job", NULL);
     114    psMetadataAddS64(listjobArgs, PS_LIST_TAIL, "-req_id", 0,            "define request", 0);
     115    psMetadataAddS64(listjobArgs, PS_LIST_TAIL, "-job_id", 0,            "define job", 0);
    116116    psMetadataAddU64(listjobArgs, PS_LIST_TAIL, "-limit",  0,            "limit result set to N items", 0);
    117117    psMetadataAddBool(listjobArgs, PS_LIST_TAIL, "-simple", 0,            "use the simple output format", false);
    … …  
    120120    psMetadata *pendingjobArgs = psMetadataAlloc();
    121121    psMetadataAddS64(pendingjobArgs, PS_LIST_TAIL, "-job_id", 0,            "define job", 0);
     122    psMetadataAddS64(pendingjobArgs, PS_LIST_TAIL, "-req_id", 0,            "define request", 0);
    122123    psMetadataAddU64(pendingjobArgs, PS_LIST_TAIL, "-limit",  0,            "limit result set to N items", 0);
    123124    psMetadataAddBool(pendingjobArgs, PS_LIST_TAIL, "-simple", 0,            "use the simple output format", false);
    124125
    125     // -processedjob
    126     psMetadata *processedjobArgs = psMetadataAlloc();
    127     psMetadataAddStr(processedjobArgs, PS_LIST_TAIL, "-job_id", 0,            "req_id for which to change state", NULL);
    128     psMetadataAddStr(processedjobArgs, PS_LIST_TAIL, "-state", 0,            "new state", NULL);
    129     // psMetadataAddStr(processedjobArgs, PS_LIST_TAIL, "-result", 0,            "new result", NULL);
    130     psMetadataAddStr(processedjobArgs, PS_LIST_TAIL, "-fault", 0,            "new result", NULL);
     126    // -updatejob
     127    psMetadata *updatejobArgs = psMetadataAlloc();
     128    psMetadataAddS64(updatejobArgs, PS_LIST_TAIL, "-job_id", 0,            "req_id for which to change state", 0);
     129    psMetadataAddStr(updatejobArgs, PS_LIST_TAIL, "-state", 0,            "new state", NULL);
     130    // psMetadataAddStr(updatejobArgs, PS_LIST_TAIL, "-result", 0,            "new result", NULL);
     131    psMetadataAddStr(updatejobArgs, PS_LIST_TAIL, "-fault", 0,            "new result", NULL);
    131132
    132133    psMetadata *argSets = psMetadataAlloc();
    … …  
    135136    PXOPT_ADD_MODE("-addreq",          "", PSTAMPTOOL_MODE_ADDREQ,       addreqArgs);
    136137    PXOPT_ADD_MODE("-pendingreq",      "", PSTAMPTOOL_MODE_PENDINGREQ,   pendingreqArgs);
    137     PXOPT_ADD_MODE("-processedreq",    "", PSTAMPTOOL_MODE_PROCESSEDREQ, processedreqArgs);
     138    PXOPT_ADD_MODE("-updatereq",    "", PSTAMPTOOL_MODE_UPDATEREQ, updatereqArgs);
    138139    PXOPT_ADD_MODE("-listreq",         "", PSTAMPTOOL_MODE_LISTREQ,      listreqArgs);
    139140    PXOPT_ADD_MODE("-completedreq",    "", PSTAMPTOOL_MODE_COMPLETEDREQ, completedreqArgs);
    … …  
    143144    PXOPT_ADD_MODE("-listjob",         "", PSTAMPTOOL_MODE_LISTJOB,      listjobArgs);
    144145    PXOPT_ADD_MODE("-pendingjob",      "", PSTAMPTOOL_MODE_PENDINGJOB,   pendingjobArgs);
    145     PXOPT_ADD_MODE("-processedjob",    "", PSTAMPTOOL_MODE_PROCESSEDJOB, processedjobArgs);
     146    PXOPT_ADD_MODE("-updatejob",    "", PSTAMPTOOL_MODE_UPDATEJOB, updatejobArgs);
    146147
    147148    PXOPT_ADD_MODE("-adddatastore",    "", PSTAMPTOOL_MODE_ADDDATASTORE, adddatastoreArgs);
Note: See TracChangeset for help on using the changeset viewer.