Use new stat item/ctr getter APIs
Patch mostly done with the help of several small spatch snippets. Change-Id: I600c7a8725f5b229b1a2feb879da7c3b2dce4505
This commit is contained in:
parent
d65bd9d7b2
commit
9c1db1738f
|
@ -325,16 +325,17 @@ static inline struct osmo_stat_item_group *bts_stat_items(struct gprs_rlcmac_bts
|
|||
}
|
||||
|
||||
static inline void bts_do_rate_ctr_inc(const struct gprs_rlcmac_bts *bts, unsigned int ctr_id) {
|
||||
rate_ctr_inc(&bts->ratectrs->ctr[ctr_id]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(bts->ratectrs, ctr_id));
|
||||
}
|
||||
|
||||
static inline void bts_do_rate_ctr_add(const struct gprs_rlcmac_bts *bts, unsigned int ctr_id, int inc) {
|
||||
rate_ctr_add(&bts->ratectrs->ctr[ctr_id], inc);
|
||||
rate_ctr_add(rate_ctr_group_get_ctr(bts->ratectrs, ctr_id), inc);
|
||||
}
|
||||
|
||||
static inline void bts_stat_item_add(struct gprs_rlcmac_bts *bts, unsigned int stat_id, int inc) {
|
||||
int32_t val = osmo_stat_item_get_last(bts->statg->items[stat_id]);
|
||||
osmo_stat_item_set(bts->statg->items[stat_id], val + inc);
|
||||
struct osmo_stat_item *item = osmo_stat_item_group_get_item(bts->statg, stat_id);
|
||||
int32_t val = osmo_stat_item_get_last(item);
|
||||
osmo_stat_item_set(item, val + inc);
|
||||
}
|
||||
|
||||
struct gprs_rlcmac_bts *bts_alloc(struct gprs_pcu *pcu, uint8_t bts_nr);
|
||||
|
|
|
@ -538,8 +538,8 @@ static int gprs_bssgp_pcu_rcvmsg(struct msgb *msg)
|
|||
if (bctx)
|
||||
{
|
||||
log_set_context(LOG_CTX_GB_BVC, bctx);
|
||||
rate_ctr_inc(&bctx->ctrg->ctr[BSSGP_CTR_PKTS_IN]);
|
||||
rate_ctr_add(&bctx->ctrg->ctr[BSSGP_CTR_BYTES_IN], msgb_bssgp_len(msg));
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(bctx->ctrg, BSSGP_CTR_PKTS_IN));
|
||||
rate_ctr_add(rate_ctr_group_get_ctr(bctx->ctrg, BSSGP_CTR_BYTES_IN), msgb_bssgp_len(msg));
|
||||
}
|
||||
|
||||
if (ns_bvci == BVCI_SIGNALLING)
|
||||
|
|
|
@ -217,7 +217,7 @@ static struct msgb *sched_select_ctrl_msg(struct gprs_rlcmac_pdch *pdch, uint32_
|
|||
LOGPDCH(pdch, DRLCMACSCHED, LOGL_DEBUG, "FN=%" PRIu32
|
||||
" Scheduling control message at RTS for %s\n",
|
||||
fn, tbf_name(tbf));
|
||||
rate_ctr_inc(&tbf->ms()->ctrs->ctr[MS_CTR_DL_CTRL_MSG_SCHED]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(tbf->ms()->ctrs, MS_CTR_DL_CTRL_MSG_SCHED));
|
||||
return msg;
|
||||
}
|
||||
|
||||
|
|
|
@ -147,7 +147,7 @@ static struct msgb *create_packet_neighbour_cell_data(struct nacc_fsm_ctx *ctx,
|
|||
goto free_ret;
|
||||
}
|
||||
LOGP(DNACC, LOGL_DEBUG, "------------------------- TX : Packet Neighbour Cell Data -------------------------\n");
|
||||
rate_ctr_inc(&bts_rate_counters(ms->bts)->ctr[CTR_PKT_NEIGH_CELL_DATA]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(bts_rate_counters(ms->bts), CTR_PKT_NEIGH_CELL_DATA));
|
||||
talloc_free(mac_control_block);
|
||||
|
||||
ctx->container_idx++;
|
||||
|
@ -204,7 +204,7 @@ static struct msgb *create_packet_cell_chg_continue(const struct nacc_fsm_ctx *c
|
|||
goto free_ret;
|
||||
}
|
||||
LOGP(DNACC, LOGL_DEBUG, "------------------------- TX : Packet Cell Change Continue -------------------------\n");
|
||||
rate_ctr_inc(&bts_rate_counters(ms->bts)->ctr[CTR_PKT_CELL_CHG_CONTINUE]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(bts_rate_counters(ms->bts), CTR_PKT_CELL_CHG_CONTINUE));
|
||||
talloc_free(mac_control_block);
|
||||
tbf_set_polling(tbf, *new_poll_fn, data->ts, PDCH_ULC_POLL_CELL_CHG_CONTINUE);
|
||||
return msg;
|
||||
|
|
|
@ -1137,7 +1137,7 @@ int gprs_rlcmac_dl_tbf::update_window(unsigned first_bsn,
|
|||
ms_update_error_rate(ms(), this, error_rate);
|
||||
|
||||
m_window.update(bts, rbb, first_bsn, &lost, &received);
|
||||
rate_ctr_add(&m_ctrs->ctr[TBF_CTR_RLC_NACKED], lost);
|
||||
rate_ctr_add(rate_ctr_group_get_ctr(m_ctrs, TBF_CTR_RLC_NACKED), lost);
|
||||
|
||||
/* report lost and received packets */
|
||||
gprs_rlcmac_received_lost(this, received, lost);
|
||||
|
@ -1193,7 +1193,7 @@ int gprs_rlcmac_dl_tbf::update_window(const uint8_t ssn, const uint8_t *rbb)
|
|||
|
||||
m_window.update(bts, show_rbb, ssn,
|
||||
&lost, &received);
|
||||
rate_ctr_add(&m_ctrs->ctr[TBF_CTR_RLC_NACKED], lost);
|
||||
rate_ctr_add(rate_ctr_group_get_ctr(m_ctrs, TBF_CTR_RLC_NACKED), lost);
|
||||
|
||||
/* report lost and received packets */
|
||||
gprs_rlcmac_received_lost(this, received, lost);
|
||||
|
@ -1509,55 +1509,55 @@ void gprs_rlcmac_dl_tbf::update_coding_scheme_counter_dl(enum CodingScheme cs)
|
|||
switch (cs) {
|
||||
case CS1:
|
||||
bts_do_rate_ctr_inc(bts, CTR_GPRS_DL_CS1);
|
||||
rate_ctr_inc(&m_dl_gprs_ctrs->ctr[TBF_CTR_GPRS_DL_CS1]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_gprs_ctrs, TBF_CTR_GPRS_DL_CS1));
|
||||
break;
|
||||
case CS2:
|
||||
bts_do_rate_ctr_inc(bts, CTR_GPRS_DL_CS2);
|
||||
rate_ctr_inc(&m_dl_gprs_ctrs->ctr[TBF_CTR_GPRS_DL_CS2]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_gprs_ctrs, TBF_CTR_GPRS_DL_CS2));
|
||||
break;
|
||||
case CS3:
|
||||
bts_do_rate_ctr_inc(bts, CTR_GPRS_DL_CS3);
|
||||
rate_ctr_inc(&m_dl_gprs_ctrs->ctr[TBF_CTR_GPRS_DL_CS3]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_gprs_ctrs, TBF_CTR_GPRS_DL_CS3));
|
||||
break;
|
||||
case CS4:
|
||||
bts_do_rate_ctr_inc(bts, CTR_GPRS_DL_CS4);
|
||||
rate_ctr_inc(&m_dl_gprs_ctrs->ctr[TBF_CTR_GPRS_DL_CS4]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_gprs_ctrs, TBF_CTR_GPRS_DL_CS4));
|
||||
break;
|
||||
case MCS1:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_DL_MCS1);
|
||||
rate_ctr_inc(&m_dl_egprs_ctrs->ctr[TBF_CTR_EGPRS_DL_MCS1]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_egprs_ctrs, TBF_CTR_EGPRS_DL_MCS1));
|
||||
break;
|
||||
case MCS2:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_DL_MCS2);
|
||||
rate_ctr_inc(&m_dl_egprs_ctrs->ctr[TBF_CTR_EGPRS_DL_MCS2]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_egprs_ctrs, TBF_CTR_EGPRS_DL_MCS2));
|
||||
break;
|
||||
case MCS3:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_DL_MCS3);
|
||||
rate_ctr_inc(&m_dl_egprs_ctrs->ctr[TBF_CTR_EGPRS_DL_MCS3]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_egprs_ctrs, TBF_CTR_EGPRS_DL_MCS3));
|
||||
break;
|
||||
case MCS4:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_DL_MCS4);
|
||||
rate_ctr_inc(&m_dl_egprs_ctrs->ctr[TBF_CTR_EGPRS_DL_MCS4]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_egprs_ctrs, TBF_CTR_EGPRS_DL_MCS4));
|
||||
break;
|
||||
case MCS5:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_DL_MCS5);
|
||||
rate_ctr_inc(&m_dl_egprs_ctrs->ctr[TBF_CTR_EGPRS_DL_MCS5]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_egprs_ctrs, TBF_CTR_EGPRS_DL_MCS5));
|
||||
break;
|
||||
case MCS6:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_DL_MCS6);
|
||||
rate_ctr_inc(&m_dl_egprs_ctrs->ctr[TBF_CTR_EGPRS_DL_MCS6]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_egprs_ctrs, TBF_CTR_EGPRS_DL_MCS6));
|
||||
break;
|
||||
case MCS7:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_DL_MCS7);
|
||||
rate_ctr_inc(&m_dl_egprs_ctrs->ctr[TBF_CTR_EGPRS_DL_MCS7]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_egprs_ctrs, TBF_CTR_EGPRS_DL_MCS7));
|
||||
break;
|
||||
case MCS8:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_DL_MCS8);
|
||||
rate_ctr_inc(&m_dl_egprs_ctrs->ctr[TBF_CTR_EGPRS_DL_MCS8]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_egprs_ctrs, TBF_CTR_EGPRS_DL_MCS8));
|
||||
break;
|
||||
case MCS9:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_DL_MCS9);
|
||||
rate_ctr_inc(&m_dl_egprs_ctrs->ctr[TBF_CTR_EGPRS_DL_MCS9]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_dl_egprs_ctrs, TBF_CTR_EGPRS_DL_MCS9));
|
||||
break;
|
||||
default:
|
||||
LOGPTBFDL(this, LOGL_ERROR, "attempting to update rate counters for unsupported (M)CS %s\n",
|
||||
|
|
|
@ -743,55 +743,55 @@ void gprs_rlcmac_ul_tbf::update_coding_scheme_counter_ul(enum CodingScheme cs)
|
|||
switch (cs) {
|
||||
case CS1:
|
||||
bts_do_rate_ctr_inc(bts, CTR_GPRS_UL_CS1);
|
||||
rate_ctr_inc(&m_ul_gprs_ctrs->ctr[TBF_CTR_GPRS_UL_CS1]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_gprs_ctrs, TBF_CTR_GPRS_UL_CS1));
|
||||
break;
|
||||
case CS2:
|
||||
bts_do_rate_ctr_inc(bts, CTR_GPRS_UL_CS2);
|
||||
rate_ctr_inc(&m_ul_gprs_ctrs->ctr[TBF_CTR_GPRS_UL_CS2]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_gprs_ctrs, TBF_CTR_GPRS_UL_CS2));
|
||||
break;
|
||||
case CS3:
|
||||
bts_do_rate_ctr_inc(bts, CTR_GPRS_UL_CS3);
|
||||
rate_ctr_inc(&m_ul_gprs_ctrs->ctr[TBF_CTR_GPRS_UL_CS3]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_gprs_ctrs, TBF_CTR_GPRS_UL_CS3));
|
||||
break;
|
||||
case CS4:
|
||||
bts_do_rate_ctr_inc(bts, CTR_GPRS_UL_CS4);
|
||||
rate_ctr_inc(&m_ul_gprs_ctrs->ctr[TBF_CTR_GPRS_UL_CS4]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_gprs_ctrs, TBF_CTR_GPRS_UL_CS4));
|
||||
break;
|
||||
case MCS1:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_UL_MCS1);
|
||||
rate_ctr_inc(&m_ul_egprs_ctrs->ctr[TBF_CTR_EGPRS_UL_MCS1]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_egprs_ctrs, TBF_CTR_EGPRS_UL_MCS1));
|
||||
break;
|
||||
case MCS2:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_UL_MCS2);
|
||||
rate_ctr_inc(&m_ul_egprs_ctrs->ctr[TBF_CTR_EGPRS_UL_MCS2]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_egprs_ctrs, TBF_CTR_EGPRS_UL_MCS2));
|
||||
break;
|
||||
case MCS3:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_UL_MCS3);
|
||||
rate_ctr_inc(&m_ul_egprs_ctrs->ctr[TBF_CTR_EGPRS_UL_MCS3]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_egprs_ctrs, TBF_CTR_EGPRS_UL_MCS3));
|
||||
break;
|
||||
case MCS4:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_UL_MCS4);
|
||||
rate_ctr_inc(&m_ul_egprs_ctrs->ctr[TBF_CTR_EGPRS_UL_MCS4]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_egprs_ctrs, TBF_CTR_EGPRS_UL_MCS4));
|
||||
break;
|
||||
case MCS5:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_UL_MCS5);
|
||||
rate_ctr_inc(&m_ul_egprs_ctrs->ctr[TBF_CTR_EGPRS_UL_MCS5]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_egprs_ctrs, TBF_CTR_EGPRS_UL_MCS5));
|
||||
break;
|
||||
case MCS6:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_UL_MCS6);
|
||||
rate_ctr_inc(&m_ul_egprs_ctrs->ctr[TBF_CTR_EGPRS_UL_MCS6]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_egprs_ctrs, TBF_CTR_EGPRS_UL_MCS6));
|
||||
break;
|
||||
case MCS7:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_UL_MCS7);
|
||||
rate_ctr_inc(&m_ul_egprs_ctrs->ctr[TBF_CTR_EGPRS_UL_MCS7]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_egprs_ctrs, TBF_CTR_EGPRS_UL_MCS7));
|
||||
break;
|
||||
case MCS8:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_UL_MCS8);
|
||||
rate_ctr_inc(&m_ul_egprs_ctrs->ctr[TBF_CTR_EGPRS_UL_MCS8]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_egprs_ctrs, TBF_CTR_EGPRS_UL_MCS8));
|
||||
break;
|
||||
case MCS9:
|
||||
bts_do_rate_ctr_inc(bts, CTR_EGPRS_UL_MCS9);
|
||||
rate_ctr_inc(&m_ul_egprs_ctrs->ctr[TBF_CTR_EGPRS_UL_MCS9]);
|
||||
rate_ctr_inc(rate_ctr_group_get_ctr(m_ul_egprs_ctrs, TBF_CTR_EGPRS_UL_MCS9));
|
||||
break;
|
||||
default:
|
||||
LOGPTBFUL(this, LOGL_ERROR, "attempting to update rate counters for unsupported (M)CS %s\n",
|
||||
|
|
Loading…
Reference in New Issue