reducing some logs and fixing some vcd traces
This commit is contained in:
@@ -505,6 +505,7 @@ void nr_fill_indication(PHY_VARS_gNB *gNB, int frame, int slot_rx, int ULSCH_id,
|
|||||||
gNB->UL_INFO.rx_ind.number_of_pdus++;
|
gNB->UL_INFO.rx_ind.number_of_pdus++;
|
||||||
|
|
||||||
pthread_mutex_unlock(&gNB->UL_INFO_mutex);
|
pthread_mutex_unlock(&gNB->UL_INFO_mutex);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Function to fill UL RB mask to be used for N0 measurements
|
// Function to fill UL RB mask to be used for N0 measurements
|
||||||
@@ -758,8 +759,11 @@ int phy_procedures_gNB_uespec_RX(PHY_VARS_gNB *gNB, int frame_rx, int slot_rx) {
|
|||||||
pusch_decode_done = 1;
|
pusch_decode_done = 1;
|
||||||
|
|
||||||
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_NR_RX_PUSCH,1);
|
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_NR_RX_PUSCH,1);
|
||||||
start_meas(&gNB->rx_pusch_stats);
|
start_meas(&gNB->rx_pusch_stats);
|
||||||
no_sig = nr_rx_pusch(gNB, ULSCH_id, frame_rx, slot_rx, harq_pid);
|
no_sig = nr_rx_pusch(gNB, ULSCH_id, frame_rx, slot_rx, harq_pid);
|
||||||
|
stop_meas(&gNB->rx_pusch_stats);
|
||||||
|
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_NR_RX_PUSCH,0);
|
||||||
|
|
||||||
if (no_sig) {
|
if (no_sig) {
|
||||||
LOG_D(PHY, "PUSCH not detected in frame %d, slot %d\n", frame_rx, slot_rx);
|
LOG_D(PHY, "PUSCH not detected in frame %d, slot %d\n", frame_rx, slot_rx);
|
||||||
nr_fill_indication(gNB, frame_rx, slot_rx, ULSCH_id, harq_pid, 1,1);
|
nr_fill_indication(gNB, frame_rx, slot_rx, ULSCH_id, harq_pid, 1,1);
|
||||||
@@ -787,8 +791,6 @@ int phy_procedures_gNB_uespec_RX(PHY_VARS_gNB *gNB, int frame_rx, int slot_rx) {
|
|||||||
return 1;
|
return 1;
|
||||||
} else gNB->pusch_vars[ULSCH_id]->DTX=0;
|
} else gNB->pusch_vars[ULSCH_id]->DTX=0;
|
||||||
|
|
||||||
stop_meas(&gNB->rx_pusch_stats);
|
|
||||||
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_NR_RX_PUSCH,0);
|
|
||||||
//LOG_M("rxdataF_comp.m","rxF_comp",gNB->pusch_vars[0]->rxdataF_comp[0],6900,1,1);
|
//LOG_M("rxdataF_comp.m","rxF_comp",gNB->pusch_vars[0]->rxdataF_comp[0],6900,1,1);
|
||||||
//LOG_M("rxdataF_ext.m","rxF_ext",gNB->pusch_vars[0]->rxdataF_ext[0],6900,1,1);
|
//LOG_M("rxdataF_ext.m","rxF_ext",gNB->pusch_vars[0]->rxdataF_ext[0],6900,1,1);
|
||||||
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_NR_ULSCH_PROCEDURES_RX,1);
|
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_NR_ULSCH_PROCEDURES_RX,1);
|
||||||
|
|||||||
@@ -128,10 +128,12 @@ void dump_mac_stats(gNB_MAC_INST *gNB, char *output, int strlen, bool reset_rsrp
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
/*
|
||||||
print_meas(&gNB->eNB_scheduler, "DL & UL scheduling timing stats", NULL, NULL);
|
print_meas(&gNB->eNB_scheduler, "DL & UL scheduling timing stats", NULL, NULL);
|
||||||
print_meas(&gNB->schedule_dlsch,"dlsch scheduler",NULL,NULL);
|
print_meas(&gNB->schedule_dlsch,"dlsch scheduler",NULL,NULL);
|
||||||
print_meas(&gNB->rlc_data_req, "rlc_data_req",NULL,NULL);
|
print_meas(&gNB->rlc_data_req, "rlc_data_req",NULL,NULL);
|
||||||
print_meas(&gNB->rlc_status_ind,"rlc_status_ind",NULL,NULL);
|
print_meas(&gNB->rlc_status_ind,"rlc_status_ind",NULL,NULL);
|
||||||
|
*/
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -464,7 +464,7 @@ VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME(VCD_SIGNAL_DUMPER_FUNCTIONS_BEAM_SWITCHI
|
|||||||
write_package[end].buff[i] = buff[i];
|
write_package[end].buff[i] = buff[i];
|
||||||
write_thread->count_write++;
|
write_thread->count_write++;
|
||||||
write_thread->end = (write_thread->end + 1)% MAX_WRITE_THREAD_PACKAGE;
|
write_thread->end = (write_thread->end + 1)% MAX_WRITE_THREAD_PACKAGE;
|
||||||
LOG_D(HW,"Signaling TX TS %llu\n",(unsigned long long)timestamp);
|
// LOG_D(HW,"Signaling TX TS %llu\n",(unsigned long long)timestamp);
|
||||||
pthread_cond_signal(&write_thread->cond_write);
|
pthread_cond_signal(&write_thread->cond_write);
|
||||||
pthread_mutex_unlock(&write_thread->mutex_write);
|
pthread_mutex_unlock(&write_thread->mutex_write);
|
||||||
return 0;
|
return 0;
|
||||||
@@ -555,7 +555,7 @@ void *trx_usrp_write_thread(void * arg){
|
|||||||
s->tx_md.start_of_burst = (s->tx_count==0) ? true : first_packet;
|
s->tx_md.start_of_burst = (s->tx_count==0) ? true : first_packet;
|
||||||
s->tx_md.end_of_burst = last_packet;
|
s->tx_md.end_of_burst = last_packet;
|
||||||
s->tx_md.time_spec = uhd::time_spec_t::from_ticks(timestamp, s->sample_rate);
|
s->tx_md.time_spec = uhd::time_spec_t::from_ticks(timestamp, s->sample_rate);
|
||||||
LOG_D(PHY,"usrp_tx_write: tx_count %llu SoB %d, EoB %d, TS %llu\n",(unsigned long long)s->tx_count,s->tx_md.start_of_burst,s->tx_md.end_of_burst,(unsigned long long)timestamp);
|
// LOG_D(PHY,"usrp_tx_write: tx_count %llu SoB %d, EoB %d, TS %llu\n",(unsigned long long)s->tx_count,s->tx_md.start_of_burst,s->tx_md.end_of_burst,(unsigned long long)timestamp);
|
||||||
s->tx_count++;
|
s->tx_count++;
|
||||||
|
|
||||||
// bit 3 enables gpio (for backward compatibility)
|
// bit 3 enables gpio (for backward compatibility)
|
||||||
|
|||||||
@@ -429,7 +429,7 @@ static int rfsimulator_write_internal(rfsimulator_state_t *t, openair0_timestamp
|
|||||||
if (!alreadyLocked)
|
if (!alreadyLocked)
|
||||||
pthread_mutex_lock(&Sockmutex);
|
pthread_mutex_lock(&Sockmutex);
|
||||||
|
|
||||||
LOG_D(HW,"sending %d samples at time: %ld\n", nsamps, timestamp);
|
//LOG_D(HW,"sending %d samples at time: %ld\n", nsamps, timestamp);
|
||||||
|
|
||||||
for (int i=0; i<FD_SETSIZE; i++) {
|
for (int i=0; i<FD_SETSIZE; i++) {
|
||||||
buffer_t *b=&t->buf[i];
|
buffer_t *b=&t->buf[i];
|
||||||
@@ -464,8 +464,8 @@ static int rfsimulator_write_internal(rfsimulator_state_t *t, openair0_timestamp
|
|||||||
if (!alreadyLocked)
|
if (!alreadyLocked)
|
||||||
pthread_mutex_unlock(&Sockmutex);
|
pthread_mutex_unlock(&Sockmutex);
|
||||||
|
|
||||||
LOG_D(HW,"sent %d samples at time: %ld->%ld, energy in first antenna: %d\n",
|
//LOG_D(HW,"sent %d samples at time: %ld->%ld, energy in first antenna: %d\n",
|
||||||
nsamps, timestamp, timestamp+nsamps, signal_energy(samplesVoid[0], nsamps) );
|
// nsamps, timestamp, timestamp+nsamps, signal_energy(samplesVoid[0], nsamps) );
|
||||||
return nsamps;
|
return nsamps;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -536,7 +536,7 @@ static bool flushInput(rfsimulator_state_t *t, int timeout, int nsamps_for_initi
|
|||||||
} else if ( sz == 0 )
|
} else if ( sz == 0 )
|
||||||
continue;
|
continue;
|
||||||
|
|
||||||
LOG_D(HW, "Socket rcv %zd bytes\n", sz);
|
//LOG_D(HW, "Socket rcv %zd bytes\n", sz);
|
||||||
AssertFatal((b->remainToTransfer-=sz) >= 0, "");
|
AssertFatal((b->remainToTransfer-=sz) >= 0, "");
|
||||||
b->transferPtr+=sz;
|
b->transferPtr+=sz;
|
||||||
|
|
||||||
@@ -599,11 +599,11 @@ static bool flushInput(rfsimulator_state_t *t, int timeout, int nsamps_for_initi
|
|||||||
if ( b->headerMode==false ) {
|
if ( b->headerMode==false ) {
|
||||||
if ( ! b->trashingPacket ) {
|
if ( ! b->trashingPacket ) {
|
||||||
b->lastReceivedTS=b->th.timestamp+b->th.size-byteToSample(b->remainToTransfer,b->th.nbAnt);
|
b->lastReceivedTS=b->th.timestamp+b->th.size-byteToSample(b->remainToTransfer,b->th.nbAnt);
|
||||||
LOG_D(HW,"UEsock: %d Set b->lastReceivedTS %ld\n", fd, b->lastReceivedTS);
|
//LOG_D(HW,"UEsock: %d Set b->lastReceivedTS %ld\n", fd, b->lastReceivedTS);
|
||||||
}
|
}
|
||||||
|
|
||||||
if ( b->remainToTransfer==0) {
|
if ( b->remainToTransfer==0) {
|
||||||
LOG_D(HW,"UEsock: %d Completed block reception: %ld\n", fd, b->lastReceivedTS);
|
//LOG_D(HW,"UEsock: %d Completed block reception: %ld\n", fd, b->lastReceivedTS);
|
||||||
b->headerMode=true;
|
b->headerMode=true;
|
||||||
b->transferPtr=(char *)&b->th;
|
b->transferPtr=(char *)&b->th;
|
||||||
b->remainToTransfer=sizeof(samplesBlockHeader_t);
|
b->remainToTransfer=sizeof(samplesBlockHeader_t);
|
||||||
|
|||||||
Reference in New Issue
Block a user