/*******************************************************************************
    OpenAirInterface
    Copyright(c) 1999 - 2014 Eurecom

    OpenAirInterface is free software: you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.


    OpenAirInterface is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with OpenAirInterface.The full GNU General Public License is
    included in this distribution in the file called "COPYING". If not,
    see <http://www.gnu.org/licenses/>.

   Contact Information
   OpenAirInterface Admin: openair_admin@eurecom.fr
   OpenAirInterface Tech : openair_tech@eurecom.fr
   OpenAirInterface Dev  : openair4g-devel@eurecom.fr

   Address      : Eurecom, Campus SophiaTech, 450 Route des Chappes, CS 50193 - 06904 Biot Sophia Antipolis cedex, FRANCE

 *******************************************************************************/

#include <string.h>
#include <math.h>
#include <unistd.h>
#include <stdint.h>
#include <stdio.h>
#include <time.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/mman.h>

#include "SIMULATION/TOOLS/defs.h"
#include "SIMULATION/RF/defs.h"
#include "PHY/types.h"
#include "PHY/defs.h"
#include "PHY/extern.h"
#include "MAC_INTERFACE/extern.h"

#ifdef OPENAIR2
#include "LAYER2/MAC/defs.h"
#include "LAYER2/MAC/extern.h"
#include "PHY_INTERFACE/extern.h"
#endif

#include "../USER/oaisim.h"
#include "channel_sim_proc.h"
#include "interface.h"
#include "Tsync.h"
#include "Process.h"

#define FILENAMEMAX 255

//#define DEBUG_SIM
void Process_Func(int node_id,int port,double **r_re0,double **r_im0,double **r_re,double **r_im,double **s_re,double **s_im,
                  node_desc_t *enb_data[NUMBER_OF_eNB_MAX],node_desc_t *ue_data[NUMBER_OF_UE_MAX],u8 abstraction_flag,LTE_DL_FRAME_PARMS *frame_parms)
{

  if(node_id<MAX_eNB)
    eNB_Inst(node_id,port,r_re0,r_im0,r_re,r_im,s_re,s_im,enb_data,abstraction_flag,frame_parms);
  else
    UE_Inst(node_id,port,r_re0,r_im0,r_re,r_im,s_re,s_im,ue_data,abstraction_flag,frame_parms);


}
void UE_Inst(int node_id,int port,double **r_re0,double **r_im0,double **r_re,double **r_im,double **s_re,double **s_im,
             node_desc_t *ue_data[NUMBER_OF_UE_MAX],u8 abstraction_flag,LTE_DL_FRAME_PARMS *frame_parms)
{


  int next_slot,last_slot,slot=0,UE_id=0,eNB_id=0;
  lte_subframe_t direction;
  printf("UE [ %d ] Starts \n",node_id-MAX_eNB);
  //   init_mmap(node_id,frame_parms, &s_re, &s_im, &r_re, &r_im, &r_re0, &r_im0);
  init_channel_vars (frame_parms, &s_re, &s_im, &r_re, &r_im, &r_re0, &r_im0);
  mmap_ue(node_id,&PHY_vars_UE_g[0]->lte_ue_common_vars.txdata,&PHY_vars_UE_g[0]->lte_ue_common_vars.rxdata,frame_parms);

  // Interface_init(port,node_id);
  char p_input[FILENAMEMAX];
  int fd_pipe;
  int fd_channel;
  mkfifo("/tmp/channel", 0666);
  fd_channel=open("/tmp/channel",O_RDWR,0);
  sprintf(p_input,"/tmp/pipe_%d",node_id);
  mkfifo(p_input, 0666);
  fd_pipe=open(p_input,O_RDWR,0);
  // IntInitAll();
  mac_xface->frame=0;

  while(1) {
    // wait_4slot(&slot,&mac_xface->frame);
    read(fd_pipe,&slot,sizeof(slot));

    last_slot = (slot - 1)%20;

    if (last_slot <0)
      last_slot+=20;

    next_slot = (slot + 1)%20;

    direction = subframe_select(frame_parms,next_slot>>1);
#ifdef DEBUG_SIM
    printf("\n\n[SIM] EMU PHY procedures UE %d for frame %d, slot %d (subframe %d)\n",
           UE_id,mac_xface->frame, slot, (next_slot >> 1));
#endif

    if (PHY_vars_UE_g[UE_id]->UE_mode[0] != NOT_SYNCHED) {
      if ((mac_xface->frame)>0) {
        phy_procedures_UE_lte ((last_slot),(next_slot), PHY_vars_UE_g[UE_id], 0, abstraction_flag);
      }
    } else {
      if (((mac_xface->frame)>0) && ((last_slot) == (SLOTS_PER_FRAME-1))) {
        initial_sync(PHY_vars_UE_g[UE_id]);
      }
    }


    if( direction == SF_UL || (direction == SF_S && next_slot%2!=0)) {
      do_OFDM_mod(PHY_vars_UE_g[UE_id]->lte_ue_common_vars.txdataF,PHY_vars_UE_g[UE_id]->lte_ue_common_vars.txdata,next_slot,&PHY_vars_UE_g[UE_id]->lte_frame_parms);
    }

    write(fd_channel,&node_id,sizeof(node_id));

    //  send_exec_complete(CHANNEL_PORT);
    if(slot==19)
      (mac_xface->frame)++;

  }

}

