/root/freebsd/sys/dev/ocs_fc/ocs

Bug Summary

File:	dev/ocs_fc/ocs_mgmt.c
Warning:	line 855, column 7 Copies out a struct with a partially unsanitized field
Annotated Source Code

Press '?' to see keyboard shortcuts
Show analyzer invocation
clang -cc1 -triple x86_64-unknown-freebsd11.2 -analyze -disable-free -disable-llvm-verifier -discard-value-names -main-file-name ocs_mgmt.c -analyzer-store=region -analyzer-opt-analyze-nested-blocks -analyzer-checker=core -analyzer-checker=apiModeling -analyzer-checker=unix -analyzer-checker=deadcode -analyzer-checker=security.insecureAPI.UncheckedReturn -analyzer-checker=security.insecureAPI.getpw -analyzer-checker=security.insecureAPI.gets -analyzer-checker=security.insecureAPI.mktemp -analyzer-checker=security.insecureAPI.mkstemp -analyzer-checker=security.insecureAPI.vfork -analyzer-checker=nullability.NullPassedToNonnull -analyzer-checker=nullability.NullReturnedFromNonnull -analyzer-output plist -w -mrelocation-model static -mthread-model posix -mdisable-fp-elim -relaxed-aliasing -masm-verbose -mconstructor-aliases -ffreestanding -mcode-model kernel -target-cpu x86-64 -target-feature -mmx -target-feature -sse -target-feature -aes -target-feature -avx -disable-red-zone -no-implicit-float -dwarf-column-info -debugger-tuning=gdb -nostdsysteminc -nobuiltininc -resource-dir /root/kernel-uninitialized-memory-checker/build/lib/clang/8.0.0 -include /usr/obj/root/freebsd/amd64.amd64/sys/GENERIC/opt_global.h -D _KERNEL -D KLD_MODULE -D KLD_TIED -D HAVE_KERNEL_OPTION_HEADERS -I . -I /root/freebsd/sys -I /root/freebsd/sys/contrib/ck/include -I /usr/obj/root/freebsd/amd64.amd64/sys/GENERIC -D __printf__=__freebsd_kprintf__ -O2 -Wno-pointer-sign -Wno-unknown-pragmas -Wno-error-tautological-compare -Wno-error-empty-body -Wno-error-parentheses-equality -Wno-error-unused-function -Wno-error-pointer-sign -Wno-error-shift-negative-value -Wno-address-of-packed-member -std=iso9899:1999 -fdebug-compilation-dir /usr/obj/root/freebsd/amd64.amd64/sys/GENERIC/modules/root/freebsd/sys/modules/ocs_fc -ferror-limit 19 -fmessage-length 0 -fwrapv -stack-protector 1 -fobjc-runtime=gnustep -fno-common -fdiagnostics-show-option -vectorize-loops -vectorize-slp -analyzer-checker alpha.security.KernelMemoryDisclosure -analyzer-disable-checker core,unix,deadcode,nullability -analyzer-output=html -o /root/analyzer/2018-12-28-044519-76292-1 -x c /root/freebsd/sys/dev/ocs_fc/ocs_mgmt.c -faddrsig
1/*-
* Copyright (c) 2017 Broadcom. All rights reserved.
* The term "Broadcom" refers to Broadcom Limited and/or its subsidiaries.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are met:
*
* 1. Redistributions of source code must retain the above copyright notice,
*    this list of conditions and the following disclaimer.
*
* 2. 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.
*
* 3. Neither the name of the copyright holder nor the names of its contributors
*    may be used to endorse or promote products derived from this software
*    without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*
* $FreeBSD$
*/

34/**
* @file
* The ocs_mgmt top level functions for Fibre Channel.
*/

39/**
* @defgroup mgmt Management Functions
*/

43#include "ocs.h"
44#include "ocs_mgmt.h"
45#include "ocs_vpd.h"

47#define SFP_PAGE_SIZE128 128

49/* Executables*/

51static int ocs_mgmt_firmware_write(ocs_t *ocs, char *, void *buf, uint32_t buf_len, void*, uint32_t);
52static int ocs_mgmt_firmware_reset(ocs_t *ocs, char *, void *buf, uint32_t buf_len, void*, uint32_t);
53static int ocs_mgmt_function_reset(ocs_t *ocs, char *, void *buf, uint32_t buf_len, void*, uint32_t);

55static void ocs_mgmt_fw_write_cb(int32_t status, uint32_t actual_write_length, uint32_t change_status, void *arg);
56static int ocs_mgmt_force_assert(ocs_t *ocs, char *, void *buf, uint32_t buf_len, void*, uint32_t);

58#if defined(OCS_INCLUDE_RAMD)
59static int32_t
60ocs_mgmt_read_phys(ocs_t *ocs, char *, void *, uint32_t , void *, uint32_t);
61#endif


64/* Getters */

