PushSupp.h

Go to the documentation of this file.

/* ======================================================================== 
 * Copyright (C) 2006  Graz University of Technology
 *
 * This framework is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This framework 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 General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this framework; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 *
 * For further information please contact 
 * Dieter Schmalstieg
 * <schmalstieg@icg.tu-graz.ac.at>
 * Graz University of Technology, 
 * Institut for Computer Graphics and Vision,
 * Inffeldgasse 16a, 8010 Graz, Austria.
 * ========================================================================
 * PROJECT: OpenTracker
 * ======================================================================== */
 /* ======================================================================= */

#ifndef _PUSHSUPP_H
#define _PUSHSUPP_H

#include <OpenTracker/OpenTracker.h>
#include <OpenTracker/tool/OT_ACE_Log.h>
#include <OpenTracker/skeletons/OT_CORBA.hh>
#include <OpenTracker/network/CORBAUtils.h>
#include <omniEvents/CosEventComm.hh>
#include <omniEvents/CosEventChannelAdmin.hh>

namespace ot {

class CORBAModule;

class Supplier_i : virtual public POA_CosEventComm::PushSupplier {
public:
  Supplier_i () {};
  void disconnect_push_supplier () {
    logPrintI("Push Supplier: disconnected.\n");
  };
};

class OPENTRACKER_API PushSupp : public Node
{
// Members
public:
  CosEventChannelAdmin::EventChannel_var channel;
  CosEventChannelAdmin::SupplierAdmin_var supplier_admin;
  CosEventChannelAdmin::ProxyPushConsumer_var proxy_consumer;
  CosEventComm::PushSupplier_var sptr;
  Supplier_i* supplier;
  int cycle;
    

// Methods
protected:
    PushSupp( CosEventChannelAdmin::EventChannel_var channel_) :
        Node(), 
        channel( channel_ ),
        cycle ( 0 )
    {
      supplier = new Supplier_i();
      try {
        supplier_admin = CORBAUtils::getSupplierAdmin(channel);
      } catch (CORBA::INV_OBJREF) {
        LOG_ACE_ERROR("Object reference of event channel is internally malformed. Exiting....\n");
        exit(-1);
      } 
      proxy_consumer = CORBAUtils::getProxyPushConsumer(supplier_admin);
      CosEventComm::PushSupplier_var sptr = supplier->_this();
      CORBAUtils::connectPushSupplier(proxy_consumer, sptr);
    }
    virtual ~PushSupp() {
      CORBAUtils::disconnectPushSupplier(proxy_consumer);
      delete supplier;
      logPrintI("PushSupp destructor");
    }

public:
    virtual int isEventGenerator()
    {
      return 1;
      //return 0;
    }
    
    virtual void onEventGenerated( Event& event, Node& generator)
    {
      cycle++;
      //OT_CORBA::Event* corba_event = new OT_CORBA::Event;
      //CORBAUtils::convertToCORBAEvent(event, *corba_event);
      OT_CORBA::Event corba_event = event.getCORBAEvent();
      try {
        CORBA::Any any;
        any <<= corba_event;
        proxy_consumer->push(any);
      }
      catch (CORBA::COMM_FAILURE) {
        logPrintE("Caught CORBA::COMM_FAILURE\n");
      }
      catch (CORBA::TRANSIENT) {
        logPrintE("Caught CORBA::TRANSIENT\n");
      }
      updateObservers( event );
    }
    
    friend class CORBAModule;
};

}

#endif

---