void eNB_Inst(int node_id,int port,double **r_re0,double **r_im0,double **r_re,double **r_im,double **s_re,double **s_im,
              node_desc_t *enb_data[NUMBER_OF_eNB_MAX],u8 abstraction_flag,LTE_DL_FRAME_PARMS *frame_parms)
{
  int next_slot,last_slot,slot=0,UE_id=0,eNB_id=0;
  lte_subframe_t direction;
  printf("eNB [ %d ] Starts \n",node_id);

  // init_mmap(node_id,frame_parms, &s_re, &s_im, &r_re, &r_im, &r_re0, &r_im0);
  init_channel_vars (frame_parms, &s_re, &s_im, &r_re, &r_im, &r_re0, &r_im0);
  mmap_enb(node_id,PHY_vars_eNB_g[0]->lte_eNB_common_vars.txdata,PHY_vars_eNB_g[0]->lte_eNB_common_vars.rxdata,frame_parms);

  // Interface_init(port,node_id);
  // IntInitAll();
  char p_input[FILENAMEMAX];
  int fd_pipe;
  int fd_channel;

  mkfifo("/tmp/channel", 0666);
  fd_channel=open("/tmp/channel",O_RDWR,0);
  sprintf(p_input,"/tmp/pipe_%d",node_id);
  mkfifo(p_input, 0666);
  fd_pipe=open(p_input, O_RDWR,0);
  mac_xface->frame=0;

  while(1) {
    // wait_4slot(&slot,&mac_xface->frame);
    read(fd_pipe,&slot,sizeof(slot));

    last_slot = (slot - 1)%20;

    if (last_slot <0)
      last_slot+=20;

    next_slot = (slot + 1)%20;
    direction = subframe_select(frame_parms,next_slot>>1);
#ifdef DEBUG_SIM
    printf
    ("\n\n [SIM]EMU PHY procedures eNB %d for frame %d, slot %d (subframe %d) (rxdataF_ext %p) Nid_cell %d\n",
     eNB_id, mac_xface->frame, slot, next_slot >> 1,
     PHY_vars_eNB_g[0]->lte_eNB_ulsch_vars[0]->rxdataF_ext, PHY_vars_eNB_g[eNB_id]->lte_frame_parms.Nid_cell);
#endif
    phy_procedures_eNB_lte (last_slot, next_slot, PHY_vars_eNB_g[eNB_id], abstraction_flag);

    if( direction == SF_DL || (direction == SF_S && next_slot%2==0)) {
      do_OFDM_mod(PHY_vars_eNB_g[eNB_id]->lte_eNB_common_vars.txdataF[0],
                  PHY_vars_eNB_g[eNB_id]->lte_eNB_common_vars.txdata[0],
                  next_slot,
                  &PHY_vars_eNB_g[eNB_id]->lte_frame_parms);
    }

    write(fd_channel,&node_id,sizeof(node_id));

    //  send_exec_complete(CHANNEL_PORT);
    if(slot==19)
      (mac_xface->frame)++;
  }

}

