diff options
| author | coryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2002-03-08 01:43:52 +0000 |
|---|---|---|
| committer | coryan <coryan@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2002-03-08 01:43:52 +0000 |
| commit | 8c23afaa17d7abd748a3fc60028766c6094195b1 (patch) | |
| tree | f0589f9e4f7f75f9cf5b650ee7affd26d6e40234 /TAO/orbsvcs/performance-tests/RTEvent/lib/Send_Task.cpp | |
| parent | d2ac5c66cbf47860e0128ab181cd96dfa53b7993 (diff) | |
| download | ATCD-8c23afaa17d7abd748a3fc60028766c6094195b1.tar.gz | |
ChangeLogTag:Thu Mar 7 17:34:26 2002 Carlos O'Ryan <coryan@uci.edu>
Diffstat (limited to 'TAO/orbsvcs/performance-tests/RTEvent/lib/Send_Task.cpp')
| -rw-r--r-- | TAO/orbsvcs/performance-tests/RTEvent/lib/Send_Task.cpp | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/TAO/orbsvcs/performance-tests/RTEvent/lib/Send_Task.cpp b/TAO/orbsvcs/performance-tests/RTEvent/lib/Send_Task.cpp index a8ac85cb79c..004628e3e83 100644 --- a/TAO/orbsvcs/performance-tests/RTEvent/lib/Send_Task.cpp +++ b/TAO/orbsvcs/performance-tests/RTEvent/lib/Send_Task.cpp @@ -14,6 +14,7 @@ ACE_RCSID(TAO_PERF_RTEC, Send_Task, "$Id$") Send_Task::Send_Task (void) : iterations_ (0) , period_in_usecs_ (0) + , startup_sleep_ (0) , event_type_ (0) , event_source_ (0) , barrier_ (0) @@ -24,6 +25,7 @@ Send_Task::Send_Task (void) void Send_Task::init (int iterations, int period_in_usecs, + int startup_sleep, int event_type, int event_source, Supplier *supplier, @@ -31,6 +33,7 @@ Send_Task::init (int iterations, { this->iterations_ = iterations; this->period_in_usecs_ = period_in_usecs; + this->startup_sleep_ = startup_sleep; this->event_type_ = event_type; this->event_source_ = event_source; this->supplier_ = Servant_var<Supplier>::duplicate (supplier); @@ -52,12 +55,16 @@ Send_Task::svc (void) this->barrier_->wait (); + ACE_Time_Value startup (0, this->startup_sleep_); + ACE_OS::sleep (startup); + ACE_DEBUG ((LM_DEBUG, "(%P|%t) - Thread started, " "iterations = %d, period = %d, event_type = %d\n", this->iterations_, this->period_in_usecs_, this->event_type_)); + int start_i = 0; if (this->iterations_ == 0) { @@ -79,12 +86,11 @@ Send_Task::svc (void) if ((i + 1) % 1000 == 0) { ACE_DEBUG ((LM_DEBUG, - "(%P|%t) - Thread has sent %d messages\n", + "(%P|%t) - Thread has sent %d messages @ %T\n", i + 1)); } ACE_Time_Value period (0, this->period_in_usecs_); - ACE_OS::sleep (period); { ACE_GUARD_RETURN (TAO_SYNCH_MUTEX, ace_mon, this->mutex_, -1); |