From b1ccfaca018e60592b7fee04adf200cfdef87001 Mon Sep 17 00:00:00 2001 From: Tomasz Zawadzki Date: Fri, 6 Oct 2017 16:17:38 +0200 Subject: [PATCH] subsystem: remove fini return code Closing the framework has to go through all subsystems without failure, so return codes are unnecessary. Signed-off-by: Tomasz Zawadzki Change-Id: I53c9b4df12d2357e641130869f398b18637e6ff7 Reviewed-on: https://review.gerrithub.io/381681 Reviewed-by: Dariusz Stojaczyk Reviewed-by: Jim Harris Reviewed-by: Daniel Verkamp Tested-by: SPDK Automated Test System --- include/spdk/bdev.h | 2 +- include/spdk/copy_engine.h | 2 +- include/spdk/net.h | 4 ++-- include/spdk/scsi.h | 2 +- include/spdk/vhost.h | 2 +- include/spdk_internal/event.h | 4 ++-- lib/bdev/bdev.c | 4 +--- lib/copy/copy_engine.c | 3 +-- lib/event/subsystem.c | 9 ++------- lib/event/subsystems/bdev/bdev.c | 4 ++-- lib/event/subsystems/copy/copy.c | 4 ++-- lib/event/subsystems/iscsi/iscsi.c | 4 ++-- lib/event/subsystems/net/net.c | 8 ++++---- lib/event/subsystems/rpc/rpc.c | 4 +--- lib/event/subsystems/scsi/scsi.c | 4 ++-- lib/event/subsystems/vhost/vhost.c | 4 ++-- lib/iscsi/iscsi.h | 2 +- lib/iscsi/iscsi_subsystem.c | 30 ++++++++---------------------- lib/net/interface.c | 6 ++---- lib/net/net_framework_default.c | 3 +-- lib/scsi/scsi.c | 3 +-- lib/vhost/vhost_scsi.c | 3 +-- 22 files changed, 41 insertions(+), 70 deletions(-) diff --git a/include/spdk/bdev.h b/include/spdk/bdev.h index 3d0e640bf..68502018c 100644 --- a/include/spdk/bdev.h +++ b/include/spdk/bdev.h @@ -127,7 +127,7 @@ typedef void (*spdk_bdev_poller_stop_cb)(struct spdk_bdev_poller **ppoller); void spdk_bdev_initialize(spdk_bdev_init_cb cb_fn, void *cb_arg, spdk_bdev_poller_start_cb start_poller_fn, spdk_bdev_poller_stop_cb stop_poller_fn); -int spdk_bdev_finish(void); +void spdk_bdev_finish(void); void spdk_bdev_config_text(FILE *fp); struct spdk_bdev *spdk_bdev_get_by_name(const char *bdev_name); diff --git a/include/spdk/copy_engine.h b/include/spdk/copy_engine.h index aa4824e37..f519a19a6 100644 --- a/include/spdk/copy_engine.h +++ b/include/spdk/copy_engine.h @@ -47,7 +47,7 @@ struct spdk_io_channel; struct spdk_copy_task; int spdk_copy_engine_initialize(void); -int spdk_copy_engine_finish(void); +void spdk_copy_engine_finish(void); struct spdk_io_channel *spdk_copy_engine_get_io_channel(void); int spdk_copy_submit(struct spdk_copy_task *copy_req, struct spdk_io_channel *ch, void *dst, diff --git a/include/spdk/net.h b/include/spdk/net.h index 5acf4ee7a..967323818 100644 --- a/include/spdk/net.h +++ b/include/spdk/net.h @@ -45,12 +45,12 @@ #define IDLE_INTERVAL_TIME_IN_US 5000 int spdk_interface_init(void); -int spdk_interface_destroy(void); +void spdk_interface_destroy(void); const char *spdk_net_framework_get_name(void); int spdk_net_framework_start(void); void spdk_net_framework_clear_socket_association(int sock); -int spdk_net_framework_fini(void); +void spdk_net_framework_fini(void); int spdk_net_framework_idle_time(void); #define SPDK_IFNAMSIZE 32 diff --git a/include/spdk/scsi.h b/include/spdk/scsi.h index 1de12758a..e4c43ea4e 100644 --- a/include/spdk/scsi.h +++ b/include/spdk/scsi.h @@ -164,7 +164,7 @@ struct spdk_scsi_lun; int spdk_scsi_init(void); -int spdk_scsi_fini(void); +void spdk_scsi_fini(void); int spdk_scsi_lun_get_id(const struct spdk_scsi_lun *lun); const char *spdk_scsi_lun_get_name(const struct spdk_scsi_lun *lun); diff --git a/include/spdk/vhost.h b/include/spdk/vhost.h index 15e20c2bb..80b15c3ef 100644 --- a/include/spdk/vhost.h +++ b/include/spdk/vhost.h @@ -44,7 +44,7 @@ #include "spdk/event.h" int spdk_vhost_init(void); -int spdk_vhost_fini(void); +void spdk_vhost_fini(void); /** * Init vhost application. This is called once by SPDK app layer. diff --git a/include/spdk_internal/event.h b/include/spdk_internal/event.h index 29a3b0383..a738ed3cf 100644 --- a/include/spdk_internal/event.h +++ b/include/spdk_internal/event.h @@ -55,7 +55,7 @@ struct spdk_subsystem { const char *name; /* User must call spdk_subsystem_init_next() when they are done with their initialization. */ void (*init)(void); - int (*fini)(void); + void (*fini)(void); void (*config)(FILE *fp); TAILQ_ENTRY(spdk_subsystem) tailq; }; @@ -71,7 +71,7 @@ void spdk_add_subsystem(struct spdk_subsystem *subsystem); void spdk_add_subsystem_depend(struct spdk_subsystem_depend *depend); void spdk_subsystem_init(void *arg1, void *arg2); -int spdk_subsystem_fini(void); +void spdk_subsystem_fini(void); void spdk_subsystem_init_next(int rc); void spdk_subsystem_config(FILE *fp); diff --git a/lib/bdev/bdev.c b/lib/bdev/bdev.c index 4e4696a16..21a953fb3 100644 --- a/lib/bdev/bdev.c +++ b/lib/bdev/bdev.c @@ -546,7 +546,7 @@ spdk_bdev_initialize(spdk_bdev_init_cb cb_fn, void *cb_arg, spdk_bdev_module_action_complete(); } -int +void spdk_bdev_finish(void) { struct spdk_bdev_module_if *bdev_module; @@ -582,8 +582,6 @@ spdk_bdev_finish(void) spdk_mempool_free(g_bdev_mgr.buf_large_pool); spdk_io_device_unregister(&g_bdev_mgr, NULL); - - return 0; } struct spdk_bdev_io * diff --git a/lib/copy/copy_engine.c b/lib/copy/copy_engine.c index 3fc6035df..bc5665fb7 100644 --- a/lib/copy/copy_engine.c +++ b/lib/copy/copy_engine.c @@ -249,11 +249,10 @@ spdk_copy_engine_initialize(void) return 0; } -int +void spdk_copy_engine_finish(void) { spdk_copy_engine_module_finish(); - return 0; } SPDK_COPY_MODULE_REGISTER(copy_engine_mem_init, NULL, NULL, copy_engine_mem_get_ctx_size) diff --git a/lib/event/subsystem.c b/lib/event/subsystem.c index b30c89da8..45505f26d 100644 --- a/lib/event/subsystem.c +++ b/lib/event/subsystem.c @@ -165,24 +165,19 @@ spdk_subsystem_init(void *arg1, void *arg2) spdk_subsystem_init_next(0); } -int +void spdk_subsystem_fini(void) { - int rc = 0; struct spdk_subsystem *cur; cur = TAILQ_LAST(&g_subsystems, spdk_subsystem_list); while (cur) { if (cur->fini) { - rc = cur->fini(); - if (rc) - return rc; + cur->fini(); } cur = TAILQ_PREV(cur, spdk_subsystem_list, tailq); } - - return rc; } void diff --git a/lib/event/subsystems/bdev/bdev.c b/lib/event/subsystems/bdev/bdev.c index 75f56a9d5..bb5424644 100644 --- a/lib/event/subsystems/bdev/bdev.c +++ b/lib/event/subsystems/bdev/bdev.c @@ -71,10 +71,10 @@ spdk_bdev_subsystem_initialize(void) spdk_bdev_subsystem_stop_poller); } -static int +static void spdk_bdev_subsystem_finish(void) { - return spdk_bdev_finish(); + spdk_bdev_finish(); } SPDK_SUBSYSTEM_REGISTER(bdev, spdk_bdev_subsystem_initialize, diff --git a/lib/event/subsystems/copy/copy.c b/lib/event/subsystems/copy/copy.c index 7e8b4ce07..3cf7d7505 100644 --- a/lib/event/subsystems/copy/copy.c +++ b/lib/event/subsystems/copy/copy.c @@ -47,10 +47,10 @@ spdk_copy_engine_subsystem_initialize(void) spdk_subsystem_init_next(rc); } -static int +static void spdk_copy_engine_subsystem_finish(void) { - return spdk_copy_engine_finish(); + spdk_copy_engine_finish(); } SPDK_SUBSYSTEM_REGISTER(copy, spdk_copy_engine_subsystem_initialize, diff --git a/lib/event/subsystems/iscsi/iscsi.c b/lib/event/subsystems/iscsi/iscsi.c index c47e3f98b..f4a5dd48b 100644 --- a/lib/event/subsystems/iscsi/iscsi.c +++ b/lib/event/subsystems/iscsi/iscsi.c @@ -47,10 +47,10 @@ spdk_iscsi_subsystem_init(void) spdk_subsystem_init_next(rc); } -static int +static void spdk_iscsi_subsystem_fini(void) { - return spdk_iscsi_fini(); + spdk_iscsi_fini(); } SPDK_SUBSYSTEM_REGISTER(iscsi, spdk_iscsi_subsystem_init, spdk_iscsi_subsystem_fini, diff --git a/lib/event/subsystems/net/net.c b/lib/event/subsystems/net/net.c index 65a8b36d9..389384b2a 100644 --- a/lib/event/subsystems/net/net.c +++ b/lib/event/subsystems/net/net.c @@ -47,10 +47,10 @@ spdk_interface_subsystem_init(void) spdk_subsystem_init_next(rc); } -static int +static void spdk_interface_subsystem_destroy(void) { - return spdk_interface_destroy(); + spdk_interface_destroy(); } SPDK_SUBSYSTEM_REGISTER(interface, spdk_interface_subsystem_init, @@ -66,10 +66,10 @@ spdk_net_subsystem_start(void) spdk_subsystem_init_next(rc); } -static int +static void spdk_net_subsystem_fini(void) { - return spdk_net_framework_fini(); + spdk_net_framework_fini(); } SPDK_SUBSYSTEM_REGISTER(net_framework, spdk_net_subsystem_start, diff --git a/lib/event/subsystems/rpc/rpc.c b/lib/event/subsystems/rpc/rpc.c index f6700807e..46840b286 100644 --- a/lib/event/subsystems/rpc/rpc.c +++ b/lib/event/subsystems/rpc/rpc.c @@ -127,13 +127,11 @@ spdk_rpc_subsystem_initialize(void) spdk_subsystem_init_next(0); } -static int +static void spdk_rpc_subsystem_finish(void) { spdk_rpc_close(); spdk_poller_unregister(&g_rpc_poller, NULL); - - return 0; } static void diff --git a/lib/event/subsystems/scsi/scsi.c b/lib/event/subsystems/scsi/scsi.c index 464bc7b04..12a7f9960 100644 --- a/lib/event/subsystems/scsi/scsi.c +++ b/lib/event/subsystems/scsi/scsi.c @@ -47,10 +47,10 @@ spdk_scsi_subsystem_init(void) spdk_subsystem_init_next(rc); } -static int +static void spdk_scsi_subsystem_fini(void) { - return spdk_scsi_fini(); + spdk_scsi_fini(); } SPDK_SUBSYSTEM_REGISTER(scsi, spdk_scsi_subsystem_init, spdk_scsi_subsystem_fini, NULL) diff --git a/lib/event/subsystems/vhost/vhost.c b/lib/event/subsystems/vhost/vhost.c index f34d8589e..503f8c350 100644 --- a/lib/event/subsystems/vhost/vhost.c +++ b/lib/event/subsystems/vhost/vhost.c @@ -47,10 +47,10 @@ spdk_vhost_subsystem_init(void) spdk_subsystem_init_next(rc); } -static int +static void spdk_vhost_subsystem_fini(void) { - return spdk_vhost_fini(); + spdk_vhost_fini(); } SPDK_SUBSYSTEM_REGISTER(vhost, spdk_vhost_subsystem_init, spdk_vhost_subsystem_fini, NULL) diff --git a/lib/iscsi/iscsi.h b/lib/iscsi/iscsi.h index 45aee16cc..5a63a1ce9 100644 --- a/lib/iscsi/iscsi.h +++ b/lib/iscsi/iscsi.h @@ -327,7 +327,7 @@ extern struct spdk_iscsi_globals g_spdk_iscsi; struct spdk_iscsi_task; int spdk_iscsi_init(void); -int spdk_iscsi_fini(void); +void spdk_iscsi_fini(void); void spdk_iscsi_config_text(FILE *fp); int spdk_iscsi_send_nopin(struct spdk_iscsi_conn *conn); diff --git a/lib/iscsi/iscsi_subsystem.c b/lib/iscsi/iscsi_subsystem.c index 6d0404032..01487d30d 100644 --- a/lib/iscsi/iscsi_subsystem.c +++ b/lib/iscsi/iscsi_subsystem.c @@ -452,35 +452,25 @@ static unsigned rte_mempool_avail_count(const struct rte_mempool *pool) } #endif -static int +static void spdk_iscsi_check_pool(struct rte_mempool *pool, uint32_t count) { if (rte_mempool_avail_count(pool) != count) { SPDK_ERRLOG("rte_mempool_avail_count(%s) == %d, should be %d\n", pool->name, rte_mempool_avail_count(pool), count); - return -1; - } else { - return 0; } } -static int +static void spdk_iscsi_check_pools(void) { - int rc = 0; struct spdk_iscsi_globals *iscsi = &g_spdk_iscsi; - rc += spdk_iscsi_check_pool(iscsi->pdu_pool, PDU_POOL_SIZE(iscsi)); - rc += spdk_iscsi_check_pool(iscsi->session_pool, SESSION_POOL_SIZE(iscsi)); - rc += spdk_iscsi_check_pool(iscsi->pdu_immediate_data_pool, IMMEDIATE_DATA_POOL_SIZE(iscsi)); - rc += spdk_iscsi_check_pool(iscsi->pdu_data_out_pool, DATA_OUT_POOL_SIZE(iscsi)); + spdk_iscsi_check_pool(iscsi->pdu_pool, PDU_POOL_SIZE(iscsi)); + spdk_iscsi_check_pool(iscsi->session_pool, SESSION_POOL_SIZE(iscsi)); + spdk_iscsi_check_pool(iscsi->pdu_immediate_data_pool, IMMEDIATE_DATA_POOL_SIZE(iscsi)); + spdk_iscsi_check_pool(iscsi->pdu_data_out_pool, DATA_OUT_POOL_SIZE(iscsi)); /* TODO: check the task_pool on exit */ - - if (rc == 0) { - return 0; - } else { - return -1; - } } static void @@ -994,12 +984,10 @@ spdk_iscsi_init(void) return 0; } -int +void spdk_iscsi_fini(void) { - int rc; - - rc = spdk_iscsi_check_pools(); + spdk_iscsi_check_pools(); spdk_iscsi_free_pools(); spdk_iscsi_shutdown_tgt_nodes(); @@ -1009,8 +997,6 @@ spdk_iscsi_fini(void) free(g_spdk_iscsi.nodebase); pthread_mutex_destroy(&g_spdk_iscsi.mutex); - - return rc; } void diff --git a/lib/net/interface.c b/lib/net/interface.c index 043ea4019..2656bd71b 100644 --- a/lib/net/interface.c +++ b/lib/net/interface.c @@ -426,7 +426,7 @@ spdk_interface_init(void) return 0; } -int +void spdk_interface_destroy(void) { struct spdk_interface *ifc_entry; @@ -436,7 +436,6 @@ spdk_interface_destroy(void) TAILQ_REMOVE(&g_interface_head, ifc_entry, tailq); free(ifc_entry); } - return 0; } int @@ -471,10 +470,9 @@ spdk_interface_init(void) return 0; } -int +void spdk_interface_destroy(void) { - return 0; } int diff --git a/lib/net/net_framework_default.c b/lib/net/net_framework_default.c index a47bf23bb..77317b097 100644 --- a/lib/net/net_framework_default.c +++ b/lib/net/net_framework_default.c @@ -46,9 +46,8 @@ int spdk_net_framework_start(void) } __attribute__((weak)) -int spdk_net_framework_fini(void) +void spdk_net_framework_fini(void) { - return 0; } __attribute__((weak)) diff --git a/lib/scsi/scsi.c b/lib/scsi/scsi.c index 937054282..868374b36 100644 --- a/lib/scsi/scsi.c +++ b/lib/scsi/scsi.c @@ -50,11 +50,10 @@ spdk_scsi_init(void) return 0; } -int +void spdk_scsi_fini(void) { pthread_mutex_destroy(&g_spdk_scsi.mutex); - return 0; } SPDK_TRACE_REGISTER_FN(scsi_trace) diff --git a/lib/vhost/vhost_scsi.c b/lib/vhost/vhost_scsi.c index 312e38319..8496c384f 100644 --- a/lib/vhost/vhost_scsi.c +++ b/lib/vhost/vhost_scsi.c @@ -1114,10 +1114,9 @@ spdk_vhost_init(void) return 0; } -int +void spdk_vhost_fini(void) { - return 0; } static void