From 116990f26472647ee9792106e79ad28ba715207b Mon Sep 17 00:00:00 2001
From: Dietmar Maurer <dietmar@proxmox.com>
Date: Wed, 10 Apr 2019 09:03:17 +0200
Subject: [PATCH] src/server/worker_task.rs: use abstract socket

---
 src/server/command_socket.rs | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

diff --git a/src/server/command_socket.rs b/src/server/command_socket.rs
index b69866dc..814d160b 100644
--- a/src/server/command_socket.rs
+++ b/src/server/command_socket.rs
@@ -13,15 +13,13 @@ use serde_json::Value;
 use std::sync::Arc;
 
 /// Listens on a Unix Socket to handle simple command asynchronously
-pub fn create_control_socket<P, F>(path: P, auto_remove: bool, f: F) -> Result<impl Future<Item=(), Error=()>, Error>
+pub fn create_control_socket<P, F>(path: P, f: F) -> Result<impl Future<Item=(), Error=()>, Error>
     where P: Into<PathBuf>,
           F: Send + Sync +'static + Fn(Value) -> Result<Value, Error>,
 {
     let path: PathBuf = path.into();
     let path1: PathBuf = path.clone();
 
-    if auto_remove { let _ = std::fs::remove_file(&path); }
-
     let socket = UnixListener::bind(&path)?;
 
     let f = Arc::new(f);
@@ -64,10 +62,7 @@ pub fn create_control_socket<P, F>(path: P, auto_remove: bool, f: F) -> Result<i
 
     let abort_future = super::last_worker_future().map_err(|_| {});
     let task = control_future.select(abort_future)
-        .then(move |_| {
-            if auto_remove { let _ = std::fs::remove_file(path1); }
-            Ok(())
-        });
+        .then(move |_| { Ok(()) });
 
     Ok(task)
 }