From 60dcb263ac437e4fb8ca74f54c1ac90c6010e817 Mon Sep 17 00:00:00 2001 From: Jingrong Chen Date: Fri, 10 May 2024 02:15:39 -0400 Subject: [PATCH] format --- experimental/mrpc/plugin/load_balancer/src/engine.rs | 6 +----- experimental/mrpc/plugin/rpc_adapter/src/engine.rs | 6 +----- experimental/mrpc/plugin/tcp_rpc_adapter/src/engine.rs | 6 +----- 3 files changed, 3 insertions(+), 15 deletions(-) diff --git a/experimental/mrpc/plugin/load_balancer/src/engine.rs b/experimental/mrpc/plugin/load_balancer/src/engine.rs index 36d46b90..859635d2 100644 --- a/experimental/mrpc/plugin/load_balancer/src/engine.rs +++ b/experimental/mrpc/plugin/load_balancer/src/engine.rs @@ -230,11 +230,7 @@ impl Engine for LoadBalancerEngine { &mut self.get_mut().indicator } - fn handle_request( - &mut self, - request: Vec, - _cred: std::os::unix::net::UCred, - ) -> Result<()> { + fn handle_request(&mut self, request: Vec, _cred: std::os::unix::net::UCred) -> Result<()> { let request: control_plane::Request = bincode::deserialize(&request[..])?; // TODO: send result to userland diff --git a/experimental/mrpc/plugin/rpc_adapter/src/engine.rs b/experimental/mrpc/plugin/rpc_adapter/src/engine.rs index fd1026d7..b9f0b022 100644 --- a/experimental/mrpc/plugin/rpc_adapter/src/engine.rs +++ b/experimental/mrpc/plugin/rpc_adapter/src/engine.rs @@ -288,11 +288,7 @@ impl Engine for RpcAdapterEngine { ELS.with_borrow_mut(|els| *els = unsafe { Some(&*tls) }); } - fn handle_request( - &mut self, - request: Vec, - _cred: std::os::unix::net::UCred, - ) -> Result<()> { + fn handle_request(&mut self, request: Vec, _cred: std::os::unix::net::UCred) -> Result<()> { let request: control_plane::Request = bincode::deserialize(&request[..])?; // TODO: send result to userland diff --git a/experimental/mrpc/plugin/tcp_rpc_adapter/src/engine.rs b/experimental/mrpc/plugin/tcp_rpc_adapter/src/engine.rs index b2b79dfc..2b437889 100644 --- a/experimental/mrpc/plugin/tcp_rpc_adapter/src/engine.rs +++ b/experimental/mrpc/plugin/tcp_rpc_adapter/src/engine.rs @@ -252,11 +252,7 @@ impl Engine for TcpRpcAdapterEngine { ELS.with_borrow_mut(|els| *els = unsafe { Some(&*tls) }); } - fn handle_request( - &mut self, - request: Vec, - _cred: std::os::unix::net::UCred, - ) -> Result<()> { + fn handle_request(&mut self, request: Vec, _cred: std::os::unix::net::UCred) -> Result<()> { let request: control_plane::Request = bincode::deserialize(&request[..])?; // TODO: send result to userland