Changeset 41213 for trunk/ippTools
- Timestamp:
- Dec 24, 2019, 2:57:20 AM (7 years ago)
- Location:
- trunk/ippTools
- Files:
-
- 13 edited
-
share/addtool_find_pendingexp_cam.sql (modified) (2 diffs)
-
share/addtool_queue_cam_id.sql (modified) (1 diff)
-
share/addtool_queue_ff_id.sql (modified) (1 diff)
-
share/addtool_queue_ffsummary.sql (modified) (1 diff)
-
share/addtool_queue_sky_id.sql (modified) (1 diff)
-
share/addtool_queue_skycal_id.sql (modified) (1 diff)
-
share/addtool_queue_stack_id.sql (modified) (1 diff)
-
src/addtool.c (modified) (18 diffs)
-
src/addtoolConfig.c (modified) (6 diffs)
-
src/flatcorr.c (modified) (1 diff)
-
src/pxadd.c (modified) (2 diffs)
-
src/pxadd.h (modified) (1 diff)
-
src/pxcam.c (modified) (2 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/ippTools/share/addtool_find_pendingexp_cam.sql
r31375 r41213 7 7 rawExp.camera, 8 8 rawExp.telescope, 9 rawExp.filelevel 9 rawExp.filelevel, 10 minidvodbRun.minidvodb_host as dvodbhost 10 11 FROM addRun 12 JOIN minidvodbRun 13 on addRun.minidvodb_group = minidvodbRun.minidvodb_group 11 14 JOIN camRun 12 15 on cam_id = stage_id … … 28 31 AND addRun.workdir IS NOT NULL 29 32 AND addMask.label IS NULL 33 AND minidvodbRun.state = 'active' 30 34 -
trunk/ippTools/share/addtool_queue_cam_id.sql
r32832 r41213 16 16 %d, -- minidvodb 17 17 '%s', -- minidvodb_group 18 '%s' -- minidvodb_name 18 '%s', -- minidvodb_name 19 '%s' -- minidvodb_host 19 20 FROM camRun 20 21 WHERE -
trunk/ippTools/share/addtool_queue_ff_id.sql
r37709 r41213 16 16 %d, -- minidvodb 17 17 '%s', -- minidvodb_group 18 '%s' -- minidvodb_name 18 '%s', -- minidvodb_name 19 '%s' -- minidvodb_host 19 20 FROM fullForceRun 20 21 WHERE -
trunk/ippTools/share/addtool_queue_ffsummary.sql
r38943 r41213 16 16 %d, -- minidvodb 17 17 '%s', -- minidvodb_group 18 '%s' -- minidvodb_name 18 '%s', -- minidvodb_name 19 '%s' -- minidvodb_host 19 20 FROM fullForceRun 20 21 WHERE -
trunk/ippTools/share/addtool_queue_sky_id.sql
r32832 r41213 16 16 %d, -- minidvodb 17 17 '%s', -- minidvodb_group 18 '%s' -- minidvodb_name 18 '%s', -- minidvodb_name 19 '%s' -- minidvodb_host 19 20 FROM staticskyRun 20 21 WHERE -
trunk/ippTools/share/addtool_queue_skycal_id.sql
r34265 r41213 16 16 %d, -- minidvodb 17 17 '%s', -- minidvodb_group 18 '%s' -- minidvodb_name 18 '%s', -- minidvodb_name 19 '%s' -- minidvodb_host 19 20 FROM skycalRun 20 21 WHERE -
trunk/ippTools/share/addtool_queue_stack_id.sql
r32832 r41213 16 16 %d, -- minidvodb 17 17 '%s', -- minidvodb_group 18 '%s' -- minidvodb_name 18 '%s', -- minidvodb_name 19 '%s' -- minidvodb_host 19 20 FROM stackRun 20 21 WHERE -
trunk/ippTools/src/addtool.c
r41072 r41213 134 134 PXOPT_LOOKUP_STR(minidvodb_name, config->args, "-set_minidvodb_name", false, false); 135 135 PXOPT_LOOKUP_STR(minidvodb_group, config->args, "-set_minidvodb_group", false, false); 136 PXOPT_LOOKUP_STR(minidvodb_host, config->args, "-set_minidvodb_host", false, false); 136 137 PXOPT_LOOKUP_BOOL(image_only, config->args, "-image_only", false); 137 138 PXOPT_LOOKUP_BOOL(minidvodb, config->args, "-set_minidvodb", false); 138 139 PXOPT_LOOKUP_BOOL(destreaked, config->args, "-destreaked", false); 139 140 PXOPT_LOOKUP_BOOL(uncensored, config->args, "-uncensored", false); 140 141 141 PXOPT_LOOKUP_U64(limit, config->args, "-limit", false, false); 142 142 … … 155 155 pxAddLabelSearchArgs (config, where, "-label", "camRun.label", "=="); // define using camRun label 156 156 pxAddLabelSearchArgs (config, where, "-data_group","camRun.data_group", "=="); // define using camRun label 157 pxAddLabelSearchArgs (config, where, "-filter", "rawExp.filter", "LIKE"); // define using camRun label 157 158 PXOPT_COPY_STR(config->args, where, "-reduction", "camRun.reduction", "=="); 158 159 } … … 703 704 minidvodb, 704 705 minidvodb_group, 705 minidvodb_name 706 minidvodb_name, 707 minidvodb_host 706 708 )) { 707 709 if (!psDBRollback(config->dbh)) { … … 745 747 minidvodb, 746 748 minidvodb_group, 747 minidvodb_name 749 minidvodb_name, 750 minidvodb_host 748 751 )) { 749 752 if (!psDBRollback(config->dbh)) { … … 779 782 return false; 780 783 } 781 782 784 // queue the exp 783 785 //for (int filter_id = 0; filter_id < num_inputs; filter_id++) { … … 795 797 minidvodb, 796 798 minidvodb_group, 797 minidvodb_name 799 minidvodb_name, 800 minidvodb_host 798 801 )) { 799 802 if (!psDBRollback(config->dbh)) { … … 838 841 minidvodb, 839 842 minidvodb_group, 840 minidvodb_name 843 minidvodb_name, 844 minidvodb_host 841 845 )) { 842 846 if (!psDBRollback(config->dbh)) { … … 886 890 minidvodb, 887 891 minidvodb_group, 888 minidvodb_name 892 minidvodb_name, 893 minidvodb_host 889 894 )) { 890 895 if (!psDBRollback(config->dbh)) { … … 934 939 minidvodb, 935 940 minidvodb_group, 936 minidvodb_name 941 minidvodb_name, 942 minidvodb_host 937 943 )) { 938 944 if (!psDBRollback(config->dbh)) { … … 976 982 minidvodb, 977 983 minidvodb_group, 978 minidvodb_name 984 minidvodb_name, 985 minidvodb_host 979 986 )) { 980 987 if (!psDBRollback(config->dbh)) { … … 1203 1210 PXOPT_LOOKUP_STR(dvodb_path, config->args, "-dvodb_path", false, false); 1204 1211 PXOPT_LOOKUP_STR(minidvodb_name, config->args, "-minidvodb_name", false, false); 1212 PXOPT_LOOKUP_STR(minidvodb_host, config->args, "-minidvodb_host", false, false); 1205 1213 PXOPT_LOOKUP_S16(fault, config->args, "-fault", false, false); 1206 1214 PXOPT_LOOKUP_S64(stage_extra1, config->args, "-stage_extra1", false, false); … … 1317 1325 } 1318 1326 } 1327 1328 //if there is a minidvodb_host, set it in addRun (it's not known until it is processed) 1329 if (minidvodb_host) { 1330 psString setName = NULL; 1331 psStringAppend (&setName, "UPDATE addRun set minidvodb_host = '%s' where add_id = %" PRId64, minidvodb_host, row->add_id); 1332 if (!p_psDBRunQuery(config->dbh, setName)) { 1333 if (!psDBRollback(config->dbh)) { 1334 psError(PS_ERR_UNKNOWN, false, "database error"); 1335 } 1336 psError(PS_ERR_UNKNOWN, false, "database error"); 1337 1338 return false; 1339 } 1340 } 1341 1319 1342 //if there is a stage_extra1, set it in addRun (it's not known until it is processed) 1320 1343 if (stage_extra1) { … … 1332 1355 } 1333 1356 } 1334 1335 1336 1337 1357 1338 1358 // since there is only one exp per 'new' set addRun.state = 'full' … … 1663 1683 // required 1664 1684 PXOPT_LOOKUP_STR(minidvodb_group, config->args, "-set_minidvodb_group", true, false); 1665 1685 PXOPT_LOOKUP_STR(minidvodb_path, config->args, "-set_minidvodb_path", false, false); 1686 PXOPT_LOOKUP_STR(minidvodb_host, config->args, "-set_minidvodb_host", false, false); 1666 1687 //optional 1667 1688 PXOPT_LOOKUP_STR(minidvodb_name, config->args, "-set_minidvodb_name", false, false); 1668 PXOPT_LOOKUP_STR(minidvodb_path, config->args, "-set_minidvodb_path", false, false);1669 1689 PXOPT_LOOKUP_STR(state, config->args, "-set_state", false, false); 1670 1690 PXOPT_LOOKUP_STR(note, config->args, "-set_note", false, false); 1671 1691 1672 1692 if (!psDBTransaction(config->dbh)) { … … 1675 1695 } 1676 1696 1677 psString minidvodbpath = "NULL";1697 // psString minidvodbpath = "NULL"; 1678 1698 1679 1699 // I don't know how to get around the complaints of minidvodb_path can't be null. this 'fixes' it, but someone smarter can fix it properly. 1680 if (minidvodb_path) {1681 minidvodbpath = minidvodb_path;1682 } else {1683 psError(PS_ERR_UNKNOWN, false, "require minidvodb_path");1684 return false;1685 }1700 // if (minidvodb_path) { 1701 // minidvodbpath = minidvodb_path; 1702 // } else { 1703 // psError(PS_ERR_UNKNOWN, false, "require minidvodb_path"); 1704 // return false; 1705 // } 1686 1706 1687 1707 if (!minidvodbRunInsert(config->dbh, … … 1689 1709 minidvodb_name, 1690 1710 minidvodb_group, 1691 minidvodbpath, 1711 minidvodb_path, 1712 minidvodb_host, 1692 1713 "new", 1714 note, 1693 1715 0 1694 1716 )) { … … 1746 1768 PXOPT_LOOKUP_STR(minidvodb_name, config->args, "-set_minidvodb_name", false, false); 1747 1769 PXOPT_LOOKUP_STR(minidvodb_path, config->args, "-set_minidvodb_path", false, false); 1770 PXOPT_LOOKUP_STR(minidvodb_host, config->args, "-set_minidvodb_host", false, false); 1748 1771 PXOPT_LOOKUP_STR(state, config->args, "-set_state", false, false); 1749 1772 PXOPT_LOOKUP_STR(minidvodb_group, config->args, "-set_minidvodb_group", false, false); … … 1770 1793 1771 1794 psStringAppend(&query, " minidvodb_path = '%s'", minidvodb_path); 1795 cnt++; 1796 } 1797 1798 if (minidvodb_host) { 1799 if (cnt) { 1800 psStringAppend(&query, "%s", comma); 1801 } 1802 1803 psStringAppend(&query, " minidvodb_host = '%s'", minidvodb_host); 1772 1804 cnt++; 1773 1805 } -
trunk/ippTools/src/addtoolConfig.c
r40803 r41213 59 59 psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-label", PS_META_DUPLICATE_OK, "search by camRun label", NULL); 60 60 psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-data_group", PS_META_DUPLICATE_OK, "search by camRun data_group", NULL); 61 psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-filter", PS_META_DUPLICATE_OK, "search by filter",NULL);61 psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-filter", PS_META_DUPLICATE_OK, "search by rawExp filter", NULL); 62 62 psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-reduction", 0, "search by camRun reduction class", NULL); 63 63 psMetadataAddBool(definebyqueryArgs, PS_LIST_TAIL, "-destreaked", 0, "queue destreaked runs", false); … … 75 75 psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-set_minidvodb_group", 0, "define minidvodb_group", NULL); 76 76 psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-set_minidvodb_name", 0, "define minidvodb_bname", NULL); 77 psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-set_minidvodb_host", 0, "define minidvodb_host", NULL); 77 78 psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-set_data_group", 0, "define new data_group", NULL); 78 79 psMetadataAddStr(definebyqueryArgs, PS_LIST_TAIL, "-set_dist_group", 0, "define new dist_group", NULL); … … 103 104 psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_state", 0, "set state", NULL); 104 105 psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_label", 0, "set label", NULL); 105 psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_dvodb", 0, "set dvodb", NULL);106 // psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_dvodb", 0, "set dvodb", NULL); 106 107 psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_data_group", 0, "define new data_group", NULL); 107 108 psMetadataAddStr(updaterunArgs, PS_LIST_TAIL, "-set_dist_group", 0, "define new dist_group", NULL); … … 133 134 psMetadataAddStr(addprocessedexpArgs, PS_LIST_TAIL, "-dvodb_path", 0, "define base output location", NULL); 134 135 psMetadataAddStr(addprocessedexpArgs, PS_LIST_TAIL, "-minidvodb_name", 0, "define minidvodb_name", NULL); 136 psMetadataAddStr(addprocessedexpArgs, PS_LIST_TAIL, "-minidvodb_host", 0, "define minidvodb_name", NULL); 135 137 psMetadataAddF32(addprocessedexpArgs, PS_LIST_TAIL, "-dtime_addstar", 0, "define elapsed time for DVO insertion (seconds)", NAN); 136 138 psMetadataAddS16(addprocessedexpArgs, PS_LIST_TAIL, "-fault", 0, "set fault code", 0); … … 190 192 psMetadataAddStr(addminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_group", 0, "define minidvodb_group (required)", NULL); 191 193 psMetadataAddStr(addminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_path", 0, "define path for minidvodb", NULL); 194 psMetadataAddStr(addminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_host", 0, "define host for minidvodb (required)", NULL); 192 195 psMetadataAddStr(addminidvodbrunArgs, PS_LIST_TAIL, "-set_state", 0, "define state", NULL); 196 psMetadataAddStr(addminidvodbrunArgs, PS_LIST_TAIL, "-set_note", 0, "define note", NULL); 193 197 194 198 // -updateminidvodbruns … … 202 206 psMetadataAddStr(updateminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_path", 0, "define path for minidvodb", NULL); 203 207 psMetadataAddStr(updateminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_group", 0, "define path for the merged dvodb", NULL); 208 psMetadataAddStr(updateminidvodbrunArgs, PS_LIST_TAIL, "-set_minidvodb_host", 0, "define host for the merged dvodb", NULL); 204 209 psMetadataAddStr(updateminidvodbrunArgs, PS_LIST_TAIL, "-set_state", 0, "define state", NULL); 205 210 -
trunk/ippTools/src/flatcorr.c
r32832 r41213 676 676 0, //The minidvodb stuff is off 677 677 NULL, 678 NULL, 678 679 NULL)) { 679 680 if (!psDBRollback(config->dbh)) { -
trunk/ippTools/src/pxadd.c
r38943 r41213 141 141 bool minidvodb, 142 142 char *minidvodb_group, 143 char *minidvodb_name) 143 char *minidvodb_name, 144 char *minidvodb_host) 144 145 { 145 146 PS_ASSERT_PTR_NON_NULL(config, false); … … 208 209 minidvodb_group, 209 210 minidvodb_name, 211 minidvodb_host, 210 212 (long long) stage_id 211 213 )) { -
trunk/ippTools/src/pxadd.h
r32832 r41213 43 43 bool minidvodb, 44 44 char *minidvodb_group, 45 char *minidvodb_name); 45 char *minidvodb_name, 46 char *minidvodb_host); 46 47 47 48 #endif // PXADD_H -
trunk/ippTools/src/pxcam.c
r41072 r41213 42 42 psMetadataAddStr(md, PS_LIST_TAIL, "-comment", 0, "search by comment", NULL); 43 43 psMetadataAddStr(md, PS_LIST_TAIL, "-filelevel", 0, "search by filelevel", NULL); 44 psMetadataAddStr(md, PS_LIST_TAIL, "-filter", 0, "search for filter", NULL);44 // psMetadataAddStr(md, PS_LIST_TAIL, "-filter", 0, "search for filter", NULL); 45 45 psMetadataAddF64(md, PS_LIST_TAIL, "-airmass_min", 0, "define min airmass", NAN); 46 46 psMetadataAddF64(md, PS_LIST_TAIL, "-airmass_max", 0, "define max airmass", NAN); … … 87 87 PXOPT_COPY_STR(config->args, where, "-comment", "rawExp.comment", "LIKE"); 88 88 PXOPT_COPY_STR(config->args, where, "-filelevel", "rawExp.filelevel", "=="); 89 PXOPT_COPY_STR(config->args, where, "-filter", "rawExp.filter", "LIKE");89 // PXOPT_COPY_STR(config->args, where, "-filter", "rawExp.filter", "LIKE"); 90 90 PXOPT_COPY_F64(config->args, where, "-airmass_min", "rawExp.airmass", ">="); 91 91 PXOPT_COPY_F64(config->args, where, "-airmass_max", "rawExp.airmass", "<");
Note:
See TracChangeset
for help on using the changeset viewer.
