diff options
| author | Johnny Willemsen <jwillemsen@remedy.nl> | 2003-04-09 17:14:24 +0000 |
|---|---|---|
| committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2003-04-09 17:14:24 +0000 |
| commit | b6f30a7aac5793854b319e7a824787d10d48d29d (patch) | |
| tree | f185d49769c4f16ec10d4a446672d3f2e20fedd6 /TAO/orbsvcs/orbsvcs/Event/EC_Reactive_SupplierControl.cpp | |
| parent | 3f2c5466c98296f743b01ad6245ec8ca1dad53cc (diff) | |
| download | ATCD-b6f30a7aac5793854b319e7a824787d10d48d29d.tar.gz | |
ChangeLogTag: Wed Apr 09 19:13:12 2002 Johnny Willemsen <jwillemsen@remedy.nl>
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Reactive_SupplierControl.cpp')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/Event/EC_Reactive_SupplierControl.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Reactive_SupplierControl.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_Reactive_SupplierControl.cpp index e1f7e0f7421..30c83096e8c 100644 --- a/TAO/orbsvcs/orbsvcs/Event/EC_Reactive_SupplierControl.cpp +++ b/TAO/orbsvcs/orbsvcs/Event/EC_Reactive_SupplierControl.cpp @@ -19,9 +19,11 @@ ACE_RCSID(Event, EC_Reactive_SupplierControl, "$Id$") TAO_EC_Reactive_SupplierControl:: TAO_EC_Reactive_SupplierControl (const ACE_Time_Value &rate, + const ACE_Time_Value &timeout, TAO_EC_Event_Channel *ec, CORBA::ORB_ptr orb) : rate_ (rate), + timeout_ (timeout), adapter_ (this), event_channel_ (ec), orb_ (CORBA::ORB::_duplicate (orb)) @@ -110,10 +112,8 @@ TAO_EC_Reactive_SupplierControl::activate (void) ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - // Pre-compute the policy list to the set the right timeout - // value... - // @@ TODO It is currently hard-coded to 10 milliseconds - TimeBase::TimeT timeout = 10 * 10000; + // Timeout for polling state (default = 10 msec) + TimeBase::TimeT timeout = timeout_.usec() * 10; CORBA::Any any; any <<= timeout; @@ -122,7 +122,7 @@ TAO_EC_Reactive_SupplierControl::activate (void) this->orb_->create_policy ( Messaging::RELATIVE_RT_TIMEOUT_POLICY_TYPE, any - ACE_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; } ACE_CATCHANY |