xref: /titanic_52/usr/src/lib/sun_sas/common/Sun_sasSendSMPPassThru.c (revision 9e86db79b7d1bbc5f2f04e99954cbd5eae0e22bb)
1 /*
2  * CDDL HEADER START
3  *
4  * The contents of this file are subject to the terms of the
5  * Common Development and Distribution License (the "License").
6  * You may not use this file except in compliance with the License.
7  *
8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9  * or http://www.opensolaris.org/os/licensing.
10  * See the License for the specific language governing permissions
11  * and limitations under the License.
12  *
13  * When distributing Covered Code, include this CDDL HEADER in each
14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15  * If applicable, add the following below this CDDL HEADER, with the
16  * fields enclosed by brackets "[]" replaced with your own identifying
17  * information: Portions Copyright [yyyy] [name of copyright owner]
18  *
19  * CDDL HEADER END
20  */
21 
22 /*
23  * Copyright 2009 Sun Microsystems, Inc.  All rights reserved.
24  * Use is subject to license terms.
25  */
26 
27 #include <sun_sas.h>
28 #include <sys/scsi/impl/usmp.h>
29 
30 /*
31  * Pass usmp_cmd into ioctl
32  */
33 static HBA_STATUS
34 SendSMPPassThru(const char *devpath, void *reqframe, HBA_UINT32 *reqsize,
35     void *rspframe, HBA_UINT32 *rspsize) {
36 	const char		ROUTINE[] = "SendSMPPassThru";
37 	int			fd;
38 	usmp_cmd_t		ucmd_buf;
39 	HBA_STATUS		ret;
40 
41 	bzero(&ucmd_buf, sizeof (ucmd_buf));
42 
43 	ucmd_buf.usmp_req = (caddr_t)reqframe;
44 	ucmd_buf.usmp_rsp = (caddr_t)rspframe;
45 	ucmd_buf.usmp_reqsize = (size_t)(*reqsize);
46 	ucmd_buf.usmp_rspsize = (size_t)(*rspsize);
47 	ucmd_buf.usmp_timeout = SMP_DEFAULT_TIMEOUT;
48 
49 	/*
50 	 * open smp device
51 	 */
52 
53 	if ((fd = open(devpath, O_RDONLY | O_NONBLOCK)) == -1) {
54 		log(LOG_DEBUG, ROUTINE,
55 		    "open devpath %s failed due to %s",
56 		    devpath, strerror(errno));
57 		return (HBA_STATUS_ERROR);
58 	}
59 
60 	/*
61 	 * send usmp command
62 	 */
63 	if (ioctl(fd, USMPFUNC, &ucmd_buf) == -1) {
64 		if ((errno == ETIME) || (errno == ETIMEDOUT) ||
65 		    (errno == EAGAIN)) {
66 		    ret = HBA_STATUS_ERROR_TRY_AGAIN;
67 		} else if (errno == EBUSY) {
68 		    ret = HBA_STATUS_ERROR_BUSY;
69 		} else {
70 		    ret = HBA_STATUS_ERROR;
71 		}
72 		log(LOG_DEBUG, ROUTINE, "ioctl:USMPFUNC failed due to %s",
73 		    strerror(errno));
74 		(void) close(fd);
75 		return (ret);
76 	}
77 
78 	(void) close(fd);
79 	return (HBA_STATUS_OK);
80 }
81 
82 /*
83  * Send a USMP command to a remote SMP node
84  */
85 HBA_STATUS
86 Sun_sasSendSMPPassThru(HBA_HANDLE handle, HBA_WWN hbaPortWWN,
87     HBA_WWN destPortWWN, HBA_WWN domainPortWWN, void *pReqBuffer,
88     HBA_UINT32 ReqBufferSize, void *pRspBuffer, HBA_UINT32 *pRspBufferSize)
89 {
90 	const char		ROUTINE[] = "Sun_sasSendSMPPassThru";
91 	HBA_STATUS		status;
92 	struct sun_sas_hba	*hba_ptr;
93 	int			domainPortFound = 0;
94 	int			chkDomainPort = 0;
95 	int			hbaPortFound = 0;
96 	struct sun_sas_port	*hba_port_ptr, *hba_disco_port;
97 	hrtime_t		start, end;
98 	double			duration;
99 
100 	start = gethrtime();
101 	/* Validate the arguments */
102 	if (pRspBuffer == NULL) {
103 		log(LOG_DEBUG, ROUTINE, "NULL response buffer");
104 		return (HBA_STATUS_ERROR_ARG);
105 	}
106 	if (pReqBuffer == NULL) {
107 		log(LOG_DEBUG, ROUTINE, "NULL sense buffer");
108 		return (HBA_STATUS_ERROR_ARG);
109 	}
110 	if (pRspBufferSize == NULL) {
111 		log(LOG_DEBUG, ROUTINE, "NULL response size");
112 		return (HBA_STATUS_ERROR_ARG);
113 	}
114 
115 	lock(&all_hbas_lock);
116 	if ((hba_ptr = Retrieve_Sun_sasHandle(handle)) == NULL) {
117 		log(LOG_DEBUG, ROUTINE, "Invalid handle %08lx", handle);
118 		unlock(&all_hbas_lock);
119 		return (HBA_STATUS_ERROR_INVALID_HANDLE);
120 	}
121 
122 	/* Check for stale data */
123 	status = verifyAdapter(hba_ptr);
124 	if (status != HBA_STATUS_OK) {
125 		log(LOG_DEBUG, ROUTINE, "Verify adapter failed");
126 		unlock(&all_hbas_lock);
127 		return (status);
128 	}
129 
130 	/*
131 	 * We are not checking to see if our data is stale.
132 	 * By verifying this information here, we will take a big performance
133 	 * hit.  This check will be done later only if the Inquiry ioctl fails
134 	 */
135 
136 	if (hba_ptr->device_path == NULL) {
137 		log(LOG_DEBUG, ROUTINE,
138 		    "HBA handle had NULL device path.\
139 		    Unable to send SCSI cmd");
140 		unlock(&all_hbas_lock);
141 		return (HBA_STATUS_ERROR);
142 	}
143 
144 	if (wwnConversion(domainPortWWN.wwn))
145 		chkDomainPort = 1;
146 
147 	/* Determine which port to use */
148 	for (hba_port_ptr = hba_ptr->first_port;
149 	    hba_port_ptr != NULL;
150 	    hba_port_ptr = hba_port_ptr->next) {
151 
152 		if (hbaPortFound == 0) {
153 			if (wwnConversion(hba_port_ptr->port_attributes.
154 			    PortSpecificAttribute.SASPort->LocalSASAddress.wwn)
155 			    != wwnConversion(hbaPortWWN.wwn)) {
156 				/*
157 				 * Since all the ports under the same HBA have
158 				 * the same LocalSASAddress, we should break
159 				 * the loop once we find it dosn't match.
160 				 */
161 				break;
162 			} else {
163 				hbaPortFound = 1;
164 			}
165 		}
166 
167 		if (chkDomainPort != 0) {
168 			if (hba_port_ptr->first_phy != NULL &&
169 			    wwnConversion(hba_port_ptr->first_phy->
170 			    phy.domainPortWWN.wwn) ==
171 			    wwnConversion(domainPortWWN.wwn)) {
172 				domainPortFound = 1;
173 			}
174 			if (!(domainPortFound)) {
175 				continue;
176 			}
177 		}
178 
179 		for (hba_disco_port = hba_port_ptr->first_attached_port;
180 		    hba_disco_port != NULL;
181 		    hba_disco_port = hba_disco_port->next) {
182 
183 			/*
184 			 * If discoveredPort is not given targetPort, just skip
185 			 */
186 			if (wwnConversion(hba_disco_port->port_attributes.\
187 			    PortSpecificAttribute.SASPort->LocalSASAddress.wwn)
188 			    != wwnConversion(destPortWWN.wwn)) {
189 				/* Does not match */
190 				continue;
191 			}
192 
193 			/*
194 			 * If matching targetPort does not support SMP protocal
195 			 * return error.
196 			 * comment it out for testing only
197 			 */
198 			if ((hba_disco_port->port_attributes.\
199 			    PortSpecificAttribute.SASPort->PortProtocol &
200 			    HBA_SASPORTPROTOCOL_SMP) == 0) {
201 				log(LOG_DEBUG, ROUTINE, "Input WWN %01611x\
202 				    does not support SMP protocol",
203 				    wwnConversion(hbaPortWWN.wwn));
204 				unlock(&all_hbas_lock);
205 				return (HBA_STATUS_ERROR_INVALID_PROTOCOL_TYPE);
206 			}
207 
208 			/*
209 			 * SMP target port doesn't have any scsi info.
210 			 *   - like /dev/rdsk/cxtxdxsx
211 			 * So we use OSDeviceName from port attributes.
212 			 *   - like /dev/smp/expd[0-9]
213 			 */
214 			status = SendSMPPassThru(
215 			    hba_disco_port->port_attributes.OSDeviceName,
216 			    pReqBuffer, &ReqBufferSize,
217 			    pRspBuffer, pRspBufferSize);
218 
219 			unlock(&all_hbas_lock);
220 			end = gethrtime();
221 			duration = end - start;
222 			duration /= HR_SECOND;
223 			log(LOG_DEBUG, ROUTINE, "Took total\
224 			    of %.4f seconds", duration);
225 			return (status);
226 		}
227 		if (chkDomainPort) {
228 			unlock(&all_hbas_lock);
229 			log(LOG_DEBUG, ROUTINE, "Unable to locate"
230 			    "requested SMP target port %16llx",
231 			    wwnConversion(destPortWWN.wwn));
232 			return (HBA_STATUS_ERROR_ILLEGAL_WWN);
233 		}
234 	}
235 	unlock(&all_hbas_lock);
236 	if (hbaPortFound == 0) {
237 		log(LOG_DEBUG, ROUTINE,
238 		    "Unable to locate requested Port WWN %016llx on "
239 		    "handle %08lx", wwnConversion(hbaPortWWN.wwn), handle);
240 	} else if (chkDomainPort && !domainPortFound) {
241 		log(LOG_DEBUG, ROUTINE, "Unable to locate requested"
242 		    " domainPortWWN %016llx on handle %08lx",
243 		    wwnConversion(domainPortWWN.wwn), handle);
244 	} else {
245 		log(LOG_DEBUG, ROUTINE, "Unable to locate"
246 		    "requested SMP target port %16llx",
247 		    wwnConversion(destPortWWN.wwn));
248 	}
249 	return (HBA_STATUS_ERROR_ILLEGAL_WWN);
250 }
251