RX PPS MODE

trx_ecpri.c

@@ -36,9 +36,17 @@
 
 #define DEBUG
 //#define DISABLE_SEND
-//#define DISABLE_ENCODE
+//#define DISABLE_WRITE
 //#define DISABLE_RECV
-//#define DISABLE_DECODE
+//#define DISABLE_READ
+
+#define RX_PPS_MODE
+
+#ifdef RX_PPS_MODE
+#define DISABLE_SEND
+#define DISABLE_READ
+#define DISABLE_WRITE
+#endif
 
 #include "utils.c"
 #include "ring_buffer.c"
@@ -111,6 +119,8 @@
    IQ Throughput / channel = 491 Mbps
    Total ethernet throughput = 1.979430336 Gbps
 
+   Comba RU sends 56155.16333333333 PPS
+
    14                   4                  4               8          8832
    +-----------------+---------------------+----------------+-------------+------------+
    | Ethernet header | eCPRI common header | IQ data header | oRAN header | IQ payload |
@@ -513,6 +523,10 @@ static void *recv_thread(void *p) {
     int ret = recvmmsg(recv_sockfd, msgh, s->rx_burst, 0, NULL);
     if(ret <= -1)
       error(EXIT_FAILURE, errno, "recvmmsg error");
+#ifdef RX_PPS_MODE
+    update_counter(&rx_packet_counter, ret);
+    continue;
+#endif
     if((i % 100000) < s->rx_drop_pcm)
       continue;
     // Process each received message
@@ -974,6 +988,11 @@ static void trx_ecpri_write(TRXState *s1, trx_timestamp_t timestamp, const void
   float ** _samples = (float **) __samples;
   TRXEcpriState *s = s1->opaque;
 
+#ifdef DISABLE_WRITE
+  while(1)
+    usleep(1000);
+#endif
+
   //log_debug("TRX_ECPRI_WRITE", "trx_ecpri_write, count = %ld", count / N_SAMPLES);
 
   // Consistency check
@@ -1031,6 +1050,11 @@ static int trx_ecpri_read(TRXState *s1, trx_timestamp_t *ptimestamp, void **__sa
   float ** _samples = (float **) __samples;
   TRXEcpriState *s = s1->opaque;
 
+#ifdef DISABLE_READ
+  while(1)
+    usleep(1000);
+#endif
+
   //log_debug("TRX_ECPRI_READ", "Read %d samples", count);
 
   for(int i = 0; i < s->rx_n_channel; i++ ) {