IPP Software Navigation Tools IPP Links Communication Pan-STARRS Links

Ignore:
Timestamp:
May 3, 2010, 8:50:52 AM (16 years ago)
Author:
eugene
Message:

updates from trunk

Location:
branches/simtest_nebulous_branches
Files:
3 edited

Legend:

Unmodified
Added
Removed

  • branches/simtest_nebulous_branches

  • branches/simtest_nebulous_branches/ippTools/src

    • Property svn:ignore

      •  

        old new  
         1*.la
         2*.lo
        13.deps
        24.gdb_history
        … …  
        46Makefile
        57Makefile.in
         8addtool
         9caltool
         10camtool
         11chiptool
        612config.h
        713config.h.in
        8 stamp-h1
        9 *.la
        10 *.lo
         14detselect
         15dettool
         16difftool
         17disttool
         18dqstatstool
         19faketool
         20flatcorr
         21guidetool
         22magicdstool
         23magictool
         24pstamptool
         25pubtool
         26pxadmin
         27pxdata.c
         28pxinject
        1129pxtoolsErrorCodes.c
        1230pxtoolsErrorCodes.h
        13 pxadmin
        14 pxinject
        15 pztool
        1631pzgetexp
        1732pzgetimfiles
         33pztool
         34receivetool
        1835regtool
        19 guidetool
        20 chiptool
        21 camtool
         36stacktool
         37stamp-h1
        2238warptool
        23 difftool
        24 stacktool
        25 faketool
        26 dettool
        27 detselect
        28 pxdata.c
        29 magictool
        30 magicdstool
        31 caltool
        32 flatcorr
        33 pstamptool
        34 disttool
        35 receivetool
        36 
        37 pubtool

  • branches/simtest_nebulous_branches/ippTools/src/dettool.c

    r24866 r27840  
    9494        MODECASE(DETTOOL_MODE_PENDINGCLEANUP_PROCESSEDEXP, pendingcleanup_processedexpMode);
    9595        MODECASE(DETTOOL_MODE_DONECLEANUP_PROCESSEDEXP, donecleanup_processedexpMode);
     96        MODECASE(DETTOOL_MODE_UPDATESTATE_PROCESSED, updatestateprocessedMode);
    9697        // stacked
    9798        MODECASE(DETTOOL_MODE_TOSTACKED,        tostackedMode);
    … …  
    142143        MODECASE(DETTOOL_MODE_PENDINGCLEANUP_RESIDEXP, pendingcleanup_residexpMode);
    143144        MODECASE(DETTOOL_MODE_DONECLEANUP_RESIDEXP, donecleanup_residexpMode);
     145        MODECASE(DETTOOL_MODE_UPDATESTATE_RESID, updatestateresidMode);
    144146        // detrunsummary
    145147        MODECASE(DETTOOL_MODE_TODETRUNSUMMARY,  todetrunsummaryMode);
    … …  
    150152        MODECASE(DETTOOL_MODE_UPDATEDETRUN,     updatedetrunMode);
    151153        MODECASE(DETTOOL_MODE_RERUN,            rerunMode);
     154        MODECASE(DETTOOL_MODE_PENDINGCLEANUP_DETRUNSUMMARY, pendingcleanup_detrunsummaryMode);
    152155        // register
    153156        MODECASE(DETTOOL_MODE_REGISTER_DETREND, register_detrendMode);
    … …  
    184187    psString query = pxDataGet("dettool_pending.sql");
    185188    if (!query) {
    186         psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
    187         return false;
    188     }
    189    
     189        psError(PXTOOLS_ERR_SYS, false, "failed to retreive SQL statement");
     190        return false;
     191    }
     192
    190193    psMetadata *where = psMetadataAlloc();
    191194    PXOPT_COPY_S64(config->args, where, "-exp_id", "exp_id", "==");
    … …  
    257260        psError(PS_ERR_UNKNOWN, false, "verify mode requires both -ref_det_id and -ref_iter");
    258261        return false;
    259     } 
     262    }
    260263    if (strcmp(mode, "verify") && ((ref_det_id != 0) || (ref_iter != -1))) {
    261264        psError(PS_ERR_UNKNOWN, false, "master mode cannot have -ref_det_id or -ref_iter set");
    262265        return false;
    263     } 
    264        
     266    }
     267
    265268    PXOPT_LOOKUP_STR(camera, config->args, "-inst", false, false);
    266269    PXOPT_LOOKUP_STR(telescope, config->args, "-telescope", false, false);
    … …  
    307310        psMetadataItem *mItem = NULL;
    308311        while ((mItem = psListGetAndIncrement(iter))) {
    309             psS64 exp_id = mItem->data.S64;
     312            psS64 exp_id = mItem->data.S64;
    310313            if (!psMetadataAddS64(where, PS_LIST_TAIL, "exp_id", PS_META_DUPLICATE_OK, "==", exp_id)) {
    311314                psError(PS_ERR_UNKNOWN, false, "failed to add item exp_id");
    … …  
    316319        }
    317320        psFree(iter);
    318     } 
     321    }
    319322    if (item->type == PS_DATA_S64) {
    320         psS64 exp_id = item->data.S64;
    321         if (!psMetadataAddS64(where, PS_LIST_TAIL, "exp_id", PS_META_DUPLICATE_OK, "==", exp_id)) {
    322             psError(PS_ERR_UNKNOWN, false, "failed to add item exp_id");
    323             psFree(where);
    324             return false;
    325         }
    326     } 
     323        psS64 exp_id = item->data.S64;
     324        if (!psMetadataAddS64(where, PS_LIST_TAIL, "exp_id", PS_META_DUPLICATE_OK, "==", exp_id)) {
     325            psError(PS_ERR_UNKNOWN, false, "failed to add item exp_id");
     326            psFree(where);
     327            return false;
     328        }
     329    }
    327330
    328331    if (psListLength(where->list) < 1) {
    … …  
    504507        psError(PS_ERR_UNKNOWN, false, "verify mode requires both -ref_det_id and -ref_iter");
    505508        return false;
    506     } 
     509    }
    507510    if (strcmp(mode, "verify") && ((ref_det_id != 0) || (ref_iter != -1))) {
    508511        psError(PS_ERR_UNKNOWN, false, "master mode cannot have -ref_det_id or -ref_iter set");
    509512        return false;
    510     } 
     513    }
    511514
    512515    PXOPT_LOOKUP_STR(filelevel, config->args, "-filelevel", false, false);
    … …  
    549552    PXOPT_COPY_F32(config->args, where, "-select_airmass_max", "airmass", "<=");
    550553    PXOPT_COPY_F32(config->args, where, "-select_sat_pixel_frac_max", "sat_pixel_frac", "<=");
     554    PXOPT_COPY_F32(config->args, where, "-select_sat_pixel_frac_min", "sat_pixel_frac", ">=");
    551555    PXOPT_COPY_F32(config->args, where, "-select_exp_time_min", "exp_time", ">=");
    552556    PXOPT_COPY_F32(config->args, where, "-select_exp_time_max", "exp_time", "<=");
    … …  
    672676                 label,
    673677                 ref_det_id,
    674                 ref_iter
     678                ref_iter
    675679        );
    676680    psS64 det_id = psDBLastInsertID(config->dbh);
    … …  
    741745{
    742746    PS_ASSERT_PTR_NON_NULL(config, false);
    743    
     747
    744748    // XXX this mode is not well-tested: probably need to specify iteration here
    745749    PXOPT_LOOKUP_S64(det_id, config->args, "-det_id", true, false); // required
    … …  
    758762        psError(PS_ERR_UNKNOWN, false, "verify mode requires both -ref_det_id and -ref_iter");
    759763        return false;
    760     } 
     764    }
    761765    if (strcmp(mode, "verify") && ((ref_det_id != 0) || (ref_iter != -1))) {
    762766        psError(PS_ERR_UNKNOWN, false, "master mode cannot have -ref_det_id or -ref_iter set");
    763767        return false;
    764     } 
     768    }
    765769
    766770    // the new detRun may have different values for these limits:
    … …  
    816820
    817821    if (iteration < 0) {
    818         iteration = detRun->iteration;
     822        iteration = detRun->iteration;
    819823    }
    820824
    … …  
    976980    psString query = pxDataGet("dettool_definebydetrun.sql");
    977981    if (!query) {
    978         psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     982        psError(PXTOOLS_ERR_SYS, false, "failed to retreive SQL statement");
    979983        return false;
    980984    }
    … …  
    988992
    989993    if (only_accepted) {
    990         psStringAppend(&query, " AND accept = 1");
     994        psStringAppend(&query, " AND accept = 1");
    991995    }
    992996
    … …  
    10671071    psString query = pxDataGet("dettool_runs.sql");
    10681072    if (!query) {
    1069         psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     1073        psError(PXTOOLS_ERR_SYS, false, "failed to retreive SQL statement");
    10701074        return false;
    10711075    }
    … …  
    11371141    psString query = pxDataGet("dettool_childlessrun.sql");
    11381142    if (!query) {
    1139         psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     1143        psError(PXTOOLS_ERR_SYS, false, "failed to retreive SQL statement");
    11401144        psFree(where);
    11411145        return false;
    … …  
    12111215    psString query = pxDataGet("dettool_input.sql");
    12121216    if (!query) {
    1213         psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     1217        psError(PXTOOLS_ERR_SYS, false, "failed to retreive SQL statement");
    12141218        psFree(where);
    12151219        return false;
    … …  
    12631267    psString query = pxDataGet("dettool_raw.sql");
    12641268    if (!query) {
    1265         psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     1269        psError(PXTOOLS_ERR_SYS, false, "failed to retreive SQL statement");
    12661270        return false;
    12671271    }
    … …  
    13371341}
    13381342
    1339 // used by updatedetrunMode 
     1343// used by updatedetrunMode
    13401344bool startNewIteration(pxConfig *config, psS64 det_id)
    13411345{
    … …  
    13441348    psString query = pxDataGet("dettool_start_new_iteration.sql");
    13451349    if (!query) {
    1346         psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     1350        psError(PXTOOLS_ERR_SYS, false, "failed to retreive SQL statement");
    13471351        return false;
    13481352    }
    … …  
    15631567        }
    15641568        detInputExpRow *newInputExp = detInputExpRowAlloc(
    1565             det_id,
     1569            det_id,
    15661570            newIteration,
    15671571            inputExp->exp_id,
    … …  
    16611665                      solang_max,
    16621666                      label,
    1663                       ref_det_id,
    1664                       ref_iter
     1667                      ref_det_id,
     1668                      ref_iter
    16651669            )) {
    16661670        psError(PS_ERR_UNKNOWN, false, "database error");
    … …  
    17121716{
    17131717    PS_ASSERT_PTR_NON_NULL(config, false);
    1714    
     1718
    17151719    PXOPT_LOOKUP_S64(det_id, config->args, "-det_id", true, false); // required
    17161720    PXOPT_LOOKUP_STR(class_id, config->args, "-class_id", true, false); // required
    … …  
    17271731
    17281732    if (!detRegisteredImfileInsert(config->dbh,
    1729                                    det_id,
    1730                                    0,  // the iteration is fixed at 0
    1731                                    class_id,
    1732                                    uri,
    1733                                    bg,
    1734                                    bg_stdev,
    1735                                    bg_mean_stdev,
    1736                                    user_1,
    1737                                    user_2,
    1738                                    user_3,
    1739                                    user_4,
    1740                                    user_5,
    1741                                    path_base,
    1742                                    "full",                                 
    1743                                    0       // fault code
    1744             )) {
     1733                                   det_id,
     1734                                   0,  // the iteration is fixed at 0
     1735                                   class_id,
     1736                                   uri,
     1737                                   bg,
     1738                                   bg_stdev,
     1739                                   bg_mean_stdev,
     1740                                   user_1,
     1741                                   user_2,
     1742                                   user_3,
     1743                                   user_4,
     1744                                   user_5,
     1745                                   path_base,
     1746                                   "full",
     1747                                   0       // fault code
     1748            )) {
    17451749        psError(PS_ERR_UNKNOWN, false, "database error");
    17461750        return false;
    … …  
    18271831    if (!strcmp(data_state, "drop")) return true;
    18281832    if (!strcmp(data_state, "register")) return true;
     1833    // These are valid data states, and are necessary for the cleanup to work correctly.
     1834    if (!strcmp(data_state, "full")) return true;
     1835    if (!strcmp(data_state, "goto_cleaned")) return true;
     1836    if (!strcmp(data_state, "goto_scrubbed")) return true;
     1837    if (!strcmp(data_state, "goto_purged")) return true;
     1838    if (!strcmp(data_state, "cleaned")) return true;
     1839    if (!strcmp(data_state, "scrubbed")) return true;
     1840    if (!strcmp(data_state, "purged")) return true;
     1841    if (!strcmp(data_state, "error_cleaned")) return true;
     1842    if (!strcmp(data_state, "error_scrubbed")) return true;
     1843    if (!strcmp(data_state, "error_purged")) return true;
    18291844
    18301845    psError(PS_ERR_UNKNOWN, true, "invalid data state: %s", data_state);
    … …  
    18461861
    18471862
    1848 bool setProcessedImfileDataState(pxConfig *config, psS64 det_id, psS64 exp_id, const char *class_id, const char *data_state)
     1863bool setProcessedImfileDataState(pxConfig *config, psMetadata *where, const char *data_state)
    18491864{
    18501865    PS_ASSERT_PTR_NON_NULL(config, false);
     1866    PS_ASSERT_PTR_NON_NULL(where, false);
    18511867    PS_ASSERT_PTR_NON_NULL(data_state, false);
    1852     PS_ASSERT_PTR_NON_NULL(class_id, false);
    18531868
    18541869    if (!isValidDataState (data_state)) return false;
    18551870
    1856     char *query = "UPDATE detProcessedImfile SET data_state = '%s'"
    1857         " WHERE det_id = %" PRId64
    1858         " AND exp_id = %" PRId64
    1859         " AND class_id = '%s'";
    1860     if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, exp_id, class_id)) {
    1861         psError(PS_ERR_UNKNOWN, false,
    1862                 "failed to change state for det_id %" PRId64 ", exp_id %" PRId64 ", class_id %s",
    1863                 det_id, exp_id, class_id);
    1864         return false;
    1865     }
    1866 
    1867     return true;
    1868 }
    1869 
    1870 bool setProcessedExpDataState(pxConfig *config, psS64 det_id, psS64 exp_id, const char *data_state)
     1871    psString query = psStringCopy("UPDATE detProcessedImfile SET data_state = '%s'");
     1872    if (where && psListLength(where->list) > 0) {
     1873      psString whereClause = psDBGenerateWhereSQL(where,NULL);
     1874      psStringAppend(&query," %s",whereClause);
     1875      psFree(whereClause);
     1876    } else {
     1877      psError(PS_ERR_UNKNOWN, true, "search parameters are required");
     1878      return(false);
     1879    }
     1880
     1881    if (!p_psDBRunQueryF(config->dbh, query, data_state)) {
     1882      psFree(query);
     1883      psError(PS_ERR_UNKNOWN, false, "database error");
     1884      return(false);
     1885    }
     1886    psFree(query);
     1887    return(true);
     1888}
     1889
     1890bool setProcessedExpDataState(pxConfig *config, psMetadata *where, const char *data_state)
    18711891{
    18721892    PS_ASSERT_PTR_NON_NULL(config, false);
     1893    PS_ASSERT_PTR_NON_NULL(where, false);
    18731894    PS_ASSERT_PTR_NON_NULL(data_state, false);
    18741895
    18751896    if (!isValidDataState (data_state)) return false;
    18761897
    1877     char *query = "UPDATE detProcessedExp SET data_state = '%s'"
    1878         " WHERE det_id = %" PRId64
    1879         " AND exp_id = %" PRId64;
    1880     if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, exp_id)) {
    1881         psError(PS_ERR_UNKNOWN, false,
    1882                 "failed to change state for det_id %" PRId64 ", exp_id %" PRId64,
    1883                 det_id, exp_id);
    1884         return false;
    1885     }
    1886 
    1887     return true;
    1888 }
    1889 
    1890 
     1898    psString query = psStringCopy("UPDATE detProcessedExp SET data_state = '%s'");
     1899    if (where && psListLength(where->list) > 0) {
     1900      psString whereClause = psDBGenerateWhereSQL(where,NULL);
     1901      psStringAppend(&query," %s",whereClause);
     1902      psFree(whereClause);
     1903    } else {
     1904      psError(PS_ERR_UNKNOWN, true, "search parameters are required");
     1905      return(false);
     1906    }
     1907
     1908    if (!p_psDBRunQueryF(config->dbh, query, data_state)) {
     1909      psFree(query);
     1910      psError(PS_ERR_UNKNOWN, false, "database error");
     1911      return(false);
     1912    }
     1913    psFree(query);
     1914    return(true);
     1915}
     1916
     1917bool setResidImfileDataState(pxConfig *config, psMetadata *where, const char *data_state)
     1918{
     1919    PS_ASSERT_PTR_NON_NULL(config, false);
     1920    PS_ASSERT_PTR_NON_NULL(where,false);
     1921    PS_ASSERT_PTR_NON_NULL(data_state, false);
     1922
     1923    if (!isValidDataState (data_state)) return false;
     1924
     1925    psString query = psStringCopy("UPDATE detResidImfile SET data_state = '%s'");
     1926    if (where && psListLength(where->list) > 0) {
     1927      psString whereClause = psDBGenerateWhereSQL(where,NULL);
     1928      psStringAppend(&query," %s",whereClause);
     1929      psFree(whereClause);
     1930    } else {
     1931      psError(PS_ERR_UNKNOWN, true, "search parameters are required");
     1932      return(false);
     1933    }
     1934
     1935    if (!p_psDBRunQueryF(config->dbh, query, data_state)) {
     1936      psFree(query);
     1937      psError(PS_ERR_UNKNOWN, false, "database error");
     1938      return(false);
     1939    }
     1940    psFree(query);
     1941    return(true);
     1942}
     1943// This function apparently not used anymore.
     1944bool setResidExpDataState(pxConfig *config, psMetadata *where, const char *data_state)
     1945{
     1946    PS_ASSERT_PTR_NON_NULL(config, false);
     1947    PS_ASSERT_PTR_NON_NULL(where,false);
     1948    PS_ASSERT_PTR_NON_NULL(data_state, false);
     1949
     1950    if (!isValidDataState (data_state)) return false;
     1951
     1952    psString query = psStringCopy("UPDATE detResidExp SET data_state = '%s'");
     1953    if (where && psListLength(where->list) > 0) {
     1954      psString whereClause = psDBGenerateWhereSQL(where,NULL);
     1955      psStringAppend(&query," %s",whereClause);
     1956      psFree(whereClause);
     1957    } else {
     1958      psError(PS_ERR_UNKNOWN, true, "search parameters are required");
     1959      return(false);
     1960    }
     1961
     1962    if (!p_psDBRunQueryF(config->dbh, query, data_state)) {
     1963      psFree(query);
     1964      psError(PS_ERR_UNKNOWN, false, "database error");
     1965      return(false);
     1966    }
     1967    psFree(query);
     1968    return(true);
     1969}
     1970
     1971// Not yet updated for cleaning
    18911972bool setStackedImfileDataState(pxConfig *config, psS64 det_id, psS32 iteration, const char *class_id, const char *data_state)
    18921973{
    … …  
    18981979
    18991980    char *query = "UPDATE detStackedImfile SET data_state = '%s'"
    1900         " WHERE det_id = %" PRId64
    1901         " AND iteration = %" PRId32
    1902         " AND class_id = %s";
     1981        " WHERE det_id = %" PRId64
     1982        " AND iteration = %" PRId32
     1983        " AND class_id = '%s'";
    19031984    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration, class_id)) {
    19041985        psError(PS_ERR_UNKNOWN, false,
    1905                 "failed to change state for det_id %" PRId64 ", iteration %" PRId32 "class_id %s", 
    1906                 det_id, iteration, class_id);
     1986                "failed to change state for det_id %" PRId64 ", iteration %" PRId32 "class_id %s",
     1987                det_id, iteration, class_id);
    19071988        return false;
    19081989    }
    … …  
    19202001
    19212002    char *query = "UPDATE detNormalizedStatImfile SET data_state = '%s'"
    1922         " WHERE det_id = %" PRId64
    1923         " AND iteration = %" PRId32
    1924         " AND class_id = %s";
    1925     if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration)) {
     2003        " WHERE det_id = %" PRId64
     2004        " AND iteration = %" PRId32
     2005        " AND class_id = '%s'";
     2006/*     fprintf(stderr,"DETTOOL SAYS: %s\n",query); */
     2007    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration,class_id)) {
    19262008        psError(PS_ERR_UNKNOWN, false,
    1927                 "failed to change state for det_id %" PRId64 ", iteration %" PRId32, 
    1928                 det_id, iteration);
     2009                "failed to change state for det_id %" PRId64 ", iteration %" PRId32,
     2010                det_id, iteration);
    19292011        return false;
    19302012    }
    … …  
    19422024
    19432025    char *query = "UPDATE detNormalizedImfile SET data_state = '%s'"
    1944         " WHERE det_id = %" PRId64
    1945         " AND iteration = %" PRId32
    1946         " AND class_id = %s";
     2026        " WHERE det_id = %" PRId64
     2027        " AND iteration = %" PRId32
     2028        " AND class_id = '%s'";
    19472029    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration, class_id)) {
    19482030        psError(PS_ERR_UNKNOWN, false,
    1949                 "failed to change state for det_id %" PRId64 ", iteration %" PRId32 " class %s", 
    1950                 det_id, iteration, class_id);
     2031                "failed to change state for det_id %" PRId64 ", iteration %" PRId32 " class %s",
     2032                det_id, iteration, class_id);
    19512033        return false;
    19522034    }
    … …  
    19632045
    19642046    char *query = "UPDATE detNormalizedExp SET data_state = '%s'"
    1965         " WHERE det_id = %" PRId64
    1966         " AND iteration = %" PRId32;
     2047        " WHERE det_id = %" PRId64
     2048        " AND iteration = %" PRId32;
    19672049    if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration)) {
    19682050        psError(PS_ERR_UNKNOWN, false,
    1969                 "failed to change state for det_id %" PRId64 ", iteration %" PRId32, 
    1970                 det_id, iteration);
     2051                "failed to change state for det_id %" PRId64 ", iteration %" PRId32,
     2052                det_id, iteration);
    19712053        return false;
    19722054    }
    … …  
    19742056    return true;
    19752057}
    1976 
    1977 bool setResidImfileDataState(pxConfig *config, psS64 det_id, psS32 iteration, psS64 exp_id, const char *class_id, const char *data_state)
    1978 {
    1979     PS_ASSERT_PTR_NON_NULL(config, false);
    1980     PS_ASSERT_PTR_NON_NULL(data_state, false);
    1981     PS_ASSERT_PTR_NON_NULL(class_id, false);
    1982 
    1983     if (!isValidDataState (data_state)) return false;
    1984 
    1985     char *query = "UPDATE detResidImfile SET data_state = '%s'"
    1986         " WHERE det_id = %" PRId64
    1987         " AND iteration = %" PRId32
    1988         " AND exp_id = %" PRId64
    1989         " AND class_id = '%s'";
    1990     if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration, exp_id, class_id)) {
    1991         psError(PS_ERR_UNKNOWN, false,
    1992                 "failed to change state for det_id %" PRId64 ", iteration %" PRId32 ", exp_id %" PRId64 ", class_id %s",
    1993                 det_id, iteration, exp_id, class_id);
    1994         return false;
    1995     }
    1996 
    1997     return true;
    1998 }
    1999 
    2000 bool setResidExpDataState(pxConfig *config, psS64 det_id, psS32 iteration, psS64 exp_id, const char *data_state)
    2001 {
    2002     PS_ASSERT_PTR_NON_NULL(config, false);
    2003     PS_ASSERT_PTR_NON_NULL(data_state, false);
    2004 
    2005     if (!isValidDataState (data_state)) return false;
    2006 
    2007     char *query = "UPDATE detResidExp SET data_state = '%s'"
    2008         " WHERE det_id = %" PRId64
    2009         " AND iteration = %" PRId32
    2010         " AND exp_id = %" PRId64;
    2011     if (!p_psDBRunQueryF(config->dbh, query, data_state, det_id, iteration, exp_id)) {
    2012         psError(PS_ERR_UNKNOWN, false,
    2013                 "failed to change state for det_id %" PRId64 ", iteration %" PRId32 ", exp_id %" PRId64,
    2014                 det_id, iteration, exp_id);
    2015         return false;
    2016     }
    2017 
    2018     return true;
    2019 }
     2058// End not yet modified for cleanup.
    20202059
    20212060bool exportrunMode(pxConfig *config)
    … …  
    20252064    char sqlFilename[80];
    20262065  } ExportTable;
    2027  
     2066
    20282067  int numExportTables = 12;
    20292068
    … …  
    20612100    psString query = pxDataGet(tables[i].sqlFilename);
    20622101    if (!query) {
    2063       psError(PXTOOLS_ERR_DATA, false, "failed to retreive SQL statement");
     2102      psError(PXTOOLS_ERR_SYS, false, "failed to retreive SQL statement");
    20642103      return false;
    20652104    }
    … …  
    21032142    }
    21042143    psFree(output);
    2105  
     2144
    21062145  }
    21072146
    … …  
    21142153{
    21152154  unsigned int nFail;
    2116  
     2155
    21172156  int numImportTables = 11;
    2118  
     2157
    21192158  char tables[11] [80] = {"detInputExp", "detNormalizedExp",
    21202159    "detNormalizedImfile", "detNormalizedStatImfile", "detProcessedExp",
    … …  
    21232162
    21242163  PS_ASSERT_PTR_NON_NULL(config, NULL);
    2125  
     2164
    21262165  PXOPT_LOOKUP_STR(infile, config->args, "-infile", true,  false);
    21272166
    … …  
    21302169  fprintf (stdout, "---- input ----\n");
    21312170  psMetadataPrint (stderr, input, 1);
    2132  
     2171
    21332172  psMetadataItem *item = psMetadataLookup (input, "detRun");
    21342173  psAssert (item, "entry not in input?");
    … …  
    21402179  detRunRow *detRun = detRunObjectFromMetadata (entry->data.md);
    21412180  detRunInsertObject (config->dbh, detRun);
    2142  
     2181
    21432182  // fprintf (stdout, "---- det run ----\n");
    21442183  // psMetadataPrint (stderr, entry->data.md, 1);
    … …  
    21482187    psAssert (item, "entry not in input?");
    21492188    psAssert (item->type == PS_DATA_METADATA_MULTI, "entry not multi?");
    2150  
     2189
    21512190    switch (i) {
    21522191      case 0:
    … …  
    21622201        }
    21632202        break;
    2164  
     2203
    21652204      case 1:
    21662205        for (int i = 0; i < item->data.list->n; i++) {
    … …  
    21752214        }
    21762215        break;
    2177        
     2216
    21782217      case 2:
    21792218        for (int i = 0; i < item->data.list->n; i++) {
    … …  
    21882227        }
    21892228        break;
    2190  
     2229
    21912230      case 3:
    21922231        for (int i = 0; i < item->data.list->n; i++) {
    … …  
    22012240        }
    22022241        break;
    2203        
     2242
    22042243      case 4:
    22052244        for (int i = 0; i < item->data.list->n; i++) {
    … …  
    22142253        }
    22152254        break;
    2216        
     2255
    22172256      case 5:
    22182257        for (int i = 0; i < item->data.list->n; i++) {
    … …  
    22272266        }
    22282267        break;
    2229        
     2268
    22302269      case 6:
    22312270        for (int i = 0; i < item->data.list->n; i++) {
    … …  
    22402279        }
    22412280        break;
    2242        
     2281
    22432282      case 7:
    22442283        for (int i = 0; i < item->data.list->n; i++) {
    … …  
    22532292        }
    22542293        break;
    2255        
     2294
    22562295      case 8:
    22572296        for (int i = 0; i < item->data.list->n; i++) {
    … …  
    22662305        }
    22672306        break;
    2268        
     2307
    22692308      case 9:
    22702309        for (int i = 0; i < item->data.list->n; i++) {
    … …  
    22792318        }
    22802319        break;
    2281        
     2320
    22822321      case 10:
    22832322        for (int i = 0; i < item->data.list->n; i++) {
Note: See TracChangeset for help on using the changeset viewer.