From 308df27a53f4a9be40f4809473101150b85de943 Mon Sep 17 00:00:00 2001
From: Gil Bregman <gbregman@il.ibm.com>
Date: Sun, 31 Mar 2024 16:51:25 +0300
Subject: [PATCH] Some adjustments to protobuf field and request names. Fixes
 #518

Signed-off-by: Gil Bregman <gbregman@il.ibm.com>
---
 control/cli.py              |  68 ++++++------
 control/discovery.py        |   8 +-
 control/grpc.py             | 214 ++++++++++++++++++------------------
 control/prometheus.py       |  14 +--
 control/proto/gateway.proto |  92 ++++++++--------
 control/server.py           |  24 ++--
 tests/test_cli.py           |  35 +++---
 tests/test_multi_gateway.py |  18 +--
 tests/test_namespaces.py    |  46 ++++----
 tests/test_nsid.py          |  16 +--
 tests/test_omap_lock.py     |  74 ++++++-------
 11 files changed, 305 insertions(+), 304 deletions(-)

diff --git a/control/cli.py b/control/cli.py
index 1db71925..36012388 100644
--- a/control/cli.py
+++ b/control/cli.py
@@ -307,8 +307,8 @@ def parse_version_string(self, version):
 
     def gw_get_info(self):
         ver = os.getenv("NVMEOF_VERSION")
-        req = pb2.get_gateway_info_req(cli_version=ver)
-        gw_info = self.stub.get_gateway_info(req)
+        req = pb2.gateway_info_get_req(cli_version=ver)
+        gw_info = self.stub.gateway_info_get(req)
         if gw_info.status == 0:
             base_ver = self.parse_version_string(BASE_GATEWAY_VERSION)
             assert base_ver != None
@@ -409,9 +409,9 @@ def gw_get_log_level(self, args):
         """Get gateway's log level"""
 
         out_func, err_func = self.get_output_functions(args)
-        req = pb2.get_gateway_log_level_req()
+        req = pb2.gateway_log_level_get_req()
         try:
-            ret = self.stub.get_gateway_log_level(req)
+            ret = self.stub.gateway_log_level_get(req)
         except Exception as ex:
             ret = pb2.req_status(status = errno.EINVAL, error_message = f"Failure getting gateway log level:\n{ex}")
 
@@ -448,12 +448,12 @@ def gw_set_log_level(self, args):
             log_level = args.level.lower()
 
         try:
-            req = pb2.set_gateway_log_level_req(log_level=log_level)
+            req = pb2.gateway_log_level_set_req(log_level=log_level)
         except ValueError as err:
             self.cli.parser.error(f"invalid log level {log_level}, error {err}")
 
         try:
-            ret = self.stub.set_gateway_log_level(req)
+            ret = self.stub.gateway_log_level_set(req)
         except Exception as ex:
             ret = pb2.req_status(status = errno.EINVAL, error_message = f"Failure setting gateway log level:\n{ex}")
 
@@ -508,9 +508,9 @@ def spdk_log_level_disable(self, args):
 
         out_func, err_func = self.get_output_functions(args)
 
-        req = pb2.disable_spdk_nvmf_logs_req()
+        req = pb2.spdk_nvmf_logs_disable_req()
         try:
-            ret = self.stub.disable_spdk_nvmf_logs(req)
+            ret = self.stub.spdk_nvmf_logs_disable(req)
         except Exception as ex:
             ret = pb2.req_status(status = errno.EINVAL, error_message = f"Failure disabling SPDK nvmf log flags:\n{ex}")
 
@@ -542,9 +542,9 @@ def spdk_log_level_get(self, args):
 
         out_func, err_func = self.get_output_functions(args)
 
-        req = pb2.get_spdk_nvmf_log_flags_and_level_req()
+        req = pb2.spdk_nvmf_log_flags_and_level_get_req()
         try:
-            ret = self.stub.get_spdk_nvmf_log_flags_and_level(req)
+            ret = self.stub.spdk_nvmf_log_flags_and_level_get(req)
         except Exception as ex:
             ret = pb2.req_status(status = errno.EINVAL, error_message = f"Failure getting SPDK log levels and nvmf log flags:\n{ex}")
 
@@ -592,12 +592,12 @@ def spdk_log_level_set(self, args):
             print_level = args.print.upper()
 
         try:
-            req = pb2.set_spdk_nvmf_logs_req(log_level=log_level, print_level=print_level)
+            req = pb2.spdk_nvmf_logs_set_req(log_level=log_level, print_level=print_level)
         except ValueError as err:
             self.cli.parser.error(f"invalid log level {log_level}, error {err}")
 
         try:
-            ret = self.stub.set_spdk_nvmf_logs(req)
+            ret = self.stub.spdk_nvmf_logs_set(req)
         except Exception as ex:
             ret = pb2.req_status(status = errno.EINVAL, error_message = f"Failure setting SPDK log levels and nvmf log flags:\n{ex}")
 
@@ -660,12 +660,12 @@ def subsystem_add(self, args):
         if args.subsystem == GatewayUtils.DISCOVERY_NQN:
             self.cli.parser.error("Can't add a discovery subsystem")
 
-        req = pb2.create_subsystem_req(subsystem_nqn=args.subsystem,
+        req = pb2.subsystem_create_req(subsystem_nqn=args.subsystem,
                                         serial_number=args.serial_number,
                                         max_namespaces=args.max_namespaces,
                                         enable_ha=True)
         try:
-            ret = self.stub.create_subsystem(req)
+            ret = self.stub.subsystem_create(req)
         except Exception as ex:
             ret = pb2.req_status(status = errno.EINVAL, error_message = f"Failure adding subsystem {args.subsystem}:\n{ex}")
 
@@ -699,9 +699,9 @@ def subsystem_del(self, args):
         if args.subsystem == GatewayUtils.DISCOVERY_NQN:
             self.cli.parser.error("Can't delete a discovery subsystem")
 
-        req = pb2.delete_subsystem_req(subsystem_nqn=args.subsystem, force=args.force)
+        req = pb2.subsystem_delete_req(subsystem_nqn=args.subsystem, force=args.force)
         try:
-            ret = self.stub.delete_subsystem(req)
+            ret = self.stub.subsystem_delete(req)
         except Exception as ex:
             ret = pb2.req_status(status = errno.EINVAL, error_message = f"Failure deleting subsystem {args.subsystem}:\n{ex}")
 
@@ -735,7 +735,7 @@ def subsystem_list(self, args):
 
         subsystems = None
         try:
-            subsystems = self.stub.list_subsystems(pb2.list_subsystems_req(subsystem_nqn=args.subsystem, serial_number=args.serial_number))
+            subsystems = self.stub.subsystem_list(pb2.subsystem_list_req(subsystem_nqn=args.subsystem, serial_number=args.serial_number))
         except Exception as ex:
             subsystems = pb2.subsystems_info_cli(status = errno.EINVAL, error_message = f"Failure listing subsystems:\n{ex}")
 
@@ -844,8 +844,8 @@ def listener_add(self, args):
         if args.adrfam:
             adrfam = args.adrfam.lower()
 
-        req = pb2.create_listener_req(
-            nqn=args.subsystem,
+        req = pb2.listener_create_req(
+            subsystem_nqn=args.subsystem,
             host_name=args.host_name,
             adrfam=adrfam,
             traddr=traddr,
@@ -853,7 +853,7 @@ def listener_add(self, args):
         )
 
         try:
-            ret = self.stub.create_listener(req)
+            ret = self.stub.listener_create(req)
         except Exception as ex:
             ret = pb2.req_status(status = errno.EINVAL,
                                  error_message = f"Failure adding {args.subsystem} listener at {traddr}:{args.trsvcid}:\n{ex}")
@@ -900,8 +900,8 @@ def listener_del(self, args):
         if args.adrfam:
             adrfam = args.adrfam.lower()
 
-        req = pb2.delete_listener_req(
-            nqn=args.subsystem,
+        req = pb2.listener_delete_req(
+            subsystem_nqn=args.subsystem,
             host_name=args.host_name,
             adrfam=adrfam,
             traddr=traddr,
@@ -910,7 +910,7 @@ def listener_del(self, args):
         )
 
         try:
-            ret = self.stub.delete_listener(req)
+            ret = self.stub.listener_delete(req)
         except Exception as ex:
             ret = pb2.req_status(status = errno.EINVAL,
                                  error_message = f"Failure deleting listener {traddr}:{args.trsvcid} from {args.subsystem}:\n{ex}")
@@ -945,7 +945,7 @@ def listener_list(self, args):
         out_func, err_func = self.get_output_functions(args)
         listeners_info = None
         try:
-            listeners_info = self.stub.list_listeners(pb2.list_listeners_req(subsystem=args.subsystem))
+            listeners_info = self.stub.listener_list(pb2.listener_list_req(subsystem_nqn=args.subsystem))
         except Exception as ex:
             listeners_info = pb2.listeners_info(status = errno.EINVAL, error_message = f"Failure listing listeners:\n{ex}", listeners=[])
 
@@ -1028,9 +1028,9 @@ def host_add(self, args):
         out_func, err_func = self.get_output_functions(args)
         if not args.host:
             self.cli.parser.error("--host argument is mandatory for add command")
-        req = pb2.add_host_req(subsystem_nqn=args.subsystem, host_nqn=args.host)
+        req = pb2.host_add_req(subsystem_nqn=args.subsystem, host_nqn=args.host)
         try:
-            ret = self.stub.add_host(req)
+            ret = self.stub.host_add(req)
         except Exception as ex:
             if args.host == "*":
                 errmsg = f"Failure allowing open host access to {args.subsystem}"
@@ -1070,10 +1070,10 @@ def host_del(self, args):
         out_func, err_func = self.get_output_functions(args)
         if not args.host:
             self.cli.parser.error("--host argument is mandatory for del command")
-        req = pb2.remove_host_req(subsystem_nqn=args.subsystem, host_nqn=args.host)
+        req = pb2.host_remove_req(subsystem_nqn=args.subsystem, host_nqn=args.host)
 
         try:
-            ret = self.stub.remove_host(req)
+            ret = self.stub.host_remove(req)
         except Exception as ex:
             if args.host == "*":
                 errmsg = f"Failure disabling open host access to {args.subsystem}"
@@ -1114,7 +1114,7 @@ def host_list(self, args):
 
         hosts_info = None
         try:
-            hosts_info = self.stub.list_hosts(pb2.list_hosts_req(subsystem=args.subsystem))
+            hosts_info = self.stub.host_list(pb2.host_list_req(subsystem_nqn=args.subsystem))
         except Exception as ex:
             hosts_info = pb2.hosts_info(status = errno.EINVAL, error_message = f"Failure listing hosts:\n{ex}", hosts=[])
 
@@ -1190,7 +1190,7 @@ def connection_list(self, args):
         out_func, err_func = self.get_output_functions(args)
         connections_info = None
         try:
-            connections_info = self.stub.list_connections(pb2.list_connections_req(subsystem=args.subsystem))
+            connections_info = self.stub.connection_list(pb2.connection_list_req(subsystem_nqn=args.subsystem))
         except Exception as ex:
             connections_info = pb2.connections_info(status = errno.EINVAL,
                                                     error_message = f"Failure listing hosts:\n{ex}", connections=[])
@@ -1280,7 +1280,7 @@ def ns_add(self, args):
                                             nsid=args.nsid,
                                             block_size=args.block_size,
                                             uuid=args.uuid,
-                                            anagrpid=args.load_balancing_group,
+                                            load_balancing_group=args.load_balancing_group,
                                             create_image=args.rbd_create_image,
                                             size=img_size,
                                             force=args.force)
@@ -1502,8 +1502,8 @@ def ns_list(self, args):
             self.cli.parser.error("nsid value must be positive")
 
         try:
-            namespaces_info = self.stub.list_namespaces(pb2.list_namespaces_req(subsystem=args.subsystem,
-                                                        nsid=args.nsid, uuid=args.uuid))
+            namespaces_info = self.stub.namespace_list(pb2.namespace_list_req(subsystem_nqn=args.subsystem,
+                                                       nsid=args.nsid, uuid=args.uuid))
         except Exception as ex:
             namespaces_info = pb2.namespaces_info(status = errno.EINVAL, error_message = f"Failure listing namespaces:\n{ex}")
 
@@ -1680,7 +1680,7 @@ def ns_change_load_balancing_group(self, args):
         try:
             change_lb_group_req = pb2.namespace_change_load_balancing_group_req(subsystem_nqn=args.subsystem,
                                                                                 nsid=args.nsid, uuid=args.uuid,
-                                                                                anagrpid=args.load_balancing_group)
+                                                                                load_balancing_group=args.load_balancing_group)
             ret = self.stub.namespace_change_load_balancing_group(change_lb_group_req)
         except Exception as ex:
             ret = pb2.req_status(status = errno.EINVAL, error_message = f"Failure changing namespace load balancing group:\n{ex}")
diff --git a/control/discovery.py b/control/discovery.py
index 64607ea4..e5e75ffe 100644
--- a/control/discovery.py
+++ b/control/discovery.py
@@ -715,7 +715,7 @@ def reply_get_log_page(self, conn, data, cmd_id):
                     for listener in listeners:
                         # TODO: It is better to change nqn in the "listener"
                         # to subsystem_nqn to avoid confusion
-                        if host["subsystem_nqn"] == listener["nqn"]:
+                        if host["subsystem_nqn"] == listener["subsystem_nqn"]:
                             allow_listeners += [listener,]
             self_conn.allow_listeners = allow_listeners
 
@@ -753,9 +753,9 @@ def reply_get_log_page(self, conn, data, cmd_id):
                     [c_ubyte(0x20)] * (32 - len(str_trsvcid))
                 # NVM subsystem qualified name
                 log_entry.subnqn = (c_ubyte * 256)(*[c_ubyte(x) for x \
-                    in allow_listeners[log_entry_counter]["nqn"].encode()])
-                log_entry.subnqn[len(allow_listeners[log_entry_counter]["nqn"]):] = \
-                    [c_ubyte(0x00)] * (256 - len(allow_listeners[log_entry_counter]["nqn"]))
+                    in allow_listeners[log_entry_counter]["subsystem_nqn"].encode()])
+                log_entry.subnqn[len(allow_listeners[log_entry_counter]["subsystem_nqn"]):] = \
+                    [c_ubyte(0x00)] * (256 - len(allow_listeners[log_entry_counter]["subsystem_nqn"]))
                 # Transport address
                 log_entry.traddr = (c_ubyte * 256)(*[c_ubyte(x) for x \
                     in allow_listeners[log_entry_counter]["traddr"].encode()])
