(&self)
| 135 | } |
| 136 | |
| 137 | fn snapshot(&self) -> ProtocolStatsSnapshot { |
| 138 | ProtocolStatsSnapshot { |
| 139 | frontend_reads: self.frontend_reads.load(Ordering::Relaxed), |
| 140 | frontend_bytes: self.frontend_bytes.load(Ordering::Relaxed), |
| 141 | frontend_messages: self.frontend_messages.load(Ordering::Relaxed), |
| 142 | startup_messages: self.startup_messages.load(Ordering::Relaxed), |
| 143 | protocol_messages: self.protocol_messages.load(Ordering::Relaxed), |
| 144 | simple_query_messages: self.simple_query_messages.load(Ordering::Relaxed), |
| 145 | parse_messages: self.parse_messages.load(Ordering::Relaxed), |
| 146 | bind_messages: self.bind_messages.load(Ordering::Relaxed), |
| 147 | execute_messages: self.execute_messages.load(Ordering::Relaxed), |
| 148 | sync_messages: self.sync_messages.load(Ordering::Relaxed), |
| 149 | flush_messages: self.flush_messages.load(Ordering::Relaxed), |
| 150 | copy_data_messages: self.copy_data_messages.load(Ordering::Relaxed), |
| 151 | protocol_batches: self.protocol_batches.load(Ordering::Relaxed), |
| 152 | protocol_batch_bytes: self.protocol_batch_bytes.load(Ordering::Relaxed), |
| 153 | backend_send_calls: self.backend_send_calls.load(Ordering::Relaxed), |
| 154 | backend_send_bytes: self.backend_send_bytes.load(Ordering::Relaxed), |
| 155 | response_writes: self.response_writes.load(Ordering::Relaxed), |
| 156 | response_bytes: self.response_bytes.load(Ordering::Relaxed), |
| 157 | socket_flushes: self.socket_flushes.load(Ordering::Relaxed), |
| 158 | copy_guard_rejections: self.copy_guard_rejections.load(Ordering::Relaxed), |
| 159 | streaming_copy_handoffs: self.streaming_copy_handoffs.load(Ordering::Relaxed), |
| 160 | } |
| 161 | } |
| 162 | |
| 163 | fn add(counter: &AtomicU64, value: u64) { |
| 164 | if PROTOCOL_STATS.enabled.load(Ordering::Relaxed) { |
no test coverage detected