summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp
diff options
context:
space:
mode:
authorjtc <jtc@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2005-01-25 19:09:17 +0000
committerjtc <jtc@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2005-01-25 19:09:17 +0000
commitfaaab0244c6bdb9e41df91cf3e9669393e74aaca (patch)
tree600212efe010ca3044779d132b160038d5d2a47b /TAO/orbsvcs/tests/Notify/Reconnecting/Consumer.cpp
parent767b3327161f15c6d0c9ffd446b104948451eb2f (diff)
downloadATCD-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.cpp98
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();