diff options
author | Sage Weil <sage@newdream.net> | 2010-01-07 19:12:36 -0500 |
---|---|---|
committer | Sage Weil <sage@newdream.net> | 2010-01-14 15:23:38 -0500 |
commit | 103e2d3ae57d38d18aaac1b327266c1407499ac1 (patch) | |
tree | 9e46032de5680bd987e8fdd16753856e496812e6 /fs/ceph/messenger.c | |
parent | 4baa75ef0ed29adae03fcbbaa9aca1511a5a8cc9 (diff) |
ceph: remove unused erank field
The ceph_entity_addr erank field is obsolete; remove it. Get rid of
trivial addr comparison helpers while we're at it.
Signed-off-by: Sage Weil <sage@newdream.net>
Diffstat (limited to 'fs/ceph/messenger.c')
-rw-r--r-- | fs/ceph/messenger.c | 19 |
1 files changed, 8 insertions, 11 deletions
diff --git a/fs/ceph/messenger.c b/fs/ceph/messenger.c index c1106e8360f0..1360708d7505 100644 --- a/fs/ceph/messenger.c +++ b/fs/ceph/messenger.c | |||
@@ -1056,16 +1056,15 @@ static int process_banner(struct ceph_connection *con) | |||
1056 | * end may not yet know their ip address, so if it's 0.0.0.0, give | 1056 | * end may not yet know their ip address, so if it's 0.0.0.0, give |
1057 | * them the benefit of the doubt. | 1057 | * them the benefit of the doubt. |
1058 | */ | 1058 | */ |
1059 | if (!ceph_entity_addr_is_local(&con->peer_addr, | 1059 | if (memcmp(&con->peer_addr, &con->actual_peer_addr, |
1060 | &con->actual_peer_addr) && | 1060 | sizeof(con->peer_addr)) != 0 && |
1061 | !(addr_is_blank(&con->actual_peer_addr.in_addr) && | 1061 | !(addr_is_blank(&con->actual_peer_addr.in_addr) && |
1062 | con->actual_peer_addr.nonce == con->peer_addr.nonce)) { | 1062 | con->actual_peer_addr.nonce == con->peer_addr.nonce)) { |
1063 | pr_warning("wrong peer, want %s/%d, " | 1063 | pr_warning("wrong peer, want %s/%lld, got %s/%lld\n", |
1064 | "got %s/%d\n", | 1064 | pr_addr(&con->peer_addr.in_addr), |
1065 | pr_addr(&con->peer_addr.in_addr), | 1065 | le64_to_cpu(con->peer_addr.nonce), |
1066 | con->peer_addr.nonce, | 1066 | pr_addr(&con->actual_peer_addr.in_addr), |
1067 | pr_addr(&con->actual_peer_addr.in_addr), | 1067 | le64_to_cpu(con->actual_peer_addr.nonce)); |
1068 | con->actual_peer_addr.nonce); | ||
1069 | con->error_msg = "wrong peer at address"; | 1068 | con->error_msg = "wrong peer at address"; |
1070 | return -1; | 1069 | return -1; |
1071 | } | 1070 | } |
@@ -1934,8 +1933,7 @@ struct ceph_messenger *ceph_messenger_create(struct ceph_entity_addr *myaddr) | |||
1934 | msgr->inst.addr = *myaddr; | 1933 | msgr->inst.addr = *myaddr; |
1935 | 1934 | ||
1936 | /* select a random nonce */ | 1935 | /* select a random nonce */ |
1937 | get_random_bytes(&msgr->inst.addr.nonce, | 1936 | get_random_bytes(&msgr->inst.addr.nonce, sizeof(msgr->inst.addr.nonce)); |
1938 | sizeof(msgr->inst.addr.nonce)); | ||
1939 | encode_my_addr(msgr); | 1937 | encode_my_addr(msgr); |
1940 | 1938 | ||
1941 | dout("messenger_create %p\n", msgr); | 1939 | dout("messenger_create %p\n", msgr); |
@@ -1966,7 +1964,6 @@ void ceph_con_send(struct ceph_connection *con, struct ceph_msg *msg) | |||
1966 | msg->hdr.src.name = con->msgr->inst.name; | 1964 | msg->hdr.src.name = con->msgr->inst.name; |
1967 | msg->hdr.src.addr = con->msgr->my_enc_addr; | 1965 | msg->hdr.src.addr = con->msgr->my_enc_addr; |
1968 | msg->hdr.orig_src = msg->hdr.src; | 1966 | msg->hdr.orig_src = msg->hdr.src; |
1969 | msg->hdr.dst_erank = con->peer_addr.erank; | ||
1970 | 1967 | ||
1971 | /* queue */ | 1968 | /* queue */ |
1972 | mutex_lock(&con->mutex); | 1969 | mutex_lock(&con->mutex); |