66static void get_nodes_count(ocs_t *, char *, ocs_textbuf_t*);
67static void get_desc(ocs_t *, char *, ocs_textbuf_t*);
68static void get_fw_rev(ocs_t *, char *, ocs_textbuf_t*);
69static void get_fw_rev2(ocs_t *, char *, ocs_textbuf_t*);
70static void get_ipl(ocs_t *, char *, ocs_textbuf_t*);
71static void get_wwnn(ocs_t *, char *, ocs_textbuf_t*);
72static void get_wwpn(ocs_t *, char *, ocs_textbuf_t*);
73static void get_fcid(ocs_t *, char *, ocs_textbuf_t *);
74static void get_sn(ocs_t *, char *, ocs_textbuf_t*);
75static void get_pn(ocs_t *, char *, ocs_textbuf_t*);
76static void get_sli4_intf_reg(ocs_t *, char *, ocs_textbuf_t*);
77static void get_phy_port_num(ocs_t *, char *, ocs_textbuf_t*);
78static void get_asic_id(ocs_t *, char *, ocs_textbuf_t*);
79static void get_pci_vendor(ocs_t *, char *, ocs_textbuf_t*);
80static void get_pci_device(ocs_t *, char *, ocs_textbuf_t*);
81static void get_pci_subsystem_vendor(ocs_t *, char *, ocs_textbuf_t*);
82static void get_pci_subsystem_device(ocs_t *, char *, ocs_textbuf_t*);
83static void get_businfo(ocs_t *, char *, ocs_textbuf_t*);
84static void get_sfp_a0(ocs_t *, char *, ocs_textbuf_t*);
85static void get_sfp_a2(ocs_t *, char *, ocs_textbuf_t*);
86static void get_hw_rev1(ocs_t *, char *, ocs_textbuf_t*);
87static void get_hw_rev2(ocs_t *, char *, ocs_textbuf_t*);
88static void get_hw_rev3(ocs_t *, char *, ocs_textbuf_t*);
89static void get_debug_mq_dump(ocs_t*, char*, ocs_textbuf_t*);
90static void get_debug_cq_dump(ocs_t*, char*, ocs_textbuf_t*);
91static void get_debug_wq_dump(ocs_t*, char*, ocs_textbuf_t*);
92static void get_debug_eq_dump(ocs_t*, char*, ocs_textbuf_t*);
93static void get_logmask(ocs_t*, char*, ocs_textbuf_t*);
94static void get_current_speed(ocs_t*, char*, ocs_textbuf_t*);
95static void get_current_topology(ocs_t*, char*, ocs_textbuf_t*);
96static void get_current_link_state(ocs_t*, char*, ocs_textbuf_t*);
97static void get_configured_speed(ocs_t*, char*, ocs_textbuf_t*);
98static void get_configured_topology(ocs_t*, char*, ocs_textbuf_t*);
99static void get_configured_link_state(ocs_t*, char*, ocs_textbuf_t*);
100static void get_linkcfg(ocs_t*, char*, ocs_textbuf_t*);
101static void get_req_wwnn(ocs_t*, char*, ocs_textbuf_t*);
102static void get_req_wwpn(ocs_t*, char*, ocs_textbuf_t*);
103static void get_nodedb_mask(ocs_t*, char*, ocs_textbuf_t*);
104static void get_profile_list(ocs_t*, char*, ocs_textbuf_t*);
105static void get_active_profile(ocs_t*, char*, ocs_textbuf_t*);
106static void get_port_protocol(ocs_t*, char*, ocs_textbuf_t*);
107static void get_driver_version(ocs_t*, char*, ocs_textbuf_t*);
108static void get_chip_type(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
109static void get_tgt_rscn_delay(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
110static void get_tgt_rscn_period(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
111static void get_inject_drop_cmd(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
112static void get_inject_free_drop_cmd(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
113static void get_inject_drop_data(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
114static void get_inject_drop_resp(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
115static void get_cmd_err_inject(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
116static void get_cmd_delay_value(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
117static void get_nv_wwpn(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
118static void get_nv_wwnn(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
119static void get_loglevel(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);
120static void get_node_abort_cnt(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf);

122/* Setters */
123static int set_debug_mq_dump(ocs_t*, char*, char*);
124static int set_debug_cq_dump(ocs_t*, char*, char*);
125static int set_debug_wq_dump(ocs_t*, char*, char*);
126static int set_debug_eq_dump(ocs_t*, char*, char*);
127static int set_logmask(ocs_t*, char*, char*);
128static int set_configured_link_state(ocs_t*, char*, char*);
129static int set_linkcfg(ocs_t*, char*, char*);
130static int set_nodedb_mask(ocs_t*, char*, char*);
131static int set_port_protocol(ocs_t*, char*, char*);
132static int set_active_profile(ocs_t*, char*, char*);
133static int set_tgt_rscn_delay(ocs_t*, char*, char*);
134static int set_tgt_rscn_period(ocs_t*, char*, char*);
135static int set_inject_drop_cmd(ocs_t*, char*, char*);
136static int set_inject_free_drop_cmd(ocs_t*, char*, char*);
137static int set_inject_drop_data(ocs_t*, char*, char*);
138static int set_inject_drop_resp(ocs_t*, char*, char*);
139static int set_cmd_err_inject(ocs_t*, char*, char*);
140static int set_cmd_delay_value(ocs_t*, char*, char*);
141static int set_nv_wwn(ocs_t*, char*, char*);
142static int set_loglevel(ocs_t*, char*, char*);

144static void ocs_mgmt_linkcfg_cb(int32_t status, uintptr_t value, void *arg);
145#if defined(OCS_INCLUDE_RAMD)
146static void* find_address_in_target(ocs_ramdisc_t **ramdisc_array, uint32_t ramdisc_count, uintptr_t target_addr);
147#endif

149ocs_mgmt_table_entry_t mgmt_table[] = {
{"nodes_count", get_nodes_count, NULL((void *)0), NULL((void *)0)},
{"desc", get_desc, NULL((void *)0), NULL((void *)0)},
{"fw_rev", get_fw_rev, NULL((void *)0), NULL((void *)0)},
{"fw_rev2", get_fw_rev2, NULL((void *)0), NULL((void *)0)},
{"ipl", get_ipl, NULL((void *)0), NULL((void *)0)},
{"hw_rev1", get_hw_rev1, NULL((void *)0), NULL((void *)0)},
{"hw_rev2", get_hw_rev2, NULL((void *)0), NULL((void *)0)},
{"hw_rev3", get_hw_rev3, NULL((void *)0), NULL((void *)0)},
{"wwnn", get_wwnn, NULL((void *)0), NULL((void *)0)},
{"wwpn", get_wwpn, NULL((void *)0), NULL((void *)0)},
{"fc_id", get_fcid, NULL((void *)0), NULL((void *)0)},
{"sn", get_sn, NULL((void *)0), NULL((void *)0)},
{"pn", get_pn, NULL((void *)0), NULL((void *)0)},
{"sli4_intf_reg", get_sli4_intf_reg, NULL((void *)0), NULL((void *)0)},
{"phy_port_num", get_phy_port_num, NULL((void *)0), NULL((void *)0)},
{"asic_id_reg", get_asic_id, NULL((void *)0), NULL((void *)0)},
{"pci_vendor", get_pci_vendor, NULL((void *)0), NULL((void *)0)},
{"pci_device", get_pci_device, NULL((void *)0), NULL((void *)0)},
{"pci_subsystem_vendor", get_pci_subsystem_vendor, NULL((void *)0), NULL((void *)0)},
{"pci_subsystem_device", get_pci_subsystem_device, NULL((void *)0), NULL((void *)0)},
{"businfo", get_businfo, NULL((void *)0), NULL((void *)0)},
{"sfp_a0", get_sfp_a0, NULL((void *)0), NULL((void *)0)},
{"sfp_a2", get_sfp_a2, NULL((void *)0), NULL((void *)0)},
{"profile_list", get_profile_list, NULL((void *)0), NULL((void *)0)},
{"driver_version", get_driver_version, NULL((void *)0), NULL((void *)0)},
{"current_speed", get_current_speed, NULL((void *)0), NULL((void *)0)},
{"current_topology", get_current_topology, NULL((void *)0), NULL((void *)0)},
{"current_link_state", get_current_link_state, NULL((void *)0), NULL((void *)0)},
{"chip_type", get_chip_type, NULL((void *)0), NULL((void *)0)},
{"configured_speed", get_configured_speed, set_configured_speed, NULL((void *)0)},
{"configured_topology", get_configured_topology, set_configured_topology, NULL((void *)0)},
{"configured_link_state", get_configured_link_state, set_configured_link_state, NULL((void *)0)},
{"debug_mq_dump", get_debug_mq_dump, set_debug_mq_dump, NULL((void *)0)},
{"debug_cq_dump", get_debug_cq_dump, set_debug_cq_dump, NULL((void *)0)},
{"debug_wq_dump", get_debug_wq_dump, set_debug_wq_dump, NULL((void *)0)},
{"debug_eq_dump", get_debug_eq_dump, set_debug_eq_dump, NULL((void *)0)},
{"logmask", get_logmask, set_logmask, NULL((void *)0)},
{"loglevel", get_loglevel, set_loglevel, NULL((void *)0)},
{"linkcfg", get_linkcfg, set_linkcfg, NULL((void *)0)},
{"requested_wwnn", get_req_wwnn, set_req_wwnn, NULL((void *)0)},
{"requested_wwpn", get_req_wwpn, set_req_wwpn, NULL((void *)0)},
{"nodedb_mask", get_nodedb_mask, set_nodedb_mask, NULL((void *)0)},
{"port_protocol", get_port_protocol, set_port_protocol, NULL((void *)0)},
{"active_profile", get_active_profile, set_active_profile, NULL((void *)0)},
{"firmware_write", NULL((void *)0), NULL((void *)0), ocs_mgmt_firmware_write},
{"firmware_reset", NULL((void *)0), NULL((void *)0), ocs_mgmt_firmware_reset},
{"function_reset", NULL((void *)0), NULL((void *)0), ocs_mgmt_function_reset},
197#if defined(OCS_INCLUDE_RAMD)
{"read_phys", NULL((void *)0), NULL((void *)0), ocs_mgmt_read_phys},
199#endif
{"force_assert", NULL((void *)0), NULL((void *)0), ocs_mgmt_force_assert},

{"tgt_rscn_delay", get_tgt_rscn_delay, set_tgt_rscn_delay, NULL((void *)0)},
{"tgt_rscn_period", get_tgt_rscn_period, set_tgt_rscn_period, NULL((void *)0)},
{"inject_drop_cmd", get_inject_drop_cmd, set_inject_drop_cmd, NULL((void *)0)},
{"inject_free_drop_cmd", get_inject_free_drop_cmd, set_inject_free_drop_cmd, NULL((void *)0)},
{"inject_drop_data", get_inject_drop_data, set_inject_drop_data, NULL((void *)0)},
{"inject_drop_resp", get_inject_drop_resp, set_inject_drop_resp, NULL((void *)0)},
{"cmd_err_inject", get_cmd_err_inject, set_cmd_err_inject, NULL((void *)0)},
{"cmd_delay_value", get_cmd_delay_value, set_cmd_delay_value, NULL((void *)0)},
{"nv_wwpn", get_nv_wwpn, NULL((void *)0), NULL((void *)0)},
{"nv_wwnn", get_nv_wwnn, NULL((void *)0), NULL((void *)0)},
{"nv_wwn", NULL((void *)0), set_nv_wwn, NULL((void *)0)},
{"node_abort_cnt", get_node_abort_cnt, NULL((void *)0), NULL((void *)0)},
214};

216/**
* @ingroup mgmt
* @brief Get a list of options supported by the driver.
*
* @par Description
* This is the top level "get list" handler for the driver. It
* performs the following:
*  - Adds entries to the textbuf for any actions supported by this level in the driver.
*  - Calls a back-end function to add any actions supported by the back-end.
*  - Calls a function on each child (domain) to recursively add supported actions.
*
* @param ocs Pointer to the ocs structure.
* @param textbuf Pointer to an ocs_textbuf, which is used to accumulate the results.
*
* @return Returns 0 on success, or a negative value on failure.
*/

233void
234ocs_mgmt_get_list(ocs_t *ocs, ocs_textbuf_t *textbuf)
235{
ocs_domain_t *domain;
uint32_t i;
int access;

ocs_mgmt_start_unnumbered_section(textbuf, "ocs");

for (i=0;i<ARRAY_SIZE(mgmt_table)(sizeof(mgmt_table) / sizeof((mgmt_table)[0]));i++) {
access = 0;
if (mgmt_table[i].get_handler) {
	access |= MGMT_MODE_RD4;
}
if (mgmt_table[i].set_handler) {
	access |= MGMT_MODE_WR2;
}
if (mgmt_table[i].action_handler) {
	access |= MGMT_MODE_EX1;
}
ocs_mgmt_emit_property_name(textbuf, access, mgmt_table[i].name);
}

if ((ocs->mgmt_functions) && (ocs->mgmt_functions->get_list_handler)) {
ocs->mgmt_functions->get_list_handler(textbuf, ocs);
}

if ((ocs->tgt_mgmt_functions) && (ocs->tgt_mgmt_functions->get_list_handler)) {
ocs->tgt_mgmt_functions->get_list_handler(textbuf, &(ocs->tgt_ocs));
}

/* Have each of my children add their actions */
if (ocs_device_lock_try(ocs) == TRUE1) {

/* If we get here then we are holding the device lock */
ocs_list_foreach(&ocs->domain_list, domain)for (domain = ocs_list_get_head((&ocs->domain_list)); domain
; domain = ocs_list_next((&ocs->domain_list), domain) ) {
	if ((domain->mgmt_functions) && (domain->mgmt_functions->get_list_handler)) {
		domain->mgmt_functions->get_list_handler(textbuf, domain);
	}
}
ocs_device_unlock(ocs);
}

ocs_mgmt_end_unnumbered_section(textbuf, "ocs");

278}

280/**
* @ingroup mgmt
* @brief Return the value of a management item.
*
* @par Description
* This is the top level "get" handler for the driver. It
* performs the following:
*  - Checks that the qualifier portion of the name begins with my qualifier (ocs).
*  - If the remaining part of the name matches a parameter that is known at this level,
*    writes the value into textbuf.
*  - If the name is not known, sends the request to the back-ends to fulfill (if possible).
*  - If the request has not been fulfilled by the back-end,
*    passes the request to each of the children (domains) to
*    have them (recursively) try to respond.
*
*  In passing the request to other entities, the request is considered to be answered
*  when a response has been written into textbuf, indicated by textbuf->buffer_written
*  being non-zero.
*
* @param ocs Pointer to the ocs structure.
* @param name Name of the status item to be retrieved.
* @param textbuf Pointer to an ocs_textbuf, which is used to return the results.
*
* @return Returns 0 if the value was found and returned, or -1 if an error occurred.
*/


307int
308ocs_mgmt_get(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
309{
ocs_domain_t *domain;
char qualifier[6];
int retval = -1;
uint32_t i;

ocs_mgmt_start_unnumbered_section(textbuf, "ocs");


snprintf(qualifier, sizeof(qualifier), "/ocs");

/* See if the name starts with my qualifier.  If not then this request isn't for me */
if (ocs_strncmp(name, qualifier, strlen(qualifier))strncmp(name,qualifier,strlen(qualifier)) == 0) {
char *unqualified_name = name + strlen(qualifier) + 1;

for (i=0;i<ARRAY_SIZE(mgmt_table)(sizeof(mgmt_table) / sizeof((mgmt_table)[0]));i++) {
	if (ocs_strcmp(unqualified_name, mgmt_table[i].name)strcmp(unqualified_name,mgmt_table[i].name) == 0) {
		if (mgmt_table[i].get_handler) {
			mgmt_table[i].get_handler(ocs, name, textbuf);
			ocs_mgmt_end_unnumbered_section(textbuf, "ocs");
			return 0;
		}
	}
}

if ((ocs->mgmt_functions) && (ocs->mgmt_functions->get_handler)) {
	retval = ocs->mgmt_functions->get_handler(textbuf, qualifier, (char*)name, ocs);
}

if (retval != 0) {
	if ((ocs->tgt_mgmt_functions) && (ocs->tgt_mgmt_functions->get_handler)) {
		retval = ocs->tgt_mgmt_functions->get_handler(textbuf, qualifier,
				(char*)name, &(ocs->tgt_ocs));
	}
}

if (retval != 0) {
	/* The driver didn't handle it, pass it to each domain */

	ocs_device_lock(ocs);
	ocs_list_foreach(&ocs->domain_list, domain)for (domain = ocs_list_get_head((&ocs->domain_list)); domain
; domain = ocs_list_next((&ocs->domain_list), domain) ) {
		if ((domain->mgmt_functions) && (domain->mgmt_functions->get_handler)) {
			retval = domain->mgmt_functions->get_handler(textbuf, qualifier, (char*)name, domain);
		}

		if (retval ==  0) {
			break;
		}


	}
	ocs_device_unlock(ocs);
}

}

ocs_mgmt_end_unnumbered_section(textbuf, "ocs");

return retval;
368}


371/**
* @ingroup mgmt
* @brief Set the value of a mgmt item.
*
* @par Description
* This is the top level "set" handler for the driver. It
* performs the following:
*  - Checks that the qualifier portion of the name begins with my qualifier (ocs).
*  - If the remaining part of the name matches a parameter that is known at this level,
*    calls the correct function to change the configuration.
*  - If the name is not known, sends the request to the back-ends to fulfill (if possible).
*  - If the request has not been fulfilled by the back-end, passes the request to each of the
*    children (domains) to have them (recursively) try to respond.
*
*  In passing the request to other entities, the request is considered to be handled
*  if the function returns 0.
*
* @param ocs Pointer to the ocs structure.
* @param name Name of the property to be changed.
* @param value Requested new value of the property.
*
* @return Returns 0 if the configuration value was updated, or -1 otherwise.
*/

395int
396ocs_mgmt_set(ocs_t *ocs, char *name, char *value)
397{
ocs_domain_t *domain;
int result = -1;
char qualifier[80];
uint32_t i;

snprintf(qualifier, sizeof(qualifier), "/ocs");

/* If it doesn't start with my qualifier I don't know what to do with it */
if (ocs_strncmp(name, qualifier, strlen(qualifier))strncmp(name,qualifier,strlen(qualifier)) == 0) {
char *unqualified_name = name + strlen(qualifier) +1;

/* See if it's a value I can set */
for (i=0;i<ARRAY_SIZE(mgmt_table)(sizeof(mgmt_table) / sizeof((mgmt_table)[0]));i++) {
	if (ocs_strcmp(unqualified_name, mgmt_table[i].name)strcmp(unqualified_name,mgmt_table[i].name) == 0) {
		if (mgmt_table[i].set_handler) {
			return mgmt_table[i].set_handler(ocs, name, value);
		}
	}
}

if ((ocs->mgmt_functions) && (ocs->mgmt_functions->set_handler)) {
	result = ocs->mgmt_functions->set_handler(qualifier, name, (char *)value, ocs);
}

if (result != 0) {
	if ((ocs->tgt_mgmt_functions) && (ocs->tgt_mgmt_functions->set_handler)) {
		result = ocs->tgt_mgmt_functions->set_handler(qualifier, name,
				(char *)value, &(ocs->tgt_ocs));
	}
}

/* If I didn't know how to set this config value pass the request to each of my children */
if (result != 0) {
	ocs_device_lock(ocs);
	ocs_list_foreach(&ocs->domain_list, domain)for (domain = ocs_list_get_head((&ocs->domain_list)); domain
; domain = ocs_list_next((&ocs->domain_list), domain) ) {
		if ((domain->mgmt_functions) && (domain->mgmt_functions->set_handler)) {
			result = domain->mgmt_functions->set_handler(qualifier, name, (char*)value, domain);
		}
		if (result == 0) {
			break;
		}
	}
	ocs_device_unlock(ocs);
}


}

return result;
447}

449/**
* @ingroup mgmt
* @brief Perform a management action.
*
* @par Description
* This is the top level "exec" handler for the driver. It
* performs the following:
*  - Checks that the qualifier portion of the name begins with my qualifier (ocs).
*  - If the remaining part of the name matches an action that is known at this level,
*    calls the correct function to perform the action.
*  - If the name is not known, sends the request to the back-ends to fulfill (if possible).
*  - If the request has not been fulfilled by the back-end, passes the request to each of the
*    children (domains) to have them (recursively) try to respond.
*
*  In passing the request to other entities, the request is considered to be handled
*  if the function returns 0.
*
* @param ocs Pointer to the ocs structure.
* @param action Name of the action to be performed.
* @param arg_in Pointer to an argument being passed to the action.
* @param arg_in_length Length of the argument pointed to by @c arg_in.
* @param arg_out Pointer to an argument being passed to the action.
* @param arg_out_length Length of the argument pointed to by @c arg_out.
*
* @return Returns 0 if the action was completed, or -1 otherwise.
*
*
*/

478int
479ocs_mgmt_exec(ocs_t *ocs, char *action, void *arg_in,
uint32_t arg_in_length, void *arg_out, uint32_t arg_out_length)
481{
ocs_domain_t *domain;
int result = -1;
char qualifier[80];
uint32_t i;

snprintf(qualifier, sizeof(qualifier), "/ocs");

/* If it doesn't start with my qualifier I don't know what to do with it */
if (ocs_strncmp(action, qualifier, strlen(qualifier))strncmp(action,qualifier,strlen(qualifier)) == 0) {
char *unqualified_name = action + strlen(qualifier) +1;

/* See if it's an action I can perform */
for (i=0;i<ARRAY_SIZE(mgmt_table)(sizeof(mgmt_table) / sizeof((mgmt_table)[0])); i++) {
	if (ocs_strcmp(unqualified_name, mgmt_table[i].name)strcmp(unqualified_name,mgmt_table[i].name) == 0) {
		if (mgmt_table[i].action_handler) {
			return mgmt_table[i].action_handler(ocs, action, arg_in, arg_in_length,
					arg_out, arg_out_length);
		}

	}
}

if ((ocs->mgmt_functions) && (ocs->mgmt_functions->exec_handler)) {
	result = ocs->mgmt_functions->exec_handler(qualifier, action, arg_in, arg_in_length,
						   arg_out, arg_out_length, ocs);
}

if (result != 0) {
	if ((ocs->tgt_mgmt_functions) && (ocs->tgt_mgmt_functions->exec_handler)) {
		result = ocs->tgt_mgmt_functions->exec_handler(qualifier, action,
				arg_in, arg_in_length, arg_out, arg_out_length,
				&(ocs->tgt_ocs));
	}
}

/* If I didn't know how to do this action pass the request to each of my children */
if (result != 0) {
	ocs_device_lock(ocs);
	ocs_list_foreach(&ocs->domain_list, domain)for (domain = ocs_list_get_head((&ocs->domain_list)); domain
; domain = ocs_list_next((&ocs->domain_list), domain) ) {
		if ((domain->mgmt_functions) && (domain->mgmt_functions->exec_handler)) {
			result = domain->mgmt_functions->exec_handler(qualifier, action, arg_in, arg_in_length, arg_out,
					arg_out_length, domain);
		}
		if (result == 0) {
			break;
		}
	}
	ocs_device_unlock(ocs);
}

}

return result;
535}

537void
538ocs_mgmt_get_all(ocs_t *ocs, ocs_textbuf_t *textbuf)
539{
ocs_domain_t *domain;
uint32_t i;

ocs_mgmt_start_unnumbered_section(textbuf, "ocs");

for (i=0;i<ARRAY_SIZE(mgmt_table)(sizeof(mgmt_table) / sizeof((mgmt_table)[0]));i++) {
if (mgmt_table[i].get_handler) {
	mgmt_table[i].get_handler(ocs, mgmt_table[i].name, textbuf);
} else if (mgmt_table[i].action_handler) {
	/* No get_handler, but there's an action_handler. Just report
	   the name */
	ocs_mgmt_emit_property_name(textbuf, MGMT_MODE_EX1, mgmt_table[i].name);
}
}

if ((ocs->mgmt_functions) && (ocs->mgmt_functions->get_all_handler)) {
ocs->mgmt_functions->get_all_handler(textbuf, ocs);
}

if ((ocs->tgt_mgmt_functions) && (ocs->tgt_mgmt_functions->get_all_handler)) {
ocs->tgt_mgmt_functions->get_all_handler(textbuf, &(ocs->tgt_ocs));
}

ocs_device_lock(ocs);
ocs_list_foreach(&ocs->domain_list, domain)for (domain = ocs_list_get_head((&ocs->domain_list)); domain
; domain = ocs_list_next((&ocs->domain_list), domain) ) {
if ((domain->mgmt_functions) && (domain->mgmt_functions->get_all_handler)) {
	domain->mgmt_functions->get_all_handler(textbuf, domain);
}
}
ocs_device_unlock(ocs);

ocs_mgmt_end_unnumbered_section(textbuf, "ocs");
572}

574#if defined(OCS_INCLUDE_RAMD)
575static int32_t
576ocs_mgmt_read_phys(ocs_t *ocs, char *name, void *arg_in, uint32_t arg_in_length, void *arg_out, uint32_t arg_out_length)
577{
      uint32_t length;
      char addr_str[80];
      uintptr_t target_addr;
      void* vaddr = NULL((void *)0);
      ocs_ramdisc_t **ramdisc_array;
      uint32_t ramdisc_count;


      if ((arg_in == NULL((void *)0)) ||
          (arg_in_length == 0) ||
          (arg_out == NULL((void *)0)) ||
          (arg_out_length == 0)) {
              return -1;
      }

      if (arg_in_length > 80) {
              arg_in_length = 80;
      }

      if (ocs_copy_from_user(addr_str, arg_in, arg_in_length)copyin(arg_in, addr_str, arg_in_length)) {
              ocs_log_test(ocs, "Failed to copy addr from user\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 598, "Failed to copy addr from user\n"
); } } while (0);;
              return -EFAULT14;
      }

      target_addr = (uintptr_t)ocs_strtoul(addr_str, NULL, 0)strtoul(addr_str,((void *)0),0);
      /* addr_str must be the physical address of a buffer that was reported
       * in an SGL.  Search ramdiscs looking for a segment that contains that
       * physical address
       */

      if (ocs->tgt_ocs.use_global_ramd) {
              /* Only one target */
              ramdisc_count = ocs->tgt_ocs.rdisc_count;
              ramdisc_array = ocs->tgt_ocs.rdisc;
              vaddr = find_address_in_target(ramdisc_array, ramdisc_count, target_addr);
      } else {
              /* Multiple targets.  Each target is on a sport */
uint32_t domain_idx;

for (domain_idx=0; domain_idx<ocs->domain_instance_count; domain_idx++) {
	ocs_domain_t *domain;
	uint32_t sport_idx;

	domain = ocs_domain_get_instance(ocs, domain_idx);
	for (sport_idx=0; sport_idx < domain->sport_instance_count; sport_idx++) {
		ocs_sport_t *sport;

		sport = ocs_sport_get_instance(domain, sport_idx);
		ramdisc_count = sport->tgt_sport.rdisc_count;
		ramdisc_array = sport->tgt_sport.rdisc;
		vaddr = find_address_in_target(ramdisc_array, ramdisc_count, target_addr);

		if (vaddr != NULL((void *)0)) {
			break;
		}
	}
              }
      }




      length = arg_out_length;

      if (vaddr != NULL((void *)0)) {

              if (ocs_copy_to_user(arg_out, vaddr, length)copyout(vaddr, arg_out, length)) {
                      ocs_log_test(ocs, "Failed to copy buffer to user\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 645, "Failed to copy buffer to user\n"
); } } while (0);;
                      return -EFAULT14;
              }

              return 0;
      } else {

              return -EFAULT14;
}

655}

657/*
* This function searches a target for a given physical address.
* The target is made up of a number of LUNs, each represented by
* a ocs_ramdisc_t.
*/
662static void* find_address_in_target(ocs_ramdisc_t **ramdisc_array, uint32_t ramdisc_count, uintptr_t target_addr)
663{
void *vaddr = NULL((void *)0);
uint32_t ramdisc_idx;

/* Check each ramdisc */
for (ramdisc_idx=0; ramdisc_idx<ramdisc_count; ramdisc_idx++) {
uint32_t segment_idx;
ocs_ramdisc_t *rdisc;
rdisc = ramdisc_array[ramdisc_idx];
/* Check each segment in the ramdisc */
for (segment_idx=0; segment_idx<rdisc->segment_count; segment_idx++) {
	ramdisc_segment_t *segment = rdisc->segments[segment_idx];
	uintptr_t segment_start;
	uintptr_t segment_end;
	uint32_t offset;

	segment_start = segment->data_segment.phys;
	segment_end = segment->data_segment.phys + segment->data_segment.size - 1;
	if ((target_addr >= segment_start) && (target_addr <= segment_end)) {
		/* Found the target address */
		offset = target_addr - segment_start;
		vaddr = (uint32_t*)segment->data_segment.virt + offset;
	}

	if (rdisc->dif_separate) {
		segment_start = segment->dif_segment.phys;
		segment_end = segment->data_segment.phys + segment->dif_segment.size - 1;
		if ((target_addr >= segment_start) && (target_addr <= segment_end)) {
			/* Found the target address */
			offset = target_addr - segment_start;
			vaddr = (uint32_t*)segment->dif_segment.virt + offset;
		}
	}

	if (vaddr != NULL((void *)0)) {
		break;
	}

}

if (vaddr != NULL((void *)0)) {
	break;
}


}

return vaddr;
711}
712#endif



716static int32_t
717ocs_mgmt_firmware_reset(ocs_t *ocs, char *name, void *buf, uint32_t buf_len, void *arg_out, uint32_t arg_out_length)
718{
int rc = 0;
int index = 0;
uint8_t bus, dev, func;
ocs_t *other_ocs;

ocs_get_bus_dev_func(ocs, &bus, &dev, &func);

ocs_log_debug(ocs, "Resetting port\n")do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 726, "Resetting port\n"
); } } while (0);;
if (ocs_hw_reset(&ocs->hw, OCS_HW_RESET_FIRMWARE)) {
ocs_log_test(ocs, "failed to reset port\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 728, "failed to reset port\n"
); } } while (0);;
rc = -1;
} else {
ocs_log_debug(ocs, "successfully reset port\n")do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 731, "successfully reset port\n"
); } } while (0);;

/* now reset all functions on the same device */

while ((other_ocs = ocs_get_instance(index++)) != NULL((void *)0)) {
	uint8_t other_bus, other_dev, other_func;

	ocs_get_bus_dev_func(other_ocs, &other_bus, &other_dev, &other_func);

	if ((bus == other_bus) && (dev == other_dev)) {
		if (other_ocs->hw.state !=
                                    OCS_HW_STATE_UNINITIALIZED) {
                                      other_ocs->hw.state =
                                              OCS_HW_STATE_QUEUES_ALLOCATED;
                              }

		ocs_device_detach(other_ocs);
		if (ocs_device_attach(other_ocs)) {
			ocs_log_err(other_ocs,do { if (1 <= loglevel) { _ocs_log(other_ocs, __func__, 750
, "device %d attach failed \n", index); } } while (0);
				"device %d attach failed \n", index)do { if (1 <= loglevel) { _ocs_log(other_ocs, __func__, 750
, "device %d attach failed \n", index); } } while (0);;
			rc = -1;
		}
	}
}
}
return rc;
757}

