wip

trx_ecpri.c

@@ -523,52 +523,6 @@ static void *decode_thread(void *p) {
   pthread_exit(EXIT_SUCCESS);
 }
 
-static void *decompress_thread(void *p) {
-
-	cpu_set_t mask;
-  TRXEcpriState * s = (TRXEcpriState *) p;
-  int rx_ready = 0;
-  const float mult = 1. / 32767.;
-  log_info("DECOMPRESS_THREAD", "Thread init");
-
-	// Set thread CPU affinity
-	CPU_ZERO(&mask);
-	CPU_SET(s->decompress_affinity, &mask);
-	if (sched_setaffinity(0, sizeof(mask), &mask))
-		error(EXIT_FAILURE, errno, "Could not set CPU affinity to CPU %d\n", s->decompress_affinity);
-
-  for(;;) {
-    int n = rbuf_read_amount(&rx_rbuf);
-    if(n) {
-      for(int j = 0; j < n; j++) {
-        int16_t samples_int[256];
-        const uint8_t * rx_samples = RBUF_READ(rx_rbuf, uint8_t) + 22;
-        // TODO : analyze seq_id, ecpri packet type etc... ?
-        // TODO : set rx_ready at some point (when ?)
-        if(rx_ready) {
-          memset(samples_int, 0, 512);
-
-          decode_bf1(samples_int      , rx_samples      , 16);
-          decode_bf1(samples_int + 64 , rx_samples  + 60, 16);
-          decode_bf1(samples_int + 128, rx_samples + 120, 16);
-          decode_bf1(samples_int + 192, rx_samples + 180, 16);
-          int16_to_float(RBUF_WRITE(trx_read_rbuf, float), samples_int, 256, mult);
-
-          rbuf_update_read_index(&rx_rbuf);
-          rbuf_update_write_index(&trx_read_rbuf);
-          sem_post(&trx_read_sem);
-        }
-      }
-    }
-    else {
-      pthread_mutex_lock(&rx_mutex);
-      pthread_cond_wait(&rx_cond, &rx_mutex);
-      pthread_mutex_unlock(&rx_mutex);
-    }
-  }
-  pthread_exit(EXIT_SUCCESS);
-}
-
 static void *statistic_thread(void *p) {
   struct timespec next, initial;
   int64_t recv_stop = 0;