cargo fmt

Author: zh-jq

vey-keyless/src/protocol/response/cloudflare.rs

@@ -10,8 +10,7 @@ use super::KeylessResponse;
 
 const MESSAGE_HEADER_LENGTH: usize = 8;
 const ITEM_HEADER_LENGTH: usize = 3;
-const BUF_PREFIX_LEN: usize =
-    MESSAGE_HEADER_LENGTH + ITEM_HEADER_LENGTH + 1 + ITEM_HEADER_LENGTH;
+const BUF_PREFIX_LEN: usize = MESSAGE_HEADER_LENGTH + ITEM_HEADER_LENGTH + 1 + ITEM_HEADER_LENGTH;
 
 impl KeylessResponse {
     /// Encode this response into the Cloudflare Keyless wire format.

vey-keyless/src/serve/cloudflare/task/multiplex.rs

@@ -224,8 +224,7 @@ impl KeylessTask {
         }
 
         let req_stats = req.stats.clone();
-        let crypto_fail =
-            crate::protocol::KeylessErrorResponse::new(req.inner.id).crypto_fail();
+        let crypto_fail = crate::protocol::KeylessErrorResponse::new(req.inner.id).crypto_fail();
         let rsp = req.build_response(KeylessResponse::Error(crypto_fail));
         let sync_op = crate::backend::OpensslOperation::new(req, key);
         let async_op_timeout = self.ctx.server_config.async_op_timeout;

vey-keyless/src/serve/registry.rs

@@ -117,7 +117,10 @@ pub(crate) fn get_server(name: &NodeName) -> Option<ArcKeyServer> {
     })
 }
 
-pub(super) fn reload_and_respawn(name: &NodeName, config: AnyKeyServerConfig) -> anyhow::Result<()> {
+pub(super) fn reload_and_respawn(
+    name: &NodeName,
+    config: AnyKeyServerConfig,
+) -> anyhow::Result<()> {
     let mut sr = RUNTIME_SERVER_REGISTRY
         .lock()
         .map_err(|e| anyhow!("failed to lock server registry: {e}"))?;