2 use crate::frame::Ping;
13 /// Acknowledges ping requests from the remote.
50 /// No user ping pending.
52 /// User has called `send_ping`, but PING hasn't been written yet.
54 /// User PING has been written, waiting for PONG.
91             payload: Ping::SHUTDOWN,  in ping_shutdown()
96     /// Process a ping
97     pub(crate) fn recv_ping(&mut self, ping: Ping) -> ReceivedPing {  in recv_ping()
102         if ping.is_ack() {  in recv_ping()
104                 if &pending.payload == ping.payload() {  in recv_ping()
107                         &Ping::SHUTDOWN,  in recv_ping()
110                     tracing::trace!("recv PING SHUTDOWN ack");  in recv_ping()
119                 if ping.payload() == &Ping::USER && users.receive_pong() {  in recv_ping()
120                     tracing::trace!("recv PING USER ack");  in recv_ping()
125             // else we were acked a ping we didn't send?  in recv_ping()
128             tracing::warn!("recv PING ack that we never sent: {:?}", ping);  in recv_ping()
131             // Save the ping's payload to be sent as an acknowledgement.  in recv_ping()
132             self.pending_pong = Some(ping.into_payload());  in recv_ping()
153             dst.buffer(Ping::pong(pong).into())  in send_pending_pong()
170         if let Some(ref mut ping) = self.pending_ping {  in send_pending_ping()
171             if !ping.sent {  in send_pending_ping()
176                 dst.buffer(Ping::new(ping.payload).into())  in send_pending_ping()
177                     .expect("invalid ping frame");  in send_pending_ping()
178                 ping.sent = true;  in send_pending_ping()
186                 dst.buffer(Ping::new(Ping::USER).into())  in send_pending_ping()
187                     .expect("invalid ping frame");  in send_pending_ping()
237         // before we could register, and then the ping would just be lost.  in poll_pong()