void Channel_Inst(int node_id,int port,double **s_re[MAX_eNB+MAX_UE],double **s_im[MAX_eNB+MAX_UE],double **r_re[MAX_eNB+MAX_UE],double **r_im[MAX_eNB+MAX_UE],double **r_re0,double **r_im0,
                  double **r_re0_d[MAX_UE][MAX_eNB],double **r_im0_d[MAX_UE][MAX_eNB],double **r_re0_u[MAX_eNB][MAX_UE],double **r_im0_u[MAX_eNB][MAX_UE],channel_desc_t *eNB2UE[NUMBER_OF_eNB_MAX][NUMBER_OF_UE_MAX],
                  channel_desc_t *UE2eNB[NUMBER_OF_UE_MAX][NUMBER_OF_eNB_MAX],node_desc_t *enb_data[NUMBER_OF_eNB_MAX],node_desc_t *ue_data[NUMBER_OF_UE_MAX],u8 abstraction_flag,LTE_DL_FRAME_PARMS *frame_parms)
{

  // Interface_init(port,node_id);
  // IntInitAll();
  mkfifo("/tmp/channel", 0666);
  fd_channel=open("/tmp/channel", O_RDWR ,0);

  int next_slot,last_slot,slot=0,UE_id=0,eNB_id=0;
  lte_subframe_t direction;
  char in_buffer[100];

  int ci,ji=0;

  for(ci=0; ci<NB_eNB_INST; ci++) {
    mmap_enb(ji,tx[ci],rx[ci],frame_parms);
    init_channel_vars (frame_parms, &(s_re[ci]), &(s_im[ci]), &(r_re[ci]), &(r_im[ci]), &(r_re0), &(r_im0));
    // init_mmap_channel(ji,frame_parms, &(s_re[ci]), &(s_im[ci]), &(r_re[ci]), &(r_im[ci]), &(r_re0), &(r_im0));
    sprintf(in_buffer, "/tmp/pipe_%d",ji);
    mkfifo(in_buffer, 0666);
    fd_NB[ci]=open(in_buffer, O_RDWR ,0);
    ji++;
  }

  ji=0;

  for(ci=NB_eNB_INST; ci<(NB_eNB_INST+NB_UE_INST); ci++) {
    mmap_enb(MAX_eNB+ji,tx[ci],rx[ci],frame_parms);
    init_channel_vars (frame_parms, &(s_re[ci]), &(s_im[ci]), &(r_re[ci]), &(r_im[ci]), &(r_re0), &(r_im0));
    //  init_mmap_channel(MAX_eNB+ji,frame_parms, &(s_re[ci]), &(s_im[ci]), &(r_re[ci]), &(r_im[ci]), &(r_re0), &(r_im0));
    sprintf(in_buffer, "/tmp/pipe_%d",MAX_eNB+ji);
    mkfifo(in_buffer, 0666);

    fd_NB[ci]=open(in_buffer, O_RDWR ,0);
    ji++;
  }

  for (eNB_id = 0; eNB_id < NB_eNB_INST; eNB_id++) {
    for (UE_id = 0; UE_id < NB_UE_INST; UE_id++) {
      init_rre(frame_parms,&(r_re0_u[eNB_id][UE_id]),&(r_im0_u[eNB_id][UE_id]));
      init_rre(frame_parms,&(r_re0_d[UE_id][eNB_id]),&(r_im0_d[UE_id][eNB_id]));
    }
  }

  for(eNB_id=0; eNB_id<NB_eNB_INST; eNB_id++) {
    for(UE_id=0; UE_id<NB_UE_INST; UE_id++) {
      e2u_t[eNB_id][UE_id]=(ch_thread*)calloc(1,sizeof(ch_thread));
    }
  }

  for(UE_id=0; UE_id<NB_UE_INST; UE_id++) {
    for(eNB_id=0; eNB_id<NB_eNB_INST; eNB_id++) {
      u2e_t[UE_id][eNB_id]=(ch_thread*)calloc(1,sizeof(ch_thread));
    }
  }

  pthread_t cthr_u[NB_eNB_INST][NB_UE_INST];
  pthread_t cthr_d[NB_UE_INST][NB_eNB_INST];


  pthread_mutex_init(&downlink_mutex_channel,NULL);
  pthread_mutex_init(&uplink_mutex_channel,NULL);
  pthread_mutex_init(&exclusive,NULL);

  if (pthread_cond_init (&downlink_cond_channel, NULL)) exit(1);

  if (pthread_cond_init (&uplink_cond_channel, NULL)) exit(1);

  if (pthread_mutex_lock(&downlink_mutex_channel)) exit(1);

  if (pthread_mutex_lock(&uplink_mutex_channel)) exit(1);

  NUM_THREAD_DOWNLINK=0;

  for (UE_id = 0; UE_id < (NB_UE_INST); UE_id++) {
    for (eNB_id=0; eNB_id<(NB_eNB_INST); eNB_id++) {
      u2e_t[UE_id][eNB_id]->thread_id=NUM_THREAD_DOWNLINK;
      u2e_t[UE_id][eNB_id]->eNB_id=eNB_id;
      u2e_t[UE_id][eNB_id]->UE_id=UE_id;
      u2e_t[UE_id][eNB_id]->r_re0=r_re0_d[UE_id][eNB_id];
      u2e_t[UE_id][eNB_id]->r_im0=r_im0_d[UE_id][eNB_id];
      u2e_t[UE_id][eNB_id]->r_re=r_re[NB_eNB_INST+UE_id];
      u2e_t[UE_id][eNB_id]->r_im=r_im[NB_eNB_INST+UE_id];
      u2e_t[UE_id][eNB_id]->s_im=s_im[eNB_id];
      u2e_t[UE_id][eNB_id]->s_re=s_re[eNB_id];
      u2e_t[UE_id][eNB_id]->eNB2UE=eNB2UE[eNB_id][UE_id];
      u2e_t[UE_id][eNB_id]->UE2eNB=UE2eNB[UE_id][eNB_id];
      u2e_t[UE_id][eNB_id]->enb_data=enb_data[eNB_id];
      u2e_t[UE_id][eNB_id]->ue_data=ue_data[UE_id];
      u2e_t[UE_id][eNB_id]->next_slot=&next_slot;
      u2e_t[UE_id][eNB_id]->abstraction_flag=&abstraction_flag;
      u2e_t[UE_id][eNB_id]->frame_parms=frame_parms;
      u2e_t[UE_id][eNB_id]->tx_data[3]=tx[eNB_id][3];
      u2e_t[UE_id][eNB_id]->rx_data[3]=rx[NB_eNB_INST+UE_id][3];

      if(pthread_cond_init (&downlink_cond[eNB_id][UE_id], NULL)) exit(1);

      if(pthread_mutex_lock(&downlink_mutex[eNB_id][UE_id])) exit(1);

      pthread_create (&cthr_d[UE_id][eNB_id], NULL, do_DL_sig_channel_T,(void*)(u2e_t[UE_id][eNB_id]));
      NUM_THREAD_DOWNLINK++;
    }
  }

  NUM_THREAD_UPLINK=0;

  for (eNB_id=0; eNB_id<(NB_eNB_INST); eNB_id++) {
    for (UE_id = 0; UE_id < (NB_UE_INST); UE_id++) {
      e2u_t[eNB_id][UE_id]->thread_id=NUM_THREAD_UPLINK;
      e2u_t[eNB_id][UE_id]->eNB_id=eNB_id;
      e2u_t[eNB_id][UE_id]->UE_id=UE_id;
      e2u_t[eNB_id][UE_id]->r_re=r_re[eNB_id];
      e2u_t[eNB_id][UE_id]->r_im=r_im[eNB_id];
      e2u_t[eNB_id][UE_id]->r_re0=r_re0_u[eNB_id][UE_id];
      e2u_t[eNB_id][UE_id]->r_im0=r_im0_u[eNB_id][UE_id];
      e2u_t[eNB_id][UE_id]->s_im=s_im[NB_eNB_INST+UE_id];
      e2u_t[eNB_id][UE_id]->s_re=s_re[NB_eNB_INST+UE_id];
      e2u_t[eNB_id][UE_id]->eNB2UE=eNB2UE[eNB_id][UE_id];
      e2u_t[eNB_id][UE_id]->UE2eNB=UE2eNB[UE_id][eNB_id];
      e2u_t[eNB_id][UE_id]->enb_data=enb_data[eNB_id];
      e2u_t[eNB_id][UE_id]->ue_data=ue_data[UE_id];
      e2u_t[eNB_id][UE_id]->next_slot=&next_slot;
      e2u_t[eNB_id][UE_id]->abstraction_flag=&abstraction_flag;
      e2u_t[eNB_id][UE_id]->frame_parms=frame_parms;
      e2u_t[eNB_id][UE_id]->tx_data[3]=tx[NB_eNB_INST+UE_id][3];
      e2u_t[eNB_id][UE_id]->rx_data[3]=rx[eNB_id][3];

      if(pthread_cond_init (&uplink_cond[UE_id][eNB_id], NULL)) exit(1);

      if(pthread_mutex_lock(&uplink_mutex[UE_id][eNB_id])) exit(1);

      pthread_create (&cthr_u[eNB_id][UE_id], NULL, do_UL_sig_channel_T,(void*)e2u_t[eNB_id][UE_id]);
      NUM_THREAD_UPLINK++;
    }
  }
}

