diff options
author | huangming <huangminghuang@users.noreply.github.com> | 2003-11-28 04:42:03 +0000 |
---|---|---|
committer | huangming <huangminghuang@users.noreply.github.com> | 2003-11-28 04:42:03 +0000 |
commit | 7e028127eaf88f75d886aad86f8c10cb96bbb528 (patch) | |
tree | 2ec82eebbfd097deffd6c6dcb3219b356757f9fa | |
parent | 9c25bdd11405a7b52bf45f9589d85e63b24fd9cf (diff) | |
download | ATCD-7e028127eaf88f75d886aad86f8c10cb96bbb528.tar.gz |
*** empty log message ***
-rw-r--r-- | TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp b/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp index d0c9f352019..fdab2871803 100644 --- a/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp +++ b/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp @@ -170,11 +170,15 @@ int PushSupplier_impl::handle_timeout (const ACE_Time_Value ¤t_time, ior += proxy_consumer_file_; CORBA::Object_var obj = orb_->string_to_object(ior.c_str() ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - RtecEventComm::PushConsumer_var consumer = - RtecEventComm::PushConsumer::_narrow(obj.in()); - ACE_OS::sleep(1); - consumer->push(event ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; + if (!CORBA::is_nil(obj.in())) { + RtecEventComm::PushConsumer_var consumer = + RtecEventComm::PushConsumer::_narrow(obj.in()); + if (!CORBA::is_nil(obj.in())) { + ACE_OS::sleep(1); + consumer->push(event ACE_ENV_ARG_PARAMETER); + ACE_TRY_CHECK; + } + } } } } |