759static int32_t
760ocs_mgmt_function_reset(ocs_t *ocs, char *name, void *buf, uint32_t buf_len, void *arg_out, uint32_t arg_out_length)
761{
int32_t rc;

ocs_device_detach(ocs);
rc = ocs_device_attach(ocs);

return rc;
768}

770static int32_t
771ocs_mgmt_firmware_write(ocs_t *ocs, char *name, void *buf, uint32_t buf_len, void *arg_out, uint32_t arg_out_length)
772{
int rc = 0;
uint32_t bytes_left;
uint32_t xfer_size;
uint32_t offset;
uint8_t *userp;
ocs_dma_t dma;
int last = 0;
ocs_mgmt_fw_write_result_t result;
uint32_t change_status = 0;
      char status_str[80];

ocs_sem_init(&(result.semaphore), 0, "fw_write");

bytes_left = buf_len;
offset = 0;
userp = (uint8_t *)buf;

if (ocs_dma_alloc(ocs, &dma, FW_WRITE_BUFSIZE64*1024, 4096)) {
1
Assuming the condition is false→
2
←
Taking false branch→
ocs_log_err(ocs, "ocs_mgmt_firmware_write: malloc failed")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 791, "ocs_mgmt_firmware_write: malloc failed"
); } } while (0);;
return -ENOMEM12;
}

while (bytes_left > 0) {
3
←
Assuming 'bytes_left' is <= 0→
4
←
Loop condition is false. Execution continues on line 850→


if (bytes_left > FW_WRITE_BUFSIZE64*1024) {
	xfer_size = FW_WRITE_BUFSIZE64*1024;
} else {
	xfer_size = bytes_left;
}

/* Copy xfer_size bytes from user space to kernel buffer */
if (ocs_copy_from_user(dma.virt, userp, xfer_size)copyin(userp, dma.virt, xfer_size)) {
	rc = -EFAULT14;
	break;
}

/* See if this is the last block */
if (bytes_left == xfer_size) {
	last = 1;
}

/* Send the HW command */
ocs_hw_firmware_write(&ocs->hw, &dma, xfer_size, offset, last, ocs_mgmt_fw_write_cb, &result);

/* Wait for semaphore to be signaled when the command completes
 * TODO:  Should there be a timeout on this?  If so, how long? */
if (ocs_sem_p(&(result.semaphore), OCS_SEM_FOREVER(-1)) != 0) {
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 821, "ocs_sem_p failed\n"
); } } while (0);;
	rc = -ENXIO6;
	break;
}

if (result.actual_xfer == 0) {
	ocs_log_test(ocs, "actual_write_length is %d\n", result.actual_xfer)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 827, "actual_write_length is %d\n"
, result.actual_xfer); } } while (0);;
	rc = -EFAULT14;
	break;
}

/* Check status */
if (result.status != 0) {
	ocs_log_test(ocs, "write returned status %d\n", result.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 834, "write returned status %d\n"
, result.status); } } while (0);;
	rc = -EFAULT14;
	break;
}

if (last) {
	change_status = result.change_status;
}

bytes_left -= result.actual_xfer;
offset += result.actual_xfer;
userp += result.actual_xfer;

}

/* Create string with status and copy to userland */
if ((arg_out_length > 0) && (arg_out != NULL((void *)0))) {
5
←
Assuming 'arg_out_length' is > 0→
6
←
Assuming 'arg_out' is not equal to NULL→
7
←
Taking true branch→
if (arg_out_length > sizeof(status_str)) {
8
←
Assuming the condition is true→
9
←
Taking true branch→
	arg_out_length = sizeof(status_str);
}
ocs_snprintf(status_str, arg_out_length, "%d", change_status)snprintf(status_str, arg_out_length, "%d", change_status);
10
←
Partial initialization occurs here→
if (ocs_copy_to_user(arg_out, status_str, arg_out_length)copyout(status_str, arg_out, arg_out_length)) {
11
←
Copies out a struct with a partially unsanitized field
	ocs_log_test(ocs, "copy to user failed for change_status\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 856, "copy to user failed for change_status\n"
); } } while (0);;
}
}


ocs_dma_free(ocs, &dma);

return rc;
864}

866static void
867ocs_mgmt_fw_write_cb(int32_t status, uint32_t actual_write_length, uint32_t change_status, void *arg)
868{
ocs_mgmt_fw_write_result_t *result = arg;

result->status = status;
result->actual_xfer = actual_write_length;
result->change_status = change_status;

ocs_sem_v(&(result->semaphore));
876}

878typedef struct ocs_mgmt_sfp_result {
ocs_sem_t semaphore;
ocs_lock_t cb_lock;
int32_t running;
int32_t status;
uint32_t bytes_read;
uint32_t page_data[32];
885} ocs_mgmt_sfp_result_t;

887static void
888ocs_mgmt_sfp_cb(void *os, int32_t status, uint32_t bytes_read, uint32_t *data, void *arg)
889{
ocs_mgmt_sfp_result_t *result = arg;
ocs_t *ocs = os;

ocs_lock(&(result->cb_lock));
result->running++;
if(result->running == 2) {
/* get_sfp() has timed out */
ocs_unlock(&(result->cb_lock));
ocs_free(ocs, result, sizeof(ocs_mgmt_sfp_result_t));
return;
}

result->status = status;
result->bytes_read = bytes_read;
ocs_memcpy(&result->page_data, data, SFP_PAGE_SIZE)__builtin_memcpy((&result->page_data), (data), (128));

ocs_sem_v(&(result->semaphore));
ocs_unlock(&(result->cb_lock));
908}

910static int32_t
911ocs_mgmt_get_sfp(ocs_t *ocs, uint16_t page, void *buf, uint32_t buf_len)
912{
int rc = 0;
ocs_mgmt_sfp_result_t *result = ocs_malloc(ocs, sizeof(ocs_mgmt_sfp_result_t),  OCS_M_ZERO0x0100 | OCS_M_NOWAIT0x0001);;

ocs_sem_init(&(result->semaphore), 0, "get_sfp");
ocs_lock_init(ocs, &(result->cb_lock), "get_sfp");

/* Send the HW command */
ocs_hw_get_sfp(&ocs->hw, page, ocs_mgmt_sfp_cb, result);

/* Wait for semaphore to be signaled when the command completes */
if (ocs_sem_p(&(result->semaphore), 5 * 1000 * 1000) != 0) {
/* Timed out, callback will free memory */
ocs_lock(&(result->cb_lock));
result->running++;
if(result->running == 1) {
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 928, "ocs_sem_p failed\n"
); } } while (0);;
	ocs_unlock(&(result->cb_lock));
	return (-ENXIO6);
}
/* sfp_cb() has already executed, proceed as normal */
ocs_unlock(&(result->cb_lock));
}

/* Check status */
if (result->status != 0) {
ocs_log_test(ocs, "read_transceiver_data returned status %d\n",do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 939, "read_transceiver_data returned status %d\n"
, result->status); } } while (0);
	     result->status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 939, "read_transceiver_data returned status %d\n"
, result->status); } } while (0);;
rc = -EFAULT14;
}

if (rc == 0) {
rc = (result->bytes_read > buf_len ? buf_len : result->bytes_read);
/* Copy the results back to the supplied buffer */
ocs_memcpy(buf, result->page_data, rc)__builtin_memcpy((buf), (result->page_data), (rc));
}

ocs_free(ocs, result, sizeof(ocs_mgmt_sfp_result_t));
return rc;
951}

953static int32_t
954ocs_mgmt_force_assert(ocs_t *ocs, char *name, void *buf, uint32_t buf_len, void *arg_out, uint32_t arg_out_length)
955{
ocs_assert(FALSE, 0)do { if (!(0)) { _ocs_assert("FALSE", "/root/freebsd/sys/dev/ocs_fc/ocs_mgmt.c"
, 956); return 0; } } while (0);
957}

959static void
960get_nodes_count(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
961{
ocs_xport_t *xport = ocs->xport;

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "nodes_count", "%d", xport->nodes_count);
965}

967static void
968get_driver_version(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
969{
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "driver_version", ocs->driver_version);
971}

973static void
974get_desc(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
975{
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "desc", ocs->desc);
977}

979static void
980get_fw_rev(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
981{
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "fw_rev", ocs_hw_get_ptr(&ocs->hw, OCS_HW_FW_REV));
983}

985static void
986get_fw_rev2(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
987{
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "fw_rev2", ocs_hw_get_ptr(&ocs->hw, OCS_HW_FW_REV2));
989}

991static void
992get_ipl(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
993{
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "ipl", ocs_hw_get_ptr(&ocs->hw, OCS_HW_IPL));
995}

997static void
998get_hw_rev1(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
999{
uint32_t value;

ocs_hw_get(&ocs->hw, OCS_HW_HW_REV1, &value);

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "hw_rev1", "%u", value);
1005}

1007static void
1008get_hw_rev2(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1009{
uint32_t value;

ocs_hw_get(&ocs->hw, OCS_HW_HW_REV2, &value);

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "hw_rev2", "%u", value);
1015}

1017static void
1018get_hw_rev3(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1019{
uint32_t value;
ocs_hw_get(&ocs->hw, OCS_HW_HW_REV3, &value);

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "hw_rev3", "%u", value);
1024}

