Skip to content

Commit

Permalink
Fix clippy
Browse files Browse the repository at this point in the history
  • Loading branch information
boqiu committed Dec 18, 2024
1 parent 934720d commit 7ad0047
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 9 deletions.
8 changes: 0 additions & 8 deletions node/rpc/src/admin/impl.rs
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@ pub struct RpcServerImpl {

#[async_trait]
impl RpcServer for RpcServerImpl {
#[tracing::instrument(skip(self), err)]
async fn find_file(&self, tx_seq: u64) -> RpcResult<()> {
info!("admin_findFile({tx_seq})");

Expand All @@ -39,7 +38,6 @@ impl RpcServer for RpcServerImpl {
}
}

#[tracing::instrument(skip(self), err)]
async fn shutdown(&self) -> RpcResult<()> {
info!("admin_shutdown()");

Expand All @@ -51,7 +49,6 @@ impl RpcServer for RpcServerImpl {
.map_err(|e| error::internal_error(format!("Failed to send shutdown command: {:?}", e)))
}

#[tracing::instrument(skip(self), err)]
async fn start_sync_file(&self, tx_seq: u64) -> RpcResult<()> {
info!("admin_startSyncFile({tx_seq})");

Expand All @@ -72,7 +69,6 @@ impl RpcServer for RpcServerImpl {
}
}

#[tracing::instrument(skip(self), err)]
async fn start_sync_chunks(
&self,
tx_seq: u64,
Expand Down Expand Up @@ -102,7 +98,6 @@ impl RpcServer for RpcServerImpl {
}
}

#[tracing::instrument(skip(self), err)]
async fn terminate_sync(&self, tx_seq: u64) -> RpcResult<bool> {
info!("admin_terminateSync({tx_seq})");

Expand Down Expand Up @@ -131,7 +126,6 @@ impl RpcServer for RpcServerImpl {
}
}

#[tracing::instrument(skip(self), err)]
async fn get_sync_status(&self, tx_seq: u64) -> RpcResult<String> {
info!("admin_getSyncStatus({tx_seq})");

Expand All @@ -148,7 +142,6 @@ impl RpcServer for RpcServerImpl {
}
}

#[tracing::instrument(skip(self), err)]
async fn get_sync_info(&self, tx_seq: Option<u64>) -> RpcResult<HashMap<u64, FileSyncInfo>> {
info!(?tx_seq, "admin_getSyncInfo()");

Expand All @@ -163,7 +156,6 @@ impl RpcServer for RpcServerImpl {
}
}

#[tracing::instrument(skip(self), err)]
async fn get_network_info(&self) -> RpcResult<NetworkInfo> {
info!("admin_getNetworkInfo()");

Expand Down
1 change: 0 additions & 1 deletion node/rpc/src/zgs/impl.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@ pub struct RpcServerImpl {

#[async_trait]
impl RpcServer for RpcServerImpl {
#[tracing::instrument(skip(self), err)]
async fn get_status(&self) -> RpcResult<Status> {
info!("zgs_getStatus()");
let sync_progress = self
Expand Down

0 comments on commit 7ad0047

Please sign in to comment.