22 #include "JackMessageBuffer.h"
23 #include "JackGlobals.h"
24 #include "JackError.h"
30 JackMessageBuffer* JackMessageBuffer::fInstance = NULL;
32 JackMessageBuffer::JackMessageBuffer()
43 JackMessageBuffer::~JackMessageBuffer()
46 bool JackMessageBuffer::Start()
50 if (fThread.StartSync() == 0) {
58 bool JackMessageBuffer::Stop()
61 jack_error(
"WARNING: %d message buffer overruns!", fOverruns);
63 jack_log(
"no message buffer overruns");
79 void JackMessageBuffer::Flush()
81 while (fOutBuffer != fInBuffer) {
82 jack_log_function(fBuffers[fOutBuffer].level, fBuffers[fOutBuffer].message);
83 fOutBuffer = MB_NEXT(fOutBuffer);
87 void JackMessageBuffer::AddMessage(
int level,
const char *message)
89 if (fGuard.Trylock()) {
90 fBuffers[fInBuffer].level = level;
91 strncpy(fBuffers[fInBuffer].message, message, MB_BUFFERSIZE);
92 fInBuffer = MB_NEXT(fInBuffer);
96 INC_ATOMIC(&fOverruns);
100 bool JackMessageBuffer::Execute()
122 jack_error(
"JackMessageBuffer::Execute lock cannot be taken");
128 bool JackMessageBuffer::Create()
130 if (fInstance == NULL) {
131 fInstance =
new JackMessageBuffer();
132 if (!fInstance->Start()) {
133 jack_error(
"JackMessageBuffer::Create cannot start thread");
143 bool JackMessageBuffer::Destroy()
145 if (fInstance != NULL) {
155 void JackMessageBufferAdd(
int level,
const char *message)
157 if (Jack::JackMessageBuffer::fInstance == NULL) {
159 jack_log_function(LOG_LEVEL_ERROR,
"messagebuffer not initialized, skip message");
161 Jack::JackMessageBuffer::fInstance->AddMessage(level, message);
165 int JackMessageBuffer::SetInitCallback(JackThreadInitCallback callback,
void *arg)
167 if (fInstance && callback && fRunning && fGuard.Lock()) {
187 while (fInit && ++count < 1000) {
192 if (count == 1000)
goto error;
199 jack_error(
"JackMessageBuffer::SetInitCallback : callback cannot be executed");
SERVER_EXPORT void jack_error(const char *fmt,...)
SERVER_EXPORT void jack_log(const char *fmt,...)