#--
# Copyright (c) 2004-2010 Mellanox Technologies LTD. All rights reserved.
#
# This software is available to you under a choice of one of two
# licenses. You may choose to be licensed under the terms of the GNU
# General Public License (GPL) Version 2, available from the file
# COPYING in the main directory of this source tree, or the
# OpenIB.org BSD license below:
#
# Redistribution and use in source and binary forms, with or
# without modification, are permitted provided that the following
# conditions are met:
#
# - Redistributions of source code must retain the above
# copyright notice, this list of conditions and the following
# disclaimer.
#
# - Redistributions in binary form must reproduce the above
# copyright notice, this list of conditions and the following
# disclaimer in the documentation and/or other materials
# provided with the distribution.
#
# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
# EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
# MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
# NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
# BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
# ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
# CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
# SOFTWARE.
#--
puts "Running Simulation flow for Muticast Routing test"
puts "Randomally Joining all the Fabric Ports with random delays"
# send a single port join request
proc sendJoinLeavForPort {port {isLeave 0}} {
# allocate a new mc member record:
set mcm [new_madMcMemberRec]
# join the IPoIB broadcast gid:
madMcMemberRec_mgid_set $mcm 0xff12401bffff0000:00000000ffffffff
# we must provide our own port gid
madMcMemberRec_port_gid_set $mcm \
"0xfe80000000000000:[string range [IBPort_guid_get $port] 2 end]"
# must require full membership:
madMcMemberRec_scope_state_set $mcm 0x1
# we need port number and sim node for the mad send:
set portNum [IBPort_num_get $port]
set node [IBPort_p_node_get $port]
# we need the comp_mask to include the mgid, port gid and join state:
set compMask [format "0x%X" [expr (1<<16) | 3]]
# send it assuming the SM_LID is always 1:
if {$isLeave} {
puts "-I- Leaving port $port"
madMcMemberRec_send_del $mcm sim$node $portNum 1 $compMask
} else {
puts "-I- Joining port $port"
madMcMemberRec_send_set $mcm sim$node $portNum 1 $compMask
}
# deallocate
delete_madMcMemberRec $mcm
return 0
}
# find all active HCA ports
proc getAllActiveHCAPorts {fabric} {
global IB_SW_NODE
set hcaPorts {}
# go over all nodes:
foreach nodeNameId [IBFabric_NodeByName_get $fabric] {
set node [lindex $nodeNameId 1]
# we do care about non switches only
if {[IBNode_type_get $node] != $IB_SW_NODE} {
# go over all ports:
for {set pn 1} {$pn <= [IBNode_numPorts_get $node]} {incr pn} {
set port [IBNode_getPort $node $pn]
if {($port != "") && ([IBPort_p_remotePort_get $port] != "")} {
lappend hcaPorts $port
}
}
}
}
return $hcaPorts
}
# randomize join for all of the fabric HCA ports:
proc randomJoinAllHCAPorts {fabric maxDelay_ms} {
# get all HCA ports:
set hcaPorts [getAllActiveHCAPorts $fabric]
# set a random order:
set orederedPorts {}
foreach port $hcaPorts {
lappend orederedPorts [list $port [rmRand]]
}
# sort:
set orederedPorts [lsort -index 1 -real $orederedPorts]
set numHcasJoined 0
# Now do the joins - waiting random time between them:
foreach portNOrder $orederedPorts {
set port [lindex $portNOrder 0]
if {![sendJoinLeavForPort $port]} {
incr numHcasJoined
}
after [expr int([rmRand]*$maxDelay_ms)]
}
return $numHcasJoined
}
# randomly select ports and then join or delete them
# do that 10 times the number of ports and return:
proc randomJoinLeavePorts {fabric maxDelay_ms} {
# get all HCA ports:
set hcaPorts [getAllActiveHCAPorts $fabric]
# set a random order:
set orederedPorts {}
foreach port $hcaPorts {
lappend orederedPorts [list $port [rmRand]]
}
# sort:
set orederedPorts [lsort -index 1 -real $orederedPorts]
set numPorts [llength $orederedPorts]
# we use 1 to flag leaving
set isLeave 1
for {set i 0} {$i < 100*$numPorts} {incr i} {
set portIdx [expr int([rmRand] * $numPorts)]
set portNOrder [lindex $orederedPorts $portIdx]
set port [lindex $portNOrder 0]
if {[rmRand] > 0.5} {
sendJoinLeavForPort $port $isLeave
} else {
sendJoinLeavForPort $port
}
if {0} {
# do we need to leave or join?
if {![info exists JOINED_PORTS($port)]} {
set JOINED_PORTS($port) 0
}
set JOINED_PORTS($port)
if {$JOINED_PORTS($port)} {
sendJoinLeavForPort $port $isLeave
set JOINED_PORTS($port) 0
} else {
sendJoinLeavForPort $port
set JOINED_PORTS($port) 1
}
}
after [expr int([rmRand]*$maxDelay_ms)]
}
return 0
}