|
|
@@ -3240,9 +3240,10 @@ void ceph_con_keepalive(struct ceph_connection *con)
|
|
|
dout("con_keepalive %p\n", con);
|
|
|
mutex_lock(&con->mutex);
|
|
|
clear_standby(con);
|
|
|
+ con_flag_set(con, CON_FLAG_KEEPALIVE_PENDING);
|
|
|
mutex_unlock(&con->mutex);
|
|
|
- if (con_flag_test_and_set(con, CON_FLAG_KEEPALIVE_PENDING) == 0 &&
|
|
|
- con_flag_test_and_set(con, CON_FLAG_WRITE_PENDING) == 0)
|
|
|
+
|
|
|
+ if (con_flag_test_and_set(con, CON_FLAG_WRITE_PENDING) == 0)
|
|
|
queue_con(con);
|
|
|
}
|
|
|
EXPORT_SYMBOL(ceph_con_keepalive);
|