ProxyManager.h

Go to the documentation of this file.

//                            Package   : omniEvents
// ProxyManager.h             Created   : 2003/12/04
//                            Author    : Alex Tingle
//
//    Copyright (C) 2003-2005 Alex Tingle.
//
//    This file is part of the omniEvents application.
//
//    omniEvents 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.1 of the License, or (at your option) any later version.
//
//    omniEvents 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 library; if not, write to the Free Software
//    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
//

#ifndef OMNIEVENTS__PROXYMANAGER_H
#define OMNIEVENTS__PROXYMANAGER_H

#ifdef HAVE_CONFIG_H
#  include "config.h"
#endif

#include <set>
#include <string>

#ifdef HAVE_IOSTREAM
#  include <iostream>
#else
#  include <iostream.h>
#endif

#include "Servant.h"

#ifdef HAVE_STD_IOSTREAM
using namespace std;
#endif

namespace OmniEvents {

class Proxy;
class PersistNode;

class ProxyManager
: public virtual POA_PortableServer::ServantActivator,
  public Servant
{
public: // CORBA interface methods
  void etherealize(
    const PortableServer::ObjectId& oid,
    PortableServer::POA_ptr         adapter,
    PortableServer::Servant         serv,
    CORBA::Boolean                  cleanup_in_progress,
    CORBA::Boolean                  remaining_activations
  );

public:
  void reincarnate(const PersistNode& node);
  void output(ostream& os);

protected:
  ProxyManager(PortableServer::POA_ptr poa);
  virtual ~ProxyManager();
  
  void activate(const char* name);

  set<Proxy*>             _servants;
  PortableServer::POA_var _managedPoa;
};


class Proxy
: public virtual PortableServer::ServantBase,
  public Servant
{
public:
  virtual ~Proxy();
  virtual void reincarnate(const string& oid, const PersistNode& node)=0;
  virtual void output(ostream &os)=0;
protected:
  Proxy(PortableServer::POA_ptr poa);

  void keyOutput(ostream& os, const char* name);
  void eraseKey(const char* name);
  void basicOutput(
    ostream& os, const char* name,
    CORBA::Object_ptr target=CORBA::Object::_nil(),
    const char* extraAttributes=NULL
  );
 
  CORBA::Request_var _req;
private:
  Proxy(const Proxy&); 
};


}; // end namespace OmniEvents

#endif // OMNIEVENTS__PROXYMANAGER_H

---