void Channel_DL(double **s_re[MAX_eNB+MAX_UE],double **s_im[MAX_eNB+MAX_UE],double **r_re[MAX_eNB+MAX_UE],double **r_im[MAX_eNB+MAX_UE],double **r_re0,double **r_im0,
                double **r_re0_d[MAX_UE][MAX_eNB],double **r_im0_d[MAX_UE][MAX_eNB],double **r_re0_u[MAX_eNB][MAX_UE],double **r_im0_u[MAX_eNB][MAX_UE],channel_desc_t *eNB2UE[NUMBER_OF_eNB_MAX][NUMBER_OF_UE_MAX],
                channel_desc_t *UE2eNB[NUMBER_OF_UE_MAX][NUMBER_OF_eNB_MAX],node_desc_t *enb_data[NUMBER_OF_eNB_MAX],node_desc_t *ue_data[NUMBER_OF_UE_MAX],u8 abstraction_flag,LTE_DL_FRAME_PARMS *frame_parms,
                int slot)
{

  int count=0;
  int next_slot,last_slot,UE_id=0,eNB_id=0;
  lte_subframe_t direction;
  s32 **txdata,**rxdata;
  double tx_pwr, rx_pwr;
  s32 rx_pwr2;
  u32 i;
  u32 slot_offset;

  for (eNB_id=0; eNB_id<(NB_eNB_INST); eNB_id++) {
    write(fd_NB[eNB_id],&slot,sizeof(slot));
    count++;
    //send_exec_msg(mac_xface->frame,slot,eNB_PORT+eNB_id);
  }


  while(count--) {
    int dummy=1;
    read(fd_channel,&dummy,sizeof(dummy));
    //wait_4Msg();
  }




  for (eNB_id=0; eNB_id<(NB_eNB_INST); eNB_id++) {
    frame_parms = &PHY_vars_eNB_g[eNB_id]->lte_frame_parms;
    slot_offset = (nslot)*(frame_parms->samples_per_tti>>1);
    txdata =tx[eNB_id][0];
    tx_pwr = dac_fixed_gain(s_re[eNB_id],
                            s_im[eNB_id],
                            txdata,
                            slot_offset,
                            frame_parms->nb_antennas_tx,
                            frame_parms->samples_per_tti>>1,
                            14,
                            40);
    printf("[SIM][DL] eNB %d: tx_pwr %f dB for slot %d (subframe %d)\n",eNB_id,10*log10(tx_pwr),nslot,nslot>>1);
  }

  _COT=0;

  for (UE_id = 0; UE_id < (NB_UE_INST); UE_id++) {
    for (eNB_id=0; eNB_id<(NB_eNB_INST); eNB_id++) {
      if(pthread_cond_signal(&downlink_cond[eNB_id][UE_id])) exit(1);

      if(pthread_mutex_unlock(&downlink_mutex[eNB_id][UE_id])) exit(1);
    }
  }

  if(pthread_cond_wait(&downlink_cond_channel, &downlink_mutex_channel)) exit(1);

  for (UE_id = 0; UE_id < (NB_UE_INST); UE_id++) {
    Clean_Param(r_re[NB_eNB_INST+UE_id],r_im[NB_eNB_INST+UE_id],frame_parms);

    for (eNB_id=0; eNB_id<(NB_eNB_INST); eNB_id++) {
      Channel_Out(SF_DL,eNB_id,UE_id,r_re[NB_eNB_INST+UE_id],r_im[NB_eNB_INST+UE_id],r_re0_d[UE_id][eNB_id],r_im0_d[UE_id][eNB_id],frame_parms);
      //  adc_channel(eNB_id,UE_id,r_re[NB_eNB_INST+UE_id],r_im[NB_eNB_INST+UE_id]);

    }
  }

  count=0;

  for (UE_id = 0; UE_id < (NB_UE_INST); UE_id++)
    if (mac_xface->frame >= (UE_id * 10)) {
      write(fd_NB[NB_eNB_INST+UE_id],&slot,sizeof(slot));
      //send_exec_msg(mac_xface->frame,slot,UE_PORT+UE_id);
      count++;
    }

  while(count--) {
    int dummy=1;
    read(fd_channel,&dummy,sizeof(dummy));
    //wait_4Msg();
  }

}


