aboutsummaryrefslogtreecommitdiffstats
path: root/fs/ceph/messenger.c
diff options
context:
space:
mode:
authorSage Weil <sage@newdream.net>2010-01-07 19:12:36 -0500
committerSage Weil <sage@newdream.net>2010-01-14 15:23:38 -0500
commit103e2d3ae57d38d18aaac1b327266c1407499ac1 (patch)
tree9e46032de5680bd987e8fdd16753856e496812e6 /fs/ceph/messenger.c
parent4baa75ef0ed29adae03fcbbaa9aca1511a5a8cc9 (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.c19
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);