qdebugstream.cpp

Go to the documentation of this file.

#include "dbe/qdebugstream.hpp"
#include "streambuf"
//using namespace daq::QTUtils;
std::streamsize QDebugStream::xsputn(const char *p, std::streamsize n) {
    QMutexLocker locker(m_mutex);
    m_string.append(p, p + n);
 
    uint pos = 0;
    while (pos != std::string::npos) {
        pos = m_string.find('\n');
        if (pos != std::string::npos) {
            std::string tmp(m_string.begin(), m_string.begin() + pos);
            m_text.append(tmp.c_str()).append("\n");
            m_string.erase(m_string.begin(), m_string.begin() + pos + 1);
        }
    }
    QCoreApplication::postEvent(this, new QEvent(QEvent::User));
    return n;
}
bool QDebugStream::event(QEvent* event) {
    if (event->type() == QEvent::User) {
        {
            QMutexLocker locker(m_mutex);
            if (!m_text.isEmpty())
                log_window->append(m_text);
            m_text.clear();
        }
        event->accept();
        return true;
    }
    return false;
}
 
std::streambuf::int_type QDebugStream::overflow(int_type v) {
    QMutexLocker locker(m_mutex);
    if (v == '\n') {
        m_text.append(m_string.c_str()).append("\n");
        m_string.erase(m_string.begin(), m_string.end());
    } else {
        m_string += v;
    }
    QCoreApplication::postEvent(this, new QEvent(QEvent::User));
    return v;
}