git.oblomov.eu Git - linux-2.6/blob - drivers/scsi/scsi_tgt_if.c

   1 /*
   2  * SCSI target kernel/user interface functions
   3  *
   4  * Copyright (C) 2005 FUJITA Tomonori <tomof@acm.org>
   5  * Copyright (C) 2005 Mike Christie <michaelc@cs.wisc.edu>
   6  *
   7  * This program is free software; you can redistribute it and/or
   8  * modify it under the terms of the GNU General Public License as
   9  * published by the Free Software Foundation; either version 2 of the
  10  * License, or (at your option) any later version.
  11  *
  12  * This program is distributed in the hope that it will be useful, but
  13  * WITHOUT ANY WARRANTY; without even the implied warranty of
  14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  15  * General Public License for more details.
  16  *
  17  * You should have received a copy of the GNU General Public License
  18  * along with this program; if not, write to the Free Software
  19  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  20  * 02110-1301 USA
  21  */
  22 #include <linux/miscdevice.h>
  23 #include <linux/file.h>
  24 #include <net/tcp.h>
  25 #include <scsi/scsi.h>
  26 #include <scsi/scsi_cmnd.h>
  27 #include <scsi/scsi_device.h>
  28 #include <scsi/scsi_host.h>
  29 #include <scsi/scsi_tgt.h>
  30 #include <scsi/scsi_tgt_if.h>
  31
  32 #include <asm/cacheflush.h>
  33
  34 #include "scsi_tgt_priv.h"
  35
  36 struct tgt_ring {
  37         u32 tr_idx;
  38         unsigned long tr_pages[TGT_RING_PAGES];
  39         spinlock_t tr_lock;
  40 };
  41
  42 /* tx_ring : kernel->user, rx_ring : user->kernel */
  43 static struct tgt_ring tx_ring, rx_ring;
  44 static DECLARE_WAIT_QUEUE_HEAD(tgt_poll_wait);
  45
  46 static inline void tgt_ring_idx_inc(struct tgt_ring *ring)
  47 {
  48         if (ring->tr_idx == TGT_MAX_EVENTS - 1)
  49                 ring->tr_idx = 0;
  50         else
  51                 ring->tr_idx++;
  52 }
  53
  54 static struct tgt_event *tgt_head_event(struct tgt_ring *ring, u32 idx)
  55 {
  56         u32 pidx, off;
  57
  58         pidx = idx / TGT_EVENT_PER_PAGE;
  59         off = idx % TGT_EVENT_PER_PAGE;
  60
  61         return (struct tgt_event *)
  62                 (ring->tr_pages[pidx] + sizeof(struct tgt_event) * off);
  63 }
  64
  65 static int tgt_uspace_send_event(u32 type, struct tgt_event *p)
  66 {
  67         struct tgt_event *ev;
  68         struct tgt_ring *ring = &tx_ring;
  69         unsigned long flags;
  70         int err = 0;
  71
  72         spin_lock_irqsave(&ring->tr_lock, flags);
  73
  74         ev = tgt_head_event(ring, ring->tr_idx);
  75         if (!ev->hdr.status)
  76                 tgt_ring_idx_inc(ring);
  77         else
  78                 err = -BUSY;
  79
  80         spin_unlock_irqrestore(&ring->tr_lock, flags);
  81
  82         if (err)
  83                 return err;
  84
  85         memcpy(ev, p, sizeof(*ev));
  86         ev->hdr.type = type;
  87         mb();
  88         ev->hdr.status = 1;
  89
  90         flush_dcache_page(virt_to_page(ev));
  91
  92         wake_up_interruptible(&tgt_poll_wait);
  93
  94         return 0;
  95 }
  96
  97 int scsi_tgt_uspace_send_cmd(struct scsi_cmnd *cmd, struct scsi_lun *lun, u64 tag)
  98 {
  99         struct Scsi_Host *shost = scsi_tgt_cmd_to_host(cmd);
 100         struct tgt_event ev;
 101         int err;
 102
 103         memset(&ev, 0, sizeof(ev));
 104         ev.p.cmd_req.host_no = shost->host_no;
 105         ev.p.cmd_req.data_len = cmd->request_bufflen;
 106         memcpy(ev.p.cmd_req.scb, cmd->cmnd, sizeof(ev.p.cmd_req.scb));
 107         memcpy(ev.p.cmd_req.lun, lun, sizeof(ev.p.cmd_req.lun));
 108         ev.p.cmd_req.attribute = cmd->tag;
 109         ev.p.cmd_req.tag = tag;
 110
 111         dprintk("%p %d %u %x %llx\n", cmd, shost->host_no,
 112                 ev.p.cmd_req.data_len, cmd->tag,
 113                 (unsigned long long) ev.p.cmd_req.tag);
 114
 115         err = tgt_uspace_send_event(TGT_KEVENT_CMD_REQ, &ev);
 116         if (err)
 117                 eprintk("tx buf is full, could not send\n");
 118
 119         return err;
 120 }
 121
 122 int scsi_tgt_uspace_send_status(struct scsi_cmnd *cmd, u64 tag)
 123 {
 124         struct Scsi_Host *shost = scsi_tgt_cmd_to_host(cmd);
 125         struct tgt_event ev;
 126         int err;
 127
 128         memset(&ev, 0, sizeof(ev));
 129         ev.p.cmd_done.host_no = shost->host_no;
 130         ev.p.cmd_done.tag = tag;
 131         ev.p.cmd_done.result = cmd->result;
 132
 133         dprintk("%p %d %llu %u %x\n", cmd, shost->host_no,
 134                 (unsigned long long) ev.p.cmd_req.tag,
 135                 ev.p.cmd_req.data_len, cmd->tag);
 136
 137         err = tgt_uspace_send_event(TGT_KEVENT_CMD_DONE, &ev);
 138         if (err)
 139                 eprintk("tx buf is full, could not send\n");
 140
 141         return err;
 142 }
 143
 144 int scsi_tgt_uspace_send_tsk_mgmt(int host_no, int function, u64 tag,
 145                                   struct scsi_lun *scsilun, void *data)
 146 {
 147         struct tgt_event ev;
 148         int err;
 149
 150         memset(&ev, 0, sizeof(ev));
 151         ev.p.tsk_mgmt_req.host_no = host_no;
 152         ev.p.tsk_mgmt_req.function = function;
 153         ev.p.tsk_mgmt_req.tag = tag;
 154         memcpy(ev.p.tsk_mgmt_req.lun, scsilun, sizeof(ev.p.tsk_mgmt_req.lun));
 155         ev.p.tsk_mgmt_req.mid = (u64) (unsigned long) data;
 156
 157         dprintk("%d %x %llx %llx\n", host_no, function, (unsigned long long) tag,
 158                 (unsigned long long) ev.p.tsk_mgmt_req.mid);
 159
 160         err = tgt_uspace_send_event(TGT_KEVENT_TSK_MGMT_REQ, &ev);
 161         if (err)
 162                 eprintk("tx buf is full, could not send\n");
 163
 164         return err;
 165 }
 166
 167 static int event_recv_msg(struct tgt_event *ev)
 168 {
 169         int err = 0;
 170
 171         switch (ev->hdr.type) {
 172         case TGT_UEVENT_CMD_RSP:
 173                 err = scsi_tgt_kspace_exec(ev->p.cmd_rsp.host_no,
 174                                            ev->p.cmd_rsp.tag,
 175                                            ev->p.cmd_rsp.result,
 176                                            ev->p.cmd_rsp.len,
 177                                            ev->p.cmd_rsp.uaddr,
 178                                            ev->p.cmd_rsp.rw);
 179                 break;
 180         case TGT_UEVENT_TSK_MGMT_RSP:
 181                 err = scsi_tgt_kspace_tsk_mgmt(ev->p.tsk_mgmt_rsp.host_no,
 182                                                ev->p.tsk_mgmt_rsp.mid,
 183                                                ev->p.tsk_mgmt_rsp.result);
 184                 break;
 185         default:
 186                 eprintk("unknown type %d\n", ev->hdr.type);
 187                 err = -EINVAL;
 188         }
 189
 190         return err;
 191 }
 192
 193 static ssize_t tgt_write(struct file *file, const char __user * buffer,
 194                          size_t count, loff_t * ppos)
 195 {
 196         struct tgt_event *ev;
 197         struct tgt_ring *ring = &rx_ring;
 198
 199         while (1) {
 200                 ev = tgt_head_event(ring, ring->tr_idx);
 201                 /* do we need this? */
 202                 flush_dcache_page(virt_to_page(ev));
 203
 204                 if (!ev->hdr.status)
 205                         break;
 206
 207                 tgt_ring_idx_inc(ring);
 208                 event_recv_msg(ev);
 209                 ev->hdr.status = 0;
 210         };
 211
 212         return count;
 213 }
 214
 215 static unsigned int tgt_poll(struct file * file, struct poll_table_struct *wait)
 216 {
 217         struct tgt_event *ev;
 218         struct tgt_ring *ring = &tx_ring;
 219         unsigned long flags;
 220         unsigned int mask = 0;
 221         u32 idx;
 222
 223         poll_wait(file, &tgt_poll_wait, wait);
 224
 225         spin_lock_irqsave(&ring->tr_lock, flags);
 226
 227         idx = ring->tr_idx ? ring->tr_idx - 1 : TGT_MAX_EVENTS - 1;
 228         ev = tgt_head_event(ring, idx);
 229         if (ev->hdr.status)
 230                 mask |= POLLIN | POLLRDNORM;
 231
 232         spin_unlock_irqrestore(&ring->tr_lock, flags);
 233
 234         return mask;
 235 }
 236
 237 static int uspace_ring_map(struct vm_area_struct *vma, unsigned long addr,
 238                            struct tgt_ring *ring)
 239 {
 240         int i, err;
 241
 242         for (i = 0; i < TGT_RING_PAGES; i++) {
 243                 struct page *page = virt_to_page(ring->tr_pages[i]);
 244                 err = vm_insert_page(vma, addr, page);
 245                 if (err)
 246                         return err;
 247                 addr += PAGE_SIZE;
 248         }
 249
 250         return 0;
 251 }
 252
 253 static int tgt_mmap(struct file *filp, struct vm_area_struct *vma)
 254 {
 255         unsigned long addr;
 256         int err;
 257
 258         if (vma->vm_pgoff)
 259                 return -EINVAL;
 260
 261         if (vma->vm_end - vma->vm_start != TGT_RING_SIZE * 2) {
 262                 eprintk("mmap size must be %lu, not %lu \n",
 263                         TGT_RING_SIZE * 2, vma->vm_end - vma->vm_start);
 264                 return -EINVAL;
 265         }
 266
 267         addr = vma->vm_start;
 268         err = uspace_ring_map(vma, addr, &tx_ring);
 269         if (err)
 270                 return err;
 271         err = uspace_ring_map(vma, addr + TGT_RING_SIZE, &rx_ring);
 272
 273         return err;
 274 }
 275
 276 static int tgt_open(struct inode *inode, struct file *file)
 277 {
 278         tx_ring.tr_idx = rx_ring.tr_idx = 0;
 279
 280         return 0;
 281 }
 282
 283 static struct file_operations tgt_fops = {
 284         .owner          = THIS_MODULE,
 285         .open           = tgt_open,
 286         .poll           = tgt_poll,
 287         .write          = tgt_write,
 288         .mmap           = tgt_mmap,
 289 };
 290
 291 static struct miscdevice tgt_miscdev = {
 292         .minor = MISC_DYNAMIC_MINOR,
 293         .name = "tgt",
 294         .fops = &tgt_fops,
 295 };
 296
 297 static void tgt_ring_exit(struct tgt_ring *ring)
 298 {
 299         int i;
 300
 301         for (i = 0; i < TGT_RING_PAGES; i++)
 302                 free_page(ring->tr_pages[i]);
 303 }
 304
 305 static int tgt_ring_init(struct tgt_ring *ring)
 306 {
 307         int i;
 308
 309         spin_lock_init(&ring->tr_lock);
 310
 311         for (i = 0; i < TGT_RING_PAGES; i++) {
 312                 ring->tr_pages[i] = get_zeroed_page(GFP_KERNEL);
 313                 if (!ring->tr_pages[i]) {
 314                         eprintk("out of memory\n");
 315                         return -ENOMEM;
 316                 }
 317         }
 318
 319         return 0;
 320 }
 321
 322 void scsi_tgt_if_exit(void)
 323 {
 324         tgt_ring_exit(&tx_ring);
 325         tgt_ring_exit(&rx_ring);
 326         misc_deregister(&tgt_miscdev);
 327 }
 328
 329 int scsi_tgt_if_init(void)
 330 {
 331         int err;
 332
 333         err = tgt_ring_init(&tx_ring);
 334         if (err)
 335                 return err;
 336
 337         err = tgt_ring_init(&rx_ring);
 338         if (err)
 339                 goto free_tx_ring;
 340
 341         err = misc_register(&tgt_miscdev);
 342         if (err)
 343                 goto free_rx_ring;
 344
 345         return 0;
 346 free_rx_ring:
 347         tgt_ring_exit(&rx_ring);
 348 free_tx_ring:
 349         tgt_ring_exit(&tx_ring);
 350
 351         return err;
 352 }