---

SupplierAdmin.cc

Go to the documentation of this file.

//                            Package   : omniEvents
// SupplierAdmin.h            Created   : 2003/12/04
//                            Author    : Alex Tingle
//
//    Copyright (C) 2003 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
//

#include "SupplierAdmin.h"

#include "EventChannel.h"
#include "ProxyPushConsumer.h"
#include "ProxyPullConsumer.h"
#include "Orb.h"
#include "PersistNode.h"

namespace OmniEvents {

CosEventChannelAdmin::ProxyPushConsumer_ptr
SupplierAdmin_i::obtain_push_consumer()
{
  return _pushConsumer->createObject();
}


CosEventChannelAdmin::ProxyPullConsumer_ptr
SupplierAdmin_i::obtain_pull_consumer()
{
  if(!_pullConsumer)
      _pullConsumer=new ProxyPullConsumerManager(_poa,_queue);
  return _pullConsumer->createObject();
}


SupplierAdmin_i::SupplierAdmin_i(
  const EventChannel_i&   channel,
  PortableServer::POA_ptr poa
)
: Servant(poa),
  _channel(channel),
  _pushConsumer(NULL),
  _pullConsumer(NULL),
  _queue(),
  _nextPull(0)
{
  // Always create the ProxyPushConsumer_i default servant. This allows
  // lazy clients to connect suppliers without having to go through the
  // proper procedure - they can make up an appropriate ObjectId, call push()
  // and it will just work (TM).
  // Note: A SupplierAdmin_i is always created by the EventChannel to allow this
  // behaviour.
  _pushConsumer=new ProxyPushConsumer_i(_poa,_queue,_channel.consumerAdmin());
  
  activateObjectWithId("SupplierAdmin");
  _remove_ref();
}


SupplierAdmin_i::~SupplierAdmin_i()
{
  if(_pushConsumer)
  {
    delete _pushConsumer;
    _pushConsumer=NULL;
  }
  for(list<CORBA::Any*>::iterator i=_queue.begin(); i!=_queue.end(); ++i)
      delete *i;
  DB(20,"~SupplierAdmin_i()")
}


void SupplierAdmin_i::collect(list<CORBA::Any*>& events)
{
  if(_pullConsumer)
  {
    // Only trigger the ProxyPullConsumer if `pullRetry' seconds have passed.
    unsigned long sec,nsec;
    omni_thread::get_time(&sec,&nsec);
    if(sec>_nextPull)
    {
      _pullConsumer->trigger();
      _nextPull=sec+_channel.pullRetryPeriod();
    }
  }
  _pushConsumer->trigger();
  // Pick up events from both pull & push consumers.
  events=_queue;
  _queue.clear();
}


void SupplierAdmin_i::disconnect()
{
  if(_pushConsumer)
     _pushConsumer->disconnect();
  if(_pullConsumer)
     _pullConsumer->disconnect();
}


void SupplierAdmin_i::reincarnate(const PersistNode& node)
{
  // Build Push Consumer proxies
  PersistNode* pushcNode =node.child("ProxyPushConsumer");
  if(pushcNode && !pushcNode->_child.empty())
  {
    assert(_pushConsumer!=NULL);
    _pushConsumer->reincarnate(*pushcNode);
  }

  // Build Pull Consumer proxies
  PersistNode* pullcNode =node.child("ProxyPullConsumer");
  if(pullcNode && !pullcNode->_child.empty())
  {
    if(!_pullConsumer)
        _pullConsumer=new ProxyPullConsumerManager(_poa,_queue);
    _pullConsumer->reincarnate(*pullcNode);
  }
}


void SupplierAdmin_i::output(ostream& os)
{
  if(_pushConsumer)
     _pushConsumer->output(os);
  if(_pullConsumer)
     _pullConsumer->output(os);
}


}; // end namespace OmniEvents

---