Blame view
drivers/target/target_core_pr.c
126 KB
c66ac9db8 [SCSI] target: Ad... |
1 2 3 4 5 6 |
/******************************************************************************* * Filename: target_core_pr.c * * This file contains SPC-3 compliant persistent reservations and * legacy SPC-2 reservations with compatible reservation handling (CRH=1) * |
fd9a11d70 target: Update co... |
7 |
* (c) Copyright 2009-2012 RisingTide Systems LLC. |
c66ac9db8 [SCSI] target: Ad... |
8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
* * Nicholas A. Bellinger <nab@kernel.org> * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. * ******************************************************************************/ |
c66ac9db8 [SCSI] target: Ad... |
26 27 28 |
#include <linux/slab.h> #include <linux/spinlock.h> #include <linux/list.h> |
0e9b10a90 target: writev() ... |
29 |
#include <linux/file.h> |
c66ac9db8 [SCSI] target: Ad... |
30 31 32 33 34 |
#include <scsi/scsi.h> #include <scsi/scsi_cmnd.h> #include <asm/unaligned.h> #include <target/target_core_base.h> |
c4795fb20 target: header re... |
35 36 |
#include <target/target_core_backend.h> #include <target/target_core_fabric.h> |
c66ac9db8 [SCSI] target: Ad... |
37 |
#include <target/target_core_configfs.h> |
e26d99aed target: reshuffle... |
38 |
#include "target_core_internal.h" |
c66ac9db8 [SCSI] target: Ad... |
39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 |
#include "target_core_pr.h" #include "target_core_ua.h" /* * Used for Specify Initiator Ports Capable Bit (SPEC_I_PT) */ struct pr_transport_id_holder { int dest_local_nexus; struct t10_pr_registration *dest_pr_reg; struct se_portal_group *dest_tpg; struct se_node_acl *dest_node_acl; struct se_dev_entry *dest_se_deve; struct list_head dest_list; }; int core_pr_dump_initiator_port( struct t10_pr_registration *pr_reg, char *buf, u32 size) { |
6708bb27b target: Follow up... |
59 |
if (!pr_reg->isid_present_at_reg) |
c66ac9db8 [SCSI] target: Ad... |
60 61 62 63 64 65 66 67 |
return 0; snprintf(buf, size, ",i,0x%s", &pr_reg->pr_reg_isid[0]); return 1; } static void __core_scsi3_complete_pro_release(struct se_device *, struct se_node_acl *, struct t10_pr_registration *, int); |
de103c93a target: pass sens... |
68 69 |
static sense_reason_t target_scsi2_reservation_check(struct se_cmd *cmd) |
c66ac9db8 [SCSI] target: Ad... |
70 |
{ |
d977f4377 target: simplify ... |
71 72 73 74 |
struct se_device *dev = cmd->se_dev; struct se_session *sess = cmd->se_sess; switch (cmd->t_task_cdb[0]) { |
c66ac9db8 [SCSI] target: Ad... |
75 76 77 78 79 |
case INQUIRY: case RELEASE: case RELEASE_10: return 0; default: |
d977f4377 target: simplify ... |
80 |
break; |
c66ac9db8 [SCSI] target: Ad... |
81 |
} |
d977f4377 target: simplify ... |
82 |
if (!dev->dev_reserved_node_acl || !sess) |
c66ac9db8 [SCSI] target: Ad... |
83 |
return 0; |
d977f4377 target: simplify ... |
84 |
if (dev->dev_reserved_node_acl != sess->se_node_acl) |
de103c93a target: pass sens... |
85 |
return TCM_RESERVATION_CONFLICT; |
d977f4377 target: simplify ... |
86 87 88 |
if (dev->dev_reservation_flags & DRF_SPC2_RESERVATIONS_WITH_ISID) { if (dev->dev_res_bin_isid != sess->sess_bin_isid) |
de103c93a target: pass sens... |
89 |
return TCM_RESERVATION_CONFLICT; |
c66ac9db8 [SCSI] target: Ad... |
90 |
} |
c66ac9db8 [SCSI] target: Ad... |
91 |
|
d977f4377 target: simplify ... |
92 |
return 0; |
c66ac9db8 [SCSI] target: Ad... |
93 |
} |
eacac00ce target: split cor... |
94 95 96 |
static struct t10_pr_registration *core_scsi3_locate_pr_reg(struct se_device *, struct se_node_acl *, struct se_session *); static void core_scsi3_put_pr_reg(struct t10_pr_registration *); |
087a03b3e target: Fix compa... |
97 |
static int target_check_scsi2_reservation_conflict(struct se_cmd *cmd) |
eacac00ce target: split cor... |
98 99 |
{ struct se_session *se_sess = cmd->se_sess; |
0fd97ccf4 target: kill stru... |
100 |
struct se_device *dev = cmd->se_dev; |
eacac00ce target: split cor... |
101 |
struct t10_pr_registration *pr_reg; |
0fd97ccf4 target: kill stru... |
102 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
eacac00ce target: split cor... |
103 |
int conflict = 0; |
eacac00ce target: split cor... |
104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 |
pr_reg = core_scsi3_locate_pr_reg(cmd->se_dev, se_sess->se_node_acl, se_sess); if (pr_reg) { /* * From spc4r17 5.7.3 Exceptions to SPC-2 RESERVE and RELEASE * behavior * * A RESERVE(6) or RESERVE(10) command shall complete with GOOD * status, but no reservation shall be established and the * persistent reservation shall not be changed, if the command * is received from a) and b) below. * * A RELEASE(6) or RELEASE(10) command shall complete with GOOD * status, but the persistent reservation shall not be released, * if the command is received from a) and b) * * a) An I_T nexus that is a persistent reservation holder; or * b) An I_T nexus that is registered if a registrants only or * all registrants type persistent reservation is present. * * In all other cases, a RESERVE(6) command, RESERVE(10) command, * RELEASE(6) command, or RELEASE(10) command shall be processed * as defined in SPC-2. */ if (pr_reg->pr_res_holder) { core_scsi3_put_pr_reg(pr_reg); |
087a03b3e target: Fix compa... |
130 |
return 1; |
eacac00ce target: split cor... |
131 132 133 134 135 136 |
} if ((pr_reg->pr_res_type == PR_TYPE_WRITE_EXCLUSIVE_REGONLY) || (pr_reg->pr_res_type == PR_TYPE_EXCLUSIVE_ACCESS_REGONLY) || (pr_reg->pr_res_type == PR_TYPE_WRITE_EXCLUSIVE_ALLREG) || (pr_reg->pr_res_type == PR_TYPE_EXCLUSIVE_ACCESS_ALLREG)) { core_scsi3_put_pr_reg(pr_reg); |
087a03b3e target: Fix compa... |
137 |
return 1; |
eacac00ce target: split cor... |
138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 |
} core_scsi3_put_pr_reg(pr_reg); conflict = 1; } else { /* * Following spc2r20 5.5.1 Reservations overview: * * If a logical unit has executed a PERSISTENT RESERVE OUT * command with the REGISTER or the REGISTER AND IGNORE * EXISTING KEY service action and is still registered by any * initiator, all RESERVE commands and all RELEASE commands * regardless of initiator shall conflict and shall terminate * with a RESERVATION CONFLICT status. */ spin_lock(&pr_tmpl->registration_lock); conflict = (list_empty(&pr_tmpl->registration_list)) ? 0 : 1; spin_unlock(&pr_tmpl->registration_lock); } if (conflict) { pr_err("Received legacy SPC-2 RESERVE/RELEASE" " while active SPC-3 registrations exist," " returning RESERVATION_CONFLICT "); |
087a03b3e target: Fix compa... |
162 |
return -EBUSY; |
eacac00ce target: split cor... |
163 |
} |
087a03b3e target: Fix compa... |
164 |
return 0; |
eacac00ce target: split cor... |
165 |
} |
de103c93a target: pass sens... |
166 167 |
sense_reason_t target_scsi2_reservation_release(struct se_cmd *cmd) |
c66ac9db8 [SCSI] target: Ad... |
168 169 170 |
{ struct se_device *dev = cmd->se_dev; struct se_session *sess = cmd->se_sess; |
609234e3b target: move the ... |
171 |
struct se_portal_group *tpg; |
de103c93a target: pass sens... |
172 |
int rc; |
c66ac9db8 [SCSI] target: Ad... |
173 |
|
609234e3b target: move the ... |
174 |
if (!sess || !sess->se_tpg) |
d29a5b6ac target: remove SC... |
175 |
goto out; |
087a03b3e target: Fix compa... |
176 177 |
rc = target_check_scsi2_reservation_conflict(cmd); if (rc == 1) |
d29a5b6ac target: remove SC... |
178 |
goto out; |
de103c93a target: pass sens... |
179 180 |
if (rc < 0) return TCM_RESERVATION_CONFLICT; |
c66ac9db8 [SCSI] target: Ad... |
181 182 |
spin_lock(&dev->dev_reservation_lock); |
d29a5b6ac target: remove SC... |
183 184 185 186 187 |
if (!dev->dev_reserved_node_acl || !sess) goto out_unlock; if (dev->dev_reserved_node_acl != sess->se_node_acl) goto out_unlock; |
c66ac9db8 [SCSI] target: Ad... |
188 |
|
edc318d9f target: Fix SPC-2... |
189 190 |
if (dev->dev_res_bin_isid != sess->sess_bin_isid) goto out_unlock; |
c66ac9db8 [SCSI] target: Ad... |
191 |
dev->dev_reserved_node_acl = NULL; |
0fd97ccf4 target: kill stru... |
192 193 |
dev->dev_reservation_flags &= ~DRF_SPC2_RESERVATIONS; if (dev->dev_reservation_flags & DRF_SPC2_RESERVATIONS_WITH_ISID) { |
c66ac9db8 [SCSI] target: Ad... |
194 |
dev->dev_res_bin_isid = 0; |
0fd97ccf4 target: kill stru... |
195 |
dev->dev_reservation_flags &= ~DRF_SPC2_RESERVATIONS_WITH_ISID; |
c66ac9db8 [SCSI] target: Ad... |
196 |
} |
609234e3b target: move the ... |
197 |
tpg = sess->se_tpg; |
6708bb27b target: Follow up... |
198 |
pr_debug("SCSI-2 Released reservation for %s LUN: %u ->" |
e3d6f909e target: Core clea... |
199 200 201 |
" MAPPED LUN: %u for %s ", tpg->se_tpg_tfo->get_fabric_name(), cmd->se_lun->unpacked_lun, cmd->se_deve->mapped_lun, |
c66ac9db8 [SCSI] target: Ad... |
202 |
sess->se_node_acl->initiatorname); |
c66ac9db8 [SCSI] target: Ad... |
203 |
|
d29a5b6ac target: remove SC... |
204 205 206 |
out_unlock: spin_unlock(&dev->dev_reservation_lock); out: |
de103c93a target: pass sens... |
207 208 |
target_complete_cmd(cmd, GOOD); return 0; |
c66ac9db8 [SCSI] target: Ad... |
209 |
} |
de103c93a target: pass sens... |
210 211 |
sense_reason_t target_scsi2_reservation_reserve(struct se_cmd *cmd) |
c66ac9db8 [SCSI] target: Ad... |
212 213 214 |
{ struct se_device *dev = cmd->se_dev; struct se_session *sess = cmd->se_sess; |
609234e3b target: move the ... |
215 |
struct se_portal_group *tpg; |
de103c93a target: pass sens... |
216 217 |
sense_reason_t ret = 0; int rc; |
c66ac9db8 [SCSI] target: Ad... |
218 |
|
a1d8b49ab target: Updates f... |
219 220 |
if ((cmd->t_task_cdb[1] & 0x01) && (cmd->t_task_cdb[1] & 0x02)) { |
6708bb27b target: Follow up... |
221 |
pr_err("LongIO and Obselete Bits set, returning" |
c66ac9db8 [SCSI] target: Ad... |
222 223 |
" ILLEGAL_REQUEST "); |
de103c93a target: pass sens... |
224 |
return TCM_UNSUPPORTED_SCSI_OPCODE; |
c66ac9db8 [SCSI] target: Ad... |
225 226 227 228 229 |
} /* * This is currently the case for target_core_mod passthrough struct se_cmd * ops */ |
609234e3b target: move the ... |
230 |
if (!sess || !sess->se_tpg) |
d29a5b6ac target: remove SC... |
231 |
goto out; |
087a03b3e target: Fix compa... |
232 233 |
rc = target_check_scsi2_reservation_conflict(cmd); if (rc == 1) |
d29a5b6ac target: remove SC... |
234 |
goto out; |
c66ac9db8 [SCSI] target: Ad... |
235 |
|
de103c93a target: pass sens... |
236 237 |
if (rc < 0) return TCM_RESERVATION_CONFLICT; |
609234e3b target: move the ... |
238 |
tpg = sess->se_tpg; |
c66ac9db8 [SCSI] target: Ad... |
239 240 241 |
spin_lock(&dev->dev_reservation_lock); if (dev->dev_reserved_node_acl && (dev->dev_reserved_node_acl != sess->se_node_acl)) { |
6708bb27b target: Follow up... |
242 243 |
pr_err("SCSI-2 RESERVATION CONFLIFT for %s fabric ", |
e3d6f909e target: Core clea... |
244 |
tpg->se_tpg_tfo->get_fabric_name()); |
6708bb27b target: Follow up... |
245 246 |
pr_err("Original reserver LUN: %u %s ", |
e3d6f909e target: Core clea... |
247 |
cmd->se_lun->unpacked_lun, |
c66ac9db8 [SCSI] target: Ad... |
248 |
dev->dev_reserved_node_acl->initiatorname); |
6708bb27b target: Follow up... |
249 |
pr_err("Current attempt - LUN: %u -> MAPPED LUN: %u" |
e3d6f909e target: Core clea... |
250 251 |
" from %s ", cmd->se_lun->unpacked_lun, |
c66ac9db8 [SCSI] target: Ad... |
252 253 |
cmd->se_deve->mapped_lun, sess->se_node_acl->initiatorname); |
de103c93a target: pass sens... |
254 |
ret = TCM_RESERVATION_CONFLICT; |
d29a5b6ac target: remove SC... |
255 |
goto out_unlock; |
c66ac9db8 [SCSI] target: Ad... |
256 257 258 |
} dev->dev_reserved_node_acl = sess->se_node_acl; |
0fd97ccf4 target: kill stru... |
259 |
dev->dev_reservation_flags |= DRF_SPC2_RESERVATIONS; |
c66ac9db8 [SCSI] target: Ad... |
260 261 |
if (sess->sess_bin_isid != 0) { dev->dev_res_bin_isid = sess->sess_bin_isid; |
0fd97ccf4 target: kill stru... |
262 |
dev->dev_reservation_flags |= DRF_SPC2_RESERVATIONS_WITH_ISID; |
c66ac9db8 [SCSI] target: Ad... |
263 |
} |
6708bb27b target: Follow up... |
264 |
pr_debug("SCSI-2 Reserved %s LUN: %u -> MAPPED LUN: %u" |
e3d6f909e target: Core clea... |
265 266 267 |
" for %s ", tpg->se_tpg_tfo->get_fabric_name(), cmd->se_lun->unpacked_lun, cmd->se_deve->mapped_lun, |
c66ac9db8 [SCSI] target: Ad... |
268 |
sess->se_node_acl->initiatorname); |
c66ac9db8 [SCSI] target: Ad... |
269 |
|
d29a5b6ac target: remove SC... |
270 271 272 |
out_unlock: spin_unlock(&dev->dev_reservation_lock); out: |
6bb35e009 target: replace -... |
273 274 |
if (!ret) target_complete_cmd(cmd, GOOD); |
d29a5b6ac target: remove SC... |
275 |
return ret; |
c66ac9db8 [SCSI] target: Ad... |
276 |
} |
c66ac9db8 [SCSI] target: Ad... |
277 278 279 280 281 282 283 284 285 |
/* * Begin SPC-3/SPC-4 Persistent Reservations emulation support * * This function is called by those initiator ports who are *NOT* * the active PR reservation holder when a reservation is present. */ static int core_scsi3_pr_seq_non_holder( struct se_cmd *cmd, |
c66ac9db8 [SCSI] target: Ad... |
286 287 |
u32 pr_reg_type) { |
d977f4377 target: simplify ... |
288 |
unsigned char *cdb = cmd->t_task_cdb; |
c66ac9db8 [SCSI] target: Ad... |
289 |
struct se_dev_entry *se_deve; |
e3d6f909e target: Core clea... |
290 |
struct se_session *se_sess = cmd->se_sess; |
c66ac9db8 [SCSI] target: Ad... |
291 292 293 294 295 296 |
int other_cdb = 0, ignore_reg; int registered_nexus = 0, ret = 1; /* Conflict by default */ int all_reg = 0, reg_only = 0; /* ALL_REG, REG_ONLY */ int we = 0; /* Write Exclusive */ int legacy = 0; /* Act like a legacy device and return * RESERVATION CONFLICT on some CDBs */ |
c66ac9db8 [SCSI] target: Ad... |
297 |
|
f2083241f target: Use array... |
298 |
se_deve = se_sess->se_node_acl->device_list[cmd->orig_fe_lun]; |
c66ac9db8 [SCSI] target: Ad... |
299 300 |
/* * Determine if the registration should be ignored due to |
d977f4377 target: simplify ... |
301 |
* non-matching ISIDs in target_scsi3_pr_reservation_check(). |
c66ac9db8 [SCSI] target: Ad... |
302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 |
*/ ignore_reg = (pr_reg_type & 0x80000000); if (ignore_reg) pr_reg_type &= ~0x80000000; switch (pr_reg_type) { case PR_TYPE_WRITE_EXCLUSIVE: we = 1; case PR_TYPE_EXCLUSIVE_ACCESS: /* * Some commands are only allowed for the persistent reservation * holder. */ if ((se_deve->def_pr_registered) && !(ignore_reg)) registered_nexus = 1; break; case PR_TYPE_WRITE_EXCLUSIVE_REGONLY: we = 1; case PR_TYPE_EXCLUSIVE_ACCESS_REGONLY: /* * Some commands are only allowed for registered I_T Nexuses. */ reg_only = 1; if ((se_deve->def_pr_registered) && !(ignore_reg)) registered_nexus = 1; break; case PR_TYPE_WRITE_EXCLUSIVE_ALLREG: we = 1; case PR_TYPE_EXCLUSIVE_ACCESS_ALLREG: /* * Each registered I_T Nexus is a reservation holder. */ all_reg = 1; if ((se_deve->def_pr_registered) && !(ignore_reg)) registered_nexus = 1; break; default: |
e3d6f909e target: Core clea... |
339 |
return -EINVAL; |
c66ac9db8 [SCSI] target: Ad... |
340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 |
} /* * Referenced from spc4r17 table 45 for *NON* PR holder access */ switch (cdb[0]) { case SECURITY_PROTOCOL_IN: if (registered_nexus) return 0; ret = (we) ? 0 : 1; break; case MODE_SENSE: case MODE_SENSE_10: case READ_ATTRIBUTE: case READ_BUFFER: case RECEIVE_DIAGNOSTIC: if (legacy) { ret = 1; break; } if (registered_nexus) { ret = 0; break; } ret = (we) ? 0 : 1; /* Allowed Write Exclusive */ break; case PERSISTENT_RESERVE_OUT: /* * This follows PERSISTENT_RESERVE_OUT service actions that * are allowed in the presence of various reservations. * See spc4r17, table 46 */ switch (cdb[1] & 0x1f) { case PRO_CLEAR: case PRO_PREEMPT: case PRO_PREEMPT_AND_ABORT: ret = (registered_nexus) ? 0 : 1; break; case PRO_REGISTER: case PRO_REGISTER_AND_IGNORE_EXISTING_KEY: ret = 0; break; case PRO_REGISTER_AND_MOVE: case PRO_RESERVE: ret = 1; break; case PRO_RELEASE: ret = (registered_nexus) ? 0 : 1; break; default: |
6708bb27b target: Follow up... |
389 |
pr_err("Unknown PERSISTENT_RESERVE_OUT service" |
c66ac9db8 [SCSI] target: Ad... |
390 391 |
" action: 0x%02x ", cdb[1] & 0x1f); |
e3d6f909e target: Core clea... |
392 |
return -EINVAL; |
c66ac9db8 [SCSI] target: Ad... |
393 394 395 396 |
} break; case RELEASE: case RELEASE_10: |
eacac00ce target: split cor... |
397 |
/* Handled by CRH=1 in target_scsi2_reservation_release() */ |
c66ac9db8 [SCSI] target: Ad... |
398 399 400 401 |
ret = 0; break; case RESERVE: case RESERVE_10: |
eacac00ce target: split cor... |
402 |
/* Handled by CRH=1 in target_scsi2_reservation_reserve() */ |
c66ac9db8 [SCSI] target: Ad... |
403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 |
ret = 0; break; case TEST_UNIT_READY: ret = (legacy) ? 1 : 0; /* Conflict for legacy */ break; case MAINTENANCE_IN: switch (cdb[1] & 0x1f) { case MI_MANAGEMENT_PROTOCOL_IN: if (registered_nexus) { ret = 0; break; } ret = (we) ? 0 : 1; /* Allowed Write Exclusive */ break; case MI_REPORT_SUPPORTED_OPERATION_CODES: case MI_REPORT_SUPPORTED_TASK_MANAGEMENT_FUNCTIONS: if (legacy) { ret = 1; break; } if (registered_nexus) { ret = 0; break; } ret = (we) ? 0 : 1; /* Allowed Write Exclusive */ break; case MI_REPORT_ALIASES: case MI_REPORT_IDENTIFYING_INFORMATION: case MI_REPORT_PRIORITY: case MI_REPORT_TARGET_PGS: case MI_REPORT_TIMESTAMP: ret = 0; /* Allowed */ break; default: |
6708bb27b target: Follow up... |
437 438 |
pr_err("Unknown MI Service Action: 0x%02x ", |
c66ac9db8 [SCSI] target: Ad... |
439 |
(cdb[1] & 0x1f)); |
e3d6f909e target: Core clea... |
440 |
return -EINVAL; |
c66ac9db8 [SCSI] target: Ad... |
441 442 443 444 445 446 447 448 449 |
} break; case ACCESS_CONTROL_IN: case ACCESS_CONTROL_OUT: case INQUIRY: case LOG_SENSE: case READ_MEDIA_SERIAL_NUMBER: case REPORT_LUNS: case REQUEST_SENSE: |
6816966a8 target: Allow PER... |
450 |
case PERSISTENT_RESERVE_IN: |
c66ac9db8 [SCSI] target: Ad... |
451 452 453 454 455 456 457 |
ret = 0; /*/ Allowed CDBs */ break; default: other_cdb = 1; break; } /* |
25985edce Fix common misspe... |
458 |
* Case where the CDB is explicitly allowed in the above switch |
c66ac9db8 [SCSI] target: Ad... |
459 460 |
* statement. */ |
6708bb27b target: Follow up... |
461 |
if (!ret && !other_cdb) { |
6708bb27b target: Follow up... |
462 |
pr_debug("Allowing explict CDB: 0x%02x for %s" |
c66ac9db8 [SCSI] target: Ad... |
463 464 465 |
" reservation holder ", cdb[0], core_scsi3_pr_dump_type(pr_reg_type)); |
8b1e1244d target/iscsi: Mis... |
466 |
|
c66ac9db8 [SCSI] target: Ad... |
467 468 469 470 471 472 |
return ret; } /* * Check if write exclusive initiator ports *NOT* holding the * WRITE_EXCLUSIVE_* reservation. */ |
ee1b1b9c3 target: Remove un... |
473 |
if (we && !registered_nexus) { |
c66ac9db8 [SCSI] target: Ad... |
474 475 476 477 |
if (cmd->data_direction == DMA_TO_DEVICE) { /* * Conflict for write exclusive */ |
6708bb27b target: Follow up... |
478 |
pr_debug("%s Conflict for unregistered nexus" |
c66ac9db8 [SCSI] target: Ad... |
479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 |
" %s CDB: 0x%02x to %s reservation ", transport_dump_cmd_direction(cmd), se_sess->se_node_acl->initiatorname, cdb[0], core_scsi3_pr_dump_type(pr_reg_type)); return 1; } else { /* * Allow non WRITE CDBs for all Write Exclusive * PR TYPEs to pass for registered and * non-registered_nexuxes NOT holding the reservation. * * We only make noise for the unregisterd nexuses, * as we expect registered non-reservation holding * nexuses to issue CDBs. */ |
8b1e1244d target/iscsi: Mis... |
495 |
|
6708bb27b target: Follow up... |
496 497 |
if (!registered_nexus) { pr_debug("Allowing implict CDB: 0x%02x" |
c66ac9db8 [SCSI] target: Ad... |
498 499 500 501 502 |
" for %s reservation on unregistered" " nexus ", cdb[0], core_scsi3_pr_dump_type(pr_reg_type)); } |
8b1e1244d target/iscsi: Mis... |
503 |
|
c66ac9db8 [SCSI] target: Ad... |
504 505 506 507 508 509 510 511 |
return 0; } } else if ((reg_only) || (all_reg)) { if (registered_nexus) { /* * For PR_*_REG_ONLY and PR_*_ALL_REG reservations, * allow commands from registered nexuses. */ |
8b1e1244d target/iscsi: Mis... |
512 |
|
6708bb27b target: Follow up... |
513 |
pr_debug("Allowing implict CDB: 0x%02x for %s" |
c66ac9db8 [SCSI] target: Ad... |
514 515 516 |
" reservation ", cdb[0], core_scsi3_pr_dump_type(pr_reg_type)); |
8b1e1244d target/iscsi: Mis... |
517 |
|
c66ac9db8 [SCSI] target: Ad... |
518 519 520 |
return 0; } } |
6708bb27b target: Follow up... |
521 |
pr_debug("%s Conflict for %sregistered nexus %s CDB: 0x%2x" |
c66ac9db8 [SCSI] target: Ad... |
522 523 524 525 526 527 528 529 |
" for %s reservation ", transport_dump_cmd_direction(cmd), (registered_nexus) ? "" : "un", se_sess->se_node_acl->initiatorname, cdb[0], core_scsi3_pr_dump_type(pr_reg_type)); return 1; /* Conflict by default */ } |
de103c93a target: pass sens... |
530 531 |
static sense_reason_t target_scsi3_pr_reservation_check(struct se_cmd *cmd) |
d977f4377 target: simplify ... |
532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 |
{ struct se_device *dev = cmd->se_dev; struct se_session *sess = cmd->se_sess; u32 pr_reg_type; if (!dev->dev_pr_res_holder) return 0; pr_reg_type = dev->dev_pr_res_holder->pr_res_type; cmd->pr_res_key = dev->dev_pr_res_holder->pr_res_key; if (dev->dev_pr_res_holder->pr_reg_nacl != sess->se_node_acl) goto check_nonholder; if (dev->dev_pr_res_holder->isid_present_at_reg) { if (dev->dev_pr_res_holder->pr_reg_bin_isid != sess->sess_bin_isid) { pr_reg_type |= 0x80000000; goto check_nonholder; } } return 0; check_nonholder: if (core_scsi3_pr_seq_non_holder(cmd, pr_reg_type)) |
de103c93a target: pass sens... |
557 |
return TCM_RESERVATION_CONFLICT; |
d977f4377 target: simplify ... |
558 559 |
return 0; } |
c66ac9db8 [SCSI] target: Ad... |
560 561 |
static u32 core_scsi3_pr_generation(struct se_device *dev) { |
c66ac9db8 [SCSI] target: Ad... |
562 |
u32 prg; |
0fd97ccf4 target: kill stru... |
563 |
|
c66ac9db8 [SCSI] target: Ad... |
564 565 566 567 568 569 570 571 572 573 |
/* * PRGeneration field shall contain the value of a 32-bit wrapping * counter mainted by the device server. * * Note that this is done regardless of Active Persist across * Target PowerLoss (APTPL) * * See spc4r17 section 6.3.12 READ_KEYS service action */ spin_lock(&dev->dev_reservation_lock); |
0fd97ccf4 target: kill stru... |
574 |
prg = dev->t10_pr.pr_generation++; |
c66ac9db8 [SCSI] target: Ad... |
575 576 577 578 |
spin_unlock(&dev->dev_reservation_lock); return prg; } |
c66ac9db8 [SCSI] target: Ad... |
579 580 581 582 583 584 585 586 587 |
static struct t10_pr_registration *__core_scsi3_do_alloc_registration( struct se_device *dev, struct se_node_acl *nacl, struct se_dev_entry *deve, unsigned char *isid, u64 sa_res_key, int all_tg_pt, int aptpl) { |
c66ac9db8 [SCSI] target: Ad... |
588 589 590 |
struct t10_pr_registration *pr_reg; pr_reg = kmem_cache_zalloc(t10_pr_reg_cache, GFP_ATOMIC); |
6708bb27b target: Follow up... |
591 592 593 |
if (!pr_reg) { pr_err("Unable to allocate struct t10_pr_registration "); |
c66ac9db8 [SCSI] target: Ad... |
594 595 |
return NULL; } |
0fd97ccf4 target: kill stru... |
596 |
pr_reg->pr_aptpl_buf = kzalloc(dev->t10_pr.pr_aptpl_buf_len, |
c66ac9db8 [SCSI] target: Ad... |
597 |
GFP_ATOMIC); |
6708bb27b target: Follow up... |
598 599 600 |
if (!pr_reg->pr_aptpl_buf) { pr_err("Unable to allocate pr_reg->pr_aptpl_buf "); |
c66ac9db8 [SCSI] target: Ad... |
601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 |
kmem_cache_free(t10_pr_reg_cache, pr_reg); return NULL; } INIT_LIST_HEAD(&pr_reg->pr_reg_list); INIT_LIST_HEAD(&pr_reg->pr_reg_abort_list); INIT_LIST_HEAD(&pr_reg->pr_reg_aptpl_list); INIT_LIST_HEAD(&pr_reg->pr_reg_atp_list); INIT_LIST_HEAD(&pr_reg->pr_reg_atp_mem_list); atomic_set(&pr_reg->pr_res_holders, 0); pr_reg->pr_reg_nacl = nacl; pr_reg->pr_reg_deve = deve; pr_reg->pr_res_mapped_lun = deve->mapped_lun; pr_reg->pr_aptpl_target_lun = deve->se_lun->unpacked_lun; pr_reg->pr_res_key = sa_res_key; pr_reg->pr_reg_all_tg_pt = all_tg_pt; pr_reg->pr_reg_aptpl = aptpl; pr_reg->pr_reg_tg_pt_lun = deve->se_lun; /* * If an ISID value for this SCSI Initiator Port exists, * save it to the registration now. */ if (isid != NULL) { pr_reg->pr_reg_bin_isid = get_unaligned_be64(isid); snprintf(pr_reg->pr_reg_isid, PR_REG_ISID_LEN, "%s", isid); pr_reg->isid_present_at_reg = 1; } return pr_reg; } static int core_scsi3_lunacl_depend_item(struct se_dev_entry *); static void core_scsi3_lunacl_undepend_item(struct se_dev_entry *); /* * Function used for handling PR registrations for ALL_TG_PT=1 and ALL_TG_PT=0 * modes. */ static struct t10_pr_registration *__core_scsi3_alloc_registration( struct se_device *dev, struct se_node_acl *nacl, struct se_dev_entry *deve, unsigned char *isid, u64 sa_res_key, int all_tg_pt, int aptpl) { struct se_dev_entry *deve_tmp; struct se_node_acl *nacl_tmp; struct se_port *port, *port_tmp; struct target_core_fabric_ops *tfo = nacl->se_tpg->se_tpg_tfo; struct t10_pr_registration *pr_reg, *pr_reg_atp, *pr_reg_tmp, *pr_reg_tmp_safe; int ret; /* * Create a registration for the I_T Nexus upon which the * PROUT REGISTER was received. */ pr_reg = __core_scsi3_do_alloc_registration(dev, nacl, deve, isid, sa_res_key, all_tg_pt, aptpl); |
6708bb27b target: Follow up... |
660 |
if (!pr_reg) |
c66ac9db8 [SCSI] target: Ad... |
661 662 663 664 |
return NULL; /* * Return pointer to pr_reg for ALL_TG_PT=0 */ |
6708bb27b target: Follow up... |
665 |
if (!all_tg_pt) |
c66ac9db8 [SCSI] target: Ad... |
666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 |
return pr_reg; /* * Create list of matching SCSI Initiator Port registrations * for ALL_TG_PT=1 */ spin_lock(&dev->se_port_lock); list_for_each_entry_safe(port, port_tmp, &dev->dev_sep_list, sep_list) { atomic_inc(&port->sep_tg_pt_ref_cnt); smp_mb__after_atomic_inc(); spin_unlock(&dev->se_port_lock); spin_lock_bh(&port->sep_alua_lock); list_for_each_entry(deve_tmp, &port->sep_alua_list, alua_port_list) { /* * This pointer will be NULL for demo mode MappedLUNs * that have not been make explict via a ConfigFS * MappedLUN group for the SCSI Initiator Node ACL. */ |
6708bb27b target: Follow up... |
685 |
if (!deve_tmp->se_lun_acl) |
c66ac9db8 [SCSI] target: Ad... |
686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 |
continue; nacl_tmp = deve_tmp->se_lun_acl->se_lun_nacl; /* * Skip the matching struct se_node_acl that is allocated * above.. */ if (nacl == nacl_tmp) continue; /* * Only perform PR registrations for target ports on * the same fabric module as the REGISTER w/ ALL_TG_PT=1 * arrived. */ if (tfo != nacl_tmp->se_tpg->se_tpg_tfo) continue; /* * Look for a matching Initiator Node ACL in ASCII format */ if (strcmp(nacl->initiatorname, nacl_tmp->initiatorname)) continue; atomic_inc(&deve_tmp->pr_ref_count); smp_mb__after_atomic_inc(); spin_unlock_bh(&port->sep_alua_lock); /* * Grab a configfs group dependency that is released * for the exception path at label out: below, or upon * completion of adding ALL_TG_PT=1 registrations in * __core_scsi3_add_registration() */ ret = core_scsi3_lunacl_depend_item(deve_tmp); if (ret < 0) { |
6708bb27b target: Follow up... |
719 |
pr_err("core_scsi3_lunacl_depend" |
c66ac9db8 [SCSI] target: Ad... |
720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 |
"_item() failed "); atomic_dec(&port->sep_tg_pt_ref_cnt); smp_mb__after_atomic_dec(); atomic_dec(&deve_tmp->pr_ref_count); smp_mb__after_atomic_dec(); goto out; } /* * Located a matching SCSI Initiator Port on a different * port, allocate the pr_reg_atp and attach it to the * pr_reg->pr_reg_atp_list that will be processed once * the original *pr_reg is processed in * __core_scsi3_add_registration() */ pr_reg_atp = __core_scsi3_do_alloc_registration(dev, nacl_tmp, deve_tmp, NULL, sa_res_key, all_tg_pt, aptpl); |
6708bb27b target: Follow up... |
738 |
if (!pr_reg_atp) { |
c66ac9db8 [SCSI] target: Ad... |
739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 |
atomic_dec(&port->sep_tg_pt_ref_cnt); smp_mb__after_atomic_dec(); atomic_dec(&deve_tmp->pr_ref_count); smp_mb__after_atomic_dec(); core_scsi3_lunacl_undepend_item(deve_tmp); goto out; } list_add_tail(&pr_reg_atp->pr_reg_atp_mem_list, &pr_reg->pr_reg_atp_list); spin_lock_bh(&port->sep_alua_lock); } spin_unlock_bh(&port->sep_alua_lock); spin_lock(&dev->se_port_lock); atomic_dec(&port->sep_tg_pt_ref_cnt); smp_mb__after_atomic_dec(); } spin_unlock(&dev->se_port_lock); return pr_reg; out: list_for_each_entry_safe(pr_reg_tmp, pr_reg_tmp_safe, &pr_reg->pr_reg_atp_list, pr_reg_atp_mem_list) { list_del(&pr_reg_tmp->pr_reg_atp_mem_list); core_scsi3_lunacl_undepend_item(pr_reg_tmp->pr_reg_deve); kmem_cache_free(t10_pr_reg_cache, pr_reg_tmp); } kmem_cache_free(t10_pr_reg_cache, pr_reg); return NULL; } int core_scsi3_alloc_aptpl_registration( |
e3d6f909e target: Core clea... |
772 |
struct t10_reservation *pr_tmpl, |
c66ac9db8 [SCSI] target: Ad... |
773 774 775 776 777 778 779 780 781 782 783 784 |
u64 sa_res_key, unsigned char *i_port, unsigned char *isid, u32 mapped_lun, unsigned char *t_port, u16 tpgt, u32 target_lun, int res_holder, int all_tg_pt, u8 type) { struct t10_pr_registration *pr_reg; |
6708bb27b target: Follow up... |
785 786 787 |
if (!i_port || !t_port || !sa_res_key) { pr_err("Illegal parameters for APTPL registration "); |
e3d6f909e target: Core clea... |
788 |
return -EINVAL; |
c66ac9db8 [SCSI] target: Ad... |
789 790 791 |
} pr_reg = kmem_cache_zalloc(t10_pr_reg_cache, GFP_KERNEL); |
6708bb27b target: Follow up... |
792 793 794 |
if (!pr_reg) { pr_err("Unable to allocate struct t10_pr_registration "); |
e3d6f909e target: Core clea... |
795 |
return -ENOMEM; |
c66ac9db8 [SCSI] target: Ad... |
796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 |
} pr_reg->pr_aptpl_buf = kzalloc(pr_tmpl->pr_aptpl_buf_len, GFP_KERNEL); INIT_LIST_HEAD(&pr_reg->pr_reg_list); INIT_LIST_HEAD(&pr_reg->pr_reg_abort_list); INIT_LIST_HEAD(&pr_reg->pr_reg_aptpl_list); INIT_LIST_HEAD(&pr_reg->pr_reg_atp_list); INIT_LIST_HEAD(&pr_reg->pr_reg_atp_mem_list); atomic_set(&pr_reg->pr_res_holders, 0); pr_reg->pr_reg_nacl = NULL; pr_reg->pr_reg_deve = NULL; pr_reg->pr_res_mapped_lun = mapped_lun; pr_reg->pr_aptpl_target_lun = target_lun; pr_reg->pr_res_key = sa_res_key; pr_reg->pr_reg_all_tg_pt = all_tg_pt; pr_reg->pr_reg_aptpl = 1; pr_reg->pr_reg_tg_pt_lun = NULL; pr_reg->pr_res_scope = 0; /* Always LUN_SCOPE */ pr_reg->pr_res_type = type; /* * If an ISID value had been saved in APTPL metadata for this * SCSI Initiator Port, restore it now. */ if (isid != NULL) { pr_reg->pr_reg_bin_isid = get_unaligned_be64(isid); snprintf(pr_reg->pr_reg_isid, PR_REG_ISID_LEN, "%s", isid); pr_reg->isid_present_at_reg = 1; } /* * Copy the i_port and t_port information from caller. */ snprintf(pr_reg->pr_iport, PR_APTPL_MAX_IPORT_LEN, "%s", i_port); snprintf(pr_reg->pr_tport, PR_APTPL_MAX_TPORT_LEN, "%s", t_port); pr_reg->pr_reg_tpgt = tpgt; /* * Set pr_res_holder from caller, the pr_reg who is the reservation * holder will get it's pointer set in core_scsi3_aptpl_reserve() once * the Initiator Node LUN ACL from the fabric module is created for * this registration. */ pr_reg->pr_res_holder = res_holder; list_add_tail(&pr_reg->pr_reg_aptpl_list, &pr_tmpl->aptpl_reg_list); |
6708bb27b target: Follow up... |
839 |
pr_debug("SPC-3 PR APTPL Successfully added registration%s from" |
c66ac9db8 [SCSI] target: Ad... |
840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 |
" metadata ", (res_holder) ? "+reservation" : ""); return 0; } static void core_scsi3_aptpl_reserve( struct se_device *dev, struct se_portal_group *tpg, struct se_node_acl *node_acl, struct t10_pr_registration *pr_reg) { char i_buf[PR_REG_ISID_ID_LEN]; int prf_isid; memset(i_buf, 0, PR_REG_ISID_ID_LEN); prf_isid = core_pr_dump_initiator_port(pr_reg, &i_buf[0], PR_REG_ISID_ID_LEN); spin_lock(&dev->dev_reservation_lock); dev->dev_pr_res_holder = pr_reg; spin_unlock(&dev->dev_reservation_lock); |
6708bb27b target: Follow up... |
861 |
pr_debug("SPC-3 PR [%s] Service Action: APTPL RESERVE created" |
c66ac9db8 [SCSI] target: Ad... |
862 863 |
" new reservation holder TYPE: %s ALL_TG_PT: %d ", |
e3d6f909e target: Core clea... |
864 |
tpg->se_tpg_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
865 866 |
core_scsi3_pr_dump_type(pr_reg->pr_res_type), (pr_reg->pr_reg_all_tg_pt) ? 1 : 0); |
6708bb27b target: Follow up... |
867 868 |
pr_debug("SPC-3 PR [%s] RESERVE Node: %s%s ", |
e3d6f909e target: Core clea... |
869 |
tpg->se_tpg_tfo->get_fabric_name(), node_acl->initiatorname, |
c66ac9db8 [SCSI] target: Ad... |
870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 |
(prf_isid) ? &i_buf[0] : ""); } static void __core_scsi3_add_registration(struct se_device *, struct se_node_acl *, struct t10_pr_registration *, int, int); static int __core_scsi3_check_aptpl_registration( struct se_device *dev, struct se_portal_group *tpg, struct se_lun *lun, u32 target_lun, struct se_node_acl *nacl, struct se_dev_entry *deve) { struct t10_pr_registration *pr_reg, *pr_reg_tmp; |
0fd97ccf4 target: kill stru... |
885 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
c66ac9db8 [SCSI] target: Ad... |
886 887 888 889 890 891 892 893 894 895 896 |
unsigned char i_port[PR_APTPL_MAX_IPORT_LEN]; unsigned char t_port[PR_APTPL_MAX_TPORT_LEN]; u16 tpgt; memset(i_port, 0, PR_APTPL_MAX_IPORT_LEN); memset(t_port, 0, PR_APTPL_MAX_TPORT_LEN); /* * Copy Initiator Port information from struct se_node_acl */ snprintf(i_port, PR_APTPL_MAX_IPORT_LEN, "%s", nacl->initiatorname); snprintf(t_port, PR_APTPL_MAX_TPORT_LEN, "%s", |
e3d6f909e target: Core clea... |
897 898 |
tpg->se_tpg_tfo->tpg_get_wwn(tpg)); tpgt = tpg->se_tpg_tfo->tpg_get_tag(tpg); |
c66ac9db8 [SCSI] target: Ad... |
899 900 901 902 903 904 905 906 907 |
/* * Look for the matching registrations+reservation from those * created from APTPL metadata. Note that multiple registrations * may exist for fabrics that use ISIDs in their SCSI Initiator Port * TransportIDs. */ spin_lock(&pr_tmpl->aptpl_reg_lock); list_for_each_entry_safe(pr_reg, pr_reg_tmp, &pr_tmpl->aptpl_reg_list, pr_reg_aptpl_list) { |
6708bb27b target: Follow up... |
908 |
if (!strcmp(pr_reg->pr_iport, i_port) && |
c66ac9db8 [SCSI] target: Ad... |
909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 |
(pr_reg->pr_res_mapped_lun == deve->mapped_lun) && !(strcmp(pr_reg->pr_tport, t_port)) && (pr_reg->pr_reg_tpgt == tpgt) && (pr_reg->pr_aptpl_target_lun == target_lun)) { pr_reg->pr_reg_nacl = nacl; pr_reg->pr_reg_deve = deve; pr_reg->pr_reg_tg_pt_lun = lun; list_del(&pr_reg->pr_reg_aptpl_list); spin_unlock(&pr_tmpl->aptpl_reg_lock); /* * At this point all of the pointers in *pr_reg will * be setup, so go ahead and add the registration. */ __core_scsi3_add_registration(dev, nacl, pr_reg, 0, 0); /* * If this registration is the reservation holder, * make that happen now.. */ if (pr_reg->pr_res_holder) core_scsi3_aptpl_reserve(dev, tpg, nacl, pr_reg); /* * Reenable pr_aptpl_active to accept new metadata * updates once the SCSI device is active again.. */ spin_lock(&pr_tmpl->aptpl_reg_lock); pr_tmpl->pr_aptpl_active = 1; } } spin_unlock(&pr_tmpl->aptpl_reg_lock); return 0; } int core_scsi3_check_aptpl_registration( struct se_device *dev, struct se_portal_group *tpg, struct se_lun *lun, struct se_lun_acl *lun_acl) { |
c66ac9db8 [SCSI] target: Ad... |
952 |
struct se_node_acl *nacl = lun_acl->se_lun_nacl; |
f2083241f target: Use array... |
953 |
struct se_dev_entry *deve = nacl->device_list[lun_acl->mapped_lun]; |
c66ac9db8 [SCSI] target: Ad... |
954 |
|
d977f4377 target: simplify ... |
955 |
if (dev->dev_reservation_flags & DRF_SPC2_RESERVATIONS) |
c66ac9db8 [SCSI] target: Ad... |
956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 |
return 0; return __core_scsi3_check_aptpl_registration(dev, tpg, lun, lun->unpacked_lun, nacl, deve); } static void __core_scsi3_dump_registration( struct target_core_fabric_ops *tfo, struct se_device *dev, struct se_node_acl *nacl, struct t10_pr_registration *pr_reg, int register_type) { struct se_portal_group *se_tpg = nacl->se_tpg; char i_buf[PR_REG_ISID_ID_LEN]; int prf_isid; memset(&i_buf[0], 0, PR_REG_ISID_ID_LEN); prf_isid = core_pr_dump_initiator_port(pr_reg, &i_buf[0], PR_REG_ISID_ID_LEN); |
6708bb27b target: Follow up... |
976 |
pr_debug("SPC-3 PR [%s] Service Action: REGISTER%s Initiator" |
c66ac9db8 [SCSI] target: Ad... |
977 978 979 980 981 |
" Node: %s%s ", tfo->get_fabric_name(), (register_type == 2) ? "_AND_MOVE" : (register_type == 1) ? "_AND_IGNORE_EXISTING_KEY" : "", nacl->initiatorname, (prf_isid) ? i_buf : ""); |
6708bb27b target: Follow up... |
982 983 |
pr_debug("SPC-3 PR [%s] registration on Target Port: %s,0x%04x ", |
c66ac9db8 [SCSI] target: Ad... |
984 985 |
tfo->get_fabric_name(), tfo->tpg_get_wwn(se_tpg), tfo->tpg_get_tag(se_tpg)); |
6708bb27b target: Follow up... |
986 |
pr_debug("SPC-3 PR [%s] for %s TCM Subsystem %s Object Target" |
c66ac9db8 [SCSI] target: Ad... |
987 988 989 |
" Port(s) ", tfo->get_fabric_name(), (pr_reg->pr_reg_all_tg_pt) ? "ALL" : "SINGLE", |
e3d6f909e target: Core clea... |
990 |
dev->transport->name); |
6708bb27b target: Follow up... |
991 |
pr_debug("SPC-3 PR [%s] SA Res Key: 0x%016Lx PRgeneration:" |
c66ac9db8 [SCSI] target: Ad... |
992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 |
" 0x%08x APTPL: %d ", tfo->get_fabric_name(), pr_reg->pr_res_key, pr_reg->pr_res_generation, pr_reg->pr_reg_aptpl); } /* * this function can be called with struct se_device->dev_reservation_lock * when register_move = 1 */ static void __core_scsi3_add_registration( struct se_device *dev, struct se_node_acl *nacl, struct t10_pr_registration *pr_reg, int register_type, int register_move) { |
c66ac9db8 [SCSI] target: Ad... |
1009 1010 |
struct target_core_fabric_ops *tfo = nacl->se_tpg->se_tpg_tfo; struct t10_pr_registration *pr_reg_tmp, *pr_reg_tmp_safe; |
0fd97ccf4 target: kill stru... |
1011 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
c66ac9db8 [SCSI] target: Ad... |
1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 |
/* * Increment PRgeneration counter for struct se_device upon a successful * REGISTER, see spc4r17 section 6.3.2 READ_KEYS service action * * Also, when register_move = 1 for PROUT REGISTER_AND_MOVE service * action, the struct se_device->dev_reservation_lock will already be held, * so we do not call core_scsi3_pr_generation() which grabs the lock * for the REGISTER. */ pr_reg->pr_res_generation = (register_move) ? |
0fd97ccf4 target: kill stru... |
1023 |
dev->t10_pr.pr_generation++ : |
c66ac9db8 [SCSI] target: Ad... |
1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 |
core_scsi3_pr_generation(dev); spin_lock(&pr_tmpl->registration_lock); list_add_tail(&pr_reg->pr_reg_list, &pr_tmpl->registration_list); pr_reg->pr_reg_deve->def_pr_registered = 1; __core_scsi3_dump_registration(tfo, dev, nacl, pr_reg, register_type); spin_unlock(&pr_tmpl->registration_lock); /* * Skip extra processing for ALL_TG_PT=0 or REGISTER_AND_MOVE. */ |
6708bb27b target: Follow up... |
1035 |
if (!pr_reg->pr_reg_all_tg_pt || register_move) |
c66ac9db8 [SCSI] target: Ad... |
1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 |
return; /* * Walk pr_reg->pr_reg_atp_list and add registrations for ALL_TG_PT=1 * allocated in __core_scsi3_alloc_registration() */ list_for_each_entry_safe(pr_reg_tmp, pr_reg_tmp_safe, &pr_reg->pr_reg_atp_list, pr_reg_atp_mem_list) { list_del(&pr_reg_tmp->pr_reg_atp_mem_list); pr_reg_tmp->pr_res_generation = core_scsi3_pr_generation(dev); spin_lock(&pr_tmpl->registration_lock); list_add_tail(&pr_reg_tmp->pr_reg_list, &pr_tmpl->registration_list); pr_reg_tmp->pr_reg_deve->def_pr_registered = 1; __core_scsi3_dump_registration(tfo, dev, pr_reg_tmp->pr_reg_nacl, pr_reg_tmp, register_type); spin_unlock(&pr_tmpl->registration_lock); /* * Drop configfs group dependency reference from * __core_scsi3_alloc_registration() */ core_scsi3_lunacl_undepend_item(pr_reg_tmp->pr_reg_deve); } } static int core_scsi3_alloc_registration( struct se_device *dev, struct se_node_acl *nacl, struct se_dev_entry *deve, unsigned char *isid, u64 sa_res_key, int all_tg_pt, int aptpl, int register_type, int register_move) { struct t10_pr_registration *pr_reg; pr_reg = __core_scsi3_alloc_registration(dev, nacl, deve, isid, sa_res_key, all_tg_pt, aptpl); |
6708bb27b target: Follow up... |
1079 |
if (!pr_reg) |
e3d6f909e target: Core clea... |
1080 |
return -EPERM; |
c66ac9db8 [SCSI] target: Ad... |
1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 |
__core_scsi3_add_registration(dev, nacl, pr_reg, register_type, register_move); return 0; } static struct t10_pr_registration *__core_scsi3_locate_pr_reg( struct se_device *dev, struct se_node_acl *nacl, unsigned char *isid) { |
0fd97ccf4 target: kill stru... |
1092 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
c66ac9db8 [SCSI] target: Ad... |
1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 |
struct t10_pr_registration *pr_reg, *pr_reg_tmp; struct se_portal_group *tpg; spin_lock(&pr_tmpl->registration_lock); list_for_each_entry_safe(pr_reg, pr_reg_tmp, &pr_tmpl->registration_list, pr_reg_list) { /* * First look for a matching struct se_node_acl */ if (pr_reg->pr_reg_nacl != nacl) continue; tpg = pr_reg->pr_reg_nacl->se_tpg; /* * If this registration does NOT contain a fabric provided * ISID, then we have found a match. */ |
6708bb27b target: Follow up... |
1110 |
if (!pr_reg->isid_present_at_reg) { |
c66ac9db8 [SCSI] target: Ad... |
1111 1112 1113 1114 1115 |
/* * Determine if this SCSI device server requires that * SCSI Intiatior TransportID w/ ISIDs is enforced * for fabric modules (iSCSI) requiring them. */ |
e3d6f909e target: Core clea... |
1116 |
if (tpg->se_tpg_tfo->sess_get_initiator_sid != NULL) { |
0fd97ccf4 target: kill stru... |
1117 |
if (dev->dev_attrib.enforce_pr_isids) |
c66ac9db8 [SCSI] target: Ad... |
1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 |
continue; } atomic_inc(&pr_reg->pr_res_holders); smp_mb__after_atomic_inc(); spin_unlock(&pr_tmpl->registration_lock); return pr_reg; } /* * If the *pr_reg contains a fabric defined ISID for multi-value * SCSI Initiator Port TransportIDs, then we expect a valid * matching ISID to be provided by the local SCSI Initiator Port. */ |
6708bb27b target: Follow up... |
1130 |
if (!isid) |
c66ac9db8 [SCSI] target: Ad... |
1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 |
continue; if (strcmp(isid, pr_reg->pr_reg_isid)) continue; atomic_inc(&pr_reg->pr_res_holders); smp_mb__after_atomic_inc(); spin_unlock(&pr_tmpl->registration_lock); return pr_reg; } spin_unlock(&pr_tmpl->registration_lock); return NULL; } static struct t10_pr_registration *core_scsi3_locate_pr_reg( struct se_device *dev, struct se_node_acl *nacl, struct se_session *sess) { struct se_portal_group *tpg = nacl->se_tpg; unsigned char buf[PR_REG_ISID_LEN], *isid_ptr = NULL; |
e3d6f909e target: Core clea... |
1152 |
if (tpg->se_tpg_tfo->sess_get_initiator_sid != NULL) { |
c66ac9db8 [SCSI] target: Ad... |
1153 |
memset(&buf[0], 0, PR_REG_ISID_LEN); |
e3d6f909e target: Core clea... |
1154 |
tpg->se_tpg_tfo->sess_get_initiator_sid(sess, &buf[0], |
c66ac9db8 [SCSI] target: Ad... |
1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 |
PR_REG_ISID_LEN); isid_ptr = &buf[0]; } return __core_scsi3_locate_pr_reg(dev, nacl, isid_ptr); } static void core_scsi3_put_pr_reg(struct t10_pr_registration *pr_reg) { atomic_dec(&pr_reg->pr_res_holders); smp_mb__after_atomic_dec(); } static int core_scsi3_check_implict_release( struct se_device *dev, struct t10_pr_registration *pr_reg) { struct se_node_acl *nacl = pr_reg->pr_reg_nacl; struct t10_pr_registration *pr_res_holder; int ret = 0; spin_lock(&dev->dev_reservation_lock); pr_res_holder = dev->dev_pr_res_holder; |
6708bb27b target: Follow up... |
1178 |
if (!pr_res_holder) { |
c66ac9db8 [SCSI] target: Ad... |
1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 |
spin_unlock(&dev->dev_reservation_lock); return ret; } if (pr_res_holder == pr_reg) { /* * Perform an implict RELEASE if the registration that * is being released is holding the reservation. * * From spc4r17, section 5.7.11.1: * * e) If the I_T nexus is the persistent reservation holder * and the persistent reservation is not an all registrants * type, then a PERSISTENT RESERVE OUT command with REGISTER * service action or REGISTER AND IGNORE EXISTING KEY * service action with the SERVICE ACTION RESERVATION KEY * field set to zero (see 5.7.11.3). */ __core_scsi3_complete_pro_release(dev, nacl, pr_reg, 0); ret = 1; /* * For 'All Registrants' reservation types, all existing * registrations are still processed as reservation holders * in core_scsi3_pr_seq_non_holder() after the initial * reservation holder is implictly released here. */ } else if (pr_reg->pr_reg_all_tg_pt && (!strcmp(pr_res_holder->pr_reg_nacl->initiatorname, pr_reg->pr_reg_nacl->initiatorname)) && (pr_res_holder->pr_res_key == pr_reg->pr_res_key)) { |
6708bb27b target: Follow up... |
1208 |
pr_err("SPC-3 PR: Unable to perform ALL_TG_PT=1" |
c66ac9db8 [SCSI] target: Ad... |
1209 1210 1211 1212 |
" UNREGISTER while existing reservation with matching" " key 0x%016Lx is present from another SCSI Initiator" " Port ", pr_reg->pr_res_key); |
e3d6f909e target: Core clea... |
1213 |
ret = -EPERM; |
c66ac9db8 [SCSI] target: Ad... |
1214 1215 1216 1217 1218 1219 1220 |
} spin_unlock(&dev->dev_reservation_lock); return ret; } /* |
e3d6f909e target: Core clea... |
1221 |
* Called with struct t10_reservation->registration_lock held. |
c66ac9db8 [SCSI] target: Ad... |
1222 1223 1224 1225 1226 1227 1228 1229 1230 |
*/ static void __core_scsi3_free_registration( struct se_device *dev, struct t10_pr_registration *pr_reg, struct list_head *preempt_and_abort_list, int dec_holders) { struct target_core_fabric_ops *tfo = pr_reg->pr_reg_nacl->se_tpg->se_tpg_tfo; |
0fd97ccf4 target: kill stru... |
1231 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
c66ac9db8 [SCSI] target: Ad... |
1232 1233 1234 1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253 1254 1255 |
char i_buf[PR_REG_ISID_ID_LEN]; int prf_isid; memset(i_buf, 0, PR_REG_ISID_ID_LEN); prf_isid = core_pr_dump_initiator_port(pr_reg, &i_buf[0], PR_REG_ISID_ID_LEN); pr_reg->pr_reg_deve->def_pr_registered = 0; pr_reg->pr_reg_deve->pr_res_key = 0; list_del(&pr_reg->pr_reg_list); /* * Caller accessing *pr_reg using core_scsi3_locate_pr_reg(), * so call core_scsi3_put_pr_reg() to decrement our reference. */ if (dec_holders) core_scsi3_put_pr_reg(pr_reg); /* * Wait until all reference from any other I_T nexuses for this * *pr_reg have been released. Because list_del() is called above, * the last core_scsi3_put_pr_reg(pr_reg) will release this reference * count back to zero, and we release *pr_reg. */ while (atomic_read(&pr_reg->pr_res_holders) != 0) { spin_unlock(&pr_tmpl->registration_lock); |
6708bb27b target: Follow up... |
1256 1257 |
pr_debug("SPC-3 PR [%s] waiting for pr_res_holders ", |
c66ac9db8 [SCSI] target: Ad... |
1258 1259 1260 1261 |
tfo->get_fabric_name()); cpu_relax(); spin_lock(&pr_tmpl->registration_lock); } |
6708bb27b target: Follow up... |
1262 |
pr_debug("SPC-3 PR [%s] Service Action: UNREGISTER Initiator" |
c66ac9db8 [SCSI] target: Ad... |
1263 1264 1265 1266 |
" Node: %s%s ", tfo->get_fabric_name(), pr_reg->pr_reg_nacl->initiatorname, (prf_isid) ? &i_buf[0] : ""); |
6708bb27b target: Follow up... |
1267 |
pr_debug("SPC-3 PR [%s] for %s TCM Subsystem %s Object Target" |
c66ac9db8 [SCSI] target: Ad... |
1268 1269 1270 |
" Port(s) ", tfo->get_fabric_name(), (pr_reg->pr_reg_all_tg_pt) ? "ALL" : "SINGLE", |
e3d6f909e target: Core clea... |
1271 |
dev->transport->name); |
6708bb27b target: Follow up... |
1272 |
pr_debug("SPC-3 PR [%s] SA Res Key: 0x%016Lx PRgeneration:" |
c66ac9db8 [SCSI] target: Ad... |
1273 1274 1275 |
" 0x%08x ", tfo->get_fabric_name(), pr_reg->pr_res_key, pr_reg->pr_res_generation); |
6708bb27b target: Follow up... |
1276 |
if (!preempt_and_abort_list) { |
c66ac9db8 [SCSI] target: Ad... |
1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 |
pr_reg->pr_reg_deve = NULL; pr_reg->pr_reg_nacl = NULL; kfree(pr_reg->pr_aptpl_buf); kmem_cache_free(t10_pr_reg_cache, pr_reg); return; } /* * For PREEMPT_AND_ABORT, the list of *pr_reg in preempt_and_abort_list * are released once the ABORT_TASK_SET has completed.. */ list_add_tail(&pr_reg->pr_reg_abort_list, preempt_and_abort_list); } void core_scsi3_free_pr_reg_from_nacl( struct se_device *dev, struct se_node_acl *nacl) { |
0fd97ccf4 target: kill stru... |
1294 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
c66ac9db8 [SCSI] target: Ad... |
1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 |
struct t10_pr_registration *pr_reg, *pr_reg_tmp, *pr_res_holder; /* * If the passed se_node_acl matches the reservation holder, * release the reservation. */ spin_lock(&dev->dev_reservation_lock); pr_res_holder = dev->dev_pr_res_holder; if ((pr_res_holder != NULL) && (pr_res_holder->pr_reg_nacl == nacl)) __core_scsi3_complete_pro_release(dev, nacl, pr_res_holder, 0); spin_unlock(&dev->dev_reservation_lock); /* * Release any registration associated with the struct se_node_acl. */ spin_lock(&pr_tmpl->registration_lock); list_for_each_entry_safe(pr_reg, pr_reg_tmp, &pr_tmpl->registration_list, pr_reg_list) { if (pr_reg->pr_reg_nacl != nacl) continue; __core_scsi3_free_registration(dev, pr_reg, NULL, 0); } spin_unlock(&pr_tmpl->registration_lock); } void core_scsi3_free_all_registrations( struct se_device *dev) { |
0fd97ccf4 target: kill stru... |
1324 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
c66ac9db8 [SCSI] target: Ad... |
1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 |
struct t10_pr_registration *pr_reg, *pr_reg_tmp, *pr_res_holder; spin_lock(&dev->dev_reservation_lock); pr_res_holder = dev->dev_pr_res_holder; if (pr_res_holder != NULL) { struct se_node_acl *pr_res_nacl = pr_res_holder->pr_reg_nacl; __core_scsi3_complete_pro_release(dev, pr_res_nacl, pr_res_holder, 0); } spin_unlock(&dev->dev_reservation_lock); spin_lock(&pr_tmpl->registration_lock); list_for_each_entry_safe(pr_reg, pr_reg_tmp, &pr_tmpl->registration_list, pr_reg_list) { __core_scsi3_free_registration(dev, pr_reg, NULL, 0); } spin_unlock(&pr_tmpl->registration_lock); spin_lock(&pr_tmpl->aptpl_reg_lock); list_for_each_entry_safe(pr_reg, pr_reg_tmp, &pr_tmpl->aptpl_reg_list, pr_reg_aptpl_list) { list_del(&pr_reg->pr_reg_aptpl_list); kfree(pr_reg->pr_aptpl_buf); kmem_cache_free(t10_pr_reg_cache, pr_reg); } spin_unlock(&pr_tmpl->aptpl_reg_lock); } static int core_scsi3_tpg_depend_item(struct se_portal_group *tpg) { |
e3d6f909e target: Core clea... |
1356 |
return configfs_depend_item(tpg->se_tpg_tfo->tf_subsys, |
c66ac9db8 [SCSI] target: Ad... |
1357 1358 1359 1360 1361 |
&tpg->tpg_group.cg_item); } static void core_scsi3_tpg_undepend_item(struct se_portal_group *tpg) { |
e3d6f909e target: Core clea... |
1362 |
configfs_undepend_item(tpg->se_tpg_tfo->tf_subsys, |
c66ac9db8 [SCSI] target: Ad... |
1363 1364 1365 1366 1367 1368 1369 1370 1371 1372 1373 1374 |
&tpg->tpg_group.cg_item); atomic_dec(&tpg->tpg_pr_ref_count); smp_mb__after_atomic_dec(); } static int core_scsi3_nodeacl_depend_item(struct se_node_acl *nacl) { struct se_portal_group *tpg = nacl->se_tpg; if (nacl->dynamic_node_acl) return 0; |
e3d6f909e target: Core clea... |
1375 |
return configfs_depend_item(tpg->se_tpg_tfo->tf_subsys, |
c66ac9db8 [SCSI] target: Ad... |
1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 |
&nacl->acl_group.cg_item); } static void core_scsi3_nodeacl_undepend_item(struct se_node_acl *nacl) { struct se_portal_group *tpg = nacl->se_tpg; if (nacl->dynamic_node_acl) { atomic_dec(&nacl->acl_pr_ref_count); smp_mb__after_atomic_dec(); return; } |
e3d6f909e target: Core clea... |
1388 |
configfs_undepend_item(tpg->se_tpg_tfo->tf_subsys, |
c66ac9db8 [SCSI] target: Ad... |
1389 1390 1391 1392 1393 1394 1395 1396 1397 1398 1399 1400 1401 1402 |
&nacl->acl_group.cg_item); atomic_dec(&nacl->acl_pr_ref_count); smp_mb__after_atomic_dec(); } static int core_scsi3_lunacl_depend_item(struct se_dev_entry *se_deve) { struct se_lun_acl *lun_acl = se_deve->se_lun_acl; struct se_node_acl *nacl; struct se_portal_group *tpg; /* * For nacl->dynamic_node_acl=1 */ |
6708bb27b target: Follow up... |
1403 |
if (!lun_acl) |
c66ac9db8 [SCSI] target: Ad... |
1404 1405 1406 1407 |
return 0; nacl = lun_acl->se_lun_nacl; tpg = nacl->se_tpg; |
e3d6f909e target: Core clea... |
1408 |
return configfs_depend_item(tpg->se_tpg_tfo->tf_subsys, |
c66ac9db8 [SCSI] target: Ad... |
1409 1410 1411 1412 1413 1414 1415 1416 1417 1418 1419 |
&lun_acl->se_lun_group.cg_item); } static void core_scsi3_lunacl_undepend_item(struct se_dev_entry *se_deve) { struct se_lun_acl *lun_acl = se_deve->se_lun_acl; struct se_node_acl *nacl; struct se_portal_group *tpg; /* * For nacl->dynamic_node_acl=1 */ |
6708bb27b target: Follow up... |
1420 |
if (!lun_acl) { |
c66ac9db8 [SCSI] target: Ad... |
1421 1422 1423 1424 1425 1426 |
atomic_dec(&se_deve->pr_ref_count); smp_mb__after_atomic_dec(); return; } nacl = lun_acl->se_lun_nacl; tpg = nacl->se_tpg; |
e3d6f909e target: Core clea... |
1427 |
configfs_undepend_item(tpg->se_tpg_tfo->tf_subsys, |
c66ac9db8 [SCSI] target: Ad... |
1428 1429 1430 1431 1432 |
&lun_acl->se_lun_group.cg_item); atomic_dec(&se_deve->pr_ref_count); smp_mb__after_atomic_dec(); } |
de103c93a target: pass sens... |
1433 1434 |
static sense_reason_t core_scsi3_decode_spec_i_port( |
c66ac9db8 [SCSI] target: Ad... |
1435 1436 1437 1438 1439 1440 1441 |
struct se_cmd *cmd, struct se_portal_group *tpg, unsigned char *l_isid, u64 sa_res_key, int all_tg_pt, int aptpl) { |
5951146de target: More core... |
1442 |
struct se_device *dev = cmd->se_dev; |
c66ac9db8 [SCSI] target: Ad... |
1443 1444 |
struct se_port *tmp_port; struct se_portal_group *dest_tpg = NULL, *tmp_tpg; |
e3d6f909e target: Core clea... |
1445 |
struct se_session *se_sess = cmd->se_sess; |
c66ac9db8 [SCSI] target: Ad... |
1446 1447 1448 1449 |
struct se_node_acl *dest_node_acl = NULL; struct se_dev_entry *dest_se_deve = NULL, *local_se_deve; struct t10_pr_registration *dest_pr_reg, *local_pr_reg, *pr_reg_e; struct t10_pr_registration *pr_reg_tmp, *pr_reg_tmp_safe; |
d0f474e50 target: Use LIST_... |
1450 |
LIST_HEAD(tid_dest_list); |
c66ac9db8 [SCSI] target: Ad... |
1451 1452 |
struct pr_transport_id_holder *tidh_new, *tidh, *tidh_tmp; struct target_core_fabric_ops *tmp_tf_ops; |
05d1c7c0d target: Make all ... |
1453 |
unsigned char *buf; |
c66ac9db8 [SCSI] target: Ad... |
1454 1455 |
unsigned char *ptr, *i_str = NULL, proto_ident, tmp_proto_ident; char *iport_ptr = NULL, dest_iport[64], i_buf[PR_REG_ISID_ID_LEN]; |
de103c93a target: pass sens... |
1456 |
sense_reason_t ret; |
c66ac9db8 [SCSI] target: Ad... |
1457 |
u32 tpdl, tid_len = 0; |
de103c93a target: pass sens... |
1458 |
int dest_local_nexus, prf_isid; |
c66ac9db8 [SCSI] target: Ad... |
1459 1460 1461 |
u32 dest_rtpi = 0; memset(dest_iport, 0, 64); |
c66ac9db8 [SCSI] target: Ad... |
1462 |
|
f2083241f target: Use array... |
1463 |
local_se_deve = se_sess->se_node_acl->device_list[cmd->orig_fe_lun]; |
c66ac9db8 [SCSI] target: Ad... |
1464 1465 1466 1467 1468 1469 1470 |
/* * Allocate a struct pr_transport_id_holder and setup the * local_node_acl and local_se_deve pointers and add to * struct list_head tid_dest_list for add registration * processing in the loop of tid_dest_list below. */ tidh_new = kzalloc(sizeof(struct pr_transport_id_holder), GFP_KERNEL); |
6708bb27b target: Follow up... |
1471 1472 1473 |
if (!tidh_new) { pr_err("Unable to allocate tidh_new "); |
de103c93a target: pass sens... |
1474 |
return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
1475 1476 1477 1478 1479 |
} INIT_LIST_HEAD(&tidh_new->dest_list); tidh_new->dest_tpg = tpg; tidh_new->dest_node_acl = se_sess->se_node_acl; tidh_new->dest_se_deve = local_se_deve; |
5951146de target: More core... |
1480 |
local_pr_reg = __core_scsi3_alloc_registration(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
1481 1482 |
se_sess->se_node_acl, local_se_deve, l_isid, sa_res_key, all_tg_pt, aptpl); |
6708bb27b target: Follow up... |
1483 |
if (!local_pr_reg) { |
c66ac9db8 [SCSI] target: Ad... |
1484 |
kfree(tidh_new); |
de103c93a target: pass sens... |
1485 |
return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
1486 1487 1488 1489 1490 1491 1492 1493 1494 |
} tidh_new->dest_pr_reg = local_pr_reg; /* * The local I_T nexus does not hold any configfs dependances, * so we set tid_h->dest_local_nexus=1 to prevent the * configfs_undepend_item() calls in the tid_dest_list loops below. */ tidh_new->dest_local_nexus = 1; list_add_tail(&tidh_new->dest_list, &tid_dest_list); |
05d1c7c0d target: Make all ... |
1495 |
|
0d7f1299c target: report to... |
1496 1497 1498 1499 |
if (cmd->data_length < 28) { pr_warn("SPC-PR: Received PR OUT parameter list" " length too small: %u ", cmd->data_length); |
de103c93a target: pass sens... |
1500 |
ret = TCM_INVALID_PARAMETER_LIST; |
0d7f1299c target: report to... |
1501 1502 |
goto out; } |
4949314c7 target: Allow con... |
1503 |
buf = transport_kmap_data_sg(cmd); |
de103c93a target: pass sens... |
1504 1505 1506 1507 |
if (!buf) { ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; goto out; } |
c66ac9db8 [SCSI] target: Ad... |
1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 |
/* * For a PERSISTENT RESERVE OUT specify initiator ports payload, * first extract TransportID Parameter Data Length, and make sure * the value matches up to the SCSI expected data transfer length. */ tpdl = (buf[24] & 0xff) << 24; tpdl |= (buf[25] & 0xff) << 16; tpdl |= (buf[26] & 0xff) << 8; tpdl |= buf[27] & 0xff; if ((tpdl + 28) != cmd->data_length) { |
6708bb27b target: Follow up... |
1519 |
pr_err("SPC-3 PR: Illegal tpdl: %u + 28 byte header" |
c66ac9db8 [SCSI] target: Ad... |
1520 1521 1522 |
" does not equal CDB data_length: %u ", tpdl, cmd->data_length); |
de103c93a target: pass sens... |
1523 1524 |
ret = TCM_INVALID_PARAMETER_LIST; goto out_unmap; |
c66ac9db8 [SCSI] target: Ad... |
1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 |
} /* * Start processing the received transport IDs using the * receiving I_T Nexus portal's fabric dependent methods to * obtain the SCSI Initiator Port/Device Identifiers. */ ptr = &buf[28]; while (tpdl > 0) { proto_ident = (ptr[0] & 0x0f); dest_tpg = NULL; spin_lock(&dev->se_port_lock); list_for_each_entry(tmp_port, &dev->dev_sep_list, sep_list) { tmp_tpg = tmp_port->sep_tpg; |
6708bb27b target: Follow up... |
1540 |
if (!tmp_tpg) |
c66ac9db8 [SCSI] target: Ad... |
1541 |
continue; |
e3d6f909e target: Core clea... |
1542 |
tmp_tf_ops = tmp_tpg->se_tpg_tfo; |
6708bb27b target: Follow up... |
1543 |
if (!tmp_tf_ops) |
c66ac9db8 [SCSI] target: Ad... |
1544 |
continue; |
6708bb27b target: Follow up... |
1545 1546 |
if (!tmp_tf_ops->get_fabric_proto_ident || !tmp_tf_ops->tpg_parse_pr_out_transport_id) |
c66ac9db8 [SCSI] target: Ad... |
1547 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 |
continue; /* * Look for the matching proto_ident provided by * the received TransportID */ tmp_proto_ident = tmp_tf_ops->get_fabric_proto_ident(tmp_tpg); if (tmp_proto_ident != proto_ident) continue; dest_rtpi = tmp_port->sep_rtpi; i_str = tmp_tf_ops->tpg_parse_pr_out_transport_id( tmp_tpg, (const char *)ptr, &tid_len, &iport_ptr); |
6708bb27b target: Follow up... |
1560 |
if (!i_str) |
c66ac9db8 [SCSI] target: Ad... |
1561 1562 1563 1564 1565 |
continue; atomic_inc(&tmp_tpg->tpg_pr_ref_count); smp_mb__after_atomic_inc(); spin_unlock(&dev->se_port_lock); |
de103c93a target: pass sens... |
1566 |
if (core_scsi3_tpg_depend_item(tmp_tpg)) { |
6708bb27b target: Follow up... |
1567 |
pr_err(" core_scsi3_tpg_depend_item()" |
c66ac9db8 [SCSI] target: Ad... |
1568 1569 1570 1571 |
" for tmp_tpg "); atomic_dec(&tmp_tpg->tpg_pr_ref_count); smp_mb__after_atomic_dec(); |
de103c93a target: pass sens... |
1572 1573 |
ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; goto out_unmap; |
c66ac9db8 [SCSI] target: Ad... |
1574 1575 |
} /* |
35d1efe80 target: Fix minor... |
1576 |
* Locate the destination initiator ACL to be registered |
c66ac9db8 [SCSI] target: Ad... |
1577 1578 1579 |
* from the decoded fabric module specific TransportID * at *i_str. */ |
28638887f target: Convert a... |
1580 |
spin_lock_irq(&tmp_tpg->acl_node_lock); |
c66ac9db8 [SCSI] target: Ad... |
1581 1582 1583 1584 1585 1586 |
dest_node_acl = __core_tpg_get_initiator_node_acl( tmp_tpg, i_str); if (dest_node_acl) { atomic_inc(&dest_node_acl->acl_pr_ref_count); smp_mb__after_atomic_inc(); } |
28638887f target: Convert a... |
1587 |
spin_unlock_irq(&tmp_tpg->acl_node_lock); |
c66ac9db8 [SCSI] target: Ad... |
1588 |
|
6708bb27b target: Follow up... |
1589 |
if (!dest_node_acl) { |
c66ac9db8 [SCSI] target: Ad... |
1590 1591 1592 1593 |
core_scsi3_tpg_undepend_item(tmp_tpg); spin_lock(&dev->se_port_lock); continue; } |
de103c93a target: pass sens... |
1594 |
if (core_scsi3_nodeacl_depend_item(dest_node_acl)) { |
6708bb27b target: Follow up... |
1595 |
pr_err("configfs_depend_item() failed" |
c66ac9db8 [SCSI] target: Ad... |
1596 1597 1598 1599 1600 |
" for dest_node_acl->acl_group "); atomic_dec(&dest_node_acl->acl_pr_ref_count); smp_mb__after_atomic_dec(); core_scsi3_tpg_undepend_item(tmp_tpg); |
de103c93a target: pass sens... |
1601 1602 |
ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; goto out_unmap; |
c66ac9db8 [SCSI] target: Ad... |
1603 1604 1605 |
} dest_tpg = tmp_tpg; |
6708bb27b target: Follow up... |
1606 |
pr_debug("SPC-3 PR SPEC_I_PT: Located %s Node:" |
c66ac9db8 [SCSI] target: Ad... |
1607 1608 |
" %s Port RTPI: %hu ", |
e3d6f909e target: Core clea... |
1609 |
dest_tpg->se_tpg_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
1610 1611 1612 1613 1614 1615 |
dest_node_acl->initiatorname, dest_rtpi); spin_lock(&dev->se_port_lock); break; } spin_unlock(&dev->se_port_lock); |
6708bb27b target: Follow up... |
1616 1617 |
if (!dest_tpg) { pr_err("SPC-3 PR SPEC_I_PT: Unable to locate" |
c66ac9db8 [SCSI] target: Ad... |
1618 1619 |
" dest_tpg "); |
de103c93a target: pass sens... |
1620 1621 |
ret = TCM_INVALID_PARAMETER_LIST; goto out_unmap; |
c66ac9db8 [SCSI] target: Ad... |
1622 |
} |
8b1e1244d target/iscsi: Mis... |
1623 |
|
6708bb27b target: Follow up... |
1624 |
pr_debug("SPC-3 PR SPEC_I_PT: Got %s data_length: %u tpdl: %u" |
c66ac9db8 [SCSI] target: Ad... |
1625 1626 |
" tid_len: %d for %s + %s ", |
e3d6f909e target: Core clea... |
1627 |
dest_tpg->se_tpg_tfo->get_fabric_name(), cmd->data_length, |
c66ac9db8 [SCSI] target: Ad... |
1628 |
tpdl, tid_len, i_str, iport_ptr); |
8b1e1244d target/iscsi: Mis... |
1629 |
|
c66ac9db8 [SCSI] target: Ad... |
1630 |
if (tid_len > tpdl) { |
6708bb27b target: Follow up... |
1631 |
pr_err("SPC-3 PR SPEC_I_PT: Illegal tid_len:" |
c66ac9db8 [SCSI] target: Ad... |
1632 1633 1634 1635 |
" %u for Transport ID: %s ", tid_len, ptr); core_scsi3_nodeacl_undepend_item(dest_node_acl); core_scsi3_tpg_undepend_item(dest_tpg); |
de103c93a target: pass sens... |
1636 1637 |
ret = TCM_INVALID_PARAMETER_LIST; goto out_unmap; |
c66ac9db8 [SCSI] target: Ad... |
1638 1639 1640 1641 1642 1643 1644 1645 |
} /* * Locate the desintation struct se_dev_entry pointer for matching * RELATIVE TARGET PORT IDENTIFIER on the receiving I_T Nexus * Target Port. */ dest_se_deve = core_get_se_deve_from_rtpi(dest_node_acl, dest_rtpi); |
6708bb27b target: Follow up... |
1646 1647 |
if (!dest_se_deve) { pr_err("Unable to locate %s dest_se_deve" |
c66ac9db8 [SCSI] target: Ad... |
1648 1649 |
" from destination RTPI: %hu ", |
e3d6f909e target: Core clea... |
1650 |
dest_tpg->se_tpg_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
1651 1652 1653 1654 |
dest_rtpi); core_scsi3_nodeacl_undepend_item(dest_node_acl); core_scsi3_tpg_undepend_item(dest_tpg); |
de103c93a target: pass sens... |
1655 1656 |
ret = TCM_INVALID_PARAMETER_LIST; goto out_unmap; |
c66ac9db8 [SCSI] target: Ad... |
1657 |
} |
de103c93a target: pass sens... |
1658 |
if (core_scsi3_lunacl_depend_item(dest_se_deve)) { |
6708bb27b target: Follow up... |
1659 |
pr_err("core_scsi3_lunacl_depend_item()" |
c66ac9db8 [SCSI] target: Ad... |
1660 1661 1662 1663 1664 1665 |
" failed "); atomic_dec(&dest_se_deve->pr_ref_count); smp_mb__after_atomic_dec(); core_scsi3_nodeacl_undepend_item(dest_node_acl); core_scsi3_tpg_undepend_item(dest_tpg); |
de103c93a target: pass sens... |
1666 1667 |
ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; goto out_unmap; |
c66ac9db8 [SCSI] target: Ad... |
1668 |
} |
8b1e1244d target/iscsi: Mis... |
1669 |
|
6708bb27b target: Follow up... |
1670 |
pr_debug("SPC-3 PR SPEC_I_PT: Located %s Node: %s" |
c66ac9db8 [SCSI] target: Ad... |
1671 1672 |
" dest_se_deve mapped_lun: %u ", |
e3d6f909e target: Core clea... |
1673 |
dest_tpg->se_tpg_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
1674 |
dest_node_acl->initiatorname, dest_se_deve->mapped_lun); |
8b1e1244d target/iscsi: Mis... |
1675 |
|
c66ac9db8 [SCSI] target: Ad... |
1676 1677 1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688 1689 1690 1691 1692 1693 1694 1695 1696 1697 1698 |
/* * Skip any TransportIDs that already have a registration for * this target port. */ pr_reg_e = __core_scsi3_locate_pr_reg(dev, dest_node_acl, iport_ptr); if (pr_reg_e) { core_scsi3_put_pr_reg(pr_reg_e); core_scsi3_lunacl_undepend_item(dest_se_deve); core_scsi3_nodeacl_undepend_item(dest_node_acl); core_scsi3_tpg_undepend_item(dest_tpg); ptr += tid_len; tpdl -= tid_len; tid_len = 0; continue; } /* * Allocate a struct pr_transport_id_holder and setup * the dest_node_acl and dest_se_deve pointers for the * loop below. */ tidh_new = kzalloc(sizeof(struct pr_transport_id_holder), GFP_KERNEL); |
6708bb27b target: Follow up... |
1699 1700 1701 |
if (!tidh_new) { pr_err("Unable to allocate tidh_new "); |
c66ac9db8 [SCSI] target: Ad... |
1702 1703 1704 |
core_scsi3_lunacl_undepend_item(dest_se_deve); core_scsi3_nodeacl_undepend_item(dest_node_acl); core_scsi3_tpg_undepend_item(dest_tpg); |
de103c93a target: pass sens... |
1705 1706 |
ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; goto out_unmap; |
c66ac9db8 [SCSI] target: Ad... |
1707 1708 1709 1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725 1726 1727 1728 |
} INIT_LIST_HEAD(&tidh_new->dest_list); tidh_new->dest_tpg = dest_tpg; tidh_new->dest_node_acl = dest_node_acl; tidh_new->dest_se_deve = dest_se_deve; /* * Allocate, but do NOT add the registration for the * TransportID referenced SCSI Initiator port. This * done because of the following from spc4r17 in section * 6.14.3 wrt SPEC_I_PT: * * "If a registration fails for any initiator port (e.g., if th * logical unit does not have enough resources available to * hold the registration information), no registrations shall be * made, and the command shall be terminated with * CHECK CONDITION status." * * That means we call __core_scsi3_alloc_registration() here, * and then call __core_scsi3_add_registration() in the * 2nd loop which will never fail. */ |
5951146de target: More core... |
1729 |
dest_pr_reg = __core_scsi3_alloc_registration(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
1730 1731 |
dest_node_acl, dest_se_deve, iport_ptr, sa_res_key, all_tg_pt, aptpl); |
6708bb27b target: Follow up... |
1732 |
if (!dest_pr_reg) { |
c66ac9db8 [SCSI] target: Ad... |
1733 1734 1735 1736 |
core_scsi3_lunacl_undepend_item(dest_se_deve); core_scsi3_nodeacl_undepend_item(dest_node_acl); core_scsi3_tpg_undepend_item(dest_tpg); kfree(tidh_new); |
de103c93a target: pass sens... |
1737 1738 |
ret = TCM_INVALID_PARAMETER_LIST; goto out_unmap; |
c66ac9db8 [SCSI] target: Ad... |
1739 1740 1741 1742 1743 1744 1745 1746 1747 |
} tidh_new->dest_pr_reg = dest_pr_reg; list_add_tail(&tidh_new->dest_list, &tid_dest_list); ptr += tid_len; tpdl -= tid_len; tid_len = 0; } |
05d1c7c0d target: Make all ... |
1748 |
|
4949314c7 target: Allow con... |
1749 |
transport_kunmap_data_sg(cmd); |
05d1c7c0d target: Make all ... |
1750 |
|
c66ac9db8 [SCSI] target: Ad... |
1751 1752 1753 1754 1755 1756 1757 1758 1759 1760 1761 1762 1763 1764 1765 1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 |
/* * Go ahead and create a registrations from tid_dest_list for the * SPEC_I_PT provided TransportID for the *tidh referenced dest_node_acl * and dest_se_deve. * * The SA Reservation Key from the PROUT is set for the * registration, and ALL_TG_PT is also passed. ALL_TG_PT=1 * means that the TransportID Initiator port will be * registered on all of the target ports in the SCSI target device * ALL_TG_PT=0 means the registration will only be for the * SCSI target port the PROUT REGISTER with SPEC_I_PT=1 * was received. */ list_for_each_entry_safe(tidh, tidh_tmp, &tid_dest_list, dest_list) { dest_tpg = tidh->dest_tpg; dest_node_acl = tidh->dest_node_acl; dest_se_deve = tidh->dest_se_deve; dest_pr_reg = tidh->dest_pr_reg; dest_local_nexus = tidh->dest_local_nexus; list_del(&tidh->dest_list); kfree(tidh); memset(i_buf, 0, PR_REG_ISID_ID_LEN); prf_isid = core_pr_dump_initiator_port(dest_pr_reg, &i_buf[0], PR_REG_ISID_ID_LEN); |
5951146de target: More core... |
1777 |
__core_scsi3_add_registration(cmd->se_dev, dest_node_acl, |
c66ac9db8 [SCSI] target: Ad... |
1778 |
dest_pr_reg, 0, 0); |
6708bb27b target: Follow up... |
1779 |
pr_debug("SPC-3 PR [%s] SPEC_I_PT: Successfully" |
c66ac9db8 [SCSI] target: Ad... |
1780 |
" registered Transport ID for Node: %s%s Mapped LUN:" |
e3d6f909e target: Core clea... |
1781 1782 |
" %u ", dest_tpg->se_tpg_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
1783 1784 1785 1786 1787 1788 1789 1790 1791 1792 1793 1794 |
dest_node_acl->initiatorname, (prf_isid) ? &i_buf[0] : "", dest_se_deve->mapped_lun); if (dest_local_nexus) continue; core_scsi3_lunacl_undepend_item(dest_se_deve); core_scsi3_nodeacl_undepend_item(dest_node_acl); core_scsi3_tpg_undepend_item(dest_tpg); } return 0; |
de103c93a target: pass sens... |
1795 |
out_unmap: |
4949314c7 target: Allow con... |
1796 |
transport_kunmap_data_sg(cmd); |
de103c93a target: pass sens... |
1797 |
out: |
c66ac9db8 [SCSI] target: Ad... |
1798 1799 1800 1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 |
/* * For the failure case, release everything from tid_dest_list * including *dest_pr_reg and the configfs dependances.. */ list_for_each_entry_safe(tidh, tidh_tmp, &tid_dest_list, dest_list) { dest_tpg = tidh->dest_tpg; dest_node_acl = tidh->dest_node_acl; dest_se_deve = tidh->dest_se_deve; dest_pr_reg = tidh->dest_pr_reg; dest_local_nexus = tidh->dest_local_nexus; list_del(&tidh->dest_list); kfree(tidh); /* * Release any extra ALL_TG_PT=1 registrations for * the SPEC_I_PT=1 case. */ list_for_each_entry_safe(pr_reg_tmp, pr_reg_tmp_safe, &dest_pr_reg->pr_reg_atp_list, pr_reg_atp_mem_list) { list_del(&pr_reg_tmp->pr_reg_atp_mem_list); core_scsi3_lunacl_undepend_item(pr_reg_tmp->pr_reg_deve); kmem_cache_free(t10_pr_reg_cache, pr_reg_tmp); } kfree(dest_pr_reg->pr_aptpl_buf); kmem_cache_free(t10_pr_reg_cache, dest_pr_reg); if (dest_local_nexus) continue; core_scsi3_lunacl_undepend_item(dest_se_deve); core_scsi3_nodeacl_undepend_item(dest_node_acl); core_scsi3_tpg_undepend_item(dest_tpg); } return ret; } /* * Called with struct se_device->dev_reservation_lock held */ static int __core_scsi3_update_aptpl_buf( struct se_device *dev, unsigned char *buf, u32 pr_aptpl_buf_len, int clear_aptpl_metadata) { struct se_lun *lun; struct se_portal_group *tpg; |
c66ac9db8 [SCSI] target: Ad... |
1847 1848 1849 1850 1851 1852 1853 1854 1855 1856 1857 1858 1859 1860 1861 1862 1863 1864 |
struct t10_pr_registration *pr_reg; unsigned char tmp[512], isid_buf[32]; ssize_t len = 0; int reg_count = 0; memset(buf, 0, pr_aptpl_buf_len); /* * Called to clear metadata once APTPL has been deactivated. */ if (clear_aptpl_metadata) { snprintf(buf, pr_aptpl_buf_len, "No Registrations or Reservations "); return 0; } /* * Walk the registration list.. */ |
0fd97ccf4 target: kill stru... |
1865 1866 |
spin_lock(&dev->t10_pr.registration_lock); list_for_each_entry(pr_reg, &dev->t10_pr.registration_list, |
c66ac9db8 [SCSI] target: Ad... |
1867 1868 1869 1870 1871 1872 1873 1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886 1887 1888 1889 1890 1891 1892 1893 1894 1895 1896 1897 1898 1899 1900 1901 |
pr_reg_list) { tmp[0] = '\0'; isid_buf[0] = '\0'; tpg = pr_reg->pr_reg_nacl->se_tpg; lun = pr_reg->pr_reg_tg_pt_lun; /* * Write out any ISID value to APTPL metadata that was included * in the original registration. */ if (pr_reg->isid_present_at_reg) snprintf(isid_buf, 32, "initiator_sid=%s ", pr_reg->pr_reg_isid); /* * Include special metadata if the pr_reg matches the * reservation holder. */ if (dev->dev_pr_res_holder == pr_reg) { snprintf(tmp, 512, "PR_REG_START: %d" " initiator_fabric=%s " "initiator_node=%s %s" "sa_res_key=%llu " "res_holder=1 res_type=%02x " "res_scope=%02x res_all_tg_pt=%d " "mapped_lun=%u ", reg_count, |
e3d6f909e target: Core clea... |
1902 |
tpg->se_tpg_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914 1915 1916 1917 1918 |
pr_reg->pr_reg_nacl->initiatorname, isid_buf, pr_reg->pr_res_key, pr_reg->pr_res_type, pr_reg->pr_res_scope, pr_reg->pr_reg_all_tg_pt, pr_reg->pr_res_mapped_lun); } else { snprintf(tmp, 512, "PR_REG_START: %d " "initiator_fabric=%s initiator_node=%s %s" "sa_res_key=%llu res_holder=0 " "res_all_tg_pt=%d mapped_lun=%u ", |
e3d6f909e target: Core clea... |
1919 |
reg_count, tpg->se_tpg_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
1920 1921 1922 1923 |
pr_reg->pr_reg_nacl->initiatorname, isid_buf, pr_reg->pr_res_key, pr_reg->pr_reg_all_tg_pt, pr_reg->pr_res_mapped_lun); } |
60d645a4e target: Fix incor... |
1924 |
if ((len + strlen(tmp) >= pr_aptpl_buf_len)) { |
6708bb27b target: Follow up... |
1925 |
pr_err("Unable to update renaming" |
c66ac9db8 [SCSI] target: Ad... |
1926 1927 |
" APTPL metadata "); |
0fd97ccf4 target: kill stru... |
1928 |
spin_unlock(&dev->t10_pr.registration_lock); |
e3d6f909e target: Core clea... |
1929 |
return -EMSGSIZE; |
c66ac9db8 [SCSI] target: Ad... |
1930 1931 1932 1933 1934 1935 1936 1937 1938 1939 1940 1941 1942 |
} len += sprintf(buf+len, "%s", tmp); /* * Include information about the associated SCSI target port. */ snprintf(tmp, 512, "target_fabric=%s target_node=%s " "tpgt=%hu port_rtpi=%hu target_lun=%u PR_REG_END:" |
e3d6f909e target: Core clea... |
1943 1944 1945 1946 |
" %d ", tpg->se_tpg_tfo->get_fabric_name(), tpg->se_tpg_tfo->tpg_get_wwn(tpg), tpg->se_tpg_tfo->tpg_get_tag(tpg), |
c66ac9db8 [SCSI] target: Ad... |
1947 |
lun->lun_sep->sep_rtpi, lun->unpacked_lun, reg_count); |
60d645a4e target: Fix incor... |
1948 |
if ((len + strlen(tmp) >= pr_aptpl_buf_len)) { |
6708bb27b target: Follow up... |
1949 |
pr_err("Unable to update renaming" |
c66ac9db8 [SCSI] target: Ad... |
1950 1951 |
" APTPL metadata "); |
0fd97ccf4 target: kill stru... |
1952 |
spin_unlock(&dev->t10_pr.registration_lock); |
e3d6f909e target: Core clea... |
1953 |
return -EMSGSIZE; |
c66ac9db8 [SCSI] target: Ad... |
1954 1955 1956 1957 |
} len += sprintf(buf+len, "%s", tmp); reg_count++; } |
0fd97ccf4 target: kill stru... |
1958 |
spin_unlock(&dev->t10_pr.registration_lock); |
c66ac9db8 [SCSI] target: Ad... |
1959 |
|
6708bb27b target: Follow up... |
1960 |
if (!reg_count) |
c66ac9db8 [SCSI] target: Ad... |
1961 1962 1963 1964 1965 1966 1967 1968 1969 1970 1971 1972 1973 1974 1975 1976 1977 1978 1979 1980 1981 1982 1983 1984 1985 1986 1987 1988 1989 |
len += sprintf(buf+len, "No Registrations or Reservations"); return 0; } static int core_scsi3_update_aptpl_buf( struct se_device *dev, unsigned char *buf, u32 pr_aptpl_buf_len, int clear_aptpl_metadata) { int ret; spin_lock(&dev->dev_reservation_lock); ret = __core_scsi3_update_aptpl_buf(dev, buf, pr_aptpl_buf_len, clear_aptpl_metadata); spin_unlock(&dev->dev_reservation_lock); return ret; } /* * Called with struct se_device->aptpl_file_mutex held */ static int __core_scsi3_write_aptpl_to_file( struct se_device *dev, unsigned char *buf, u32 pr_aptpl_buf_len) { |
0fd97ccf4 target: kill stru... |
1990 |
struct t10_wwn *wwn = &dev->t10_wwn; |
c66ac9db8 [SCSI] target: Ad... |
1991 |
struct file *file; |
c66ac9db8 [SCSI] target: Ad... |
1992 1993 1994 |
int flags = O_RDWR | O_CREAT | O_TRUNC; char path[512]; int ret; |
c66ac9db8 [SCSI] target: Ad... |
1995 |
memset(path, 0, 512); |
60d645a4e target: Fix incor... |
1996 |
if (strlen(&wwn->unit_serial[0]) >= 512) { |
6708bb27b target: Follow up... |
1997 |
pr_err("WWN value for struct se_device does not fit" |
c66ac9db8 [SCSI] target: Ad... |
1998 1999 |
" into path buffer "); |
e3d6f909e target: Core clea... |
2000 |
return -EMSGSIZE; |
c66ac9db8 [SCSI] target: Ad... |
2001 2002 2003 2004 |
} snprintf(path, 512, "/var/target/pr/aptpl_%s", &wwn->unit_serial[0]); file = filp_open(path, flags, 0600); |
0e9b10a90 target: writev() ... |
2005 |
if (IS_ERR(file)) { |
6708bb27b target: Follow up... |
2006 |
pr_err("filp_open(%s) for APTPL metadata" |
c66ac9db8 [SCSI] target: Ad... |
2007 2008 |
" failed ", path); |
0e9b10a90 target: writev() ... |
2009 |
return PTR_ERR(file); |
c66ac9db8 [SCSI] target: Ad... |
2010 |
} |
6708bb27b target: Follow up... |
2011 |
if (!pr_aptpl_buf_len) |
0e9b10a90 target: writev() ... |
2012 |
pr_aptpl_buf_len = (strlen(&buf[0]) + 1); /* Add extra for NULL */ |
c66ac9db8 [SCSI] target: Ad... |
2013 |
|
0e9b10a90 target: writev() ... |
2014 |
ret = kernel_write(file, buf, pr_aptpl_buf_len, 0); |
c66ac9db8 [SCSI] target: Ad... |
2015 |
|
0e9b10a90 target: writev() ... |
2016 |
if (ret < 0) |
6708bb27b target: Follow up... |
2017 2018 |
pr_debug("Error writing APTPL metadata file: %s ", path); |
0e9b10a90 target: writev() ... |
2019 |
fput(file); |
c66ac9db8 [SCSI] target: Ad... |
2020 |
|
0e9b10a90 target: writev() ... |
2021 |
return ret ? -EIO : 0; |
c66ac9db8 [SCSI] target: Ad... |
2022 |
} |
de103c93a target: pass sens... |
2023 2024 2025 |
static int core_scsi3_update_and_write_aptpl(struct se_device *dev, unsigned char *in_buf, u32 in_pr_aptpl_buf_len) |
c66ac9db8 [SCSI] target: Ad... |
2026 2027 2028 |
{ unsigned char null_buf[64], *buf; u32 pr_aptpl_buf_len; |
de103c93a target: pass sens... |
2029 2030 |
int clear_aptpl_metadata = 0; int ret; |
c66ac9db8 [SCSI] target: Ad... |
2031 2032 2033 |
/* * Can be called with a NULL pointer from PROUT service action CLEAR */ |
6708bb27b target: Follow up... |
2034 |
if (!in_buf) { |
c66ac9db8 [SCSI] target: Ad... |
2035 2036 2037 2038 2039 2040 2041 2042 2043 2044 2045 2046 2047 2048 2049 2050 |
memset(null_buf, 0, 64); buf = &null_buf[0]; /* * This will clear the APTPL metadata to: * "No Registrations or Reservations" status */ pr_aptpl_buf_len = 64; clear_aptpl_metadata = 1; } else { buf = in_buf; pr_aptpl_buf_len = in_pr_aptpl_buf_len; } ret = core_scsi3_update_aptpl_buf(dev, buf, pr_aptpl_buf_len, clear_aptpl_metadata); if (ret != 0) |
e3d6f909e target: Core clea... |
2051 |
return ret; |
de103c93a target: pass sens... |
2052 |
|
c66ac9db8 [SCSI] target: Ad... |
2053 2054 2055 2056 |
/* * __core_scsi3_write_aptpl_to_file() will call strlen() * on the passed buf to determine pr_aptpl_buf_len. */ |
de103c93a target: pass sens... |
2057 |
return __core_scsi3_write_aptpl_to_file(dev, buf, 0); |
c66ac9db8 [SCSI] target: Ad... |
2058 |
} |
de103c93a target: pass sens... |
2059 2060 2061 |
static sense_reason_t core_scsi3_emulate_pro_register(struct se_cmd *cmd, u64 res_key, u64 sa_res_key, int aptpl, int all_tg_pt, int spec_i_pt, int ignore_key) |
c66ac9db8 [SCSI] target: Ad... |
2062 |
{ |
e3d6f909e target: Core clea... |
2063 |
struct se_session *se_sess = cmd->se_sess; |
5951146de target: More core... |
2064 |
struct se_device *dev = cmd->se_dev; |
c66ac9db8 [SCSI] target: Ad... |
2065 |
struct se_dev_entry *se_deve; |
e3d6f909e target: Core clea... |
2066 |
struct se_lun *se_lun = cmd->se_lun; |
c66ac9db8 [SCSI] target: Ad... |
2067 2068 |
struct se_portal_group *se_tpg; struct t10_pr_registration *pr_reg, *pr_reg_p, *pr_reg_tmp, *pr_reg_e; |
0fd97ccf4 target: kill stru... |
2069 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
c66ac9db8 [SCSI] target: Ad... |
2070 2071 2072 |
/* Used for APTPL metadata w/ UNREGISTER */ unsigned char *pr_aptpl_buf = NULL; unsigned char isid_buf[PR_REG_ISID_LEN], *isid_ptr = NULL; |
a0d50f62c target: Use TCM_N... |
2073 |
sense_reason_t ret = TCM_NO_SENSE; |
de103c93a target: pass sens... |
2074 |
int pr_holder = 0, type; |
c66ac9db8 [SCSI] target: Ad... |
2075 |
|
6708bb27b target: Follow up... |
2076 2077 2078 |
if (!se_sess || !se_lun) { pr_err("SPC-3 PR: se_sess || struct se_lun is NULL! "); |
de103c93a target: pass sens... |
2079 |
return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
2080 2081 |
} se_tpg = se_sess->se_tpg; |
f2083241f target: Use array... |
2082 |
se_deve = se_sess->se_node_acl->device_list[cmd->orig_fe_lun]; |
c66ac9db8 [SCSI] target: Ad... |
2083 |
|
e3d6f909e target: Core clea... |
2084 |
if (se_tpg->se_tpg_tfo->sess_get_initiator_sid) { |
c66ac9db8 [SCSI] target: Ad... |
2085 |
memset(&isid_buf[0], 0, PR_REG_ISID_LEN); |
e3d6f909e target: Core clea... |
2086 |
se_tpg->se_tpg_tfo->sess_get_initiator_sid(se_sess, &isid_buf[0], |
c66ac9db8 [SCSI] target: Ad... |
2087 2088 2089 2090 2091 2092 2093 |
PR_REG_ISID_LEN); isid_ptr = &isid_buf[0]; } /* * Follow logic from spc4r17 Section 5.7.7, Register Behaviors Table 47 */ pr_reg_e = core_scsi3_locate_pr_reg(dev, se_sess->se_node_acl, se_sess); |
6708bb27b target: Follow up... |
2094 |
if (!pr_reg_e) { |
c66ac9db8 [SCSI] target: Ad... |
2095 |
if (res_key) { |
6708bb27b target: Follow up... |
2096 |
pr_warn("SPC-3 PR: Reservation Key non-zero" |
c66ac9db8 [SCSI] target: Ad... |
2097 2098 |
" for SA REGISTER, returning CONFLICT "); |
de103c93a target: pass sens... |
2099 |
return TCM_RESERVATION_CONFLICT; |
c66ac9db8 [SCSI] target: Ad... |
2100 2101 2102 2103 |
} /* * Do nothing but return GOOD status. */ |
6708bb27b target: Follow up... |
2104 |
if (!sa_res_key) |
03e98c9eb target: Address l... |
2105 |
return 0; |
c66ac9db8 [SCSI] target: Ad... |
2106 |
|
6708bb27b target: Follow up... |
2107 |
if (!spec_i_pt) { |
c66ac9db8 [SCSI] target: Ad... |
2108 2109 2110 2111 2112 |
/* * Perform the Service Action REGISTER on the Initiator * Port Endpoint that the PRO was received from on the * Logical Unit of the SCSI device server. */ |
de103c93a target: pass sens... |
2113 |
if (core_scsi3_alloc_registration(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
2114 2115 |
se_sess->se_node_acl, se_deve, isid_ptr, sa_res_key, all_tg_pt, aptpl, |
de103c93a target: pass sens... |
2116 |
ignore_key, 0)) { |
6708bb27b target: Follow up... |
2117 |
pr_err("Unable to allocate" |
c66ac9db8 [SCSI] target: Ad... |
2118 2119 |
" struct t10_pr_registration "); |
de103c93a target: pass sens... |
2120 |
return TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
2121 2122 2123 2124 2125 2126 2127 2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138 |
} } else { /* * Register both the Initiator port that received * PROUT SA REGISTER + SPEC_I_PT=1 and extract SCSI * TransportID from Parameter list and loop through * fabric dependent parameter list while calling * logic from of core_scsi3_alloc_registration() for * each TransportID provided SCSI Initiator Port/Device */ ret = core_scsi3_decode_spec_i_port(cmd, se_tpg, isid_ptr, sa_res_key, all_tg_pt, aptpl); if (ret != 0) return ret; } /* * Nothing left to do for the APTPL=0 case. */ |
6708bb27b target: Follow up... |
2139 |
if (!aptpl) { |
c66ac9db8 [SCSI] target: Ad... |
2140 |
pr_tmpl->pr_aptpl_active = 0; |
5951146de target: More core... |
2141 |
core_scsi3_update_and_write_aptpl(cmd->se_dev, NULL, 0); |
6708bb27b target: Follow up... |
2142 |
pr_debug("SPC-3 PR: Set APTPL Bit Deactivated for" |
c66ac9db8 [SCSI] target: Ad... |
2143 2144 2145 2146 2147 2148 2149 2150 2151 |
" REGISTER "); return 0; } /* * Locate the newly allocated local I_T Nexus *pr_reg, and * update the APTPL metadata information using its * preallocated *pr_reg->pr_aptpl_buf. */ |
5951146de target: More core... |
2152 |
pr_reg = core_scsi3_locate_pr_reg(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
2153 |
se_sess->se_node_acl, se_sess); |
de103c93a target: pass sens... |
2154 |
if (core_scsi3_update_and_write_aptpl(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
2155 |
&pr_reg->pr_aptpl_buf[0], |
de103c93a target: pass sens... |
2156 |
pr_tmpl->pr_aptpl_buf_len)) { |
c66ac9db8 [SCSI] target: Ad... |
2157 |
pr_tmpl->pr_aptpl_active = 1; |
6708bb27b target: Follow up... |
2158 2159 |
pr_debug("SPC-3 PR: Set APTPL Bit Activated for REGISTER "); |
c66ac9db8 [SCSI] target: Ad... |
2160 |
} |
de103c93a target: pass sens... |
2161 2162 2163 2164 2165 2166 2167 2168 2169 2170 2171 2172 2173 2174 2175 2176 2177 2178 2179 |
goto out_put_pr_reg; } /* * Locate the existing *pr_reg via struct se_node_acl pointers */ pr_reg = pr_reg_e; type = pr_reg->pr_res_type; if (!ignore_key) { if (res_key != pr_reg->pr_res_key) { pr_err("SPC-3 PR REGISTER: Received" " res_key: 0x%016Lx does not match" " existing SA REGISTER res_key:" " 0x%016Lx ", res_key, pr_reg->pr_res_key); ret = TCM_RESERVATION_CONFLICT; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2180 |
} |
de103c93a target: pass sens... |
2181 2182 2183 2184 2185 2186 2187 2188 2189 2190 2191 2192 2193 2194 2195 2196 2197 2198 2199 2200 2201 2202 2203 2204 2205 2206 2207 2208 2209 2210 2211 2212 2213 2214 2215 |
} if (spec_i_pt) { pr_err("SPC-3 PR UNREGISTER: SPEC_I_PT" " set while sa_res_key=0 "); ret = TCM_INVALID_PARAMETER_LIST; goto out_put_pr_reg; } /* * An existing ALL_TG_PT=1 registration being released * must also set ALL_TG_PT=1 in the incoming PROUT. */ if (pr_reg->pr_reg_all_tg_pt && !(all_tg_pt)) { pr_err("SPC-3 PR UNREGISTER: ALL_TG_PT=1" " registration exists, but ALL_TG_PT=1 bit not" " present in received PROUT "); ret = TCM_INVALID_CDB_FIELD; goto out_put_pr_reg; } /* * Allocate APTPL metadata buffer used for UNREGISTER ops */ if (aptpl) { pr_aptpl_buf = kzalloc(pr_tmpl->pr_aptpl_buf_len, GFP_KERNEL); if (!pr_aptpl_buf) { pr_err("Unable to allocate" " pr_aptpl_buf "); ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2216 |
} |
de103c93a target: pass sens... |
2217 2218 2219 2220 2221 2222 2223 2224 2225 2226 2227 2228 2229 2230 |
} /* * sa_res_key=0 Unregister Reservation Key for registered I_T * Nexus sa_res_key=1 Change Reservation Key for registered I_T * Nexus. */ if (!sa_res_key) { pr_holder = core_scsi3_check_implict_release( cmd->se_dev, pr_reg); if (pr_holder < 0) { kfree(pr_aptpl_buf); ret = TCM_RESERVATION_CONFLICT; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2231 |
} |
de103c93a target: pass sens... |
2232 2233 |
spin_lock(&pr_tmpl->registration_lock); |
c66ac9db8 [SCSI] target: Ad... |
2234 |
/* |
de103c93a target: pass sens... |
2235 2236 |
* Release all ALL_TG_PT=1 for the matching SCSI Initiator Port * and matching pr_res_key. |
c66ac9db8 [SCSI] target: Ad... |
2237 |
*/ |
de103c93a target: pass sens... |
2238 2239 2240 2241 2242 2243 2244 2245 2246 2247 2248 2249 2250 2251 2252 2253 2254 |
if (pr_reg->pr_reg_all_tg_pt) { list_for_each_entry_safe(pr_reg_p, pr_reg_tmp, &pr_tmpl->registration_list, pr_reg_list) { if (!pr_reg_p->pr_reg_all_tg_pt) continue; if (pr_reg_p->pr_res_key != res_key) continue; if (pr_reg == pr_reg_p) continue; if (strcmp(pr_reg->pr_reg_nacl->initiatorname, pr_reg_p->pr_reg_nacl->initiatorname)) continue; __core_scsi3_free_registration(dev, pr_reg_p, NULL, 0); |
c66ac9db8 [SCSI] target: Ad... |
2255 2256 |
} } |
de103c93a target: pass sens... |
2257 |
|
c66ac9db8 [SCSI] target: Ad... |
2258 |
/* |
de103c93a target: pass sens... |
2259 |
* Release the calling I_T Nexus registration now.. |
c66ac9db8 [SCSI] target: Ad... |
2260 |
*/ |
de103c93a target: pass sens... |
2261 |
__core_scsi3_free_registration(cmd->se_dev, pr_reg, NULL, 1); |
c66ac9db8 [SCSI] target: Ad... |
2262 |
|
de103c93a target: pass sens... |
2263 2264 2265 2266 2267 2268 2269 2270 2271 2272 2273 2274 2275 2276 2277 2278 2279 2280 2281 2282 2283 2284 2285 |
/* * From spc4r17, section 5.7.11.3 Unregistering * * If the persistent reservation is a registrants only * type, the device server shall establish a unit * attention condition for the initiator port associated * with every registered I_T nexus except for the I_T * nexus on which the PERSISTENT RESERVE OUT command was * received, with the additional sense code set to * RESERVATIONS RELEASED. */ if (pr_holder && (type == PR_TYPE_WRITE_EXCLUSIVE_REGONLY || type == PR_TYPE_EXCLUSIVE_ACCESS_REGONLY)) { list_for_each_entry(pr_reg_p, &pr_tmpl->registration_list, pr_reg_list) { core_scsi3_ua_allocate( pr_reg_p->pr_reg_nacl, pr_reg_p->pr_res_mapped_lun, 0x2A, ASCQ_2AH_RESERVATIONS_RELEASED); |
c66ac9db8 [SCSI] target: Ad... |
2286 |
} |
de103c93a target: pass sens... |
2287 2288 |
} spin_unlock(&pr_tmpl->registration_lock); |
c66ac9db8 [SCSI] target: Ad... |
2289 |
|
de103c93a target: pass sens... |
2290 2291 2292 2293 2294 2295 2296 2297 |
if (!aptpl) { pr_tmpl->pr_aptpl_active = 0; core_scsi3_update_and_write_aptpl(dev, NULL, 0); pr_debug("SPC-3 PR: Set APTPL Bit Deactivated" " for UNREGISTER "); return 0; } |
c66ac9db8 [SCSI] target: Ad... |
2298 |
|
de103c93a target: pass sens... |
2299 2300 2301 2302 2303 2304 2305 |
if (!core_scsi3_update_and_write_aptpl(dev, &pr_aptpl_buf[0], pr_tmpl->pr_aptpl_buf_len)) { pr_tmpl->pr_aptpl_active = 1; pr_debug("SPC-3 PR: Set APTPL Bit Activated" " for UNREGISTER "); } |
c66ac9db8 [SCSI] target: Ad... |
2306 |
|
de103c93a target: pass sens... |
2307 2308 |
goto out_free_aptpl_buf; } |
c66ac9db8 [SCSI] target: Ad... |
2309 |
|
de103c93a target: pass sens... |
2310 2311 2312 2313 2314 2315 2316 2317 2318 2319 2320 2321 2322 2323 |
/* * Increment PRgeneration counter for struct se_device" * upon a successful REGISTER, see spc4r17 section 6.3.2 * READ_KEYS service action. */ pr_reg->pr_res_generation = core_scsi3_pr_generation(cmd->se_dev); pr_reg->pr_res_key = sa_res_key; pr_debug("SPC-3 PR [%s] REGISTER%s: Changed Reservation" " Key for %s to: 0x%016Lx PRgeneration:" " 0x%08x ", cmd->se_tfo->get_fabric_name(), (ignore_key) ? "_AND_IGNORE_EXISTING_KEY" : "", pr_reg->pr_reg_nacl->initiatorname, pr_reg->pr_res_key, pr_reg->pr_res_generation); |
c66ac9db8 [SCSI] target: Ad... |
2324 |
|
de103c93a target: pass sens... |
2325 2326 2327 2328 2329 2330 2331 2332 |
if (!aptpl) { pr_tmpl->pr_aptpl_active = 0; core_scsi3_update_and_write_aptpl(dev, NULL, 0); pr_debug("SPC-3 PR: Set APTPL Bit Deactivated" " for REGISTER "); ret = 0; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2333 |
} |
de103c93a target: pass sens... |
2334 2335 2336 2337 2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348 |
if (!core_scsi3_update_and_write_aptpl(dev, &pr_aptpl_buf[0], pr_tmpl->pr_aptpl_buf_len)) { pr_tmpl->pr_aptpl_active = 1; pr_debug("SPC-3 PR: Set APTPL Bit Activated" " for REGISTER "); } out_free_aptpl_buf: kfree(pr_aptpl_buf); ret = 0; out_put_pr_reg: core_scsi3_put_pr_reg(pr_reg); return ret; |
c66ac9db8 [SCSI] target: Ad... |
2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361 2362 2363 2364 2365 2366 2367 2368 2369 2370 2371 |
} unsigned char *core_scsi3_pr_dump_type(int type) { switch (type) { case PR_TYPE_WRITE_EXCLUSIVE: return "Write Exclusive Access"; case PR_TYPE_EXCLUSIVE_ACCESS: return "Exclusive Access"; case PR_TYPE_WRITE_EXCLUSIVE_REGONLY: return "Write Exclusive Access, Registrants Only"; case PR_TYPE_EXCLUSIVE_ACCESS_REGONLY: return "Exclusive Access, Registrants Only"; case PR_TYPE_WRITE_EXCLUSIVE_ALLREG: return "Write Exclusive Access, All Registrants"; case PR_TYPE_EXCLUSIVE_ACCESS_ALLREG: return "Exclusive Access, All Registrants"; default: break; } return "Unknown SPC-3 PR Type"; } |
de103c93a target: pass sens... |
2372 2373 |
static sense_reason_t core_scsi3_pro_reserve(struct se_cmd *cmd, int type, int scope, u64 res_key) |
c66ac9db8 [SCSI] target: Ad... |
2374 |
{ |
de103c93a target: pass sens... |
2375 |
struct se_device *dev = cmd->se_dev; |
e3d6f909e target: Core clea... |
2376 |
struct se_session *se_sess = cmd->se_sess; |
e3d6f909e target: Core clea... |
2377 |
struct se_lun *se_lun = cmd->se_lun; |
c66ac9db8 [SCSI] target: Ad... |
2378 |
struct t10_pr_registration *pr_reg, *pr_res_holder; |
0fd97ccf4 target: kill stru... |
2379 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
c66ac9db8 [SCSI] target: Ad... |
2380 |
char i_buf[PR_REG_ISID_ID_LEN]; |
de103c93a target: pass sens... |
2381 2382 |
sense_reason_t ret; int prf_isid; |
c66ac9db8 [SCSI] target: Ad... |
2383 2384 |
memset(i_buf, 0, PR_REG_ISID_ID_LEN); |
6708bb27b target: Follow up... |
2385 2386 2387 |
if (!se_sess || !se_lun) { pr_err("SPC-3 PR: se_sess || struct se_lun is NULL! "); |
de103c93a target: pass sens... |
2388 |
return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
2389 |
} |
c66ac9db8 [SCSI] target: Ad... |
2390 2391 2392 |
/* * Locate the existing *pr_reg via struct se_node_acl pointers */ |
5951146de target: More core... |
2393 |
pr_reg = core_scsi3_locate_pr_reg(cmd->se_dev, se_sess->se_node_acl, |
c66ac9db8 [SCSI] target: Ad... |
2394 |
se_sess); |
6708bb27b target: Follow up... |
2395 2396 |
if (!pr_reg) { pr_err("SPC-3 PR: Unable to locate" |
c66ac9db8 [SCSI] target: Ad... |
2397 2398 |
" PR_REGISTERED *pr_reg for RESERVE "); |
de103c93a target: pass sens... |
2399 |
return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
2400 2401 2402 2403 2404 2405 2406 2407 2408 2409 2410 |
} /* * From spc4r17 Section 5.7.9: Reserving: * * An application client creates a persistent reservation by issuing * a PERSISTENT RESERVE OUT command with RESERVE service action through * a registered I_T nexus with the following parameters: * a) RESERVATION KEY set to the value of the reservation key that is * registered with the logical unit for the I_T nexus; and */ if (res_key != pr_reg->pr_res_key) { |
6708bb27b target: Follow up... |
2411 |
pr_err("SPC-3 PR RESERVE: Received res_key: 0x%016Lx" |
c66ac9db8 [SCSI] target: Ad... |
2412 2413 2414 |
" does not match existing SA REGISTER res_key:" " 0x%016Lx ", res_key, pr_reg->pr_res_key); |
de103c93a target: pass sens... |
2415 2416 |
ret = TCM_RESERVATION_CONFLICT; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428 |
} /* * From spc4r17 Section 5.7.9: Reserving: * * From above: * b) TYPE field and SCOPE field set to the persistent reservation * being created. * * Only one persistent reservation is allowed at a time per logical unit * and that persistent reservation has a scope of LU_SCOPE. */ if (scope != PR_SCOPE_LU_SCOPE) { |
6708bb27b target: Follow up... |
2429 2430 |
pr_err("SPC-3 PR: Illegal SCOPE: 0x%02x ", scope); |
de103c93a target: pass sens... |
2431 2432 |
ret = TCM_INVALID_PARAMETER_LIST; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2433 2434 2435 2436 2437 2438 2439 2440 |
} /* * See if we have an existing PR reservation holder pointer at * struct se_device->dev_pr_res_holder in the form struct t10_pr_registration * *pr_res_holder. */ spin_lock(&dev->dev_reservation_lock); pr_res_holder = dev->dev_pr_res_holder; |
ee1b1b9c3 target: Remove un... |
2441 |
if (pr_res_holder) { |
c66ac9db8 [SCSI] target: Ad... |
2442 2443 2444 2445 2446 2447 2448 2449 2450 2451 2452 2453 |
/* * From spc4r17 Section 5.7.9: Reserving: * * If the device server receives a PERSISTENT RESERVE OUT * command from an I_T nexus other than a persistent reservation * holder (see 5.7.10) that attempts to create a persistent * reservation when a persistent reservation already exists for * the logical unit, then the command shall be completed with * RESERVATION CONFLICT status. */ if (pr_res_holder != pr_reg) { struct se_node_acl *pr_res_nacl = pr_res_holder->pr_reg_nacl; |
6708bb27b target: Follow up... |
2454 |
pr_err("SPC-3 PR: Attempted RESERVE from" |
c66ac9db8 [SCSI] target: Ad... |
2455 2456 2457 |
" [%s]: %s while reservation already held by" " [%s]: %s, returning RESERVATION_CONFLICT ", |
e3d6f909e target: Core clea... |
2458 |
cmd->se_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
2459 |
se_sess->se_node_acl->initiatorname, |
e3d6f909e target: Core clea... |
2460 |
pr_res_nacl->se_tpg->se_tpg_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
2461 2462 2463 |
pr_res_holder->pr_reg_nacl->initiatorname); spin_unlock(&dev->dev_reservation_lock); |
de103c93a target: pass sens... |
2464 2465 |
ret = TCM_RESERVATION_CONFLICT; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2466 2467 2468 2469 2470 2471 2472 2473 2474 2475 2476 |
} /* * From spc4r17 Section 5.7.9: Reserving: * * If a persistent reservation holder attempts to modify the * type or scope of an existing persistent reservation, the * command shall be completed with RESERVATION CONFLICT status. */ if ((pr_res_holder->pr_res_type != type) || (pr_res_holder->pr_res_scope != scope)) { struct se_node_acl *pr_res_nacl = pr_res_holder->pr_reg_nacl; |
6708bb27b target: Follow up... |
2477 |
pr_err("SPC-3 PR: Attempted RESERVE from" |
c66ac9db8 [SCSI] target: Ad... |
2478 2479 2480 2481 |
" [%s]: %s trying to change TYPE and/or SCOPE," " while reservation already held by [%s]: %s," " returning RESERVATION_CONFLICT ", |
e3d6f909e target: Core clea... |
2482 |
cmd->se_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
2483 |
se_sess->se_node_acl->initiatorname, |
e3d6f909e target: Core clea... |
2484 |
pr_res_nacl->se_tpg->se_tpg_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
2485 2486 2487 |
pr_res_holder->pr_reg_nacl->initiatorname); spin_unlock(&dev->dev_reservation_lock); |
de103c93a target: pass sens... |
2488 2489 |
ret = TCM_RESERVATION_CONFLICT; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2490 2491 2492 2493 2494 2495 2496 2497 2498 2499 2500 2501 |
} /* * From spc4r17 Section 5.7.9: Reserving: * * If the device server receives a PERSISTENT RESERVE OUT * command with RESERVE service action where the TYPE field and * the SCOPE field contain the same values as the existing type * and scope from a persistent reservation holder, it shall not * make any change to the existing persistent reservation and * shall completethe command with GOOD status. */ spin_unlock(&dev->dev_reservation_lock); |
de103c93a target: pass sens... |
2502 2503 |
ret = 0; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2504 2505 2506 2507 2508 2509 2510 2511 2512 2513 2514 |
} /* * Otherwise, our *pr_reg becomes the PR reservation holder for said * TYPE/SCOPE. Also set the received scope and type in *pr_reg. */ pr_reg->pr_res_scope = scope; pr_reg->pr_res_type = type; pr_reg->pr_res_holder = 1; dev->dev_pr_res_holder = pr_reg; prf_isid = core_pr_dump_initiator_port(pr_reg, &i_buf[0], PR_REG_ISID_ID_LEN); |
6708bb27b target: Follow up... |
2515 |
pr_debug("SPC-3 PR [%s] Service Action: RESERVE created new" |
c66ac9db8 [SCSI] target: Ad... |
2516 2517 |
" reservation holder TYPE: %s ALL_TG_PT: %d ", |
e3d6f909e target: Core clea... |
2518 |
cmd->se_tfo->get_fabric_name(), core_scsi3_pr_dump_type(type), |
c66ac9db8 [SCSI] target: Ad... |
2519 |
(pr_reg->pr_reg_all_tg_pt) ? 1 : 0); |
6708bb27b target: Follow up... |
2520 2521 |
pr_debug("SPC-3 PR [%s] RESERVE Node: %s%s ", |
e3d6f909e target: Core clea... |
2522 |
cmd->se_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
2523 2524 2525 2526 2527 |
se_sess->se_node_acl->initiatorname, (prf_isid) ? &i_buf[0] : ""); spin_unlock(&dev->dev_reservation_lock); if (pr_tmpl->pr_aptpl_active) { |
de103c93a target: pass sens... |
2528 |
if (!core_scsi3_update_and_write_aptpl(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
2529 |
&pr_reg->pr_aptpl_buf[0], |
de103c93a target: pass sens... |
2530 |
pr_tmpl->pr_aptpl_buf_len)) { |
6708bb27b target: Follow up... |
2531 |
pr_debug("SPC-3 PR: Updated APTPL metadata" |
c66ac9db8 [SCSI] target: Ad... |
2532 2533 |
" for RESERVE "); |
de103c93a target: pass sens... |
2534 |
} |
c66ac9db8 [SCSI] target: Ad... |
2535 |
} |
de103c93a target: pass sens... |
2536 2537 |
ret = 0; out_put_pr_reg: |
c66ac9db8 [SCSI] target: Ad... |
2538 |
core_scsi3_put_pr_reg(pr_reg); |
de103c93a target: pass sens... |
2539 |
return ret; |
c66ac9db8 [SCSI] target: Ad... |
2540 |
} |
de103c93a target: pass sens... |
2541 2542 2543 |
static sense_reason_t core_scsi3_emulate_pro_reserve(struct se_cmd *cmd, int type, int scope, u64 res_key) |
c66ac9db8 [SCSI] target: Ad... |
2544 |
{ |
c66ac9db8 [SCSI] target: Ad... |
2545 2546 2547 2548 2549 2550 2551 |
switch (type) { case PR_TYPE_WRITE_EXCLUSIVE: case PR_TYPE_EXCLUSIVE_ACCESS: case PR_TYPE_WRITE_EXCLUSIVE_REGONLY: case PR_TYPE_EXCLUSIVE_ACCESS_REGONLY: case PR_TYPE_WRITE_EXCLUSIVE_ALLREG: case PR_TYPE_EXCLUSIVE_ACCESS_ALLREG: |
de103c93a target: pass sens... |
2552 |
return core_scsi3_pro_reserve(cmd, type, scope, res_key); |
c66ac9db8 [SCSI] target: Ad... |
2553 |
default: |
6708bb27b target: Follow up... |
2554 |
pr_err("SPC-3 PR: Unknown Service Action RESERVE Type:" |
c66ac9db8 [SCSI] target: Ad... |
2555 2556 |
" 0x%02x ", type); |
de103c93a target: pass sens... |
2557 |
return TCM_INVALID_CDB_FIELD; |
c66ac9db8 [SCSI] target: Ad... |
2558 |
} |
c66ac9db8 [SCSI] target: Ad... |
2559 2560 2561 2562 2563 2564 2565 2566 2567 2568 2569 2570 2571 2572 2573 2574 2575 2576 2577 2578 2579 2580 |
} /* * Called with struct se_device->dev_reservation_lock held. */ static void __core_scsi3_complete_pro_release( struct se_device *dev, struct se_node_acl *se_nacl, struct t10_pr_registration *pr_reg, int explict) { struct target_core_fabric_ops *tfo = se_nacl->se_tpg->se_tpg_tfo; char i_buf[PR_REG_ISID_ID_LEN]; int prf_isid; memset(i_buf, 0, PR_REG_ISID_ID_LEN); prf_isid = core_pr_dump_initiator_port(pr_reg, &i_buf[0], PR_REG_ISID_ID_LEN); /* * Go ahead and release the current PR reservation holder. */ dev->dev_pr_res_holder = NULL; |
6708bb27b target: Follow up... |
2581 |
pr_debug("SPC-3 PR [%s] Service Action: %s RELEASE cleared" |
c66ac9db8 [SCSI] target: Ad... |
2582 2583 2584 2585 2586 |
" reservation holder TYPE: %s ALL_TG_PT: %d ", tfo->get_fabric_name(), (explict) ? "explict" : "implict", core_scsi3_pr_dump_type(pr_reg->pr_res_type), (pr_reg->pr_reg_all_tg_pt) ? 1 : 0); |
6708bb27b target: Follow up... |
2587 2588 |
pr_debug("SPC-3 PR [%s] RELEASE Node: %s%s ", |
c66ac9db8 [SCSI] target: Ad... |
2589 2590 2591 2592 2593 2594 2595 |
tfo->get_fabric_name(), se_nacl->initiatorname, (prf_isid) ? &i_buf[0] : ""); /* * Clear TYPE and SCOPE for the next PROUT Service Action: RESERVE */ pr_reg->pr_res_holder = pr_reg->pr_res_type = pr_reg->pr_res_scope = 0; } |
de103c93a target: pass sens... |
2596 2597 2598 |
static sense_reason_t core_scsi3_emulate_pro_release(struct se_cmd *cmd, int type, int scope, u64 res_key) |
c66ac9db8 [SCSI] target: Ad... |
2599 2600 |
{ struct se_device *dev = cmd->se_dev; |
e3d6f909e target: Core clea... |
2601 2602 |
struct se_session *se_sess = cmd->se_sess; struct se_lun *se_lun = cmd->se_lun; |
c66ac9db8 [SCSI] target: Ad... |
2603 |
struct t10_pr_registration *pr_reg, *pr_reg_p, *pr_res_holder; |
0fd97ccf4 target: kill stru... |
2604 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
de103c93a target: pass sens... |
2605 2606 |
int all_reg = 0; sense_reason_t ret = 0; |
c66ac9db8 [SCSI] target: Ad... |
2607 |
|
6708bb27b target: Follow up... |
2608 2609 2610 |
if (!se_sess || !se_lun) { pr_err("SPC-3 PR: se_sess || struct se_lun is NULL! "); |
de103c93a target: pass sens... |
2611 |
return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
2612 2613 2614 2615 2616 |
} /* * Locate the existing *pr_reg via struct se_node_acl pointers */ pr_reg = core_scsi3_locate_pr_reg(dev, se_sess->se_node_acl, se_sess); |
6708bb27b target: Follow up... |
2617 2618 |
if (!pr_reg) { pr_err("SPC-3 PR: Unable to locate" |
c66ac9db8 [SCSI] target: Ad... |
2619 2620 |
" PR_REGISTERED *pr_reg for RELEASE "); |
de103c93a target: pass sens... |
2621 |
return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
2622 2623 2624 2625 2626 2627 2628 2629 2630 2631 2632 2633 2634 2635 2636 |
} /* * From spc4r17 Section 5.7.11.2 Releasing: * * If there is no persistent reservation or in response to a persistent * reservation release request from a registered I_T nexus that is not a * persistent reservation holder (see 5.7.10), the device server shall * do the following: * * a) Not release the persistent reservation, if any; * b) Not remove any registrations; and * c) Complete the command with GOOD status. */ spin_lock(&dev->dev_reservation_lock); pr_res_holder = dev->dev_pr_res_holder; |
6708bb27b target: Follow up... |
2637 |
if (!pr_res_holder) { |
c66ac9db8 [SCSI] target: Ad... |
2638 2639 2640 2641 |
/* * No persistent reservation, return GOOD status. */ spin_unlock(&dev->dev_reservation_lock); |
bb7a8c8eb target: Fix excep... |
2642 |
goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2643 2644 2645 2646 2647 2648 2649 2650 2651 2652 2653 2654 |
} if ((pr_res_holder->pr_res_type == PR_TYPE_WRITE_EXCLUSIVE_ALLREG) || (pr_res_holder->pr_res_type == PR_TYPE_EXCLUSIVE_ACCESS_ALLREG)) all_reg = 1; if ((all_reg == 0) && (pr_res_holder != pr_reg)) { /* * Non 'All Registrants' PR Type cases.. * Release request from a registered I_T nexus that is not a * persistent reservation holder. return GOOD status. */ spin_unlock(&dev->dev_reservation_lock); |
de103c93a target: pass sens... |
2655 |
goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2656 |
} |
de103c93a target: pass sens... |
2657 |
|
c66ac9db8 [SCSI] target: Ad... |
2658 2659 2660 2661 2662 2663 2664 2665 2666 2667 2668 2669 2670 2671 2672 |
/* * From spc4r17 Section 5.7.11.2 Releasing: * * Only the persistent reservation holder (see 5.7.10) is allowed to * release a persistent reservation. * * An application client releases the persistent reservation by issuing * a PERSISTENT RESERVE OUT command with RELEASE service action through * an I_T nexus that is a persistent reservation holder with the * following parameters: * * a) RESERVATION KEY field set to the value of the reservation key * that is registered with the logical unit for the I_T nexus; */ if (res_key != pr_reg->pr_res_key) { |
6708bb27b target: Follow up... |
2673 |
pr_err("SPC-3 PR RELEASE: Received res_key: 0x%016Lx" |
c66ac9db8 [SCSI] target: Ad... |
2674 2675 2676 2677 |
" does not match existing SA REGISTER res_key:" " 0x%016Lx ", res_key, pr_reg->pr_res_key); spin_unlock(&dev->dev_reservation_lock); |
de103c93a target: pass sens... |
2678 2679 |
ret = TCM_RESERVATION_CONFLICT; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2680 2681 2682 2683 2684 2685 2686 2687 2688 2689 |
} /* * From spc4r17 Section 5.7.11.2 Releasing and above: * * b) TYPE field and SCOPE field set to match the persistent * reservation being released. */ if ((pr_res_holder->pr_res_type != type) || (pr_res_holder->pr_res_scope != scope)) { struct se_node_acl *pr_res_nacl = pr_res_holder->pr_reg_nacl; |
6708bb27b target: Follow up... |
2690 |
pr_err("SPC-3 PR RELEASE: Attempted to release" |
c66ac9db8 [SCSI] target: Ad... |
2691 2692 2693 2694 |
" reservation from [%s]: %s with different TYPE " "and/or SCOPE while reservation already held by" " [%s]: %s, returning RESERVATION_CONFLICT ", |
e3d6f909e target: Core clea... |
2695 |
cmd->se_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
2696 |
se_sess->se_node_acl->initiatorname, |
e3d6f909e target: Core clea... |
2697 |
pr_res_nacl->se_tpg->se_tpg_tfo->get_fabric_name(), |
c66ac9db8 [SCSI] target: Ad... |
2698 2699 2700 |
pr_res_holder->pr_reg_nacl->initiatorname); spin_unlock(&dev->dev_reservation_lock); |
de103c93a target: pass sens... |
2701 2702 |
ret = TCM_RESERVATION_CONFLICT; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713 2714 2715 2716 2717 2718 2719 2720 2721 2722 2723 2724 2725 2726 2727 2728 2729 2730 2731 2732 2733 2734 2735 2736 2737 2738 2739 2740 2741 2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754 |
} /* * In response to a persistent reservation release request from the * persistent reservation holder the device server shall perform a * release by doing the following as an uninterrupted series of actions: * a) Release the persistent reservation; * b) Not remove any registration(s); * c) If the released persistent reservation is a registrants only type * or all registrants type persistent reservation, * the device server shall establish a unit attention condition for * the initiator port associated with every regis- * tered I_T nexus other than I_T nexus on which the PERSISTENT * RESERVE OUT command with RELEASE service action was received, * with the additional sense code set to RESERVATIONS RELEASED; and * d) If the persistent reservation is of any other type, the device * server shall not establish a unit attention condition. */ __core_scsi3_complete_pro_release(dev, se_sess->se_node_acl, pr_reg, 1); spin_unlock(&dev->dev_reservation_lock); if ((type != PR_TYPE_WRITE_EXCLUSIVE_REGONLY) && (type != PR_TYPE_EXCLUSIVE_ACCESS_REGONLY) && (type != PR_TYPE_WRITE_EXCLUSIVE_ALLREG) && (type != PR_TYPE_EXCLUSIVE_ACCESS_ALLREG)) { /* * If no UNIT ATTENTION conditions will be established for * PR_TYPE_WRITE_EXCLUSIVE or PR_TYPE_EXCLUSIVE_ACCESS * go ahead and check for APTPL=1 update+write below */ goto write_aptpl; } spin_lock(&pr_tmpl->registration_lock); list_for_each_entry(pr_reg_p, &pr_tmpl->registration_list, pr_reg_list) { /* * Do not establish a UNIT ATTENTION condition * for the calling I_T Nexus */ if (pr_reg_p == pr_reg) continue; core_scsi3_ua_allocate(pr_reg_p->pr_reg_nacl, pr_reg_p->pr_res_mapped_lun, 0x2A, ASCQ_2AH_RESERVATIONS_RELEASED); } spin_unlock(&pr_tmpl->registration_lock); write_aptpl: if (pr_tmpl->pr_aptpl_active) { |
de103c93a target: pass sens... |
2755 2756 |
if (!core_scsi3_update_and_write_aptpl(cmd->se_dev, &pr_reg->pr_aptpl_buf[0], pr_tmpl->pr_aptpl_buf_len)) { |
6708bb27b target: Follow up... |
2757 2758 |
pr_debug("SPC-3 PR: Updated APTPL metadata for RELEASE "); |
de103c93a target: pass sens... |
2759 |
} |
c66ac9db8 [SCSI] target: Ad... |
2760 |
} |
de103c93a target: pass sens... |
2761 |
out_put_pr_reg: |
c66ac9db8 [SCSI] target: Ad... |
2762 |
core_scsi3_put_pr_reg(pr_reg); |
de103c93a target: pass sens... |
2763 |
return ret; |
c66ac9db8 [SCSI] target: Ad... |
2764 |
} |
de103c93a target: pass sens... |
2765 2766 |
static sense_reason_t core_scsi3_emulate_pro_clear(struct se_cmd *cmd, u64 res_key) |
c66ac9db8 [SCSI] target: Ad... |
2767 2768 2769 |
{ struct se_device *dev = cmd->se_dev; struct se_node_acl *pr_reg_nacl; |
e3d6f909e target: Core clea... |
2770 |
struct se_session *se_sess = cmd->se_sess; |
0fd97ccf4 target: kill stru... |
2771 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
c66ac9db8 [SCSI] target: Ad... |
2772 2773 2774 2775 2776 2777 |
struct t10_pr_registration *pr_reg, *pr_reg_tmp, *pr_reg_n, *pr_res_holder; u32 pr_res_mapped_lun = 0; int calling_it_nexus = 0; /* * Locate the existing *pr_reg via struct se_node_acl pointers */ |
5951146de target: More core... |
2778 |
pr_reg_n = core_scsi3_locate_pr_reg(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
2779 |
se_sess->se_node_acl, se_sess); |
6708bb27b target: Follow up... |
2780 2781 |
if (!pr_reg_n) { pr_err("SPC-3 PR: Unable to locate" |
c66ac9db8 [SCSI] target: Ad... |
2782 2783 |
" PR_REGISTERED *pr_reg for CLEAR "); |
de103c93a target: pass sens... |
2784 |
return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
2785 2786 2787 2788 2789 2790 2791 2792 2793 2794 2795 2796 2797 |
} /* * From spc4r17 section 5.7.11.6, Clearing: * * Any application client may release the persistent reservation and * remove all registrations from a device server by issuing a * PERSISTENT RESERVE OUT command with CLEAR service action through a * registered I_T nexus with the following parameter: * * a) RESERVATION KEY field set to the value of the reservation key * that is registered with the logical unit for the I_T nexus. */ if (res_key != pr_reg_n->pr_res_key) { |
6708bb27b target: Follow up... |
2798 |
pr_err("SPC-3 PR REGISTER: Received" |
c66ac9db8 [SCSI] target: Ad... |
2799 2800 2801 2802 2803 |
" res_key: 0x%016Lx does not match" " existing SA REGISTER res_key:" " 0x%016Lx ", res_key, pr_reg_n->pr_res_key); core_scsi3_put_pr_reg(pr_reg_n); |
de103c93a target: pass sens... |
2804 |
return TCM_RESERVATION_CONFLICT; |
c66ac9db8 [SCSI] target: Ad... |
2805 2806 2807 2808 2809 2810 2811 2812 2813 2814 2815 2816 2817 2818 2819 2820 2821 2822 2823 2824 2825 2826 2827 2828 2829 2830 2831 2832 2833 2834 2835 |
} /* * a) Release the persistent reservation, if any; */ spin_lock(&dev->dev_reservation_lock); pr_res_holder = dev->dev_pr_res_holder; if (pr_res_holder) { struct se_node_acl *pr_res_nacl = pr_res_holder->pr_reg_nacl; __core_scsi3_complete_pro_release(dev, pr_res_nacl, pr_res_holder, 0); } spin_unlock(&dev->dev_reservation_lock); /* * b) Remove all registration(s) (see spc4r17 5.7.7); */ spin_lock(&pr_tmpl->registration_lock); list_for_each_entry_safe(pr_reg, pr_reg_tmp, &pr_tmpl->registration_list, pr_reg_list) { calling_it_nexus = (pr_reg_n == pr_reg) ? 1 : 0; pr_reg_nacl = pr_reg->pr_reg_nacl; pr_res_mapped_lun = pr_reg->pr_res_mapped_lun; __core_scsi3_free_registration(dev, pr_reg, NULL, calling_it_nexus); /* * e) Establish a unit attention condition for the initiator * port associated with every registered I_T nexus other * than the I_T nexus on which the PERSISTENT RESERVE OUT * command with CLEAR service action was received, with the * additional sense code set to RESERVATIONS PREEMPTED. */ |
6708bb27b target: Follow up... |
2836 |
if (!calling_it_nexus) |
c66ac9db8 [SCSI] target: Ad... |
2837 2838 2839 2840 |
core_scsi3_ua_allocate(pr_reg_nacl, pr_res_mapped_lun, 0x2A, ASCQ_2AH_RESERVATIONS_PREEMPTED); } spin_unlock(&pr_tmpl->registration_lock); |
6708bb27b target: Follow up... |
2841 2842 |
pr_debug("SPC-3 PR [%s] Service Action: CLEAR complete ", |
e3d6f909e target: Core clea... |
2843 |
cmd->se_tfo->get_fabric_name()); |
c66ac9db8 [SCSI] target: Ad... |
2844 2845 |
if (pr_tmpl->pr_aptpl_active) { |
5951146de target: More core... |
2846 |
core_scsi3_update_and_write_aptpl(cmd->se_dev, NULL, 0); |
6708bb27b target: Follow up... |
2847 |
pr_debug("SPC-3 PR: Updated APTPL metadata" |
c66ac9db8 [SCSI] target: Ad... |
2848 2849 2850 2851 2852 2853 2854 2855 2856 2857 2858 2859 2860 2861 2862 2863 2864 2865 2866 2867 2868 2869 2870 2871 2872 2873 2874 2875 2876 2877 2878 2879 2880 2881 2882 2883 2884 2885 |
" for CLEAR "); } core_scsi3_pr_generation(dev); return 0; } /* * Called with struct se_device->dev_reservation_lock held. */ static void __core_scsi3_complete_pro_preempt( struct se_device *dev, struct t10_pr_registration *pr_reg, struct list_head *preempt_and_abort_list, int type, int scope, int abort) { struct se_node_acl *nacl = pr_reg->pr_reg_nacl; struct target_core_fabric_ops *tfo = nacl->se_tpg->se_tpg_tfo; char i_buf[PR_REG_ISID_ID_LEN]; int prf_isid; memset(i_buf, 0, PR_REG_ISID_ID_LEN); prf_isid = core_pr_dump_initiator_port(pr_reg, &i_buf[0], PR_REG_ISID_ID_LEN); /* * Do an implict RELEASE of the existing reservation. */ if (dev->dev_pr_res_holder) __core_scsi3_complete_pro_release(dev, nacl, dev->dev_pr_res_holder, 0); dev->dev_pr_res_holder = pr_reg; pr_reg->pr_res_holder = 1; pr_reg->pr_res_type = type; pr_reg->pr_res_scope = scope; |
6708bb27b target: Follow up... |
2886 |
pr_debug("SPC-3 PR [%s] Service Action: PREEMPT%s created new" |
c66ac9db8 [SCSI] target: Ad... |
2887 2888 2889 2890 2891 |
" reservation holder TYPE: %s ALL_TG_PT: %d ", tfo->get_fabric_name(), (abort) ? "_AND_ABORT" : "", core_scsi3_pr_dump_type(type), (pr_reg->pr_reg_all_tg_pt) ? 1 : 0); |
6708bb27b target: Follow up... |
2892 2893 |
pr_debug("SPC-3 PR [%s] PREEMPT%s from Node: %s%s ", |
c66ac9db8 [SCSI] target: Ad... |
2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908 2909 2910 2911 2912 2913 2914 2915 2916 2917 2918 |
tfo->get_fabric_name(), (abort) ? "_AND_ABORT" : "", nacl->initiatorname, (prf_isid) ? &i_buf[0] : ""); /* * For PREEMPT_AND_ABORT, add the preempting reservation's * struct t10_pr_registration to the list that will be compared * against received CDBs.. */ if (preempt_and_abort_list) list_add_tail(&pr_reg->pr_reg_abort_list, preempt_and_abort_list); } static void core_scsi3_release_preempt_and_abort( struct list_head *preempt_and_abort_list, struct t10_pr_registration *pr_reg_holder) { struct t10_pr_registration *pr_reg, *pr_reg_tmp; list_for_each_entry_safe(pr_reg, pr_reg_tmp, preempt_and_abort_list, pr_reg_abort_list) { list_del(&pr_reg->pr_reg_abort_list); if (pr_reg_holder == pr_reg) continue; if (pr_reg->pr_res_holder) { |
6708bb27b target: Follow up... |
2919 2920 |
pr_warn("pr_reg->pr_res_holder still set "); |
c66ac9db8 [SCSI] target: Ad... |
2921 2922 2923 2924 2925 2926 2927 2928 2929 |
continue; } pr_reg->pr_reg_deve = NULL; pr_reg->pr_reg_nacl = NULL; kfree(pr_reg->pr_aptpl_buf); kmem_cache_free(t10_pr_reg_cache, pr_reg); } } |
de103c93a target: pass sens... |
2930 2931 2932 |
static sense_reason_t core_scsi3_pro_preempt(struct se_cmd *cmd, int type, int scope, u64 res_key, u64 sa_res_key, int abort) |
c66ac9db8 [SCSI] target: Ad... |
2933 |
{ |
5951146de target: More core... |
2934 |
struct se_device *dev = cmd->se_dev; |
c66ac9db8 [SCSI] target: Ad... |
2935 |
struct se_node_acl *pr_reg_nacl; |
e3d6f909e target: Core clea... |
2936 |
struct se_session *se_sess = cmd->se_sess; |
d0f474e50 target: Use LIST_... |
2937 |
LIST_HEAD(preempt_and_abort_list); |
c66ac9db8 [SCSI] target: Ad... |
2938 |
struct t10_pr_registration *pr_reg, *pr_reg_tmp, *pr_reg_n, *pr_res_holder; |
0fd97ccf4 target: kill stru... |
2939 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
c66ac9db8 [SCSI] target: Ad... |
2940 2941 |
u32 pr_res_mapped_lun = 0; int all_reg = 0, calling_it_nexus = 0, released_regs = 0; |
de103c93a target: pass sens... |
2942 |
int prh_type = 0, prh_scope = 0; |
c66ac9db8 [SCSI] target: Ad... |
2943 |
|
de103c93a target: pass sens... |
2944 2945 |
if (!se_sess) return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
2946 |
|
5951146de target: More core... |
2947 |
pr_reg_n = core_scsi3_locate_pr_reg(cmd->se_dev, se_sess->se_node_acl, |
c66ac9db8 [SCSI] target: Ad... |
2948 |
se_sess); |
6708bb27b target: Follow up... |
2949 2950 |
if (!pr_reg_n) { pr_err("SPC-3 PR: Unable to locate" |
c66ac9db8 [SCSI] target: Ad... |
2951 2952 2953 |
" PR_REGISTERED *pr_reg for PREEMPT%s ", (abort) ? "_AND_ABORT" : ""); |
de103c93a target: pass sens... |
2954 |
return TCM_RESERVATION_CONFLICT; |
c66ac9db8 [SCSI] target: Ad... |
2955 2956 2957 |
} if (pr_reg_n->pr_res_key != res_key) { core_scsi3_put_pr_reg(pr_reg_n); |
de103c93a target: pass sens... |
2958 |
return TCM_RESERVATION_CONFLICT; |
c66ac9db8 [SCSI] target: Ad... |
2959 2960 |
} if (scope != PR_SCOPE_LU_SCOPE) { |
6708bb27b target: Follow up... |
2961 2962 |
pr_err("SPC-3 PR: Illegal SCOPE: 0x%02x ", scope); |
c66ac9db8 [SCSI] target: Ad... |
2963 |
core_scsi3_put_pr_reg(pr_reg_n); |
de103c93a target: pass sens... |
2964 |
return TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
2965 |
} |
c66ac9db8 [SCSI] target: Ad... |
2966 2967 2968 2969 2970 2971 2972 |
spin_lock(&dev->dev_reservation_lock); pr_res_holder = dev->dev_pr_res_holder; if (pr_res_holder && ((pr_res_holder->pr_res_type == PR_TYPE_WRITE_EXCLUSIVE_ALLREG) || (pr_res_holder->pr_res_type == PR_TYPE_EXCLUSIVE_ACCESS_ALLREG))) all_reg = 1; |
6708bb27b target: Follow up... |
2973 |
if (!all_reg && !sa_res_key) { |
c66ac9db8 [SCSI] target: Ad... |
2974 2975 |
spin_unlock(&dev->dev_reservation_lock); core_scsi3_put_pr_reg(pr_reg_n); |
de103c93a target: pass sens... |
2976 |
return TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
2977 2978 2979 2980 2981 2982 2983 2984 2985 2986 |
} /* * From spc4r17, section 5.7.11.4.4 Removing Registrations: * * If the SERVICE ACTION RESERVATION KEY field does not identify a * persistent reservation holder or there is no persistent reservation * holder (i.e., there is no persistent reservation), then the device * server shall perform a preempt by doing the following in an * uninterrupted series of actions. (See below..) */ |
6708bb27b target: Follow up... |
2987 |
if (!pr_res_holder || (pr_res_holder->pr_res_key != sa_res_key)) { |
c66ac9db8 [SCSI] target: Ad... |
2988 2989 2990 2991 2992 2993 2994 2995 2996 2997 2998 2999 3000 3001 3002 3003 3004 3005 3006 3007 3008 3009 3010 3011 3012 3013 |
/* * No existing or SA Reservation Key matching reservations.. * * PROUT SA PREEMPT with All Registrant type reservations are * allowed to be processed without a matching SA Reservation Key */ spin_lock(&pr_tmpl->registration_lock); list_for_each_entry_safe(pr_reg, pr_reg_tmp, &pr_tmpl->registration_list, pr_reg_list) { /* * Removing of registrations in non all registrants * type reservations without a matching SA reservation * key. * * a) Remove the registrations for all I_T nexuses * specified by the SERVICE ACTION RESERVATION KEY * field; * b) Ignore the contents of the SCOPE and TYPE fields; * c) Process tasks as defined in 5.7.1; and * d) Establish a unit attention condition for the * initiator port associated with every I_T nexus * that lost its registration other than the I_T * nexus on which the PERSISTENT RESERVE OUT command * was received, with the additional sense code set * to REGISTRATIONS PREEMPTED. */ |
6708bb27b target: Follow up... |
3014 |
if (!all_reg) { |
c66ac9db8 [SCSI] target: Ad... |
3015 3016 3017 3018 3019 3020 3021 3022 3023 3024 3025 3026 3027 3028 3029 3030 3031 3032 3033 3034 3035 3036 3037 3038 3039 3040 3041 3042 3043 3044 3045 3046 3047 3048 3049 3050 3051 3052 3053 |
if (pr_reg->pr_res_key != sa_res_key) continue; calling_it_nexus = (pr_reg_n == pr_reg) ? 1 : 0; pr_reg_nacl = pr_reg->pr_reg_nacl; pr_res_mapped_lun = pr_reg->pr_res_mapped_lun; __core_scsi3_free_registration(dev, pr_reg, (abort) ? &preempt_and_abort_list : NULL, calling_it_nexus); released_regs++; } else { /* * Case for any existing all registrants type * reservation, follow logic in spc4r17 section * 5.7.11.4 Preempting, Table 52 and Figure 7. * * For a ZERO SA Reservation key, release * all other registrations and do an implict * release of active persistent reservation. * * For a non-ZERO SA Reservation key, only * release the matching reservation key from * registrations. */ if ((sa_res_key) && (pr_reg->pr_res_key != sa_res_key)) continue; calling_it_nexus = (pr_reg_n == pr_reg) ? 1 : 0; if (calling_it_nexus) continue; pr_reg_nacl = pr_reg->pr_reg_nacl; pr_res_mapped_lun = pr_reg->pr_res_mapped_lun; __core_scsi3_free_registration(dev, pr_reg, (abort) ? &preempt_and_abort_list : NULL, 0); released_regs++; } |
6708bb27b target: Follow up... |
3054 |
if (!calling_it_nexus) |
c66ac9db8 [SCSI] target: Ad... |
3055 3056 |
core_scsi3_ua_allocate(pr_reg_nacl, pr_res_mapped_lun, 0x2A, |
9e08e34e3 target: Use corre... |
3057 |
ASCQ_2AH_REGISTRATIONS_PREEMPTED); |
c66ac9db8 [SCSI] target: Ad... |
3058 3059 3060 3061 3062 3063 3064 3065 3066 |
} spin_unlock(&pr_tmpl->registration_lock); /* * If a PERSISTENT RESERVE OUT with a PREEMPT service action or * a PREEMPT AND ABORT service action sets the SERVICE ACTION * RESERVATION KEY field to a value that does not match any * registered reservation key, then the device server shall * complete the command with RESERVATION CONFLICT status. */ |
6708bb27b target: Follow up... |
3067 |
if (!released_regs) { |
c66ac9db8 [SCSI] target: Ad... |
3068 3069 |
spin_unlock(&dev->dev_reservation_lock); core_scsi3_put_pr_reg(pr_reg_n); |
de103c93a target: pass sens... |
3070 |
return TCM_RESERVATION_CONFLICT; |
c66ac9db8 [SCSI] target: Ad... |
3071 3072 3073 3074 3075 3076 3077 3078 3079 3080 3081 3082 3083 3084 3085 3086 3087 3088 |
} /* * For an existing all registrants type reservation * with a zero SA rservation key, preempt the existing * reservation with the new PR type and scope. */ if (pr_res_holder && all_reg && !(sa_res_key)) { __core_scsi3_complete_pro_preempt(dev, pr_reg_n, (abort) ? &preempt_and_abort_list : NULL, type, scope, abort); if (abort) core_scsi3_release_preempt_and_abort( &preempt_and_abort_list, pr_reg_n); } spin_unlock(&dev->dev_reservation_lock); if (pr_tmpl->pr_aptpl_active) { |
de103c93a target: pass sens... |
3089 |
if (!core_scsi3_update_and_write_aptpl(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
3090 |
&pr_reg_n->pr_aptpl_buf[0], |
de103c93a target: pass sens... |
3091 |
pr_tmpl->pr_aptpl_buf_len)) { |
6708bb27b target: Follow up... |
3092 |
pr_debug("SPC-3 PR: Updated APTPL" |
c66ac9db8 [SCSI] target: Ad... |
3093 3094 3095 |
" metadata for PREEMPT%s ", (abort) ? "_AND_ABORT" : ""); |
de103c93a target: pass sens... |
3096 |
} |
c66ac9db8 [SCSI] target: Ad... |
3097 3098 3099 |
} core_scsi3_put_pr_reg(pr_reg_n); |
5951146de target: More core... |
3100 |
core_scsi3_pr_generation(cmd->se_dev); |
c66ac9db8 [SCSI] target: Ad... |
3101 3102 3103 3104 3105 3106 3107 3108 3109 3110 3111 3112 3113 3114 3115 3116 3117 3118 3119 3120 3121 3122 3123 3124 3125 3126 3127 3128 3129 3130 3131 3132 3133 3134 3135 3136 3137 3138 3139 3140 3141 3142 3143 3144 3145 3146 3147 3148 3149 3150 3151 3152 3153 3154 3155 3156 3157 3158 3159 3160 3161 3162 3163 3164 3165 3166 3167 3168 3169 |
return 0; } /* * The PREEMPTing SA reservation key matches that of the * existing persistent reservation, first, we check if * we are preempting our own reservation. * From spc4r17, section 5.7.11.4.3 Preempting * persistent reservations and registration handling * * If an all registrants persistent reservation is not * present, it is not an error for the persistent * reservation holder to preempt itself (i.e., a * PERSISTENT RESERVE OUT with a PREEMPT service action * or a PREEMPT AND ABORT service action with the * SERVICE ACTION RESERVATION KEY value equal to the * persistent reservation holder's reservation key that * is received from the persistent reservation holder). * In that case, the device server shall establish the * new persistent reservation and maintain the * registration. */ prh_type = pr_res_holder->pr_res_type; prh_scope = pr_res_holder->pr_res_scope; /* * If the SERVICE ACTION RESERVATION KEY field identifies a * persistent reservation holder (see 5.7.10), the device * server shall perform a preempt by doing the following as * an uninterrupted series of actions: * * a) Release the persistent reservation for the holder * identified by the SERVICE ACTION RESERVATION KEY field; */ if (pr_reg_n != pr_res_holder) __core_scsi3_complete_pro_release(dev, pr_res_holder->pr_reg_nacl, dev->dev_pr_res_holder, 0); /* * b) Remove the registrations for all I_T nexuses identified * by the SERVICE ACTION RESERVATION KEY field, except the * I_T nexus that is being used for the PERSISTENT RESERVE * OUT command. If an all registrants persistent reservation * is present and the SERVICE ACTION RESERVATION KEY field * is set to zero, then all registrations shall be removed * except for that of the I_T nexus that is being used for * the PERSISTENT RESERVE OUT command; */ spin_lock(&pr_tmpl->registration_lock); list_for_each_entry_safe(pr_reg, pr_reg_tmp, &pr_tmpl->registration_list, pr_reg_list) { calling_it_nexus = (pr_reg_n == pr_reg) ? 1 : 0; if (calling_it_nexus) continue; if (pr_reg->pr_res_key != sa_res_key) continue; pr_reg_nacl = pr_reg->pr_reg_nacl; pr_res_mapped_lun = pr_reg->pr_res_mapped_lun; __core_scsi3_free_registration(dev, pr_reg, (abort) ? &preempt_and_abort_list : NULL, calling_it_nexus); /* * e) Establish a unit attention condition for the initiator * port associated with every I_T nexus that lost its * persistent reservation and/or registration, with the * additional sense code set to REGISTRATIONS PREEMPTED; */ core_scsi3_ua_allocate(pr_reg_nacl, pr_res_mapped_lun, 0x2A, |
9e08e34e3 target: Use corre... |
3170 |
ASCQ_2AH_REGISTRATIONS_PREEMPTED); |
c66ac9db8 [SCSI] target: Ad... |
3171 3172 3173 3174 3175 3176 3177 3178 3179 3180 3181 3182 3183 3184 3185 3186 3187 3188 3189 3190 3191 3192 3193 3194 3195 3196 3197 3198 3199 3200 3201 3202 3203 3204 3205 3206 3207 3208 3209 3210 3211 3212 3213 3214 3215 3216 3217 3218 3219 3220 3221 3222 3223 3224 3225 |
} spin_unlock(&pr_tmpl->registration_lock); /* * c) Establish a persistent reservation for the preempting * I_T nexus using the contents of the SCOPE and TYPE fields; */ __core_scsi3_complete_pro_preempt(dev, pr_reg_n, (abort) ? &preempt_and_abort_list : NULL, type, scope, abort); /* * d) Process tasks as defined in 5.7.1; * e) See above.. * f) If the type or scope has changed, then for every I_T nexus * whose reservation key was not removed, except for the I_T * nexus on which the PERSISTENT RESERVE OUT command was * received, the device server shall establish a unit * attention condition for the initiator port associated with * that I_T nexus, with the additional sense code set to * RESERVATIONS RELEASED. If the type or scope have not * changed, then no unit attention condition(s) shall be * established for this reason. */ if ((prh_type != type) || (prh_scope != scope)) { spin_lock(&pr_tmpl->registration_lock); list_for_each_entry_safe(pr_reg, pr_reg_tmp, &pr_tmpl->registration_list, pr_reg_list) { calling_it_nexus = (pr_reg_n == pr_reg) ? 1 : 0; if (calling_it_nexus) continue; core_scsi3_ua_allocate(pr_reg->pr_reg_nacl, pr_reg->pr_res_mapped_lun, 0x2A, ASCQ_2AH_RESERVATIONS_RELEASED); } spin_unlock(&pr_tmpl->registration_lock); } spin_unlock(&dev->dev_reservation_lock); /* * Call LUN_RESET logic upon list of struct t10_pr_registration, * All received CDBs for the matching existing reservation and * registrations undergo ABORT_TASK logic. * * From there, core_scsi3_release_preempt_and_abort() will * release every registration in the list (which have already * been removed from the primary pr_reg list), except the * new persistent reservation holder, the calling Initiator Port. */ if (abort) { core_tmr_lun_reset(dev, NULL, &preempt_and_abort_list, cmd); core_scsi3_release_preempt_and_abort(&preempt_and_abort_list, pr_reg_n); } if (pr_tmpl->pr_aptpl_active) { |
de103c93a target: pass sens... |
3226 |
if (!core_scsi3_update_and_write_aptpl(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
3227 |
&pr_reg_n->pr_aptpl_buf[0], |
de103c93a target: pass sens... |
3228 |
pr_tmpl->pr_aptpl_buf_len)) { |
6708bb27b target: Follow up... |
3229 |
pr_debug("SPC-3 PR: Updated APTPL metadata for PREEMPT" |
de103c93a target: pass sens... |
3230 3231 3232 |
"%s ", abort ? "_AND_ABORT" : ""); } |
c66ac9db8 [SCSI] target: Ad... |
3233 3234 3235 |
} core_scsi3_put_pr_reg(pr_reg_n); |
5951146de target: More core... |
3236 |
core_scsi3_pr_generation(cmd->se_dev); |
c66ac9db8 [SCSI] target: Ad... |
3237 3238 |
return 0; } |
de103c93a target: pass sens... |
3239 3240 3241 |
static sense_reason_t core_scsi3_emulate_pro_preempt(struct se_cmd *cmd, int type, int scope, u64 res_key, u64 sa_res_key, int abort) |
c66ac9db8 [SCSI] target: Ad... |
3242 |
{ |
c66ac9db8 [SCSI] target: Ad... |
3243 3244 3245 3246 3247 3248 3249 |
switch (type) { case PR_TYPE_WRITE_EXCLUSIVE: case PR_TYPE_EXCLUSIVE_ACCESS: case PR_TYPE_WRITE_EXCLUSIVE_REGONLY: case PR_TYPE_EXCLUSIVE_ACCESS_REGONLY: case PR_TYPE_WRITE_EXCLUSIVE_ALLREG: case PR_TYPE_EXCLUSIVE_ACCESS_ALLREG: |
de103c93a target: pass sens... |
3250 3251 |
return core_scsi3_pro_preempt(cmd, type, scope, res_key, sa_res_key, abort); |
c66ac9db8 [SCSI] target: Ad... |
3252 |
default: |
6708bb27b target: Follow up... |
3253 |
pr_err("SPC-3 PR: Unknown Service Action PREEMPT%s" |
c66ac9db8 [SCSI] target: Ad... |
3254 3255 |
" Type: 0x%02x ", (abort) ? "_AND_ABORT" : "", type); |
de103c93a target: pass sens... |
3256 |
return TCM_INVALID_CDB_FIELD; |
c66ac9db8 [SCSI] target: Ad... |
3257 |
} |
c66ac9db8 [SCSI] target: Ad... |
3258 |
} |
de103c93a target: pass sens... |
3259 3260 3261 |
static sense_reason_t core_scsi3_emulate_pro_register_and_move(struct se_cmd *cmd, u64 res_key, u64 sa_res_key, int aptpl, int unreg) |
c66ac9db8 [SCSI] target: Ad... |
3262 |
{ |
e3d6f909e target: Core clea... |
3263 |
struct se_session *se_sess = cmd->se_sess; |
5951146de target: More core... |
3264 |
struct se_device *dev = cmd->se_dev; |
281689051 target: remove ob... |
3265 |
struct se_dev_entry *dest_se_deve = NULL; |
e3d6f909e target: Core clea... |
3266 |
struct se_lun *se_lun = cmd->se_lun; |
c66ac9db8 [SCSI] target: Ad... |
3267 3268 3269 3270 3271 |
struct se_node_acl *pr_res_nacl, *pr_reg_nacl, *dest_node_acl = NULL; struct se_port *se_port; struct se_portal_group *se_tpg, *dest_se_tpg = NULL; struct target_core_fabric_ops *dest_tf_ops = NULL, *tf_ops; struct t10_pr_registration *pr_reg, *pr_res_holder, *dest_pr_reg; |
0fd97ccf4 target: kill stru... |
3272 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
05d1c7c0d target: Make all ... |
3273 |
unsigned char *buf; |
c66ac9db8 [SCSI] target: Ad... |
3274 3275 3276 |
unsigned char *initiator_str; char *iport_ptr = NULL, dest_iport[64], i_buf[PR_REG_ISID_ID_LEN]; u32 tid_len, tmp_tid_len; |
de103c93a target: pass sens... |
3277 3278 |
int new_reg = 0, type, scope, matching_iname, prf_isid; sense_reason_t ret; |
c66ac9db8 [SCSI] target: Ad... |
3279 3280 |
unsigned short rtpi; unsigned char proto_ident; |
6708bb27b target: Follow up... |
3281 3282 3283 |
if (!se_sess || !se_lun) { pr_err("SPC-3 PR: se_sess || struct se_lun is NULL! "); |
de103c93a target: pass sens... |
3284 |
return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
3285 |
} |
de103c93a target: pass sens... |
3286 |
|
c66ac9db8 [SCSI] target: Ad... |
3287 3288 3289 |
memset(dest_iport, 0, 64); memset(i_buf, 0, PR_REG_ISID_ID_LEN); se_tpg = se_sess->se_tpg; |
e3d6f909e target: Core clea... |
3290 |
tf_ops = se_tpg->se_tpg_tfo; |
c66ac9db8 [SCSI] target: Ad... |
3291 3292 3293 3294 3295 3296 |
/* * Follow logic from spc4r17 Section 5.7.8, Table 50 -- * Register behaviors for a REGISTER AND MOVE service action * * Locate the existing *pr_reg via struct se_node_acl pointers */ |
5951146de target: More core... |
3297 |
pr_reg = core_scsi3_locate_pr_reg(cmd->se_dev, se_sess->se_node_acl, |
c66ac9db8 [SCSI] target: Ad... |
3298 |
se_sess); |
6708bb27b target: Follow up... |
3299 3300 |
if (!pr_reg) { pr_err("SPC-3 PR: Unable to locate PR_REGISTERED" |
c66ac9db8 [SCSI] target: Ad... |
3301 3302 |
" *pr_reg for REGISTER_AND_MOVE "); |
de103c93a target: pass sens... |
3303 |
return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
3304 3305 3306 3307 3308 3309 |
} /* * The provided reservation key much match the existing reservation key * provided during this initiator's I_T nexus registration. */ if (res_key != pr_reg->pr_res_key) { |
6708bb27b target: Follow up... |
3310 |
pr_warn("SPC-3 PR REGISTER_AND_MOVE: Received" |
c66ac9db8 [SCSI] target: Ad... |
3311 3312 3313 |
" res_key: 0x%016Lx does not match existing SA REGISTER" " res_key: 0x%016Lx ", res_key, pr_reg->pr_res_key); |
de103c93a target: pass sens... |
3314 3315 |
ret = TCM_RESERVATION_CONFLICT; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
3316 3317 3318 3319 |
} /* * The service active reservation key needs to be non zero */ |
6708bb27b target: Follow up... |
3320 3321 |
if (!sa_res_key) { pr_warn("SPC-3 PR REGISTER_AND_MOVE: Received zero" |
c66ac9db8 [SCSI] target: Ad... |
3322 3323 |
" sa_res_key "); |
de103c93a target: pass sens... |
3324 3325 |
ret = TCM_INVALID_PARAMETER_LIST; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
3326 |
} |
05d1c7c0d target: Make all ... |
3327 |
|
c66ac9db8 [SCSI] target: Ad... |
3328 3329 3330 3331 3332 |
/* * Determine the Relative Target Port Identifier where the reservation * will be moved to for the TransportID containing SCSI initiator WWN * information. */ |
4949314c7 target: Allow con... |
3333 |
buf = transport_kmap_data_sg(cmd); |
de103c93a target: pass sens... |
3334 3335 3336 3337 |
if (!buf) { ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; goto out_put_pr_reg; } |
c66ac9db8 [SCSI] target: Ad... |
3338 3339 3340 3341 3342 3343 |
rtpi = (buf[18] & 0xff) << 8; rtpi |= buf[19] & 0xff; tid_len = (buf[20] & 0xff) << 24; tid_len |= (buf[21] & 0xff) << 16; tid_len |= (buf[22] & 0xff) << 8; tid_len |= buf[23] & 0xff; |
4949314c7 target: Allow con... |
3344 |
transport_kunmap_data_sg(cmd); |
05d1c7c0d target: Make all ... |
3345 |
buf = NULL; |
c66ac9db8 [SCSI] target: Ad... |
3346 3347 |
if ((tid_len + 24) != cmd->data_length) { |
6708bb27b target: Follow up... |
3348 |
pr_err("SPC-3 PR: Illegal tid_len: %u + 24 byte header" |
c66ac9db8 [SCSI] target: Ad... |
3349 3350 3351 |
" does not equal CDB data_length: %u ", tid_len, cmd->data_length); |
de103c93a target: pass sens... |
3352 3353 |
ret = TCM_INVALID_PARAMETER_LIST; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
3354 3355 3356 3357 3358 3359 3360 |
} spin_lock(&dev->se_port_lock); list_for_each_entry(se_port, &dev->dev_sep_list, sep_list) { if (se_port->sep_rtpi != rtpi) continue; dest_se_tpg = se_port->sep_tpg; |
6708bb27b target: Follow up... |
3361 |
if (!dest_se_tpg) |
c66ac9db8 [SCSI] target: Ad... |
3362 |
continue; |
e3d6f909e target: Core clea... |
3363 |
dest_tf_ops = dest_se_tpg->se_tpg_tfo; |
6708bb27b target: Follow up... |
3364 |
if (!dest_tf_ops) |
c66ac9db8 [SCSI] target: Ad... |
3365 3366 3367 3368 3369 |
continue; atomic_inc(&dest_se_tpg->tpg_pr_ref_count); smp_mb__after_atomic_inc(); spin_unlock(&dev->se_port_lock); |
de103c93a target: pass sens... |
3370 |
if (core_scsi3_tpg_depend_item(dest_se_tpg)) { |
6708bb27b target: Follow up... |
3371 |
pr_err("core_scsi3_tpg_depend_item() failed" |
c66ac9db8 [SCSI] target: Ad... |
3372 3373 3374 3375 |
" for dest_se_tpg "); atomic_dec(&dest_se_tpg->tpg_pr_ref_count); smp_mb__after_atomic_dec(); |
de103c93a target: pass sens... |
3376 3377 |
ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
3378 3379 3380 3381 3382 3383 |
} spin_lock(&dev->se_port_lock); break; } spin_unlock(&dev->se_port_lock); |
6708bb27b target: Follow up... |
3384 3385 |
if (!dest_se_tpg || !dest_tf_ops) { pr_err("SPC-3 PR REGISTER_AND_MOVE: Unable to locate" |
c66ac9db8 [SCSI] target: Ad... |
3386 3387 3388 |
" fabric ops from Relative Target Port Identifier:" " %hu ", rtpi); |
de103c93a target: pass sens... |
3389 3390 |
ret = TCM_INVALID_PARAMETER_LIST; goto out_put_pr_reg; |
c66ac9db8 [SCSI] target: Ad... |
3391 |
} |
05d1c7c0d target: Make all ... |
3392 |
|
4949314c7 target: Allow con... |
3393 |
buf = transport_kmap_data_sg(cmd); |
de103c93a target: pass sens... |
3394 3395 3396 3397 |
if (!buf) { ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; goto out_put_pr_reg; } |
c66ac9db8 [SCSI] target: Ad... |
3398 |
proto_ident = (buf[24] & 0x0f); |
8b1e1244d target/iscsi: Mis... |
3399 |
|
6708bb27b target: Follow up... |
3400 |
pr_debug("SPC-3 PR REGISTER_AND_MOVE: Extracted Protocol Identifier:" |
c66ac9db8 [SCSI] target: Ad... |
3401 3402 |
" 0x%02x ", proto_ident); |
8b1e1244d target/iscsi: Mis... |
3403 |
|
c66ac9db8 [SCSI] target: Ad... |
3404 |
if (proto_ident != dest_tf_ops->get_fabric_proto_ident(dest_se_tpg)) { |
6708bb27b target: Follow up... |
3405 |
pr_err("SPC-3 PR REGISTER_AND_MOVE: Received" |
c66ac9db8 [SCSI] target: Ad... |
3406 3407 3408 3409 3410 |
" proto_ident: 0x%02x does not match ident: 0x%02x" " from fabric: %s ", proto_ident, dest_tf_ops->get_fabric_proto_ident(dest_se_tpg), dest_tf_ops->get_fabric_name()); |
de103c93a target: pass sens... |
3411 |
ret = TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
3412 3413 3414 |
goto out; } if (dest_tf_ops->tpg_parse_pr_out_transport_id == NULL) { |
6708bb27b target: Follow up... |
3415 |
pr_err("SPC-3 PR REGISTER_AND_MOVE: Fabric does not" |
c66ac9db8 [SCSI] target: Ad... |
3416 3417 3418 |
" containg a valid tpg_parse_pr_out_transport_id" " function pointer "); |
de103c93a target: pass sens... |
3419 |
ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
3420 3421 3422 3423 |
goto out; } initiator_str = dest_tf_ops->tpg_parse_pr_out_transport_id(dest_se_tpg, (const char *)&buf[24], &tmp_tid_len, &iport_ptr); |
6708bb27b target: Follow up... |
3424 3425 |
if (!initiator_str) { pr_err("SPC-3 PR REGISTER_AND_MOVE: Unable to locate" |
c66ac9db8 [SCSI] target: Ad... |
3426 3427 |
" initiator_str from Transport ID "); |
de103c93a target: pass sens... |
3428 |
ret = TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
3429 3430 |
goto out; } |
4949314c7 target: Allow con... |
3431 |
transport_kunmap_data_sg(cmd); |
05d1c7c0d target: Make all ... |
3432 |
buf = NULL; |
6708bb27b target: Follow up... |
3433 |
pr_debug("SPC-3 PR [%s] Extracted initiator %s identifier: %s" |
c66ac9db8 [SCSI] target: Ad... |
3434 3435 3436 3437 3438 3439 3440 3441 3442 3443 3444 3445 3446 3447 3448 |
" %s ", dest_tf_ops->get_fabric_name(), (iport_ptr != NULL) ? "port" : "device", initiator_str, (iport_ptr != NULL) ? iport_ptr : ""); /* * If a PERSISTENT RESERVE OUT command with a REGISTER AND MOVE service * action specifies a TransportID that is the same as the initiator port * of the I_T nexus for the command received, then the command shall * be terminated with CHECK CONDITION status, with the sense key set to * ILLEGAL REQUEST, and the additional sense code set to INVALID FIELD * IN PARAMETER LIST. */ pr_reg_nacl = pr_reg->pr_reg_nacl; matching_iname = (!strcmp(initiator_str, pr_reg_nacl->initiatorname)) ? 1 : 0; |
6708bb27b target: Follow up... |
3449 |
if (!matching_iname) |
c66ac9db8 [SCSI] target: Ad... |
3450 |
goto after_iport_check; |
6708bb27b target: Follow up... |
3451 3452 |
if (!iport_ptr || !pr_reg->isid_present_at_reg) { pr_err("SPC-3 PR REGISTER_AND_MOVE: TransportID: %s" |
c66ac9db8 [SCSI] target: Ad... |
3453 3454 3455 |
" matches: %s on received I_T Nexus ", initiator_str, pr_reg_nacl->initiatorname); |
de103c93a target: pass sens... |
3456 |
ret = TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
3457 3458 |
goto out; } |
6708bb27b target: Follow up... |
3459 3460 |
if (!strcmp(iport_ptr, pr_reg->pr_reg_isid)) { pr_err("SPC-3 PR REGISTER_AND_MOVE: TransportID: %s %s" |
c66ac9db8 [SCSI] target: Ad... |
3461 3462 3463 3464 |
" matches: %s %s on received I_T Nexus ", initiator_str, iport_ptr, pr_reg_nacl->initiatorname, pr_reg->pr_reg_isid); |
de103c93a target: pass sens... |
3465 |
ret = TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
3466 3467 3468 3469 3470 3471 |
goto out; } after_iport_check: /* * Locate the destination struct se_node_acl from the received Transport ID */ |
28638887f target: Convert a... |
3472 |
spin_lock_irq(&dest_se_tpg->acl_node_lock); |
c66ac9db8 [SCSI] target: Ad... |
3473 3474 3475 3476 3477 3478 |
dest_node_acl = __core_tpg_get_initiator_node_acl(dest_se_tpg, initiator_str); if (dest_node_acl) { atomic_inc(&dest_node_acl->acl_pr_ref_count); smp_mb__after_atomic_inc(); } |
28638887f target: Convert a... |
3479 |
spin_unlock_irq(&dest_se_tpg->acl_node_lock); |
c66ac9db8 [SCSI] target: Ad... |
3480 |
|
6708bb27b target: Follow up... |
3481 3482 |
if (!dest_node_acl) { pr_err("Unable to locate %s dest_node_acl for" |
c66ac9db8 [SCSI] target: Ad... |
3483 3484 3485 |
" TransportID%s ", dest_tf_ops->get_fabric_name(), initiator_str); |
de103c93a target: pass sens... |
3486 |
ret = TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
3487 3488 |
goto out; } |
de103c93a target: pass sens... |
3489 3490 |
if (core_scsi3_nodeacl_depend_item(dest_node_acl)) { |
6708bb27b target: Follow up... |
3491 |
pr_err("core_scsi3_nodeacl_depend_item() for" |
c66ac9db8 [SCSI] target: Ad... |
3492 3493 3494 3495 3496 |
" dest_node_acl "); atomic_dec(&dest_node_acl->acl_pr_ref_count); smp_mb__after_atomic_dec(); dest_node_acl = NULL; |
de103c93a target: pass sens... |
3497 |
ret = TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
3498 3499 |
goto out; } |
8b1e1244d target/iscsi: Mis... |
3500 |
|
6708bb27b target: Follow up... |
3501 |
pr_debug("SPC-3 PR REGISTER_AND_MOVE: Found %s dest_node_acl:" |
c66ac9db8 [SCSI] target: Ad... |
3502 3503 3504 |
" %s from TransportID ", dest_tf_ops->get_fabric_name(), dest_node_acl->initiatorname); |
8b1e1244d target/iscsi: Mis... |
3505 |
|
c66ac9db8 [SCSI] target: Ad... |
3506 3507 3508 3509 3510 |
/* * Locate the struct se_dev_entry pointer for the matching RELATIVE TARGET * PORT IDENTIFIER. */ dest_se_deve = core_get_se_deve_from_rtpi(dest_node_acl, rtpi); |
6708bb27b target: Follow up... |
3511 3512 |
if (!dest_se_deve) { pr_err("Unable to locate %s dest_se_deve from RTPI:" |
c66ac9db8 [SCSI] target: Ad... |
3513 3514 |
" %hu ", dest_tf_ops->get_fabric_name(), rtpi); |
de103c93a target: pass sens... |
3515 |
ret = TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
3516 3517 |
goto out; } |
de103c93a target: pass sens... |
3518 |
if (core_scsi3_lunacl_depend_item(dest_se_deve)) { |
6708bb27b target: Follow up... |
3519 3520 |
pr_err("core_scsi3_lunacl_depend_item() failed "); |
c66ac9db8 [SCSI] target: Ad... |
3521 3522 3523 |
atomic_dec(&dest_se_deve->pr_ref_count); smp_mb__after_atomic_dec(); dest_se_deve = NULL; |
de103c93a target: pass sens... |
3524 |
ret = TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
3525 3526 |
goto out; } |
8b1e1244d target/iscsi: Mis... |
3527 |
|
6708bb27b target: Follow up... |
3528 |
pr_debug("SPC-3 PR REGISTER_AND_MOVE: Located %s node %s LUN" |
c66ac9db8 [SCSI] target: Ad... |
3529 3530 3531 3532 |
" ACL for dest_se_deve->mapped_lun: %u ", dest_tf_ops->get_fabric_name(), dest_node_acl->initiatorname, dest_se_deve->mapped_lun); |
8b1e1244d target/iscsi: Mis... |
3533 |
|
c66ac9db8 [SCSI] target: Ad... |
3534 3535 3536 3537 3538 3539 |
/* * A persistent reservation needs to already existing in order to * successfully complete the REGISTER_AND_MOVE service action.. */ spin_lock(&dev->dev_reservation_lock); pr_res_holder = dev->dev_pr_res_holder; |
6708bb27b target: Follow up... |
3540 3541 |
if (!pr_res_holder) { pr_warn("SPC-3 PR REGISTER_AND_MOVE: No reservation" |
c66ac9db8 [SCSI] target: Ad... |
3542 3543 3544 |
" currently held "); spin_unlock(&dev->dev_reservation_lock); |
de103c93a target: pass sens... |
3545 |
ret = TCM_INVALID_CDB_FIELD; |
c66ac9db8 [SCSI] target: Ad... |
3546 3547 3548 3549 3550 3551 3552 3553 3554 |
goto out; } /* * The received on I_T Nexus must be the reservation holder. * * From spc4r17 section 5.7.8 Table 50 -- * Register behaviors for a REGISTER AND MOVE service action */ if (pr_res_holder != pr_reg) { |
6708bb27b target: Follow up... |
3555 |
pr_warn("SPC-3 PR REGISTER_AND_MOVE: Calling I_T" |
c66ac9db8 [SCSI] target: Ad... |
3556 3557 3558 |
" Nexus is not reservation holder "); spin_unlock(&dev->dev_reservation_lock); |
de103c93a target: pass sens... |
3559 |
ret = TCM_RESERVATION_CONFLICT; |
c66ac9db8 [SCSI] target: Ad... |
3560 3561 3562 3563 3564 3565 3566 3567 3568 3569 3570 3571 3572 |
goto out; } /* * From spc4r17 section 5.7.8: registering and moving reservation * * If a PERSISTENT RESERVE OUT command with a REGISTER AND MOVE service * action is received and the established persistent reservation is a * Write Exclusive - All Registrants type or Exclusive Access - * All Registrants type reservation, then the command shall be completed * with RESERVATION CONFLICT status. */ if ((pr_res_holder->pr_res_type == PR_TYPE_WRITE_EXCLUSIVE_ALLREG) || (pr_res_holder->pr_res_type == PR_TYPE_EXCLUSIVE_ACCESS_ALLREG)) { |
6708bb27b target: Follow up... |
3573 |
pr_warn("SPC-3 PR REGISTER_AND_MOVE: Unable to move" |
c66ac9db8 [SCSI] target: Ad... |
3574 3575 3576 3577 |
" reservation for type: %s ", core_scsi3_pr_dump_type(pr_res_holder->pr_res_type)); spin_unlock(&dev->dev_reservation_lock); |
de103c93a target: pass sens... |
3578 |
ret = TCM_RESERVATION_CONFLICT; |
c66ac9db8 [SCSI] target: Ad... |
3579 3580 3581 3582 3583 3584 3585 3586 3587 3588 3589 3590 3591 3592 3593 3594 3595 3596 3597 3598 3599 3600 3601 3602 3603 3604 3605 3606 3607 3608 |
goto out; } pr_res_nacl = pr_res_holder->pr_reg_nacl; /* * b) Ignore the contents of the (received) SCOPE and TYPE fields; */ type = pr_res_holder->pr_res_type; scope = pr_res_holder->pr_res_type; /* * c) Associate the reservation key specified in the SERVICE ACTION * RESERVATION KEY field with the I_T nexus specified as the * destination of the register and move, where: * A) The I_T nexus is specified by the TransportID and the * RELATIVE TARGET PORT IDENTIFIER field (see 6.14.4); and * B) Regardless of the TransportID format used, the association for * the initiator port is based on either the initiator port name * (see 3.1.71) on SCSI transport protocols where port names are * required or the initiator port identifier (see 3.1.70) on SCSI * transport protocols where port names are not required; * d) Register the reservation key specified in the SERVICE ACTION * RESERVATION KEY field; * e) Retain the reservation key specified in the SERVICE ACTION * RESERVATION KEY field and associated information; * * Also, It is not an error for a REGISTER AND MOVE service action to * register an I_T nexus that is already registered with the same * reservation key or a different reservation key. */ dest_pr_reg = __core_scsi3_locate_pr_reg(dev, dest_node_acl, iport_ptr); |
6708bb27b target: Follow up... |
3609 |
if (!dest_pr_reg) { |
de103c93a target: pass sens... |
3610 |
if (core_scsi3_alloc_registration(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
3611 |
dest_node_acl, dest_se_deve, iport_ptr, |
de103c93a target: pass sens... |
3612 |
sa_res_key, 0, aptpl, 2, 1)) { |
c66ac9db8 [SCSI] target: Ad... |
3613 |
spin_unlock(&dev->dev_reservation_lock); |
de103c93a target: pass sens... |
3614 |
ret = TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
3615 3616 3617 3618 3619 3620 3621 3622 3623 3624 3625 3626 3627 3628 3629 3630 3631 3632 3633 3634 3635 3636 3637 3638 3639 3640 |
goto out; } dest_pr_reg = __core_scsi3_locate_pr_reg(dev, dest_node_acl, iport_ptr); new_reg = 1; } /* * f) Release the persistent reservation for the persistent reservation * holder (i.e., the I_T nexus on which the */ __core_scsi3_complete_pro_release(dev, pr_res_nacl, dev->dev_pr_res_holder, 0); /* * g) Move the persistent reservation to the specified I_T nexus using * the same scope and type as the persistent reservation released in * item f); and */ dev->dev_pr_res_holder = dest_pr_reg; dest_pr_reg->pr_res_holder = 1; dest_pr_reg->pr_res_type = type; pr_reg->pr_res_scope = scope; prf_isid = core_pr_dump_initiator_port(pr_reg, &i_buf[0], PR_REG_ISID_ID_LEN); /* * Increment PRGeneration for existing registrations.. */ |
6708bb27b target: Follow up... |
3641 |
if (!new_reg) |
c66ac9db8 [SCSI] target: Ad... |
3642 3643 |
dest_pr_reg->pr_res_generation = pr_tmpl->pr_generation++; spin_unlock(&dev->dev_reservation_lock); |
6708bb27b target: Follow up... |
3644 |
pr_debug("SPC-3 PR [%s] Service Action: REGISTER_AND_MOVE" |
c66ac9db8 [SCSI] target: Ad... |
3645 3646 3647 3648 3649 |
" created new reservation holder TYPE: %s on object RTPI:" " %hu PRGeneration: 0x%08x ", dest_tf_ops->get_fabric_name(), core_scsi3_pr_dump_type(type), rtpi, dest_pr_reg->pr_res_generation); |
6708bb27b target: Follow up... |
3650 |
pr_debug("SPC-3 PR Successfully moved reservation from" |
c66ac9db8 [SCSI] target: Ad... |
3651 3652 3653 3654 3655 3656 3657 3658 3659 3660 3661 3662 3663 3664 3665 3666 3667 3668 3669 3670 3671 3672 3673 3674 3675 3676 3677 3678 |
" %s Fabric Node: %s%s -> %s Fabric Node: %s %s ", tf_ops->get_fabric_name(), pr_reg_nacl->initiatorname, (prf_isid) ? &i_buf[0] : "", dest_tf_ops->get_fabric_name(), dest_node_acl->initiatorname, (iport_ptr != NULL) ? iport_ptr : ""); /* * It is now safe to release configfs group dependencies for destination * of Transport ID Initiator Device/Port Identifier */ core_scsi3_lunacl_undepend_item(dest_se_deve); core_scsi3_nodeacl_undepend_item(dest_node_acl); core_scsi3_tpg_undepend_item(dest_se_tpg); /* * h) If the UNREG bit is set to one, unregister (see 5.7.11.3) the I_T * nexus on which PERSISTENT RESERVE OUT command was received. */ if (unreg) { spin_lock(&pr_tmpl->registration_lock); __core_scsi3_free_registration(dev, pr_reg, NULL, 1); spin_unlock(&pr_tmpl->registration_lock); } else core_scsi3_put_pr_reg(pr_reg); /* * Clear the APTPL metadata if APTPL has been disabled, otherwise * write out the updated metadata to struct file for this SCSI device. */ |
6708bb27b target: Follow up... |
3679 |
if (!aptpl) { |
c66ac9db8 [SCSI] target: Ad... |
3680 |
pr_tmpl->pr_aptpl_active = 0; |
5951146de target: More core... |
3681 |
core_scsi3_update_and_write_aptpl(cmd->se_dev, NULL, 0); |
6708bb27b target: Follow up... |
3682 |
pr_debug("SPC-3 PR: Set APTPL Bit Deactivated for" |
c66ac9db8 [SCSI] target: Ad... |
3683 3684 3685 3686 |
" REGISTER_AND_MOVE "); } else { pr_tmpl->pr_aptpl_active = 1; |
de103c93a target: pass sens... |
3687 |
if (!core_scsi3_update_and_write_aptpl(cmd->se_dev, |
c66ac9db8 [SCSI] target: Ad... |
3688 |
&dest_pr_reg->pr_aptpl_buf[0], |
de103c93a target: pass sens... |
3689 |
pr_tmpl->pr_aptpl_buf_len)) { |
6708bb27b target: Follow up... |
3690 |
pr_debug("SPC-3 PR: Set APTPL Bit Activated for" |
c66ac9db8 [SCSI] target: Ad... |
3691 3692 |
" REGISTER_AND_MOVE "); |
de103c93a target: pass sens... |
3693 |
} |
c66ac9db8 [SCSI] target: Ad... |
3694 |
} |
4949314c7 target: Allow con... |
3695 |
transport_kunmap_data_sg(cmd); |
05d1c7c0d target: Make all ... |
3696 |
|
c66ac9db8 [SCSI] target: Ad... |
3697 3698 3699 |
core_scsi3_put_pr_reg(dest_pr_reg); return 0; out: |
05d1c7c0d target: Make all ... |
3700 |
if (buf) |
4949314c7 target: Allow con... |
3701 |
transport_kunmap_data_sg(cmd); |
c66ac9db8 [SCSI] target: Ad... |
3702 3703 3704 3705 3706 |
if (dest_se_deve) core_scsi3_lunacl_undepend_item(dest_se_deve); if (dest_node_acl) core_scsi3_nodeacl_undepend_item(dest_node_acl); core_scsi3_tpg_undepend_item(dest_se_tpg); |
de103c93a target: pass sens... |
3707 3708 |
out_put_pr_reg: |
c66ac9db8 [SCSI] target: Ad... |
3709 3710 3711 3712 3713 3714 3715 3716 3717 3718 3719 3720 3721 3722 3723 3724 3725 |
core_scsi3_put_pr_reg(pr_reg); return ret; } static unsigned long long core_scsi3_extract_reservation_key(unsigned char *cdb) { unsigned int __v1, __v2; __v1 = (cdb[0] << 24) | (cdb[1] << 16) | (cdb[2] << 8) | cdb[3]; __v2 = (cdb[4] << 24) | (cdb[5] << 16) | (cdb[6] << 8) | cdb[7]; return ((unsigned long long)__v2) | (unsigned long long)__v1 << 32; } /* * See spc4r17 section 6.14 Table 170 */ |
de103c93a target: pass sens... |
3726 3727 |
sense_reason_t target_scsi3_emulate_pr_out(struct se_cmd *cmd) |
c66ac9db8 [SCSI] target: Ad... |
3728 |
{ |
617c0e06c target: split cor... |
3729 |
unsigned char *cdb = &cmd->t_task_cdb[0]; |
05d1c7c0d target: Make all ... |
3730 |
unsigned char *buf; |
c66ac9db8 [SCSI] target: Ad... |
3731 3732 3733 |
u64 res_key, sa_res_key; int sa, scope, type, aptpl; int spec_i_pt = 0, all_tg_pt = 0, unreg = 0; |
de103c93a target: pass sens... |
3734 |
sense_reason_t ret; |
617c0e06c target: split cor... |
3735 3736 3737 3738 3739 3740 3741 3742 3743 3744 |
/* * Following spc2r20 5.5.1 Reservations overview: * * If a logical unit has been reserved by any RESERVE command and is * still reserved by any initiator, all PERSISTENT RESERVE IN and all * PERSISTENT RESERVE OUT commands shall conflict regardless of * initiator or service action and shall terminate with a RESERVATION * CONFLICT status. */ |
0fd97ccf4 target: kill stru... |
3745 |
if (cmd->se_dev->dev_reservation_flags & DRF_SPC2_RESERVATIONS) { |
617c0e06c target: split cor... |
3746 3747 3748 3749 |
pr_err("Received PERSISTENT_RESERVE CDB while legacy" " SPC-2 reservation is held, returning" " RESERVATION_CONFLICT "); |
de103c93a target: pass sens... |
3750 |
return TCM_RESERVATION_CONFLICT; |
617c0e06c target: split cor... |
3751 |
} |
c66ac9db8 [SCSI] target: Ad... |
3752 3753 3754 3755 |
/* * FIXME: A NULL struct se_session pointer means an this is not coming from * a $FABRIC_MOD's nexus, but from internal passthrough ops. */ |
de103c93a target: pass sens... |
3756 3757 |
if (!cmd->se_sess) return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
3758 3759 |
if (cmd->data_length < 24) { |
6708bb27b target: Follow up... |
3760 |
pr_warn("SPC-PR: Received PR OUT parameter list" |
c66ac9db8 [SCSI] target: Ad... |
3761 3762 |
" length too small: %u ", cmd->data_length); |
de103c93a target: pass sens... |
3763 |
return TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
3764 |
} |
de103c93a target: pass sens... |
3765 |
|
c66ac9db8 [SCSI] target: Ad... |
3766 3767 3768 3769 3770 3771 |
/* * From the PERSISTENT_RESERVE_OUT command descriptor block (CDB) */ sa = (cdb[1] & 0x1f); scope = (cdb[2] & 0xf0); type = (cdb[2] & 0x0f); |
05d1c7c0d target: Make all ... |
3772 |
|
4949314c7 target: Allow con... |
3773 |
buf = transport_kmap_data_sg(cmd); |
de103c93a target: pass sens... |
3774 3775 |
if (!buf) return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
c66ac9db8 [SCSI] target: Ad... |
3776 3777 3778 3779 3780 3781 3782 3783 3784 3785 3786 3787 3788 3789 3790 3791 3792 |
/* * From PERSISTENT_RESERVE_OUT parameter list (payload) */ res_key = core_scsi3_extract_reservation_key(&buf[0]); sa_res_key = core_scsi3_extract_reservation_key(&buf[8]); /* * REGISTER_AND_MOVE uses a different SA parameter list containing * SCSI TransportIDs. */ if (sa != PRO_REGISTER_AND_MOVE) { spec_i_pt = (buf[20] & 0x08); all_tg_pt = (buf[20] & 0x04); aptpl = (buf[20] & 0x01); } else { aptpl = (buf[17] & 0x01); unreg = (buf[17] & 0x02); } |
4949314c7 target: Allow con... |
3793 |
transport_kunmap_data_sg(cmd); |
05d1c7c0d target: Make all ... |
3794 |
buf = NULL; |
c66ac9db8 [SCSI] target: Ad... |
3795 3796 3797 |
/* * SPEC_I_PT=1 is only valid for Service action: REGISTER */ |
de103c93a target: pass sens... |
3798 3799 |
if (spec_i_pt && ((cdb[1] & 0x1f) != PRO_REGISTER)) return TCM_INVALID_PARAMETER_LIST; |
d29a5b6ac target: remove SC... |
3800 |
|
c66ac9db8 [SCSI] target: Ad... |
3801 3802 3803 3804 3805 3806 3807 3808 3809 |
/* * From spc4r17 section 6.14: * * If the SPEC_I_PT bit is set to zero, the service action is not * REGISTER AND MOVE, and the parameter list length is not 24, then * the command shall be terminated with CHECK CONDITION status, with * the sense key set to ILLEGAL REQUEST, and the additional sense * code set to PARAMETER LIST LENGTH ERROR. */ |
6708bb27b target: Follow up... |
3810 |
if (!spec_i_pt && ((cdb[1] & 0x1f) != PRO_REGISTER_AND_MOVE) && |
c66ac9db8 [SCSI] target: Ad... |
3811 |
(cmd->data_length != 24)) { |
6708bb27b target: Follow up... |
3812 |
pr_warn("SPC-PR: Received PR OUT illegal parameter" |
c66ac9db8 [SCSI] target: Ad... |
3813 3814 |
" list length: %u ", cmd->data_length); |
de103c93a target: pass sens... |
3815 |
return TCM_INVALID_PARAMETER_LIST; |
c66ac9db8 [SCSI] target: Ad... |
3816 |
} |
de103c93a target: pass sens... |
3817 |
|
c66ac9db8 [SCSI] target: Ad... |
3818 3819 3820 3821 3822 3823 3824 |
/* * (core_scsi3_emulate_pro_* function parameters * are defined by spc4r17 Table 174: * PERSISTENT_RESERVE_OUT service actions and valid parameters. */ switch (sa) { case PRO_REGISTER: |
d29a5b6ac target: remove SC... |
3825 |
ret = core_scsi3_emulate_pro_register(cmd, |
c66ac9db8 [SCSI] target: Ad... |
3826 |
res_key, sa_res_key, aptpl, all_tg_pt, spec_i_pt, 0); |
d29a5b6ac target: remove SC... |
3827 |
break; |
c66ac9db8 [SCSI] target: Ad... |
3828 |
case PRO_RESERVE: |
d29a5b6ac target: remove SC... |
3829 3830 |
ret = core_scsi3_emulate_pro_reserve(cmd, type, scope, res_key); break; |
c66ac9db8 [SCSI] target: Ad... |
3831 |
case PRO_RELEASE: |
d29a5b6ac target: remove SC... |
3832 3833 |
ret = core_scsi3_emulate_pro_release(cmd, type, scope, res_key); break; |
c66ac9db8 [SCSI] target: Ad... |
3834 |
case PRO_CLEAR: |
d29a5b6ac target: remove SC... |
3835 3836 |
ret = core_scsi3_emulate_pro_clear(cmd, res_key); break; |
c66ac9db8 [SCSI] target: Ad... |
3837 |
case PRO_PREEMPT: |
d29a5b6ac target: remove SC... |
3838 |
ret = core_scsi3_emulate_pro_preempt(cmd, type, scope, |
c66ac9db8 [SCSI] target: Ad... |
3839 |
res_key, sa_res_key, 0); |
d29a5b6ac target: remove SC... |
3840 |
break; |
c66ac9db8 [SCSI] target: Ad... |
3841 |
case PRO_PREEMPT_AND_ABORT: |
d29a5b6ac target: remove SC... |
3842 |
ret = core_scsi3_emulate_pro_preempt(cmd, type, scope, |
c66ac9db8 [SCSI] target: Ad... |
3843 |
res_key, sa_res_key, 1); |
d29a5b6ac target: remove SC... |
3844 |
break; |
c66ac9db8 [SCSI] target: Ad... |
3845 |
case PRO_REGISTER_AND_IGNORE_EXISTING_KEY: |
d29a5b6ac target: remove SC... |
3846 |
ret = core_scsi3_emulate_pro_register(cmd, |
c66ac9db8 [SCSI] target: Ad... |
3847 |
0, sa_res_key, aptpl, all_tg_pt, spec_i_pt, 1); |
d29a5b6ac target: remove SC... |
3848 |
break; |
c66ac9db8 [SCSI] target: Ad... |
3849 |
case PRO_REGISTER_AND_MOVE: |
d29a5b6ac target: remove SC... |
3850 |
ret = core_scsi3_emulate_pro_register_and_move(cmd, res_key, |
c66ac9db8 [SCSI] target: Ad... |
3851 |
sa_res_key, aptpl, unreg); |
d29a5b6ac target: remove SC... |
3852 |
break; |
c66ac9db8 [SCSI] target: Ad... |
3853 |
default: |
6708bb27b target: Follow up... |
3854 |
pr_err("Unknown PERSISTENT_RESERVE_OUT service" |
c66ac9db8 [SCSI] target: Ad... |
3855 3856 |
" action: 0x%02x ", cdb[1] & 0x1f); |
de103c93a target: pass sens... |
3857 |
return TCM_INVALID_CDB_FIELD; |
c66ac9db8 [SCSI] target: Ad... |
3858 |
} |
6bb35e009 target: replace -... |
3859 3860 |
if (!ret) target_complete_cmd(cmd, GOOD); |
d29a5b6ac target: remove SC... |
3861 |
return ret; |
c66ac9db8 [SCSI] target: Ad... |
3862 3863 3864 3865 3866 3867 3868 |
} /* * PERSISTENT_RESERVE_IN Service Action READ_KEYS * * See spc4r17 section 5.7.6.2 and section 6.13.2, Table 160 */ |
de103c93a target: pass sens... |
3869 3870 |
static sense_reason_t core_scsi3_pri_read_keys(struct se_cmd *cmd) |
c66ac9db8 [SCSI] target: Ad... |
3871 |
{ |
0fd97ccf4 target: kill stru... |
3872 |
struct se_device *dev = cmd->se_dev; |
c66ac9db8 [SCSI] target: Ad... |
3873 |
struct t10_pr_registration *pr_reg; |
05d1c7c0d target: Make all ... |
3874 |
unsigned char *buf; |
c66ac9db8 [SCSI] target: Ad... |
3875 3876 3877 |
u32 add_len = 0, off = 8; if (cmd->data_length < 8) { |
6708bb27b target: Follow up... |
3878 |
pr_err("PRIN SA READ_KEYS SCSI Data Length: %u" |
c66ac9db8 [SCSI] target: Ad... |
3879 3880 |
" too small ", cmd->data_length); |
de103c93a target: pass sens... |
3881 |
return TCM_INVALID_CDB_FIELD; |
c66ac9db8 [SCSI] target: Ad... |
3882 |
} |
4949314c7 target: Allow con... |
3883 |
buf = transport_kmap_data_sg(cmd); |
de103c93a target: pass sens... |
3884 3885 |
if (!buf) return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
0fd97ccf4 target: kill stru... |
3886 3887 3888 3889 |
buf[0] = ((dev->t10_pr.pr_generation >> 24) & 0xff); buf[1] = ((dev->t10_pr.pr_generation >> 16) & 0xff); buf[2] = ((dev->t10_pr.pr_generation >> 8) & 0xff); buf[3] = (dev->t10_pr.pr_generation & 0xff); |
c66ac9db8 [SCSI] target: Ad... |
3890 |
|
0fd97ccf4 target: kill stru... |
3891 3892 |
spin_lock(&dev->t10_pr.registration_lock); list_for_each_entry(pr_reg, &dev->t10_pr.registration_list, |
c66ac9db8 [SCSI] target: Ad... |
3893 3894 3895 3896 3897 3898 3899 3900 3901 3902 3903 3904 3905 3906 3907 3908 3909 3910 3911 |
pr_reg_list) { /* * Check for overflow of 8byte PRI READ_KEYS payload and * next reservation key list descriptor. */ if ((add_len + 8) > (cmd->data_length - 8)) break; buf[off++] = ((pr_reg->pr_res_key >> 56) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 48) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 40) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 32) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 24) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 16) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 8) & 0xff); buf[off++] = (pr_reg->pr_res_key & 0xff); add_len += 8; } |
0fd97ccf4 target: kill stru... |
3912 |
spin_unlock(&dev->t10_pr.registration_lock); |
c66ac9db8 [SCSI] target: Ad... |
3913 3914 3915 3916 3917 |
buf[4] = ((add_len >> 24) & 0xff); buf[5] = ((add_len >> 16) & 0xff); buf[6] = ((add_len >> 8) & 0xff); buf[7] = (add_len & 0xff); |
4949314c7 target: Allow con... |
3918 |
transport_kunmap_data_sg(cmd); |
05d1c7c0d target: Make all ... |
3919 |
|
c66ac9db8 [SCSI] target: Ad... |
3920 3921 3922 3923 3924 3925 3926 3927 |
return 0; } /* * PERSISTENT_RESERVE_IN Service Action READ_RESERVATION * * See spc4r17 section 5.7.6.3 and section 6.13.3.2 Table 161 and 162 */ |
de103c93a target: pass sens... |
3928 3929 |
static sense_reason_t core_scsi3_pri_read_reservation(struct se_cmd *cmd) |
c66ac9db8 [SCSI] target: Ad... |
3930 |
{ |
0fd97ccf4 target: kill stru... |
3931 |
struct se_device *dev = cmd->se_dev; |
c66ac9db8 [SCSI] target: Ad... |
3932 |
struct t10_pr_registration *pr_reg; |
05d1c7c0d target: Make all ... |
3933 |
unsigned char *buf; |
c66ac9db8 [SCSI] target: Ad... |
3934 3935 3936 3937 |
u64 pr_res_key; u32 add_len = 16; /* Hardcoded to 16 when a reservation is held. */ if (cmd->data_length < 8) { |
6708bb27b target: Follow up... |
3938 |
pr_err("PRIN SA READ_RESERVATIONS SCSI Data Length: %u" |
c66ac9db8 [SCSI] target: Ad... |
3939 3940 |
" too small ", cmd->data_length); |
de103c93a target: pass sens... |
3941 |
return TCM_INVALID_CDB_FIELD; |
c66ac9db8 [SCSI] target: Ad... |
3942 |
} |
4949314c7 target: Allow con... |
3943 |
buf = transport_kmap_data_sg(cmd); |
de103c93a target: pass sens... |
3944 3945 |
if (!buf) return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
0fd97ccf4 target: kill stru... |
3946 3947 3948 3949 |
buf[0] = ((dev->t10_pr.pr_generation >> 24) & 0xff); buf[1] = ((dev->t10_pr.pr_generation >> 16) & 0xff); buf[2] = ((dev->t10_pr.pr_generation >> 8) & 0xff); buf[3] = (dev->t10_pr.pr_generation & 0xff); |
c66ac9db8 [SCSI] target: Ad... |
3950 |
|
0fd97ccf4 target: kill stru... |
3951 3952 |
spin_lock(&dev->dev_reservation_lock); pr_reg = dev->dev_pr_res_holder; |
ee1b1b9c3 target: Remove un... |
3953 |
if (pr_reg) { |
c66ac9db8 [SCSI] target: Ad... |
3954 3955 3956 3957 3958 3959 3960 |
/* * Set the hardcoded Additional Length */ buf[4] = ((add_len >> 24) & 0xff); buf[5] = ((add_len >> 16) & 0xff); buf[6] = ((add_len >> 8) & 0xff); buf[7] = (add_len & 0xff); |
05d1c7c0d target: Make all ... |
3961 3962 |
if (cmd->data_length < 22) goto err; |
c66ac9db8 [SCSI] target: Ad... |
3963 3964 3965 3966 3967 3968 3969 3970 3971 3972 3973 3974 3975 3976 3977 3978 3979 3980 3981 3982 3983 3984 3985 3986 3987 3988 3989 3990 3991 3992 3993 3994 3995 3996 3997 3998 |
/* * Set the Reservation key. * * From spc4r17, section 5.7.10: * A persistent reservation holder has its reservation key * returned in the parameter data from a PERSISTENT * RESERVE IN command with READ RESERVATION service action as * follows: * a) For a persistent reservation of the type Write Exclusive * - All Registrants or Exclusive Access  All Regitrants, * the reservation key shall be set to zero; or * b) For all other persistent reservation types, the * reservation key shall be set to the registered * reservation key for the I_T nexus that holds the * persistent reservation. */ if ((pr_reg->pr_res_type == PR_TYPE_WRITE_EXCLUSIVE_ALLREG) || (pr_reg->pr_res_type == PR_TYPE_EXCLUSIVE_ACCESS_ALLREG)) pr_res_key = 0; else pr_res_key = pr_reg->pr_res_key; buf[8] = ((pr_res_key >> 56) & 0xff); buf[9] = ((pr_res_key >> 48) & 0xff); buf[10] = ((pr_res_key >> 40) & 0xff); buf[11] = ((pr_res_key >> 32) & 0xff); buf[12] = ((pr_res_key >> 24) & 0xff); buf[13] = ((pr_res_key >> 16) & 0xff); buf[14] = ((pr_res_key >> 8) & 0xff); buf[15] = (pr_res_key & 0xff); /* * Set the SCOPE and TYPE */ buf[21] = (pr_reg->pr_res_scope & 0xf0) | (pr_reg->pr_res_type & 0x0f); } |
05d1c7c0d target: Make all ... |
3999 4000 |
err: |
0fd97ccf4 target: kill stru... |
4001 |
spin_unlock(&dev->dev_reservation_lock); |
4949314c7 target: Allow con... |
4002 |
transport_kunmap_data_sg(cmd); |
c66ac9db8 [SCSI] target: Ad... |
4003 4004 4005 4006 4007 4008 4009 4010 4011 |
return 0; } /* * PERSISTENT_RESERVE_IN Service Action REPORT_CAPABILITIES * * See spc4r17 section 6.13.4 Table 165 */ |
de103c93a target: pass sens... |
4012 4013 |
static sense_reason_t core_scsi3_pri_report_capabilities(struct se_cmd *cmd) |
c66ac9db8 [SCSI] target: Ad... |
4014 |
{ |
5951146de target: More core... |
4015 |
struct se_device *dev = cmd->se_dev; |
0fd97ccf4 target: kill stru... |
4016 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
05d1c7c0d target: Make all ... |
4017 |
unsigned char *buf; |
c66ac9db8 [SCSI] target: Ad... |
4018 4019 4020 |
u16 add_len = 8; /* Hardcoded to 8. */ if (cmd->data_length < 6) { |
6708bb27b target: Follow up... |
4021 |
pr_err("PRIN SA REPORT_CAPABILITIES SCSI Data Length:" |
c66ac9db8 [SCSI] target: Ad... |
4022 4023 |
" %u too small ", cmd->data_length); |
de103c93a target: pass sens... |
4024 |
return TCM_INVALID_CDB_FIELD; |
c66ac9db8 [SCSI] target: Ad... |
4025 |
} |
4949314c7 target: Allow con... |
4026 |
buf = transport_kmap_data_sg(cmd); |
de103c93a target: pass sens... |
4027 4028 |
if (!buf) return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
05d1c7c0d target: Make all ... |
4029 |
|
c66ac9db8 [SCSI] target: Ad... |
4030 4031 4032 4033 4034 4035 4036 4037 4038 4039 4040 4041 4042 4043 4044 4045 4046 4047 4048 4049 4050 4051 4052 4053 4054 4055 4056 4057 4058 |
buf[0] = ((add_len << 8) & 0xff); buf[1] = (add_len & 0xff); buf[2] |= 0x10; /* CRH: Compatible Reservation Hanlding bit. */ buf[2] |= 0x08; /* SIP_C: Specify Initiator Ports Capable bit */ buf[2] |= 0x04; /* ATP_C: All Target Ports Capable bit */ buf[2] |= 0x01; /* PTPL_C: Persistence across Target Power Loss bit */ /* * We are filling in the PERSISTENT RESERVATION TYPE MASK below, so * set the TMV: Task Mask Valid bit. */ buf[3] |= 0x80; /* * Change ALLOW COMMANDs to 0x20 or 0x40 later from Table 166 */ buf[3] |= 0x10; /* ALLOW COMMANDs field 001b */ /* * PTPL_A: Persistence across Target Power Loss Active bit */ if (pr_tmpl->pr_aptpl_active) buf[3] |= 0x01; /* * Setup the PERSISTENT RESERVATION TYPE MASK from Table 167 */ buf[4] |= 0x80; /* PR_TYPE_EXCLUSIVE_ACCESS_ALLREG */ buf[4] |= 0x40; /* PR_TYPE_EXCLUSIVE_ACCESS_REGONLY */ buf[4] |= 0x20; /* PR_TYPE_WRITE_EXCLUSIVE_REGONLY */ buf[4] |= 0x08; /* PR_TYPE_EXCLUSIVE_ACCESS */ buf[4] |= 0x02; /* PR_TYPE_WRITE_EXCLUSIVE */ buf[5] |= 0x01; /* PR_TYPE_EXCLUSIVE_ACCESS_ALLREG */ |
4949314c7 target: Allow con... |
4059 |
transport_kunmap_data_sg(cmd); |
05d1c7c0d target: Make all ... |
4060 |
|
c66ac9db8 [SCSI] target: Ad... |
4061 4062 4063 4064 4065 4066 4067 4068 |
return 0; } /* * PERSISTENT_RESERVE_IN Service Action READ_FULL_STATUS * * See spc4r17 section 6.13.5 Table 168 and 169 */ |
de103c93a target: pass sens... |
4069 4070 |
static sense_reason_t core_scsi3_pri_read_full_status(struct se_cmd *cmd) |
c66ac9db8 [SCSI] target: Ad... |
4071 |
{ |
0fd97ccf4 target: kill stru... |
4072 |
struct se_device *dev = cmd->se_dev; |
c66ac9db8 [SCSI] target: Ad... |
4073 |
struct se_node_acl *se_nacl; |
c66ac9db8 [SCSI] target: Ad... |
4074 4075 |
struct se_portal_group *se_tpg; struct t10_pr_registration *pr_reg, *pr_reg_tmp; |
0fd97ccf4 target: kill stru... |
4076 |
struct t10_reservation *pr_tmpl = &dev->t10_pr; |
05d1c7c0d target: Make all ... |
4077 |
unsigned char *buf; |
c66ac9db8 [SCSI] target: Ad... |
4078 4079 4080 4081 4082 |
u32 add_desc_len = 0, add_len = 0, desc_len, exp_desc_len; u32 off = 8; /* off into first Full Status descriptor */ int format_code = 0; if (cmd->data_length < 8) { |
6708bb27b target: Follow up... |
4083 |
pr_err("PRIN SA READ_FULL_STATUS SCSI Data Length: %u" |
c66ac9db8 [SCSI] target: Ad... |
4084 4085 |
" too small ", cmd->data_length); |
de103c93a target: pass sens... |
4086 |
return TCM_INVALID_CDB_FIELD; |
c66ac9db8 [SCSI] target: Ad... |
4087 |
} |
4949314c7 target: Allow con... |
4088 |
buf = transport_kmap_data_sg(cmd); |
de103c93a target: pass sens... |
4089 4090 |
if (!buf) return TCM_LOGICAL_UNIT_COMMUNICATION_FAILURE; |
05d1c7c0d target: Make all ... |
4091 |
|
0fd97ccf4 target: kill stru... |
4092 4093 4094 4095 |
buf[0] = ((dev->t10_pr.pr_generation >> 24) & 0xff); buf[1] = ((dev->t10_pr.pr_generation >> 16) & 0xff); buf[2] = ((dev->t10_pr.pr_generation >> 8) & 0xff); buf[3] = (dev->t10_pr.pr_generation & 0xff); |
c66ac9db8 [SCSI] target: Ad... |
4096 4097 4098 4099 4100 4101 4102 4103 4104 4105 4106 4107 4108 4109 4110 4111 |
spin_lock(&pr_tmpl->registration_lock); list_for_each_entry_safe(pr_reg, pr_reg_tmp, &pr_tmpl->registration_list, pr_reg_list) { se_nacl = pr_reg->pr_reg_nacl; se_tpg = pr_reg->pr_reg_nacl->se_tpg; add_desc_len = 0; atomic_inc(&pr_reg->pr_res_holders); smp_mb__after_atomic_inc(); spin_unlock(&pr_tmpl->registration_lock); /* * Determine expected length of $FABRIC_MOD specific * TransportID full status descriptor.. */ |
e3d6f909e target: Core clea... |
4112 |
exp_desc_len = se_tpg->se_tpg_tfo->tpg_get_pr_transport_id_len( |
c66ac9db8 [SCSI] target: Ad... |
4113 4114 4115 |
se_tpg, se_nacl, pr_reg, &format_code); if ((exp_desc_len + add_len) > cmd->data_length) { |
6708bb27b target: Follow up... |
4116 |
pr_warn("SPC-3 PRIN READ_FULL_STATUS ran" |
c66ac9db8 [SCSI] target: Ad... |
4117 4118 4119 4120 4121 4122 4123 4124 4125 4126 4127 4128 4129 4130 4131 4132 4133 4134 4135 4136 4137 4138 4139 4140 4141 4142 4143 4144 4145 4146 4147 4148 4149 4150 4151 4152 4153 4154 4155 4156 4157 4158 4159 4160 4161 4162 4163 4164 4165 4166 |
" out of buffer: %d ", cmd->data_length); spin_lock(&pr_tmpl->registration_lock); atomic_dec(&pr_reg->pr_res_holders); smp_mb__after_atomic_dec(); break; } /* * Set RESERVATION KEY */ buf[off++] = ((pr_reg->pr_res_key >> 56) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 48) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 40) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 32) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 24) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 16) & 0xff); buf[off++] = ((pr_reg->pr_res_key >> 8) & 0xff); buf[off++] = (pr_reg->pr_res_key & 0xff); off += 4; /* Skip Over Reserved area */ /* * Set ALL_TG_PT bit if PROUT SA REGISTER had this set. */ if (pr_reg->pr_reg_all_tg_pt) buf[off] = 0x02; /* * The struct se_lun pointer will be present for the * reservation holder for PR_HOLDER bit. * * Also, if this registration is the reservation * holder, fill in SCOPE and TYPE in the next byte. */ if (pr_reg->pr_res_holder) { buf[off++] |= 0x01; buf[off++] = (pr_reg->pr_res_scope & 0xf0) | (pr_reg->pr_res_type & 0x0f); } else off += 2; off += 4; /* Skip over reserved area */ /* * From spc4r17 6.3.15: * * If the ALL_TG_PT bit set to zero, the RELATIVE TARGET PORT * IDENTIFIER field contains the relative port identifier (see * 3.1.120) of the target port that is part of the I_T nexus * described by this full status descriptor. If the ALL_TG_PT * bit is set to one, the contents of the RELATIVE TARGET PORT * IDENTIFIER field are not defined by this standard. */ |
6708bb27b target: Follow up... |
4167 |
if (!pr_reg->pr_reg_all_tg_pt) { |
c66ac9db8 [SCSI] target: Ad... |
4168 4169 4170 4171 4172 |
struct se_port *port = pr_reg->pr_reg_tg_pt_lun->lun_sep; buf[off++] = ((port->sep_rtpi >> 8) & 0xff); buf[off++] = (port->sep_rtpi & 0xff); } else |
35d1efe80 target: Fix minor... |
4173 |
off += 2; /* Skip over RELATIVE TARGET PORT IDENTIFIER */ |
c66ac9db8 [SCSI] target: Ad... |
4174 4175 4176 4177 |
/* * Now, have the $FABRIC_MOD fill in the protocol identifier */ |
e3d6f909e target: Core clea... |
4178 |
desc_len = se_tpg->se_tpg_tfo->tpg_get_pr_transport_id(se_tpg, |
c66ac9db8 [SCSI] target: Ad... |
4179 4180 4181 4182 4183 4184 4185 4186 4187 4188 4189 4190 4191 4192 4193 4194 4195 4196 4197 4198 4199 4200 4201 4202 4203 4204 4205 4206 4207 4208 4209 4210 |
se_nacl, pr_reg, &format_code, &buf[off+4]); spin_lock(&pr_tmpl->registration_lock); atomic_dec(&pr_reg->pr_res_holders); smp_mb__after_atomic_dec(); /* * Set the ADDITIONAL DESCRIPTOR LENGTH */ buf[off++] = ((desc_len >> 24) & 0xff); buf[off++] = ((desc_len >> 16) & 0xff); buf[off++] = ((desc_len >> 8) & 0xff); buf[off++] = (desc_len & 0xff); /* * Size of full desctipor header minus TransportID * containing $FABRIC_MOD specific) initiator device/port * WWN information. * * See spc4r17 Section 6.13.5 Table 169 */ add_desc_len = (24 + desc_len); off += desc_len; add_len += add_desc_len; } spin_unlock(&pr_tmpl->registration_lock); /* * Set ADDITIONAL_LENGTH */ buf[4] = ((add_len >> 24) & 0xff); buf[5] = ((add_len >> 16) & 0xff); buf[6] = ((add_len >> 8) & 0xff); buf[7] = (add_len & 0xff); |
4949314c7 target: Allow con... |
4211 |
transport_kunmap_data_sg(cmd); |
05d1c7c0d target: Make all ... |
4212 |
|
c66ac9db8 [SCSI] target: Ad... |
4213 4214 |
return 0; } |
de103c93a target: pass sens... |
4215 4216 |
sense_reason_t target_scsi3_emulate_pr_in(struct se_cmd *cmd) |
c66ac9db8 [SCSI] target: Ad... |
4217 |
{ |
de103c93a target: pass sens... |
4218 |
sense_reason_t ret; |
e76a35d6c target: pass the ... |
4219 |
|
c66ac9db8 [SCSI] target: Ad... |
4220 4221 4222 4223 4224 4225 4226 4227 4228 |
/* * Following spc2r20 5.5.1 Reservations overview: * * If a logical unit has been reserved by any RESERVE command and is * still reserved by any initiator, all PERSISTENT RESERVE IN and all * PERSISTENT RESERVE OUT commands shall conflict regardless of * initiator or service action and shall terminate with a RESERVATION * CONFLICT status. */ |
0fd97ccf4 target: kill stru... |
4229 |
if (cmd->se_dev->dev_reservation_flags & DRF_SPC2_RESERVATIONS) { |
6708bb27b target: Follow up... |
4230 |
pr_err("Received PERSISTENT_RESERVE CDB while legacy" |
c66ac9db8 [SCSI] target: Ad... |
4231 4232 4233 |
" SPC-2 reservation is held, returning" " RESERVATION_CONFLICT "); |
de103c93a target: pass sens... |
4234 |
return TCM_RESERVATION_CONFLICT; |
c66ac9db8 [SCSI] target: Ad... |
4235 |
} |
617c0e06c target: split cor... |
4236 4237 |
switch (cmd->t_task_cdb[1] & 0x1f) { case PRI_READ_KEYS: |
d29a5b6ac target: remove SC... |
4238 4239 |
ret = core_scsi3_pri_read_keys(cmd); break; |
617c0e06c target: split cor... |
4240 |
case PRI_READ_RESERVATION: |
d29a5b6ac target: remove SC... |
4241 4242 |
ret = core_scsi3_pri_read_reservation(cmd); break; |
617c0e06c target: split cor... |
4243 |
case PRI_REPORT_CAPABILITIES: |
d29a5b6ac target: remove SC... |
4244 4245 |
ret = core_scsi3_pri_report_capabilities(cmd); break; |
617c0e06c target: split cor... |
4246 |
case PRI_READ_FULL_STATUS: |
d29a5b6ac target: remove SC... |
4247 4248 |
ret = core_scsi3_pri_read_full_status(cmd); break; |
617c0e06c target: split cor... |
4249 4250 4251 4252 |
default: pr_err("Unknown PERSISTENT_RESERVE_IN service" " action: 0x%02x ", cmd->t_task_cdb[1] & 0x1f); |
de103c93a target: pass sens... |
4253 |
return TCM_INVALID_CDB_FIELD; |
d29a5b6ac target: remove SC... |
4254 |
} |
6bb35e009 target: replace -... |
4255 4256 |
if (!ret) target_complete_cmd(cmd, GOOD); |
d29a5b6ac target: remove SC... |
4257 |
return ret; |
c66ac9db8 [SCSI] target: Ad... |
4258 |
} |
de103c93a target: pass sens... |
4259 4260 |
sense_reason_t target_check_reservation(struct se_cmd *cmd) |
c66ac9db8 [SCSI] target: Ad... |
4261 |
{ |
d977f4377 target: simplify ... |
4262 |
struct se_device *dev = cmd->se_dev; |
de103c93a target: pass sens... |
4263 |
sense_reason_t ret; |
c66ac9db8 [SCSI] target: Ad... |
4264 |
|
d977f4377 target: simplify ... |
4265 4266 4267 4268 4269 4270 |
if (!cmd->se_sess) return 0; if (dev->se_hba->hba_flags & HBA_FLAGS_INTERNAL_USE) return 0; if (dev->transport->transport_type == TRANSPORT_PLUGIN_PHBA_PDEV) return 0; |
c66ac9db8 [SCSI] target: Ad... |
4271 |
|
d977f4377 target: simplify ... |
4272 4273 4274 4275 4276 4277 |
spin_lock(&dev->dev_reservation_lock); if (dev->dev_reservation_flags & DRF_SPC2_RESERVATIONS) ret = target_scsi2_reservation_check(cmd); else ret = target_scsi3_pr_reservation_check(cmd); spin_unlock(&dev->dev_reservation_lock); |
0fd97ccf4 target: kill stru... |
4278 |
|
d977f4377 target: simplify ... |
4279 |
return ret; |
c66ac9db8 [SCSI] target: Ad... |
4280 |
} |