basicmsgqueuemux.h

Go to the documentation of this file.

/*******************************************************************\

                   SESAME project software license

          Copyright (C) 2002, 2003 University of Amsterdam

    This program is free software; you can redistribute it and/or
     modify it under the terms of the GNU General Public License
    as published by the Free Software Foundation; either version 2
        of the License, or (at your option) any later version.

   This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
             GNU General Public License for more details.

  You should have received a copy of the GNU General Public License
     along with this program; if not, write to the Free Software
      Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
                           02111-1307, USA.

      For information regarding the SESAME software project see
              http://sesamesim.sourceforge.net or email
                    jcofflan@users.sourceforge.net

\*******************************************************************/

#ifndef BASICMSGQUEUEMUX_H
#define BASICMSGQUEUEMUX_H

#include <BasicUtils/BasicThread.h>
#include <BasicUtils/BasicFunctor.h>
#include "basicipcmsgqueue.h"
#include "basicmuxmessage.h"

#include <map>
#include <list>

class BasicMUXChannelBase;

class BasicMsgQueueMUX {
  typedef enum {MSGQ_OWNER = 1, MSGQ_CLIENT} message_types;

  BasicIPCMsgQueue msgQueue;

  bool writerFlushAndExit;

  BasicFunctor<BasicMsgQueueMUX> readFunctor;
  BasicFunctor<BasicMsgQueueMUX> writeFunctor;

  BasicThread readerThread;
  BasicThread writerThread;

  typedef std::map<int, BasicMUXChannelBase *> channelMap_t;
  channelMap_t channelMap;

  typedef std::list<BasicMUXChannelBase *> channelList_t;
  channelList_t channelList;

  typedef std::list<int> msgClearedList_t;
  msgClearedList_t msgClearedList;

  typedef struct {
    long type;
    long key;
  } clear_message_t;

 public:

  BasicMsgQueueMUX();
  virtual ~BasicMsgQueueMUX();

  bool addChannel(BasicMUXChannelBase *channel);
  void removeChannel(BasicMUXChannelBase *channel);

  bool isOpen();
  bool open(key_t key);
  key_t create(key_t key);
  void close(bool flushFirst = true);

 protected:
  void msgCleared(int key);
  void wakeWriter();

  void writeRun();
  void readRun();

 private:
  bool writesAllClear();
  int sendClears(int max);
  int sendMessages(int max);

  void readClear(clear_message_t *clearMsg);
  void readMessage(BasicMUXMessageBase::message_t *msg, int len);

  friend class BasicMUXChannelBase;
  friend class BasicFunctor<BasicMsgQueueMUX>;
};
#endif

---