diff --git a/control/grpc.py b/control/grpc.py
index 6f9cb720..6796f687 100644
--- a/control/grpc.py
+++ b/control/grpc.py
@@ -457,7 +457,7 @@ def serial_number_already_used(self, context, serial) -> str:
                 continue
         return None
 
-    def create_subsystem_safe(self, request, context):
+    def subsystem_create_safe(self, request, context):
         """Creates a subsystem."""
 
         create_subsystem_error_prefix = f"Failure creating subsystem {request.subsystem_nqn}"
@@ -557,8 +557,8 @@ def create_subsystem_safe(self, request, context):
 
         return pb2.req_status(status=0, error_message=os.strerror(0))
 
-    def create_subsystem(self, request, context=None):
-        return self.execute_grpc_function(self.create_subsystem_safe, request, context)
+    def subsystem_create(self, request, context=None):
+        return self.execute_grpc_function(self.subsystem_create_safe, request, context)
 
     def get_subsystem_namespaces(self, nqn) -> list:
         ns_list = []
@@ -584,7 +584,7 @@ def subsystem_has_listeners(self, nqn) -> bool:
                 continue
             try:
                 lsnr = json.loads(val)
-                if lsnr["nqn"] == nqn:
+                if lsnr["subsystem_nqn"] == nqn:
                     return True
             except Exception:
                 self.logger.exception(f"Got exception trying to get subsystem {nqn} listener")
@@ -606,7 +606,7 @@ def remove_subsystem_from_state(self, nqn, context):
             return pb2.req_status(status=errno.EINVAL, error_message=errmsg)
         return pb2.req_status(status=0, error_message=os.strerror(0))
 
-    def delete_subsystem_safe(self, request, context):
+    def subsystem_delete_safe(self, request, context):
         """Deletes a subsystem."""
 
         delete_subsystem_error_prefix = f"Failure deleting subsystem {request.subsystem_nqn}"
@@ -640,7 +640,7 @@ def delete_subsystem_safe(self, request, context):
 
             return self.remove_subsystem_from_state(request.subsystem_nqn, context)
 
-    def delete_subsystem(self, request, context=None):
+    def subsystem_delete(self, request, context=None):
         """Deletes a subsystem."""
 
         delete_subsystem_error_prefix = f"Failure deleting subsystem {request.subsystem_nqn}"
@@ -672,7 +672,7 @@ def delete_subsystem(self, request, context=None):
             else:
                 self.logger.error(f"Failure removing namespace {nsid} from {request.subsystem_nqn}:\n{ret.error_message}")
                 self.logger.warning(f"Will continue deleting {request.subsystem_nqn} anyway")
-        return self.execute_grpc_function(self.delete_subsystem_safe, request, context)
+        return self.execute_grpc_function(self.subsystem_delete_safe, request, context)
 
     def check_if_image_used(self, pool_name, image_name):
         """Check if image is used by any other namespace."""
@@ -866,7 +866,7 @@ def namespace_add_safe(self, request, context):
             create_image = request.create_image
             if not context:
                 create_image = False
-            anagrp = int(request.anagrpid) if request.anagrpid is not None else 0
+            anagrp = int(request.load_balancing_group) if request.load_balancing_group is not None else 0
             ret_bdev = self.create_bdev(anagrp, bdev_name, request.uuid, request.rbd_pool_name,
                                         request.rbd_image_name, request.block_size, create_image, request.size)
             if ret_bdev.status != 0:
@@ -933,7 +933,7 @@ def namespace_change_load_balancing_group_safe(self, request, context):
         """Changes a namespace load balancing group."""
 
         nsid_msg = self.get_ns_id_message(request.nsid, request.uuid)
-        self.logger.info(f"Received request to change load balancing group for namespace {nsid_msg}in {request.subsystem_nqn} to {request.anagrpid}, context: {context}")
+        self.logger.info(f"Received request to change load balancing group for namespace {nsid_msg}in {request.subsystem_nqn} to {request.load_balancing_group}, context: {context}")
 
         with self.omap_lock(context=context):
             find_ret = self.find_namespace_and_bdev_name(request.subsystem_nqn, request.nsid, request.uuid, False,
@@ -994,7 +994,7 @@ def namespace_change_load_balancing_group_safe(self, request, context):
             if nsid:
                 self.remove_namespace_from_state(request.subsystem_nqn, nsid, context)
 
-            ret_ns = self.create_namespace(request.subsystem_nqn, bdev_name, nsid, request.anagrpid, uuid, context)
+            ret_ns = self.create_namespace(request.subsystem_nqn, bdev_name, nsid, request.load_balancing_group, uuid, context)
             if ret_ns.status != 0:
                 errmsg = f"Failure changing load balancing group for namespace {nsid_msg}in {request.subsystem_nqn}:{ret_ns.error_message}"
                 self.logger.error(errmsg)
@@ -1028,7 +1028,7 @@ def namespace_change_load_balancing_group_safe(self, request, context):
                         namespace_add_req.uuid=ns_entry["uuid"]
                     except KeyError:
                         pass
-                    namespace_add_req.anagrpid=request.anagrpid
+                    namespace_add_req.load_balancing_group=request.load_balancing_group
                     json_req = json_format.MessageToJson(
                             namespace_add_req, preserving_proto_field_name=True, including_default_value_fields=True)
                     self.gateway_state.add_namespace(request.subsystem_nqn, nsid, json_req)
@@ -1123,7 +1123,7 @@ def get_bdev_info(self, bdev_name, need_to_lock):
 
         return ret_bdev
 
-    def list_namespaces(self, request, context=None):
+    def namespace_list(self, request, context=None):
         """List namespaces."""
 
         if request.nsid == None or request.nsid == 0:
@@ -1136,12 +1136,12 @@ def list_namespaces(self, request, context=None):
                 nsid_msg = f"namespace with NSID {request.nsid} and UUID {request.uuid}"
             else:
                 nsid_msg = f"namespace with NSID {request.nsid}"
-        self.logger.info(f"Received request to list {nsid_msg} for {request.subsystem}, context: {context}")
+        self.logger.info(f"Received request to list {nsid_msg} for {request.subsystem_nqn}, context: {context}")
 
         with self.rpc_lock:
             try:
-                ret = rpc_nvmf.nvmf_get_subsystems(self.spdk_rpc_client, nqn=request.subsystem)
-                self.logger.info(f"list_namespaces: {ret}")
+                ret = rpc_nvmf.nvmf_get_subsystems(self.spdk_rpc_client, nqn=request.subsystem_nqn)
+                self.logger.info(f"get_subsystems: {ret}")
             except Exception as ex:
                 errmsg = f"Failure listing namespaces"
                 self.logger.exception(errmsg)
@@ -1151,13 +1151,13 @@ def list_namespaces(self, request, context=None):
                 if resp:
                     status = resp["code"]
                     errmsg = f"Failure listing namespaces: {resp['message']}"
-                return pb2.namespaces_info(status=status, error_message=errmsg, subsystem_nqn=request.subsystem, namespaces=[])
+                return pb2.namespaces_info(status=status, error_message=errmsg, subsystem_nqn=request.subsystem_nqn, namespaces=[])
 
         namespaces = []
         for s in ret:
             try:
-                if s["nqn"] != request.subsystem:
-                    self.logger.warning(f'Got subsystem {s["nqn"]} instead of {request.subsystem}, ignore')
+                if s["nqn"] != request.subsystem_nqn:
+                    self.logger.warning(f'Got subsystem {s["nqn"]} instead of {request.subsystem_nqn}, ignore')
                     continue
                 try:
                     ns_list = s["namespaces"]
@@ -1209,7 +1209,7 @@ def list_namespaces(self, request, context=None):
                 self.logger.exception(f"{s=} parse error")
                 pass
 
-        return pb2.namespaces_info(status = 0, error_message = os.strerror(0), subsystem_nqn=request.subsystem, namespaces=namespaces)
+        return pb2.namespaces_info(status = 0, error_message = os.strerror(0), subsystem_nqn=request.subsystem_nqn, namespaces=namespaces)
 
     def namespace_get_io_stats(self, request, context=None):
         """Get namespace's IO stats."""
@@ -1588,7 +1588,7 @@ def matching_host_exists(self, context, subsys_nqn, host_nqn) -> bool:
         else:
             return False
 
-    def add_host_safe(self, request, context):
+    def host_add_safe(self, request, context):
         """Adds a host to a subsystem."""
 
         all_host_failure_prefix=f"Failure allowing open host access to {request.subsystem_nqn}"
@@ -1644,7 +1644,7 @@ def add_host_safe(self, request, context):
                         nqn=request.subsystem_nqn,
                         disable=False,
                     )
