Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
O
OpenXG-RAN
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Michael Black
OpenXG-RAN
Commits
8f621c3e
Commit
8f621c3e
authored
Nov 04, 2017
by
Raymond Knopp
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
bugfixes for TDD in RRU (IF4p5) and timing statistics of fronthaul and compression.
parent
d915c208
Changes
5
Hide whitespace changes
Inline
Side-by-side
Showing
5 changed files
with
71 additions
and
29 deletions
+71
-29
openair1/PHY/LTE_TRANSPORT/if4_tools.c
openair1/PHY/LTE_TRANSPORT/if4_tools.c
+44
-18
openair1/PHY/LTE_TRANSPORT/if4_tools.h
openair1/PHY/LTE_TRANSPORT/if4_tools.h
+5
-5
openair1/PHY/defs.h
openair1/PHY/defs.h
+4
-0
targets/ARCH/ETHERNET/USERSPACE/LIB/eth_udp.c
targets/ARCH/ETHERNET/USERSPACE/LIB/eth_udp.c
+2
-1
targets/RT/USER/lte-ru.c
targets/RT/USER/lte-ru.c
+16
-5
No files found.
openair1/PHY/LTE_TRANSPORT/if4_tools.c
View file @
8f621c3e
...
@@ -58,7 +58,7 @@ void send_IF4p5(RU_t *ru, int frame, int subframe, uint16_t packet_type) {
...
@@ -58,7 +58,7 @@ void send_IF4p5(RU_t *ru, int frame, int subframe, uint16_t packet_type) {
uint16_t
db_fulllength
,
db_halflength
;
uint16_t
db_fulllength
,
db_halflength
;
int
slotoffsetF
=
0
,
blockoffsetF
=
0
;
int
slotoffsetF
=
0
,
blockoffsetF
=
0
;
uint16_t
*
data_block
=
NULL
,
*
i
=
NULL
;
uint16_t
*
data_block
=
NULL
,
*
i
=
NULL
,
*
d
=
NULL
;
IF4p5_header_t
*
packet_header
=
NULL
;
IF4p5_header_t
*
packet_header
=
NULL
;
eth_state_t
*
eth
=
(
eth_state_t
*
)
(
ru
->
ifdevice
.
priv
);
eth_state_t
*
eth
=
(
eth_state_t
*
)
(
ru
->
ifdevice
.
priv
);
...
@@ -138,23 +138,48 @@ void send_IF4p5(RU_t *ru, int frame, int subframe, uint16_t packet_type) {
...
@@ -138,23 +138,48 @@ void send_IF4p5(RU_t *ru, int frame, int subframe, uint16_t packet_type) {
if
(
packet_type
==
IF4p5_PULFFT
)
{
if
(
packet_type
==
IF4p5_PULFFT
)
{
uint16_t
*
rx0
=
(
uint16_t
*
)
&
rxdataF
[
0
][
blockoffsetF
];
uint16_t
*
rx1
=
(
uint16_t
*
)
&
rxdataF
[
0
][
slotoffsetF
];
for
(
symbol_id
=
fp
->
symbols_per_tti
-
nsym
;
symbol_id
<
fp
->
symbols_per_tti
;
symbol_id
++
)
{
for
(
symbol_id
=
fp
->
symbols_per_tti
-
nsym
;
symbol_id
<
fp
->
symbols_per_tti
;
symbol_id
++
)
{
VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME
(
VCD_SIGNAL_DUMPER_VARIABLES_SEND_IF4_SYMBOL
,
symbol_id
);
VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME
(
VCD_SIGNAL_DUMPER_VARIABLES_SEND_IF4_SYMBOL
,
symbol_id
);
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_COMPR_IF
,
1
);
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_COMPR_IF
,
1
);
for
(
element_id
=
0
;
element_id
<
db_halflength
;
element_id
++
)
{
i
=
(
uint16_t
*
)
&
rxdataF
[
0
][
blockoffsetF
+
element_id
];
start_meas
(
&
ru
->
compression
);
data_block
[
element_id
]
=
((
uint16_t
)
lin2alaw_if4p5
[
*
i
])
|
((
uint16_t
)(
lin2alaw_if4p5
[
*
(
i
+
1
)]
<<
8
));
for
(
element_id
=
0
;
element_id
<
db_halflength
;
element_id
+=
8
)
{
i
=
(
uint16_t
*
)
&
rxdataF
[
0
][
slotoffsetF
+
element_id
];
i
=
(
uint16_t
*
)
&
rx0
[
element_id
];
data_block
[
element_id
+
db_halflength
]
=
((
uint16_t
)
lin2alaw_if4p5
[
*
i
])
|
((
uint16_t
)(
lin2alaw_if4p5
[
*
(
i
+
1
)]
<<
8
));
d
=
(
uint16_t
*
)
&
data_block
[
element_id
];
//if (element_id==0) LOG_I(PHY,"send_if4p5: symbol %d rxdata0 = (%d,%d)\n",symbol_id,*i,*(i+1));
d
[
0
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
0
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
1
]]
<<
8
));
d
[
1
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
2
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
3
]]
<<
8
));
}
d
[
2
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
4
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
5
]]
<<
8
));
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_COMPR_IF
,
0
);
d
[
3
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
6
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
7
]]
<<
8
));
packet_header
->
frame_status
&=
~
(
0x000f
<<
26
);
d
[
4
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
8
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
9
]]
<<
8
));
packet_header
->
frame_status
|=
(
symbol_id
&
0x000f
)
<<
26
;
d
[
5
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
10
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
11
]]
<<
8
));
d
[
6
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
12
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
13
]]
<<
8
));
d
[
7
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
14
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
15
]]
<<
8
));
i
=
(
uint16_t
*
)
&
rx1
[
element_id
];
d
=
(
uint16_t
*
)
&
data_block
[
element_id
+
db_halflength
];
d
[
0
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
0
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
1
]]
<<
8
));
d
[
1
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
2
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
3
]]
<<
8
));
d
[
2
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
4
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
5
]]
<<
8
));
d
[
3
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
6
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
7
]]
<<
8
));
d
[
4
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
8
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
9
]]
<<
8
));
d
[
5
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
10
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
11
]]
<<
8
));
d
[
6
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
12
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
13
]]
<<
8
));
d
[
7
]
=
((
uint16_t
)
lin2alaw_if4p5
[
i
[
14
]])
|
((
uint16_t
)(
lin2alaw_if4p5
[
i
[
15
]]
<<
8
));
}
stop_meas
(
&
ru
->
compression
);
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_COMPR_IF
,
0
);
packet_header
->
frame_status
&=
~
(
0x000f
<<
26
);
packet_header
->
frame_status
|=
(
symbol_id
&
0x000f
)
<<
26
;
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_WRITE_IF
,
1
);
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_WRITE_IF
,
1
);
start_meas
(
&
ru
->
transport
);
if
((
ru
->
ifdevice
.
trx_write_func
(
&
ru
->
ifdevice
,
if
((
ru
->
ifdevice
.
trx_write_func
(
&
ru
->
ifdevice
,
symbol_id
,
symbol_id
,
&
tx_buffer
,
&
tx_buffer
,
...
@@ -163,6 +188,7 @@ void send_IF4p5(RU_t *ru, int frame, int subframe, uint16_t packet_type) {
...
@@ -163,6 +188,7 @@ void send_IF4p5(RU_t *ru, int frame, int subframe, uint16_t packet_type) {
IF4p5_PULFFT
))
<
0
)
{
IF4p5_PULFFT
))
<
0
)
{
perror
(
"ETHERNET write for IF4p5_PULFFT
\n
"
);
perror
(
"ETHERNET write for IF4p5_PULFFT
\n
"
);
}
}
stop_meas
(
&
ru
->
transport
);
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_WRITE_IF
,
0
);
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_WRITE_IF
,
0
);
slotoffsetF
+=
fp
->
ofdm_symbol_size
;
slotoffsetF
+=
fp
->
ofdm_symbol_size
;
blockoffsetF
+=
fp
->
ofdm_symbol_size
;
blockoffsetF
+=
fp
->
ofdm_symbol_size
;
...
@@ -181,7 +207,7 @@ void send_IF4p5(RU_t *ru, int frame, int subframe, uint16_t packet_type) {
...
@@ -181,7 +207,7 @@ void send_IF4p5(RU_t *ru, int frame, int subframe, uint16_t packet_type) {
}
else
if
(
packet_type
>=
IF4p5_PRACH
&&
}
else
if
(
packet_type
>=
IF4p5_PRACH
&&
packet_type
<=
IF4p5_PRACH
+
4
)
{
packet_type
<=
IF4p5_PRACH
+
4
)
{
// FIX: hard coded prach samples length
// FIX: hard coded prach samples length
LOG_D
(
PHY
,
"IF4p5_PRACH: frame %d, subframe %d
\n
"
,
frame
,
subfram
e
);
LOG_D
(
PHY
,
"IF4p5_PRACH: frame %d, subframe %d
,packet type %x
\n
"
,
frame
,
subframe
,
packet_typ
e
);
db_fulllength
=
PRACH_NUM_SAMPLES
;
db_fulllength
=
PRACH_NUM_SAMPLES
;
if
(
eth
->
flags
==
ETH_RAW_IF4p5_MODE
)
{
if
(
eth
->
flags
==
ETH_RAW_IF4p5_MODE
)
{
...
@@ -222,6 +248,7 @@ void send_IF4p5(RU_t *ru, int frame, int subframe, uint16_t packet_type) {
...
@@ -222,6 +248,7 @@ void send_IF4p5(RU_t *ru, int frame, int subframe, uint16_t packet_type) {
packet_type
))
<
0
)
{
packet_type
))
<
0
)
{
perror
(
"ETHERNET write for IF4p5_PRACH
\n
"
);
perror
(
"ETHERNET write for IF4p5_PRACH
\n
"
);
}
}
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_WRITE_IF
,
0
);
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_WRITE_IF
,
0
);
}
else
{
}
else
{
AssertFatal
(
1
==
0
,
"send_IF4p5 - Unknown packet_type %x"
,
packet_type
);
AssertFatal
(
1
==
0
,
"send_IF4p5 - Unknown packet_type %x"
,
packet_type
);
...
@@ -283,7 +310,7 @@ void recv_IF4p5(RU_t *ru, int *frame, int *subframe, uint16_t *packet_type, uint
...
@@ -283,7 +310,7 @@ void recv_IF4p5(RU_t *ru, int *frame, int *subframe, uint16_t *packet_type, uint
*
subframe
=
((
packet_header
->
frame_status
)
>>
22
)
&
0x000f
;
*
subframe
=
((
packet_header
->
frame_status
)
>>
22
)
&
0x000f
;
*
packet_type
=
packet_header
->
sub_type
;
*
packet_type
=
packet_header
->
sub_type
;
LOG_D
(
PHY
,
"recv_IF4p5: Frame %d, Subframe %d: packet_type %x
\n
"
,
*
frame
,
*
subframe
,
*
packet_type
);
if
(
*
packet_type
==
IF4p5_PDLFFT
)
{
if
(
*
packet_type
==
IF4p5_PDLFFT
)
{
*
symbol_number
=
((
packet_header
->
frame_status
)
>>
26
)
&
0x000f
;
*
symbol_number
=
((
packet_header
->
frame_status
)
>>
26
)
&
0x000f
;
VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME
(
VCD_SIGNAL_DUMPER_VARIABLES_RECV_IF4_SYMBOL
,
*
symbol_number
);
VCD_SIGNAL_DUMPER_DUMP_VARIABLE_BY_NAME
(
VCD_SIGNAL_DUMPER_VARIABLES_RECV_IF4_SYMBOL
,
*
symbol_number
);
...
@@ -313,7 +340,6 @@ void recv_IF4p5(RU_t *ru, int *frame, int *subframe, uint16_t *packet_type, uint
...
@@ -313,7 +340,6 @@ void recv_IF4p5(RU_t *ru, int *frame, int *subframe, uint16_t *packet_type, uint
slotoffsetF
=
(
*
symbol_number
)
*
(
fp
->
ofdm_symbol_size
);
slotoffsetF
=
(
*
symbol_number
)
*
(
fp
->
ofdm_symbol_size
);
blockoffsetF
=
slotoffsetF
+
fp
->
ofdm_symbol_size
-
db_halflength
;
blockoffsetF
=
slotoffsetF
+
fp
->
ofdm_symbol_size
-
db_halflength
;
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_DECOMPR_IF
,
1
);
VCD_SIGNAL_DUMPER_DUMP_FUNCTION_BY_NAME
(
VCD_SIGNAL_DUMPER_FUNCTIONS_TRX_DECOMPR_IF
,
1
);
if
(
ru
->
idx
==
0
)
LOG_D
(
PHY
,
"UL_IF4p5: CC_id %d : frame %d, subframe %d, symbol %d
\n
"
,
ru
->
idx
,
*
frame
,
*
subframe
,
*
symbol_number
);
for
(
element_id
=
0
;
element_id
<
db_halflength
;
element_id
++
)
{
for
(
element_id
=
0
;
element_id
<
db_halflength
;
element_id
++
)
{
i
=
(
uint16_t
*
)
&
rxdataF
[
0
][
blockoffsetF
+
element_id
];
i
=
(
uint16_t
*
)
&
rxdataF
[
0
][
blockoffsetF
+
element_id
];
*
i
=
alaw2lin_if4p5
[
(
data_block
[
element_id
]
&
0xff
)
];
*
i
=
alaw2lin_if4p5
[
(
data_block
[
element_id
]
&
0xff
)
];
...
@@ -353,8 +379,8 @@ void recv_IF4p5(RU_t *ru, int *frame, int *subframe, uint16_t *packet_type, uint
...
@@ -353,8 +379,8 @@ void recv_IF4p5(RU_t *ru, int *frame, int *subframe, uint16_t *packet_type, uint
PRACH_BLOCK_SIZE_BYTES
);
PRACH_BLOCK_SIZE_BYTES
);
}
}
//
LOG_D(PHY,"PRACH_IF4p5: CC_id %d : frame %d, subframe %d => %d dB\n",ru->idx,*frame,*subframe,
LOG_D
(
PHY
,
"PRACH_IF4p5: CC_id %d : frame %d, subframe %d => %d dB
\n
"
,
ru
->
idx
,
*
frame
,
*
subframe
,
//
dB_fixed(signal_energy((int*)&prach_rxsigF[0][0],839)));
dB_fixed
(
signal_energy
((
int
*
)
&
prach_rxsigF
[
0
][
0
],
839
)));
for
(
idx
=
0
;
idx
<
ru
->
num_eNB
;
idx
++
)
ru
->
wakeup_prach_eNB
(
ru
->
eNB_list
[
idx
],
ru
,
*
frame
,
*
subframe
);
for
(
idx
=
0
;
idx
<
ru
->
num_eNB
;
idx
++
)
ru
->
wakeup_prach_eNB
(
ru
->
eNB_list
[
idx
],
ru
,
*
frame
,
*
subframe
);
}
else
if
(
*
packet_type
==
IF4p5_PULTICK
)
{
}
else
if
(
*
packet_type
==
IF4p5_PULTICK
)
{
...
...
openair1/PHY/LTE_TRANSPORT/if4_tools.h
View file @
8f621c3e
...
@@ -39,11 +39,11 @@
...
@@ -39,11 +39,11 @@
#define IF4p5_PULFFT 0x0019
#define IF4p5_PULFFT 0x0019
#define IF4p5_PDLFFT 0x0020
#define IF4p5_PDLFFT 0x0020
#define IF4p5_PRACH 0x0021
#define IF4p5_PRACH 0x0021
#define IF4p5_PRACH_BR_CE0 0x002
1
#define IF4p5_PRACH_BR_CE0 0x002
2
#define IF4p5_PRACH_BR_CE1 0x002
2
#define IF4p5_PRACH_BR_CE1 0x002
3
#define IF4p5_PRACH_BR_CE2 0x002
3
#define IF4p5_PRACH_BR_CE2 0x002
4
#define IF4p5_PRACH_BR_CE3 0x002
4
#define IF4p5_PRACH_BR_CE3 0x002
5
#define IF4p5_PULTICK 0x002
5
#define IF4p5_PULTICK 0x002
6
struct
IF4p5_header
{
struct
IF4p5_header
{
/// Type
/// Type
...
...
openair1/PHY/defs.h
View file @
8f621c3e
...
@@ -756,6 +756,10 @@ typedef struct RU_t_s{
...
@@ -756,6 +756,10 @@ typedef struct RU_t_s{
time_stats_t
rx_fhaul
;
time_stats_t
rx_fhaul
;
/// Timing statistics (TX Fronthaul + Compression)
/// Timing statistics (TX Fronthaul + Compression)
time_stats_t
tx_fhaul
;
time_stats_t
tx_fhaul
;
/// Timong statistics (Compression)
time_stats_t
compression
;
/// Timing statistics (Fronthaul transport)
time_stats_t
transport
;
/// RX and TX buffers for precoder output
/// RX and TX buffers for precoder output
RU_COMMON
common
;
RU_COMMON
common
;
/// beamforming weight vectors per eNB
/// beamforming weight vectors per eNB
...
...
targets/ARCH/ETHERNET/USERSPACE/LIB/eth_udp.c
View file @
8f621c3e
...
@@ -235,7 +235,8 @@ int trx_eth_write_udp_IF4p5(openair0_device *device, openair0_timestamp timestam
...
@@ -235,7 +235,8 @@ int trx_eth_write_udp_IF4p5(openair0_device *device, openair0_timestamp timestam
packet_size
=
UDP_IF4p5_PULFFT_SIZE_BYTES
(
nblocks
);
packet_size
=
UDP_IF4p5_PULFFT_SIZE_BYTES
(
nblocks
);
}
else
if
(
flags
==
IF4p5_PULTICK
)
{
}
else
if
(
flags
==
IF4p5_PULTICK
)
{
packet_size
=
UDP_IF4p5_PULTICK_SIZE_BYTES
;
packet_size
=
UDP_IF4p5_PULTICK_SIZE_BYTES
;
}
else
if
(
flags
==
IF4p5_PRACH
)
{
}
else
if
((
flags
>=
IF4p5_PRACH
)
&&
(
flags
<=
(
IF4p5_PRACH
+
4
)))
{
packet_size
=
UDP_IF4p5_PRACH_SIZE_BYTES
;
packet_size
=
UDP_IF4p5_PRACH_SIZE_BYTES
;
}
else
{
}
else
{
printf
(
"trx_eth_write_udp_IF4p5: unknown flags %d
\n
"
,
flags
);
printf
(
"trx_eth_write_udp_IF4p5: unknown flags %d
\n
"
,
flags
);
...
...
targets/RT/USER/lte-ru.c
View file @
8f621c3e
...
@@ -596,13 +596,14 @@ void fh_if4p5_north_asynch_in(RU_t *ru,int *frame,int *subframe) {
...
@@ -596,13 +596,14 @@ void fh_if4p5_north_asynch_in(RU_t *ru,int *frame,int *subframe) {
symbol_mask_full
=
((
subframe_select
(
fp
,
*
subframe
)
==
SF_S
)
?
(
1
<<
fp
->
dl_symbols_in_S_subframe
)
:
(
1
<<
fp
->
symbols_per_tti
))
-
1
;
symbol_mask_full
=
((
subframe_select
(
fp
,
*
subframe
)
==
SF_S
)
?
(
1
<<
fp
->
dl_symbols_in_S_subframe
)
:
(
1
<<
fp
->
symbols_per_tti
))
-
1
;
do
{
do
{
recv_IF4p5
(
ru
,
&
frame_tx
,
&
subframe_tx
,
&
packet_type
,
&
symbol_number
);
recv_IF4p5
(
ru
,
&
frame_tx
,
&
subframe_tx
,
&
packet_type
,
&
symbol_number
);
if
((
subframe_select
(
fp
,
*
subframe
)
==
SF_DL
)
&&
(
symbol_number
==
0
))
start_meas
(
&
ru
->
rx_fhaul
);
if
((
subframe_select
(
fp
,
subframe_tx
)
==
SF_DL
)
&&
(
symbol_number
==
0
))
start_meas
(
&
ru
->
rx_fhaul
);
LOG_D
(
PHY
,
"subframe %d (%d): frame %d, subframe %d, symbol %d
\n
"
,
LOG_D
(
PHY
,
"subframe %d (%d): frame %d, subframe %d, symbol %d
\n
"
,
*
subframe
,
subframe_select
(
fp
,
*
subframe
),
frame_tx
,
subframe_tx
,
symbol_number
);
*
subframe
,
subframe_select
(
fp
,
*
subframe
),
frame_tx
,
subframe_tx
,
symbol_number
);
if
(
proc
->
first_tx
!=
0
)
{
if
(
proc
->
first_tx
!=
0
)
{
*
frame
=
frame_tx
;
*
frame
=
frame_tx
;
*
subframe
=
subframe_tx
;
*
subframe
=
subframe_tx
;
proc
->
first_tx
=
0
;
proc
->
first_tx
=
0
;
symbol_mask_full
=
((
subframe_select
(
fp
,
*
subframe
)
==
SF_S
)
?
(
1
<<
fp
->
dl_symbols_in_S_subframe
)
:
(
1
<<
fp
->
symbols_per_tti
))
-
1
;
}
}
else
{
else
{
AssertFatal
(
frame_tx
==
*
frame
,
AssertFatal
(
frame_tx
==
*
frame
,
...
@@ -616,7 +617,7 @@ void fh_if4p5_north_asynch_in(RU_t *ru,int *frame,int *subframe) {
...
@@ -616,7 +617,7 @@ void fh_if4p5_north_asynch_in(RU_t *ru,int *frame,int *subframe) {
else
AssertFatal
(
1
==
0
,
"Illegal IF4p5 packet type (should only be IF4p5_PDLFFT%d
\n
"
,
packet_type
);
else
AssertFatal
(
1
==
0
,
"Illegal IF4p5 packet type (should only be IF4p5_PDLFFT%d
\n
"
,
packet_type
);
}
while
(
symbol_mask
!=
symbol_mask_full
);
}
while
(
symbol_mask
!=
symbol_mask_full
);
if
(
subframe_select
(
fp
,
*
subframe
)
==
SF_DL
)
stop_meas
(
&
ru
->
rx_fhaul
);
if
(
subframe_select
(
fp
,
subframe_tx
)
==
SF_DL
)
stop_meas
(
&
ru
->
rx_fhaul
);
proc
->
subframe_tx
=
subframe_tx
;
proc
->
subframe_tx
=
subframe_tx
;
proc
->
frame_tx
=
frame_tx
;
proc
->
frame_tx
=
frame_tx
;
...
@@ -871,7 +872,10 @@ static void* ru_thread_asynch_rxtx( void* param ) {
...
@@ -871,7 +872,10 @@ static void* ru_thread_asynch_rxtx( void* param ) {
// asynchronous receive from south (Mobipass)
// asynchronous receive from south (Mobipass)
if
(
ru
->
fh_south_asynch_in
)
ru
->
fh_south_asynch_in
(
ru
,
&
frame
,
&
subframe
);
if
(
ru
->
fh_south_asynch_in
)
ru
->
fh_south_asynch_in
(
ru
,
&
frame
,
&
subframe
);
// asynchronous receive from north (RRU IF4/IF5)
// asynchronous receive from north (RRU IF4/IF5)
else
if
(
ru
->
fh_north_asynch_in
)
ru
->
fh_north_asynch_in
(
ru
,
&
frame
,
&
subframe
);
else
if
(
ru
->
fh_north_asynch_in
)
{
if
(
subframe_select
(
&
ru
->
frame_parms
,
subframe
)
!=
SF_UL
)
ru
->
fh_north_asynch_in
(
ru
,
&
frame
,
&
subframe
);
}
else
AssertFatal
(
1
==
0
,
"Unknown function in ru_thread_asynch_rxtx
\n
"
);
else
AssertFatal
(
1
==
0
,
"Unknown function in ru_thread_asynch_rxtx
\n
"
);
}
}
...
@@ -1322,8 +1326,11 @@ static void* ru_stats_thread(void* param) {
...
@@ -1322,8 +1326,11 @@ static void* ru_stats_thread(void* param) {
if
(
ru
->
feprx
)
print_meas
(
&
ru
->
ofdm_demod_stats
,
"feprx"
,
NULL
,
NULL
);
if
(
ru
->
feprx
)
print_meas
(
&
ru
->
ofdm_demod_stats
,
"feprx"
,
NULL
,
NULL
);
if
(
ru
->
feptx_ofdm
)
print_meas
(
&
ru
->
ofdm_mod_stats
,
"feptx_ofdm"
,
NULL
,
NULL
);
if
(
ru
->
feptx_ofdm
)
print_meas
(
&
ru
->
ofdm_mod_stats
,
"feptx_ofdm"
,
NULL
,
NULL
);
if
(
ru
->
fh_north_asynch_in
)
print_meas
(
&
ru
->
rx_fhaul
,
"rx_fhaul"
,
NULL
,
NULL
);
if
(
ru
->
fh_north_asynch_in
)
print_meas
(
&
ru
->
rx_fhaul
,
"rx_fhaul"
,
NULL
,
NULL
);
if
(
ru
->
fh_north_out
)
print_meas
(
&
ru
->
tx_fhaul
,
"tx_fhaul"
,
NULL
,
NULL
);
if
(
ru
->
fh_north_out
)
{
print_meas
(
&
ru
->
tx_fhaul
,
"tx_fhaul"
,
NULL
,
NULL
);
print_meas
(
&
ru
->
compression
,
"compression"
,
NULL
,
NULL
);
print_meas
(
&
ru
->
transport
,
"transport"
,
NULL
,
NULL
);
}
}
}
}
}
return
(
NULL
);
return
(
NULL
);
...
@@ -1911,6 +1918,8 @@ void init_RU(char *rf_config_file) {
...
@@ -1911,6 +1918,8 @@ void init_RU(char *rf_config_file) {
ru
->
ifdevice
.
eth_params
=
&
ru
->
eth_params
;
ru
->
ifdevice
.
eth_params
=
&
ru
->
eth_params
;
reset_meas
(
&
ru
->
rx_fhaul
);
reset_meas
(
&
ru
->
rx_fhaul
);
reset_meas
(
&
ru
->
tx_fhaul
);
reset_meas
(
&
ru
->
tx_fhaul
);
reset_meas
(
&
ru
->
compression
);
reset_meas
(
&
ru
->
transport
);
ret
=
openair0_transport_load
(
&
ru
->
ifdevice
,
&
ru
->
openair0_cfg
,
&
ru
->
eth_params
);
ret
=
openair0_transport_load
(
&
ru
->
ifdevice
,
&
ru
->
openair0_cfg
,
&
ru
->
eth_params
);
printf
(
"openair0_transport_init returns %d for ru_id %d
\n
"
,
ret
,
ru_id
);
printf
(
"openair0_transport_init returns %d for ru_id %d
\n
"
,
ret
,
ru_id
);
...
@@ -1934,6 +1943,8 @@ void init_RU(char *rf_config_file) {
...
@@ -1934,6 +1943,8 @@ void init_RU(char *rf_config_file) {
ru
->
ifdevice
.
eth_params
=
&
ru
->
eth_params
;
ru
->
ifdevice
.
eth_params
=
&
ru
->
eth_params
;
reset_meas
(
&
ru
->
rx_fhaul
);
reset_meas
(
&
ru
->
rx_fhaul
);
reset_meas
(
&
ru
->
tx_fhaul
);
reset_meas
(
&
ru
->
tx_fhaul
);
reset_meas
(
&
ru
->
compression
);
reset_meas
(
&
ru
->
transport
);
ret
=
openair0_transport_load
(
&
ru
->
ifdevice
,
&
ru
->
openair0_cfg
,
&
ru
->
eth_params
);
ret
=
openair0_transport_load
(
&
ru
->
ifdevice
,
&
ru
->
openair0_cfg
,
&
ru
->
eth_params
);
printf
(
"openair0_transport_init returns %d for ru_id %d
\n
"
,
ret
,
ru_id
);
printf
(
"openair0_transport_init returns %d for ru_id %d
\n
"
,
ret
,
ru_id
);
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment