| From f10a18433a1b3192e71eecffeaeca5f5f1694016 Mon Sep 17 00:00:00 2001 |
| From: Sage Weil <sage@inktank.com> |
| Date: Thu, 27 Dec 2012 20:27:04 -0600 |
| Subject: libceph: fix protocol feature mismatch failure path |
| |
| |
| From: Sage Weil <sage@inktank.com> |
| |
| (cherry picked from commit 0fa6ebc600bc8e830551aee47a0e929e818a1868) |
| |
| We should not set con->state to CLOSED here; that happens in |
| ceph_fault() in the caller, where it first asserts that the state |
| is not yet CLOSED. Avoids a BUG when the features don't match. |
| |
| Since the fail_protocol() has become a trivial wrapper, replace |
| calls to it with direct calls to reset_connection(). |
| |
| Signed-off-by: Sage Weil <sage@inktank.com> |
| Reviewed-by: Alex Elder <elder@inktank.com> |
| Signed-off-by: Greg Kroah-Hartman <gregkh@linuxfoundation.org> |
| --- |
| net/ceph/messenger.c | 14 ++++---------- |
| 1 file changed, 4 insertions(+), 10 deletions(-) |
| |
| --- a/net/ceph/messenger.c |
| +++ b/net/ceph/messenger.c |
| @@ -506,6 +506,7 @@ static void reset_connection(struct ceph |
| { |
| /* reset connection, out_queue, msg_ and connect_seq */ |
| /* discard existing out_queue and msg_seq */ |
| + dout("reset_connection %p\n", con); |
| ceph_msg_remove_list(&con->out_queue); |
| ceph_msg_remove_list(&con->out_sent); |
| |
| @@ -1506,13 +1507,6 @@ static int process_banner(struct ceph_co |
| return 0; |
| } |
| |
| -static void fail_protocol(struct ceph_connection *con) |
| -{ |
| - reset_connection(con); |
| - WARN_ON(con->state != CON_STATE_NEGOTIATING); |
| - con->state = CON_STATE_CLOSED; |
| -} |
| - |
| static int process_connect(struct ceph_connection *con) |
| { |
| u64 sup_feat = con->msgr->supported_features; |
| @@ -1530,7 +1524,7 @@ static int process_connect(struct ceph_c |
| ceph_pr_addr(&con->peer_addr.in_addr), |
| sup_feat, server_feat, server_feat & ~sup_feat); |
| con->error_msg = "missing required protocol features"; |
| - fail_protocol(con); |
| + reset_connection(con); |
| return -1; |
| |
| case CEPH_MSGR_TAG_BADPROTOVER: |
| @@ -1541,7 +1535,7 @@ static int process_connect(struct ceph_c |
| le32_to_cpu(con->out_connect.protocol_version), |
| le32_to_cpu(con->in_reply.protocol_version)); |
| con->error_msg = "protocol version mismatch"; |
| - fail_protocol(con); |
| + reset_connection(con); |
| return -1; |
| |
| case CEPH_MSGR_TAG_BADAUTHORIZER: |
| @@ -1631,7 +1625,7 @@ static int process_connect(struct ceph_c |
| ceph_pr_addr(&con->peer_addr.in_addr), |
| req_feat, server_feat, req_feat & ~server_feat); |
| con->error_msg = "missing required protocol features"; |
| - fail_protocol(con); |
| + reset_connection(con); |
| return -1; |
| } |
| |