-                    self.logger.info(f"add_host *: {ret}")
+                    self.logger.info(f"allow_any_host: {ret}")
                 else:  # Allow single host access to subsystem
                     self.logger.info(
                         f"Received request to add host {request.host_nqn} to {request.subsystem_nqn}, context: {context}")
@@ -1695,8 +1695,8 @@ def add_host_safe(self, request, context):
 
         return pb2.req_status(status=0, error_message=os.strerror(0))
 
-    def add_host(self, request, context=None):
-        return self.execute_grpc_function(self.add_host_safe, request, context)
+    def host_add(self, request, context=None):
+        return self.execute_grpc_function(self.host_add_safe, request, context)
 
     def remove_host_from_state(self, subsystem_nqn, host_nqn, context):
         if not context:
@@ -1714,7 +1714,7 @@ def remove_host_from_state(self, subsystem_nqn, host_nqn, context):
             return pb2.req_status(status=errno.EINVAL, error_message=errmsg)
         return pb2.req_status(status=0, error_message=os.strerror(0))
 
-    def remove_host_safe(self, request, context):
+    def host_remove_safe(self, request, context):
         """Removes a host from a subsystem."""
 
         all_host_failure_prefix=f"Failure disabling open host access to {request.subsystem_nqn}"
@@ -1747,7 +1747,7 @@ def remove_host_safe(self, request, context):
                         nqn=request.subsystem_nqn,
                         disable=True,
                     )
-                    self.logger.info(f"remove_host *: {ret}")
+                    self.logger.info(f"allow_any_host: {ret}")
                 else:  # Remove single host access to subsystem
                     self.logger.info(
                         f"Received request to remove host {request.host_nqn} access from"
@@ -1789,16 +1789,16 @@ def remove_host_safe(self, request, context):
 
             return self.remove_host_from_state(request.subsystem_nqn, request.host_nqn, context)
 
-    def remove_host(self, request, context=None):
-        return self.execute_grpc_function(self.remove_host_safe, request, context)
+    def host_remove(self, request, context=None):
+        return self.execute_grpc_function(self.host_remove_safe, request, context)
 
-    def list_hosts_safe(self, request, context):
+    def host_list_safe(self, request, context):
         """List hosts."""
 
-        self.logger.info(f"Received request to list hosts for {request.subsystem}, context: {context}")
+        self.logger.info(f"Received request to list hosts for {request.subsystem_nqn}, context: {context}")
         try:
-            ret = rpc_nvmf.nvmf_get_subsystems(self.spdk_rpc_client, nqn=request.subsystem)
-            self.logger.info(f"list_hosts: {ret}")
+            ret = rpc_nvmf.nvmf_get_subsystems(self.spdk_rpc_client, nqn=request.subsystem_nqn)
+            self.logger.info(f"get_subsystems: {ret}")
         except Exception as ex:
             errmsg = f"Failure listing hosts, can't get subsystems"
             self.logger.exception(errmsg)
@@ -1814,8 +1814,8 @@ def list_hosts_safe(self, request, context):
         allow_any_host = False
         for s in ret:
             try:
-                if s["nqn"] != request.subsystem:
-                    self.logger.warning(f'Got subsystem {s["nqn"]} instead of {request.subsystem}, ignore')
+                if s["nqn"] != request.subsystem_nqn:
+                    self.logger.warning(f'Got subsystem {s["nqn"]} instead of {request.subsystem_nqn}, ignore')
                     continue
                 try:
                     allow_any_host = s["allow_any_host"]
@@ -1832,18 +1832,18 @@ def list_hosts_safe(self, request, context):
                 pass
 
         return pb2.hosts_info(status = 0, error_message = os.strerror(0), allow_any_host=allow_any_host,
-                              subsystem_nqn=request.subsystem, hosts=hosts)
+                              subsystem_nqn=request.subsystem_nqn, hosts=hosts)
 
-    def list_hosts(self, request, context=None):
-        return self.execute_grpc_function(self.list_hosts_safe, request, context)
+    def host_list(self, request, context=None):
+        return self.execute_grpc_function(self.host_list_safe, request, context)
 
-    def list_connections_safe(self, request, context):
+    def connection_list_safe(self, request, context):
         """List connections."""
 
-        self.logger.info(f"Received request to list connections for {request.subsystem}, context: {context}")
+        self.logger.info(f"Received request to list connections for {request.subsystem_nqn}, context: {context}")
         try:
-            qpair_ret = rpc_nvmf.nvmf_subsystem_get_qpairs(self.spdk_rpc_client, nqn=request.subsystem)
-            self.logger.info(f"list_connections get_qpairs: {qpair_ret}")
+            qpair_ret = rpc_nvmf.nvmf_subsystem_get_qpairs(self.spdk_rpc_client, nqn=request.subsystem_nqn)
+            self.logger.info(f"connection_list get_qpairs: {qpair_ret}")
         except Exception as ex:
             errmsg = f"Failure listing connections, can't get qpairs"
             self.logger.exception(errmsg)
@@ -1856,8 +1856,8 @@ def list_connections_safe(self, request, context):
             return pb2.connections_info(status=status, error_message=errmsg, connections=[])
 
         try:
-            ctrl_ret = rpc_nvmf.nvmf_subsystem_get_controllers(self.spdk_rpc_client, nqn=request.subsystem)
-            self.logger.info(f"list_connections get_controllers: {ctrl_ret}")
+            ctrl_ret = rpc_nvmf.nvmf_subsystem_get_controllers(self.spdk_rpc_client, nqn=request.subsystem_nqn)
+            self.logger.info(f"connection_list get_controllers: {ctrl_ret}")
         except Exception as ex:
             errmsg = f"Failure listing connections, can't get controllers"
             self.logger.exception(errmsg)
@@ -1870,8 +1870,8 @@ def list_connections_safe(self, request, context):
             return pb2.bconnections_info(status=status, error_message=errmsg, connections=[])
 
         try:
-            subsys_ret = rpc_nvmf.nvmf_get_subsystems(self.spdk_rpc_client, nqn=request.subsystem)
-            self.logger.info(f"list_connections subsystems: {subsys_ret}")
+            subsys_ret = rpc_nvmf.nvmf_get_subsystems(self.spdk_rpc_client, nqn=request.subsystem_nqn)
+            self.logger.info(f"connection list subsystems: {subsys_ret}")
         except Exception as ex:
             errmsg = f"Failure listing connections, can't get subsystems"
             self.logger.exception(errmsg)
@@ -1887,8 +1887,8 @@ def list_connections_safe(self, request, context):
         host_nqns = []
         for s in subsys_ret:
             try:
-                if s["nqn"] != request.subsystem:
-                    self.logger.warning(f'Got subsystem {s["nqn"]} instead of {request.subsystem}, ignore')
+                if s["nqn"] != request.subsystem_nqn:
+                    self.logger.warning(f'Got subsystem {s["nqn"]} instead of {request.subsystem_nqn}, ignore')
                     continue
                 try:
                     subsys_hosts = s["hosts"]
@@ -1950,10 +1950,10 @@ def list_connections_safe(self, request, context):
             connections.append(one_conn)
 
         return pb2.connections_info(status = 0, error_message = os.strerror(0),
-                              subsystem_nqn=request.subsystem, connections=connections)
+                              subsystem_nqn=request.subsystem_nqn, connections=connections)
 
-    def list_connections(self, request, context=None):
-        return self.execute_grpc_function(self.list_connections_safe, request, context)
+    def connection_list(self, request, context=None):
+        return self.execute_grpc_function(self.connection_list_safe, request, context)
 
     def get_subsystem_ha_status(self, nqn) -> bool:
         if nqn not in self.subsys_ha:
@@ -1982,12 +1982,12 @@ def matching_listener_exists(self, context, nqn, traddr, trsvcid) -> bool:
 
         return False
 
-    def create_listener_safe(self, request, context):
+    def listener_create_safe(self, request, context):
         """Creates a listener for a subsystem at a given IP/Port."""
 
         ret = True
         traddr = GatewayUtils.escape_address_if_ipv6(request.traddr)
-        create_listener_error_prefix = f"Failure adding {request.nqn} listener at {traddr}:{request.trsvcid}"
+        create_listener_error_prefix = f"Failure adding {request.subsystem_nqn} listener at {traddr}:{request.trsvcid}"
 
         adrfam = GatewayEnumUtils.get_key_from_value(pb2.AddressFamily, request.adrfam)
         if adrfam == None:
@@ -1996,10 +1996,10 @@ def create_listener_safe(self, request, context):
             return pb2.req_status(status=errno.ENOKEY, error_message=errmsg)
 
         self.logger.info(f"Received request to create {request.host_name}"
-                         f" TCP {adrfam} listener for {request.nqn} at"
+                         f" TCP {adrfam} listener for {request.subsystem_nqn} at"
                          f" {traddr}:{request.trsvcid}, context: {context}")
 
-        if GatewayUtils.is_discovery_nqn(request.nqn):
+        if GatewayUtils.is_discovery_nqn(request.subsystem_nqn):
             errmsg=f"{create_listener_error_prefix}: Can't create a listener for a discovery subsystem"
             self.logger.error(f"{errmsg}")
             return pb2.req_status(status=errno.EINVAL, error_message=errmsg)
@@ -2013,20 +2013,20 @@ def create_listener_safe(self, request, context):
             try:
                 if request.host_name == self.host_name:
                     listener_already_exist = self.matching_listener_exists(
-                            context, request.nqn, request.traddr, request.trsvcid)
+                            context, request.subsystem_nqn, request.traddr, request.trsvcid)
                     if listener_already_exist:
-                        self.logger.error(f"{request.nqn} already listens on address {traddr}:{request.trsvcid}")
+                        self.logger.error(f"{request.subsystem_nqn} already listens on address {traddr}:{request.trsvcid}")
                         return pb2.req_status(status=errno.EEXIST,
                                   error_message=f"{create_listener_error_prefix}: Subsystem already listens on this address")
                     ret = rpc_nvmf.nvmf_subsystem_add_listener(
                         self.spdk_rpc_client,
-                        nqn=request.nqn,
+                        nqn=request.subsystem_nqn,
                         trtype="TCP",
                         traddr=request.traddr,
                         trsvcid=str(request.trsvcid),
                         adrfam=adrfam,
                     )
-                    self.logger.info(f"create_listener: {ret}")
+                    self.logger.info(f"add_listener: {ret}")
                 else:
                     if context:
                         errmsg=f"{create_listener_error_prefix}: Gateway's host name must match current host ({self.host_name})"
@@ -2051,7 +2051,7 @@ def create_listener_safe(self, request, context):
                 self.logger.error(create_listener_error_prefix)
                 return pb2.req_status(status=errno.EINVAL, error_message=create_listener_error_prefix)
 
-            enable_ha = self.get_subsystem_ha_status(request.nqn)
+            enable_ha = self.get_subsystem_ha_status(request.subsystem_nqn)
 
             if enable_ha:
                 try:
