};
/*
- * Set int const in table at top of stack
+ * Set const int in table at top of stack
*/
#define SET_INT_CONST(var) do { \
lua_pushinteger(L, var); \
}
}
- bool ruleset_exists(int const ruleset) const {
+ bool ruleset_exists(const int ruleset) const {
for (size_t i = 0; i < crush->max_rules; ++i) {
if (rule_exists(i) && crush->rules[i]->mask.ruleset == ruleset) {
return true;
// If the pointer object is not present, then create it with
// front = default ino and back = null
JournalPointer jp(mds->get_nodeid(), mds->mdsmap->get_metadata_pool());
- int const read_result = jp.load(mds->objecter);
+ const int read_result = jp.load(mds->objecter);
if (read_result == -ENOENT) {
inodeno_t const default_log_ino = MDS_INO_LOG_OFFSET + mds->get_nodeid();
jp.front = default_log_ino;
* in order to generate health metrics if the session doesn't see
* a commensurate number of calls to ::notify_cap_release
*/
-void Session::notify_recall_sent(int const new_limit)
+void Session::notify_recall_sent(const int new_limit)
{
if (recalled_at.is_zero()) {
// Entering recall phase, set up counters so we can later
interval_set<inodeno_t> pending_prealloc_inos; // journaling prealloc, will be added to prealloc_inos
void notify_cap_release(size_t n_caps);
- void notify_recall_sent(int const new_limit);
+ void notify_recall_sent(const int new_limit);
void clear_recalled_at();
inodeno_t next_ino() const {
health.decode(bl_i);
}
for (const auto &metric : health.metrics) {
- int const rank = info.rank;
+ const int rank = info.rank;
health_check_t *check = &new_checks.get_or_add(
mds_metric_name(metric.type),
metric.sev,
health.decode(bl_i);
for (const auto &metric : health.metrics) {
- int const rank = info.rank;
+ const int rank = info.rank;
std::ostringstream message;
message << "mds" << rank << ": " << metric.message;
summary.push_back(std::make_pair(metric.sev, message.str()));
int poolbase = get_max_osd() ? get_max_osd() : 1;
- int const default_replicated_rule = crush->get_osd_pool_default_crush_replicated_ruleset(cct);
+ const int default_replicated_rule = crush->get_osd_pool_default_crush_replicated_ruleset(cct);
assert(default_replicated_rule >= 0);
if (default_pool) {
if (!op->session) {
_calc_target(&op->target, nullptr);
OSDSession *s = NULL;
- int const r = _get_session(op->target.osd, &s, sul);
+ const int r = _get_session(op->target.osd, &s, sul);
assert(r == 0);
assert(s != NULL);
op->session = s;
lock.Lock();
journaler->recover(&cond);
lock.Unlock();
- int const r = cond.wait();
+ const int r = cond.wait();
if (r < 0) { // Error
derr << "error on recovery: " << cpp_strerror(r) << dendl;
librados::IoCtx &io;
// Input constraints
- int const rank;
+ const int rank;
JournalFilter const filter;
void gap_advance();