|
Fabio M. Di Nitto |
17c73a |
Index: daemons/clvmd/clvmd-corosync.c
|
|
Fabio M. Di Nitto |
17c73a |
===================================================================
|
|
Fabio M. Di Nitto |
17c73a |
RCS file: /cvs/lvm2/LVM2/daemons/clvmd/clvmd-corosync.c,v
|
|
Fabio M. Di Nitto |
17c73a |
retrieving revision 1.9
|
|
Fabio M. Di Nitto |
17c73a |
retrieving revision 1.10
|
|
Fabio M. Di Nitto |
17c73a |
diff -u -r1.9 -r1.10
|
|
Fabio M. Di Nitto |
17c73a |
--- a/daemons/clvmd/clvmd-corosync.c 21 Apr 2009 13:11:28 -0000 1.9
|
|
Fabio M. Di Nitto |
17c73a |
+++ b/daemons/clvmd/clvmd-corosync.c 3 Jun 2009 13:42:02 -0000 1.10
|
|
Fabio M. Di Nitto |
17c73a |
@@ -56,16 +56,16 @@
|
|
Fabio M. Di Nitto |
17c73a |
#define LOCKSPACE_NAME "clvmd"
|
|
Fabio M. Di Nitto |
17c73a |
|
|
Fabio M. Di Nitto |
17c73a |
static void cpg_deliver_callback (cpg_handle_t handle,
|
|
Fabio M. Di Nitto |
17c73a |
- struct cpg_name *groupName,
|
|
Fabio M. Di Nitto |
17c73a |
+ const struct cpg_name *groupName,
|
|
Fabio M. Di Nitto |
17c73a |
uint32_t nodeid,
|
|
Fabio M. Di Nitto |
17c73a |
uint32_t pid,
|
|
Fabio M. Di Nitto |
17c73a |
void *msg,
|
|
Fabio M. Di Nitto |
17c73a |
- int msg_len);
|
|
Fabio M. Di Nitto |
17c73a |
+ size_t msg_len);
|
|
Fabio M. Di Nitto |
17c73a |
static void cpg_confchg_callback(cpg_handle_t handle,
|
|
Fabio M. Di Nitto |
17c73a |
- struct cpg_name *groupName,
|
|
Fabio M. Di Nitto |
17c73a |
- struct cpg_address *member_list, int member_list_entries,
|
|
Fabio M. Di Nitto |
17c73a |
- struct cpg_address *left_list, int left_list_entries,
|
|
Fabio M. Di Nitto |
17c73a |
- struct cpg_address *joined_list, int joined_list_entries);
|
|
Fabio M. Di Nitto |
17c73a |
+ const struct cpg_name *groupName,
|
|
Fabio M. Di Nitto |
17c73a |
+ const struct cpg_address *member_list, size_t member_list_entries,
|
|
Fabio M. Di Nitto |
17c73a |
+ const struct cpg_address *left_list, size_t left_list_entries,
|
|
Fabio M. Di Nitto |
17c73a |
+ const struct cpg_address *joined_list, size_t joined_list_entries);
|
|
Fabio M. Di Nitto |
17c73a |
static void _cluster_closedown(void);
|
|
Fabio M. Di Nitto |
17c73a |
|
|
Fabio M. Di Nitto |
17c73a |
/* Hash list of nodes in the cluster */
|
|
Fabio M. Di Nitto |
17c73a |
@@ -206,17 +206,17 @@
|
|
Fabio M. Di Nitto |
17c73a |
}
|
|
Fabio M. Di Nitto |
17c73a |
|
|
Fabio M. Di Nitto |
17c73a |
static void cpg_deliver_callback (cpg_handle_t handle,
|
|
Fabio M. Di Nitto |
17c73a |
- struct cpg_name *groupName,
|
|
Fabio M. Di Nitto |
17c73a |
+ const struct cpg_name *groupName,
|
|
Fabio M. Di Nitto |
17c73a |
uint32_t nodeid,
|
|
Fabio M. Di Nitto |
17c73a |
uint32_t pid,
|
|
Fabio M. Di Nitto |
17c73a |
void *msg,
|
|
Fabio M. Di Nitto |
17c73a |
- int msg_len)
|
|
Fabio M. Di Nitto |
17c73a |
+ size_t msg_len)
|
|
Fabio M. Di Nitto |
17c73a |
{
|
|
Fabio M. Di Nitto |
17c73a |
int target_nodeid;
|
|
Fabio M. Di Nitto |
17c73a |
|
|
Fabio M. Di Nitto |
17c73a |
memcpy(&target_nodeid, msg, COROSYNC_CSID_LEN);
|
|
Fabio M. Di Nitto |
17c73a |
|
|
Fabio M. Di Nitto |
17c73a |
- DEBUGLOG("%u got message from nodeid %d for %d. len %d\n",
|
|
Fabio M. Di Nitto |
17c73a |
+ DEBUGLOG("%u got message from nodeid %d for %d. len %zd\n",
|
|
Fabio M. Di Nitto |
17c73a |
our_nodeid, nodeid, target_nodeid, msg_len-4);
|
|
Fabio M. Di Nitto |
17c73a |
|
|
Fabio M. Di Nitto |
17c73a |
if (nodeid != our_nodeid)
|
|
Fabio M. Di Nitto |
17c73a |
@@ -226,15 +226,15 @@
|
|
Fabio M. Di Nitto |
17c73a |
}
|
|
Fabio M. Di Nitto |
17c73a |
|
|
Fabio M. Di Nitto |
17c73a |
static void cpg_confchg_callback(cpg_handle_t handle,
|
|
Fabio M. Di Nitto |
17c73a |
- struct cpg_name *groupName,
|
|
Fabio M. Di Nitto |
17c73a |
- struct cpg_address *member_list, int member_list_entries,
|
|
Fabio M. Di Nitto |
17c73a |
- struct cpg_address *left_list, int left_list_entries,
|
|
Fabio M. Di Nitto |
17c73a |
- struct cpg_address *joined_list, int joined_list_entries)
|
|
Fabio M. Di Nitto |
17c73a |
+ const struct cpg_name *groupName,
|
|
Fabio M. Di Nitto |
17c73a |
+ const struct cpg_address *member_list, size_t member_list_entries,
|
|
Fabio M. Di Nitto |
17c73a |
+ const struct cpg_address *left_list, size_t left_list_entries,
|
|
Fabio M. Di Nitto |
17c73a |
+ const struct cpg_address *joined_list, size_t joined_list_entries)
|
|
Fabio M. Di Nitto |
17c73a |
{
|
|
Fabio M. Di Nitto |
17c73a |
int i;
|
|
Fabio M. Di Nitto |
17c73a |
struct node_info *ninfo;
|
|
Fabio M. Di Nitto |
17c73a |
|
|
Fabio M. Di Nitto |
17c73a |
- DEBUGLOG("confchg callback. %d joined, %d left, %d members\n",
|
|
Fabio M. Di Nitto |
17c73a |
+ DEBUGLOG("confchg callback. %zd joined, %zd left, %zd members\n",
|
|
Fabio M. Di Nitto |
17c73a |
joined_list_entries, left_list_entries, member_list_entries);
|
|
Fabio M. Di Nitto |
17c73a |
|
|
Fabio M. Di Nitto |
17c73a |
for (i=0; i
|
|
Fabio M. Di Nitto |
17c73a |
@@ -580,7 +580,7 @@
|
|
Fabio M. Di Nitto |
17c73a |
{
|
|
Fabio M. Di Nitto |
17c73a |
confdb_handle_t handle;
|
|
Fabio M. Di Nitto |
17c73a |
int result;
|
|
Fabio M. Di Nitto |
17c73a |
- int namelen = buflen;
|
|
Fabio M. Di Nitto |
17c73a |
+ size_t namelen = buflen;
|
|
Fabio M. Di Nitto |
17c73a |
hdb_handle_t cluster_handle;
|
|
Fabio M. Di Nitto |
17c73a |
confdb_callbacks_t callbacks = {
|
|
Fabio M. Di Nitto |
17c73a |
.confdb_key_change_notify_fn = NULL,
|