rxe_cfg_small: Align the way how devices are added|removed

This is done to be more conscious of what net|rxe devices ar currently
in use to make sure we don't unnecessarily write to infiniband class.

Also, this makes use of net/infiniband class more consistent between
both the add and remove actions.

Change-Id: I0ba3bc3a14047e12a804bfdf3aca8c089d34d6b0
Signed-off-by: Michal Berger <michalx.berger@intel.com>
Reviewed-on: https://review.spdk.io/gerrit/c/spdk/spdk/+/3825
Tested-by: SPDK CI Jenkins <sys_sgci@intel.com>
Community-CI: Mellanox Build Bot
Reviewed-by: Tomasz Zawadzki <tomasz.zawadzki@intel.com>
Reviewed-by: Jim Harris <james.r.harris@intel.com>
This commit is contained in:
Michal Berger 2020-08-17 17:30:08 +02:00 committed by Tomasz Zawadzki
parent 3f190fe170
commit 60f3b6b218

View File

@ -10,6 +10,10 @@ declare -r rdma_rxe_rm=$rdma_rxe/parameters/remove
declare -r infiniband=/sys/class/infiniband declare -r infiniband=/sys/class/infiniband
declare -r net=/sys/class/net declare -r net=/sys/class/net
declare -A net_devices
declare -A net_to_rxe
declare -A rxe_to_net
uevent() ( uevent() (
[[ -e $1/uevent ]] || return 0 [[ -e $1/uevent ]] || return 0
@ -70,11 +74,7 @@ start() {
} }
stop() { stop() {
local rxe remove_rxe
for rxe in "$infiniband/rxe"+([0-9]); do
remove_rxe "${rxe##*/}"
done
if ! modprobeq -r rdma_rxe \ if ! modprobeq -r rdma_rxe \
|| [[ -e $rdma_rxe ]]; then || [[ -e $rdma_rxe ]]; then
@ -93,7 +93,7 @@ status() {
printf 'rdma_rxe module not loaded\n' >&2 printf 'rdma_rxe module not loaded\n' >&2
fi fi
local dev net_devs local dev
local link_map local link_map
link_map[0]=no link_map[0]=no
@ -102,21 +102,14 @@ status() {
status_header status_header
local name link driver speed mtu ip rxe rxe_dev active_mtu local name link driver speed mtu ip rxe rxe_dev active_mtu
for dev in "$net/"!(bonding_masters); do for dev in "${net_devices[@]}"; do
(($(< "$dev/type") == 1)) || continue
name="" link="" driver="" name="" link="" driver=""
speed="" mtu="" ip="" speed="" mtu="" ip=""
rxe_dev="" active_mtu="" rxe_dev="" active_mtu=""
name=${dev##*/} name=${dev##*/}
for rxe in "$infiniband/rxe"+([0-9]); do rxe_dev=${net_to_rxe["$name"]}
if [[ $(< "$rxe/parent") == "$name" ]]; then active_mtu=$(get_rxe_mtu "$rxe_dev")
rxe_dev=${rxe##*/}
active_mtu=$(get_rxe_mtu "$rxe_dev")
break
fi
done
link=${link_map[$(< "$dev/carrier")]} link=${link_map[$(< "$dev/carrier")]}
@ -206,23 +199,42 @@ add_rxe() {
[[ -e $rdma_rxe/parameters ]] || return 1 [[ -e $rdma_rxe/parameters ]] || return 1
if [[ -z $1 || $1 == all ]]; then if [[ -z $1 || $1 == all ]]; then
net_devs=("$net/"!(bonding_masters)) net_devs=("${!net_devices[@]}")
elif [[ -e $net/$1 ]]; then elif [[ -n ${net_to_rxe["$1"]} ]]; then
net_devs=("$net/$1") printf '%s interface already in use (%s)\n' \
"$1" "${net_to_rxe["$1"]}"
return 0
elif [[ -n ${net_devices["$1"]} ]]; then
net_devs=("$1")
else else
printf '%s interface does not exist\n' "$1" printf '%s interface does not exist\n' "$1"
return 1 return 1
fi fi
for dev in "${net_devs[@]}"; do for dev in "${net_devs[@]}"; do
(($(< "$dev/type") != 1)) && continue if [[ -z ${net_to_rxe["$dev"]} ]]; then
echo "${dev##*/}" > "$rdma_rxe_add" echo "${dev##*/}" > "$rdma_rxe_add"
fi
link_up "${dev##*/}" link_up "${dev##*/}"
done 2> /dev/null done 2> /dev/null
} }
remove_rxe() { remove_rxe() {
[[ -e $infiniband/${1##*/} ]] && echo "${1##*/}" > "$rdma_rxe_rm" local rxes rxe
rxes=("${!rxe_to_net[@]}")
if [[ -z $1 || $1 == all ]]; then
rxes=("${!rxe_to_net[@]}")
elif [[ -z ${rxe_to_net["$1"]} ]]; then
printf '%s rxe interface does not exist\n' "$1"
return 0
elif [[ -n ${rxe_to_net["$1"]} ]]; then
rxes=("$1")
fi
for rxe in "${rxes[@]}"; do
echo "$rxe" > "$rdma_rxe_rm"
done
} }
link_up() { link_up() {
@ -231,6 +243,24 @@ link_up() {
echo $(($(< "$net/$1/flags") | 0x1)) > "$net/$1/flags" echo $(($(< "$net/$1/flags") | 0x1)) > "$net/$1/flags"
} }
collect_devices() {
local net_dev rxe_dev
for net_dev in "$net/"!(bonding_masters); do
(($(< "$net_dev/type") != 1)) && continue
net_devices["${net_dev##*/}"]=$net_dev
for rxe_dev in "$infiniband/rxe"+([0-9]); do
if [[ $(< "$rxe_dev/parent") == "${net_dev##*/}" ]]; then
net_to_rxe["${net_dev##*/}"]=${rxe_dev##*/}
rxe_to_net["${rxe_dev##*/}"]=${net_dev##*/}
continue 2
fi
done
done
}
collect_devices
case "${1:-status}" in case "${1:-status}" in
start) start)
start start
@ -242,7 +272,7 @@ case "${1:-status}" in
add_rxe "${2:-all}" add_rxe "${2:-all}"
;; ;;
remove) remove)
remove_rxe "$2" remove_rxe "${2:-all}"
;; ;;
status) status)
IFS= read -r match < <( IFS= read -r match < <(