common/JackMessageBuffer.cpp

   1 /*
   2  *  Copyright (C) 2004 Rui Nuno Capela, Steve Harris
   3  *  Copyright (C) 2008 Nedko Arnaudov
   4  *  Copyright (C) 2008 Grame
   5  *
   6  *  This program is free software; you can redistribute it and/or modify
   7  *  it under the terms of the GNU Lesser General Public License as published by
   8  *  the Free Software Foundation; either version 2.1 of the License, or
   9  *  (at your option) any later version.
  10  *
  11  *  This program is distributed in the hope that it will be useful,
  12  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14  *  GNU Lesser General Public License for more details.
  15  *
  16  *  You should have received a copy of the GNU Lesser General Public License
  17  *  along with this program; if not, write to the Free Software
  18  *  Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
  19  *
  20  */
  21
  22 #include "JackMessageBuffer.h"
  23 #include "JackGlobals.h"
  24 #include "JackError.h"
  25
  26 namespace Jack
  27 {
  28
  29 JackMessageBuffer* JackMessageBuffer::fInstance = NULL;
  30
  31 JackMessageBuffer::JackMessageBuffer()
  32     :fThread(this),fInBuffer(0),fOutBuffer(0),fOverruns(0)
  33 {
  34     fRunning = true;
  35     fThread.StartSync();
  36 }
  37
  38 JackMessageBuffer::~JackMessageBuffer()
  39 {
  40     if (fOverruns > 0) {
  41         jack_error("WARNING: %d message buffer overruns!", fOverruns);
  42     } else {
  43         jack_info("no message buffer overruns");
  44     }
  45     fGuard.Lock();
  46     fRunning = false;
  47     fGuard.Signal();
  48     fGuard.Unlock();
  49     fThread.Stop();
  50     Flush();
  51 }
  52
  53 void JackMessageBuffer::Flush()
  54 {
  55     while (fOutBuffer != fInBuffer) {
  56         jack_log_function(fBuffers[fOutBuffer].level, fBuffers[fOutBuffer].message);
  57         fOutBuffer = MB_NEXT(fOutBuffer);
  58     }
  59 }
  60
  61 void JackMessageBuffer::AddMessage(int level, const char *message)
  62 {
  63     if (fGuard.Trylock()) {
  64         fBuffers[fInBuffer].level = level;
  65         strncpy(fBuffers[fInBuffer].message, message, MB_BUFFERSIZE);
  66         fInBuffer = MB_NEXT(fInBuffer);
  67         fGuard.Signal();
  68         fGuard.Unlock();
  69     } else {            /* lock collision */
  70         INC_ATOMIC(&fOverruns);
  71     }
  72 }
  73
  74 bool JackMessageBuffer::Execute()
  75 {
  76     while (fRunning) {
  77         fGuard.Lock();
  78         fGuard.Wait();
  79         Flush();
  80         fGuard.Unlock();
  81     }
  82     return false;
  83 }
  84
  85 void JackMessageBuffer::Create()
  86 {
  87     if (fInstance == NULL) {
  88         fInstance = new JackMessageBuffer();
  89     }
  90 }
  91
  92 void JackMessageBuffer::Destroy()
  93 {
  94     if (fInstance != NULL) {
  95         delete fInstance;
  96         fInstance = NULL;
  97     }
  98 }
  99
 100 void JackMessageBufferAdd(int level, const char *message)
 101 {
 102     if (Jack::JackMessageBuffer::fInstance == NULL) {
 103         /* Unable to print message with realtime safety.
 104          * Complain and print it anyway. */
 105         jack_log_function(LOG_LEVEL_ERROR, "messagebuffer not initialized, skip message");
 106     } else {
 107         Jack::JackMessageBuffer::fInstance->AddMessage(level, message);
 108     }
 109 }
 110
 111 };
 112