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
alex037yang
OpenXG-RAN
Commits
3098eec5
Commit
3098eec5
authored
Feb 20, 2018
by
Niccolò Iardella
Committed by
Robert Schmidt
Apr 18, 2018
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Add positioning support for DL
parent
184d51c6
Changes
3
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
165 additions
and
130 deletions
+165
-130
openair2/LAYER2/MAC/eNB_scheduler_dlsch.c
openair2/LAYER2/MAC/eNB_scheduler_dlsch.c
+55
-29
openair2/LAYER2/MAC/pre_processor.c
openair2/LAYER2/MAC/pre_processor.c
+100
-82
openair2/LAYER2/MAC/proto.h
openair2/LAYER2/MAC/proto.h
+10
-19
No files found.
openair2/LAYER2/MAC/eNB_scheduler_dlsch.c
View file @
3098eec5
...
@@ -83,6 +83,10 @@ float slice_percentage_current[MAX_NUM_SLICES] = {1.0, 0.0, 0.0, 0.0};
...
@@ -83,6 +83,10 @@ float slice_percentage_current[MAX_NUM_SLICES] = {1.0, 0.0, 0.0, 0.0};
float
total_slice_percentage
=
0
;
float
total_slice_percentage
=
0
;
float
total_slice_percentage_current
=
0
;
float
total_slice_percentage_current
=
0
;
// Frequency ranges for slice positioning
int
slice_position
[
MAX_NUM_SLICES
*
2
]
=
{
0
,
N_RBG_MAX
,
0
,
N_RBG_MAX
,
0
,
N_RBG_MAX
,
0
,
N_RBG_MAX
};
int
slice_position_current
[
MAX_NUM_SLICES
*
2
]
=
{
0
,
N_RBG_MAX
,
0
,
N_RBG_MAX
,
0
,
N_RBG_MAX
,
0
,
N_RBG_MAX
};
// MAX MCS for each slice for past and current time
// MAX MCS for each slice for past and current time
int
slice_maxmcs
[
MAX_NUM_SLICES
]
=
{
28
,
28
,
28
,
28
};
int
slice_maxmcs
[
MAX_NUM_SLICES
]
=
{
28
,
28
,
28
,
28
};
int
slice_maxmcs_current
[
MAX_NUM_SLICES
]
=
{
28
,
28
,
28
,
28
};
int
slice_maxmcs_current
[
MAX_NUM_SLICES
]
=
{
28
,
28
,
28
,
28
};
...
@@ -445,9 +449,7 @@ set_ul_DAI(int module_idP, int UE_idP, int CC_idP, int frameP,
...
@@ -445,9 +449,7 @@ set_ul_DAI(int module_idP, int UE_idP, int CC_idP, int frameP,
//------------------------------------------------------------------------------
//------------------------------------------------------------------------------
void
void
schedule_dlsch
(
module_id_t
module_idP
,
schedule_dlsch
(
module_id_t
module_idP
,
frame_t
frameP
,
sub_frame_t
subframeP
,
int
*
mbsfn_flag
)
frame_t
frameP
,
sub_frame_t
subframeP
,
int
*
mbsfn_flag
)
//------------------------------------------------------------------------------{
{
{
int
i
=
0
;
int
i
=
0
;
...
@@ -462,7 +464,7 @@ schedule_dlsch(module_id_t module_idP,
...
@@ -462,7 +464,7 @@ schedule_dlsch(module_id_t module_idP,
for
(
i
=
0
;
i
<
n_active_slices
;
i
++
)
{
for
(
i
=
0
;
i
<
n_active_slices
;
i
++
)
{
if
(
slice_percentage
[
i
]
<
0
){
if
(
slice_percentage
[
i
]
<
0
){
LOG_W
(
MAC
,
"[eNB %d] frame %d subframe %d:invalid slice %d percentage %f. resetting to zero"
,
LOG_W
(
MAC
,
"[eNB %d] frame %d subframe %d:invalid slice %d percentage %f. resetting to zero"
,
module_idP
,
frameP
,
subframeP
,
i
,
slice_percentage
[
i
]);
module_idP
,
frameP
,
subframeP
,
i
,
slice_percentage
[
i
]);
slice_percentage
[
i
]
=
0
;
slice_percentage
[
i
]
=
0
;
}
}
total_slice_percentage
+=
slice_percentage
[
i
];
total_slice_percentage
+=
slice_percentage
[
i
];
...
@@ -482,37 +484,38 @@ schedule_dlsch(module_id_t module_idP,
...
@@ -482,37 +484,38 @@ schedule_dlsch(module_id_t module_idP,
// check if the number of slices has changed, and log
// check if the number of slices has changed, and log
if
(
n_active_slices_current
!=
n_active_slices
){
if
(
n_active_slices_current
!=
n_active_slices
){
if
((
n_active_slices
>
0
)
&&
(
n_active_slices
<=
MAX_NUM_SLICES
))
{
if
((
n_active_slices
>
0
)
&&
(
n_active_slices
<=
MAX_NUM_SLICES
))
{
LOG_N
(
MAC
,
"[eNB %d]frame %d subframe %d: number of active DL slices has changed: %d-->%d
\n
"
,
LOG_N
(
MAC
,
"[eNB %d]frame %d subframe %d: number of active DL slices has changed: %d-->%d
\n
"
,
module_idP
,
frameP
,
subframeP
,
n_active_slices_current
,
n_active_slices
);
module_idP
,
frameP
,
subframeP
,
n_active_slices_current
,
n_active_slices
);
n_active_slices_current
=
n_active_slices
;
n_active_slices_current
=
n_active_slices
;
}
else
{
LOG_W
(
MAC
,
"invalid number of DL slices %d, revert to the previous value %d
\n
"
,
}
else
{
n_active_slices
,
n_active_slices_current
);
LOG_W
(
MAC
,
"invalid number of DL slices %d, revert to the previous value %d
\n
"
,
n_active_slices
,
n_active_slices_current
);
n_active_slices
=
n_active_slices_current
;
n_active_slices
=
n_active_slices_current
;
}
}
}
}
// check if the slice rb share has changed, and log the console
// check if the slice rb share has changed, and log the console
if
(
slice_percentage_current
[
i
]
!=
slice_percentage
[
i
]){
// new slice percentage
if
(
slice_percentage_current
[
i
]
!=
slice_percentage
[
i
])
{
// new slice percentage
LOG_N
(
MAC
,
"[eNB %d][SLICE %d][DL] frame %d subframe %d: total percentage %f-->%f, slice RB percentage has changed: %f-->%f
\n
"
,
LOG_N
(
MAC
,
module_idP
,
i
,
frameP
,
subframeP
,
total_slice_percentage_current
,
total_slice_percentage
,
slice_percentage_current
[
i
],
slice_percentage
[
i
]);
"[eNB %d][SLICE %d][DL] frame %d subframe %d: total percentage %f-->%f, slice RB percentage has changed: %f-->%f
\n
"
,
total_slice_percentage_current
=
total_slice_percentage
;
module_idP
,
i
,
frameP
,
subframeP
,
total_slice_percentage_current
,
total_slice_percentage
,
slice_percentage_current
[
i
]
=
slice_percentage
[
i
];
slice_percentage_current
[
i
],
slice_percentage
[
i
]);
total_slice_percentage_current
=
total_slice_percentage
;
slice_percentage_current
[
i
]
=
slice_percentage
[
i
];
}
}
// check if the slice max MCS, and log the console
// check if the slice max MCS, and log the console
if
(
slice_maxmcs_current
[
i
]
!=
slice_maxmcs
[
i
]){
if
(
slice_maxmcs_current
[
i
]
!=
slice_maxmcs
[
i
])
{
if
((
slice_maxmcs
[
i
]
>=
0
)
&&
(
slice_maxmcs
[
i
]
<
29
)){
if
((
slice_maxmcs
[
i
]
>=
0
)
&&
(
slice_maxmcs
[
i
]
<
29
))
{
LOG_N
(
MAC
,
"[eNB %d][SLICE %d][DL] frame %d subframe %d: slice MAX MCS has changed: %d-->%d
\n
"
,
LOG_N
(
MAC
,
"[eNB %d][SLICE %d][DL] frame %d subframe %d: slice MAX MCS has changed: %d-->%d
\n
"
,
module_idP
,
i
,
frameP
,
subframeP
,
slice_maxmcs_current
[
i
],
slice_maxmcs
[
i
]);
module_idP
,
i
,
frameP
,
subframeP
,
slice_maxmcs_current
[
i
],
slice_maxmcs
[
i
]);
slice_maxmcs_current
[
i
]
=
slice_maxmcs
[
i
];
slice_maxmcs_current
[
i
]
=
slice_maxmcs
[
i
];
}
else
{
}
else
{
LOG_W
(
MAC
,
"[eNB %d][SLICE %d][DL] invalid slice max mcs %d, revert the previous value %d
\n
"
,
module_idP
,
i
,
slice_maxmcs
[
i
],
slice_maxmcs_current
[
i
]);
LOG_W
(
MAC
,
"[eNB %d][SLICE %d][DL] invalid slice max mcs %d, revert the previous value %d
\n
"
,
slice_maxmcs
[
i
]
=
slice_maxmcs_current
[
i
];
module_idP
,
i
,
slice_maxmcs
[
i
],
slice_maxmcs_current
[
i
]);
}
slice_maxmcs
[
i
]
=
slice_maxmcs_current
[
i
];
}
}
}
// check if a new scheduler, and log the console
// check if a new scheduler, and log the console
...
@@ -541,6 +544,29 @@ schedule_dlsch(module_id_t module_idP,
...
@@ -541,6 +544,29 @@ schedule_dlsch(module_id_t module_idP,
}
}
}
}
// Check for new slice positions
if
(
slice_position
[
i
*
2
]
>
slice_position
[
i
*
2
+
1
]
||
slice_position
[
i
*
2
]
<
0
||
slice_position
[
i
*
2
+
1
]
>
N_RBG_MAX
)
{
LOG_W
(
MAC
,
"[eNB %d][SLICE %d][DL] invalid slicing position (%d-%d), using previous values (%d-%d)
\n
"
,
module_idP
,
i
,
slice_position
[
i
*
2
],
slice_position
[
i
*
2
+
1
],
slice_position_current
[
i
*
2
],
slice_position_current
[
i
*
2
+
1
]);
slice_position
[
i
*
2
]
=
slice_position_current
[
i
*
2
];
slice_position
[
i
*
2
+
1
]
=
slice_position_current
[
i
*
2
+
1
];
}
else
{
if
(
slice_position_current
[
i
*
2
]
!=
slice_position
[
i
*
2
])
{
LOG_N
(
MAC
,
"[eNB %d][SLICE %d][DL] frame %d subframe %d: start frequency has changed (%d-->%d)
\n
"
,
module_idP
,
i
,
frameP
,
subframeP
,
slice_position_current
[
i
*
2
],
slice_position
[
i
*
2
]);
slice_position_current
[
i
*
2
]
=
slice_position
[
i
*
2
];
}
if
(
slice_position_current
[
i
*
2
+
1
]
!=
slice_position
[
i
*
2
+
1
])
{
LOG_N
(
MAC
,
"[eNB %d][SLICE %d][DL] frame %d subframe %d: end frequency has changed (%d-->%d)
\n
"
,
module_idP
,
i
,
frameP
,
subframeP
,
slice_position_current
[
i
*
2
+
1
],
slice_position
[
i
*
2
+
1
]);
slice_position_current
[
i
*
2
+
1
]
=
slice_position
[
i
*
2
+
1
];
}
}
// Check for new sorting policy
// Check for new sorting policy
if
(
sorting_policy_current
[
i
]
!=
sorting_policy
[
i
])
{
if
(
sorting_policy_current
[
i
]
!=
sorting_policy
[
i
])
{
LOG_N
(
MAC
,
"[eNB %d][SLICE %d][DL] frame %d subframe %d: UE sorting policy has changed (%x-->%x)
\n
"
,
LOG_N
(
MAC
,
"[eNB %d][SLICE %d][DL] frame %d subframe %d: UE sorting policy has changed (%x-->%x)
\n
"
,
...
...
openair2/LAYER2/MAC/pre_processor.c
View file @
3098eec5
...
@@ -58,6 +58,7 @@
...
@@ -58,6 +58,7 @@
extern
float
slice_percentage
[
MAX_NUM_SLICES
];
extern
float
slice_percentage
[
MAX_NUM_SLICES
];
extern
float
slice_percentage_uplink
[
MAX_NUM_SLICES
];
extern
float
slice_percentage_uplink
[
MAX_NUM_SLICES
];
extern
int
slice_position
[
MAX_NUM_SLICES
*
2
];
extern
uint32_t
sorting_policy
[
MAX_NUM_SLICES
];
extern
uint32_t
sorting_policy
[
MAX_NUM_SLICES
];
extern
int
slice_maxmcs
[
MAX_NUM_SLICES
];
extern
int
slice_maxmcs
[
MAX_NUM_SLICES
];
...
@@ -480,6 +481,28 @@ void decode_sorting_policy(module_id_t Mod_idP, slice_id_t slice_id) {
...
@@ -480,6 +481,28 @@ void decode_sorting_policy(module_id_t Mod_idP, slice_id_t slice_id) {
}
}
}
}
void
decode_slice_positioning
(
module_id_t
Mod_idP
,
slice_id_t
slice_id
,
uint8_t
slice_allocation_mask
[
MAX_NUM_CCs
][
N_RBG_MAX
])
{
uint8_t
CC_id
;
int
RBG
,
start_frequency
,
end_frequency
;
// Init slice_alloc_mask
for
(
CC_id
=
0
;
CC_id
<
MAX_NUM_CCs
;
++
CC_id
)
{
for
(
RBG
=
0
;
RBG
<
N_RBG_MAX
;
++
RBG
)
{
slice_allocation_mask
[
CC_id
][
RBG
]
=
0
;
}
}
start_frequency
=
slice_position
[
slice_id
*
2
];
end_frequency
=
slice_position
[
slice_id
*
2
+
1
];
for
(
CC_id
=
0
;
CC_id
<
MAX_NUM_CCs
;
++
CC_id
)
{
for
(
RBG
=
start_frequency
;
RBG
<=
end_frequency
;
++
RBG
)
{
slice_allocation_mask
[
CC_id
][
RBG
]
=
1
;
}
}
}
// This fuction sorts the UE in order their dlsch buffer and CQI
// This fuction sorts the UE in order their dlsch buffer and CQI
void
sort_UEs
(
module_id_t
Mod_idP
,
slice_id_t
slice_id
,
int
frameP
,
sub_frame_t
subframeP
)
void
sort_UEs
(
module_id_t
Mod_idP
,
slice_id_t
slice_id
,
int
frameP
,
sub_frame_t
subframeP
)
...
@@ -600,6 +623,7 @@ void dlsch_scheduler_pre_processor_accounting(module_id_t Mod_id,
...
@@ -600,6 +623,7 @@ void dlsch_scheduler_pre_processor_accounting(module_id_t Mod_id,
int
N_RBG
[
MAX_NUM_CCs
],
int
N_RBG
[
MAX_NUM_CCs
],
int
min_rb_unit
[
MAX_NUM_CCs
],
int
min_rb_unit
[
MAX_NUM_CCs
],
uint8_t
rballoc_sub
[
MAX_NUM_CCs
][
N_RBG_MAX
],
uint8_t
rballoc_sub
[
MAX_NUM_CCs
][
N_RBG_MAX
],
uint8_t
slice_allocation_mask
[
MAX_NUM_CCs
][
N_RBG_MAX
],
uint8_t
MIMO_mode_indicator
[
MAX_NUM_CCs
][
N_RBG_MAX
],
uint8_t
MIMO_mode_indicator
[
MAX_NUM_CCs
][
N_RBG_MAX
],
uint16_t
nb_rbs_required
[
MAX_NUM_CCs
][
NUMBER_OF_UE_MAX
])
{
uint16_t
nb_rbs_required
[
MAX_NUM_CCs
][
NUMBER_OF_UE_MAX
])
{
...
@@ -735,11 +759,9 @@ void dlsch_scheduler_pre_processor_accounting(module_id_t Mod_id,
...
@@ -735,11 +759,9 @@ void dlsch_scheduler_pre_processor_accounting(module_id_t Mod_id,
// control channel or retransmission
// control channel or retransmission
/* TODO: do we have to check for retransmission? */
/* TODO: do we have to check for retransmission? */
if
(
mac_eNB_get_rrc_status
(
Mod_id
,
rnti
)
<
RRC_RECONFIGURED
||
round
!=
8
)
{
if
(
mac_eNB_get_rrc_status
(
Mod_id
,
rnti
)
<
RRC_RECONFIGURED
||
round
!=
8
)
{
nb_rbs_required_remaining_1
[
CC_id
][
UE_id
]
=
nb_rbs_required_remaining_1
[
CC_id
][
UE_id
]
=
nb_rbs_required
[
CC_id
][
UE_id
];
nb_rbs_required
[
CC_id
][
UE_id
];
}
else
{
}
else
{
nb_rbs_required_remaining_1
[
CC_id
][
UE_id
]
=
nb_rbs_required_remaining_1
[
CC_id
][
UE_id
]
=
cmin
(
average_rbs_per_user
[
CC_id
],
nb_rbs_required
[
CC_id
][
UE_id
]);
cmin
(
average_rbs_per_user
[
CC_id
],
nb_rbs_required
[
CC_id
][
UE_id
]);
}
}
}
}
}
}
...
@@ -807,20 +829,17 @@ void dlsch_scheduler_pre_processor_accounting(module_id_t Mod_id,
...
@@ -807,20 +829,17 @@ void dlsch_scheduler_pre_processor_accounting(module_id_t Mod_id,
// retransmission in data channels
// retransmission in data channels
// control channel in the 1st transmission
// control channel in the 1st transmission
// data channel for all TM
// data channel for all TM
LOG_T
(
MAC
,
LOG_T
(
MAC
,
"calling dlsch_scheduler_pre_processor_allocate ..
\n
"
);
"calling dlsch_scheduler_pre_processor_allocate ..
\n
"
);
dlsch_scheduler_pre_processor_allocate
(
Mod_id
,
dlsch_scheduler_pre_processor_allocate
(
Mod_id
,
UE_id
,
UE_id
,
CC_id
,
CC_id
,
N_RBG
[
CC_id
],
N_RBG
[
CC_id
],
transmission_mode
,
transmission_mode
,
min_rb_unit
min_rb_unit
[
CC_id
],
[
CC_id
],
to_prb
(
RC
.
mac
[
Mod_id
]
->
common_channels
[
CC_id
].
mib
->
message
.
dl_Bandwidth
),
nb_rbs_required
,
nb_rbs_required
,
nb_rbs_required_remaining
,
nb_rbs_required_remaining
,
rballoc_sub
,
rballoc_sub
,
slice_allocation_mask
,
MIMO_mode_indicator
);
MIMO_mode_indicator
);
#ifdef TM5
#ifdef TM5
...
@@ -1005,6 +1024,7 @@ dlsch_scheduler_pre_processor(module_id_t Mod_id,
...
@@ -1005,6 +1024,7 @@ dlsch_scheduler_pre_processor(module_id_t Mod_id,
uint16_t
i
,
j
;
uint16_t
i
,
j
;
uint8_t
rballoc_sub
[
MAX_NUM_CCs
][
N_RBG_MAX
];
uint8_t
rballoc_sub
[
MAX_NUM_CCs
][
N_RBG_MAX
];
uint8_t
slice_allocation_mask
[
MAX_NUM_CCs
][
N_RBG_MAX
];
uint8_t
MIMO_mode_indicator
[
MAX_NUM_CCs
][
N_RBG_MAX
];
// If TM5 is revisited, we can move this inside accounting
uint8_t
MIMO_mode_indicator
[
MAX_NUM_CCs
][
N_RBG_MAX
];
// If TM5 is revisited, we can move this inside accounting
int
min_rb_unit
[
MAX_NUM_CCs
];
int
min_rb_unit
[
MAX_NUM_CCs
];
...
@@ -1062,7 +1082,11 @@ dlsch_scheduler_pre_processor(module_id_t Mod_id,
...
@@ -1062,7 +1082,11 @@ dlsch_scheduler_pre_processor(module_id_t Mod_id,
// Sorts the user on the basis of dlsch logical channel buffer and CQI
// Sorts the user on the basis of dlsch logical channel buffer and CQI
sort_UEs
(
Mod_id
,
slice_id
,
frameP
,
subframeP
);
sort_UEs
(
Mod_id
,
slice_id
,
frameP
,
subframeP
);
// This function does the main allocation of the number of RBs
// TODO: When accounting() is revised, this will be moved inside positioning()
decode_slice_positioning
(
Mod_id
,
slice_id
,
slice_allocation_mask
);
// ACCOUNTING
// This function does the main allocation of the *number* of RBs
dlsch_scheduler_pre_processor_accounting
(
Mod_id
,
dlsch_scheduler_pre_processor_accounting
(
Mod_id
,
slice_id
,
slice_id
,
frameP
,
frameP
,
...
@@ -1070,6 +1094,7 @@ dlsch_scheduler_pre_processor(module_id_t Mod_id,
...
@@ -1070,6 +1094,7 @@ dlsch_scheduler_pre_processor(module_id_t Mod_id,
N_RBG
,
N_RBG
,
min_rb_unit
,
min_rb_unit
,
rballoc_sub
,
rballoc_sub
,
slice_allocation_mask
,
MIMO_mode_indicator
,
MIMO_mode_indicator
,
nb_rbs_required
);
nb_rbs_required
);
...
@@ -1332,77 +1357,70 @@ dlsch_scheduler_pre_processor_reset(int module_idP,
...
@@ -1332,77 +1357,70 @@ dlsch_scheduler_pre_processor_reset(int module_idP,
void
void
dlsch_scheduler_pre_processor_allocate
(
module_id_t
Mod_id
,
dlsch_scheduler_pre_processor_allocate
(
module_id_t
Mod_id
,
int
UE_id
,
int
UE_id
,
uint8_t
CC_id
,
uint8_t
CC_id
,
int
N_RBG
,
int
N_RBG
,
int
transmission_mode
,
int
transmission_mode
,
int
min_rb_unit
,
int
min_rb_unit
,
uint8_t
N_RB_DL
,
uint16_t
nb_rbs_required
[
MAX_NUM_CCs
][
NUMBER_OF_UE_MAX
],
uint16_t
uint16_t
nb_rbs_required_remaining
[
MAX_NUM_CCs
][
NUMBER_OF_UE_MAX
],
nb_rbs_required
[
MAX_NUM_CCs
]
unsigned
char
rballoc_sub
[
MAX_NUM_CCs
][
N_RBG_MAX
],
[
NUMBER_OF_UE_MAX
],
uint8_t
slice_allocation_mask
[
MAX_NUM_CCs
][
N_RBG_MAX
],
uint16_t
unsigned
char
MIMO_mode_indicator
[
MAX_NUM_CCs
][
N_RBG_MAX
])
{
nb_rbs_required_remaining
[
MAX_NUM_CCs
]
[
NUMBER_OF_UE_MAX
],
unsigned
char
rballoc_sub
[
MAX_NUM_CCs
]
[
N_RBG_MAX
],
unsigned
char
MIMO_mode_indicator
[
MAX_NUM_CCs
][
N_RBG_MAX
])
{
int
i
;
int
i
;
UE_list_t
*
UE_list
=
&
RC
.
mac
[
Mod_id
]
->
UE_list
;
UE_list_t
*
UE_list
=
&
RC
.
mac
[
Mod_id
]
->
UE_list
;
UE_sched_ctrl
*
ue_sched_ctl
=
&
UE_list
->
UE_sched_ctrl
[
UE_id
];
UE_sched_ctrl
*
ue_sched_ctl
=
&
UE_list
->
UE_sched_ctrl
[
UE_id
];
int
N_RB_DL
=
to_prb
(
RC
.
mac
[
Mod_id
]
->
common_channels
[
CC_id
].
mib
->
message
.
dl_Bandwidth
);
for
(
i
=
0
;
i
<
N_RBG
;
i
++
)
{
for
(
i
=
0
;
i
<
N_RBG
;
i
++
)
{
if
((
rballoc_sub
[
CC_id
][
i
]
==
0
)
&&
(
ue_sched_ctl
->
rballoc_sub_UE
[
CC_id
][
i
]
==
0
)
&&
if
(
rballoc_sub
[
CC_id
][
i
]
!=
0
)
(
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
>
0
)
&&
continue
;
(
ue_sched_ctl
->
pre_nb_available_rbs
[
CC_id
]
<
if
(
ue_sched_ctl
->
rballoc_sub_UE
[
CC_id
][
i
]
!=
0
)
nb_rbs_required
[
CC_id
][
UE_id
]))
{
continue
;
if
(
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
<=
0
)
// if this UE is not scheduled for TM5
continue
;
if
(
ue_sched_ctl
->
dl_pow_off
[
CC_id
]
!=
0
)
{
if
(
ue_sched_ctl
->
pre_nb_available_rbs
[
CC_id
]
>=
nb_rbs_required
[
CC_id
][
UE_id
])
continue
;
if
((
i
==
N_RBG
-
1
)
if
(
ue_sched_ctl
->
dl_pow_off
[
CC_id
]
==
0
)
&&
((
N_RB_DL
==
25
)
||
(
N_RB_DL
==
50
)))
{
continue
;
if
(
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
>=
if
(
slice_allocation_mask
[
CC_id
][
i
]
==
0
)
min_rb_unit
-
1
)
{
continue
;
rballoc_sub
[
CC_id
][
i
]
=
1
;
ue_sched_ctl
->
rballoc_sub_UE
[
CC_id
][
i
]
=
1
;
// if ((rballoc_sub[CC_id][i] == 0) &&
MIMO_mode_indicator
[
CC_id
][
i
]
=
1
;
// (ue_sched_ctl->rballoc_sub_UE[CC_id][i] == 0) &&
if
(
transmission_mode
==
5
)
{
// (nb_rbs_required_remaining[CC_id][UE_id] > 0) &&
ue_sched_ctl
->
dl_pow_off
[
CC_id
]
=
1
;
// (ue_sched_ctl->pre_nb_available_rbs[CC_id] < nb_rbs_required[CC_id][UE_id])) {
}
// // if this UE is not scheduled for TM5
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
=
// if (ue_sched_ctl->dl_pow_off[CC_id] != 0) {
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
-
min_rb_unit
+
1
;
if
((
i
==
N_RBG
-
1
)
&&
((
N_RB_DL
==
25
)
||
(
N_RB_DL
==
50
)))
{
ue_sched_ctl
->
pre_nb_available_rbs
[
CC_id
]
=
if
(
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
>=
min_rb_unit
-
1
)
{
ue_sched_ctl
->
pre_nb_available_rbs
[
CC_id
]
+
rballoc_sub
[
CC_id
][
i
]
=
1
;
min_rb_unit
-
1
;
ue_sched_ctl
->
rballoc_sub_UE
[
CC_id
][
i
]
=
1
;
}
MIMO_mode_indicator
[
CC_id
][
i
]
=
1
;
}
else
{
if
(
transmission_mode
==
5
)
{
if
(
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
>=
ue_sched_ctl
->
dl_pow_off
[
CC_id
]
=
1
;
min_rb_unit
)
{
}
rballoc_sub
[
CC_id
][
i
]
=
1
;
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
=
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
-
min_rb_unit
+
1
;
ue_sched_ctl
->
rballoc_sub_UE
[
CC_id
][
i
]
=
1
;
ue_sched_ctl
->
pre_nb_available_rbs
[
CC_id
]
=
ue_sched_ctl
->
pre_nb_available_rbs
[
CC_id
]
+
min_rb_unit
-
1
;
MIMO_mode_indicator
[
CC_id
][
i
]
=
1
;
}
if
(
transmission_mode
==
5
)
{
}
else
{
ue_sched_ctl
->
dl_pow_off
[
CC_id
]
=
1
;
if
(
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
>=
min_rb_unit
)
{
}
rballoc_sub
[
CC_id
][
i
]
=
1
;
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
=
ue_sched_ctl
->
rballoc_sub_UE
[
CC_id
][
i
]
=
1
;
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
-
MIMO_mode_indicator
[
CC_id
][
i
]
=
1
;
min_rb_unit
;
if
(
transmission_mode
==
5
)
{
ue_sched_ctl
->
pre_nb_available_rbs
[
CC_id
]
=
ue_sched_ctl
->
dl_pow_off
[
CC_id
]
=
1
;
ue_sched_ctl
->
pre_nb_available_rbs
[
CC_id
]
+
}
min_rb_unit
;
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
=
nb_rbs_required_remaining
[
CC_id
][
UE_id
]
-
min_rb_unit
;
}
ue_sched_ctl
->
pre_nb_available_rbs
[
CC_id
]
=
ue_sched_ctl
->
pre_nb_available_rbs
[
CC_id
]
+
min_rb_unit
;
}
}
}
// dl_pow_off[CC_id][UE_id] ! = 0
}
}
}
// } // dl_pow_off[CC_id][UE_id] ! = 0
// }
}
}
}
...
...
openair2/LAYER2/MAC/proto.h
View file @
3098eec5
...
@@ -237,25 +237,16 @@ void dlsch_scheduler_pre_processor(module_id_t module_idP,
...
@@ -237,25 +237,16 @@ void dlsch_scheduler_pre_processor(module_id_t module_idP,
void
dlsch_scheduler_pre_processor_allocate
(
module_id_t
Mod_id
,
void
dlsch_scheduler_pre_processor_allocate
(
module_id_t
Mod_id
,
int
UE_id
,
int
UE_id
,
uint8_t
CC_id
,
uint8_t
CC_id
,
int
N_RBG
,
int
N_RBG
,
int
transmission_mode
,
int
transmission_mode
,
int
min_rb_unit
,
int
min_rb_unit
,
uint8_t
N_RB_DL
,
uint16_t
nb_rbs_required
[
MAX_NUM_CCs
][
NUMBER_OF_UE_MAX
],
uint16_t
uint16_t
nb_rbs_required_remaining
[
MAX_NUM_CCs
][
NUMBER_OF_UE_MAX
],
nb_rbs_required
[
MAX_NUM_CCs
]
unsigned
char
rballoc_sub
[
MAX_NUM_CCs
][
N_RBG_MAX
],
[
NUMBER_OF_UE_MAX
],
uint8_t
slice_allocation_mask
[
MAX_NUM_CCs
][
N_RBG_MAX
],
uint16_t
unsigned
char
MIMO_mode_indicator
[
MAX_NUM_CCs
][
N_RBG_MAX
]);
nb_rbs_required_remaining
[
MAX_NUM_CCs
]
[
NUMBER_OF_UE_MAX
],
unsigned
char
rballoc_sub
[
MAX_NUM_CCs
]
[
N_RBG_MAX
],
unsigned
char
MIMO_mode_indicator
[
MAX_NUM_CCs
][
N_RBG_MAX
]);
/* \brief Function to trigger the eNB scheduling procedure. It is called by PHY at the beginning of each subframe, \f$n$\f
/* \brief Function to trigger the eNB scheduling procedure. It is called by PHY at the beginning of each subframe, \f$n$\f
and generates all DLSCH allocations for subframe \f$n\f$ and ULSCH allocations for subframe \f$n+k$\f.
and generates all DLSCH allocations for subframe \f$n\f$ and ULSCH allocations for subframe \f$n+k$\f.
...
...
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