Quellcode durchsuchen

bin/ircd: cargo +nightly fmt.

parazyd vor 4 Jahren
Ursprung
Commit
2786f881c2
1 geänderte Dateien mit 6 neuen und 6 gelöschten Zeilen
  1. 6 6
      bin/ircd/src/main.rs

+ 6 - 6
bin/ircd/src/main.rs

@@ -84,7 +84,7 @@ async fn process_user_input(
 ) -> Result<()> {
 ) -> Result<()> {
     if line.is_empty() {
     if line.is_empty() {
         warn!("Received empty line from {}. Closing connection.", peer_addr);
         warn!("Received empty line from {}. Closing connection.", peer_addr);
-        return Err(Error::ChannelStopped);
+        return Err(Error::ChannelStopped)
     }
     }
     assert!(&line[(line.len() - 1)..] == "\n");
     assert!(&line[(line.len() - 1)..] == "\n");
     // Remove the \n character
     // Remove the \n character
@@ -94,7 +94,7 @@ async fn process_user_input(
 
 
     if let Err(err) = connection.update(line, p2p.clone()).await {
     if let Err(err) = connection.update(line, p2p.clone()).await {
         warn!("Connection error: {} for {}", err, peer_addr);
         warn!("Connection error: {} for {}", err, peer_addr);
-        return Err(Error::ChannelStopped);
+        return Err(Error::ChannelStopped)
     }
     }
 
 
     Ok(())
     Ok(())
@@ -105,14 +105,14 @@ async fn start(executor: Arc<Executor<'_>>, options: ProgramOptions) -> Result<(
         Ok(listener) => listener,
         Ok(listener) => listener,
         Err(err) => {
         Err(err) => {
             error!("Bind listener failed: {}", err);
             error!("Bind listener failed: {}", err);
-            return Err(Error::OperationFailed);
+            return Err(Error::OperationFailed)
         }
         }
     };
     };
     let local_addr = match listener.get_ref().local_addr() {
     let local_addr = match listener.get_ref().local_addr() {
         Ok(addr) => addr,
         Ok(addr) => addr,
         Err(err) => {
         Err(err) => {
             error!("Failed to get local address: {}", err);
             error!("Failed to get local address: {}", err);
-            return Err(Error::OperationFailed);
+            return Err(Error::OperationFailed)
         }
         }
     };
     };
     info!("Listening on {}", local_addr);
     info!("Listening on {}", local_addr);
@@ -179,7 +179,7 @@ async fn start(executor: Arc<Executor<'_>>, options: ProgramOptions) -> Result<(
             Ok((s, a)) => (s, a),
             Ok((s, a)) => (s, a),
             Err(err) => {
             Err(err) => {
                 error!("Error listening for connections: {}", err);
                 error!("Error listening for connections: {}", err);
-                return Err(Error::ServiceStopped);
+                return Err(Error::ServiceStopped)
             }
             }
         };
         };
         info!("Accepted client: {}", peer_addr);
         info!("Accepted client: {}", peer_addr);
@@ -198,7 +198,7 @@ struct JsonRpcInterface {}
 impl RequestHandler for JsonRpcInterface {
 impl RequestHandler for JsonRpcInterface {
     async fn handle_request(&self, req: JsonRequest, _executor: Arc<Executor<'_>>) -> JsonResult {
     async fn handle_request(&self, req: JsonRequest, _executor: Arc<Executor<'_>>) -> JsonResult {
         if req.params.as_array().is_none() {
         if req.params.as_array().is_none() {
-            return JsonResult::Err(jsonerr(InvalidParams, None, req.id));
+            return JsonResult::Err(jsonerr(InvalidParams, None, req.id))
         }
         }
 
 
         debug!(target: "RPC", "--> {}", serde_json::to_string(&req).unwrap());
         debug!(target: "RPC", "--> {}", serde_json::to_string(&req).unwrap());