Fixed cluster membership notification.

Cluster events with RefCountedBuffers for queueing.
PollableQueue clears bacth immediately.
Improved perfdist: clients hit multiple brokers in a cluster.


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@692521 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 0 insertions, 30 deletions

diff --git a/cpp/src/qpid/cluster/Cpg.cpp b/cpp/src/qpid/cluster/Cpg.cpp
index 754b4abd58..96a5b3da43 100644
--- a/cpp/src/qpid/cluster/Cpg.cpp
+++ b/cpp/src/qpid/cluster/Cpg.cpp
@@ -184,33 +184,3 @@ ostream& operator<<(ostream& o, const ConnectionId& c) {
 }
 
 }} // namespace qpid::cluster
-
-
-// In proper namespace for ADL.
-
-std::ostream& operator<<(std::ostream& o, const ::cpg_address& a) {
-    const char* reasonString;
-    switch (a.reason) {
-      case CPG_REASON_JOIN: reasonString = " joined"; break;
-      case CPG_REASON_LEAVE: reasonString = " left";break;
-      case CPG_REASON_NODEDOWN: reasonString = " node-down";break;
-      case CPG_REASON_NODEUP: reasonString = " node-up";break;
-      case CPG_REASON_PROCDOWN: reasonString = " process-down";break;
-      default: reasonString = "";
-    }
-    return o << qpid::cluster::MemberId(a.nodeid, a.pid) << reasonString;
-}
-
-std::ostream& operator<<(std::ostream& o, const cpg_name& name) {
-    return o << std::string(name.value, name.length);
-}
-
-namespace std {
-ostream& operator<<(ostream& o, std::pair<cpg_address*,int> a) {
-    for (cpg_address* p = a.first; p < a.first+a.second; ++p)
-        o << *p << " ";
-    return o;
-}
-}
-
-