1026static void
1027get_wwnn(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1028{
uint64_t *wwnn;

wwnn = ocs_hw_get_ptr(&ocs->hw, OCS_HW_WWN_NODE);

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "wwnn", "0x%llx", (unsigned long long)ocs_htobe64(*wwnn)(__builtin_constant_p((*wwnn)) ? (((__uint64_t)(__builtin_constant_p
(((__uint64_t)((*wwnn))) & 0xffffffff) ? (((__uint32_t)((
__uint16_t)(__builtin_constant_p(((__uint32_t)(((__uint64_t)(
(*wwnn))) & 0xffffffff)) & 0xffff) ? (__uint16_t)(((__uint16_t
)(((__uint32_t)(((__uint64_t)((*wwnn))) & 0xffffffff)) &
 0xffff)) << 8 | ((__uint16_t)(((__uint32_t)(((__uint64_t
)((*wwnn))) & 0xffffffff)) & 0xffff)) >> 8) : __bswap16_var
(((__uint32_t)(((__uint64_t)((*wwnn))) & 0xffffffff)) &
 0xffff))) << 16) | ((__uint16_t)(__builtin_constant_p(
((__uint32_t)(((__uint64_t)((*wwnn))) & 0xffffffff)) >>
 16) ? (__uint16_t)(((__uint16_t)(((__uint32_t)(((__uint64_t)
((*wwnn))) & 0xffffffff)) >> 16)) << 8 | ((__uint16_t
)(((__uint32_t)(((__uint64_t)((*wwnn))) & 0xffffffff)) >>
 16)) >> 8) : __bswap16_var(((__uint32_t)(((__uint64_t)
((*wwnn))) & 0xffffffff)) >> 16)))) : __bswap32_var
(((__uint64_t)((*wwnn))) & 0xffffffff)) << 32) | (__builtin_constant_p
(((__uint64_t)((*wwnn))) >> 32) ? (((__uint32_t)((__uint16_t
)(__builtin_constant_p(((__uint32_t)(((__uint64_t)((*wwnn))) >>
 32)) & 0xffff) ? (__uint16_t)(((__uint16_t)(((__uint32_t
)(((__uint64_t)((*wwnn))) >> 32)) & 0xffff)) <<
| ((__uint16_t)(((__uint32_t)(((__uint64_t)((*wwnn))) >>
 32)) & 0xffff)) >> 8) : __bswap16_var(((__uint32_t
)(((__uint64_t)((*wwnn))) >> 32)) & 0xffff))) <<
 16) | ((__uint16_t)(__builtin_constant_p(((__uint32_t)(((__uint64_t
)((*wwnn))) >> 32)) >> 16) ? (__uint16_t)(((__uint16_t
)(((__uint32_t)(((__uint64_t)((*wwnn))) >> 32)) >>
 16)) << 8 | ((__uint16_t)(((__uint32_t)(((__uint64_t)(
(*wwnn))) >> 32)) >> 16)) >> 8) : __bswap16_var
(((__uint32_t)(((__uint64_t)((*wwnn))) >> 32)) >>
 16)))) : __bswap32_var(((__uint64_t)((*wwnn))) >> 32))
) : __bswap64_var((*wwnn))));
1034}

1036static void
1037get_wwpn(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1038{
uint64_t *wwpn;

wwpn = ocs_hw_get_ptr(&ocs->hw, OCS_HW_WWN_PORT);

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "wwpn", "0x%llx", (unsigned long long)ocs_htobe64(*wwpn)(__builtin_constant_p((*wwpn)) ? (((__uint64_t)(__builtin_constant_p
(((__uint64_t)((*wwpn))) & 0xffffffff) ? (((__uint32_t)((
__uint16_t)(__builtin_constant_p(((__uint32_t)(((__uint64_t)(
(*wwpn))) & 0xffffffff)) & 0xffff) ? (__uint16_t)(((__uint16_t
)(((__uint32_t)(((__uint64_t)((*wwpn))) & 0xffffffff)) &
 0xffff)) << 8 | ((__uint16_t)(((__uint32_t)(((__uint64_t
)((*wwpn))) & 0xffffffff)) & 0xffff)) >> 8) : __bswap16_var
(((__uint32_t)(((__uint64_t)((*wwpn))) & 0xffffffff)) &
 0xffff))) << 16) | ((__uint16_t)(__builtin_constant_p(
((__uint32_t)(((__uint64_t)((*wwpn))) & 0xffffffff)) >>
 16) ? (__uint16_t)(((__uint16_t)(((__uint32_t)(((__uint64_t)
((*wwpn))) & 0xffffffff)) >> 16)) << 8 | ((__uint16_t
)(((__uint32_t)(((__uint64_t)((*wwpn))) & 0xffffffff)) >>
 16)) >> 8) : __bswap16_var(((__uint32_t)(((__uint64_t)
((*wwpn))) & 0xffffffff)) >> 16)))) : __bswap32_var
(((__uint64_t)((*wwpn))) & 0xffffffff)) << 32) | (__builtin_constant_p
(((__uint64_t)((*wwpn))) >> 32) ? (((__uint32_t)((__uint16_t
)(__builtin_constant_p(((__uint32_t)(((__uint64_t)((*wwpn))) >>
 32)) & 0xffff) ? (__uint16_t)(((__uint16_t)(((__uint32_t
)(((__uint64_t)((*wwpn))) >> 32)) & 0xffff)) <<
| ((__uint16_t)(((__uint32_t)(((__uint64_t)((*wwpn))) >>
 32)) & 0xffff)) >> 8) : __bswap16_var(((__uint32_t
)(((__uint64_t)((*wwpn))) >> 32)) & 0xffff))) <<
 16) | ((__uint16_t)(__builtin_constant_p(((__uint32_t)(((__uint64_t
)((*wwpn))) >> 32)) >> 16) ? (__uint16_t)(((__uint16_t
)(((__uint32_t)(((__uint64_t)((*wwpn))) >> 32)) >>
 16)) << 8 | ((__uint16_t)(((__uint32_t)(((__uint64_t)(
(*wwpn))) >> 32)) >> 16)) >> 8) : __bswap16_var
(((__uint32_t)(((__uint64_t)((*wwpn))) >> 32)) >>
 16)))) : __bswap32_var(((__uint64_t)((*wwpn))) >> 32))
) : __bswap64_var((*wwpn))));
1044}

1046static void
1047get_fcid(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1048{

if (ocs->domain && ocs->domain->attached) {
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "fc_id", "0x%06x", 
				ocs->domain->sport->fc_id);
} else {
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "fc_id", "UNKNOWN"); 
}

1057}

1059static void
1060get_sn(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1061{
uint8_t *pserial;
uint32_t len;
char sn_buf[256];

pserial = ocs_scsi_get_property_ptr(ocs, OCS_SCSI_SERIALNUMBER);
if (pserial) {
len = *pserial ++;
strncpy(sn_buf, (char*)pserial, len);
sn_buf[len] = '\0';
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "sn", sn_buf);
}
1073}

1075static void
1076get_pn(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1077{
uint8_t *pserial;
uint32_t len;
char sn_buf[256];

pserial = ocs_scsi_get_property_ptr(ocs, OCS_SCSI_PARTNUMBER);
if (pserial) {
len = *pserial ++;
strncpy(sn_buf, (char*)pserial, len);
sn_buf[len] = '\0';
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "pn", sn_buf);
} else {
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "pn", ocs->model);
}
1091}

1093static void
1094get_sli4_intf_reg(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1095{

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "sli4_intf_reg", "0x%04x",
ocs_config_read32(ocs, SLI4_INTF_REG0x0058));
1099}

1101static void
1102get_phy_port_num(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1103{
char *phy_port = NULL((void *)0);

phy_port = ocs_scsi_get_property_ptr(ocs, OCS_SCSI_PORTNUM);
if (phy_port) {
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "phy_port_num", phy_port);
} else {
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "phy_port_num", "unknown");
}
1112}
1113static void
1114get_asic_id(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1115{

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "asic_id_reg", "0x%04x",
ocs_config_read32(ocs, SLI4_ASIC_ID_REG0x009c));
1119}

1121static void
1122get_chip_type(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1123{
uint32_t family;
uint32_t asic_id;
uint32_t asic_gen_num;
uint32_t asic_rev_num;
uint32_t rev_id;
char result_buf[80];
char tmp_buf[80];

family = (ocs_config_read32(ocs, SLI4_INTF_REG0x0058) & 0x00000f00) >> 8;
asic_id = ocs_config_read32(ocs, SLI4_ASIC_ID_REG0x009c);
asic_rev_num = asic_id & 0xff;
asic_gen_num = (asic_id & 0xff00) >> 8;

rev_id = ocs_config_read32(ocs, SLI4_PCI_CLASS_REVISION0x0008) & 0xff;

switch(family) {
case 0x00:
/* BE2 */
ocs_strncpy(result_buf,  "BE2 A", sizeof(result_buf))strncpy(result_buf, "BE2 A", sizeof(result_buf));
ocs_snprintf(tmp_buf, 2, "%d", rev_id)snprintf(tmp_buf, 2, "%d", rev_id);
strcat(result_buf, tmp_buf);
break;
case 0x01:
/* BE3 */
ocs_strncpy(result_buf, "BE3", sizeof(result_buf))strncpy(result_buf, "BE3", sizeof(result_buf));
if (rev_id >= 0x10) {
	strcat(result_buf, "-R");
}
ocs_snprintf(tmp_buf, 3, " %c", ((rev_id & 0xf0) >> 4) + 'A')snprintf(tmp_buf, 3, " %c", ((rev_id & 0xf0) >> 4) +
 'A');
strcat(result_buf, tmp_buf);
ocs_snprintf(tmp_buf, 2, "%d", rev_id & 0x0f)snprintf(tmp_buf, 2, "%d", rev_id & 0x0f);
strcat(result_buf, tmp_buf);
break;
case 0x02:
/* Skyhawk A0 */
ocs_strncpy(result_buf, "Skyhawk A0", sizeof(result_buf))strncpy(result_buf, "Skyhawk A0", sizeof(result_buf));
break;
case 0x0a:
/* Lancer A0 */
ocs_strncpy(result_buf, "Lancer A", sizeof(result_buf))strncpy(result_buf, "Lancer A", sizeof(result_buf));
ocs_snprintf(tmp_buf, 2, "%d", rev_id & 0x0f)snprintf(tmp_buf, 2, "%d", rev_id & 0x0f);
strcat(result_buf, tmp_buf);
break;
case 0x0b:
/* Lancer B0 or D0 */
ocs_strncpy(result_buf, "Lancer", sizeof(result_buf))strncpy(result_buf, "Lancer", sizeof(result_buf));
ocs_snprintf(tmp_buf, 3, " %c", ((rev_id & 0xf0) >> 4) + 'A')snprintf(tmp_buf, 3, " %c", ((rev_id & 0xf0) >> 4) +
 'A');
strcat(result_buf, tmp_buf);
ocs_snprintf(tmp_buf, 2, "%d", rev_id & 0x0f)snprintf(tmp_buf, 2, "%d", rev_id & 0x0f);
strcat(result_buf, tmp_buf);
break;
case 0x0c:
ocs_strncpy(result_buf, "Lancer G6", sizeof(result_buf))strncpy(result_buf, "Lancer G6", sizeof(result_buf));
break;
case 0x0f:
/* Refer to ASIC_ID */
switch(asic_gen_num) {
case 0x00:
	ocs_strncpy(result_buf, "BE2", sizeof(result_buf))strncpy(result_buf, "BE2", sizeof(result_buf));
	break;
case 0x03:
	ocs_strncpy(result_buf, "BE3-R", sizeof(result_buf))strncpy(result_buf, "BE3-R", sizeof(result_buf));
	break;
case 0x04:
	ocs_strncpy(result_buf, "Skyhawk-R", sizeof(result_buf))strncpy(result_buf, "Skyhawk-R", sizeof(result_buf));
	break;
case 0x05:
	ocs_strncpy(result_buf, "Corsair", sizeof(result_buf))strncpy(result_buf, "Corsair", sizeof(result_buf));
	break;
case 0x0b:
	ocs_strncpy(result_buf, "Lancer", sizeof(result_buf))strncpy(result_buf, "Lancer", sizeof(result_buf));
	break;
case 0x0c:
	ocs_strncpy(result_buf, "LancerG6", sizeof(result_buf))strncpy(result_buf, "LancerG6", sizeof(result_buf));
	break;
default:
	ocs_strncpy(result_buf, "Unknown", sizeof(result_buf))strncpy(result_buf, "Unknown", sizeof(result_buf));
}
if (ocs_strcmp(result_buf, "Unknown")strcmp(result_buf,"Unknown") != 0) {
	ocs_snprintf(tmp_buf, 3, " %c", ((asic_rev_num & 0xf0) >> 4) + 'A')snprintf(tmp_buf, 3, " %c", ((asic_rev_num & 0xf0) >>
 4) + 'A');
	strcat(result_buf, tmp_buf);
	ocs_snprintf(tmp_buf, 2, "%d", asic_rev_num & 0x0f)snprintf(tmp_buf, 2, "%d", asic_rev_num & 0x0f);
	strcat(result_buf, tmp_buf);
}
break;
default:
ocs_strncpy(result_buf, "Unknown", sizeof(result_buf))strncpy(result_buf, "Unknown", sizeof(result_buf));
}

ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "chip_type", result_buf);

1215}

1217static void
1218get_pci_vendor(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1219{

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "pci_vendor", "0x%04x", ocs->pci_vendor);
1222}

1224static void
1225get_pci_device(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1226{

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "pci_device", "0x%04x", ocs->pci_device);
1229}

1231static void
1232get_pci_subsystem_vendor(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1233{

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "pci_subsystem_vendor", "0x%04x", ocs->pci_subsystem_vendor);
1236}

1238static void
1239get_pci_subsystem_device(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1240{

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "pci_subsystem_device", "0x%04x", ocs->pci_subsystem_device);
1243}

1245static void
1246get_tgt_rscn_delay(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1247{
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "tgt_rscn_delay", "%ld", (unsigned long)ocs->tgt_rscn_delay_msec / 1000);
1249}

1251static void
1252get_tgt_rscn_period(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1253{
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "tgt_rscn_period", "%ld", (unsigned long)ocs->tgt_rscn_period_msec / 1000);
1255}

1257static void
1258get_inject_drop_cmd(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1259{
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "inject_drop_cmd", "%d",
	(ocs->err_injection == INJECT_DROP_CMD ? 1:0));
1262}

1264static void
1265get_inject_free_drop_cmd(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1266{
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "inject_free_drop_cmd", "%d",
	(ocs->err_injection == INJECT_FREE_DROPPED ? 1:0));
1269}

1271static void
1272get_inject_drop_data(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1273{
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "inject_drop_data", "%d",
	(ocs->err_injection == INJECT_DROP_DATA ? 1:0));
1276}

1278static void
1279get_inject_drop_resp(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1280{
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "inject_drop_resp", "%d",
	(ocs->err_injection == INJECT_DROP_RESP ? 1:0));
1283}

1285static void
1286get_cmd_err_inject(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1287{
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "cmd_err_inject", "0x%02x", ocs->cmd_err_inject);
1289}

1291static void
1292get_cmd_delay_value(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1293{
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "cmd_delay_value", "%ld", (unsigned long)ocs->delay_value_msec);
1295}

