summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-11-13 13:27:01 +0000
committerGordon Sim <gsim@apache.org>2008-11-13 13:27:01 +0000
commit0c7f79bbd58aaa23863f200abbf4edf9f247f370 (patch)
treeefca6ed5fc0dc40f3e1ceb402d42976e6e26ac90
parentcbe59216f132ec8a2579cb55262dd80536068bdd (diff)
downloadqpid-python-0c7f79bbd58aaa23863f200abbf4edf9f247f370.tar.gz
QPID-1459: don't call Broker::getPort() with empty string as transport
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@713720 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/cpp/src/posix/QpiddBroker.cpp10
1 files changed, 7 insertions, 3 deletions
diff --git a/qpid/cpp/src/posix/QpiddBroker.cpp b/qpid/cpp/src/posix/QpiddBroker.cpp
index ee98429074..906ccc8554 100644
--- a/qpid/cpp/src/posix/QpiddBroker.cpp
+++ b/qpid/cpp/src/posix/QpiddBroker.cpp
@@ -46,6 +46,10 @@ BootstrapOptions::BootstrapOptions(const char* argv0)
add(log);
}
+namespace {
+const std::string TCP = "tcp";
+}
+
struct DaemonOptions : public qpid::Options {
bool daemon;
bool quit;
@@ -54,7 +58,7 @@ struct DaemonOptions : public qpid::Options {
std::string piddir;
std::string transport;
- DaemonOptions() : qpid::Options("Daemon options"), daemon(false), quit(false), check(false), wait(10)
+ DaemonOptions() : qpid::Options("Daemon options"), daemon(false), quit(false), check(false), wait(10), transport(TCP)
{
char *home = ::getenv("HOME");
@@ -111,7 +115,7 @@ struct QpiddDaemon : public Daemon {
/** Code for parent process */
void parent() {
uint16_t port = wait(options->daemon.wait);
- if (options->parent->broker.port == 0 || !options->daemon.transport.empty())
+ if (options->parent->broker.port == 0 || options->daemon.transport != TCP)
cout << port << endl;
}
@@ -156,7 +160,7 @@ int QpiddBroker::execute (QpiddOptions *options) {
else { // Non-daemon broker.
boost::intrusive_ptr<Broker> brokerPtr(new Broker(options->broker));
broker::SignalHandler::setBroker(brokerPtr);
- if (options->broker.port == 0 || !myOptions->daemon.transport.empty())
+ if (options->broker.port == 0 || myOptions->daemon.transport != TCP)
cout << uint16_t(brokerPtr->getPort(myOptions->daemon.transport)) << endl;
brokerPtr->run();
}