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 ea76cd712dea97f30175358de714994b2c46f0d8..5c298b51986b5245b95b357d526b92dfa478d026 100644 (file)
--- 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 6c91395a352f77529002a685d18e93fcf2af8e6a..6e6a363640129a9fb189dd98ff7d5f8f3c2802a4 100644 (file)
--- 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() {