mirror of https://github.com/PentHertz/srsLTE.git
fixing eMBMS after new ue_db architecture and scheduler changes
This commit is contained in:
parent
181b903117
commit
ce30b7e1ce
|
@ -976,9 +976,12 @@ void mac::write_mcch(const srsran::sib2_mbms_t* sib2_,
|
||||||
sib13 = *sib13_;
|
sib13 = *sib13_;
|
||||||
memcpy(mcch_payload_buffer, mcch_payload, mcch_payload_length * sizeof(uint8_t));
|
memcpy(mcch_payload_buffer, mcch_payload, mcch_payload_length * sizeof(uint8_t));
|
||||||
current_mcch_length = mcch_payload_length;
|
current_mcch_length = mcch_payload_length;
|
||||||
ue_db[SRSRAN_MRNTI] = std::unique_ptr<ue>{
|
std::unique_ptr<ue> ptr = std::unique_ptr<ue>{
|
||||||
new ue(SRSRAN_MRNTI, 0, &scheduler, rrc_h, rlc_h, phy_h, logger, cells.size(), softbuffer_pool.get())};
|
new ue(SRSRAN_MRNTI, args.nof_prb, &scheduler, rrc_h, rlc_h, phy_h, logger, cells.size(), softbuffer_pool.get())};
|
||||||
|
auto ret = ue_db.insert(SRSRAN_MRNTI, std::move(ptr));
|
||||||
|
if (!ret) {
|
||||||
|
logger.info("Failed to allocate rnti=0x%x.for eMBMS", SRSRAN_MRNTI);
|
||||||
|
}
|
||||||
rrc_h->add_user(SRSRAN_MRNTI, {});
|
rrc_h->add_user(SRSRAN_MRNTI, {});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -35,6 +35,12 @@ sched_time_pf::sched_time_pf(const sched_cell_params_t& cell_params_, const sche
|
||||||
|
|
||||||
void sched_time_pf::new_tti(sched_ue_list& ue_db, sf_sched* tti_sched)
|
void sched_time_pf::new_tti(sched_ue_list& ue_db, sf_sched* tti_sched)
|
||||||
{
|
{
|
||||||
|
while (not dl_queue.empty()) {
|
||||||
|
dl_queue.pop();
|
||||||
|
}
|
||||||
|
while (not ul_queue.empty()) {
|
||||||
|
ul_queue.pop();
|
||||||
|
}
|
||||||
current_tti_rx = tti_point{tti_sched->get_tti_rx()};
|
current_tti_rx = tti_point{tti_sched->get_tti_rx()};
|
||||||
// remove deleted users from history
|
// remove deleted users from history
|
||||||
for (auto it = ue_history_db.begin(); it != ue_history_db.end();) {
|
for (auto it = ue_history_db.begin(); it != ue_history_db.end();) {
|
||||||
|
|
Loading…
Reference in New Issue