@@ -2059,7 +2059,7 @@ def create_listener_safe(self, request, context):
                     _ana_state = "inaccessible"
                     ret = rpc_nvmf.nvmf_subsystem_listener_set_ana_state(
                       self.spdk_rpc_client,
-                      nqn=request.nqn,
+                      nqn=request.subsystem_nqn,
                       ana_state=_ana_state,
                       trtype="TCP",
                       traddr=request.traddr,
@@ -2069,15 +2069,15 @@ def create_listener_safe(self, request, context):
 
                     # have been provided with ana state for this nqn prior to creation
                     # update optimized ana groups
-                    if self.ana_map[request.nqn]:
-                        for x in range (self.subsys_max_ns[request.nqn]):
+                    if self.ana_map[request.subsystem_nqn]:
+                        for x in range (self.subsys_max_ns[request.subsystem_nqn]):
                             ana_grp = x+1
-                            if ana_grp in self.ana_map[request.nqn] and self.ana_map[request.nqn][ana_grp] == pb2.ana_state.OPTIMIZED:
+                            if ana_grp in self.ana_map[request.subsystem_nqn] and self.ana_map[request.subsystem_nqn][ana_grp] == pb2.ana_state.OPTIMIZED:
                                 _ana_state = "optimized"
-                                self.logger.info(f"using ana_map: set listener on nqn : {request.nqn}  ana state : {_ana_state} for group : {ana_grp}")
+                                self.logger.info(f"using ana_map: set listener on nqn : {request.subsystem_nqn}  ana state : {_ana_state} for group : {ana_grp}")
                                 ret = rpc_nvmf.nvmf_subsystem_listener_set_ana_state(
                                   self.spdk_rpc_client,
-                                  nqn=request.nqn,
+                                  nqn=request.subsystem_nqn,
                                   ana_state=_ana_state,
                                   trtype="TCP",
                                   traddr=request.traddr,
@@ -2102,7 +2102,7 @@ def create_listener_safe(self, request, context):
                 try:
                     json_req = json_format.MessageToJson(
                         request, preserving_proto_field_name=True, including_default_value_fields=True)
-                    self.gateway_state.add_listener(request.nqn,
+                    self.gateway_state.add_listener(request.subsystem_nqn,
                                                     request.host_name,
                                                     "TCP", request.traddr,
                                                     request.trsvcid, json_req)
@@ -2114,8 +2114,8 @@ def create_listener_safe(self, request, context):
 
         return pb2.req_status(status=0, error_message=os.strerror(0))
 
-    def create_listener(self, request, context=None):
-        return self.execute_grpc_function(self.create_listener_safe, request, context)
+    def listener_create(self, request, context=None):
+        return self.execute_grpc_function(self.listener_create_safe, request, context)
 
     def remove_listener_from_state(self, nqn, host_name, traddr, port, context):
         if not context:
@@ -2134,7 +2134,7 @@ def remove_listener_from_state(self, nqn, host_name, traddr, port, context):
                     continue
                 try:
                     listener = json.loads(val)
-                    listener_nqn = listener["nqn"]
+                    listener_nqn = listener["subsystem_nqn"]
                     if listener_nqn != nqn:
                         self.logger.warning(f"Got subsystem {listener_nqn} instead of {nqn}, ignore")
                         continue
@@ -2165,12 +2165,12 @@ def remove_listener_from_state(self, nqn, host_name, traddr, port, context):
 
         return req_status
 
-    def delete_listener_safe(self, request, context):
+    def listener_delete_safe(self, request, context):
         """Deletes a listener from a subsystem at a given IP/Port."""
 
         ret = True
         traddr = GatewayUtils.escape_address_if_ipv6(request.traddr)
-        delete_listener_error_prefix = f"Listener {traddr}:{request.trsvcid} failed to delete from {request.nqn}"
+        delete_listener_error_prefix = f"Listener {traddr}:{request.trsvcid} failed to delete from {request.subsystem_nqn}"
 
         adrfam = GatewayEnumUtils.get_key_from_value(pb2.AddressFamily, request.adrfam)
         if adrfam == None:
@@ -2182,7 +2182,7 @@ def delete_listener_safe(self, request, context):
         host_msg = "all hosts" if request.host_name == "*" else f"host {request.host_name}"
 
         self.logger.info(f"Received request to delete TCP listener of {host_msg}"
-                         f" for subsystem {request.nqn} at"
+                         f" for subsystem {request.subsystem_nqn} at"
                          f" {traddr}:{request.trsvcid}{force_msg}, context: {context}")
 
         if request.host_name == "*" and not request.force:
@@ -2190,14 +2190,14 @@ def delete_listener_safe(self, request, context):
             self.logger.error(errmsg)
             return pb2.req_status(status=errno.EINVAL, error_message=errmsg)
 
-        if GatewayUtils.is_discovery_nqn(request.nqn):
+        if GatewayUtils.is_discovery_nqn(request.subsystem_nqn):
             errmsg=f"{delete_listener_error_prefix}. Can't delete a listener from a discovery subsystem"
             self.logger.error(errmsg)
             return pb2.req_status(status=errno.EINVAL, error_message=errmsg)
 
         if not request.force:
-            list_conn_req = pb2.list_connections_req(subsystem=request.nqn)
-            list_conn_ret = self.list_connections_safe(list_conn_req, context)
+            list_conn_req = pb2.connection_list_req(subsystem_nqn=request.subsystem_nqn)
+            list_conn_ret = self.connection_list_safe(list_conn_req, context)
             if list_conn_ret.status != 0:
                 errmsg=f"{delete_listener_error_prefix}. Can't verify there are no active connections for this address"
                 self.logger.error(errmsg)
@@ -2218,13 +2218,13 @@ def delete_listener_safe(self, request, context):
                 if request.host_name == self.host_name or request.force:
                     ret = rpc_nvmf.nvmf_subsystem_remove_listener(
                         self.spdk_rpc_client,
-                        nqn=request.nqn,
+                        nqn=request.subsystem_nqn,
                         trtype="TCP",
                         traddr=request.traddr,
                         trsvcid=str(request.trsvcid),
                         adrfam=adrfam,
                     )
-                    self.logger.info(f"delete_listener: {ret}")
+                    self.logger.info(f"remove_listener: {ret}")
                 else:
                     errmsg=f"{delete_listener_error_prefix}. Gateway's host name must match current host ({self.host_name}). You can continue to delete the listener by adding the `--force` parameter."
                     self.logger.error(f"{errmsg}")
@@ -2234,7 +2234,7 @@ def delete_listener_safe(self, request, context):
                 # It's OK for SPDK to fail in case we used a different host name, just continue to remove from OMAP
                 if request.host_name == self.host_name:
                     errmsg = f"{delete_listener_error_prefix}:\n{ex}"
-                    self.remove_listener_from_state(request.nqn, request.host_name,
+                    self.remove_listener_from_state(request.subsystem_nqn, request.host_name,
                                                     request.traddr, request.trsvcid, context)
                     resp = self.parse_json_exeption(ex)
                     status = errno.EINVAL
@@ -2247,33 +2247,33 @@ def delete_listener_safe(self, request, context):
             # Just in case SPDK failed with no exception
             if not ret:
                 self.logger.error(delete_listener_error_prefix)
-                self.remove_listener_from_state(request.nqn, request.host_name,
+                self.remove_listener_from_state(request.subsystem_nqn, request.host_name,
                                                 request.traddr, request.trsvcid, context)
                 return pb2.req_status(status=errno.EINVAL, error_message=delete_listener_error_prefix)
 
-            return self.remove_listener_from_state(request.nqn, request.host_name,
+            return self.remove_listener_from_state(request.subsystem_nqn, request.host_name,
                                                    request.traddr, request.trsvcid, context)
 
-    def delete_listener(self, request, context=None):
-        return self.execute_grpc_function(self.delete_listener_safe, request, context)
+    def listener_delete(self, request, context=None):
+        return self.execute_grpc_function(self.listener_delete_safe, request, context)
 
-    def list_listeners_safe(self, request, context):
+    def listener_list_safe(self, request, context):
         """List listeners."""
 
-        self.logger.info(f"Received request to list listeners for {request.subsystem}, context: {context}")
+        self.logger.info(f"Received request to list listeners for {request.subsystem_nqn}, context: {context}")
 
         listeners = []
         with self.omap_lock(context=context):
             state = self.gateway_state.local.get_state()
-            listener_prefix = GatewayState.build_partial_listener_key(request.subsystem)
+            listener_prefix = GatewayState.build_partial_listener_key(request.subsystem_nqn)
             for key, val in state.items():
                 if not key.startswith(listener_prefix):
                     continue
                 try:
                     listener = json.loads(val)
-                    nqn = listener["nqn"]
-                    if nqn != request.subsystem:
-                        self.logger.warning(f"Got subsystem {nqn} instead of {request.subsystem}, ignore")
+                    nqn = listener["subsystem_nqn"]
+                    if nqn != request.subsystem_nqn:
+                        self.logger.warning(f"Got subsystem {nqn} instead of {request.subsystem_nqn}, ignore")
                         continue
                     one_listener = pb2.listener_info(host_name = listener["host_name"],
                                                      trtype = "TCP",
@@ -2287,10 +2287,10 @@ def list_listeners_safe(self, request, context):
 
         return pb2.listeners_info(status = 0, error_message = os.strerror(0), listeners=listeners)
 
-    def list_listeners(self, request, context=None):
-        return self.execute_grpc_function(self.list_listeners_safe, request, context)
+    def listener_list(self, request, context=None):
+        return self.execute_grpc_function(self.listener_list_safe, request, context)
 
-    def list_subsystems_safe(self, request, context):
+    def subsystem_list_safe(self, request, context):
         """List subsystems."""
 
         ser_msg = ""
@@ -2307,7 +2307,7 @@ def list_subsystems_safe(self, request, context):
                 ret = rpc_nvmf.nvmf_get_subsystems(self.spdk_rpc_client, nqn=request.subsystem_nqn)
             else:
                 ret = rpc_nvmf.nvmf_get_subsystems(self.spdk_rpc_client)
-            self.logger.info(f"list_subsystems: {ret}")
+            self.logger.info(f"get_subsystems: {ret}")
         except Exception as ex:
             errmsg = f"Failure listing subsystems"
             self.logger.exception(errmsg)
@@ -2379,10 +2379,10 @@ def get_subsystems(self, request, context):
         with self.rpc_lock:
             return self.get_subsystems_safe(request, context)
 
-    def list_subsystems(self, request, context=None):
-        return self.execute_grpc_function(self.list_subsystems_safe, request, context)
+    def subsystem_list(self, request, context=None):
+        return self.execute_grpc_function(self.subsystem_list_safe, request, context)
 
-    def get_spdk_nvmf_log_flags_and_level_safe(self, request, context):
+    def spdk_nvmf_log_flags_and_level_get_safe(self, request, context):
         """Gets spdk nvmf log flags, log level and log print level"""
         self.logger.info(f"Received request to get SPDK nvmf log flags and level")
         log_flags = []
@@ -2416,10 +2416,10 @@ def get_spdk_nvmf_log_flags_and_level_safe(self, request, context):
             status = 0,
             error_message = os.strerror(0))
 
-    def get_spdk_nvmf_log_flags_and_level(self, request, context=None):
-        return self.execute_grpc_function(self.get_spdk_nvmf_log_flags_and_level_safe, request, context)
+    def spdk_nvmf_log_flags_and_level_get(self, request, context=None):
+        return self.execute_grpc_function(self.spdk_nvmf_log_flags_and_level_get_safe, request, context)
 
-    def set_spdk_nvmf_logs_safe(self, request, context):
+    def spdk_nvmf_logs_set_safe(self, request, context):
         """Enables spdk nvmf logs"""
         log_level = None
         print_level = None
@@ -2482,10 +2482,10 @@ def set_spdk_nvmf_logs_safe(self, request, context):
             errmsg = "Failure setting some SPDK nvmf log flags"
         return pb2.req_status(status=status, error_message=errmsg)
 
-    def set_spdk_nvmf_logs(self, request, context=None):
-        return self.execute_grpc_function(self.set_spdk_nvmf_logs_safe, request, context)
+    def spdk_nvmf_logs_set(self, request, context=None):
+        return self.execute_grpc_function(self.spdk_nvmf_logs_set_safe, request, context)
 
-    def disable_spdk_nvmf_logs_safe(self, request, context):
+    def spdk_nvmf_logs_disable_safe(self, request, context):
         """Disables spdk nvmf logs"""
         self.logger.info(f"Received request to disable SPDK nvmf logs")
 
@@ -2515,8 +2515,8 @@ def disable_spdk_nvmf_logs_safe(self, request, context):
             errmsg = "Failure in disable SPDK nvmf log flags"
         return pb2.req_status(status=status, error_message=errmsg)
 
-    def disable_spdk_nvmf_logs(self, request, context=None):
-        return self.execute_grpc_function(self.disable_spdk_nvmf_logs_safe, request, context)
+    def spdk_nvmf_logs_disable(self, request, context=None):
+        return self.execute_grpc_function(self.spdk_nvmf_logs_disable_safe, request, context)
 
     def parse_version(self, version):
         if not version:
@@ -2533,7 +2533,7 @@ def parse_version(self, version):
             return None
         return (v1, v2, v3)
 
-    def get_gateway_info_safe(self, request, context):
+    def gateway_info_get_safe(self, request, context):
         """Get gateway's info"""
 
         self.logger.info(f"Received request to get gateway's info")
@@ -2579,11 +2579,11 @@ def get_gateway_info_safe(self, request, context):
         log_func(f"Gateway's info:\n{ret}")
         return ret
 
-    def get_gateway_info(self, request, context=None):
+    def gateway_info_get(self, request, context=None):
         """Get gateway's info"""
-        return self.execute_grpc_function(self.get_gateway_info_safe, request, context)
+        return self.execute_grpc_function(self.gateway_info_get_safe, request, context)
 
-    def get_gateway_log_level(self, request, context=None):
+    def gateway_log_level_get(self, request, context=None):
         """Get gateway's log level"""
         try:
             log_level = GatewayEnumUtils.get_key_from_value(pb2.GwLogLevel, self.logger.level)
@@ -2594,7 +2594,7 @@ def get_gateway_log_level(self, request, context=None):
         self.logger.info(f"Received request to get gateway's log level. Level is {log_level}")
         return pb2.gateway_log_level_info(status = 0, error_message=os.strerror(0), log_level=log_level)
 
-    def set_gateway_log_level(self, request, context=None):
+    def gateway_log_level_set(self, request, context=None):
         """Set gateway's log level"""
 
         log_level = GatewayEnumUtils.get_key_from_value(pb2.GwLogLevel, request.log_level)
diff --git a/control/prometheus.py b/control/prometheus.py
index 4d3886b1..d1703284 100644
--- a/control/prometheus.py
+++ b/control/prometheus.py
@@ -138,8 +138,8 @@ def __init__(self, spdk_rpc_client, config, gateway_rpc):
     def _get_gw_metadata(self):
         """Fetch Gateway metadata"""
         ver = os.getenv("NVMEOF_VERSION")
-        req = pb2.get_gateway_info_req(cli_version=ver)
-        metadata = self.gateway_rpc.get_gateway_info(req)
+        req = pb2.gateway_info_get_req(cli_version=ver)
+        metadata = self.gateway_rpc.gateway_info_get(req)
 
         # Since empty values result in a missing label, when the group name is not
         # defined _null_ is used to ensure any promql queries will always work against
@@ -170,11 +170,11 @@ def _get_subsystems(self):
         return subsystems_info.subsystems
 
     @timer
-    def _list_subsystems(self):
+    def _subsystem_list(self):
         """Fetch abbreviated subsystem information used by the CLI"""
-        resp = self.gateway_rpc.list_subsystems(pb2.list_subsystems_req())
+        resp = self.gateway_rpc.subsystem_list(pb2.subsystem_list_req())
         if resp.status != 0:
-            logger.error(f"Exporter failed to execute list_subsystems: {resp.error_message}")
+            logger.error(f"Exporter failed to execute subsystem_list: {resp.error_message}")
             return {}
 
         return {subsys.nqn: subsys for subsys in resp.subsystems}
@@ -184,7 +184,7 @@ def _get_connection_map(self, subsystem_list):
         """Fetch connection information for all defined subsystems"""
         connection_map = {}
         for subsys in subsystem_list:
-            resp = self.gateway_rpc.list_connections(pb2.list_connections_req(subsystem=subsys.nqn))
+            resp = self.gateway_rpc.connection_list(pb2.connection_list_req(subsystem_nqn=subsys.nqn))
             if resp.status != 0:
                 logger.error(f"Exporter failed to fetch connection info for {subsys.nqn}: {resp.error_message}")
                 continue
@@ -197,7 +197,7 @@ def _get_data(self):
         self.bdev_io_stats = self._get_bdev_io_stats()
         self.spdk_thread_stats = self._get_spdk_thread_stats()
         self.subsystems = self._get_subsystems()
-        self.subsystems_cli = self._list_subsystems()
+        self.subsystems_cli = self._subsystem_list()
         self.connections = self._get_connection_map(self.subsystems)
 
     @ttl
diff --git a/control/proto/gateway.proto b/control/proto/gateway.proto
index 3b44515e..e2bae97d 100644
--- a/control/proto/gateway.proto
+++ b/control/proto/gateway.proto
@@ -37,13 +37,13 @@ service Gateway {
 	rpc namespace_add(namespace_add_req) returns (nsid_status) {}
 
 	// Creates a subsystem
-	rpc create_subsystem(create_subsystem_req) returns(req_status) {}
+	rpc subsystem_create(subsystem_create_req) returns(req_status) {}
 
 	// Deletes a subsystem
-	rpc delete_subsystem(delete_subsystem_req) returns(req_status) {}
+	rpc subsystem_delete(subsystem_delete_req) returns(req_status) {}
 
 	// List namespaces
-	rpc list_namespaces(list_namespaces_req) returns(namespaces_info) {}
+	rpc namespace_list(namespace_list_req) returns(namespaces_info) {}
 
 	// Resizes a namespace
 	rpc namespace_resize(namespace_resize_req) returns (req_status) {}
@@ -61,28 +61,28 @@ service Gateway {
 	rpc namespace_delete(namespace_delete_req) returns (req_status) {}
 
 	// Adds a host to a subsystem
-	rpc add_host(add_host_req) returns (req_status) {}
+	rpc host_add(host_add_req) returns (req_status) {}
 
 	// Removes a host from a subsystem
-	rpc remove_host(remove_host_req) returns (req_status) {}
+	rpc host_remove(host_remove_req) returns (req_status) {}
 
 	// List hosts
-	rpc list_hosts(list_hosts_req) returns(hosts_info) {}
+	rpc host_list(host_list_req) returns(hosts_info) {}
 
 	// List connections
-	rpc list_connections(list_connections_req) returns(connections_info) {}
+	rpc connection_list(connection_list_req) returns(connections_info) {}
 
 	// Creates a listener for a subsystem at a given IP/Port
-	rpc create_listener(create_listener_req) returns(req_status) {}
+	rpc listener_create(listener_create_req) returns(req_status) {}
 
 	// Deletes a listener from a subsystem at a given IP/Port
-	rpc delete_listener(delete_listener_req) returns(req_status) {}
+	rpc listener_delete(listener_delete_req) returns(req_status) {}
 
 	// List listeners
-	rpc list_listeners(list_listeners_req) returns(listeners_info) {}
+	rpc listener_list(listener_list_req) returns(listeners_info) {}
 
 	// List subsystems
-	rpc list_subsystems(list_subsystems_req) returns(subsystems_info_cli) {}
+	rpc subsystem_list(subsystem_list_req) returns(subsystems_info_cli) {}
 
         // Gets subsystems
         rpc get_subsystems(get_subsystems_req) returns(subsystems_info) {}
@@ -91,22 +91,22 @@ service Gateway {
 	rpc set_ana_state(ana_info) returns(req_status) {}
 
 	// Gets spdk nvmf log flags and level
-	rpc get_spdk_nvmf_log_flags_and_level(get_spdk_nvmf_log_flags_and_level_req) returns(spdk_nvmf_log_flags_and_level_info) {}
+	rpc spdk_nvmf_log_flags_and_level_get(spdk_nvmf_log_flags_and_level_get_req) returns(spdk_nvmf_log_flags_and_level_info) {}
 
         // Disables spdk nvmf logs
-        rpc disable_spdk_nvmf_logs(disable_spdk_nvmf_logs_req) returns(req_status) {}
+        rpc spdk_nvmf_logs_disable(spdk_nvmf_logs_disable_req) returns(req_status) {}
 
 	// Set spdk nvmf logs
-	rpc set_spdk_nvmf_logs(set_spdk_nvmf_logs_req) returns(req_status) {}
+	rpc spdk_nvmf_logs_set(spdk_nvmf_logs_set_req) returns(req_status) {}
 
 	// Get gateway info
-	rpc get_gateway_info(get_gateway_info_req) returns(gateway_info) {}
+	rpc gateway_info_get(gateway_info_get_req) returns(gateway_info) {}
 
 	// Get gateway log level
-	rpc get_gateway_log_level(get_gateway_log_level_req) returns(gateway_log_level_info) {}
+	rpc gateway_log_level_get(gateway_log_level_get_req) returns(gateway_log_level_info) {}
 
 	// Set gateway log level
-	rpc set_gateway_log_level(set_gateway_log_level_req) returns(req_status) {}
+	rpc gateway_log_level_set(gateway_log_level_set_req) returns(req_status) {}
 }
 
 // Request messages
@@ -118,7 +118,7 @@ message namespace_add_req {
 	optional uint32 nsid = 4;
 	uint32 block_size = 5;
 	optional string uuid = 6;
-	optional int32 anagrpid = 7;
+	optional int32 load_balancing_group = 7;
 	optional bool create_image = 8;
 	optional uint64 size = 9;
 	optional bool force = 10;
@@ -151,7 +151,13 @@ message namespace_change_load_balancing_group_req {
 	string subsystem_nqn = 1;
 	optional uint32 nsid = 2;
 	optional string uuid = 3;
-	int32 anagrpid = 4;
+	int32 load_balancing_group = 4;
+}
+
+message namespace_list_req {
+	string subsystem_nqn = 1;
+	optional uint32 nsid = 2;
+	optional string uuid = 3;
 }
 
 message namespace_delete_req {
@@ -160,52 +166,46 @@ message namespace_delete_req {
 	optional string uuid = 3;
 }
 
-message create_subsystem_req {
+message subsystem_create_req {
 	string subsystem_nqn = 1;
 	string serial_number = 2;
 	optional uint32 max_namespaces = 3;
 	bool enable_ha = 4;
 }
 
-message delete_subsystem_req {
+message subsystem_delete_req {
 	string subsystem_nqn = 1;
 	optional bool force = 2;
 }
 
-message list_namespaces_req {
-	string subsystem = 1;
-	optional uint32 nsid = 2;
-	optional string uuid = 3;
-}
-
-message add_host_req {
+message host_add_req {
 	string subsystem_nqn = 1;
 	string host_nqn = 2;
 }
 
-message remove_host_req {
+message host_remove_req {
 	string subsystem_nqn = 1;
 	string host_nqn = 2;
 }
 
-message list_hosts_req {
-	string subsystem = 1;
+message host_list_req {
+	string subsystem_nqn = 1;
 }
 
-message list_connections_req {
-	string subsystem = 1;
+message connection_list_req {
+	string subsystem_nqn = 1;
 }
 
-message create_listener_req {
-	string nqn = 1;
+message listener_create_req {
+	string subsystem_nqn = 1;
 	string host_name = 2;
 	string traddr = 3;
 	optional AddressFamily adrfam = 5;
 	optional uint32 trsvcid = 6;
 }
 
-message delete_listener_req {
-	string nqn = 1;
+message listener_delete_req {
+	string subsystem_nqn = 1;
 	string host_name = 2;
 	string traddr = 3;
 	optional AddressFamily adrfam = 5;
@@ -213,11 +213,11 @@ message delete_listener_req {
 	optional bool force = 7;
 }
 
-message list_listeners_req {
-	string subsystem = 1;
+message listener_list_req {
+	string subsystem_nqn = 1;
 }
 
-message list_subsystems_req {
+message subsystem_list_req {
 	optional string subsystem_nqn = 1;
 	optional string serial_number = 2;
 }
@@ -225,25 +225,25 @@ message list_subsystems_req {
 message get_subsystems_req {
 }
 
-message get_spdk_nvmf_log_flags_and_level_req {
+message spdk_nvmf_log_flags_and_level_get_req {
 }
 
-message disable_spdk_nvmf_logs_req {
+message spdk_nvmf_logs_disable_req {
 }
 
-message set_spdk_nvmf_logs_req {
+message spdk_nvmf_logs_set_req {
 	optional LogLevel log_level = 1;
 	optional LogLevel print_level = 2;
 }
 
-message get_gateway_info_req {
+message gateway_info_get_req {
 	optional string cli_version = 1;
 }
 
-message get_gateway_log_level_req {
+message gateway_log_level_get_req {
 }
 
-message set_gateway_log_level_req {
+message gateway_log_level_set_req {
 	GwLogLevel log_level = 1;
 }
 
diff --git a/control/server.py b/control/server.py
index 63253a89..f803f386 100644
--- a/control/server.py
+++ b/control/server.py
@@ -463,13 +463,13 @@ def gateway_rpc_caller(self, requests, is_add_req):
         for key, val in requests.items():
             if key.startswith(GatewayState.SUBSYSTEM_PREFIX):
                 if is_add_req:
-                    req = json_format.Parse(val, pb2.create_subsystem_req())
-                    self.gateway_rpc.create_subsystem(req)
+                    req = json_format.Parse(val, pb2.subsystem_create_req())
+                    self.gateway_rpc.subsystem_create(req)
                 else:
                     req = json_format.Parse(val,
-                                            pb2.delete_subsystem_req(),
+                                            pb2.subsystem_delete_req(),
                                             ignore_unknown_fields=True)
-                    self.gateway_rpc.delete_subsystem(req)
+                    self.gateway_rpc.subsystem_delete(req)
             elif key.startswith(GatewayState.NAMESPACE_PREFIX):
                 if is_add_req:
                     req = json_format.Parse(val, pb2.namespace_add_req())
@@ -488,15 +488,15 @@ def gateway_rpc_caller(self, requests, is_add_req):
                     pass
             elif key.startswith(GatewayState.HOST_PREFIX):
                 if is_add_req:
-                    req = json_format.Parse(val, pb2.add_host_req())
-                    self.gateway_rpc.add_host(req)
+                    req = json_format.Parse(val, pb2.host_add_req())
+                    self.gateway_rpc.host_add(req)
                 else:
-                    req = json_format.Parse(val, pb2.remove_host_req(), ignore_unknown_fields=True)
-                    self.gateway_rpc.remove_host(req)
+                    req = json_format.Parse(val, pb2.host_remove_req(), ignore_unknown_fields=True)
+                    self.gateway_rpc.host_remove(req)
             elif key.startswith(GatewayState.LISTENER_PREFIX):
                 if is_add_req:
-                    req = json_format.Parse(val, pb2.create_listener_req())
-                    self.gateway_rpc.create_listener(req)
+                    req = json_format.Parse(val, pb2.listener_create_req())
+                    self.gateway_rpc.listener_create(req)
                 else:
-                    req = json_format.Parse(val, pb2.delete_listener_req(), ignore_unknown_fields=True)
-                    self.gateway_rpc.delete_listener(req)
+                    req = json_format.Parse(val, pb2.listener_delete_req(), ignore_unknown_fields=True)
+                    self.gateway_rpc.listener_delete(req)
diff --git a/tests/test_cli.py b/tests/test_cli.py
index daabd524..8796fe9b 100644
--- a/tests/test_cli.py
+++ b/tests/test_cli.py
@@ -72,27 +72,27 @@ def test_get_subsystems_ipv6(self, caplog, gateway):
         cli(["--server-address", server_addr_ipv6, "subsystem", "list"])
         assert "No subsystems" in caplog.text
 
-    def test_get_gateway_info(self, caplog, gateway):
+    def test_gateway_info_get(self, caplog, gateway):
         gw, stub = gateway
         caplog.clear()
-        gw_info_req = pb2.get_gateway_info_req(cli_version="0.0.1")
-        ret = stub.get_gateway_info(gw_info_req)
+        gw_info_req = pb2.gateway_info_get_req(cli_version="0.0.1")
+        ret = stub.gateway_info_get(gw_info_req)
         assert ret.status != 0
         assert "is older than gateway" in caplog.text
         caplog.clear()
-        gw_info_req = pb2.get_gateway_info_req()
-        ret = stub.get_gateway_info(gw_info_req)
+        gw_info_req = pb2.gateway_info_get_req()
+        ret = stub.gateway_info_get(gw_info_req)
         assert "No CLI version specified" in caplog.text
         assert ret.status == 0
         caplog.clear()
-        gw_info_req = pb2.get_gateway_info_req(cli_version="0.0.1.4")
-        ret = stub.get_gateway_info(gw_info_req)
+        gw_info_req = pb2.gateway_info_get_req(cli_version="0.0.1.4")
+        ret = stub.gateway_info_get(gw_info_req)
         assert "Can't parse version" in caplog.text
         assert "Invalid CLI version" in caplog.text
         assert ret.status == 0
         caplog.clear()
-        gw_info_req = pb2.get_gateway_info_req(cli_version="0.X.4")
-        ret = stub.get_gateway_info(gw_info_req)
+        gw_info_req = pb2.gateway_info_get_req(cli_version="0.X.4")
+        ret = stub.gateway_info_get(gw_info_req)
         assert "Can't parse version" in caplog.text
         assert "Invalid CLI version" in caplog.text
         assert ret.status == 0
@@ -102,8 +102,8 @@ def test_get_gateway_info(self, caplog, gateway):
         save_addr = gw.config.config["gateway"]["addr"]
         gw.config.config["gateway"]["port"] = "6789"
         gw.config.config["gateway"]["addr"] = "10.10.10.10"
-        gw_info_req = pb2.get_gateway_info_req(cli_version=cli_ver)
-        ret = stub.get_gateway_info(gw_info_req)
+        gw_info_req = pb2.gateway_info_get_req(cli_version=cli_ver)
+        ret = stub.gateway_info_get(gw_info_req)
         assert ret.status == 0
         assert f'version: "{cli_ver}"' in caplog.text
         assert 'port: "6789"' in caplog.text
@@ -542,7 +542,7 @@ def test_namespace_io_stats(self, caplog, gateway):
         assert rc == 2
 
     @pytest.mark.parametrize("host", host_list)
-    def test_add_host(self, caplog, host):
+    def test_host_add(self, caplog, host):
         caplog.clear()
         rc = 0
         try:
@@ -559,7 +559,7 @@ def test_add_host(self, caplog, host):
         else:
             assert f"Adding host {host} to {subsystem}: Successful" in caplog.text
 
-    def test_add_host_invalid_nqn(self, caplog):
+    def test_host_add_invalid_nqn(self, caplog):
         caplog.clear()
         cli(["host", "add", "--subsystem", subsystem, "--host", "nqn.2016"])
         assert f'NQN "nqn.2016" is too short, minimal length is 11' in caplog.text
@@ -663,7 +663,7 @@ def test_create_listener_on_discovery(self, caplog, listener, gateway):
 
 class TestDelete:
     @pytest.mark.parametrize("host", host_list)
-    def test_remove_host(self, caplog, host, gateway):
+    def test_host_remove(self, caplog, host, gateway):
         caplog.clear()
         rc = 0
         try:
@@ -755,6 +755,7 @@ def test_remove_namespace(self, caplog, gateway):
                     break
             except KeyError:
                 print(f"Couldn't find field name in: {b}")
+                print(f"bdev list is: {bdev_list}")
         assert bdev_found
         caplog.clear()
         del_ns_req = pb2.namespace_delete_req(subsystem_nqn=subsystem)
@@ -782,7 +783,7 @@ def test_remove_namespace(self, caplog, gateway):
         cli(["namespace", "del", "--subsystem", subsystem, "--nsid", nsid_ipv6])
         assert f"Deleting namespace {nsid_ipv6} from {subsystem}: Successful" in caplog.text
 
-    def test_delete_subsystem(self, caplog, gateway):
+    def test_subsystem_delete(self, caplog, gateway):
         caplog.clear()
         cli(["subsystem", "del", "--subsystem", subsystem])
         assert f"Failure deleting subsystem {subsystem}: Namespace 2 is still using the subsystem"
@@ -796,7 +797,7 @@ def test_delete_subsystem(self, caplog, gateway):
         cli(["subsystem", "list"])
         assert "No subsystems" in caplog.text
 
-    def test_delete_subsystem_with_discovery_nqn(self, caplog, gateway):
+    def test_subsystem_delete_with_discovery_nqn(self, caplog, gateway):
         caplog.clear()
         rc = 0
         try:
@@ -862,7 +863,7 @@ def test_remove_namespace_ana(self, caplog, gateway):
         cli(["namespace", "del", "--subsystem", subsystem, "--nsid", nsid])
         assert f"Deleting namespace {nsid} from {subsystem}: Successful" in caplog.text
 
-    def test_delete_subsystem_ana(self, caplog, gateway):
+    def test_subsystem_delete_ana(self, caplog, gateway):
         caplog.clear()
         cli(["subsystem", "del", "--subsystem", subsystem])
         assert f"Deleting subsystem {subsystem}: Successful" in caplog.text
diff --git a/tests/test_multi_gateway.py b/tests/test_multi_gateway.py
index a1936351..3bbf94e9 100644
--- a/tests/test_multi_gateway.py
+++ b/tests/test_multi_gateway.py
@@ -73,22 +73,22 @@ def test_multi_gateway_coordination(config, image, conn):
     pool = config.get("ceph", "pool")
 
     # Send requests to create a subsystem with one namespace to GatewayA
-    subsystem_req = pb2.create_subsystem_req(subsystem_nqn=nqn,
+    subsystem_req = pb2.subsystem_create_req(subsystem_nqn=nqn,
                                              serial_number=serial, enable_ha=True)
     namespace_req = pb2.namespace_add_req(subsystem_nqn=nqn,
                                           rbd_pool_name=pool,
                                           rbd_image_name=image,
                                           block_size=4096,
                                           nsid=nsid, create_image=True, size=16*1024*1024)
-    list_subsystems_req = pb2.list_subsystems_req()
-    list_namespaces_req = pb2.list_namespaces_req(subsystem=nqn)
-    ret_subsystem = stubA.create_subsystem(subsystem_req)
+    subsystem_list_req = pb2.subsystem_list_req()
+    namespace_list_req = pb2.namespace_list_req(subsystem_nqn=nqn)
+    ret_subsystem = stubA.subsystem_create(subsystem_req)
     ret_namespace = stubA.namespace_add(namespace_req)
     assert ret_subsystem.status == 0
     assert ret_namespace.status == 0
 
     nsListA = json.loads(json_format.MessageToJson(
-        stubA.list_namespaces(list_namespaces_req),
+        stubA.namespace_list(namespace_list_req),
         preserving_proto_field_name=True, including_default_value_fields=True))['namespaces']
     assert len(nsListA) == 1
     assert nsListA[0]["nsid"] == nsid
@@ -98,7 +98,7 @@ def test_multi_gateway_coordination(config, image, conn):
     if update_notify:
         time.sleep(1)
         listB = json.loads(json_format.MessageToJson(
-            stubB.list_subsystems(list_subsystems_req),
+            stubB.subsystem_list(subsystem_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
         assert len(listB) == num_subsystems
         assert listB[num_subsystems-1]["nqn"] == nqn
@@ -106,7 +106,7 @@ def test_multi_gateway_coordination(config, image, conn):
         assert listB[num_subsystems-1]["namespace_count"] == 1
 
         nsListB = json.loads(json_format.MessageToJson(
-            stubB.list_namespaces(list_namespaces_req),
+            stubB.namespace_list(namespace_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))['namespaces']
         assert len(nsListB) == 1
         assert nsListB[0]["nsid"] == nsid
@@ -117,14 +117,14 @@ def test_multi_gateway_coordination(config, image, conn):
     # Periodic update
     time.sleep(update_interval_sec + 1)
     listB = json.loads(json_format.MessageToJson(
-        stubB.list_subsystems(list_subsystems_req),
+        stubB.subsystem_list(subsystem_list_req),
         preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
     assert len(listB) == num_subsystems
     assert listB[num_subsystems-1]["nqn"] == nqn
     assert listB[num_subsystems-1]["serial_number"] == serial
     assert listB[num_subsystems-1]["namespace_count"] == 1
     nsListB = json.loads(json_format.MessageToJson(
-        stubB.list_namespaces(list_namespaces_req),
+        stubB.namespace_list(namespace_list_req),
         preserving_proto_field_name=True, including_default_value_fields=True))['namespaces']
     assert len(nsListB) == 1
     assert nsListB[0]["nsid"] == nsid
diff --git a/tests/test_namespaces.py b/tests/test_namespaces.py
index 065fea15..91200b33 100644
--- a/tests/test_namespaces.py
+++ b/tests/test_namespaces.py
@@ -86,18 +86,18 @@ def delete_namespace(stub, nsid):
     ret_del_namespace = stub.namespace_delete(del_ns_req)
     assert ret_del_namespace.status == 0
 
-def create_subsystem(stub, nqn, max_ns):
-    subsystem_req = pb2.create_subsystem_req(subsystem_nqn=nqn, max_namespaces=max_ns, enable_ha=True)
-    ret_subsystem = stub.create_subsystem(subsystem_req)
+def subsystem_create(stub, nqn, max_ns):
+    subsystem_req = pb2.subsystem_create_req(subsystem_nqn=nqn, max_namespaces=max_ns, enable_ha=True)
+    ret_subsystem = stub.subsystem_create(subsystem_req)
     assert ret_subsystem.status == 0
 
-def create_listener(stub, nqn, name, addr, port):
-    listener_req = pb2.create_listener_req(nqn=nqn,
+def listener_create(stub, nqn, name, addr, port):
+    listener_req = pb2.listener_create_req(subsystem_nqn=nqn,
                                            host_name=name,
                                            adrfam="ipv4",
                                            traddr=addr,
                                            trsvcid=port)
-    listener_ret = stub.create_listener(listener_req)
+    listener_ret = stub.listener_create(listener_req)
     assert listener_ret.status == 0
 
 def wait_for_update():
@@ -119,17 +119,17 @@ def test_create_subsystem_and_namespaces(config, image, conn):
 
     # Send requests to create a subsystem to GatewayA
     max_ns = namespace_count * run_count + 10
-    create_subsystem(stubA, subsystem_nqn, max_ns)
-    list_namespaces_req = pb2.list_namespaces_req(subsystem=subsystem_nqn)
+    subsystem_create(stubA, subsystem_nqn, max_ns)
+    namespace_list_req = pb2.namespace_list_req(subsystem_nqn=subsystem_nqn)
     listA = json.loads(json_format.MessageToJson(
-        stubA.list_subsystems(pb2.list_subsystems_req()),
+        stubA.subsystem_list(pb2.subsystem_list_req()),
         preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
     assert len(listA) == 2
     assert listA[1]["nqn"] == subsystem_nqn
 
     wait_for_update()
     listB = json.loads(json_format.MessageToJson(
-        stubB.list_subsystems(pb2.list_subsystems_req()),
+        stubB.subsystem_list(pb2.subsystem_list_req()),
         preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
 
     assert len(listB) == 2
@@ -138,8 +138,8 @@ def test_create_subsystem_and_namespaces(config, image, conn):
 
     wait_for_update()
 
-    create_listener(stubA, subsystem_nqn, gwA.host_name, "127.0.0.1", 5101)
-    create_listener(stubB, subsystem_nqn, gwB.host_name, "127.0.0.1", 5102)
+    listener_create(stubA, subsystem_nqn, gwA.host_name, "127.0.0.1", 5101)
+    listener_create(stubB, subsystem_nqn, gwB.host_name, "127.0.0.1", 5102)
 
     wait_for_update()
 
@@ -152,7 +152,7 @@ def test_create_subsystem_and_namespaces(config, image, conn):
             create_namespace(stubB, pool, image, nsid)
 
         time.sleep(0.5)
-        create_subsystem(stubA, f"{subsystem_nqn}A{nsid}", 256)
+        subsystem_create(stubA, f"{subsystem_nqn}A{nsid}", 256)
 
         for ns in range(int(namespace_count / 2), namespace_count):
             nsid += 1
@@ -160,23 +160,23 @@ def test_create_subsystem_and_namespaces(config, image, conn):
             create_namespace(stubB, f"{pool}2", f"{image}2", nsid)
 
         time.sleep(0.5)
-        create_subsystem(stubA, f"{subsystem_nqn}B{nsid}", 256)
+        subsystem_create(stubA, f"{subsystem_nqn}B{nsid}", 256)
 
         listB = json.loads(json_format.MessageToJson(
-            stubB.list_subsystems(pb2.list_subsystems_req()),
+            stubB.subsystem_list(pb2.subsystem_list_req()),
             preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
         assert listB[1]["namespace_count"] == ns_count
         nsListB = json.loads(json_format.MessageToJson(
-            stubB.list_namespaces(list_namespaces_req),
+            stubB.namespace_list(namespace_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))['namespaces']
         assert len(nsListB) == ns_count
         wait_for_update()
         listA = json.loads(json_format.MessageToJson(
-            stubA.list_subsystems(pb2.list_subsystems_req()),
+            stubA.subsystem_list(pb2.subsystem_list_req()),
             preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
         assert listA[1]["namespace_count"] == ns_count
         nsListA = json.loads(json_format.MessageToJson(
-            stubA.list_namespaces(list_namespaces_req),
+            stubA.namespace_list(namespace_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))['namespaces']
         assert len(nsListA) == ns_count
 
@@ -185,22 +185,22 @@ def test_create_subsystem_and_namespaces(config, image, conn):
             delete_namespace(stubB, run * namespace_count + ns)
 
         time.sleep(0.5)
-        create_subsystem(stubA, f"{subsystem_nqn}C{nsid}", 256)
+        subsystem_create(stubA, f"{subsystem_nqn}C{nsid}", 256)
 
         listB = json.loads(json_format.MessageToJson(
-            stubB.list_subsystems(pb2.list_subsystems_req()),
+            stubB.subsystem_list(pb2.subsystem_list_req()),
             preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
         assert listB[1]["namespace_count"] == ns_count
         nsListB = json.loads(json_format.MessageToJson(
-            stubB.list_namespaces(list_namespaces_req),
+            stubB.namespace_list(namespace_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))['namespaces']
         assert len(nsListB) == ns_count
         wait_for_update()
         listA = json.loads(json_format.MessageToJson(
-            stubA.list_subsystems(pb2.list_subsystems_req()),
+            stubA.subsystem_list(pb2.subsystem_list_req()),
             preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
         assert listA[1]["namespace_count"] == ns_count
         nsListA = json.loads(json_format.MessageToJson(
-            stubA.list_namespaces(list_namespaces_req),
+            stubA.namespace_list(namespace_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))['namespaces']
         assert len(nsListA) == ns_count
diff --git a/tests/test_nsid.py b/tests/test_nsid.py
index 01f78dcf..74ab891c 100644
--- a/tests/test_nsid.py
+++ b/tests/test_nsid.py
@@ -75,14 +75,14 @@ def test_multi_gateway_namespace_ids(config, image, caplog):
         # Send requests to create a subsystem on GatewayA
         caplog.clear()
         subsystem = f"{subsystem_prefix}PPP"
-        subsystem_add_req = pb2.create_subsystem_req(subsystem_nqn=subsystem)
-        ret_subsystem = stubA.create_subsystem(subsystem_add_req)
+        subsystem_add_req = pb2.subsystem_create_req(subsystem_nqn=subsystem)
+        ret_subsystem = stubA.subsystem_create(subsystem_add_req)
         assert ret_subsystem.status != 0
         assert "HA must be enabled for subsystems" in caplog.text
         caplog.clear()
         subsystem = f"{subsystem_prefix}WWW"
-        subsystem_add_req = pb2.create_subsystem_req(subsystem_nqn=subsystem, enable_ha=True)
-        ret_subsystem = stubA.create_subsystem(subsystem_add_req)
+        subsystem_add_req = pb2.subsystem_create_req(subsystem_nqn=subsystem, enable_ha=True)
+        ret_subsystem = stubA.subsystem_create(subsystem_add_req)
         assert ret_subsystem.status == 0
         assert f"create_subsystem {subsystem}: True" in caplog.text
         assert f"Failure creating subsystem {subsystem}" not in caplog.text
@@ -102,9 +102,9 @@ def test_multi_gateway_namespace_ids(config, image, caplog):
         assert ret_ns.status == 0
         time.sleep(10)
 
-        namespace_list_req = pb2.list_namespaces_req(subsystem=subsystem)
+        namespace_list_req = pb2.namespace_list_req(subsystem_nqn=subsystem)
         listA = json.loads(json_format.MessageToJson(
-            stubA.list_namespaces(namespace_list_req),
+            stubA.namespace_list(namespace_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))
         assert listA["status"] == 0
         assert len(listA["namespaces"]) == 2
@@ -118,7 +118,7 @@ def test_multi_gateway_namespace_ids(config, image, caplog):
         imgA2 = listA["namespaces"][1]["rbd_image_name"]
         time.sleep(10)
         listB = json.loads(json_format.MessageToJson(
-            stubB.list_namespaces(namespace_list_req),
+            stubB.namespace_list(namespace_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))
         assert listB["status"] == 0
         assert len(listB["namespaces"]) == 2
@@ -156,7 +156,7 @@ def test_multi_gateway_namespace_ids(config, image, caplog):
         stubB = pb2_grpc.GatewayStub(channelB)
         time.sleep(10)
         listB = json.loads(json_format.MessageToJson(
-            stubB.list_namespaces(namespace_list_req),
+            stubB.namespace_list(namespace_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))
         assert listB["status"] == 0
         assert len(listB["namespaces"]) == 2
diff --git a/tests/test_omap_lock.py b/tests/test_omap_lock.py
index 3bc15804..e5b093f6 100644
--- a/tests/test_omap_lock.py
+++ b/tests/test_omap_lock.py
@@ -135,8 +135,8 @@ def build_host_nqn(i):
 
 def create_resource_by_index(stub, i, caplog):
     subsystem = f"{subsystem_prefix}{i}"
-    subsystem_req = pb2.create_subsystem_req(subsystem_nqn=subsystem, enable_ha=True)
-    ret_subsystem = stub.create_subsystem(subsystem_req)
+    subsystem_req = pb2.subsystem_create_req(subsystem_nqn=subsystem, enable_ha=True)
+    ret_subsystem = stub.subsystem_create(subsystem_req)
     assert ret_subsystem.status == 0
     if caplog != None:
         assert f"create_subsystem {subsystem}: True" in caplog.text
@@ -147,15 +147,15 @@ def create_resource_by_index(stub, i, caplog):
     ret_namespace = stub.namespace_add(namespace_req)
     assert ret_namespace.status == 0
     hostnqn = build_host_nqn(i)
-    host_req = pb2.add_host_req(subsystem_nqn=subsystem, host_nqn=hostnqn)
-    ret_host = stub.add_host(host_req)
+    host_req = pb2.host_add_req(subsystem_nqn=subsystem, host_nqn=hostnqn)
+    ret_host = stub.host_add(host_req)
     assert ret_host.status == 0
-    host_req = pb2.add_host_req(subsystem_nqn=subsystem, host_nqn="*")
-    ret_host = stub.add_host(host_req)
+    host_req = pb2.host_add_req(subsystem_nqn=subsystem, host_nqn="*")
+    ret_host = stub.host_add(host_req)
     assert ret_host.status == 0
     if caplog != None:
         assert f"add_host {hostnqn}: True" in caplog.text
-        assert "add_host *: True" in caplog.text
+        assert f"allow_any_host: True" in caplog.text
         assert f"Failure allowing open host access to {subsystem}" not in caplog.text
         assert f"Failure adding host {hostnqn} to {subsystem}" not in caplog.text
 
@@ -187,25 +187,25 @@ def test_multi_gateway_omap_reread(config, conn_omap_reread, caplog):
     num_subsystems = 2
 
     # Send requests to create a subsystem with one namespace to GatewayA
-    subsystem_req = pb2.create_subsystem_req(subsystem_nqn=nqn, serial_number=serial, enable_ha=True)
+    subsystem_req = pb2.subsystem_create_req(subsystem_nqn=nqn, serial_number=serial, enable_ha=True)
     namespace_req = pb2.namespace_add_req(subsystem_nqn=nqn, nsid=nsid,
                                           rbd_pool_name=pool, rbd_image_name=image, block_size=4096,
                                           create_image=True, size=16*1024*1024, force=True)
 
-    subsystem_list_req = pb2.list_subsystems_req()
-    ret_subsystem = stubA.create_subsystem(subsystem_req)
+    subsystem_list_req = pb2.subsystem_list_req()
+    ret_subsystem = stubA.subsystem_create(subsystem_req)
     assert ret_subsystem.status == 0
     ret_namespace = stubA.namespace_add(namespace_req)
     assert ret_namespace.status == 0
 
     # Until we create some resource on GW-B it shouldn't still have the resrouces created on GW-A, only the discovery subsystem
     listB = json.loads(json_format.MessageToJson(
-        stubB.list_subsystems(subsystem_list_req),
+        stubB.subsystem_list(subsystem_list_req),
         preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
     assert len(listB) == 1
 
     listA = json.loads(json_format.MessageToJson(
-        stubA.list_subsystems(subsystem_list_req),
+        stubA.subsystem_list(subsystem_list_req),
         preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
     assert len(listA) == num_subsystems
 
@@ -219,7 +219,7 @@ def test_multi_gateway_omap_reread(config, conn_omap_reread, caplog):
 
     # Make sure that after reading the OMAP file GW-B has the subsystem and namespace created on GW-A
     listB = json.loads(json_format.MessageToJson(
-        stubB.list_subsystems(subsystem_list_req),
+        stubB.subsystem_list(subsystem_list_req),
         preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
     assert len(listB) == num_subsystems
     assert listB[num_subsystems-1]["nqn"] == nqn
@@ -268,15 +268,15 @@ def test_multi_gateway_concurrent_changes(config, image, conn_concurrent, caplog
         else:
             create_resource_by_index(stubB, i, caplog)
         assert "failed" not in caplog.text.lower()
-    listener_req = pb2.create_listener_req(nqn=f"{subsystem_prefix}0",
+    listener_req = pb2.listener_create_req(subsystem_nqn=f"{subsystem_prefix}0",
                                            host_name=gwA.host_name,
                                            adrfam="ipv4",
                                            traddr="127.0.0.1",
                                            trsvcid=5001)
-    listener_ret = stubA.create_listener(listener_req)
+    listener_ret = stubA.listener_create(listener_req)
     assert listener_ret.status == 0
     assert f"Received request to create {gwA.host_name} TCP ipv4 listener for {subsystem_prefix}0 at 127.0.0.1:5001" in caplog.text
-    assert f"create_listener: True" in caplog.text
+    assert f"add_listener: True" in caplog.text
 
     timeout = 15  # Maximum time to wait (in seconds)
     start_time = time.time()
@@ -289,21 +289,21 @@ def test_multi_gateway_concurrent_changes(config, image, conn_concurrent, caplog
 
     assert expected_warning_other_gw in caplog.text
     caplog.clear()
-    subsystem_list_req = pb2.list_subsystems_req()
+    subsystem_list_req = pb2.subsystem_list_req()
     subListA = json.loads(json_format.MessageToJson(
-        stubA.list_subsystems(subsystem_list_req),
+        stubA.subsystem_list(subsystem_list_req),
         preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
     subListB = json.loads(json_format.MessageToJson(
-        stubB.list_subsystems(subsystem_list_req),
+        stubB.subsystem_list(subsystem_list_req),
         preserving_proto_field_name=True, including_default_value_fields=True))['subsystems']
     for i in range(created_resource_count):
         subsystem = f"{subsystem_prefix}{i}"
-        host_list_req = pb2.list_hosts_req(subsystem=subsystem)
+        host_list_req = pb2.host_list_req(subsystem_nqn=subsystem)
         hostListA = json.loads(json_format.MessageToJson(
-            stubA.list_hosts(host_list_req),
+            stubA.host_list(host_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))
         hostListB = json.loads(json_format.MessageToJson(
-            stubB.list_hosts(host_list_req),
+            stubB.host_list(host_list_req),
             preserving_proto_field_name=True, including_default_value_fields=True))
         check_resource_by_index(i, subListA, hostListA)
         check_resource_by_index(i, subListB, hostListB)
@@ -315,51 +315,51 @@ def test_multi_gateway_listener_update(config, image, conn_concurrent, caplog):
 
     caplog.clear()
     subsystem = f"{subsystem_prefix}QQQ"
-    subsystem_add_req = pb2.create_subsystem_req(subsystem_nqn=subsystem, enable_ha=True)
-    ret_subsystem = stubA.create_subsystem(subsystem_add_req)
+    subsystem_add_req = pb2.subsystem_create_req(subsystem_nqn=subsystem, enable_ha=True)
+    ret_subsystem = stubA.subsystem_create(subsystem_add_req)
     assert ret_subsystem.status == 0
     assert f"create_subsystem {subsystem}: True" in caplog.text
     assert f"Failure creating subsystem {subsystem}" not in caplog.text
     caplog.clear()
-    listenerA_req = pb2.create_listener_req(nqn=subsystem,
+    listenerA_req = pb2.listener_create_req(subsystem_nqn=subsystem,
                                            host_name=gwA.host_name,
                                            adrfam="ipv4",
                                            traddr="127.0.0.1",
                                            trsvcid=5101)
-    listener_ret = stubA.create_listener(listenerA_req)
+    listener_ret = stubA.listener_create(listenerA_req)
     assert listener_ret.status == 0
     assert f"Received request to create {gwA.host_name} TCP ipv4 listener for {subsystem} at 127.0.0.1:5101" in caplog.text
-    assert f"create_listener: True" in caplog.text
+    assert f"add_listener: True" in caplog.text
     caplog.clear()
-    listenerB_req = pb2.create_listener_req(nqn=subsystem,
+    listenerB_req = pb2.listener_create_req(subsystem_nqn=subsystem,
                                            host_name=gwB.host_name,
                                            adrfam="ipv4",
                                            traddr="127.0.0.1",
                                            trsvcid=5102)
-    listener_ret = stubB.create_listener(listenerB_req)
+    listener_ret = stubB.istener_create(listenerB_req)
     assert listener_ret.status == 0
     assert f"Received request to create {gwB.host_name} TCP ipv4 listener for {subsystem} at 127.0.0.1:5102" in caplog.text
-    assert f"create_listener: True" in caplog.text
+    assert f"add_listener: True" in caplog.text
     caplog.clear()
-    subsystem_del_req = pb2.delete_subsystem_req(subsystem_nqn=subsystem)
-    ret_subsystem = stubA.delete_subsystem(subsystem_del_req)
+    subsystem_del_req = pb2.subsystem_delete_req(subsystem_nqn=subsystem)
+    ret_subsystem = stubA.subsystem_system(subsystem_del_req)
     assert ret_subsystem.status == 0
     assert f"delete_subsystem {subsystem}: True" in caplog.text
     assert f"Failure deleting subsystem {subsystem}" not in caplog.text
     caplog.clear()
-    ret_subsystem = stubA.create_subsystem(subsystem_add_req)
+    ret_subsystem = stubA.subsystem_create(subsystem_add_req)
     assert ret_subsystem.status == 0
     assert f"create_subsystem {subsystem}: True" in caplog.text
     assert f"Failure creating subsystem {subsystem}" not in caplog.text
     caplog.clear()
-    listener_ret = stubA.create_listener(listenerA_req)
+    listener_ret = stubA.listener_create(listenerA_req)
     assert listener_ret.status == 0
     assert f"Received request to create {gwA.host_name} TCP ipv4 listener for {subsystem} at 127.0.0.1:5101" in caplog.text
-    assert f"create_listener: True" in caplog.text
+    assert f"add_listener: True" in caplog.text
     assert f"Failure adding {subsystem} listener at 127.0.0.1:5101" not in caplog.text
     caplog.clear()
-    listener_ret = stubB.create_listener(listenerB_req)
+    listener_ret = stubB.listener_create(listenerB_req)
     assert listener_ret.status == 0
     assert f"Received request to create {gwB.host_name} TCP ipv4 listener for {subsystem} at 127.0.0.1:5102" in caplog.text
-    assert f"create_listener: True" in caplog.text
+    assert f"add_listener: True" in caplog.text
     assert f"Failure adding {subsystem} listener at 127.0.0.1:5102" not in caplog.text