Changeset 28218 for trunk/ppTranslate/src/ppMopsMerge.c

Timestamp:

Jun 4, 2010, 10:44:09 AM (16 years ago)

Author:

Paul Price

Message:

Bug fixes to get it working. Seems a bit slow, but it's working.

File:

• trunk/ppTranslate/src/ppMopsMerge.c (modified) (6 diffs)

trunk/ppTranslate/src/ppMopsMerge.c

@@ -41 +41 @@
     for (int i = 0; i < numInputs; i++) {
         ppMopsDetections *det = detections->data[i]; // Detections from
+        if (!det || det->num == 0) {
+            continue;
+        }
         psVector *dupes = duplicates->data[i] = psVectorAlloc(det->num, PS_TYPE_U8);
         psVectorInit(dupes, 0);
         total += det->num;
     }
-
-    psVector *raMerged = psVectorAllocEmpty(total, PS_TYPE_F64); // Merged RAs
-    psVector *decMerged = psVectorAllocEmpty(total, PS_TYPE_F64); // Merged Decs
-#if 0
-    psVector *xMerged = psVectorAllocEmpty(total, PS_TYPE_F32);   // Merged x coords
-    psVector *yMerged = psVectorAllocEmpty(total, PS_TYPE_F32);   // Merged y coords
-#endif
-    psVector *sourceMerged = psVectorAllocEmpty(total, PS_TYPE_U16); // Source image of merged sources
-    psVector *indexMerged = psVectorAllocEmpty(total, PS_TYPE_U32); // Index of merged sources
+    psTrace("ppMops.merge", 2, "Total detections: %ld\n", total);
+
+    psVector *raMerged = psVectorAlloc(total, PS_TYPE_F64); // Merged RAs
+    psVector *decMerged = psVectorAlloc(total, PS_TYPE_F64); // Merged Decs
+    psVector *sourceMerged = psVectorAlloc(total, PS_TYPE_U16); // Source image of merged sources
+    psVector *indexMerged = psVectorAlloc(total, PS_TYPE_U32); // Index of merged sources
     long num = 0;                                                   // Number of merged sources
 
@@ -62 +62 @@
     double mjd = NAN;                           // Time of exposure
 
-    for (int i = 0; i < detections->n; i++) {
+    for (int i = 0; i < numInputs; i++) {
         ppMopsDetections *det = detections->data[i]; // Detections of interest
         if (!det) {
@@ -82 +82 @@
             alt = det->alt;
             az = det->az;
-            continue;
         } else {
             if (strcmp(raBoresight, det->raBoresight) != 0) {
@@ -132 +131 @@
 
         psTrace("ppMops.merge", 3, "Accepting %ld detections from input %d\n", det->num, i);
-        memcpy(&raMerged->data.F64[num], det->ra, det->num * PSELEMTYPE_SIZEOF(PS_TYPE_F64));
-        memcpy(&decMerged->data.F64[num], det->dec, det->num * PSELEMTYPE_SIZEOF(PS_TYPE_F64));
+        memcpy(&raMerged->data.F64[num], det->ra->data.F64, det->num * PSELEMTYPE_SIZEOF(PS_TYPE_F64));
+        memcpy(&decMerged->data.F64[num], det->dec->data.F64, det->num * PSELEMTYPE_SIZEOF(PS_TYPE_F64));
         for (long j = 0, k = num; j < det->num; j++, k++) {
             sourceMerged->data.U16[k] = i;
@@ -215 +214 @@
                 dupNum->data.U32[i]++;
             }
+            psFree(indices);
         }
         psFree(coords);
@@ -250 +250 @@
         psArray *table = psListToArray(det->table->list); // Table of data
         for (int j = 0; j < table->n; j++) {
-            psVector *vector = table->data[j]; // Vector to purge
+            psMetadataItem *item = table->data[j]; // Table item
+            psAssert(item->type == PS_DATA_VECTOR, "Table column is not a vector: %x", item->type);
+            psVector *vector = item->data.V; // Vector to purge
             switch (vector->type.type) {
                 VECTOR_PURGE_CASE(U8);