Changeset 9054 for trunk/ippdb/src/ippdb.c
- Timestamp:
- Sep 28, 2006, 5:16:20 PM (20 years ago)
- File:
-
- 1 edited
-
trunk/ippdb/src/ippdb.c (modified) (231 diffs)
Legend:
- Unmodified
- Added
- Removed
-
trunk/ippdb/src/ippdb.c
r9044 r9054 4619 4619 return false; 4620 4620 } 4621 if (!psMetadataAddStr(md, PS_LIST_TAIL, "camera", 0, NULL, "255")) {4621 if (!psMetadataAddStr(md, PS_LIST_TAIL, "camera", 0, "Primary Key", "255")) { 4622 4622 psError(PS_ERR_UNKNOWN, false, "failed to add item camera"); 4623 4623 psFree(md); 4624 4624 return false; 4625 4625 } 4626 if (!psMetadataAddStr(md, PS_LIST_TAIL, "telescope", 0, NULL, "255")) {4626 if (!psMetadataAddStr(md, PS_LIST_TAIL, "telescope", 0, "Primary Key", "255")) { 4627 4627 psError(PS_ERR_UNKNOWN, false, "failed to add item telescope"); 4628 4628 psFree(md); … … 5123 5123 return false; 5124 5124 } 5125 if (!psMetadataAddStr(md, PS_LIST_TAIL, "camera", 0, NULL, "255")) {5125 if (!psMetadataAddStr(md, PS_LIST_TAIL, "camera", 0, "Primary Key", "255")) { 5126 5126 psError(PS_ERR_UNKNOWN, false, "failed to add item camera"); 5127 5127 psFree(md); 5128 5128 return false; 5129 5129 } 5130 if (!psMetadataAddStr(md, PS_LIST_TAIL, "telescope", 0, NULL, "255")) {5130 if (!psMetadataAddStr(md, PS_LIST_TAIL, "telescope", 0, "Primary Key", "255")) { 5131 5131 psError(PS_ERR_UNKNOWN, false, "failed to add item telescope"); 5132 5132 psFree(md); … … 5587 5587 static void pzPendingImfileRowFree(pzPendingImfileRow *object); 5588 5588 5589 pzPendingImfileRow *pzPendingImfileRowAlloc(const char *exp_id, psS32 bytes, const char *md5sum, const char *class, const char *class_id, const char *uri)5589 pzPendingImfileRow *pzPendingImfileRowAlloc(const char *exp_id, const char *camera, const char *telescope, psS32 bytes, const char *md5sum, const char *class, const char *class_id, const char *uri) 5590 5590 { 5591 5591 pzPendingImfileRow *object; … … 5595 5595 5596 5596 object->exp_id = psStringCopy(exp_id); 5597 object->camera = psStringCopy(camera); 5598 object->telescope = psStringCopy(telescope); 5597 5599 object->bytes = bytes; 5598 5600 object->md5sum = psStringCopy(md5sum); … … 5607 5609 { 5608 5610 psFree(object->exp_id); 5611 psFree(object->camera); 5612 psFree(object->telescope); 5609 5613 psFree(object->md5sum); 5610 5614 psFree(object->class); … … 5629 5633 return false; 5630 5634 } 5635 if (!psMetadataAddStr(md, PS_LIST_TAIL, "camera", 0, "Primary Key", "255")) { 5636 psError(PS_ERR_UNKNOWN, false, "failed to add item camera"); 5637 psFree(md); 5638 return false; 5639 } 5640 if (!psMetadataAddStr(md, PS_LIST_TAIL, "telescope", 0, "Primary Key", "255")) { 5641 psError(PS_ERR_UNKNOWN, false, "failed to add item telescope"); 5642 psFree(md); 5643 return false; 5644 } 5631 5645 if (!psMetadataAddS32(md, PS_LIST_TAIL, "bytes", 0, NULL, 0)) { 5632 5646 psError(PS_ERR_UNKNOWN, false, "failed to add item bytes"); … … 5667 5681 } 5668 5682 5669 bool pzPendingImfileInsert(psDB * dbh, const char *exp_id, psS32 bytes, const char *md5sum, const char *class, const char *class_id, const char *uri)5683 bool pzPendingImfileInsert(psDB * dbh, const char *exp_id, const char *camera, const char *telescope, psS32 bytes, const char *md5sum, const char *class, const char *class_id, const char *uri) 5670 5684 { 5671 5685 psMetadata *md; … … 5675 5689 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_id", 0, NULL, exp_id)) { 5676 5690 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_id"); 5691 psFree(md); 5692 return false; 5693 } 5694 if (!psMetadataAddStr(md, PS_LIST_TAIL, "camera", 0, NULL, camera)) { 5695 psError(PS_ERR_UNKNOWN, false, "failed to add item camera"); 5696 psFree(md); 5697 return false; 5698 } 5699 if (!psMetadataAddStr(md, PS_LIST_TAIL, "telescope", 0, NULL, telescope)) { 5700 psError(PS_ERR_UNKNOWN, false, "failed to add item telescope"); 5677 5701 psFree(md); 5678 5702 return false; … … 5724 5748 return deleted; 5725 5749 } 5726 bool pzPendingImfilePop(psDB *dbh, char **exp_id, psS32 *bytes, char **md5sum, char **class, char **class_id, char **uri)5750 bool pzPendingImfilePop(psDB *dbh, char **exp_id, char **camera, char **telescope, psS32 *bytes, char **md5sum, char **class, char **class_id, char **uri) 5727 5751 { 5728 5752 psArray *rowSet; … … 5774 5798 return false; 5775 5799 } 5800 *camera = psMetadataLookupPtr(&status, row, "camera"); 5801 if (!status) { 5802 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item camera"); 5803 psFree(row); 5804 return false; 5805 } 5806 *telescope = psMetadataLookupPtr(&status, row, "telescope"); 5807 if (!status) { 5808 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item telescope"); 5809 psFree(row); 5810 return false; 5811 } 5776 5812 *bytes = psMetadataLookupS32(&status, row, "bytes"); 5777 5813 if (!status) { … … 5812 5848 bool pzPendingImfileInsertObject(psDB *dbh, pzPendingImfileRow *object) 5813 5849 { 5814 return pzPendingImfileInsert(dbh, object->exp_id, object-> bytes, object->md5sum, object->class, object->class_id, object->uri);5850 return pzPendingImfileInsert(dbh, object->exp_id, object->camera, object->telescope, object->bytes, object->md5sum, object->class, object->class_id, object->uri); 5815 5851 } 5816 5852 … … 5829 5865 { 5830 5866 char exp_id[256]; 5867 char camera[256]; 5868 char telescope[256]; 5831 5869 psS32 bytes; 5832 5870 char md5sum[256]; … … 5835 5873 char uri[256]; 5836 5874 5837 if (!pzPendingImfilePop(dbh, (char **)&exp_id, &bytes, (char **)&md5sum, (char **)&class, (char **)&class_id, (char **)&uri)) {5875 if (!pzPendingImfilePop(dbh, (char **)&exp_id, (char **)&camera, (char **)&telescope, &bytes, (char **)&md5sum, (char **)&class, (char **)&class_id, (char **)&uri)) { 5838 5876 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 5839 5877 return NULL; 5840 5878 } 5841 5879 5842 return pzPendingImfileRowAlloc(exp_id, bytes, md5sum, class, class_id, uri);5880 return pzPendingImfileRowAlloc(exp_id, camera, telescope, bytes, md5sum, class, class_id, uri); 5843 5881 } 5844 5882 … … 5944 5982 return NULL; 5945 5983 } 5984 if (!psMetadataAddStr(md, PS_LIST_TAIL, "camera", 0, NULL, object->camera)) { 5985 psError(PS_ERR_UNKNOWN, false, "failed to add item camera"); 5986 psFree(md); 5987 return NULL; 5988 } 5989 if (!psMetadataAddStr(md, PS_LIST_TAIL, "telescope", 0, NULL, object->telescope)) { 5990 psError(PS_ERR_UNKNOWN, false, "failed to add item telescope"); 5991 psFree(md); 5992 return NULL; 5993 } 5946 5994 if (!psMetadataAddS32(md, PS_LIST_TAIL, "bytes", 0, NULL, object->bytes)) { 5947 5995 psError(PS_ERR_UNKNOWN, false, "failed to add item bytes"); … … 5977 6025 bool status; 5978 6026 char *exp_id; 6027 char *camera; 6028 char *telescope; 5979 6029 psS32 bytes; 5980 6030 char *md5sum; … … 5988 6038 return false; 5989 6039 } 6040 camera = psMetadataLookupPtr(&status, md, "camera"); 6041 if (!status) { 6042 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item camera"); 6043 return false; 6044 } 6045 telescope = psMetadataLookupPtr(&status, md, "telescope"); 6046 if (!status) { 6047 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item telescope"); 6048 return false; 6049 } 5990 6050 bytes = psMetadataLookupS32(&status, md, "bytes"); 5991 6051 if (!status) { … … 6014 6074 } 6015 6075 6016 return pzPendingImfileRowAlloc(exp_id, bytes, md5sum, class, class_id, uri);6076 return pzPendingImfileRowAlloc(exp_id, camera, telescope, bytes, md5sum, class, class_id, uri); 6017 6077 } 6018 6078 psArray *pzPendingImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 6121 6181 static void newExpRowFree(newExpRow *object); 6122 6182 6123 newExpRow *newExpRowAlloc(const char *exp_ id, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles)6183 newExpRow *newExpRowAlloc(const char *exp_tag, const char *exp_id, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles) 6124 6184 { 6125 6185 newExpRow *object; … … 6128 6188 psMemSetDeallocator(object, (psFreeFunc)newExpRowFree); 6129 6189 6190 object->exp_tag = psStringCopy(exp_tag); 6130 6191 object->exp_id = psStringCopy(exp_id); 6131 6192 object->camera = psStringCopy(camera); … … 6139 6200 static void newExpRowFree(newExpRow *object) 6140 6201 { 6202 psFree(object->exp_tag); 6141 6203 psFree(object->exp_id); 6142 6204 psFree(object->camera); … … 6156 6218 return false; 6157 6219 } 6158 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_id", 0, "Primary Key", "64")) { 6220 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 6221 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 6222 psFree(md); 6223 return false; 6224 } 6225 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_id", 0, "Key", "64")) { 6159 6226 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_id"); 6160 6227 psFree(md); … … 6194 6261 } 6195 6262 6196 bool newExpInsert(psDB * dbh, const char *exp_ id, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles)6263 bool newExpInsert(psDB * dbh, const char *exp_tag, const char *exp_id, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles) 6197 6264 { 6198 6265 psMetadata *md; … … 6200 6267 6201 6268 md = psMetadataAlloc(); 6269 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 6270 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 6271 psFree(md); 6272 return false; 6273 } 6202 6274 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_id", 0, NULL, exp_id)) { 6203 6275 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_id"); … … 6246 6318 return deleted; 6247 6319 } 6248 bool newExpPop(psDB *dbh, char **exp_ id, char **camera, char **telescope, char **exp_type, psS32 *imfiles)6320 bool newExpPop(psDB *dbh, char **exp_tag, char **exp_id, char **camera, char **telescope, char **exp_type, psS32 *imfiles) 6249 6321 { 6250 6322 psArray *rowSet; … … 6290 6362 psFree(popped); 6291 6363 6364 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 6365 if (!status) { 6366 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 6367 psFree(row); 6368 return false; 6369 } 6292 6370 *exp_id = psMetadataLookupPtr(&status, row, "exp_id"); 6293 6371 if (!status) { … … 6328 6406 bool newExpInsertObject(psDB *dbh, newExpRow *object) 6329 6407 { 6330 return newExpInsert(dbh, object->exp_ id, object->camera, object->telescope, object->exp_type, object->imfiles);6408 return newExpInsert(dbh, object->exp_tag, object->exp_id, object->camera, object->telescope, object->exp_type, object->imfiles); 6331 6409 } 6332 6410 … … 6344 6422 newExpRow *newExpPopObject(psDB *dbh) 6345 6423 { 6424 char exp_tag[256]; 6346 6425 char exp_id[256]; 6347 6426 char camera[256]; … … 6350 6429 psS32 imfiles; 6351 6430 6352 if (!newExpPop(dbh, (char **)&exp_ id, (char **)&camera, (char **)&telescope, (char **)&exp_type, &imfiles)) {6431 if (!newExpPop(dbh, (char **)&exp_tag, (char **)&exp_id, (char **)&camera, (char **)&telescope, (char **)&exp_type, &imfiles)) { 6353 6432 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 6354 6433 return NULL; 6355 6434 } 6356 6435 6357 return newExpRowAlloc(exp_ id, camera, telescope, exp_type, imfiles);6436 return newExpRowAlloc(exp_tag, exp_id, camera, telescope, exp_type, imfiles); 6358 6437 } 6359 6438 … … 6454 6533 6455 6534 md = psMetadataAlloc(); 6535 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 6536 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 6537 psFree(md); 6538 return NULL; 6539 } 6456 6540 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_id", 0, NULL, object->exp_id)) { 6457 6541 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_id"); … … 6486 6570 { 6487 6571 bool status; 6572 char *exp_tag; 6488 6573 char *exp_id; 6489 6574 char *camera; … … 6492 6577 psS32 imfiles; 6493 6578 6579 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 6580 if (!status) { 6581 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 6582 return false; 6583 } 6494 6584 exp_id = psMetadataLookupPtr(&status, md, "exp_id"); 6495 6585 if (!status) { … … 6518 6608 } 6519 6609 6520 return newExpRowAlloc(exp_ id, camera, telescope, exp_type, imfiles);6610 return newExpRowAlloc(exp_tag, exp_id, camera, telescope, exp_type, imfiles); 6521 6611 } 6522 6612 psArray *newExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 6625 6715 static void newImfileRowFree(newImfileRow *object); 6626 6716 6627 newImfileRow *newImfileRowAlloc(const char *exp_ id, const char *class, const char *class_id, const char *uri)6717 newImfileRow *newImfileRowAlloc(const char *exp_tag, const char *class, const char *class_id, const char *uri) 6628 6718 { 6629 6719 newImfileRow *object; … … 6632 6722 psMemSetDeallocator(object, (psFreeFunc)newImfileRowFree); 6633 6723 6634 object->exp_ id = psStringCopy(exp_id);6724 object->exp_tag = psStringCopy(exp_tag); 6635 6725 object->class = psStringCopy(class); 6636 6726 object->class_id = psStringCopy(class_id); … … 6642 6732 static void newImfileRowFree(newImfileRow *object) 6643 6733 { 6644 psFree(object->exp_ id);6734 psFree(object->exp_tag); 6645 6735 psFree(object->class); 6646 6736 psFree(object->class_id); … … 6659 6749 return false; 6660 6750 } 6661 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {6662 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");6751 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 6752 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 6663 6753 psFree(md); 6664 6754 return false; … … 6692 6782 } 6693 6783 6694 bool newImfileInsert(psDB * dbh, const char *exp_ id, const char *class, const char *class_id, const char *uri)6784 bool newImfileInsert(psDB * dbh, const char *exp_tag, const char *class, const char *class_id, const char *uri) 6695 6785 { 6696 6786 psMetadata *md; … … 6698 6788 6699 6789 md = psMetadataAlloc(); 6700 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {6701 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");6790 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 6791 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 6702 6792 psFree(md); 6703 6793 return false; … … 6739 6829 return deleted; 6740 6830 } 6741 bool newImfilePop(psDB *dbh, char **exp_ id, char **class, char **class_id, char **uri)6831 bool newImfilePop(psDB *dbh, char **exp_tag, char **class, char **class_id, char **uri) 6742 6832 { 6743 6833 psArray *rowSet; … … 6783 6873 psFree(popped); 6784 6874 6785 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");6786 if (!status) { 6787 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");6875 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 6876 if (!status) { 6877 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 6788 6878 psFree(row); 6789 6879 return false; … … 6815 6905 bool newImfileInsertObject(psDB *dbh, newImfileRow *object) 6816 6906 { 6817 return newImfileInsert(dbh, object->exp_ id, object->class, object->class_id, object->uri);6907 return newImfileInsert(dbh, object->exp_tag, object->class, object->class_id, object->uri); 6818 6908 } 6819 6909 … … 6831 6921 newImfileRow *newImfilePopObject(psDB *dbh) 6832 6922 { 6833 char exp_ id[256];6923 char exp_tag[256]; 6834 6924 char class[256]; 6835 6925 char class_id[256]; 6836 6926 char uri[256]; 6837 6927 6838 if (!newImfilePop(dbh, (char **)&exp_ id, (char **)&class, (char **)&class_id, (char **)&uri)) {6928 if (!newImfilePop(dbh, (char **)&exp_tag, (char **)&class, (char **)&class_id, (char **)&uri)) { 6839 6929 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 6840 6930 return NULL; 6841 6931 } 6842 6932 6843 return newImfileRowAlloc(exp_ id, class, class_id, uri);6933 return newImfileRowAlloc(exp_tag, class, class_id, uri); 6844 6934 } 6845 6935 … … 6940 7030 6941 7031 md = psMetadataAlloc(); 6942 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {6943 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");7032 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 7033 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 6944 7034 psFree(md); 6945 7035 return NULL; … … 6967 7057 { 6968 7058 bool status; 6969 char *exp_ id;7059 char *exp_tag; 6970 7060 char *class; 6971 7061 char *class_id; 6972 7062 char *uri; 6973 7063 6974 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");6975 if (!status) { 6976 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");7064 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 7065 if (!status) { 7066 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 6977 7067 return false; 6978 7068 } … … 6993 7083 } 6994 7084 6995 return newImfileRowAlloc(exp_ id, class, class_id, uri);7085 return newImfileRowAlloc(exp_tag, class, class_id, uri); 6996 7086 } 6997 7087 psArray *newImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 7100 7190 static void rawDetrendExpRowFree(rawDetrendExpRow *object); 7101 7191 7102 rawDetrendExpRow *rawDetrendExpRowAlloc(const char *exp_ id, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang)7192 rawDetrendExpRow *rawDetrendExpRowAlloc(const char *exp_tag, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang) 7103 7193 { 7104 7194 rawDetrendExpRow *object; … … 7107 7197 psMemSetDeallocator(object, (psFreeFunc)rawDetrendExpRowFree); 7108 7198 7109 object->exp_ id = psStringCopy(exp_id);7199 object->exp_tag = psStringCopy(exp_tag); 7110 7200 object->camera = psStringCopy(camera); 7111 7201 object->telescope = psStringCopy(telescope); … … 7130 7220 static void rawDetrendExpRowFree(rawDetrendExpRow *object) 7131 7221 { 7132 psFree(object->exp_ id);7222 psFree(object->exp_tag); 7133 7223 psFree(object->camera); 7134 7224 psFree(object->telescope); … … 7148 7238 return false; 7149 7239 } 7150 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {7151 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");7240 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 7241 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 7152 7242 psFree(md); 7153 7243 return false; … … 7246 7336 } 7247 7337 7248 bool rawDetrendExpInsert(psDB * dbh, const char *exp_ id, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang)7338 bool rawDetrendExpInsert(psDB * dbh, const char *exp_tag, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang) 7249 7339 { 7250 7340 psMetadata *md; … … 7252 7342 7253 7343 md = psMetadataAlloc(); 7254 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {7255 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");7344 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 7345 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 7256 7346 psFree(md); 7257 7347 return false; … … 7358 7448 return deleted; 7359 7449 } 7360 bool rawDetrendExpPop(psDB *dbh, char **exp_ id, char **camera, char **telescope, char **exp_type, psS32 *imfiles, char **filter, psF32 *airmass, psF64 *ra, psF64 *decl, psF32 *exp_time, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, psF64 *alt, psF64 *az, psF32 *ccd_temp, psF64 *posang)7450 bool rawDetrendExpPop(psDB *dbh, char **exp_tag, char **camera, char **telescope, char **exp_type, psS32 *imfiles, char **filter, psF32 *airmass, psF64 *ra, psF64 *decl, psF32 *exp_time, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, psF64 *alt, psF64 *az, psF32 *ccd_temp, psF64 *posang) 7361 7451 { 7362 7452 psArray *rowSet; … … 7402 7492 psFree(popped); 7403 7493 7404 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");7405 if (!status) { 7406 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");7494 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 7495 if (!status) { 7496 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 7407 7497 psFree(row); 7408 7498 return false; … … 7512 7602 bool rawDetrendExpInsertObject(psDB *dbh, rawDetrendExpRow *object) 7513 7603 { 7514 return rawDetrendExpInsert(dbh, object->exp_ id, object->camera, object->telescope, object->exp_type, object->imfiles, object->filter, object->airmass, object->ra, object->decl, object->exp_time, object->bg, object->bg_stdev, object->bg_mean_stdev, object->alt, object->az, object->ccd_temp, object->posang);7604 return rawDetrendExpInsert(dbh, object->exp_tag, object->camera, object->telescope, object->exp_type, object->imfiles, object->filter, object->airmass, object->ra, object->decl, object->exp_time, object->bg, object->bg_stdev, object->bg_mean_stdev, object->alt, object->az, object->ccd_temp, object->posang); 7515 7605 } 7516 7606 … … 7528 7618 rawDetrendExpRow *rawDetrendExpPopObject(psDB *dbh) 7529 7619 { 7530 char exp_ id[256];7620 char exp_tag[256]; 7531 7621 char camera[256]; 7532 7622 char telescope[256]; … … 7546 7636 psF64 posang; 7547 7637 7548 if (!rawDetrendExpPop(dbh, (char **)&exp_ id, (char **)&camera, (char **)&telescope, (char **)&exp_type, &imfiles, (char **)&filter, &airmass, &ra, &decl, &exp_time, &bg, &bg_stdev, &bg_mean_stdev, &alt, &az, &ccd_temp, &posang)) {7638 if (!rawDetrendExpPop(dbh, (char **)&exp_tag, (char **)&camera, (char **)&telescope, (char **)&exp_type, &imfiles, (char **)&filter, &airmass, &ra, &decl, &exp_time, &bg, &bg_stdev, &bg_mean_stdev, &alt, &az, &ccd_temp, &posang)) { 7549 7639 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 7550 7640 return NULL; 7551 7641 } 7552 7642 7553 return rawDetrendExpRowAlloc(exp_ id, camera, telescope, exp_type, imfiles, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang);7643 return rawDetrendExpRowAlloc(exp_tag, camera, telescope, exp_type, imfiles, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang); 7554 7644 } 7555 7645 … … 7650 7740 7651 7741 md = psMetadataAlloc(); 7652 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {7653 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");7742 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 7743 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 7654 7744 psFree(md); 7655 7745 return NULL; … … 7742 7832 { 7743 7833 bool status; 7744 char *exp_ id;7834 char *exp_tag; 7745 7835 char *camera; 7746 7836 char *telescope; … … 7760 7850 psF64 posang; 7761 7851 7762 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");7763 if (!status) { 7764 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");7852 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 7853 if (!status) { 7854 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 7765 7855 return false; 7766 7856 } … … 7846 7936 } 7847 7937 7848 return rawDetrendExpRowAlloc(exp_ id, camera, telescope, exp_type, imfiles, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang);7938 return rawDetrendExpRowAlloc(exp_tag, camera, telescope, exp_type, imfiles, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang); 7849 7939 } 7850 7940 psArray *rawDetrendExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 7953 8043 static void rawScienceExpRowFree(rawScienceExpRow *object); 7954 8044 7955 rawScienceExpRow *rawScienceExpRowAlloc(const char *exp_ id, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang)8045 rawScienceExpRow *rawScienceExpRowAlloc(const char *exp_tag, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang) 7956 8046 { 7957 8047 rawScienceExpRow *object; … … 7960 8050 psMemSetDeallocator(object, (psFreeFunc)rawScienceExpRowFree); 7961 8051 7962 object->exp_ id = psStringCopy(exp_id);8052 object->exp_tag = psStringCopy(exp_tag); 7963 8053 object->camera = psStringCopy(camera); 7964 8054 object->telescope = psStringCopy(telescope); … … 7983 8073 static void rawScienceExpRowFree(rawScienceExpRow *object) 7984 8074 { 7985 psFree(object->exp_ id);8075 psFree(object->exp_tag); 7986 8076 psFree(object->camera); 7987 8077 psFree(object->telescope); … … 8001 8091 return false; 8002 8092 } 8003 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {8004 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");8093 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 8094 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 8005 8095 psFree(md); 8006 8096 return false; … … 8099 8189 } 8100 8190 8101 bool rawScienceExpInsert(psDB * dbh, const char *exp_ id, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang)8191 bool rawScienceExpInsert(psDB * dbh, const char *exp_tag, const char *camera, const char *telescope, const char *exp_type, psS32 imfiles, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang) 8102 8192 { 8103 8193 psMetadata *md; … … 8105 8195 8106 8196 md = psMetadataAlloc(); 8107 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {8108 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");8197 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 8198 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 8109 8199 psFree(md); 8110 8200 return false; … … 8211 8301 return deleted; 8212 8302 } 8213 bool rawScienceExpPop(psDB *dbh, char **exp_ id, char **camera, char **telescope, char **exp_type, psS32 *imfiles, char **filter, psF32 *airmass, psF64 *ra, psF64 *decl, psF32 *exp_time, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, psF64 *alt, psF64 *az, psF32 *ccd_temp, psF64 *posang)8303 bool rawScienceExpPop(psDB *dbh, char **exp_tag, char **camera, char **telescope, char **exp_type, psS32 *imfiles, char **filter, psF32 *airmass, psF64 *ra, psF64 *decl, psF32 *exp_time, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, psF64 *alt, psF64 *az, psF32 *ccd_temp, psF64 *posang) 8214 8304 { 8215 8305 psArray *rowSet; … … 8255 8345 psFree(popped); 8256 8346 8257 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");8258 if (!status) { 8259 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");8347 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 8348 if (!status) { 8349 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 8260 8350 psFree(row); 8261 8351 return false; … … 8365 8455 bool rawScienceExpInsertObject(psDB *dbh, rawScienceExpRow *object) 8366 8456 { 8367 return rawScienceExpInsert(dbh, object->exp_ id, object->camera, object->telescope, object->exp_type, object->imfiles, object->filter, object->airmass, object->ra, object->decl, object->exp_time, object->bg, object->bg_stdev, object->bg_mean_stdev, object->alt, object->az, object->ccd_temp, object->posang);8457 return rawScienceExpInsert(dbh, object->exp_tag, object->camera, object->telescope, object->exp_type, object->imfiles, object->filter, object->airmass, object->ra, object->decl, object->exp_time, object->bg, object->bg_stdev, object->bg_mean_stdev, object->alt, object->az, object->ccd_temp, object->posang); 8368 8458 } 8369 8459 … … 8381 8471 rawScienceExpRow *rawScienceExpPopObject(psDB *dbh) 8382 8472 { 8383 char exp_ id[256];8473 char exp_tag[256]; 8384 8474 char camera[256]; 8385 8475 char telescope[256]; … … 8399 8489 psF64 posang; 8400 8490 8401 if (!rawScienceExpPop(dbh, (char **)&exp_ id, (char **)&camera, (char **)&telescope, (char **)&exp_type, &imfiles, (char **)&filter, &airmass, &ra, &decl, &exp_time, &bg, &bg_stdev, &bg_mean_stdev, &alt, &az, &ccd_temp, &posang)) {8491 if (!rawScienceExpPop(dbh, (char **)&exp_tag, (char **)&camera, (char **)&telescope, (char **)&exp_type, &imfiles, (char **)&filter, &airmass, &ra, &decl, &exp_time, &bg, &bg_stdev, &bg_mean_stdev, &alt, &az, &ccd_temp, &posang)) { 8402 8492 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 8403 8493 return NULL; 8404 8494 } 8405 8495 8406 return rawScienceExpRowAlloc(exp_ id, camera, telescope, exp_type, imfiles, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang);8496 return rawScienceExpRowAlloc(exp_tag, camera, telescope, exp_type, imfiles, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang); 8407 8497 } 8408 8498 … … 8503 8593 8504 8594 md = psMetadataAlloc(); 8505 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {8506 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");8595 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 8596 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 8507 8597 psFree(md); 8508 8598 return NULL; … … 8595 8685 { 8596 8686 bool status; 8597 char *exp_ id;8687 char *exp_tag; 8598 8688 char *camera; 8599 8689 char *telescope; … … 8613 8703 psF64 posang; 8614 8704 8615 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");8616 if (!status) { 8617 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");8705 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 8706 if (!status) { 8707 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 8618 8708 return false; 8619 8709 } … … 8699 8789 } 8700 8790 8701 return rawScienceExpRowAlloc(exp_ id, camera, telescope, exp_type, imfiles, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang);8791 return rawScienceExpRowAlloc(exp_tag, camera, telescope, exp_type, imfiles, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang); 8702 8792 } 8703 8793 psArray *rawScienceExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 8806 8896 static void rawImfileRowFree(rawImfileRow *object); 8807 8897 8808 rawImfileRow *rawImfileRowAlloc(const char *exp_ id, const char *class, const char *class_id, const char *uri, const char *exp_type, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang)8898 rawImfileRow *rawImfileRowAlloc(const char *exp_tag, const char *class, const char *class_id, const char *uri, const char *exp_type, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang) 8809 8899 { 8810 8900 rawImfileRow *object; … … 8813 8903 psMemSetDeallocator(object, (psFreeFunc)rawImfileRowFree); 8814 8904 8815 object->exp_ id = psStringCopy(exp_id);8905 object->exp_tag = psStringCopy(exp_tag); 8816 8906 object->class = psStringCopy(class); 8817 8907 object->class_id = psStringCopy(class_id); … … 8836 8926 static void rawImfileRowFree(rawImfileRow *object) 8837 8927 { 8838 psFree(object->exp_ id);8928 psFree(object->exp_tag); 8839 8929 psFree(object->class); 8840 8930 psFree(object->class_id); … … 8855 8945 return false; 8856 8946 } 8857 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {8858 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");8947 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 8948 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 8859 8949 psFree(md); 8860 8950 return false; … … 8953 9043 } 8954 9044 8955 bool rawImfileInsert(psDB * dbh, const char *exp_ id, const char *class, const char *class_id, const char *uri, const char *exp_type, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang)9045 bool rawImfileInsert(psDB * dbh, const char *exp_tag, const char *class, const char *class_id, const char *uri, const char *exp_type, const char *filter, psF32 airmass, psF64 ra, psF64 decl, psF32 exp_time, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, psF64 alt, psF64 az, psF32 ccd_temp, psF64 posang) 8956 9046 { 8957 9047 psMetadata *md; … … 8959 9049 8960 9050 md = psMetadataAlloc(); 8961 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {8962 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");9051 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 9052 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 8963 9053 psFree(md); 8964 9054 return false; … … 9065 9155 return deleted; 9066 9156 } 9067 bool rawImfilePop(psDB *dbh, char **exp_ id, char **class, char **class_id, char **uri, char **exp_type, char **filter, psF32 *airmass, psF64 *ra, psF64 *decl, psF32 *exp_time, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, psF64 *alt, psF64 *az, psF32 *ccd_temp, psF64 *posang)9157 bool rawImfilePop(psDB *dbh, char **exp_tag, char **class, char **class_id, char **uri, char **exp_type, char **filter, psF32 *airmass, psF64 *ra, psF64 *decl, psF32 *exp_time, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, psF64 *alt, psF64 *az, psF32 *ccd_temp, psF64 *posang) 9068 9158 { 9069 9159 psArray *rowSet; … … 9109 9199 psFree(popped); 9110 9200 9111 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");9112 if (!status) { 9113 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");9201 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 9202 if (!status) { 9203 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 9114 9204 psFree(row); 9115 9205 return false; … … 9219 9309 bool rawImfileInsertObject(psDB *dbh, rawImfileRow *object) 9220 9310 { 9221 return rawImfileInsert(dbh, object->exp_ id, object->class, object->class_id, object->uri, object->exp_type, object->filter, object->airmass, object->ra, object->decl, object->exp_time, object->bg, object->bg_stdev, object->bg_mean_stdev, object->alt, object->az, object->ccd_temp, object->posang);9311 return rawImfileInsert(dbh, object->exp_tag, object->class, object->class_id, object->uri, object->exp_type, object->filter, object->airmass, object->ra, object->decl, object->exp_time, object->bg, object->bg_stdev, object->bg_mean_stdev, object->alt, object->az, object->ccd_temp, object->posang); 9222 9312 } 9223 9313 … … 9235 9325 rawImfileRow *rawImfilePopObject(psDB *dbh) 9236 9326 { 9237 char exp_ id[256];9327 char exp_tag[256]; 9238 9328 char class[256]; 9239 9329 char class_id[256]; … … 9253 9343 psF64 posang; 9254 9344 9255 if (!rawImfilePop(dbh, (char **)&exp_ id, (char **)&class, (char **)&class_id, (char **)&uri, (char **)&exp_type, (char **)&filter, &airmass, &ra, &decl, &exp_time, &bg, &bg_stdev, &bg_mean_stdev, &alt, &az, &ccd_temp, &posang)) {9345 if (!rawImfilePop(dbh, (char **)&exp_tag, (char **)&class, (char **)&class_id, (char **)&uri, (char **)&exp_type, (char **)&filter, &airmass, &ra, &decl, &exp_time, &bg, &bg_stdev, &bg_mean_stdev, &alt, &az, &ccd_temp, &posang)) { 9256 9346 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 9257 9347 return NULL; 9258 9348 } 9259 9349 9260 return rawImfileRowAlloc(exp_ id, class, class_id, uri, exp_type, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang);9350 return rawImfileRowAlloc(exp_tag, class, class_id, uri, exp_type, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang); 9261 9351 } 9262 9352 … … 9357 9447 9358 9448 md = psMetadataAlloc(); 9359 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {9360 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");9449 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 9450 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 9361 9451 psFree(md); 9362 9452 return NULL; … … 9449 9539 { 9450 9540 bool status; 9451 char *exp_ id;9541 char *exp_tag; 9452 9542 char *class; 9453 9543 char *class_id; … … 9467 9557 psF64 posang; 9468 9558 9469 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");9470 if (!status) { 9471 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");9559 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 9560 if (!status) { 9561 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 9472 9562 return false; 9473 9563 } … … 9553 9643 } 9554 9644 9555 return rawImfileRowAlloc(exp_ id, class, class_id, uri, exp_type, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang);9645 return rawImfileRowAlloc(exp_tag, class, class_id, uri, exp_type, filter, airmass, ra, decl, exp_time, bg, bg_stdev, bg_mean_stdev, alt, az, ccd_temp, posang); 9556 9646 } 9557 9647 psArray *rawImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 9660 9750 static void p1PendingExpRowFree(p1PendingExpRow *object); 9661 9751 9662 p1PendingExpRow *p1PendingExpRowAlloc(const char *exp_ id, const char *recipe, psS32 p1_version)9752 p1PendingExpRow *p1PendingExpRowAlloc(const char *exp_tag, const char *recipe, psS32 p1_version) 9663 9753 { 9664 9754 p1PendingExpRow *object; … … 9667 9757 psMemSetDeallocator(object, (psFreeFunc)p1PendingExpRowFree); 9668 9758 9669 object->exp_ id = psStringCopy(exp_id);9759 object->exp_tag = psStringCopy(exp_tag); 9670 9760 object->recipe = psStringCopy(recipe); 9671 9761 object->p1_version = p1_version; … … 9676 9766 static void p1PendingExpRowFree(p1PendingExpRow *object) 9677 9767 { 9678 psFree(object->exp_ id);9768 psFree(object->exp_tag); 9679 9769 psFree(object->recipe); 9680 9770 } … … 9691 9781 return false; 9692 9782 } 9693 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {9694 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");9783 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 9784 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 9695 9785 psFree(md); 9696 9786 return false; … … 9719 9809 } 9720 9810 9721 bool p1PendingExpInsert(psDB * dbh, const char *exp_ id, const char *recipe, psS32 p1_version)9811 bool p1PendingExpInsert(psDB * dbh, const char *exp_tag, const char *recipe, psS32 p1_version) 9722 9812 { 9723 9813 psMetadata *md; … … 9725 9815 9726 9816 md = psMetadataAlloc(); 9727 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {9728 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");9817 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 9818 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 9729 9819 psFree(md); 9730 9820 return false; … … 9761 9851 return deleted; 9762 9852 } 9763 bool p1PendingExpPop(psDB *dbh, char **exp_ id, char **recipe, psS32 *p1_version)9853 bool p1PendingExpPop(psDB *dbh, char **exp_tag, char **recipe, psS32 *p1_version) 9764 9854 { 9765 9855 psArray *rowSet; … … 9805 9895 psFree(popped); 9806 9896 9807 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");9808 if (!status) { 9809 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");9897 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 9898 if (!status) { 9899 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 9810 9900 psFree(row); 9811 9901 return false; … … 9831 9921 bool p1PendingExpInsertObject(psDB *dbh, p1PendingExpRow *object) 9832 9922 { 9833 return p1PendingExpInsert(dbh, object->exp_ id, object->recipe, object->p1_version);9923 return p1PendingExpInsert(dbh, object->exp_tag, object->recipe, object->p1_version); 9834 9924 } 9835 9925 … … 9847 9937 p1PendingExpRow *p1PendingExpPopObject(psDB *dbh) 9848 9938 { 9849 char exp_ id[256];9939 char exp_tag[256]; 9850 9940 char recipe[256]; 9851 9941 psS32 p1_version; 9852 9942 9853 if (!p1PendingExpPop(dbh, (char **)&exp_ id, (char **)&recipe, &p1_version)) {9943 if (!p1PendingExpPop(dbh, (char **)&exp_tag, (char **)&recipe, &p1_version)) { 9854 9944 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 9855 9945 return NULL; 9856 9946 } 9857 9947 9858 return p1PendingExpRowAlloc(exp_ id, recipe, p1_version);9948 return p1PendingExpRowAlloc(exp_tag, recipe, p1_version); 9859 9949 } 9860 9950 … … 9955 10045 9956 10046 md = psMetadataAlloc(); 9957 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {9958 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");10047 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 10048 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 9959 10049 psFree(md); 9960 10050 return NULL; … … 9977 10067 { 9978 10068 bool status; 9979 char *exp_ id;10069 char *exp_tag; 9980 10070 char *recipe; 9981 10071 psS32 p1_version; 9982 10072 9983 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");9984 if (!status) { 9985 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");10073 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 10074 if (!status) { 10075 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 9986 10076 return false; 9987 10077 } … … 9997 10087 } 9998 10088 9999 return p1PendingExpRowAlloc(exp_ id, recipe, p1_version);10089 return p1PendingExpRowAlloc(exp_tag, recipe, p1_version); 10000 10090 } 10001 10091 psArray *p1PendingExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 10104 10194 static void p2PendingExpRowFree(p2PendingExpRow *object); 10105 10195 10106 p2PendingExpRow *p2PendingExpRowAlloc(const char *exp_ id, const char *recipe, psS32 p1_version, psS32 p2_version)10196 p2PendingExpRow *p2PendingExpRowAlloc(const char *exp_tag, const char *recipe, psS32 p1_version, psS32 p2_version) 10107 10197 { 10108 10198 p2PendingExpRow *object; … … 10111 10201 psMemSetDeallocator(object, (psFreeFunc)p2PendingExpRowFree); 10112 10202 10113 object->exp_ id = psStringCopy(exp_id);10203 object->exp_tag = psStringCopy(exp_tag); 10114 10204 object->recipe = psStringCopy(recipe); 10115 10205 object->p1_version = p1_version; … … 10121 10211 static void p2PendingExpRowFree(p2PendingExpRow *object) 10122 10212 { 10123 psFree(object->exp_ id);10213 psFree(object->exp_tag); 10124 10214 psFree(object->recipe); 10125 10215 } … … 10136 10226 return false; 10137 10227 } 10138 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {10139 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");10228 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 10229 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 10140 10230 psFree(md); 10141 10231 return false; … … 10169 10259 } 10170 10260 10171 bool p2PendingExpInsert(psDB * dbh, const char *exp_ id, const char *recipe, psS32 p1_version, psS32 p2_version)10261 bool p2PendingExpInsert(psDB * dbh, const char *exp_tag, const char *recipe, psS32 p1_version, psS32 p2_version) 10172 10262 { 10173 10263 psMetadata *md; … … 10175 10265 10176 10266 md = psMetadataAlloc(); 10177 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {10178 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");10267 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 10268 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 10179 10269 psFree(md); 10180 10270 return false; … … 10216 10306 return deleted; 10217 10307 } 10218 bool p2PendingExpPop(psDB *dbh, char **exp_ id, char **recipe, psS32 *p1_version, psS32 *p2_version)10308 bool p2PendingExpPop(psDB *dbh, char **exp_tag, char **recipe, psS32 *p1_version, psS32 *p2_version) 10219 10309 { 10220 10310 psArray *rowSet; … … 10260 10350 psFree(popped); 10261 10351 10262 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");10263 if (!status) { 10264 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");10352 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 10353 if (!status) { 10354 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 10265 10355 psFree(row); 10266 10356 return false; … … 10292 10382 bool p2PendingExpInsertObject(psDB *dbh, p2PendingExpRow *object) 10293 10383 { 10294 return p2PendingExpInsert(dbh, object->exp_ id, object->recipe, object->p1_version, object->p2_version);10384 return p2PendingExpInsert(dbh, object->exp_tag, object->recipe, object->p1_version, object->p2_version); 10295 10385 } 10296 10386 … … 10308 10398 p2PendingExpRow *p2PendingExpPopObject(psDB *dbh) 10309 10399 { 10310 char exp_ id[256];10400 char exp_tag[256]; 10311 10401 char recipe[256]; 10312 10402 psS32 p1_version; 10313 10403 psS32 p2_version; 10314 10404 10315 if (!p2PendingExpPop(dbh, (char **)&exp_ id, (char **)&recipe, &p1_version, &p2_version)) {10405 if (!p2PendingExpPop(dbh, (char **)&exp_tag, (char **)&recipe, &p1_version, &p2_version)) { 10316 10406 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 10317 10407 return NULL; 10318 10408 } 10319 10409 10320 return p2PendingExpRowAlloc(exp_ id, recipe, p1_version, p2_version);10410 return p2PendingExpRowAlloc(exp_tag, recipe, p1_version, p2_version); 10321 10411 } 10322 10412 … … 10417 10507 10418 10508 md = psMetadataAlloc(); 10419 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {10420 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");10509 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 10510 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 10421 10511 psFree(md); 10422 10512 return NULL; … … 10444 10534 { 10445 10535 bool status; 10446 char *exp_ id;10536 char *exp_tag; 10447 10537 char *recipe; 10448 10538 psS32 p1_version; 10449 10539 psS32 p2_version; 10450 10540 10451 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");10452 if (!status) { 10453 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");10541 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 10542 if (!status) { 10543 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 10454 10544 return false; 10455 10545 } … … 10470 10560 } 10471 10561 10472 return p2PendingExpRowAlloc(exp_ id, recipe, p1_version, p2_version);10562 return p2PendingExpRowAlloc(exp_tag, recipe, p1_version, p2_version); 10473 10563 } 10474 10564 psArray *p2PendingExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 10577 10667 static void p2PendingImfileRowFree(p2PendingImfileRow *object); 10578 10668 10579 p2PendingImfileRow *p2PendingImfileRowAlloc(const char *exp_ id, const char *class_id, const char *uri, const char *recipe, psS32 p1_version, psS32 p2_version)10669 p2PendingImfileRow *p2PendingImfileRowAlloc(const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psS32 p1_version, psS32 p2_version) 10580 10670 { 10581 10671 p2PendingImfileRow *object; … … 10584 10674 psMemSetDeallocator(object, (psFreeFunc)p2PendingImfileRowFree); 10585 10675 10586 object->exp_ id = psStringCopy(exp_id);10676 object->exp_tag = psStringCopy(exp_tag); 10587 10677 object->class_id = psStringCopy(class_id); 10588 10678 object->uri = psStringCopy(uri); … … 10596 10686 static void p2PendingImfileRowFree(p2PendingImfileRow *object) 10597 10687 { 10598 psFree(object->exp_ id);10688 psFree(object->exp_tag); 10599 10689 psFree(object->class_id); 10600 10690 psFree(object->uri); … … 10613 10703 return false; 10614 10704 } 10615 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {10616 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");10705 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 10706 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 10617 10707 psFree(md); 10618 10708 return false; … … 10656 10746 } 10657 10747 10658 bool p2PendingImfileInsert(psDB * dbh, const char *exp_ id, const char *class_id, const char *uri, const char *recipe, psS32 p1_version, psS32 p2_version)10748 bool p2PendingImfileInsert(psDB * dbh, const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psS32 p1_version, psS32 p2_version) 10659 10749 { 10660 10750 psMetadata *md; … … 10662 10752 10663 10753 md = psMetadataAlloc(); 10664 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {10665 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");10754 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 10755 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 10666 10756 psFree(md); 10667 10757 return false; … … 10713 10803 return deleted; 10714 10804 } 10715 bool p2PendingImfilePop(psDB *dbh, char **exp_ id, char **class_id, char **uri, char **recipe, psS32 *p1_version, psS32 *p2_version)10805 bool p2PendingImfilePop(psDB *dbh, char **exp_tag, char **class_id, char **uri, char **recipe, psS32 *p1_version, psS32 *p2_version) 10716 10806 { 10717 10807 psArray *rowSet; … … 10757 10847 psFree(popped); 10758 10848 10759 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");10760 if (!status) { 10761 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");10849 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 10850 if (!status) { 10851 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 10762 10852 psFree(row); 10763 10853 return false; … … 10801 10891 bool p2PendingImfileInsertObject(psDB *dbh, p2PendingImfileRow *object) 10802 10892 { 10803 return p2PendingImfileInsert(dbh, object->exp_ id, object->class_id, object->uri, object->recipe, object->p1_version, object->p2_version);10893 return p2PendingImfileInsert(dbh, object->exp_tag, object->class_id, object->uri, object->recipe, object->p1_version, object->p2_version); 10804 10894 } 10805 10895 … … 10817 10907 p2PendingImfileRow *p2PendingImfilePopObject(psDB *dbh) 10818 10908 { 10819 char exp_ id[256];10909 char exp_tag[256]; 10820 10910 char class_id[256]; 10821 10911 char uri[256]; … … 10824 10914 psS32 p2_version; 10825 10915 10826 if (!p2PendingImfilePop(dbh, (char **)&exp_ id, (char **)&class_id, (char **)&uri, (char **)&recipe, &p1_version, &p2_version)) {10916 if (!p2PendingImfilePop(dbh, (char **)&exp_tag, (char **)&class_id, (char **)&uri, (char **)&recipe, &p1_version, &p2_version)) { 10827 10917 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 10828 10918 return NULL; 10829 10919 } 10830 10920 10831 return p2PendingImfileRowAlloc(exp_ id, class_id, uri, recipe, p1_version, p2_version);10921 return p2PendingImfileRowAlloc(exp_tag, class_id, uri, recipe, p1_version, p2_version); 10832 10922 } 10833 10923 … … 10928 11018 10929 11019 md = psMetadataAlloc(); 10930 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {10931 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");11020 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 11021 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 10932 11022 psFree(md); 10933 11023 return NULL; … … 10965 11055 { 10966 11056 bool status; 10967 char *exp_ id;11057 char *exp_tag; 10968 11058 char *class_id; 10969 11059 char *uri; … … 10972 11062 psS32 p2_version; 10973 11063 10974 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");10975 if (!status) { 10976 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");11064 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 11065 if (!status) { 11066 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 10977 11067 return false; 10978 11068 } … … 11003 11093 } 11004 11094 11005 return p2PendingImfileRowAlloc(exp_ id, class_id, uri, recipe, p1_version, p2_version);11095 return p2PendingImfileRowAlloc(exp_tag, class_id, uri, recipe, p1_version, p2_version); 11006 11096 } 11007 11097 psArray *p2PendingImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 11110 11200 static void p2ProcessedExpRowFree(p2ProcessedExpRow *object); 11111 11201 11112 p2ProcessedExpRow *p2ProcessedExpRowAlloc(const char *exp_ id, psS32 p1_version, psS32 p2_version)11202 p2ProcessedExpRow *p2ProcessedExpRowAlloc(const char *exp_tag, psS32 p1_version, psS32 p2_version) 11113 11203 { 11114 11204 p2ProcessedExpRow *object; … … 11117 11207 psMemSetDeallocator(object, (psFreeFunc)p2ProcessedExpRowFree); 11118 11208 11119 object->exp_ id = psStringCopy(exp_id);11209 object->exp_tag = psStringCopy(exp_tag); 11120 11210 object->p1_version = p1_version; 11121 11211 object->p2_version = p2_version; … … 11126 11216 static void p2ProcessedExpRowFree(p2ProcessedExpRow *object) 11127 11217 { 11128 psFree(object->exp_ id);11218 psFree(object->exp_tag); 11129 11219 } 11130 11220 … … 11140 11230 return false; 11141 11231 } 11142 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {11143 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");11232 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 11233 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 11144 11234 psFree(md); 11145 11235 return false; … … 11168 11258 } 11169 11259 11170 bool p2ProcessedExpInsert(psDB * dbh, const char *exp_ id, psS32 p1_version, psS32 p2_version)11260 bool p2ProcessedExpInsert(psDB * dbh, const char *exp_tag, psS32 p1_version, psS32 p2_version) 11171 11261 { 11172 11262 psMetadata *md; … … 11174 11264 11175 11265 md = psMetadataAlloc(); 11176 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {11177 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");11266 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 11267 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 11178 11268 psFree(md); 11179 11269 return false; … … 11210 11300 return deleted; 11211 11301 } 11212 bool p2ProcessedExpPop(psDB *dbh, char **exp_ id, psS32 *p1_version, psS32 *p2_version)11302 bool p2ProcessedExpPop(psDB *dbh, char **exp_tag, psS32 *p1_version, psS32 *p2_version) 11213 11303 { 11214 11304 psArray *rowSet; … … 11254 11344 psFree(popped); 11255 11345 11256 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");11257 if (!status) { 11258 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");11346 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 11347 if (!status) { 11348 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 11259 11349 psFree(row); 11260 11350 return false; … … 11280 11370 bool p2ProcessedExpInsertObject(psDB *dbh, p2ProcessedExpRow *object) 11281 11371 { 11282 return p2ProcessedExpInsert(dbh, object->exp_ id, object->p1_version, object->p2_version);11372 return p2ProcessedExpInsert(dbh, object->exp_tag, object->p1_version, object->p2_version); 11283 11373 } 11284 11374 … … 11296 11386 p2ProcessedExpRow *p2ProcessedExpPopObject(psDB *dbh) 11297 11387 { 11298 char exp_ id[256];11388 char exp_tag[256]; 11299 11389 psS32 p1_version; 11300 11390 psS32 p2_version; 11301 11391 11302 if (!p2ProcessedExpPop(dbh, (char **)&exp_ id, &p1_version, &p2_version)) {11392 if (!p2ProcessedExpPop(dbh, (char **)&exp_tag, &p1_version, &p2_version)) { 11303 11393 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 11304 11394 return NULL; 11305 11395 } 11306 11396 11307 return p2ProcessedExpRowAlloc(exp_ id, p1_version, p2_version);11397 return p2ProcessedExpRowAlloc(exp_tag, p1_version, p2_version); 11308 11398 } 11309 11399 … … 11404 11494 11405 11495 md = psMetadataAlloc(); 11406 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {11407 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");11496 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 11497 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 11408 11498 psFree(md); 11409 11499 return NULL; … … 11426 11516 { 11427 11517 bool status; 11428 char *exp_ id;11518 char *exp_tag; 11429 11519 psS32 p1_version; 11430 11520 psS32 p2_version; 11431 11521 11432 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");11433 if (!status) { 11434 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");11522 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 11523 if (!status) { 11524 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 11435 11525 return false; 11436 11526 } … … 11446 11536 } 11447 11537 11448 return p2ProcessedExpRowAlloc(exp_ id, p1_version, p2_version);11538 return p2ProcessedExpRowAlloc(exp_tag, p1_version, p2_version); 11449 11539 } 11450 11540 psArray *p2ProcessedExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 11553 11643 static void p2ProcessedImfileRowFree(p2ProcessedImfileRow *object); 11554 11644 11555 p2ProcessedImfileRow *p2ProcessedImfileRowAlloc(const char *exp_ id, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, psS32 p1_version, psS32 p2_version)11645 p2ProcessedImfileRow *p2ProcessedImfileRowAlloc(const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, psS32 p1_version, psS32 p2_version) 11556 11646 { 11557 11647 p2ProcessedImfileRow *object; … … 11560 11650 psMemSetDeallocator(object, (psFreeFunc)p2ProcessedImfileRowFree); 11561 11651 11562 object->exp_ id = psStringCopy(exp_id);11652 object->exp_tag = psStringCopy(exp_tag); 11563 11653 object->class_id = psStringCopy(class_id); 11564 11654 object->uri = psStringCopy(uri); … … 11577 11667 static void p2ProcessedImfileRowFree(p2ProcessedImfileRow *object) 11578 11668 { 11579 psFree(object->exp_ id);11669 psFree(object->exp_tag); 11580 11670 psFree(object->class_id); 11581 11671 psFree(object->uri); … … 11596 11686 return false; 11597 11687 } 11598 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {11599 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");11688 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 11689 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 11600 11690 psFree(md); 11601 11691 return false; … … 11664 11754 } 11665 11755 11666 bool p2ProcessedImfileInsert(psDB * dbh, const char *exp_ id, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, psS32 p1_version, psS32 p2_version)11756 bool p2ProcessedImfileInsert(psDB * dbh, const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, psS32 p1_version, psS32 p2_version) 11667 11757 { 11668 11758 psMetadata *md; … … 11670 11760 11671 11761 md = psMetadataAlloc(); 11672 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {11673 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");11762 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 11763 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 11674 11764 psFree(md); 11675 11765 return false; … … 11746 11836 return deleted; 11747 11837 } 11748 bool p2ProcessedImfilePop(psDB *dbh, char **exp_ id, char **class_id, char **uri, char **recipe, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, char **b1_uri, char **b2_uri, psS32 *p1_version, psS32 *p2_version)11838 bool p2ProcessedImfilePop(psDB *dbh, char **exp_tag, char **class_id, char **uri, char **recipe, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, char **b1_uri, char **b2_uri, psS32 *p1_version, psS32 *p2_version) 11749 11839 { 11750 11840 psArray *rowSet; … … 11790 11880 psFree(popped); 11791 11881 11792 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");11793 if (!status) { 11794 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");11882 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 11883 if (!status) { 11884 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 11795 11885 psFree(row); 11796 11886 return false; … … 11864 11954 bool p2ProcessedImfileInsertObject(psDB *dbh, p2ProcessedImfileRow *object) 11865 11955 { 11866 return p2ProcessedImfileInsert(dbh, object->exp_ id, object->class_id, object->uri, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->b1_uri, object->b2_uri, object->p1_version, object->p2_version);11956 return p2ProcessedImfileInsert(dbh, object->exp_tag, object->class_id, object->uri, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->b1_uri, object->b2_uri, object->p1_version, object->p2_version); 11867 11957 } 11868 11958 … … 11880 11970 p2ProcessedImfileRow *p2ProcessedImfilePopObject(psDB *dbh) 11881 11971 { 11882 char exp_ id[256];11972 char exp_tag[256]; 11883 11973 char class_id[256]; 11884 11974 char uri[256]; … … 11892 11982 psS32 p2_version; 11893 11983 11894 if (!p2ProcessedImfilePop(dbh, (char **)&exp_ id, (char **)&class_id, (char **)&uri, (char **)&recipe, &bg, &bg_stdev, &bg_mean_stdev, (char **)&b1_uri, (char **)&b2_uri, &p1_version, &p2_version)) {11984 if (!p2ProcessedImfilePop(dbh, (char **)&exp_tag, (char **)&class_id, (char **)&uri, (char **)&recipe, &bg, &bg_stdev, &bg_mean_stdev, (char **)&b1_uri, (char **)&b2_uri, &p1_version, &p2_version)) { 11895 11985 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 11896 11986 return NULL; 11897 11987 } 11898 11988 11899 return p2ProcessedImfileRowAlloc(exp_ id, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri, p1_version, p2_version);11989 return p2ProcessedImfileRowAlloc(exp_tag, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri, p1_version, p2_version); 11900 11990 } 11901 11991 … … 11996 12086 11997 12087 md = psMetadataAlloc(); 11998 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {11999 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");12088 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 12089 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 12000 12090 psFree(md); 12001 12091 return NULL; … … 12058 12148 { 12059 12149 bool status; 12060 char *exp_ id;12150 char *exp_tag; 12061 12151 char *class_id; 12062 12152 char *uri; … … 12070 12160 psS32 p2_version; 12071 12161 12072 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");12073 if (!status) { 12074 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");12162 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 12163 if (!status) { 12164 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 12075 12165 return false; 12076 12166 } … … 12126 12216 } 12127 12217 12128 return p2ProcessedImfileRowAlloc(exp_ id, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri, p1_version, p2_version);12218 return p2ProcessedImfileRowAlloc(exp_tag, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri, p1_version, p2_version); 12129 12219 } 12130 12220 psArray *p2ProcessedImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 12233 12323 static void p3PendingExpRowFree(p3PendingExpRow *object); 12234 12324 12235 p3PendingExpRow *p3PendingExpRowAlloc(const char *exp_ id, psS32 p2_version, psS32 p3_version)12325 p3PendingExpRow *p3PendingExpRowAlloc(const char *exp_tag, psS32 p2_version, psS32 p3_version) 12236 12326 { 12237 12327 p3PendingExpRow *object; … … 12240 12330 psMemSetDeallocator(object, (psFreeFunc)p3PendingExpRowFree); 12241 12331 12242 object->exp_ id = psStringCopy(exp_id);12332 object->exp_tag = psStringCopy(exp_tag); 12243 12333 object->p2_version = p2_version; 12244 12334 object->p3_version = p3_version; … … 12249 12339 static void p3PendingExpRowFree(p3PendingExpRow *object) 12250 12340 { 12251 psFree(object->exp_ id);12341 psFree(object->exp_tag); 12252 12342 } 12253 12343 … … 12263 12353 return false; 12264 12354 } 12265 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {12266 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");12355 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 12356 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 12267 12357 psFree(md); 12268 12358 return false; … … 12291 12381 } 12292 12382 12293 bool p3PendingExpInsert(psDB * dbh, const char *exp_ id, psS32 p2_version, psS32 p3_version)12383 bool p3PendingExpInsert(psDB * dbh, const char *exp_tag, psS32 p2_version, psS32 p3_version) 12294 12384 { 12295 12385 psMetadata *md; … … 12297 12387 12298 12388 md = psMetadataAlloc(); 12299 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {12300 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");12389 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 12390 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 12301 12391 psFree(md); 12302 12392 return false; … … 12333 12423 return deleted; 12334 12424 } 12335 bool p3PendingExpPop(psDB *dbh, char **exp_ id, psS32 *p2_version, psS32 *p3_version)12425 bool p3PendingExpPop(psDB *dbh, char **exp_tag, psS32 *p2_version, psS32 *p3_version) 12336 12426 { 12337 12427 psArray *rowSet; … … 12377 12467 psFree(popped); 12378 12468 12379 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");12380 if (!status) { 12381 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");12469 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 12470 if (!status) { 12471 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 12382 12472 psFree(row); 12383 12473 return false; … … 12403 12493 bool p3PendingExpInsertObject(psDB *dbh, p3PendingExpRow *object) 12404 12494 { 12405 return p3PendingExpInsert(dbh, object->exp_ id, object->p2_version, object->p3_version);12495 return p3PendingExpInsert(dbh, object->exp_tag, object->p2_version, object->p3_version); 12406 12496 } 12407 12497 … … 12419 12509 p3PendingExpRow *p3PendingExpPopObject(psDB *dbh) 12420 12510 { 12421 char exp_ id[256];12511 char exp_tag[256]; 12422 12512 psS32 p2_version; 12423 12513 psS32 p3_version; 12424 12514 12425 if (!p3PendingExpPop(dbh, (char **)&exp_ id, &p2_version, &p3_version)) {12515 if (!p3PendingExpPop(dbh, (char **)&exp_tag, &p2_version, &p3_version)) { 12426 12516 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 12427 12517 return NULL; 12428 12518 } 12429 12519 12430 return p3PendingExpRowAlloc(exp_ id, p2_version, p3_version);12520 return p3PendingExpRowAlloc(exp_tag, p2_version, p3_version); 12431 12521 } 12432 12522 … … 12527 12617 12528 12618 md = psMetadataAlloc(); 12529 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {12530 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");12619 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 12620 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 12531 12621 psFree(md); 12532 12622 return NULL; … … 12549 12639 { 12550 12640 bool status; 12551 char *exp_ id;12641 char *exp_tag; 12552 12642 psS32 p2_version; 12553 12643 psS32 p3_version; 12554 12644 12555 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");12556 if (!status) { 12557 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");12645 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 12646 if (!status) { 12647 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 12558 12648 return false; 12559 12649 } … … 12569 12659 } 12570 12660 12571 return p3PendingExpRowAlloc(exp_ id, p2_version, p3_version);12661 return p3PendingExpRowAlloc(exp_tag, p2_version, p3_version); 12572 12662 } 12573 12663 psArray *p3PendingExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 13090 13180 static void detInputExpRowFree(detInputExpRow *object); 13091 13181 13092 detInputExpRow *detInputExpRowAlloc(psS32 det_id, psS32 iteration, const char *exp_ id, bool include)13182 detInputExpRow *detInputExpRowAlloc(psS32 det_id, psS32 iteration, const char *exp_tag, bool include) 13093 13183 { 13094 13184 detInputExpRow *object; … … 13099 13189 object->det_id = det_id; 13100 13190 object->iteration = iteration; 13101 object->exp_ id = psStringCopy(exp_id);13191 object->exp_tag = psStringCopy(exp_tag); 13102 13192 object->include = include; 13103 13193 … … 13107 13197 static void detInputExpRowFree(detInputExpRow *object) 13108 13198 { 13109 psFree(object->exp_ id);13199 psFree(object->exp_tag); 13110 13200 } 13111 13201 … … 13131 13221 return false; 13132 13222 } 13133 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {13134 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");13223 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 13224 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 13135 13225 psFree(md); 13136 13226 return false; … … 13154 13244 } 13155 13245 13156 bool detInputExpInsert(psDB * dbh, psS32 det_id, psS32 iteration, const char *exp_ id, bool include)13246 bool detInputExpInsert(psDB * dbh, psS32 det_id, psS32 iteration, const char *exp_tag, bool include) 13157 13247 { 13158 13248 psMetadata *md; … … 13170 13260 return false; 13171 13261 } 13172 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {13173 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");13262 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 13263 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 13174 13264 psFree(md); 13175 13265 return false; … … 13201 13291 return deleted; 13202 13292 } 13203 bool detInputExpPop(psDB *dbh, psS32 *det_id, psS32 *iteration, char **exp_ id, bool *include)13293 bool detInputExpPop(psDB *dbh, psS32 *det_id, psS32 *iteration, char **exp_tag, bool *include) 13204 13294 { 13205 13295 psArray *rowSet; … … 13257 13347 return false; 13258 13348 } 13259 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");13260 if (!status) { 13261 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");13349 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 13350 if (!status) { 13351 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 13262 13352 psFree(row); 13263 13353 return false; … … 13277 13367 bool detInputExpInsertObject(psDB *dbh, detInputExpRow *object) 13278 13368 { 13279 return detInputExpInsert(dbh, object->det_id, object->iteration, object->exp_ id, object->include);13369 return detInputExpInsert(dbh, object->det_id, object->iteration, object->exp_tag, object->include); 13280 13370 } 13281 13371 … … 13295 13385 psS32 det_id; 13296 13386 psS32 iteration; 13297 char exp_ id[256];13387 char exp_tag[256]; 13298 13388 bool include; 13299 13389 13300 if (!detInputExpPop(dbh, &det_id, &iteration, (char **)&exp_ id, &include)) {13390 if (!detInputExpPop(dbh, &det_id, &iteration, (char **)&exp_tag, &include)) { 13301 13391 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 13302 13392 return NULL; 13303 13393 } 13304 13394 13305 return detInputExpRowAlloc(det_id, iteration, exp_ id, include);13395 return detInputExpRowAlloc(det_id, iteration, exp_tag, include); 13306 13396 } 13307 13397 … … 13412 13502 return NULL; 13413 13503 } 13414 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {13415 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");13504 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 13505 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 13416 13506 psFree(md); 13417 13507 return NULL; … … 13431 13521 psS32 det_id; 13432 13522 psS32 iteration; 13433 char *exp_ id;13523 char *exp_tag; 13434 13524 bool include; 13435 13525 … … 13444 13534 return false; 13445 13535 } 13446 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");13447 if (!status) { 13448 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");13536 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 13537 if (!status) { 13538 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 13449 13539 return false; 13450 13540 } … … 13455 13545 } 13456 13546 13457 return detInputExpRowAlloc(det_id, iteration, exp_ id, include);13547 return detInputExpRowAlloc(det_id, iteration, exp_tag, include); 13458 13548 } 13459 13549 psArray *detInputExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 13562 13652 static void detProcessedImfileRowFree(detProcessedImfileRow *object); 13563 13653 13564 detProcessedImfileRow *detProcessedImfileRowAlloc(psS32 det_id, const char *exp_ id, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri)13654 detProcessedImfileRow *detProcessedImfileRowAlloc(psS32 det_id, const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri) 13565 13655 { 13566 13656 detProcessedImfileRow *object; … … 13570 13660 13571 13661 object->det_id = det_id; 13572 object->exp_ id = psStringCopy(exp_id);13662 object->exp_tag = psStringCopy(exp_tag); 13573 13663 object->class_id = psStringCopy(class_id); 13574 13664 object->uri = psStringCopy(uri); … … 13585 13675 static void detProcessedImfileRowFree(detProcessedImfileRow *object) 13586 13676 { 13587 psFree(object->exp_ id);13677 psFree(object->exp_tag); 13588 13678 psFree(object->class_id); 13589 13679 psFree(object->uri); … … 13609 13699 return false; 13610 13700 } 13611 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {13612 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");13701 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 13702 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 13613 13703 psFree(md); 13614 13704 return false; … … 13667 13757 } 13668 13758 13669 bool detProcessedImfileInsert(psDB * dbh, psS32 det_id, const char *exp_ id, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri)13759 bool detProcessedImfileInsert(psDB * dbh, psS32 det_id, const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri) 13670 13760 { 13671 13761 psMetadata *md; … … 13678 13768 return false; 13679 13769 } 13680 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {13681 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");13770 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 13771 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 13682 13772 psFree(md); 13683 13773 return false; … … 13744 13834 return deleted; 13745 13835 } 13746 bool detProcessedImfilePop(psDB *dbh, psS32 *det_id, char **exp_ id, char **class_id, char **uri, char **recipe, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, char **b1_uri, char **b2_uri)13836 bool detProcessedImfilePop(psDB *dbh, psS32 *det_id, char **exp_tag, char **class_id, char **uri, char **recipe, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, char **b1_uri, char **b2_uri) 13747 13837 { 13748 13838 psArray *rowSet; … … 13794 13884 return false; 13795 13885 } 13796 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");13797 if (!status) { 13798 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");13886 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 13887 if (!status) { 13888 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 13799 13889 psFree(row); 13800 13890 return false; … … 13856 13946 bool detProcessedImfileInsertObject(psDB *dbh, detProcessedImfileRow *object) 13857 13947 { 13858 return detProcessedImfileInsert(dbh, object->det_id, object->exp_ id, object->class_id, object->uri, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->b1_uri, object->b2_uri);13948 return detProcessedImfileInsert(dbh, object->det_id, object->exp_tag, object->class_id, object->uri, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->b1_uri, object->b2_uri); 13859 13949 } 13860 13950 … … 13873 13963 { 13874 13964 psS32 det_id; 13875 char exp_ id[256];13965 char exp_tag[256]; 13876 13966 char class_id[256]; 13877 13967 char uri[256]; … … 13883 13973 char b2_uri[256]; 13884 13974 13885 if (!detProcessedImfilePop(dbh, &det_id, (char **)&exp_ id, (char **)&class_id, (char **)&uri, (char **)&recipe, &bg, &bg_stdev, &bg_mean_stdev, (char **)&b1_uri, (char **)&b2_uri)) {13975 if (!detProcessedImfilePop(dbh, &det_id, (char **)&exp_tag, (char **)&class_id, (char **)&uri, (char **)&recipe, &bg, &bg_stdev, &bg_mean_stdev, (char **)&b1_uri, (char **)&b2_uri)) { 13886 13976 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 13887 13977 return NULL; 13888 13978 } 13889 13979 13890 return detProcessedImfileRowAlloc(det_id, exp_ id, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri);13980 return detProcessedImfileRowAlloc(det_id, exp_tag, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri); 13891 13981 } 13892 13982 … … 13992 14082 return NULL; 13993 14083 } 13994 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {13995 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");14084 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 14085 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 13996 14086 psFree(md); 13997 14087 return NULL; … … 14045 14135 bool status; 14046 14136 psS32 det_id; 14047 char *exp_ id;14137 char *exp_tag; 14048 14138 char *class_id; 14049 14139 char *uri; … … 14060 14150 return false; 14061 14151 } 14062 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");14063 if (!status) { 14064 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");14152 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 14153 if (!status) { 14154 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 14065 14155 return false; 14066 14156 } … … 14106 14196 } 14107 14197 14108 return detProcessedImfileRowAlloc(det_id, exp_ id, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri);14198 return detProcessedImfileRowAlloc(det_id, exp_tag, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri); 14109 14199 } 14110 14200 psArray *detProcessedImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 16694 16784 static void detResidImfileRowFree(detResidImfileRow *object); 16695 16785 16696 detResidImfileRow *detResidImfileRowAlloc(psS32 det_id, psS32 iteration, const char *exp_ id, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri)16786 detResidImfileRow *detResidImfileRowAlloc(psS32 det_id, psS32 iteration, const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri) 16697 16787 { 16698 16788 detResidImfileRow *object; … … 16703 16793 object->det_id = det_id; 16704 16794 object->iteration = iteration; 16705 object->exp_ id = psStringCopy(exp_id);16795 object->exp_tag = psStringCopy(exp_tag); 16706 16796 object->class_id = psStringCopy(class_id); 16707 16797 object->uri = psStringCopy(uri); … … 16718 16808 static void detResidImfileRowFree(detResidImfileRow *object) 16719 16809 { 16720 psFree(object->exp_ id);16810 psFree(object->exp_tag); 16721 16811 psFree(object->class_id); 16722 16812 psFree(object->uri); … … 16747 16837 return false; 16748 16838 } 16749 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {16750 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");16839 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 16840 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 16751 16841 psFree(md); 16752 16842 return false; … … 16805 16895 } 16806 16896 16807 bool detResidImfileInsert(psDB * dbh, psS32 det_id, psS32 iteration, const char *exp_ id, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri)16897 bool detResidImfileInsert(psDB * dbh, psS32 det_id, psS32 iteration, const char *exp_tag, const char *class_id, const char *uri, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri) 16808 16898 { 16809 16899 psMetadata *md; … … 16821 16911 return false; 16822 16912 } 16823 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {16824 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");16913 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 16914 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 16825 16915 psFree(md); 16826 16916 return false; … … 16887 16977 return deleted; 16888 16978 } 16889 bool detResidImfilePop(psDB *dbh, psS32 *det_id, psS32 *iteration, char **exp_ id, char **class_id, char **uri, char **recipe, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, char **b1_uri, char **b2_uri)16979 bool detResidImfilePop(psDB *dbh, psS32 *det_id, psS32 *iteration, char **exp_tag, char **class_id, char **uri, char **recipe, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, char **b1_uri, char **b2_uri) 16890 16980 { 16891 16981 psArray *rowSet; … … 16943 17033 return false; 16944 17034 } 16945 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");16946 if (!status) { 16947 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");17035 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 17036 if (!status) { 17037 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 16948 17038 psFree(row); 16949 17039 return false; … … 17005 17095 bool detResidImfileInsertObject(psDB *dbh, detResidImfileRow *object) 17006 17096 { 17007 return detResidImfileInsert(dbh, object->det_id, object->iteration, object->exp_ id, object->class_id, object->uri, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->b1_uri, object->b2_uri);17097 return detResidImfileInsert(dbh, object->det_id, object->iteration, object->exp_tag, object->class_id, object->uri, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->b1_uri, object->b2_uri); 17008 17098 } 17009 17099 … … 17023 17113 psS32 det_id; 17024 17114 psS32 iteration; 17025 char exp_ id[256];17115 char exp_tag[256]; 17026 17116 char class_id[256]; 17027 17117 char uri[256]; … … 17033 17123 char b2_uri[256]; 17034 17124 17035 if (!detResidImfilePop(dbh, &det_id, &iteration, (char **)&exp_ id, (char **)&class_id, (char **)&uri, (char **)&recipe, &bg, &bg_stdev, &bg_mean_stdev, (char **)&b1_uri, (char **)&b2_uri)) {17125 if (!detResidImfilePop(dbh, &det_id, &iteration, (char **)&exp_tag, (char **)&class_id, (char **)&uri, (char **)&recipe, &bg, &bg_stdev, &bg_mean_stdev, (char **)&b1_uri, (char **)&b2_uri)) { 17036 17126 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 17037 17127 return NULL; 17038 17128 } 17039 17129 17040 return detResidImfileRowAlloc(det_id, iteration, exp_ id, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri);17130 return detResidImfileRowAlloc(det_id, iteration, exp_tag, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri); 17041 17131 } 17042 17132 … … 17147 17237 return NULL; 17148 17238 } 17149 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {17150 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");17239 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 17240 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 17151 17241 psFree(md); 17152 17242 return NULL; … … 17201 17291 psS32 det_id; 17202 17292 psS32 iteration; 17203 char *exp_ id;17293 char *exp_tag; 17204 17294 char *class_id; 17205 17295 char *uri; … … 17221 17311 return false; 17222 17312 } 17223 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");17224 if (!status) { 17225 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");17313 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 17314 if (!status) { 17315 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 17226 17316 return false; 17227 17317 } … … 17267 17357 } 17268 17358 17269 return detResidImfileRowAlloc(det_id, iteration, exp_ id, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri);17359 return detResidImfileRowAlloc(det_id, iteration, exp_tag, class_id, uri, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri); 17270 17360 } 17271 17361 psArray *detResidImfileSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit) … … 17374 17464 static void detResidExpRowFree(detResidExpRow *object); 17375 17465 17376 detResidExpRow *detResidExpRowAlloc(psS32 det_id, psS32 iteration, const char *exp_ id, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, bool accept)17466 detResidExpRow *detResidExpRowAlloc(psS32 det_id, psS32 iteration, const char *exp_tag, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, bool accept) 17377 17467 { 17378 17468 detResidExpRow *object; … … 17383 17473 object->det_id = det_id; 17384 17474 object->iteration = iteration; 17385 object->exp_ id = psStringCopy(exp_id);17475 object->exp_tag = psStringCopy(exp_tag); 17386 17476 object->recipe = psStringCopy(recipe); 17387 17477 object->bg = bg; … … 17397 17487 static void detResidExpRowFree(detResidExpRow *object) 17398 17488 { 17399 psFree(object->exp_ id);17489 psFree(object->exp_tag); 17400 17490 psFree(object->recipe); 17401 17491 psFree(object->b1_uri); … … 17424 17514 return false; 17425 17515 } 17426 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, "Primary Key", "64")) {17427 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");17516 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, "Primary Key", "64")) { 17517 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 17428 17518 psFree(md); 17429 17519 return false; … … 17477 17567 } 17478 17568 17479 bool detResidExpInsert(psDB * dbh, psS32 det_id, psS32 iteration, const char *exp_ id, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, bool accept)17569 bool detResidExpInsert(psDB * dbh, psS32 det_id, psS32 iteration, const char *exp_tag, const char *recipe, psF64 bg, psF64 bg_stdev, psF64 bg_mean_stdev, const char *b1_uri, const char *b2_uri, bool accept) 17480 17570 { 17481 17571 psMetadata *md; … … 17493 17583 return false; 17494 17584 } 17495 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, exp_id)) {17496 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");17585 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, exp_tag)) { 17586 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 17497 17587 psFree(md); 17498 17588 return false; … … 17554 17644 return deleted; 17555 17645 } 17556 bool detResidExpPop(psDB *dbh, psS32 *det_id, psS32 *iteration, char **exp_ id, char **recipe, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, char **b1_uri, char **b2_uri, bool *accept)17646 bool detResidExpPop(psDB *dbh, psS32 *det_id, psS32 *iteration, char **exp_tag, char **recipe, psF64 *bg, psF64 *bg_stdev, psF64 *bg_mean_stdev, char **b1_uri, char **b2_uri, bool *accept) 17557 17647 { 17558 17648 psArray *rowSet; … … 17610 17700 return false; 17611 17701 } 17612 *exp_ id = psMetadataLookupPtr(&status, row, "exp_id");17613 if (!status) { 17614 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");17702 *exp_tag = psMetadataLookupPtr(&status, row, "exp_tag"); 17703 if (!status) { 17704 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 17615 17705 psFree(row); 17616 17706 return false; … … 17666 17756 bool detResidExpInsertObject(psDB *dbh, detResidExpRow *object) 17667 17757 { 17668 return detResidExpInsert(dbh, object->det_id, object->iteration, object->exp_ id, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->b1_uri, object->b2_uri, object->accept);17758 return detResidExpInsert(dbh, object->det_id, object->iteration, object->exp_tag, object->recipe, object->bg, object->bg_stdev, object->bg_mean_stdev, object->b1_uri, object->b2_uri, object->accept); 17669 17759 } 17670 17760 … … 17684 17774 psS32 det_id; 17685 17775 psS32 iteration; 17686 char exp_ id[256];17776 char exp_tag[256]; 17687 17777 char recipe[256]; 17688 17778 psF64 bg; … … 17693 17783 bool accept; 17694 17784 17695 if (!detResidExpPop(dbh, &det_id, &iteration, (char **)&exp_ id, (char **)&recipe, &bg, &bg_stdev, &bg_mean_stdev, (char **)&b1_uri, (char **)&b2_uri, &accept)) {17785 if (!detResidExpPop(dbh, &det_id, &iteration, (char **)&exp_tag, (char **)&recipe, &bg, &bg_stdev, &bg_mean_stdev, (char **)&b1_uri, (char **)&b2_uri, &accept)) { 17696 17786 psError(PS_ERR_UNKNOWN, false, "failed to pop a database row"); 17697 17787 return NULL; 17698 17788 } 17699 17789 17700 return detResidExpRowAlloc(det_id, iteration, exp_ id, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri, accept);17790 return detResidExpRowAlloc(det_id, iteration, exp_tag, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri, accept); 17701 17791 } 17702 17792 … … 17807 17897 return NULL; 17808 17898 } 17809 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_ id", 0, NULL, object->exp_id)) {17810 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_ id");17899 if (!psMetadataAddStr(md, PS_LIST_TAIL, "exp_tag", 0, NULL, object->exp_tag)) { 17900 psError(PS_ERR_UNKNOWN, false, "failed to add item exp_tag"); 17811 17901 psFree(md); 17812 17902 return NULL; … … 17856 17946 psS32 det_id; 17857 17947 psS32 iteration; 17858 char *exp_ id;17948 char *exp_tag; 17859 17949 char *recipe; 17860 17950 psF64 bg; … … 17875 17965 return false; 17876 17966 } 17877 exp_ id = psMetadataLookupPtr(&status, md, "exp_id");17878 if (!status) { 17879 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_ id");17967 exp_tag = psMetadataLookupPtr(&status, md, "exp_tag"); 17968 if (!status) { 17969 psError(PS_ERR_UNKNOWN, true, "failed to lookup value for item exp_tag"); 17880 17970 return false; 17881 17971 } … … 17916 18006 } 17917 18007 17918 return detResidExpRowAlloc(det_id, iteration, exp_ id, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri, accept);18008 return detResidExpRowAlloc(det_id, iteration, exp_tag, recipe, bg, bg_stdev, bg_mean_stdev, b1_uri, b2_uri, accept); 17919 18009 } 17920 18010 psArray *detResidExpSelectRowObjects(psDB *dbh, const psMetadata *where, unsigned long long limit)
Note:
See TracChangeset
for help on using the changeset viewer.
