L:/channel/channel/include/Channel.h

Go to the documentation of this file.

// Copyright (c) 2005, 2006 Yigong Liu
// Permission to use, copy, modify, distribute and sell this software for any 
//     purpose is hereby granted without fee, provided that the above copyright 
//     notice appear in all copies and that both that copyright notice and this 
//     permission notice appear in supporting documentation.
// The author makes no representations about the 
//     suitability of this software for any purpose. It is provided "as is" 
//     without express or implied warranty.

//--------------------------------------------------------------
//
// Channel.h
//
//-------------------------------------------------------------

#ifndef _CHANNEL_H_
#define _CHANNEL_H_

//ace headers
#include "ace/Synch_Traits.h"

//Channel headers
#include <Clock.h>
#include <BaseDef.h>
#include <Msg.h>
#include <ConnInfo.h>
#include <LinearIdTrait.h>
#include <HierarchicalIdTrait.h>
#include <Marshaler.h>
#include <Binder.h>
#include <Member.h>
#include <ConnHandler.h>
#include <Interface.h>
#include <OutputMgr.h>
#include <Connector.h>
#include <LocalConnector.h>
#include <TcpSockConnector.h>
#include <UnixSockConnector.h>
#include <Port.h>
#include <MapRouter.h>
#include <TrieRouter.h>


namespace channel {

  template 
    <
    class Id_Type, 
    class Id_Trait = IdTrait<Id_Type>,
    class Synch_Policy = ACE_MT_SYNCH, 
    //class AllocPolicy,
    class RouterType = MapRouter<Id_Type, Id_Trait, Synch_Policy/*, AllocPolicy*/>
    >
    class  Channel : public Id_Trait, public RouterType
    {
      public:

      typedef Id_Type IdType;
      typedef Id_Trait IdTrait;
      typedef Synch_Policy SynchPolicy;
      typedef RouterType Router;
      typedef Channel<IdType, Id_Trait, SynchPolicy, Router> ChannelType;
      typedef Source<ChannelType, Router::NamespaceType> Source;
      typedef Destination<ChannelType, Router::NamespaceType> Destination;
      typedef Callback<ChannelType> Callback;
      typedef Port<ChannelType> Port;
      typedef Msg<Id_Type, SynchPolicy> Msg;
      typedef struct Channel_Info_Msg Channel_Info_Msg;
      typedef PubSub_Info_Msg<Id_Type> PubSub_Info_Msg;

      typedef LocalConnector<ChannelType> LocalConnector;
      typedef Connector<ChannelType, TcpSockTransport<ChannelType> > TcpSockConnector;
      typedef Connector<ChannelType, UnixSockTransport<ChannelType> > UnixSockConnector;

    };

};

#endif

---