(label: &str, msg: &ProtocolMessage)
| 207 | } |
| 208 | |
| 209 | pub fn trace_message(label: &str, msg: &ProtocolMessage) { |
| 210 | match msg { |
| 211 | ProtocolMessage::CreateDataChannelWithId(data) => { |
| 212 | trace!( |
| 213 | "{}: CreateDataChannelWithId {{ channel_id: {}, {:?} }}", |
| 214 | label, |
| 215 | data.channel_id, |
| 216 | data.endpoint |
| 217 | ); |
| 218 | } |
| 219 | ProtocolMessage::DataChannelData(data) => { |
| 220 | //let data_str = String::from_utf8_lossy(&data.data); |
| 221 | trace!( |
| 222 | "{}: DataChannelData {{ channel_id: {}, data_size: {} bytes }}", |
| 223 | label, |
| 224 | data.channel_id, |
| 225 | data.data.len(), |
| 226 | ); |
| 227 | } |
| 228 | ProtocolMessage::DataChannelDataUdp(data) => { |
| 229 | trace!( |
| 230 | "{}: DataChannelDataUdp {{ channel_id: {}, data_size: {} bytes, socket_addr: {:?} }}", |
| 231 | label, |
| 232 | data.channel_id, |
| 233 | data.data.len(), |
| 234 | data.socket_addr |
| 235 | ); |
| 236 | } |
| 237 | ProtocolMessage::DataChannelAck(data) => { |
| 238 | trace!( |
| 239 | "{}: DataChannelAck {{ channel_id: {}, consumed: {} bytes }}", |
| 240 | label, |
| 241 | data.channel_id, |
| 242 | data.consumed |
| 243 | ); |
| 244 | } |
| 245 | ProtocolMessage::DataChannelEof(data) => { |
| 246 | trace!( |
| 247 | "{}: DataChannelEof {{ channel_id: {}, error: {} }}", |
| 248 | label, |
| 249 | data.channel_id, |
| 250 | data.error |
| 251 | ); |
| 252 | } |
| 253 | ProtocolMessage::Progress(data) => { |
| 254 | trace!("{}: Progress {:?}", label, data); |
| 255 | } |
| 256 | ProtocolMessage::HeartBeat(_) => { |
| 257 | trace!("{}: HeartBeat", label); |
| 258 | } |
| 259 | _ => { |
| 260 | debug!("{}: {:?}", label, msg); |
| 261 | } |
| 262 | } |
| 263 | } |
no outgoing calls
no test coverage detected