summaryrefslogtreecommitdiff
path: root/ctdb/server/ipalloc_common.c
diff options
context:
space:
mode:
authorMartin Schwenke <martin@meltin.net>2016-05-26 15:31:47 +1000
committerAmitay Isaacs <amitay@samba.org>2016-07-04 15:42:26 +0200
commita2124a1cd8719d2aab4a16cb791b533ddc744a95 (patch)
tree89f5875b34089f0367f505e4edb9a0600f6f7359 /ctdb/server/ipalloc_common.c
parent7d5a81e561d2d5485fc806d0aa9ac67619a8d032 (diff)
downloadsamba-a2124a1cd8719d2aab4a16cb791b533ddc744a95.tar.gz
ctdb-ipalloc: Drop implicit dependency on ctdb-common
Use new functions from protocol API instead. Signed-off-by: Martin Schwenke <martin@meltin.net> Reviewed-by: Amitay Isaacs <amitay@gmail.com>
Diffstat (limited to 'ctdb/server/ipalloc_common.c')
-rw-r--r--ctdb/server/ipalloc_common.c13
1 files changed, 9 insertions, 4 deletions
diff --git a/ctdb/server/ipalloc_common.c b/ctdb/server/ipalloc_common.c
index 95d5ecf0c21..1a52ff3772f 100644
--- a/ctdb/server/ipalloc_common.c
+++ b/ctdb/server/ipalloc_common.c
@@ -32,6 +32,8 @@
#include "common/common.h"
#include "common/rb_tree.h"
+#include "protocol/protocol_api.h"
+
#include "server/ipalloc_private.h"
#define TAKEOVER_TIMEOUT() timeval_current_ofs(ctdb->tunable.takeover_timeout,0)
@@ -72,7 +74,7 @@ static bool can_node_host_ip(struct ipalloc_state *ipalloc_state,
public_ips = &ipalloc_state->available_public_ips[pnn];
for (i=0; i<public_ips->num; i++) {
- if (ctdb_same_ip(&ip->addr, &public_ips->ip[i].addr)) {
+ if (ctdb_sock_addr_same(&ip->addr, &public_ips->ip[i].addr)) {
/* yes, this node can serve this public ip */
return true;
}
@@ -125,7 +127,8 @@ int find_takeover_node(struct ipalloc_state *ipalloc_state,
}
if (pnn == -1) {
DEBUG(DEBUG_WARNING,(__location__ " Could not find node to take over public address '%s'\n",
- ctdb_addr_to_str(&ip->addr)));
+ ctdb_sock_addr_to_string(ipalloc_state,
+ &ip->addr)));
return -1;
}
@@ -175,7 +178,8 @@ void basic_allocate_unassigned(struct ipalloc_state *ipalloc_state)
if (find_takeover_node(ipalloc_state, t)) {
DEBUG(DEBUG_WARNING,
("Failed to find node to cover ip %s\n",
- ctdb_addr_to_str(&t->addr)));
+ ctdb_sock_addr_to_string(ipalloc_state,
+ &t->addr)));
}
}
}
@@ -195,7 +199,8 @@ void unassign_unsuitable_ips(struct ipalloc_state *ipalloc_state)
if (!can_node_host_ip(ipalloc_state, t->pnn, t) != 0) {
/* this node can not serve this ip. */
DEBUG(DEBUG_DEBUG,("Unassign IP: %s from %d\n",
- ctdb_addr_to_str(&(t->addr)),
+ ctdb_sock_addr_to_string(ipalloc_state,
+ &t->addr),
t->pnn));
t->pnn = -1;
}