tests/vhost-user-bridge.c

   1 /*
   2  * Vhost User Bridge
   3  *
   4  * Copyright (c) 2015 Red Hat, Inc.
   5  *
   6  * Authors:
   7  *  Victor Kaplansky <victork@redhat.com>
   8  *
   9  * This work is licensed under the terms of the GNU GPL, version 2 or
  10  * later.  See the COPYING file in the top-level directory.
  11  */
  12
  13 /*
  14  * TODO:
  15  *     - main should get parameters from the command line.
  16  *     - implement all request handlers. Still not implemented:
  17  *          vubr_get_queue_num_exec()
  18  *          vubr_send_rarp_exec()
  19  *     - test for broken requests and virtqueue.
  20  *     - implement features defined by Virtio 1.0 spec.
  21  *     - support mergeable buffers and indirect descriptors.
  22  *     - implement clean shutdown.
  23  *     - implement non-blocking writes to UDP backend.
  24  *     - implement polling strategy.
  25  *     - implement clean starting/stopping of vq processing
  26  *     - implement clean starting/stopping of used and buffers
  27  *       dirty page logging.
  28  */
  29
  30 #define _FILE_OFFSET_BITS 64
  31
  32 #include "qemu/atomic.h"
  33 #include "qemu/osdep.h"
  34 #include "qemu/iov.h"
  35 #include "standard-headers/linux/virtio_net.h"
  36 #include "contrib/libvhost-user/libvhost-user.h"
  37
  38 #define VHOST_USER_BRIDGE_DEBUG 1
  39
  40 #define DPRINT(...) \
  41     do { \
  42         if (VHOST_USER_BRIDGE_DEBUG) { \
  43             printf(__VA_ARGS__); \
  44         } \
  45     } while (0)
  46
  47 typedef void (*CallbackFunc)(int sock, void *ctx);
  48
  49 typedef struct Event {
  50     void *ctx;
  51     CallbackFunc callback;
  52 } Event;
  53
  54 typedef struct Dispatcher {
  55     int max_sock;
  56     fd_set fdset;
  57     Event events[FD_SETSIZE];
  58 } Dispatcher;
  59
  60 typedef struct VubrDev {
  61     VuDev vudev;
  62     Dispatcher dispatcher;
  63     int backend_udp_sock;
  64     struct sockaddr_in backend_udp_dest;
  65     int hdrlen;
  66     int sock;
  67     int ready;
  68     int quit;
  69     struct {
  70         int fd;
  71         void *addr;
  72         pthread_t thread;
  73     } notifier;
  74 } VubrDev;
  75
  76 static void
  77 vubr_die(const char *s)
  78 {
  79     perror(s);
  80     exit(1);
  81 }
  82
  83 static int
  84 dispatcher_init(Dispatcher *dispr)
  85 {
  86     FD_ZERO(&dispr->fdset);
  87     dispr->max_sock = -1;
  88     return 0;
  89 }
  90
  91 static int
  92 dispatcher_add(Dispatcher *dispr, int sock, void *ctx, CallbackFunc cb)
  93 {
  94     if (sock >= FD_SETSIZE) {
  95         fprintf(stderr,
  96                 "Error: Failed to add new event. sock %d should be less than %d\n",
  97                 sock, FD_SETSIZE);
  98         return -1;
  99     }
 100
 101     dispr->events[sock].ctx = ctx;
 102     dispr->events[sock].callback = cb;
 103
 104     FD_SET(sock, &dispr->fdset);
 105     if (sock > dispr->max_sock) {
 106         dispr->max_sock = sock;
 107     }
 108     DPRINT("Added sock %d for watching. max_sock: %d\n",
 109            sock, dispr->max_sock);
 110     return 0;
 111 }
 112
 113 static int
 114 dispatcher_remove(Dispatcher *dispr, int sock)
 115 {
 116     if (sock >= FD_SETSIZE) {
 117         fprintf(stderr,
 118                 "Error: Failed to remove event. sock %d should be less than %d\n",
 119                 sock, FD_SETSIZE);
 120         return -1;
 121     }
 122
 123     FD_CLR(sock, &dispr->fdset);
 124     DPRINT("Sock %d removed from dispatcher watch.\n", sock);
 125     return 0;
 126 }
 127
 128 /* timeout in us */
 129 static int
 130 dispatcher_wait(Dispatcher *dispr, uint32_t timeout)
 131 {
 132     struct timeval tv;
 133     tv.tv_sec = timeout / 1000000;
 134     tv.tv_usec = timeout % 1000000;
 135
 136     fd_set fdset = dispr->fdset;
 137
 138     /* wait until some of sockets become readable. */
 139     int rc = select(dispr->max_sock + 1, &fdset, 0, 0, &tv);
 140
 141     if (rc == -1) {
 142         vubr_die("select");
 143     }
 144
 145     /* Timeout */
 146     if (rc == 0) {
 147         return 0;
 148     }
 149
 150     /* Now call callback for every ready socket. */
 151
 152     int sock;
 153     for (sock = 0; sock < dispr->max_sock + 1; sock++) {
 154         /* The callback on a socket can remove other sockets from the
 155          * dispatcher, thus we have to check that the socket is
 156          * still not removed from dispatcher's list
 157          */
 158         if (FD_ISSET(sock, &fdset) && FD_ISSET(sock, &dispr->fdset)) {
 159             Event *e = &dispr->events[sock];
 160             e->callback(sock, e->ctx);
 161         }
 162     }
 163
 164     return 0;
 165 }
 166
 167 static void
 168 vubr_handle_tx(VuDev *dev, int qidx)
 169 {
 170     VuVirtq *vq = vu_get_queue(dev, qidx);
 171     VubrDev *vubr = container_of(dev, VubrDev, vudev);
 172     int hdrlen = vubr->hdrlen;
 173     VuVirtqElement *elem = NULL;
 174
 175     assert(qidx % 2);
 176
 177     for (;;) {
 178         ssize_t ret;
 179         unsigned int out_num;
 180         struct iovec sg[VIRTQUEUE_MAX_SIZE], *out_sg;
 181
 182         elem = vu_queue_pop(dev, vq, sizeof(VuVirtqElement));
 183         if (!elem) {
 184             break;
 185         }
 186
 187         out_num = elem->out_num;
 188         out_sg = elem->out_sg;
 189         if (out_num < 1) {
 190             fprintf(stderr, "virtio-net header not in first element\n");
 191             break;
 192         }
 193         if (VHOST_USER_BRIDGE_DEBUG) {
 194             iov_hexdump(out_sg, out_num, stderr, "TX:", 1024);
 195         }
 196
 197         if (hdrlen) {
 198             unsigned sg_num = iov_copy(sg, ARRAY_SIZE(sg),
 199                                        out_sg, out_num,
 200                                        hdrlen, -1);
 201             out_num = sg_num;
 202             out_sg = sg;
 203         }
 204
 205         struct msghdr msg = {
 206             .msg_name = (struct sockaddr *) &vubr->backend_udp_dest,
 207             .msg_namelen = sizeof(struct sockaddr_in),
 208             .msg_iov = out_sg,
 209             .msg_iovlen = out_num,
 210         };
 211         do {
 212             ret = sendmsg(vubr->backend_udp_sock, &msg, 0);
 213         } while (ret == -1 && (errno == EAGAIN || errno == EINTR));
 214
 215         if (ret == -1) {
 216             vubr_die("sendmsg()");
 217         }
 218
 219         vu_queue_push(dev, vq, elem, 0);
 220         vu_queue_notify(dev, vq);
 221
 222         free(elem);
 223         elem = NULL;
 224     }
 225
 226     free(elem);
 227 }
 228
 229
 230 /* this function reverse the effect of iov_discard_front() it must be
 231  * called with 'front' being the original struct iovec and 'bytes'
 232  * being the number of bytes you shaved off
 233  */
 234 static void
 235 iov_restore_front(struct iovec *front, struct iovec *iov, size_t bytes)
 236 {
 237     struct iovec *cur;
 238
 239     for (cur = front; cur != iov; cur++) {
 240         assert(bytes >= cur->iov_len);
 241         bytes -= cur->iov_len;
 242     }
 243
 244     cur->iov_base -= bytes;
 245     cur->iov_len += bytes;
 246 }
 247
 248 static void
 249 iov_truncate(struct iovec *iov, unsigned iovc, size_t bytes)
 250 {
 251     unsigned i;
 252
 253     for (i = 0; i < iovc; i++, iov++) {
 254         if (bytes < iov->iov_len) {
 255             iov->iov_len = bytes;
 256             return;
 257         }
 258
 259         bytes -= iov->iov_len;
 260     }
 261
 262     assert(!"couldn't truncate iov");
 263 }
 264
 265 static void
 266 vubr_backend_recv_cb(int sock, void *ctx)
 267 {
 268     VubrDev *vubr = (VubrDev *) ctx;
 269     VuDev *dev = &vubr->vudev;
 270     VuVirtq *vq = vu_get_queue(dev, 0);
 271     VuVirtqElement *elem = NULL;
 272     struct iovec mhdr_sg[VIRTQUEUE_MAX_SIZE];
 273     struct virtio_net_hdr_mrg_rxbuf mhdr;
 274     unsigned mhdr_cnt = 0;
 275     int hdrlen = vubr->hdrlen;
 276     int i = 0;
 277     struct virtio_net_hdr hdr = {
 278         .flags = 0,
 279         .gso_type = VIRTIO_NET_HDR_GSO_NONE
 280     };
 281
 282     DPRINT("\n\n   ***   IN UDP RECEIVE CALLBACK    ***\n\n");
 283     DPRINT("    hdrlen = %d\n", hdrlen);
 284
 285     if (!vu_queue_enabled(dev, vq) ||
 286         !vu_queue_started(dev, vq) ||
 287         !vu_queue_avail_bytes(dev, vq, hdrlen, 0)) {
 288         DPRINT("Got UDP packet, but no available descriptors on RX virtq.\n");
 289         return;
 290     }
 291
 292     while (1) {
 293         struct iovec *sg;
 294         ssize_t ret, total = 0;
 295         unsigned int num;
 296
 297         elem = vu_queue_pop(dev, vq, sizeof(VuVirtqElement));
 298         if (!elem) {
 299             break;
 300         }
 301
 302         if (elem->in_num < 1) {
 303             fprintf(stderr, "virtio-net contains no in buffers\n");
 304             break;
 305         }
 306
 307         sg = elem->in_sg;
 308         num = elem->in_num;
 309         if (i == 0) {
 310             if (hdrlen == 12) {
 311                 mhdr_cnt = iov_copy(mhdr_sg, ARRAY_SIZE(mhdr_sg),
 312                                     sg, elem->in_num,
 313                                     offsetof(typeof(mhdr), num_buffers),
 314                                     sizeof(mhdr.num_buffers));
 315             }
 316             iov_from_buf(sg, elem->in_num, 0, &hdr, sizeof hdr);
 317             total += hdrlen;
 318             ret = iov_discard_front(&sg, &num, hdrlen);
 319             assert(ret == hdrlen);
 320         }
 321
 322         struct msghdr msg = {
 323             .msg_name = (struct sockaddr *) &vubr->backend_udp_dest,
 324             .msg_namelen = sizeof(struct sockaddr_in),
 325             .msg_iov = sg,
 326             .msg_iovlen = elem->in_num,
 327             .msg_flags = MSG_DONTWAIT,
 328         };
 329         do {
 330             ret = recvmsg(vubr->backend_udp_sock, &msg, 0);
 331         } while (ret == -1 && (errno == EINTR));
 332
 333         if (i == 0) {
 334             iov_restore_front(elem->in_sg, sg, hdrlen);
 335         }
 336
 337         if (ret == -1) {
 338             if (errno == EWOULDBLOCK) {
 339                 vu_queue_rewind(dev, vq, 1);
 340                 break;
 341             }
 342
 343             vubr_die("recvmsg()");
 344         }
 345
 346         total += ret;
 347         iov_truncate(elem->in_sg, elem->in_num, total);
 348         vu_queue_fill(dev, vq, elem, total, i++);
 349
 350         free(elem);
 351         elem = NULL;
 352
 353         break;        /* could loop if DONTWAIT worked? */
 354     }
 355
 356     if (mhdr_cnt) {
 357         mhdr.num_buffers = i;
 358         iov_from_buf(mhdr_sg, mhdr_cnt,
 359                      0,
 360                      &mhdr.num_buffers, sizeof mhdr.num_buffers);
 361     }
 362
 363     vu_queue_flush(dev, vq, i);
 364     vu_queue_notify(dev, vq);
 365
 366     free(elem);
 367 }
 368
 369 static void
 370 vubr_receive_cb(int sock, void *ctx)
 371 {
 372     VubrDev *vubr = (VubrDev *)ctx;
 373
 374     if (!vu_dispatch(&vubr->vudev)) {
 375         fprintf(stderr, "Error while dispatching\n");
 376     }
 377 }
 378
 379 typedef struct WatchData {
 380     VuDev *dev;
 381     vu_watch_cb cb;
 382     void *data;
 383 } WatchData;
 384
 385 static void
 386 watch_cb(int sock, void *ctx)
 387 {
 388     struct WatchData *wd = ctx;
 389
 390     wd->cb(wd->dev, VU_WATCH_IN, wd->data);
 391 }
 392
 393 static void
 394 vubr_set_watch(VuDev *dev, int fd, int condition,
 395                vu_watch_cb cb, void *data)
 396 {
 397     VubrDev *vubr = container_of(dev, VubrDev, vudev);
 398     static WatchData watches[FD_SETSIZE];
 399     struct WatchData *wd = &watches[fd];
 400
 401     wd->cb = cb;
 402     wd->data = data;
 403     wd->dev = dev;
 404     dispatcher_add(&vubr->dispatcher, fd, wd, watch_cb);
 405 }
 406
 407 static void
 408 vubr_remove_watch(VuDev *dev, int fd)
 409 {
 410     VubrDev *vubr = container_of(dev, VubrDev, vudev);
 411
 412     dispatcher_remove(&vubr->dispatcher, fd);
 413 }
 414
 415 static int
 416 vubr_send_rarp_exec(VuDev *dev, VhostUserMsg *vmsg)
 417 {
 418     DPRINT("Function %s() not implemented yet.\n", __func__);
 419     return 0;
 420 }
 421
 422 static int
 423 vubr_process_msg(VuDev *dev, VhostUserMsg *vmsg, int *do_reply)
 424 {
 425     switch (vmsg->request) {
 426     case VHOST_USER_SEND_RARP:
 427         *do_reply = vubr_send_rarp_exec(dev, vmsg);
 428         return 1;
 429     default:
 430         /* let the library handle the rest */
 431         return 0;
 432     }
 433
 434     return 0;
 435 }
 436
 437 static void
 438 vubr_set_features(VuDev *dev, uint64_t features)
 439 {
 440     VubrDev *vubr = container_of(dev, VubrDev, vudev);
 441
 442     if ((features & (1ULL << VIRTIO_F_VERSION_1)) ||
 443         (features & (1ULL << VIRTIO_NET_F_MRG_RXBUF))) {
 444         vubr->hdrlen = 12;
 445     } else {
 446         vubr->hdrlen = 10;
 447     }
 448 }
 449
 450 static uint64_t
 451 vubr_get_features(VuDev *dev)
 452 {
 453     return 1ULL << VIRTIO_NET_F_GUEST_ANNOUNCE |
 454         1ULL << VIRTIO_NET_F_MRG_RXBUF |
 455         1ULL << VIRTIO_F_VERSION_1;
 456 }
 457
 458 static void
 459 vubr_queue_set_started(VuDev *dev, int qidx, bool started)
 460 {
 461     VubrDev *vubr = container_of(dev, VubrDev, vudev);
 462     VuVirtq *vq = vu_get_queue(dev, qidx);
 463
 464     if (started && vubr->notifier.fd >= 0) {
 465         vu_set_queue_host_notifier(dev, vq, vubr->notifier.fd,
 466                                    getpagesize(),
 467                                    qidx * getpagesize());
 468     }
 469
 470     if (qidx % 2 == 1) {
 471         vu_set_queue_handler(dev, vq, started ? vubr_handle_tx : NULL);
 472     }
 473 }
 474
 475 static void
 476 vubr_panic(VuDev *dev, const char *msg)
 477 {
 478     VubrDev *vubr = container_of(dev, VubrDev, vudev);
 479
 480     fprintf(stderr, "PANIC: %s\n", msg);
 481
 482     dispatcher_remove(&vubr->dispatcher, dev->sock);
 483     vubr->quit = 1;
 484 }
 485
 486 static bool
 487 vubr_queue_is_processed_in_order(VuDev *dev, int qidx)
 488 {
 489     return true;
 490 }
 491
 492 static const VuDevIface vuiface = {
 493     .get_features = vubr_get_features,
 494     .set_features = vubr_set_features,
 495     .process_msg = vubr_process_msg,
 496     .queue_set_started = vubr_queue_set_started,
 497     .queue_is_processed_in_order = vubr_queue_is_processed_in_order,
 498 };
 499
 500 static void
 501 vubr_accept_cb(int sock, void *ctx)
 502 {
 503     VubrDev *dev = (VubrDev *)ctx;
 504     int conn_fd;
 505     struct sockaddr_un un;
 506     socklen_t len = sizeof(un);
 507
 508     conn_fd = accept(sock, (struct sockaddr *) &un, &len);
 509     if (conn_fd == -1) {
 510         vubr_die("accept()");
 511     }
 512     DPRINT("Got connection from remote peer on sock %d\n", conn_fd);
 513
 514     vu_init(&dev->vudev,
 515             conn_fd,
 516             vubr_panic,
 517             vubr_set_watch,
 518             vubr_remove_watch,
 519             &vuiface);
 520
 521     dispatcher_add(&dev->dispatcher, conn_fd, ctx, vubr_receive_cb);
 522     dispatcher_remove(&dev->dispatcher, sock);
 523 }
 524
 525 static VubrDev *
 526 vubr_new(const char *path, bool client)
 527 {
 528     VubrDev *dev = (VubrDev *) calloc(1, sizeof(VubrDev));
 529     struct sockaddr_un un;
 530     CallbackFunc cb;
 531     size_t len;
 532
 533     /* Get a UNIX socket. */
 534     dev->sock = socket(AF_UNIX, SOCK_STREAM, 0);
 535     if (dev->sock == -1) {
 536         vubr_die("socket");
 537     }
 538
 539     dev->notifier.fd = -1;
 540
 541     un.sun_family = AF_UNIX;
 542     strcpy(un.sun_path, path);
 543     len = sizeof(un.sun_family) + strlen(path);
 544
 545     if (!client) {
 546         unlink(path);
 547
 548         if (bind(dev->sock, (struct sockaddr *) &un, len) == -1) {
 549             vubr_die("bind");
 550         }
 551
 552         if (listen(dev->sock, 1) == -1) {
 553             vubr_die("listen");
 554         }
 555         cb = vubr_accept_cb;
 556
 557         DPRINT("Waiting for connections on UNIX socket %s ...\n", path);
 558     } else {
 559         if (connect(dev->sock, (struct sockaddr *)&un, len) == -1) {
 560             vubr_die("connect");
 561         }
 562         vu_init(&dev->vudev,
 563                 dev->sock,
 564                 vubr_panic,
 565                 vubr_set_watch,
 566                 vubr_remove_watch,
 567                 &vuiface);
 568         cb = vubr_receive_cb;
 569     }
 570
 571     dispatcher_init(&dev->dispatcher);
 572
 573     dispatcher_add(&dev->dispatcher, dev->sock, (void *)dev, cb);
 574
 575     return dev;
 576 }
 577
 578 static void *notifier_thread(void *arg)
 579 {
 580     VuDev *dev = (VuDev *)arg;
 581     VubrDev *vubr = container_of(dev, VubrDev, vudev);
 582     int pagesize = getpagesize();
 583     int qidx;
 584
 585     while (true) {
 586         for (qidx = 0; qidx < VHOST_MAX_NR_VIRTQUEUE; qidx++) {
 587             uint16_t *n = vubr->notifier.addr + pagesize * qidx;
 588
 589             if (*n == qidx) {
 590                 *n = 0xffff;
 591                 /* We won't miss notifications if we reset
 592                  * the memory first. */
 593                 smp_mb();
 594
 595                 DPRINT("Got a notification for queue%d via host notifier.\n",
 596                        qidx);
 597
 598                 if (qidx % 2 == 1) {
 599                     vubr_handle_tx(dev, qidx);
 600                 }
 601             }
 602             usleep(1000);
 603         }
 604     }
 605
 606     return NULL;
 607 }
 608
 609 static void
 610 vubr_host_notifier_setup(VubrDev *dev)
 611 {
 612     char template[] = "/tmp/vubr-XXXXXX";
 613     pthread_t thread;
 614     size_t length;
 615     void *addr;
 616     int fd;
 617
 618     length = getpagesize() * VHOST_MAX_NR_VIRTQUEUE;
 619
 620     fd = mkstemp(template);
 621     if (fd < 0) {
 622         vubr_die("mkstemp()");
 623     }
 624
 625     if (posix_fallocate(fd, 0, length) != 0) {
 626         vubr_die("posix_fallocate()");
 627     }
 628
 629     addr = mmap(NULL, length, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
 630     if (addr == MAP_FAILED) {
 631         vubr_die("mmap()");
 632     }
 633
 634     memset(addr, 0xff, length);
 635
 636     if (pthread_create(&thread, NULL, notifier_thread, &dev->vudev) != 0) {
 637         vubr_die("pthread_create()");
 638     }
 639
 640     dev->notifier.fd = fd;
 641     dev->notifier.addr = addr;
 642     dev->notifier.thread = thread;
 643 }
 644
 645 static void
 646 vubr_set_host(struct sockaddr_in *saddr, const char *host)
 647 {
 648     if (isdigit(host[0])) {
 649         if (!inet_aton(host, &saddr->sin_addr)) {
 650             fprintf(stderr, "inet_aton() failed.\n");
 651             exit(1);
 652         }
 653     } else {
 654         struct hostent *he = gethostbyname(host);
 655
 656         if (!he) {
 657             fprintf(stderr, "gethostbyname() failed.\n");
 658             exit(1);
 659         }
 660         saddr->sin_addr = *(struct in_addr *)he->h_addr;
 661     }
 662 }
 663
 664 static void
 665 vubr_backend_udp_setup(VubrDev *dev,
 666                        const char *local_host,
 667                        const char *local_port,
 668                        const char *remote_host,
 669                        const char *remote_port)
 670 {
 671     int sock;
 672     const char *r;
 673
 674     int lport, rport;
 675
 676     lport = strtol(local_port, (char **)&r, 0);
 677     if (r == local_port) {
 678         fprintf(stderr, "lport parsing failed.\n");
 679         exit(1);
 680     }
 681
 682     rport = strtol(remote_port, (char **)&r, 0);
 683     if (r == remote_port) {
 684         fprintf(stderr, "rport parsing failed.\n");
 685         exit(1);
 686     }
 687
 688     struct sockaddr_in si_local = {
 689         .sin_family = AF_INET,
 690         .sin_port = htons(lport),
 691     };
 692
 693     vubr_set_host(&si_local, local_host);
 694
 695     /* setup destination for sends */
 696     dev->backend_udp_dest = (struct sockaddr_in) {
 697         .sin_family = AF_INET,
 698         .sin_port = htons(rport),
 699     };
 700     vubr_set_host(&dev->backend_udp_dest, remote_host);
 701
 702     sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
 703     if (sock == -1) {
 704         vubr_die("socket");
 705     }
 706
 707     if (bind(sock, (struct sockaddr *)&si_local, sizeof(si_local)) == -1) {
 708         vubr_die("bind");
 709     }
 710
 711     dev->backend_udp_sock = sock;
 712     dispatcher_add(&dev->dispatcher, sock, dev, vubr_backend_recv_cb);
 713     DPRINT("Waiting for data from udp backend on %s:%d...\n",
 714            local_host, lport);
 715 }
 716
 717 static void
 718 vubr_run(VubrDev *dev)
 719 {
 720     while (!dev->quit) {
 721         /* timeout 200ms */
 722         dispatcher_wait(&dev->dispatcher, 200000);
 723         /* Here one can try polling strategy. */
 724     }
 725 }
 726
 727 static int
 728 vubr_parse_host_port(const char **host, const char **port, const char *buf)
 729 {
 730     char *p = strchr(buf, ':');
 731
 732     if (!p) {
 733         return -1;
 734     }
 735     *p = '\0';
 736     *host = strdup(buf);
 737     *port = strdup(p + 1);
 738     return 0;
 739 }
 740
 741 #define DEFAULT_UD_SOCKET "/tmp/vubr.sock"
 742 #define DEFAULT_LHOST "127.0.0.1"
 743 #define DEFAULT_LPORT "4444"
 744 #define DEFAULT_RHOST "127.0.0.1"
 745 #define DEFAULT_RPORT "5555"
 746
 747 static const char *ud_socket_path = DEFAULT_UD_SOCKET;
 748 static const char *lhost = DEFAULT_LHOST;
 749 static const char *lport = DEFAULT_LPORT;
 750 static const char *rhost = DEFAULT_RHOST;
 751 static const char *rport = DEFAULT_RPORT;
 752
 753 int
 754 main(int argc, char *argv[])
 755 {
 756     VubrDev *dev;
 757     int opt;
 758     bool client = false;
 759     bool host_notifier = false;
 760
 761     while ((opt = getopt(argc, argv, "l:r:u:cH")) != -1) {
 762
 763         switch (opt) {
 764         case 'l':
 765             if (vubr_parse_host_port(&lhost, &lport, optarg) < 0) {
 766                 goto out;
 767             }
 768             break;
 769         case 'r':
 770             if (vubr_parse_host_port(&rhost, &rport, optarg) < 0) {
 771                 goto out;
 772             }
 773             break;
 774         case 'u':
 775             ud_socket_path = strdup(optarg);
 776             break;
 777         case 'c':
 778             client = true;
 779             break;
 780         case 'H':
 781             host_notifier = true;
 782             break;
 783         default:
 784             goto out;
 785         }
 786     }
 787
 788     DPRINT("ud socket: %s (%s)\n", ud_socket_path,
 789            client ? "client" : "server");
 790     DPRINT("local:     %s:%s\n", lhost, lport);
 791     DPRINT("remote:    %s:%s\n", rhost, rport);
 792
 793     dev = vubr_new(ud_socket_path, client);
 794     if (!dev) {
 795         return 1;
 796     }
 797
 798     if (host_notifier) {
 799         vubr_host_notifier_setup(dev);
 800     }
 801
 802     vubr_backend_udp_setup(dev, lhost, lport, rhost, rport);
 803     vubr_run(dev);
 804
 805     vu_deinit(&dev->vudev);
 806
 807     return 0;
 808
 809 out:
 810     fprintf(stderr, "Usage: %s ", argv[0]);
 811     fprintf(stderr, "[-c] [-H] [-u ud_socket_path] [-l lhost:lport] [-r rhost:rport]\n");
 812     fprintf(stderr, "\t-u path to unix doman socket. default: %s\n",
 813             DEFAULT_UD_SOCKET);
 814     fprintf(stderr, "\t-l local host and port. default: %s:%s\n",
 815             DEFAULT_LHOST, DEFAULT_LPORT);
 816     fprintf(stderr, "\t-r remote host and port. default: %s:%s\n",
 817             DEFAULT_RHOST, DEFAULT_RPORT);
 818     fprintf(stderr, "\t-c client mode\n");
 819     fprintf(stderr, "\t-H use host notifier\n");
 820
 821     return 1;
 822 }