PseudoNode.h

Go to the documentation of this file.

//=============================================================================
//  Computational Process Networks class library
//  Copyright (C) 1997-2006  Gregory E. Allen and The University of Texas
//
//  This library is free software; you can redistribute it and/or modify it
//  under the terms of the GNU Library General Public License as published
//  by the Free Software Foundation; either version 2 of the License, or
//  (at your option) any later version.
//
//  This library 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
//  Library General Public License for more details.
//
//  The GNU Public License is available in the file LICENSE, or you
//  can write to the Free Software Foundation, Inc., 59 Temple Place -
//  Suite 330, Boston, MA 02111-1307, USA, or you can find it on the
//  World Wide Web at http://www.fsf.org.
//=============================================================================
#pragma once

#include <cpn/common.h>
#include <cpn/bits/QueueReleaser.h>
#include <cpn/utils/Logger.h>
#include <cpn/threading/ReentrantLock.h>
#include <map>

namespace D4R {
    class Node;
}

namespace CPN {

    class CPN_API PseudoNode : private QueueReleaser {
    public:
        PseudoNode(const std::string &name_, Key_t k, shared_ptr<Context> ctx);
        virtual ~PseudoNode();

        const std::string &GetName() const { return name; }

        Key_t GetKey() const { return nodekey; }

        shared_ptr<QueueReader> GetIQueue(const std::string &portname);

        shared_ptr<QueueWriter> GetOQueue(const std::string &portname);

        void CreateReader(shared_ptr<QueueBase> q);
        void CreateWriter(shared_ptr<QueueBase> q);
        void NotifyTerminate();
        virtual void Shutdown();
        virtual bool IsPurePseudo();

        virtual void LogState();
    protected:
        Logger logger;
    private:
        PseudoNode(const PseudoNode &);
        void ReleaseReader(Key_t ekey);
        void ReleaseWriter(Key_t ekey);
        shared_ptr<QueueReader> GetReader(Key_t ekey);
        shared_ptr<QueueWriter> GetWriter(Key_t ekey);


        Sync::ReentrantLock lock;
        Sync::ReentrantCondition cond;
        const std::string name;
        const Key_t nodekey;
        shared_ptr<D4R::Node> d4rnode;

        typedef std::map<Key_t, shared_ptr<QueueReader> > ReaderMap;
        typedef std::map<Key_t, shared_ptr<QueueWriter> > WriterMap;
        ReaderMap readermap;
        WriterMap writermap;

        shared_ptr<Context> context;
    };
}