listener.H

/*
 * This file is part of the "Archon" framework.
 * (http://files3d.sourceforge.net)
 *
 * Copyright © 2002 by Kristian Spangsege and Brian Kristiansen.
 *
 * Permission to use, copy, modify, and distribute this software and
 * its documentation under the terms of the GNU General Public License is
 * hereby granted. No representations are made about the suitability of
 * this software for any purpose. It is provided "as is" without express
 * or implied warranty. See the GNU General Public License
 * (http://www.gnu.org/copyleft/gpl.html) for more details.
 *
 * The characters in this file are ISO8859-1 encoded.
 *
 * The documentation in this file is in "Doxygen" style
 * (http://www.doxygen.org).
 */
#ifndef ARCHON_X3D_SAI_LISTENER_H
#define ARCHON_X3D_SAI_LISTENER_H

#include <archon/util/time.H>

#include <archon/x3d/server/server.H>

#include <archon/x3d/sai/exception.H>
#include <archon/x3d/sai/session.H>

namespace Archon
{
  namespace X3D
  {
    namespace SAI
    {
      using namespace Utilities;

      struct Listener: Server::Listener
      {
        Listener(Ref<Server> server,
                 Time applicationHeartbeat,
                 int corbaEndpointPort);
      
        ~Listener();

        Orb &getOrb() { return orb; }

        struct NameServerException: Exception
        {
          NameServerException(string l, string m): Exception(l, m) {}
        };

        void startServingClientRequests(Ref<GroupingNode> applicationContainer)
          throw(NameServerException);

        void removeSession(Ref<Session>);

        const BackRef<Server> server;

        Ref<GroupingNode> getApplicationContainer()
        {
          Mutex::Lock lock(mutex);
          return applicationContainer;
        }

      private:
        void refForwardDestroy();

        Mutex mutex;

        const Time applicationHeartbeat;

        Ref<GroupingNode> applicationContainer;

        Orb orb;

        struct Servant;
        PortableServer::ObjectId_var servantId;
        bool active;

        void activate() throw(NameServerException);

        void deactivate();

        CORBA::ULong getNodeTypeBitsInId();
        CORBA::ULong getNodeType(const char *);
        CORBA::ULong getImmediateField(CORBA::ULong, const char *);
        x3d::sai::Session_ptr createSession(x3d::sai::Application_ptr);

        list<Ref<Session> > sessions;
      };
    }
  }
}

#endif // ARCHON_X3D_SAI_LISTENER_H

---