MCPcopy Create free account
hub / github.com/ermak-dev/cloudpub / trace_message

Function trace_message

common/src/utils.rs:209–263  ·  view source on GitHub ↗
(label: &str, msg: &ProtocolMessage)

Source from the content-addressed store, hash-verified

207}
208
209pub 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}

Callers 2

recv_messageMethod · 0.85
send_messageMethod · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected