2 * CCW device PGID and path verification I/O handling.
4 * Copyright IBM Corp. 2002,2009
5 * Author(s): Cornelia Huck <cornelia.huck@de.ibm.com>
6 * Martin Schwidefsky <schwidefsky@de.ibm.com>
7 * Peter Oberparleiter <peter.oberparleiter@de.ibm.com>
10 #include <linux/kernel.h>
11 #include <linux/string.h>
12 #include <linux/types.h>
13 #include <linux/errno.h>
14 #include <linux/bitops.h>
15 #include <asm/ccwdev.h>
19 #include "cio_debug.h"
23 #define PGID_RETRIES 256
24 #define PGID_TIMEOUT (10 * HZ)
27 * Process path verification data and report result.
29 static void verify_done(struct ccw_device *cdev, int rc)
31 struct subchannel *sch = to_subchannel(cdev->dev.parent);
32 struct ccw_dev_id *id = &cdev->private->dev_id;
33 int mpath = cdev->private->flags.mpath;
34 int pgroup = cdev->private->flags.pgroup;
38 /* Ensure consistent multipathing state at device and channel. */
39 if (sch->config.mp != mpath) {
40 sch->config.mp = mpath;
41 rc = cio_commit_config(sch);
44 CIO_MSG_EVENT(2, "vrfy: device 0.%x.%04x: rc=%d pgroup=%d mpath=%d "
45 "vpm=%02x\n", id->ssid, id->devno, rc, pgroup, mpath,
47 ccw_device_verify_done(cdev, rc);
51 * Create channel program to perform a NOOP.
53 static void nop_build_cp(struct ccw_device *cdev)
55 struct ccw_request *req = &cdev->private->req;
56 struct ccw1 *cp = cdev->private->iccws;
58 cp->cmd_code = CCW_CMD_NOOP;
61 cp->flags = CCW_FLAG_SLI;
66 * Perform NOOP on a single path.
68 static void nop_do(struct ccw_device *cdev)
70 struct subchannel *sch = to_subchannel(cdev->dev.parent);
71 struct ccw_request *req = &cdev->private->req;
74 req->lpm = lpm_adjust(req->lpm, sch->schib.pmcw.pam & sch->opm);
78 ccw_request_start(cdev);
82 verify_done(cdev, sch->vpm ? 0 : -EACCES);
86 * Adjust NOOP I/O status.
88 static enum io_status nop_filter(struct ccw_device *cdev, void *data,
89 struct irb *irb, enum io_status status)
91 /* Only subchannel status might indicate a path error. */
92 if (status == IO_STATUS_ERROR && irb->scsw.cmd.cstat == 0)
98 * Process NOOP request result for a single path.
100 static void nop_callback(struct ccw_device *cdev, void *data, int rc)
102 struct subchannel *sch = to_subchannel(cdev->dev.parent);
103 struct ccw_request *req = &cdev->private->req;
106 sch->vpm |= req->lpm;
107 else if (rc != -EACCES)
114 verify_done(cdev, rc);
118 * Create channel program to perform SET PGID on a single path.
120 static void spid_build_cp(struct ccw_device *cdev, u8 fn)
122 struct ccw_request *req = &cdev->private->req;
123 struct ccw1 *cp = cdev->private->iccws;
124 int i = 8 - ffs(req->lpm);
125 struct pgid *pgid = &cdev->private->pgid[i];
128 cp->cmd_code = CCW_CMD_SET_PGID;
129 cp->cda = (u32) (addr_t) pgid;
130 cp->count = sizeof(*pgid);
131 cp->flags = CCW_FLAG_SLI;
136 * Perform establish/resign SET PGID on a single path.
138 static void spid_do(struct ccw_device *cdev)
140 struct subchannel *sch = to_subchannel(cdev->dev.parent);
141 struct ccw_request *req = &cdev->private->req;
144 /* Use next available path that is not already in correct state. */
145 req->lpm = lpm_adjust(req->lpm, cdev->private->pgid_todo_mask);
148 /* Channel program setup. */
149 if (req->lpm & sch->opm)
150 fn = SPID_FUNC_ESTABLISH;
152 fn = SPID_FUNC_RESIGN;
153 if (cdev->private->flags.mpath)
154 fn |= SPID_FUNC_MULTI_PATH;
155 spid_build_cp(cdev, fn);
156 ccw_request_start(cdev);
160 verify_done(cdev, sch->vpm ? 0 : -EACCES);
163 static void verify_start(struct ccw_device *cdev);
166 * Process SET PGID request result for a single path.
168 static void spid_callback(struct ccw_device *cdev, void *data, int rc)
170 struct subchannel *sch = to_subchannel(cdev->dev.parent);
171 struct ccw_request *req = &cdev->private->req;
175 sch->vpm |= req->lpm & sch->opm;
180 if (cdev->private->flags.mpath) {
181 /* Try without multipathing. */
182 cdev->private->flags.mpath = 0;
185 /* Try without pathgrouping. */
186 cdev->private->flags.pgroup = 0;
199 verify_done(cdev, rc);
202 static void spid_start(struct ccw_device *cdev)
204 struct ccw_request *req = &cdev->private->req;
206 /* Initialize request data. */
207 memset(req, 0, sizeof(*req));
208 req->timeout = PGID_TIMEOUT;
209 req->maxretries = PGID_RETRIES;
212 req->callback = spid_callback;
216 static int pgid_cmp(struct pgid *p1, struct pgid *p2)
218 return memcmp((char *) p1 + 1, (char *) p2 + 1,
219 sizeof(struct pgid) - 1);
223 * Determine pathgroup state from PGID data.
225 static void pgid_analyze(struct ccw_device *cdev, struct pgid **p,
226 int *mismatch, int *reserved, int *reset)
228 struct pgid *pgid = &cdev->private->pgid[0];
229 struct pgid *first = NULL;
236 for (i = 0, lpm = 0x80; i < 8; i++, pgid++, lpm >>= 1) {
237 if ((cdev->private->pgid_valid_mask & lpm) == 0)
239 if (pgid->inf.ps.state2 == SNID_STATE2_RESVD_ELSE)
241 if (pgid->inf.ps.state1 == SNID_STATE1_RESET) {
242 /* A PGID was reset. */
250 if (pgid_cmp(pgid, first) != 0)
254 first = &channel_subsystems[0]->global_pgid;
258 static u8 pgid_to_donepm(struct ccw_device *cdev)
260 struct subchannel *sch = to_subchannel(cdev->dev.parent);
266 /* Set bits for paths which are already in the target state. */
267 for (i = 0; i < 8; i++) {
269 if ((cdev->private->pgid_valid_mask & lpm) == 0)
271 pgid = &cdev->private->pgid[i];
272 if (sch->opm & lpm) {
273 if (pgid->inf.ps.state1 != SNID_STATE1_GROUPED)
276 if (pgid->inf.ps.state1 != SNID_STATE1_UNGROUPED)
279 if (cdev->private->flags.mpath) {
280 if (pgid->inf.ps.state3 != SNID_STATE3_MULTI_PATH)
283 if (pgid->inf.ps.state3 != SNID_STATE3_SINGLE_PATH)
292 static void pgid_fill(struct ccw_device *cdev, struct pgid *pgid)
296 for (i = 0; i < 8; i++)
297 memcpy(&cdev->private->pgid[i], pgid, sizeof(struct pgid));
301 * Process SENSE PGID data and report result.
303 static void snid_done(struct ccw_device *cdev, int rc)
305 struct ccw_dev_id *id = &cdev->private->dev_id;
306 struct subchannel *sch = to_subchannel(cdev->dev.parent);
315 pgid_analyze(cdev, &pgid, &mismatch, &reserved, &reset);
321 donepm = pgid_to_donepm(cdev);
322 sch->vpm = donepm & sch->opm;
323 cdev->private->pgid_todo_mask &= ~donepm;
324 pgid_fill(cdev, pgid);
327 CIO_MSG_EVENT(2, "snid: device 0.%x.%04x: rc=%d pvm=%02x vpm=%02x "
328 "todo=%02x mism=%d rsvd=%d reset=%d\n", id->ssid,
329 id->devno, rc, cdev->private->pgid_valid_mask, sch->vpm,
330 cdev->private->pgid_todo_mask, mismatch, reserved, reset);
333 /* Anything left to do? */
334 if (cdev->private->pgid_todo_mask == 0) {
335 verify_done(cdev, sch->vpm == 0 ? -EACCES : 0);
338 /* Perform path-grouping. */
342 /* Path-grouping not supported. */
343 cdev->private->flags.pgroup = 0;
344 cdev->private->flags.mpath = 0;
348 verify_done(cdev, rc);
353 * Create channel program to perform a SENSE PGID on a single path.
355 static void snid_build_cp(struct ccw_device *cdev)
357 struct ccw_request *req = &cdev->private->req;
358 struct ccw1 *cp = cdev->private->iccws;
359 int i = 8 - ffs(req->lpm);
361 /* Channel program setup. */
362 cp->cmd_code = CCW_CMD_SENSE_PGID;
363 cp->cda = (u32) (addr_t) &cdev->private->pgid[i];
364 cp->count = sizeof(struct pgid);
365 cp->flags = CCW_FLAG_SLI;
370 * Perform SENSE PGID on a single path.
372 static void snid_do(struct ccw_device *cdev)
374 struct subchannel *sch = to_subchannel(cdev->dev.parent);
375 struct ccw_request *req = &cdev->private->req;
377 /* Adjust lpm if paths are not set in pam. */
378 req->lpm = lpm_adjust(req->lpm, sch->schib.pmcw.pam);
382 ccw_request_start(cdev);
386 snid_done(cdev, cdev->private->pgid_valid_mask ? 0 : -EACCES);
390 * Process SENSE PGID request result for single path.
392 static void snid_callback(struct ccw_device *cdev, void *data, int rc)
394 struct ccw_request *req = &cdev->private->req;
397 cdev->private->pgid_valid_mask |= req->lpm;
398 else if (rc != -EACCES)
409 * Perform path verification.
411 static void verify_start(struct ccw_device *cdev)
413 struct subchannel *sch = to_subchannel(cdev->dev.parent);
414 struct ccw_request *req = &cdev->private->req;
415 struct ccw_dev_id *devid = &cdev->private->dev_id;
418 sch->lpm = sch->schib.pmcw.pam;
419 /* Initialize request data. */
420 memset(req, 0, sizeof(*req));
421 req->timeout = PGID_TIMEOUT;
422 req->maxretries = PGID_RETRIES;
425 if (cdev->private->flags.pgroup) {
426 CIO_TRACE_EVENT(4, "snid");
427 CIO_HEX_EVENT(4, devid, sizeof(*devid));
428 req->callback = snid_callback;
431 CIO_TRACE_EVENT(4, "nop");
432 CIO_HEX_EVENT(4, devid, sizeof(*devid));
433 req->filter = nop_filter;
434 req->callback = nop_callback;
440 * ccw_device_verify_start - perform path verification
443 * Perform an I/O on each available channel path to @cdev to determine which
444 * paths are operational. The resulting path mask is stored in sch->vpm.
445 * If device options specify pathgrouping, establish a pathgroup for the
446 * operational paths. When finished, call ccw_device_verify_done with a
447 * return code specifying the result.
449 void ccw_device_verify_start(struct ccw_device *cdev)
451 struct subchannel *sch = to_subchannel(cdev->dev.parent);
453 CIO_TRACE_EVENT(4, "vrfy");
454 CIO_HEX_EVENT(4, &cdev->private->dev_id, sizeof(cdev->private->dev_id));
455 /* Initialize PGID data. */
456 memset(cdev->private->pgid, 0, sizeof(cdev->private->pgid));
457 cdev->private->pgid_valid_mask = 0;
458 cdev->private->pgid_todo_mask = sch->schib.pmcw.pam;
460 * Initialize pathgroup and multipath state with target values.
461 * They may change in the course of path verification.
463 cdev->private->flags.pgroup = cdev->private->options.pgroup;
464 cdev->private->flags.mpath = cdev->private->options.mpath;
465 cdev->private->flags.doverify = 0;
470 * Process disband SET PGID request result.
472 static void disband_callback(struct ccw_device *cdev, void *data, int rc)
474 struct subchannel *sch = to_subchannel(cdev->dev.parent);
475 struct ccw_dev_id *id = &cdev->private->dev_id;
479 /* Ensure consistent multipathing state at device and channel. */
480 cdev->private->flags.mpath = 0;
481 if (sch->config.mp) {
483 rc = cio_commit_config(sch);
486 CIO_MSG_EVENT(0, "disb: device 0.%x.%04x: rc=%d\n", id->ssid, id->devno,
488 ccw_device_disband_done(cdev, rc);
492 * ccw_device_disband_start - disband pathgroup
495 * Execute a SET PGID channel program on @cdev to disband a previously
496 * established pathgroup. When finished, call ccw_device_disband_done with
497 * a return code specifying the result.
499 void ccw_device_disband_start(struct ccw_device *cdev)
501 struct subchannel *sch = to_subchannel(cdev->dev.parent);
502 struct ccw_request *req = &cdev->private->req;
505 CIO_TRACE_EVENT(4, "disb");
506 CIO_HEX_EVENT(4, &cdev->private->dev_id, sizeof(cdev->private->dev_id));
508 memset(req, 0, sizeof(*req));
509 req->timeout = PGID_TIMEOUT;
510 req->maxretries = PGID_RETRIES;
511 req->lpm = sch->schib.pmcw.pam & sch->opm;
513 req->callback = disband_callback;
514 fn = SPID_FUNC_DISBAND;
515 if (cdev->private->flags.mpath)
516 fn |= SPID_FUNC_MULTI_PATH;
517 spid_build_cp(cdev, fn);
518 ccw_request_start(cdev);
521 static void stlck_build_cp(struct ccw_device *cdev, void *buf1, void *buf2)
523 struct ccw_request *req = &cdev->private->req;
524 struct ccw1 *cp = cdev->private->iccws;
526 cp[0].cmd_code = CCW_CMD_STLCK;
527 cp[0].cda = (u32) (addr_t) buf1;
529 cp[0].flags = CCW_FLAG_CC;
530 cp[1].cmd_code = CCW_CMD_RELEASE;
531 cp[1].cda = (u32) (addr_t) buf2;
537 static void stlck_callback(struct ccw_device *cdev, void *data, int rc)
539 ccw_device_stlck_done(cdev, data, rc);
543 * ccw_device_stlck_start - perform unconditional release
545 * @data: data pointer to be passed to ccw_device_stlck_done
546 * @buf1: data pointer used in channel program
547 * @buf2: data pointer used in channel program
549 * Execute a channel program on @cdev to release an existing PGID reservation.
550 * When finished, call ccw_device_stlck_done with a return code specifying the
553 void ccw_device_stlck_start(struct ccw_device *cdev, void *data, void *buf1,
556 struct subchannel *sch = to_subchannel(cdev->dev.parent);
557 struct ccw_request *req = &cdev->private->req;
559 CIO_TRACE_EVENT(4, "stlck");
560 CIO_HEX_EVENT(4, &cdev->private->dev_id, sizeof(cdev->private->dev_id));
562 memset(req, 0, sizeof(*req));
563 req->timeout = PGID_TIMEOUT;
564 req->maxretries = PGID_RETRIES;
565 req->lpm = sch->schib.pmcw.pam & sch->opm;
567 req->callback = stlck_callback;
568 stlck_build_cp(cdev, buf1, buf2);
569 ccw_request_start(cdev);