You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2014/02/06 23:45:07 UTC
svn commit: r1565467 - /qpid/dispatch/trunk/src/router_config.c
Author: tross
Date: Thu Feb 6 22:45:07 2014
New Revision: 1565467
URL: http://svn.apache.org/r1565467
Log:
DISPATCH-25 - Fixed a bug found when writing the man pages :)
Modified:
qpid/dispatch/trunk/src/router_config.c
Modified: qpid/dispatch/trunk/src/router_config.c
URL: http://svn.apache.org/viewvc/qpid/dispatch/trunk/src/router_config.c?rev=1565467&r1=1565466&r2=1565467&view=diff
==============================================================================
--- qpid/dispatch/trunk/src/router_config.c (original)
+++ qpid/dispatch/trunk/src/router_config.c Thu Feb 6 22:45:07 2014
@@ -52,15 +52,18 @@ void qd_router_configure(qd_router_t *ro
else
assert(0);
- if (strcmp("none", bias) == 0) semantics |= QD_BIAS_NONE;
- else if (strcmp("closest", bias) == 0) semantics |= QD_BIAS_CLOSEST;
- else if (strcmp("spread", bias) == 0) semantics |= QD_BIAS_SPREAD;
- else
- assert(0);
+ if ((semantics & QD_FANOUTMASK) == QD_FANOUT_SINGLE) {
+ if (strcmp("closest", bias) == 0) semantics |= QD_BIAS_CLOSEST;
+ else if (strcmp("spread", bias) == 0) semantics |= QD_BIAS_SPREAD;
+ else
+ assert(0);
+ qd_log(router->log_source, QD_LOG_INFO, "Configured Address: prefix=%s fanout=%s bias=%s", prefix, fanout, bias);
+ } else {
+ semantics |= QD_BIAS_NONE;
+ qd_log(router->log_source, QD_LOG_INFO, "Configured Address: prefix=%s fanout=%s", prefix, fanout);
+ }
router->config_addrs[idx].semantics = semantics;
-
- qd_log(router->log_source, QD_LOG_INFO, "Configured Address: prefix=%s fanout=%s bias=%s", prefix, fanout, bias);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org