summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Event/lib/Supplier.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Event/lib/Supplier.cpp')
-rw-r--r--TAO/orbsvcs/tests/Event/lib/Supplier.cpp299
1 files changed, 0 insertions, 299 deletions
diff --git a/TAO/orbsvcs/tests/Event/lib/Supplier.cpp b/TAO/orbsvcs/tests/Event/lib/Supplier.cpp
deleted file mode 100644
index 33d9d45af56..00000000000
--- a/TAO/orbsvcs/tests/Event/lib/Supplier.cpp
+++ /dev/null
@@ -1,299 +0,0 @@
-// $Id$
-
-#include "Supplier.h"
-#include "orbsvcs/Time_Utilities.h"
-#include "orbsvcs/Event_Utilities.h"
-
-ACE_RCSID(EC_Tests, EC_Supplier, "$Id$")
-
-EC_Supplier::EC_Supplier (EC_Driver *driver,
- void* cookie)
- : driver_ (driver),
- cookie_ (cookie),
- push_count_ (0),
- burst_count_ (0),
- burst_size_ (0),
- payload_size_ (0),
- burst_pause_ (0),
- shutdown_event_type_ (0),
- is_active_ (0)
-{
-}
-
-void
-EC_Supplier::send_event (int event_number,
- CORBA::Environment &ACE_TRY_ENV)
-{
- if (CORBA::is_nil (this->consumer_proxy_.in ()))
- return;
-
- // Create the event...
-
- RtecEventComm::EventSet event (1);
- event.length (1);
-
- event[0].header.ttl = 1;
-
- ACE_hrtime_t t = ACE_OS::gethrtime ();
- ORBSVCS_Time::hrtime_to_TimeT (event[0].header.creation_time, t);
- event[0].header.ec_recv_time = ORBSVCS_Time::zero ();
- event[0].header.ec_send_time = ORBSVCS_Time::zero ();
-
- event[0].data.x = 0;
- event[0].data.y = 0;
-
- // We use replace to minimize the copies, this should result
- // in just one memory allocation:
- event[0].data.payload.length (this->payload_size_);
-
- this->event_type (event_number, event[0]);
-
- this->send_event (event, ACE_TRY_ENV);
-}
-
-void
-EC_Supplier::send_event (const RtecEventComm::EventSet& event,
- CORBA::Environment &ACE_TRY_ENV)
-{
- ACE_GUARD (ACE_SYNCH_MUTEX, ace_mon, this->lock_);
-
- if (this->push_count_ == 0)
- this->throughput_.start ();
-
- // We start the timer as soon as we receive the first event...
- this->throughput_.sample ();
-
- this->push_count_ += event.length ();
-
- if (TAO_debug_level > 0
- && this->push_count_ % 100 == 0)
- {
- ACE_DEBUG ((LM_DEBUG,
- "EC_Consumer (%P|%t): %d events received\n",
- this->push_count_));
- }
- this->consumer_proxy_->push (event, ACE_TRY_ENV);
-}
-
-void
-EC_Supplier::event_type (int event_number,
- RtecEventComm::Event &event)
-{
- CORBA::ULong l = this->qos_.publications.length ();
-
- if (l == 0)
- {
- event.header.source = 0;
- event.header.type = this->shutdown_event_type_;
- }
- else
- {
- int i = event_number % l;
- int type = this->qos_.publications[i].event.header.type;
- if (type == this->shutdown_event_type_)
- i = 0;
-
- RtecEventComm::EventHeader& header =
- this->qos_.publications[i].event.header;
-
- event.header.source = header.source;
- event.header.type = header.type;
- }
-}
-
-void
-EC_Supplier::connect (RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin,
- const RtecEventChannelAdmin::SupplierQOS& qos,
- int shutdown_event_type,
- CORBA::Environment &ACE_TRY_ENV)
-{
- this->consumer_proxy_ =
- supplier_admin->obtain_push_consumer (ACE_TRY_ENV);
- ACE_CHECK;
-
- this->connect (qos, shutdown_event_type, ACE_TRY_ENV);
- ACE_CHECK;
-}
-
-void
-EC_Supplier::connect (const RtecEventChannelAdmin::SupplierQOS& qos,
- int shutdown_event_type,
- CORBA::Environment &ACE_TRY_ENV)
-{
- if (CORBA::is_nil (this->consumer_proxy_.in ()))
- return; // @@ Throw?
-
- this->qos_ = qos;
- this->shutdown_event_type_ = shutdown_event_type;
-
- RtecEventComm::PushSupplier_var objref = this->_this (ACE_TRY_ENV);
- ACE_CHECK;
- this->is_active_ = 1;
-
- this->consumer_proxy_->connect_push_supplier (objref.in (),
- qos,
- ACE_TRY_ENV);
- ACE_CHECK;
-}
-
-void
-EC_Supplier::disconnect (CORBA::Environment &ACE_TRY_ENV)
-{
- if (CORBA::is_nil (this->consumer_proxy_.in ()))
- return;
-
- this->consumer_proxy_->disconnect_push_consumer (ACE_TRY_ENV);
- ACE_CHECK;
-
- this->consumer_proxy_ =
- RtecEventChannelAdmin::ProxyPushConsumer::_nil ();
-}
-
-void
-EC_Supplier::shutdown (CORBA::Environment &ACE_TRY_ENV)
-{
- if (!this->is_active_)
- return;
-
- // Deactivate the servant
- PortableServer::POA_var poa =
- this->_default_POA (ACE_TRY_ENV);
- ACE_CHECK;
- PortableServer::ObjectId_var id =
- poa->servant_to_id (this, ACE_TRY_ENV);
- ACE_CHECK;
- poa->deactivate_object (id.in (), ACE_TRY_ENV);
- ACE_CHECK;
- this->is_active_ = 0;
-}
-
-void
-EC_Supplier::disconnect_push_supplier (CORBA::Environment &ACE_TRY_ENV)
- ACE_THROW_SPEC ((CORBA::SystemException))
-{
- this->driver_->supplier_disconnect (this->cookie_, ACE_TRY_ENV);
- this->consumer_proxy_ =
- RtecEventChannelAdmin::ProxyPushConsumer::_nil ();
-}
-
-void
-EC_Supplier::dump_results (const char* name)
-{
- this->throughput_.dump_results ("EC_Supplier", name);
-}
-
-void
-EC_Supplier::accumulate (EC_Driver::Throughput_Stats& stats) const
-{
- stats.accumulate (this->throughput_);
-}
-
-// ****************************************************************
-
-EC_Supplier_Task::EC_Supplier_Task (EC_Supplier* supplier,
- EC_Driver* driver,
- void* cookie,
- int burst_count,
- int burst_size,
- int burst_pause,
- int payload_size,
- int shutdown_event_type,
- ACE_Thread_Manager* thr_mgr)
- : ACE_Task_Base (thr_mgr),
- supplier_ (supplier),
- driver_ (driver),
- cookie_ (cookie),
- burst_count_ (burst_count),
- burst_size_ (burst_size),
- burst_pause_ (burst_pause),
- payload_size_ (payload_size),
- shutdown_event_type_ (shutdown_event_type)
-{
-}
-
-int
-EC_Supplier_Task::svc (void)
-{
- ACE_DECLARE_NEW_CORBA_ENV;
-
- // Initialize a time value to pace the test
- ACE_Time_Value tv (0, this->burst_pause_);
-
- RtecEventComm::EventSet event (1);
- event.length (1);
-
- event[0].header.ttl = 1;
-
- ACE_hrtime_t t = ACE_OS::gethrtime ();
- ORBSVCS_Time::hrtime_to_TimeT (event[0].header.creation_time, t);
- event[0].header.ec_recv_time = ORBSVCS_Time::zero ();
- event[0].header.ec_send_time = ORBSVCS_Time::zero ();
-
- event[0].data.x = 0;
- event[0].data.y = 0;
-
- // We use replace to minimize the copies, this should result
- // in just one memory allocation;
- event[0].data.payload.length (this->payload_size_);
-
- for (int i = 0; i < this->burst_count_; ++i)
- {
- for (int j = 0; j < this->burst_size_; ++j)
- {
- ACE_TRY
- {
- this->supplier_->event_type (j, event[0]);
-
- ACE_hrtime_t now = ACE_OS::gethrtime ();
- ORBSVCS_Time::hrtime_to_TimeT (event[0].header.creation_time,
- now);
- // ACE_DEBUG ((LM_DEBUG, "(%t) supplier push event\n"));
-
- this->supplier_->send_event (event, ACE_TRY_ENV);
-
- ACE_TRY_CHECK;
- }
- ACE_CATCH (CORBA::SystemException, sys_ex)
- {
- ACE_PRINT_EXCEPTION (sys_ex, "SYS_EX");
- }
- ACE_CATCHANY
- {
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "SYS_EX");
- }
- ACE_ENDTRY;
-
- ACE_OS::sleep (tv);
- }
- }
-
- ACE_TRY_EX(SHUTDOWN)
- {
- // Send one event shutdown from each supplier
- event[0].header.type = this->shutdown_event_type_;
- ACE_hrtime_t now = ACE_OS::gethrtime ();
- ORBSVCS_Time::hrtime_to_TimeT (event[0].header.creation_time,
- now);
- this->supplier_->send_event (event, ACE_TRY_ENV);
- ACE_TRY_CHECK_EX (SHUTDOWN);
- }
- ACE_CATCH (CORBA::SystemException, sys_ex)
- {
- ACE_PRINT_EXCEPTION (sys_ex, "SYS_EX");
- }
- ACE_CATCHANY
- {
- ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "SYS_EX");
- }
- ACE_ENDTRY;
-
- ACE_DEBUG ((LM_DEBUG,
- "Supplier task finished\n"));
- return 0;
-}
-
-// ****************************************************************
-
-#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
-#elif defined(ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
-#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
View Lorry Controller Status