chore(lint): fix lint

Signed-off-by: Abhilash Shetty <[email protected]>

io-engine/src/grpc/mod.rs

@@ -13,7 +13,6 @@ use tonic::{Request, Response, Status};
 use crate::{
     bdev_api::BdevError,
     core::{CoreError, Reactor, VerboseError},
-    grpc::v1::{pool::PoolService, replica::ReplicaService},
 };
 
 impl From<BdevError> for tonic::Status {
@@ -130,18 +129,6 @@ pub(crate) trait RWSerializer<F, T> {
     async fn shared(&self, ctx: GrpcClientContext, f: F) -> Result<T, Status>;
 }
 
-/// Trait allows Service implementing it to lock Pool and Replica Service.
-#[async_trait::async_trait]
-pub(crate) trait SvcLocker<F, T> {
-    async fn svc_lock(
-        &self,
-        ctx: GrpcClientContext,
-        pool_svc: PoolService,
-        replica_svc: ReplicaService,
-        f: F,
-    ) -> Result<T, Status>;
-}
-
 pub type GrpcResult<T> = std::result::Result<Response<T>, Status>;
 
 /// call the given future within the context of the reactor on the first core

io-engine/src/grpc/v1/stats.rs

@@ -6,7 +6,7 @@ use crate::{
         GrpcClientContext,
         GrpcResult,
         RWSerializer,
-        SvcLocker,
+        Serializer,
     },
     lvs::Lvs,
 };
@@ -30,20 +30,14 @@ pub struct StatsService {
 }
 
 #[async_trait::async_trait]
-impl<F, T> SvcLocker<F, T> for StatsService
+impl<F, T> Serializer<F, T> for StatsService
 where
     T: Send + 'static,
     F: core::future::Future<Output = Result<T, Status>> + Send + 'static,
 {
-    async fn svc_lock(
-        &self,
-        ctx: GrpcClientContext,
-        pool_svc: PoolService,
-        replica_svc: ReplicaService,
-        f: F,
-    ) -> Result<T, Status> {
-        let pool_context = pool_svc.client_context.write().await;
-        let replica_context = replica_svc.client_context.write().await;
+    async fn locked(&self, ctx: GrpcClientContext, f: F) -> Result<T, Status> {
+        let pool_context = self.pool_svc.client_context.write().await;
+        let replica_context = self.replica_svc.client_context.write().await;
         if let Some(c) = pool_context.as_ref() {
             warn!("{}: gRPC method timed out, args: {}", c.id, c.args);
         }
@@ -143,10 +137,8 @@ impl StatsRpc for StatsService {
     }
     #[named]
     async fn reset_io_stats(&self, request: Request<()>) -> GrpcResult<()> {
-        self.svc_lock(
+        self.locked(
             GrpcClientContext::new(&request, function_name!()),
-            self.pool_svc.clone(),
-            self.replica_svc.clone(),
             async move {
                 let rx = rpc_submit::<_, _, CoreError>(async move {
                     if let Some(bdev) = UntypedBdev::bdev_first() {