1297static void
1298get_businfo(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1299{
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "businfo", ocs->businfo);
1301}

1303static void
1304get_sfp_a0(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1305{
uint8_t *page_data;
char *buf;
int i;
int32_t bytes_read;

page_data = ocs_malloc(ocs, SFP_PAGE_SIZE128, OCS_M_ZERO0x0100 | OCS_M_NOWAIT0x0001);
if (page_data == NULL((void *)0)) {
return;
}

buf = ocs_malloc(ocs, (SFP_PAGE_SIZE128 * 3) + 1, OCS_M_ZERO0x0100 | OCS_M_NOWAIT0x0001);
if (buf == NULL((void *)0)) {
ocs_free(ocs, page_data, SFP_PAGE_SIZE128);
return;
}

bytes_read = ocs_mgmt_get_sfp(ocs, 0xa0, page_data, SFP_PAGE_SIZE128);

if (bytes_read <= 0) {
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "sfp_a0", "(unknown)");
} else {
char *d = buf;
uint8_t *s = page_data;
int buffer_remaining = (SFP_PAGE_SIZE128 * 3) + 1;
int bytes_added;

for (i = 0; i < bytes_read; i++) {
	bytes_added = ocs_snprintf(d, buffer_remaining, "%02x ", *s)snprintf(d, buffer_remaining, "%02x ", *s);
	++s;
	d += bytes_added;
	buffer_remaining -= bytes_added;
}
*d = '\0';
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "sfp_a0", buf);
}

ocs_free(ocs, page_data, SFP_PAGE_SIZE128);
ocs_free(ocs, buf, (3 * SFP_PAGE_SIZE128) + 1);
1344}

1346static void
1347get_sfp_a2(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1348{
uint8_t *page_data;
char *buf;
int i;
int32_t bytes_read;

page_data = ocs_malloc(ocs, SFP_PAGE_SIZE128, OCS_M_ZERO0x0100 | OCS_M_NOWAIT0x0001);
if (page_data == NULL((void *)0)) {
return;
}

buf = ocs_malloc(ocs, (SFP_PAGE_SIZE128 * 3) + 1, OCS_M_ZERO0x0100 | OCS_M_NOWAIT0x0001);
if (buf == NULL((void *)0)) {
ocs_free(ocs, page_data, SFP_PAGE_SIZE128);
return;
}

bytes_read = ocs_mgmt_get_sfp(ocs, 0xa2, page_data, SFP_PAGE_SIZE128);

if (bytes_read <= 0) {
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "sfp_a2", "(unknown)");
} else {
char *d = buf;
uint8_t *s = page_data;
int buffer_remaining = (SFP_PAGE_SIZE128 * 3) + 1;
int bytes_added;

for (i=0; i < bytes_read; i++) {
	bytes_added = ocs_snprintf(d, buffer_remaining, "%02x ", *s)snprintf(d, buffer_remaining, "%02x ", *s);
	++s;
	d += bytes_added;
	buffer_remaining -= bytes_added;
}
*d = '\0';
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "sfp_a2", buf);
}

ocs_free(ocs, page_data, SFP_PAGE_SIZE128);
ocs_free(ocs, buf, (3 * SFP_PAGE_SIZE128) + 1);
1387}

1389static void
1390get_debug_mq_dump(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1391{

ocs_mgmt_emit_boolean(textbuf, MGMT_MODE_RW(4 | 2), "debug_mq_dump",
ocs_debug_is_enabled(OCS_DEBUG_ENABLE_MQ_DUMP(1U << 1)));
1395}

1397static void
1398get_debug_cq_dump(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1399{

ocs_mgmt_emit_boolean(textbuf, MGMT_MODE_RW(4 | 2), "debug_cq_dump",
ocs_debug_is_enabled(OCS_DEBUG_ENABLE_CQ_DUMP(1U << 2)));
1403}

1405static void
1406get_debug_wq_dump(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1407{
ocs_mgmt_emit_boolean(textbuf, MGMT_MODE_RW(4 | 2), "debug_wq_dump",
ocs_debug_is_enabled(OCS_DEBUG_ENABLE_WQ_DUMP(1U << 3)));
1410}

1412static void
1413get_debug_eq_dump(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1414{
ocs_mgmt_emit_boolean(textbuf, MGMT_MODE_RW(4 | 2), "debug_eq_dump",
ocs_debug_is_enabled(OCS_DEBUG_ENABLE_EQ_DUMP(1U << 4)));
1417}

1419static void
1420get_logmask(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1421{

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "logmask", "0x%02x", ocs->logmask);

1425}

1427static void
1428get_loglevel(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1429{

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "loglevel", "%d", loglevel);

1433}

1435static void
1436get_current_speed(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1437{
uint32_t value;

ocs_hw_get(&(ocs->hw), OCS_HW_LINK_SPEED, &value);

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "current_speed", "%d", value);
1443}

1445static void
1446get_configured_speed(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1447{
uint32_t value;

ocs_hw_get(&(ocs->hw), OCS_HW_LINK_CONFIG_SPEED, &value);
if (value == 0) {
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "configured_speed", "auto");
} else {
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "configured_speed", "%d", value);
}

1457}

1459static void
1460get_current_topology(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1461{
uint32_t value;

ocs_hw_get(&(ocs->hw), OCS_HW_TOPOLOGY, &value);
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "current_topology", "%d", value);

1467}

1469static void
1470get_configured_topology(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1471{
uint32_t value;

ocs_hw_get(&(ocs->hw), OCS_HW_CONFIG_TOPOLOGY, &value);
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "configured_topology", "%d", value);

1477}

1479static void
1480get_current_link_state(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1481{
ocs_xport_stats_t value;

if (ocs_xport_status(ocs->xport, OCS_XPORT_PORT_STATUS, &value) == 0) {
if (value.value == OCS_XPORT_PORT_ONLINE) {
	ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "current_link_state", "online");
} else {
	ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "current_link_state", "offline");
}
}
1491}

1493static void
1494get_configured_link_state(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1495{
ocs_xport_stats_t value;

if (ocs_xport_status(ocs->xport, OCS_XPORT_CONFIG_PORT_STATUS, &value) == 0) {
if (value.value == OCS_XPORT_PORT_ONLINE) {
	ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "configured_link_state", "online");
} else {
	ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "configured_link_state", "offline");
}
}
1505}

1507/**
* @brief HW link config enum to mgmt string value mapping.
*
* This structure provides a mapping from the ocs_hw_linkcfg_e
* enum (enum exposed for the OCS_HW_PORT_SET_LINK_CONFIG port
* control) to the mgmt string that is passed in by the mgmt application
* (elxsdkutil).
*/
1515typedef struct ocs_mgmt_linkcfg_map_s {
ocs_hw_linkcfg_e linkcfg;
const char *mgmt_str;
1518} ocs_mgmt_linkcfg_map_t;

1520static ocs_mgmt_linkcfg_map_t mgmt_linkcfg_map[] = {
{OCS_HW_LINKCFG_4X10G, OCS_CONFIG_LINKCFG_4X10G"ETH_4x10G"},
{OCS_HW_LINKCFG_1X40G, OCS_CONFIG_LINKCFG_1X40G"ETH_1x40G"},
{OCS_HW_LINKCFG_2X16G, OCS_CONFIG_LINKCFG_2X16G"FC_2x16G"},
{OCS_HW_LINKCFG_4X8G, OCS_CONFIG_LINKCFG_4X8G"FC_4x8G"},
{OCS_HW_LINKCFG_4X1G, OCS_CONFIG_LINKCFG_4X1G"FC_4x1G"},
{OCS_HW_LINKCFG_2X10G, OCS_CONFIG_LINKCFG_2X10G"ETH_2x10G"},
{OCS_HW_LINKCFG_2X10G_2X8G, OCS_CONFIG_LINKCFG_2X10G_2X8G"ETH_2x10G_FC_2x8G"}};

1529/**
* @brief Get the HW linkcfg enum from the mgmt config string.
*
* @param mgmt_str mgmt string value.
*
* @return Returns the HW linkcfg enum corresponding to clp_str.
*/
1536static ocs_hw_linkcfg_e
1537ocs_hw_linkcfg_from_mgmt(const char *mgmt_str)
1538{
uint32_t i;
for (i = 0; i < ARRAY_SIZE(mgmt_linkcfg_map)(sizeof(mgmt_linkcfg_map) / sizeof((mgmt_linkcfg_map)[0])); i++) {
if (ocs_strncmp(mgmt_linkcfg_map[i].mgmt_str,strncmp(mgmt_linkcfg_map[i].mgmt_str,mgmt_str,strlen(mgmt_str
))
		mgmt_str, ocs_strlen(mgmt_str))strncmp(mgmt_linkcfg_map[i].mgmt_str,mgmt_str,strlen(mgmt_str
)) == 0) {
	return mgmt_linkcfg_map[i].linkcfg;
}
}
return OCS_HW_LINKCFG_NA;
1547}

1549/**
* @brief Get the mgmt string value from the HW linkcfg enum.
*
* @param linkcfg HW linkcfg enum.
*
* @return Returns the mgmt string value corresponding to the given HW linkcfg.
*/
1556static const char *
1557ocs_mgmt_from_hw_linkcfg(ocs_hw_linkcfg_e linkcfg)
1558{
uint32_t i;
for (i = 0; i < ARRAY_SIZE(mgmt_linkcfg_map)(sizeof(mgmt_linkcfg_map) / sizeof((mgmt_linkcfg_map)[0])); i++) {
if (mgmt_linkcfg_map[i].linkcfg == linkcfg) {
	return mgmt_linkcfg_map[i].mgmt_str;
}
}
return OCS_CONFIG_LINKCFG_UNKNOWN"UNKNOWN";
1566}

1568/**
* @brief Link configuration callback argument
*/
1571typedef struct ocs_mgmt_linkcfg_arg_s {
ocs_sem_t semaphore;
int32_t status;
ocs_hw_linkcfg_e linkcfg;
1575} ocs_mgmt_linkcfg_arg_t;

1577/**
* @brief Get linkcfg config value
*
* @param ocs Pointer to the ocs structure.
* @param name Not used.
* @param textbuf The textbuf to which the result is written.
*
* @return None.
*/
1586static void
1587get_linkcfg(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1588{
const char *linkcfg_str = NULL((void *)0);
uint32_t value;
ocs_hw_linkcfg_e linkcfg;
ocs_hw_get(&ocs->hw, OCS_HW_LINKCFG, &value);
linkcfg = (ocs_hw_linkcfg_e)value;
linkcfg_str = ocs_mgmt_from_hw_linkcfg(linkcfg);
ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "linkcfg", linkcfg_str);
1596}

1598/**
* @brief Get requested WWNN config value
*
* @param ocs Pointer to the ocs structure.
* @param name Not used.
* @param textbuf The textbuf to which the result is written.
*
* @return None.
*/
1607static void
1608get_req_wwnn(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1609{
ocs_xport_t *xport = ocs->xport;

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "requested_wwnn", "0x%llx", (unsigned long long)xport->req_wwnn);
1613}

1615/**
* @brief Get requested WWPN config value
*
* @param ocs Pointer to the ocs structure.
* @param name Not used.
* @param textbuf The textbuf to which the result is written.
*
* @return None.
*/
1624static void
1625get_req_wwpn(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1626{
ocs_xport_t *xport = ocs->xport;

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "requested_wwpn", "0x%llx", (unsigned long long)xport->req_wwpn);
1630}

1632/**
* @brief Get requested nodedb_mask config value
*
* @param ocs Pointer to the ocs structure.
* @param name Not used.
* @param textbuf The textbuf to which the result is written.
*
* @return None.
*/
1641static void
1642get_nodedb_mask(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
1643{
ocs_mgmt_emit_int(textbuf, MGMT_MODE_RW(4 | 2), "nodedb_mask", "0x%08x", ocs->nodedb_mask);
1645}

1647/**
* @brief Set requested WWNN value.
*
* @param ocs Pointer to the ocs structure.
* @param name Not used.
* @param value Value to which the linkcfg is set.
*
* @return Returns 0 on success.
*/

1657int
1658set_req_wwnn(ocs_t *ocs, char *name, char *value)
1659{
int rc;
uint64_t wwnn;

if (ocs_strcasecmp(value, "default")strcasecmp(value,"default") == 0) {
wwnn = 0;
}
else if (parse_wwn(value, &wwnn) != 0) {
ocs_log_test(ocs, "Invalid WWNN: %s\n", value)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1667, "Invalid WWNN: %s\n"
, value); } } while (0);;
return 1;
}

rc = ocs_xport_control(ocs->xport, OCS_XPORT_WWNN_SET, wwnn);

if(rc) {
ocs_log_test(ocs, "OCS_XPORT_WWNN_SET failed: %d\n", rc)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1674, "OCS_XPORT_WWNN_SET failed: %d\n"
, rc); } } while (0);;
return rc;
}

rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_OFFLINE);
if (rc) {
ocs_log_test(ocs, "port offline failed : %d\n", rc)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1680, "port offline failed : %d\n"
, rc); } } while (0);;
}

rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_ONLINE);
if (rc) {
ocs_log_test(ocs, "port online failed : %d\n", rc)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1685, "port online failed : %d\n"
, rc); } } while (0);;
}

return rc;
1689}

1691/**
* @brief Set requested WWNP value.
*
* @param ocs Pointer to the ocs structure.
* @param name Not used.
* @param value Value to which the linkcfg is set.
*
* @return Returns 0 on success.
*/

1701int
1702set_req_wwpn(ocs_t *ocs, char *name, char *value)
1703{
int rc;
uint64_t wwpn;

if (ocs_strcasecmp(value, "default")strcasecmp(value,"default") == 0) {
wwpn = 0;
}
else if (parse_wwn(value, &wwpn) != 0) {
ocs_log_test(ocs, "Invalid WWPN: %s\n", value)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1711, "Invalid WWPN: %s\n"
, value); } } while (0);;
return 1;
}

rc = ocs_xport_control(ocs->xport, OCS_XPORT_WWPN_SET, wwpn);

if(rc) {
ocs_log_test(ocs, "OCS_XPORT_WWPN_SET failed: %d\n", rc)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1718, "OCS_XPORT_WWPN_SET failed: %d\n"
, rc); } } while (0);;
return rc;
}

rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_OFFLINE);
if (rc) {
ocs_log_test(ocs, "port offline failed : %d\n", rc)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1724, "port offline failed : %d\n"
, rc); } } while (0);;
}

rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_ONLINE);
if (rc) {
ocs_log_test(ocs, "port online failed : %d\n", rc)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1729, "port online failed : %d\n"
, rc); } } while (0);;
}

return rc;
1733}

1735/**
* @brief Set node debug mask value
*
* @param ocs Pointer to the ocs structure.
* @param name Not used.
* @param value Value to which the nodedb_mask is set.
*
* @return Returns 0 on success.
*/
1744static int
1745set_nodedb_mask(ocs_t *ocs, char *name, char *value)
1746{
ocs->nodedb_mask = ocs_strtoul(value, 0, 0)strtoul(value,0,0);
return 0;
1749}

