From 1adba473e6917b227e1b0a1118148101dca202e7 Mon Sep 17 00:00:00 2001 From: Manuel Traut Date: Mon, 31 Mar 2014 16:53:55 +0200 Subject: add quellcode Signed-off-by: Manuel Traut --- quellcode/versuch5/bench_i.cpp | 224 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 224 insertions(+) create mode 100755 quellcode/versuch5/bench_i.cpp (limited to 'quellcode/versuch5/bench_i.cpp') diff --git a/quellcode/versuch5/bench_i.cpp b/quellcode/versuch5/bench_i.cpp new file mode 100755 index 0000000..92c544e --- /dev/null +++ b/quellcode/versuch5/bench_i.cpp @@ -0,0 +1,224 @@ +// -*- C++ -*- +// +// $Id$ + +// **** Code generated by the The ACE ORB (TAO) IDL Compiler **** +// TAO and the TAO IDL Compiler have been developed by: +// Center for Distributed Object Computing +// Washington University +// St. Louis, MO +// USA +// http://www.cs.wustl.edu/~schmidt/doc-center.html +// and +// Distributed Object Computing Laboratory +// University of California at Irvine +// Irvine, CA +// USA +// http://doc.ece.uci.edu/ +// and +// Institute for Software Integrated Systems +// Vanderbilt University +// Nashville, TN +// USA +// http://www.isis.vanderbilt.edu/ +// +// Information about TAO is available at: +// http://www.cs.wustl.edu/~schmidt/TAO.html + +// TAO_IDL - Generated from +// be/be_codegen.cpp:1063 + +#include "bench_i.h" +#include + +// Implementation skeleton constructor +benchmark_msgAndPort1_i::benchmark_msgAndPort1_i (CORBA::ORB_ptr orb) +{ + CORBA::Object_var obj = orb->resolve_initial_references("RTCurrent"); + rt_current_ = RTCORBA::Current::_narrow(obj.in()); +} + +// Implementation skeleton destructor +benchmark_msgAndPort1_i::~benchmark_msgAndPort1_i (void) +{ +} + +void benchmark_msgAndPort1_i::connect ( + + ) + ACE_THROW_SPEC (( + ::CORBA::SystemException, + ::benchmark::invalidRequest + )) +{ + // Add your implementation here + cpx = new CPX(); +} + +void benchmark_msgAndPort1_i::setPorts ( + ::CORBA::Short valPort1, + ::CORBA::Short valPort2, + ::CORBA::Short valPort3 + ) + ACE_THROW_SPEC (( + ::CORBA::SystemException, + ::benchmark::invalidRequest + )) +{ + // Add your implementation here + + CORBA::Short priority = rt_current_->the_priority(); + + ACE_hthread_t current; + ACE_Thread::self (current); + int native_priority; + + cpx->set(1, valPort1); + cpx->set(2, valPort2); + cpx->set(3, valPort3); + + if (ACE_Thread::getprio (current, native_priority) != -1) { + std::cout << "Port: Native Priority: " << ACE_Thread::getprio (current, native_priority) << std::endl; + } + +} + +::CORBA::Boolean benchmark_msgAndPort1_i::sendMsg ( + const ::benchmark::msg & message + ) + ACE_THROW_SPEC (( + ::CORBA::SystemException, + ::benchmark::invalidRequest + )) +{ + // Add your implementation here + + CORBA::Short priority = rt_current_->the_priority(); + + ACE_hthread_t current; + ACE_Thread::self (current); + int native_priority; + + lastString = message.sender; + lastString += ": "; + lastString += message.message; + + if (ACE_Thread::getprio (current, native_priority) != -1) { + std::cout << "Message: Native Priority: " << ACE_Thread::getprio (current, native_priority) << std::endl; + } + + return true; +} + +// Implementation skeleton constructor +benchmark_msgAndPort2_i::benchmark_msgAndPort2_i (CORBA::ORB_ptr orb) +{ + CORBA::Object_var obj = orb->resolve_initial_references("RTCurrent"); + rt_current_ = RTCORBA::Current::_narrow(obj.in()); +} + +// Implementation skeleton destructor +benchmark_msgAndPort2_i::~benchmark_msgAndPort2_i (void) +{ +} + +void benchmark_msgAndPort2_i::connect ( + + ) + ACE_THROW_SPEC (( + ::CORBA::SystemException, + ::benchmark::invalidRequest + )) +{ + // Add your implementation here + cpx = new CPX(); +} + +void benchmark_msgAndPort2_i::setPortsSendMsg ( + ::CORBA::Short valPort1, + ::CORBA::Short valPort2, + ::CORBA::Short valPort3, + const ::benchmark::msg & message + ) + ACE_THROW_SPEC (( + ::CORBA::SystemException, + ::benchmark::invalidRequest + )) +{ + // Add your implementation here + cpx->set(1, valPort1); + cpx->set(2, valPort2); + cpx->set(3, valPort3); + lastString = message.sender; + lastString += ": "; + lastString += message.message; +} + +// Implementation skeleton constructor +benchmark_msgOnly_i::benchmark_msgOnly_i (CORBA::ORB_ptr orb) +{ +} + +// Implementation skeleton destructor +benchmark_msgOnly_i::~benchmark_msgOnly_i (void) +{ +} + +::CORBA::Boolean benchmark_msgOnly_i::sendMsg ( + const ::benchmark::msg & message + ) + ACE_THROW_SPEC (( + ::CORBA::SystemException, + ::benchmark::invalidRequest + )) +{ + // Add your implementation here + lastString = message.sender; + lastString += ": "; + lastString += message.message; + + return true; +} + +// Implementation skeleton constructor +benchmark_setPortsOnly_i::benchmark_setPortsOnly_i (CORBA::ORB_ptr orb) +{ + CORBA::Object_var obj = orb->resolve_initial_references("RTCurrent"); + rt_current_ = RTCORBA::Current::_narrow(obj.in()); +} + +// Implementation skeleton destructor +benchmark_setPortsOnly_i::~benchmark_setPortsOnly_i (void) +{ +} + +void benchmark_setPortsOnly_i::connect ( + + ) + ACE_THROW_SPEC (( + ::CORBA::SystemException, + ::benchmark::invalidRequest + )) +{ + // Add your implementation here + cpx = new CPX(); +} + +void benchmark_setPortsOnly_i::setPorts ( + ::CORBA::Short valPort1, + ::CORBA::Short valPort2, + ::CORBA::Short valPort3 + ) + ACE_THROW_SPEC (( + ::CORBA::SystemException, + ::benchmark::invalidRequest + )) +{ + // Add your implementation here + cpx->set(1, valPort1); + cpx->set(2, valPort2); + cpx->set(3, valPort3); + +} + + -- cgit v1.2.3