summaryrefslogtreecommitdiff
path: root/orbsvcs/tests/EC_Mcast/EC_Mcast.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'orbsvcs/tests/EC_Mcast/EC_Mcast.cpp')
-rw-r--r--orbsvcs/tests/EC_Mcast/EC_Mcast.cpp23
1 files changed, 8 insertions, 15 deletions
diff --git a/orbsvcs/tests/EC_Mcast/EC_Mcast.cpp b/orbsvcs/tests/EC_Mcast/EC_Mcast.cpp
index 75d1ae02c5d..10b0777b219 100644
--- a/orbsvcs/tests/EC_Mcast/EC_Mcast.cpp
+++ b/orbsvcs/tests/EC_Mcast/EC_Mcast.cpp
@@ -23,10 +23,6 @@
#include "EC_Mcast.inl"
#endif /* __ACE_INLINE__ */
-ACE_RCSID (EC_Mcast,
- EC_Mcast,
- "$Id$")
-
ECM_Driver::ECM_Driver (void)
: event_period_ (250000),
event_count_ (100),
@@ -205,8 +201,7 @@ ECM_Driver::open_federations (RtecEventChannelAdmin::EventChannel_ptr ec)
{
for (int i = 0; i < this->local_federations_count_; ++i)
{
- this->local_federations_[i]->open (this->event_count_,
- ec);
+ this->local_federations_[i]->open (this->event_count_, ec);
}
}
@@ -218,8 +213,7 @@ ECM_Driver::activate_federations (RtecEventChannelAdmin::EventChannel_ptr ec)
interval *= 10;
for (int i = 0; i < this->local_federations_count_; ++i)
{
- this->local_federations_[i]->activate (ec,
- interval);
+ this->local_federations_[i]->activate (ec, interval);
}
}
@@ -256,8 +250,7 @@ ECM_Driver::open_senders (RtecEventChannelAdmin::EventChannel_ptr ec)
ACE_NEW (clone,
TAO_ECG_UDP_Out_Endpoint (this->endpoint_));
- this->all_federations_[i]->open (clone,
- ec);
+ this->all_federations_[i]->open (clone, ec);
}
}
@@ -743,7 +736,7 @@ ECM_Consumer::ECM_Consumer (ECM_Local_Federation *federation)
void
ECM_Consumer::open (const char*,
RtecEventChannelAdmin::EventChannel_ptr ec,
- ACE_RANDR_TYPE &seed)
+ unsigned int *seed)
{
// The worst case execution time is far less than 2
// milliseconds, but that is a safe estimate....
@@ -758,7 +751,7 @@ ECM_Consumer::open (const char*,
}
void
-ECM_Consumer::connect (ACE_RANDR_TYPE &seed)
+ECM_Consumer::connect (unsigned int *seed)
{
if (CORBA::is_nil (this->consumer_admin_.in ()))
return;
@@ -887,7 +880,7 @@ ECM_Local_Federation::open (int event_count,
ACE_OS::strcpy (buf, this->federation_->name ());
ACE_OS::strcat (buf, "/consumer");
- this->consumer_.open (buf, ec, this->seed_);
+ this->consumer_.open (buf, ec, &this->seed_);
this->last_subscription_change_ = ACE_OS::gettimeofday ();
}
@@ -940,7 +933,7 @@ ECM_Local_Federation::supplier_timeout (RtecEventComm::PushConsumer_ptr consumer
ACE_Time_Value delta = ACE_OS::gettimeofday () -
this->last_subscription_change_;
- unsigned int x = ACE_OS::rand_r (this->seed_);
+ unsigned int x = ACE_OS::rand_r (&this->seed_);
double p = double (x) / RAND_MAX;
double maxp = double (delta.msec ()) / this->subscription_change_period_;
@@ -950,7 +943,7 @@ ECM_Local_Federation::supplier_timeout (RtecEventComm::PushConsumer_ptr consumer
"Reconfiguring federation %s: %f %f [%d]\n",
this->name (), p, maxp, x));
this->consumer_.disconnect ();
- this->consumer_.connect (this->seed_);
+ this->consumer_.connect (&this->seed_);
this->last_subscription_change_ = ACE_OS::gettimeofday ();
}
}