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