interaction.hh

来自「certi-SHM-3.0.tar 不错的开源的分布式方针软件 大家多多支持 他」· HH 代码 · 共 179 行

// -*- mode:C++ ; tab-width:4 ; c-basic-offset:4 ; indent-tabs-mode:nil -*-
// ----------------------------------------------------------------------------
// CERTI - HLA RunTime Infrastructure
// Copyright (C) 2002, 2003  ONERA
//
// This file is part of CERTI-libCERTI
//
// CERTI-libCERTI is free software ; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public License
// as published by the Free Software Foundation ; either version 2 of
// the License, or (at your option) any later version.
//
// CERTI-libCERTI 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
// Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser 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
//
// $Id: Interaction.hh,v 3.7 2003/02/19 18:07:29 breholee Exp $
// ----------------------------------------------------------------------------

#ifndef _CERTI_INTERACTION_HH
#define _CERTI_INTERACTION_HH

#include <config.h>

#include <list>
using std::list ;

#include <iostream>
using std::cout ;
using std::endl ;

#include "PrettyDebug.hh"
#include "RTItypes.hh"
#include "Parameter.hh"
#include "Subscriber.hh"
#include "Publisher.hh"
#include "SecurityServer.hh"
#include "InteractionBroadcastList.hh"

namespace certi {

class Interaction
{
    // ATTRIBUTES ------------------------------------------------------------
public:
    InteractionClassHandle handle ; //!< Interaction class handle.
    //! This Object helps to find a TCPLink given a Federate Handle.
    SecurityServer *server ;
    InteractionClassHandle parent ; //!< Parent Class' Handle.

    list<InteractionClassHandle> children ; //!< Children Classes' Handles List
    UShort depth ;

    /*! Interaction messages' Transport Type(Reliable, Best Effort),
      Currently not used.
    */
    TransportType transport ;

    //! Interaction message Ordering Type(TSO, FIFO), currently not used.
    OrderType order ;

private:
    char *name ; //!< Must be locally allocated and deleted.
    SecurityLevelID id ; //!< The default Security Level for new parameters

    //! List of this Interaction Class' Parameters.
    list<Parameter*> parameterSet ;
    //! List of the Federates(Handles) who subscribed to this Class.
    list<Subscriber*> subscribers ;
    //! List of the Federates(Handles) publishing this Class.
    list<Publisher *> publishers ;


    // METHODS ---------------------------------------------------------------
public:
    Interaction(void);
    ~Interaction(void);

    const char *getName(void) const ;
    void setName(const char *new_name)
        throw (ValueLengthExceeded, RTIinternalError);

    ParameterHandle addParameter(Parameter *the_parameter,
                                 bool is_inherited = false);

    void addParametersToChild(Interaction *new_child);
    void display(void) const ;

    // -- Security Methods --
    void checkFederateAccess(FederateHandle the_federate,
                             const char *reason) const
        throw (SecurityError);

    SecurityLevelID getLevelId(void) const { return id ; };
    void setLevelId(SecurityLevelID NewLevelID);

    // -- Publication and Subscription --
    void publish(bool publish, FederateHandle the_handle)
        throw (FederateNotPublishing, RTIinternalError, SecurityError);

    void subscribe(bool subscribe, FederateHandle the_handle)
        throw (FederateNotSubscribing, RTIinternalError, SecurityError);

    void subscribe(bool subscribe, Subscriber *the_subscriber)
        throw (RegionNotKnown, InvalidRoutingSpace, RTIinternalError);

    // -- RTI Support Services --
    ParameterHandle getParameterHandle(const char *) const
        throw (InteractionParameterNotDefined, RTIinternalError);

    const char *getParameterName(ParameterHandle) const
        throw (InteractionParameterNotDefined, RTIinternalError);

    void killFederate(FederateHandle theFederate)
        throw ();

    // -- Transport and Ordering --
    void changeTransportationType(TransportType new_type,
                                  FederateHandle the_handle)
        throw (FederateNotPublishing, InvalidTransportType, RTIinternalError);

    void changeOrderType(OrderType new_order, FederateHandle the_handle)
        throw (FederateNotPublishing, InvalidOrderType, RTIinternalError);

    // -- Instance Broadcasting --
    void isReady(FederateHandle federate_handle,
                 ParameterHandle *parameter_list,
                 UShort list_size) const
        throw (FederateNotPublishing,
               InteractionParameterNotDefined,
               RTIinternalError);

    InteractionBroadcastList *
    sendInteraction(FederateHandle federate_handle,
                    ParameterHandle *parameter_list,
                    ParameterValue *value_list,
                    UShort list_size,
                    FederationTime the_time,
                    const char *the_tag)
        throw (FederateNotPublishing,
               InteractionClassNotDefined,
               InteractionParameterNotDefined,
               RTIinternalError);

    void broadcastInteractionMessage(InteractionBroadcastList *ibList);

private:
    Parameter *getParameterByHandle(ParameterHandle the_handle) const
        throw (InteractionParameterNotDefined,
               RTIinternalError);

    // -- Private Publishers' Management --

    void addPublisher(FederateHandle the_federate)
        throw (RTIinternalError);
    void deletePublisher(int the_rank);
    int getPublisherRank(FederateHandle the_federate) const ;
    bool isPublishing(FederateHandle the_handle) const ;

    // -- Private Subcribers' Management --
    void addSubscriber(FederateHandle the_federate)
        throw (RTIinternalError);
    void deleteSubscriber(int the_rank);
    bool isSubscribed(FederateHandle the_handle) const ;
    int getSubscriberRank(FederateHandle the_federate) const ;
};

} // namespace

#endif // _CERTI_INTERACTION.HH

// $Id: Interaction.hh,v 3.7 2003/02/19 18:07:29 breholee Exp $