socketserver.hh~

certi-SHM-3.0.tar 不错的开源的分布式方针软件 大家多多支持 他是linux

// -*- 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: SocketServer.hh,v 3.4 2003/02/19 18:07:30 breholee Exp $
// ----------------------------------------------------------------------------

#ifndef _CERTI_SOCKET_SERVER_HH
#define _CERTI_SOCKET_SERVER_HH

#include <list>
using std::list ;

#include "RTItypes.hh"
#include "Socket.hh"
#include "SocketTCP.hh"
#include "SocketUDP.hh"
#include "SocketSHM.hh"

#include "NetworkMessage.hh"

#include "SecurityLevel.hh"
#include "SecureTCPSocket.hh"
#include <sys/ioctl.h>

#include "PrettyDebug.hh"

namespace certi {

// ----------------------------------------------------------------------------
//! Element of the SocketServer internal list.
class SocketTuple
{
public:
    FederationHandle Federation ;
    FederateHandle Federate ;

    SocketTCP *ReliableLink ;
    SocketUDP *BestEffortLink ;
    SocketSHM *QuickLink;

    SocketTuple(Socket *theTCPLink);
    ~SocketTuple();
};

// ----------------------------------------------------------------------------
/*! Liste dynamique mettant en relation un couple(Federation, Federe)
  avec une Socket TCP. Sont decritent les classes : SocketTuple
  (l'element de la liste) SocketServer(la liste au niveau du RTIG)
  CFederationSocketServer (l'interface de la liste precedente au
  niveau de la federation et de ses objets, qui contient en plus des
  fonctionnalites de securite)
*/
class SocketServer : private list<SocketTuple *>
{
public:
    SocketServer(SocketTCP *tcp_socket,
                 SocketUDP *udp_socket, int the_port);

    ~SocketServer(void);

    // --------------------------------
    // -- Connection related methods --
    // --------------------------------
    void open(void)
        throw (RTIinternalError);

    void close(long socket, // Provided
               FederationHandle &federation_referenced, // Returned
               FederateHandle &federate_referenced) // Returned
        throw (RTIinternalError);

    void setReferences(long the_socket,
                       FederationHandle federation_reference,
                       FederateHandle federate_reference,
                       unsigned long the_address,
                       unsigned int the_port)
        throw (RTIinternalError);

    // -----------------------------
    // -- Message related methods --
    // -----------------------------
    void checkMessage(long socket, NetworkMessage *message) const
        throw (SecurityError);

    // --------------------------
    // -- RTIG related methods --
    // --------------------------
    void addToFDSet(fd_set *select_fdset);
    Socket *getActiveSocket(fd_set *select_fdset) const ;

    // ------------------------------------------
    // -- Message Broadcasting related Methods --
    // ------------------------------------------
    Socket *getSocketLink(FederationHandle the_federation,
                          FederateHandle the_federate,
                          TransportType the_type = RELIABLE) const
        throw (FederateNotExecutionMember,
               RTIinternalError);

    SocketTuple *getWithReferences(FederationHandle the_federation,
                                   FederateHandle the_federate) const
        throw (FederateNotExecutionMember);
	
    SocketTuple* SocketServer::select(fd_set * fd);

private:
    // The Server socket object(used for Accepts)
    SocketTCP *ServerSocketTCP ;
    SocketUDP *ServerSocketUDP ;
    fd_set fd ;
    // int port ;

    // ---------------------
    // -- Private Methods --
    // ---------------------
    SocketTuple *getWithSocket(long socket_descriptor) const
        throw (RTIinternalError);
};

} // namespace certi

#endif // _CERTI_SOCKET_SERVER_HH

// $Id: SocketServer.hh,v 3.4 2003/02/19 18:07:30 breholee Exp $