void Channel_UL(double **s_re[MAX_eNB+MAX_UE],double **s_im[MAX_eNB+MAX_UE],double **r_re[MAX_eNB+MAX_UE],double **r_im[MAX_eNB+MAX_UE],double **r_re0,double **r_im0,
                double **r_re0_d[MAX_UE][MAX_eNB],double **r_im0_d[MAX_UE][MAX_eNB],double **r_re0_u[MAX_eNB][MAX_UE],double **r_im0_u[MAX_eNB][MAX_UE],channel_desc_t *eNB2UE[NUMBER_OF_eNB_MAX][NUMBER_OF_UE_MAX],
                channel_desc_t *UE2eNB[NUMBER_OF_UE_MAX][NUMBER_OF_eNB_MAX],node_desc_t *enb_data[NUMBER_OF_eNB_MAX],node_desc_t *ue_data[NUMBER_OF_UE_MAX],u8 abstraction_flag,LTE_DL_FRAME_PARMS *frame_parms,
                int slot)
{
  int count=0;
  int next_slot,last_slot,UE_id=0,eNB_id=0;
  lte_subframe_t direction;
  s32 **txdata,**rxdata;
  double tx_pwr, rx_pwr;
  s32 rx_pwr2;
  u32 i;
  u32 slot_offset;

  for (UE_id = 0; UE_id < (NB_UE_INST); UE_id++)
    if (mac_xface->frame >= (UE_id * 10)) {
      write(fd_NB[NB_eNB_INST+UE_id],&slot,sizeof(slot));
      //send_exec_msg(mac_xface->frame,slot,UE_PORT+UE_id);
      count++;
    }

  while(count--) {
    int dummy=1;
    read(fd_channel,&dummy,sizeof(dummy));
    //wait_4Msg();
  }



  for (UE_id = 0; UE_id < (NB_UE_INST); UE_id++) {
    frame_parms = &PHY_vars_UE_g[UE_id]->lte_frame_parms;
    slot_offset = (nslot)*(frame_parms->samples_per_tti>>1);
    txdata =tx[NB_eNB_INST+UE_id][0]; //PHY_vars_UE_g[UE_id]->lte_ue_common_vars.txdata;
    tx_pwr = dac_fixed_gain(s_re[NB_eNB_INST+UE_id],
                            s_im[NB_eNB_INST+UE_id],
                            txdata,
                            slot_offset,
                            frame_parms->nb_antennas_tx,
                            frame_parms->samples_per_tti>>1,
                            14,
                            18);
    printf("[SIM][UL] UE %d tx_pwr %f dB for slot %d (subframe %d)\n",UE_id,10*log10(tx_pwr),nslot,nslot>>1);
    rx_pwr = signal_energy_fp(s_re[NB_eNB_INST+UE_id],s_im[NB_eNB_INST+UE_id],frame_parms->nb_antennas_rx,frame_parms->samples_per_tti>>1,0);
    printf("[SIM][UL] UE %d tx_pwr %f dB for slot %d (subframe %d)\n",UE_id,10*log10(rx_pwr),nslot,nslot>>1);
  }

  _COT_U=0;

  for (eNB_id=0; eNB_id<(NB_eNB_INST); eNB_id++) {
    for (UE_id = 0; UE_id < (NB_UE_INST); UE_id++) {
      if ( pthread_cond_signal(&uplink_cond[UE_id][eNB_id])) exit(1);

      if ( pthread_mutex_unlock(&uplink_mutex[UE_id][eNB_id])) exit(1);
    }
  }

  if ( pthread_cond_wait(&uplink_cond_channel, &uplink_mutex_channel)) exit(1);

  for (eNB_id=0; eNB_id<(NB_eNB_INST); eNB_id++) {
    Clean_Param(r_re[eNB_id],r_im[eNB_id],frame_parms);

    for (UE_id = 0; UE_id < (NB_UE_INST); UE_id++) {
      Channel_Out(SF_UL,eNB_id,UE_id,r_re[eNB_id],r_im[eNB_id],r_re0_u[eNB_id][UE_id],r_im0_u[eNB_id][UE_id],frame_parms);
      printf("[SIM][DL] eNB %d: tx_pwr %f dB for slot %d (subframe %d)\n",eNB_id,10*log10(tx_pwr),next_slot,next_slot>>1);
    }
  }


  count=0;

  for (eNB_id=0; eNB_id<(NB_eNB_INST); eNB_id++) {
    write(fd_NB[eNB_id],&slot,sizeof(slot));
    //  send_exec_msg(mac_xface->frame,slot,eNB_PORT+eNB_id);
    count++;
  }

  while(count--) {
    int dummy=1;
    read(fd_channel,&dummy,sizeof(dummy));
    //  wait_4Msg();
  }

}

