diff --git a/pageserver/src/bin/replay.rs b/pageserver/src/bin/replay.rs index 7d0009d757..fe714f5788 100644 --- a/pageserver/src/bin/replay.rs +++ b/pageserver/src/bin/replay.rs @@ -51,20 +51,19 @@ impl PagestreamApi { let msg_bytes = msg.serialize(); let mut buf = BytesMut::new(); let copy_msg = BeMessage::CopyData(&msg_bytes); + + // TODO it's actually a fe message but it doesn't have a serializer yet BeMessage::write(&mut buf, ©_msg)?; buf.freeze() }; - println!("sending msg"); self.stream.write_all(&request).await?; - println!("sent"); // TODO It's actually a be message, but it doesn't have a parser. // So error response (code b'E' parses incorrectly as FeExecuteMessage) - let response = match FeMessage::read_fut(&mut self.stream).await? { + let _response = match FeMessage::read_fut(&mut self.stream).await? { Some(FeMessage::CopyData(page)) => page, r => panic!("Expected CopyData message, got: {:?}", r), }; - println!("received"); Ok(()) }