comparison query.cpp @ 452:25ee0b77f8ca api-inversion

No more audioDB::error in audioDB::query_loop

Change it to return an int, and return non-zero for an error instead.
This is very coarse-grained, yes, but necessary.

     VERB_LOG(1, "Calling indexed query on database %s, radius=%f, sequence_length=%d\n", adb->path, qspec.refine.radius, qspec.qid.sequence_length);
     index_query_loop(&qspec, dbName, query_from_key_index);
   }
   else{
     VERB_LOG(1, "Calling brute-force query on database %s\n", dbName);
-    query_loop(adb, &qspec, query_from_key_index);
+    if(query_loop(adb, &qspec, query_from_key_index)) {
+      error("query_loop failed");
+    }
   }
 
   adb_query_results_t *rs = accumulator->get_points();
   for(unsigned int k = 0; k < rs->nresults; k++) {
     adb_result_t r = rs->results[k];

   SAFE_DELETE_ARRAY(dbpointers.l2norm_data);
   SAFE_DELETE_ARRAY(dbpointers.power_data);
   SAFE_DELETE_ARRAY(dbpointers.mean_duration);
 }
 
-void audioDB::query_loop(adb_t *adb, adb_query_spec_t *spec, Uns32T queryIndex) {
+int audioDB::query_loop(adb_t *adb, adb_query_spec_t *spec, Uns32T queryIndex) {
   
   double *query, *query_data;
   adb_qpointers_internal_t qpointers = {0}, dbpointers = {0};
 
   bool power_refine = spec->refine.flags & (ADB_REFINE_ABSOLUTE_THRESHOLD|ADB_REFINE_RELATIVE_THRESHOLD);
 
-  if( adb->header->flags & O2_FLAG_LARGE_ADB )
-    error("error: LARGE_ADB requires indexed query");
+  if(adb->header->flags & O2_FLAG_LARGE_ADB) {
+    /* FIXME: actually it would be nice to support this mode of
+     * operation, but for now... */
+    return 1;
+  }
 
   if(audiodb_query_spec_qpointers(adb, spec, &query_data, &query, &qpointers)) {
-    error("failed to set up qpointers");
+    return 1;
   }
 
   if(audiodb_set_up_dbpointers(adb, spec, &dbpointers)) {
-    error("failed to set up db");
+    return 1;
   }
 
   unsigned j,k,track,trackOffset=0, HOP_SIZE = spec->refine.hopsize;
   unsigned wL = spec->qid.sequence_length;
   double **D = 0;    // Differences query and target 

     if(trackFile) {
       trackFile->getline(nextKey,MAXSTR);
       if(!trackFile->eof()) {
 	track = audiodb_key_index(adb, nextKey);
         if(track == (uint32_t) -1) {
-          error("key not found", nextKey);
+          return 1;
         }
         trackOffset = (*adb->track_offsets)[track];
         lseek(adb->fd, adb->header->dataOffset + trackOffset, SEEK_SET);
       } else {
 	break;

       }
     }
 
     trackIndexOffset = trackOffset / (adb->header->dim * sizeof(double)); // dbpointers.nvectors offset
 
-    if(audiodb_read_data(adb, adb->fd, track, &data_buffer, &data_buffer_size))
-      error("failed to read data");
+    if(audiodb_read_data(adb, adb->fd, track, &data_buffer, &data_buffer_size)) {
+      return 1;
+    }
     if(wL <= (*adb->track_lengths)[track]) {  // test for short sequences
       
       audiodb_initialize_arrays(adb, spec, track, qpointers.nvectors, query, data_buffer, D, DD);
 
       if((!(spec->refine.flags & ADB_REFINE_DURATION_RATIO)) || 

     delete[] D;
   if(DD)
     delete[] DD;
   if(dbpointers.mean_duration)
     delete[] dbpointers.mean_duration;
-}
+
+  return 0;
+}