IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Ignore:
Timestamp:
Feb 22, 2008, 11:49:29 AM (18 years ago)
Author:
jhoblitt
Message:

update

File:
1 edited

Legend:

Unmodified
Added
Removed

  • trunk/ippdb/src/ippdb.c

    r16587 r16616  
    2478924789static void pstampDataStoreRowFree(pstampDataStoreRow *object);
    2479024790
    24791 pstampDataStoreRow *pstampDataStoreRowAlloc(psS64 ds_id, const char *uri, const char *lastFileset, const char *state)
     24791pstampDataStoreRow *pstampDataStoreRowAlloc(psS64 ds_id, const char *state, const char *lastFileset, const char *outProduct, const char *uri)
    2479224792{
    2479324793    pstampDataStoreRow *_object;
    … …  
    2479724797
    2479824798    _object->ds_id = ds_id;
     24799    _object->state = psStringCopy(state);
     24800    _object->lastFileset = psStringCopy(lastFileset);
     24801    _object->outProduct = psStringCopy(outProduct);
    2479924802    _object->uri = psStringCopy(uri);
    24800     _object->lastFileset = psStringCopy(lastFileset);
    24801     _object->state = psStringCopy(state);
    2480224803
    2480324804    return _object;
    … …  
    2480624807static void pstampDataStoreRowFree(pstampDataStoreRow *object)
    2480724808{
     24809    psFree(object->state);
     24810    psFree(object->lastFileset);
     24811    psFree(object->outProduct);
    2480824812    psFree(object->uri);
    24809     psFree(object->lastFileset);
    24810     psFree(object->state);
    2481124813}
    2481224814
    … …  
    2481924821        return false;
    2482024822    }
     24823    if (!psMetadataAdd(md, PS_LIST_TAIL, "state", PS_DATA_STRING, NULL, "64")) {
     24824        psError(PS_ERR_UNKNOWN, false, "failed to add item state");
     24825        psFree(md);
     24826        return false;
     24827    }
     24828    if (!psMetadataAdd(md, PS_LIST_TAIL, "lastFileset", PS_DATA_STRING, NULL, "64")) {
     24829        psError(PS_ERR_UNKNOWN, false, "failed to add item lastFileset");
     24830        psFree(md);
     24831        return false;
     24832    }
     24833    if (!psMetadataAdd(md, PS_LIST_TAIL, "outProduct", PS_DATA_STRING, "UNIQUE", "64")) {
     24834        psError(PS_ERR_UNKNOWN, false, "failed to add item outProduct");
     24835        psFree(md);
     24836        return false;
     24837    }
    2482124838    if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, "255")) {
    2482224839        psError(PS_ERR_UNKNOWN, false, "failed to add item uri");
    … …  
    2482424841        return false;
    2482524842    }
    24826     if (!psMetadataAdd(md, PS_LIST_TAIL, "lastFileset", PS_DATA_STRING, NULL, "64")) {
    24827         psError(PS_ERR_UNKNOWN, false, "failed to add item lastFileset");
    24828         psFree(md);
    24829         return false;
    24830     }
    24831     if (!psMetadataAdd(md, PS_LIST_TAIL, "state", PS_DATA_STRING, NULL, "64")) {
    24832         psError(PS_ERR_UNKNOWN, false, "failed to add item state");
    24833         psFree(md);
    24834         return false;
    24835     }
    2483624843
    2483724844    bool status = psDBCreateTable(dbh, PSTAMPDATASTORE_TABLE_NAME, md);
    … …  
    2484724854}
    2484824855
    24849 bool pstampDataStoreInsert(psDB * dbh, psS64 ds_id, const char *uri, const char *lastFileset, const char *state)
     24856bool pstampDataStoreInsert(psDB * dbh, psS64 ds_id, const char *state, const char *lastFileset, const char *outProduct, const char *uri)
    2485024857{
    2485124858    psMetadata *md = psMetadataAlloc();
    … …  
    2485524862        return false;
    2485624863    }
     24864    if (!psMetadataAdd(md, PS_LIST_TAIL, "state", PS_DATA_STRING, NULL, state)) {
     24865        psError(PS_ERR_UNKNOWN, false, "failed to add item state");
     24866        psFree(md);
     24867        return false;
     24868    }
     24869    if (!psMetadataAdd(md, PS_LIST_TAIL, "lastFileset", PS_DATA_STRING, NULL, lastFileset)) {
     24870        psError(PS_ERR_UNKNOWN, false, "failed to add item lastFileset");
     24871        psFree(md);
     24872        return false;
     24873    }
     24874    if (!psMetadataAdd(md, PS_LIST_TAIL, "outProduct", PS_DATA_STRING, NULL, outProduct)) {
     24875        psError(PS_ERR_UNKNOWN, false, "failed to add item outProduct");
     24876        psFree(md);
     24877        return false;
     24878    }
    2485724879    if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, uri)) {
    2485824880        psError(PS_ERR_UNKNOWN, false, "failed to add item uri");
    24859         psFree(md);
    24860         return false;
    24861     }
    24862     if (!psMetadataAdd(md, PS_LIST_TAIL, "lastFileset", PS_DATA_STRING, NULL, lastFileset)) {
    24863         psError(PS_ERR_UNKNOWN, false, "failed to add item lastFileset");
    24864         psFree(md);
    24865         return false;
    24866     }
    24867     if (!psMetadataAdd(md, PS_LIST_TAIL, "state", PS_DATA_STRING, NULL, state)) {
    24868         psError(PS_ERR_UNKNOWN, false, "failed to add item state");
    2486924881        psFree(md);
    2487024882        return false;
    … …  
    2489324905bool pstampDataStoreInsertObject(psDB *dbh, pstampDataStoreRow *object)
    2489424906{
    24895     return pstampDataStoreInsert(dbh, object->ds_id, object->uri, object->lastFileset, object->state);
     24907    return pstampDataStoreInsert(dbh, object->ds_id, object->state, object->lastFileset, object->outProduct, object->uri);
    2489624908}
    2489724909
    … …  
    2497124983        return false;
    2497224984    }
     24985    if (!psMetadataAdd(md, PS_LIST_TAIL, "state", PS_DATA_STRING, NULL, object->state)) {
     24986        psError(PS_ERR_UNKNOWN, false, "failed to add item state");
     24987        psFree(md);
     24988        return false;
     24989    }
     24990    if (!psMetadataAdd(md, PS_LIST_TAIL, "lastFileset", PS_DATA_STRING, NULL, object->lastFileset)) {
     24991        psError(PS_ERR_UNKNOWN, false, "failed to add item lastFileset");
     24992        psFree(md);
     24993        return false;
     24994    }
     24995    if (!psMetadataAdd(md, PS_LIST_TAIL, "outProduct", PS_DATA_STRING, NULL, object->outProduct)) {
     24996        psError(PS_ERR_UNKNOWN, false, "failed to add item outProduct");
     24997        psFree(md);
     24998        return false;
     24999    }
    2497325000    if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, object->uri)) {
    2497425001        psError(PS_ERR_UNKNOWN, false, "failed to add item uri");
    … …  
    2497625003        return false;
    2497725004    }
    24978     if (!psMetadataAdd(md, PS_LIST_TAIL, "lastFileset", PS_DATA_STRING, NULL, object->lastFileset)) {
    24979         psError(PS_ERR_UNKNOWN, false, "failed to add item lastFileset");
    24980         psFree(md);
    24981         return false;
    24982     }
    24983     if (!psMetadataAdd(md, PS_LIST_TAIL, "state", PS_DATA_STRING, NULL, object->state)) {
    24984         psError(PS_ERR_UNKNOWN, false, "failed to add item state");
    24985         psFree(md);
    24986         return false;
    24987     }
    2498825005
    2498925006
    … …  
    2500025017        return false;
    2500125018    }
     25019    char* state = psMetadataLookupPtr(&status, md, "state");
     25020    if (!status) {
     25021        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item state");
     25022        return false;
     25023    }
     25024    char* lastFileset = psMetadataLookupPtr(&status, md, "lastFileset");
     25025    if (!status) {
     25026        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item lastFileset");
     25027        return false;
     25028    }
     25029    char* outProduct = psMetadataLookupPtr(&status, md, "outProduct");
     25030    if (!status) {
     25031        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item outProduct");
     25032        return false;
     25033    }
    2500225034    char* uri = psMetadataLookupPtr(&status, md, "uri");
    2500325035    if (!status) {
    … …  
    2500525037        return false;
    2500625038    }
    25007     char* lastFileset = psMetadataLookupPtr(&status, md, "lastFileset");
    25008     if (!status) {
    25009         psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item lastFileset");
    25010         return false;
    25011     }
    25012     char* state = psMetadataLookupPtr(&status, md, "state");
    25013     if (!status) {
    25014         psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item state");
    25015         return false;
    25016     }
    25017 
    25018     return pstampDataStoreRowAlloc(ds_id, uri, lastFileset, state);
     25039
     25040    return pstampDataStoreRowAlloc(ds_id, state, lastFileset, outProduct, uri);
    2501925041}
    2502025042psArray *pstampDataStoreSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit)
    … …  
    2513425156static void pstampRequestRowFree(pstampRequestRow *object);
    2513525157
    25136 pstampRequestRow *pstampRequestRowAlloc(psS64 req_id, psS64 ds_id, const char *state, const char *uri)
     25158pstampRequestRow *pstampRequestRowAlloc(psS64 req_id, psS64 ds_id, const char *state, const char *outFileset, const char *uri)
    2513725159{
    2513825160    pstampRequestRow *_object;
    … …  
    2514425166    _object->ds_id = ds_id;
    2514525167    _object->state = psStringCopy(state);
     25168    _object->outFileset = psStringCopy(outFileset);
    2514625169    _object->uri = psStringCopy(uri);
    2514725170
    … …  
    2515225175{
    2515325176    psFree(object->state);
     25177    psFree(object->outFileset);
    2515425178    psFree(object->uri);
    2515525179}
    … …  
    2517325197        return false;
    2517425198    }
     25199    if (!psMetadataAdd(md, PS_LIST_TAIL, "outFileset", PS_DATA_STRING, "UNIQUE", "64")) {
     25200        psError(PS_ERR_UNKNOWN, false, "failed to add item outFileset");
     25201        psFree(md);
     25202        return false;
     25203    }
    2517525204    if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, "255")) {
    2517625205        psError(PS_ERR_UNKNOWN, false, "failed to add item uri");
    … …  
    2519125220}
    2519225221
    25193 bool pstampRequestInsert(psDB * dbh, psS64 req_id, psS64 ds_id, const char *state, const char *uri)
     25222bool pstampRequestInsert(psDB * dbh, psS64 req_id, psS64 ds_id, const char *state, const char *outFileset, const char *uri)
    2519425223{
    2519525224    psMetadata *md = psMetadataAlloc();
    … …  
    2520625235    if (!psMetadataAdd(md, PS_LIST_TAIL, "state", PS_DATA_STRING, NULL, state)) {
    2520725236        psError(PS_ERR_UNKNOWN, false, "failed to add item state");
     25237        psFree(md);
     25238        return false;
     25239    }
     25240    if (!psMetadataAdd(md, PS_LIST_TAIL, "outFileset", PS_DATA_STRING, NULL, outFileset)) {
     25241        psError(PS_ERR_UNKNOWN, false, "failed to add item outFileset");
    2520825242        psFree(md);
    2520925243        return false;
    … …  
    2523725271bool pstampRequestInsertObject(psDB *dbh, pstampRequestRow *object)
    2523825272{
    25239     return pstampRequestInsert(dbh, object->req_id, object->ds_id, object->state, object->uri);
     25273    return pstampRequestInsert(dbh, object->req_id, object->ds_id, object->state, object->outFileset, object->uri);
    2524025274}
    2524125275
    … …  
    2532525359        return false;
    2532625360    }
     25361    if (!psMetadataAdd(md, PS_LIST_TAIL, "outFileset", PS_DATA_STRING, NULL, object->outFileset)) {
     25362        psError(PS_ERR_UNKNOWN, false, "failed to add item outFileset");
     25363        psFree(md);
     25364        return false;
     25365    }
    2532725366    if (!psMetadataAdd(md, PS_LIST_TAIL, "uri", PS_DATA_STRING, NULL, object->uri)) {
    2532825367        psError(PS_ERR_UNKNOWN, false, "failed to add item uri");
    … …  
    2535425393        return false;
    2535525394    }
     25395    char* outFileset = psMetadataLookupPtr(&status, md, "outFileset");
     25396    if (!status) {
     25397        psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item outFileset");
     25398        return false;
     25399    }
    2535625400    char* uri = psMetadataLookupPtr(&status, md, "uri");
    2535725401    if (!status) {
    … …  
    2536025404    }
    2536125405
    25362     return pstampRequestRowAlloc(req_id, ds_id, state, uri);
     25406    return pstampRequestRowAlloc(req_id, ds_id, state, outFileset, uri);
    2536325407}
    2536425408psArray *pstampRequestSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit)
Note: See TracChangeset for help on using the changeset viewer.