(&self)
| 110 | } |
| 111 | |
| 112 | fn reset(&self) { |
| 113 | self.enabled.store(true, Ordering::Relaxed); |
| 114 | self.frontend_reads.store(0, Ordering::Relaxed); |
| 115 | self.frontend_bytes.store(0, Ordering::Relaxed); |
| 116 | self.frontend_messages.store(0, Ordering::Relaxed); |
| 117 | self.startup_messages.store(0, Ordering::Relaxed); |
| 118 | self.protocol_messages.store(0, Ordering::Relaxed); |
| 119 | self.simple_query_messages.store(0, Ordering::Relaxed); |
| 120 | self.parse_messages.store(0, Ordering::Relaxed); |
| 121 | self.bind_messages.store(0, Ordering::Relaxed); |
| 122 | self.execute_messages.store(0, Ordering::Relaxed); |
| 123 | self.sync_messages.store(0, Ordering::Relaxed); |
| 124 | self.flush_messages.store(0, Ordering::Relaxed); |
| 125 | self.copy_data_messages.store(0, Ordering::Relaxed); |
| 126 | self.protocol_batches.store(0, Ordering::Relaxed); |
| 127 | self.protocol_batch_bytes.store(0, Ordering::Relaxed); |
| 128 | self.backend_send_calls.store(0, Ordering::Relaxed); |
| 129 | self.backend_send_bytes.store(0, Ordering::Relaxed); |
| 130 | self.response_writes.store(0, Ordering::Relaxed); |
| 131 | self.response_bytes.store(0, Ordering::Relaxed); |
| 132 | self.socket_flushes.store(0, Ordering::Relaxed); |
| 133 | self.copy_guard_rejections.store(0, Ordering::Relaxed); |
| 134 | self.streaming_copy_handoffs.store(0, Ordering::Relaxed); |
| 135 | } |
| 136 | |
| 137 | fn snapshot(&self) -> ProtocolStatsSnapshot { |
| 138 | ProtocolStatsSnapshot { |
no outgoing calls
no test coverage detected