?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
rcv reorder queue bugfix
[cor_2_6_31.git] / drivers / scsi / osst.c
blobacb835837eec6213cae3f70679406570a5eba557
1 /*
2 SCSI Tape Driver for Linux version 1.1 and newer. See the accompanying
3 file Documentation/scsi/st.txt for more information.
4
5 History:
6
7 OnStream SCSI Tape support (osst) cloned from st.c by
8 Willem Riede (osst@riede.org) Feb 2000
9 Fixes ... Kurt Garloff <garloff@suse.de> Mar 2000
10
11 Rewritten from Dwayne Forsyth's SCSI tape driver by Kai Makisara.
12 Contribution and ideas from several people including (in alphabetical
13 order) Klaus Ehrenfried, Wolfgang Denk, Steve Hirsch, Andreas Koppenh"ofer,
14 Michael Leodolter, Eyal Lebedinsky, J"org Weule, and Eric Youngdale.
15
16 Copyright 1992 - 2002 Kai Makisara / 2000 - 2006 Willem Riede
17 email osst@riede.org
18
19 $Header: /cvsroot/osst/Driver/osst.c,v 1.73 2005/01/01 21:13:34 wriede Exp $
20
21 Microscopic alterations - Rik Ling, 2000/12/21
22 Last st.c sync: Tue Oct 15 22:01:04 2002 by makisara
23 Some small formal changes - aeb, 950809
24 */
25
26 static const char * cvsid = "$Id: osst.c,v 1.73 2005/01/01 21:13:34 wriede Exp $";
27 static const char * osst_version = "0.99.4";
28
29 /* The "failure to reconnect" firmware bug */
30 #define OSST_FW_NEED_POLL_MIN 10601 /*(107A)*/
31 #define OSST_FW_NEED_POLL_MAX 10704 /*(108D)*/
32 #define OSST_FW_NEED_POLL(x,d) ((x) >= OSST_FW_NEED_POLL_MIN && (x) <= OSST_FW_NEED_POLL_MAX && d->host->this_id != 7)
33
34 #include <linux/module.h>
35
36 #include <linux/fs.h>
37 #include <linux/kernel.h>
38 #include <linux/sched.h>
39 #include <linux/proc_fs.h>
40 #include <linux/mm.h>
41 #include <linux/init.h>
42 #include <linux/string.h>
43 #include <linux/errno.h>
44 #include <linux/mtio.h>
45 #include <linux/ioctl.h>
46 #include <linux/fcntl.h>
47 #include <linux/spinlock.h>
48 #include <linux/vmalloc.h>
49 #include <linux/blkdev.h>
50 #include <linux/moduleparam.h>
51 #include <linux/delay.h>
52 #include <linux/jiffies.h>
53 #include <linux/smp_lock.h>
54 #include <asm/uaccess.h>
55 #include <asm/dma.h>
56 #include <asm/system.h>
57
58 /* The driver prints some debugging information on the console if DEBUG
59 is defined and non-zero. */
60 #define DEBUG 0
61
62 /* The message level for the debug messages is currently set to KERN_NOTICE
63 so that people can easily see the messages. Later when the debugging messages
64 in the drivers are more widely classified, this may be changed to KERN_DEBUG. */
65 #define OSST_DEB_MSG KERN_NOTICE
66
67 #include <scsi/scsi.h>
68 #include <scsi/scsi_dbg.h>
69 #include <scsi/scsi_device.h>
70 #include <scsi/scsi_driver.h>
71 #include <scsi/scsi_eh.h>
72 #include <scsi/scsi_host.h>
73 #include <scsi/scsi_ioctl.h>
74
75 #define ST_KILOBYTE 1024
76
77 #include "st.h"
78 #include "osst.h"
79 #include "osst_options.h"
80 #include "osst_detect.h"
81
82 static int max_dev = 0;
83 static int write_threshold_kbs = 0;
84 static int max_sg_segs = 0;
85
86 #ifdef MODULE
87 MODULE_AUTHOR("Willem Riede");
88 MODULE_DESCRIPTION("OnStream {DI-|FW-|SC-|USB}{30|50} Tape Driver");
89 MODULE_LICENSE("GPL");
90 MODULE_ALIAS_CHARDEV_MAJOR(OSST_MAJOR);
91 MODULE_ALIAS_SCSI_DEVICE(TYPE_TAPE);
92
93 module_param(max_dev, int, 0444);
94 MODULE_PARM_DESC(max_dev, "Maximum number of OnStream Tape Drives to attach (4)");
95
96 module_param(write_threshold_kbs, int, 0644);
97 MODULE_PARM_DESC(write_threshold_kbs, "Asynchronous write threshold (KB; 32)");
98
99 module_param(max_sg_segs, int, 0644);
100 MODULE_PARM_DESC(max_sg_segs, "Maximum number of scatter/gather segments to use (9)");
101 #else
102 static struct osst_dev_parm {
103 char *name;
104 int *val;
105 } parms[] __initdata = {
106 { "max_dev", &max_dev },
107 { "write_threshold_kbs", &write_threshold_kbs },
108 { "max_sg_segs", &max_sg_segs }
109 };
110 #endif
111
112 /* Some default definitions have been moved to osst_options.h */
113 #define OSST_BUFFER_SIZE (OSST_BUFFER_BLOCKS * ST_KILOBYTE)
114 #define OSST_WRITE_THRESHOLD (OSST_WRITE_THRESHOLD_BLOCKS * ST_KILOBYTE)
115
116 /* The buffer size should fit into the 24 bits for length in the
117 6-byte SCSI read and write commands. */
118 #if OSST_BUFFER_SIZE >= (2 << 24 - 1)
119 #error "Buffer size should not exceed (2 << 24 - 1) bytes!"
120 #endif
121
122 #if DEBUG
123 static int debugging = 1;
124 /* uncomment define below to test error recovery */
125 // #define OSST_INJECT_ERRORS 1
126 #endif
127
128 /* Do not retry! The drive firmware already retries when appropriate,
129 and when it tries to tell us something, we had better listen... */
130 #define MAX_RETRIES 0
131
132 #define NO_TAPE NOT_READY
133
134 #define OSST_WAIT_POSITION_COMPLETE (HZ > 200 ? HZ / 200 : 1)
135 #define OSST_WAIT_WRITE_COMPLETE (HZ / 12)
136 #define OSST_WAIT_LONG_WRITE_COMPLETE (HZ / 2)
137
138 #define OSST_TIMEOUT (200 * HZ)
139 #define OSST_LONG_TIMEOUT (1800 * HZ)
140
141 #define TAPE_NR(x) (iminor(x) & ~(-1 << ST_MODE_SHIFT))
142 #define TAPE_MODE(x) ((iminor(x) & ST_MODE_MASK) >> ST_MODE_SHIFT)
143 #define TAPE_REWIND(x) ((iminor(x) & 0x80) == 0)
144 #define TAPE_IS_RAW(x) (TAPE_MODE(x) & (ST_NBR_MODES >> 1))
145
146 /* Internal ioctl to set both density (uppermost 8 bits) and blocksize (lower
147 24 bits) */
148 #define SET_DENS_AND_BLK 0x10001
149
150 static int osst_buffer_size = OSST_BUFFER_SIZE;
151 static int osst_write_threshold = OSST_WRITE_THRESHOLD;
152 static int osst_max_sg_segs = OSST_MAX_SG;
153 static int osst_max_dev = OSST_MAX_TAPES;
154 static int osst_nr_dev;
155
156 static struct osst_tape **os_scsi_tapes = NULL;
157 static DEFINE_RWLOCK(os_scsi_tapes_lock);
158
159 static int modes_defined = 0;
160
161 static struct osst_buffer *new_tape_buffer(int, int, int);
162 static int enlarge_buffer(struct osst_buffer *, int);
163 static void normalize_buffer(struct osst_buffer *);
164 static int append_to_buffer(const char __user *, struct osst_buffer *, int);
165 static int from_buffer(struct osst_buffer *, char __user *, int);
166 static int osst_zero_buffer_tail(struct osst_buffer *);
167 static int osst_copy_to_buffer(struct osst_buffer *, unsigned char *);
168 static int osst_copy_from_buffer(struct osst_buffer *, unsigned char *);
169
170 static int osst_probe(struct device *);
171 static int osst_remove(struct device *);
172
173 static struct scsi_driver osst_template = {
174 .owner = THIS_MODULE,
175 .gendrv = {
176 .name = "osst",
177 .probe = osst_probe,
178 .remove = osst_remove,
179 }
180 };
181
182 static int osst_int_ioctl(struct osst_tape *STp, struct osst_request ** aSRpnt,
183 unsigned int cmd_in, unsigned long arg);
184
185 static int osst_set_frame_position(struct osst_tape *STp, struct osst_request ** aSRpnt, int frame, int skip);
186
187 static int osst_get_frame_position(struct osst_tape *STp, struct osst_request ** aSRpnt);
188
189 static int osst_flush_write_buffer(struct osst_tape *STp, struct osst_request ** aSRpnt);
190
191 static int osst_write_error_recovery(struct osst_tape * STp, struct osst_request ** aSRpnt, int pending);
192
193 static inline char *tape_name(struct osst_tape *tape)
194 {
195 return tape->drive->disk_name;
196 }
197 \f
198 /* Routines that handle the interaction with mid-layer SCSI routines */
199
200
201 /* Normalize Sense */
202 static void osst_analyze_sense(struct osst_request *SRpnt, struct st_cmdstatus *s)
203 {
204 const u8 *ucp;
205 const u8 *sense = SRpnt->sense;
206
207 s->have_sense = scsi_normalize_sense(SRpnt->sense,
208 SCSI_SENSE_BUFFERSIZE, &s->sense_hdr);
209 s->flags = 0;
210
211 if (s->have_sense) {
212 s->deferred = 0;
213 s->remainder_valid =
214 scsi_get_sense_info_fld(sense, SCSI_SENSE_BUFFERSIZE, &s->uremainder64);
215 switch (sense[0] & 0x7f) {
216 case 0x71:
217 s->deferred = 1;
218 case 0x70:
219 s->fixed_format = 1;
220 s->flags = sense[2] & 0xe0;
221 break;
222 case 0x73:
223 s->deferred = 1;
224 case 0x72:
225 s->fixed_format = 0;
226 ucp = scsi_sense_desc_find(sense, SCSI_SENSE_BUFFERSIZE, 4);
227 s->flags = ucp ? (ucp[3] & 0xe0) : 0;
228 break;
229 }
230 }
231 }
232
233 /* Convert the result to success code */
234 static int osst_chk_result(struct osst_tape * STp, struct osst_request * SRpnt)
235 {
236 char *name = tape_name(STp);
237 int result = SRpnt->result;
238 u8 * sense = SRpnt->sense, scode;
239 #if DEBUG
240 const char *stp;
241 #endif
242 struct st_cmdstatus *cmdstatp;
243
244 if (!result)
245 return 0;
246
247 cmdstatp = &STp->buffer->cmdstat;
248 osst_analyze_sense(SRpnt, cmdstatp);
249
250 if (cmdstatp->have_sense)
251 scode = STp->buffer->cmdstat.sense_hdr.sense_key;
252 else
253 scode = 0;
254 #if DEBUG
255 if (debugging) {
256 printk(OSST_DEB_MSG "%s:D: Error: %x, cmd: %x %x %x %x %x %x\n",
257 name, result,
258 SRpnt->cmd[0], SRpnt->cmd[1], SRpnt->cmd[2],
259 SRpnt->cmd[3], SRpnt->cmd[4], SRpnt->cmd[5]);
260 if (scode) printk(OSST_DEB_MSG "%s:D: Sense: %02x, ASC: %02x, ASCQ: %02x\n",
261 name, scode, sense[12], sense[13]);
262 if (cmdstatp->have_sense)
263 __scsi_print_sense("osst ", SRpnt->sense, SCSI_SENSE_BUFFERSIZE);
264 }
265 else
266 #endif
267 if (cmdstatp->have_sense && (
268 scode != NO_SENSE &&
269 scode != RECOVERED_ERROR &&
270 /* scode != UNIT_ATTENTION && */
271 scode != BLANK_CHECK &&
272 scode != VOLUME_OVERFLOW &&
273 SRpnt->cmd[0] != MODE_SENSE &&
274 SRpnt->cmd[0] != TEST_UNIT_READY)) { /* Abnormal conditions for tape */
275 if (cmdstatp->have_sense) {
276 printk(KERN_WARNING "%s:W: Command with sense data:\n", name);
277 __scsi_print_sense("osst ", SRpnt->sense, SCSI_SENSE_BUFFERSIZE);
278 }
279 else {
280 static int notyetprinted = 1;
281
282 printk(KERN_WARNING
283 "%s:W: Warning %x (driver bt 0x%x, host bt 0x%x).\n",
284 name, result, driver_byte(result),
285 host_byte(result));
286 if (notyetprinted) {
287 notyetprinted = 0;
288 printk(KERN_INFO
289 "%s:I: This warning may be caused by your scsi controller,\n", name);
290 printk(KERN_INFO
291 "%s:I: it has been reported with some Buslogic cards.\n", name);
292 }
293 }
294 }
295 STp->pos_unknown |= STp->device->was_reset;
296
297 if (cmdstatp->have_sense && scode == RECOVERED_ERROR) {
298 STp->recover_count++;
299 STp->recover_erreg++;
300 #if DEBUG
301 if (debugging) {
302 if (SRpnt->cmd[0] == READ_6)
303 stp = "read";
304 else if (SRpnt->cmd[0] == WRITE_6)
305 stp = "write";
306 else
307 stp = "ioctl";
308 printk(OSST_DEB_MSG "%s:D: Recovered %s error (%d).\n", name, stp,
309 STp->recover_count);
310 }
311 #endif
312 if ((sense[2] & 0xe0) == 0)
313 return 0;
314 }
315 return (-EIO);
316 }
317
318
319 /* Wakeup from interrupt */
320 static void osst_end_async(struct request *req, int update)
321 {
322 struct osst_request *SRpnt = req->end_io_data;
323 struct osst_tape *STp = SRpnt->stp;
324 struct rq_map_data *mdata = &SRpnt->stp->buffer->map_data;
325
326 STp->buffer->cmdstat.midlevel_result = SRpnt->result = req->errors;
327 #if DEBUG
328 STp->write_pending = 0;
329 #endif
330 if (SRpnt->waiting)
331 complete(SRpnt->waiting);
332
333 if (SRpnt->bio) {
334 kfree(mdata->pages);
335 blk_rq_unmap_user(SRpnt->bio);
336 }
337
338 __blk_put_request(req->q, req);
339 }
340
341 /* osst_request memory management */
342 static struct osst_request *osst_allocate_request(void)
343 {
344 return kzalloc(sizeof(struct osst_request), GFP_KERNEL);
345 }
346
347 static void osst_release_request(struct osst_request *streq)
348 {
349 kfree(streq);
350 }
351
352 static int osst_execute(struct osst_request *SRpnt, const unsigned char *cmd,
353 int cmd_len, int data_direction, void *buffer, unsigned bufflen,
354 int use_sg, int timeout, int retries)
355 {
356 struct request *req;
357 struct page **pages = NULL;
358 struct rq_map_data *mdata = &SRpnt->stp->buffer->map_data;
359
360 int err = 0;
361 int write = (data_direction == DMA_TO_DEVICE);
362
363 req = blk_get_request(SRpnt->stp->device->request_queue, write, GFP_KERNEL);
364 if (!req)
365 return DRIVER_ERROR << 24;
366
367 req->cmd_type = REQ_TYPE_BLOCK_PC;
368 req->cmd_flags |= REQ_QUIET;
369
370 SRpnt->bio = NULL;
371
372 if (use_sg) {
373 struct scatterlist *sg, *sgl = (struct scatterlist *)buffer;
374 int i;
375
376 pages = kzalloc(use_sg * sizeof(struct page *), GFP_KERNEL);
377 if (!pages)
378 goto free_req;
379
380 for_each_sg(sgl, sg, use_sg, i)
381 pages[i] = sg_page(sg);
382
383 mdata->null_mapped = 1;
384
385 mdata->page_order = get_order(sgl[0].length);
386 mdata->nr_entries =
387 DIV_ROUND_UP(bufflen, PAGE_SIZE << mdata->page_order);
388 mdata->offset = 0;
389
390 err = blk_rq_map_user(req->q, req, mdata, NULL, bufflen, GFP_KERNEL);
391 if (err) {
392 kfree(pages);
393 goto free_req;
394 }
395 SRpnt->bio = req->bio;
396 mdata->pages = pages;
397
398 } else if (bufflen) {
399 err = blk_rq_map_kern(req->q, req, buffer, bufflen, GFP_KERNEL);
400 if (err)
401 goto free_req;
402 }
403
404 req->cmd_len = cmd_len;
405 memset(req->cmd, 0, BLK_MAX_CDB); /* ATAPI hates garbage after CDB */
406 memcpy(req->cmd, cmd, req->cmd_len);
407 req->sense = SRpnt->sense;
408 req->sense_len = 0;
409 req->timeout = timeout;
410 req->retries = retries;
411 req->end_io_data = SRpnt;
412
413 blk_execute_rq_nowait(req->q, NULL, req, 1, osst_end_async);
414 return 0;
415 free_req:
416 blk_put_request(req);
417 return DRIVER_ERROR << 24;
418 }
419
420 /* Do the scsi command. Waits until command performed if do_wait is true.
421 Otherwise osst_write_behind_check() is used to check that the command
422 has finished. */
423 static struct osst_request * osst_do_scsi(struct osst_request *SRpnt, struct osst_tape *STp,
424 unsigned char *cmd, int bytes, int direction, int timeout, int retries, int do_wait)
425 {
426 unsigned char *bp;
427 unsigned short use_sg;
428 #ifdef OSST_INJECT_ERRORS
429 static int inject = 0;
430 static int repeat = 0;
431 #endif
432 struct completion *waiting;
433
434 /* if async, make sure there's no command outstanding */
435 if (!do_wait && ((STp->buffer)->last_SRpnt)) {
436 printk(KERN_ERR "%s: Async command already active.\n",
437 tape_name(STp));
438 if (signal_pending(current))
439 (STp->buffer)->syscall_result = (-EINTR);
440 else
441 (STp->buffer)->syscall_result = (-EBUSY);
442 return NULL;
443 }
444
445 if (SRpnt == NULL) {
446 SRpnt = osst_allocate_request();
447 if (SRpnt == NULL) {
448 printk(KERN_ERR "%s: Can't allocate SCSI request.\n",
449 tape_name(STp));
450 if (signal_pending(current))
451 (STp->buffer)->syscall_result = (-EINTR);
452 else
453 (STp->buffer)->syscall_result = (-EBUSY);
454 return NULL;
455 }
456 SRpnt->stp = STp;
457 }
458
459 /* If async IO, set last_SRpnt. This ptr tells write_behind_check
460 which IO is outstanding. It's nulled out when the IO completes. */
461 if (!do_wait)
462 (STp->buffer)->last_SRpnt = SRpnt;
463
464 waiting = &STp->wait;
465 init_completion(waiting);
466 SRpnt->waiting = waiting;
467
468 use_sg = (bytes > STp->buffer->sg[0].length) ? STp->buffer->use_sg : 0;
469 if (use_sg) {
470 bp = (char *)&(STp->buffer->sg[0]);
471 if (STp->buffer->sg_segs < use_sg)
472 use_sg = STp->buffer->sg_segs;
473 }
474 else
475 bp = (STp->buffer)->b_data;
476
477 memcpy(SRpnt->cmd, cmd, sizeof(SRpnt->cmd));
478 STp->buffer->cmdstat.have_sense = 0;
479 STp->buffer->syscall_result = 0;
480
481 if (osst_execute(SRpnt, cmd, COMMAND_SIZE(cmd[0]), direction, bp, bytes,
482 use_sg, timeout, retries))
483 /* could not allocate the buffer or request was too large */
484 (STp->buffer)->syscall_result = (-EBUSY);
485 else if (do_wait) {
486 wait_for_completion(waiting);
487 SRpnt->waiting = NULL;
488 STp->buffer->syscall_result = osst_chk_result(STp, SRpnt);
489 #ifdef OSST_INJECT_ERRORS
490 if (STp->buffer->syscall_result == 0 &&
491 cmd[0] == READ_6 &&
492 cmd[4] &&
493 ( (++ inject % 83) == 29 ||
494 (STp->first_frame_position == 240
495 /* or STp->read_error_frame to fail again on the block calculated above */ &&
496 ++repeat < 3))) {
497 printk(OSST_DEB_MSG "%s:D: Injecting read error\n", tape_name(STp));
498 STp->buffer->last_result_fatal = 1;
499 }
500 #endif
501 }
502 return SRpnt;
503 }
504
505
506 /* Handle the write-behind checking (downs the semaphore) */
507 static void osst_write_behind_check(struct osst_tape *STp)
508 {
509 struct osst_buffer * STbuffer;
510
511 STbuffer = STp->buffer;
512
513 #if DEBUG
514 if (STp->write_pending)
515 STp->nbr_waits++;
516 else
517 STp->nbr_finished++;
518 #endif
519 wait_for_completion(&(STp->wait));
520 STp->buffer->last_SRpnt->waiting = NULL;
521
522 STp->buffer->syscall_result = osst_chk_result(STp, STp->buffer->last_SRpnt);
523
524 if (STp->buffer->syscall_result)
525 STp->buffer->syscall_result =
526 osst_write_error_recovery(STp, &(STp->buffer->last_SRpnt), 1);
527 else
528 STp->first_frame_position++;
529
530 osst_release_request(STp->buffer->last_SRpnt);
531
532 if (STbuffer->writing < STbuffer->buffer_bytes)
533 printk(KERN_WARNING "osst :A: write_behind_check: something left in buffer!\n");
534
535 STbuffer->last_SRpnt = NULL;
536 STbuffer->buffer_bytes -= STbuffer->writing;
537 STbuffer->writing = 0;
538
539 return;
540 }
541
542
543 \f
544 /* Onstream specific Routines */
545 /*
546 * Initialize the OnStream AUX
547 */
548 static void osst_init_aux(struct osst_tape * STp, int frame_type, int frame_seq_number,
549 int logical_blk_num, int blk_sz, int blk_cnt)
550 {
551 os_aux_t *aux = STp->buffer->aux;
552 os_partition_t *par = &aux->partition;
553 os_dat_t *dat = &aux->dat;
554
555 if (STp->raw) return;
556
557 memset(aux, 0, sizeof(*aux));
558 aux->format_id = htonl(0);
559 memcpy(aux->application_sig, "LIN4", 4);
560 aux->hdwr = htonl(0);
561 aux->frame_type = frame_type;
562
563 switch (frame_type) {
564 case OS_FRAME_TYPE_HEADER:
565 aux->update_frame_cntr = htonl(STp->update_frame_cntr);
566 par->partition_num = OS_CONFIG_PARTITION;
567 par->par_desc_ver = OS_PARTITION_VERSION;
568 par->wrt_pass_cntr = htons(0xffff);
569 /* 0-4 = reserved, 5-9 = header, 2990-2994 = header, 2995-2999 = reserved */
570 par->first_frame_ppos = htonl(0);
571 par->last_frame_ppos = htonl(0xbb7);
572 aux->frame_seq_num = htonl(0);
573 aux->logical_blk_num_high = htonl(0);
574 aux->logical_blk_num = htonl(0);
575 aux->next_mark_ppos = htonl(STp->first_mark_ppos);
576 break;
577 case OS_FRAME_TYPE_DATA:
578 case OS_FRAME_TYPE_MARKER:
579 dat->dat_sz = 8;
580 dat->reserved1 = 0;
581 dat->entry_cnt = 1;
582 dat->reserved3 = 0;
583 dat->dat_list[0].blk_sz = htonl(blk_sz);
584 dat->dat_list[0].blk_cnt = htons(blk_cnt);
585 dat->dat_list[0].flags = frame_type==OS_FRAME_TYPE_MARKER?
586 OS_DAT_FLAGS_MARK:OS_DAT_FLAGS_DATA;
587 dat->dat_list[0].reserved = 0;
588 case OS_FRAME_TYPE_EOD:
589 aux->update_frame_cntr = htonl(0);
590 par->partition_num = OS_DATA_PARTITION;
591 par->par_desc_ver = OS_PARTITION_VERSION;
592 par->wrt_pass_cntr = htons(STp->wrt_pass_cntr);
593 par->first_frame_ppos = htonl(STp->first_data_ppos);
594 par->last_frame_ppos = htonl(STp->capacity);
595 aux->frame_seq_num = htonl(frame_seq_number);
596 aux->logical_blk_num_high = htonl(0);
597 aux->logical_blk_num = htonl(logical_blk_num);
598 break;
599 default: ; /* probably FILL */
600 }
601 aux->filemark_cnt = htonl(STp->filemark_cnt);
602 aux->phys_fm = htonl(0xffffffff);
603 aux->last_mark_ppos = htonl(STp->last_mark_ppos);
604 aux->last_mark_lbn = htonl(STp->last_mark_lbn);
605 }
606
607 /*
608 * Verify that we have the correct tape frame
609 */
610 static int osst_verify_frame(struct osst_tape * STp, int frame_seq_number, int quiet)
611 {
612 char * name = tape_name(STp);
613 os_aux_t * aux = STp->buffer->aux;
614 os_partition_t * par = &(aux->partition);
615 struct st_partstat * STps = &(STp->ps[STp->partition]);
616 int blk_cnt, blk_sz, i;
617
618 if (STp->raw) {
619 if (STp->buffer->syscall_result) {
620 for (i=0; i < STp->buffer->sg_segs; i++)
621 memset(page_address(sg_page(&STp->buffer->sg[i])),
622 0, STp->buffer->sg[i].length);
623 strcpy(STp->buffer->b_data, "READ ERROR ON FRAME");
624 } else
625 STp->buffer->buffer_bytes = OS_FRAME_SIZE;
626 return 1;
627 }
628 if (STp->buffer->syscall_result) {
629 #if DEBUG
630 printk(OSST_DEB_MSG "%s:D: Skipping frame, read error\n", name);
631 #endif
632 return 0;
633 }
634 if (ntohl(aux->format_id) != 0) {
635 #if DEBUG
636 printk(OSST_DEB_MSG "%s:D: Skipping frame, format_id %u\n", name, ntohl(aux->format_id));
637 #endif
638 goto err_out;
639 }
640 if (memcmp(aux->application_sig, STp->application_sig, 4) != 0 &&
641 (memcmp(aux->application_sig, "LIN3", 4) != 0 || STp->linux_media_version != 4)) {
642 #if DEBUG
643 printk(OSST_DEB_MSG "%s:D: Skipping frame, incorrect application signature\n", name);
644 #endif
645 goto err_out;
646 }
647 if (par->partition_num != OS_DATA_PARTITION) {
648 if (!STp->linux_media || STp->linux_media_version != 2) {
649 #if DEBUG
650 printk(OSST_DEB_MSG "%s:D: Skipping frame, partition num %d\n",
651 name, par->partition_num);
652 #endif
653 goto err_out;
654 }
655 }
656 if (par->par_desc_ver != OS_PARTITION_VERSION) {
657 #if DEBUG
658 printk(OSST_DEB_MSG "%s:D: Skipping frame, partition version %d\n", name, par->par_desc_ver);
659 #endif
660 goto err_out;
661 }
662 if (ntohs(par->wrt_pass_cntr) != STp->wrt_pass_cntr) {
663 #if DEBUG
664 printk(OSST_DEB_MSG "%s:D: Skipping frame, wrt_pass_cntr %d (expected %d)\n",
665 name, ntohs(par->wrt_pass_cntr), STp->wrt_pass_cntr);
666 #endif
667 goto err_out;
668 }
669 if (aux->frame_type != OS_FRAME_TYPE_DATA &&
670 aux->frame_type != OS_FRAME_TYPE_EOD &&
671 aux->frame_type != OS_FRAME_TYPE_MARKER) {
672 if (!quiet) {
673 #if DEBUG
674 printk(OSST_DEB_MSG "%s:D: Skipping frame, frame type %x\n", name, aux->frame_type);
675 #endif
676 }
677 goto err_out;
678 }
679 if (aux->frame_type == OS_FRAME_TYPE_EOD &&
680 STp->first_frame_position < STp->eod_frame_ppos) {
681 printk(KERN_INFO "%s:I: Skipping premature EOD frame %d\n", name,
682 STp->first_frame_position);
683 goto err_out;
684 }
685 if (frame_seq_number != -1 && ntohl(aux->frame_seq_num) != frame_seq_number) {
686 if (!quiet) {
687 #if DEBUG
688 printk(OSST_DEB_MSG "%s:D: Skipping frame, sequence number %u (expected %d)\n",
689 name, ntohl(aux->frame_seq_num), frame_seq_number);
690 #endif
691 }
692 goto err_out;
693 }
694 if (aux->frame_type == OS_FRAME_TYPE_MARKER) {
695 STps->eof = ST_FM_HIT;
696
697 i = ntohl(aux->filemark_cnt);
698 if (STp->header_cache != NULL && i < OS_FM_TAB_MAX && (i > STp->filemark_cnt ||
699 STp->first_frame_position - 1 != ntohl(STp->header_cache->dat_fm_tab.fm_tab_ent[i]))) {
700 #if DEBUG
701 printk(OSST_DEB_MSG "%s:D: %s filemark %d at frame pos %d\n", name,
702 STp->header_cache->dat_fm_tab.fm_tab_ent[i] == 0?"Learned":"Corrected",
703 i, STp->first_frame_position - 1);
704 #endif
705 STp->header_cache->dat_fm_tab.fm_tab_ent[i] = htonl(STp->first_frame_position - 1);
706 if (i >= STp->filemark_cnt)
707 STp->filemark_cnt = i+1;
708 }
709 }
710 if (aux->frame_type == OS_FRAME_TYPE_EOD) {
711 STps->eof = ST_EOD_1;
712 STp->frame_in_buffer = 1;
713 }
714 if (aux->frame_type == OS_FRAME_TYPE_DATA) {
715 blk_cnt = ntohs(aux->dat.dat_list[0].blk_cnt);
716 blk_sz = ntohl(aux->dat.dat_list[0].blk_sz);
717 STp->buffer->buffer_bytes = blk_cnt * blk_sz;
718 STp->buffer->read_pointer = 0;
719 STp->frame_in_buffer = 1;
720
721 /* See what block size was used to write file */
722 if (STp->block_size != blk_sz && blk_sz > 0) {
723 printk(KERN_INFO
724 "%s:I: File was written with block size %d%c, currently %d%c, adjusted to match.\n",
725 name, blk_sz<1024?blk_sz:blk_sz/1024,blk_sz<1024?'b':'k',
726 STp->block_size<1024?STp->block_size:STp->block_size/1024,
727 STp->block_size<1024?'b':'k');
728 STp->block_size = blk_sz;
729 STp->buffer->buffer_blocks = OS_DATA_SIZE / blk_sz;
730 }
731 STps->eof = ST_NOEOF;
732 }
733 STp->frame_seq_number = ntohl(aux->frame_seq_num);
734 STp->logical_blk_num = ntohl(aux->logical_blk_num);
735 return 1;
736
737 err_out:
738 if (STp->read_error_frame == 0)
739 STp->read_error_frame = STp->first_frame_position - 1;
740 return 0;
741 }
742
743 /*
744 * Wait for the unit to become Ready
745 */
746 static int osst_wait_ready(struct osst_tape * STp, struct osst_request ** aSRpnt,
747 unsigned timeout, int initial_delay)
748 {
749 unsigned char cmd[MAX_COMMAND_SIZE];
750 struct osst_request * SRpnt;
751 unsigned long startwait = jiffies;
752 #if DEBUG
753 int dbg = debugging;
754 char * name = tape_name(STp);
755
756 printk(OSST_DEB_MSG "%s:D: Reached onstream wait ready\n", name);
757 #endif
758
759 if (initial_delay > 0)
760 msleep(jiffies_to_msecs(initial_delay));
761
762 memset(cmd, 0, MAX_COMMAND_SIZE);
763 cmd[0] = TEST_UNIT_READY;
764
765 SRpnt = osst_do_scsi(*aSRpnt, STp, cmd, 0, DMA_NONE, STp->timeout, MAX_RETRIES, 1);
766 *aSRpnt = SRpnt;
767 if (!SRpnt) return (-EBUSY);
768
769 while ( STp->buffer->syscall_result && time_before(jiffies, startwait + timeout*HZ) &&
770 (( SRpnt->sense[2] == 2 && SRpnt->sense[12] == 4 &&
771 (SRpnt->sense[13] == 1 || SRpnt->sense[13] == 8) ) ||
772 ( SRpnt->sense[2] == 6 && SRpnt->sense[12] == 0x28 &&
773 SRpnt->sense[13] == 0 ) )) {
774 #if DEBUG
775 if (debugging) {
776 printk(OSST_DEB_MSG "%s:D: Sleeping in onstream wait ready\n", name);
777 printk(OSST_DEB_MSG "%s:D: Turning off debugging for a while\n", name);
778 debugging = 0;
779 }
780 #endif
781 msleep(100);
782
783 memset(cmd, 0, MAX_COMMAND_SIZE);
784 cmd[0] = TEST_UNIT_READY;
785
786 SRpnt = osst_do_scsi(SRpnt, STp, cmd, 0, DMA_NONE, STp->timeout, MAX_RETRIES, 1);
787 }
788 *aSRpnt = SRpnt;
789 #if DEBUG
790 debugging = dbg;
791 #endif
792 if ( STp->buffer->syscall_result &&
793 osst_write_error_recovery(STp, aSRpnt, 0) ) {
794 #if DEBUG
795 printk(OSST_DEB_MSG "%s:D: Abnormal exit from onstream wait ready\n", name);
796 printk(OSST_DEB_MSG "%s:D: Result = %d, Sense: 0=%02x, 2=%02x, 12=%02x, 13=%02x\n", name,
797 STp->buffer->syscall_result, SRpnt->sense[0], SRpnt->sense[2],
798 SRpnt->sense[12], SRpnt->sense[13]);
799 #endif
800 return (-EIO);
801 }
802 #if DEBUG
803 printk(OSST_DEB_MSG "%s:D: Normal exit from onstream wait ready\n", name);
804 #endif
805 return 0;
806 }
807
808 /*
809 * Wait for a tape to be inserted in the unit
810 */
811 static int osst_wait_for_medium(struct osst_tape * STp, struct osst_request ** aSRpnt, unsigned timeout)
812 {
813 unsigned char cmd[MAX_COMMAND_SIZE];
814 struct osst_request * SRpnt;
815 unsigned long startwait = jiffies;
816 #if DEBUG
817 int dbg = debugging;
818 char * name = tape_name(STp);
819
820 printk(OSST_DEB_MSG "%s:D: Reached onstream wait for medium\n", name);
821 #endif
822
823 memset(cmd, 0, MAX_COMMAND_SIZE);
824 cmd[0] = TEST_UNIT_READY;
825
826 SRpnt = osst_do_scsi(*aSRpnt, STp, cmd, 0, DMA_NONE, STp->timeout, MAX_RETRIES, 1);
827 *aSRpnt = SRpnt;
828 if (!SRpnt) return (-EBUSY);
829
830 while ( STp->buffer->syscall_result && time_before(jiffies, startwait + timeout*HZ) &&
831 SRpnt->sense[2] == 2 && SRpnt->sense[12] == 0x3a && SRpnt->sense[13] == 0 ) {
832 #if DEBUG
833 if (debugging) {
834 printk(OSST_DEB_MSG "%s:D: Sleeping in onstream wait medium\n", name);
835 printk(OSST_DEB_MSG "%s:D: Turning off debugging for a while\n", name);
836 debugging = 0;
837 }
838 #endif
839 msleep(100);
840
841 memset(cmd, 0, MAX_COMMAND_SIZE);
842 cmd[0] = TEST_UNIT_READY;
843
844 SRpnt = osst_do_scsi(SRpnt, STp, cmd, 0, DMA_NONE, STp->timeout, MAX_RETRIES, 1);
845 }
846 *aSRpnt = SRpnt;
847 #if DEBUG
848 debugging = dbg;
849 #endif
850 if ( STp->buffer->syscall_result && SRpnt->sense[2] != 2 &&
851 SRpnt->sense[12] != 4 && SRpnt->sense[13] == 1) {
852 #if DEBUG
853 printk(OSST_DEB_MSG "%s:D: Abnormal exit from onstream wait medium\n", name);
854 printk(OSST_DEB_MSG "%s:D: Result = %d, Sense: 0=%02x, 2=%02x, 12=%02x, 13=%02x\n", name,
855 STp->buffer->syscall_result, SRpnt->sense[0], SRpnt->sense[2],
856 SRpnt->sense[12], SRpnt->sense[13]);
857 #endif
858 return 0;
859 }
860 #if DEBUG
861 printk(OSST_DEB_MSG "%s:D: Normal exit from onstream wait medium\n", name);
862 #endif
863 return 1;
864 }
865
866 static int osst_position_tape_and_confirm(struct osst_tape * STp, struct osst_request ** aSRpnt, int frame)
867 {
868 int retval;
869
870 osst_wait_ready(STp, aSRpnt, 15 * 60, 0); /* TODO - can this catch a write error? */
871 retval = osst_set_frame_position(STp, aSRpnt, frame, 0);
872 if (retval) return (retval);
873 osst_wait_ready(STp, aSRpnt, 15 * 60, OSST_WAIT_POSITION_COMPLETE);
874 return (osst_get_frame_position(STp, aSRpnt));
875 }
876
877 /*
878 * Wait for write(s) to complete
879 */
880 static int osst_flush_drive_buffer(struct osst_tape * STp, struct osst_request ** aSRpnt)
881 {
882 unsigned char cmd[MAX_COMMAND_SIZE];
883 struct osst_request * SRpnt;
884 int result = 0;
885 int delay = OSST_WAIT_WRITE_COMPLETE;
886 #if DEBUG
887 char * name = tape_name(STp);
888
889 printk(OSST_DEB_MSG "%s:D: Reached onstream flush drive buffer (write filemark)\n", name);
890 #endif
891
892 memset(cmd, 0, MAX_COMMAND_SIZE);
893 cmd[0] = WRITE_FILEMARKS;
894 cmd[1] = 1;
895
896 SRpnt = osst_do_scsi(*aSRpnt, STp, cmd, 0, DMA_NONE, STp->timeout, MAX_RETRIES, 1);
897 *aSRpnt = SRpnt;
898 if (!SRpnt) return (-EBUSY);
899 if (STp->buffer->syscall_result) {
900 if ((SRpnt->sense[2] & 0x0f) == 2 && SRpnt->sense[12] == 4) {
901 if (SRpnt->sense[13] == 8) {
902 delay = OSST_WAIT_LONG_WRITE_COMPLETE;
903 }
904 } else
905 result = osst_write_error_recovery(STp, aSRpnt, 0);
906 }
907 result |= osst_wait_ready(STp, aSRpnt, 5 * 60, delay);
908 STp->ps[STp->partition].rw = OS_WRITING_COMPLETE;
909
910 return (result);
911 }
912
913 #define OSST_POLL_PER_SEC 10
914 static int osst_wait_frame(struct osst_tape * STp, struct osst_request ** aSRpnt, int curr, int minlast, int to)
915 {
916 unsigned long startwait = jiffies;
917 char * name = tape_name(STp);
918 #if DEBUG
919 char notyetprinted = 1;
920 #endif
921 if (minlast >= 0 && STp->ps[STp->partition].rw != ST_READING)
922 printk(KERN_ERR "%s:A: Waiting for frame without having initialized read!\n", name);
923
924 while (time_before (jiffies, startwait + to*HZ))
925 {
926 int result;
927 result = osst_get_frame_position(STp, aSRpnt);
928 if (result == -EIO)
929 if ((result = osst_write_error_recovery(STp, aSRpnt, 0)) == 0)
930 return 0; /* successful recovery leaves drive ready for frame */
931 if (result < 0) break;
932 if (STp->first_frame_position == curr &&
933 ((minlast < 0 &&
934 (signed)STp->last_frame_position > (signed)curr + minlast) ||
935 (minlast >= 0 && STp->cur_frames > minlast)
936 ) && result >= 0)
937 {
938 #if DEBUG
939 if (debugging || time_after_eq(jiffies, startwait + 2*HZ/OSST_POLL_PER_SEC))
940 printk (OSST_DEB_MSG
941 "%s:D: Succ wait f fr %i (>%i): %i-%i %i (%i): %3li.%li s\n",
942 name, curr, curr+minlast, STp->first_frame_position,
943 STp->last_frame_position, STp->cur_frames,
944 result, (jiffies-startwait)/HZ,
945 (((jiffies-startwait)%HZ)*10)/HZ);
946 #endif
947 return 0;
948 }
949 #if DEBUG
950 if (time_after_eq(jiffies, startwait + 2*HZ/OSST_POLL_PER_SEC) && notyetprinted)
951 {
952 printk (OSST_DEB_MSG "%s:D: Wait for frame %i (>%i): %i-%i %i (%i)\n",
953 name, curr, curr+minlast, STp->first_frame_position,
954 STp->last_frame_position, STp->cur_frames, result);
955 notyetprinted--;
956 }
957 #endif
958 msleep(1000 / OSST_POLL_PER_SEC);
959 }
960 #if DEBUG
961 printk (OSST_DEB_MSG "%s:D: Fail wait f fr %i (>%i): %i-%i %i: %3li.%li s\n",
962 name, curr, curr+minlast, STp->first_frame_position,
963 STp->last_frame_position, STp->cur_frames,
964 (jiffies-startwait)/HZ, (((jiffies-startwait)%HZ)*10)/HZ);
965 #endif
966 return -EBUSY;
967 }
968
969 static int osst_recover_wait_frame(struct osst_tape * STp, struct osst_request ** aSRpnt, int writing)
970 {
971 struct osst_request * SRpnt;
972 unsigned char cmd[MAX_COMMAND_SIZE];
973 unsigned long startwait = jiffies;
974 int retval = 1;
975 char * name = tape_name(STp);
976
977 if (writing) {
978 char mybuf[24];
979 char * olddata = STp->buffer->b_data;
980 int oldsize = STp->buffer->buffer_size;
981
982 /* write zero fm then read pos - if shows write error, try to recover - if no progress, wait */
983
984 memset(cmd, 0, MAX_COMMAND_SIZE);
985 cmd[0] = WRITE_FILEMARKS;
986 cmd[1] = 1;
987 SRpnt = osst_do_scsi(*aSRpnt, STp, cmd, 0, DMA_NONE, STp->timeout,
988 MAX_RETRIES, 1);
989
990 while (retval && time_before (jiffies, startwait + 5*60*HZ)) {
991
992 if (STp->buffer->syscall_result && (SRpnt->sense[2] & 0x0f) != 2) {
993
994 /* some failure - not just not-ready */
995 retval = osst_write_error_recovery(STp, aSRpnt, 0);
996 break;
997 }
998 schedule_timeout_interruptible(HZ / OSST_POLL_PER_SEC);
999
1000 STp->buffer->b_data = mybuf; STp->buffer->buffer_size = 24;
1001 memset(cmd, 0, MAX_COMMAND_SIZE);
1002 cmd[0] = READ_POSITION;
1003
1004 SRpnt = osst_do_scsi(SRpnt, STp, cmd, 20, DMA_FROM_DEVICE, STp->timeout,
1005 MAX_RETRIES, 1);
1006
1007 retval = ( STp->buffer->syscall_result || (STp->buffer)->b_data[15] > 25 );
1008 STp->buffer->b_data = olddata; STp->buffer->buffer_size = oldsize;
1009 }
1010 if (retval)
1011 printk(KERN_ERR "%s:E: Device did not succeed to write buffered data\n", name);
1012 } else
1013 /* TODO - figure out which error conditions can be handled */
1014 if (STp->buffer->syscall_result)
1015 printk(KERN_WARNING
1016 "%s:W: Recover_wait_frame(read) cannot handle %02x:%02x:%02x\n", name,
1017 (*aSRpnt)->sense[ 2] & 0x0f,
1018 (*aSRpnt)->sense[12],
1019 (*aSRpnt)->sense[13]);
1020
1021 return retval;
1022 }
1023
1024 /*
1025 * Read the next OnStream tape frame at the current location
1026 */
1027 static int osst_read_frame(struct osst_tape * STp, struct osst_request ** aSRpnt, int timeout)
1028 {
1029 unsigned char cmd[MAX_COMMAND_SIZE];
1030 struct osst_request * SRpnt;
1031 int retval = 0;
1032 #if DEBUG
1033 os_aux_t * aux = STp->buffer->aux;
1034 char * name = tape_name(STp);
1035 #endif
1036
1037 if (STp->poll)
1038 if (osst_wait_frame (STp, aSRpnt, STp->first_frame_position, 0, timeout))
1039 retval = osst_recover_wait_frame(STp, aSRpnt, 0);
1040
1041 memset(cmd, 0, MAX_COMMAND_SIZE);
1042 cmd[0] = READ_6;
1043 cmd[1] = 1;
1044 cmd[4] = 1;
1045
1046 #if DEBUG
1047 if (debugging)
1048 printk(OSST_DEB_MSG "%s:D: Reading frame from OnStream tape\n", name);
1049 #endif
1050 SRpnt = osst_do_scsi(*aSRpnt, STp, cmd, OS_FRAME_SIZE, DMA_FROM_DEVICE,
1051 STp->timeout, MAX_RETRIES, 1);
1052 *aSRpnt = SRpnt;
1053 if (!SRpnt)
1054 return (-EBUSY);
1055
1056 if ((STp->buffer)->syscall_result) {
1057 retval = 1;
1058 if (STp->read_error_frame == 0) {
1059 STp->read_error_frame = STp->first_frame_position;
1060 #if DEBUG
1061 printk(OSST_DEB_MSG "%s:D: Recording read error at %d\n", name, STp->read_error_frame);
1062 #endif
1063 }
1064 #if DEBUG
1065 if (debugging)
1066 printk(OSST_DEB_MSG "%s:D: Sense: %2x %2x %2x %2x %2x %2x %2x %2x\n",
1067 name,
1068 SRpnt->sense[0], SRpnt->sense[1],
1069 SRpnt->sense[2], SRpnt->sense[3],
1070 SRpnt->sense[4], SRpnt->sense[5],
1071 SRpnt->sense[6], SRpnt->sense[7]);
1072 #endif
1073 }
1074 else
1075 STp->first_frame_position++;
1076 #if DEBUG
1077 if (debugging) {
1078 char sig[8]; int i;
1079 for (i=0;i<4;i++)
1080 sig[i] = aux->application_sig[i]<32?'^':aux->application_sig[i];
1081 sig[4] = '\0';
1082 printk(OSST_DEB_MSG
1083 "%s:D: AUX: %s UpdFrCt#%d Wpass#%d %s FrSeq#%d LogBlk#%d Qty=%d Sz=%d\n", name, sig,
1084 ntohl(aux->update_frame_cntr), ntohs(aux->partition.wrt_pass_cntr),
1085 aux->frame_type==1?"EOD":aux->frame_type==2?"MARK":
1086 aux->frame_type==8?"HEADR":aux->frame_type==0x80?"DATA":"FILL",
1087 ntohl(aux->frame_seq_num), ntohl(aux->logical_blk_num),
1088 ntohs(aux->dat.dat_list[0].blk_cnt), ntohl(aux->dat.dat_list[0].blk_sz) );
1089 if (aux->frame_type==2)
1090 printk(OSST_DEB_MSG "%s:D: mark_cnt=%d, last_mark_ppos=%d, last_mark_lbn=%d\n", name,
1091 ntohl(aux->filemark_cnt), ntohl(aux->last_mark_ppos), ntohl(aux->last_mark_lbn));
1092 printk(OSST_DEB_MSG "%s:D: Exit read frame from OnStream tape with code %d\n", name, retval);
1093 }
1094 #endif
1095 return (retval);
1096 }
1097
1098 static int osst_initiate_read(struct osst_tape * STp, struct osst_request ** aSRpnt)
1099 {
1100 struct st_partstat * STps = &(STp->ps[STp->partition]);
1101 struct osst_request * SRpnt ;
1102 unsigned char cmd[MAX_COMMAND_SIZE];
1103 int retval = 0;
1104 char * name = tape_name(STp);
1105
1106 if (STps->rw != ST_READING) { /* Initialize read operation */
1107 if (STps->rw == ST_WRITING || STp->dirty) {
1108 STp->write_type = OS_WRITE_DATA;
1109 osst_flush_write_buffer(STp, aSRpnt);
1110 osst_flush_drive_buffer(STp, aSRpnt);
1111 }
1112 STps->rw = ST_READING;
1113 STp->frame_in_buffer = 0;
1114
1115 /*
1116 * Issue a read 0 command to get the OnStream drive
1117 * read frames into its buffer.
1118 */
1119 memset(cmd, 0, MAX_COMMAND_SIZE);
1120 cmd[0] = READ_6;
1121 cmd[1] = 1;
1122
1123 #if DEBUG
1124 printk(OSST_DEB_MSG "%s:D: Start Read Ahead on OnStream tape\n", name);
1125 #endif
1126 SRpnt = osst_do_scsi(*aSRpnt, STp, cmd, 0, DMA_NONE, STp->timeout, MAX_RETRIES, 1);
1127 *aSRpnt = SRpnt;
1128 if ((retval = STp->buffer->syscall_result))
1129 printk(KERN_WARNING "%s:W: Error starting read ahead\n", name);
1130 }
1131
1132 return retval;
1133 }
1134
1135 static int osst_get_logical_frame(struct osst_tape * STp, struct osst_request ** aSRpnt,
1136 int frame_seq_number, int quiet)
1137 {
1138 struct st_partstat * STps = &(STp->ps[STp->partition]);
1139 char * name = tape_name(STp);
1140 int cnt = 0,
1141 bad = 0,
1142 past = 0,
1143 x,
1144 position;
1145
1146 /*
1147 * If we want just any frame (-1) and there is a frame in the buffer, return it
1148 */
1149 if (frame_seq_number == -1 && STp->frame_in_buffer) {
1150 #if DEBUG
1151 printk(OSST_DEB_MSG "%s:D: Frame %d still in buffer\n", name, STp->frame_seq_number);
1152 #endif
1153 return (STps->eof);
1154 }
1155 /*
1156 * Search and wait for the next logical tape frame
1157 */
1158 while (1) {
1159 if (cnt++ > 400) {
1160 printk(KERN_ERR "%s:E: Couldn't find logical frame %d, aborting\n",
1161 name, frame_seq_number);
1162 if (STp->read_error_frame) {
1163 osst_set_frame_position(STp, aSRpnt, STp->read_error_frame, 0);
1164 #if DEBUG
1165 printk(OSST_DEB_MSG "%s:D: Repositioning tape to bad frame %d\n",
1166 name, STp->read_error_frame);
1167 #endif
1168 STp->read_error_frame = 0;
1169 STp->abort_count++;
1170 }
1171 return (-EIO);
1172 }
1173 #if DEBUG
1174 if (debugging)
1175 printk(OSST_DEB_MSG "%s:D: Looking for frame %d, attempt %d\n",
1176 name, frame_seq_number, cnt);
1177 #endif
1178 if ( osst_initiate_read(STp, aSRpnt)
1179 || ( (!STp->frame_in_buffer) && osst_read_frame(STp, aSRpnt, 30) ) ) {
1180 if (STp->raw)
1181 return (-EIO);
1182 position = osst_get_frame_position(STp, aSRpnt);
1183 if (position >= 0xbae && position < 0xbb8)
1184 position = 0xbb8;
1185 else if (position > STp->eod_frame_ppos || ++bad == 10) {
1186 position = STp->read_error_frame - 1;
1187 bad = 0;
1188 }
1189 else {
1190 position += 29;
1191 cnt += 19;
1192 }
1193 #if DEBUG
1194 printk(OSST_DEB_MSG "%s:D: Bad frame detected, positioning tape to block %d\n",
1195 name, position);
1196 #endif
1197 osst_set_frame_position(STp, aSRpnt, position, 0);
1198 continue;
1199 }
1200 if (osst_verify_frame(STp, frame_seq_number, quiet))
1201 break;
1202 if (osst_verify_frame(STp, -1, quiet)) {
1203 x = ntohl(STp->buffer->aux->frame_seq_num);
1204 if (STp->fast_open) {
1205 printk(KERN_WARNING
1206 "%s:W: Found logical frame %d instead of %d after fast open\n",
1207 name, x, frame_seq_number);
1208 STp->header_ok = 0;
1209 STp->read_error_frame = 0;
1210 return (-EIO);
1211 }
1212 if (x > frame_seq_number) {
1213 if (++past > 3) {
1214 /* positioning backwards did not bring us to the desired frame */
1215 position = STp->read_error_frame - 1;
1216 }
1217 else {
1218 position = osst_get_frame_position(STp, aSRpnt)
1219 + frame_seq_number - x - 1;
1220
1221 if (STp->first_frame_position >= 3000 && position < 3000)
1222 position -= 10;
1223 }
1224 #if DEBUG
1225 printk(OSST_DEB_MSG
1226 "%s:D: Found logical frame %d while looking for %d: back up %d\n",
1227 name, x, frame_seq_number,
1228 STp->first_frame_position - position);
1229 #endif
1230 osst_set_frame_position(STp, aSRpnt, position, 0);
1231 cnt += 10;
1232 }
1233 else
1234 past = 0;
1235 }
1236 if (osst_get_frame_position(STp, aSRpnt) == 0xbaf) {
1237 #if DEBUG
1238 printk(OSST_DEB_MSG "%s:D: Skipping config partition\n", name);
1239 #endif
1240 osst_set_frame_position(STp, aSRpnt, 0xbb8, 0);
1241 cnt--;
1242 }
1243 STp->frame_in_buffer = 0;
1244 }
1245 if (cnt > 1) {
1246 STp->recover_count++;
1247 STp->recover_erreg++;
1248 printk(KERN_WARNING "%s:I: Don't worry, Read error at position %d recovered\n",
1249 name, STp->read_error_frame);
1250 }
1251 STp->read_count++;
1252
1253 #if DEBUG
1254 if (debugging || STps->eof)
1255 printk(OSST_DEB_MSG
1256 "%s:D: Exit get logical frame (%d=>%d) from OnStream tape with code %d\n",
1257 name, frame_seq_number, STp->frame_seq_number, STps->eof);
1258 #endif
1259 STp->fast_open = 0;
1260 STp->read_error_frame = 0;
1261 return (STps->eof);
1262 }
1263
1264 static int osst_seek_logical_blk(struct osst_tape * STp, struct osst_request ** aSRpnt, int logical_blk_num)
1265 {
1266 struct st_partstat * STps = &(STp->ps[STp->partition]);
1267 char * name = tape_name(STp);
1268 int retries = 0;
1269 int frame_seq_estimate, ppos_estimate, move;
1270
1271 if (logical_blk_num < 0) logical_blk_num = 0;
1272 #if DEBUG
1273 printk(OSST_DEB_MSG "%s:D: Seeking logical block %d (now at %d, size %d%c)\n",
1274 name, logical_blk_num, STp->logical_blk_num,
1275 STp->block_size<1024?STp->block_size:STp->block_size/1024,
1276 STp->block_size<1024?'b':'k');
1277 #endif
1278 /* Do we know where we are? */
1279 if (STps->drv_block >= 0) {
1280 move = logical_blk_num - STp->logical_blk_num;
1281 if (move < 0) move -= (OS_DATA_SIZE / STp->block_size) - 1;
1282 move /= (OS_DATA_SIZE / STp->block_size);
1283 frame_seq_estimate = STp->frame_seq_number + move;
1284 } else
1285 frame_seq_estimate = logical_blk_num * STp->block_size / OS_DATA_SIZE;
1286
1287 if (frame_seq_estimate < 2980) ppos_estimate = frame_seq_estimate + 10;
1288 else ppos_estimate = frame_seq_estimate + 20;
1289 while (++retries < 10) {
1290 if (ppos_estimate > STp->eod_frame_ppos-2) {
1291 frame_seq_estimate += STp->eod_frame_ppos - 2 - ppos_estimate;
1292 ppos_estimate = STp->eod_frame_ppos - 2;
1293 }
1294 if (frame_seq_estimate < 0) {
1295 frame_seq_estimate = 0;
1296 ppos_estimate = 10;
1297 }
1298 osst_set_frame_position(STp, aSRpnt, ppos_estimate, 0);
1299 if (osst_get_logical_frame(STp, aSRpnt, frame_seq_estimate, 1) >= 0) {
1300 /* we've located the estimated frame, now does it have our block? */
1301 if (logical_blk_num < STp->logical_blk_num ||
1302 logical_blk_num >= STp->logical_blk_num + ntohs(STp->buffer->aux->dat.dat_list[0].blk_cnt)) {
1303 if (STps->eof == ST_FM_HIT)
1304 move = logical_blk_num < STp->logical_blk_num? -2 : 1;
1305 else {
1306 move = logical_blk_num - STp->logical_blk_num;
1307 if (move < 0) move -= (OS_DATA_SIZE / STp->block_size) - 1;
1308 move /= (OS_DATA_SIZE / STp->block_size);
1309 }
1310 if (!move) move = logical_blk_num > STp->logical_blk_num ? 1 : -1;
1311 #if DEBUG
1312 printk(OSST_DEB_MSG
1313 "%s:D: Seek retry %d at ppos %d fsq %d (est %d) lbn %d (need %d) move %d\n",
1314 name, retries, ppos_estimate, STp->frame_seq_number, frame_seq_estimate,
1315 STp->logical_blk_num, logical_blk_num, move);
1316 #endif
1317 frame_seq_estimate += move;
1318 ppos_estimate += move;
1319 continue;
1320 } else {
1321 STp->buffer->read_pointer = (logical_blk_num - STp->logical_blk_num) * STp->block_size;
1322 STp->buffer->buffer_bytes -= STp->buffer->read_pointer;
1323 STp->logical_blk_num = logical_blk_num;
1324 #if DEBUG
1325 printk(OSST_DEB_MSG
1326 "%s:D: Seek success at ppos %d fsq %d in_buf %d, bytes %d, ptr %d*%d\n",
1327 name, ppos_estimate, STp->frame_seq_number, STp->frame_in_buffer,
1328 STp->buffer->buffer_bytes, STp->buffer->read_pointer / STp->block_size,
1329 STp->block_size);
1330 #endif
1331 STps->drv_file = ntohl(STp->buffer->aux->filemark_cnt);
1332 if (STps->eof == ST_FM_HIT) {
1333 STps->drv_file++;
1334 STps->drv_block = 0;
1335 } else {
1336 STps->drv_block = ntohl(STp->buffer->aux->last_mark_lbn)?
1337 STp->logical_blk_num -
1338 (STps->drv_file ? ntohl(STp->buffer->aux->last_mark_lbn) + 1 : 0):
1339 -1;
1340 }
1341 STps->eof = (STp->first_frame_position >= STp->eod_frame_ppos)?ST_EOD:ST_NOEOF;
1342 return 0;
1343 }
1344 }
1345 if (osst_get_logical_frame(STp, aSRpnt, -1, 1) < 0)
1346 goto error;
1347 /* we are not yet at the estimated frame, adjust our estimate of its physical position */
1348 #if DEBUG
1349 printk(OSST_DEB_MSG "%s:D: Seek retry %d at ppos %d fsq %d (est %d) lbn %d (need %d)\n",
1350 name, retries, ppos_estimate, STp->frame_seq_number, frame_seq_estimate,
1351 STp->logical_blk_num, logical_blk_num);
1352 #endif
1353 if (frame_seq_estimate != STp->frame_seq_number)
1354 ppos_estimate += frame_seq_estimate - STp->frame_seq_number;
1355 else
1356 break;
1357 }
1358 error:
1359 printk(KERN_ERR "%s:E: Couldn't seek to logical block %d (at %d), %d retries\n",
1360 name, logical_blk_num, STp->logical_blk_num, retries);
1361 return (-EIO);
1362 }
1363
1364 /* The values below are based on the OnStream frame payload size of 32K == 2**15,
1365 * that is, OSST_FRAME_SHIFT + OSST_SECTOR_SHIFT must be 15. With a minimum block
1366 * size of 512 bytes, we need to be able to resolve 32K/512 == 64 == 2**6 positions
1367 * inside each frame. Finaly, OSST_SECTOR_MASK == 2**OSST_FRAME_SHIFT - 1.
1368 */
1369 #define OSST_FRAME_SHIFT 6
1370 #define OSST_SECTOR_SHIFT 9
1371 #define OSST_SECTOR_MASK 0x03F
1372
1373 static int osst_get_sector(struct osst_tape * STp, struct osst_request ** aSRpnt)
1374 {
1375 int sector;
1376 #if DEBUG
1377 char * name = tape_name(STp);
1378
1379 printk(OSST_DEB_MSG
1380 "%s:D: Positioned at ppos %d, frame %d, lbn %d, file %d, blk %d, %cptr %d, eof %d\n",
1381 name, STp->first_frame_position, STp->frame_seq_number, STp->logical_blk_num,
1382 STp->ps[STp->partition].drv_file, STp->ps[STp->partition].drv_block,
1383 STp->ps[STp->partition].rw == ST_WRITING?'w':'r',
1384 STp->ps[STp->partition].rw == ST_WRITING?STp->buffer->buffer_bytes:
1385 STp->buffer->read_pointer, STp->ps[STp->partition].eof);
1386 #endif
1387 /* do we know where we are inside a file? */
1388 if (STp->ps[STp->partition].drv_block >= 0) {
1389 sector = (STp->frame_in_buffer ? STp->first_frame_position-1 :
1390 STp->first_frame_position) << OSST_FRAME_SHIFT;
1391 if (STp->ps[STp->partition].rw == ST_WRITING)
1392 sector |= (STp->buffer->buffer_bytes >> OSST_SECTOR_SHIFT) & OSST_SECTOR_MASK;
1393 else
1394 sector |= (STp->buffer->read_pointer >> OSST_SECTOR_SHIFT) & OSST_SECTOR_MASK;
1395 } else {
1396 sector = osst_get_frame_position(STp, aSRpnt);
1397 if (sector > 0)
1398 sector <<= OSST_FRAME_SHIFT;
1399 }
1400 return sector;
1401 }
1402
1403 static int osst_seek_sector(struct osst_tape * STp, struct osst_request ** aSRpnt, int sector)
1404 {
1405 struct st_partstat * STps = &(STp->ps[STp->partition]);
1406 int frame = sector >> OSST_FRAME_SHIFT,
1407 offset = (sector & OSST_SECTOR_MASK) << OSST_SECTOR_SHIFT,
1408 r;
1409 #if DEBUG
1410 char * name = tape_name(STp);
1411
1412 printk(OSST_DEB_MSG "%s:D: Seeking sector %d in frame %d at offset %d\n",
1413 name, sector, frame, offset);
1414 #endif
1415 if (frame < 0 || frame >= STp->capacity) return (-ENXIO);
1416
1417 if (frame <= STp->first_data_ppos) {
1418 STp->frame_seq_number = STp->logical_blk_num = STps->drv_file = STps->drv_block = 0;
1419 return (osst_set_frame_position(STp, aSRpnt, frame, 0));
1420 }
1421 r = osst_set_frame_position(STp, aSRpnt, offset?frame:frame-1, 0);
1422 if (r < 0) return r;
1423
1424 r = osst_get_logical_frame(STp, aSRpnt, -1, 1);
1425 if (r < 0) return r;
1426
1427 if (osst_get_frame_position(STp, aSRpnt) != (offset?frame+1:frame)) return (-EIO);
1428
1429 if (offset) {
1430 STp->logical_blk_num += offset / STp->block_size;
1431 STp->buffer->read_pointer = offset;
1432 STp->buffer->buffer_bytes -= offset;
1433 } else {
1434 STp->frame_seq_number++;
1435 STp->frame_in_buffer = 0;
1436 STp->logical_blk_num += ntohs(STp->buffer->aux->dat.dat_list[0].blk_cnt);
1437 STp->buffer->buffer_bytes = STp->buffer->read_pointer = 0;
1438 }
1439 STps->drv_file = ntohl(STp->buffer->aux->filemark_cnt);
1440 if (STps->eof == ST_FM_HIT) {
1441 STps->drv_file++;
1442 STps->drv_block = 0;
1443 } else {
1444 STps->drv_block = ntohl(STp->buffer->aux->last_mark_lbn)?
1445 STp->logical_blk_num -
1446 (STps->drv_file ? ntohl(STp->buffer->aux->last_mark_lbn) + 1 : 0):
1447 -1;
1448 }
1449 STps->eof = (STp->first_frame_position >= STp->eod_frame_ppos)?ST_EOD:ST_NOEOF;
1450 #if DEBUG
1451 printk(OSST_DEB_MSG
1452 "%s:D: Now positioned at ppos %d, frame %d, lbn %d, file %d, blk %d, rptr %d, eof %d\n",
1453 name, STp->first_frame_position, STp->frame_seq_number, STp->logical_blk_num,
1454 STps->drv_file, STps->drv_block, STp->buffer->read_pointer, STps->eof);
1455 #endif
1456 return 0;
1457 }
1458
1459 /*
1460 * Read back the drive's internal buffer contents, as a part
1461 * of the write error recovery mechanism for old OnStream
1462 * firmware revisions.
1463 * Precondition for this function to work: all frames in the
1464 * drive's buffer must be of one type (DATA, MARK or EOD)!
1465 */
1466 static int osst_read_back_buffer_and_rewrite(struct osst_tape * STp, struct osst_request ** aSRpnt,
1467 unsigned int frame, unsigned int skip, int pending)
1468 {
1469 struct osst_request * SRpnt = * aSRpnt;
1470 unsigned char * buffer, * p;
1471 unsigned char cmd[MAX_COMMAND_SIZE];
1472 int flag, new_frame, i;
1473 int nframes = STp->cur_frames;
1474 int blks_per_frame = ntohs(STp->buffer->aux->dat.dat_list[0].blk_cnt);
1475 int frame_seq_number = ntohl(STp->buffer->aux->frame_seq_num)
1476 - (nframes + pending - 1);
1477 int logical_blk_num = ntohl(STp->buffer->aux->logical_blk_num)
1478 - (nframes + pending - 1) * blks_per_frame;
1479 char * name = tape_name(STp);
1480 unsigned long startwait = jiffies;
1481 #if DEBUG
1482 int dbg = debugging;
1483 #endif
1484
1485 if ((buffer = (unsigned char *)vmalloc((nframes + 1) * OS_DATA_SIZE)) == NULL)
1486 return (-EIO);
1487
1488 printk(KERN_INFO "%s:I: Reading back %d frames from drive buffer%s\n",
1489 name, nframes, pending?" and one that was pending":"");
1490
1491 osst_copy_from_buffer(STp->buffer, (p = &buffer[nframes * OS_DATA_SIZE]));
1492 #if DEBUG
1493 if (pending && debugging)
1494 printk(OSST_DEB_MSG "%s:D: Pending frame %d (lblk %d), data %02x %02x %02x %02x\n",
1495 name, frame_seq_number + nframes,
1496 logical_blk_num + nframes * blks_per_frame,
1497 p[0], p[1], p[2], p[3]);
1498 #endif
1499 for (i = 0, p = buffer; i < nframes; i++, p += OS_DATA_SIZE) {
1500
1501 memset(cmd, 0, MAX_COMMAND_SIZE);
1502 cmd[0] = 0x3C; /* Buffer Read */
1503 cmd[1] = 6; /* Retrieve Faulty Block */
1504 cmd[7] = 32768 >> 8;
1505 cmd[8] = 32768 & 0xff;
1506
1507 SRpnt = osst_do_scsi(SRpnt, STp, cmd, OS_FRAME_SIZE, DMA_FROM_DEVICE,
1508 STp->timeout, MAX_RETRIES, 1);
1509
1510 if ((STp->buffer)->syscall_result || !SRpnt) {
1511 printk(KERN_ERR "%s:E: Failed to read frame back from OnStream buffer\n", name);
1512 vfree(buffer);
1513 *aSRpnt = SRpnt;
1514 return (-EIO);
1515 }
1516 osst_copy_from_buffer(STp->buffer, p);
1517 #if DEBUG
1518 if (debugging)
1519 printk(OSST_DEB_MSG "%s:D: Read back logical frame %d, data %02x %02x %02x %02x\n",
1520 name, frame_seq_number + i, p[0], p[1], p[2], p[3]);
1521 #endif
1522 }
1523 *aSRpnt = SRpnt;
1524 osst_get_frame_position(STp, aSRpnt);
1525
1526 #if DEBUG
1527 printk(OSST_DEB_MSG "%s:D: Frames left in buffer: %d\n", name, STp->cur_frames);
1528 #endif
1529 /* Write synchronously so we can be sure we're OK again and don't have to recover recursively */
1530 /* In the header we don't actually re-write the frames that fail, just the ones after them */
1531
1532 for (flag=1, new_frame=frame, p=buffer, i=0; i < nframes + pending; ) {
1533
1534 if (flag) {
1535 if (STp->write_type == OS_WRITE_HEADER) {
1536 i += skip;
1537 p += skip * OS_DATA_SIZE;
1538 }
1539 else if (new_frame < 2990 && new_frame+skip+nframes+pending >= 2990)
1540 new_frame = 3000-i;
1541 else
1542 new_frame += skip;
1543 #if DEBUG
1544 printk(OSST_DEB_MSG "%s:D: Position to frame %d, write fseq %d\n",
1545 name, new_frame+i, frame_seq_number+i);
1546 #endif
1547 osst_set_frame_position(STp, aSRpnt, new_frame + i, 0);
1548 osst_wait_ready(STp, aSRpnt, 60, OSST_WAIT_POSITION_COMPLETE);
1549 osst_get_frame_position(STp, aSRpnt);
1550 SRpnt = * aSRpnt;
1551
1552 if (new_frame > frame + 1000) {
1553 printk(KERN_ERR "%s:E: Failed to find writable tape media\n", name);
1554 vfree(buffer);
1555 return (-EIO);
1556 }
1557 if ( i >= nframes + pending ) break;
1558 flag = 0;
1559 }
1560 osst_copy_to_buffer(STp->buffer, p);
1561 /*
1562 * IMPORTANT: for error recovery to work, _never_ queue frames with mixed frame type!
1563 */
1564 osst_init_aux(STp, STp->buffer->aux->frame_type, frame_seq_number+i,
1565 logical_blk_num + i*blks_per_frame,
1566 ntohl(STp->buffer->aux->dat.dat_list[0].blk_sz), blks_per_frame);
1567 memset(cmd, 0, MAX_COMMAND_SIZE);
1568 cmd[0] = WRITE_6;
1569 cmd[1] = 1;
1570 cmd[4] = 1;
1571
1572 #if DEBUG
1573 if (debugging)
1574 printk(OSST_DEB_MSG
1575 "%s:D: About to write frame %d, seq %d, lbn %d, data %02x %02x %02x %02x\n",
1576 name, new_frame+i, frame_seq_number+i, logical_blk_num + i*blks_per_frame,
1577 p[0], p[1], p[2], p[3]);
1578 #endif
1579 SRpnt = osst_do_scsi(SRpnt, STp, cmd, OS_FRAME_SIZE, DMA_TO_DEVICE,
1580 STp->timeout, MAX_RETRIES, 1);
1581
1582 if (STp->buffer->syscall_result)
1583 flag = 1;
1584 else {
1585 p += OS_DATA_SIZE; i++;
1586
1587 /* if we just sent the last frame, wait till all successfully written */
1588 if ( i == nframes + pending ) {
1589 #if DEBUG
1590 printk(OSST_DEB_MSG "%s:D: Check re-write successful\n", name);
1591 #endif
1592 memset(cmd, 0, MAX_COMMAND_SIZE);
1593 cmd[0] = WRITE_FILEMARKS;
1594 cmd[1] = 1;
1595 SRpnt = osst_do_scsi(SRpnt, STp, cmd, 0, DMA_NONE,
1596 STp->timeout, MAX_RETRIES, 1);
1597 #if DEBUG
1598 if (debugging) {
1599 printk(OSST_DEB_MSG "%s:D: Sleeping in re-write wait ready\n", name);
1600 printk(OSST_DEB_MSG "%s:D: Turning off debugging for a while\n", name);
1601 debugging = 0;
1602 }
1603 #endif
1604 flag = STp->buffer->syscall_result;
1605 while ( !flag && time_before(jiffies, startwait + 60*HZ) ) {
1606
1607 memset(cmd, 0, MAX_COMMAND_SIZE);
1608 cmd[0] = TEST_UNIT_READY;
1609
1610 SRpnt = osst_do_scsi(SRpnt, STp, cmd, 0, DMA_NONE, STp->timeout,
1611 MAX_RETRIES, 1);
1612
1613 if (SRpnt->sense[2] == 2 && SRpnt->sense[12] == 4 &&
1614 (SRpnt->sense[13] == 1 || SRpnt->sense[13] == 8)) {
1615 /* in the process of becoming ready */
1616 msleep(100);
1617 continue;
1618 }
1619 if (STp->buffer->syscall_result)
1620 flag = 1;
1621 break;
1622 }
1623 #if DEBUG
1624 debugging = dbg;
1625 printk(OSST_DEB_MSG "%s:D: Wait re-write finished\n", name);
1626 #endif
1627 }
1628 }
1629 *aSRpnt = SRpnt;
1630 if (flag) {
1631 if ((SRpnt->sense[ 2] & 0x0f) == 13 &&
1632 SRpnt->sense[12] == 0 &&
1633 SRpnt->sense[13] == 2) {
1634 printk(KERN_ERR "%s:E: Volume overflow in write error recovery\n", name);
1635 vfree(buffer);
1636 return (-EIO); /* hit end of tape = fail */
1637 }
1638 i = ((SRpnt->sense[3] << 24) |
1639 (SRpnt->sense[4] << 16) |
1640 (SRpnt->sense[5] << 8) |
1641 SRpnt->sense[6] ) - new_frame;
1642 p = &buffer[i * OS_DATA_SIZE];
1643 #if DEBUG
1644 printk(OSST_DEB_MSG "%s:D: Additional write error at %d\n", name, new_frame+i);
1645 #endif
1646 osst_get_frame_position(STp, aSRpnt);
1647 #if DEBUG
1648 printk(OSST_DEB_MSG "%s:D: reported frame positions: host = %d, tape = %d, buffer = %d\n",
1649 name, STp->first_frame_position, STp->last_frame_position, STp->cur_frames);
1650 #endif
1651 }
1652 }
1653 if (flag) {
1654 /* error recovery did not successfully complete */
1655 printk(KERN_ERR "%s:D: Write error recovery failed in %s\n", name,
1656 STp->write_type == OS_WRITE_HEADER?"header":"body");
1657 }
1658 if (!pending)
1659 osst_copy_to_buffer(STp->buffer, p); /* so buffer content == at entry in all cases */
1660 vfree(buffer);
1661 return 0;
1662 }
1663
1664 static int osst_reposition_and_retry(struct osst_tape * STp, struct osst_request ** aSRpnt,
1665 unsigned int frame, unsigned int skip, int pending)
1666 {
1667 unsigned char cmd[MAX_COMMAND_SIZE];
1668 struct osst_request * SRpnt;
1669 char * name = tape_name(STp);
1670 int expected = 0;
1671 int attempts = 1000 / skip;
1672 int flag = 1;
1673 unsigned long startwait = jiffies;
1674 #if DEBUG
1675 int dbg = debugging;
1676 #endif
1677
1678 while (attempts && time_before(jiffies, startwait + 60*HZ)) {
1679 if (flag) {
1680 #if DEBUG
1681 debugging = dbg;
1682 #endif
1683 if (frame < 2990 && frame+skip+STp->cur_frames+pending >= 2990)
1684 frame = 3000-skip;
1685 expected = frame+skip+STp->cur_frames+pending;
1686 #if DEBUG
1687 printk(OSST_DEB_MSG "%s:D: Position to fppos %d, re-write from fseq %d\n",
1688 name, frame+skip, STp->frame_seq_number-STp->cur_frames-pending);
1689 #endif
1690 osst_set_frame_position(STp, aSRpnt, frame + skip, 1);
1691 flag = 0;
1692 attempts--;
1693 schedule_timeout_interruptible(msecs_to_jiffies(100));
1694 }
1695 if (osst_get_frame_position(STp, aSRpnt) < 0) { /* additional write error */
1696 #if DEBUG
1697 printk(OSST_DEB_MSG "%s:D: Addl error, host %d, tape %d, buffer %d\n",
1698 name, STp->first_frame_position,
1699 STp->last_frame_position, STp->cur_frames);
1700 #endif
1701 frame = STp->last_frame_position;
1702 flag = 1;
1703 continue;
1704 }
1705 if (pending && STp->cur_frames < 50) {
1706
1707 memset(cmd, 0, MAX_COMMAND_SIZE);
1708 cmd[0] = WRITE_6;
1709 cmd[1] = 1;
1710 cmd[4] = 1;
1711 #if DEBUG
1712 printk(OSST_DEB_MSG "%s:D: About to write pending fseq %d at fppos %d\n",
1713 name, STp->frame_seq_number-1, STp->first_frame_position);
1714 #endif
1715 SRpnt = osst_do_scsi(*aSRpnt, STp, cmd, OS_FRAME_SIZE, DMA_TO_DEVICE,
1716 STp->timeout, MAX_RETRIES, 1);
1717 *aSRpnt = SRpnt;
1718
1719 if (STp->buffer->syscall_result) { /* additional write error */
1720 if ((SRpnt->sense[ 2] & 0x0f) == 13 &&
1721 SRpnt->sense[12] == 0 &&
1722 SRpnt->sense[13] == 2) {
1723 printk(KERN_ERR
1724 "%s:E: Volume overflow in write error recovery\n",
1725 name);
1726 break; /* hit end of tape = fail */
1727 }
1728 flag = 1;
1729 }
1730 else
1731 pending = 0;
1732
1733 continue;
1734 }
1735 if (STp->cur_frames == 0) {
1736 #if DEBUG
1737 debugging = dbg;
1738 printk(OSST_DEB_MSG "%s:D: Wait re-write finished\n", name);
1739 #endif
1740 if (STp->first_frame_position != expected) {
1741 printk(KERN_ERR "%s:A: Actual position %d - expected %d\n",
1742 name, STp->first_frame_position, expected);
1743 return (-EIO);
1744 }
1745 return 0;
1746 }
1747 #if DEBUG
1748 if (debugging) {
1749 printk(OSST_DEB_MSG "%s:D: Sleeping in re-write wait ready\n", name);
1750 printk(OSST_DEB_MSG "%s:D: Turning off debugging for a while\n", name);
1751 debugging = 0;
1752 }
1753 #endif
1754 schedule_timeout_interruptible(msecs_to_jiffies(100));
1755 }
1756 printk(KERN_ERR "%s:E: Failed to find valid tape media\n", name);
1757 #if DEBUG
1758 debugging = dbg;
1759 #endif
1760 return (-EIO);
1761 }
1762
1763 /*
1764 * Error recovery algorithm for the OnStream tape.
1765 */
1766
1767 static int osst_write_error_recovery(struct osst_tape * STp, struct osst_request ** aSRpnt, int pending)
1768 {
1769 struct osst_request * SRpnt = * aSRpnt;
1770 struct st_partstat * STps = & STp->ps[STp->partition];
1771 char * name = tape_name(STp);
1772 int retval = 0;
1773 int rw_state;
1774 unsigned int frame, skip;
1775
1776 rw_state = STps->rw;
1777
1778 if ((SRpnt->sense[ 2] & 0x0f) != 3
1779 || SRpnt->sense[12] != 12
1780 || SRpnt->sense[13] != 0) {
1781 #if DEBUG
1782 printk(OSST_DEB_MSG "%s:D: Write error recovery cannot handle %02x:%02x:%02x\n", name,
1783 SRpnt->sense[2], SRpnt->sense[12], SRpnt->sense[13]);
1784 #endif
1785 return (-EIO);
1786 }
1787 frame = (SRpnt->sense[3] << 24) |
1788 (SRpnt->sense[4] << 16) |
1789 (SRpnt->sense[5] << 8) |
1790 SRpnt->sense[6];
1791 skip = SRpnt->sense[9];
1792
1793 #if DEBUG
1794 printk(OSST_DEB_MSG "%s:D: Detected physical bad frame at %u, advised to skip %d\n", name, frame, skip);
1795 #endif
1796 osst_get_frame_position(STp, aSRpnt);
1797 #if DEBUG
1798 printk(OSST_DEB_MSG "%s:D: reported frame positions: host = %d, tape = %d\n",
1799 name, STp->first_frame_position, STp->last_frame_position);
1800 #endif
1801 switch (STp->write_type) {
1802 case OS_WRITE_DATA:
1803 case OS_WRITE_EOD:
1804 case OS_WRITE_NEW_MARK:
1805 printk(KERN_WARNING
1806 "%s:I: Relocating %d buffered logical frames from position %u to %u\n",
1807 name, STp->cur_frames, frame, (frame + skip > 3000 && frame < 3000)?3000:frame + skip);
1808 if (STp->os_fw_rev >= 10600)
1809 retval = osst_reposition_and_retry(STp, aSRpnt, frame, skip, pending);
1810 else
1811 retval = osst_read_back_buffer_and_rewrite(STp, aSRpnt, frame, skip, pending);
1812 printk(KERN_WARNING "%s:%s: %sWrite error%srecovered\n", name,
1813 retval?"E" :"I",
1814 retval?"" :"Don't worry, ",
1815 retval?" not ":" ");
1816 break;
1817 case OS_WRITE_LAST_MARK:
1818 printk(KERN_ERR "%s:E: Bad frame in update last marker, fatal\n", name);
1819 osst_set_frame_position(STp, aSRpnt, frame + STp->cur_frames + pending, 0);
1820 retval = -EIO;
1821 break;
1822 case OS_WRITE_HEADER:
1823 printk(KERN_WARNING "%s:I: Bad frame in header partition, skipped\n", name);
1824 retval = osst_read_back_buffer_and_rewrite(STp, aSRpnt, frame, 1, pending);
1825 break;
1826 default:
1827 printk(KERN_INFO "%s:I: Bad frame in filler, ignored\n", name);
1828 osst_set_frame_position(STp, aSRpnt, frame + STp->cur_frames + pending, 0);
1829 }
1830 osst_get_frame_position(STp, aSRpnt);
1831 #if DEBUG
1832 printk(OSST_DEB_MSG "%s:D: Positioning complete, cur_frames %d, pos %d, tape pos %d\n",
1833 name, STp->cur_frames, STp->first_frame_position, STp->last_frame_position);
1834 printk(OSST_DEB_MSG "%s:D: next logical frame to write: %d\n", name, STp->logical_blk_num);
1835 #endif
1836 if (retval == 0) {
1837 STp->recover_count++;
1838 STp->recover_erreg++;
1839 } else
1840 STp->abort_count++;
1841
1842 STps->rw = rw_state;
1843 return retval;
1844 }
1845
1846 static int osst_space_over_filemarks_backward(struct osst_tape * STp, struct osst_request ** aSRpnt,
1847 int mt_op, int mt_count)
1848 {
1849 char * name = tape_name(STp);
1850 int cnt;
1851 int last_mark_ppos = -1;
1852
1853 #if DEBUG
1854 printk(OSST_DEB_MSG "%s:D: Reached space_over_filemarks_backwards %d %d\n", name, mt_op, mt_count);
1855 #endif
1856 if (osst_get_logical_frame(STp, aSRpnt, -1, 0) < 0) {
1857 #if DEBUG
1858 printk(OSST_DEB_MSG "%s:D: Couldn't get logical blk num in space_filemarks_bwd\n", name);
1859 #endif
1860 return -EIO;
1861 }
1862 if (STp->linux_media_version >= 4) {
1863 /*
1864 * direct lookup in header filemark list
1865 */
1866 cnt = ntohl(STp->buffer->aux->filemark_cnt);
1867 if (STp->header_ok &&
1868 STp->header_cache != NULL &&
1869 (cnt - mt_count) >= 0 &&
1870 (cnt - mt_count) < OS_FM_TAB_MAX &&
1871 (cnt - mt_count) < STp->filemark_cnt &&
1872 STp->header_cache->dat_fm_tab.fm_tab_ent[cnt-1] == STp->buffer->aux->last_mark_ppos)
1873
1874 last_mark_ppos = ntohl(STp->header_cache->dat_fm_tab.fm_tab_ent[cnt - mt_count]);
1875 #if DEBUG
1876 if (STp->header_cache == NULL || (cnt - mt_count) < 0 || (cnt - mt_count) >= OS_FM_TAB_MAX)
1877 printk(OSST_DEB_MSG "%s:D: Filemark lookup fail due to %s\n", name,
1878 STp->header_cache == NULL?"lack of header cache":"count out of range");
1879 else
1880 printk(OSST_DEB_MSG "%s:D: Filemark lookup: prev mark %d (%s), skip %d to %d\n",
1881 name, cnt,
1882 ((cnt == -1 && ntohl(STp->buffer->aux->last_mark_ppos) == -1) ||
1883 (STp->header_cache->dat_fm_tab.fm_tab_ent[cnt-1] ==
1884 STp->buffer->aux->last_mark_ppos))?"match":"error",
1885 mt_count, last_mark_ppos);
1886 #endif
1887 if (last_mark_ppos > 10 && last_mark_ppos < STp->eod_frame_ppos) {
1888 osst_position_tape_and_confirm(STp, aSRpnt, last_mark_ppos);
1889 if (osst_get_logical_frame(STp, aSRpnt, -1, 0) < 0) {
1890 #if DEBUG
1891 printk(OSST_DEB_MSG
1892 "%s:D: Couldn't get logical blk num in space_filemarks\n", name);
1893 #endif
1894 return (-EIO);
1895 }
1896 if (STp->buffer->aux->frame_type != OS_FRAME_TYPE_MARKER) {
1897 printk(KERN_WARNING "%s:W: Expected to find marker at ppos %d, not found\n",
1898 name, last_mark_ppos);
1899 return (-EIO);
1900 }
1901 goto found;
1902 }
1903 #if DEBUG
1904 printk(OSST_DEB_MSG "%s:D: Reverting to scan filemark backwards\n", name);
1905 #endif
1906 }
1907 cnt = 0;
1908 while (cnt != mt_count) {
1909 last_mark_ppos = ntohl(STp->buffer->aux->last_mark_ppos);
1910 if (last_mark_ppos == -1)
1911 return (-EIO);
1912 #if DEBUG
1913 printk(OSST_DEB_MSG "%s:D: Positioning to last mark at %d\n", name, last_mark_ppos);
1914 #endif
1915 osst_position_tape_and_confirm(STp, aSRpnt, last_mark_ppos);
1916 cnt++;
1917 if (osst_get_logical_frame(STp, aSRpnt, -1, 0) < 0) {
1918 #if DEBUG
1919 printk(OSST_DEB_MSG "%s:D: Couldn't get logical blk num in space_filemarks\n", name);
1920 #endif
1921 return (-EIO);
1922 }
1923 if (STp->buffer->aux->frame_type != OS_FRAME_TYPE_MARKER) {
1924 printk(KERN_WARNING "%s:W: Expected to find marker at ppos %d, not found\n",
1925 name, last_mark_ppos);
1926 return (-EIO);
1927 }
1928 }
1929 found:
1930 if (mt_op == MTBSFM) {
1931 STp->frame_seq_number++;
1932 STp->frame_in_buffer = 0;
1933 STp->buffer->buffer_bytes = 0;
1934 STp->buffer->read_pointer = 0;
1935 STp->logical_blk_num += ntohs(STp->buffer->aux->dat.dat_list[0].blk_cnt);
1936 }
1937 return 0;
1938 }
1939
1940 /*
1941 * ADRL 1.1 compatible "slow" space filemarks fwd version
1942 *
1943 * Just scans for the filemark sequentially.
1944 */
1945 static int osst_space_over_filemarks_forward_slow(struct osst_tape * STp, struct osst_request ** aSRpnt,
1946 int mt_op, int mt_count)
1947 {
1948 int cnt = 0;
1949 #if DEBUG
1950 char * name = tape_name(STp);
1951
1952 printk(OSST_DEB_MSG "%s:D: Reached space_over_filemarks_forward_slow %d %d\n", name, mt_op, mt_count);
1953 #endif
1954 if (osst_get_logical_frame(STp, aSRpnt, -1, 0) < 0) {
1955 #if DEBUG
1956 printk(OSST_DEB_MSG "%s:D: Couldn't get logical blk num in space_filemarks_fwd\n", name);
1957 #endif
1958 return (-EIO);
1959 }
1960 while (1) {
1961 if (osst_get_logical_frame(STp, aSRpnt, -1, 0) < 0) {
1962 #if DEBUG
1963 printk(OSST_DEB_MSG "%s:D: Couldn't get logical blk num in space_filemarks\n", name);
1964 #endif
1965 return (-EIO);
1966 }
1967 if (STp->buffer->aux->frame_type == OS_FRAME_TYPE_MARKER)
1968 cnt++;
1969 if (STp->buffer->aux->frame_type == OS_FRAME_TYPE_EOD) {
1970 #if DEBUG
1971 printk(OSST_DEB_MSG "%s:D: space_fwd: EOD reached\n", name);
1972 #endif
1973 if (STp->first_frame_position > STp->eod_frame_ppos+1) {
1974 #if DEBUG
1975 printk(OSST_DEB_MSG "%s:D: EOD position corrected (%d=>%d)\n",
1976 name, STp->eod_frame_ppos, STp->first_frame_position-1);
1977 #endif
1978 STp->eod_frame_ppos = STp->first_frame_position-1;
1979 }
1980 return (-EIO);
1981 }
1982 if (cnt == mt_count)
1983 break;
1984 STp->frame_in_buffer = 0;
1985 }
1986 if (mt_op == MTFSF) {
1987 STp->frame_seq_number++;
1988 STp->frame_in_buffer = 0;
1989 STp->buffer->buffer_bytes = 0;
1990 STp->buffer->read_pointer = 0;
1991 STp->logical_blk_num += ntohs(STp->buffer->aux->dat.dat_list[0].blk_cnt);
1992 }
1993 return 0;
1994 }
1995
1996 /*
1997 * Fast linux specific version of OnStream FSF
1998 */
1999 static int osst_space_over_filemarks_forward_fast(struct osst_tape * STp, struct osst_request ** aSRpnt,
2000 int mt_op, int mt_count)
2001 {
2002 char * name = tape_name(STp);
2003 int cnt = 0,
2004 next_mark_ppos = -1;
2005
2006 #if DEBUG
2007 printk(OSST_DEB_MSG "%s:D: Reached space_over_filemarks_forward_fast %d %d\n", name, mt_op, mt_count);
2008 #endif
2009 if (osst_get_logical_frame(STp, aSRpnt, -1, 0) < 0) {
2010 #if DEBUG
2011 printk(OSST_DEB_MSG "%s:D: Couldn't get logical blk num in space_filemarks_fwd\n", name);
2012 #endif
2013 return (-EIO);
2014 }
2015
2016 if (STp->linux_media_version >= 4) {
2017 /*
2018 * direct lookup in header filemark list
2019 */
2020 cnt = ntohl(STp->buffer->aux->filemark_cnt) - 1;
2021 if (STp->header_ok &&
2022 STp->header_cache != NULL &&
2023 (cnt + mt_count) < OS_FM_TAB_MAX &&
2024 (cnt + mt_count) < STp->filemark_cnt &&
2025 ((cnt == -1 && ntohl(STp->buffer->aux->last_mark_ppos) == -1) ||
2026 (STp->header_cache->dat_fm_tab.fm_tab_ent[cnt] == STp->buffer->aux->last_mark_ppos)))
2027
2028 next_mark_ppos = ntohl(STp->header_cache->dat_fm_tab.fm_tab_ent[cnt + mt_count]);
2029 #if DEBUG
2030 if (STp->header_cache == NULL || (cnt + mt_count) >= OS_FM_TAB_MAX)
2031 printk(OSST_DEB_MSG "%s:D: Filemark lookup fail due to %s\n", name,
2032 STp->header_cache == NULL?"lack of header cache":"count out of range");
2033 else
2034 printk(OSST_DEB_MSG "%s:D: Filemark lookup: prev mark %d (%s), skip %d to %d\n",
2035 name, cnt,
2036 ((cnt == -1 && ntohl(STp->buffer->aux->last_mark_ppos) == -1) ||
2037 (STp->header_cache->dat_fm_tab.fm_tab_ent[cnt] ==
2038 STp->buffer->aux->last_mark_ppos))?"match":"error",
2039 mt_count, next_mark_ppos);
2040 #endif
2041 if (next_mark_ppos <= 10 || next_mark_ppos > STp->eod_frame_ppos) {
2042 #if DEBUG
2043 printk(OSST_DEB_MSG "%s:D: Reverting to slow filemark space\n", name);
2044 #endif
2045 return osst_space_over_filemarks_forward_slow(STp, aSRpnt, mt_op, mt_count);
2046 } else {
2047 osst_position_tape_and_confirm(STp, aSRpnt, next_mark_ppos);
2048 if (osst_get_logical_frame(STp, aSRpnt, -1, 0) < 0) {
2049 #if DEBUG
2050 printk(OSST_DEB_MSG "%s:D: Couldn't get logical blk num in space_filemarks\n",
2051 name);
2052 #endif
2053 return (-EIO);
2054 }
2055 if (STp->buffer->aux->frame_type != OS_FRAME_TYPE_MARKER) {
2056 printk(KERN_WARNING "%s:W: Expected to find marker at ppos %d, not found\n",
2057 name, next_mark_ppos);
2058 return (-EIO);
2059 }
2060 if (ntohl(STp->buffer->aux->filemark_cnt) != cnt + mt_count) {
2061 printk(KERN_WARNING "%s:W: Expected to find marker %d at ppos %d, not %d\n",
2062 name, cnt+mt_count, next_mark_ppos,
2063 ntohl(STp->buffer->aux->filemark_cnt));
2064 return (-EIO);
2065 }
2066 }
2067 } else {
2068 /*
2069 * Find nearest (usually previous) marker, then jump from marker to marker
2070 */
2071 while (1) {
2072 if (STp->buffer->aux->frame_type == OS_FRAME_TYPE_MARKER)
2073 break;
2074 if (STp->buffer->aux->frame_type == OS_FRAME_TYPE_EOD) {
2075 #if DEBUG
2076 printk(OSST_DEB_MSG "%s:D: space_fwd: EOD reached\n", name);
2077 #endif
2078 return (-EIO);
2079 }
2080 if (ntohl(STp->buffer->aux->filemark_cnt) == 0) {
2081 if (STp->first_mark_ppos == -1) {
2082 #if DEBUG
2083 printk(OSST_DEB_MSG "%s:D: Reverting to slow filemark space\n", name);
2084 #endif
2085 return osst_space_over_filemarks_forward_slow(STp, aSRpnt, mt_op, mt_count);
2086 }
2087 osst_position_tape_and_confirm(STp, aSRpnt, STp->first_mark_ppos);
2088 if (osst_get_logical_frame(STp, aSRpnt, -1, 0) < 0) {
2089 #if DEBUG
2090 printk(OSST_DEB_MSG
2091 "%s:D: Couldn't get logical blk num in space_filemarks_fwd_fast\n",
2092 name);
2093 #endif
2094 return (-EIO);
2095 }
2096 if (STp->buffer->aux->frame_type != OS_FRAME_TYPE_MARKER) {
2097 printk(KERN_WARNING "%s:W: Expected to find filemark at %d\n",
2098 name, STp->first_mark_ppos);
2099 return (-EIO);
2100 }
2101 } else {
2102 if (osst_space_over_filemarks_backward(STp, aSRpnt, MTBSF, 1) < 0)
2103 return (-EIO);
2104 mt_count++;
2105 }
2106 }
2107 cnt++;
2108 while (cnt != mt_count) {
2109 next_mark_ppos = ntohl(STp->buffer->aux->next_mark_ppos);
2110 if (!next_mark_ppos || next_mark_ppos > STp->eod_frame_ppos) {
2111 #if DEBUG
2112 printk(OSST_DEB_MSG "%s:D: Reverting to slow filemark space\n", name);
2113 #endif
2114 return osst_space_over_filemarks_forward_slow(STp, aSRpnt, mt_op, mt_count - cnt);
2115 }
2116 #if DEBUG
2117 else printk(OSST_DEB_MSG "%s:D: Positioning to next mark at %d\n", name, next_mark_ppos);
2118 #endif
2119 osst_position_tape_and_confirm(STp, aSRpnt, next_mark_ppos);
2120 cnt++;
2121 if (osst_get_logical_frame(STp, aSRpnt, -1, 0) < 0) {
2122 #if DEBUG
2123 printk(OSST_DEB_MSG "%s:D: Couldn't get logical blk num in space_filemarks\n",
2124 name);
2125 #endif
2126 return (-EIO);
2127 }
2128 if (STp->buffer->aux->frame_type != OS_FRAME_TYPE_MARKER) {
2129 printk(KERN_WARNING "%s:W: Expected to find marker at ppos %d, not found\n",
2130 name, next_mark_ppos);
2131 return (-EIO);
2132 }
2133 }
2134 }
2135 if (mt_op == MTFSF) {
2136 STp->frame_seq_number++;
2137 STp->frame_in_buffer = 0;
2138 STp->buffer->buffer_bytes = 0;
2139 STp->buffer->read_pointer = 0;
2140 STp->logical_blk_num += ntohs(STp->buffer->aux->dat.dat_list[0].blk_cnt);
2141 }
2142 return 0;
2143 }
2144
2145 /*
2146 * In debug mode, we want to see as many errors as possible
2147 * to test the error recovery mechanism.
2148 */
2149 #if DEBUG
2150 static void osst_set_retries(struct osst_tape * STp, struct osst_request ** aSRpnt, int retries)
2151 {
2152 unsigned char cmd[MAX_COMMAND_SIZE];
2153 struct osst_request * SRpnt = * aSRpnt;
2154 char * name = tape_name(STp);
2155
2156 memset(cmd, 0, MAX_COMMAND_SIZE);
2157 cmd[0] = MODE_SELECT;
2158 cmd[1] = 0x10;
2159 cmd[4] = NUMBER_RETRIES_PAGE_LENGTH + MODE_HEADER_LENGTH;
2160
2161 (STp->buffer)->b_data[0] = cmd[4] - 1;
2162 (STp->buffer)->b_data[1] = 0; /* Medium Type - ignoring */
2163 (STp->buffer)->b_data[2] = 0; /* Reserved */
2164 (STp->buffer)->b_data[3] = 0; /* Block Descriptor Length */
2165 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 0] = NUMBER_RETRIES_PAGE | (1 << 7);
2166 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 1] = 2;
2167 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 2] = 4;
2168 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 3] = retries;
2169
2170 if (debugging)
2171 printk(OSST_DEB_MSG "%s:D: Setting number of retries on OnStream tape to %d\n", name, retries);
2172
2173 SRpnt = osst_do_scsi(SRpnt, STp, cmd, cmd[4], DMA_TO_DEVICE, STp->timeout, 0, 1);
2174 *aSRpnt = SRpnt;
2175
2176 if ((STp->buffer)->syscall_result)
2177 printk (KERN_ERR "%s:D: Couldn't set retries to %d\n", name, retries);
2178 }
2179 #endif
2180
2181
2182 static int osst_write_filemark(struct osst_tape * STp, struct osst_request ** aSRpnt)
2183 {
2184 int result;
2185 int this_mark_ppos = STp->first_frame_position;
2186 int this_mark_lbn = STp->logical_blk_num;
2187 #if DEBUG
2188 char * name = tape_name(STp);
2189 #endif
2190
2191 if (STp->raw) return 0;
2192
2193 STp->write_type = OS_WRITE_NEW_MARK;
2194 #if DEBUG
2195 printk(OSST_DEB_MSG "%s:D: Writing Filemark %i at fppos %d (fseq %d, lblk %d)\n",
2196 name, STp->filemark_cnt, this_mark_ppos, STp->frame_seq_number, this_mark_lbn);
2197 #endif
2198 STp->dirty = 1;
2199 result = osst_flush_write_buffer(STp, aSRpnt);
2200 result |= osst_flush_drive_buffer(STp, aSRpnt);
2201 STp->last_mark_ppos = this_mark_ppos;
2202 STp->last_mark_lbn = this_mark_lbn;
2203 if (STp->header_cache != NULL && STp->filemark_cnt < OS_FM_TAB_MAX)
2204 STp->header_cache->dat_fm_tab.fm_tab_ent[STp->filemark_cnt] = htonl(this_mark_ppos);
2205 if (STp->filemark_cnt++ == 0)
2206 STp->first_mark_ppos = this_mark_ppos;
2207 return result;
2208 }
2209
2210 static int osst_write_eod(struct osst_tape * STp, struct osst_request ** aSRpnt)
2211 {
2212 int result;
2213 #if DEBUG
2214 char * name = tape_name(STp);
2215 #endif
2216
2217 if (STp->raw) return 0;
2218
2219 STp->write_type = OS_WRITE_EOD;
2220 STp->eod_frame_ppos = STp->first_frame_position;
2221 #if DEBUG
2222 printk(OSST_DEB_MSG "%s:D: Writing EOD at fppos %d (fseq %d, lblk %d)\n", name,
2223 STp->eod_frame_ppos, STp->frame_seq_number, STp->logical_blk_num);
2224 #endif
2225 STp->dirty = 1;
2226
2227 result = osst_flush_write_buffer(STp, aSRpnt);
2228 result |= osst_flush_drive_buffer(STp, aSRpnt);
2229 STp->eod_frame_lfa = --(STp->frame_seq_number);
2230 return result;
2231 }
2232
2233 static int osst_write_filler(struct osst_tape * STp, struct osst_request ** aSRpnt, int where, int count)
2234 {
2235 char * name = tape_name(STp);
2236
2237 #if DEBUG
2238 printk(OSST_DEB_MSG "%s:D: Reached onstream write filler group %d\n", name, where);
2239 #endif
2240 osst_wait_ready(STp, aSRpnt, 60 * 5, 0);
2241 osst_set_frame_position(STp, aSRpnt, where, 0);
2242 STp->write_type = OS_WRITE_FILLER;
2243 while (count--) {
2244 memcpy(STp->buffer->b_data, "Filler", 6);
2245 STp->buffer->buffer_bytes = 6;
2246 STp->dirty = 1;
2247 if (osst_flush_write_buffer(STp, aSRpnt)) {
2248 printk(KERN_INFO "%s:I: Couldn't write filler frame\n", name);
2249 return (-EIO);
2250 }
2251 }
2252 #if DEBUG
2253 printk(OSST_DEB_MSG "%s:D: Exiting onstream write filler group\n", name);
2254 #endif
2255 return osst_flush_drive_buffer(STp, aSRpnt);
2256 }
2257
2258 static int __osst_write_header(struct osst_tape * STp, struct osst_request ** aSRpnt, int where, int count)
2259 {
2260 char * name = tape_name(STp);
2261 int result;
2262
2263 #if DEBUG
2264 printk(OSST_DEB_MSG "%s:D: Reached onstream write header group %d\n", name, where);
2265 #endif
2266 osst_wait_ready(STp, aSRpnt, 60 * 5, 0);
2267 osst_set_frame_position(STp, aSRpnt, where, 0);
2268 STp->write_type = OS_WRITE_HEADER;
2269 while (count--) {
2270 osst_copy_to_buffer(STp->buffer, (unsigned char *)STp->header_cache);
2271 STp->buffer->buffer_bytes = sizeof(os_header_t);
2272 STp->dirty = 1;
2273 if (osst_flush_write_buffer(STp, aSRpnt)) {
2274 printk(KERN_INFO "%s:I: Couldn't write header frame\n", name);
2275 return (-EIO);
2276 }
2277 }
2278 result = osst_flush_drive_buffer(STp, aSRpnt);
2279 #if DEBUG
2280 printk(OSST_DEB_MSG "%s:D: Write onstream header group %s\n", name, result?"failed":"done");
2281 #endif
2282 return result;
2283 }
2284
2285 static int osst_write_header(struct osst_tape * STp, struct osst_request ** aSRpnt, int locate_eod)
2286 {
2287 os_header_t * header;
2288 int result;
2289 char * name = tape_name(STp);
2290
2291 #if DEBUG
2292 printk(OSST_DEB_MSG "%s:D: Writing tape header\n", name);
2293 #endif
2294 if (STp->raw) return 0;
2295
2296 if (STp->header_cache == NULL) {
2297 if ((STp->header_cache = (os_header_t *)vmalloc(sizeof(os_header_t))) == NULL) {
2298 printk(KERN_ERR "%s:E: Failed to allocate header cache\n", name);
2299 return (-ENOMEM);
2300 }
2301 memset(STp->header_cache, 0, sizeof(os_header_t));
2302 #if DEBUG
2303 printk(OSST_DEB_MSG "%s:D: Allocated and cleared memory for header cache\n", name);
2304 #endif
2305 }
2306 if (STp->header_ok) STp->update_frame_cntr++;
2307 else STp->update_frame_cntr = 0;
2308
2309 header = STp->header_cache;
2310 strcpy(header->ident_str, "ADR_SEQ");
2311 header->major_rev = 1;
2312 header->minor_rev = 4;
2313 header->ext_trk_tb_off = htons(17192);
2314 header->pt_par_num = 1;
2315 header->partition[0].partition_num = OS_DATA_PARTITION;
2316 header->partition[0].par_desc_ver = OS_PARTITION_VERSION;
2317 header->partition[0].wrt_pass_cntr = htons(STp->wrt_pass_cntr);
2318 header->partition[0].first_frame_ppos = htonl(STp->first_data_ppos);
2319 header->partition[0].last_frame_ppos = htonl(STp->capacity);
2320 header->partition[0].eod_frame_ppos = htonl(STp->eod_frame_ppos);
2321 header->cfg_col_width = htonl(20);
2322 header->dat_col_width = htonl(1500);
2323 header->qfa_col_width = htonl(0);
2324 header->ext_track_tb.nr_stream_part = 1;
2325 header->ext_track_tb.et_ent_sz = 32;
2326 header->ext_track_tb.dat_ext_trk_ey.et_part_num = 0;
2327 header->ext_track_tb.dat_ext_trk_ey.fmt = 1;
2328 header->ext_track_tb.dat_ext_trk_ey.fm_tab_off = htons(17736);
2329 header->ext_track_tb.dat_ext_trk_ey.last_hlb_hi = 0;
2330 header->ext_track_tb.dat_ext_trk_ey.last_hlb = htonl(STp->eod_frame_lfa);
2331 header->ext_track_tb.dat_ext_trk_ey.last_pp = htonl(STp->eod_frame_ppos);
2332 header->dat_fm_tab.fm_part_num = 0;
2333 header->dat_fm_tab.fm_tab_ent_sz = 4;
2334 header->dat_fm_tab.fm_tab_ent_cnt = htons(STp->filemark_cnt<OS_FM_TAB_MAX?
2335 STp->filemark_cnt:OS_FM_TAB_MAX);
2336
2337 result = __osst_write_header(STp, aSRpnt, 0xbae, 5);
2338 if (STp->update_frame_cntr == 0)
2339 osst_write_filler(STp, aSRpnt, 0xbb3, 5);
2340 result &= __osst_write_header(STp, aSRpnt, 5, 5);
2341
2342 if (locate_eod) {
2343 #if DEBUG
2344 printk(OSST_DEB_MSG "%s:D: Locating back to eod frame addr %d\n", name, STp->eod_frame_ppos);
2345 #endif
2346 osst_set_frame_position(STp, aSRpnt, STp->eod_frame_ppos, 0);
2347 }
2348 if (result)
2349 printk(KERN_ERR "%s:E: Write header failed\n", name);
2350 else {
2351 memcpy(STp->application_sig, "LIN4", 4);
2352 STp->linux_media = 1;
2353 STp->linux_media_version = 4;
2354 STp->header_ok = 1;
2355 }
2356 return result;
2357 }
2358
2359 static int osst_reset_header(struct osst_tape * STp, struct osst_request ** aSRpnt)
2360 {
2361 if (STp->header_cache != NULL)
2362 memset(STp->header_cache, 0, sizeof(os_header_t));
2363
2364 STp->logical_blk_num = STp->frame_seq_number = 0;
2365 STp->frame_in_buffer = 0;
2366 STp->eod_frame_ppos = STp->first_data_ppos = 0x0000000A;
2367 STp->filemark_cnt = 0;
2368 STp->first_mark_ppos = STp->last_mark_ppos = STp->last_mark_lbn = -1;
2369 return osst_write_header(STp, aSRpnt, 1);
2370 }
2371
2372 static int __osst_analyze_headers(struct osst_tape * STp, struct osst_request ** aSRpnt, int ppos)
2373 {
2374 char * name = tape_name(STp);
2375 os_header_t * header;
2376 os_aux_t * aux;
2377 char id_string[8];
2378 int linux_media_version,
2379 update_frame_cntr;
2380
2381 if (STp->raw)
2382 return 1;
2383
2384 if (ppos == 5 || ppos == 0xbae || STp->buffer->syscall_result) {
2385 if (osst_set_frame_position(STp, aSRpnt, ppos, 0))
2386 printk(KERN_WARNING "%s:W: Couldn't position tape\n", name);
2387 osst_wait_ready(STp, aSRpnt, 60 * 15, 0);
2388 if (osst_initiate_read (STp, aSRpnt)) {
2389 printk(KERN_WARNING "%s:W: Couldn't initiate read\n", name);
2390 return 0;
2391 }
2392 }
2393 if (osst_read_frame(STp, aSRpnt, 180)) {
2394 #if DEBUG
2395 printk(OSST_DEB_MSG "%s:D: Couldn't read header frame\n", name);
2396 #endif
2397 return 0;
2398 }
2399 header = (os_header_t *) STp->buffer->b_data; /* warning: only first segment addressable */
2400 aux = STp->buffer->aux;
2401 if (aux->frame_type != OS_FRAME_TYPE_HEADER) {
2402 #if DEBUG
2403 printk(OSST_DEB_MSG "%s:D: Skipping non-header frame (%d)\n", name, ppos);
2404 #endif
2405 return 0;
2406 }
2407 if (ntohl(aux->frame_seq_num) != 0 ||
2408 ntohl(aux->logical_blk_num) != 0 ||
2409 aux->partition.partition_num != OS_CONFIG_PARTITION ||
2410 ntohl(aux->partition.first_frame_ppos) != 0 ||
2411 ntohl(aux->partition.last_frame_ppos) != 0xbb7 ) {
2412 #if DEBUG
2413 printk(OSST_DEB_MSG "%s:D: Invalid header frame (%d,%d,%d,%d,%d)\n", name,
2414 ntohl(aux->frame_seq_num), ntohl(aux->logical_blk_num),
2415 aux->partition.partition_num, ntohl(aux->partition.first_frame_ppos),
2416 ntohl(aux->partition.last_frame_ppos));
2417 #endif
2418 return 0;
2419 }
2420 if (strncmp(header->ident_str, "ADR_SEQ", 7) != 0 &&
2421 strncmp(header->ident_str, "ADR-SEQ", 7) != 0) {
2422 strlcpy(id_string, header->ident_str, 8);
2423 #if DEBUG
2424 printk(OSST_DEB_MSG "%s:D: Invalid header identification string %s\n", name, id_string);
2425 #endif
2426 return 0;
2427 }
2428 update_frame_cntr = ntohl(aux->update_frame_cntr);
2429 if (update_frame_cntr < STp->update_frame_cntr) {
2430 #if DEBUG
2431 printk(OSST_DEB_MSG "%s:D: Skipping frame %d with update_frame_counter %d<%d\n",
2432 name, ppos, update_frame_cntr, STp->update_frame_cntr);
2433 #endif
2434 return 0;
2435 }
2436 if (header->major_rev != 1 || header->minor_rev != 4 ) {
2437 #if DEBUG
2438 printk(OSST_DEB_MSG "%s:D: %s revision %d.%d detected (1.4 supported)\n",
2439 name, (header->major_rev != 1 || header->minor_rev < 2 ||
2440 header->minor_rev > 4 )? "Invalid" : "Warning:",
2441 header->major_rev, header->minor_rev);
2442 #endif
2443 if (header->major_rev != 1 || header->minor_rev < 2 || header->minor_rev > 4)
2444 return 0;
2445 }
2446 #if DEBUG
2447 if (header->pt_par_num != 1)
2448 printk(KERN_INFO "%s:W: %d partitions defined, only one supported\n",
2449 name, header->pt_par_num);
2450 #endif
2451 memcpy(id_string, aux->application_sig, 4);
2452 id_string[4] = 0;
2453 if (memcmp(id_string, "LIN", 3) == 0) {
2454 STp->linux_media = 1;
2455 linux_media_version = id_string[3] - '0';
2456 if (linux_media_version != 4)
2457 printk(KERN_INFO "%s:I: Linux media version %d detected (current 4)\n",
2458 name, linux_media_version);
2459 } else {
2460 printk(KERN_WARNING "%s:W: Non Linux media detected (%s)\n", name, id_string);
2461 return 0;
2462 }
2463 if (linux_media_version < STp->linux_media_version) {
2464 #if DEBUG
2465 printk(OSST_DEB_MSG "%s:D: Skipping frame %d with linux_media_version %d\n",
2466 name, ppos, linux_media_version);
2467 #endif
2468 return 0;
2469 }
2470 if (linux_media_version > STp->linux_media_version) {
2471 #if DEBUG
2472 printk(OSST_DEB_MSG "%s:D: Frame %d sets linux_media_version to %d\n",
2473 name, ppos, linux_media_version);
2474 #endif
2475 memcpy(STp->application_sig, id_string, 5);
2476 STp->linux_media_version = linux_media_version;
2477 STp->update_frame_cntr = -1;
2478 }
2479 if (update_frame_cntr > STp->update_frame_cntr) {
2480 #if DEBUG
2481 printk(OSST_DEB_MSG "%s:D: Frame %d sets update_frame_counter to %d\n",
2482 name, ppos, update_frame_cntr);
2483 #endif
2484 if (STp->header_cache == NULL) {
2485 if ((STp->header_cache = (os_header_t *)vmalloc(sizeof(os_header_t))) == NULL) {
2486 printk(KERN_ERR "%s:E: Failed to allocate header cache\n", name);
2487 return 0;
2488 }
2489 #if DEBUG
2490 printk(OSST_DEB_MSG "%s:D: Allocated memory for header cache\n", name);
2491 #endif
2492 }
2493 osst_copy_from_buffer(STp->buffer, (unsigned char *)STp->header_cache);
2494 header = STp->header_cache; /* further accesses from cached (full) copy */
2495
2496 STp->wrt_pass_cntr = ntohs(header->partition[0].wrt_pass_cntr);
2497 STp->first_data_ppos = ntohl(header->partition[0].first_frame_ppos);
2498 STp->eod_frame_ppos = ntohl(header->partition[0].eod_frame_ppos);
2499 STp->eod_frame_lfa = ntohl(header->ext_track_tb.dat_ext_trk_ey.last_hlb);
2500 STp->filemark_cnt = ntohl(aux->filemark_cnt);
2501 STp->first_mark_ppos = ntohl(aux->next_mark_ppos);
2502 STp->last_mark_ppos = ntohl(aux->last_mark_ppos);
2503 STp->last_mark_lbn = ntohl(aux->last_mark_lbn);
2504 STp->update_frame_cntr = update_frame_cntr;
2505 #if DEBUG
2506 printk(OSST_DEB_MSG "%s:D: Detected write pass %d, update frame counter %d, filemark counter %d\n",
2507 name, STp->wrt_pass_cntr, STp->update_frame_cntr, STp->filemark_cnt);
2508 printk(OSST_DEB_MSG "%s:D: first data frame on tape = %d, last = %d, eod frame = %d\n", name,
2509 STp->first_data_ppos,
2510 ntohl(header->partition[0].last_frame_ppos),
2511 ntohl(header->partition[0].eod_frame_ppos));
2512 printk(OSST_DEB_MSG "%s:D: first mark on tape = %d, last = %d, eod frame = %d\n",
2513 name, STp->first_mark_ppos, STp->last_mark_ppos, STp->eod_frame_ppos);
2514 #endif
2515 if (header->minor_rev < 4 && STp->linux_media_version == 4) {
2516 #if DEBUG
2517 printk(OSST_DEB_MSG "%s:D: Moving filemark list to ADR 1.4 location\n", name);
2518 #endif
2519 memcpy((void *)header->dat_fm_tab.fm_tab_ent,
2520 (void *)header->old_filemark_list, sizeof(header->dat_fm_tab.fm_tab_ent));
2521 memset((void *)header->old_filemark_list, 0, sizeof(header->old_filemark_list));
2522 }
2523 if (header->minor_rev == 4 &&
2524 (header->ext_trk_tb_off != htons(17192) ||
2525 header->partition[0].partition_num != OS_DATA_PARTITION ||
2526 header->partition[0].par_desc_ver != OS_PARTITION_VERSION ||
2527 header->partition[0].last_frame_ppos != htonl(STp->capacity) ||
2528 header->cfg_col_width != htonl(20) ||
2529 header->dat_col_width != htonl(1500) ||
2530 header->qfa_col_width != htonl(0) ||
2531 header->ext_track_tb.nr_stream_part != 1 ||
2532 header->ext_track_tb.et_ent_sz != 32 ||
2533 header->ext_track_tb.dat_ext_trk_ey.et_part_num != OS_DATA_PARTITION ||
2534 header->ext_track_tb.dat_ext_trk_ey.fmt != 1 ||
2535 header->ext_track_tb.dat_ext_trk_ey.fm_tab_off != htons(17736) ||
2536 header->ext_track_tb.dat_ext_trk_ey.last_hlb_hi != 0 ||
2537 header->ext_track_tb.dat_ext_trk_ey.last_pp != htonl(STp->eod_frame_ppos) ||
2538 header->dat_fm_tab.fm_part_num != OS_DATA_PARTITION ||
2539 header->dat_fm_tab.fm_tab_ent_sz != 4 ||
2540 header->dat_fm_tab.fm_tab_ent_cnt !=
2541 htons(STp->filemark_cnt<OS_FM_TAB_MAX?STp->filemark_cnt:OS_FM_TAB_MAX)))
2542 printk(KERN_WARNING "%s:W: Failed consistency check ADR 1.4 format\n", name);
2543
2544 }
2545
2546 return 1;
2547 }
2548
2549 static int osst_analyze_headers(struct osst_tape * STp, struct osst_request ** aSRpnt)
2550 {
2551 int position, ppos;
2552 int first, last;
2553 int valid = 0;
2554 char * name = tape_name(STp);
2555
2556 position = osst_get_frame_position(STp, aSRpnt);
2557
2558 if (STp->raw) {
2559 STp->header_ok = STp->linux_media = 1;
2560 STp->linux_media_version = 0;
2561 return 1;
2562 }
2563 STp->header_ok = STp->linux_media = STp->linux_media_version = 0;
2564 STp->wrt_pass_cntr = STp->update_frame_cntr = -1;
2565 STp->eod_frame_ppos = STp->first_data_ppos = -1;
2566 STp->first_mark_ppos = STp->last_mark_ppos = STp->last_mark_lbn = -1;
2567 #if DEBUG
2568 printk(OSST_DEB_MSG "%s:D: Reading header\n", name);
2569 #endif
2570
2571 /* optimization for speed - if we are positioned at ppos 10, read second group first */
2572 /* TODO try the ADR 1.1 locations for the second group if we have no valid one yet... */
2573
2574 first = position==10?0xbae: 5;
2575 last = position==10?0xbb3:10;
2576
2577 for (ppos = first; ppos < last; ppos++)
2578 if (__osst_analyze_headers(STp, aSRpnt, ppos))
2579 valid = 1;
2580
2581 first = position==10? 5:0xbae;
2582 last = position==10?10:0xbb3;
2583
2584 for (ppos = first; ppos < last; ppos++)
2585 if (__osst_analyze_headers(STp, aSRpnt, ppos))
2586 valid = 1;
2587
2588 if (!valid) {
2589 printk(KERN_ERR "%s:E: Failed to find valid ADRL header, new media?\n", name);
2590 STp->eod_frame_ppos = STp->first_data_ppos = 0;
2591 osst_set_frame_position(STp, aSRpnt, 10, 0);
2592 return 0;
2593 }
2594 if (position <= STp->first_data_ppos) {
2595 position = STp->first_data_ppos;
2596 STp->ps[0].drv_file = STp->ps[0].drv_block = STp->frame_seq_number = STp->logical_blk_num = 0;
2597 }
2598 osst_set_frame_position(STp, aSRpnt, position, 0);
2599 STp->header_ok = 1;
2600
2601 return 1;
2602 }
2603
2604 static int osst_verify_position(struct osst_tape * STp, struct osst_request ** aSRpnt)
2605 {
2606 int frame_position = STp->first_frame_position;
2607 int frame_seq_numbr = STp->frame_seq_number;
2608 int logical_blk_num = STp->logical_blk_num;
2609 int halfway_frame = STp->frame_in_buffer;
2610 int read_pointer = STp->buffer->read_pointer;
2611 int prev_mark_ppos = -1;
2612 int actual_mark_ppos, i, n;
2613 #if DEBUG
2614 char * name = tape_name(STp);
2615
2616 printk(OSST_DEB_MSG "%s:D: Verify that the tape is really the one we think before writing\n", name);
2617 #endif
2618 osst_set_frame_position(STp, aSRpnt, frame_position - 1, 0);
2619 if (osst_get_logical_frame(STp, aSRpnt, -1, 0) < 0) {
2620 #if DEBUG
2621 printk(OSST_DEB_MSG "%s:D: Couldn't get logical blk num in verify_position\n", name);
2622 #endif
2623 return (-EIO);
2624 }
2625 if (STp->linux_media_version >= 4) {
2626 for (i=0; i<STp->filemark_cnt; i++)
2627 if ((n=ntohl(STp->header_cache->dat_fm_tab.fm_tab_ent[i])) < frame_position)
2628 prev_mark_ppos = n;
2629 } else
2630 prev_mark_ppos = frame_position - 1; /* usually - we don't really know */
2631 actual_mark_ppos = STp->buffer->aux->frame_type == OS_FRAME_TYPE_MARKER ?
2632 frame_position - 1 : ntohl(STp->buffer->aux->last_mark_ppos);
2633 if (frame_position != STp->first_frame_position ||
2634 frame_seq_numbr != STp->frame_seq_number + (halfway_frame?0:1) ||
2635 prev_mark_ppos != actual_mark_ppos ) {
2636 #if DEBUG
2637 printk(OSST_DEB_MSG "%s:D: Block mismatch: fppos %d-%d, fseq %d-%d, mark %d-%d\n", name,
2638 STp->first_frame_position, frame_position,
2639 STp->frame_seq_number + (halfway_frame?0:1),
2640 frame_seq_numbr, actual_mark_ppos, prev_mark_ppos);
2641 #endif
2642 return (-EIO);
2643 }
2644 if (halfway_frame) {
2645 /* prepare buffer for append and rewrite on top of original */
2646 osst_set_frame_position(STp, aSRpnt, frame_position - 1, 0);
2647 STp->buffer->buffer_bytes = read_pointer;
2648 STp->ps[STp->partition].rw = ST_WRITING;
2649 STp->dirty = 1;
2650 }
2651 STp->frame_in_buffer = halfway_frame;
2652 STp->frame_seq_number = frame_seq_numbr;
2653 STp->logical_blk_num = logical_blk_num;
2654 return 0;
2655 }
2656
2657 /* Acc. to OnStream, the vers. numbering is the following:
2658 * X.XX for released versions (X=digit),
2659 * XXXY for unreleased versions (Y=letter)
2660 * Ordering 1.05 < 106A < 106B < ... < 106a < ... < 1.06
2661 * This fn makes monoton numbers out of this scheme ...
2662 */
2663 static unsigned int osst_parse_firmware_rev (const char * str)
2664 {
2665 if (str[1] == '.') {
2666 return (str[0]-'0')*10000
2667 +(str[2]-'0')*1000
2668 +(str[3]-'0')*100;
2669 } else {
2670 return (str[0]-'0')*10000
2671 +(str[1]-'0')*1000
2672 +(str[2]-'0')*100 - 100
2673 +(str[3]-'@');
2674 }
2675 }
2676
2677 /*
2678 * Configure the OnStream SCII tape drive for default operation
2679 */
2680 static int osst_configure_onstream(struct osst_tape *STp, struct osst_request ** aSRpnt)
2681 {
2682 unsigned char cmd[MAX_COMMAND_SIZE];
2683 char * name = tape_name(STp);
2684 struct osst_request * SRpnt = * aSRpnt;
2685 osst_mode_parameter_header_t * header;
2686 osst_block_size_page_t * bs;
2687 osst_capabilities_page_t * cp;
2688 osst_tape_paramtr_page_t * prm;
2689 int drive_buffer_size;
2690
2691 if (STp->ready != ST_READY) {
2692 #if DEBUG
2693 printk(OSST_DEB_MSG "%s:D: Not Ready\n", name);
2694 #endif
2695 return (-EIO);
2696 }
2697
2698 if (STp->os_fw_rev < 10600) {
2699 printk(KERN_INFO "%s:I: Old OnStream firmware revision detected (%s),\n", name, STp->device->rev);
2700 printk(KERN_INFO "%s:I: an upgrade to version 1.06 or above is recommended\n", name);
2701 }
2702
2703 /*
2704 * Configure 32.5KB (data+aux) frame size.
2705 * Get the current frame size from the block size mode page
2706 */
2707 memset(cmd, 0, MAX_COMMAND_SIZE);
2708 cmd[0] = MODE_SENSE;
2709 cmd[1] = 8;
2710 cmd[2] = BLOCK_SIZE_PAGE;
2711 cmd[4] = BLOCK_SIZE_PAGE_LENGTH + MODE_HEADER_LENGTH;
2712
2713 SRpnt = osst_do_scsi(SRpnt, STp, cmd, cmd[4], DMA_FROM_DEVICE, STp->timeout, 0, 1);
2714 if (SRpnt == NULL) {
2715 #if DEBUG
2716 printk(OSST_DEB_MSG "osst :D: Busy\n");
2717 #endif
2718 return (-EBUSY);
2719 }
2720 *aSRpnt = SRpnt;
2721 if ((STp->buffer)->syscall_result != 0) {
2722 printk (KERN_ERR "%s:E: Can't get tape block size mode page\n", name);
2723 return (-EIO);
2724 }
2725
2726 header = (osst_mode_parameter_header_t *) (STp->buffer)->b_data;
2727 bs = (osst_block_size_page_t *) ((STp->buffer)->b_data + sizeof(osst_mode_parameter_header_t) + header->bdl);
2728
2729 #if DEBUG
2730 printk(OSST_DEB_MSG "%s:D: 32KB play back: %s\n", name, bs->play32 ? "Yes" : "No");
2731 printk(OSST_DEB_MSG "%s:D: 32.5KB play back: %s\n", name, bs->play32_5 ? "Yes" : "No");
2732 printk(OSST_DEB_MSG "%s:D: 32KB record: %s\n", name, bs->record32 ? "Yes" : "No");
2733 printk(OSST_DEB_MSG "%s:D: 32.5KB record: %s\n", name, bs->record32_5 ? "Yes" : "No");
2734 #endif
2735
2736 /*
2737 * Configure default auto columns mode, 32.5KB transfer mode
2738 */
2739 bs->one = 1;
2740 bs->play32 = 0;
2741 bs->play32_5 = 1;
2742 bs->record32 = 0;
2743 bs->record32_5 = 1;
2744
2745 memset(cmd, 0, MAX_COMMAND_SIZE);
2746 cmd[0] = MODE_SELECT;
2747 cmd[1] = 0x10;
2748 cmd[4] = BLOCK_SIZE_PAGE_LENGTH + MODE_HEADER_LENGTH;
2749
2750 SRpnt = osst_do_scsi(SRpnt, STp, cmd, cmd[4], DMA_TO_DEVICE, STp->timeout, 0, 1);
2751 *aSRpnt = SRpnt;
2752 if ((STp->buffer)->syscall_result != 0) {
2753 printk (KERN_ERR "%s:E: Couldn't set tape block size mode page\n", name);
2754 return (-EIO);
2755 }
2756
2757 #if DEBUG
2758 printk(KERN_INFO "%s:D: Drive Block Size changed to 32.5K\n", name);
2759 /*
2760 * In debug mode, we want to see as many errors as possible
2761 * to test the error recovery mechanism.
2762 */
2763 osst_set_retries(STp, aSRpnt, 0);
2764 SRpnt = * aSRpnt;
2765 #endif
2766
2767 /*
2768 * Set vendor name to 'LIN4' for "Linux support version 4".
2769 */
2770
2771 memset(cmd, 0, MAX_COMMAND_SIZE);
2772 cmd[0] = MODE_SELECT;
2773 cmd[1] = 0x10;
2774 cmd[4] = VENDOR_IDENT_PAGE_LENGTH + MODE_HEADER_LENGTH;
2775
2776 header->mode_data_length = VENDOR_IDENT_PAGE_LENGTH + MODE_HEADER_LENGTH - 1;
2777 header->medium_type = 0; /* Medium Type - ignoring */
2778 header->dsp = 0; /* Reserved */
2779 header->bdl = 0; /* Block Descriptor Length */
2780
2781 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 0] = VENDOR_IDENT_PAGE | (1 << 7);
2782 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 1] = 6;
2783 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 2] = 'L';
2784 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 3] = 'I';
2785 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 4] = 'N';
2786 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 5] = '4';
2787 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 6] = 0;
2788 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 7] = 0;
2789
2790 SRpnt = osst_do_scsi(SRpnt, STp, cmd, cmd[4], DMA_TO_DEVICE, STp->timeout, 0, 1);
2791 *aSRpnt = SRpnt;
2792
2793 if ((STp->buffer)->syscall_result != 0) {
2794 printk (KERN_ERR "%s:E: Couldn't set vendor name to %s\n", name,
2795 (char *) ((STp->buffer)->b_data + MODE_HEADER_LENGTH + 2));
2796 return (-EIO);
2797 }
2798
2799 memset(cmd, 0, MAX_COMMAND_SIZE);
2800 cmd[0] = MODE_SENSE;
2801 cmd[1] = 8;
2802 cmd[2] = CAPABILITIES_PAGE;
2803 cmd[4] = CAPABILITIES_PAGE_LENGTH + MODE_HEADER_LENGTH;
2804
2805 SRpnt = osst_do_scsi(SRpnt, STp, cmd, cmd[4], DMA_FROM_DEVICE, STp->timeout, 0, 1);
2806 *aSRpnt = SRpnt;
2807
2808 if ((STp->buffer)->syscall_result != 0) {
2809 printk (KERN_ERR "%s:E: Can't get capabilities page\n", name);
2810 return (-EIO);
2811 }
2812
2813 header = (osst_mode_parameter_header_t *) (STp->buffer)->b_data;
2814 cp = (osst_capabilities_page_t *) ((STp->buffer)->b_data +
2815 sizeof(osst_mode_parameter_header_t) + header->bdl);
2816
2817 drive_buffer_size = ntohs(cp->buffer_size) / 2;
2818
2819 memset(cmd, 0, MAX_COMMAND_SIZE);
2820 cmd[0] = MODE_SENSE;
2821 cmd[1] = 8;
2822 cmd[2] = TAPE_PARAMTR_PAGE;
2823 cmd[4] = TAPE_PARAMTR_PAGE_LENGTH + MODE_HEADER_LENGTH;
2824
2825 SRpnt = osst_do_scsi(SRpnt, STp, cmd, cmd[4], DMA_FROM_DEVICE, STp->timeout, 0, 1);
2826 *aSRpnt = SRpnt;
2827
2828 if ((STp->buffer)->syscall_result != 0) {
2829 printk (KERN_ERR "%s:E: Can't get tape parameter page\n", name);
2830 return (-EIO);
2831 }
2832
2833 header = (osst_mode_parameter_header_t *) (STp->buffer)->b_data;
2834 prm = (osst_tape_paramtr_page_t *) ((STp->buffer)->b_data +
2835 sizeof(osst_mode_parameter_header_t) + header->bdl);
2836
2837 STp->density = prm->density;
2838 STp->capacity = ntohs(prm->segtrk) * ntohs(prm->trks);
2839 #if DEBUG
2840 printk(OSST_DEB_MSG "%s:D: Density %d, tape length: %dMB, drive buffer size: %dKB\n",
2841 name, STp->density, STp->capacity / 32, drive_buffer_size);
2842 #endif
2843
2844 return 0;
2845
2846 }
2847
2848
2849 /* Step over EOF if it has been inadvertently crossed (ioctl not used because
2850 it messes up the block number). */
2851 static int cross_eof(struct osst_tape *STp, struct osst_request ** aSRpnt, int forward)
2852 {
2853 int result;
2854 char * name = tape_name(STp);
2855
2856 #if DEBUG
2857 if (debugging)
2858 printk(OSST_DEB_MSG "%s:D: Stepping over filemark %s.\n",
2859 name, forward ? "forward" : "backward");
2860 #endif
2861
2862 if (forward) {
2863 /* assumes that the filemark is already read by the drive, so this is low cost */
2864 result = osst_space_over_filemarks_forward_slow(STp, aSRpnt, MTFSF, 1);
2865 }
2866 else
2867 /* assumes this is only called if we just read the filemark! */
2868 result = osst_seek_logical_blk(STp, aSRpnt, STp->logical_blk_num - 1);
2869
2870 if (result < 0)
2871 printk(KERN_WARNING "%s:W: Stepping over filemark %s failed.\n",
2872 name, forward ? "forward" : "backward");
2873
2874 return result;
2875 }
2876
2877
2878 /* Get the tape position. */
2879
2880 static int osst_get_frame_position(struct osst_tape *STp, struct osst_request ** aSRpnt)
2881 {
2882 unsigned char scmd[MAX_COMMAND_SIZE];
2883 struct osst_request * SRpnt;
2884 int result = 0;
2885 char * name = tape_name(STp);
2886
2887 /* KG: We want to be able to use it for checking Write Buffer availability
2888 * and thus don't want to risk to overwrite anything. Exchange buffers ... */
2889 char mybuf[24];
2890 char * olddata = STp->buffer->b_data;
2891 int oldsize = STp->buffer->buffer_size;
2892
2893 if (STp->ready != ST_READY) return (-EIO);
2894
2895 memset (scmd, 0, MAX_COMMAND_SIZE);
2896 scmd[0] = READ_POSITION;
2897
2898 STp->buffer->b_data = mybuf; STp->buffer->buffer_size = 24;
2899 SRpnt = osst_do_scsi(*aSRpnt, STp, scmd, 20, DMA_FROM_DEVICE,
2900 STp->timeout, MAX_RETRIES, 1);
2901 if (!SRpnt) {
2902 STp->buffer->b_data = olddata; STp->buffer->buffer_size = oldsize;
2903 return (-EBUSY);
2904 }
2905 *aSRpnt = SRpnt;
2906
2907 if (STp->buffer->syscall_result)
2908 result = ((SRpnt->sense[2] & 0x0f) == 3) ? -EIO : -EINVAL; /* 3: Write Error */
2909
2910 if (result == -EINVAL)
2911 printk(KERN_ERR "%s:E: Can't read tape position.\n", name);
2912 else {
2913 if (result == -EIO) { /* re-read position - this needs to preserve media errors */
2914 unsigned char mysense[16];
2915 memcpy (mysense, SRpnt->sense, 16);
2916 memset (scmd, 0, MAX_COMMAND_SIZE);
2917 scmd[0] = READ_POSITION;
2918 STp->buffer->b_data = mybuf; STp->buffer->buffer_size = 24;
2919 SRpnt = osst_do_scsi(SRpnt, STp, scmd, 20, DMA_FROM_DEVICE,
2920 STp->timeout, MAX_RETRIES, 1);
2921 #if DEBUG
2922 printk(OSST_DEB_MSG "%s:D: Reread position, reason=[%02x:%02x:%02x], result=[%s%02x:%02x:%02x]\n",
2923 name, mysense[2], mysense[12], mysense[13], STp->buffer->syscall_result?"":"ok:",
2924 SRpnt->sense[2],SRpnt->sense[12],SRpnt->sense[13]);
2925 #endif
2926 if (!STp->buffer->syscall_result)
2927 memcpy (SRpnt->sense, mysense, 16);
2928 else
2929 printk(KERN_WARNING "%s:W: Double error in get position\n", name);
2930 }
2931 STp->first_frame_position = ((STp->buffer)->b_data[4] << 24)
2932 + ((STp->buffer)->b_data[5] << 16)
2933 + ((STp->buffer)->b_data[6] << 8)
2934 + (STp->buffer)->b_data[7];
2935 STp->last_frame_position = ((STp->buffer)->b_data[ 8] << 24)
2936 + ((STp->buffer)->b_data[ 9] << 16)
2937 + ((STp->buffer)->b_data[10] << 8)
2938 + (STp->buffer)->b_data[11];
2939 STp->cur_frames = (STp->buffer)->b_data[15];
2940 #if DEBUG
2941 if (debugging) {
2942 printk(OSST_DEB_MSG "%s:D: Drive Positions: host %d, tape %d%s, buffer %d\n", name,
2943 STp->first_frame_position, STp->last_frame_position,
2944 ((STp->buffer)->b_data[0]&0x80)?" (BOP)":
2945 ((STp->buffer)->b_data[0]&0x40)?" (EOP)":"",
2946 STp->cur_frames);
2947 }
2948 #endif
2949 if (STp->cur_frames == 0 && STp->first_frame_position != STp->last_frame_position) {
2950 #if DEBUG
2951 printk(OSST_DEB_MSG "%s:D: Correcting read position %d, %d, %d\n", name,
2952 STp->first_frame_position, STp->last_frame_position, STp->cur_frames);
2953 #endif
2954 STp->first_frame_position = STp->last_frame_position;
2955 }
2956 }
2957 STp->buffer->b_data = olddata; STp->buffer->buffer_size = oldsize;
2958
2959 return (result == 0 ? STp->first_frame_position : result);
2960 }
2961
2962
2963 /* Set the tape block */
2964 static int osst_set_frame_position(struct osst_tape *STp, struct osst_request ** aSRpnt, int ppos, int skip)
2965 {
2966 unsigned char scmd[MAX_COMMAND_SIZE];
2967 struct osst_request * SRpnt;
2968 struct st_partstat * STps;
2969 int result = 0;
2970 int pp = (ppos == 3000 && !skip)? 0 : ppos;
2971 char * name = tape_name(STp);
2972
2973 if (STp->ready != ST_READY) return (-EIO);
2974
2975 STps = &(STp->ps[STp->partition]);
2976
2977 if (ppos < 0 || ppos > STp->capacity) {
2978 printk(KERN_WARNING "%s:W: Reposition request %d out of range\n", name, ppos);
2979 pp = ppos = ppos < 0 ? 0 : (STp->capacity - 1);
2980 result = (-EINVAL);
2981 }
2982
2983 do {
2984 #if DEBUG
2985 if (debugging)
2986 printk(OSST_DEB_MSG "%s:D: Setting ppos to %d.\n", name, pp);
2987 #endif
2988 memset (scmd, 0, MAX_COMMAND_SIZE);
2989 scmd[0] = SEEK_10;
2990 scmd[1] = 1;
2991 scmd[3] = (pp >> 24);
2992 scmd[4] = (pp >> 16);
2993 scmd[5] = (pp >> 8);
2994 scmd[6] = pp;
2995 if (skip)
2996 scmd[9] = 0x80;
2997
2998 SRpnt = osst_do_scsi(*aSRpnt, STp, scmd, 0, DMA_NONE, STp->long_timeout,
2999 MAX_RETRIES, 1);
3000 if (!SRpnt)
3001 return (-EBUSY);
3002 *aSRpnt = SRpnt;
3003
3004 if ((STp->buffer)->syscall_result != 0) {
3005 #if DEBUG
3006 printk(OSST_DEB_MSG "%s:D: SEEK command from %d to %d failed.\n",
3007 name, STp->first_frame_position, pp);
3008 #endif
3009 result = (-EIO);
3010 }
3011 if (pp != ppos)
3012 osst_wait_ready(STp, aSRpnt, 5 * 60, OSST_WAIT_POSITION_COMPLETE);
3013 } while ((pp != ppos) && (pp = ppos));
3014 STp->first_frame_position = STp->last_frame_position = ppos;
3015 STps->eof = ST_NOEOF;
3016 STps->at_sm = 0;
3017 STps->rw = ST_IDLE;
3018 STp->frame_in_buffer = 0;
3019 return result;
3020 }
3021
3022 static int osst_write_trailer(struct osst_tape *STp, struct osst_request ** aSRpnt, int leave_at_EOT)
3023 {
3024 struct st_partstat * STps = &(STp->ps[STp->partition]);
3025 int result = 0;
3026
3027 if (STp->write_type != OS_WRITE_NEW_MARK) {
3028 /* true unless the user wrote the filemark for us */
3029 result = osst_flush_drive_buffer(STp, aSRpnt);
3030 if (result < 0) goto out;
3031 result = osst_write_filemark(STp, aSRpnt);
3032 if (result < 0) goto out;
3033
3034 if (STps->drv_file >= 0)
3035 STps->drv_file++ ;
3036 STps->drv_block = 0;
3037 }
3038 result = osst_write_eod(STp, aSRpnt);
3039 osst_write_header(STp, aSRpnt, leave_at_EOT);
3040
3041 STps->eof = ST_FM;
3042 out:
3043 return result;
3044 }
3045 \f
3046 /* osst versions of st functions - augmented and stripped to suit OnStream only */
3047
3048 /* Flush the write buffer (never need to write if variable blocksize). */
3049 static int osst_flush_write_buffer(struct osst_tape *STp, struct osst_request ** aSRpnt)
3050 {
3051 int offset, transfer, blks = 0;
3052 int result = 0;
3053 unsigned char cmd[MAX_COMMAND_SIZE];
3054 struct osst_request * SRpnt = *aSRpnt;
3055 struct st_partstat * STps;
3056 char * name = tape_name(STp);
3057
3058 if ((STp->buffer)->writing) {
3059 if (SRpnt == (STp->buffer)->last_SRpnt)
3060 #if DEBUG
3061 { printk(OSST_DEB_MSG
3062 "%s:D: aSRpnt points to osst_request that write_behind_check will release -- cleared\n", name);
3063 #endif
3064 *aSRpnt = SRpnt = NULL;
3065 #if DEBUG
3066 } else if (SRpnt)
3067 printk(OSST_DEB_MSG
3068 "%s:D: aSRpnt does not point to osst_request that write_behind_check will release -- strange\n", name);
3069 #endif
3070 osst_write_behind_check(STp);
3071 if ((STp->buffer)->syscall_result) {
3072 #if DEBUG
3073 if (debugging)
3074 printk(OSST_DEB_MSG "%s:D: Async write error (flush) %x.\n",
3075 name, (STp->buffer)->midlevel_result);
3076 #endif
3077 if ((STp->buffer)->midlevel_result == INT_MAX)
3078 return (-ENOSPC);
3079 return (-EIO);
3080 }
3081 }
3082
3083 result = 0;
3084 if (STp->dirty == 1) {
3085
3086 STp->write_count++;
3087 STps = &(STp->ps[STp->partition]);
3088 STps->rw = ST_WRITING;
3089 offset = STp->buffer->buffer_bytes;
3090 blks = (offset + STp->block_size - 1) / STp->block_size;
3091 transfer = OS_FRAME_SIZE;
3092
3093 if (offset < OS_DATA_SIZE)
3094 osst_zero_buffer_tail(STp->buffer);
3095
3096 if (STp->poll)
3097 if (osst_wait_frame (STp, aSRpnt, STp->first_frame_position, -50, 120))
3098 result = osst_recover_wait_frame(STp, aSRpnt, 1);
3099
3100 memset(cmd, 0, MAX_COMMAND_SIZE);
3101 cmd[0] = WRITE_6;
3102 cmd[1] = 1;
3103 cmd[4] = 1;
3104
3105 switch (STp->write_type) {
3106 case OS_WRITE_DATA:
3107 #if DEBUG
3108 if (debugging)
3109 printk(OSST_DEB_MSG "%s:D: Writing %d blocks to frame %d, lblks %d-%d\n",
3110 name, blks, STp->frame_seq_number,
3111 STp->logical_blk_num - blks, STp->logical_blk_num - 1);
3112 #endif
3113 osst_init_aux(STp, OS_FRAME_TYPE_DATA, STp->frame_seq_number++,
3114 STp->logical_blk_num - blks, STp->block_size, blks);
3115 break;
3116 case OS_WRITE_EOD:
3117 osst_init_aux(STp, OS_FRAME_TYPE_EOD, STp->frame_seq_number++,
3118 STp->logical_blk_num, 0, 0);
3119 break;
3120 case OS_WRITE_NEW_MARK:
3121 osst_init_aux(STp, OS_FRAME_TYPE_MARKER, STp->frame_seq_number++,
3122 STp->logical_blk_num++, 0, blks=1);
3123 break;
3124 case OS_WRITE_HEADER:
3125 osst_init_aux(STp, OS_FRAME_TYPE_HEADER, 0, 0, 0, blks=0);
3126 break;
3127 default: /* probably FILLER */
3128 osst_init_aux(STp, OS_FRAME_TYPE_FILL, 0, 0, 0, 0);
3129 }
3130 #if DEBUG
3131 if (debugging)
3132 printk(OSST_DEB_MSG "%s:D: Flushing %d bytes, Transfering %d bytes in %d lblocks.\n",
3133 name, offset, transfer, blks);
3134 #endif
3135
3136 SRpnt = osst_do_scsi(*aSRpnt, STp, cmd, transfer, DMA_TO_DEVICE,
3137 STp->timeout, MAX_RETRIES, 1);
3138 *aSRpnt = SRpnt;
3139 if (!SRpnt)
3140 return (-EBUSY);
3141
3142 if ((STp->buffer)->syscall_result != 0) {
3143 #if DEBUG
3144 printk(OSST_DEB_MSG
3145 "%s:D: write sense [0]=0x%02x [2]=%02x [12]=%02x [13]=%02x\n",
3146 name, SRpnt->sense[0], SRpnt->sense[2],
3147 SRpnt->sense[12], SRpnt->sense[13]);
3148 #endif
3149 if ((SRpnt->sense[0] & 0x70) == 0x70 &&
3150 (SRpnt->sense[2] & 0x40) && /* FIXME - SC-30 drive doesn't assert EOM bit */
3151 (SRpnt->sense[2] & 0x0f) == NO_SENSE) {
3152 STp->dirty = 0;
3153 (STp->buffer)->buffer_bytes = 0;
3154 result = (-ENOSPC);
3155 }
3156 else {
3157 if (osst_write_error_recovery(STp, aSRpnt, 1)) {
3158 printk(KERN_ERR "%s:E: Error on flush write.\n", name);
3159 result = (-EIO);
3160 }
3161 }
3162 STps->drv_block = (-1); /* FIXME - even if write recovery succeeds? */
3163 }
3164 else {
3165 STp->first_frame_position++;
3166 STp->dirty = 0;
3167 (STp->buffer)->buffer_bytes = 0;
3168 }
3169 }
3170 #if DEBUG
3171 printk(OSST_DEB_MSG "%s:D: Exit flush write buffer with code %d\n", name, result);
3172 #endif
3173 return result;
3174 }
3175
3176
3177 /* Flush the tape buffer. The tape will be positioned correctly unless
3178 seek_next is true. */
3179 static int osst_flush_buffer(struct osst_tape * STp, struct osst_request ** aSRpnt, int seek_next)
3180 {
3181 struct st_partstat * STps;
3182 int backspace = 0, result = 0;
3183 #if DEBUG
3184 char * name = tape_name(STp);
3185 #endif
3186
3187 /*
3188 * If there was a bus reset, block further access
3189 * to this device.
3190 */
3191 if( STp->pos_unknown)
3192 return (-EIO);
3193
3194 if (STp->ready != ST_READY)
3195 return 0;
3196
3197 STps = &(STp->ps[STp->partition]);
3198 if (STps->rw == ST_WRITING || STp->dirty) { /* Writing */
3199 STp->write_type = OS_WRITE_DATA;
3200 return osst_flush_write_buffer(STp, aSRpnt);
3201 }
3202 if (STp->block_size == 0)
3203 return 0;
3204
3205 #if DEBUG
3206 printk(OSST_DEB_MSG "%s:D: Reached flush (read) buffer\n", name);
3207 #endif
3208
3209 if (!STp->can_bsr) {
3210 backspace = ((STp->buffer)->buffer_bytes + (STp->buffer)->read_pointer) / STp->block_size -
3211 ((STp->buffer)->read_pointer + STp->block_size - 1 ) / STp->block_size ;
3212 (STp->buffer)->buffer_bytes = 0;
3213 (STp->buffer)->read_pointer = 0;
3214 STp->frame_in_buffer = 0; /* FIXME is this relevant w. OSST? */
3215 }
3216
3217 if (!seek_next) {
3218 if (STps->eof == ST_FM_HIT) {
3219 result = cross_eof(STp, aSRpnt, 0); /* Back over the EOF hit */
3220 if (!result)
3221 STps->eof = ST_NOEOF;
3222 else {
3223 if (STps->drv_file >= 0)
3224 STps->drv_file++;
3225 STps->drv_block = 0;
3226 }
3227 }
3228 if (!result && backspace > 0) /* TODO -- design and run a test case for this */
3229 result = osst_seek_logical_blk(STp, aSRpnt, STp->logical_blk_num - backspace);
3230 }
3231 else if (STps->eof == ST_FM_HIT) {
3232 if (STps->drv_file >= 0)
3233 STps->drv_file++;
3234 STps->drv_block = 0;
3235 STps->eof = ST_NOEOF;
3236 }
3237
3238 return result;
3239 }
3240
3241 static int osst_write_frame(struct osst_tape * STp, struct osst_request ** aSRpnt, int synchronous)
3242 {
3243 unsigned char cmd[MAX_COMMAND_SIZE];
3244 struct osst_request * SRpnt;
3245 int blks;
3246 #if DEBUG
3247 char * name = tape_name(STp);
3248 #endif
3249
3250 if ((!STp-> raw) && (STp->first_frame_position == 0xbae)) { /* _must_ preserve buffer! */
3251 #if DEBUG
3252 printk(OSST_DEB_MSG "%s:D: Reaching config partition.\n", name);
3253 #endif
3254 if (osst_flush_drive_buffer(STp, aSRpnt) < 0) {
3255 return (-EIO);
3256 }
3257 /* error recovery may have bumped us past the header partition */
3258 if (osst_get_frame_position(STp, aSRpnt) < 0xbb8) {
3259 #if DEBUG
3260 printk(OSST_DEB_MSG "%s:D: Skipping over config partition.\n", name);
3261 #endif
3262 osst_position_tape_and_confirm(STp, aSRpnt, 0xbb8);
3263 }
3264 }
3265
3266 if (STp->poll)
3267 if (osst_wait_frame (STp, aSRpnt, STp->first_frame_position, -48, 120))
3268 if (osst_recover_wait_frame(STp, aSRpnt, 1))
3269 return (-EIO);
3270
3271 // osst_build_stats(STp, &SRpnt);
3272
3273 STp->ps[STp->partition].rw = ST_WRITING;
3274 STp->write_type = OS_WRITE_DATA;
3275
3276 memset(cmd, 0, MAX_COMMAND_SIZE);
3277 cmd[0] = WRITE_6;
3278 cmd[1] = 1;
3279 cmd[4] = 1; /* one frame at a time... */
3280 blks = STp->buffer->buffer_bytes / STp->block_size;
3281 #if DEBUG
3282 if (debugging)
3283 printk(OSST_DEB_MSG "%s:D: Writing %d blocks to frame %d, lblks %d-%d\n", name, blks,
3284 STp->frame_seq_number, STp->logical_blk_num - blks, STp->logical_blk_num - 1);
3285 #endif
3286 osst_init_aux(STp, OS_FRAME_TYPE_DATA, STp->frame_seq_number++,
3287 STp->logical_blk_num - blks, STp->block_size, blks);
3288
3289 #if DEBUG
3290 if (!synchronous)
3291 STp->write_pending = 1;
3292 #endif
3293 SRpnt = osst_do_scsi(*aSRpnt, STp, cmd, OS_FRAME_SIZE, DMA_TO_DEVICE, STp->timeout,
3294 MAX_RETRIES, synchronous);
3295 if (!SRpnt)
3296 return (-EBUSY);
3297 *aSRpnt = SRpnt;
3298
3299 if (synchronous) {
3300 if (STp->buffer->syscall_result != 0) {
3301 #if DEBUG
3302 if (debugging)
3303 printk(OSST_DEB_MSG "%s:D: Error on write:\n", name);
3304 #endif
3305 if ((SRpnt->sense[0] & 0x70) == 0x70 &&
3306 (SRpnt->sense[2] & 0x40)) {
3307 if ((SRpnt->sense[2] & 0x0f) == VOLUME_OVERFLOW)
3308 return (-ENOSPC);
3309 }
3310 else {
3311 if (osst_write_error_recovery(STp, aSRpnt, 1))
3312 return (-EIO);
3313 }
3314 }
3315 else
3316 STp->first_frame_position++;
3317 }
3318
3319 STp->write_count++;
3320
3321 return 0;
3322 }
3323
3324 /* Lock or unlock the drive door. Don't use when struct osst_request allocated. */
3325 static int do_door_lock(struct osst_tape * STp, int do_lock)
3326 {
3327 int retval, cmd;
3328
3329 cmd = do_lock ? SCSI_IOCTL_DOORLOCK : SCSI_IOCTL_DOORUNLOCK;
3330 #if DEBUG
3331 printk(OSST_DEB_MSG "%s:D: %socking drive door.\n", tape_name(STp), do_lock ? "L" : "Unl");
3332 #endif
3333 retval = scsi_ioctl(STp->device, cmd, NULL);
3334 if (!retval) {
3335 STp->door_locked = do_lock ? ST_LOCKED_EXPLICIT : ST_UNLOCKED;
3336 }
3337 else {
3338 STp->door_locked = ST_LOCK_FAILS;
3339 }
3340 return retval;
3341 }
3342
3343 /* Set the internal state after reset */
3344 static void reset_state(struct osst_tape *STp)
3345 {
3346 int i;
3347 struct st_partstat *STps;
3348
3349 STp->pos_unknown = 0;
3350 for (i = 0; i < ST_NBR_PARTITIONS; i++) {
3351 STps = &(STp->ps[i]);
3352 STps->rw = ST_IDLE;
3353 STps->eof = ST_NOEOF;
3354 STps->at_sm = 0;
3355 STps->last_block_valid = 0;
3356 STps->drv_block = -1;
3357 STps->drv_file = -1;
3358 }
3359 }
3360
3361 \f
3362 /* Entry points to osst */
3363
3364 /* Write command */
3365 static ssize_t osst_write(struct file * filp, const char __user * buf, size_t count, loff_t *ppos)
3366 {
3367 ssize_t total, retval = 0;
3368 ssize_t i, do_count, blks, transfer;
3369 int write_threshold;
3370 int doing_write = 0;
3371 const char __user * b_point;
3372 struct osst_request * SRpnt = NULL;
3373 struct st_modedef * STm;
3374 struct st_partstat * STps;
3375 struct osst_tape * STp = filp->private_data;
3376 char * name = tape_name(STp);
3377
3378
3379 if (mutex_lock_interruptible(&STp->lock))
3380 return (-ERESTARTSYS);
3381
3382 /*
3383 * If we are in the middle of error recovery, don't let anyone
3384 * else try and use this device. Also, if error recovery fails, it
3385 * may try and take the device offline, in which case all further
3386 * access to the device is prohibited.
3387 */
3388 if( !scsi_block_when_processing_errors(STp->device) ) {
3389 retval = (-ENXIO);
3390 goto out;
3391 }
3392
3393 if (STp->ready != ST_READY) {
3394 if (STp->ready == ST_NO_TAPE)
3395 retval = (-ENOMEDIUM);
3396 else
3397 retval = (-EIO);
3398 goto out;
3399 }
3400 STm = &(STp->modes[STp->current_mode]);
3401 if (!STm->defined) {
3402 retval = (-ENXIO);
3403 goto out;
3404 }
3405 if (count == 0)
3406 goto out;
3407
3408 /*
3409 * If there was a bus reset, block further access
3410 * to this device.
3411 */
3412 if (STp->pos_unknown) {
3413 retval = (-EIO);
3414 goto out;
3415 }
3416
3417 #if DEBUG
3418 if (!STp->in_use) {
3419 printk(OSST_DEB_MSG "%s:D: Incorrect device.\n", name);
3420 retval = (-EIO);
3421 goto out;
3422 }
3423 #endif
3424
3425 if (STp->write_prot) {
3426 retval = (-EACCES);
3427 goto out;
3428 }
3429
3430 /* Write must be integral number of blocks */
3431 if (STp->block_size != 0 && (count % STp->block_size) != 0) {
3432 printk(KERN_ERR "%s:E: Write (%Zd bytes) not multiple of tape block size (%d%c).\n",
3433 name, count, STp->block_size<1024?
3434 STp->block_size:STp->block_size/1024, STp->block_size<1024?'b':'k');
3435 retval = (-EINVAL);
3436 goto out;
3437 }
3438
3439 if (STp->first_frame_position >= STp->capacity - OSST_EOM_RESERVE) {
3440 printk(KERN_ERR "%s:E: Write truncated at EOM early warning (frame %d).\n",
3441 name, STp->first_frame_position);
3442 retval = (-ENOSPC);
3443 goto out;
3444 }
3445
3446 if (STp->do_auto_lock && STp->door_locked == ST_UNLOCKED && !do_door_lock(STp, 1))
3447 STp->door_locked = ST_LOCKED_AUTO;
3448
3449 STps = &(STp->ps[STp->partition]);
3450
3451 if (STps->rw == ST_READING) {
3452 #if DEBUG
3453 printk(OSST_DEB_MSG "%s:D: Switching from read to write at file %d, block %d\n", name,
3454 STps->drv_file, STps->drv_block);
3455 #endif
3456 retval = osst_flush_buffer(STp, &SRpnt, 0);
3457 if (retval)
3458 goto out;
3459 STps->rw = ST_IDLE;
3460 }
3461 if (STps->rw != ST_WRITING) {
3462 /* Are we totally rewriting this tape? */
3463 if (!STp->header_ok ||
3464 (STp->first_frame_position == STp->first_data_ppos && STps->drv_block < 0) ||
3465 (STps->drv_file == 0 && STps->drv_block == 0)) {
3466 STp->wrt_pass_cntr++;
3467 #if DEBUG
3468 printk(OSST_DEB_MSG "%s:D: Allocating next write pass counter: %d\n",
3469 name, STp->wrt_pass_cntr);
3470 #endif
3471 osst_reset_header(STp, &SRpnt);
3472 STps->drv_file = STps->drv_block = 0;
3473 }
3474 /* Do we know where we'll be writing on the tape? */
3475 else {
3476 if ((STp->fast_open && osst_verify_position(STp, &SRpnt)) ||
3477 STps->drv_file < 0 || STps->drv_block < 0) {
3478 if (STp->first_frame_position == STp->eod_frame_ppos) { /* at EOD */
3479 STps->drv_file = STp->filemark_cnt;
3480 STps->drv_block = 0;
3481 }
3482 else {
3483 /* We have no idea where the tape is positioned - give up */
3484 #if DEBUG
3485 printk(OSST_DEB_MSG
3486 "%s:D: Cannot write at indeterminate position.\n", name);
3487 #endif
3488 retval = (-EIO);
3489 goto out;
3490 }
3491 }
3492 if ((STps->drv_file + STps->drv_block) > 0 && STps->drv_file < STp->filemark_cnt) {
3493 STp->filemark_cnt = STps->drv_file;
3494 STp->last_mark_ppos =
3495 ntohl(STp->header_cache->dat_fm_tab.fm_tab_ent[STp->filemark_cnt-1]);
3496 printk(KERN_WARNING
3497 "%s:W: Overwriting file %d with old write pass counter %d\n",
3498 name, STps->drv_file, STp->wrt_pass_cntr);
3499 printk(KERN_WARNING
3500 "%s:W: may lead to stale data being accepted on reading back!\n",
3501 name);
3502 #if DEBUG
3503 printk(OSST_DEB_MSG
3504 "%s:D: resetting filemark count to %d and last mark ppos,lbn to %d,%d\n",
3505 name, STp->filemark_cnt, STp->last_mark_ppos, STp->last_mark_lbn);
3506 #endif
3507 }
3508 }
3509 STp->fast_open = 0;
3510 }
3511 if (!STp->header_ok) {
3512 #if DEBUG
3513 printk(OSST_DEB_MSG "%s:D: Write cannot proceed without valid headers\n", name);
3514 #endif
3515 retval = (-EIO);
3516 goto out;
3517 }
3518
3519 if ((STp->buffer)->writing) {
3520 if (SRpnt) printk(KERN_ERR "%s:A: Not supposed to have SRpnt at line %d\n", name, __LINE__);
3521 osst_write_behind_check(STp);
3522 if ((STp->buffer)->syscall_result) {
3523 #if DEBUG
3524 if (debugging)
3525 printk(OSST_DEB_MSG "%s:D: Async write error (write) %x.\n", name,
3526 (STp->buffer)->midlevel_result);
3527 #endif
3528 if ((STp->buffer)->midlevel_result == INT_MAX)
3529 STps->eof = ST_EOM_OK;
3530 else
3531 STps->eof = ST_EOM_ERROR;
3532 }
3533 }
3534 if (STps->eof == ST_EOM_OK) {
3535 retval = (-ENOSPC);
3536 goto out;
3537 }
3538 else if (STps->eof == ST_EOM_ERROR) {
3539 retval = (-EIO);
3540 goto out;
3541 }
3542
3543 /* Check the buffer readability in cases where copy_user might catch
3544 the problems after some tape movement. */
3545 if ((copy_from_user(&i, buf, 1) != 0 ||
3546 copy_from_user(&i, buf + count - 1, 1) != 0)) {
3547 retval = (-EFAULT);
3548 goto out;
3549 }
3550
3551 if (!STm->do_buffer_writes) {
3552 write_threshold = 1;
3553 }
3554 else
3555 write_threshold = (STp->buffer)->buffer_blocks * STp->block_size;
3556 if (!STm->do_async_writes)
3557 write_threshold--;
3558
3559 total = count;
3560 #if DEBUG
3561 if (debugging)
3562 printk(OSST_DEB_MSG "%s:D: Writing %d bytes to file %d block %d lblk %d fseq %d fppos %d\n",
3563 name, (int) count, STps->drv_file, STps->drv_block,
3564 STp->logical_blk_num, STp->frame_seq_number, STp->first_frame_position);
3565 #endif
3566 b_point = buf;
3567 while ((STp->buffer)->buffer_bytes + count > write_threshold)
3568 {
3569 doing_write = 1;
3570 do_count = (STp->buffer)->buffer_blocks * STp->block_size -
3571 (STp->buffer)->buffer_bytes;
3572 if (do_count > count)
3573 do_count = count;
3574
3575 i = append_to_buffer(b_point, STp->buffer, do_count);
3576 if (i) {
3577 retval = i;
3578 goto out;
3579 }
3580
3581 blks = do_count / STp->block_size;
3582 STp->logical_blk_num += blks; /* logical_blk_num is incremented as data is moved from user */
3583
3584 i = osst_write_frame(STp, &SRpnt, 1);
3585
3586 if (i == (-ENOSPC)) {
3587 transfer = STp->buffer->writing; /* FIXME -- check this logic */
3588 if (transfer <= do_count) {
3589 filp->f_pos += do_count - transfer;
3590 count -= do_count - transfer;
3591 if (STps->drv_block >= 0) {
3592 STps->drv_block += (do_count - transfer) / STp->block_size;
3593 }
3594 STps->eof = ST_EOM_OK;
3595 retval = (-ENOSPC); /* EOM within current request */
3596 #if DEBUG
3597 if (debugging)
3598 printk(OSST_DEB_MSG "%s:D: EOM with %d bytes unwritten.\n",
3599 name, (int) transfer);
3600 #endif
3601 }
3602 else {
3603 STps->eof = ST_EOM_ERROR;
3604 STps->drv_block = (-1); /* Too cautious? */
3605 retval = (-EIO); /* EOM for old data */
3606 #if DEBUG
3607 if (debugging)
3608 printk(OSST_DEB_MSG "%s:D: EOM with lost data.\n", name);
3609 #endif
3610 }
3611 }
3612 else
3613 retval = i;
3614
3615 if (retval < 0) {
3616 if (SRpnt != NULL) {
3617 osst_release_request(SRpnt);
3618 SRpnt = NULL;
3619 }
3620 STp->buffer->buffer_bytes = 0;
3621 STp->dirty = 0;
3622 if (count < total)
3623 retval = total - count;
3624 goto out;
3625 }
3626
3627 filp->f_pos += do_count;
3628 b_point += do_count;
3629 count -= do_count;
3630 if (STps->drv_block >= 0) {
3631 STps->drv_block += blks;
3632 }
3633 STp->buffer->buffer_bytes = 0;
3634 STp->dirty = 0;
3635 } /* end while write threshold exceeded */
3636
3637 if (count != 0) {
3638 STp->dirty = 1;
3639 i = append_to_buffer(b_point, STp->buffer, count);
3640 if (i) {
3641 retval = i;
3642 goto out;
3643 }
3644 blks = count / STp->block_size;
3645 STp->logical_blk_num += blks;
3646 if (STps->drv_block >= 0) {
3647 STps->drv_block += blks;
3648 }
3649 filp->f_pos += count;
3650 count = 0;
3651 }
3652
3653 if (doing_write && (STp->buffer)->syscall_result != 0) {
3654 retval = (STp->buffer)->syscall_result;
3655 goto out;
3656 }
3657
3658 if (STm->do_async_writes && ((STp->buffer)->buffer_bytes >= STp->write_threshold)) {
3659 /* Schedule an asynchronous write */
3660 (STp->buffer)->writing = ((STp->buffer)->buffer_bytes /
3661 STp->block_size) * STp->block_size;
3662 STp->dirty = !((STp->buffer)->writing ==
3663 (STp->buffer)->buffer_bytes);
3664
3665 i = osst_write_frame(STp, &SRpnt, 0);
3666 if (i < 0) {
3667 retval = (-EIO);
3668 goto out;
3669 }
3670 SRpnt = NULL; /* Prevent releasing this request! */
3671 }
3672 STps->at_sm &= (total == 0);
3673 if (total > 0)
3674 STps->eof = ST_NOEOF;
3675
3676 retval = total;
3677
3678 out:
3679 if (SRpnt != NULL) osst_release_request(SRpnt);
3680
3681 mutex_unlock(&STp->lock);
3682
3683 return retval;
3684 }
3685
3686
3687 /* Read command */
3688 static ssize_t osst_read(struct file * filp, char __user * buf, size_t count, loff_t *ppos)
3689 {
3690 ssize_t total, retval = 0;
3691 ssize_t i, transfer;
3692 int special;
3693 struct st_modedef * STm;
3694 struct st_partstat * STps;
3695 struct osst_request * SRpnt = NULL;
3696 struct osst_tape * STp = filp->private_data;
3697 char * name = tape_name(STp);
3698
3699
3700 if (mutex_lock_interruptible(&STp->lock))
3701 return (-ERESTARTSYS);
3702
3703 /*
3704 * If we are in the middle of error recovery, don't let anyone
3705 * else try and use this device. Also, if error recovery fails, it
3706 * may try and take the device offline, in which case all further
3707 * access to the device is prohibited.
3708 */
3709 if( !scsi_block_when_processing_errors(STp->device) ) {
3710 retval = (-ENXIO);
3711 goto out;
3712 }
3713
3714 if (STp->ready != ST_READY) {
3715 if (STp->ready == ST_NO_TAPE)
3716 retval = (-ENOMEDIUM);
3717 else
3718 retval = (-EIO);
3719 goto out;
3720 }
3721 STm = &(STp->modes[STp->current_mode]);
3722 if (!STm->defined) {
3723 retval = (-ENXIO);
3724 goto out;
3725 }
3726 #if DEBUG
3727 if (!STp->in_use) {
3728 printk(OSST_DEB_MSG "%s:D: Incorrect device.\n", name);
3729 retval = (-EIO);
3730 goto out;
3731 }
3732 #endif
3733 /* Must have initialized medium */
3734 if (!STp->header_ok) {
3735 retval = (-EIO);
3736 goto out;
3737 }
3738
3739 if (STp->do_auto_lock && STp->door_locked == ST_UNLOCKED && !do_door_lock(STp, 1))
3740 STp->door_locked = ST_LOCKED_AUTO;
3741
3742 STps = &(STp->ps[STp->partition]);
3743 if (STps->rw == ST_WRITING) {
3744 retval = osst_flush_buffer(STp, &SRpnt, 0);
3745 if (retval)
3746 goto out;
3747 STps->rw = ST_IDLE;
3748 /* FIXME -- this may leave the tape without EOD and up2date headers */
3749 }
3750
3751 if ((count % STp->block_size) != 0) {
3752 printk(KERN_WARNING
3753 "%s:W: Read (%Zd bytes) not multiple of tape block size (%d%c).\n", name, count,
3754 STp->block_size<1024?STp->block_size:STp->block_size/1024, STp->block_size<1024?'b':'k');
3755 }
3756
3757 #if DEBUG
3758 if (debugging && STps->eof != ST_NOEOF)
3759 printk(OSST_DEB_MSG "%s:D: EOF/EOM flag up (%d). Bytes %d\n", name,
3760 STps->eof, (STp->buffer)->buffer_bytes);
3761 #endif
3762 if ((STp->buffer)->buffer_bytes == 0 &&
3763 STps->eof >= ST_EOD_1) {
3764 if (STps->eof < ST_EOD) {
3765 STps->eof += 1;
3766 retval = 0;
3767 goto out;
3768 }
3769 retval = (-EIO); /* EOM or Blank Check */
3770 goto out;
3771 }
3772
3773 /* Check the buffer writability before any tape movement. Don't alter
3774 buffer data. */
3775 if (copy_from_user(&i, buf, 1) != 0 ||
3776 copy_to_user (buf, &i, 1) != 0 ||
3777 copy_from_user(&i, buf + count - 1, 1) != 0 ||
3778 copy_to_user (buf + count - 1, &i, 1) != 0) {
3779 retval = (-EFAULT);
3780 goto out;
3781 }
3782
3783 /* Loop until enough data in buffer or a special condition found */
3784 for (total = 0, special = 0; total < count - STp->block_size + 1 && !special; ) {
3785
3786 /* Get new data if the buffer is empty */
3787 if ((STp->buffer)->buffer_bytes == 0) {
3788 if (STps->eof == ST_FM_HIT)
3789 break;
3790 special = osst_get_logical_frame(STp, &SRpnt, STp->frame_seq_number, 0);
3791 if (special < 0) { /* No need to continue read */
3792 STp->frame_in_buffer = 0;
3793 retval = special;
3794 goto out;
3795 }
3796 }
3797
3798 /* Move the data from driver buffer to user buffer */
3799 if ((STp->buffer)->buffer_bytes > 0) {
3800 #if DEBUG
3801 if (debugging && STps->eof != ST_NOEOF)
3802 printk(OSST_DEB_MSG "%s:D: EOF up (%d). Left %d, needed %d.\n", name,
3803 STps->eof, (STp->buffer)->buffer_bytes, (int) (count - total));
3804 #endif
3805 /* force multiple of block size, note block_size may have been adjusted */
3806 transfer = (((STp->buffer)->buffer_bytes < count - total ?
3807 (STp->buffer)->buffer_bytes : count - total)/
3808 STp->block_size) * STp->block_size;
3809
3810 if (transfer == 0) {
3811 printk(KERN_WARNING
3812 "%s:W: Nothing can be transfered, requested %Zd, tape block size (%d%c).\n",
3813 name, count, STp->block_size < 1024?
3814 STp->block_size:STp->block_size/1024,
3815 STp->block_size<1024?'b':'k');
3816 break;
3817 }
3818 i = from_buffer(STp->buffer, buf, transfer);
3819 if (i) {
3820 retval = i;
3821 goto out;
3822 }
3823 STp->logical_blk_num += transfer / STp->block_size;
3824 STps->drv_block += transfer / STp->block_size;
3825 filp->f_pos += transfer;
3826 buf += transfer;
3827 total += transfer;
3828 }
3829
3830 if ((STp->buffer)->buffer_bytes == 0) {
3831 #if DEBUG
3832 if (debugging)
3833 printk(OSST_DEB_MSG "%s:D: Finished with frame %d\n",
3834 name, STp->frame_seq_number);
3835 #endif
3836 STp->frame_in_buffer = 0;
3837 STp->frame_seq_number++; /* frame to look for next time */
3838 }
3839 } /* for (total = 0, special = 0; total < count && !special; ) */
3840
3841 /* Change the eof state if no data from tape or buffer */
3842 if (total == 0) {
3843 if (STps->eof == ST_FM_HIT) {
3844 STps->eof = (STp->first_frame_position >= STp->eod_frame_ppos)?ST_EOD_2:ST_FM;
3845 STps->drv_block = 0;
3846 if (STps->drv_file >= 0)
3847 STps->drv_file++;
3848 }
3849 else if (STps->eof == ST_EOD_1) {
3850 STps->eof = ST_EOD_2;
3851 if (STps->drv_block > 0 && STps->drv_file >= 0)
3852 STps->drv_file++;
3853 STps->drv_block = 0;
3854 }
3855 else if (STps->eof == ST_EOD_2)
3856 STps->eof = ST_EOD;
3857 }
3858 else if (STps->eof == ST_FM)
3859 STps->eof = ST_NOEOF;
3860
3861 retval = total;
3862
3863 out:
3864 if (SRpnt != NULL) osst_release_request(SRpnt);
3865
3866 mutex_unlock(&STp->lock);
3867
3868 return retval;
3869 }
3870
3871
3872 /* Set the driver options */
3873 static void osst_log_options(struct osst_tape *STp, struct st_modedef *STm, char *name)
3874 {
3875 printk(KERN_INFO
3876 "%s:I: Mode %d options: buffer writes: %d, async writes: %d, read ahead: %d\n",
3877 name, STp->current_mode, STm->do_buffer_writes, STm->do_async_writes,
3878 STm->do_read_ahead);
3879 printk(KERN_INFO
3880 "%s:I: can bsr: %d, two FMs: %d, fast mteom: %d, auto lock: %d,\n",
3881 name, STp->can_bsr, STp->two_fm, STp->fast_mteom, STp->do_auto_lock);
3882 printk(KERN_INFO
3883 "%s:I: defs for wr: %d, no block limits: %d, partitions: %d, s2 log: %d\n",
3884 name, STm->defaults_for_writes, STp->omit_blklims, STp->can_partitions,
3885 STp->scsi2_logical);
3886 printk(KERN_INFO
3887 "%s:I: sysv: %d\n", name, STm->sysv);
3888 #if DEBUG
3889 printk(KERN_INFO
3890 "%s:D: debugging: %d\n",
3891 name, debugging);
3892 #endif
3893 }
3894
3895
3896 static int osst_set_options(struct osst_tape *STp, long options)
3897 {
3898 int value;
3899 long code;
3900 struct st_modedef * STm;
3901 char * name = tape_name(STp);
3902
3903 STm = &(STp->modes[STp->current_mode]);
3904 if (!STm->defined) {
3905 memcpy(STm, &(STp->modes[0]), sizeof(*STm));
3906 modes_defined = 1;
3907 #if DEBUG
3908 if (debugging)
3909 printk(OSST_DEB_MSG "%s:D: Initialized mode %d definition from mode 0\n",
3910 name, STp->current_mode);
3911 #endif
3912 }
3913
3914 code = options & MT_ST_OPTIONS;
3915 if (code == MT_ST_BOOLEANS) {
3916 STm->do_buffer_writes = (options & MT_ST_BUFFER_WRITES) != 0;
3917 STm->do_async_writes = (options & MT_ST_ASYNC_WRITES) != 0;
3918 STm->defaults_for_writes = (options & MT_ST_DEF_WRITES) != 0;
3919 STm->do_read_ahead = (options & MT_ST_READ_AHEAD) != 0;
3920 STp->two_fm = (options & MT_ST_TWO_FM) != 0;
3921 STp->fast_mteom = (options & MT_ST_FAST_MTEOM) != 0;
3922 STp->do_auto_lock = (options & MT_ST_AUTO_LOCK) != 0;
3923 STp->can_bsr = (options & MT_ST_CAN_BSR) != 0;
3924 STp->omit_blklims = (options & MT_ST_NO_BLKLIMS) != 0;
3925 if ((STp->device)->scsi_level >= SCSI_2)
3926 STp->can_partitions = (options & MT_ST_CAN_PARTITIONS) != 0;
3927 STp->scsi2_logical = (options & MT_ST_SCSI2LOGICAL) != 0;
3928 STm->sysv = (options & MT_ST_SYSV) != 0;
3929 #if DEBUG
3930 debugging = (options & MT_ST_DEBUGGING) != 0;
3931 #endif
3932 osst_log_options(STp, STm, name);
3933 }
3934 else if (code == MT_ST_SETBOOLEANS || code == MT_ST_CLEARBOOLEANS) {
3935 value = (code == MT_ST_SETBOOLEANS);
3936 if ((options & MT_ST_BUFFER_WRITES) != 0)
3937 STm->do_buffer_writes = value;
3938 if ((options & MT_ST_ASYNC_WRITES) != 0)
3939 STm->do_async_writes = value;
3940 if ((options & MT_ST_DEF_WRITES) != 0)
3941 STm->defaults_for_writes = value;
3942 if ((options & MT_ST_READ_AHEAD) != 0)
3943 STm->do_read_ahead = value;
3944 if ((options & MT_ST_TWO_FM) != 0)
3945 STp->two_fm = value;
3946 if ((options & MT_ST_FAST_MTEOM) != 0)
3947 STp->fast_mteom = value;
3948 if ((options & MT_ST_AUTO_LOCK) != 0)
3949 STp->do_auto_lock = value;
3950 if ((options & MT_ST_CAN_BSR) != 0)
3951 STp->can_bsr = value;
3952 if ((options & MT_ST_NO_BLKLIMS) != 0)
3953 STp->omit_blklims = value;
3954 if ((STp->device)->scsi_level >= SCSI_2 &&
3955 (options & MT_ST_CAN_PARTITIONS) != 0)
3956 STp->can_partitions = value;
3957 if ((options & MT_ST_SCSI2LOGICAL) != 0)
3958 STp->scsi2_logical = value;
3959 if ((options & MT_ST_SYSV) != 0)
3960 STm->sysv = value;
3961 #if DEBUG
3962 if ((options & MT_ST_DEBUGGING) != 0)
3963 debugging = value;
3964 #endif
3965 osst_log_options(STp, STm, name);
3966 }
3967 else if (code == MT_ST_WRITE_THRESHOLD) {
3968 value = (options & ~MT_ST_OPTIONS) * ST_KILOBYTE;
3969 if (value < 1 || value > osst_buffer_size) {
3970 printk(KERN_WARNING "%s:W: Write threshold %d too small or too large.\n",
3971 name, value);
3972 return (-EIO);
3973 }
3974 STp->write_threshold = value;
3975 printk(KERN_INFO "%s:I: Write threshold set to %d bytes.\n",
3976 name, value);
3977 }
3978 else if (code == MT_ST_DEF_BLKSIZE) {
3979 value = (options & ~MT_ST_OPTIONS);
3980 if (value == ~MT_ST_OPTIONS) {
3981 STm->default_blksize = (-1);
3982 printk(KERN_INFO "%s:I: Default block size disabled.\n", name);
3983 }
3984 else {
3985 if (value < 512 || value > OS_DATA_SIZE || OS_DATA_SIZE % value) {
3986 printk(KERN_WARNING "%s:W: Default block size cannot be set to %d.\n",
3987 name, value);
3988 return (-EINVAL);
3989 }
3990 STm->default_blksize = value;
3991 printk(KERN_INFO "%s:I: Default block size set to %d bytes.\n",
3992 name, STm->default_blksize);
3993 }
3994 }
3995 else if (code == MT_ST_TIMEOUTS) {
3996 value = (options & ~MT_ST_OPTIONS);
3997 if ((value & MT_ST_SET_LONG_TIMEOUT) != 0) {
3998 STp->long_timeout = (value & ~MT_ST_SET_LONG_TIMEOUT) * HZ;
3999 printk(KERN_INFO "%s:I: Long timeout set to %d seconds.\n", name,
4000 (value & ~MT_ST_SET_LONG_TIMEOUT));
4001 }
4002 else {
4003 STp->timeout = value * HZ;
4004 printk(KERN_INFO "%s:I: Normal timeout set to %d seconds.\n", name, value);
4005 }
4006 }
4007 else if (code == MT_ST_DEF_OPTIONS) {
4008 code = (options & ~MT_ST_CLEAR_DEFAULT);
4009 value = (options & MT_ST_CLEAR_DEFAULT);
4010 if (code == MT_ST_DEF_DENSITY) {
4011 if (value == MT_ST_CLEAR_DEFAULT) {
4012 STm->default_density = (-1);
4013 printk(KERN_INFO "%s:I: Density default disabled.\n", name);
4014 }
4015 else {
4016 STm->default_density = value & 0xff;
4017 printk(KERN_INFO "%s:I: Density default set to %x\n",
4018 name, STm->default_density);
4019 }
4020 }
4021 else if (code == MT_ST_DEF_DRVBUFFER) {
4022 if (value == MT_ST_CLEAR_DEFAULT) {
4023 STp->default_drvbuffer = 0xff;
4024 printk(KERN_INFO "%s:I: Drive buffer default disabled.\n", name);
4025 }
4026 else {
4027 STp->default_drvbuffer = value & 7;
4028 printk(KERN_INFO "%s:I: Drive buffer default set to %x\n",
4029 name, STp->default_drvbuffer);
4030 }
4031 }
4032 else if (code == MT_ST_DEF_COMPRESSION) {
4033 if (value == MT_ST_CLEAR_DEFAULT) {
4034 STm->default_compression = ST_DONT_TOUCH;
4035 printk(KERN_INFO "%s:I: Compression default disabled.\n", name);
4036 }
4037 else {
4038 STm->default_compression = (value & 1 ? ST_YES : ST_NO);
4039 printk(KERN_INFO "%s:I: Compression default set to %x\n",
4040 name, (value & 1));
4041 }
4042 }
4043 }
4044 else
4045 return (-EIO);
4046
4047 return 0;
4048 }
4049
4050
4051 /* Internal ioctl function */
4052 static int osst_int_ioctl(struct osst_tape * STp, struct osst_request ** aSRpnt,
4053 unsigned int cmd_in, unsigned long arg)
4054 {
4055 int timeout;
4056 long ltmp;
4057 int i, ioctl_result;
4058 int chg_eof = 1;
4059 unsigned char cmd[MAX_COMMAND_SIZE];
4060 struct osst_request * SRpnt = * aSRpnt;
4061 struct st_partstat * STps;
4062 int fileno, blkno, at_sm, frame_seq_numbr, logical_blk_num;
4063 int datalen = 0, direction = DMA_NONE;
4064 char * name = tape_name(STp);
4065
4066 if (STp->ready != ST_READY && cmd_in != MTLOAD) {
4067 if (STp->ready == ST_NO_TAPE)
4068 return (-ENOMEDIUM);
4069 else
4070 return (-EIO);
4071 }
4072 timeout = STp->long_timeout;
4073 STps = &(STp->ps[STp->partition]);
4074 fileno = STps->drv_file;
4075 blkno = STps->drv_block;
4076 at_sm = STps->at_sm;
4077 frame_seq_numbr = STp->frame_seq_number;
4078 logical_blk_num = STp->logical_blk_num;
4079
4080 memset(cmd, 0, MAX_COMMAND_SIZE);
4081 switch (cmd_in) {
4082 case MTFSFM:
4083 chg_eof = 0; /* Changed from the FSF after this */
4084 case MTFSF:
4085 if (STp->raw)
4086 return (-EIO);
4087 if (STp->linux_media)
4088 ioctl_result = osst_space_over_filemarks_forward_fast(STp, &SRpnt, cmd_in, arg);
4089 else
4090 ioctl_result = osst_space_over_filemarks_forward_slow(STp, &SRpnt, cmd_in, arg);
4091 if (fileno >= 0)
4092 fileno += arg;
4093 blkno = 0;
4094 at_sm &= (arg == 0);
4095 goto os_bypass;
4096
4097 case MTBSF:
4098 chg_eof = 0; /* Changed from the FSF after this */
4099 case MTBSFM:
4100 if (STp->raw)
4101 return (-EIO);
4102 ioctl_result = osst_space_over_filemarks_backward(STp, &SRpnt, cmd_in, arg);
4103 if (fileno >= 0)
4104 fileno -= arg;
4105 blkno = (-1); /* We can't know the block number */
4106 at_sm &= (arg == 0);
4107 goto os_bypass;
4108
4109 case MTFSR:
4110 case MTBSR:
4111 #if DEBUG
4112 if (debugging)
4113 printk(OSST_DEB_MSG "%s:D: Skipping %lu blocks %s from logical block %d\n",
4114 name, arg, cmd_in==MTFSR?"forward":"backward", logical_blk_num);
4115 #endif
4116 if (cmd_in == MTFSR) {
4117 logical_blk_num += arg;
4118 if (blkno >= 0) blkno += arg;
4119 }
4120 else {
4121 logical_blk_num -= arg;
4122 if (blkno >= 0) blkno -= arg;
4123 }
4124 ioctl_result = osst_seek_logical_blk(STp, &SRpnt, logical_blk_num);
4125 fileno = STps->drv_file;
4126 blkno = STps->drv_block;
4127 at_sm &= (arg == 0);
4128 goto os_bypass;
4129
4130 case MTFSS:
4131 cmd[0] = SPACE;
4132 cmd[1] = 0x04; /* Space Setmarks */ /* FIXME -- OS can't do this? */
4133 cmd[2] = (arg >> 16);
4134 cmd[3] = (arg >> 8);
4135 cmd[4] = arg;
4136 #if DEBUG
4137 if (debugging)
4138 printk(OSST_DEB_MSG "%s:D: Spacing tape forward %d setmarks.\n", name,
4139 cmd[2] * 65536 + cmd[3] * 256 + cmd[4]);
4140 #endif
4141 if (arg != 0) {
4142 blkno = fileno = (-1);
4143 at_sm = 1;
4144 }
4145 break;
4146 case MTBSS:
4147 cmd[0] = SPACE;
4148 cmd[1] = 0x04; /* Space Setmarks */ /* FIXME -- OS can't do this? */
4149 ltmp = (-arg);
4150 cmd[2] = (ltmp >> 16);
4151 cmd[3] = (ltmp >> 8);
4152 cmd[4] = ltmp;
4153 #if DEBUG
4154 if (debugging) {
4155 if (cmd[2] & 0x80)
4156 ltmp = 0xff000000;
4157 ltmp = ltmp | (cmd[2] << 16) | (cmd[3] << 8) | cmd[4];
4158 printk(OSST_DEB_MSG "%s:D: Spacing tape backward %ld setmarks.\n",
4159 name, (-ltmp));
4160 }
4161 #endif
4162 if (arg != 0) {
4163 blkno = fileno = (-1);
4164 at_sm = 1;
4165 }
4166 break;
4167 case MTWEOF:
4168 if ((STps->rw == ST_WRITING || STp->dirty) && !STp->pos_unknown) {
4169 STp->write_type = OS_WRITE_DATA;
4170 ioctl_result = osst_flush_write_buffer(STp, &SRpnt);
4171 } else
4172 ioctl_result = 0;
4173 #if DEBUG
4174 if (debugging)
4175 printk(OSST_DEB_MSG "%s:D: Writing %ld filemark(s).\n", name, arg);
4176 #endif
4177 for (i=0; i<arg; i++)
4178 ioctl_result |= osst_write_filemark(STp, &SRpnt);
4179 if (fileno >= 0) fileno += arg;
4180 if (blkno >= 0) blkno = 0;
4181 goto os_bypass;
4182
4183 case MTWSM:
4184 if (STp->write_prot)
4185 return (-EACCES);
4186 if (!STp->raw)
4187 return 0;
4188 cmd[0] = WRITE_FILEMARKS; /* FIXME -- need OS version */
4189 if (cmd_in == MTWSM)
4190 cmd[1] = 2;
4191 cmd[2] = (arg >> 16);
4192 cmd[3] = (arg >> 8);
4193 cmd[4] = arg;
4194 timeout = STp->timeout;
4195 #if DEBUG
4196 if (debugging)
4197 printk(OSST_DEB_MSG "%s:D: Writing %d setmark(s).\n", name,
4198 cmd[2] * 65536 + cmd[3] * 256 + cmd[4]);
4199 #endif
4200 if (fileno >= 0)
4201 fileno += arg;
4202 blkno = 0;
4203 at_sm = (cmd_in == MTWSM);
4204 break;
4205 case MTOFFL:
4206 case MTLOAD:
4207 case MTUNLOAD:
4208 case MTRETEN:
4209 cmd[0] = START_STOP;
4210 cmd[1] = 1; /* Don't wait for completion */
4211 if (cmd_in == MTLOAD) {
4212 if (STp->ready == ST_NO_TAPE)
4213 cmd[4] = 4; /* open tray */
4214 else
4215 cmd[4] = 1; /* load */
4216 }
4217 if (cmd_in == MTRETEN)
4218 cmd[4] = 3; /* retension then mount */
4219 if (cmd_in == MTOFFL)
4220 cmd[4] = 4; /* rewind then eject */
4221 timeout = STp->timeout;
4222 #if DEBUG
4223 if (debugging) {
4224 switch (cmd_in) {
4225 case MTUNLOAD:
4226 printk(OSST_DEB_MSG "%s:D: Unloading tape.\n", name);
4227 break;
4228 case MTLOAD:
4229 printk(OSST_DEB_MSG "%s:D: Loading tape.\n", name);
4230 break;
4231 case MTRETEN:
4232 printk(OSST_DEB_MSG "%s:D: Retensioning tape.\n", name);
4233 break;
4234 case MTOFFL:
4235 printk(OSST_DEB_MSG "%s:D: Ejecting tape.\n", name);
4236 break;
4237 }
4238 }
4239 #endif
4240 fileno = blkno = at_sm = frame_seq_numbr = logical_blk_num = 0 ;
4241 break;
4242 case MTNOP:
4243 #if DEBUG
4244 if (debugging)
4245 printk(OSST_DEB_MSG "%s:D: No-op on tape.\n", name);
4246 #endif
4247 return 0; /* Should do something ? */
4248 break;
4249 case MTEOM:
4250 #if DEBUG
4251 if (debugging)
4252 printk(OSST_DEB_MSG "%s:D: Spacing to end of recorded medium.\n", name);
4253 #endif
4254 if ((osst_position_tape_and_confirm(STp, &SRpnt, STp->eod_frame_ppos) < 0) ||
4255 (osst_get_logical_frame(STp, &SRpnt, -1, 0) < 0)) {
4256 ioctl_result = -EIO;
4257 goto os_bypass;
4258 }
4259 if (STp->buffer->aux->frame_type != OS_FRAME_TYPE_EOD) {
4260 #if DEBUG
4261 printk(OSST_DEB_MSG "%s:D: No EOD frame found where expected.\n", name);
4262 #endif
4263 ioctl_result = -EIO;
4264 goto os_bypass;
4265 }
4266 ioctl_result = osst_set_frame_position(STp, &SRpnt, STp->eod_frame_ppos, 0);
4267 fileno = STp->filemark_cnt;
4268 blkno = at_sm = 0;
4269 goto os_bypass;
4270
4271 case MTERASE:
4272 if (STp->write_prot)
4273 return (-EACCES);
4274 ioctl_result = osst_reset_header(STp, &SRpnt);
4275 i = osst_write_eod(STp, &SRpnt);
4276 if (i < ioctl_result) ioctl_result = i;
4277 i = osst_position_tape_and_confirm(STp, &SRpnt, STp->eod_frame_ppos);
4278 if (i < ioctl_result) ioctl_result = i;
4279 fileno = blkno = at_sm = 0 ;
4280 goto os_bypass;
4281
4282 case MTREW:
4283 cmd[0] = REZERO_UNIT; /* rewind */
4284 cmd[1] = 1;
4285 #if DEBUG
4286 if (debugging)
4287 printk(OSST_DEB_MSG "%s:D: Rewinding tape, Immed=%d.\n", name, cmd[1]);
4288 #endif
4289 fileno = blkno = at_sm = frame_seq_numbr = logical_blk_num = 0 ;
4290 break;
4291
4292 case MTSETBLK: /* Set block length */
4293 if ((STps->drv_block == 0 ) &&
4294 !STp->dirty &&
4295 ((STp->buffer)->buffer_bytes == 0) &&
4296 ((arg & MT_ST_BLKSIZE_MASK) >= 512 ) &&
4297 ((arg & MT_ST_BLKSIZE_MASK) <= OS_DATA_SIZE) &&
4298 !(OS_DATA_SIZE % (arg & MT_ST_BLKSIZE_MASK)) ) {
4299 /*
4300 * Only allowed to change the block size if you opened the
4301 * device at the beginning of a file before writing anything.
4302 * Note, that when reading, changing block_size is futile,
4303 * as the size used when writing overrides it.
4304 */
4305 STp->block_size = (arg & MT_ST_BLKSIZE_MASK);
4306 printk(KERN_INFO "%s:I: Block size set to %d bytes.\n",
4307 name, STp->block_size);
4308 return 0;
4309 }
4310 case MTSETDENSITY: /* Set tape density */
4311 case MTSETDRVBUFFER: /* Set drive buffering */
4312 case SET_DENS_AND_BLK: /* Set density and block size */
4313 chg_eof = 0;
4314 if (STp->dirty || (STp->buffer)->buffer_bytes != 0)
4315 return (-EIO); /* Not allowed if data in buffer */
4316 if ((cmd_in == MTSETBLK || cmd_in == SET_DENS_AND_BLK) &&
4317 (arg & MT_ST_BLKSIZE_MASK) != 0 &&
4318 (arg & MT_ST_BLKSIZE_MASK) != STp->block_size ) {
4319 printk(KERN_WARNING "%s:W: Illegal to set block size to %d%s.\n",
4320 name, (int)(arg & MT_ST_BLKSIZE_MASK),
4321 (OS_DATA_SIZE % (arg & MT_ST_BLKSIZE_MASK))?"":" now");
4322 return (-EINVAL);
4323 }
4324 return 0; /* FIXME silently ignore if block size didn't change */
4325
4326 default:
4327 return (-ENOSYS);
4328 }
4329
4330 SRpnt = osst_do_scsi(SRpnt, STp, cmd, datalen, direction, timeout, MAX_RETRIES, 1);
4331
4332 ioctl_result = (STp->buffer)->syscall_result;
4333
4334 if (!SRpnt) {
4335 #if DEBUG
4336 printk(OSST_DEB_MSG "%s:D: Couldn't exec scsi cmd for IOCTL\n", name);
4337 #endif
4338 return ioctl_result;
4339 }
4340
4341 if (!ioctl_result) { /* SCSI command successful */
4342 STp->frame_seq_number = frame_seq_numbr;
4343 STp->logical_blk_num = logical_blk_num;
4344 }
4345
4346 os_bypass:
4347 #if DEBUG
4348 if (debugging)
4349 printk(OSST_DEB_MSG "%s:D: IOCTL (%d) Result=%d\n", name, cmd_in, ioctl_result);
4350 #endif
4351
4352 if (!ioctl_result) { /* success */
4353
4354 if (cmd_in == MTFSFM) {
4355 fileno--;
4356 blkno--;
4357 }
4358 if (cmd_in == MTBSFM) {
4359 fileno++;
4360 blkno++;
4361 }
4362 STps->drv_block = blkno;
4363 STps->drv_file = fileno;
4364 STps->at_sm = at_sm;
4365
4366 if (cmd_in == MTEOM)
4367 STps->eof = ST_EOD;
4368 else if ((cmd_in == MTFSFM || cmd_in == MTBSF) && STps->eof == ST_FM_HIT) {
4369 ioctl_result = osst_seek_logical_blk(STp, &SRpnt, STp->logical_blk_num-1);
4370 STps->drv_block++;
4371 STp->logical_blk_num++;
4372 STp->frame_seq_number++;
4373 STp->frame_in_buffer = 0;
4374 STp->buffer->read_pointer = 0;
4375 }
4376 else if (cmd_in == MTFSF)
4377 STps->eof = (STp->first_frame_position >= STp->eod_frame_ppos)?ST_EOD:ST_FM;
4378 else if (chg_eof)
4379 STps->eof = ST_NOEOF;
4380
4381 if (cmd_in == MTOFFL || cmd_in == MTUNLOAD)
4382 STp->rew_at_close = 0;
4383 else if (cmd_in == MTLOAD) {
4384 for (i=0; i < ST_NBR_PARTITIONS; i++) {
4385 STp->ps[i].rw = ST_IDLE;
4386 STp->ps[i].last_block_valid = 0;/* FIXME - where else is this field maintained? */
4387 }
4388 STp->partition = 0;
4389 }
4390
4391 if (cmd_in == MTREW) {
4392 ioctl_result = osst_position_tape_and_confirm(STp, &SRpnt, STp->first_data_ppos);
4393 if (ioctl_result > 0)
4394 ioctl_result = 0;
4395 }
4396
4397 } else if (cmd_in == MTBSF || cmd_in == MTBSFM ) {
4398 if (osst_position_tape_and_confirm(STp, &SRpnt, STp->first_data_ppos) < 0)
4399 STps->drv_file = STps->drv_block = -1;
4400 else
4401 STps->drv_file = STps->drv_block = 0;
4402 STps->eof = ST_NOEOF;
4403 } else if (cmd_in == MTFSF || cmd_in == MTFSFM) {
4404 if (osst_position_tape_and_confirm(STp, &SRpnt, STp->eod_frame_ppos) < 0)
4405 STps->drv_file = STps->drv_block = -1;
4406 else {
4407 STps->drv_file = STp->filemark_cnt;
4408 STps->drv_block = 0;
4409 }
4410 STps->eof = ST_EOD;
4411 } else if (cmd_in == MTBSR || cmd_in == MTFSR || cmd_in == MTWEOF || cmd_in == MTEOM) {
4412 STps->drv_file = STps->drv_block = (-1);
4413 STps->eof = ST_NOEOF;
4414 STp->header_ok = 0;
4415 } else if (cmd_in == MTERASE) {
4416 STp->header_ok = 0;
4417 } else if (SRpnt) { /* SCSI command was not completely successful. */
4418 if (SRpnt->sense[2] & 0x40) {
4419 STps->eof = ST_EOM_OK;
4420 STps->drv_block = 0;
4421 }
4422 if (chg_eof)
4423 STps->eof = ST_NOEOF;
4424
4425 if ((SRpnt->sense[2] & 0x0f) == BLANK_CHECK)
4426 STps->eof = ST_EOD;
4427
4428 if (cmd_in == MTLOAD && osst_wait_for_medium(STp, &SRpnt, 60))
4429 ioctl_result = osst_wait_ready(STp, &SRpnt, 5 * 60, OSST_WAIT_POSITION_COMPLETE);
4430 }
4431 *aSRpnt = SRpnt;
4432
4433 return ioctl_result;
4434 }
4435
4436
4437 /* Open the device */
4438 static int __os_scsi_tape_open(struct inode * inode, struct file * filp)
4439 {
4440 unsigned short flags;
4441 int i, b_size, new_session = 0, retval = 0;
4442 unsigned char cmd[MAX_COMMAND_SIZE];
4443 struct osst_request * SRpnt = NULL;
4444 struct osst_tape * STp;
4445 struct st_modedef * STm;
4446 struct st_partstat * STps;
4447 char * name;
4448 int dev = TAPE_NR(inode);
4449 int mode = TAPE_MODE(inode);
4450
4451 /*
4452 * We really want to do nonseekable_open(inode, filp); here, but some
4453 * versions of tar incorrectly call lseek on tapes and bail out if that
4454 * fails. So we disallow pread() and pwrite(), but permit lseeks.
4455 */
4456 filp->f_mode &= ~(FMODE_PREAD | FMODE_PWRITE);
4457
4458 write_lock(&os_scsi_tapes_lock);
4459 if (dev >= osst_max_dev || os_scsi_tapes == NULL ||
4460 (STp = os_scsi_tapes[dev]) == NULL || !STp->device) {
4461 write_unlock(&os_scsi_tapes_lock);
4462 return (-ENXIO);
4463 }
4464
4465 name = tape_name(STp);
4466
4467 if (STp->in_use) {
4468 write_unlock(&os_scsi_tapes_lock);
4469 #if DEBUG
4470 printk(OSST_DEB_MSG "%s:D: Device already in use.\n", name);
4471 #endif
4472 return (-EBUSY);
4473 }
4474 if (scsi_device_get(STp->device)) {
4475 write_unlock(&os_scsi_tapes_lock);
4476 #if DEBUG
4477 printk(OSST_DEB_MSG "%s:D: Failed scsi_device_get.\n", name);
4478 #endif
4479 return (-ENXIO);
4480 }
4481 filp->private_data = STp;
4482 STp->in_use = 1;
4483 write_unlock(&os_scsi_tapes_lock);
4484 STp->rew_at_close = TAPE_REWIND(inode);
4485
4486 if( !scsi_block_when_processing_errors(STp->device) ) {
4487 return -ENXIO;
4488 }
4489
4490 if (mode != STp->current_mode) {
4491 #if DEBUG
4492 if (debugging)
4493 printk(OSST_DEB_MSG "%s:D: Mode change from %d to %d.\n",
4494 name, STp->current_mode, mode);
4495 #endif
4496 new_session = 1;
4497 STp->current_mode = mode;
4498 }
4499 STm = &(STp->modes[STp->current_mode]);
4500
4501 flags = filp->f_flags;
4502 STp->write_prot = ((flags & O_ACCMODE) == O_RDONLY);
4503
4504 STp->raw = TAPE_IS_RAW(inode);
4505 if (STp->raw)
4506 STp->header_ok = 0;
4507
4508 /* Allocate data segments for this device's tape buffer */
4509 if (!enlarge_buffer(STp->buffer, STp->restr_dma)) {
4510 printk(KERN_ERR "%s:E: Unable to allocate memory segments for tape buffer.\n", name);
4511 retval = (-EOVERFLOW);
4512 goto err_out;
4513 }
4514 if (STp->buffer->buffer_size >= OS_FRAME_SIZE) {
4515 for (i = 0, b_size = 0;
4516 (i < STp->buffer->sg_segs) && ((b_size + STp->buffer->sg[i].length) <= OS_DATA_SIZE);
4517 b_size += STp->buffer->sg[i++].length);
4518 STp->buffer->aux = (os_aux_t *) (page_address(sg_page(&STp->buffer->sg[i])) + OS_DATA_SIZE - b_size);
4519 #if DEBUG
4520 printk(OSST_DEB_MSG "%s:D: b_data points to %p in segment 0 at %p\n", name,
4521 STp->buffer->b_data, page_address(STp->buffer->sg[0].page));
4522 printk(OSST_DEB_MSG "%s:D: AUX points to %p in segment %d at %p\n", name,
4523 STp->buffer->aux, i, page_address(STp->buffer->sg[i].page));
4524 #endif
4525 } else {
4526 STp->buffer->aux = NULL; /* this had better never happen! */
4527 printk(KERN_NOTICE "%s:A: Framesize %d too large for buffer.\n", name, OS_FRAME_SIZE);
4528 retval = (-EIO);
4529 goto err_out;
4530 }
4531 STp->buffer->writing = 0;
4532 STp->buffer->syscall_result = 0;
4533 STp->dirty = 0;
4534 for (i=0; i < ST_NBR_PARTITIONS; i++) {
4535 STps = &(STp->ps[i]);
4536 STps->rw = ST_IDLE;
4537 }
4538 STp->ready = ST_READY;
4539 #if DEBUG
4540 STp->nbr_waits = STp->nbr_finished = 0;
4541 #endif
4542
4543 memset (cmd, 0, MAX_COMMAND_SIZE);
4544 cmd[0] = TEST_UNIT_READY;
4545
4546 SRpnt = osst_do_scsi(NULL, STp, cmd, 0, DMA_NONE, STp->timeout, MAX_RETRIES, 1);
4547 if (!SRpnt) {
4548 retval = (STp->buffer)->syscall_result; /* FIXME - valid? */
4549 goto err_out;
4550 }
4551 if ((SRpnt->sense[0] & 0x70) == 0x70 &&
4552 (SRpnt->sense[2] & 0x0f) == NOT_READY &&
4553 SRpnt->sense[12] == 4 ) {
4554 #if DEBUG
4555 printk(OSST_DEB_MSG "%s:D: Unit not ready, cause %x\n", name, SRpnt->sense[13]);
4556 #endif
4557 if (filp->f_flags & O_NONBLOCK) {
4558 retval = -EAGAIN;
4559 goto err_out;
4560 }
4561 if (SRpnt->sense[13] == 2) { /* initialize command required (LOAD) */
4562 memset (cmd, 0, MAX_COMMAND_SIZE);
4563 cmd[0] = START_STOP;
4564 cmd[1] = 1;
4565 cmd[4] = 1;
4566 SRpnt = osst_do_scsi(SRpnt, STp, cmd, 0, DMA_NONE,
4567 STp->timeout, MAX_RETRIES, 1);
4568 }
4569 osst_wait_ready(STp, &SRpnt, (SRpnt->sense[13]==1?15:3) * 60, 0);
4570 }
4571 if ((SRpnt->sense[0] & 0x70) == 0x70 &&
4572 (SRpnt->sense[2] & 0x0f) == UNIT_ATTENTION) { /* New media? */
4573 #if DEBUG
4574 printk(OSST_DEB_MSG "%s:D: Unit wants attention\n", name);
4575 #endif
4576 STp->header_ok = 0;
4577
4578 for (i=0; i < 10; i++) {
4579
4580 memset (cmd, 0, MAX_COMMAND_SIZE);
4581 cmd[0] = TEST_UNIT_READY;
4582
4583 SRpnt = osst_do_scsi(SRpnt, STp, cmd, 0, DMA_NONE,
4584 STp->timeout, MAX_RETRIES, 1);
4585 if ((SRpnt->sense[0] & 0x70) != 0x70 ||
4586 (SRpnt->sense[2] & 0x0f) != UNIT_ATTENTION)
4587 break;
4588 }
4589
4590 STp->pos_unknown = 0;
4591 STp->partition = STp->new_partition = 0;
4592 if (STp->can_partitions)
4593 STp->nbr_partitions = 1; /* This guess will be updated later if necessary */
4594 for (i=0; i < ST_NBR_PARTITIONS; i++) {
4595 STps = &(STp->ps[i]);
4596 STps->rw = ST_IDLE; /* FIXME - seems to be redundant... */
4597 STps->eof = ST_NOEOF;
4598 STps->at_sm = 0;
4599 STps->last_block_valid = 0;
4600 STps->drv_block = 0;
4601 STps->drv_file = 0 ;
4602 }
4603 new_session = 1;
4604 STp->recover_count = 0;
4605 STp->abort_count = 0;
4606 }
4607 /*
4608 * if we have valid headers from before, and the drive/tape seem untouched,
4609 * open without reconfiguring and re-reading the headers
4610 */
4611 if (!STp->buffer->syscall_result && STp->header_ok &&
4612 !SRpnt->result && SRpnt->sense[0] == 0) {
4613
4614 memset(cmd, 0, MAX_COMMAND_SIZE);
4615 cmd[0] = MODE_SENSE;
4616 cmd[1] = 8;
4617 cmd[2] = VENDOR_IDENT_PAGE;
4618 cmd[4] = VENDOR_IDENT_PAGE_LENGTH + MODE_HEADER_LENGTH;
4619
4620 SRpnt = osst_do_scsi(SRpnt, STp, cmd, cmd[4], DMA_FROM_DEVICE, STp->timeout, 0, 1);
4621
4622 if (STp->buffer->syscall_result ||
4623 STp->buffer->b_data[MODE_HEADER_LENGTH + 2] != 'L' ||
4624 STp->buffer->b_data[MODE_HEADER_LENGTH + 3] != 'I' ||
4625 STp->buffer->b_data[MODE_HEADER_LENGTH + 4] != 'N' ||
4626 STp->buffer->b_data[MODE_HEADER_LENGTH + 5] != '4' ) {
4627 #if DEBUG
4628 printk(OSST_DEB_MSG "%s:D: Signature was changed to %c%c%c%c\n", name,
4629 STp->buffer->b_data[MODE_HEADER_LENGTH + 2],
4630 STp->buffer->b_data[MODE_HEADER_LENGTH + 3],
4631 STp->buffer->b_data[MODE_HEADER_LENGTH + 4],
4632 STp->buffer->b_data[MODE_HEADER_LENGTH + 5]);
4633 #endif
4634 STp->header_ok = 0;
4635 }
4636 i = STp->first_frame_position;
4637 if (STp->header_ok && i == osst_get_frame_position(STp, &SRpnt)) {
4638 if (STp->door_locked == ST_UNLOCKED) {
4639 if (do_door_lock(STp, 1))
4640 printk(KERN_INFO "%s:I: Can't lock drive door\n", name);
4641 else
4642 STp->door_locked = ST_LOCKED_AUTO;
4643 }
4644 if (!STp->frame_in_buffer) {
4645 STp->block_size = (STm->default_blksize > 0) ?
4646 STm->default_blksize : OS_DATA_SIZE;
4647 STp->buffer->buffer_bytes = STp->buffer->read_pointer = 0;
4648 }
4649 STp->buffer->buffer_blocks = OS_DATA_SIZE / STp->block_size;
4650 STp->fast_open = 1;
4651 osst_release_request(SRpnt);
4652 return 0;
4653 }
4654 #if DEBUG
4655 if (i != STp->first_frame_position)
4656 printk(OSST_DEB_MSG "%s:D: Tape position changed from %d to %d\n",
4657 name, i, STp->first_frame_position);
4658 #endif
4659 STp->header_ok = 0;
4660 }
4661 STp->fast_open = 0;
4662
4663 if ((STp->buffer)->syscall_result != 0 && /* in all error conditions except no medium */
4664 (SRpnt->sense[2] != 2 || SRpnt->sense[12] != 0x3A) ) {
4665
4666 memset(cmd, 0, MAX_COMMAND_SIZE);
4667 cmd[0] = MODE_SELECT;
4668 cmd[1] = 0x10;
4669 cmd[4] = 4 + MODE_HEADER_LENGTH;
4670
4671 (STp->buffer)->b_data[0] = cmd[4] - 1;
4672 (STp->buffer)->b_data[1] = 0; /* Medium Type - ignoring */
4673 (STp->buffer)->b_data[2] = 0; /* Reserved */
4674 (STp->buffer)->b_data[3] = 0; /* Block Descriptor Length */
4675 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 0] = 0x3f;
4676 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 1] = 1;
4677 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 2] = 2;
4678 (STp->buffer)->b_data[MODE_HEADER_LENGTH + 3] = 3;
4679
4680 #if DEBUG
4681 printk(OSST_DEB_MSG "%s:D: Applying soft reset\n", name);
4682 #endif
4683 SRpnt = osst_do_scsi(SRpnt, STp, cmd, cmd[4], DMA_TO_DEVICE, STp->timeout, 0, 1);
4684
4685 STp->header_ok = 0;
4686
4687 for (i=0; i < 10; i++) {
4688
4689 memset (cmd, 0, MAX_COMMAND_SIZE);
4690 cmd[0] = TEST_UNIT_READY;
4691
4692 SRpnt = osst_do_scsi(SRpnt, STp, cmd, 0, DMA_NONE,
4693 STp->timeout, MAX_RETRIES, 1);
4694 if ((SRpnt->sense[0] & 0x70) != 0x70 ||
4695 (SRpnt->sense[2] & 0x0f) == NOT_READY)
4696 break;
4697
4698 if ((SRpnt->sense[2] & 0x0f) == UNIT_ATTENTION) {
4699 STp->pos_unknown = 0;
4700 STp->partition = STp->new_partition = 0;
4701 if (STp->can_partitions)
4702 STp->nbr_partitions = 1; /* This guess will be updated later if necessary */
4703 for (i=0; i < ST_NBR_PARTITIONS; i++) {
4704 STps = &(STp->ps[i]);
4705 STps->rw = ST_IDLE;
4706 STps->eof = ST_NOEOF;
4707 STps->at_sm = 0;
4708 STps->last_block_valid = 0;
4709 STps->drv_block = 0;
4710 STps->drv_file = 0 ;
4711 }
4712 new_session = 1;
4713 }
4714 }
4715 }
4716
4717 if (osst_wait_ready(STp, &SRpnt, 15 * 60, 0)) /* FIXME - not allowed with NOBLOCK */
4718 printk(KERN_INFO "%s:I: Device did not become Ready in open\n", name);
4719
4720 if ((STp->buffer)->syscall_result != 0) {
4721 if ((STp->device)->scsi_level >= SCSI_2 &&
4722 (SRpnt->sense[0] & 0x70) == 0x70 &&
4723 (SRpnt->sense[2] & 0x0f) == NOT_READY &&
4724 SRpnt->sense[12] == 0x3a) { /* Check ASC */
4725 STp->ready = ST_NO_TAPE;
4726 } else
4727 STp->ready = ST_NOT_READY;
4728 osst_release_request(SRpnt);
4729 SRpnt = NULL;
4730 STp->density = 0; /* Clear the erroneous "residue" */
4731 STp->write_prot = 0;
4732 STp->block_size = 0;
4733 STp->ps[0].drv_file = STp->ps[0].drv_block = (-1);
4734 STp->partition = STp->new_partition = 0;
4735 STp->door_locked = ST_UNLOCKED;
4736 return 0;
4737 }
4738
4739 osst_configure_onstream(STp, &SRpnt);
4740
4741 STp->block_size = STp->raw ? OS_FRAME_SIZE : (
4742 (STm->default_blksize > 0) ? STm->default_blksize : OS_DATA_SIZE);
4743 STp->buffer->buffer_blocks = STp->raw ? 1 : OS_DATA_SIZE / STp->block_size;
4744 STp->buffer->buffer_bytes =
4745 STp->buffer->read_pointer =
4746 STp->frame_in_buffer = 0;
4747
4748 #if DEBUG
4749 if (debugging)
4750 printk(OSST_DEB_MSG "%s:D: Block size: %d, frame size: %d, buffer size: %d (%d blocks).\n",
4751 name, STp->block_size, OS_FRAME_SIZE, (STp->buffer)->buffer_size,
4752 (STp->buffer)->buffer_blocks);
4753 #endif
4754
4755 if (STp->drv_write_prot) {
4756 STp->write_prot = 1;
4757 #if DEBUG
4758 if (debugging)
4759 printk(OSST_DEB_MSG "%s:D: Write protected\n", name);
4760 #endif
4761 if ((flags & O_ACCMODE) == O_WRONLY || (flags & O_ACCMODE) == O_RDWR) {
4762 retval = (-EROFS);
4763 goto err_out;
4764 }
4765 }
4766
4767 if (new_session) { /* Change the drive parameters for the new mode */
4768 #if DEBUG
4769 if (debugging)
4770 printk(OSST_DEB_MSG "%s:D: New Session\n", name);
4771 #endif
4772 STp->density_changed = STp->blksize_changed = 0;
4773 STp->compression_changed = 0;
4774 }
4775
4776 /*
4777 * properly position the tape and check the ADR headers
4778 */
4779 if (STp->door_locked == ST_UNLOCKED) {
4780 if (do_door_lock(STp, 1))
4781 printk(KERN_INFO "%s:I: Can't lock drive door\n", name);
4782 else
4783 STp->door_locked = ST_LOCKED_AUTO;
4784 }
4785
4786 osst_analyze_headers(STp, &SRpnt);
4787
4788 osst_release_request(SRpnt);
4789 SRpnt = NULL;
4790
4791 return 0;
4792
4793 err_out:
4794 if (SRpnt != NULL)
4795 osst_release_request(SRpnt);
4796 normalize_buffer(STp->buffer);
4797 STp->header_ok = 0;
4798 STp->in_use = 0;
4799 scsi_device_put(STp->device);
4800
4801 return retval;
4802 }
4803
4804 /* BKL pushdown: spaghetti avoidance wrapper */
4805 static int os_scsi_tape_open(struct inode * inode, struct file * filp)
4806 {
4807 int ret;
4808
4809 lock_kernel();
4810 ret = __os_scsi_tape_open(inode, filp);
4811 unlock_kernel();
4812 return ret;
4813 }
4814
4815
4816
4817 /* Flush the tape buffer before close */
4818 static int os_scsi_tape_flush(struct file * filp, fl_owner_t id)
4819 {
4820 int result = 0, result2;
4821 struct osst_tape * STp = filp->private_data;
4822 struct st_modedef * STm = &(STp->modes[STp->current_mode]);
4823 struct st_partstat * STps = &(STp->ps[STp->partition]);
4824 struct osst_request * SRpnt = NULL;
4825 char * name = tape_name(STp);
4826
4827 if (file_count(filp) > 1)
4828 return 0;
4829
4830 if ((STps->rw == ST_WRITING || STp->dirty) && !STp->pos_unknown) {
4831 STp->write_type = OS_WRITE_DATA;
4832 result = osst_flush_write_buffer(STp, &SRpnt);
4833 if (result != 0 && result != (-ENOSPC))
4834 goto out;
4835 }
4836 if ( STps->rw >= ST_WRITING && !STp->pos_unknown) {
4837
4838 #if DEBUG
4839 if (debugging) {
4840 printk(OSST_DEB_MSG "%s:D: File length %ld bytes.\n",
4841 name, (long)(filp->f_pos));
4842 printk(OSST_DEB_MSG "%s:D: Async write waits %d, finished %d.\n",
4843 name, STp->nbr_waits, STp->nbr_finished);
4844 }
4845 #endif
4846 result = osst_write_trailer(STp, &SRpnt, !(STp->rew_at_close));
4847 #if DEBUG
4848 if (debugging)
4849 printk(OSST_DEB_MSG "%s:D: Buffer flushed, %d EOF(s) written\n",
4850 name, 1+STp->two_fm);
4851 #endif
4852 }
4853 else if (!STp->rew_at_close) {
4854 STps = &(STp->ps[STp->partition]);
4855 if (!STm->sysv || STps->rw != ST_READING) {
4856 if (STp->can_bsr)
4857 result = osst_flush_buffer(STp, &SRpnt, 0); /* this is the default path */
4858 else if (STps->eof == ST_FM_HIT) {
4859 result = cross_eof(STp, &SRpnt, 0);
4860 if (result) {
4861 if (STps->drv_file >= 0)
4862 STps->drv_file++;
4863 STps->drv_block = 0;
4864 STps->eof = ST_FM;
4865 }
4866 else
4867 STps->eof = ST_NOEOF;
4868 }
4869 }
4870 else if ((STps->eof == ST_NOEOF &&
4871 !(result = cross_eof(STp, &SRpnt, 1))) ||
4872 STps->eof == ST_FM_HIT) {
4873 if (STps->drv_file >= 0)
4874 STps->drv_file++;
4875 STps->drv_block = 0;
4876 STps->eof = ST_FM;
4877 }
4878 }
4879
4880 out:
4881 if (STp->rew_at_close) {
4882 result2 = osst_position_tape_and_confirm(STp, &SRpnt, STp->first_data_ppos);
4883 STps->drv_file = STps->drv_block = STp->frame_seq_number = STp->logical_blk_num = 0;
4884 if (result == 0 && result2 < 0)
4885 result = result2;
4886 }
4887 if (SRpnt) osst_release_request(SRpnt);
4888
4889 if (STp->abort_count || STp->recover_count) {
4890 printk(KERN_INFO "%s:I:", name);
4891 if (STp->abort_count)
4892 printk(" %d unrecovered errors", STp->abort_count);
4893 if (STp->recover_count)
4894 printk(" %d recovered errors", STp->recover_count);
4895 if (STp->write_count)
4896 printk(" in %d frames written", STp->write_count);
4897 if (STp->read_count)
4898 printk(" in %d frames read", STp->read_count);
4899 printk("\n");
4900 STp->recover_count = 0;
4901 STp->abort_count = 0;
4902 }
4903 STp->write_count = 0;
4904 STp->read_count = 0;
4905
4906 return result;
4907 }
4908
4909
4910 /* Close the device and release it */
4911 static int os_scsi_tape_close(struct inode * inode, struct file * filp)
4912 {
4913 int result = 0;
4914 struct osst_tape * STp = filp->private_data;
4915
4916 if (STp->door_locked == ST_LOCKED_AUTO)
4917 do_door_lock(STp, 0);
4918
4919 if (STp->raw)
4920 STp->header_ok = 0;
4921
4922 normalize_buffer(STp->buffer);
4923 write_lock(&os_scsi_tapes_lock);
4924 STp->in_use = 0;
4925 write_unlock(&os_scsi_tapes_lock);
4926
4927 scsi_device_put(STp->device);
4928
4929 return result;
4930 }
4931
4932
4933 /* The ioctl command */
4934 static int osst_ioctl(struct inode * inode,struct file * file,
4935 unsigned int cmd_in, unsigned long arg)
4936 {
4937 int i, cmd_nr, cmd_type, blk, retval = 0;
4938 struct st_modedef * STm;
4939 struct st_partstat * STps;
4940 struct osst_request * SRpnt = NULL;
4941 struct osst_tape * STp = file->private_data;
4942 char * name = tape_name(STp);
4943 void __user * p = (void __user *)arg;
4944
4945 if (mutex_lock_interruptible(&STp->lock))
4946 return -ERESTARTSYS;
4947
4948 #if DEBUG
4949 if (debugging && !STp->in_use) {
4950 printk(OSST_DEB_MSG "%s:D: Incorrect device.\n", name);
4951 retval = (-EIO);
4952 goto out;
4953 }
4954 #endif
4955 STm = &(STp->modes[STp->current_mode]);
4956 STps = &(STp->ps[STp->partition]);
4957
4958 /*
4959 * If we are in the middle of error recovery, don't let anyone
4960 * else try and use this device. Also, if error recovery fails, it
4961 * may try and take the device offline, in which case all further
4962 * access to the device is prohibited.
4963 */
4964 if( !scsi_block_when_processing_errors(STp->device) ) {
4965 retval = (-ENXIO);
4966 goto out;
4967 }
4968
4969 cmd_type = _IOC_TYPE(cmd_in);
4970 cmd_nr = _IOC_NR(cmd_in);
4971 #if DEBUG
4972 printk(OSST_DEB_MSG "%s:D: Ioctl %d,%d in %s mode\n", name,
4973 cmd_type, cmd_nr, STp->raw?"raw":"normal");
4974 #endif
4975 if (cmd_type == _IOC_TYPE(MTIOCTOP) && cmd_nr == _IOC_NR(MTIOCTOP)) {
4976 struct mtop mtc;
4977 int auto_weof = 0;
4978
4979 if (_IOC_SIZE(cmd_in) != sizeof(mtc)) {
4980 retval = (-EINVAL);
4981 goto out;
4982 }
4983
4984 i = copy_from_user((char *) &mtc, p, sizeof(struct mtop));
4985 if (i) {
4986 retval = (-EFAULT);
4987 goto out;
4988 }
4989
4990 if (mtc.mt_op == MTSETDRVBUFFER && !capable(CAP_SYS_ADMIN)) {
4991 printk(KERN_WARNING "%s:W: MTSETDRVBUFFER only allowed for root.\n", name);
4992 retval = (-EPERM);
4993 goto out;
4994 }
4995
4996 if (!STm->defined && (mtc.mt_op != MTSETDRVBUFFER && (mtc.mt_count & MT_ST_OPTIONS) == 0)) {
4997 retval = (-ENXIO);
4998 goto out;
4999 }
5000
5001 if (!STp->pos_unknown) {
5002
5003 if (STps->eof == ST_FM_HIT) {
5004 if (mtc.mt_op == MTFSF || mtc.mt_op == MTFSFM|| mtc.mt_op == MTEOM) {
5005 mtc.mt_count -= 1;
5006 if (STps->drv_file >= 0)
5007 STps->drv_file += 1;
5008 }
5009 else if (mtc.mt_op == MTBSF || mtc.mt_op == MTBSFM) {
5010 mtc.mt_count += 1;
5011 if (STps->drv_file >= 0)
5012 STps->drv_file += 1;
5013 }
5014 }
5015
5016 if (mtc.mt_op == MTSEEK) {
5017 /* Old position must be restored if partition will be changed */
5018 i = !STp->can_partitions || (STp->new_partition != STp->partition);
5019 }
5020 else {
5021 i = mtc.mt_op == MTREW || mtc.mt_op == MTOFFL ||
5022 mtc.mt_op == MTRETEN || mtc.mt_op == MTEOM ||
5023 mtc.mt_op == MTLOCK || mtc.mt_op == MTLOAD ||
5024 mtc.mt_op == MTFSF || mtc.mt_op == MTFSFM ||
5025 mtc.mt_op == MTBSF || mtc.mt_op == MTBSFM ||
5026 mtc.mt_op == MTCOMPRESSION;
5027 }
5028 i = osst_flush_buffer(STp, &SRpnt, i);
5029 if (i < 0) {
5030 retval = i;
5031 goto out;
5032 }
5033 }
5034 else {
5035 /*
5036 * If there was a bus reset, block further access
5037 * to this device. If the user wants to rewind the tape,
5038 * then reset the flag and allow access again.
5039 */
5040 if(mtc.mt_op != MTREW &&
5041 mtc.mt_op != MTOFFL &&
5042 mtc.mt_op != MTRETEN &&
5043 mtc.mt_op != MTERASE &&
5044 mtc.mt_op != MTSEEK &&
5045 mtc.mt_op != MTEOM) {
5046 retval = (-EIO);
5047 goto out;
5048 }
5049 reset_state(STp);
5050 /* remove this when the midlevel properly clears was_reset */
5051 STp->device->was_reset = 0;
5052 }
5053
5054 if (mtc.mt_op != MTCOMPRESSION && mtc.mt_op != MTLOCK &&
5055 mtc.mt_op != MTNOP && mtc.mt_op != MTSETBLK &&
5056 mtc.mt_op != MTSETDENSITY && mtc.mt_op != MTSETDRVBUFFER &&
5057 mtc.mt_op != MTMKPART && mtc.mt_op != MTSETPART &&
5058 mtc.mt_op != MTWEOF && mtc.mt_op != MTWSM ) {
5059
5060 /*
5061 * The user tells us to move to another position on the tape.
5062 * If we were appending to the tape content, that would leave
5063 * the tape without proper end, in that case write EOD and
5064 * update the header to reflect its position.
5065 */
5066 #if DEBUG
5067 printk(KERN_WARNING "%s:D: auto_weod %s at ffp=%d,efp=%d,fsn=%d,lbn=%d,fn=%d,bn=%d\n", name,
5068 STps->rw >= ST_WRITING ? "write" : STps->rw == ST_READING ? "read" : "idle",
5069 STp->first_frame_position, STp->eod_frame_ppos, STp->frame_seq_number,
5070 STp->logical_blk_num, STps->drv_file, STps->drv_block );
5071 #endif
5072 if (STps->rw >= ST_WRITING && STp->first_frame_position >= STp->eod_frame_ppos) {
5073 auto_weof = ((STp->write_type != OS_WRITE_NEW_MARK) &&
5074 !(mtc.mt_op == MTREW || mtc.mt_op == MTOFFL));
5075 i = osst_write_trailer(STp, &SRpnt,
5076 !(mtc.mt_op == MTREW || mtc.mt_op == MTOFFL));
5077 #if DEBUG
5078 printk(KERN_WARNING "%s:D: post trailer xeof=%d,ffp=%d,efp=%d,fsn=%d,lbn=%d,fn=%d,bn=%d\n",
5079 name, auto_weof, STp->first_frame_position, STp->eod_frame_ppos,
5080 STp->frame_seq_number, STp->logical_blk_num, STps->drv_file, STps->drv_block );
5081 #endif
5082 if (i < 0) {
5083 retval = i;
5084 goto out;
5085 }
5086 }
5087 STps->rw = ST_IDLE;
5088 }
5089
5090 if (mtc.mt_op == MTOFFL && STp->door_locked != ST_UNLOCKED)
5091 do_door_lock(STp, 0); /* Ignore result! */
5092
5093 if (mtc.mt_op == MTSETDRVBUFFER &&
5094 (mtc.mt_count & MT_ST_OPTIONS) != 0) {
5095 retval = osst_set_options(STp, mtc.mt_count);
5096 goto out;
5097 }
5098
5099 if (mtc.mt_op == MTSETPART) {
5100 if (mtc.mt_count >= STp->nbr_partitions)
5101 retval = -EINVAL;
5102 else {
5103 STp->new_partition = mtc.mt_count;
5104 retval = 0;
5105 }
5106 goto out;
5107 }
5108
5109 if (mtc.mt_op == MTMKPART) {
5110 if (!STp->can_partitions) {
5111 retval = (-EINVAL);
5112 goto out;
5113 }
5114 if ((i = osst_int_ioctl(STp, &SRpnt, MTREW, 0)) < 0 /*||
5115 (i = partition_tape(inode, mtc.mt_count)) < 0*/) {
5116 retval = i;
5117 goto out;
5118 }
5119 for (i=0; i < ST_NBR_PARTITIONS; i++) {
5120 STp->ps[i].rw = ST_IDLE;
5121 STp->ps[i].at_sm = 0;
5122 STp->ps[i].last_block_valid = 0;
5123 }
5124 STp->partition = STp->new_partition = 0;
5125 STp->nbr_partitions = 1; /* Bad guess ?-) */
5126 STps->drv_block = STps->drv_file = 0;
5127 retval = 0;
5128 goto out;
5129 }
5130
5131 if (mtc.mt_op == MTSEEK) {
5132 if (STp->raw)
5133 i = osst_set_frame_position(STp, &SRpnt, mtc.mt_count, 0);
5134 else
5135 i = osst_seek_sector(STp, &SRpnt, mtc.mt_count);
5136 if (!STp->can_partitions)
5137 STp->ps[0].rw = ST_IDLE;
5138 retval = i;
5139 goto out;
5140 }
5141
5142 if (mtc.mt_op == MTLOCK || mtc.mt_op == MTUNLOCK) {
5143 retval = do_door_lock(STp, (mtc.mt_op == MTLOCK));
5144 goto out;
5145 }
5146
5147 if (auto_weof)
5148 cross_eof(STp, &SRpnt, 0);
5149
5150 if (mtc.mt_op == MTCOMPRESSION)
5151 retval = -EINVAL; /* OnStream drives don't have compression hardware */
5152 else
5153 /* MTBSF MTBSFM MTBSR MTBSS MTEOM MTERASE MTFSF MTFSFB MTFSR MTFSS
5154 * MTLOAD MTOFFL MTRESET MTRETEN MTREW MTUNLOAD MTWEOF MTWSM */
5155 retval = osst_int_ioctl(STp, &SRpnt, mtc.mt_op, mtc.mt_count);
5156 goto out;
5157 }
5158
5159 if (!STm->defined) {
5160 retval = (-ENXIO);
5161 goto out;
5162 }
5163
5164 if ((i = osst_flush_buffer(STp, &SRpnt, 0)) < 0) {
5165 retval = i;
5166 goto out;
5167 }
5168
5169 if (cmd_type == _IOC_TYPE(MTIOCGET) && cmd_nr == _IOC_NR(MTIOCGET)) {
5170 struct mtget mt_status;
5171
5172 if (_IOC_SIZE(cmd_in) != sizeof(struct mtget)) {
5173 retval = (-EINVAL);
5174 goto out;
5175 }
5176
5177 mt_status.mt_type = MT_ISONSTREAM_SC;
5178 mt_status.mt_erreg = STp->recover_erreg << MT_ST_SOFTERR_SHIFT;
5179 mt_status.mt_dsreg =
5180 ((STp->block_size << MT_ST_BLKSIZE_SHIFT) & MT_ST_BLKSIZE_MASK) |
5181 ((STp->density << MT_ST_DENSITY_SHIFT) & MT_ST_DENSITY_MASK);
5182 mt_status.mt_blkno = STps->drv_block;
5183 mt_status.mt_fileno = STps->drv_file;
5184 if (STp->block_size != 0) {
5185 if (STps->rw == ST_WRITING)
5186 mt_status.mt_blkno += (STp->buffer)->buffer_bytes / STp->block_size;
5187 else if (STps->rw == ST_READING)
5188 mt_status.mt_blkno -= ((STp->buffer)->buffer_bytes +
5189 STp->block_size - 1) / STp->block_size;
5190 }
5191
5192 mt_status.mt_gstat = 0;
5193 if (STp->drv_write_prot)
5194 mt_status.mt_gstat |= GMT_WR_PROT(0xffffffff);
5195 if (mt_status.mt_blkno == 0) {
5196 if (mt_status.mt_fileno == 0)
5197 mt_status.mt_gstat |= GMT_BOT(0xffffffff);
5198 else
5199 mt_status.mt_gstat |= GMT_EOF(0xffffffff);
5200 }
5201 mt_status.mt_resid = STp->partition;
5202 if (STps->eof == ST_EOM_OK || STps->eof == ST_EOM_ERROR)
5203 mt_status.mt_gstat |= GMT_EOT(0xffffffff);
5204 else if (STps->eof >= ST_EOM_OK)
5205 mt_status.mt_gstat |= GMT_EOD(0xffffffff);
5206 if (STp->density == 1)
5207 mt_status.mt_gstat |= GMT_D_800(0xffffffff);
5208 else if (STp->density == 2)
5209 mt_status.mt_gstat |= GMT_D_1600(0xffffffff);
5210 else if (STp->density == 3)
5211 mt_status.mt_gstat |= GMT_D_6250(0xffffffff);
5212 if (STp->ready == ST_READY)
5213 mt_status.mt_gstat |= GMT_ONLINE(0xffffffff);
5214 if (STp->ready == ST_NO_TAPE)
5215 mt_status.mt_gstat |= GMT_DR_OPEN(0xffffffff);
5216 if (STps->at_sm)
5217 mt_status.mt_gstat |= GMT_SM(0xffffffff);
5218 if (STm->do_async_writes || (STm->do_buffer_writes && STp->block_size != 0) ||
5219 STp->drv_buffer != 0)
5220 mt_status.mt_gstat |= GMT_IM_REP_EN(0xffffffff);
5221
5222 i = copy_to_user(p, &mt_status, sizeof(struct mtget));
5223 if (i) {
5224 retval = (-EFAULT);
5225 goto out;
5226 }
5227
5228 STp->recover_erreg = 0; /* Clear after read */
5229 retval = 0;
5230 goto out;
5231 } /* End of MTIOCGET */
5232
5233 if (cmd_type == _IOC_TYPE(MTIOCPOS) && cmd_nr == _IOC_NR(MTIOCPOS)) {
5234 struct mtpos mt_pos;
5235
5236 if (_IOC_SIZE(cmd_in) != sizeof(struct mtpos)) {
5237 retval = (-EINVAL);
5238 goto out;
5239 }
5240 if (STp->raw)
5241 blk = osst_get_frame_position(STp, &SRpnt);
5242 else
5243 blk = osst_get_sector(STp, &SRpnt);
5244 if (blk < 0) {
5245 retval = blk;
5246 goto out;
5247 }
5248 mt_pos.mt_blkno = blk;
5249 i = copy_to_user(p, &mt_pos, sizeof(struct mtpos));
5250 if (i)
5251 retval = -EFAULT;
5252 goto out;
5253 }
5254 if (SRpnt) osst_release_request(SRpnt);
5255
5256 mutex_unlock(&STp->lock);
5257
5258 return scsi_ioctl(STp->device, cmd_in, p);
5259
5260 out:
5261 if (SRpnt) osst_release_request(SRpnt);
5262
5263 mutex_unlock(&STp->lock);
5264
5265 return retval;
5266 }
5267
5268 #ifdef CONFIG_COMPAT
5269 static long osst_compat_ioctl(struct file * file, unsigned int cmd_in, unsigned long arg)
5270 {
5271 struct osst_tape *STp = file->private_data;
5272 struct scsi_device *sdev = STp->device;
5273 int ret = -ENOIOCTLCMD;
5274 if (sdev->host->hostt->compat_ioctl) {
5275
5276 ret = sdev->host->hostt->compat_ioctl(sdev, cmd_in, (void __user *)arg);
5277
5278 }
5279 return ret;
5280 }
5281 #endif
5282
5283
5284 \f
5285 /* Memory handling routines */
5286
5287 /* Try to allocate a new tape buffer skeleton. Caller must not hold os_scsi_tapes_lock */
5288 static struct osst_buffer * new_tape_buffer( int from_initialization, int need_dma, int max_sg )
5289 {
5290 int i;
5291 gfp_t priority;
5292 struct osst_buffer *tb;
5293
5294 if (from_initialization)
5295 priority = GFP_ATOMIC;
5296 else
5297 priority = GFP_KERNEL;
5298
5299 i = sizeof(struct osst_buffer) + (osst_max_sg_segs - 1) * sizeof(struct scatterlist);
5300 tb = kzalloc(i, priority);
5301 if (!tb) {
5302 printk(KERN_NOTICE "osst :I: Can't allocate new tape buffer.\n");
5303 return NULL;
5304 }
5305
5306 tb->sg_segs = tb->orig_sg_segs = 0;
5307 tb->use_sg = max_sg;
5308 tb->in_use = 1;
5309 tb->dma = need_dma;
5310 tb->buffer_size = 0;
5311 #if DEBUG
5312 if (debugging)
5313 printk(OSST_DEB_MSG
5314 "osst :D: Allocated tape buffer skeleton (%d bytes, %d segments, dma: %d).\n",
5315 i, max_sg, need_dma);
5316 #endif
5317 return tb;
5318 }
5319
5320 /* Try to allocate a temporary (while a user has the device open) enlarged tape buffer */
5321 static int enlarge_buffer(struct osst_buffer *STbuffer, int need_dma)
5322 {
5323 int segs, nbr, max_segs, b_size, order, got;
5324 gfp_t priority;
5325
5326 if (STbuffer->buffer_size >= OS_FRAME_SIZE)
5327 return 1;
5328
5329 if (STbuffer->sg_segs) {
5330 printk(KERN_WARNING "osst :A: Buffer not previously normalized.\n");
5331 normalize_buffer(STbuffer);
5332 }
5333 /* See how many segments we can use -- need at least two */
5334 nbr = max_segs = STbuffer->use_sg;
5335 if (nbr <= 2)
5336 return 0;
5337
5338 priority = GFP_KERNEL /* | __GFP_NOWARN */;
5339 if (need_dma)
5340 priority |= GFP_DMA;
5341
5342 /* Try to allocate the first segment up to OS_DATA_SIZE and the others
5343 big enough to reach the goal (code assumes no segments in place) */
5344 for (b_size = OS_DATA_SIZE, order = OSST_FIRST_ORDER; b_size >= PAGE_SIZE; order--, b_size /= 2) {
5345 struct page *page = alloc_pages(priority, order);
5346
5347 STbuffer->sg[0].offset = 0;
5348 if (page != NULL) {
5349 sg_set_page(&STbuffer->sg[0], page, b_size, 0);
5350 STbuffer->b_data = page_address(page);
5351 break;
5352 }
5353 }
5354 if (sg_page(&STbuffer->sg[0]) == NULL) {
5355 printk(KERN_NOTICE "osst :I: Can't allocate tape buffer main segment.\n");
5356 return 0;
5357 }
5358 /* Got initial segment of 'bsize,order', continue with same size if possible, except for AUX */
5359 for (segs=STbuffer->sg_segs=1, got=b_size;
5360 segs < max_segs && got < OS_FRAME_SIZE; ) {
5361 struct page *page = alloc_pages(priority, (OS_FRAME_SIZE - got <= PAGE_SIZE) ? 0 : order);
5362 STbuffer->sg[segs].offset = 0;
5363 if (page == NULL) {
5364 printk(KERN_WARNING "osst :W: Failed to enlarge buffer to %d bytes.\n",
5365 OS_FRAME_SIZE);
5366 #if DEBUG
5367 STbuffer->buffer_size = got;
5368 #endif
5369 normalize_buffer(STbuffer);
5370 return 0;
5371 }
5372 sg_set_page(&STbuffer->sg[segs], page, (OS_FRAME_SIZE - got <= PAGE_SIZE / 2) ? (OS_FRAME_SIZE - got) : b_size, 0);
5373 got += STbuffer->sg[segs].length;
5374 STbuffer->buffer_size = got;
5375 STbuffer->sg_segs = ++segs;
5376 }
5377 #if DEBUG
5378 if (debugging) {
5379 printk(OSST_DEB_MSG
5380 "osst :D: Expanded tape buffer (%d bytes, %d->%d segments, dma: %d, at: %p).\n",
5381 got, STbuffer->orig_sg_segs, STbuffer->sg_segs, need_dma, STbuffer->b_data);
5382 printk(OSST_DEB_MSG
5383 "osst :D: segment sizes: first %d at %p, last %d bytes at %p.\n",
5384 STbuffer->sg[0].length, page_address(STbuffer->sg[0].page),
5385 STbuffer->sg[segs-1].length, page_address(STbuffer->sg[segs-1].page));
5386 }
5387 #endif
5388
5389 return 1;
5390 }
5391
5392
5393 /* Release the segments */
5394 static void normalize_buffer(struct osst_buffer *STbuffer)
5395 {
5396 int i, order, b_size;
5397
5398 for (i=0; i < STbuffer->sg_segs; i++) {
5399
5400 for (b_size = PAGE_SIZE, order = 0;
5401 b_size < STbuffer->sg[i].length;
5402 b_size *= 2, order++);
5403
5404 __free_pages(sg_page(&STbuffer->sg[i]), order);
5405 STbuffer->buffer_size -= STbuffer->sg[i].length;
5406 }
5407 #if DEBUG
5408 if (debugging && STbuffer->orig_sg_segs < STbuffer->sg_segs)
5409 printk(OSST_DEB_MSG "osst :D: Buffer at %p normalized to %d bytes (segs %d).\n",
5410 STbuffer->b_data, STbuffer->buffer_size, STbuffer->sg_segs);
5411 #endif
5412 STbuffer->sg_segs = STbuffer->orig_sg_segs = 0;
5413 }
5414
5415
5416 /* Move data from the user buffer to the tape buffer. Returns zero (success) or
5417 negative error code. */
5418 static int append_to_buffer(const char __user *ubp, struct osst_buffer *st_bp, int do_count)
5419 {
5420 int i, cnt, res, offset;
5421
5422 for (i=0, offset=st_bp->buffer_bytes;
5423 i < st_bp->sg_segs && offset >= st_bp->sg[i].length; i++)
5424 offset -= st_bp->sg[i].length;
5425 if (i == st_bp->sg_segs) { /* Should never happen */
5426 printk(KERN_WARNING "osst :A: Append_to_buffer offset overflow.\n");
5427 return (-EIO);
5428 }
5429 for ( ; i < st_bp->sg_segs && do_count > 0; i++) {
5430 cnt = st_bp->sg[i].length - offset < do_count ?
5431 st_bp->sg[i].length - offset : do_count;
5432 res = copy_from_user(page_address(sg_page(&st_bp->sg[i])) + offset, ubp, cnt);
5433 if (res)
5434 return (-EFAULT);
5435 do_count -= cnt;
5436 st_bp->buffer_bytes += cnt;
5437 ubp += cnt;
5438 offset = 0;
5439 }
5440 if (do_count) { /* Should never happen */
5441 printk(KERN_WARNING "osst :A: Append_to_buffer overflow (left %d).\n",
5442 do_count);
5443 return (-EIO);
5444 }
5445 return 0;
5446 }
5447
5448
5449 /* Move data from the tape buffer to the user buffer. Returns zero (success) or
5450 negative error code. */
5451 static int from_buffer(struct osst_buffer *st_bp, char __user *ubp, int do_count)
5452 {
5453 int i, cnt, res, offset;
5454
5455 for (i=0, offset=st_bp->read_pointer;
5456 i < st_bp->sg_segs && offset >= st_bp->sg[i].length; i++)
5457 offset -= st_bp->sg[i].length;
5458 if (i == st_bp->sg_segs) { /* Should never happen */
5459 printk(KERN_WARNING "osst :A: From_buffer offset overflow.\n");
5460 return (-EIO);
5461 }
5462 for ( ; i < st_bp->sg_segs && do_count > 0; i++) {
5463 cnt = st_bp->sg[i].length - offset < do_count ?
5464 st_bp->sg[i].length - offset : do_count;
5465 res = copy_to_user(ubp, page_address(sg_page(&st_bp->sg[i])) + offset, cnt);
5466 if (res)
5467 return (-EFAULT);
5468 do_count -= cnt;
5469 st_bp->buffer_bytes -= cnt;
5470 st_bp->read_pointer += cnt;
5471 ubp += cnt;
5472 offset = 0;
5473 }
5474 if (do_count) { /* Should never happen */
5475 printk(KERN_WARNING "osst :A: From_buffer overflow (left %d).\n", do_count);
5476 return (-EIO);
5477 }
5478 return 0;
5479 }
5480
5481 /* Sets the tail of the buffer after fill point to zero.
5482 Returns zero (success) or negative error code. */
5483 static int osst_zero_buffer_tail(struct osst_buffer *st_bp)
5484 {
5485 int i, offset, do_count, cnt;
5486
5487 for (i = 0, offset = st_bp->buffer_bytes;
5488 i < st_bp->sg_segs && offset >= st_bp->sg[i].length; i++)
5489 offset -= st_bp->sg[i].length;
5490 if (i == st_bp->sg_segs) { /* Should never happen */
5491 printk(KERN_WARNING "osst :A: Zero_buffer offset overflow.\n");
5492 return (-EIO);
5493 }
5494 for (do_count = OS_DATA_SIZE - st_bp->buffer_bytes;
5495 i < st_bp->sg_segs && do_count > 0; i++) {
5496 cnt = st_bp->sg[i].length - offset < do_count ?
5497 st_bp->sg[i].length - offset : do_count ;
5498 memset(page_address(sg_page(&st_bp->sg[i])) + offset, 0, cnt);
5499 do_count -= cnt;
5500 offset = 0;
5501 }
5502 if (do_count) { /* Should never happen */
5503 printk(KERN_WARNING "osst :A: Zero_buffer overflow (left %d).\n", do_count);
5504 return (-EIO);
5505 }
5506 return 0;
5507 }
5508
5509 /* Copy a osst 32K chunk of memory into the buffer.
5510 Returns zero (success) or negative error code. */
5511 static int osst_copy_to_buffer(struct osst_buffer *st_bp, unsigned char *ptr)
5512 {
5513 int i, cnt, do_count = OS_DATA_SIZE;
5514
5515 for (i = 0; i < st_bp->sg_segs && do_count > 0; i++) {
5516 cnt = st_bp->sg[i].length < do_count ?
5517 st_bp->sg[i].length : do_count ;
5518 memcpy(page_address(sg_page(&st_bp->sg[i])), ptr, cnt);
5519 do_count -= cnt;
5520 ptr += cnt;
5521 }
5522 if (do_count || i != st_bp->sg_segs-1) { /* Should never happen */
5523 printk(KERN_WARNING "osst :A: Copy_to_buffer overflow (left %d at sg %d).\n",
5524 do_count, i);
5525 return (-EIO);
5526 }
5527 return 0;
5528 }
5529
5530 /* Copy a osst 32K chunk of memory from the buffer.
5531 Returns zero (success) or negative error code. */
5532 static int osst_copy_from_buffer(struct osst_buffer *st_bp, unsigned char *ptr)
5533 {
5534 int i, cnt, do_count = OS_DATA_SIZE;
5535
5536 for (i = 0; i < st_bp->sg_segs && do_count > 0; i++) {
5537 cnt = st_bp->sg[i].length < do_count ?
5538 st_bp->sg[i].length : do_count ;
5539 memcpy(ptr, page_address(sg_page(&st_bp->sg[i])), cnt);
5540 do_count -= cnt;
5541 ptr += cnt;
5542 }
5543 if (do_count || i != st_bp->sg_segs-1) { /* Should never happen */
5544 printk(KERN_WARNING "osst :A: Copy_from_buffer overflow (left %d at sg %d).\n",
5545 do_count, i);
5546 return (-EIO);
5547 }
5548 return 0;
5549 }
5550
5551 \f
5552 /* Module housekeeping */
5553
5554 static void validate_options (void)
5555 {
5556 if (max_dev > 0)
5557 osst_max_dev = max_dev;
5558 if (write_threshold_kbs > 0)
5559 osst_write_threshold = write_threshold_kbs * ST_KILOBYTE;
5560 if (osst_write_threshold > osst_buffer_size)
5561 osst_write_threshold = osst_buffer_size;
5562 if (max_sg_segs >= OSST_FIRST_SG)
5563 osst_max_sg_segs = max_sg_segs;
5564 #if DEBUG
5565 printk(OSST_DEB_MSG "osst :D: max tapes %d, write threshold %d, max s/g segs %d.\n",
5566 osst_max_dev, osst_write_threshold, osst_max_sg_segs);
5567 #endif
5568 }
5569
5570 #ifndef MODULE
5571 /* Set the boot options. Syntax: osst=xxx,yyy,...
5572 where xxx is write threshold in 1024 byte blocks,
5573 and yyy is number of s/g segments to use. */
5574 static int __init osst_setup (char *str)
5575 {
5576 int i, ints[5];
5577 char *stp;
5578
5579 stp = get_options(str, ARRAY_SIZE(ints), ints);
5580
5581 if (ints[0] > 0) {
5582 for (i = 0; i < ints[0] && i < ARRAY_SIZE(parms); i++)
5583 *parms[i].val = ints[i + 1];
5584 } else {
5585 while (stp != NULL) {
5586 for (i = 0; i < ARRAY_SIZE(parms); i++) {
5587 int len = strlen(parms[i].name);
5588 if (!strncmp(stp, parms[i].name, len) &&
5589 (*(stp + len) == ':' || *(stp + len) == '=')) {
5590 *parms[i].val =
5591 simple_strtoul(stp + len + 1, NULL, 0);
5592 break;
5593 }
5594 }
5595 if (i >= ARRAY_SIZE(parms))
5596 printk(KERN_INFO "osst :I: Illegal parameter in '%s'\n",
5597 stp);
5598 stp = strchr(stp, ',');
5599 if (stp)
5600 stp++;
5601 }
5602 }
5603
5604 return 1;
5605 }
5606
5607 __setup("osst=", osst_setup);
5608
5609 #endif
5610
5611 static const struct file_operations osst_fops = {
5612 .owner = THIS_MODULE,
5613 .read = osst_read,
5614 .write = osst_write,
5615 .ioctl = osst_ioctl,
5616 #ifdef CONFIG_COMPAT
5617 .compat_ioctl = osst_compat_ioctl,
5618 #endif
5619 .open = os_scsi_tape_open,
5620 .flush = os_scsi_tape_flush,
5621 .release = os_scsi_tape_close,
5622 };
5623
5624 static int osst_supports(struct scsi_device * SDp)
5625 {
5626 struct osst_support_data {
5627 char *vendor;
5628 char *model;
5629 char *rev;
5630 char *driver_hint; /* Name of the correct driver, NULL if unknown */
5631 };
5632
5633 static struct osst_support_data support_list[] = {
5634 /* {"XXX", "Yy-", "", NULL}, example */
5635 SIGS_FROM_OSST,
5636 {NULL, }};
5637
5638 struct osst_support_data *rp;
5639
5640 /* We are willing to drive OnStream SC-x0 as well as the
5641 * * IDE, ParPort, FireWire, USB variants, if accessible by
5642 * * emulation layer (ide-scsi, usb-storage, ...) */
5643
5644 for (rp=&(support_list[0]); rp->vendor != NULL; rp++)
5645 if (!strncmp(rp->vendor, SDp->vendor, strlen(rp->vendor)) &&
5646 !strncmp(rp->model, SDp->model, strlen(rp->model)) &&
5647 !strncmp(rp->rev, SDp->rev, strlen(rp->rev)))
5648 return 1;
5649 return 0;
5650 }
5651
5652 /*
5653 * sysfs support for osst driver parameter information
5654 */
5655
5656 static ssize_t osst_version_show(struct device_driver *ddd, char *buf)
5657 {
5658 return snprintf(buf, PAGE_SIZE, "%s\n", osst_version);
5659 }
5660
5661 static DRIVER_ATTR(version, S_IRUGO, osst_version_show, NULL);
5662
5663 static int osst_create_sysfs_files(struct device_driver *sysfs)
5664 {
5665 return driver_create_file(sysfs, &driver_attr_version);
5666 }
5667
5668 static void osst_remove_sysfs_files(struct device_driver *sysfs)
5669 {
5670 driver_remove_file(sysfs, &driver_attr_version);
5671 }
5672
5673 /*
5674 * sysfs support for accessing ADR header information
5675 */
5676
5677 static ssize_t osst_adr_rev_show(struct device *dev,
5678 struct device_attribute *attr, char *buf)
5679 {
5680 struct osst_tape * STp = (struct osst_tape *) dev_get_drvdata (dev);
5681 ssize_t l = 0;
5682
5683 if (STp && STp->header_ok && STp->linux_media)
5684 l = snprintf(buf, PAGE_SIZE, "%d.%d\n", STp->header_cache->major_rev, STp->header_cache->minor_rev);
5685 return l;
5686 }
5687
5688 DEVICE_ATTR(ADR_rev, S_IRUGO, osst_adr_rev_show, NULL);
5689
5690 static ssize_t osst_linux_media_version_show(struct device *dev,
5691 struct device_attribute *attr,
5692 char *buf)
5693 {
5694 struct osst_tape * STp = (struct osst_tape *) dev_get_drvdata (dev);
5695 ssize_t l = 0;
5696
5697 if (STp && STp->header_ok && STp->linux_media)
5698 l = snprintf(buf, PAGE_SIZE, "LIN%d\n", STp->linux_media_version);
5699 return l;
5700 }
5701
5702 DEVICE_ATTR(media_version, S_IRUGO, osst_linux_media_version_show, NULL);
5703
5704 static ssize_t osst_capacity_show(struct device *dev,
5705 struct device_attribute *attr, char *buf)
5706 {
5707 struct osst_tape * STp = (struct osst_tape *) dev_get_drvdata (dev);
5708 ssize_t l = 0;
5709
5710 if (STp && STp->header_ok && STp->linux_media)
5711 l = snprintf(buf, PAGE_SIZE, "%d\n", STp->capacity);
5712 return l;
5713 }
5714
5715 DEVICE_ATTR(capacity, S_IRUGO, osst_capacity_show, NULL);
5716
5717 static ssize_t osst_first_data_ppos_show(struct device *dev,
5718 struct device_attribute *attr,
5719 char *buf)
5720 {
5721 struct osst_tape * STp = (struct osst_tape *) dev_get_drvdata (dev);
5722 ssize_t l = 0;
5723
5724 if (STp && STp->header_ok && STp->linux_media)
5725 l = snprintf(buf, PAGE_SIZE, "%d\n", STp->first_data_ppos);
5726 return l;
5727 }
5728
5729 DEVICE_ATTR(BOT_frame, S_IRUGO, osst_first_data_ppos_show, NULL);
5730
5731 static ssize_t osst_eod_frame_ppos_show(struct device *dev,
5732 struct device_attribute *attr,
5733 char *buf)
5734 {
5735 struct osst_tape * STp = (struct osst_tape *) dev_get_drvdata (dev);
5736 ssize_t l = 0;
5737
5738 if (STp && STp->header_ok && STp->linux_media)
5739 l = snprintf(buf, PAGE_SIZE, "%d\n", STp->eod_frame_ppos);
5740 return l;
5741 }
5742
5743 DEVICE_ATTR(EOD_frame, S_IRUGO, osst_eod_frame_ppos_show, NULL);
5744
5745 static ssize_t osst_filemark_cnt_show(struct device *dev,
5746 struct device_attribute *attr, char *buf)
5747 {
5748 struct osst_tape * STp = (struct osst_tape *) dev_get_drvdata (dev);
5749 ssize_t l = 0;
5750
5751 if (STp && STp->header_ok && STp->linux_media)
5752 l = snprintf(buf, PAGE_SIZE, "%d\n", STp->filemark_cnt);
5753 return l;
5754 }
5755
5756 DEVICE_ATTR(file_count, S_IRUGO, osst_filemark_cnt_show, NULL);
5757
5758 static struct class *osst_sysfs_class;
5759
5760 static int osst_sysfs_init(void)
5761 {
5762 osst_sysfs_class = class_create(THIS_MODULE, "onstream_tape");
5763 if (IS_ERR(osst_sysfs_class)) {
5764 printk(KERN_ERR "osst :W: Unable to register sysfs class\n");
5765 return PTR_ERR(osst_sysfs_class);
5766 }
5767
5768 return 0;
5769 }
5770
5771 static void osst_sysfs_destroy(dev_t dev)
5772 {
5773 device_destroy(osst_sysfs_class, dev);
5774 }
5775
5776 static int osst_sysfs_add(dev_t dev, struct device *device, struct osst_tape * STp, char * name)
5777 {
5778 struct device *osst_member;
5779 int err;
5780
5781 osst_member = device_create(osst_sysfs_class, device, dev, STp,
5782 "%s", name);
5783 if (IS_ERR(osst_member)) {
5784 printk(KERN_WARNING "osst :W: Unable to add sysfs class member %s\n", name);
5785 return PTR_ERR(osst_member);
5786 }
5787
5788 err = device_create_file(osst_member, &dev_attr_ADR_rev);
5789 if (err)
5790 goto err_out;
5791 err = device_create_file(osst_member, &dev_attr_media_version);
5792 if (err)
5793 goto err_out;
5794 err = device_create_file(osst_member, &dev_attr_capacity);
5795 if (err)
5796 goto err_out;
5797 err = device_create_file(osst_member, &dev_attr_BOT_frame);
5798 if (err)
5799 goto err_out;
5800 err = device_create_file(osst_member, &dev_attr_EOD_frame);
5801 if (err)
5802 goto err_out;
5803 err = device_create_file(osst_member, &dev_attr_file_count);
5804 if (err)
5805 goto err_out;
5806
5807 return 0;
5808
5809 err_out:
5810 osst_sysfs_destroy(dev);
5811 return err;
5812 }
5813
5814 static void osst_sysfs_cleanup(void)
5815 {
5816 class_destroy(osst_sysfs_class);
5817 }
5818
5819 /*
5820 * osst startup / cleanup code
5821 */
5822
5823 static int osst_probe(struct device *dev)
5824 {
5825 struct scsi_device * SDp = to_scsi_device(dev);
5826 struct osst_tape * tpnt;
5827 struct st_modedef * STm;
5828 struct st_partstat * STps;
5829 struct osst_buffer * buffer;
5830 struct gendisk * drive;
5831 int i, dev_num, err = -ENODEV;
5832
5833 if (SDp->type != TYPE_TAPE || !osst_supports(SDp))
5834 return -ENODEV;
5835
5836 drive = alloc_disk(1);
5837 if (!drive) {
5838 printk(KERN_ERR "osst :E: Out of memory. Device not attached.\n");
5839 return -ENODEV;
5840 }
5841
5842 /* if this is the first attach, build the infrastructure */
5843 write_lock(&os_scsi_tapes_lock);
5844 if (os_scsi_tapes == NULL) {
5845 os_scsi_tapes =
5846 (struct osst_tape **)kmalloc(osst_max_dev * sizeof(struct osst_tape *),
5847 GFP_ATOMIC);
5848 if (os_scsi_tapes == NULL) {
5849 write_unlock(&os_scsi_tapes_lock);
5850 printk(KERN_ERR "osst :E: Unable to allocate array for OnStream SCSI tapes.\n");
5851 goto out_put_disk;
5852 }
5853 for (i=0; i < osst_max_dev; ++i) os_scsi_tapes[i] = NULL;
5854 }
5855
5856 if (osst_nr_dev >= osst_max_dev) {
5857 write_unlock(&os_scsi_tapes_lock);
5858 printk(KERN_ERR "osst :E: Too many tape devices (max. %d).\n", osst_max_dev);
5859 goto out_put_disk;
5860 }
5861
5862 /* find a free minor number */
5863 for (i=0; os_scsi_tapes[i] && i<osst_max_dev; i++);
5864 if(i >= osst_max_dev) panic ("Scsi_devices corrupt (osst)");
5865 dev_num = i;
5866
5867 /* allocate a struct osst_tape for this device */
5868 tpnt = kzalloc(sizeof(struct osst_tape), GFP_ATOMIC);
5869 if (!tpnt) {
5870 write_unlock(&os_scsi_tapes_lock);
5871 printk(KERN_ERR "osst :E: Can't allocate device descriptor, device not attached.\n");
5872 goto out_put_disk;
5873 }
5874
5875 /* allocate a buffer for this device */
5876 i = SDp->host->sg_tablesize;
5877 if (osst_max_sg_segs < i)
5878 i = osst_max_sg_segs;
5879 buffer = new_tape_buffer(1, SDp->host->unchecked_isa_dma, i);
5880 if (buffer == NULL) {
5881 write_unlock(&os_scsi_tapes_lock);
5882 printk(KERN_ERR "osst :E: Unable to allocate a tape buffer, device not attached.\n");
5883 kfree(tpnt);
5884 goto out_put_disk;
5885 }
5886 os_scsi_tapes[dev_num] = tpnt;
5887 tpnt->buffer = buffer;
5888 tpnt->device = SDp;
5889 drive->private_data = &tpnt->driver;
5890 sprintf(drive->disk_name, "osst%d", dev_num);
5891 tpnt->driver = &osst_template;
5892 tpnt->drive = drive;
5893 tpnt->in_use = 0;
5894 tpnt->capacity = 0xfffff;
5895 tpnt->dirty = 0;
5896 tpnt->drv_buffer = 1; /* Try buffering if no mode sense */
5897 tpnt->restr_dma = (SDp->host)->unchecked_isa_dma;
5898 tpnt->density = 0;
5899 tpnt->do_auto_lock = OSST_AUTO_LOCK;
5900 tpnt->can_bsr = OSST_IN_FILE_POS;
5901 tpnt->can_partitions = 0;
5902 tpnt->two_fm = OSST_TWO_FM;
5903 tpnt->fast_mteom = OSST_FAST_MTEOM;
5904 tpnt->scsi2_logical = OSST_SCSI2LOGICAL; /* FIXME */
5905 tpnt->write_threshold = osst_write_threshold;
5906 tpnt->default_drvbuffer = 0xff; /* No forced buffering */
5907 tpnt->partition = 0;
5908 tpnt->new_partition = 0;
5909 tpnt->nbr_partitions = 0;
5910 tpnt->min_block = 512;
5911 tpnt->max_block = OS_DATA_SIZE;
5912 tpnt->timeout = OSST_TIMEOUT;
5913 tpnt->long_timeout = OSST_LONG_TIMEOUT;
5914
5915 /* Recognize OnStream tapes */
5916 /* We don't need to test for OnStream, as this has been done in detect () */
5917 tpnt->os_fw_rev = osst_parse_firmware_rev (SDp->rev);
5918 tpnt->omit_blklims = 1;
5919
5920 tpnt->poll = (strncmp(SDp->model, "DI-", 3) == 0) ||
5921 (strncmp(SDp->model, "FW-", 3) == 0) || OSST_FW_NEED_POLL(tpnt->os_fw_rev,SDp);
5922 tpnt->frame_in_buffer = 0;
5923 tpnt->header_ok = 0;
5924 tpnt->linux_media = 0;
5925 tpnt->header_cache = NULL;
5926
5927 for (i=0; i < ST_NBR_MODES; i++) {
5928 STm = &(tpnt->modes[i]);
5929 STm->defined = 0;
5930 STm->sysv = OSST_SYSV;
5931 STm->defaults_for_writes = 0;
5932 STm->do_async_writes = OSST_ASYNC_WRITES;
5933 STm->do_buffer_writes = OSST_BUFFER_WRITES;
5934 STm->do_read_ahead = OSST_READ_AHEAD;
5935 STm->default_compression = ST_DONT_TOUCH;
5936 STm->default_blksize = 512;
5937 STm->default_density = (-1); /* No forced density */
5938 }
5939
5940 for (i=0; i < ST_NBR_PARTITIONS; i++) {
5941 STps = &(tpnt->ps[i]);
5942 STps->rw = ST_IDLE;
5943 STps->eof = ST_NOEOF;
5944 STps->at_sm = 0;
5945 STps->last_block_valid = 0;
5946 STps->drv_block = (-1);
5947 STps->drv_file = (-1);
5948 }
5949
5950 tpnt->current_mode = 0;
5951 tpnt->modes[0].defined = 1;
5952 tpnt->modes[2].defined = 1;
5953 tpnt->density_changed = tpnt->compression_changed = tpnt->blksize_changed = 0;
5954
5955 mutex_init(&tpnt->lock);
5956 osst_nr_dev++;
5957 write_unlock(&os_scsi_tapes_lock);
5958
5959 {
5960 char name[8];
5961
5962 /* Rewind entry */
5963 err = osst_sysfs_add(MKDEV(OSST_MAJOR, dev_num), dev, tpnt, tape_name(tpnt));
5964 if (err)
5965 goto out_free_buffer;
5966
5967 /* No-rewind entry */
5968 snprintf(name, 8, "%s%s", "n", tape_name(tpnt));
5969 err = osst_sysfs_add(MKDEV(OSST_MAJOR, dev_num + 128), dev, tpnt, name);
5970 if (err)
5971 goto out_free_sysfs1;
5972 }
5973
5974 sdev_printk(KERN_INFO, SDp,
5975 "osst :I: Attached OnStream %.5s tape as %s\n",
5976 SDp->model, tape_name(tpnt));
5977
5978 return 0;
5979
5980 out_free_sysfs1:
5981 osst_sysfs_destroy(MKDEV(OSST_MAJOR, dev_num));
5982 out_free_buffer:
5983 kfree(buffer);
5984 out_put_disk:
5985 put_disk(drive);
5986 return err;
5987 };
5988
5989 static int osst_remove(struct device *dev)
5990 {
5991 struct scsi_device * SDp = to_scsi_device(dev);
5992 struct osst_tape * tpnt;
5993 int i;
5994
5995 if ((SDp->type != TYPE_TAPE) || (osst_nr_dev <= 0))
5996 return 0;
5997
5998 write_lock(&os_scsi_tapes_lock);
5999 for(i=0; i < osst_max_dev; i++) {
6000 if((tpnt = os_scsi_tapes[i]) && (tpnt->device == SDp)) {
6001 osst_sysfs_destroy(MKDEV(OSST_MAJOR, i));
6002 osst_sysfs_destroy(MKDEV(OSST_MAJOR, i+128));
6003 tpnt->device = NULL;
6004 put_disk(tpnt->drive);
6005 os_scsi_tapes[i] = NULL;
6006 osst_nr_dev--;
6007 write_unlock(&os_scsi_tapes_lock);
6008 vfree(tpnt->header_cache);
6009 if (tpnt->buffer) {
6010 normalize_buffer(tpnt->buffer);
6011 kfree(tpnt->buffer);
6012 }
6013 kfree(tpnt);
6014 return 0;
6015 }
6016 }
6017 write_unlock(&os_scsi_tapes_lock);
6018 return 0;
6019 }
6020
6021 static int __init init_osst(void)
6022 {
6023 int err;
6024
6025 printk(KERN_INFO "osst :I: Tape driver with OnStream support version %s\nosst :I: %s\n", osst_version, cvsid);
6026
6027 validate_options();
6028
6029 err = osst_sysfs_init();
6030 if (err)
6031 return err;
6032
6033 err = register_chrdev(OSST_MAJOR, "osst", &osst_fops);
6034 if (err < 0) {
6035 printk(KERN_ERR "osst :E: Unable to register major %d for OnStream tapes\n", OSST_MAJOR);
6036 goto err_out;
6037 }
6038
6039 err = scsi_register_driver(&osst_template.gendrv);
6040 if (err)
6041 goto err_out_chrdev;
6042
6043 err = osst_create_sysfs_files(&osst_template.gendrv);
6044 if (err)
6045 goto err_out_scsidrv;
6046
6047 return 0;
6048
6049 err_out_scsidrv:
6050 scsi_unregister_driver(&osst_template.gendrv);
6051 err_out_chrdev:
6052 unregister_chrdev(OSST_MAJOR, "osst");
6053 err_out:
6054 osst_sysfs_cleanup();
6055 return err;
6056 }
6057
6058 static void __exit exit_osst (void)
6059 {
6060 int i;
6061 struct osst_tape * STp;
6062
6063 osst_remove_sysfs_files(&osst_template.gendrv);
6064 scsi_unregister_driver(&osst_template.gendrv);
6065 unregister_chrdev(OSST_MAJOR, "osst");
6066 osst_sysfs_cleanup();
6067
6068 if (os_scsi_tapes) {
6069 for (i=0; i < osst_max_dev; ++i) {
6070 if (!(STp = os_scsi_tapes[i])) continue;
6071 /* This is defensive, supposed to happen during detach */
6072 vfree(STp->header_cache);
6073 if (STp->buffer) {
6074 normalize_buffer(STp->buffer);
6075 kfree(STp->buffer);
6076 }
6077 put_disk(STp->drive);
6078 kfree(STp);
6079 }
6080 kfree(os_scsi_tapes);
6081 }
6082 printk(KERN_INFO "osst :I: Unloaded.\n");
6083 }
6084
6085 module_init(init_osst);
6086 module_exit(exit_osst);
connection oriented routing - ARCHIVE NO UPDATES HERE