summaryrefslogtreecommitdiffstats
path: root/xlators/mgmt/glusterd/src
diff options
context:
space:
mode:
Diffstat (limited to 'xlators/mgmt/glusterd/src')
-rw-r--r--xlators/mgmt/glusterd/src/glusterd-handler.c36
-rw-r--r--xlators/mgmt/glusterd/src/glusterd-utils.c10
2 files changed, 29 insertions, 17 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-handler.c b/xlators/mgmt/glusterd/src/glusterd-handler.c
index 31af726509c..07c6b060fae 100644
--- a/xlators/mgmt/glusterd/src/glusterd-handler.c
+++ b/xlators/mgmt/glusterd/src/glusterd-handler.c
@@ -528,7 +528,7 @@ glusterd_handle_cli_probe (rpcsvc_request_t *req)
cli_req.hostname, cli_req.port);
goto out;
}
- if (!(ret = glusterd_friend_find_by_hostname(cli_req.hostname,
+ if (!(ret = glusterd_friend_find_by_hostname(cli_req.hostname,
&peerinfo))) {
if ((peerinfo->state.state != GD_FRIEND_STATE_REQ_RCVD)
|| (peerinfo->state.state != GD_FRIEND_STATE_DEFAULT)) {
@@ -1012,7 +1012,7 @@ glusterd_handle_create_volume (rpcsvc_request_t *req)
if ((ret = glusterd_check_volume_exists (volname))) {
snprintf(err_str, 1048, "Volname %s already exists",
- volname);
+ volname);
gf_log ("glusterd", GF_LOG_ERROR, "%s", err_str);
err_ret = 1;
goto out;
@@ -1030,23 +1030,25 @@ glusterd_handle_create_volume (rpcsvc_request_t *req)
goto out;
}
- if (bricks)
+ if (bricks)
brick_list = gf_strdup (bricks);
while ( i < brick_count) {
i++;
- brick= strtok_r (brick_list, " \n", &tmpptr);
+ brick= strtok_r (brick_list, " \n", &tmpptr);
brick_list = tmpptr;
ret = glusterd_brickinfo_from_brick (brick, &brickinfo);
if (ret)
goto out;
- if(!(ret = glusterd_is_local_addr(brickinfo->hostname)))
- goto brick_validation; //localhost, continue without validation
- ret = glusterd_friend_find_by_hostname(brickinfo->hostname,
- &peerinfo);
+
+ if(!(ret = glusterd_is_local_addr (brickinfo->hostname)))
+ goto brick_validation; //localhost, continue without validation
+
+ ret = glusterd_friend_find_by_hostname (brickinfo->hostname,
+ &peerinfo);
if (ret) {
- snprintf(err_str, 1048, "Host %s not a friend",
- brickinfo->hostname);
+ snprintf (err_str, 1048, "Host %s not a friend",
+ brickinfo->hostname);
gf_log ("glusterd", GF_LOG_ERROR, "%s", err_str);
err_ret = 1;
goto out;
@@ -1062,7 +1064,7 @@ glusterd_handle_create_volume (rpcsvc_request_t *req)
brick_validation:
list_for_each_entry (volinfo, &priv->volumes, vol_list) {
- list_for_each_entry (tmpbrkinfo, &volinfo->bricks,
+ list_for_each_entry (tmpbrkinfo, &volinfo->bricks,
brick_list) {
if ((!strcmp(brickinfo->hostname, tmpbrkinfo->
@@ -1074,7 +1076,7 @@ brick_validation:
err_str);
err_ret = 1;
goto out;
- }
+ }
}
}
}
@@ -1093,7 +1095,7 @@ out:
gf_log ("glusterd", GF_LOG_ERROR, "Unlock on opinfo"
" failed");
ret = 0; //Client response sent, prevent second response
- }
+ }
return ret;
}
@@ -1260,7 +1262,7 @@ glusterd_handle_add_brick (rpcsvc_request_t *req)
snprintf(err_str, 2048, "Incorrect number of bricks"
" supplied %d for type %s with count %d",
brick_count, (volinfo->type == 1)? "STRIPE":
- "REPLICATE", volinfo->sub_count);
+ "REPLICATE", volinfo->sub_count);
rsp.op_errstr = err_str;
cli_rsp = &rsp;
glusterd_submit_reply(req, cli_rsp, NULL, 0, NULL,
@@ -1271,11 +1273,11 @@ glusterd_handle_add_brick (rpcsvc_request_t *req)
ret = 0; //sent error to cli, prevent second reply
goto out;
- }
+ }
} else {
gf_log("", GF_LOG_ERROR, "Unable to get volinfo for volname"
" %s", volname);
- goto out;
+ goto out;
}
brick_val:
@@ -1296,7 +1298,7 @@ brick_val:
if (ret)
goto out;
if(!(ret = glusterd_is_local_addr(brickinfo->hostname)))
- continue; //localhost, continue without validation
+ continue; //localhost, continue without validation
ret = glusterd_friend_find_by_hostname(brickinfo->hostname,
&peerinfo);
if (ret) {
diff --git a/xlators/mgmt/glusterd/src/glusterd-utils.c b/xlators/mgmt/glusterd/src/glusterd-utils.c
index 27493a53928..156e262ab16 100644
--- a/xlators/mgmt/glusterd/src/glusterd-utils.c
+++ b/xlators/mgmt/glusterd/src/glusterd-utils.c
@@ -87,6 +87,7 @@ glusterd_is_local_addr (char *hostname)
struct addrinfo *res = NULL;
int32_t found = 0;
struct ifconf buf = {0,};
+ char nodename[256] = {0,};
if ((!strcmp (hostname, "localhost")) ||
(!strcmp (hostname, "127.0.0.1"))) {
@@ -94,6 +95,15 @@ glusterd_is_local_addr (char *hostname)
goto out;
}
+ ret = gethostname (nodename, 256);
+ if (ret)
+ goto out;
+
+ if ((!strcmp (nodename, hostname))) {
+ found = 1;
+ goto out;
+ }
+
ret = getaddrinfo (hostname, NULL, NULL, &result);
if (ret != 0) {