1751/**
* @brief Set linkcfg config value.
*
* @param ocs Pointer to the ocs structure.
* @param name Not used.
* @param value Value to which the linkcfg is set.
*
* @return Returns 0 on success.
*/
1760static int
1761set_linkcfg(ocs_t *ocs, char *name, char *value)
1762{
ocs_hw_linkcfg_e linkcfg;
ocs_mgmt_linkcfg_arg_t cb_arg;
ocs_hw_rtn_e status;

ocs_sem_init(&cb_arg.semaphore, 0, "mgmt_linkcfg");

/* translate mgmt linkcfg string to HW linkcfg enum */
linkcfg = ocs_hw_linkcfg_from_mgmt(value);

/* set HW linkcfg */
status = ocs_hw_port_control(&ocs->hw, OCS_HW_PORT_SET_LINK_CONFIG,
		      (uintptr_t)linkcfg, ocs_mgmt_linkcfg_cb, &cb_arg);
if (status) {
ocs_log_test(ocs, "ocs_hw_set_linkcfg failed\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1776, "ocs_hw_set_linkcfg failed\n"
); } } while (0);;
return -1;
}

if (ocs_sem_p(&cb_arg.semaphore, OCS_SEM_FOREVER(-1))) {
ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 1781, "ocs_sem_p failed\n"
); } } while (0);;
return -1;
}

if (cb_arg.status) {
ocs_log_test(ocs, "failed to set linkcfg from HW status=%d\n",do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1787, "failed to set linkcfg from HW status=%d\n"
, cb_arg.status); } } while (0);
	     cb_arg.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1787, "failed to set linkcfg from HW status=%d\n"
, cb_arg.status); } } while (0);;
return -1;
}

return 0;
1792}

1794/**
* @brief Linkcfg callback
*
* @param status Result of the linkcfg get/set operation.
* @param value Resulting linkcfg value.
* @param arg Callback argument.
*
* @return None.
*/
1803static void
1804ocs_mgmt_linkcfg_cb(int32_t status, uintptr_t value, void *arg)
1805{
ocs_mgmt_linkcfg_arg_t *cb_arg = (ocs_mgmt_linkcfg_arg_t *)arg;
cb_arg->status = status;
cb_arg->linkcfg = (ocs_hw_linkcfg_e)value;
ocs_sem_v(&cb_arg->semaphore);
1810}

1812static int
1813set_debug_mq_dump(ocs_t *ocs, char *name, char *value)
1814{
int result;

if (ocs_strcasecmp(value, "false")strcasecmp(value,"false") == 0) {
ocs_debug_disable(OCS_DEBUG_ENABLE_MQ_DUMP(1U << 1));
result = 0;
} else if (ocs_strcasecmp(value, "true")strcasecmp(value,"true") == 0) {
ocs_debug_enable(OCS_DEBUG_ENABLE_MQ_DUMP(1U << 1));
result = 0;
} else {
result = -1;
}

return result;
1828}

1830static int
1831set_debug_cq_dump(ocs_t *ocs, char *name, char *value)
1832{
int result;

if (ocs_strcasecmp(value, "false")strcasecmp(value,"false") == 0) {
ocs_debug_disable(OCS_DEBUG_ENABLE_CQ_DUMP(1U << 2));
result = 0;
} else if (ocs_strcasecmp(value, "true")strcasecmp(value,"true") == 0) {
ocs_debug_enable(OCS_DEBUG_ENABLE_CQ_DUMP(1U << 2));
result = 0;
} else {
result = -1;
}

return result;
1846}

1848static int
1849set_debug_wq_dump(ocs_t *ocs, char *name, char *value)
1850{
int result;

if (ocs_strcasecmp(value, "false")strcasecmp(value,"false") == 0) {
ocs_debug_disable(OCS_DEBUG_ENABLE_WQ_DUMP(1U << 3));
result = 0;
} else if (ocs_strcasecmp(value, "true")strcasecmp(value,"true") == 0) {
ocs_debug_enable(OCS_DEBUG_ENABLE_WQ_DUMP(1U << 3));
result = 0;
} else {
result = -1;
}

return result;
1864}

1866static int
1867set_debug_eq_dump(ocs_t *ocs, char *name, char *value)
1868{
int result;

if (ocs_strcasecmp(value, "false")strcasecmp(value,"false") == 0) {
ocs_debug_disable(OCS_DEBUG_ENABLE_EQ_DUMP(1U << 4));
result = 0;
} else if (ocs_strcasecmp(value, "true")strcasecmp(value,"true") == 0) {
ocs_debug_enable(OCS_DEBUG_ENABLE_EQ_DUMP(1U << 4));
result = 0;
} else {
result = -1;
}

return result;
1882}

1884static int
1885set_logmask(ocs_t *ocs, char *name, char *value)
1886{

ocs->logmask = ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0);

return 0;
1891}

1893static int
1894set_loglevel(ocs_t *ocs, char *name, char *value)
1895{

loglevel = ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0);

return 0;
1900}

1902int
1903set_configured_speed(ocs_t *ocs, char *name, char *value)
1904{
int result = 0;
ocs_hw_rtn_e hw_rc;
int xport_rc;
uint32_t spd;

spd = ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0);

if ((spd != 0) && (spd != 2000) && (spd != 4000) &&
(spd != 8000) && (spd != 16000) && (spd != 32000)) {
ocs_log_test(ocs, "unsupported speed %d\n", spd)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1914, "unsupported speed %d\n"
, spd); } } while (0);;
return 1;
}

ocs_log_debug(ocs, "Taking port offline\n")do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 1918, "Taking port offline\n"
); } } while (0);;
xport_rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_OFFLINE);
if (xport_rc != 0) {
ocs_log_test(ocs, "Port offline failed\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1921, "Port offline failed\n"
); } } while (0);;
result = 1;
} else {
ocs_log_debug(ocs, "Setting port to speed %d\n", spd)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 1924, "Setting port to speed %d\n"
, spd); } } while (0);;
hw_rc = ocs_hw_set(&ocs->hw, OCS_HW_LINK_SPEED, spd);
if (hw_rc != OCS_HW_RTN_SUCCESS) {
	ocs_log_test(ocs, "Speed set failed\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1927, "Speed set failed\n"
); } } while (0);;
	result = 1;
}

/* If we failed to set the speed we still want to try to bring
 * the port back online */

ocs_log_debug(ocs, "Bringing port online\n")do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 1934, "Bringing port online\n"
); } } while (0);;
xport_rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_ONLINE);
if (xport_rc != 0) {
	result = 1;
}
}

return result;
1942}

1944int
1945set_configured_topology(ocs_t *ocs, char *name, char *value)
1946{
int result = 0;
ocs_hw_rtn_e hw_rc;
int xport_rc;
uint32_t topo;

topo = ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0);
if (topo >= OCS_HW_TOPOLOGY_NONE) {
return 1;
}

ocs_log_debug(ocs, "Taking port offline\n")do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 1957, "Taking port offline\n"
); } } while (0);;
xport_rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_OFFLINE);
if (xport_rc != 0) {
ocs_log_test(ocs, "Port offline failed\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1960, "Port offline failed\n"
); } } while (0);;
result = 1;
} else {
ocs_log_debug(ocs, "Setting port to topology %d\n", topo)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 1963, "Setting port to topology %d\n"
, topo); } } while (0);;
hw_rc = ocs_hw_set(&ocs->hw, OCS_HW_TOPOLOGY, topo);
if (hw_rc != OCS_HW_RTN_SUCCESS) {
	ocs_log_test(ocs, "Topology set failed\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1966, "Topology set failed\n"
); } } while (0);;
	result = 1;
}

/* If we failed to set the topology we still want to try to bring
 * the port back online */

ocs_log_debug(ocs, "Bringing port online\n")do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 1973, "Bringing port online\n"
); } } while (0);;
xport_rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_ONLINE);
if (xport_rc != 0) {
	result = 1;
}
}

return result;
1981}

1983static int
1984set_configured_link_state(ocs_t *ocs, char *name, char *value)
1985{
int result = 0;
int xport_rc;

if (ocs_strcasecmp(value, "offline")strcasecmp(value,"offline") == 0) {
ocs_log_debug(ocs, "Setting port to %s\n", value)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 1990, "Setting port to %s\n"
, value); } } while (0);;
xport_rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_OFFLINE);
if (xport_rc != 0) {
	ocs_log_test(ocs, "Setting port to offline failed\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 1993, "Setting port to offline failed\n"
); } } while (0);;
	result = -1;
}
} else if (ocs_strcasecmp(value, "online")strcasecmp(value,"online") == 0) {
ocs_log_debug(ocs, "Setting port to %s\n", value)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 1997, "Setting port to %s\n"
, value); } } while (0);;
xport_rc = ocs_xport_control(ocs->xport, OCS_XPORT_PORT_ONLINE);
if (xport_rc != 0) {
	ocs_log_test(ocs, "Setting port to online failed\n")do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2000, "Setting port to online failed\n"
); } } while (0);;
	result = -1;
}
} else {
ocs_log_test(ocs, "Unsupported link state \"%s\"\n", value)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2004, "Unsupported link state \"%s\"\n"
, value); } } while (0);;
result = -1;
}

return result;
2009}

2011typedef struct ocs_mgmt_get_port_protocol_result {
ocs_sem_t semaphore;
int32_t status;
ocs_hw_port_protocol_e port_protocol;
2015} ocs_mgmt_get_port_protocol_result_t;


2018static void
2019ocs_mgmt_get_port_protocol_cb(int32_t status,
	      ocs_hw_port_protocol_e port_protocol,
	      void    *arg)
2022{
ocs_mgmt_get_port_protocol_result_t *result = arg;

result->status = status;
result->port_protocol = port_protocol;

ocs_sem_v(&(result->semaphore));
2029}

2031static void
2032get_port_protocol(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
2033{
ocs_mgmt_get_port_protocol_result_t result;
uint8_t bus;
uint8_t dev;
uint8_t func;

ocs_sem_init(&(result.semaphore), 0, "get_port_protocol");

ocs_get_bus_dev_func(ocs, &bus, &dev, &func);

if(ocs_hw_get_port_protocol(&ocs->hw, func, ocs_mgmt_get_port_protocol_cb, &result) == OCS_HW_RTN_SUCCESS) {
if (ocs_sem_p(&(result.semaphore), OCS_SEM_FOREVER(-1)) != 0) {
	/* Undefined failure */
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 2046, "ocs_sem_p failed\n"
); } } while (0);;
}
if (result.status == 0) {
	switch (result.port_protocol) {
	case OCS_HW_PORT_PROTOCOL_ISCSI:
		ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "port_protocol", "iSCSI");
		break;
	case OCS_HW_PORT_PROTOCOL_FCOE:
		ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "port_protocol", "FCoE");
		break;
	case OCS_HW_PORT_PROTOCOL_FC:
		ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "port_protocol", "FC");
		break;
	case OCS_HW_PORT_PROTOCOL_OTHER:
		ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "port_protocol", "Other");
		break;
	}
} else {
	ocs_log_test(ocs, "getting port profile status 0x%x\n", result.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2064, "getting port profile status 0x%x\n"
, result.status); } } while (0);;
	ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "port_protocol", "Unknown");
}
}
2068}

2070typedef struct ocs_mgmt_set_port_protocol_result {
ocs_sem_t semaphore;
int32_t status;
2073} ocs_mgmt_set_port_protocol_result_t;



2077static void
2078ocs_mgmt_set_port_protocol_cb(int32_t status,
	      void    *arg)
2080{
ocs_mgmt_get_port_protocol_result_t *result = arg;

result->status = status;

ocs_sem_v(&(result->semaphore));
2086}

2088/**
* @brief  Set port protocol
* @par Description
* This is a management action handler to set the current
* port protocol.  Input value should be one of iSCSI,
* FC, or FCoE.
*
* @param ocs Pointer to the ocs structure.
* @param name Name of the action being performed.
* @param value The value to be assigned
*
* @return Returns 0 on success, non-zero on failure.
*/
2101static int32_t
2102set_port_protocol(ocs_t *ocs, char *name, char *value)
2103{
ocs_mgmt_set_port_protocol_result_t result;
int32_t rc = 0;
ocs_hw_port_protocol_e new_protocol;
uint8_t bus;
uint8_t dev;
uint8_t func;

ocs_get_bus_dev_func(ocs, &bus, &dev, &func);

ocs_sem_init(&(result.semaphore), 0, "set_port_protocol");

if (ocs_strcasecmp(value, "iscsi")strcasecmp(value,"iscsi") == 0) {
new_protocol = OCS_HW_PORT_PROTOCOL_ISCSI;
} else if (ocs_strcasecmp(value, "fc")strcasecmp(value,"fc") == 0) {
new_protocol = OCS_HW_PORT_PROTOCOL_FC;
} else if (ocs_strcasecmp(value, "fcoe")strcasecmp(value,"fcoe") == 0) {
new_protocol = OCS_HW_PORT_PROTOCOL_FCOE;
} else {
return -1;
}

rc = ocs_hw_set_port_protocol(&ocs->hw, new_protocol, func,
		       ocs_mgmt_set_port_protocol_cb, &result);
if (rc == OCS_HW_RTN_SUCCESS) {
if (ocs_sem_p(&(result.semaphore), OCS_SEM_FOREVER(-1)) != 0) {
	/* Undefined failure */
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 2130, "ocs_sem_p failed\n"
); } } while (0);;
	rc = -ENXIO6;
}
if (result.status == 0) {
	/* Success. */
	rc = 0;
} else {
	rc = -1;
	ocs_log_test(ocs, "setting active profile status 0x%x\n",do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2139, "setting active profile status 0x%x\n"
, result.status); } } while (0);
		     result.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2139, "setting active profile status 0x%x\n"
, result.status); } } while (0);;
}
}

return rc;
2144}

2146typedef struct ocs_mgmt_get_profile_list_result_s {
ocs_sem_t semaphore;
int32_t status;
ocs_hw_profile_list_t *list;
2150} ocs_mgmt_get_profile_list_result_t;

2152static void
2153ocs_mgmt_get_profile_list_cb(int32_t status, ocs_hw_profile_list_t *list, void *ul_arg)
2154{
ocs_mgmt_get_profile_list_result_t *result = ul_arg;

result->status = status;
result->list = list;

ocs_sem_v(&(result->semaphore));
2161}

