Commit 260d18d1 authored by Anton Nayshtut's avatar Anton Nayshtut Committed by Jim Harris
Browse files

rpc/fsdev: Add fsdev RPC methods 



Change-Id: I04e60bfe864c80727816477649370e244a3c5692
Signed-off-by: default avatarAnton Nayshtut <anayshtut@nvidia.com>
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/22533


Reviewed-by: default avatarJim Harris <jim.harris@samsung.com>
Tested-by: default avatarSPDK CI Jenkins <sys_sgci@intel.com>
Reviewed-by: default avatarBen Walker <ben@nvidia.com>
Community-CI: Mellanox Build Bot
parent 2b435d1a

python/spdk/rpc/__init__.py

+1 −0
Original line number Diff line number Diff line
@@ -13,6 +13,7 @@ from . import app 
from . import bdev

from . import blobfs

from . import compressdev

from . import fsdev

from . import env_dpdk

from . import dsa

from . import iaa

python/spdk/rpc/fsdev.py

0 → 100644
+32 −0
Original line number Diff line number Diff line 
#  SPDX-License-Identifier: BSD-3-Clause

#  Copyright (C) 2023 NVIDIA CORPORATION & AFFILIATES.

#  All rights reserved.



import json





def fsdev_get_opts(client):

    """Get fsdev subsystem opts.



    Args:

        NONE

    """

    return client.call('fsdev_get_opts')





def fsdev_set_opts(client, fsdev_io_pool_size: int = None, fsdev_io_cache_size: int = None):

    """Set fsdev subsystem opts.



    Args:

        fsdev_io_pool_size: size of fsdev IO objects pool

        fsdev_io_cache_size: size of fsdev IO objects cache per thread

    """

    params = {

    }



    if fsdev_io_pool_size is not None:

        params['fsdev_io_pool_size'] = fsdev_io_pool_size

    if fsdev_io_cache_size is not None:

        params['fsdev_io_cache_size'] = fsdev_io_cache_size



    return client.call('fsdev_set_opts', params)

scripts/rpc.py

+16 −0
Original line number Diff line number Diff line
@@ -3549,6 +3549,22 @@ Format: 'user:u1 secret:s1 muser:mu1 msecret:ms1,user:u2 secret:s2 muser:mu2 mse 
    p.add_argument('size_in_mb', help='Cache size for blobfs in megabytes.', type=int)

    p.set_defaults(func=blobfs_set_cache_size)



    # fsdev

    def fsdev_get_opts(args):

        print_json(rpc.fsdev.fsdev_get_opts(args.client))



    p = subparsers.add_parser('fsdev_get_opts', help='Get the fsdev subsystem options')

    p.set_defaults(func=fsdev_get_opts)



    def fsdev_set_opts(args):

        print(rpc.fsdev.fsdev_set_opts(args.client, fsdev_io_pool_size=args.fsdev_io_pool_size,

                                       fsdev_io_cache_size=args.fsdev_io_cache_size))



    p = subparsers.add_parser('fsdev_set_opts', help='Set the fsdev subsystem options')

    p.add_argument('fsdev-io-pool-size', help='Size of fsdev IO objects pool', type=int)

    p.add_argument('fsdev-io-cache-size', help='Size of fsdev IO objects cache per thread', type=int)

    p.set_defaults(func=fsdev_set_opts)



    # sock

    def sock_impl_get_options(args):

        print_json(rpc.sock.sock_impl_get_options(args.client,