From 8420dce1aad6e14e62240ff615eb9fe3f3125e47 Mon Sep 17 00:00:00 2001
From: Raymond Knopp <raymond.knopp@eurecom.fr>
Date: Sun, 15 Oct 2017 01:47:14 -0700
Subject: [PATCH] addition of worker thread for fep TX procedures in RU
---
openair1/PHY/defs.h | 16 ++-
openair1/SCHED/phy_procedures_lte_eNb.c | 4 +-
openair1/SCHED/ru_procedures.c | 181 +++++++++++++++++++++++-
3 files changed, 189 insertions(+), 12 deletions(-)
diff --git a/openair1/PHY/defs.h b/openair1/PHY/defs.h
index ccdb6d7a06..6dd94bafcd 100644
--- a/openair1/PHY/defs.h
+++ b/openair1/PHY/defs.h
@@ -330,6 +330,8 @@ typedef struct RU_proc_t_s {
int instance_cnt_asynch_rxtx;
/// \internal This variable is protected by \ref mutex_fep
int instance_cnt_fep;
+ /// \internal This variable is protected by \ref mutex_fep
+ int instance_cnt_feptx;
/// pthread structure for RU FH processing thread
pthread_t pthread_FH;
/// pthread structure for RU prach processing thread
@@ -340,8 +342,10 @@ typedef struct RU_proc_t_s {
#endif
/// pthread struct for RU synch thread
pthread_t pthread_synch;
- /// pthread struct for RU RX FEP thread
+ /// pthread struct for RU RX FEP worker thread
pthread_t pthread_fep;
+ /// pthread struct for RU RX FEPTX worker thread
+ pthread_t pthread_feptx;
/// pthread structure for asychronous RX/TX processing thread
pthread_t pthread_asynch_rxtx;
/// flag to indicate first RX acquisition
@@ -360,8 +364,10 @@ typedef struct RU_proc_t_s {
pthread_attr_t attr_synch;
/// pthread attributes for asynchronous RX thread
pthread_attr_t attr_asynch_rxtx;
- /// pthread attributes for parallel fep thread
+ /// pthread attributes for worker fep thread
pthread_attr_t attr_fep;
+ /// pthread attributes for worker feptx thread
+ pthread_attr_t attr_feptx;
/// scheduling parameters for RU FH thread
struct sched_param sched_param_FH;
/// scheduling parameters for RU prach thread
@@ -388,6 +394,8 @@ typedef struct RU_proc_t_s {
pthread_cond_t cond_asynch_rxtx;
/// condition varaible for RU RX FEP thread
pthread_cond_t cond_fep;
+ /// condition varaible for RU RX FEPTX thread
+ pthread_cond_t cond_feptx;
/// condition variable for eNB signal
pthread_cond_t cond_eNBs;
/// mutex for RU FH
@@ -404,8 +412,10 @@ typedef struct RU_proc_t_s {
pthread_mutex_t mutex_eNBs;
/// mutex for asynch RX/TX thread
pthread_mutex_t mutex_asynch_rxtx;
- /// mutex for fep RX
+ /// mutex for fep RX worker thread
pthread_mutex_t mutex_fep;
+ /// mutex for fep TX worker thread
+ pthread_mutex_t mutex_feptx;
/// symbol mask for IF4p5 reception per subframe
uint32_t symbol_mask[10];
/// number of slave threads
diff --git a/openair1/SCHED/phy_procedures_lte_eNb.c b/openair1/SCHED/phy_procedures_lte_eNb.c
index 5b38e95d24..8e5358da34 100644
--- a/openair1/SCHED/phy_procedures_lte_eNb.c
+++ b/openair1/SCHED/phy_procedures_lte_eNb.c
@@ -1094,9 +1094,9 @@ void uci_procedures(PHY_VARS_eNB *eNB,eNB_rxtx_proc_t *proc)
tdd_multiplexing_mask = 0x4;
}
}
+ uci->stat = max_metric;
+ fill_uci_harq_indication(eNB,uci,frame,subframe,harq_ack,1,tdd_multiplexing_mask); // multiplexing mode
}
- uci->stat = max_metric;
- fill_uci_harq_indication(eNB,uci,frame,subframe,harq_ack,1,tdd_multiplexing_mask); // multiplexing mode
} //else if ((uci->tdd_bundling == 0) && (res==3))
else if ((uci->tdd_bundling == 0) && (uci->num_pucch_resources==4)){ // multiplexing + no SR, implement Table 10.1.3-7 (Rel14) for multiplexing with M=4
if (pucch_b0b1[0][0] == 4 ||
diff --git a/openair1/SCHED/ru_procedures.c b/openair1/SCHED/ru_procedures.c
index 75f71e107f..26436e08c5 100644
--- a/openair1/SCHED/ru_procedures.c
+++ b/openair1/SCHED/ru_procedures.c
@@ -54,10 +54,170 @@
#include <time.h>
+#include "targets/RT/USER/rt_wrapper.h"
+
// RU OFDM Modulator, used in IF4p5 RRU, RCC/RAU with IF5, eNodeB
extern openair0_config_t openair0_cfg[MAX_CARDS];
+extern int oai_exit;
+
+
+void feptx0(RU_t *ru,int slot) {
+
+ LTE_DL_FRAME_PARMS *fp = &ru->frame_parms;
+ int dummy_tx_b[7680*2] __attribute__((aligned(32)));
+
+ unsigned int aa,slot_offset;
+ int i,j, tx_offset;
+ int slot_sizeF = (fp->ofdm_symbol_size)*
+ ((fp->Ncp==1) ? 6 : 7);
+ int len,len2;
+ int16_t *txdata;
+ int subframe = ru->proc.subframe_tx;
+
+ slot_offset = subframe*fp->samples_per_tti + (slot*(fp->samples_per_tti>>1));
+
+ // LOG_D(HW,"Frame %d: Generating slot %d\n",frame,next_slot);
+
+ for (aa=0; aa<ru->nb_tx; aa++) {
+ if (fp->Ncp == EXTENDED) PHY_ofdm_mod(&ru->common.txdataF_BF[aa][slot*slot_sizeF],
+ dummy_tx_b,
+ fp->ofdm_symbol_size,
+ 6,
+ fp->nb_prefix_samples,
+ CYCLIC_PREFIX);
+ else normal_prefix_mod(&ru->common.txdataF_BF[aa][slot*slot_sizeF],
+ dummy_tx_b,
+ 7,
+ fp);
+
+
+ len = fp->samples_per_tti>>1;
+
+ // cyclic extension
+ if ((slot_offset+len)>(LTE_NUMBER_OF_SUBFRAMES_PER_FRAME*fp->samples_per_tti)) {
+ tx_offset = (int)slot_offset;
+ txdata = (int16_t*)&ru->common.txdata[aa][tx_offset];
+ len2 = -tx_offset+LTE_NUMBER_OF_SUBFRAMES_PER_FRAME*fp->samples_per_tti;
+ for (i=0; i<(len2<<1); i++) {
+ txdata[i] = ((int16_t*)dummy_tx_b)[i];
+ }
+ txdata = (int16_t*)&ru->common.txdata[aa][0];
+ for (j=0; i<(len<<1); i++,j++) {
+ txdata[j++] = ((int16_t*)dummy_tx_b)[i];
+ }
+ }
+ else {
+ tx_offset = (int)slot_offset;
+ txdata = (int16_t*)&ru->common.txdata[aa][tx_offset];
+
+ for (i=0; i<(len<<1); i++) {
+ txdata[i] = ((int16_t*)dummy_tx_b)[i];
+ }
+ }
+
+ // TDD: turn on tx switch N_TA_offset before by setting buffer in these samples to 0
+ if ((slot == 0) &&
+ ((((fp->tdd_config==0) ||
+ (fp->tdd_config==1) ||
+ (fp->tdd_config==2) ||
+ (fp->tdd_config==6)) &&
+ (subframe==0)) || (subframe==5))) {
+
+ for (i=0; i<ru->N_TA_offset; i++) {
+ tx_offset = (int)slot_offset+i-ru->N_TA_offset/2;
+ if (tx_offset<0)
+ tx_offset += LTE_NUMBER_OF_SUBFRAMES_PER_FRAME*fp->samples_per_tti;
+
+ if (tx_offset>=(LTE_NUMBER_OF_SUBFRAMES_PER_FRAME*fp->samples_per_tti))
+ tx_offset -= LTE_NUMBER_OF_SUBFRAMES_PER_FRAME*fp->samples_per_tti;
+
+ ru->common.txdata[aa][tx_offset] = 0x00000000;
+ }
+ }
+ LOG_D(PHY,"feptx_ofdm (TXPATH): frame %d, subframe %d: txp (time %p) %d dB, txp (freq) %d dB\n",
+ ru->proc.frame_tx,subframe,txdata,dB_fixed(signal_energy((int32_t*)txdata,fp->samples_per_tti)),
+ dB_fixed(signal_energy_nodc(ru->common.txdataF_BF[aa],2*slot_sizeF)));
+ }
+}
+
+static void *feptx_thread(void *param) {
+
+ RU_t *ru = (RU_t *)param;
+ RU_proc_t *proc = &ru->proc;
+
+ thread_top_init("feptx_thread",0,870000,1000000,1000000);
+
+ while (!oai_exit) {
+
+ if (wait_on_condition(&proc->mutex_feptx,&proc->cond_feptx,&proc->instance_cnt_feptx,"feptx thread")<0) break;
+ feptx0(ru,1);
+ if (release_thread(&proc->mutex_feptx,&proc->instance_cnt_feptx,"feptx thread")<0) break;
+
+ if (pthread_cond_signal(&proc->cond_feptx) != 0) {
+ printf("[eNB] ERROR pthread_cond_signal for feptx thread exit\n");
+ exit_fun( "ERROR pthread_cond_signal" );
+ return NULL;
+ }
+ }
+
+
+
+ return(NULL);
+}
+
+void feptx_ofdm_2thread(RU_t *ru) {
+
+ LTE_DL_FRAME_PARMS *fp=&ru->frame_parms;
+ RU_proc_t *proc = &ru->proc;
+ struct timespec wait;
+ int subframe = ru->proc.subframe_tx;
+
+ wait.tv_sec=0;
+ wait.tv_nsec=5000000L;
+
+ start_meas(&ru->ofdm_demod_stats);
+
+ if (subframe_select(fp,subframe) == SF_UL) return;
+
+ if (subframe_select(fp,subframe)==SF_DL) {
+ // If this is not an S-subframe
+ if (pthread_mutex_timedlock(&proc->mutex_feptx,&wait) != 0) {
+ printf("[RU] ERROR pthread_mutex_lock for feptx thread (IC %d)\n", proc->instance_cnt_feptx);
+ exit_fun( "error locking mutex_feptx" );
+ return;
+ }
+
+ if (proc->instance_cnt_feptx==0) {
+ printf("[RU] FEPtx thread busy\n");
+ exit_fun("FEPtx thread busy");
+ pthread_mutex_unlock( &proc->mutex_feptx );
+ return;
+ }
+
+ ++proc->instance_cnt_feptx;
+
+
+ if (pthread_cond_signal(&proc->cond_feptx) != 0) {
+ printf("[RU] ERROR pthread_cond_signal for feptx thread\n");
+ exit_fun( "ERROR pthread_cond_signal" );
+ return;
+ }
+
+ pthread_mutex_unlock( &proc->mutex_feptx );
+ }
+
+ // call first slot in this thread
+
+ feptx0(ru,0);
+
+ wait_on_busy_condition(&proc->mutex_feptx,&proc->cond_feptx,&proc->instance_cnt_feptx,"feptx thread");
+
+ stop_meas(&ru->ofdm_demod_stats);
+
+}
+
void feptx_ofdm(RU_t *ru) {
LTE_DL_FRAME_PARMS *fp=&ru->frame_parms;
@@ -237,11 +397,6 @@ void feptx_prec(RU_t *ru) {
}
}
-typedef struct {
- RU_t *ru;
- int slot;
-} fep_task;
-
void fep0(RU_t *ru,int slot) {
RU_proc_t *proc = &ru->proc;
@@ -262,8 +417,6 @@ void fep0(RU_t *ru,int slot) {
-extern int oai_exit;
-
static void *fep_thread(void *param) {
RU_t *ru = (RU_t *)param;
@@ -289,6 +442,20 @@ static void *fep_thread(void *param) {
return(NULL);
}
+void init_feptx_thread(RU_t *ru,pthread_attr_t *attr_feptx) {
+
+ RU_proc_t *proc = &ru->proc;
+
+ proc->instance_cnt_feptx = -1;
+
+ pthread_mutex_init( &proc->mutex_feptx, NULL);
+ pthread_cond_init( &proc->cond_feptx, NULL);
+
+ pthread_create(&proc->pthread_feptx, attr_feptx, feptx_thread, (void*)ru);
+
+
+}
+
void init_fep_thread(RU_t *ru,pthread_attr_t *attr_fep) {
RU_proc_t *proc = &ru->proc;
--
GitLab