diff options
Diffstat (limited to 'mqtt-tester/src/behaviour')
9 files changed, 9 insertions, 0 deletions
diff --git a/mqtt-tester/src/behaviour/connack_flags_are_set_as_reserved.rs b/mqtt-tester/src/behaviour/connack_flags_are_set_as_reserved.rs index 49012c1..b128be7 100644 --- a/mqtt-tester/src/behaviour/connack_flags_are_set_as_reserved.rs +++ b/mqtt-tester/src/behaviour/connack_flags_are_set_as_reserved.rs @@ -19,6 +19,7 @@ impl BehaviourTest for ConnackFlagsAreSetAsReserved { vec![] } + #[tracing::instrument(skip_all)] async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> { input .send(&[ diff --git a/mqtt-tester/src/behaviour/first_packet_from_client_is_connect.rs b/mqtt-tester/src/behaviour/first_packet_from_client_is_connect.rs index 17525b6..1315a63 100644 --- a/mqtt-tester/src/behaviour/first_packet_from_client_is_connect.rs +++ b/mqtt-tester/src/behaviour/first_packet_from_client_is_connect.rs @@ -21,6 +21,7 @@ impl BehaviourTest for FirstPacketFromClientIsConnect { vec![] } + #[tracing::instrument(skip_all)] async fn execute(&self, _input: Input, mut output: Output) -> Result<(), miette::Error> { output .wait_and_check( diff --git a/mqtt-tester/src/behaviour/invalid_first_packet_is_rejected.rs b/mqtt-tester/src/behaviour/invalid_first_packet_is_rejected.rs index a4c95ad..ea3d663 100644 --- a/mqtt-tester/src/behaviour/invalid_first_packet_is_rejected.rs +++ b/mqtt-tester/src/behaviour/invalid_first_packet_is_rejected.rs @@ -21,6 +21,7 @@ impl BehaviourTest for InvalidFirstPacketIsRejected { vec![] } + #[tracing::instrument(skip_all)] async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> { input .send_packet(MConnect { diff --git a/mqtt-tester/src/behaviour/invalid_utf8_is_rejected.rs b/mqtt-tester/src/behaviour/invalid_utf8_is_rejected.rs index efe7a6d..cb77b80 100644 --- a/mqtt-tester/src/behaviour/invalid_utf8_is_rejected.rs +++ b/mqtt-tester/src/behaviour/invalid_utf8_is_rejected.rs @@ -21,6 +21,7 @@ impl BehaviourTest for InvalidUtf8IsRejected { vec![] } + #[tracing::instrument(skip_all)] async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> { input .send_packet(MConnack { diff --git a/mqtt-tester/src/behaviour/publish_qos_2_is_acked.rs b/mqtt-tester/src/behaviour/publish_qos_2_is_acked.rs index 95dfeae..1e57928 100644 --- a/mqtt-tester/src/behaviour/publish_qos_2_is_acked.rs +++ b/mqtt-tester/src/behaviour/publish_qos_2_is_acked.rs @@ -27,6 +27,7 @@ impl BehaviourTest for PublishQos2IsAcked { vec![] } + #[tracing::instrument(skip_all)] async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> { input .send_packet(MConnack { diff --git a/mqtt-tester/src/behaviour/publish_qos_zero_with_ident_fails.rs b/mqtt-tester/src/behaviour/publish_qos_zero_with_ident_fails.rs index fe5544d..5f80a66 100644 --- a/mqtt-tester/src/behaviour/publish_qos_zero_with_ident_fails.rs +++ b/mqtt-tester/src/behaviour/publish_qos_zero_with_ident_fails.rs @@ -27,6 +27,7 @@ impl BehaviourTest for PublishQosZeroWithIdentFails { vec![] } + #[tracing::instrument(skip_all)] async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> { input .send_packet(MConnack { diff --git a/mqtt-tester/src/behaviour/receiving_server_packet.rs b/mqtt-tester/src/behaviour/receiving_server_packet.rs index f88888e..ee1e981 100644 --- a/mqtt-tester/src/behaviour/receiving_server_packet.rs +++ b/mqtt-tester/src/behaviour/receiving_server_packet.rs @@ -26,6 +26,7 @@ impl BehaviourTest for ReceivingServerPacket { vec![] } + #[tracing::instrument(skip_all)] async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> { input .send_packet(MConnack { diff --git a/mqtt-tester/src/behaviour/utf8_with_nullchar_is_rejected.rs b/mqtt-tester/src/behaviour/utf8_with_nullchar_is_rejected.rs index 32283b6..1f1ad34 100644 --- a/mqtt-tester/src/behaviour/utf8_with_nullchar_is_rejected.rs +++ b/mqtt-tester/src/behaviour/utf8_with_nullchar_is_rejected.rs @@ -24,6 +24,7 @@ impl BehaviourTest for Utf8WithNullcharIsRejected { vec![] } + #[tracing::instrument(skip_all)] async fn execute(&self, mut input: Input, _output: Output) -> Result<(), miette::Error> { input .send_packet(MConnack { diff --git a/mqtt-tester/src/behaviour/wait_for_connect.rs b/mqtt-tester/src/behaviour/wait_for_connect.rs index ab16677..1d643e3 100644 --- a/mqtt-tester/src/behaviour/wait_for_connect.rs +++ b/mqtt-tester/src/behaviour/wait_for_connect.rs @@ -19,6 +19,7 @@ impl BehaviourTest for WaitForConnect { vec![] } + #[tracing::instrument(skip_all)] async fn execute(&self, _input: Input, mut output: Output) -> Result<(), miette::Error> { output .wait_and_check( |