This patch implements a new CLI command pair
'suspend path' and 'resume path' to block and unblock
a remote FC port manually.
It also will block the remote FC port if a path checker
returns 'PATH_TIMEOUT'.
Signed-off-by: Hannes Reinecke <hare@xxxxxxx>
---
multipathd/cli.c | 2 ++
multipathd/cli_handlers.c | 50 +++++++++++++++++++++++++++++++++++++++++++++
multipathd/cli_handlers.h | 2 ++
multipathd/main.c | 7 +++++++
4 files changed, 61 insertions(+)
diff --git a/multipathd/cli.c b/multipathd/cli.c
index d95cba0..e278956 100644
--- a/multipathd/cli.c
+++ b/multipathd/cli.c
@@ -439,6 +439,8 @@ cli_init (void) {
add_handler(LIST+WILDCARDS, NULL);
add_handler(ADD+PATH, NULL);
add_handler(DEL+PATH, NULL);
+ add_handler(SUSPEND+PATH, NULL);
+ add_handler(RESUME+PATH, NULL);
add_handler(ADD+MAP, NULL);
add_handler(DEL+MAP, NULL);
add_handler(SWITCH+MAP+GROUP, NULL);
diff --git a/multipathd/cli_handlers.c b/multipathd/cli_handlers.c
index a1e4bde..6c8d8d8 100644
--- a/multipathd/cli_handlers.c
+++ b/multipathd/cli_handlers.c
@@ -469,6 +469,56 @@ cli_del_path (void * v, char ** reply, int * len, void * data)
}
int
+cli_block_path(void * v, char ** reply, int * len, void * data)
+{
+ struct vectors * vecs = (struct vectors *)data;
+ char * param = get_keyparam(v, PATH);
+ struct path * pp;
+ int r;
+
+ pp = find_path_by_dev(vecs->pathvec, param);
+ if (!pp)
+ pp = find_path_by_devt(vecs->pathvec, param);
+
+ if (!pp || !pp->mpp || !pp->mpp->alias) {
+ condlog(3, "%s: path not found\n", param);
+ return 1;
+ }
+ condlog(2, "%s: block path %s (operator)",
+ pp->mpp->alias, pp->dev_t);
+
+
+ r = sysfs_set_fc_rport_state(pp, 1);
+
+ return r ? 1 : 0;
+}
+
+int
+cli_unblock_path(void * v, char ** reply, int * len, void * data)
+{
+ struct vectors * vecs = (struct vectors *)data;
+ char * param = get_keyparam(v, PATH);
+ struct path * pp;
+ int r;
+
+ pp = find_path_by_dev(vecs->pathvec, param);
+ if (!pp)
+ pp = find_path_by_devt(vecs->pathvec, param);
+
+ if (!pp || !pp->mpp || !pp->mpp->alias) {
+ condlog(3, "%s: path not found\n", param);
+ return 1;
+ }
+ condlog(2, "%s: unblock path %s (operator)",
+ pp->mpp->alias, pp->dev_t);
+
+
+ r = sysfs_set_fc_rport_state(pp, 0);
+
+ return r ? 1 : 0;
+}
+
+int
cli_add_map (void * v, char ** reply, int * len, void * data)
{
struct vectors * vecs = (struct vectors *)data;
diff --git a/multipathd/cli_handlers.h b/multipathd/cli_handlers.h
index c62a273..8734610 100644
--- a/multipathd/cli_handlers.h
+++ b/multipathd/cli_handlers.h
@@ -14,6 +14,8 @@ int cli_list_devices (void * v, char ** reply, int * len, void * data);
int cli_list_wildcards (void * v, char ** reply, int * len, void * data);
int cli_add_path (void * v, char ** reply, int * len, void * data);
int cli_del_path (void * v, char ** reply, int * len, void * data);
+int cli_block_path (void * v, char ** reply, int * len, void * data);
+int cli_unblock_path (void * v, char ** reply, int * len, void * data);
int cli_add_map (void * v, char ** reply, int * len, void * data);
int cli_del_map (void * v, char ** reply, int * len, void * data);
int cli_switch_group(void * v, char ** reply, int * len, void * data);
diff --git a/multipathd/main.c b/multipathd/main.c
index 95264fc..30afb24 100644
--- a/multipathd/main.c
+++ b/multipathd/main.c
@@ -861,6 +861,8 @@ uxlsnrloop (void * ap)
set_handler_callback(LIST+WILDCARDS, cli_list_wildcards);
set_handler_callback(ADD+PATH, cli_add_path);
set_handler_callback(DEL+PATH, cli_del_path);
+ set_handler_callback(SUSPEND+PATH, cli_block_path);
+ set_handler_callback(RESUME+PATH, cli_unblock_path);
set_handler_callback(ADD+MAP, cli_add_map);
set_handler_callback(DEL+MAP, cli_del_map);
set_handler_callback(SWITCH+MAP+GROUP, cli_switch_group);
@@ -1132,6 +1134,11 @@ check_path (struct vectors * vecs, struct path * pp)
pp->tick = 1;
return;
}
+ if (newstate == PATH_TIMEOUT) {
+ /* Command timeout, block path */
+ sysfs_set_fc_rport_state(pp, 1);
+ newstate = PATH_DOWN;
+ }
/*
* Synchronize with kernel state
*/
--
1.7.10.4
--
dm-devel mailing list
dm-devel@xxxxxxxxxx
https://www.redhat.com/mailman/listinfo/dm-devel
