pnconnection.h

Go to the documentation of this file.

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

                   SESAME project software license

              Copyright (C) 2002 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 PNCONNECTION_H
#define PNCONNECTION_H

#include "datablockclass.h"

#include <ymlconnection.h>
#include <BasicUtils/BasicCondition.h>
#include <BasicUtils/BasicException.h>

#include <pthread.h>
#include <iostream>
#include <list>

// Forward declarations
class ProcessLoader;
class YMLPort;


class PNConnection : public BasicCondition, public YMLConnection {
  // Attributes
private:
  std::list<DataBlockClass *> dataQueue;
  unsigned int dataQueueSize;

  ProcessLoader *reader;
  ProcessLoader *writer;
  YMLPort *readerPort;
  YMLPort *writerPort;

  unsigned int sizeLimit;

  int numReads;

  int numWrites;

  // Operations
public:
  PNConnection();
  ~PNConnection();

  DataBlockClass *read();
  void write(DataBlockClass *data);
  int getNumReads() {return numReads;}
  int getNumWrites() {return numWrites;}


  void clear() {lock(); dataQueue.clear(); dataQueueSize = 0; unlock();}
  bool isEmpty();
  unsigned int getSize();

  ProcessLoader *getWriter() {return writer;}
  ProcessLoader *getReader() {return reader;}
  void setReader(ProcessLoader *reader, YMLPort *port)
    {ASSERT_OR_THROW("NULL parameter", reader && port);
    this->reader = reader; readerPort = port;}
  void setWriter(ProcessLoader *writer, YMLPort *port)
    {ASSERT_OR_THROW("NULL parameter", writer && port);
    this->writer = writer; writerPort = port;}
  YMLPort *getReaderPort() {return readerPort;}
  YMLPort *getWriterPort() {return writerPort;}
};

std::ostream &operator<<(std::ostream &stream, PNConnection &c);
#endif

---