Dump out runtime components when integration test times out to help w…

…ith diagnosing problem.

integration/run-sanity.sh

@@ -1 +1,2 @@
+export RUST_OPCUA_LOG=debug
 cargo test -- --exact --test-threads=1 --ignored tests::connect_none

integration/src/tests.rs

@@ -1,24 +1,23 @@
 use std::{
     sync::{
-        Arc, Mutex, RwLock, mpsc, mpsc::channel,
-        atomic::{AtomicUsize, Ordering},
+        Arc, atomic::{AtomicUsize, Ordering}, mpsc, mpsc::channel, Mutex,
+        RwLock,
     },
     thread, time,
 };
 
-use log::{info, trace};
 use chrono::Utc;
+use log::*;
 
-// Integration tests are asynchronous so futures will be used
-use opcua_core;
+use opcua_client::prelude::*;
+use opcua_console_logging;
+use opcua_core::{self, runtime_components};
 use opcua_server::{
     self,
-    config::ServerEndpoint,
     builder::ServerBuilder,
+    config::ServerEndpoint,
     prelude::*,
 };
-use opcua_client::prelude::*;
-use opcua_console_logging;
 
 const ENDPOINT_ID_NONE: &str = "sample_none";
 const ENDPOINT_ID_BASIC128RSA15_SIGN_ENCRYPT: &str = "sample_basic128rsa15_signencrypt";
@@ -382,7 +381,14 @@ fn perform_test<CT, ST>(port_offset: u16, client_test: Option<CT>, server_test:
         if elapsed.num_milliseconds() > timeout {
             let _ = tx_client_command.send(ClientCommand::Quit);
             let _ = tx_server_command.send(ServerCommand::Quit);
-            panic!("Test timed out after {} ms", elapsed.num_milliseconds());
+
+            error!("Test timed out after {} ms", elapsed.num_milliseconds());
+            error!("Running components:\n  {}", {
+                let components = runtime_components!();
+                components.iter().cloned().collect::<Vec<String>>().join("\n  ")
+            });
+
+            panic!();
         }
 
         // Check for a client response

server/src/comms/tcp_transport.rs

@@ -283,7 +283,7 @@ impl TcpTransport {
     /// Spawns the writing loop task. The writing loop takes messages to send off of a queue
     /// and sends them to the stream.
     fn spawn_writing_loop_task(writer: WriteHalf<TcpStream>, receiver: UnboundedReceiver<(u32, SupportedMessage)>, secure_channel: Arc<RwLock<SecureChannel>>, transport: Arc<RwLock<TcpTransport>>, send_buffer: Arc<Mutex<MessageWriter>>) {
-        let id = Self::make_session_id("writing_loop_task", transport.clone());
+        let id = Self::make_session_id("server_writing_loop_task", transport.clone());
         let id_for_map = id.clone();
         let id_for_map_err = id.clone();
         register_runtime_component!(id);
@@ -460,7 +460,7 @@ impl TcpTransport {
         }));
         let framed_read_task = Self::framed_read_task(reader, finished_flag, connection.clone());
 
-        let id = Self::make_session_id("reading_loop_task", transport.clone());
+        let id = Self::make_session_id("server_reading_loop_task", transport.clone());
         let id_for_map = id.clone();
         let id_for_map_err = id.clone();
         register_runtime_component!(id);