f->dump_string("scale_type", "log2");
break;
default:
- ceph_assert(false && "Invalid scale type");
+ ceph_abort_msg("Invalid scale type");
}
{
case PerfHistogramCommon::SCALE_LOG2:
return int64_t(1) << (i - 1);
}
- ceph_assert(false && "Invalid scale type");
+ ceph_abort_msg("Invalid scale type");
}
int64_t PerfHistogramCommon::get_bucket_for_axis(
}
return ac.m_buckets - 1;
}
- ceph_assert(false && "Invalid scale type");
+ ceph_abort_msg("Invalid scale type");
}
std::vector<std::pair<int64_t, int64_t>>
return crimson::ct_error::enoent::make();
} else if (r < 0) {
logger().error("omap_get_header: {}", r);
- ceph_assert(0 == "impossible");
+ ceph_abort_msg("impossible");
} else {
return get_attr_errorator::make_ready_future<ceph::bufferlist>(
std::move(bl));
} else {
mclock_queue_t::PullReq result = scheduler.pull_request();
if (result.is_future()) {
- ceph_assert(
- 0 == "Not implemented, user would have to be able to be woken up");
+ ceph_abort_msg(
+ "Not implemented, user would have to be able to be woken up");
return std::move(*(item_t*)nullptr);
} else if (result.is_none()) {
- ceph_assert(
- 0 == "Impossible, must have checked empty() first");
+ ceph_abort_msg(
+ "Impossible, must have checked empty() first");
return std::move(*(item_t*)nullptr);
} else {
ceph_assert(result.is_retn());
case CIPHER_MODE_DEC:
return m_decrypt_contexts;
default:
- ceph_assert(false);
+ ceph_abort();
}
}
};
entity_addr_t socket_addr;
int send_message(Message *m) override {
- ceph_assert(!"send_message on anonymous connection");
+ ceph_abort_msg("send_message on anonymous connection");
}
void send_keepalive() override {
- ceph_assert(!"send_keepalive on anonymous connection");
+ ceph_abort_msg("send_keepalive on anonymous connection");
}
void mark_down() override {
// silently ignore
}
/// Check whether there is anything to do.
bool _empty() override {
- ceph_assert(false);
+ ceph_abort();
}
/// Get the next work item to process.
* so at most one copy will execute simultaneously for a given thread pool.
* It can be used for non-thread-safe finalization. */
void _void_process_finish(void*) override {
- ceph_assert(false);
+ ceph_abort();
}
bool queue(
}
loc -= e.length;
}
- ceph_assert(false);
+ ceph_abort();
};
/// updates blob's pextents container and return unused pextents eligible
mClockScheduler>(cct, whoami, num_shards, shard_id, is_rotational,
op_queue_cut_off, monc);
} else {
- ceph_assert("Invalid choice of wq" == 0);
+ ceph_abort_msg("Invalid choice of wq");
}
}
allocator.reset(new AvlAllocator(false));
return seastar::now();
}
- ceph_assert(0 == "no support");
+ ceph_abort("no support");
}
seastar::future<> tear_down_fut() final {
if (allocator) {
return ret;
default:
lderr(m_cct) << "unrecognized object cache status" << dendl;
- ceph_assert(0);
+ ceph_abort();
}
}