SharedEngineNode.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 _SHAREDENGINENODE_H
#define _SHAREDENGINENODE_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>
#include <shared/shared.hh>

namespace ot {

class CORBAModule;

class OPENTRACKER_API SharedEngineNode : 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:
    SharedEngineNode( CosEventChannelAdmin::EventChannel_var channel_) :
        Node(), 
        channel( channel_ ),
        cycle ( 0 )
    {
      supplier = new Supplier_i();
      supplier_admin = CORBAUtils::getSupplierAdmin(channel);
      proxy_consumer = CORBAUtils::getProxyPushConsumer(supplier_admin);
      CosEventComm::PushSupplier_var sptr = supplier->_this();
      CORBAUtils::connectPushSupplier(proxy_consumer, sptr);
    }
    virtual ~SharedEngineNode() {
      CORBAUtils::disconnectPushSupplier(proxy_consumer);
      delete supplier;
    }

public:
    virtual int isEventGenerator()
    {
      return 1;
      //return 0;
    }
    
    virtual void onEventGenerated( Event& event, Node& generator)
    {
      cycle++;
      Shared::FieldUpdate shared_event;// = new Shared::FieldUpdate;
      try {
        shared_event.supplier = CosEventComm::PushSupplier::_duplicate(sptr);
        shared_event.value.length(2);
        char s1[100];
        char s2[100];
        std::vector<float> position = event.getPosition();
        std::vector<float> quaternion = event.getOrientation();
        std::vector<float> orientation(4);
        MathUtils::quaternionToAxisAngle(quaternion, orientation);
        sprintf(s1,"%f %f %f %f", orientation[0], orientation[1], orientation[2], orientation[3]);
        //sprintf(s1,"%f %f %f %f", quaternion[0], quaternion[1], quaternion[2], quaternion[3]);
        sprintf(s2,"%f %f %f", position[0], position[1], position[2]);
        shared_event.value[0] = CORBA::string_dup((const char*) s2);
        shared_event.value[1] = CORBA::string_dup((const char*) s1);
        CORBA::Any any;
        any <<= shared_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 );
      //delete corba_event;
    }
    
    friend class CORBAModule;
};

}

#endif

---