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
SendSMPPassThru(const char * devpath,void * reqframe,HBA_UINT32 * reqsize,void * rspframe,HBA_UINT32 * rspsize)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
Sun_sasSendSMPPassThru(HBA_HANDLE handle,HBA_WWN hbaPortWWN,HBA_WWN destPortWWN,HBA_WWN domainPortWWN,void * pReqBuffer,HBA_UINT32 ReqBufferSize,void * pRspBuffer,HBA_UINT32 * pRspBufferSize)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