aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--include/linux/ceph/messenger.h1
-rw-r--r--net/ceph/messenger.c9
2 files changed, 4 insertions, 6 deletions
diff --git a/include/linux/ceph/messenger.h b/include/linux/ceph/messenger.h
index eb31e108a64..31d91a64838 100644
--- a/include/linux/ceph/messenger.h
+++ b/include/linux/ceph/messenger.h
@@ -161,7 +161,6 @@ struct ceph_connection {
161 struct list_head out_queue; 161 struct list_head out_queue;
162 struct list_head out_sent; /* sending or sent but unacked */ 162 struct list_head out_sent; /* sending or sent but unacked */
163 u64 out_seq; /* last message queued for send */ 163 u64 out_seq; /* last message queued for send */
164 bool out_keepalive_pending;
165 164
166 u64 in_seq, in_seq_acked; /* last message received, acked */ 165 u64 in_seq, in_seq_acked; /* last message received, acked */
167 166
diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c
index 46fbc422ba7..3252ea974e8 100644
--- a/net/ceph/messenger.c
+++ b/net/ceph/messenger.c
@@ -336,7 +336,6 @@ static void reset_connection(struct ceph_connection *con)
336 ceph_msg_put(con->out_msg); 336 ceph_msg_put(con->out_msg);
337 con->out_msg = NULL; 337 con->out_msg = NULL;
338 } 338 }
339 con->out_keepalive_pending = false;
340 con->in_seq = 0; 339 con->in_seq = 0;
341 con->in_seq_acked = 0; 340 con->in_seq_acked = 0;
342} 341}
@@ -2019,10 +2018,10 @@ static void ceph_fault(struct ceph_connection *con)
2019 /* Requeue anything that hasn't been acked */ 2018 /* Requeue anything that hasn't been acked */
2020 list_splice_init(&con->out_sent, &con->out_queue); 2019 list_splice_init(&con->out_sent, &con->out_queue);
2021 2020
2022 /* If there are no messages in the queue, place the connection 2021 /* If there are no messages queued or keepalive pending, place
2023 * in a STANDBY state (i.e., don't try to reconnect just yet). */ 2022 * the connection in a STANDBY state */
2024 if (list_empty(&con->out_queue) && !con->out_keepalive_pending) { 2023 if (list_empty(&con->out_queue) &&
2025 dout("fault setting STANDBY\n"); 2024 !test_bit(KEEPALIVE_PENDING, &con->state)) {
2026 set_bit(STANDBY, &con->state); 2025 set_bit(STANDBY, &con->state);
2027 } else { 2026 } else {
2028 /* retry after a delay. */ 2027 /* retry after a delay. */