diff options
author | jtc <jtc@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2005-01-25 19:09:17 +0000 |
---|---|---|
committer | jtc <jtc@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2005-01-25 19:09:17 +0000 |
commit | faaab0244c6bdb9e41df91cf3e9669393e74aaca (patch) | |
tree | 600212efe010ca3044779d132b160038d5d2a47b /TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp | |
parent | 767b3327161f15c6d0c9ffd446b104948451eb2f (diff) | |
download | ATCD-faaab0244c6bdb9e41df91cf3e9669393e74aaca.tar.gz |
ChangeLogTag: Tue Jan 25 09:59:28 2005 J.T. Conklin <jtc@acorntoolworks.com>
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp | 98 |
1 files changed, 49 insertions, 49 deletions
diff --git a/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp b/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp index 09fe4e04c2c..ce464e1ec1a 100644 --- a/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp +++ b/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp @@ -90,7 +90,7 @@ StructuredPushConsumer_i::check_serial_number (CORBA::ULong seq) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Structured Consumer received event %d.\n"), - ACE_static_cast (int, seq) + static_cast<int>(seq) )); } } @@ -102,7 +102,7 @@ StructuredPushConsumer_i::check_serial_number (CORBA::ULong seq) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Structured Consumer received correct event %d.\n"), - ACE_static_cast (int, seq) + static_cast<int>(seq) )); } } @@ -112,8 +112,8 @@ StructuredPushConsumer_i::check_serial_number (CORBA::ULong seq) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Structured Consumer: service received event %d; Notify discarded %d*.\n"), - ACE_static_cast (int, seq), - ACE_static_cast (int, this->serial_number_) + static_cast<int>(seq), + static_cast<int>(this->serial_number_) )); } this->received_ += seq - this->serial_number_; @@ -123,8 +123,8 @@ StructuredPushConsumer_i::check_serial_number (CORBA::ULong seq) this->problem_ = true; ACE_DEBUG ((LM_ERROR, ACE_TEXT ("(%P|%t) Structured Consumer received notifications out of sequence. Expecting %d received %d.\n"), - ACE_static_cast (int, this->serial_number_), - ACE_static_cast (int, seq) + static_cast<int>(this->serial_number_), + static_cast<int>(seq) )); } this->serial_number_ = seq + 1; @@ -156,7 +156,7 @@ StructuredPushConsumer_i::push_structured_event ( this->may_discard_ = 1; ACE_DEBUG ((LM_ERROR, ACE_TEXT ("(%P|%t) Structured Consumer failing at event # %d.\n"), - ACE_static_cast (int, this->received_) + static_cast<int>(this->received_) )); ACE_THROW (CORBA::UNKNOWN()); ACE_CHECK; @@ -185,7 +185,7 @@ StructuredPushConsumer_i::push_structured_event ( this->problem_ = true; ACE_DEBUG ((LM_ERROR, ACE_TEXT ("(%P|%t) Structured Consumer received wrong filterable data name.%s. Expecting serial_number\n"), - ACE_static_cast (const char *, notification.filterable_data[0].name) + static_cast<const char *>(notification.filterable_data[0].name) )); } } @@ -313,7 +313,7 @@ SequencePushConsumer_i::check_serial_number (CORBA::ULong seq) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Sequence Consumer received event %d.\n"), - ACE_static_cast (int, seq) + static_cast<int>(seq) )); } } @@ -325,7 +325,7 @@ SequencePushConsumer_i::check_serial_number (CORBA::ULong seq) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Sequence Consumer received correct event %d.\n"), - ACE_static_cast (int, seq) + static_cast<int>(seq) )); } } @@ -335,8 +335,8 @@ SequencePushConsumer_i::check_serial_number (CORBA::ULong seq) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Sequence Consumer: service received event %d; Notify discarded %d*.\n"), - ACE_static_cast (int, seq), - ACE_static_cast (int, this->serial_number_) + static_cast<int>(seq), + static_cast<int>(this->serial_number_) )); } this->received_ += seq - this->serial_number_; @@ -346,8 +346,8 @@ SequencePushConsumer_i::check_serial_number (CORBA::ULong seq) this->problem_ = true; ACE_DEBUG ((LM_ERROR, ACE_TEXT ("(%P|%t) Sequence Consumer received notifications out of sequence. Expecting %d received %d.\n"), - ACE_static_cast (int, this->serial_number_), - ACE_static_cast (int, seq) + static_cast<int>(this->serial_number_), + static_cast<int>(seq) )); } this->serial_number_ = seq + 1; @@ -368,7 +368,7 @@ SequencePushConsumer_i::push_structured_events ( { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Sequence Consumer received batch of %d events.\n"), - ACE_static_cast (int, batch_size) + static_cast<int>(batch_size) )); } for (size_t nevent = 0; nevent < batch_size; ++nevent) @@ -389,7 +389,7 @@ SequencePushConsumer_i::push_structured_events ( this->may_discard_ = batch_size; ACE_DEBUG ((LM_ERROR, ACE_TEXT ("(%P|%t) Sequence Consumer failing at event # %d. Expecting %d duplicates.\n"), - ACE_static_cast (int, this->received_), + static_cast<int>(this->received_), ACE_static_cast (int, nevent + 1) )); ACE_THROW (CORBA::UNKNOWN()); @@ -420,7 +420,7 @@ SequencePushConsumer_i::push_structured_events ( this->problem_ = true; ACE_DEBUG ((LM_ERROR, ACE_TEXT ("(%P|%t) Sequence Consumer received wrong filterable data name.%s. Expecting serial_number\n"), - ACE_static_cast (const char *, notification.filterable_data[0].name) + static_cast<const char *>(notification.filterable_data[0].name) )); } } @@ -536,7 +536,7 @@ AnyPushConsumer_i::check_serial_number (CORBA::ULong seq) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Any Consumer received event %d.\n"), - ACE_static_cast (int, seq) + static_cast<int>(seq) )); } } @@ -548,7 +548,7 @@ AnyPushConsumer_i::check_serial_number (CORBA::ULong seq) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Any Consumer received correct event %d.\n"), - ACE_static_cast (int, seq) + static_cast<int>(seq) )); } } @@ -558,8 +558,8 @@ AnyPushConsumer_i::check_serial_number (CORBA::ULong seq) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Any Consumer: service received event %d; Notify discarded %d*.\n"), - ACE_static_cast (int, seq), - ACE_static_cast (int, this->serial_number_) + static_cast<int>(seq), + static_cast<int>(this->serial_number_) )); } this->received_ += seq - this->serial_number_; @@ -569,8 +569,8 @@ AnyPushConsumer_i::check_serial_number (CORBA::ULong seq) this->problem_ = true; ACE_DEBUG ((LM_ERROR, ACE_TEXT ("(%P|%t) Any Consumer received notifications out of sequence. Expecting %d received %d.\n"), - ACE_static_cast (int, this->serial_number_), - ACE_static_cast (int, seq) + static_cast<int>(this->serial_number_), + static_cast<int>(seq) )); } this->serial_number_ = seq + 1; @@ -602,7 +602,7 @@ AnyPushConsumer_i::push ( this->may_discard_ = 1; ACE_DEBUG ((LM_ERROR, ACE_TEXT ("(%P|%t) Any Consumer failing at event # %d.\n"), - ACE_static_cast (int, this->received_) + static_cast<int>(this->received_) )); ACE_THROW (CORBA::UNKNOWN()); ACE_CHECK; @@ -641,7 +641,7 @@ AnyPushConsumer_i::push ( this->problem_ = true; ACE_DEBUG ((LM_ERROR, ACE_TEXT ("(%P|%t) Any Consumer received wrong filterable data name in structured event: %s. Expecting serial_number\n"), - ACE_static_cast (const char *, notification->filterable_data[0].name) + static_cast<const char *>(notification->filterable_data[0].name) )); } } @@ -979,8 +979,8 @@ int Consumer_Main::init (int argc, char *argv[] ACE_ENV_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P,%t) Consumer: Listening for %d structured events. Failing every %d events.\n"), - ACE_static_cast (int, this->expect_), - ACE_static_cast (int, this->fail_) + static_cast<int>(this->expect_), + static_cast<int>(this->fail_) )); } this->structured_push_consumer_.set_expectations (this->expect_, this->fail_, this->serial_number_, this->verbose_); @@ -994,8 +994,8 @@ int Consumer_Main::init (int argc, char *argv[] ACE_ENV_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P,%t) Consumer: Listening for %d sequence events. Failing every %d events.\n"), - ACE_static_cast (int, this->expect_), - ACE_static_cast (int, this->fail_) + static_cast<int>(this->expect_), + static_cast<int>(this->fail_) )); } this->sequence_push_consumer_.set_expectations (this->expect_, this->fail_, this->serial_number_, this->verbose_); @@ -1009,8 +1009,8 @@ int Consumer_Main::init (int argc, char *argv[] ACE_ENV_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P,%t) Consumer: Listening for %d CORBA::Any events. Failing every %d events.\n"), - ACE_static_cast (int, this->expect_), - ACE_static_cast (int, this->fail_) + static_cast<int>(this->expect_), + static_cast<int>(this->fail_) )); } this->any_push_consumer_.set_expectations (this->expect_, this->fail_, this->serial_number_, this->verbose_); @@ -1045,7 +1045,7 @@ Consumer_Main::save_ids() if (idf != 0) { int endflag = 12345; - int imode = ACE_static_cast (int, this->mode_); + int imode = static_cast<int>(this->mode_); ACE_OS::fprintf (idf, "%d,%d,%d,%d,%d,%d,%d,\n", static_cast<int> (imode), @@ -1253,7 +1253,7 @@ Consumer_Main::init_event_channel (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Reconnect to event channel %d\n"), - ACE_static_cast (int, this->ec_id_) + static_cast<int>(this->ec_id_) )); } } @@ -1289,7 +1289,7 @@ Consumer_Main::init_event_channel (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Connect to Existing event channel %d\n"), - ACE_static_cast (int, this->ec_id_) + static_cast<int>(this->ec_id_) )); } // kill the channel filename so we don't overwrite the file @@ -1415,7 +1415,7 @@ Consumer_Main::init_consumer_admin (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Reconnect to consumer admin %d\n"), - ACE_static_cast (int, this->sa_id_) + static_cast<int>(this->sa_id_) )); } } @@ -1482,7 +1482,7 @@ Consumer_Main::init_consumer_admin (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Create new consumer admin %d\n"), - ACE_static_cast (int, this->sa_id_) + static_cast<int>(this->sa_id_) )); } } @@ -1491,7 +1491,7 @@ Consumer_Main::init_consumer_admin (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: connect to consumer admin failed %d\n"), - ACE_static_cast (int, this->sa_id_) + static_cast<int>(this->sa_id_) )); } } @@ -1514,7 +1514,7 @@ Consumer_Main::init_structured_proxy_supplier (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Reconnect to proxy supplier %d\n"), - ACE_static_cast (int, this->structured_proxy_id_) + static_cast<int>(this->structured_proxy_id_) )); } } @@ -1536,7 +1536,7 @@ Consumer_Main::init_structured_proxy_supplier (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Create new structured proxy %d\n"), - ACE_static_cast (int, this->structured_proxy_id_) + static_cast<int>(this->structured_proxy_id_) )); } } @@ -1602,7 +1602,7 @@ Consumer_Main::init_sequence_proxy_supplier (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Reconnect to proxy %d\n"), - ACE_static_cast (int, this->sequence_proxy_id_) + static_cast<int>(this->sequence_proxy_id_) )); } } @@ -1632,7 +1632,7 @@ Consumer_Main::init_sequence_proxy_supplier (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Create new sequence proxy %d\n"), - ACE_static_cast (int, this->sequence_proxy_id_) + static_cast<int>(this->sequence_proxy_id_) )); } } @@ -1644,7 +1644,7 @@ Consumer_Main::init_sequence_proxy_supplier (ACE_ENV_SINGLE_ARG_DECL) { ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%P|%t) Consumer: Received wrong type of push supplier proxy %d\n"), - ACE_static_cast (int, this->sequence_proxy_id_) + static_cast<int>(this->sequence_proxy_id_) )); ACE_THROW (CORBA::BAD_PARAM()); @@ -1719,14 +1719,14 @@ Consumer_Main::init_any_proxy_supplier (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Reconnect to proxy %d\n"), - ACE_static_cast (int, this->any_proxy_id_) + static_cast<int>(this->any_proxy_id_) )); } else { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Get proxy supplier %d returned nil\n"), - ACE_static_cast (int, this->any_proxy_id_) + static_cast<int>(this->any_proxy_id_) )); } } @@ -1734,7 +1734,7 @@ Consumer_Main::init_any_proxy_supplier (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Get proxy supplier %d threw exception\n"), - ACE_static_cast (int, this->any_proxy_id_) + static_cast<int>(this->any_proxy_id_) )); ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, ACE_TEXT ("To wit:")); } @@ -1742,7 +1742,7 @@ Consumer_Main::init_any_proxy_supplier (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Get proxy supplier %d threw exception\n"), - ACE_static_cast (int, this->any_proxy_id_) + static_cast<int>(this->any_proxy_id_) )); } ACE_ENDTRY; @@ -1761,7 +1761,7 @@ Consumer_Main::init_any_proxy_supplier (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) Consumer: Create new Any proxy %d\n"), - ACE_static_cast (int, this->any_proxy_id_) + static_cast<int>(this->any_proxy_id_) )); } } @@ -1773,7 +1773,7 @@ Consumer_Main::init_any_proxy_supplier (ACE_ENV_SINGLE_ARG_DECL) { ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%P|%t) Consumer: Received wrong type of push supplier proxy %d\n"), - ACE_static_cast (int, this->any_proxy_id_) + static_cast<int>(this->any_proxy_id_) )); ACE_THROW (CORBA::BAD_PARAM()); } @@ -1836,7 +1836,7 @@ int Consumer_Main::fini (ACE_ENV_SINGLE_ARG_DECL) { ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) destroy admin %d\n"), - ACE_static_cast(int, this->sa_id_) + static_cast<int>(this->sa_id_) )); } this->sa_->destroy(); |