diff options
Diffstat (limited to 'fs/ceph/messenger.c')
| -rw-r--r-- | fs/ceph/messenger.c | 23 |
1 files changed, 12 insertions, 11 deletions
diff --git a/fs/ceph/messenger.c b/fs/ceph/messenger.c index 15167b2daa55..2502d76fcec1 100644 --- a/fs/ceph/messenger.c +++ b/fs/ceph/messenger.c | |||
| @@ -108,7 +108,7 @@ void ceph_msgr_exit(void) | |||
| 108 | destroy_workqueue(ceph_msgr_wq); | 108 | destroy_workqueue(ceph_msgr_wq); |
| 109 | } | 109 | } |
| 110 | 110 | ||
| 111 | void ceph_msgr_flush() | 111 | void ceph_msgr_flush(void) |
| 112 | { | 112 | { |
| 113 | flush_workqueue(ceph_msgr_wq); | 113 | flush_workqueue(ceph_msgr_wq); |
| 114 | } | 114 | } |
| @@ -647,7 +647,7 @@ static void prepare_write_connect(struct ceph_messenger *msgr, | |||
| 647 | dout("prepare_write_connect %p cseq=%d gseq=%d proto=%d\n", con, | 647 | dout("prepare_write_connect %p cseq=%d gseq=%d proto=%d\n", con, |
| 648 | con->connect_seq, global_seq, proto); | 648 | con->connect_seq, global_seq, proto); |
| 649 | 649 | ||
| 650 | con->out_connect.features = cpu_to_le64(CEPH_FEATURE_SUPPORTED_CLIENT); | 650 | con->out_connect.features = cpu_to_le64(CEPH_FEATURE_SUPPORTED); |
| 651 | con->out_connect.host_type = cpu_to_le32(CEPH_ENTITY_TYPE_CLIENT); | 651 | con->out_connect.host_type = cpu_to_le32(CEPH_ENTITY_TYPE_CLIENT); |
| 652 | con->out_connect.connect_seq = cpu_to_le32(con->connect_seq); | 652 | con->out_connect.connect_seq = cpu_to_le32(con->connect_seq); |
| 653 | con->out_connect.global_seq = cpu_to_le32(global_seq); | 653 | con->out_connect.global_seq = cpu_to_le32(global_seq); |
| @@ -1081,11 +1081,11 @@ static int process_banner(struct ceph_connection *con) | |||
| 1081 | sizeof(con->peer_addr)) != 0 && | 1081 | sizeof(con->peer_addr)) != 0 && |
| 1082 | !(addr_is_blank(&con->actual_peer_addr.in_addr) && | 1082 | !(addr_is_blank(&con->actual_peer_addr.in_addr) && |
| 1083 | con->actual_peer_addr.nonce == con->peer_addr.nonce)) { | 1083 | con->actual_peer_addr.nonce == con->peer_addr.nonce)) { |
| 1084 | pr_warning("wrong peer, want %s/%lld, got %s/%lld\n", | 1084 | pr_warning("wrong peer, want %s/%d, got %s/%d\n", |
| 1085 | pr_addr(&con->peer_addr.in_addr), | 1085 | pr_addr(&con->peer_addr.in_addr), |
| 1086 | le64_to_cpu(con->peer_addr.nonce), | 1086 | (int)le32_to_cpu(con->peer_addr.nonce), |
| 1087 | pr_addr(&con->actual_peer_addr.in_addr), | 1087 | pr_addr(&con->actual_peer_addr.in_addr), |
| 1088 | le64_to_cpu(con->actual_peer_addr.nonce)); | 1088 | (int)le32_to_cpu(con->actual_peer_addr.nonce)); |
| 1089 | con->error_msg = "wrong peer at address"; | 1089 | con->error_msg = "wrong peer at address"; |
| 1090 | return -1; | 1090 | return -1; |
| 1091 | } | 1091 | } |
| @@ -1123,8 +1123,8 @@ static void fail_protocol(struct ceph_connection *con) | |||
| 1123 | 1123 | ||
| 1124 | static int process_connect(struct ceph_connection *con) | 1124 | static int process_connect(struct ceph_connection *con) |
| 1125 | { | 1125 | { |
| 1126 | u64 sup_feat = CEPH_FEATURE_SUPPORTED_CLIENT; | 1126 | u64 sup_feat = CEPH_FEATURE_SUPPORTED; |
| 1127 | u64 req_feat = CEPH_FEATURE_REQUIRED_CLIENT; | 1127 | u64 req_feat = CEPH_FEATURE_REQUIRED; |
| 1128 | u64 server_feat = le64_to_cpu(con->in_reply.features); | 1128 | u64 server_feat = le64_to_cpu(con->in_reply.features); |
| 1129 | 1129 | ||
| 1130 | dout("process_connect on %p tag %d\n", con, (int)con->in_tag); | 1130 | dout("process_connect on %p tag %d\n", con, (int)con->in_tag); |
| @@ -1302,8 +1302,8 @@ static void process_ack(struct ceph_connection *con) | |||
| 1302 | 1302 | ||
| 1303 | 1303 | ||
| 1304 | static int read_partial_message_section(struct ceph_connection *con, | 1304 | static int read_partial_message_section(struct ceph_connection *con, |
| 1305 | struct kvec *section, unsigned int sec_len, | 1305 | struct kvec *section, |
| 1306 | u32 *crc) | 1306 | unsigned int sec_len, u32 *crc) |
| 1307 | { | 1307 | { |
| 1308 | int left; | 1308 | int left; |
| 1309 | int ret; | 1309 | int ret; |
| @@ -1434,7 +1434,8 @@ static int read_partial_message(struct ceph_connection *con) | |||
| 1434 | 1434 | ||
| 1435 | /* middle */ | 1435 | /* middle */ |
| 1436 | if (m->middle) { | 1436 | if (m->middle) { |
| 1437 | ret = read_partial_message_section(con, &m->middle->vec, middle_len, | 1437 | ret = read_partial_message_section(con, &m->middle->vec, |
| 1438 | middle_len, | ||
| 1438 | &con->in_middle_crc); | 1439 | &con->in_middle_crc); |
| 1439 | if (ret <= 0) | 1440 | if (ret <= 0) |
| 1440 | return ret; | 1441 | return ret; |
| @@ -1920,7 +1921,7 @@ out: | |||
| 1920 | /* | 1921 | /* |
| 1921 | * in case we faulted due to authentication, invalidate our | 1922 | * in case we faulted due to authentication, invalidate our |
| 1922 | * current tickets so that we can get new ones. | 1923 | * current tickets so that we can get new ones. |
| 1923 | */ | 1924 | */ |
| 1924 | if (con->auth_retry && con->ops->invalidate_authorizer) { | 1925 | if (con->auth_retry && con->ops->invalidate_authorizer) { |
| 1925 | dout("calling invalidate_authorizer()\n"); | 1926 | dout("calling invalidate_authorizer()\n"); |
| 1926 | con->ops->invalidate_authorizer(con); | 1927 | con->ops->invalidate_authorizer(con); |
