|
@@ -1469,6 +1469,17 @@ static void prepare_write_banner(struct ceph_connection *con)
|
|
|
con_flag_set(con, CON_FLAG_WRITE_PENDING);
|
|
|
}
|
|
|
|
|
|
+static void __prepare_write_connect(struct ceph_connection *con)
|
|
|
+{
|
|
|
+ con_out_kvec_add(con, sizeof(con->out_connect), &con->out_connect);
|
|
|
+ if (con->auth)
|
|
|
+ con_out_kvec_add(con, con->auth->authorizer_buf_len,
|
|
|
+ con->auth->authorizer_buf);
|
|
|
+
|
|
|
+ con->out_more = 0;
|
|
|
+ con_flag_set(con, CON_FLAG_WRITE_PENDING);
|
|
|
+}
|
|
|
+
|
|
|
static int prepare_write_connect(struct ceph_connection *con)
|
|
|
{
|
|
|
unsigned int global_seq = get_global_seq(con->msgr, 0);
|
|
@@ -1504,15 +1515,7 @@ static int prepare_write_connect(struct ceph_connection *con)
|
|
|
if (ret)
|
|
|
return ret;
|
|
|
|
|
|
- con_out_kvec_add(con, sizeof (con->out_connect),
|
|
|
- &con->out_connect);
|
|
|
- if (con->auth)
|
|
|
- con_out_kvec_add(con, con->auth->authorizer_buf_len,
|
|
|
- con->auth->authorizer_buf);
|
|
|
-
|
|
|
- con->out_more = 0;
|
|
|
- con_flag_set(con, CON_FLAG_WRITE_PENDING);
|
|
|
-
|
|
|
+ __prepare_write_connect(con);
|
|
|
return 0;
|
|
|
}
|
|
|
|