diff options
| -rw-r--r-- | net/ceph/messenger.c | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c index 47499dc0e413..cf292939dd1e 100644 --- a/net/ceph/messenger.c +++ b/net/ceph/messenger.c | |||
| @@ -697,6 +697,7 @@ static int prepare_write_connect(struct ceph_connection *con) | |||
| 697 | { | 697 | { |
| 698 | unsigned global_seq = get_global_seq(con->msgr, 0); | 698 | unsigned global_seq = get_global_seq(con->msgr, 0); |
| 699 | int proto; | 699 | int proto; |
| 700 | int ret; | ||
| 700 | 701 | ||
| 701 | switch (con->peer_name.type) { | 702 | switch (con->peer_name.type) { |
| 702 | case CEPH_ENTITY_TYPE_MON: | 703 | case CEPH_ENTITY_TYPE_MON: |
| @@ -723,11 +724,14 @@ static int prepare_write_connect(struct ceph_connection *con) | |||
| 723 | con->out_connect.flags = 0; | 724 | con->out_connect.flags = 0; |
| 724 | 725 | ||
| 725 | ceph_con_out_kvec_add(con, sizeof (con->out_connect), &con->out_connect); | 726 | ceph_con_out_kvec_add(con, sizeof (con->out_connect), &con->out_connect); |
| 727 | ret = prepare_connect_authorizer(con); | ||
| 728 | if (ret) | ||
| 729 | return ret; | ||
| 726 | 730 | ||
| 727 | con->out_more = 0; | 731 | con->out_more = 0; |
| 728 | set_bit(WRITE_PENDING, &con->state); | 732 | set_bit(WRITE_PENDING, &con->state); |
| 729 | 733 | ||
| 730 | return prepare_connect_authorizer(con); | 734 | return 0; |
| 731 | } | 735 | } |
| 732 | 736 | ||
| 733 | /* | 737 | /* |
