diff options
Diffstat (limited to 'qpid/cpp/src/qpid/cluster/Cpg.h')
| -rw-r--r-- | qpid/cpp/src/qpid/cluster/Cpg.h | 29 |
1 files changed, 23 insertions, 6 deletions
diff --git a/qpid/cpp/src/qpid/cluster/Cpg.h b/qpid/cpp/src/qpid/cluster/Cpg.h index 624721b560..cffbf0bdb3 100644 --- a/qpid/cpp/src/qpid/cluster/Cpg.h +++ b/qpid/cpp/src/qpid/cluster/Cpg.h @@ -20,7 +20,6 @@ */ #include "qpid/Exception.h" -#include "qpid/cluster/Dispatchable.h" #include "qpid/cluster/types.h" #include "qpid/sys/IOHandle.h" #include "qpid/sys/Mutex.h" @@ -68,7 +67,7 @@ class Cpg : public sys::IOHandle { virtual ~Handler() {}; virtual void deliver( cpg_handle_t /*handle*/, - struct cpg_name *group, + const struct cpg_name *group, uint32_t /*nodeid*/, uint32_t /*pid*/, void* /*msg*/, @@ -76,10 +75,10 @@ class Cpg : public sys::IOHandle { virtual void configChange( cpg_handle_t /*handle*/, - struct cpg_name */*group*/, - struct cpg_address */*members*/, int /*nMembers*/, - struct cpg_address */*left*/, int /*nLeft*/, - struct cpg_address */*joined*/, int /*nJoined*/ + const struct cpg_name */*group*/, + const struct cpg_address */*members*/, int /*nMembers*/, + const struct cpg_address */*left*/, int /*nLeft*/, + const struct cpg_address */*joined*/, int /*nJoined*/ ) = 0; }; @@ -122,6 +121,24 @@ class Cpg : public sys::IOHandle { static Cpg* cpgFromHandle(cpg_handle_t); + // New versions for corosync 1.0 and higher + static void globalDeliver( + cpg_handle_t handle, + const struct cpg_name *group, + uint32_t nodeid, + uint32_t pid, + void* msg, + size_t msg_len); + + static void globalConfigChange( + cpg_handle_t handle, + const struct cpg_name *group, + const struct cpg_address *members, size_t nMembers, + const struct cpg_address *left, size_t nLeft, + const struct cpg_address *joined, size_t nJoined + ); + + // Old versions for openais static void globalDeliver( cpg_handle_t handle, struct cpg_name *group, |