rename PING/PONG to STATUS/STATUS_REPLY

1 files changed, 11 insertions, 11 deletions

diff --git a/src/transport/sim.rs b/src/transport/sim.rs
index 149798b..500050b 100644
--- a/src/transport/sim.rs
+++ b/src/transport/sim.rs
@@ -319,10 +319,10 @@ impl Transport for SimTransport {
 mod tests {
     use super::*;
     use crate::document::replica::Epoch;
-    use crate::transport::{HeadsSummary, Keepalive};
+    use crate::transport::{HeadsSummary, Status};
 
-    fn ping() -> ParsedMessage {
-        ParsedMessage::Ping(Keepalive {
+    fn status() -> ParsedMessage {
+        ParsedMessage::Status(Status {
             heads: HeadsSummary::of(Vec::new()),
             epoch: Epoch::GENESIS,
             epoch_seq: 0,
@@ -353,13 +353,13 @@ mod tests {
         let received = record(net.transport("b"));
 
         let settle = || tokio::time::sleep(Duration::from_millis(30));
-        a.send_message("b", &ping()).await.unwrap();
+        a.send_message("b", &status()).await.unwrap();
         settle().await;
         net.take_down("b");
-        a.send_message("b", &ping()).await.unwrap();
+        a.send_message("b", &status()).await.unwrap();
         settle().await;
         net.bring_up("b");
-        a.send_message("b", &ping()).await.unwrap();
+        a.send_message("b", &status()).await.unwrap();
         settle().await;
 
         assert_eq!(*received.lock().unwrap(), vec!["a", "a"]);
@@ -381,7 +381,7 @@ mod tests {
             let a = net.transport("a");
             let _b = net.transport("b");
             for _ in 0..200 {
-                a.send_message("b", &ping()).await.unwrap();
+                a.send_message("b", &status()).await.unwrap();
             }
             tokio::time::sleep(Duration::from_millis(50)).await;
             net.counts()
@@ -408,8 +408,8 @@ mod tests {
         let at_a = record(Arc::clone(&a));
         let at_b = record(Arc::clone(&b));
 
-        a.send_message("b", &ping()).await.unwrap();
-        b.send_message("a", &ping()).await.unwrap();
+        a.send_message("b", &status()).await.unwrap();
+        b.send_message("a", &status()).await.unwrap();
         tokio::time::sleep(Duration::from_millis(30)).await;
 
         assert!(at_b.lock().unwrap().is_empty());
@@ -420,8 +420,8 @@ mod tests {
     async fn inject_returns_once_handled() {
         let net = SimNet::new(1);
         let received = record(net.transport("b"));
-        net.inject("ghost", "b", &ping()).await.unwrap();
+        net.inject("ghost", "b", &status()).await.unwrap();
         assert_eq!(*received.lock().unwrap(), vec!["ghost"]);
-        assert!(net.inject("ghost", "nobody", &ping()).await.is_err());
+        assert!(net.inject("ghost", "nobody", &status()).await.is_err());
     }
 }