From 5b3747294a4bf4a12ad494d2c72b72512794ba90 Mon Sep 17 00:00:00 2001 From: Chris Horn Date: Fri, 1 May 2020 15:47:06 -0500 Subject: [PATCH] LU-13502 lnet: Add param to control response tracking Add lnet_response_tracking parameter which will be used to control the behavior of LNet response tracking. Test-Parameters: trivial HPE-bug-id: LUS-8827 Signed-off-by: Chris Horn Change-Id: I9c5be488673bbaa3c3cb983fe099d2203c1d9fa7 Reviewed-on: https://review.whamcloud.com/38449 Tested-by: jenkins Tested-by: Maloo Reviewed-by: Neil Brown Reviewed-by: Serguei Smirnov Reviewed-by: Oleg Drokin --- lnet/include/lnet/lib-lnet.h | 1 + lnet/lnet/api-ni.c | 41 +++++++++++++++++++++++++++++++++++++++++ 2 files changed, 42 insertions(+) diff --git a/lnet/include/lnet/lib-lnet.h b/lnet/include/lnet/lib-lnet.h index f4adc2b..a89a802 100644 --- a/lnet/include/lnet/lib-lnet.h +++ b/lnet/include/lnet/lib-lnet.h @@ -457,6 +457,7 @@ struct lnet_net *lnet_get_net_locked(__u32 net_id); int lnet_lib_init(void); void lnet_lib_exit(void); +extern unsigned int lnet_response_tracking; extern unsigned lnet_transaction_timeout; extern unsigned lnet_retry_count; extern unsigned int lnet_lnd_timeout; diff --git a/lnet/lnet/api-ni.c b/lnet/lnet/api-ni.c index 1f933a1..500f4a1 100644 --- a/lnet/lnet/api-ni.c +++ b/lnet/lnet/api-ni.c @@ -222,6 +222,24 @@ module_param_call(lnet_retry_count, retry_count_set, param_get_int, MODULE_PARM_DESC(lnet_retry_count, "Maximum number of times to retry transmitting a message"); +unsigned int lnet_response_tracking = 3; +static int response_tracking_set(const char *val, cfs_kernel_param_arg_t *kp); + +#ifdef HAVE_KERNEL_PARAM_OPS +static struct kernel_param_ops param_ops_response_tracking = { + .set = response_tracking_set, + .get = param_get_int, +}; + +#define param_check_response_tracking(name, p) \ + __param_check(name, p, int) +module_param(lnet_response_tracking, response_tracking, 0644); +#else +module_param_call(lnet_response_tracking, response_tracking_set, param_get_int, + &lnet_response_tracking, 0644); +#endif +MODULE_PARM_DESC(lnet_response_tracking, + "(0|1|2|3) LNet Internal Only|GET Reply only|PUT ACK only|Full Tracking (default)"); #define LNET_LND_TIMEOUT_DEFAULT ((LNET_TRANSACTION_TIMEOUT_HEALTH_DEFAULT - 1) / \ (LNET_RETRY_COUNT_HEALTH_DEFAULT + 1)) @@ -533,6 +551,29 @@ intf_max_set(const char *val, cfs_kernel_param_arg_t *kp) return 0; } +static int +response_tracking_set(const char *val, cfs_kernel_param_arg_t *kp) +{ + int rc; + unsigned long new_value; + + rc = kstrtoul(val, 0, &new_value); + if (rc) { + CERROR("Invalid value for 'lnet_response_tracking'\n"); + return -EINVAL; + } + + if (new_value < 0 || new_value > 3) { + CWARN("Invalid value (%lu) for 'lnet_response_tracking'\n", + new_value); + return -EINVAL; + } + + lnet_response_tracking = new_value; + + return 0; +} + static const char * lnet_get_routes(void) { -- 1.8.3.1