|
@@ -830,13 +830,6 @@ static void prepare_read_connect(struct ceph_connection *con)
|
|
|
con->in_base_pos = 0;
|
|
|
}
|
|
|
|
|
|
-static void prepare_read_connect_retry(struct ceph_connection *con)
|
|
|
-{
|
|
|
- dout("prepare_read_connect_retry %p\n", con);
|
|
|
- con->in_base_pos = strlen(CEPH_BANNER) + sizeof(con->actual_peer_addr)
|
|
|
- + sizeof(con->peer_addr_for_me);
|
|
|
-}
|
|
|
-
|
|
|
static void prepare_read_ack(struct ceph_connection *con)
|
|
|
{
|
|
|
dout("prepare_read_ack %p\n", con);
|
|
@@ -1146,7 +1139,7 @@ static int process_connect(struct ceph_connection *con)
|
|
|
}
|
|
|
con->auth_retry = 1;
|
|
|
prepare_write_connect(con->msgr, con, 0);
|
|
|
- prepare_read_connect_retry(con);
|
|
|
+ prepare_read_connect(con);
|
|
|
break;
|
|
|
|
|
|
case CEPH_MSGR_TAG_RESETSESSION:
|