Messager.h

#ifndef STK_MESSAGER_H
#define STK_MESSAGER_H
 
#include "Stk.h"
// deactivate this functionality if no fstreams are supported by the environment
#ifndef __NO_FSTREAM__
#include "Skini.h"
#include <queue>
 
#if defined(__STK_REALTIME__)
 
#include "Mutex.h"
#include "Thread.h"
#include "TcpServer.h"
#include "RtMidi.h"
 
#endif // __STK_REALTIME__
 
namespace stk {
 
/***************************************************/
/***************************************************/
 
const int DEFAULT_QUEUE_LIMIT = 200;
 
class Messager : public Stk
{
 public:
 
  // This structure is used to share data among the various realtime
  // messager threads.  It must be public.
  struct MessagerData {
    Skini skini;
    std::queue<Skini::Message> queue;
    unsigned int queueLimit;
    int sources;
 
#if defined(__STK_REALTIME__)
    Mutex mutex;
    RtMidiIn *midi;
    TcpServer *socket;
    std::vector<int> fd;
    fd_set mask;
#endif
 
    // Default constructor.
    MessagerData()
      :queueLimit(0), sources(0) {}
  };
 
  Messager();
 
  ~Messager();
 
 
  void popMessage( Skini::Message& message );
 
  void pushMessage( Skini::Message& message );
 
 
  bool setScoreFile( const char* filename );
 
#if defined(__STK_REALTIME__)
 
  bool startStdInput();
 
 
  bool startSocketInput( int port=2001 );
 
 
  bool startMidiInput( int port=0 );
 
#endif
 
 protected:
 
  MessagerData data_;
 
#if defined(__STK_REALTIME__)
  Thread stdinThread_;
  Thread socketThread_;
#endif
 
};
 
} // stk namespace
 
#endif
 
#endif //__NO_FSTREAM__