diff options
| author | sharath <sharath@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2001-03-31 10:09:07 +0000 |
|---|---|---|
| committer | sharath <sharath@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2001-03-31 10:09:07 +0000 |
| commit | 988fa6d952d21cb5a147e4d7930d8a3810f07bc2 (patch) | |
| tree | f554e4d3a86b6020b6eaeab31c22398cd4a7ed8d /TAO/orbsvcs/tests/AVStreams/Latency | |
| parent | d1611b1899ded55321746ab01e76e9f8f77c7841 (diff) | |
| download | ATCD-988fa6d952d21cb5a147e4d7930d8a3810f07bc2.tar.gz | |
ChangeLogTag: Sat Mar 31 02:23:16 2001 Sharath Cholleti <sharath@cs.wustl.edu>
Diffstat (limited to 'TAO/orbsvcs/tests/AVStreams/Latency')
| -rw-r--r-- | TAO/orbsvcs/tests/AVStreams/Latency/control.cpp | 3 | ||||
| -rw-r--r-- | TAO/orbsvcs/tests/AVStreams/Latency/ping.cpp | 49 | ||||
| -rw-r--r-- | TAO/orbsvcs/tests/AVStreams/Latency/pong.cpp | 3 |
3 files changed, 29 insertions, 26 deletions
diff --git a/TAO/orbsvcs/tests/AVStreams/Latency/control.cpp b/TAO/orbsvcs/tests/AVStreams/Latency/control.cpp index e1b458412d6..bb503c4efde 100644 --- a/TAO/orbsvcs/tests/AVStreams/Latency/control.cpp +++ b/TAO/orbsvcs/tests/AVStreams/Latency/control.cpp @@ -84,7 +84,8 @@ int main (int argc, char *argv[]) argv); CORBA::Object_var obj - = orb->resolve_initial_references ("RootPOA"); + = orb->resolve_initial_references ("RootPOA", ACE_TRY_ENV); + ACE_TRY_CHECK; PortableServer::POA_var poa = PortableServer::POA::_narrow (obj.in ()); diff --git a/TAO/orbsvcs/tests/AVStreams/Latency/ping.cpp b/TAO/orbsvcs/tests/AVStreams/Latency/ping.cpp index 5ca2dde38c1..48bc32bf648 100644 --- a/TAO/orbsvcs/tests/AVStreams/Latency/ping.cpp +++ b/TAO/orbsvcs/tests/AVStreams/Latency/ping.cpp @@ -100,7 +100,8 @@ int main (int argc, char *argv[]) argv); CORBA::Object_var obj - = orb->resolve_initial_references ("RootPOA"); + = orb->resolve_initial_references ("RootPOA", ACE_TRY_ENV); + ACE_TRY_CHECK; PortableServer::POA_var poa = PortableServer::POA::_narrow (obj.in ()); @@ -234,36 +235,36 @@ Ping_Recv_Callback::receive_frame (ACE_Message_Block *frame, const ACE_Addr &) { this->count_++; - + ACE_DEBUG ((LM_DEBUG,"Ping_Recv_Callback::receive_frame %d\n", this->count_)); if (this->count_ < 10) { for (const ACE_Message_Block *i = frame; - i != 0; - i = i->cont ()) - { - ACE_hrtime_t stamp; - - if (i->length () < sizeof(stamp)) - return 0; - - ACE_OS::memcpy (&stamp, i->rd_ptr (), sizeof(stamp)); - - ACE_hrtime_t now = ACE_OS::gethrtime (); - if (recv_base == 0) - { - recv_base = now; - } - else - { + i != 0; + i = i->cont ()) + { + ACE_hrtime_t stamp; + + if (i->length () < sizeof(stamp)) + return 0; + + ACE_OS::memcpy (&stamp, i->rd_ptr (), sizeof(stamp)); + + ACE_hrtime_t now = ACE_OS::gethrtime (); + if (recv_base == 0) + { + recv_base = now; + } + else + { recv_latency.sample (now - recv_base, now - stamp); - } - - if (respond == 1) - pong_callback.send_response (stamp); - } + } + + if (respond == 1) + pong_callback.send_response (stamp); + } } else TAO_AV_CORE::instance ()->orb ()->shutdown (); diff --git a/TAO/orbsvcs/tests/AVStreams/Latency/pong.cpp b/TAO/orbsvcs/tests/AVStreams/Latency/pong.cpp index 1fca2fa09b6..87bf7b709ce 100644 --- a/TAO/orbsvcs/tests/AVStreams/Latency/pong.cpp +++ b/TAO/orbsvcs/tests/AVStreams/Latency/pong.cpp @@ -117,7 +117,8 @@ int main (int argc, char *argv[]) argv); CORBA::Object_var obj - = orb->resolve_initial_references ("RootPOA"); + = orb->resolve_initial_references ("RootPOA", ACE_TRY_ENV); + ACE_TRY_CHECK; PortableServer::POA_var poa = PortableServer::POA::_narrow (obj.in ()); |