summaryrefslogtreecommitdiff
path: root/perf/src/IceStorm/Subscriber.cpp
diff options
context:
space:
mode:
authorBernard Normier <bernard@zeroc.com>2012-10-23 16:19:38 -0400
committerBernard Normier <bernard@zeroc.com>2012-10-23 16:19:38 -0400
commitada25bad3511a359eb28cf48f018d6a42e166f10 (patch)
tree430749f887a1c6f708c2d4a23b3e3ec4ef18ef2c /perf/src/IceStorm/Subscriber.cpp
parentRuby 1.8 fix (diff)
downloadice-ada25bad3511a359eb28cf48f018d6a42e166f10.tar.bz2
ice-ada25bad3511a359eb28cf48f018d6a42e166f10.tar.xz
ice-ada25bad3511a359eb28cf48f018d6a42e166f10.zip
Fixed ICE-4855: expand tabs to space (8) for .php, .cpp, .h, .java and .cs files
Diffstat (limited to 'perf/src/IceStorm/Subscriber.cpp')
-rw-r--r--perf/src/IceStorm/Subscriber.cpp72
1 files changed, 36 insertions, 36 deletions
diff --git a/perf/src/IceStorm/Subscriber.cpp b/perf/src/IceStorm/Subscriber.cpp
index 57a93ef3a59..f2e561f0189 100644
--- a/perf/src/IceStorm/Subscriber.cpp
+++ b/perf/src/IceStorm/Subscriber.cpp
@@ -44,26 +44,26 @@ Subscriber::run(int argc, char* argv[])
int nPublishers = 1;
for(int i = 0; i < argc; i++)
{
- if(strcmp(argv[i], "-r") == 0)
- {
- repetitions = atoi(argv[++i]);
- }
- if(strcmp(argv[i], "-b") == 0)
- {
- batch = true;
- }
- if(strcmp(argv[i], "-t") == 0)
- {
- twoway = true;
- }
- if(strcmp(argv[i], "-o") == 0)
- {
- ordered = true;
- }
- if(strcmp(argv[i], "-c") == 0)
- {
- nPublishers = atoi(argv[++i]);
- }
+ if(strcmp(argv[i], "-r") == 0)
+ {
+ repetitions = atoi(argv[++i]);
+ }
+ if(strcmp(argv[i], "-b") == 0)
+ {
+ batch = true;
+ }
+ if(strcmp(argv[i], "-t") == 0)
+ {
+ twoway = true;
+ }
+ if(strcmp(argv[i], "-o") == 0)
+ {
+ ordered = true;
+ }
+ if(strcmp(argv[i], "-c") == 0)
+ {
+ nPublishers = atoi(argv[++i]);
+ }
}
Ice::PropertiesPtr properties = communicator()->getProperties();
@@ -72,16 +72,16 @@ Subscriber::run(int argc, char* argv[])
string proxy = properties->getProperty(proxyProperty);
if(proxy.empty())
{
- cerr << appName() << ": property `" << proxyProperty << "' not set" << endl;
- return EXIT_FAILURE;
+ cerr << appName() << ": property `" << proxyProperty << "' not set" << endl;
+ return EXIT_FAILURE;
}
Ice::ObjectPrx base = communicator()->stringToProxy(proxy);
IceStorm::TopicManagerPrx manager = IceStorm::TopicManagerPrx::checkedCast(base);
if(!manager)
{
- cerr << appName() << ": invalid proxy" << endl;
- return EXIT_FAILURE;
+ cerr << appName() << ": invalid proxy" << endl;
+ return EXIT_FAILURE;
}
//
@@ -92,15 +92,15 @@ Subscriber::run(int argc, char* argv[])
IceStorm::QoS qos;
if(batch)
{
- qos["reliability"] = "batch";
+ qos["reliability"] = "batch";
}
else if(twoway)
{
- qos["reliability"] = "twoway";
+ qos["reliability"] = "twoway";
}
else if(ordered)
{
- qos["reliability"] = "twoway-ordered";
+ qos["reliability"] = "twoway-ordered";
}
//
@@ -116,18 +116,18 @@ Subscriber::run(int argc, char* argv[])
IceStorm::TopicPrx topic;
try
{
- topic = manager->retrieve("time");
+ topic = manager->retrieve("time");
}
catch(const IceStorm::NoSuchTopic&)
{
- try
- {
- topic = manager->create("time");
- }
- catch(const IceStorm::TopicExists&)
- {
- topic = manager->retrieve("time");
- }
+ try
+ {
+ topic = manager->create("time");
+ }
+ catch(const IceStorm::TopicExists&)
+ {
+ topic = manager->retrieve("time");
+ }
}
topic->subscribe(qos, object);