From: Greg Farnum <greg@inktank.com>
Date: Wed, 26 Mar 2014 22:58:10 +0000 (-0700)
Subject: Pipe: rename keepalive->send_keepalive
X-Git-Tag: v0.79~34^2~2
X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=38d4c71a456c1cc9a5044dbcae5378836a34484d;p=ceph.git

Pipe: rename keepalive->send_keepalive

Signed-off-by: Greg Farnum <greg@inktank.com>
---

diff --git a/src/msg/Pipe.cc b/src/msg/Pipe.cc
index ea76cd712dea9..5c298b51986b5 100644
--- a/src/msg/Pipe.cc
+++ b/src/msg/Pipe.cc
@@ -86,7 +86,7 @@ Pipe::Pipe(SimpleMessenger *r, int st, Connection *con)
     reader_running(false), reader_needs_join(false),
     writer_running(false),
     in_q(&(r->dispatch_queue)),
-    keepalive(false),
+    send_keepalive(false),
     close_on_empty(false),
     connect_seq(0), peer_global_seq(0),
     out_seq(0), in_seq(0), in_seq_acked(0) {
@@ -1569,7 +1569,7 @@ void Pipe::writer()
 	(is_queued() || in_seq > in_seq_acked)) {
 
       // keepalive?
-      if (keepalive) {
+      if (send_keepalive) {
 	pipe_lock.Unlock();
 	int rc = write_keepalive();
 	pipe_lock.Lock();
@@ -1578,7 +1578,7 @@ void Pipe::writer()
 	  fault();
  	  continue;
 	}
-	keepalive = false;
+	send_keepalive = false;
       }
 
       // send ack?
diff --git a/src/msg/Pipe.h b/src/msg/Pipe.h
index 6c91395a352f7..6e6a363640129 100644
--- a/src/msg/Pipe.h
+++ b/src/msg/Pipe.h
@@ -161,7 +161,7 @@ class DispatchQueue;
     DispatchQueue *in_q;
     list<Message*> sent;
     Cond cond;
-    bool keepalive;
+    bool send_keepalive;
     bool halt_delivery; //if a pipe's queue is destroyed, stop adding to it
     bool close_on_empty;
     
@@ -218,7 +218,7 @@ class DispatchQueue;
 
     __u32 get_out_seq() { return out_seq; }
 
-    bool is_queued() { return !out_q.empty() || keepalive; }
+    bool is_queued() { return !out_q.empty() || send_keepalive; }
 
     entity_addr_t& get_peer_addr() { return peer_addr; }
 
@@ -244,7 +244,7 @@ class DispatchQueue;
     }
     void _send_keepalive() {
       assert(pipe_lock.is_locked());
-      keepalive = true;
+      send_keepalive = true;
       cond.Signal();
     }
     Message *_get_next_outgoing() {