contrib/vhost-user-scsi/vhost-user-scsi.c

   1 /*
   2  * vhost-user-scsi sample application
   3  *
   4  * Copyright (c) 2016 Nutanix Inc. All rights reserved.
   5  *
   6  * Author:
   7  *  Felipe Franciosi <felipe@nutanix.com>
   8  *
   9  * This work is licensed under the terms of the GNU GPL, version 2 only.
  10  * See the COPYING file in the top-level directory.
  11  */
  12
  13 #include "qemu/osdep.h"
  14 #include "contrib/libvhost-user/libvhost-user.h"
  15 #include "hw/virtio/virtio-scsi.h"
  16 #include "iscsi/iscsi.h"
  17
  18 #include <glib.h>
  19
  20 /* #define VUS_DEBUG 1 */
  21
  22 /** Log helpers **/
  23
  24 #define PPRE                                                          \
  25     struct timespec ts;                                               \
  26     char   timebuf[64];                                               \
  27     struct tm tm;                                                     \
  28     (void)clock_gettime(CLOCK_REALTIME, &ts);                         \
  29     (void)strftime(timebuf, 64, "%Y%m%d %T", gmtime_r(&ts.tv_sec, &tm))
  30
  31 #define PEXT(lvl, msg, ...) do {                                      \
  32     PPRE;                                                             \
  33     fprintf(stderr, "%s.%06ld " lvl ": %s:%s():%d: " msg "\n",        \
  34             timebuf, ts.tv_nsec / 1000,                               \
  35             __FILE__, __func__, __LINE__, ## __VA_ARGS__);            \
  36 } while (0)
  37
  38 #define PNOR(lvl, msg, ...) do {                                      \
  39     PPRE;                                                             \
  40     fprintf(stderr, "%s.%06ld " lvl ": " msg "\n",                    \
  41             timebuf, ts.tv_nsec / 1000, ## __VA_ARGS__);              \
  42 } while (0)
  43
  44 #ifdef VUS_DEBUG
  45 #define PDBG(msg, ...) PEXT("DBG", msg, ## __VA_ARGS__)
  46 #define PERR(msg, ...) PEXT("ERR", msg, ## __VA_ARGS__)
  47 #define PLOG(msg, ...) PEXT("LOG", msg, ## __VA_ARGS__)
  48 #else
  49 #define PDBG(msg, ...) { }
  50 #define PERR(msg, ...) PNOR("ERR", msg, ## __VA_ARGS__)
  51 #define PLOG(msg, ...) PNOR("LOG", msg, ## __VA_ARGS__)
  52 #endif
  53
  54 /** vhost-user-scsi specific definitions **/
  55
  56  /* Only 1 LUN and device supported today */
  57 #define VUS_MAX_LUNS 1
  58 #define VUS_ISCSI_INITIATOR "iqn.2016-11.com.nutanix:vhost-user-scsi"
  59
  60 typedef struct iscsi_lun {
  61     struct iscsi_context *iscsi_ctx;
  62     int iscsi_lun;
  63 } iscsi_lun_t;
  64
  65 typedef struct vhost_scsi_dev {
  66     VuDev vu_dev;
  67     int server_sock;
  68     GMainLoop *loop;
  69     GTree *fdmap;   /* fd -> gsource context id */
  70     iscsi_lun_t luns[VUS_MAX_LUNS];
  71 } vhost_scsi_dev_t;
  72
  73 /** glib event loop integration for libvhost-user and misc callbacks **/
  74
  75 QEMU_BUILD_BUG_ON((int)G_IO_IN != (int)VU_WATCH_IN);
  76 QEMU_BUILD_BUG_ON((int)G_IO_OUT != (int)VU_WATCH_OUT);
  77 QEMU_BUILD_BUG_ON((int)G_IO_PRI != (int)VU_WATCH_PRI);
  78 QEMU_BUILD_BUG_ON((int)G_IO_ERR != (int)VU_WATCH_ERR);
  79 QEMU_BUILD_BUG_ON((int)G_IO_HUP != (int)VU_WATCH_HUP);
  80
  81 typedef struct vus_gsrc {
  82     GSource parent;
  83     vhost_scsi_dev_t *vdev_scsi;
  84     GPollFD gfd;
  85     vu_watch_cb vu_cb;
  86 } vus_gsrc_t;
  87
  88 static gint vus_fdmap_compare(gconstpointer a, gconstpointer b)
  89 {
  90     return (b > a) - (b < a);
  91 }
  92
  93 static gboolean vus_gsrc_prepare(GSource *src, gint *timeout)
  94 {
  95     assert(timeout);
  96
  97     *timeout = -1;
  98     return FALSE;
  99 }
 100
 101 static gboolean vus_gsrc_check(GSource *src)
 102 {
 103     vus_gsrc_t *vus_src = (vus_gsrc_t *)src;
 104
 105     assert(vus_src);
 106
 107     return vus_src->gfd.revents & vus_src->gfd.events;
 108 }
 109
 110 static gboolean vus_gsrc_dispatch(GSource *src, GSourceFunc cb, gpointer data)
 111 {
 112     vhost_scsi_dev_t *vdev_scsi;
 113     vus_gsrc_t *vus_src = (vus_gsrc_t *)src;
 114
 115     assert(vus_src);
 116     assert(!(vus_src->vu_cb && cb));
 117
 118     vdev_scsi = vus_src->vdev_scsi;
 119
 120     assert(vdev_scsi);
 121
 122     if (cb) {
 123         return cb(data);
 124     }
 125     if (vus_src->vu_cb) {
 126         vus_src->vu_cb(&vdev_scsi->vu_dev, vus_src->gfd.revents, data);
 127     }
 128     return G_SOURCE_CONTINUE;
 129 }
 130
 131 static GSourceFuncs vus_gsrc_funcs = {
 132     vus_gsrc_prepare,
 133     vus_gsrc_check,
 134     vus_gsrc_dispatch,
 135     NULL
 136 };
 137
 138 static void vus_gsrc_new(vhost_scsi_dev_t *vdev_scsi, int fd, GIOCondition cond,
 139                          vu_watch_cb vu_cb, GSourceFunc gsrc_cb, gpointer data)
 140 {
 141     GSource *vus_gsrc;
 142     vus_gsrc_t *vus_src;
 143     guint id;
 144
 145     assert(vdev_scsi);
 146     assert(fd >= 0);
 147     assert(vu_cb || gsrc_cb);
 148     assert(!(vu_cb && gsrc_cb));
 149
 150     vus_gsrc = g_source_new(&vus_gsrc_funcs, sizeof(vus_gsrc_t));
 151     vus_src = (vus_gsrc_t *)vus_gsrc;
 152
 153     vus_src->vdev_scsi = vdev_scsi;
 154     vus_src->gfd.fd = fd;
 155     vus_src->gfd.events = cond;
 156     vus_src->vu_cb = vu_cb;
 157
 158     g_source_add_poll(vus_gsrc, &vus_src->gfd);
 159     g_source_set_callback(vus_gsrc, gsrc_cb, data, NULL);
 160     id = g_source_attach(vus_gsrc, NULL);
 161     assert(id);
 162     g_source_unref(vus_gsrc);
 163
 164     g_tree_insert(vdev_scsi->fdmap, (gpointer)(uintptr_t)fd,
 165                                     (gpointer)(uintptr_t)id);
 166 }
 167
 168 /* from libiscsi's scsi-lowlevel.h **
 169  *
 170  * nb. We can't directly include scsi-lowlevel.h due to a namespace conflict:
 171  *     QEMU's scsi.h also defines "SCSI_XFER_NONE".
 172  */
 173
 174 #define SCSI_CDB_MAX_SIZE           16
 175
 176 struct scsi_iovector {
 177     struct scsi_iovec *iov;
 178     int niov;
 179     int nalloc;
 180     size_t offset;
 181     int consumed;
 182 };
 183
 184 struct scsi_allocated_memory {
 185     struct scsi_allocated_memory *next;
 186     char buf[0];
 187 };
 188
 189 struct scsi_data {
 190     int            size;
 191     unsigned char *data;
 192 };
 193
 194 enum scsi_sense_key {
 195     SCSI_SENSE_NO_SENSE            = 0x00,
 196     SCSI_SENSE_RECOVERED_ERROR     = 0x01,
 197     SCSI_SENSE_NOT_READY           = 0x02,
 198     SCSI_SENSE_MEDIUM_ERROR        = 0x03,
 199     SCSI_SENSE_HARDWARE_ERROR      = 0x04,
 200     SCSI_SENSE_ILLEGAL_REQUEST     = 0x05,
 201     SCSI_SENSE_UNIT_ATTENTION      = 0x06,
 202     SCSI_SENSE_DATA_PROTECTION     = 0x07,
 203     SCSI_SENSE_BLANK_CHECK         = 0x08,
 204     SCSI_SENSE_VENDOR_SPECIFIC     = 0x09,
 205     SCSI_SENSE_COPY_ABORTED        = 0x0a,
 206     SCSI_SENSE_COMMAND_ABORTED     = 0x0b,
 207     SCSI_SENSE_OBSOLETE_ERROR_CODE = 0x0c,
 208     SCSI_SENSE_OVERFLOW_COMMAND    = 0x0d,
 209     SCSI_SENSE_MISCOMPARE          = 0x0e
 210 };
 211
 212 struct scsi_sense {
 213     unsigned char       error_type;
 214     enum scsi_sense_key key;
 215     int                 ascq;
 216     unsigned            sense_specific:1;
 217     unsigned            ill_param_in_cdb:1;
 218     unsigned            bit_pointer_valid:1;
 219     unsigned char       bit_pointer;
 220     uint16_t            field_pointer;
 221 };
 222
 223 enum scsi_residual {
 224     SCSI_RESIDUAL_NO_RESIDUAL = 0,
 225     SCSI_RESIDUAL_UNDERFLOW,
 226     SCSI_RESIDUAL_OVERFLOW
 227 };
 228
 229 struct scsi_task {
 230     int status;
 231     int cdb_size;
 232     int xfer_dir;
 233     int expxferlen;
 234     unsigned char cdb[SCSI_CDB_MAX_SIZE];
 235     enum scsi_residual residual_status;
 236     size_t residual;
 237     struct scsi_sense sense;
 238     struct scsi_data datain;
 239     struct scsi_allocated_memory *mem;
 240     void *ptr;
 241
 242     uint32_t itt;
 243     uint32_t cmdsn;
 244     uint32_t lun;
 245
 246     struct scsi_iovector iovector_in;
 247     struct scsi_iovector iovector_out;
 248 };
 249
 250 /** libiscsi integration **/
 251
 252 static int iscsi_add_lun(iscsi_lun_t *lun, char *iscsi_uri)
 253 {
 254     struct iscsi_url *iscsi_url;
 255     struct iscsi_context *iscsi_ctx;
 256     int ret = 0;
 257
 258     assert(lun);
 259     assert(iscsi_uri);
 260
 261     iscsi_ctx = iscsi_create_context(VUS_ISCSI_INITIATOR);
 262     if (!iscsi_ctx) {
 263         PERR("Unable to create iSCSI context");
 264         return -1;
 265     }
 266
 267     iscsi_url = iscsi_parse_full_url(iscsi_ctx, iscsi_uri);
 268     if (!iscsi_url) {
 269         PERR("Unable to parse iSCSI URL: %s", iscsi_get_error(iscsi_ctx));
 270         goto fail;
 271     }
 272
 273     iscsi_set_session_type(iscsi_ctx, ISCSI_SESSION_NORMAL);
 274     iscsi_set_header_digest(iscsi_ctx, ISCSI_HEADER_DIGEST_NONE_CRC32C);
 275     if (iscsi_full_connect_sync(iscsi_ctx, iscsi_url->portal, iscsi_url->lun)) {
 276         PERR("Unable to login to iSCSI portal: %s", iscsi_get_error(iscsi_ctx));
 277         goto fail;
 278     }
 279
 280     lun->iscsi_ctx = iscsi_ctx;
 281     lun->iscsi_lun = iscsi_url->lun;
 282
 283     PDBG("Context %p created for lun 0: %s", iscsi_ctx, iscsi_uri);
 284
 285 out:
 286     if (iscsi_url) {
 287         iscsi_destroy_url(iscsi_url);
 288     }
 289     return ret;
 290
 291 fail:
 292     (void)iscsi_destroy_context(iscsi_ctx);
 293     ret = -1;
 294     goto out;
 295 }
 296
 297 static struct scsi_task *scsi_task_new(int cdb_len, uint8_t *cdb, int dir,
 298                                        int xfer_len)
 299 {
 300     struct scsi_task *task;
 301
 302     assert(cdb_len > 0);
 303     assert(cdb);
 304
 305     task = g_new0(struct scsi_task, 1);
 306     memcpy(task->cdb, cdb, cdb_len);
 307     task->cdb_size = cdb_len;
 308     task->xfer_dir = dir;
 309     task->expxferlen = xfer_len;
 310
 311     return task;
 312 }
 313
 314 static int get_cdb_len(uint8_t *cdb)
 315 {
 316     assert(cdb);
 317
 318     switch (cdb[0] >> 5) {
 319     case 0: return 6;
 320     case 1: /* fall through */
 321     case 2: return 10;
 322     case 4: return 16;
 323     case 5: return 12;
 324     }
 325     PERR("Unable to determine cdb len (0x%02hhX)", cdb[0] >> 5);
 326     return -1;
 327 }
 328
 329 static int handle_cmd_sync(struct iscsi_context *ctx,
 330                            VirtIOSCSICmdReq *req,
 331                            struct iovec *out, unsigned int out_len,
 332                            VirtIOSCSICmdResp *rsp,
 333                            struct iovec *in, unsigned int in_len)
 334 {
 335     struct scsi_task *task;
 336     uint32_t dir;
 337     uint32_t len;
 338     int cdb_len;
 339     int i;
 340
 341     assert(ctx);
 342     assert(req);
 343     assert(rsp);
 344
 345     if (!(!req->lun[1] && req->lun[2] == 0x40 && !req->lun[3])) {
 346         /* Ignore anything different than target=0, lun=0 */
 347         PDBG("Ignoring unconnected lun (0x%hhX, 0x%hhX)",
 348              req->lun[1], req->lun[3]);
 349         rsp->status = SCSI_STATUS_CHECK_CONDITION;
 350         memset(rsp->sense, 0, sizeof(rsp->sense));
 351         rsp->sense_len = 18;
 352         rsp->sense[0] = 0x70;
 353         rsp->sense[2] = SCSI_SENSE_ILLEGAL_REQUEST;
 354         rsp->sense[7] = 10;
 355         rsp->sense[12] = 0x24;
 356
 357         return 0;
 358     }
 359
 360     cdb_len = get_cdb_len(req->cdb);
 361     if (cdb_len == -1) {
 362         return -1;
 363     }
 364
 365     len = 0;
 366     if (!out_len && !in_len) {
 367         dir = SCSI_XFER_NONE;
 368     } else if (out_len) {
 369         dir = SCSI_XFER_TO_DEV;
 370         for (i = 0; i < out_len; i++) {
 371             len += out[i].iov_len;
 372         }
 373     } else {
 374         dir = SCSI_XFER_FROM_DEV;
 375         for (i = 0; i < in_len; i++) {
 376             len += in[i].iov_len;
 377         }
 378     }
 379
 380     task = scsi_task_new(cdb_len, req->cdb, dir, len);
 381
 382     if (dir == SCSI_XFER_TO_DEV) {
 383         task->iovector_out.iov = (struct scsi_iovec *)out;
 384         task->iovector_out.niov = out_len;
 385     } else if (dir == SCSI_XFER_FROM_DEV) {
 386         task->iovector_in.iov = (struct scsi_iovec *)in;
 387         task->iovector_in.niov = in_len;
 388     }
 389
 390     PDBG("Sending iscsi cmd (cdb_len=%d, dir=%d, task=%p)",
 391          cdb_len, dir, task);
 392     if (!iscsi_scsi_command_sync(ctx, 0, task, NULL)) {
 393         PERR("Error serving SCSI command");
 394         g_free(task);
 395         return -1;
 396     }
 397
 398     memset(rsp, 0, sizeof(*rsp));
 399
 400     rsp->status = task->status;
 401     rsp->resid  = task->residual;
 402
 403     if (task->status == SCSI_STATUS_CHECK_CONDITION) {
 404         rsp->response = VIRTIO_SCSI_S_FAILURE;
 405         rsp->sense_len = task->datain.size - 2;
 406         memcpy(rsp->sense, &task->datain.data[2], rsp->sense_len);
 407     }
 408
 409     g_free(task);
 410
 411     PDBG("Filled in rsp: status=%hhX, resid=%u, response=%hhX, sense_len=%u",
 412          rsp->status, rsp->resid, rsp->response, rsp->sense_len);
 413
 414     return 0;
 415 }
 416
 417 /** libvhost-user callbacks **/
 418
 419 static void vus_panic_cb(VuDev *vu_dev, const char *buf)
 420 {
 421     vhost_scsi_dev_t *vdev_scsi;
 422
 423     assert(vu_dev);
 424
 425     vdev_scsi = container_of(vu_dev, vhost_scsi_dev_t, vu_dev);
 426     if (buf) {
 427         PERR("vu_panic: %s", buf);
 428     }
 429
 430     g_main_loop_quit(vdev_scsi->loop);
 431 }
 432
 433 static void vus_add_watch_cb(VuDev *vu_dev, int fd, int vu_evt, vu_watch_cb cb,
 434                              void *pvt)
 435 {
 436     vhost_scsi_dev_t *vdev_scsi;
 437     guint id;
 438
 439     assert(vu_dev);
 440     assert(fd >= 0);
 441     assert(cb);
 442
 443     vdev_scsi = container_of(vu_dev, vhost_scsi_dev_t, vu_dev);
 444     id = (guint)(uintptr_t)g_tree_lookup(vdev_scsi->fdmap,
 445                                          (gpointer)(uintptr_t)fd);
 446     if (id) {
 447         GSource *vus_src = g_main_context_find_source_by_id(NULL, id);
 448         assert(vus_src);
 449         g_source_destroy(vus_src);
 450         (void)g_tree_remove(vdev_scsi->fdmap, (gpointer)(uintptr_t)fd);
 451     }
 452
 453     vus_gsrc_new(vdev_scsi, fd, vu_evt, cb, NULL, pvt);
 454 }
 455
 456 static void vus_del_watch_cb(VuDev *vu_dev, int fd)
 457 {
 458     vhost_scsi_dev_t *vdev_scsi;
 459     guint id;
 460
 461     assert(vu_dev);
 462     assert(fd >= 0);
 463
 464     vdev_scsi = container_of(vu_dev, vhost_scsi_dev_t, vu_dev);
 465     id = (guint)(uintptr_t)g_tree_lookup(vdev_scsi->fdmap,
 466                                          (gpointer)(uintptr_t)fd);
 467     if (id) {
 468         GSource *vus_src = g_main_context_find_source_by_id(NULL, id);
 469         assert(vus_src);
 470         g_source_destroy(vus_src);
 471         (void)g_tree_remove(vdev_scsi->fdmap, (gpointer)(uintptr_t)fd);
 472     }
 473 }
 474
 475 static void vus_proc_ctl(VuDev *vu_dev, int idx)
 476 {
 477     /* Control VQ not implemented */
 478 }
 479
 480 static void vus_proc_evt(VuDev *vu_dev, int idx)
 481 {
 482     /* Event VQ not implemented */
 483 }
 484
 485 static void vus_proc_req(VuDev *vu_dev, int idx)
 486 {
 487     vhost_scsi_dev_t *vdev_scsi;
 488     VuVirtq *vq;
 489
 490     assert(vu_dev);
 491
 492     vdev_scsi = container_of(vu_dev, vhost_scsi_dev_t, vu_dev);
 493     if (idx < 0 || idx >= VHOST_MAX_NR_VIRTQUEUE) {
 494         PERR("VQ Index out of range: %d", idx);
 495         vus_panic_cb(vu_dev, NULL);
 496         return;
 497     }
 498
 499     vq = vu_get_queue(vu_dev, idx);
 500     if (!vq) {
 501         PERR("Error fetching VQ (dev=%p, idx=%d)", vu_dev, idx);
 502         vus_panic_cb(vu_dev, NULL);
 503         return;
 504     }
 505
 506     PDBG("Got kicked on vq[%d]@%p", idx, vq);
 507
 508     while (1) {
 509         VuVirtqElement *elem;
 510         VirtIOSCSICmdReq *req;
 511         VirtIOSCSICmdResp *rsp;
 512
 513         elem = vu_queue_pop(vu_dev, vq, sizeof(VuVirtqElement));
 514         if (!elem) {
 515             PDBG("No more elements pending on vq[%d]@%p", idx, vq);
 516             break;
 517         }
 518         PDBG("Popped elem@%p", elem);
 519
 520         assert(!(elem->out_num > 1 && elem->in_num > 1));
 521         assert(elem->out_num > 0 && elem->in_num > 0);
 522
 523         if (elem->out_sg[0].iov_len < sizeof(VirtIOSCSICmdReq)) {
 524             PERR("Invalid virtio-scsi req header");
 525             vus_panic_cb(vu_dev, NULL);
 526             break;
 527         }
 528         req = (VirtIOSCSICmdReq *)elem->out_sg[0].iov_base;
 529
 530         if (elem->in_sg[0].iov_len < sizeof(VirtIOSCSICmdResp)) {
 531             PERR("Invalid virtio-scsi rsp header");
 532             vus_panic_cb(vu_dev, NULL);
 533             break;
 534         }
 535         rsp = (VirtIOSCSICmdResp *)elem->in_sg[0].iov_base;
 536
 537         if (handle_cmd_sync(vdev_scsi->luns[0].iscsi_ctx,
 538                             req, &elem->out_sg[1], elem->out_num - 1,
 539                             rsp, &elem->in_sg[1], elem->in_num - 1) != 0) {
 540             vus_panic_cb(vu_dev, NULL);
 541             break;
 542         }
 543
 544         vu_queue_push(vu_dev, vq, elem, 0);
 545         vu_queue_notify(vu_dev, vq);
 546
 547         free(elem);
 548     }
 549 }
 550
 551 static void vus_queue_set_started(VuDev *vu_dev, int idx, bool started)
 552 {
 553     VuVirtq *vq;
 554
 555     assert(vu_dev);
 556
 557     if (idx < 0 || idx >= VHOST_MAX_NR_VIRTQUEUE) {
 558         PERR("VQ Index out of range: %d", idx);
 559         vus_panic_cb(vu_dev, NULL);
 560         return;
 561     }
 562
 563     vq = vu_get_queue(vu_dev, idx);
 564
 565     switch (idx) {
 566     case 0:
 567         vu_set_queue_handler(vu_dev, vq, started ? vus_proc_ctl : NULL);
 568         break;
 569     case 1:
 570         vu_set_queue_handler(vu_dev, vq, started ? vus_proc_evt : NULL);
 571         break;
 572     default:
 573         vu_set_queue_handler(vu_dev, vq, started ? vus_proc_req : NULL);
 574     }
 575 }
 576
 577 static const VuDevIface vus_iface = {
 578     .queue_set_started = vus_queue_set_started,
 579 };
 580
 581 static gboolean vus_vhost_cb(gpointer data)
 582 {
 583     VuDev *vu_dev = (VuDev *)data;
 584
 585     assert(vu_dev);
 586
 587     if (!vu_dispatch(vu_dev) != 0) {
 588         PERR("Error processing vhost message");
 589         vus_panic_cb(vu_dev, NULL);
 590         return G_SOURCE_REMOVE;
 591     }
 592
 593     return G_SOURCE_CONTINUE;
 594 }
 595
 596 /** misc helpers **/
 597
 598 static int unix_sock_new(char *unix_fn)
 599 {
 600     int sock;
 601     struct sockaddr_un un;
 602     size_t len;
 603
 604     assert(unix_fn);
 605
 606     sock = socket(AF_UNIX, SOCK_STREAM, 0);
 607     if (sock <= 0) {
 608         perror("socket");
 609         return -1;
 610     }
 611
 612     un.sun_family = AF_UNIX;
 613     (void)snprintf(un.sun_path, sizeof(un.sun_path), "%s", unix_fn);
 614     len = sizeof(un.sun_family) + strlen(un.sun_path);
 615
 616     (void)unlink(unix_fn);
 617     if (bind(sock, (struct sockaddr *)&un, len) < 0) {
 618         perror("bind");
 619         goto fail;
 620     }
 621
 622     if (listen(sock, 1) < 0) {
 623         perror("listen");
 624         goto fail;
 625     }
 626
 627     return sock;
 628
 629 fail:
 630     (void)close(sock);
 631
 632     return -1;
 633 }
 634
 635 /** vhost-user-scsi **/
 636
 637 static void vdev_scsi_free(vhost_scsi_dev_t *vdev_scsi)
 638 {
 639     if (vdev_scsi->server_sock >= 0) {
 640         close(vdev_scsi->server_sock);
 641     }
 642     g_main_loop_unref(vdev_scsi->loop);
 643     g_tree_destroy(vdev_scsi->fdmap);
 644     g_free(vdev_scsi);
 645 }
 646
 647 static vhost_scsi_dev_t *vdev_scsi_new(int server_sock)
 648 {
 649     vhost_scsi_dev_t *vdev_scsi;
 650
 651     vdev_scsi = g_new0(vhost_scsi_dev_t, 1);
 652     vdev_scsi->server_sock = server_sock;
 653     vdev_scsi->loop = g_main_loop_new(NULL, FALSE);
 654     vdev_scsi->fdmap = g_tree_new(vus_fdmap_compare);
 655
 656     return vdev_scsi;
 657 }
 658
 659 static int vdev_scsi_add_iscsi_lun(vhost_scsi_dev_t *vdev_scsi,
 660                                    char *iscsi_uri, uint32_t lun)
 661 {
 662     assert(vdev_scsi);
 663     assert(iscsi_uri);
 664     assert(lun < VUS_MAX_LUNS);
 665
 666     if (vdev_scsi->luns[lun].iscsi_ctx) {
 667         PERR("Lun %d already configured", lun);
 668         return -1;
 669     }
 670
 671     if (iscsi_add_lun(&vdev_scsi->luns[lun], iscsi_uri) != 0) {
 672         return -1;
 673     }
 674
 675     return 0;
 676 }
 677
 678 static int vdev_scsi_run(vhost_scsi_dev_t *vdev_scsi)
 679 {
 680     int cli_sock;
 681     int ret = 0;
 682
 683     assert(vdev_scsi);
 684     assert(vdev_scsi->server_sock >= 0);
 685     assert(vdev_scsi->loop);
 686
 687     cli_sock = accept(vdev_scsi->server_sock, (void *)0, (void *)0);
 688     if (cli_sock < 0) {
 689         perror("accept");
 690         return -1;
 691     }
 692
 693     vu_init(&vdev_scsi->vu_dev,
 694             cli_sock,
 695             vus_panic_cb,
 696             vus_add_watch_cb,
 697             vus_del_watch_cb,
 698             &vus_iface);
 699
 700     vus_gsrc_new(vdev_scsi, cli_sock, G_IO_IN, NULL, vus_vhost_cb,
 701                  &vdev_scsi->vu_dev);
 702
 703     g_main_loop_run(vdev_scsi->loop);
 704
 705     vu_deinit(&vdev_scsi->vu_dev);
 706
 707     return ret;
 708 }
 709
 710 int main(int argc, char **argv)
 711 {
 712     vhost_scsi_dev_t *vdev_scsi = NULL;
 713     char *unix_fn = NULL;
 714     char *iscsi_uri = NULL;
 715     int sock, opt, err = EXIT_SUCCESS;
 716
 717     while ((opt = getopt(argc, argv, "u:i:")) != -1) {
 718         switch (opt) {
 719         case 'h':
 720             goto help;
 721         case 'u':
 722             unix_fn = g_strdup(optarg);
 723             break;
 724         case 'i':
 725             iscsi_uri = g_strdup(optarg);
 726             break;
 727         default:
 728             goto help;
 729         }
 730     }
 731     if (!unix_fn || !iscsi_uri) {
 732         goto help;
 733     }
 734
 735     sock = unix_sock_new(unix_fn);
 736     if (sock < 0) {
 737         goto err;
 738     }
 739     vdev_scsi = vdev_scsi_new(sock);
 740
 741     if (vdev_scsi_add_iscsi_lun(vdev_scsi, iscsi_uri, 0) != 0) {
 742         goto err;
 743     }
 744
 745     if (vdev_scsi_run(vdev_scsi) != 0) {
 746         goto err;
 747     }
 748
 749 out:
 750     if (vdev_scsi) {
 751         vdev_scsi_free(vdev_scsi);
 752         unlink(unix_fn);
 753     }
 754     g_free(unix_fn);
 755     g_free(iscsi_uri);
 756
 757     return err;
 758
 759 err:
 760     err = EXIT_FAILURE;
 761     goto out;
 762
 763 help:
 764     fprintf(stderr, "Usage: %s [ -u unix_sock_path -i iscsi_uri ] | [ -h ]\n",
 765             argv[0]);
 766     fprintf(stderr, "          -u path to unix socket\n");
 767     fprintf(stderr, "          -i iscsi uri for lun 0\n");
 768     fprintf(stderr, "          -h print help and quit\n");
 769
 770     goto err;
 771 }