void Channel_Func(double **s_re[MAX_eNB+MAX_UE],double **s_im[MAX_eNB+MAX_UE],double **r_re[MAX_eNB+MAX_UE],double **r_im[MAX_eNB+MAX_UE],double **r_re0,double **r_im0,
                  double **r_re0_d[MAX_UE][MAX_eNB],double **r_im0_d[MAX_UE][MAX_eNB],double **r_re0_u[MAX_eNB][MAX_UE],double **r_im0_u[MAX_eNB][MAX_UE],channel_desc_t *eNB2UE[NUMBER_OF_eNB_MAX][NUMBER_OF_UE_MAX],
                  channel_desc_t *UE2eNB[NUMBER_OF_UE_MAX][NUMBER_OF_eNB_MAX],node_desc_t *enb_data[NUMBER_OF_eNB_MAX],node_desc_t *ue_data[NUMBER_OF_UE_MAX],u8 abstraction_flag,LTE_DL_FRAME_PARMS *frame_parms,
                  int slot)
{
  int last_slot;
  lte_subframe_t direction;

  last_slot = (slot - 1)%20;

  if (last_slot <0)
    last_slot+=20;

  nslot = (slot + 1)%20;

  direction = subframe_select(frame_parms,nslot>>1);

  if( direction == SF_DL || (direction == SF_S && nslot%2==0)) {
    Channel_DL(s_re,s_im,r_re,r_im,r_re0,r_im0,r_re0_d,r_im0_d,r_re0_u,r_im0_u,eNB2UE,UE2eNB,enb_data,ue_data,abstraction_flag,frame_parms,slot);
  } else {
    Channel_UL(s_re,s_im,r_re,r_im,r_re0,r_im0,r_re0_d,r_im0_d,r_re0_u,r_im0_u,eNB2UE,UE2eNB,enb_data,ue_data,abstraction_flag,frame_parms,slot);
  }
}