int ret;
ret = pthread_mutex_init(&m_flush_mutex, NULL);
- assert(ret == 0);
+ ceph_assert(ret == 0);
ret = pthread_mutex_init(&m_queue_mutex, NULL);
- assert(ret == 0);
+ ceph_assert(ret == 0);
ret = pthread_cond_init(&m_cond_loggers, NULL);
- assert(ret == 0);
+ ceph_assert(ret == 0);
ret = pthread_cond_init(&m_cond_flusher, NULL);
- assert(ret == 0);
+ ceph_assert(ret == 0);
m_log_buf = (char*)malloc(MAX_LOG_BUF);
*m_indirect_this = NULL;
}
- assert(!is_started());
+ ceph_assert(!is_started());
if (m_fd >= 0)
VOID_TEMP_FAILURE_RETRY(::close(m_fd));
free(m_log_buf);
(unsigned long)e->m_thread, e->m_prio);
line_used += e->snprintf(line + line_used, line_size - line_used - 1);
- assert(line_used < line_size - 1);
+ ceph_assert(line_used < line_size - 1);
if (do_syslog) {
syslog(LOG_USER|LOG_INFO, "%s", line);
void Log::start()
{
- assert(!is_started());
+ ceph_assert(!is_started());
pthread_mutex_lock(&m_queue_mutex);
m_stop = false;
pthread_mutex_unlock(&m_queue_mutex);
}
}
bool should_gather(const unsigned sub, int level) const {
- assert(sub < m_subsys.size());
+ ceph_assert(sub < m_subsys.size());
return level <= static_cast<int>(m_gather_levels[sub]);
}
void set_log_level(unsigned subsys, uint8_t log)
{
- assert(subsys < m_subsys.size());
+ ceph_assert(subsys < m_subsys.size());
m_subsys[subsys].log_level = log;
m_gather_levels[subsys] = \
std::max(log, m_subsys[subsys].gather_level);
void set_gather_level(unsigned subsys, uint8_t gather)
{
- assert(subsys < m_subsys.size());
+ ceph_assert(subsys < m_subsys.size());
m_subsys[subsys].gather_level = gather;
m_gather_levels[subsys] = \
std::max(m_subsys[subsys].log_level, gather);