fix(socket source): Remove debugging prints left in

vectordotdev · Jun 9, 2022 · 2cc4cbb · 2cc4cbb
1 parent 9b2ecaf
commit 2cc4cbb
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 18 deletions.
diff --git a/src/sources/socket/mod.rs b/src/sources/socket/mod.rs
@@ -1121,16 +1121,10 @@ mod test {
                     match meta.permissions().mode() {
                         // S_IFSOCK   0140000   socket
                         0o140555 => ready(true),
-                        perm => {
-                            println!("socket has different permissions: {:?}", perm);
-                            ready(false)
-                        }
+                        _ => ready(false),
                     }
                 }
-                Err(_) => {
-                    println!("socket doesn't exist yet");
-                    ready(false)
-                }
+                Err(_) => ready(false),
             }
         })
         .await;
@@ -1243,16 +1237,10 @@ mod test {
                     match meta.permissions().mode() {
                         // S_IFSOCK   0140000   socket
                         0o140421 => ready(true),
-                        perm => {
-                            println!("socket has different permissions: {:?}", perm);
-                            ready(false)
-                        }
+                        _ => ready(false),
                     }
                 }
-                Err(_) => {
-                    println!("socket doesn't exist yet");
-                    ready(false)
-                }
+                Err(_) => ready(false),
             }
         })
         .await;

diff --git a/src/sources/util/unix_stream.rs b/src/sources/util/unix_stream.rs
@@ -40,9 +40,7 @@ pub fn build_unix_stream_source(
     shutdown: ShutdownSignal,
     out: SourceSender,
 ) -> crate::Result<Source> {
-    dbg!("hello");
     Ok(Box::pin(async move {
-        dbg!("creating");
         let listener = UnixListener::bind(&listen_path).expect("Failed to bind to listener socket");
         info!(message = "Listening.", path = ?listen_path, r#type = "unix");