Merge branch 'enhancement-10-harmony' of...

Merge branch 'enhancement-10-harmony' of https://gitlab.eurecom.fr/oai/openairinterface5g into enhancement-10-harmony

openair1/PHY/LTE_TRANSPORT/prach.c

@@ -1272,9 +1272,10 @@ void rx_prach(PHY_VARS_eNB *eNB,
     //send prachF to RCC
     return;
   }
-  else if (eNB->node_function == NGFI_RCC_IF4) {
+  // in case of RCC and prach received rx_thread wakes up prach
+  //else if (eNB->node_function == NGFI_RCC_IF4) {
     //wait for prachF from RRU and continue with PRACH processing
-  }
+  //}
 
 
 

openair1/SCHED/phy_procedures_lte_eNb.c

@@ -2498,7 +2498,7 @@ void phy_procedures_eNB_common_RX(PHY_VARS_eNB *eNB,const uint8_t abstraction_fl
   eNB_proc_t *proc = &eNB->proc;
   int subframe = proc->subframe_rx;
   int frame = proc->frame_rx;
-
+  int symbol_number, symbol_mask, symbol_mask_full, prach_rx;
 
   if (subframe==9) { 
     subframe=0;
@@ -2578,6 +2578,26 @@ void phy_procedures_eNB_common_RX(PHY_VARS_eNB *eNB,const uint8_t abstraction_fl
       }
       else if (eNB->node_function == NGFI_RCC_IF4) { // => acquisition from RRU (IF4)
 	      // get frame/subframe information from IF4 interface
+	      // timed loop (200 us)
+	
+        symbol_mask = 0;
+        symbol_mask_full = (1<<fp->symbols_per_tti)-1;
+        if (is_prach_subframe(fp,frame,subframe)>0)
+          prach_rx = 0;
+        else
+          prach_rx = 1;
+          
+        do {
+				  recv_IF4(eNB, proc, &packet_type, &symbol_number);
+				  if (is_prach_subframe(fp,frame,subframe)>0 && packet_type == PRACH) {
+					  // wake up prach_rx
+					  prach_rx = 1;
+					}
+					if (packet_type == PULFFT)
+					  symbol_mask = symbol_mask | (1<<symbol_number);
+					
+				} while( (symbol_mask != symbol_mask_full) || (prach_rx == 0));    
+					 
 
 	      //recv_IF4(eNB,subframe<<1);
 	      //recv_IF4(eNB,1+(subframe<<1));