cnamedpipecomm.h

//=========================================================================
//  CNAMEDPIPECOMM.H - part of
//
//                  OMNeT++/OMNEST
//           Discrete System Simulation in C++
//
//  Author: Andras Varga, 2003
//          Dept. of Electrical and Computer Systems Engineering,
//          Monash University, Melbourne, Australia
//
//=========================================================================

/*--------------------------------------------------------------*
  Copyright (C) 2003-2008 Andras Varga
  Copyright (C) 2006-2008 OpenSim Ltd.
  Monash University, Dept. of Electrical and Computer Systems Eng.
  Melbourne, Australia

  This file is distributed WITHOUT ANY WARRANTY. See the file
  `license' for details on this and other legal matters.
*--------------------------------------------------------------*/


#ifndef __CNAMEDPIPECOMM_H__
#define __CNAMEDPIPECOMM_H__


#include <stdio.h>
#include <deque>
#include "simutil.h"
#include "opp_string.h"
#include "cparsimcomm.h"
#include "platdep/platmisc.h"  // for <windows.h>

// decide platform
#if defined(_WIN32)
#define USE_WINDOWS_PIPES
#endif

NAMESPACE_BEGIN

#ifdef USE_WINDOWS_PIPES
typedef HANDLE PIPE;
#else
typedef int PIPE;
#endif


class SIM_API cNamedPipeCommunications : public cParsimCommunications
{
  protected:
    int numPartitions;
    int myProcId;

    // pipes
    opp_string prefix;
    PIPE *rpipes;
    PIPE *wpipes;
    int maxFdPlus1;
    int rrBase;

    // reordering buffer needed because of tag filtering support (filtTag)
    std::deque<cCommBuffer*> storedBuffers;

  protected:
    // common impl. for receiveBlocking() and receiveNonblocking()
    bool receive(int filtTag, cCommBuffer *buffer, int& receivedTag, int& sourceProcId, bool blocking);
    bool doReceive(cCommBuffer *buffer, int& receivedTag, int& sourceProcId, bool blocking);

  public:
    cNamedPipeCommunications();

    virtual ~cNamedPipeCommunications();

    virtual void init();

    virtual void shutdown();

    virtual int getNumPartitions() const;

    virtual int getProcId() const;

    virtual cCommBuffer *createCommBuffer();

    virtual void recycleCommBuffer(cCommBuffer *buffer);

    virtual void send(cCommBuffer *buffer, int tag, int destination);

    virtual bool receiveBlocking(int filtTag, cCommBuffer *buffer, int& receivedTag, int& sourceProcId);

    virtual bool receiveNonblocking(int filtTag, cCommBuffer *buffer,  int& receivedTag, int& sourceProcId);
};

NAMESPACE_END


#endif