|
@@ -2569,6 +2569,11 @@ static int try_write(struct ceph_connection *con)
|
|
int ret = 1;
|
|
int ret = 1;
|
|
|
|
|
|
dout("try_write start %p state %lu\n", con, con->state);
|
|
dout("try_write start %p state %lu\n", con, con->state);
|
|
|
|
+ if (con->state != CON_STATE_PREOPEN &&
|
|
|
|
+ con->state != CON_STATE_CONNECTING &&
|
|
|
|
+ con->state != CON_STATE_NEGOTIATING &&
|
|
|
|
+ con->state != CON_STATE_OPEN)
|
|
|
|
+ return 0;
|
|
|
|
|
|
more:
|
|
more:
|
|
dout("try_write out_kvec_bytes %d\n", con->out_kvec_bytes);
|
|
dout("try_write out_kvec_bytes %d\n", con->out_kvec_bytes);
|
|
@@ -2594,6 +2599,8 @@ more:
|
|
}
|
|
}
|
|
|
|
|
|
more_kvec:
|
|
more_kvec:
|
|
|
|
+ BUG_ON(!con->sock);
|
|
|
|
+
|
|
/* kvec data queued? */
|
|
/* kvec data queued? */
|
|
if (con->out_kvec_left) {
|
|
if (con->out_kvec_left) {
|
|
ret = write_partial_kvec(con);
|
|
ret = write_partial_kvec(con);
|