wip

Author: andrewjstone

tls/src/lib.rs

@@ -580,9 +580,6 @@ mod tests {
 
         let server_config = local_config(1);
 
-        let max_connections = 3;
-        let done_count = Arc::new(AtomicUsize::new(0));
-
         // Message to send over TLS
         const MSG: &str = "Hello Joe";
 
@@ -592,10 +589,12 @@ mod tests {
             pki_keydir.join("corim-sp.cbor"),
         ];
 
-        // Accept connections from 3 clients in different tasks
+        // Accept connections from `max_connections` clients in different tasks
         //
         // For this test, the clients all share a set of keys, because
         // we only generate 2 sets of keys from the KDL.
+        let max_connections = 3;
+        let done_count = Arc::new(AtomicUsize::new(0));
         let dc2 = done_count.clone();
         tokio::spawn(async move {
             let server = Server::new(server_config, addr, log2.clone())
@@ -617,11 +616,12 @@ mod tests {
             }
         });
 
-        // Loop until we succesfully connect
+        // Spawn `max_connections` tasks to concurrently connect
         for _ in 0..max_connections {
             let pki_keydir = pki_keydir.clone();
             let log = log.clone();
             tokio::spawn(async move {
+                // Loop until we succesfully connect
                 let mut stream = loop {
                     let client_config = local_config(2);
 
@@ -651,8 +651,8 @@ mod tests {
             });
         }
 
-        // Wait for the other side of the connection to receive and assert the
-        // message
+        // Wait each spawned server task to receive and assert the message from
+        // a single client.
         while done_count.load(std::sync::atomic::Ordering::Relaxed)
             != max_connections
         {