2163/**
* @brief  Get list of profiles
* @par Description
* This is a management action handler to get the list of
* profiles supported by the SLI port.  Although the spec says
* that all SLI platforms support this, only Skyhawk actually
* has a useful implementation.
*
* @param ocs Pointer to the ocs structure.
* @param name Name of the action being performed.
* @param textbuf Pointer to an ocs_textbuf, which is used to return the results.
*
* @return none
*/
2177static void
2178get_profile_list(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
2179{
ocs_mgmt_get_profile_list_result_t result;

ocs_sem_init(&(result.semaphore), 0, "get_profile_list");

if(ocs_hw_get_profile_list(&ocs->hw, ocs_mgmt_get_profile_list_cb, &result) == OCS_HW_RTN_SUCCESS) {
if (ocs_sem_p(&(result.semaphore), OCS_SEM_FOREVER(-1)) != 0) {
	/* Undefined failure */
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 2187, "ocs_sem_p failed\n"
); } } while (0);;
}
if (result.status == 0) {
	/* Success. */
2191#define MAX_LINE_SIZE520 520
2192#define BUFFER_SIZE520*40 MAX_LINE_SIZE520*40
	char *result_buf;
	char result_line[MAX_LINE_SIZE520];
	uint32_t bytes_left;
	uint32_t i;

	result_buf = ocs_malloc(ocs, BUFFER_SIZE520*40, OCS_M_ZERO0x0100);
	bytes_left = BUFFER_SIZE520*40;

	for (i=0; i<result.list->num_descriptors; i++) {
		sprintf(result_line, "0x%02x:%s\n", result.list->descriptors[i].profile_id,
			result.list->descriptors[i].profile_description);
		if (strlen(result_line) < bytes_left) {
			strcat(result_buf, result_line);
			bytes_left -= strlen(result_line);
		}
	}


	ocs_mgmt_emit_string(textbuf, MGMT_MODE_RD4, "profile_list", result_buf);

	ocs_free(ocs, result_buf, BUFFER_SIZE520*40);
	ocs_free(ocs, result.list, sizeof(ocs_hw_profile_list_t));
} else {
	ocs_log_test(ocs, "getting profile list status 0x%x\n", result.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2216, "getting profile list status 0x%x\n"
, result.status); } } while (0);;
}
}
2219}

2221typedef struct ocs_mgmt_get_active_profile_result {
ocs_sem_t semaphore;
int32_t status;
uint32_t active_profile_id;
2225} ocs_mgmt_get_active_profile_result_t;

2227static void
2228ocs_mgmt_get_active_profile_cb(int32_t status, uint32_t active_profile, void *ul_arg)
2229{
ocs_mgmt_get_active_profile_result_t *result = ul_arg;

result->status = status;
result->active_profile_id = active_profile;

ocs_sem_v(&(result->semaphore));
2236}

2238#define MAX_PROFILE_LENGTH5 5

2240/**
* @brief  Get active profile
* @par Description
* This is a management action handler to get the currently
* active profile for an SLI port.  Although the spec says that
* all SLI platforms support this, only Skyhawk actually has a
* useful implementation.
*
* @param ocs Pointer to the ocs structure.
* @param name Name of the action being performed.
* @param textbuf Pointer to an ocs_textbuf, which is used to return the results.
*
* @return none
*/
2254static void
2255get_active_profile(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
2256{
char result_string[MAX_PROFILE_LENGTH5];
ocs_mgmt_get_active_profile_result_t result;

ocs_sem_init(&(result.semaphore), 0, "get_active_profile");

if(ocs_hw_get_active_profile(&ocs->hw, ocs_mgmt_get_active_profile_cb, &result) == OCS_HW_RTN_SUCCESS) {
if (ocs_sem_p(&(result.semaphore), OCS_SEM_FOREVER(-1)) != 0) {
	/* Undefined failure */
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 2265, "ocs_sem_p failed\n"
); } } while (0);;
}
if (result.status == 0) {
	/* Success. */
	sprintf(result_string, "0x%02x", result.active_profile_id);
	ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "active_profile", result_string);
} else {
	ocs_log_test(ocs, "getting active profile status 0x%x\n", result.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2272, "getting active profile status 0x%x\n"
, result.status); } } while (0);;
}
}
2275}

2277typedef struct ocs_mgmt_set_active_profile_result {
ocs_sem_t semaphore;
int32_t status;
2280} ocs_mgmt_set_active_profile_result_t;


2283static void
2284ocs_mgmt_set_active_profile_cb(int32_t status, void *ul_arg)
2285{
ocs_mgmt_get_profile_list_result_t *result = ul_arg;

result->status = status;

ocs_sem_v(&(result->semaphore));
2291}

2293/**
* @brief  Set active profile
* @par Description
* This is a management action handler to set the currently
* active profile for an SLI port.  Although the spec says that
* all SLI platforms support this, only Skyhawk actually has a
* useful implementation.
*
* @param ocs Pointer to the ocs structure.
* @param name Name of the action being performed.
* @param value Requested new value of the property.
*
* @return Returns 0 on success, non-zero on failure.
*/
2307static int32_t
2308set_active_profile(ocs_t *ocs, char *name, char *value)
2309{
ocs_mgmt_set_active_profile_result_t result;
int32_t rc = 0;
int32_t new_profile;

new_profile = ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0);

ocs_sem_init(&(result.semaphore), 0, "set_active_profile");

rc = ocs_hw_set_active_profile(&ocs->hw, ocs_mgmt_set_active_profile_cb, new_profile, &result);
if (rc == OCS_HW_RTN_SUCCESS) {
if (ocs_sem_p(&(result.semaphore), OCS_SEM_FOREVER(-1)) != 0) {
	/* Undefined failure */
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 2322, "ocs_sem_p failed\n"
); } } while (0);;
	rc = -ENXIO6;
}
if (result.status == 0) {
	/* Success. */
	rc = 0;
} else {
	rc = -1;
	ocs_log_test(ocs, "setting active profile status 0x%x\n", result.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2330, "setting active profile status 0x%x\n"
, result.status); } } while (0);;
}
}

return rc;
2335}

2337typedef struct ocs_mgmt_get_nvparms_result {
ocs_sem_t semaphore;
int32_t status;
uint8_t	wwpn[8];
uint8_t wwnn[8];
uint8_t hard_alpa;
uint32_t preferred_d_id;
2344} ocs_mgmt_get_nvparms_result_t;

2346static void
2347ocs_mgmt_get_nvparms_cb(int32_t status, uint8_t *wwpn, uint8_t *wwnn, uint8_t hard_alpa,
uint32_t preferred_d_id, void *ul_arg)
2349{
ocs_mgmt_get_nvparms_result_t *result = ul_arg;

result->status = status;
ocs_memcpy(result->wwpn, wwpn, sizeof(result->wwpn))__builtin_memcpy((result->wwpn), (wwpn), (sizeof(result->
wwpn)));
ocs_memcpy(result->wwnn, wwnn, sizeof(result->wwnn))__builtin_memcpy((result->wwnn), (wwnn), (sizeof(result->
wwnn)));
result->hard_alpa = hard_alpa;
result->preferred_d_id = preferred_d_id;

ocs_sem_v(&(result->semaphore));
2359}

2361/**
* @brief  Get wwpn
* @par Description
*
*
* @param ocs Pointer to the ocs structure.
* @param name Name of the action being performed.
* @param textbuf Pointer to an ocs_textbuf, which is used to return the results.
*
* @return none
*/
2372static void
2373get_nv_wwpn(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
2374{
char result_string[24];
ocs_mgmt_get_nvparms_result_t result;

ocs_sem_init(&(result.semaphore), 0, "get_nv_wwpn");

if(ocs_hw_get_nvparms(&ocs->hw, ocs_mgmt_get_nvparms_cb, &result) == OCS_HW_RTN_SUCCESS) {
if (ocs_sem_p(&(result.semaphore), OCS_SEM_FOREVER(-1)) != 0) {
	/* Undefined failure */
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 2383, "ocs_sem_p failed\n"
); } } while (0);;
	return;
}
if (result.status == 0) {
	/* Success.  Copy wwpn from result struct to result string */
	sprintf(result_string, "%02x:%02x:%02x:%02x:%02x:%02x:%02x:%02x",
			result.wwpn[0], result.wwpn[1], result.wwpn[2],
			result.wwpn[3], result.wwpn[4], result.wwpn[5],
			result.wwpn[6], result.wwpn[7]);
	ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "nv_wwpn", result_string);
} else {
	ocs_log_test(ocs, "getting wwpn status 0x%x\n", result.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2394, "getting wwpn status 0x%x\n"
, result.status); } } while (0);;
}
}
2397}

2399/**
* @brief  Get wwnn
* @par Description
*
*
* @param ocs Pointer to the ocs structure.
* @param name Name of the action being performed.
* @param textbuf Pointer to an ocs_textbuf, which is used to return the results.
*
* @return none
*/
2410static void
2411get_nv_wwnn(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
2412{
char result_string[24];
ocs_mgmt_get_nvparms_result_t result;

ocs_sem_init(&(result.semaphore), 0, "get_nv_wwnn");

if(ocs_hw_get_nvparms(&ocs->hw, ocs_mgmt_get_nvparms_cb, &result) == OCS_HW_RTN_SUCCESS) {
if (ocs_sem_p(&(result.semaphore), OCS_SEM_FOREVER(-1)) != 0) {
	/* Undefined failure */
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 2421, "ocs_sem_p failed\n"
); } } while (0);;
	return;
}
if (result.status == 0) {
	/* Success. Copy wwnn from result struct to result string */
	ocs_snprintf(result_string, sizeof(result_string), "%02x:%02x:%02x:%02x:%02x:%02x:%02x:%02x",snprintf(result_string, sizeof(result_string), "%02x:%02x:%02x:%02x:%02x:%02x:%02x:%02x"
, result.wwnn[0], result.wwnn[1], result.wwnn[2], result.wwnn
[3], result.wwnn[4], result.wwnn[5], result.wwnn[6], result.wwnn
[7])
			result.wwnn[0], result.wwnn[1], result.wwnn[2],snprintf(result_string, sizeof(result_string), "%02x:%02x:%02x:%02x:%02x:%02x:%02x:%02x"
, result.wwnn[0], result.wwnn[1], result.wwnn[2], result.wwnn
[3], result.wwnn[4], result.wwnn[5], result.wwnn[6], result.wwnn
[7])
			result.wwnn[3], result.wwnn[4], result.wwnn[5],snprintf(result_string, sizeof(result_string), "%02x:%02x:%02x:%02x:%02x:%02x:%02x:%02x"
, result.wwnn[0], result.wwnn[1], result.wwnn[2], result.wwnn
[3], result.wwnn[4], result.wwnn[5], result.wwnn[6], result.wwnn
[7])
			result.wwnn[6], result.wwnn[7])snprintf(result_string, sizeof(result_string), "%02x:%02x:%02x:%02x:%02x:%02x:%02x:%02x"
, result.wwnn[0], result.wwnn[1], result.wwnn[2], result.wwnn
[3], result.wwnn[4], result.wwnn[5], result.wwnn[6], result.wwnn
[7]);
	ocs_mgmt_emit_string(textbuf, MGMT_MODE_RW(4 | 2), "nv_wwnn", result_string);
} else {
	ocs_log_test(ocs, "getting wwnn status 0x%x\n", result.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2432, "getting wwnn status 0x%x\n"
, result.status); } } while (0);;
}
}
2435}

2437/**
* @brief Get accumulated node abort counts
* @par Description Get the sum of all nodes abort count.
*
* @param ocs Pointer to the ocs structure.
* @param name Name of the action being performed.
* @param textbuf Pointer to an ocs_textbuf, which is used to return the results.
*
* @return None.
*/
2447static void
2448get_node_abort_cnt(ocs_t *ocs, char *name, ocs_textbuf_t *textbuf)
2449{
uint32_t abort_counts = 0;
ocs_domain_t *domain;
ocs_sport_t *sport;
ocs_node_t *node;

if (ocs_device_lock_try(ocs) != TRUE1) {
/* Didn't get the lock */
return;
}

/* Here the Device lock is held */
ocs_list_foreach(&ocs->domain_list, domain)for (domain = ocs_list_get_head((&ocs->domain_list)); domain
; domain = ocs_list_next((&ocs->domain_list), domain) ) {
	if (ocs_domain_lock_try(domain) != TRUE1) {
		/* Didn't get the lock */
		ocs_device_unlock(ocs);
		return;
	}

		/* Here the Domain lock is held */
		ocs_list_foreach(&domain->sport_list, sport)for (sport = ocs_list_get_head((&domain->sport_list));
 sport; sport = ocs_list_next((&domain->sport_list), sport
) ) {
			if (ocs_sport_lock_try(sport) != TRUE1) {
				/* Didn't get the lock */
				ocs_domain_unlock(domain);
				ocs_device_unlock(ocs);
				return;
			}

				/* Here the sport lock is held */
				ocs_list_foreach(&sport->node_list, node)for (node = ocs_list_get_head((&sport->node_list)); node
; node = ocs_list_next((&sport->node_list), node) ) {
					abort_counts += node->abort_cnt;
				}

			ocs_sport_unlock(sport);
		}

	ocs_domain_unlock(domain);
}

ocs_device_unlock(ocs);

ocs_mgmt_emit_int(textbuf, MGMT_MODE_RD4, "node_abort_cnt", "%d" , abort_counts);
2491}

2493typedef struct ocs_mgmt_set_nvparms_result {
ocs_sem_t semaphore;
int32_t status;
2496} ocs_mgmt_set_nvparms_result_t;


2499static void
2500ocs_mgmt_set_nvparms_cb(int32_t status, void *ul_arg)
2501{
ocs_mgmt_get_profile_list_result_t *result = ul_arg;

result->status = status;

ocs_sem_v(&(result->semaphore));
2507}

2509/**
* @brief  Set wwn
* @par Description Sets the Non-volatile worldwide names,
* if provided.
*
* @param ocs Pointer to the ocs structure.
* @param name Name of the action being performed.
* @param wwn_p Requested new WWN values.
*
* @return Returns 0 on success, non-zero on failure.
*/
2520static int32_t
2521set_nv_wwn(ocs_t *ocs, char *name, char *wwn_p)
2522{
ocs_mgmt_get_nvparms_result_t result;
uint8_t new_wwpn[8];
uint8_t new_wwnn[8];
char *wwpn_p = NULL((void *)0);
char *wwnn_p = NULL((void *)0);
int32_t rc = -1;
int wwpn;
int wwnn;
int i;

/* This is a read-modify-write operation, so first we have to read
* the current values
*/
ocs_sem_init(&(result.semaphore), 0, "set_nv_wwn1");

rc = ocs_hw_get_nvparms(&ocs->hw, ocs_mgmt_get_nvparms_cb, &result);

if (rc == OCS_HW_RTN_SUCCESS) {
if (ocs_sem_p(&(result.semaphore), OCS_SEM_FOREVER(-1)) != 0) {
	/* Undefined failure */
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 2543, "ocs_sem_p failed\n"
); } } while (0);;
	return -ENXIO6;
}
if (result.status != 0) {
	ocs_log_test(ocs, "getting nvparms status 0x%x\n", result.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2547, "getting nvparms status 0x%x\n"
, result.status); } } while (0);;
	return -1;
}
}

/* wwn_p contains wwpn_p@wwnn_p values */
if (wwn_p != NULL((void *)0)) {
wwpn_p = ocs_strsep(&wwn_p, "@")strsep(&wwn_p, "@");
wwnn_p = wwn_p;
}

wwpn = ocs_strcmp(wwpn_p, "NA")strcmp(wwpn_p,"NA");
wwnn = ocs_strcmp(wwnn_p, "NA")strcmp(wwnn_p,"NA");

