IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

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

File:
1 edited

Legend:

Unmodified
Added
Removed

  • 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)) {
Note: See TracChangeset for help on using the changeset viewer.