|
Packit |
db064d |
/*
|
|
Packit |
db064d |
* Copyright (c) 2004-2009 Voltaire Inc. All rights reserved.
|
|
Packit |
db064d |
* Copyright (c) 2011 Mellanox Technologies LTD. All rights reserved.
|
|
Packit |
db064d |
* Copyright (c) 2011 Lawrence Livermore National Lab. All rights reserved.
|
|
Packit |
db064d |
*
|
|
Packit |
db064d |
* This software is available to you under a choice of one of two
|
|
Packit |
db064d |
* licenses. You may choose to be licensed under the terms of the GNU
|
|
Packit |
db064d |
* General Public License (GPL) Version 2, available from the file
|
|
Packit |
db064d |
* COPYING in the main directory of this source tree, or the
|
|
Packit |
db064d |
* OpenIB.org BSD license below:
|
|
Packit |
db064d |
*
|
|
Packit |
db064d |
* Redistribution and use in source and binary forms, with or
|
|
Packit |
db064d |
* without modification, are permitted provided that the following
|
|
Packit |
db064d |
* conditions are met:
|
|
Packit |
db064d |
*
|
|
Packit |
db064d |
* - Redistributions of source code must retain the above
|
|
Packit |
db064d |
* copyright notice, this list of conditions and the following
|
|
Packit |
db064d |
* disclaimer.
|
|
Packit |
db064d |
*
|
|
Packit |
db064d |
* - Redistributions in binary form must reproduce the above
|
|
Packit |
db064d |
* copyright notice, this list of conditions and the following
|
|
Packit |
db064d |
* disclaimer in the documentation and/or other materials
|
|
Packit |
db064d |
* provided with the distribution.
|
|
Packit |
db064d |
*
|
|
Packit |
db064d |
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
|
|
Packit |
db064d |
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
|
Packit |
db064d |
* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
|
|
Packit |
db064d |
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
|
|
Packit |
db064d |
* BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
|
|
Packit |
db064d |
* ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
|
|
Packit |
db064d |
* CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
|
Packit |
db064d |
* SOFTWARE.
|
|
Packit |
db064d |
*
|
|
Packit |
db064d |
*/
|
|
Packit |
db064d |
|
|
Packit |
db064d |
#if HAVE_CONFIG_H
|
|
Packit |
db064d |
# include <config.h>
|
|
Packit |
db064d |
#endif /* HAVE_CONFIG_H */
|
|
Packit |
db064d |
|
|
Packit |
db064d |
#include <stdio.h>
|
|
Packit |
db064d |
#include <stdlib.h>
|
|
Packit |
db064d |
#include <unistd.h>
|
|
Packit |
db064d |
#include <string.h>
|
|
Packit |
db064d |
#include <errno.h>
|
|
Packit |
db064d |
#include <netinet/in.h>
|
|
Packit |
db064d |
#include <limits.h>
|
|
Packit |
db064d |
#include <ctype.h>
|
|
Packit |
db064d |
|
|
Packit |
db064d |
#define __STDC_FORMAT_MACROS
|
|
Packit |
db064d |
#include <inttypes.h>
|
|
Packit |
db064d |
|
|
Packit |
db064d |
#include <infiniband/mad.h>
|
|
Packit |
db064d |
|
|
Packit |
db064d |
#include "ibdiag_common.h"
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static struct ibmad_port *srcport;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static op_fn_t congestion_key_info;
|
|
Packit |
db064d |
static op_fn_t switch_congestion_setting;
|
|
Packit |
db064d |
static op_fn_t switch_port_congestion_setting;
|
|
Packit |
db064d |
static op_fn_t ca_congestion_setting;
|
|
Packit |
db064d |
static op_fn_t congestion_control_table;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static const match_rec_t match_tbl[] = {
|
|
Packit |
db064d |
{"CongestionKeyInfo", "CK", congestion_key_info, 0,
|
|
Packit |
db064d |
"<cckey> <cckeyprotectbit> <cckeyleaseperiod> <cckeyviolations>"},
|
|
Packit |
db064d |
{"SwitchCongestionSetting", "SS", switch_congestion_setting, 0,
|
|
Packit |
db064d |
"<controlmap> <victimmask> <creditmask> <threshold> <packetsize> "
|
|
Packit |
db064d |
"<csthreshold> <csreturndelay> <markingrate>"},
|
|
Packit |
db064d |
{"SwitchPortCongestionSetting", "SP", switch_port_congestion_setting, 1,
|
|
Packit |
db064d |
"<valid> <control_type> <threshold> <packet_size> <cong_parm_marking_rate>"},
|
|
Packit |
db064d |
{"CACongestionSetting", "CS", ca_congestion_setting, 0,
|
|
Packit |
db064d |
"<port_control> <control_map> <ccti_timer> <ccti_increase> "
|
|
Packit |
db064d |
"<trigger_threshold> <ccti_min>"},
|
|
Packit |
db064d |
{"CongestionControlTable", "CT", congestion_control_table, 0,
|
|
Packit |
db064d |
"<cctilimit> <index> <cctentry> <cctentry> ..."},
|
|
Packit |
db064d |
{}
|
|
Packit |
db064d |
};
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static uint64_t cckey;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
/*******************************************/
|
|
Packit |
db064d |
static const char *parselonglongint(char *arg, uint64_t *val)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
char *endptr = NULL;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
errno = 0;
|
|
Packit |
db064d |
*val = strtoull(arg, &endptr, 0);
|
|
Packit |
db064d |
if ((endptr && *endptr != '\0')
|
|
Packit |
db064d |
|| errno != 0) {
|
|
Packit |
db064d |
if (errno == ERANGE)
|
|
Packit |
db064d |
return "value out of range";
|
|
Packit |
db064d |
return "invalid integer input";
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
return NULL;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static const char *parseint(char *arg, uint32_t *val, int hexonly)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
char *endptr = NULL;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
errno = 0;
|
|
Packit |
db064d |
*val = strtoul(arg, &endptr, hexonly ? 16 : 0);
|
|
Packit |
db064d |
if ((endptr && *endptr != '\0')
|
|
Packit |
db064d |
|| errno != 0) {
|
|
Packit |
db064d |
if (errno == ERANGE)
|
|
Packit |
db064d |
return "value out of range";
|
|
Packit |
db064d |
return "invalid integer input";
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
return NULL;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static const char *congestion_key_info(ib_portid_t *dest, char **argv, int argc)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
uint8_t rcv[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint8_t payload[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint64_t cc_key;
|
|
Packit |
db064d |
uint32_t cc_keyprotectbit;
|
|
Packit |
db064d |
uint32_t cc_keyleaseperiod;
|
|
Packit |
db064d |
uint32_t cc_keyviolations;
|
|
Packit |
db064d |
const char *errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (argc != 4)
|
|
Packit |
db064d |
return "invalid number of parameters for CongestionKeyInfo";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parselonglongint(argv[0], &cc_key)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
if ((errstr = parseint(argv[1], &cc_keyprotectbit, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
if ((errstr = parseint(argv[2], &cc_keyleaseperiod, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
if ((errstr = parseint(argv[3], &cc_keyviolations, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (cc_keyprotectbit != 0 && cc_keyprotectbit != 1)
|
|
Packit |
db064d |
return "invalid cc_keyprotectbit value";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (cc_keyleaseperiod > USHRT_MAX)
|
|
Packit |
db064d |
return "invalid cc_keyleaseperiod value";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (cc_keyviolations > USHRT_MAX)
|
|
Packit |
db064d |
return "invalid cc_keyviolations value";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_set_field64(payload,
|
|
Packit |
db064d |
0,
|
|
Packit |
db064d |
IB_CC_CONGESTION_KEY_INFO_CC_KEY_F,
|
|
Packit |
db064d |
cc_key);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_CONGESTION_KEY_INFO_CC_KEY_PROTECT_BIT_F,
|
|
Packit |
db064d |
&cc_keyprotectbit);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_CONGESTION_KEY_INFO_CC_KEY_LEASE_PERIOD_F,
|
|
Packit |
db064d |
&cc_keyleaseperiod);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
/* spec says "setting the counter to a value other than zero results
|
|
Packit |
db064d |
* in the counter being left unchanged. So if user wants no change,
|
|
Packit |
db064d |
* they gotta input non-zero
|
|
Packit |
db064d |
*/
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_CONGESTION_KEY_INFO_CC_KEY_VIOLATIONS_F,
|
|
Packit |
db064d |
&cc_keyviolations);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (!cc_config_status_via(payload, rcv, dest, IB_CC_ATTR_CONGESTION_KEY_INFO,
|
|
Packit |
db064d |
0, 0, NULL, srcport, cckey))
|
|
Packit |
db064d |
return "congestion key info config failed";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
return NULL;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
|
|
Packit |
db064d |
/* parse like it's a hypothetical 256 bit hex code */
|
|
Packit |
db064d |
static const char *parse256(char *arg, uint8_t *buf)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
int numdigits = 0;
|
|
Packit |
db064d |
int startindex;
|
|
Packit |
db064d |
char *ptr;
|
|
Packit |
db064d |
int i;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (!strncmp(arg, "0x", 2) || !strncmp(arg, "0X", 2))
|
|
Packit |
db064d |
arg += 2;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
for (ptr = arg; *ptr; ptr++) {
|
|
Packit |
db064d |
if (!isxdigit(*ptr))
|
|
Packit |
db064d |
return "invalid hex digit read";
|
|
Packit |
db064d |
numdigits++;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (numdigits > 64)
|
|
Packit |
db064d |
return "hex code too long";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
/* we need to imagine that this is like a 256-bit int stored
|
|
Packit |
db064d |
* in big endian. So we need to find the first index
|
|
Packit |
db064d |
* point where the user's input would start in our array.
|
|
Packit |
db064d |
*/
|
|
Packit |
db064d |
startindex = 32 - ((numdigits - 1) / 2) - 1;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
for (i = startindex; i <= 31; i++) {
|
|
Packit |
db064d |
char tmp[3] = { 0 };
|
|
Packit |
db064d |
uint32_t tmpint;
|
|
Packit |
db064d |
const char *errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
/* I can't help but think there is a strtoX that
|
|
Packit |
db064d |
* will do this for me, but I can't find it.
|
|
Packit |
db064d |
*/
|
|
Packit |
db064d |
if (i == startindex && numdigits % 2) {
|
|
Packit |
db064d |
memcpy(tmp, arg, 1);
|
|
Packit |
db064d |
arg++;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
else {
|
|
Packit |
db064d |
memcpy(tmp, arg, 2);
|
|
Packit |
db064d |
arg += 2;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(tmp, &tmpint, 1)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
buf[i] = tmpint;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
return NULL;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static const char *parsecct(char *arg, uint32_t *shift, uint32_t *multiplier)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
char buf[1024] = { 0 };
|
|
Packit |
db064d |
const char *errstr;
|
|
Packit |
db064d |
char *ptr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
strcpy(buf, arg);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (!(ptr = strchr(buf, ':')))
|
|
Packit |
db064d |
return "ccts are formatted shift:multiplier";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
*ptr = '\0';
|
|
Packit |
db064d |
ptr++;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(buf, shift, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(ptr, multiplier, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
return NULL;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static const char *switch_congestion_setting(ib_portid_t *dest, char **argv,
|
|
Packit |
db064d |
int argc)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
uint8_t rcv[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint8_t payload[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint32_t control_map;
|
|
Packit |
db064d |
uint8_t victim_mask[32] = { 0 };
|
|
Packit |
db064d |
uint8_t credit_mask[32] = { 0 };
|
|
Packit |
db064d |
uint32_t threshold;
|
|
Packit |
db064d |
uint32_t packet_size;
|
|
Packit |
db064d |
uint32_t cs_threshold;
|
|
Packit |
db064d |
uint32_t cs_returndelay_s;
|
|
Packit |
db064d |
uint32_t cs_returndelay_m;
|
|
Packit |
db064d |
uint32_t cs_returndelay;
|
|
Packit |
db064d |
uint32_t marking_rate;
|
|
Packit |
db064d |
const char *errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (argc != 8)
|
|
Packit |
db064d |
return "invalid number of parameters for SwitchCongestionSetting";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[0], &control_map, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parse256(argv[1], victim_mask)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parse256(argv[2], credit_mask)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[3], &threshold, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[4], &packet_size, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[5], &cs_threshold, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parsecct(argv[6], &cs_returndelay_s, &cs_returndelay_m)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
cs_returndelay = cs_returndelay_m;
|
|
Packit |
db064d |
cs_returndelay |= (cs_returndelay_s << 14);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[7], &marking_rate, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_SWITCH_CONGESTION_SETTING_CONTROL_MAP_F,
|
|
Packit |
db064d |
&control_map);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_set_array(payload,
|
|
Packit |
db064d |
0,
|
|
Packit |
db064d |
IB_CC_SWITCH_CONGESTION_SETTING_VICTIM_MASK_F,
|
|
Packit |
db064d |
victim_mask);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_set_array(payload,
|
|
Packit |
db064d |
0,
|
|
Packit |
db064d |
IB_CC_SWITCH_CONGESTION_SETTING_CREDIT_MASK_F,
|
|
Packit |
db064d |
credit_mask);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_SWITCH_CONGESTION_SETTING_THRESHOLD_F,
|
|
Packit |
db064d |
&threshold);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_SWITCH_CONGESTION_SETTING_PACKET_SIZE_F,
|
|
Packit |
db064d |
&packet_size);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_SWITCH_CONGESTION_SETTING_CS_THRESHOLD_F,
|
|
Packit |
db064d |
&cs_threshold);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_SWITCH_CONGESTION_SETTING_CS_RETURN_DELAY_F,
|
|
Packit |
db064d |
&cs_returndelay);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_SWITCH_CONGESTION_SETTING_MARKING_RATE_F,
|
|
Packit |
db064d |
&marking_rate);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (!cc_config_status_via(payload, rcv, dest, IB_CC_ATTR_SWITCH_CONGESTION_SETTING,
|
|
Packit |
db064d |
0, 0, NULL, srcport, cckey))
|
|
Packit |
db064d |
return "switch congestion setting config failed";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
return NULL;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static const char *switch_port_congestion_setting(ib_portid_t *dest,
|
|
Packit |
db064d |
char **argv, int argc)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
uint8_t rcv[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint8_t payload[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint8_t data[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint32_t portnum;
|
|
Packit |
db064d |
uint32_t valid;
|
|
Packit |
db064d |
uint32_t control_type;
|
|
Packit |
db064d |
uint32_t threshold;
|
|
Packit |
db064d |
uint32_t packet_size;
|
|
Packit |
db064d |
uint32_t cong_parm_marking_rate;
|
|
Packit |
db064d |
uint32_t type;
|
|
Packit |
db064d |
uint32_t numports;
|
|
Packit |
db064d |
uint8_t *ptr;
|
|
Packit |
db064d |
const char *errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (argc != 6)
|
|
Packit |
db064d |
return "invalid number of parameters for SwitchPortCongestion";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[0], &portnum, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[1], &valid, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[2], &control_type, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[3], &threshold, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[4], &packet_size, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[5], &cong_parm_marking_rate, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
/* Figure out number of ports first */
|
|
Packit |
db064d |
if (!smp_query_via(data, dest, IB_ATTR_NODE_INFO, 0, 0, srcport))
|
|
Packit |
db064d |
return "node info config failed";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_decode_field((uint8_t *)data, IB_NODE_TYPE_F, &type);
|
|
Packit |
db064d |
mad_decode_field((uint8_t *)data, IB_NODE_NPORTS_F, &numports);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (type != IB_NODE_SWITCH)
|
|
Packit |
db064d |
return "destination not a switch";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (portnum > numports)
|
|
Packit |
db064d |
return "invalid port number specified";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
/* We are modifying only 1 port, so get the current config */
|
|
Packit |
db064d |
if (!cc_query_status_via(payload, dest, IB_CC_ATTR_SWITCH_PORT_CONGESTION_SETTING,
|
|
Packit |
db064d |
portnum / 32, 0, NULL, srcport, cckey))
|
|
Packit |
db064d |
return "switch port congestion setting query failed";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
ptr = payload + (((portnum % 32) * 4));
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(ptr,
|
|
Packit |
db064d |
IB_CC_SWITCH_PORT_CONGESTION_SETTING_ELEMENT_VALID_F,
|
|
Packit |
db064d |
&valid);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(ptr,
|
|
Packit |
db064d |
IB_CC_SWITCH_PORT_CONGESTION_SETTING_ELEMENT_CONTROL_TYPE_F,
|
|
Packit |
db064d |
&control_type);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(ptr,
|
|
Packit |
db064d |
IB_CC_SWITCH_PORT_CONGESTION_SETTING_ELEMENT_THRESHOLD_F,
|
|
Packit |
db064d |
&threshold);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(ptr,
|
|
Packit |
db064d |
IB_CC_SWITCH_PORT_CONGESTION_SETTING_ELEMENT_PACKET_SIZE_F,
|
|
Packit |
db064d |
&packet_size);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(ptr,
|
|
Packit |
db064d |
IB_CC_SWITCH_PORT_CONGESTION_SETTING_ELEMENT_CONG_PARM_MARKING_RATE_F,
|
|
Packit |
db064d |
&cong_parm_marking_rate);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (!cc_config_status_via(payload, rcv, dest, IB_CC_ATTR_SWITCH_PORT_CONGESTION_SETTING,
|
|
Packit |
db064d |
portnum / 48, 0, NULL, srcport, cckey))
|
|
Packit |
db064d |
return "switch port congestion setting config failed";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
return NULL;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static const char *ca_congestion_setting(ib_portid_t *dest, char **argv,
|
|
Packit |
db064d |
int argc)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
uint8_t rcv[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint8_t payload[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint32_t port_control;
|
|
Packit |
db064d |
uint32_t control_map;
|
|
Packit |
db064d |
uint32_t ccti_timer;
|
|
Packit |
db064d |
uint32_t ccti_increase;
|
|
Packit |
db064d |
uint32_t trigger_threshold;
|
|
Packit |
db064d |
uint32_t ccti_min;
|
|
Packit |
db064d |
const char *errstr;
|
|
Packit |
db064d |
int i;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (argc != 6)
|
|
Packit |
db064d |
return "invalid number of parameters for CACongestionSetting";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[0], &port_control, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[1], &control_map, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[2], &ccti_timer, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[3], &ccti_increase, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[4], &trigger_threshold, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[5], &ccti_min, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_CA_CONGESTION_SETTING_PORT_CONTROL_F,
|
|
Packit |
db064d |
&port_control);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_CA_CONGESTION_SETTING_CONTROL_MAP_F,
|
|
Packit |
db064d |
&control_map);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
for (i = 0; i < 16; i++) {
|
|
Packit |
db064d |
uint8_t *ptr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (!(control_map & (0x1 << i)))
|
|
Packit |
db064d |
continue;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
ptr = payload + 2 + 2 + i * 8;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(ptr,
|
|
Packit |
db064d |
IB_CC_CA_CONGESTION_ENTRY_CCTI_TIMER_F,
|
|
Packit |
db064d |
&ccti_timer);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(ptr,
|
|
Packit |
db064d |
IB_CC_CA_CONGESTION_ENTRY_CCTI_INCREASE_F,
|
|
Packit |
db064d |
&ccti_increase);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(ptr,
|
|
Packit |
db064d |
IB_CC_CA_CONGESTION_ENTRY_TRIGGER_THRESHOLD_F,
|
|
Packit |
db064d |
&trigger_threshold);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(ptr,
|
|
Packit |
db064d |
IB_CC_CA_CONGESTION_ENTRY_CCTI_MIN_F,
|
|
Packit |
db064d |
&ccti_min);
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (!cc_config_status_via(payload, rcv, dest, IB_CC_ATTR_CA_CONGESTION_SETTING,
|
|
Packit |
db064d |
0, 0, NULL, srcport, cckey))
|
|
Packit |
db064d |
return "ca congestion setting config failed";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
return NULL;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static const char *congestion_control_table(ib_portid_t *dest, char **argv,
|
|
Packit |
db064d |
int argc)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
uint8_t rcv[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint8_t payload[IB_CC_DATA_SZ] = { 0 };
|
|
Packit |
db064d |
uint32_t ccti_limit;
|
|
Packit |
db064d |
uint32_t index;
|
|
Packit |
db064d |
uint32_t cctshifts[64];
|
|
Packit |
db064d |
uint32_t cctmults[64];
|
|
Packit |
db064d |
const char *errstr;
|
|
Packit |
db064d |
int i;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (argc < 2 || argc > 66)
|
|
Packit |
db064d |
return "invalid number of parameters for CongestionControlTable";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[0], &ccti_limit, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if ((errstr = parseint(argv[1], &index, 0)))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (ccti_limit && (ccti_limit + 1) != (index * 64 + (argc - 2)))
|
|
Packit |
db064d |
return "invalid number of cct entries input given ccti_limit and index";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
for (i = 0; i < (argc - 2); i++) {
|
|
Packit |
db064d |
if ((errstr = parsecct(argv[i + 2], &cctshifts[i], &cctmults[i])))
|
|
Packit |
db064d |
return errstr;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload,
|
|
Packit |
db064d |
IB_CC_CONGESTION_CONTROL_TABLE_CCTI_LIMIT_F,
|
|
Packit |
db064d |
&ccti_limit);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
for (i = 0; i < (argc - 2); i++) {
|
|
Packit |
db064d |
mad_encode_field(payload + 4 + i * 2,
|
|
Packit |
db064d |
IB_CC_CONGESTION_CONTROL_TABLE_ENTRY_CCT_SHIFT_F,
|
|
Packit |
db064d |
&cctshifts[i]);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_encode_field(payload + 4 + i * 2,
|
|
Packit |
db064d |
IB_CC_CONGESTION_CONTROL_TABLE_ENTRY_CCT_MULTIPLIER_F,
|
|
Packit |
db064d |
&cctmults[i]);
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (!cc_config_status_via(payload, rcv, dest, IB_CC_ATTR_CONGESTION_CONTROL_TABLE,
|
|
Packit |
db064d |
index, 0, NULL, srcport, cckey))
|
|
Packit |
db064d |
return "congestion control table config failed";
|
|
Packit |
db064d |
|
|
Packit |
db064d |
return NULL;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
static int process_opt(void *context, int ch)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
switch (ch) {
|
|
Packit |
db064d |
case 'c':
|
|
Packit |
db064d |
cckey = (uint64_t) strtoull(optarg, NULL, 0);
|
|
Packit |
db064d |
break;
|
|
Packit |
db064d |
default:
|
|
Packit |
db064d |
return -1;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
return 0;
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
int main(int argc, char **argv)
|
|
Packit |
db064d |
{
|
|
Packit |
db064d |
char usage_args[1024];
|
|
Packit |
db064d |
int mgmt_classes[3] = { IB_SMI_CLASS, IB_SA_CLASS, IB_CC_CLASS };
|
|
Packit |
db064d |
ib_portid_t portid = { 0 };
|
|
Packit |
db064d |
const char *err;
|
|
Packit |
db064d |
op_fn_t *fn;
|
|
Packit |
db064d |
const match_rec_t *r;
|
|
Packit |
db064d |
int n;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
const struct ibdiag_opt opts[] = {
|
|
Packit |
db064d |
{"cckey", 'c', 1, "<key>", "CC key"},
|
|
Packit |
db064d |
{}
|
|
Packit |
db064d |
};
|
|
Packit |
db064d |
const char *usage_examples[] = {
|
|
Packit |
db064d |
"SwitchCongestionSetting 2 0x1F 0x1FFFFFFFFF 0x0 0xF 8 0 0:0 1\t# Configure Switch Congestion Settings",
|
|
Packit |
db064d |
"CACongestionSetting 1 0 0x3 150 1 0 0\t\t# Configure CA Congestion Settings to SL 0 and SL 1",
|
|
Packit |
db064d |
"CACongestionSetting 1 0 0x4 200 1 0 0\t\t# Configure CA Congestion Settings to SL 2",
|
|
Packit |
db064d |
"CongestionControlTable 1 63 0 0:0 0:1 ...\t# Configure first block of Congestion Control Table",
|
|
Packit |
db064d |
"CongestionControlTable 1 127 0 0:64 0:65 ...\t# Configure second block of Congestion Control Table",
|
|
Packit |
db064d |
NULL
|
|
Packit |
db064d |
};
|
|
Packit |
db064d |
|
|
Packit |
db064d |
n = sprintf(usage_args, "[-c key] <op> <lid|guid>\n"
|
|
Packit |
db064d |
"\nWARNING -- You should understand what you are "
|
|
Packit |
db064d |
"doing before using this tool. Misuse of this "
|
|
Packit |
db064d |
"tool could result in a broken fabric.\n"
|
|
Packit |
db064d |
"\nSupported ops (and aliases, case insensitive):\n");
|
|
Packit |
db064d |
for (r = match_tbl; r->name; r++) {
|
|
Packit |
db064d |
n += snprintf(usage_args + n, sizeof(usage_args) - n,
|
|
Packit |
db064d |
" %s (%s) <lid|guid>%s%s%s\n", r->name,
|
|
Packit |
db064d |
r->alias ? r->alias : "",
|
|
Packit |
db064d |
r->opt_portnum ? " <portnum>" : "",
|
|
Packit |
db064d |
r->ops_extra ? " " : "",
|
|
Packit |
db064d |
r->ops_extra ? r->ops_extra : "");
|
|
Packit |
db064d |
if (n >= sizeof(usage_args))
|
|
Packit |
db064d |
exit(-1);
|
|
Packit |
db064d |
}
|
|
Packit |
db064d |
|
|
Packit |
db064d |
ibdiag_process_opts(argc, argv, NULL, "DK", opts, process_opt,
|
|
Packit |
db064d |
usage_args, usage_examples);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
argc -= optind;
|
|
Packit |
db064d |
argv += optind;
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (argc < 2)
|
|
Packit |
db064d |
ibdiag_show_usage();
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (!(fn = match_op(match_tbl, argv[0])))
|
|
Packit |
db064d |
IBEXIT("operation '%s' not supported", argv[0]);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
srcport = mad_rpc_open_port(ibd_ca, ibd_ca_port, mgmt_classes, 3);
|
|
Packit |
db064d |
if (!srcport)
|
|
Packit |
db064d |
IBEXIT("Failed to open '%s' port '%d'", ibd_ca, ibd_ca_port);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
smp_mkey_set(srcport, ibd_mkey);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
if (resolve_portid_str(ibd_ca, ibd_ca_port, &portid, argv[1],
|
|
Packit |
db064d |
ibd_dest_type, ibd_sm_id, srcport) < 0)
|
|
Packit |
db064d |
IBEXIT("can't resolve destination %s", argv[1]);
|
|
Packit |
db064d |
if ((err = fn(&portid, argv + 2, argc - 2)))
|
|
Packit |
db064d |
IBEXIT("operation %s: %s", argv[0], err);
|
|
Packit |
db064d |
|
|
Packit |
db064d |
mad_rpc_close_port(srcport);
|
|
Packit |
db064d |
exit(0);
|
|
Packit |
db064d |
}
|