/* Parse the new WWPN */
if ((wwpn_p != NULL((void *)0)) && (wwpn != 0)) {
if (ocs_sscanf(wwpn_p, "%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx",sscanf(wwpn_p, "%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx"
, &(new_wwpn[0]), &(new_wwpn[1]), &(new_wwpn[2]),
 &(new_wwpn[3]), &(new_wwpn[4]), &(new_wwpn[5]), &
(new_wwpn[6]), &(new_wwpn[7]))
		&(new_wwpn[0]), &(new_wwpn[1]), &(new_wwpn[2]),sscanf(wwpn_p, "%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx"
, &(new_wwpn[0]), &(new_wwpn[1]), &(new_wwpn[2]),
 &(new_wwpn[3]), &(new_wwpn[4]), &(new_wwpn[5]), &
(new_wwpn[6]), &(new_wwpn[7]))
		&(new_wwpn[3]), &(new_wwpn[4]), &(new_wwpn[5]),sscanf(wwpn_p, "%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx"
, &(new_wwpn[0]), &(new_wwpn[1]), &(new_wwpn[2]),
 &(new_wwpn[3]), &(new_wwpn[4]), &(new_wwpn[5]), &
(new_wwpn[6]), &(new_wwpn[7]))
		&(new_wwpn[6]), &(new_wwpn[7]))sscanf(wwpn_p, "%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx"
, &(new_wwpn[0]), &(new_wwpn[1]), &(new_wwpn[2]),
 &(new_wwpn[3]), &(new_wwpn[4]), &(new_wwpn[5]), &
(new_wwpn[6]), &(new_wwpn[7])) != 8) {
	ocs_log_test(ocs, "can't parse WWPN %s\n", wwpn_p)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2567, "can't parse WWPN %s\n"
, wwpn_p); } } while (0);;
	return -1;
}
}

/* Parse the new WWNN */
if ((wwnn_p != NULL((void *)0)) && (wwnn != 0 )) {
if (ocs_sscanf(wwnn_p, "%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx",sscanf(wwnn_p, "%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx"
, &(new_wwnn[0]), &(new_wwnn[1]), &(new_wwnn[2]),
 &(new_wwnn[3]), &(new_wwnn[4]), &(new_wwnn[5]), &
(new_wwnn[6]), &(new_wwnn[7]))
		&(new_wwnn[0]), &(new_wwnn[1]), &(new_wwnn[2]),sscanf(wwnn_p, "%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx"
, &(new_wwnn[0]), &(new_wwnn[1]), &(new_wwnn[2]),
 &(new_wwnn[3]), &(new_wwnn[4]), &(new_wwnn[5]), &
(new_wwnn[6]), &(new_wwnn[7]))
		&(new_wwnn[3]), &(new_wwnn[4]), &(new_wwnn[5]),sscanf(wwnn_p, "%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx"
, &(new_wwnn[0]), &(new_wwnn[1]), &(new_wwnn[2]),
 &(new_wwnn[3]), &(new_wwnn[4]), &(new_wwnn[5]), &
(new_wwnn[6]), &(new_wwnn[7]))
		&(new_wwnn[6]), &(new_wwnn[7]))sscanf(wwnn_p, "%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx:%2hhx"
, &(new_wwnn[0]), &(new_wwnn[1]), &(new_wwnn[2]),
 &(new_wwnn[3]), &(new_wwnn[4]), &(new_wwnn[5]), &
(new_wwnn[6]), &(new_wwnn[7])) != 8) {
	ocs_log_test(ocs, "can't parse WWNN %s\n", wwnn_p)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2578, "can't parse WWNN %s\n"
, wwnn_p); } } while (0);;
	return -1;
}
}

for (i = 0; i < 8; i++) {
/* Use active wwpn, if new one is not provided */
if (wwpn == 0) {
	new_wwpn[i] = result.wwpn[i];
}

/* Use active wwnn, if new one is not provided */
if (wwnn == 0) {
	new_wwnn[i] = result.wwnn[i];
}
}

/* Modify the nv_wwnn and nv_wwpn, then write it back */
ocs_sem_init(&(result.semaphore), 0, "set_nv_wwn2");

rc = ocs_hw_set_nvparms(&ocs->hw, ocs_mgmt_set_nvparms_cb, new_wwpn,
		 new_wwnn, result.hard_alpa, result.preferred_d_id,
		 &result);
if (rc == OCS_HW_RTN_SUCCESS) {
if (ocs_sem_p(&(result.semaphore), OCS_SEM_FOREVER(-1)) != 0) {
	/* Undefined failure */
	ocs_log_err(ocs, "ocs_sem_p failed\n")do { if (1 <= loglevel) { _ocs_log(ocs, __func__, 2604, "ocs_sem_p failed\n"
); } } while (0);;
	return -ENXIO6;
}
if (result.status != 0) {
	ocs_log_test(ocs, "setting wwn status 0x%x\n", result.status)do { if (4 <= loglevel) { _ocs_log(ocs, __func__, 2608, "setting wwn status 0x%x\n"
, result.status); } } while (0);;
	return -1;
}
}

return rc;
2614}

2616static int
2617set_tgt_rscn_delay(ocs_t *ocs, char *name, char *value)
2618{
ocs->tgt_rscn_delay_msec = ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0) * 1000;
ocs_log_debug(ocs, "mgmt set: %s %s\n", name, value)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 2620, "mgmt set: %s %s\n"
, name, value); } } while (0);;
return 0;
2622}

2624static int
2625set_tgt_rscn_period(ocs_t *ocs, char *name, char *value)
2626{
ocs->tgt_rscn_period_msec = ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0) * 1000;
ocs_log_debug(ocs, "mgmt set: %s %s\n", name, value)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 2628, "mgmt set: %s %s\n"
, name, value); } } while (0);;
return 0;
2630}

2632static int
2633set_inject_drop_cmd(ocs_t *ocs, char *name, char *value)
2634{
ocs->err_injection = (ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0) == 0 ? NO_ERR_INJECT : INJECT_DROP_CMD);
ocs_log_debug(ocs, "mgmt set: %s %s\n", name, value)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 2636, "mgmt set: %s %s\n"
, name, value); } } while (0);;
return 0;
2638}

2640static int
2641set_inject_free_drop_cmd(ocs_t *ocs, char *name, char *value)
2642{
ocs->err_injection = (ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0) == 0 ? NO_ERR_INJECT : INJECT_FREE_DROPPED);
ocs_log_debug(ocs, "mgmt set: %s %s\n", name, value)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 2644, "mgmt set: %s %s\n"
, name, value); } } while (0);;
return 0;
2646}

2648static int
2649set_inject_drop_data(ocs_t *ocs, char *name, char *value)
2650{
ocs->err_injection = (ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0) == 0 ? NO_ERR_INJECT : INJECT_DROP_DATA);
ocs_log_debug(ocs, "mgmt set: %s %s\n", name, value)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 2652, "mgmt set: %s %s\n"
, name, value); } } while (0);;
return 0;
2654}

2656static int
2657set_inject_drop_resp(ocs_t *ocs, char *name, char *value)
2658{
ocs->err_injection = (ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0) == 0 ? NO_ERR_INJECT : INJECT_DROP_RESP);
ocs_log_debug(ocs, "mgmt set: %s %s\n", name, value)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 2660, "mgmt set: %s %s\n"
, name, value); } } while (0);;
return 0;
2662}

2664static int
2665set_cmd_err_inject(ocs_t *ocs, char *name, char *value)
2666{
ocs->cmd_err_inject = ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0);
ocs_log_debug(ocs, "mgmt set: %s %s\n", name, value)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 2668, "mgmt set: %s %s\n"
, name, value); } } while (0);;
return 0;
2670}

2672static int
2673set_cmd_delay_value(ocs_t *ocs, char *name, char *value)
2674{
ocs->delay_value_msec = ocs_strtoul(value, NULL, 0)strtoul(value,((void *)0),0);
ocs->err_injection = (ocs->delay_value_msec == 0 ? NO_ERR_INJECT : INJECT_DELAY_CMD);
ocs_log_debug(ocs, "mgmt set: %s %s\n", name, value)do { if (5 <= loglevel) { _ocs_log(ocs, __func__, 2677, "mgmt set: %s %s\n"
, name, value); } } while (0);;
return 0;
2679}

2681/**
* @brief parse a WWN from a string into a 64-bit value
*
* Given a pointer to a string, parse the string into a 64-bit
* WWN value.  The format of the string must be xx:xx:xx:xx:xx:xx:xx:xx
*
* @param wwn_in pointer to the string to be parsed
* @param wwn_out pointer to uint64_t in which to put the parsed result
*
* @return 0 if successful, non-zero if the WWN is malformed and couldn't be parsed
*/
2692int
2693parse_wwn(char *wwn_in, uint64_t *wwn_out)
2694{
uint8_t byte0;
uint8_t byte1;
uint8_t byte2;
uint8_t byte3;
uint8_t byte4;
uint8_t byte5;
uint8_t byte6;
uint8_t byte7;
int rc;

rc = ocs_sscanf(wwn_in, "0x%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx",sscanf(wwn_in, "0x%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx", &
byte0, &byte1, &byte2, &byte3, &byte4, &byte5
, &byte6, &byte7)
		&byte0, &byte1, &byte2, &byte3,sscanf(wwn_in, "0x%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx", &
byte0, &byte1, &byte2, &byte3, &byte4, &byte5
, &byte6, &byte7)
		&byte4, &byte5, &byte6, &byte7)sscanf(wwn_in, "0x%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx%2hhx", &
byte0, &byte1, &byte2, &byte3, &byte4, &byte5
, &byte6, &byte7);

if (rc == 8) {
*wwn_out = ((uint64_t)byte0 << 56) |
		((uint64_t)byte1 << 48) |
		((uint64_t)byte2 << 40) |
		((uint64_t)byte3 << 32) |
		((uint64_t)byte4 << 24) |
		((uint64_t)byte5 << 16) |
		((uint64_t)byte6 <<  8) |
		((uint64_t)byte7);
return 0;

} else {
return 1;
}
2723}



2727static char *mode_string(int mode);


2730/**
* @ingroup mgmt
* @brief Generate the beginning of a numbered section in a management XML document.
*
* @par Description
* This function begins a section. The XML information is appended to
* the textbuf. This form of the function is used for sections that might have
* multiple instances, such as a node or a SLI Port (sport). The index number
* is appended to the name.
*
* @param textbuf Pointer to the driver dump text buffer.
* @param name Name of the section.
* @param index Index number of this instance of the section.
*
* @return None.
*/

2747extern void ocs_mgmt_start_section(ocs_textbuf_t *textbuf, const char *name, int index)
2748{
ocs_textbuf_printf(textbuf, "<%s instance=\"%d\">\n", name, index);
2750}

2752/**
* @ingroup mgmt
* @brief Generate the beginning of an unnumbered section in a management XML document.
*
* @par Description
* This function begins a section. The XML information is appended to
* the textbuf. This form of the function is used for sections that have
* a single instance only. Therefore, no index number is needed.
*
* @param textbuf Pointer to the driver dump text buffer.
* @param name Name of the section.
*
* @return None.
*/

2767extern void ocs_mgmt_start_unnumbered_section(ocs_textbuf_t *textbuf, const char *name)
2768{
ocs_textbuf_printf(textbuf, "<%s>\n", name);
2770}

2772/**
* @ingroup mgmt
* @brief Generate the end of a section in a management XML document.
*
* @par Description
* This function ends a section. The XML information is appended to
* the textbuf.
*
* @param textbuf Pointer to the driver dump text buffer.
* @param name Name of the section.
*
* @return None.
*/

2786void ocs_mgmt_end_unnumbered_section(ocs_textbuf_t *textbuf, const char *name)
2787{
ocs_textbuf_printf(textbuf, "</%s>\n", name);
2789}

2791/**
* @ingroup mgmt
* @brief Generate the indexed end of a section in a management XML document.
*
* @par Description
* This function ends a section. The XML information is appended to
* the textbuf.
*
* @param textbuf Pointer to the driver dump text buffer.
* @param name Name of the section.
* @param index Index number of this instance of the section.
*
* @return None.
*/

2806void ocs_mgmt_end_section(ocs_textbuf_t *textbuf, const char *name, int index)
2807{

ocs_textbuf_printf(textbuf, "</%s>\n", name);

2811}

2813/**
* @ingroup mgmt
* @brief Generate a property, with no value, in a management XML document.
*
* @par Description
* This function generates a property name. The XML information is appended to
* the textbuf. This form of the function is used by the list functions
* when the property name only (and not the current value) is given.
*
* @param textbuf Pointer to the driver dump text buffer.
* @param mode Defines whether the property is read(r)/write(w)/executable(x).
* @param name Name of the property.
*
* @return None.
*/

2829void ocs_mgmt_emit_property_name(ocs_textbuf_t *textbuf, int mode, const char *name)
2830{
ocs_textbuf_printf(textbuf, "<%s mode=\"%s\"/>\n", name, mode_string(mode));
2832}

2834/**
* @ingroup mgmt
* @brief Generate a property with a string value in a management XML document.
*
* @par Description
* This function generates a property name and a string value.
* The XML information is appended to the textbuf.
*
* @param textbuf Pointer to the driver dump text buffer.
* @param mode Defines whether the property is read(r)/write(w)/executable(x).
* @param name Name of the property.
* @param value Value of the property.
*
* @return None.
*/

2850void ocs_mgmt_emit_string(ocs_textbuf_t *textbuf, int mode, const char *name, const char *value)
2851{
ocs_textbuf_printf(textbuf, "<%s mode=\"%s\">%s</%s>\n", name, mode_string(mode), value, name);
2853}

2855/**
* @ingroup mgmt
* @brief Generate a property with an integer value in a management XML document.
*
* @par Description
* This function generates a property name and an integer value.
* The XML information is appended to the textbuf.
*
* @param textbuf Pointer to driver dump text buffer.
* @param mode Defines whether the property is read(r)/write(w)/executable(x).
* @param name Name of the property.
* @param fmt A printf format for formatting the integer value.
*
* @return none
*/

2871void ocs_mgmt_emit_int(ocs_textbuf_t *textbuf, int mode, const char *name, const char *fmt, ...)
2872{
va_list ap;
char valuebuf[64];

va_start(ap, fmt)__builtin_va_start((ap), (fmt));
ocs_vsnprintf(valuebuf, sizeof(valuebuf), fmt, ap)vsnprintf((char*)valuebuf, sizeof(valuebuf), fmt, ap);
va_end(ap)__builtin_va_end(ap);

ocs_textbuf_printf(textbuf, "<%s mode=\"%s\">%s</%s>\n", name, mode_string(mode), valuebuf, name);
2881}

2883/**
* @ingroup mgmt
* @brief Generate a property with a boolean value in a management XML document.
*
* @par Description
* This function generates a property name and a boolean value.
* The XML information is appended to the textbuf.
*
* @param textbuf Pointer to the driver dump text buffer.
* @param mode Defines whether the property is read(r)/write(w)/executable(x).
* @param name Name of the property.
* @param value Boolean value to be added to the textbuf.
*
* @return None.
*/

2899void ocs_mgmt_emit_boolean(ocs_textbuf_t *textbuf, int mode, const char *name, int value)
2900{
char *valuebuf = value ? "true" : "false";

ocs_textbuf_printf(textbuf, "<%s mode=\"%s\">%s</%s>\n", name, mode_string(mode), valuebuf, name);
2904}

2906static char *mode_string(int mode)
2907{
static char mode_str[4];

mode_str[0] = '\0';
if (mode & MGMT_MODE_RD4) {
strcat(mode_str, "r");
}
if (mode & MGMT_MODE_WR2) {
strcat(mode_str, "w");
}
if (mode & MGMT_MODE_EX1) {
strcat(mode_str, "x");
}

return mode_str;

2923}