st.c
上传用户:jlfgdled
上传日期:2013-04-10
资源大小:33168k
文件大小:112k
源码类别:

Linux/Unix编程

开发平台:

Unix_Linux

  1. /*
  2.    SCSI Tape Driver for Linux version 1.1 and newer. See the accompanying
  3.    file README.st for more information.
  4.    History:
  5.    Rewritten from Dwayne Forsyth's SCSI tape driver by Kai Makisara.
  6.    Contribution and ideas from several people including (in alphabetical
  7.    order) Klaus Ehrenfried, Eugene Exarevsky, Eric Lee Green, Wolfgang Denk,
  8.    Steve Hirsch, Andreas Koppenh"ofer, Michael Leodolter, Eyal Lebedinsky,
  9.    Michael Schaefer, J"org Weule, and Eric Youngdale.
  10.    Copyright 1992 - 2002 Kai Makisara
  11.    email Kai.Makisara@metla.fi
  12.    Last modified: Mon Aug  5 22:54:13 2002 by makisara
  13.    Some small formal changes - aeb, 950809
  14.    Last modified: 18-JAN-1998 Richard Gooch <rgooch@atnf.csiro.au> Devfs support
  15.    Reminder: write_lock_irqsave() can be replaced by write_lock() when the old SCSI
  16.    error handling will be discarded.
  17.  */
  18. static char *verstr = "20020805";
  19. #include <linux/module.h>
  20. #include <linux/fs.h>
  21. #include <linux/kernel.h>
  22. #include <linux/sched.h>
  23. #include <linux/mm.h>
  24. #include <linux/init.h>
  25. #include <linux/string.h>
  26. #include <linux/errno.h>
  27. #include <linux/mtio.h>
  28. #include <linux/ioctl.h>
  29. #include <linux/fcntl.h>
  30. #include <linux/spinlock.h>
  31. #include <linux/smp_lock.h>
  32. #include <asm/uaccess.h>
  33. #include <asm/dma.h>
  34. #include <asm/system.h>
  35. /* The driver prints some debugging information on the console if DEBUG
  36.    is defined and non-zero. */
  37. #define DEBUG 0
  38. #if DEBUG
  39. /* The message level for the debug messages is currently set to KERN_NOTICE
  40.    so that people can easily see the messages. Later when the debugging messages
  41.    in the drivers are more widely classified, this may be changed to KERN_DEBUG. */
  42. #define ST_DEB_MSG  KERN_NOTICE
  43. #define DEB(a) a
  44. #define DEBC(a) if (debugging) { a ; }
  45. #else
  46. #define DEB(a)
  47. #define DEBC(a)
  48. #endif
  49. #define MAJOR_NR SCSI_TAPE_MAJOR
  50. #include <linux/blk.h>
  51. #include "scsi.h"
  52. #include "hosts.h"
  53. #include <scsi/scsi_ioctl.h>
  54. #define ST_KILOBYTE 1024
  55. #include "st_options.h"
  56. #include "st.h"
  57. #include "constants.h"
  58. static int buffer_kbs;
  59. static int write_threshold_kbs;
  60. static int max_buffers = (-1);
  61. static int max_sg_segs;
  62. static int blocking_open = ST_BLOCKING_OPEN;
  63. MODULE_AUTHOR("Kai Makisara");
  64. MODULE_DESCRIPTION("SCSI Tape Driver");
  65. MODULE_LICENSE("GPL");
  66. MODULE_PARM(buffer_kbs, "i");
  67. MODULE_PARM_DESC(buffer_kbs, "Default driver buffer size (KB; 32)");
  68. MODULE_PARM(write_threshold_kbs, "i");
  69. MODULE_PARM_DESC(write_threshold_kbs, "Asynchronous write threshold (KB; 30)");
  70. MODULE_PARM(max_buffers, "i");
  71. MODULE_PARM_DESC(max_buffers, "Maximum number of buffer allocated at initialisation (4)");
  72. MODULE_PARM(max_sg_segs, "i");
  73. MODULE_PARM_DESC(max_sg_segs, "Maximum number of scatter/gather segments to use (32)");
  74. MODULE_PARM(blocking_open, "i");
  75. MODULE_PARM_DESC(blocking_open, "Block in open if not ready an no O_NONBLOCK (0)");
  76. EXPORT_NO_SYMBOLS;
  77. #ifndef MODULE
  78. static struct st_dev_parm {
  79. char *name;
  80. int *val;
  81. } parms[] __initdata = {
  82. {
  83. "buffer_kbs", &buffer_kbs
  84. },
  85. {
  86. "write_threshold_kbs", &write_threshold_kbs
  87. },
  88. {
  89. "max_buffers", &max_buffers
  90. },
  91. {
  92. "max_sg_segs", &max_sg_segs
  93. },
  94. {
  95. "blocking_open", &blocking_open
  96. }
  97. };
  98. #endif
  99. /* The default definitions have been moved to st_options.h */
  100. #define ST_BUFFER_SIZE (ST_BUFFER_BLOCKS * ST_KILOBYTE)
  101. #define ST_WRITE_THRESHOLD (ST_WRITE_THRESHOLD_BLOCKS * ST_KILOBYTE)
  102. /* The buffer size should fit into the 24 bits for length in the
  103.    6-byte SCSI read and write commands. */
  104. #if ST_BUFFER_SIZE >= (2 << 24 - 1)
  105. #error "Buffer size should not exceed (2 << 24 - 1) bytes!"
  106. #endif
  107. DEB( static int debugging = DEBUG; )
  108. #define MAX_RETRIES 0
  109. #define MAX_WRITE_RETRIES 0
  110. #define MAX_READY_RETRIES 5
  111. #define NO_TAPE  NOT_READY
  112. #define ST_TIMEOUT (900 * HZ)
  113. #define ST_LONG_TIMEOUT (14000 * HZ)
  114. #define TAPE_NR(x) (MINOR(x) & ~(128 | ST_MODE_MASK))
  115. #define TAPE_MODE(x) ((MINOR(x) & ST_MODE_MASK) >> ST_MODE_SHIFT)
  116. /* Internal ioctl to set both density (uppermost 8 bits) and blocksize (lower
  117.    24 bits) */
  118. #define SET_DENS_AND_BLK 0x10001
  119. #define ST_DEV_ARR_LUMP  6
  120. static rwlock_t st_dev_arr_lock = RW_LOCK_UNLOCKED;
  121. static int st_nbr_buffers;
  122. static ST_buffer **st_buffers = NULL;
  123. static int st_buffer_size = ST_BUFFER_SIZE;
  124. static int st_write_threshold = ST_WRITE_THRESHOLD;
  125. static int st_max_buffers = ST_MAX_BUFFERS;
  126. static int st_max_sg_segs = ST_MAX_SG;
  127. static Scsi_Tape **scsi_tapes = NULL;
  128. static int modes_defined;
  129. static ST_buffer *new_tape_buffer(int, int, int);
  130. static int enlarge_buffer(ST_buffer *, int, int);
  131. static void normalize_buffer(ST_buffer *);
  132. static int set_sg_lengths(ST_buffer *, unsigned int);
  133. static int append_to_buffer(const char *, ST_buffer *, int);
  134. static int from_buffer(ST_buffer *, char *, int);
  135. static int st_init(void);
  136. static int st_attach(Scsi_Device *);
  137. static int st_detect(Scsi_Device *);
  138. static void st_detach(Scsi_Device *);
  139. static struct Scsi_Device_Template st_template =
  140. {
  141. name:"tape", 
  142. tag:"st", 
  143. scsi_type:TYPE_TAPE,
  144. major:SCSI_TAPE_MAJOR, 
  145. detect:st_detect, 
  146. init:st_init,
  147. attach:st_attach, 
  148. detach:st_detach
  149. };
  150. static int st_compression(Scsi_Tape *, int);
  151. static int find_partition(Scsi_Tape *);
  152. static int update_partition(Scsi_Tape *);
  153. static int st_int_ioctl(Scsi_Tape *, unsigned int, unsigned long);
  154. #include "osst_detect.h"
  155. #ifndef SIGS_FROM_OSST
  156. #define SIGS_FROM_OSST 
  157. {"OnStream", "SC-", "", "osst"}, 
  158. {"OnStream", "DI-", "", "osst"}, 
  159. {"OnStream", "DP-", "", "osst"}, 
  160. {"OnStream", "USB", "", "osst"}, 
  161. {"OnStream", "FW-", "", "osst"}
  162. #endif
  163. struct st_reject_data {
  164. char *vendor;
  165. char *model;
  166. char *rev;
  167. char *driver_hint; /* Name of the correct driver, NULL if unknown */
  168. };
  169. static struct st_reject_data reject_list[] = {
  170. /* {"XXX", "Yy-", "", NULL},  example */
  171. SIGS_FROM_OSST,
  172. {NULL, }};
  173. /* If the device signature is on the list of incompatible drives, the
  174.    function returns a pointer to the name of the correct driver (if known) */
  175. static char * st_incompatible(Scsi_Device* SDp)
  176. {
  177. struct st_reject_data *rp;
  178. for (rp=&(reject_list[0]); rp->vendor != NULL; rp++)
  179. if (!strncmp(rp->vendor, SDp->vendor, strlen(rp->vendor)) &&
  180.     !strncmp(rp->model, SDp->model, strlen(rp->model)) &&
  181.     !strncmp(rp->rev, SDp->rev, strlen(rp->rev))) {
  182. if (rp->driver_hint)
  183. return rp->driver_hint;
  184. else
  185. return "unknown";
  186. }
  187. return NULL;
  188. }
  189. /* Convert the result to success code */
  190. static int st_chk_result(Scsi_Tape *STp, Scsi_Request * SRpnt)
  191. {
  192. int dev;
  193. int result = SRpnt->sr_result;
  194. unsigned char *sense = SRpnt->sr_sense_buffer, scode;
  195. DEB(const char *stp;)
  196. if (!result) {
  197. sense[0] = 0; /* We don't have sense data if this byte is zero */
  198. return 0;
  199. }
  200. if ((driver_byte(result) & DRIVER_SENSE) == DRIVER_SENSE)
  201. scode = sense[2] & 0x0f;
  202. else {
  203. sense[0] = 0;
  204. scode = 0;
  205. }
  206. dev = TAPE_NR(SRpnt->sr_request.rq_dev);
  207.         DEB(
  208.         if (debugging) {
  209.                 printk(ST_DEB_MSG "st%d: Error: %x, cmd: %x %x %x %x %x %x Len: %dn",
  210.        dev, result,
  211.        SRpnt->sr_cmnd[0], SRpnt->sr_cmnd[1], SRpnt->sr_cmnd[2],
  212.        SRpnt->sr_cmnd[3], SRpnt->sr_cmnd[4], SRpnt->sr_cmnd[5],
  213.        SRpnt->sr_bufflen);
  214. if (driver_byte(result) & DRIVER_SENSE)
  215. print_req_sense("st", SRpnt);
  216. } else ) /* end DEB */
  217. if (!(driver_byte(result) & DRIVER_SENSE) ||
  218.     ((sense[0] & 0x70) == 0x70 &&
  219.      scode != NO_SENSE &&
  220.      scode != RECOVERED_ERROR &&
  221.                      /* scode != UNIT_ATTENTION && */
  222.      scode != BLANK_CHECK &&
  223.      scode != VOLUME_OVERFLOW &&
  224.      SRpnt->sr_cmnd[0] != MODE_SENSE &&
  225.      SRpnt->sr_cmnd[0] != TEST_UNIT_READY)) { /* Abnormal conditions for tape */
  226. if (driver_byte(result) & DRIVER_SENSE) {
  227. printk(KERN_WARNING "st%d: Error with sense data: ", dev);
  228. print_req_sense("st", SRpnt);
  229. } else
  230. printk(KERN_WARNING
  231.        "st%d: Error %x (sugg. bt 0x%x, driver bt 0x%x, host bt 0x%x).n",
  232.        dev, result, suggestion(result),
  233.                                driver_byte(result) & DRIVER_MASK, host_byte(result));
  234. }
  235. if (STp->cln_mode >= EXTENDED_SENSE_START) {
  236. if (STp->cln_sense_value)
  237. STp->cleaning_req |= ((SRpnt->sr_sense_buffer[STp->cln_mode] &
  238.        STp->cln_sense_mask) == STp->cln_sense_value);
  239. else
  240. STp->cleaning_req |= ((SRpnt->sr_sense_buffer[STp->cln_mode] &
  241.        STp->cln_sense_mask) != 0);
  242. }
  243. if (sense[12] == 0 && sense[13] == 0x17) /* ASC and ASCQ => cleaning requested */
  244. STp->cleaning_req = 1;
  245. if ((sense[0] & 0x70) == 0x70 &&
  246.     scode == RECOVERED_ERROR
  247. #if ST_RECOVERED_WRITE_FATAL
  248.     && SRpnt->sr_cmnd[0] != WRITE_6
  249.     && SRpnt->sr_cmnd[0] != WRITE_FILEMARKS
  250. #endif
  251.     ) {
  252. STp->recover_count++;
  253. STp->recover_reg++;
  254.                 DEB(
  255. if (debugging) {
  256. if (SRpnt->sr_cmnd[0] == READ_6)
  257. stp = "read";
  258. else if (SRpnt->sr_cmnd[0] == WRITE_6)
  259. stp = "write";
  260. else
  261. stp = "ioctl";
  262. printk(ST_DEB_MSG "st%d: Recovered %s error (%d).n", dev, stp,
  263.        STp->recover_count);
  264. } ) /* end DEB */
  265. if ((sense[2] & 0xe0) == 0)
  266. return 0;
  267. }
  268. return (-EIO);
  269. }
  270. /* Wakeup from interrupt */
  271. static void st_sleep_done(Scsi_Cmnd * SCpnt)
  272. {
  273. unsigned int st_nbr;
  274. int remainder;
  275. Scsi_Tape *STp;
  276. st_nbr = TAPE_NR(SCpnt->request.rq_dev);
  277. read_lock(&st_dev_arr_lock);
  278. STp = scsi_tapes[st_nbr];
  279. read_unlock(&st_dev_arr_lock);
  280. if ((STp->buffer)->writing &&
  281.     (SCpnt->sense_buffer[0] & 0x70) == 0x70 &&
  282.     (SCpnt->sense_buffer[2] & 0x40)) {
  283. /* EOM at write-behind, has all been written? */
  284. if ((SCpnt->sense_buffer[0] & 0x80) != 0)
  285. remainder = (SCpnt->sense_buffer[3] << 24) |
  286. (SCpnt->sense_buffer[4] << 16) |
  287. (SCpnt->sense_buffer[5] << 8) |
  288. SCpnt->sense_buffer[6];
  289. else
  290. remainder = 0;
  291. if ((SCpnt->sense_buffer[2] & 0x0f) == VOLUME_OVERFLOW ||
  292.     remainder > 0)
  293. (STp->buffer)->midlevel_result = SCpnt->result; /* Error */
  294. else
  295. (STp->buffer)->midlevel_result = INT_MAX; /* OK */
  296. } else
  297. (STp->buffer)->midlevel_result = SCpnt->result;
  298. SCpnt->request.rq_status = RQ_SCSI_DONE;
  299. (STp->buffer)->last_SRpnt = SCpnt->sc_request;
  300. DEB( STp->write_pending = 0; )
  301. complete(SCpnt->request.waiting);
  302. }
  303. /* Do the scsi command. Waits until command performed if do_wait is true.
  304.    Otherwise write_behind_check() is used to check that the command
  305.    has finished. */
  306. static Scsi_Request *
  307.  st_do_scsi(Scsi_Request * SRpnt, Scsi_Tape * STp, unsigned char *cmd, int bytes,
  308.     int direction, int timeout, int retries, int do_wait)
  309. {
  310. unsigned char *bp;
  311. if (SRpnt == NULL) {
  312. SRpnt = scsi_allocate_request(STp->device);
  313. if (SRpnt == NULL) {
  314. DEBC( printk(KERN_ERR "st%d: Can't get SCSI request.n",
  315.      TAPE_NR(STp->devt)); );
  316. if (signal_pending(current))
  317. (STp->buffer)->syscall_result = (-EINTR);
  318. else
  319. (STp->buffer)->syscall_result = (-EBUSY);
  320. return NULL;
  321. }
  322. }
  323. if (SRpnt->sr_device->scsi_level <= SCSI_2)
  324. cmd[1] |= (SRpnt->sr_device->lun << 5) & 0xe0;
  325. init_completion(&STp->wait);
  326. SRpnt->sr_use_sg = (bytes > (STp->buffer)->sg_lengths[0]) ?
  327.     (STp->buffer)->use_sg : 0;
  328. if (SRpnt->sr_use_sg) {
  329. bp = (char *) &((STp->buffer)->sg[0]);
  330. SRpnt->sr_use_sg = set_sg_lengths(STp->buffer, bytes);
  331. } else
  332. bp = (STp->buffer)->b_data;
  333. SRpnt->sr_data_direction = direction;
  334. SRpnt->sr_cmd_len = 0;
  335. SRpnt->sr_request.waiting = &(STp->wait);
  336. SRpnt->sr_request.rq_status = RQ_SCSI_BUSY;
  337. SRpnt->sr_request.rq_dev = STp->devt;
  338. scsi_do_req(SRpnt, (void *) cmd, bp, bytes,
  339.     st_sleep_done, timeout, retries);
  340. if (do_wait) {
  341. wait_for_completion(SRpnt->sr_request.waiting);
  342. SRpnt->sr_request.waiting = NULL;
  343. (STp->buffer)->syscall_result = st_chk_result(STp, SRpnt);
  344. }
  345. return SRpnt;
  346. }
  347. /* Handle the write-behind checking (downs the semaphore) */
  348. static void write_behind_check(Scsi_Tape * STp)
  349. {
  350. ST_buffer *STbuffer;
  351. ST_partstat *STps;
  352. STbuffer = STp->buffer;
  353.         DEB(
  354. if (STp->write_pending)
  355. STp->nbr_waits++;
  356. else
  357. STp->nbr_finished++;
  358.         ) /* end DEB */
  359. wait_for_completion(&(STp->wait));
  360. (STp->buffer)->last_SRpnt->sr_request.waiting = NULL;
  361. (STp->buffer)->syscall_result = st_chk_result(STp, (STp->buffer)->last_SRpnt);
  362. scsi_release_request((STp->buffer)->last_SRpnt);
  363. STbuffer->buffer_bytes -= STbuffer->writing;
  364. STps = &(STp->ps[STp->partition]);
  365. if (STps->drv_block >= 0) {
  366. if (STp->block_size == 0)
  367. STps->drv_block++;
  368. else
  369. STps->drv_block += STbuffer->writing / STp->block_size;
  370. }
  371. STbuffer->writing = 0;
  372. return;
  373. }
  374. /* Step over EOF if it has been inadvertently crossed (ioctl not used because
  375.    it messes up the block number). */
  376. static int cross_eof(Scsi_Tape * STp, int forward)
  377. {
  378. Scsi_Request *SRpnt;
  379. unsigned char cmd[MAX_COMMAND_SIZE];
  380. cmd[0] = SPACE;
  381. cmd[1] = 0x01; /* Space FileMarks */
  382. if (forward) {
  383. cmd[2] = cmd[3] = 0;
  384. cmd[4] = 1;
  385. } else
  386. cmd[2] = cmd[3] = cmd[4] = 0xff; /* -1 filemarks */
  387. cmd[5] = 0;
  388.         DEBC(printk(ST_DEB_MSG "st%d: Stepping over filemark %s.n",
  389.    TAPE_NR(STp->devt), forward ? "forward" : "backward"));
  390. SRpnt = st_do_scsi(NULL, STp, cmd, 0, SCSI_DATA_NONE,
  391.    STp->timeout, MAX_RETRIES, TRUE);
  392. if (!SRpnt)
  393. return (STp->buffer)->syscall_result;
  394. scsi_release_request(SRpnt);
  395. SRpnt = NULL;
  396. if ((STp->buffer)->midlevel_result != 0)
  397. printk(KERN_ERR "st%d: Stepping over filemark %s failed.n",
  398.    TAPE_NR(STp->devt), forward ? "forward" : "backward");
  399. return (STp->buffer)->syscall_result;
  400. }
  401. /* Flush the write buffer (never need to write if variable blocksize). */
  402. static int flush_write_buffer(Scsi_Tape * STp)
  403. {
  404. int offset, transfer, blks;
  405. int result;
  406. unsigned char cmd[MAX_COMMAND_SIZE];
  407. Scsi_Request *SRpnt;
  408. ST_partstat *STps;
  409. if ((STp->buffer)->writing) {
  410. write_behind_check(STp);
  411. if ((STp->buffer)->syscall_result) {
  412.                         DEBC(printk(ST_DEB_MSG
  413.                                        "st%d: Async write error (flush) %x.n",
  414.        TAPE_NR(STp->devt), (STp->buffer)->midlevel_result))
  415. if ((STp->buffer)->midlevel_result == INT_MAX)
  416. return (-ENOSPC);
  417. return (-EIO);
  418. }
  419. }
  420. if (STp->block_size == 0)
  421. return 0;
  422. result = 0;
  423. if (STp->dirty == 1) {
  424. offset = (STp->buffer)->buffer_bytes;
  425. transfer = ((offset + STp->block_size - 1) /
  426.     STp->block_size) * STp->block_size;
  427.                 DEBC(printk(ST_DEB_MSG "st%d: Flushing %d bytes.n",
  428.                                TAPE_NR(STp->devt), transfer));
  429. memset((STp->buffer)->b_data + offset, 0, transfer - offset);
  430. memset(cmd, 0, MAX_COMMAND_SIZE);
  431. cmd[0] = WRITE_6;
  432. cmd[1] = 1;
  433. blks = transfer / STp->block_size;
  434. cmd[2] = blks >> 16;
  435. cmd[3] = blks >> 8;
  436. cmd[4] = blks;
  437. SRpnt = st_do_scsi(NULL, STp, cmd, transfer, SCSI_DATA_WRITE,
  438.    STp->timeout, MAX_WRITE_RETRIES, TRUE);
  439. if (!SRpnt)
  440. return (STp->buffer)->syscall_result;
  441. STps = &(STp->ps[STp->partition]);
  442. if ((STp->buffer)->syscall_result != 0) {
  443. if ((SRpnt->sr_sense_buffer[0] & 0x70) == 0x70 &&
  444.     (SRpnt->sr_sense_buffer[2] & 0x40) &&
  445.     (SRpnt->sr_sense_buffer[2] & 0x0f) == NO_SENSE) {
  446. STp->dirty = 0;
  447. (STp->buffer)->buffer_bytes = 0;
  448. result = (-ENOSPC);
  449. } else {
  450. printk(KERN_ERR "st%d: Error on flush.n",
  451.                                        TAPE_NR(STp->devt));
  452. result = (-EIO);
  453. }
  454. STps->drv_block = (-1);
  455. } else {
  456. if (STps->drv_block >= 0)
  457. STps->drv_block += blks;
  458. STp->dirty = 0;
  459. (STp->buffer)->buffer_bytes = 0;
  460. }
  461. scsi_release_request(SRpnt);
  462. SRpnt = NULL;
  463. }
  464. return result;
  465. }
  466. /* Flush the tape buffer. The tape will be positioned correctly unless
  467.    seek_next is true. */
  468. static int flush_buffer(Scsi_Tape *STp, int seek_next)
  469. {
  470. int backspace, result;
  471. ST_buffer *STbuffer;
  472. ST_partstat *STps;
  473. STbuffer = STp->buffer;
  474. /*
  475.  * If there was a bus reset, block further access
  476.  * to this device.
  477.  */
  478. if (STp->device->was_reset)
  479. return (-EIO);
  480. if (STp->ready != ST_READY)
  481. return 0;
  482. STps = &(STp->ps[STp->partition]);
  483. if (STps->rw == ST_WRITING) /* Writing */
  484. return flush_write_buffer(STp);
  485. if (STp->block_size == 0)
  486. return 0;
  487. backspace = ((STp->buffer)->buffer_bytes +
  488.      (STp->buffer)->read_pointer) / STp->block_size -
  489.     ((STp->buffer)->read_pointer + STp->block_size - 1) /
  490.     STp->block_size;
  491. (STp->buffer)->buffer_bytes = 0;
  492. (STp->buffer)->read_pointer = 0;
  493. result = 0;
  494. if (!seek_next) {
  495. if (STps->eof == ST_FM_HIT) {
  496. result = cross_eof(STp, FALSE); /* Back over the EOF hit */
  497. if (!result)
  498. STps->eof = ST_NOEOF;
  499. else {
  500. if (STps->drv_file >= 0)
  501. STps->drv_file++;
  502. STps->drv_block = 0;
  503. }
  504. }
  505. if (!result && backspace > 0)
  506. result = st_int_ioctl(STp, MTBSR, backspace);
  507. } else if (STps->eof == ST_FM_HIT) {
  508. if (STps->drv_file >= 0)
  509. STps->drv_file++;
  510. STps->drv_block = 0;
  511. STps->eof = ST_NOEOF;
  512. }
  513. return result;
  514. }
  515. /* Set the mode parameters */
  516. static int set_mode_densblk(Scsi_Tape * STp, ST_mode * STm)
  517. {
  518. int set_it = FALSE;
  519. unsigned long arg;
  520. int dev = TAPE_NR(STp->devt);
  521. if (!STp->density_changed &&
  522.     STm->default_density >= 0 &&
  523.     STm->default_density != STp->density) {
  524. arg = STm->default_density;
  525. set_it = TRUE;
  526. } else
  527. arg = STp->density;
  528. arg <<= MT_ST_DENSITY_SHIFT;
  529. if (!STp->blksize_changed &&
  530.     STm->default_blksize >= 0 &&
  531.     STm->default_blksize != STp->block_size) {
  532. arg |= STm->default_blksize;
  533. set_it = TRUE;
  534. } else
  535. arg |= STp->block_size;
  536. if (set_it &&
  537.     st_int_ioctl(STp, SET_DENS_AND_BLK, arg)) {
  538. printk(KERN_WARNING
  539.        "st%d: Can't set default block size to %d bytes and density %x.n",
  540.        dev, STm->default_blksize, STm->default_density);
  541. if (modes_defined)
  542. return (-EINVAL);
  543. }
  544. return 0;
  545. }
  546. /* Test if the drive is ready. Returns either one of the codes below or a negative system
  547.    error code. */
  548. #define CHKRES_READY       0
  549. #define CHKRES_NEW_SESSION 1
  550. #define CHKRES_NOT_READY   2
  551. #define CHKRES_NO_TAPE     3
  552. #define MAX_ATTENTIONS    10
  553. static int test_ready(Scsi_Tape *STp, int do_wait)
  554. {
  555. int attentions, waits, max_wait, scode;
  556. int retval = CHKRES_READY, new_session = FALSE;
  557. unsigned char cmd[MAX_COMMAND_SIZE];
  558. Scsi_Request *SRpnt = NULL;
  559. max_wait = do_wait ? ST_BLOCK_SECONDS : 0;
  560. for (attentions=waits=0; ; ) {
  561. memset((void *) &cmd[0], 0, MAX_COMMAND_SIZE);
  562. cmd[0] = TEST_UNIT_READY;
  563. SRpnt = st_do_scsi(SRpnt, STp, cmd, 0, SCSI_DATA_NONE,
  564.    STp->long_timeout, MAX_READY_RETRIES, TRUE);
  565. if (!SRpnt) {
  566. retval = (STp->buffer)->syscall_result;
  567. break;
  568. }
  569. if ((SRpnt->sr_sense_buffer[0] & 0x70) == 0x70) {
  570. scode = (SRpnt->sr_sense_buffer[2] & 0x0f);
  571. if (scode == UNIT_ATTENTION) { /* New media? */
  572. new_session = TRUE;
  573. if (attentions < MAX_ATTENTIONS) {
  574. attentions++;
  575. continue;
  576. }
  577. else {
  578. retval = (-EIO);
  579. break;
  580. }
  581. }
  582. if (scode == NOT_READY) {
  583. if (waits < max_wait) {
  584. set_current_state(TASK_INTERRUPTIBLE);
  585. schedule_timeout(HZ);
  586. if (signal_pending(current)) {
  587. retval = (-EINTR);
  588. break;
  589. }
  590. waits++;
  591. continue;
  592. }
  593. else {
  594. if ((STp->device)->scsi_level >= SCSI_2 &&
  595.     SRpnt->sr_sense_buffer[12] == 0x3a) /* Check ASC */
  596. retval = CHKRES_NO_TAPE;
  597. else
  598. retval = CHKRES_NOT_READY;
  599. break;
  600. }
  601. }
  602. }
  603. retval = (STp->buffer)->syscall_result;
  604. if (!retval)
  605. retval = new_session ? CHKRES_NEW_SESSION : CHKRES_READY;
  606. break;
  607. }
  608. if (SRpnt != NULL)
  609. scsi_release_request(SRpnt);
  610. return retval;
  611. }
  612. /* See if the drive is ready and gather information about the tape. Return values:
  613.    < 0   negative error code from errno.h
  614.    0     drive ready
  615.    1     drive not ready (possibly no tape)
  616. */
  617. static int check_tape(Scsi_Tape *STp, struct file *filp)
  618. {
  619. int i, retval, new_session = FALSE, do_wait;
  620. unsigned char cmd[MAX_COMMAND_SIZE], saved_cleaning;
  621. unsigned short st_flags = filp->f_flags;
  622. Scsi_Request *SRpnt = NULL;
  623. ST_mode *STm;
  624. ST_partstat *STps;
  625. int dev = TAPE_NR(STp->devt);
  626. struct inode *inode = filp->f_dentry->d_inode;
  627. int mode = TAPE_MODE(inode->i_rdev);
  628. STp->ready = ST_READY;
  629. if (mode != STp->current_mode) {
  630.                 DEBC(printk(ST_DEB_MSG "st%d: Mode change from %d to %d.n",
  631.        dev, STp->current_mode, mode));
  632. new_session = TRUE;
  633. STp->current_mode = mode;
  634. }
  635. STm = &(STp->modes[STp->current_mode]);
  636. saved_cleaning = STp->cleaning_req;
  637. STp->cleaning_req = 0;
  638. do_wait = (blocking_open && (filp->f_flags & O_NONBLOCK) == 0);
  639. retval = test_ready(STp, do_wait);
  640. if (retval < 0)
  641. goto err_out;
  642. if (retval == CHKRES_NEW_SESSION) {
  643. (STp->device)->was_reset = 0;
  644. STp->partition = STp->new_partition = 0;
  645. if (STp->can_partitions)
  646. STp->nbr_partitions = 1; /* This guess will be updated later
  647.                                                     if necessary */
  648. for (i = 0; i < ST_NBR_PARTITIONS; i++) {
  649. STps = &(STp->ps[i]);
  650. STps->rw = ST_IDLE;
  651. STps->eof = ST_NOEOF;
  652. STps->at_sm = 0;
  653. STps->last_block_valid = FALSE;
  654. STps->drv_block = 0;
  655. STps->drv_file = 0;
  656. }
  657. new_session = TRUE;
  658. }
  659. else {
  660. STp->cleaning_req |= saved_cleaning;
  661. if (retval == CHKRES_NOT_READY || retval == CHKRES_NO_TAPE) {
  662. if (retval == CHKRES_NO_TAPE)
  663. STp->ready = ST_NO_TAPE;
  664. else
  665. STp->ready = ST_NOT_READY;
  666. STp->density = 0; /* Clear the erroneous "residue" */
  667. STp->write_prot = 0;
  668. STp->block_size = 0;
  669. STp->ps[0].drv_file = STp->ps[0].drv_block = (-1);
  670. STp->partition = STp->new_partition = 0;
  671. STp->door_locked = ST_UNLOCKED;
  672. return CHKRES_NOT_READY;
  673. }
  674. }
  675. if (STp->omit_blklims)
  676. STp->min_block = STp->max_block = (-1);
  677. else {
  678. memset((void *) &cmd[0], 0, MAX_COMMAND_SIZE);
  679. cmd[0] = READ_BLOCK_LIMITS;
  680. SRpnt = st_do_scsi(SRpnt, STp, cmd, 6, SCSI_DATA_READ, STp->timeout,
  681.    MAX_READY_RETRIES, TRUE);
  682. if (!SRpnt) {
  683. retval = (STp->buffer)->syscall_result;
  684. goto err_out;
  685. }
  686. if (!SRpnt->sr_result && !SRpnt->sr_sense_buffer[0]) {
  687. STp->max_block = ((STp->buffer)->b_data[1] << 16) |
  688.     ((STp->buffer)->b_data[2] << 8) | (STp->buffer)->b_data[3];
  689. STp->min_block = ((STp->buffer)->b_data[4] << 8) |
  690.     (STp->buffer)->b_data[5];
  691. if ( DEB( debugging || ) !STp->inited)
  692. printk(KERN_WARNING
  693.                                        "st%d: Block limits %d - %d bytes.n", dev,
  694.                                        STp->min_block, STp->max_block);
  695. } else {
  696. STp->min_block = STp->max_block = (-1);
  697.                         DEBC(printk(ST_DEB_MSG "st%d: Can't read block limits.n",
  698.                                        dev));
  699. }
  700. }
  701. memset((void *) &cmd[0], 0, MAX_COMMAND_SIZE);
  702. cmd[0] = MODE_SENSE;
  703. cmd[4] = 12;
  704. SRpnt = st_do_scsi(SRpnt, STp, cmd, 12, SCSI_DATA_READ, STp->timeout,
  705.    MAX_READY_RETRIES, TRUE);
  706. if (!SRpnt) {
  707. retval = (STp->buffer)->syscall_result;
  708. goto err_out;
  709. }
  710. if ((STp->buffer)->syscall_result != 0) {
  711.                 DEBC(printk(ST_DEB_MSG "st%d: No Mode Sense.n", dev));
  712. STp->block_size = ST_DEFAULT_BLOCK; /* Educated guess (?) */
  713. (STp->buffer)->syscall_result = 0; /* Prevent error propagation */
  714. STp->drv_write_prot = 0;
  715. } else {
  716.                 DEBC(printk(ST_DEB_MSG
  717.                             "st%d: Mode sense. Length %d, medium %x, WBS %x, BLL %dn",
  718.                             dev,
  719.                             (STp->buffer)->b_data[0], (STp->buffer)->b_data[1],
  720.                             (STp->buffer)->b_data[2], (STp->buffer)->b_data[3]));
  721. if ((STp->buffer)->b_data[3] >= 8) {
  722. STp->drv_buffer = ((STp->buffer)->b_data[2] >> 4) & 7;
  723. STp->density = (STp->buffer)->b_data[4];
  724. STp->block_size = (STp->buffer)->b_data[9] * 65536 +
  725.     (STp->buffer)->b_data[10] * 256 + (STp->buffer)->b_data[11];
  726.                         DEBC(printk(ST_DEB_MSG
  727.                                     "st%d: Density %x, tape length: %x, drv buffer: %dn",
  728.                                     dev, STp->density, (STp->buffer)->b_data[5] * 65536 +
  729.                                     (STp->buffer)->b_data[6] * 256 + (STp->buffer)->b_data[7],
  730.                                     STp->drv_buffer));
  731. }
  732. STp->drv_write_prot = ((STp->buffer)->b_data[2] & 0x80) != 0;
  733. }
  734. scsi_release_request(SRpnt);
  735. SRpnt = NULL;
  736.         STp->inited = TRUE;
  737. if (STp->block_size > 0)
  738. (STp->buffer)->buffer_blocks =
  739.                         (STp->buffer)->buffer_size / STp->block_size;
  740. else
  741. (STp->buffer)->buffer_blocks = 1;
  742. (STp->buffer)->buffer_bytes = (STp->buffer)->read_pointer = 0;
  743.         DEBC(printk(ST_DEB_MSG
  744.                        "st%d: Block size: %d, buffer size: %d (%d blocks).n", dev,
  745.        STp->block_size, (STp->buffer)->buffer_size,
  746.        (STp->buffer)->buffer_blocks));
  747. if (STp->drv_write_prot) {
  748. STp->write_prot = 1;
  749.                 DEBC(printk(ST_DEB_MSG "st%d: Write protectedn", dev));
  750. if ((st_flags & O_ACCMODE) == O_WRONLY ||
  751.     (st_flags & O_ACCMODE) == O_RDWR) {
  752. retval = (-EROFS);
  753. goto err_out;
  754. }
  755. }
  756. if (STp->can_partitions && STp->nbr_partitions < 1) {
  757. /* This code is reached when the device is opened for the first time
  758.    after the driver has been initialized with tape in the drive and the
  759.    partition support has been enabled. */
  760.                 DEBC(printk(ST_DEB_MSG
  761.                             "st%d: Updating partition number in status.n", dev));
  762. if ((STp->partition = find_partition(STp)) < 0) {
  763. retval = STp->partition;
  764. goto err_out;
  765. }
  766. STp->new_partition = STp->partition;
  767. STp->nbr_partitions = 1; /* This guess will be updated when necessary */
  768. }
  769. if (new_session) { /* Change the drive parameters for the new mode */
  770. STp->density_changed = STp->blksize_changed = FALSE;
  771. STp->compression_changed = FALSE;
  772. if (!(STm->defaults_for_writes) &&
  773.     (retval = set_mode_densblk(STp, STm)) < 0)
  774.     goto err_out;
  775. if (STp->default_drvbuffer != 0xff) {
  776. if (st_int_ioctl(STp, MTSETDRVBUFFER, STp->default_drvbuffer))
  777. printk(KERN_WARNING
  778.                                        "st%d: Can't set default drive buffering to %d.n",
  779.        dev, STp->default_drvbuffer);
  780. }
  781. }
  782. return CHKRES_READY;
  783.  err_out:
  784. return retval;
  785. }
  786. /* Open the device. Needs to be called with BKL only because of incrementing the SCSI host
  787.    module count. */
  788. static int st_open(struct inode *inode, struct file *filp)
  789. {
  790. int i, need_dma_buffer;
  791. int retval = (-EIO);
  792. Scsi_Tape *STp;
  793. ST_partstat *STps;
  794. int dev = TAPE_NR(inode->i_rdev);
  795. unsigned long flags;
  796. write_lock_irqsave(&st_dev_arr_lock, flags);
  797. STp = scsi_tapes[dev];
  798. if (dev >= st_template.dev_max || STp == NULL) {
  799. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  800. return (-ENXIO);
  801. }
  802. if (STp->in_use) {
  803. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  804. DEB( printk(ST_DEB_MSG "st%d: Device already in use.n", dev); )
  805. return (-EBUSY);
  806. }
  807. STp->in_use = 1;
  808. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  809. STp->rew_at_close = STp->autorew_dev = (MINOR(inode->i_rdev) & 0x80) == 0;
  810. if (STp->device->host->hostt->module)
  811. __MOD_INC_USE_COUNT(STp->device->host->hostt->module);
  812. STp->device->access_count++;
  813. if (!scsi_block_when_processing_errors(STp->device)) {
  814. retval = (-ENXIO);
  815. goto err_out;
  816. }
  817. /* Allocate a buffer for this user */
  818. need_dma_buffer = STp->restr_dma;
  819. write_lock_irqsave(&st_dev_arr_lock, flags);
  820. for (i = 0; i < st_nbr_buffers; i++)
  821. if (!st_buffers[i]->in_use &&
  822.     (!need_dma_buffer || st_buffers[i]->dma)) {
  823. STp->buffer = st_buffers[i];
  824. (STp->buffer)->in_use = 1;
  825. break;
  826. }
  827. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  828. if (i >= st_nbr_buffers) {
  829. STp->buffer = new_tape_buffer(FALSE, need_dma_buffer, TRUE);
  830. if (STp->buffer == NULL) {
  831. printk(KERN_WARNING "st%d: Can't allocate tape buffer.n", dev);
  832. retval = (-EBUSY);
  833. goto err_out;
  834. }
  835. }
  836. (STp->buffer)->writing = 0;
  837. (STp->buffer)->syscall_result = 0;
  838. (STp->buffer)->use_sg = STp->device->host->sg_tablesize;
  839. /* Compute the usable buffer size for this SCSI adapter */
  840. if (!(STp->buffer)->use_sg)
  841. (STp->buffer)->buffer_size = (STp->buffer)->sg_lengths[0];
  842. else {
  843. for (i = 0, (STp->buffer)->buffer_size = 0; i < (STp->buffer)->use_sg &&
  844.      i < (STp->buffer)->sg_segs; i++)
  845. (STp->buffer)->buffer_size += (STp->buffer)->sg_lengths[i];
  846. }
  847. STp->write_prot = ((filp->f_flags & O_ACCMODE) == O_RDONLY);
  848. STp->dirty = 0;
  849. for (i = 0; i < ST_NBR_PARTITIONS; i++) {
  850. STps = &(STp->ps[i]);
  851. STps->rw = ST_IDLE;
  852. }
  853. STp->recover_count = 0;
  854. DEB( STp->nbr_waits = STp->nbr_finished = 0; )
  855. retval = check_tape(STp, filp);
  856. if (retval < 0)
  857. goto err_out;
  858. if (blocking_open &&
  859.     (filp->f_flags & O_NONBLOCK) == 0 &&
  860.     retval != CHKRES_READY) {
  861. retval = (-EIO);
  862. goto err_out;
  863. }
  864. return 0;
  865.  err_out:
  866. if (STp->buffer != NULL) {
  867. (STp->buffer)->in_use = 0;
  868. STp->buffer = NULL;
  869. }
  870. STp->in_use = 0;
  871. STp->device->access_count--;
  872. if (STp->device->host->hostt->module)
  873.     __MOD_DEC_USE_COUNT(STp->device->host->hostt->module);
  874. return retval;
  875. }
  876. /* Flush the tape buffer before close */
  877. static int st_flush(struct file *filp)
  878. {
  879. int result = 0, result2;
  880. unsigned char cmd[MAX_COMMAND_SIZE];
  881. Scsi_Request *SRpnt;
  882. Scsi_Tape *STp;
  883. ST_mode *STm;
  884. ST_partstat *STps;
  885. struct inode *inode = filp->f_dentry->d_inode;
  886. kdev_t devt = inode->i_rdev;
  887. int dev;
  888. if (file_count(filp) > 1)
  889. return 0;
  890. dev = TAPE_NR(devt);
  891. read_lock(&st_dev_arr_lock);
  892. STp = scsi_tapes[dev];
  893. read_unlock(&st_dev_arr_lock);
  894. STm = &(STp->modes[STp->current_mode]);
  895. STps = &(STp->ps[STp->partition]);
  896. if (STps->rw == ST_WRITING && !(STp->device)->was_reset) {
  897. result = flush_write_buffer(STp);
  898. if (result != 0 && result != (-ENOSPC))
  899. goto out;
  900. }
  901. if (STp->can_partitions &&
  902.     (result2 = update_partition(STp)) < 0) {
  903.                 DEBC(printk(ST_DEB_MSG
  904.                                "st%d: update_partition at close failed.n", dev));
  905. if (result == 0)
  906. result = result2;
  907. goto out;
  908. }
  909. if (STps->rw == ST_WRITING && !(STp->device)->was_reset) {
  910.                 DEBC(printk(ST_DEB_MSG "st%d: File length %ld bytes.n",
  911.                             dev, (long) (filp->f_pos));
  912.                      printk(ST_DEB_MSG "st%d: Async write waits %d, finished %d.n",
  913.                             dev, STp->nbr_waits, STp->nbr_finished);
  914. )
  915. memset(cmd, 0, MAX_COMMAND_SIZE);
  916. cmd[0] = WRITE_FILEMARKS;
  917. cmd[4] = 1 + STp->two_fm;
  918. SRpnt = st_do_scsi(NULL, STp, cmd, 0, SCSI_DATA_NONE,
  919.    STp->timeout, MAX_WRITE_RETRIES, TRUE);
  920. if (!SRpnt) {
  921. result = (STp->buffer)->syscall_result;
  922. goto out;
  923. }
  924. if ((STp->buffer)->syscall_result != 0 &&
  925.     ((SRpnt->sr_sense_buffer[0] & 0x70) != 0x70 ||
  926.      (SRpnt->sr_sense_buffer[2] & 0x4f) != 0x40 ||
  927.      ((SRpnt->sr_sense_buffer[0] & 0x80) != 0 &&
  928.       (SRpnt->sr_sense_buffer[3] | SRpnt->sr_sense_buffer[4] |
  929.        SRpnt->sr_sense_buffer[5] |
  930.        SRpnt->sr_sense_buffer[6]) != 0))) {
  931. /* Filter out successful write at EOM */
  932. scsi_release_request(SRpnt);
  933. SRpnt = NULL;
  934. printk(KERN_ERR "st%d: Error on write filemark.n", dev);
  935. if (result == 0)
  936. result = (-EIO);
  937. } else {
  938. scsi_release_request(SRpnt);
  939. SRpnt = NULL;
  940. if (STps->drv_file >= 0)
  941. STps->drv_file++;
  942. STps->drv_block = 0;
  943. if (STp->two_fm)
  944. cross_eof(STp, FALSE);
  945. STps->eof = ST_FM;
  946. }
  947.                 DEBC(printk(ST_DEB_MSG "st%d: Buffer flushed, %d EOF(s) writtenn",
  948.                             dev, cmd[4]));
  949. } else if (!STp->rew_at_close) {
  950. STps = &(STp->ps[STp->partition]);
  951. if (!STm->sysv || STps->rw != ST_READING) {
  952. if (STp->can_bsr)
  953. result = flush_buffer(STp, 0);
  954. else if (STps->eof == ST_FM_HIT) {
  955. result = cross_eof(STp, FALSE);
  956. if (result) {
  957. if (STps->drv_file >= 0)
  958. STps->drv_file++;
  959. STps->drv_block = 0;
  960. STps->eof = ST_FM;
  961. } else
  962. STps->eof = ST_NOEOF;
  963. }
  964. } else if ((STps->eof == ST_NOEOF &&
  965.     !(result = cross_eof(STp, TRUE))) ||
  966.    STps->eof == ST_FM_HIT) {
  967. if (STps->drv_file >= 0)
  968. STps->drv_file++;
  969. STps->drv_block = 0;
  970. STps->eof = ST_FM;
  971. }
  972. }
  973.       out:
  974. if (STp->rew_at_close) {
  975. result2 = st_int_ioctl(STp, MTREW, 1);
  976. if (result == 0)
  977. result = result2;
  978. }
  979. return result;
  980. }
  981. /* Close the device and release it. BKL is not needed: this is the only thread
  982.    accessing this tape. */
  983. static int st_release(struct inode *inode, struct file *filp)
  984. {
  985. int result = 0;
  986. Scsi_Tape *STp;
  987. unsigned long flags;
  988. kdev_t devt = inode->i_rdev;
  989. int dev;
  990. dev = TAPE_NR(devt);
  991. read_lock(&st_dev_arr_lock);
  992. STp = scsi_tapes[dev];
  993. read_unlock(&st_dev_arr_lock);
  994. if (STp->door_locked == ST_LOCKED_AUTO)
  995. st_int_ioctl(STp, MTUNLOCK, 0);
  996. if (STp->buffer != NULL) {
  997. normalize_buffer(STp->buffer);
  998. write_lock_irqsave(&st_dev_arr_lock, flags);
  999. (STp->buffer)->in_use = 0;
  1000. STp->buffer = NULL;
  1001. }
  1002. else {
  1003. write_lock_irqsave(&st_dev_arr_lock, flags);
  1004. }
  1005. STp->in_use = 0;
  1006. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  1007. STp->device->access_count--;
  1008. if (STp->device->host->hostt->module)
  1009. __MOD_DEC_USE_COUNT(STp->device->host->hostt->module);
  1010. return result;
  1011. }
  1012. /* Write command */
  1013. static ssize_t
  1014.  st_write(struct file *filp, const char *buf, size_t count, loff_t * ppos)
  1015. {
  1016. struct inode *inode = filp->f_dentry->d_inode;
  1017. ssize_t total;
  1018. ssize_t i, do_count, blks, transfer;
  1019. ssize_t retval = 0;
  1020. int write_threshold;
  1021. int doing_write = 0;
  1022. unsigned char cmd[MAX_COMMAND_SIZE];
  1023. const char *b_point;
  1024. Scsi_Request *SRpnt = NULL;
  1025. Scsi_Tape *STp;
  1026. ST_mode *STm;
  1027. ST_partstat *STps;
  1028. int dev = TAPE_NR(inode->i_rdev);
  1029. read_lock(&st_dev_arr_lock);
  1030. STp = scsi_tapes[dev];
  1031. read_unlock(&st_dev_arr_lock);
  1032. if (down_interruptible(&STp->lock))
  1033. return -ERESTARTSYS;
  1034. /*
  1035.  * If we are in the middle of error recovery, don't let anyone
  1036.  * else try and use this device.  Also, if error recovery fails, it
  1037.  * may try and take the device offline, in which case all further
  1038.  * access to the device is prohibited.
  1039.  */
  1040. if (!scsi_block_when_processing_errors(STp->device)) {
  1041. retval = (-ENXIO);
  1042. goto out;
  1043. }
  1044. if (ppos != &filp->f_pos) {
  1045. /* "A request was outside the capabilities of the device." */
  1046. retval = (-ENXIO);
  1047. goto out;
  1048. }
  1049. if (STp->ready != ST_READY) {
  1050. if (STp->ready == ST_NO_TAPE)
  1051. retval = (-ENOMEDIUM);
  1052. else
  1053. retval = (-EIO);
  1054. goto out;
  1055. }
  1056. STm = &(STp->modes[STp->current_mode]);
  1057. if (!STm->defined) {
  1058. retval = (-ENXIO);
  1059. goto out;
  1060. }
  1061. if (count == 0)
  1062. goto out;
  1063. /*
  1064.  * If there was a bus reset, block further access
  1065.  * to this device.
  1066.  */
  1067. if (STp->device->was_reset) {
  1068. retval = (-EIO);
  1069. goto out;
  1070. }
  1071.         DEB(
  1072. if (!STp->in_use) {
  1073. printk(ST_DEB_MSG "st%d: Incorrect device.n", dev);
  1074. retval = (-EIO);
  1075. goto out;
  1076. } ) /* end DEB */
  1077. /* Write must be integral number of blocks */
  1078. if (STp->block_size != 0 && (count % STp->block_size) != 0) {
  1079. printk(KERN_WARNING "st%d: Write not multiple of tape block size.n",
  1080.        dev);
  1081. retval = (-EINVAL);
  1082. goto out;
  1083. }
  1084. if (STp->can_partitions &&
  1085.     (retval = update_partition(STp)) < 0)
  1086. goto out;
  1087. STps = &(STp->ps[STp->partition]);
  1088. if (STp->write_prot) {
  1089. retval = (-EACCES);
  1090. goto out;
  1091. }
  1092. if (STp->block_size == 0) {
  1093. if (STp->max_block > 0 &&
  1094.     (count < STp->min_block || count > STp->max_block)) {
  1095. retval = (-EINVAL);
  1096. goto out;
  1097. }
  1098. if (count > (STp->buffer)->buffer_size &&
  1099.     !enlarge_buffer(STp->buffer, count, STp->restr_dma)) {
  1100. retval = (-EOVERFLOW);
  1101. goto out;
  1102. }
  1103. }
  1104. if ((STp->buffer)->buffer_blocks < 1) {
  1105. /* Fixed block mode with too small buffer */
  1106. if (!enlarge_buffer(STp->buffer, STp->block_size, STp->restr_dma)) {
  1107. retval = (-EOVERFLOW);
  1108. goto out;
  1109. }
  1110. (STp->buffer)->buffer_blocks = 1;
  1111. }
  1112. if (STp->do_auto_lock && STp->door_locked == ST_UNLOCKED &&
  1113.     !st_int_ioctl(STp, MTLOCK, 0))
  1114. STp->door_locked = ST_LOCKED_AUTO;
  1115. if (STps->rw == ST_READING) {
  1116. retval = flush_buffer(STp, 0);
  1117. if (retval)
  1118. goto out;
  1119. STps->rw = ST_WRITING;
  1120. } else if (STps->rw != ST_WRITING &&
  1121.    STps->drv_file == 0 && STps->drv_block == 0) {
  1122. if ((retval = set_mode_densblk(STp, STm)) < 0)
  1123. goto out;
  1124. if (STm->default_compression != ST_DONT_TOUCH &&
  1125.     !(STp->compression_changed)) {
  1126. if (st_compression(STp, (STm->default_compression == ST_YES))) {
  1127. printk(KERN_WARNING "st%d: Can't set default compression.n",
  1128.        dev);
  1129. if (modes_defined) {
  1130. retval = (-EINVAL);
  1131. goto out;
  1132. }
  1133. }
  1134. }
  1135. }
  1136. if ((STp->buffer)->writing) {
  1137. write_behind_check(STp);
  1138. if ((STp->buffer)->syscall_result) {
  1139.                         DEBC(printk(ST_DEB_MSG "st%d: Async write error (write) %x.n",
  1140.                                     dev, (STp->buffer)->midlevel_result));
  1141. if ((STp->buffer)->midlevel_result == INT_MAX)
  1142. STps->eof = ST_EOM_OK;
  1143. else
  1144. STps->eof = ST_EOM_ERROR;
  1145. }
  1146. }
  1147. if (STps->eof == ST_EOM_OK) {
  1148. retval = (-ENOSPC);
  1149. goto out;
  1150. }
  1151. else if (STps->eof == ST_EOM_ERROR) {
  1152. retval = (-EIO);
  1153. goto out;
  1154. }
  1155. /* Check the buffer readability in cases where copy_user might catch
  1156.    the problems after some tape movement. */
  1157. if (STp->block_size != 0 &&
  1158.     (copy_from_user(&i, buf, 1) != 0 ||
  1159.      copy_from_user(&i, buf + count - 1, 1) != 0)) {
  1160. retval = (-EFAULT);
  1161. goto out;
  1162. }
  1163. if (!STm->do_buffer_writes) {
  1164. #if 0
  1165. if (STp->block_size != 0 && (count % STp->block_size) != 0) {
  1166. retval = (-EINVAL); /* Write must be integral number of blocks */
  1167. goto out;
  1168. }
  1169. #endif
  1170. write_threshold = 1;
  1171. } else
  1172. write_threshold = (STp->buffer)->buffer_blocks * STp->block_size;
  1173. if (!STm->do_async_writes)
  1174. write_threshold--;
  1175. total = count;
  1176. memset(cmd, 0, MAX_COMMAND_SIZE);
  1177. cmd[0] = WRITE_6;
  1178. cmd[1] = (STp->block_size != 0);
  1179. STps->rw = ST_WRITING;
  1180. b_point = buf;
  1181. while ((STp->block_size == 0 && !STm->do_async_writes && count > 0) ||
  1182.        (STp->block_size != 0 &&
  1183. (STp->buffer)->buffer_bytes + count > write_threshold)) {
  1184. doing_write = 1;
  1185. if (STp->block_size == 0)
  1186. do_count = count;
  1187. else {
  1188. do_count = (STp->buffer)->buffer_blocks * STp->block_size -
  1189.     (STp->buffer)->buffer_bytes;
  1190. if (do_count > count)
  1191. do_count = count;
  1192. }
  1193. i = append_to_buffer(b_point, STp->buffer, do_count);
  1194. if (i) {
  1195. retval = i;
  1196. goto out;
  1197. }
  1198. if (STp->block_size == 0)
  1199. blks = transfer = do_count;
  1200. else {
  1201. blks = (STp->buffer)->buffer_bytes /
  1202.     STp->block_size;
  1203. transfer = blks * STp->block_size;
  1204. }
  1205. cmd[2] = blks >> 16;
  1206. cmd[3] = blks >> 8;
  1207. cmd[4] = blks;
  1208. SRpnt = st_do_scsi(SRpnt, STp, cmd, transfer, SCSI_DATA_WRITE,
  1209.    STp->timeout, MAX_WRITE_RETRIES, TRUE);
  1210. if (!SRpnt) {
  1211. retval = (STp->buffer)->syscall_result;
  1212. goto out;
  1213. }
  1214. if ((STp->buffer)->syscall_result != 0) {
  1215.                         DEBC(printk(ST_DEB_MSG "st%d: Error on write:n", dev));
  1216. if ((SRpnt->sr_sense_buffer[0] & 0x70) == 0x70 &&
  1217.     (SRpnt->sr_sense_buffer[2] & 0x40)) {
  1218. if ((SRpnt->sr_sense_buffer[0] & 0x80) != 0)
  1219. transfer = (SRpnt->sr_sense_buffer[3] << 24) |
  1220.     (SRpnt->sr_sense_buffer[4] << 16) |
  1221.     (SRpnt->sr_sense_buffer[5] << 8) |
  1222.                                                 SRpnt->sr_sense_buffer[6];
  1223. else if (STp->block_size == 0 &&
  1224.  (SRpnt->sr_sense_buffer[2] & 0x0f) ==
  1225.                                          VOLUME_OVERFLOW)
  1226. transfer = do_count;
  1227. else
  1228. transfer = 0;
  1229. if (STp->block_size != 0)
  1230. transfer *= STp->block_size;
  1231. if (transfer <= do_count) {
  1232. filp->f_pos += do_count - transfer;
  1233. count -= do_count - transfer;
  1234. if (STps->drv_block >= 0) {
  1235. if (STp->block_size == 0 &&
  1236.                                                     transfer < do_count)
  1237. STps->drv_block++;
  1238. else if (STp->block_size != 0)
  1239. STps->drv_block +=
  1240.                                                                 (do_count - transfer) /
  1241.                                                                 STp->block_size;
  1242. }
  1243. STps->eof = ST_EOM_OK;
  1244. retval = (-ENOSPC); /* EOM within current request */
  1245.                                         DEBC(printk(ST_DEB_MSG
  1246.                                                        "st%d: EOM with %d bytes unwritten.n",
  1247.        dev, transfer));
  1248. } else {
  1249. STps->eof = ST_EOM_ERROR;
  1250. STps->drv_block = (-1); /* Too cautious? */
  1251. retval = (-EIO); /* EOM for old data */
  1252. DEBC(printk(ST_DEB_MSG
  1253.                                                        "st%d: EOM with lost data.n",
  1254.                                                        dev));
  1255. }
  1256. } else {
  1257. STps->drv_block = (-1); /* Too cautious? */
  1258. retval = (-EIO);
  1259. }
  1260. scsi_release_request(SRpnt);
  1261. SRpnt = NULL;
  1262. (STp->buffer)->buffer_bytes = 0;
  1263. STp->dirty = 0;
  1264. if (count < total)
  1265. retval = total - count;
  1266. goto out;
  1267. }
  1268. filp->f_pos += do_count;
  1269. b_point += do_count;
  1270. count -= do_count;
  1271. if (STps->drv_block >= 0) {
  1272. if (STp->block_size == 0)
  1273. STps->drv_block++;
  1274. else
  1275. STps->drv_block += blks;
  1276. }
  1277. (STp->buffer)->buffer_bytes = 0;
  1278. STp->dirty = 0;
  1279. }
  1280. if (count != 0) {
  1281. STp->dirty = 1;
  1282. i = append_to_buffer(b_point, STp->buffer, count);
  1283. if (i) {
  1284. retval = i;
  1285. goto out;
  1286. }
  1287. filp->f_pos += count;
  1288. count = 0;
  1289. }
  1290. if (doing_write && (STp->buffer)->syscall_result != 0) {
  1291. retval = (STp->buffer)->syscall_result;
  1292. goto out;
  1293. }
  1294. if (STm->do_async_writes &&
  1295.     (((STp->buffer)->buffer_bytes >= STp->write_threshold &&
  1296.       (STp->buffer)->buffer_bytes >= STp->block_size) ||
  1297.      STp->block_size == 0)) {
  1298. /* Schedule an asynchronous write */
  1299. if (STp->block_size == 0)
  1300. (STp->buffer)->writing = (STp->buffer)->buffer_bytes;
  1301. else
  1302. (STp->buffer)->writing = ((STp->buffer)->buffer_bytes /
  1303.       STp->block_size) * STp->block_size;
  1304. STp->dirty = !((STp->buffer)->writing ==
  1305.        (STp->buffer)->buffer_bytes);
  1306. if (STp->block_size == 0)
  1307. blks = (STp->buffer)->writing;
  1308. else
  1309. blks = (STp->buffer)->writing / STp->block_size;
  1310. cmd[2] = blks >> 16;
  1311. cmd[3] = blks >> 8;
  1312. cmd[4] = blks;
  1313. DEB( STp->write_pending = 1; )
  1314. SRpnt = st_do_scsi(SRpnt, STp, cmd, (STp->buffer)->writing,
  1315.    SCSI_DATA_WRITE, STp->timeout,
  1316.    MAX_WRITE_RETRIES, FALSE);
  1317. if (SRpnt == NULL) {
  1318. retval = (STp->buffer)->syscall_result;
  1319. goto out;
  1320. }
  1321. SRpnt = NULL;  /* Prevent releasing this request! */
  1322. }
  1323. STps->at_sm &= (total == 0);
  1324. if (total > 0)
  1325. STps->eof = ST_NOEOF;
  1326. retval = total;
  1327.  out:
  1328. if (SRpnt != NULL)
  1329. scsi_release_request(SRpnt);
  1330. up(&STp->lock);
  1331. return retval;
  1332. }
  1333. /* Read data from the tape. Returns zero in the normal case, one if the
  1334.    eof status has changed, and the negative error code in case of a
  1335.    fatal error. Otherwise updates the buffer and the eof state. */
  1336. static long read_tape(Scsi_Tape *STp, long count, Scsi_Request ** aSRpnt)
  1337. {
  1338. int transfer, blks, bytes;
  1339. unsigned char cmd[MAX_COMMAND_SIZE];
  1340. Scsi_Request *SRpnt;
  1341. ST_mode *STm;
  1342. ST_partstat *STps;
  1343. int dev = TAPE_NR(STp->devt);
  1344. int retval = 0;
  1345. if (count == 0)
  1346. return 0;
  1347. STm = &(STp->modes[STp->current_mode]);
  1348. STps = &(STp->ps[STp->partition]);
  1349. if (STps->eof == ST_FM_HIT)
  1350. return 1;
  1351. memset(cmd, 0, MAX_COMMAND_SIZE);
  1352. cmd[0] = READ_6;
  1353. cmd[1] = (STp->block_size != 0);
  1354. if (STp->block_size == 0)
  1355. blks = bytes = count;
  1356. else {
  1357. if (STm->do_read_ahead) {
  1358. blks = (STp->buffer)->buffer_blocks;
  1359. bytes = blks * STp->block_size;
  1360. } else {
  1361. bytes = count;
  1362. if (bytes > (STp->buffer)->buffer_size)
  1363. bytes = (STp->buffer)->buffer_size;
  1364. blks = bytes / STp->block_size;
  1365. bytes = blks * STp->block_size;
  1366. }
  1367. }
  1368. cmd[2] = blks >> 16;
  1369. cmd[3] = blks >> 8;
  1370. cmd[4] = blks;
  1371. SRpnt = *aSRpnt;
  1372. SRpnt = st_do_scsi(SRpnt, STp, cmd, bytes, SCSI_DATA_READ,
  1373.    STp->timeout, MAX_RETRIES, TRUE);
  1374. *aSRpnt = SRpnt;
  1375. if (!SRpnt)
  1376. return (STp->buffer)->syscall_result;
  1377. (STp->buffer)->read_pointer = 0;
  1378. STps->at_sm = 0;
  1379. /* Something to check */
  1380. if ((STp->buffer)->syscall_result) {
  1381. retval = 1;
  1382. DEBC(printk(ST_DEB_MSG "st%d: Sense: %2x %2x %2x %2x %2x %2x %2x %2xn",
  1383.                             dev,
  1384.                             SRpnt->sr_sense_buffer[0], SRpnt->sr_sense_buffer[1],
  1385.                             SRpnt->sr_sense_buffer[2], SRpnt->sr_sense_buffer[3],
  1386.                             SRpnt->sr_sense_buffer[4], SRpnt->sr_sense_buffer[5],
  1387.                             SRpnt->sr_sense_buffer[6], SRpnt->sr_sense_buffer[7]));
  1388. if ((SRpnt->sr_sense_buffer[0] & 0x70) == 0x70) { /* extended sense */
  1389. if ((SRpnt->sr_sense_buffer[2] & 0x0f) == BLANK_CHECK)
  1390. SRpnt->sr_sense_buffer[2] &= 0xcf; /* No need for EOM in this case */
  1391. if ((SRpnt->sr_sense_buffer[2] & 0xe0) != 0) { /* EOF, EOM, or ILI */
  1392. /* Compute the residual count */
  1393. if ((SRpnt->sr_sense_buffer[0] & 0x80) != 0)
  1394. transfer = (SRpnt->sr_sense_buffer[3] << 24) |
  1395.     (SRpnt->sr_sense_buffer[4] << 16) |
  1396.     (SRpnt->sr_sense_buffer[5] << 8) |
  1397.     SRpnt->sr_sense_buffer[6];
  1398. else
  1399. transfer = 0;
  1400. if (STp->block_size == 0 &&
  1401.     (SRpnt->sr_sense_buffer[2] & 0x0f) == MEDIUM_ERROR)
  1402. transfer = bytes;
  1403. if (SRpnt->sr_sense_buffer[2] & 0x20) { /* ILI */
  1404. if (STp->block_size == 0) {
  1405. if (transfer < 0) {
  1406. if (STps->drv_block >= 0)
  1407. STps->drv_block += 1;
  1408. return (-ENOMEM);
  1409. }
  1410. (STp->buffer)->buffer_bytes = bytes - transfer;
  1411. } else {
  1412. scsi_release_request(SRpnt);
  1413. SRpnt = *aSRpnt = NULL;
  1414. if (transfer == blks) { /* We did not get anything, error */
  1415. printk(KERN_NOTICE "st%d: Incorrect block size.n", dev);
  1416. if (STps->drv_block >= 0)
  1417. STps->drv_block += blks - transfer + 1;
  1418. st_int_ioctl(STp, MTBSR, 1);
  1419. return (-EIO);
  1420. }
  1421. /* We have some data, deliver it */
  1422. (STp->buffer)->buffer_bytes = (blks - transfer) *
  1423.     STp->block_size;
  1424.                                                 DEBC(printk(ST_DEB_MSG
  1425.                                                             "st%d: ILI but enough data received %ld %d.n",
  1426.                                                             dev, count, (STp->buffer)->buffer_bytes));
  1427. if (STps->drv_block >= 0)
  1428. STps->drv_block += 1;
  1429. if (st_int_ioctl(STp, MTBSR, 1))
  1430. return (-EIO);
  1431. }
  1432. } else if (SRpnt->sr_sense_buffer[2] & 0x80) { /* FM overrides EOM */
  1433. if (STps->eof != ST_FM_HIT)
  1434. STps->eof = ST_FM_HIT;
  1435. else
  1436. STps->eof = ST_EOD_2;
  1437. if (STp->block_size == 0)
  1438. (STp->buffer)->buffer_bytes = 0;
  1439. else
  1440. (STp->buffer)->buffer_bytes =
  1441.     bytes - transfer * STp->block_size;
  1442.                                         DEBC(printk(ST_DEB_MSG
  1443.                                                     "st%d: EOF detected (%d bytes read).n",
  1444.                                                     dev, (STp->buffer)->buffer_bytes));
  1445. } else if (SRpnt->sr_sense_buffer[2] & 0x40) {
  1446. if (STps->eof == ST_FM)
  1447. STps->eof = ST_EOD_1;
  1448. else
  1449. STps->eof = ST_EOM_OK;
  1450. if (STp->block_size == 0)
  1451. (STp->buffer)->buffer_bytes = bytes - transfer;
  1452. else
  1453. (STp->buffer)->buffer_bytes =
  1454.     bytes - transfer * STp->block_size;
  1455.                                         DEBC(printk(ST_DEB_MSG "st%d: EOM detected (%d bytes read).n",
  1456.                                                     dev, (STp->buffer)->buffer_bytes));
  1457. }
  1458. }
  1459. /* end of EOF, EOM, ILI test */ 
  1460. else { /* nonzero sense key */
  1461.                                 DEBC(printk(ST_DEB_MSG
  1462.                                             "st%d: Tape error while reading.n", dev));
  1463. STps->drv_block = (-1);
  1464. if (STps->eof == ST_FM &&
  1465.     (SRpnt->sr_sense_buffer[2] & 0x0f) == BLANK_CHECK) {
  1466.                                         DEBC(printk(ST_DEB_MSG
  1467.                                                     "st%d: Zero returned for first BLANK CHECK after EOF.n",
  1468.                                                     dev));
  1469. STps->eof = ST_EOD_2; /* First BLANK_CHECK after FM */
  1470. } else /* Some other extended sense code */
  1471. retval = (-EIO);
  1472. }
  1473. }
  1474. /* End of extended sense test */ 
  1475. else { /* Non-extended sense */
  1476. retval = (STp->buffer)->syscall_result;
  1477. }
  1478. }
  1479. /* End of error handling */ 
  1480. else /* Read successful */
  1481. (STp->buffer)->buffer_bytes = bytes;
  1482. if (STps->drv_block >= 0) {
  1483. if (STp->block_size == 0)
  1484. STps->drv_block++;
  1485. else
  1486. STps->drv_block += (STp->buffer)->buffer_bytes / STp->block_size;
  1487. }
  1488. return retval;
  1489. }
  1490. /* Read command */
  1491. static ssize_t
  1492.  st_read(struct file *filp, char *buf, size_t count, loff_t * ppos)
  1493. {
  1494. struct inode *inode = filp->f_dentry->d_inode;
  1495. ssize_t total;
  1496. ssize_t retval = 0;
  1497. ssize_t i, transfer;
  1498. int special;
  1499. Scsi_Request *SRpnt = NULL;
  1500. Scsi_Tape *STp;
  1501. ST_mode *STm;
  1502. ST_partstat *STps;
  1503. int dev = TAPE_NR(inode->i_rdev);
  1504. read_lock(&st_dev_arr_lock);
  1505. STp = scsi_tapes[dev];
  1506. read_unlock(&st_dev_arr_lock);
  1507. if (down_interruptible(&STp->lock))
  1508. return -ERESTARTSYS;
  1509. /*
  1510.  * If we are in the middle of error recovery, don't let anyone
  1511.  * else try and use this device.  Also, if error recovery fails, it
  1512.  * may try and take the device offline, in which case all further
  1513.  * access to the device is prohibited.
  1514.  */
  1515. if (!scsi_block_when_processing_errors(STp->device)) {
  1516. retval = (-ENXIO);
  1517. goto out;
  1518. }
  1519. if (ppos != &filp->f_pos) {
  1520. /* "A request was outside the capabilities of the device." */
  1521. retval = (-ENXIO);
  1522. goto out;
  1523. }
  1524. if (STp->ready != ST_READY) {
  1525. if (STp->ready == ST_NO_TAPE)
  1526. retval = (-ENOMEDIUM);
  1527. else
  1528. retval = (-EIO);
  1529. goto out;
  1530. }
  1531. STm = &(STp->modes[STp->current_mode]);
  1532. if (!STm->defined) {
  1533. retval = (-ENXIO);
  1534. goto out;
  1535. }
  1536.         DEB(
  1537. if (!STp->in_use) {
  1538. printk(ST_DEB_MSG "st%d: Incorrect device.n", dev);
  1539. retval = (-EIO);
  1540. goto out;
  1541. } ) /* end DEB */
  1542. if (STp->can_partitions &&
  1543.     (retval = update_partition(STp)) < 0)
  1544. goto out;
  1545. if (STp->block_size == 0) {
  1546. if (STp->max_block > 0 &&
  1547.     (count < STp->min_block || count > STp->max_block)) {
  1548. retval = (-EINVAL);
  1549. goto out;
  1550. }
  1551. if (count > (STp->buffer)->buffer_size &&
  1552.     !enlarge_buffer(STp->buffer, count, STp->restr_dma)) {
  1553. retval = (-EOVERFLOW);
  1554. goto out;
  1555. }
  1556. }
  1557. if ((STp->buffer)->buffer_blocks < 1) {
  1558. /* Fixed block mode with too small buffer */
  1559. if (!enlarge_buffer(STp->buffer, STp->block_size, STp->restr_dma)) {
  1560. retval = (-EOVERFLOW);
  1561. goto out;
  1562. }
  1563. (STp->buffer)->buffer_blocks = 1;
  1564. }
  1565. if (!(STm->do_read_ahead) && STp->block_size != 0 &&
  1566.     (count % STp->block_size) != 0) {
  1567. retval = (-EINVAL); /* Read must be integral number of blocks */
  1568. goto out;
  1569. }
  1570. if (STp->do_auto_lock && STp->door_locked == ST_UNLOCKED &&
  1571.     !st_int_ioctl(STp, MTLOCK, 0))
  1572. STp->door_locked = ST_LOCKED_AUTO;
  1573. STps = &(STp->ps[STp->partition]);
  1574. if (STps->rw == ST_WRITING) {
  1575. retval = flush_buffer(STp, 0);
  1576. if (retval)
  1577. goto out;
  1578. STps->rw = ST_READING;
  1579. }
  1580.         DEB(
  1581. if (debugging && STps->eof != ST_NOEOF)
  1582. printk(ST_DEB_MSG "st%d: EOF/EOM flag up (%d). Bytes %dn", dev,
  1583.        STps->eof, (STp->buffer)->buffer_bytes);
  1584.         ) /* end DEB */
  1585. if ((STp->buffer)->buffer_bytes == 0 &&
  1586.     STps->eof >= ST_EOD_1) {
  1587. if (STps->eof < ST_EOD) {
  1588. STps->eof += 1;
  1589. retval = 0;
  1590. goto out;
  1591. }
  1592. retval = (-EIO); /* EOM or Blank Check */
  1593. goto out;
  1594. }
  1595. /* Check the buffer writability before any tape movement. Don't alter
  1596.    buffer data. */
  1597. if (copy_from_user(&i, buf, 1) != 0 ||
  1598.     copy_to_user(buf, &i, 1) != 0 ||
  1599.     copy_from_user(&i, buf + count - 1, 1) != 0 ||
  1600.     copy_to_user(buf + count - 1, &i, 1) != 0) {
  1601. retval = (-EFAULT);
  1602. goto out;
  1603. }
  1604. STps->rw = ST_READING;
  1605. /* Loop until enough data in buffer or a special condition found */
  1606. for (total = 0, special = 0; total < count && !special;) {
  1607. /* Get new data if the buffer is empty */
  1608. if ((STp->buffer)->buffer_bytes == 0) {
  1609. special = read_tape(STp, count - total, &SRpnt);
  1610. if (special < 0) { /* No need to continue read */
  1611. retval = special;
  1612. goto out;
  1613. }
  1614. }
  1615. /* Move the data from driver buffer to user buffer */
  1616. if ((STp->buffer)->buffer_bytes > 0) {
  1617.                         DEB(
  1618. if (debugging && STps->eof != ST_NOEOF)
  1619. printk(ST_DEB_MSG
  1620.                                        "st%d: EOF up (%d). Left %d, needed %d.n", dev,
  1621.        STps->eof, (STp->buffer)->buffer_bytes,
  1622.                                        count - total);
  1623.                         ) /* end DEB */
  1624. transfer = (STp->buffer)->buffer_bytes < count - total ?
  1625.     (STp->buffer)->buffer_bytes : count - total;
  1626. i = from_buffer(STp->buffer, buf, transfer);
  1627. if (i) {
  1628. retval = i;
  1629. goto out;
  1630. }
  1631. filp->f_pos += transfer;
  1632. buf += transfer;
  1633. total += transfer;
  1634. }
  1635. if (STp->block_size == 0)
  1636. break; /* Read only one variable length block */
  1637. } /* for (total = 0, special = 0;
  1638.                                    total < count && !special; ) */
  1639. /* Change the eof state if no data from tape or buffer */
  1640. if (total == 0) {
  1641. if (STps->eof == ST_FM_HIT) {
  1642. STps->eof = ST_FM;
  1643. STps->drv_block = 0;
  1644. if (STps->drv_file >= 0)
  1645. STps->drv_file++;
  1646. } else if (STps->eof == ST_EOD_1) {
  1647. STps->eof = ST_EOD_2;
  1648. STps->drv_block = 0;
  1649. if (STps->drv_file >= 0)
  1650. STps->drv_file++;
  1651. } else if (STps->eof == ST_EOD_2)
  1652. STps->eof = ST_EOD;
  1653. } else if (STps->eof == ST_FM)
  1654. STps->eof = ST_NOEOF;
  1655. retval = total;
  1656.  out:
  1657. if (SRpnt != NULL) {
  1658. scsi_release_request(SRpnt);
  1659. SRpnt = NULL;
  1660. }
  1661. up(&STp->lock);
  1662. return retval;
  1663. }
  1664. /* Set the driver options */
  1665. static void st_log_options(Scsi_Tape * STp, ST_mode * STm, int dev)
  1666. {
  1667. printk(KERN_INFO
  1668.        "st%d: Mode %d options: buffer writes: %d, async writes: %d, read ahead: %dn",
  1669.        dev, STp->current_mode, STm->do_buffer_writes, STm->do_async_writes,
  1670.        STm->do_read_ahead);
  1671. printk(KERN_INFO
  1672.        "st%d:    can bsr: %d, two FMs: %d, fast mteom: %d, auto lock: %d,n",
  1673.        dev, STp->can_bsr, STp->two_fm, STp->fast_mteom, STp->do_auto_lock);
  1674. printk(KERN_INFO
  1675.        "st%d:    defs for wr: %d, no block limits: %d, partitions: %d, s2 log: %dn",
  1676.        dev, STm->defaults_for_writes, STp->omit_blklims, STp->can_partitions,
  1677.        STp->scsi2_logical);
  1678. printk(KERN_INFO
  1679.        "st%d:    sysv: %d nowait: %dn", dev, STm->sysv, STp->immediate);
  1680.         DEB(printk(KERN_INFO
  1681.                    "st%d:    debugging: %dn",
  1682.                    dev, debugging);)
  1683. }
  1684. static int st_set_options(Scsi_Tape *STp, long options)
  1685. {
  1686. int value;
  1687. long code;
  1688. ST_mode *STm;
  1689. int dev = TAPE_NR(STp->devt);
  1690. STm = &(STp->modes[STp->current_mode]);
  1691. if (!STm->defined) {
  1692. memcpy(STm, &(STp->modes[0]), sizeof(ST_mode));
  1693. modes_defined = TRUE;
  1694.                 DEBC(printk(ST_DEB_MSG
  1695.                             "st%d: Initialized mode %d definition from mode 0n",
  1696.                             dev, STp->current_mode));
  1697. }
  1698. code = options & MT_ST_OPTIONS;
  1699. if (code == MT_ST_BOOLEANS) {
  1700. STm->do_buffer_writes = (options & MT_ST_BUFFER_WRITES) != 0;
  1701. STm->do_async_writes = (options & MT_ST_ASYNC_WRITES) != 0;
  1702. STm->defaults_for_writes = (options & MT_ST_DEF_WRITES) != 0;
  1703. STm->do_read_ahead = (options & MT_ST_READ_AHEAD) != 0;
  1704. STp->two_fm = (options & MT_ST_TWO_FM) != 0;
  1705. STp->fast_mteom = (options & MT_ST_FAST_MTEOM) != 0;
  1706. STp->do_auto_lock = (options & MT_ST_AUTO_LOCK) != 0;
  1707. STp->can_bsr = (options & MT_ST_CAN_BSR) != 0;
  1708. STp->omit_blklims = (options & MT_ST_NO_BLKLIMS) != 0;
  1709. if ((STp->device)->scsi_level >= SCSI_2)
  1710. STp->can_partitions = (options & MT_ST_CAN_PARTITIONS) != 0;
  1711. STp->scsi2_logical = (options & MT_ST_SCSI2LOGICAL) != 0;
  1712. STp->immediate = (options & MT_ST_NOWAIT) != 0;
  1713. STm->sysv = (options & MT_ST_SYSV) != 0;
  1714. DEB( debugging = (options & MT_ST_DEBUGGING) != 0; )
  1715. st_log_options(STp, STm, dev);
  1716. } else if (code == MT_ST_SETBOOLEANS || code == MT_ST_CLEARBOOLEANS) {
  1717. value = (code == MT_ST_SETBOOLEANS);
  1718. if ((options & MT_ST_BUFFER_WRITES) != 0)
  1719. STm->do_buffer_writes = value;
  1720. if ((options & MT_ST_ASYNC_WRITES) != 0)
  1721. STm->do_async_writes = value;
  1722. if ((options & MT_ST_DEF_WRITES) != 0)
  1723. STm->defaults_for_writes = value;
  1724. if ((options & MT_ST_READ_AHEAD) != 0)
  1725. STm->do_read_ahead = value;
  1726. if ((options & MT_ST_TWO_FM) != 0)
  1727. STp->two_fm = value;
  1728. if ((options & MT_ST_FAST_MTEOM) != 0)
  1729. STp->fast_mteom = value;
  1730. if ((options & MT_ST_AUTO_LOCK) != 0)
  1731. STp->do_auto_lock = value;
  1732. if ((options & MT_ST_CAN_BSR) != 0)
  1733. STp->can_bsr = value;
  1734. if ((options & MT_ST_NO_BLKLIMS) != 0)
  1735. STp->omit_blklims = value;
  1736. if ((STp->device)->scsi_level >= SCSI_2 &&
  1737.     (options & MT_ST_CAN_PARTITIONS) != 0)
  1738. STp->can_partitions = value;
  1739. if ((options & MT_ST_SCSI2LOGICAL) != 0)
  1740. STp->scsi2_logical = value;
  1741. if ((options & MT_ST_NOWAIT) != 0)
  1742. STp->immediate = value;
  1743. if ((options & MT_ST_SYSV) != 0)
  1744. STm->sysv = value;
  1745.                 DEB(
  1746. if ((options & MT_ST_DEBUGGING) != 0)
  1747. debugging = value; )
  1748. st_log_options(STp, STm, dev);
  1749. } else if (code == MT_ST_WRITE_THRESHOLD) {
  1750. value = (options & ~MT_ST_OPTIONS) * ST_KILOBYTE;
  1751. if (value < 1 || value > st_buffer_size) {
  1752. printk(KERN_WARNING
  1753.                                "st%d: Write threshold %d too small or too large.n",
  1754.        dev, value);
  1755. return (-EIO);
  1756. }
  1757. STp->write_threshold = value;
  1758. printk(KERN_INFO "st%d: Write threshold set to %d bytes.n",
  1759.        dev, value);
  1760. } else if (code == MT_ST_DEF_BLKSIZE) {
  1761. value = (options & ~MT_ST_OPTIONS);
  1762. if (value == ~MT_ST_OPTIONS) {
  1763. STm->default_blksize = (-1);
  1764. printk(KERN_INFO "st%d: Default block size disabled.n", dev);
  1765. } else {
  1766. STm->default_blksize = value;
  1767. printk(KERN_INFO "st%d: Default block size set to %d bytes.n",
  1768.        dev, STm->default_blksize);
  1769. if (STp->ready == ST_READY) {
  1770. STp->blksize_changed = FALSE;
  1771. set_mode_densblk(STp, STm);
  1772. }
  1773. }
  1774. } else if (code == MT_ST_TIMEOUTS) {
  1775. value = (options & ~MT_ST_OPTIONS);
  1776. if ((value & MT_ST_SET_LONG_TIMEOUT) != 0) {
  1777. STp->long_timeout = (value & ~MT_ST_SET_LONG_TIMEOUT) * HZ;
  1778. printk(KERN_INFO "st%d: Long timeout set to %d seconds.n", dev,
  1779.        (value & ~MT_ST_SET_LONG_TIMEOUT));
  1780. } else {
  1781. STp->timeout = value * HZ;
  1782. printk(KERN_INFO "st%d: Normal timeout set to %d seconds.n",
  1783.                                dev, value);
  1784. }
  1785. } else if (code == MT_ST_SET_CLN) {
  1786. value = (options & ~MT_ST_OPTIONS) & 0xff;
  1787. if (value != 0 &&
  1788.     value < EXTENDED_SENSE_START && value >= SCSI_SENSE_BUFFERSIZE)
  1789. return (-EINVAL);
  1790. STp->cln_mode = value;
  1791. STp->cln_sense_mask = (options >> 8) & 0xff;
  1792. STp->cln_sense_value = (options >> 16) & 0xff;
  1793. printk(KERN_INFO
  1794.        "st%d: Cleaning request mode %d, mask %02x, value %02xn",
  1795.        dev, value, STp->cln_sense_mask, STp->cln_sense_value);
  1796. } else if (code == MT_ST_DEF_OPTIONS) {
  1797. code = (options & ~MT_ST_CLEAR_DEFAULT);
  1798. value = (options & MT_ST_CLEAR_DEFAULT);
  1799. if (code == MT_ST_DEF_DENSITY) {
  1800. if (value == MT_ST_CLEAR_DEFAULT) {
  1801. STm->default_density = (-1);
  1802. printk(KERN_INFO "st%d: Density default disabled.n",
  1803.                                        dev);
  1804. } else {
  1805. STm->default_density = value & 0xff;
  1806. printk(KERN_INFO "st%d: Density default set to %xn",
  1807.        dev, STm->default_density);
  1808. if (STp->ready == ST_READY) {
  1809. STp->density_changed = FALSE;
  1810. set_mode_densblk(STp, STm);
  1811. }
  1812. }
  1813. } else if (code == MT_ST_DEF_DRVBUFFER) {
  1814. if (value == MT_ST_CLEAR_DEFAULT) {
  1815. STp->default_drvbuffer = 0xff;
  1816. printk(KERN_INFO
  1817.                                        "st%d: Drive buffer default disabled.n", dev);
  1818. } else {
  1819. STp->default_drvbuffer = value & 7;
  1820. printk(KERN_INFO
  1821.                                        "st%d: Drive buffer default set to %xn",
  1822.        dev, STp->default_drvbuffer);
  1823. if (STp->ready == ST_READY)
  1824. st_int_ioctl(STp, MTSETDRVBUFFER, STp->default_drvbuffer);
  1825. }
  1826. } else if (code == MT_ST_DEF_COMPRESSION) {
  1827. if (value == MT_ST_CLEAR_DEFAULT) {
  1828. STm->default_compression = ST_DONT_TOUCH;
  1829. printk(KERN_INFO
  1830.                                        "st%d: Compression default disabled.n", dev);
  1831. } else {
  1832. if ((value & 0xff00) != 0) {
  1833. STp->c_algo = (value & 0xff00) >> 8;
  1834. printk(KERN_INFO "st%d: Compression algorithm set to 0x%x.n",
  1835.        dev, STp->c_algo);
  1836. }
  1837. if ((value & 0xff) != 0xff) {
  1838. STm->default_compression = (value & 1 ? ST_YES : ST_NO);
  1839. printk(KERN_INFO "st%d: Compression default set to %xn",
  1840.        dev, (value & 1));
  1841. if (STp->ready == ST_READY) {
  1842. STp->compression_changed = FALSE;
  1843. st_compression(STp, (STm->default_compression == ST_YES));
  1844. }
  1845. }
  1846. }
  1847. }
  1848. } else
  1849. return (-EIO);
  1850. return 0;
  1851. }
  1852. #define MODE_HEADER_LENGTH  4
  1853. /* Mode header and page byte offsets */
  1854. #define MH_OFF_DATA_LENGTH     0
  1855. #define MH_OFF_MEDIUM_TYPE     1
  1856. #define MH_OFF_DEV_SPECIFIC    2
  1857. #define MH_OFF_BDESCS_LENGTH   3
  1858. #define MP_OFF_PAGE_NBR        0
  1859. #define MP_OFF_PAGE_LENGTH     1
  1860. /* Mode header and page bit masks */
  1861. #define MH_BIT_WP              0x80
  1862. #define MP_MSK_PAGE_NBR        0x3f
  1863. /* Don't return block descriptors */
  1864. #define MODE_SENSE_OMIT_BDESCS 0x08
  1865. #define MODE_SELECT_PAGE_FORMAT 0x10
  1866. /* Read a mode page into the tape buffer. The block descriptors are included
  1867.    if incl_block_descs is true. The page control is ored to the page number
  1868.    parameter, if necessary. */
  1869. static int read_mode_page(Scsi_Tape *STp, int page, int omit_block_descs)
  1870. {
  1871. unsigned char cmd[MAX_COMMAND_SIZE];
  1872. Scsi_Request *SRpnt = NULL;
  1873. memset(cmd, 0, MAX_COMMAND_SIZE);
  1874. cmd[0] = MODE_SENSE;
  1875. if (omit_block_descs)
  1876. cmd[1] = MODE_SENSE_OMIT_BDESCS;
  1877. cmd[2] = page;
  1878. cmd[4] = 255;
  1879. SRpnt = st_do_scsi(SRpnt, STp, cmd, cmd[4], SCSI_DATA_READ,
  1880.    STp->timeout, 0, TRUE);
  1881. if (SRpnt == NULL)
  1882. return (STp->buffer)->syscall_result;
  1883. scsi_release_request(SRpnt);
  1884. return (STp->buffer)->syscall_result;
  1885. }
  1886. /* Send the mode page in the tape buffer to the drive. Assumes that the mode data
  1887.    in the buffer is correctly formatted. */
  1888. static int write_mode_page(Scsi_Tape *STp, int page)
  1889. {
  1890. int pgo;
  1891. unsigned char cmd[MAX_COMMAND_SIZE];
  1892. Scsi_Request *SRpnt = NULL;
  1893. memset(cmd, 0, MAX_COMMAND_SIZE);
  1894. cmd[0] = MODE_SELECT;
  1895. cmd[1] = MODE_SELECT_PAGE_FORMAT;
  1896. pgo = MODE_HEADER_LENGTH + (STp->buffer)->b_data[MH_OFF_BDESCS_LENGTH];
  1897. cmd[4] = pgo + (STp->buffer)->b_data[pgo + MP_OFF_PAGE_LENGTH] + 2;
  1898. /* Clear reserved fields */
  1899. (STp->buffer)->b_data[MH_OFF_DATA_LENGTH] = 0;
  1900. (STp->buffer)->b_data[MH_OFF_MEDIUM_TYPE] = 0;
  1901. (STp->buffer)->b_data[MH_OFF_DEV_SPECIFIC] &= ~MH_BIT_WP;
  1902. (STp->buffer)->b_data[pgo + MP_OFF_PAGE_NBR] &= MP_MSK_PAGE_NBR;
  1903. SRpnt = st_do_scsi(SRpnt, STp, cmd, cmd[4], SCSI_DATA_WRITE,
  1904.    STp->timeout, 0, TRUE);
  1905. if (SRpnt == NULL)
  1906. return (STp->buffer)->syscall_result;
  1907. scsi_release_request(SRpnt);
  1908. return (STp->buffer)->syscall_result;
  1909. }
  1910. #define COMPRESSION_PAGE        0x0f
  1911. #define COMPRESSION_PAGE_LENGTH 16
  1912. #define CP_OFF_DCE_DCC          2
  1913. #define CP_OFF_C_ALGO           7
  1914. #define DCE_MASK  0x80
  1915. #define DCC_MASK  0x40
  1916. #define RED_MASK  0x60
  1917. /* Control the compression with mode page 15. Algorithm not changed if zero.
  1918.    The block descriptors are read and written because Sony SDT-7000 does not
  1919.    work without this (suggestion from Michael Schaefer <Michael.Schaefer@dlr.de>).
  1920.    Including block descriptors should not cause any harm to other drives. */
  1921. static int st_compression(Scsi_Tape * STp, int state)
  1922. {
  1923. int retval;
  1924. int mpoffs;  /* Offset to mode page start */
  1925. unsigned char *b_data = (STp->buffer)->b_data;
  1926. DEB( int dev = TAPE_NR(STp->devt); )
  1927. if (STp->ready != ST_READY)
  1928. return (-EIO);
  1929. /* Read the current page contents */
  1930. retval = read_mode_page(STp, COMPRESSION_PAGE, FALSE);
  1931. if (retval) {
  1932.                 DEBC(printk(ST_DEB_MSG "st%d: Compression mode page not supported.n",
  1933.                             dev));
  1934. return (-EIO);
  1935. }
  1936. mpoffs = MODE_HEADER_LENGTH + b_data[MH_OFF_BDESCS_LENGTH];
  1937.         DEBC(printk(ST_DEB_MSG "st%d: Compression state is %d.n", dev,
  1938.                     (b_data[mpoffs + CP_OFF_DCE_DCC] & DCE_MASK ? 1 : 0)));
  1939. /* Check if compression can be changed */
  1940. if ((b_data[mpoffs + CP_OFF_DCE_DCC] & DCC_MASK) == 0) {
  1941.                 DEBC(printk(ST_DEB_MSG "st%d: Compression not supported.n", dev));
  1942. return (-EIO);
  1943. }
  1944. /* Do the change */
  1945. if (state) {
  1946. b_data[mpoffs + CP_OFF_DCE_DCC] |= DCE_MASK;
  1947. if (STp->c_algo != 0)
  1948. b_data[mpoffs + CP_OFF_C_ALGO] = STp->c_algo;
  1949. }
  1950. else {
  1951. b_data[mpoffs + CP_OFF_DCE_DCC] &= ~DCE_MASK;
  1952. if (STp->c_algo != 0)
  1953. b_data[mpoffs + CP_OFF_C_ALGO] = 0; /* no compression */
  1954. }
  1955. retval = write_mode_page(STp, COMPRESSION_PAGE);
  1956. if (retval) {
  1957.                 DEBC(printk(ST_DEB_MSG "st%d: Compression change failed.n", dev));
  1958. return (-EIO);
  1959. }
  1960.         DEBC(printk(ST_DEB_MSG "st%d: Compression state changed to %d.n",
  1961.        dev, state));
  1962. STp->compression_changed = TRUE;
  1963. return 0;
  1964. }
  1965. /* Process the load and unload commands (does unload if the load code is zero) */
  1966. static int do_load_unload(Scsi_Tape *STp, struct file *filp, int load_code)
  1967. {
  1968. int retval = (-EIO), timeout;
  1969. DEB(int dev = TAPE_NR(STp->devt);)
  1970. unsigned char cmd[MAX_COMMAND_SIZE];
  1971. ST_partstat *STps;
  1972. Scsi_Request *SRpnt;
  1973. if (STp->ready != ST_READY && !load_code) {
  1974. if (STp->ready == ST_NO_TAPE)
  1975. return (-ENOMEDIUM);
  1976. else
  1977. return (-EIO);
  1978. }
  1979. memset(cmd, 0, MAX_COMMAND_SIZE);
  1980. cmd[0] = START_STOP;
  1981. if (load_code)
  1982. cmd[4] |= 1;
  1983. /*
  1984.  * If arg >= 1 && arg <= 6 Enhanced load/unload in HP C1553A
  1985.  */
  1986. if (load_code >= 1 + MT_ST_HPLOADER_OFFSET
  1987.     && load_code <= 6 + MT_ST_HPLOADER_OFFSET) {
  1988. DEBC(printk(ST_DEB_MSG "st%d: Enhanced %sload slot %2d.n",
  1989.     dev, (cmd[4]) ? "" : "un",
  1990.     load_code - MT_ST_HPLOADER_OFFSET));
  1991. cmd[3] = load_code - MT_ST_HPLOADER_OFFSET; /* MediaID field of C1553A */
  1992. }
  1993. if (STp->immediate) {
  1994. cmd[1] = 1; /* Don't wait for completion */
  1995. timeout = STp->timeout;
  1996. }
  1997. else
  1998. timeout = STp->long_timeout;
  1999. DEBC(
  2000. if (!load_code)
  2001. printk(ST_DEB_MSG "st%d: Unloading tape.n", dev);
  2002. else
  2003. printk(ST_DEB_MSG "st%d: Loading tape.n", dev);
  2004. );
  2005. SRpnt = st_do_scsi(NULL, STp, cmd, 0, SCSI_DATA_NONE,
  2006.    timeout, MAX_RETRIES, TRUE);
  2007. if (!SRpnt)
  2008. return (STp->buffer)->syscall_result;
  2009. retval = (STp->buffer)->syscall_result;
  2010. scsi_release_request(SRpnt);
  2011. if (!retval) { /* SCSI command successful */
  2012. if (!load_code) {
  2013. STp->rew_at_close = 0;
  2014. STp->ready = ST_NO_TAPE;
  2015. }
  2016. else {
  2017. STp->rew_at_close = STp->autorew_dev;
  2018. retval = check_tape(STp, filp);
  2019. if (retval > 0)
  2020. retval = 0;
  2021. }
  2022. }
  2023. else {
  2024. STps = &(STp->ps[STp->partition]);
  2025. STps->drv_file = STps->drv_block = (-1);
  2026. }
  2027. return retval;
  2028. }
  2029. /* Internal ioctl function */
  2030. static int st_int_ioctl(Scsi_Tape *STp, unsigned int cmd_in, unsigned long arg)
  2031. {
  2032. int timeout;
  2033. long ltmp;
  2034. int ioctl_result;
  2035. int chg_eof = TRUE;
  2036. unsigned char cmd[MAX_COMMAND_SIZE];
  2037. Scsi_Request *SRpnt;
  2038. ST_partstat *STps;
  2039. int fileno, blkno, at_sm, undone;
  2040. int datalen = 0, direction = SCSI_DATA_NONE;
  2041. int dev = TAPE_NR(STp->devt);
  2042. if (STp->ready != ST_READY) {
  2043. if (STp->ready == ST_NO_TAPE)
  2044. return (-ENOMEDIUM);
  2045. else
  2046. return (-EIO);
  2047. }
  2048. timeout = STp->long_timeout;
  2049. STps = &(STp->ps[STp->partition]);
  2050. fileno = STps->drv_file;
  2051. blkno = STps->drv_block;
  2052. at_sm = STps->at_sm;
  2053. memset(cmd, 0, MAX_COMMAND_SIZE);
  2054. switch (cmd_in) {
  2055. case MTFSFM:
  2056. chg_eof = FALSE; /* Changed from the FSF after this */
  2057. case MTFSF:
  2058. cmd[0] = SPACE;
  2059. cmd[1] = 0x01; /* Space FileMarks */
  2060. cmd[2] = (arg >> 16);
  2061. cmd[3] = (arg >> 8);
  2062. cmd[4] = arg;
  2063.                 DEBC(printk(ST_DEB_MSG "st%d: Spacing tape forward over %d filemarks.n",
  2064.     dev, cmd[2] * 65536 + cmd[3] * 256 + cmd[4]));
  2065. if (fileno >= 0)
  2066. fileno += arg;
  2067. blkno = 0;
  2068. at_sm &= (arg == 0);
  2069. break;
  2070. case MTBSFM:
  2071. chg_eof = FALSE; /* Changed from the FSF after this */
  2072. case MTBSF:
  2073. cmd[0] = SPACE;
  2074. cmd[1] = 0x01; /* Space FileMarks */
  2075. ltmp = (-arg);
  2076. cmd[2] = (ltmp >> 16);
  2077. cmd[3] = (ltmp >> 8);
  2078. cmd[4] = ltmp;
  2079.                 DEBC(
  2080.                      if (cmd[2] & 0x80)
  2081.                       ltmp = 0xff000000;
  2082.                      ltmp = ltmp | (cmd[2] << 16) | (cmd[3] << 8) | cmd[4];
  2083.                      printk(ST_DEB_MSG
  2084.                             "st%d: Spacing tape backward over %ld filemarks.n",
  2085.                             dev, (-ltmp));
  2086. )
  2087. if (fileno >= 0)
  2088. fileno -= arg;
  2089. blkno = (-1); /* We can't know the block number */
  2090. at_sm &= (arg == 0);
  2091. break;
  2092. case MTFSR:
  2093. cmd[0] = SPACE;
  2094. cmd[1] = 0x00; /* Space Blocks */
  2095. cmd[2] = (arg >> 16);
  2096. cmd[3] = (arg >> 8);
  2097. cmd[4] = arg;
  2098.                 DEBC(printk(ST_DEB_MSG "st%d: Spacing tape forward %d blocks.n", dev,
  2099.        cmd[2] * 65536 + cmd[3] * 256 + cmd[4]));
  2100. if (blkno >= 0)
  2101. blkno += arg;
  2102. at_sm &= (arg == 0);
  2103. break;
  2104. case MTBSR:
  2105. cmd[0] = SPACE;
  2106. cmd[1] = 0x00; /* Space Blocks */
  2107. ltmp = (-arg);
  2108. cmd[2] = (ltmp >> 16);
  2109. cmd[3] = (ltmp >> 8);
  2110. cmd[4] = ltmp;
  2111.                 DEBC(
  2112.                      if (cmd[2] & 0x80)
  2113.                           ltmp = 0xff000000;
  2114.                      ltmp = ltmp | (cmd[2] << 16) | (cmd[3] << 8) | cmd[4];
  2115.                      printk(ST_DEB_MSG
  2116.                             "st%d: Spacing tape backward %ld blocks.n", dev, (-ltmp));
  2117. )
  2118. if (blkno >= 0)
  2119. blkno -= arg;
  2120. at_sm &= (arg == 0);
  2121. break;
  2122. case MTFSS:
  2123. cmd[0] = SPACE;
  2124. cmd[1] = 0x04; /* Space Setmarks */
  2125. cmd[2] = (arg >> 16);
  2126. cmd[3] = (arg >> 8);
  2127. cmd[4] = arg;
  2128.                 DEBC(printk(ST_DEB_MSG "st%d: Spacing tape forward %d setmarks.n", dev,
  2129.                             cmd[2] * 65536 + cmd[3] * 256 + cmd[4]));
  2130. if (arg != 0) {
  2131. blkno = fileno = (-1);
  2132. at_sm = 1;
  2133. }
  2134. break;
  2135. case MTBSS:
  2136. cmd[0] = SPACE;
  2137. cmd[1] = 0x04; /* Space Setmarks */
  2138. ltmp = (-arg);
  2139. cmd[2] = (ltmp >> 16);
  2140. cmd[3] = (ltmp >> 8);
  2141. cmd[4] = ltmp;
  2142.                 DEBC(
  2143.                      if (cmd[2] & 0x80)
  2144. ltmp = 0xff000000;
  2145.                      ltmp = ltmp | (cmd[2] << 16) | (cmd[3] << 8) | cmd[4];
  2146.                      printk(ST_DEB_MSG "st%d: Spacing tape backward %ld setmarks.n",
  2147.                             dev, (-ltmp));
  2148. )
  2149. if (arg != 0) {
  2150. blkno = fileno = (-1);
  2151. at_sm = 1;
  2152. }
  2153. break;
  2154. case MTWEOF:
  2155. case MTWSM:
  2156. if (STp->write_prot)
  2157. return (-EACCES);
  2158. cmd[0] = WRITE_FILEMARKS;
  2159. if (cmd_in == MTWSM)
  2160. cmd[1] = 2;
  2161. cmd[2] = (arg >> 16);
  2162. cmd[3] = (arg >> 8);
  2163. cmd[4] = arg;
  2164. timeout = STp->timeout;
  2165.                 DEBC(
  2166.                      if (cmd_in == MTWEOF)
  2167.                                printk(ST_DEB_MSG "st%d: Writing %d filemarks.n", dev,
  2168.  cmd[2] * 65536 + cmd[3] * 256 + cmd[4]);
  2169.                      else
  2170. printk(ST_DEB_MSG "st%d: Writing %d setmarks.n", dev,
  2171.  cmd[2] * 65536 + cmd[3] * 256 + cmd[4]);
  2172. )
  2173. if (fileno >= 0)
  2174. fileno += arg;
  2175. blkno = 0;
  2176. at_sm = (cmd_in == MTWSM);
  2177. break;
  2178. case MTREW:
  2179. cmd[0] = REZERO_UNIT;
  2180. if (STp->immediate) {
  2181. cmd[1] = 1; /* Don't wait for completion */
  2182. timeout = STp->timeout;
  2183. }
  2184.                 DEBC(printk(ST_DEB_MSG "st%d: Rewinding tape.n", dev));
  2185. fileno = blkno = at_sm = 0;
  2186. break;
  2187. case MTNOP:
  2188.                 DEBC(printk(ST_DEB_MSG "st%d: No op on tape.n", dev));
  2189. return 0; /* Should do something ? */
  2190. break;
  2191. case MTRETEN:
  2192. cmd[0] = START_STOP;
  2193. if (STp->immediate) {
  2194. cmd[1] = 1; /* Don't wait for completion */
  2195. timeout = STp->timeout;
  2196. }
  2197. cmd[4] = 3;
  2198.                 DEBC(printk(ST_DEB_MSG "st%d: Retensioning tape.n", dev));
  2199. fileno = blkno = at_sm = 0;
  2200. break;
  2201. case MTEOM:
  2202. if (!STp->fast_mteom) {
  2203. /* space to the end of tape */
  2204. ioctl_result = st_int_ioctl(STp, MTFSF, 0x7fffff);
  2205. fileno = STps->drv_file;
  2206. if (STps->eof >= ST_EOD_1)
  2207. return 0;
  2208. /* The next lines would hide the number of spaced FileMarks
  2209.    That's why I inserted the previous lines. I had no luck
  2210.    with detecting EOM with FSF, so we go now to EOM.
  2211.    Joerg Weule */
  2212. } else
  2213. fileno = (-1);
  2214. cmd[0] = SPACE;
  2215. cmd[1] = 3;
  2216.                 DEBC(printk(ST_DEB_MSG "st%d: Spacing to end of recorded medium.n",
  2217.                             dev));
  2218. blkno = 0;
  2219. at_sm = 0;
  2220. break;
  2221. case MTERASE:
  2222. if (STp->write_prot)
  2223. return (-EACCES);
  2224. cmd[0] = ERASE;
  2225. cmd[1] = 1; /* To the end of tape */
  2226. if (STp->immediate) {
  2227. cmd[1] |= 2; /* Don't wait for completion */
  2228. timeout = STp->timeout;
  2229. }
  2230. else
  2231. timeout = STp->long_timeout * 8;
  2232.                 DEBC(printk(ST_DEB_MSG "st%d: Erasing tape.n", dev));
  2233. fileno = blkno = at_sm = 0;
  2234. break;
  2235. case MTLOCK:
  2236. chg_eof = FALSE;
  2237. cmd[0] = ALLOW_MEDIUM_REMOVAL;
  2238. cmd[4] = SCSI_REMOVAL_PREVENT;
  2239.                 DEBC(printk(ST_DEB_MSG "st%d: Locking drive door.n", dev));
  2240. break;
  2241. case MTUNLOCK:
  2242. chg_eof = FALSE;
  2243. cmd[0] = ALLOW_MEDIUM_REMOVAL;
  2244. cmd[4] = SCSI_REMOVAL_ALLOW;
  2245.                 DEBC(printk(ST_DEB_MSG "st%d: Unlocking drive door.n", dev));
  2246. break;
  2247. case MTSETBLK: /* Set block length */
  2248. case MTSETDENSITY: /* Set tape density */
  2249. case MTSETDRVBUFFER: /* Set drive buffering */
  2250. case SET_DENS_AND_BLK: /* Set density and block size */
  2251. chg_eof = FALSE;
  2252. if (STp->dirty || (STp->buffer)->buffer_bytes != 0)
  2253. return (-EIO); /* Not allowed if data in buffer */
  2254. if ((cmd_in == MTSETBLK || cmd_in == SET_DENS_AND_BLK) &&
  2255.     (arg & MT_ST_BLKSIZE_MASK) != 0 &&
  2256.     STp->max_block > 0 &&
  2257.     ((arg & MT_ST_BLKSIZE_MASK) < STp->min_block ||
  2258.      (arg & MT_ST_BLKSIZE_MASK) > STp->max_block)) {
  2259. printk(KERN_WARNING "st%d: Illegal block size.n", dev);
  2260. return (-EINVAL);
  2261. }
  2262. cmd[0] = MODE_SELECT;
  2263. if ((STp->use_pf & USE_PF))
  2264. cmd[1] = MODE_SELECT_PAGE_FORMAT;
  2265. cmd[4] = datalen = 12;
  2266. direction = SCSI_DATA_WRITE;
  2267. memset((STp->buffer)->b_data, 0, 12);
  2268. if (cmd_in == MTSETDRVBUFFER)
  2269. (STp->buffer)->b_data[2] = (arg & 7) << 4;
  2270. else
  2271. (STp->buffer)->b_data[2] =
  2272.     STp->drv_buffer << 4;
  2273. (STp->buffer)->b_data[3] = 8; /* block descriptor length */
  2274. if (cmd_in == MTSETDENSITY) {
  2275. (STp->buffer)->b_data[4] = arg;
  2276. STp->density_changed = TRUE; /* At least we tried ;-) */
  2277. } else if (cmd_in == SET_DENS_AND_BLK)
  2278. (STp->buffer)->b_data[4] = arg >> 24;
  2279. else
  2280. (STp->buffer)->b_data[4] = STp->density;
  2281. if (cmd_in == MTSETBLK || cmd_in == SET_DENS_AND_BLK) {
  2282. ltmp = arg & MT_ST_BLKSIZE_MASK;
  2283. if (cmd_in == MTSETBLK)
  2284. STp->blksize_changed = TRUE; /* At least we tried ;-) */
  2285. } else
  2286. ltmp = STp->block_size;
  2287. (STp->buffer)->b_data[9] = (ltmp >> 16);
  2288. (STp->buffer)->b_data[10] = (ltmp >> 8);
  2289. (STp->buffer)->b_data[11] = ltmp;
  2290. timeout = STp->timeout;
  2291.                 DEBC(
  2292. if (cmd_in == MTSETBLK || cmd_in == SET_DENS_AND_BLK)
  2293. printk(ST_DEB_MSG
  2294.                                        "st%d: Setting block size to %d bytes.n", dev,
  2295.        (STp->buffer)->b_data[9] * 65536 +
  2296.        (STp->buffer)->b_data[10] * 256 +
  2297.        (STp->buffer)->b_data[11]);
  2298. if (cmd_in == MTSETDENSITY || cmd_in == SET_DENS_AND_BLK)
  2299. printk(ST_DEB_MSG
  2300.                                        "st%d: Setting density code to %x.n", dev,
  2301.        (STp->buffer)->b_data[4]);
  2302. if (cmd_in == MTSETDRVBUFFER)
  2303. printk(ST_DEB_MSG
  2304.                                        "st%d: Setting drive buffer code to %d.n", dev,
  2305.     ((STp->buffer)->b_data[2] >> 4) & 7);
  2306. )
  2307. break;
  2308. default:
  2309. return (-ENOSYS);
  2310. }
  2311. SRpnt = st_do_scsi(NULL, STp, cmd, datalen, direction,
  2312.    timeout, MAX_RETRIES, TRUE);
  2313. if (!SRpnt)
  2314. return (STp->buffer)->syscall_result;
  2315. ioctl_result = (STp->buffer)->syscall_result;
  2316. if (!ioctl_result) { /* SCSI command successful */
  2317. scsi_release_request(SRpnt);
  2318. SRpnt = NULL;
  2319. STps->drv_block = blkno;
  2320. STps->drv_file = fileno;
  2321. STps->at_sm = at_sm;
  2322. if (cmd_in == MTLOCK)
  2323. STp->door_locked = ST_LOCKED_EXPLICIT;
  2324. else if (cmd_in == MTUNLOCK)
  2325. STp->door_locked = ST_UNLOCKED;
  2326. if (cmd_in == MTBSFM)
  2327. ioctl_result = st_int_ioctl(STp, MTFSF, 1);
  2328. else if (cmd_in == MTFSFM)
  2329. ioctl_result = st_int_ioctl(STp, MTBSF, 1);
  2330. if (cmd_in == MTSETBLK || cmd_in == SET_DENS_AND_BLK) {
  2331. STp->block_size = arg & MT_ST_BLKSIZE_MASK;
  2332. if (STp->block_size != 0)
  2333. (STp->buffer)->buffer_blocks =
  2334.     (STp->buffer)->buffer_size / STp->block_size;
  2335. (STp->buffer)->buffer_bytes = (STp->buffer)->read_pointer = 0;
  2336. if (cmd_in == SET_DENS_AND_BLK)
  2337. STp->density = arg >> MT_ST_DENSITY_SHIFT;
  2338. } else if (cmd_in == MTSETDRVBUFFER)
  2339. STp->drv_buffer = (arg & 7);
  2340. else if (cmd_in == MTSETDENSITY)
  2341. STp->density = arg;
  2342. if (cmd_in == MTEOM)
  2343. STps->eof = ST_EOD;
  2344. else if (cmd_in == MTFSF)
  2345. STps->eof = ST_FM;
  2346. else if (chg_eof)
  2347. STps->eof = ST_NOEOF;
  2348. } else { /* SCSI command was not completely successful. Don't return
  2349.                     from this block without releasing the SCSI command block! */
  2350. if (SRpnt->sr_sense_buffer[2] & 0x40) {
  2351. if (cmd_in != MTBSF && cmd_in != MTBSFM &&
  2352.     cmd_in != MTBSR && cmd_in != MTBSS)
  2353. STps->eof = ST_EOM_OK;
  2354. STps->drv_block = 0;
  2355. }
  2356. undone = ((SRpnt->sr_sense_buffer[3] << 24) +
  2357.   (SRpnt->sr_sense_buffer[4] << 16) +
  2358.   (SRpnt->sr_sense_buffer[5] << 8) +
  2359.   SRpnt->sr_sense_buffer[6]);
  2360. if (cmd_in == MTWEOF &&
  2361.     (SRpnt->sr_sense_buffer[0] & 0x70) == 0x70 &&
  2362.     (SRpnt->sr_sense_buffer[2] & 0x4f) == 0x40 &&
  2363.  ((SRpnt->sr_sense_buffer[0] & 0x80) == 0 || undone == 0)) {
  2364. ioctl_result = 0; /* EOF written succesfully at EOM */
  2365. if (fileno >= 0)
  2366. fileno++;
  2367. STps->drv_file = fileno;
  2368. STps->eof = ST_NOEOF;
  2369. } else if ((cmd_in == MTFSF) || (cmd_in == MTFSFM)) {
  2370. if (fileno >= 0)
  2371. STps->drv_file = fileno - undone;
  2372. else
  2373. STps->drv_file = fileno;
  2374. STps->drv_block = 0;
  2375. STps->eof = ST_NOEOF;
  2376. } else if ((cmd_in == MTBSF) || (cmd_in == MTBSFM)) {
  2377. if (arg > 0 && undone < 0)  /* Some drives get this wrong */
  2378. undone = (-undone);
  2379. if (STps->drv_file >= 0)
  2380. STps->drv_file = fileno + undone;
  2381. STps->drv_block = 0;
  2382. STps->eof = ST_NOEOF;
  2383. } else if (cmd_in == MTFSR) {
  2384. if (SRpnt->sr_sense_buffer[2] & 0x80) { /* Hit filemark */
  2385. if (STps->drv_file >= 0)
  2386. STps->drv_file++;
  2387. STps->drv_block = 0;
  2388. STps->eof = ST_FM;
  2389. } else {
  2390. if (blkno >= undone)
  2391. STps->drv_block = blkno - undone;
  2392. else
  2393. STps->drv_block = (-1);
  2394. STps->eof = ST_NOEOF;
  2395. }
  2396. } else if (cmd_in == MTBSR) {
  2397. if (SRpnt->sr_sense_buffer[2] & 0x80) { /* Hit filemark */
  2398. STps->drv_file--;
  2399. STps->drv_block = (-1);
  2400. } else {
  2401. if (arg > 0 && undone < 0)  /* Some drives get this wrong */
  2402. undone = (-undone);
  2403. if (STps->drv_block >= 0)
  2404. STps->drv_block = blkno + undone;
  2405. }
  2406. STps->eof = ST_NOEOF;
  2407. } else if (cmd_in == MTEOM) {
  2408. STps->drv_file = (-1);
  2409. STps->drv_block = (-1);
  2410. STps->eof = ST_EOD;
  2411. } else if (cmd_in == MTSETBLK ||
  2412.    cmd_in == MTSETDENSITY ||
  2413.    cmd_in == MTSETDRVBUFFER ||
  2414.    cmd_in == SET_DENS_AND_BLK) {
  2415. if ((SRpnt->sr_sense_buffer[2] & 0x0f) == ILLEGAL_REQUEST &&
  2416.     !(STp->use_pf & PF_TESTED)) {
  2417. /* Try the other possible state of Page Format if not
  2418.    already tried */
  2419. STp->use_pf = !STp->use_pf | PF_TESTED;
  2420. scsi_release_request(SRpnt);
  2421. SRpnt = NULL;
  2422. return st_int_ioctl(STp, cmd_in, arg);
  2423. }
  2424. } else if (chg_eof)
  2425. STps->eof = ST_NOEOF;
  2426. if ((SRpnt->sr_sense_buffer[2] & 0x0f) == BLANK_CHECK)
  2427. STps->eof = ST_EOD;
  2428. if (cmd_in == MTLOCK)
  2429. STp->door_locked = ST_LOCK_FAILS;
  2430. scsi_release_request(SRpnt);
  2431. SRpnt = NULL;
  2432. }
  2433. return ioctl_result;
  2434. }
  2435. /* Get the tape position. If bt == 2, arg points into a kernel space mt_loc
  2436.    structure. */
  2437. static int get_location(Scsi_Tape *STp, unsigned int *block, int *partition,
  2438. int logical)
  2439. {
  2440. int result;
  2441. unsigned char scmd[MAX_COMMAND_SIZE];
  2442. Scsi_Request *SRpnt;
  2443. DEB( int dev = TAPE_NR(STp->devt); )
  2444. if (STp->ready != ST_READY)
  2445. return (-EIO);
  2446. memset(scmd, 0, MAX_COMMAND_SIZE);
  2447. if ((STp->device)->scsi_level < SCSI_2) {
  2448. scmd[0] = QFA_REQUEST_BLOCK;
  2449. scmd[4] = 3;
  2450. } else {
  2451. scmd[0] = READ_POSITION;
  2452. if (!logical && !STp->scsi2_logical)
  2453. scmd[1] = 1;
  2454. }
  2455. SRpnt = st_do_scsi(NULL, STp, scmd, 20, SCSI_DATA_READ, STp->timeout,
  2456.    MAX_READY_RETRIES, TRUE);
  2457. if (!SRpnt)
  2458. return (STp->buffer)->syscall_result;
  2459. if ((STp->buffer)->syscall_result != 0 ||
  2460.     (STp->device->scsi_level >= SCSI_2 &&
  2461.      ((STp->buffer)->b_data[0] & 4) != 0)) {
  2462. *block = *partition = 0;
  2463.                 DEBC(printk(ST_DEB_MSG "st%d: Can't read tape position.n", dev));
  2464. result = (-EIO);
  2465. } else {
  2466. result = 0;
  2467. if ((STp->device)->scsi_level < SCSI_2) {
  2468. *block = ((STp->buffer)->b_data[0] << 16)
  2469.     + ((STp->buffer)->b_data[1] << 8)
  2470.     + (STp->buffer)->b_data[2];
  2471. *partition = 0;
  2472. } else {
  2473. *block = ((STp->buffer)->b_data[4] << 24)
  2474.     + ((STp->buffer)->b_data[5] << 16)
  2475.     + ((STp->buffer)->b_data[6] << 8)
  2476.     + (STp->buffer)->b_data[7];
  2477. *partition = (STp->buffer)->b_data[1];
  2478. if (((STp->buffer)->b_data[0] & 0x80) &&
  2479.     (STp->buffer)->b_data[1] == 0) /* BOP of partition 0 */
  2480. STp->ps[0].drv_block = STp->ps[0].drv_file = 0;
  2481. }
  2482.                 DEBC(printk(ST_DEB_MSG "st%d: Got tape pos. blk %d part %d.n", dev,
  2483.                             *block, *partition));
  2484. }
  2485. scsi_release_request(SRpnt);
  2486. SRpnt = NULL;
  2487. return result;
  2488. }
  2489. /* Set the tape block and partition. Negative partition means that only the
  2490.    block should be set in vendor specific way. */
  2491. static int set_location(Scsi_Tape *STp, unsigned int block, int partition,
  2492. int logical)
  2493. {
  2494. ST_partstat *STps;
  2495. int result, p;
  2496. unsigned int blk;
  2497. int timeout;
  2498. unsigned char scmd[MAX_COMMAND_SIZE];
  2499. Scsi_Request *SRpnt;
  2500. DEB( int dev = TAPE_NR(STp->devt); )
  2501. if (STp->ready != ST_READY)
  2502. return (-EIO);
  2503. timeout = STp->long_timeout;
  2504. STps = &(STp->ps[STp->partition]);
  2505.         DEBC(printk(ST_DEB_MSG "st%d: Setting block to %d and partition to %d.n",
  2506.                     dev, block, partition));
  2507. DEB(if (partition < 0)
  2508. return (-EIO); )
  2509. /* Update the location at the partition we are leaving */
  2510. if ((!STp->can_partitions && partition != 0) ||
  2511.     partition >= ST_NBR_PARTITIONS)
  2512. return (-EINVAL);
  2513. if (partition != STp->partition) {
  2514. if (get_location(STp, &blk, &p, 1))
  2515. STps->last_block_valid = FALSE;
  2516. else {
  2517. STps->last_block_valid = TRUE;
  2518. STps->last_block_visited = blk;
  2519.                         DEBC(printk(ST_DEB_MSG
  2520.                                     "st%d: Visited block %d for partition %d saved.n",
  2521.                                     dev, blk, STp->partition));
  2522. }
  2523. }
  2524. memset(scmd, 0, MAX_COMMAND_SIZE);
  2525. if ((STp->device)->scsi_level < SCSI_2) {
  2526. scmd[0] = QFA_SEEK_BLOCK;
  2527. scmd[2] = (block >> 16);
  2528. scmd[3] = (block >> 8);
  2529. scmd[4] = block;
  2530. scmd[5] = 0;
  2531. } else {
  2532. scmd[0] = SEEK_10;
  2533. scmd[3] = (block >> 24);
  2534. scmd[4] = (block >> 16);
  2535. scmd[5] = (block >> 8);
  2536. scmd[6] = block;
  2537. if (!logical && !STp->scsi2_logical)
  2538. scmd[1] = 4;
  2539. if (STp->partition != partition) {
  2540. scmd[1] |= 2;
  2541. scmd[8] = partition;
  2542.                         DEBC(printk(ST_DEB_MSG
  2543.                                     "st%d: Trying to change partition from %d to %dn",
  2544.                                     dev, STp->partition, partition));
  2545. }
  2546. }
  2547. if (STp->immediate) {
  2548. scmd[1] |= 1; /* Don't wait for completion */
  2549. timeout = STp->timeout;
  2550. }
  2551. SRpnt = st_do_scsi(NULL, STp, scmd, 0, SCSI_DATA_NONE,
  2552.    timeout, MAX_READY_RETRIES, TRUE);
  2553. if (!SRpnt)
  2554. return (STp->buffer)->syscall_result;
  2555. STps->drv_block = STps->drv_file = (-1);
  2556. STps->eof = ST_NOEOF;
  2557. if ((STp->buffer)->syscall_result != 0) {
  2558. result = (-EIO);
  2559. if (STp->can_partitions &&
  2560.     (STp->device)->scsi_level >= SCSI_2 &&
  2561.     (p = find_partition(STp)) >= 0)
  2562. STp->partition = p;
  2563. } else {
  2564. if (STp->can_partitions) {
  2565. STp->partition = partition;
  2566. STps = &(STp->ps[partition]);
  2567. if (!STps->last_block_valid ||
  2568.     STps->last_block_visited != block) {
  2569. STps->at_sm = 0;
  2570. STps->rw = ST_IDLE;
  2571. }
  2572. } else
  2573. STps->at_sm = 0;
  2574. if (block == 0)
  2575. STps->drv_block = STps->drv_file = 0;
  2576. result = 0;
  2577. }
  2578. scsi_release_request(SRpnt);
  2579. SRpnt = NULL;
  2580. return result;
  2581. }
  2582. /* Find the current partition number for the drive status. Called from open and
  2583.    returns either partition number of negative error code. */
  2584. static int find_partition(Scsi_Tape *STp)
  2585. {
  2586. int i, partition;
  2587. unsigned int block;
  2588. if ((i = get_location(STp, &block, &partition, 1)) < 0)
  2589. return i;
  2590. if (partition >= ST_NBR_PARTITIONS)
  2591. return (-EIO);
  2592. return partition;
  2593. }
  2594. /* Change the partition if necessary */
  2595. static int update_partition(Scsi_Tape *STp)
  2596. {
  2597. ST_partstat *STps;
  2598. if (STp->partition == STp->new_partition)
  2599. return 0;
  2600. STps = &(STp->ps[STp->new_partition]);
  2601. if (!STps->last_block_valid)
  2602. STps->last_block_visited = 0;
  2603. return set_location(STp, STps->last_block_visited, STp->new_partition, 1);
  2604. }
  2605. /* Functions for reading and writing the medium partition mode page. */
  2606. #define PART_PAGE   0x11
  2607. #define PART_PAGE_FIXED_LENGTH 8
  2608. #define PP_OFF_MAX_ADD_PARTS   2
  2609. #define PP_OFF_NBR_ADD_PARTS   3
  2610. #define PP_OFF_FLAGS           4
  2611. #define PP_OFF_PART_UNITS      6
  2612. #define PP_OFF_RESERVED        7
  2613. #define PP_BIT_IDP             0x20
  2614. #define PP_MSK_PSUM_MB         0x10
  2615. /* Get the number of partitions on the tape. As a side effect reads the
  2616.    mode page into the tape buffer. */
  2617. static int nbr_partitions(Scsi_Tape *STp)
  2618. {
  2619. int result;
  2620. DEB( int dev = TAPE_NR(STp->devt) );
  2621. if (STp->ready != ST_READY)
  2622. return (-EIO);
  2623. result = read_mode_page(STp, PART_PAGE, TRUE);
  2624. if (result) {
  2625.                 DEBC(printk(ST_DEB_MSG "st%d: Can't read medium partition page.n",
  2626.                             dev));
  2627. result = (-EIO);
  2628. } else {
  2629. result = (STp->buffer)->b_data[MODE_HEADER_LENGTH +
  2630.       PP_OFF_NBR_ADD_PARTS] + 1;
  2631.                 DEBC(printk(ST_DEB_MSG "st%d: Number of partitions %d.n", dev, result));
  2632. }
  2633. return result;
  2634. }
  2635. /* Partition the tape into two partitions if size > 0 or one partition if
  2636.    size == 0.
  2637.    The block descriptors are read and written because Sony SDT-7000 does not
  2638.    work without this (suggestion from Michael Schaefer <Michael.Schaefer@dlr.de>).
  2639.    My HP C1533A drive returns only one partition size field. This is used to
  2640.    set the size of partition 1. There is no size field for the default partition.
  2641.    Michael Schaefer's Sony SDT-7000 returns two descriptors and the second is
  2642.    used to set the size of partition 1 (this is what the SCSI-3 standard specifies).
  2643.    The following algorithm is used to accomodate both drives: if the number of
  2644.    partition size fields is greater than the maximum number of additional partitions
  2645.    in the mode page, the second field is used. Otherwise the first field is used.
  2646.    For Seagate DDS drives the page length must be 8 when no partitions is defined
  2647.    and 10 when 1 partition is defined (information from Eric Lee Green). This is
  2648.    is acceptable also to some other old drives and enforced if the first partition
  2649.    size field is used for the first additional partition size.
  2650.  */
  2651. static int partition_tape(Scsi_Tape *STp, int size)
  2652. {
  2653. int dev = TAPE_NR(STp->devt), result;
  2654. int pgo, psd_cnt, psdo;
  2655. unsigned char *bp;
  2656. result = read_mode_page(STp, PART_PAGE, FALSE);
  2657. if (result) {
  2658. DEBC(printk(ST_DEB_MSG "st%d: Can't read partition mode page.n", dev));
  2659. return result;
  2660. }
  2661. /* The mode page is in the buffer. Let's modify it and write it. */
  2662. bp = (STp->buffer)->b_data;
  2663. pgo = MODE_HEADER_LENGTH + bp[MH_OFF_BDESCS_LENGTH];
  2664. DEBC(printk(ST_DEB_MSG "st%d: Partition page length is %d bytes.n",
  2665.     dev, bp[pgo + MP_OFF_PAGE_LENGTH] + 2));
  2666. psd_cnt = (bp[pgo + MP_OFF_PAGE_LENGTH] + 2 - PART_PAGE_FIXED_LENGTH) / 2;
  2667. psdo = pgo + PART_PAGE_FIXED_LENGTH;
  2668. if (psd_cnt > bp[pgo + PP_OFF_MAX_ADD_PARTS]) {
  2669. bp[psdo] = bp[psdo + 1] = 0xff;  /* Rest of the tape */
  2670. psdo += 2;
  2671. }
  2672. memset(bp + psdo, 0, bp[pgo + PP_OFF_NBR_ADD_PARTS] * 2);
  2673. DEBC(printk("st%d: psd_cnt %d, max.parts %d, nbr_parts %dn", dev,
  2674.     psd_cnt, bp[pgo + PP_OFF_MAX_ADD_PARTS],
  2675.     bp[pgo + PP_OFF_NBR_ADD_PARTS]));
  2676. if (size <= 0) {
  2677. bp[pgo + PP_OFF_NBR_ADD_PARTS] = 0;
  2678. if (psd_cnt <= bp[pgo + PP_OFF_MAX_ADD_PARTS])
  2679.     bp[pgo + MP_OFF_PAGE_LENGTH] = 6;
  2680.                 DEBC(printk(ST_DEB_MSG "st%d: Formatting tape with one partition.n",
  2681.                             dev));
  2682. } else {
  2683. bp[psdo] = (size >> 8) & 0xff;
  2684. bp[psdo + 1] = size & 0xff;
  2685. bp[pgo + 3] = 1;
  2686. if (bp[pgo + MP_OFF_PAGE_LENGTH] < 8)
  2687.     bp[pgo + MP_OFF_PAGE_LENGTH] = 8;
  2688.                 DEBC(printk(ST_DEB_MSG
  2689.                             "st%d: Formatting tape with two partitions (1 = %d MB).n",
  2690.                             dev, size));
  2691. }
  2692. bp[pgo + PP_OFF_PART_UNITS] = 0;
  2693. bp[pgo + PP_OFF_RESERVED] = 0;
  2694. bp[pgo + PP_OFF_FLAGS] = PP_BIT_IDP | PP_MSK_PSUM_MB;
  2695. result = write_mode_page(STp, PART_PAGE);
  2696. if (result) {
  2697. printk(KERN_INFO "st%d: Partitioning of tape failed.n", dev);
  2698. result = (-EIO);
  2699. }
  2700. return result;
  2701. }
  2702. /* The ioctl command */
  2703. static int st_ioctl(struct inode *inode, struct file *file,
  2704.     unsigned int cmd_in, unsigned long arg)
  2705. {
  2706. int i, cmd_nr, cmd_type, bt;
  2707. int retval = 0;
  2708. unsigned int blk;
  2709. Scsi_Tape *STp;
  2710. ST_mode *STm;
  2711. ST_partstat *STps;
  2712. int dev = TAPE_NR(inode->i_rdev);
  2713. read_lock(&st_dev_arr_lock);
  2714. STp = scsi_tapes[dev];
  2715. read_unlock(&st_dev_arr_lock);
  2716. if (down_interruptible(&STp->lock))
  2717. return -ERESTARTSYS;
  2718.         DEB(
  2719. if (debugging && !STp->in_use) {
  2720. printk(ST_DEB_MSG "st%d: Incorrect device.n", dev);
  2721. retval = (-EIO);
  2722. goto out;
  2723. } ) /* end DEB */
  2724. STm = &(STp->modes[STp->current_mode]);
  2725. STps = &(STp->ps[STp->partition]);
  2726. /*
  2727.  * If we are in the middle of error recovery, don't let anyone
  2728.  * else try and use this device.  Also, if error recovery fails, it
  2729.  * may try and take the device offline, in which case all further
  2730.  * access to the device is prohibited.
  2731.  */
  2732. if (!scsi_block_when_processing_errors(STp->device)) {
  2733. retval = (-ENXIO);
  2734. goto out;
  2735. }
  2736. cmd_type = _IOC_TYPE(cmd_in);
  2737. cmd_nr = _IOC_NR(cmd_in);
  2738. if (cmd_type == _IOC_TYPE(MTIOCTOP) && cmd_nr == _IOC_NR(MTIOCTOP)) {
  2739. struct mtop mtc;
  2740. if (_IOC_SIZE(cmd_in) != sizeof(mtc)) {
  2741. retval = (-EINVAL);
  2742. goto out;
  2743. }
  2744. i = copy_from_user((char *) &mtc, (char *) arg, sizeof(struct mtop));
  2745. if (i) {
  2746. retval = (-EFAULT);
  2747. goto out;
  2748. }
  2749. if (mtc.mt_op == MTSETDRVBUFFER && !capable(CAP_SYS_ADMIN)) {
  2750. printk(KERN_WARNING
  2751.                                "st%d: MTSETDRVBUFFER only allowed for root.n", dev);
  2752. retval = (-EPERM);
  2753. goto out;
  2754. }
  2755. if (!STm->defined &&
  2756.     (mtc.mt_op != MTSETDRVBUFFER &&
  2757.      (mtc.mt_count & MT_ST_OPTIONS) == 0)) {
  2758. retval = (-ENXIO);
  2759. goto out;
  2760. }
  2761. if (!(STp->device)->was_reset) {
  2762. if (STps->eof == ST_FM_HIT) {
  2763. if (mtc.mt_op == MTFSF || mtc.mt_op == MTFSFM ||
  2764.                                     mtc.mt_op == MTEOM) {
  2765. mtc.mt_count -= 1;
  2766. if (STps->drv_file >= 0)
  2767. STps->drv_file += 1;
  2768. } else if (mtc.mt_op == MTBSF || mtc.mt_op == MTBSFM) {
  2769. mtc.mt_count += 1;
  2770. if (STps->drv_file >= 0)
  2771. STps->drv_file += 1;
  2772. }
  2773. }
  2774. if (mtc.mt_op == MTSEEK) {
  2775. /* Old position must be restored if partition will be
  2776.                                    changed */
  2777. i = !STp->can_partitions ||
  2778.     (STp->new_partition != STp->partition);
  2779. } else {
  2780. i = mtc.mt_op == MTREW || mtc.mt_op == MTOFFL ||
  2781.     mtc.mt_op == MTRETEN || mtc.mt_op == MTEOM ||
  2782.     mtc.mt_op == MTLOCK || mtc.mt_op == MTLOAD ||
  2783.     mtc.mt_op == MTFSF || mtc.mt_op == MTFSFM ||
  2784.     mtc.mt_op == MTBSF || mtc.mt_op == MTBSFM ||
  2785.     mtc.mt_op == MTCOMPRESSION;
  2786. }
  2787. i = flush_buffer(STp, i);
  2788. if (i < 0) {
  2789. retval = i;
  2790. goto out;
  2791. }
  2792. } else {
  2793. /*
  2794.  * If there was a bus reset, block further access
  2795.  * to this device.  If the user wants to rewind the tape,
  2796.  * then reset the flag and allow access again.
  2797.  */
  2798. if (mtc.mt_op != MTREW &&
  2799.     mtc.mt_op != MTOFFL &&
  2800.     mtc.mt_op != MTRETEN &&
  2801.     mtc.mt_op != MTERASE &&
  2802.     mtc.mt_op != MTSEEK &&
  2803.     mtc.mt_op != MTEOM) {
  2804. retval = (-EIO);
  2805. goto out;
  2806. }
  2807. STp->device->was_reset = 0;
  2808. if (STp->door_locked != ST_UNLOCKED &&
  2809.     STp->door_locked != ST_LOCK_FAILS) {
  2810. if (st_int_ioctl(STp, MTLOCK, 0)) {
  2811. printk(KERN_NOTICE
  2812.                                                "st%d: Could not relock door after bus reset.n",
  2813.        dev);
  2814. STp->door_locked = ST_UNLOCKED;
  2815. }
  2816. }
  2817. }
  2818. if (mtc.mt_op != MTNOP && mtc.mt_op != MTSETBLK &&
  2819.     mtc.mt_op != MTSETDENSITY && mtc.mt_op != MTWSM &&
  2820.     mtc.mt_op != MTSETDRVBUFFER && mtc.mt_op != MTSETPART)
  2821. STps->rw = ST_IDLE; /* Prevent automatic WEOF and fsf */
  2822. if (mtc.mt_op == MTOFFL && STp->door_locked != ST_UNLOCKED)
  2823. st_int_ioctl(STp, MTUNLOCK, 0); /* Ignore result! */
  2824. if (mtc.mt_op == MTSETDRVBUFFER &&
  2825.     (mtc.mt_count & MT_ST_OPTIONS) != 0) {
  2826. retval = st_set_options(STp, mtc.mt_count);
  2827. goto out;
  2828. }
  2829. if (mtc.mt_op == MTSETPART) {
  2830. if (!STp->can_partitions ||
  2831.     mtc.mt_count < 0 || mtc.mt_count >= ST_NBR_PARTITIONS) {
  2832. retval = (-EINVAL);
  2833. goto out;
  2834. }
  2835. if (mtc.mt_count >= STp->nbr_partitions &&
  2836.     (STp->nbr_partitions = nbr_partitions(STp)) < 0) {
  2837. retval = (-EIO);
  2838. goto out;
  2839. }
  2840. if (mtc.mt_count >= STp->nbr_partitions) {
  2841. retval = (-EINVAL);
  2842. goto out;
  2843. }
  2844. STp->new_partition = mtc.mt_count;
  2845. retval = 0;
  2846. goto out;
  2847. }
  2848. if (mtc.mt_op == MTMKPART) {
  2849. if (!STp->can_partitions) {
  2850. retval = (-EINVAL);
  2851. goto out;
  2852. }
  2853. if ((i = st_int_ioctl(STp, MTREW, 0)) < 0 ||
  2854.     (i = partition_tape(STp, mtc.mt_count)) < 0) {
  2855. retval = i;
  2856. goto out;
  2857. }
  2858. for (i = 0; i < ST_NBR_PARTITIONS; i++) {
  2859. STp->ps[i].rw = ST_IDLE;
  2860. STp->ps[i].at_sm = 0;
  2861. STp->ps[i].last_block_valid = FALSE;
  2862. }
  2863. STp->partition = STp->new_partition = 0;
  2864. STp->nbr_partitions = 1; /* Bad guess ?-) */
  2865. STps->drv_block = STps->drv_file = 0;
  2866. retval = 0;
  2867. goto out;
  2868. }
  2869. if (mtc.mt_op == MTSEEK) {
  2870. i = set_location(STp, mtc.mt_count, STp->new_partition, 0);
  2871. if (!STp->can_partitions)
  2872. STp->ps[0].rw = ST_IDLE;
  2873. retval = i;
  2874. goto out;
  2875. }
  2876. if (mtc.mt_op == MTUNLOAD || mtc.mt_op == MTOFFL) {
  2877. retval = do_load_unload(STp, file, 0);
  2878. goto out;
  2879. }
  2880. if (mtc.mt_op == MTLOAD) {
  2881. retval = do_load_unload(STp, file, max(1, mtc.mt_count));
  2882. goto out;
  2883. }
  2884. if (STp->can_partitions && STp->ready == ST_READY &&
  2885.     (i = update_partition(STp)) < 0) {
  2886. retval = i;
  2887. goto out;
  2888. }
  2889. if (mtc.mt_op == MTCOMPRESSION)
  2890. retval = st_compression(STp, (mtc.mt_count & 1));
  2891. else
  2892. retval = st_int_ioctl(STp, mtc.mt_op, mtc.mt_count);
  2893. goto out;
  2894. }
  2895. if (!STm->defined) {
  2896. retval = (-ENXIO);
  2897. goto out;
  2898. }
  2899. if ((i = flush_buffer(STp, FALSE)) < 0) {
  2900. retval = i;
  2901. goto out;
  2902. }
  2903. if (STp->can_partitions &&
  2904.     (i = update_partition(STp)) < 0) {
  2905. retval = i;
  2906. goto out;
  2907. }
  2908. if (cmd_type == _IOC_TYPE(MTIOCGET) && cmd_nr == _IOC_NR(MTIOCGET)) {
  2909. struct mtget mt_status;
  2910. if (_IOC_SIZE(cmd_in) != sizeof(struct mtget)) {
  2911.  retval = (-EINVAL);
  2912.  goto out;
  2913. }
  2914. mt_status.mt_type = STp->tape_type;
  2915. mt_status.mt_dsreg =
  2916.     ((STp->block_size << MT_ST_BLKSIZE_SHIFT) & MT_ST_BLKSIZE_MASK) |
  2917.     ((STp->density << MT_ST_DENSITY_SHIFT) & MT_ST_DENSITY_MASK);
  2918. mt_status.mt_blkno = STps->drv_block;
  2919. mt_status.mt_fileno = STps->drv_file;
  2920. if (STp->block_size != 0) {
  2921. if (STps->rw == ST_WRITING)
  2922. mt_status.mt_blkno +=
  2923.     (STp->buffer)->buffer_bytes / STp->block_size;
  2924. else if (STps->rw == ST_READING)
  2925. mt_status.mt_blkno -=
  2926.                                         ((STp->buffer)->buffer_bytes +
  2927.                                          STp->block_size - 1) / STp->block_size;
  2928. }
  2929. mt_status.mt_gstat = 0;
  2930. if (STp->drv_write_prot)
  2931. mt_status.mt_gstat |= GMT_WR_PROT(0xffffffff);
  2932. if (mt_status.mt_blkno == 0) {
  2933. if (mt_status.mt_fileno == 0)
  2934. mt_status.mt_gstat |= GMT_BOT(0xffffffff);
  2935. else
  2936. mt_status.mt_gstat |= GMT_EOF(0xffffffff);
  2937. }
  2938. mt_status.mt_erreg = (STp->recover_reg << MT_ST_SOFTERR_SHIFT);
  2939. mt_status.mt_resid = STp->partition;
  2940. if (STps->eof == ST_EOM_OK || STps->eof == ST_EOM_ERROR)
  2941. mt_status.mt_gstat |= GMT_EOT(0xffffffff);
  2942. else if (STps->eof >= ST_EOM_OK)
  2943. mt_status.mt_gstat |= GMT_EOD(0xffffffff);
  2944. if (STp->density == 1)
  2945. mt_status.mt_gstat |= GMT_D_800(0xffffffff);
  2946. else if (STp->density == 2)
  2947. mt_status.mt_gstat |= GMT_D_1600(0xffffffff);
  2948. else if (STp->density == 3)
  2949. mt_status.mt_gstat |= GMT_D_6250(0xffffffff);
  2950. if (STp->ready == ST_READY)
  2951. mt_status.mt_gstat |= GMT_ONLINE(0xffffffff);
  2952. if (STp->ready == ST_NO_TAPE)
  2953. mt_status.mt_gstat |= GMT_DR_OPEN(0xffffffff);
  2954. if (STps->at_sm)
  2955. mt_status.mt_gstat |= GMT_SM(0xffffffff);
  2956. if (STm->do_async_writes ||
  2957.                     (STm->do_buffer_writes && STp->block_size != 0) ||
  2958.     STp->drv_buffer != 0)
  2959. mt_status.mt_gstat |= GMT_IM_REP_EN(0xffffffff);
  2960. if (STp->cleaning_req)
  2961. mt_status.mt_gstat |= GMT_CLN(0xffffffff);
  2962. i = copy_to_user((char *) arg, (char *) &(mt_status),
  2963.  sizeof(struct mtget));
  2964. if (i) {
  2965. retval = (-EFAULT);
  2966. goto out;
  2967. }
  2968. STp->recover_reg = 0; /* Clear after read */
  2969. retval = 0;
  2970. goto out;
  2971. } /* End of MTIOCGET */
  2972. if (cmd_type == _IOC_TYPE(MTIOCPOS) && cmd_nr == _IOC_NR(MTIOCPOS)) {
  2973. struct mtpos mt_pos;
  2974. if (_IOC_SIZE(cmd_in) != sizeof(struct mtpos)) {
  2975.  retval = (-EINVAL);
  2976.  goto out;
  2977. }
  2978. if ((i = get_location(STp, &blk, &bt, 0)) < 0) {
  2979. retval = i;
  2980. goto out;
  2981. }
  2982. mt_pos.mt_blkno = blk;
  2983. i = copy_to_user((char *) arg, (char *) (&mt_pos), sizeof(struct mtpos));
  2984. if (i)
  2985. retval = (-EFAULT);
  2986. goto out;
  2987. }
  2988. up(&STp->lock);
  2989. return scsi_ioctl(STp->device, cmd_in, (void *) arg);
  2990.  out:
  2991. up(&STp->lock);
  2992. return retval;
  2993. }
  2994. /* Try to allocate a new tape buffer. Calling function must not hold
  2995.    dev_arr_lock. */
  2996. static ST_buffer *
  2997.  new_tape_buffer(int from_initialization, int need_dma, int in_use)
  2998. {
  2999. int i, priority, b_size, order, got = 0, segs = 0;
  3000. unsigned long flags;
  3001. ST_buffer *tb;
  3002. read_lock(&st_dev_arr_lock);
  3003. if (st_nbr_buffers >= st_template.dev_max) {
  3004. read_unlock(&st_dev_arr_lock);
  3005. return NULL; /* Should never happen */
  3006. }
  3007. read_unlock(&st_dev_arr_lock);
  3008. if (from_initialization)
  3009. priority = GFP_ATOMIC;
  3010. else
  3011. priority = GFP_KERNEL;
  3012. i = sizeof(ST_buffer) + (st_max_sg_segs - 1) * sizeof(struct scatterlist) +
  3013. st_max_sg_segs * sizeof(unsigned int);
  3014. tb = kmalloc(i, priority);
  3015. if (tb) {
  3016. tb->sg_lengths = (unsigned int *)(&tb->sg[0] + st_max_sg_segs);
  3017. if (need_dma)
  3018. priority |= GFP_DMA;
  3019. /* Try to allocate the first segment up to ST_FIRST_ORDER and the
  3020.    others big enough to reach the goal */
  3021. for (b_size = PAGE_SIZE, order=0;
  3022.      b_size < st_buffer_size && order < ST_FIRST_ORDER;
  3023.      order++, b_size *= 2)
  3024. ;
  3025. for ( ; b_size >= PAGE_SIZE; order--, b_size /= 2) {
  3026. tb->sg[0].address =
  3027.     (unsigned char *) __get_free_pages(priority, order);
  3028. if (tb->sg[0].address != NULL) {
  3029. tb->sg_lengths[0] = b_size;
  3030. break;
  3031. }
  3032. }
  3033. tb->sg[0].page = NULL;
  3034. if (tb->sg[segs].address == NULL) {
  3035. kfree(tb);
  3036. tb = NULL;
  3037. } else { /* Got something, continue */
  3038. for (b_size = PAGE_SIZE, order=0;
  3039.      st_buffer_size >
  3040.                                      tb->sg_lengths[0] + (ST_FIRST_SG - 1) * b_size;
  3041.      order++, b_size *= 2)
  3042. ;
  3043. for (segs = 1, got = tb->sg_lengths[0];
  3044.      got < st_buffer_size && segs < ST_FIRST_SG;) {
  3045. tb->sg[segs].address =
  3046. (unsigned char *) __get_free_pages(priority,
  3047.    order);
  3048. if (tb->sg[segs].address == NULL) {
  3049. if (st_buffer_size - got <=
  3050.     (ST_FIRST_SG - segs) * b_size / 2) {
  3051. b_size /= 2; /* Large enough for the
  3052.                                                                 rest of the buffers */
  3053. order--;
  3054. continue;
  3055. }
  3056. tb->sg_segs = segs;
  3057. tb->orig_sg_segs = 0;
  3058. DEB(tb->buffer_size = got);
  3059. normalize_buffer(tb);
  3060. kfree(tb);
  3061. tb = NULL;
  3062. break;
  3063. }
  3064. tb->sg[segs].page = NULL;
  3065. tb->sg_lengths[segs] = b_size;
  3066. got += b_size;
  3067. segs++;
  3068. }
  3069. }
  3070. }
  3071. if (!tb) {
  3072. printk(KERN_NOTICE "st: Can't allocate new tape buffer (nbr %d).n",
  3073.        st_nbr_buffers);
  3074. return NULL;
  3075. }
  3076. tb->sg_segs = tb->orig_sg_segs = segs;
  3077. tb->b_data = tb->sg[0].address;
  3078.         DEBC(printk(ST_DEB_MSG
  3079.                     "st: Allocated tape buffer %d (%d bytes, %d segments, dma: %d, a: %p).n",
  3080.                     st_nbr_buffers, got, tb->sg_segs, need_dma, tb->b_data);
  3081.              printk(ST_DEB_MSG
  3082.                     "st: segment sizes: first %d, last %d bytes.n",
  3083.                     tb->sg_lengths[0], tb->sg_lengths[segs - 1]);
  3084. )
  3085. tb->in_use = in_use;
  3086. tb->dma = need_dma;
  3087. tb->buffer_size = got;
  3088. tb->writing = 0;
  3089. write_lock_irqsave(&st_dev_arr_lock, flags);
  3090. st_buffers[st_nbr_buffers++] = tb;
  3091. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  3092. return tb;
  3093. }
  3094. /* Try to allocate a temporary enlarged tape buffer */
  3095. static int enlarge_buffer(ST_buffer * STbuffer, int new_size, int need_dma)
  3096. {
  3097. int segs, nbr, max_segs, b_size, priority, order, got;
  3098. normalize_buffer(STbuffer);
  3099. max_segs = STbuffer->use_sg;
  3100. if (max_segs > st_max_sg_segs)
  3101. max_segs = st_max_sg_segs;
  3102. nbr = max_segs - STbuffer->sg_segs;
  3103. if (nbr <= 0)
  3104. return FALSE;
  3105. priority = GFP_KERNEL;
  3106. if (need_dma)
  3107. priority |= GFP_DMA;
  3108. for (b_size = PAGE_SIZE, order=0;
  3109.      b_size * nbr < new_size - STbuffer->buffer_size;
  3110.      order++, b_size *= 2)
  3111. ;  /* empty */
  3112. for (segs = STbuffer->sg_segs, got = STbuffer->buffer_size;
  3113.      segs < max_segs && got < new_size;) {
  3114. STbuffer->sg[segs].address =
  3115. (unsigned char *) __get_free_pages(priority, order);
  3116. if (STbuffer->sg[segs].address == NULL) {
  3117. if (new_size - got <= (max_segs - segs) * b_size / 2) {
  3118. b_size /= 2; /* Large enough for the rest of the buffers */
  3119. order--;
  3120. continue;
  3121. }
  3122. printk(KERN_NOTICE "st: failed to enlarge buffer to %d bytes.n",
  3123.        new_size);
  3124. DEB(STbuffer->buffer_size = got);
  3125. normalize_buffer(STbuffer);
  3126. return FALSE;
  3127. }
  3128. STbuffer->sg[segs].page = NULL;
  3129. STbuffer->sg_lengths[segs] = b_size;
  3130. STbuffer->sg_segs += 1;
  3131. got += b_size;
  3132. STbuffer->buffer_size = got;
  3133. segs++;
  3134. }
  3135.         DEBC(printk(ST_DEB_MSG
  3136.                     "st: Succeeded to enlarge buffer to %d bytes (segs %d->%d, %d).n",
  3137.                     got, STbuffer->orig_sg_segs, STbuffer->sg_segs, b_size));
  3138. return TRUE;
  3139. }
  3140. /* Release the extra buffer */
  3141. static void normalize_buffer(ST_buffer * STbuffer)
  3142. {
  3143. int i, order, b_size;
  3144. for (i = STbuffer->orig_sg_segs; i < STbuffer->sg_segs; i++) {
  3145. for (b_size=PAGE_SIZE, order=0; b_size < STbuffer->sg_lengths[i];
  3146.      order++, b_size *= 2)
  3147. ; /* empty */
  3148. free_pages((unsigned long)(STbuffer->sg[i].address), order);
  3149. STbuffer->buffer_size -= STbuffer->sg_lengths[i];
  3150. }
  3151.         DEB(
  3152. if (debugging && STbuffer->orig_sg_segs < STbuffer->sg_segs)
  3153. printk(ST_DEB_MSG "st: Buffer at %p normalized to %d bytes (segs %d).n",
  3154.        STbuffer->sg[0].address, STbuffer->buffer_size,
  3155.        STbuffer->sg_segs);
  3156.         ) /* end DEB */
  3157. STbuffer->sg_segs = STbuffer->orig_sg_segs;
  3158. }
  3159. /* Move data from the user buffer to the tape buffer. Returns zero (success) or
  3160.    negative error code. */
  3161. static int append_to_buffer(const char *ubp, ST_buffer * st_bp, int do_count)
  3162. {
  3163. int i, cnt, res, offset;
  3164. for (i = 0, offset = st_bp->buffer_bytes;
  3165.      i < st_bp->sg_segs && offset >= st_bp->sg_lengths[i]; i++)
  3166. offset -= st_bp->sg_lengths[i];
  3167. if (i == st_bp->sg_segs) { /* Should never happen */
  3168. printk(KERN_WARNING "st: append_to_buffer offset overflow.n");
  3169. return (-EIO);
  3170. }
  3171. for (; i < st_bp->sg_segs && do_count > 0; i++) {
  3172. cnt = st_bp->sg_lengths[i] - offset < do_count ?
  3173.     st_bp->sg_lengths[i] - offset : do_count;
  3174. res = copy_from_user(st_bp->sg[i].address + offset, ubp, cnt);
  3175. if (res)
  3176. return (-EFAULT);
  3177. do_count -= cnt;
  3178. st_bp->buffer_bytes += cnt;
  3179. ubp += cnt;
  3180. offset = 0;
  3181. }
  3182. if (do_count) { /* Should never happen */
  3183. printk(KERN_WARNING "st: append_to_buffer overflow (left %d).n",
  3184.        do_count);
  3185. return (-EIO);
  3186. }
  3187. return 0;
  3188. }
  3189. /* Move data from the tape buffer to the user buffer. Returns zero (success) or
  3190.    negative error code. */
  3191. static int from_buffer(ST_buffer * st_bp, char *ubp, int do_count)
  3192. {
  3193. int i, cnt, res, offset;
  3194. for (i = 0, offset = st_bp->read_pointer;
  3195.      i < st_bp->sg_segs && offset >= st_bp->sg_lengths[i]; i++)
  3196. offset -= st_bp->sg_lengths[i];
  3197. if (i == st_bp->sg_segs) { /* Should never happen */
  3198. printk(KERN_WARNING "st: from_buffer offset overflow.n");
  3199. return (-EIO);
  3200. }
  3201. for (; i < st_bp->sg_segs && do_count > 0; i++) {
  3202. cnt = st_bp->sg_lengths[i] - offset < do_count ?
  3203.     st_bp->sg_lengths[i] - offset : do_count;
  3204. res = copy_to_user(ubp, st_bp->sg[i].address + offset, cnt);
  3205. if (res)
  3206. return (-EFAULT);
  3207. do_count -= cnt;
  3208. st_bp->buffer_bytes -= cnt;
  3209. st_bp->read_pointer += cnt;
  3210. ubp += cnt;
  3211. offset = 0;
  3212. }
  3213. if (do_count) { /* Should never happen */
  3214. printk(KERN_WARNING "st: from_buffer overflow (left %d).n",
  3215.        do_count);
  3216. return (-EIO);
  3217. }
  3218. return 0;
  3219. }
  3220. /* Set the scatter/gather list length fields to sum up to the transfer length.
  3221.    Return the number of segments being used. */
  3222. static int set_sg_lengths(ST_buffer *st_bp, unsigned int length)
  3223. {
  3224. int i;
  3225. for (i=0; i < st_bp->sg_segs; i++) {
  3226. if (length > st_bp->sg_lengths[i])
  3227. st_bp->sg[i].length = st_bp->sg_lengths[i];
  3228. else {
  3229. st_bp->sg[i].length = length;
  3230. break;
  3231. }
  3232. length -= st_bp->sg_lengths[i];
  3233. }
  3234. return i + 1;
  3235. }
  3236. /* Validate the options from command line or module parameters */
  3237. static void validate_options(void)
  3238. {
  3239. if (buffer_kbs > 0)
  3240. st_buffer_size = buffer_kbs * ST_KILOBYTE;
  3241. if (write_threshold_kbs > 0)
  3242. st_write_threshold = write_threshold_kbs * ST_KILOBYTE;
  3243. else if (buffer_kbs > 0)
  3244. st_write_threshold = st_buffer_size - 2048;
  3245. if (st_write_threshold > st_buffer_size) {
  3246. st_write_threshold = st_buffer_size;
  3247. printk(KERN_WARNING "st: write_threshold limited to %d bytes.n",
  3248.        st_write_threshold);
  3249. }
  3250. if (max_buffers >= 0)
  3251. st_max_buffers = max_buffers;
  3252. if (max_sg_segs >= ST_FIRST_SG)
  3253. st_max_sg_segs = max_sg_segs;
  3254. }
  3255. #ifndef MODULE
  3256. /* Set the boot options. Syntax is defined in README.st.
  3257.  */
  3258. static int __init st_setup(char *str)
  3259. {
  3260. int i, len, ints[5];
  3261. char *stp;
  3262. stp = get_options(str, ARRAY_SIZE(ints), ints);
  3263. if (ints[0] > 0) {
  3264. for (i = 0; i < ints[0] && i < ARRAY_SIZE(parms); i++)
  3265. *parms[i].val = ints[i + 1];
  3266. } else {
  3267. while (stp != NULL) {
  3268. for (i = 0; i < ARRAY_SIZE(parms); i++) {
  3269. len = strlen(parms[i].name);
  3270. if (!strncmp(stp, parms[i].name, len) &&
  3271.     (*(stp + len) == ':' || *(stp + len) == '=')) {
  3272. *parms[i].val =
  3273.                                                 simple_strtoul(stp + len + 1, NULL, 0);
  3274. break;
  3275. }
  3276. }
  3277. if (i >= sizeof(parms) / sizeof(struct st_dev_parm))
  3278.  printk(KERN_WARNING "st: illegal parameter in '%s'n",
  3279. stp);
  3280. stp = strchr(stp, ',');
  3281. if (stp)
  3282. stp++;
  3283. }
  3284. }
  3285. validate_options();
  3286. return 1;
  3287. }
  3288. __setup("st=", st_setup);
  3289. #endif
  3290. static struct file_operations st_fops =
  3291. {
  3292. owner: THIS_MODULE,
  3293. read: st_read,
  3294. write: st_write,
  3295. ioctl: st_ioctl,
  3296. open: st_open,
  3297. flush: st_flush,
  3298. release: st_release,
  3299. };
  3300. static int st_attach(Scsi_Device * SDp)
  3301. {
  3302. Scsi_Tape *tpnt;
  3303. ST_mode *STm;
  3304. ST_partstat *STps;
  3305. int i, mode, target_nbr, dev_num;
  3306. unsigned long flags = 0;
  3307. char *stp;
  3308. if (SDp->type != TYPE_TAPE)
  3309. return 1;
  3310. if ((stp = st_incompatible(SDp))) {
  3311. printk(KERN_INFO
  3312.        "st: Found incompatible tape at scsi%d, channel %d, id %d, lun %dn",
  3313.        SDp->host->host_no, SDp->channel, SDp->id, SDp->lun);
  3314. printk(KERN_INFO "st: The suggested driver is %s.n", stp);
  3315. return 1;
  3316. }
  3317. write_lock_irqsave(&st_dev_arr_lock, flags);
  3318. if (st_template.nr_dev >= st_template.dev_max) {
  3319. Scsi_Tape **tmp_da;
  3320. ST_buffer **tmp_ba;
  3321. int tmp_dev_max;
  3322. tmp_dev_max = st_template.nr_dev + ST_DEV_ARR_LUMP;
  3323. if (tmp_dev_max > ST_MAX_TAPES)
  3324. tmp_dev_max = ST_MAX_TAPES;
  3325. if (tmp_dev_max <= st_template.nr_dev) {
  3326. SDp->attached--;
  3327. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  3328. printk(KERN_ERR "st: Too many tape devices (max. %d).n",
  3329.        ST_MAX_TAPES);
  3330. return 1;
  3331. }
  3332. tmp_da = kmalloc(tmp_dev_max * sizeof(Scsi_Tape *), GFP_ATOMIC);
  3333. tmp_ba = kmalloc(tmp_dev_max * sizeof(ST_buffer *), GFP_ATOMIC);
  3334. if (tmp_da == NULL || tmp_ba == NULL) {
  3335. if (tmp_da != NULL)
  3336. kfree(tmp_da);
  3337. if (tmp_ba != NULL)
  3338. kfree(tmp_ba);
  3339. SDp->attached--;
  3340. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  3341. printk(KERN_ERR "st: Can't extend device array.n");
  3342. return 1;
  3343. }
  3344. memset(tmp_da, 0, tmp_dev_max * sizeof(Scsi_Tape *));
  3345. if (scsi_tapes != NULL) {
  3346. memcpy(tmp_da, scsi_tapes,
  3347.        st_template.dev_max * sizeof(Scsi_Tape *));
  3348. kfree(scsi_tapes);
  3349. }
  3350. scsi_tapes = tmp_da;
  3351. memset(tmp_ba, 0, tmp_dev_max * sizeof(ST_buffer *));
  3352. if (st_buffers != NULL) {
  3353. memcpy(tmp_ba, st_buffers,
  3354.        st_template.dev_max * sizeof(ST_buffer *));
  3355. kfree(st_buffers);
  3356. }
  3357. st_buffers = tmp_ba;
  3358. st_template.dev_max = tmp_dev_max;
  3359. }
  3360. for (i = 0; i < st_template.dev_max; i++)
  3361. if (scsi_tapes[i] == NULL)
  3362. break;
  3363. if (i >= st_template.dev_max)
  3364. panic("scsi_devices corrupt (st)");
  3365. tpnt = kmalloc(sizeof(Scsi_Tape), GFP_ATOMIC);
  3366. if (tpnt == NULL) {
  3367. SDp->attached--;
  3368. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  3369. printk(KERN_ERR "st: Can't allocate device descriptor.n");
  3370. return 1;
  3371. }
  3372. memset(tpnt, 0, sizeof(Scsi_Tape));
  3373. scsi_tapes[i] = tpnt;
  3374. dev_num = i;
  3375. for (mode = 0; mode < ST_NBR_MODES; ++mode) {
  3376.     char name[8];
  3377.     static char *formats[ST_NBR_MODES] ={"", "l", "m", "a"};
  3378.     /*  Rewind entry  */
  3379.     sprintf (name, "mt%s", formats[mode]);
  3380.     tpnt->de_r[mode] =
  3381. devfs_register (SDp->de, name, DEVFS_FL_DEFAULT,
  3382. MAJOR_NR, i + (mode << 5),
  3383. S_IFCHR | S_IRUGO | S_IWUGO,
  3384. &st_fops, NULL);
  3385.     /*  No-rewind entry  */
  3386.     sprintf (name, "mt%sn", formats[mode]);
  3387.     tpnt->de_n[mode] =
  3388. devfs_register (SDp->de, name, DEVFS_FL_DEFAULT,
  3389. MAJOR_NR, i + (mode << 5) + 128,
  3390. S_IFCHR | S_IRUGO | S_IWUGO,
  3391. &st_fops, NULL);
  3392. }
  3393. devfs_register_tape (tpnt->de_r[0]);
  3394. tpnt->device = SDp;
  3395. if (SDp->scsi_level <= 2)
  3396. tpnt->tape_type = MT_ISSCSI1;
  3397. else
  3398. tpnt->tape_type = MT_ISSCSI2;
  3399.         tpnt->inited = 0;
  3400. tpnt->devt = MKDEV(SCSI_TAPE_MAJOR, i);
  3401. tpnt->dirty = 0;
  3402. tpnt->in_use = 0;
  3403. tpnt->drv_buffer = 1; /* Try buffering if no mode sense */
  3404. tpnt->restr_dma = (SDp->host)->unchecked_isa_dma;
  3405. tpnt->use_pf = (SDp->scsi_level >= SCSI_2);
  3406. tpnt->density = 0;
  3407. tpnt->do_auto_lock = ST_AUTO_LOCK;
  3408. tpnt->can_bsr = ST_IN_FILE_POS;
  3409. tpnt->can_partitions = 0;
  3410. tpnt->two_fm = ST_TWO_FM;
  3411. tpnt->fast_mteom = ST_FAST_MTEOM;
  3412. tpnt->scsi2_logical = ST_SCSI2LOGICAL;
  3413. tpnt->immediate = ST_NOWAIT;
  3414. tpnt->write_threshold = st_write_threshold;
  3415. tpnt->default_drvbuffer = 0xff; /* No forced buffering */
  3416. tpnt->partition = 0;
  3417. tpnt->new_partition = 0;
  3418. tpnt->nbr_partitions = 0;
  3419. tpnt->timeout = ST_TIMEOUT;
  3420. tpnt->long_timeout = ST_LONG_TIMEOUT;
  3421. for (i = 0; i < ST_NBR_MODES; i++) {
  3422. STm = &(tpnt->modes[i]);
  3423. STm->defined = FALSE;
  3424. STm->sysv = ST_SYSV;
  3425. STm->defaults_for_writes = 0;
  3426. STm->do_async_writes = ST_ASYNC_WRITES;
  3427. STm->do_buffer_writes = ST_BUFFER_WRITES;
  3428. STm->do_read_ahead = ST_READ_AHEAD;
  3429. STm->default_compression = ST_DONT_TOUCH;
  3430. STm->default_blksize = (-1); /* No forced size */
  3431. STm->default_density = (-1); /* No forced density */
  3432. }
  3433. for (i = 0; i < ST_NBR_PARTITIONS; i++) {
  3434. STps = &(tpnt->ps[i]);
  3435. STps->rw = ST_IDLE;
  3436. STps->eof = ST_NOEOF;
  3437. STps->at_sm = 0;
  3438. STps->last_block_valid = FALSE;
  3439. STps->drv_block = (-1);
  3440. STps->drv_file = (-1);
  3441. }
  3442. tpnt->current_mode = 0;
  3443. tpnt->modes[0].defined = TRUE;
  3444. tpnt->density_changed = tpnt->compression_changed =
  3445.     tpnt->blksize_changed = FALSE;
  3446. init_MUTEX(&tpnt->lock);
  3447. st_template.nr_dev++;
  3448. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  3449. printk(KERN_WARNING
  3450. "Attached scsi tape st%d at scsi%d, channel %d, id %d, lun %dn",
  3451.        dev_num, SDp->host->host_no, SDp->channel, SDp->id, SDp->lun);
  3452. /* See if we need to allocate more static buffers */
  3453. target_nbr = st_template.nr_dev;
  3454. if (target_nbr > st_max_buffers)
  3455. target_nbr = st_max_buffers;
  3456. for (i=st_nbr_buffers; i < target_nbr; i++)
  3457. if (!new_tape_buffer(TRUE, TRUE, FALSE)) {
  3458. printk(KERN_INFO "st: Unable to allocate new static buffer.n");
  3459. break;
  3460. }
  3461. /* If the previous allocation fails, we will try again when the buffer is
  3462.    really needed. */
  3463. return 0;
  3464. };
  3465. static int st_detect(Scsi_Device * SDp)
  3466. {
  3467. if (SDp->type != TYPE_TAPE || st_incompatible(SDp))
  3468. return 0;
  3469.         st_template.dev_noticed++;
  3470. return 1;
  3471. }
  3472. static int st_registered = 0;
  3473. /* Driver initialization (not __init because may be called later) */
  3474. static int st_init()
  3475. {
  3476. unsigned long flags;
  3477. if (st_template.dev_noticed == 0 || st_registered)
  3478. return 0;
  3479. printk(KERN_INFO
  3480.        "st: Version %s, bufsize %d, wrt %d, max init. bufs %d, s/g segs %dn",
  3481.        verstr, st_buffer_size, st_write_threshold, st_max_buffers, st_max_sg_segs);
  3482. write_lock_irqsave(&st_dev_arr_lock, flags);
  3483. if (!st_registered) {
  3484. if (devfs_register_chrdev(SCSI_TAPE_MAJOR, "st", &st_fops)) {
  3485. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  3486. printk(KERN_ERR "Unable to get major %d for SCSI tapesn",
  3487.                                MAJOR_NR);
  3488. st_template.dev_noticed = 0;
  3489. return 1;
  3490. }
  3491. st_registered++;
  3492. }
  3493. st_template.dev_max = 0;
  3494. st_nbr_buffers = 0;
  3495. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  3496. return 0;
  3497. }
  3498. static void st_detach(Scsi_Device * SDp)
  3499. {
  3500. Scsi_Tape *tpnt;
  3501. int i, mode;
  3502. unsigned long flags;
  3503. write_lock_irqsave(&st_dev_arr_lock, flags);
  3504. for (i = 0; i < st_template.dev_max; i++) {
  3505. tpnt = scsi_tapes[i];
  3506. if (tpnt != NULL && tpnt->device == SDp) {
  3507. tpnt->device = NULL;
  3508. for (mode = 0; mode < ST_NBR_MODES; ++mode) {
  3509. devfs_unregister (tpnt->de_r[mode]);
  3510. tpnt->de_r[mode] = NULL;
  3511. devfs_unregister (tpnt->de_n[mode]);
  3512. tpnt->de_n[mode] = NULL;
  3513. }
  3514. kfree(tpnt);
  3515. scsi_tapes[i] = 0;
  3516. SDp->attached--;
  3517. st_template.nr_dev--;
  3518. st_template.dev_noticed--;
  3519. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  3520. return;
  3521. }
  3522. }
  3523. write_unlock_irqrestore(&st_dev_arr_lock, flags);
  3524. return;
  3525. }
  3526. static int __init init_st(void)
  3527. {
  3528. validate_options();
  3529. st_template.module = THIS_MODULE;
  3530.         return scsi_register_module(MODULE_SCSI_DEV, &st_template);
  3531. }
  3532. static void __exit exit_st(void)
  3533. {
  3534. int i;
  3535. scsi_unregister_module(MODULE_SCSI_DEV, &st_template);
  3536. devfs_unregister_chrdev(SCSI_TAPE_MAJOR, "st");
  3537. st_registered--;
  3538. if (scsi_tapes != NULL) {
  3539. for (i=0; i < st_template.dev_max; ++i)
  3540. if (scsi_tapes[i])
  3541. kfree(scsi_tapes[i]);
  3542. kfree(scsi_tapes);
  3543. if (st_buffers != NULL) {
  3544. for (i = 0; i < st_nbr_buffers; i++) {
  3545. if (st_buffers[i] != NULL) {
  3546. st_buffers[i]->orig_sg_segs = 0;
  3547. normalize_buffer(st_buffers[i]);
  3548. kfree(st_buffers[i]);
  3549. }
  3550. }
  3551. kfree(st_buffers);
  3552. }
  3553. }
  3554. st_template.dev_max = 0;
  3555. printk(KERN_INFO "st: Unloaded.n");
  3556. }
  3557. module_init(init_st);
  3558. module_exit(exit_st);