backends/cryptodev-vhost.c

   1 /*
   2  * QEMU Cryptodev backend for QEMU cipher APIs
   3  *
   4  * Copyright (c) 2016 HUAWEI TECHNOLOGIES CO., LTD.
   5  *
   6  * Authors:
   7  *    Gonglei <arei.gonglei@huawei.com>
   8  *    Jay Zhou <jianjay.zhou@huawei.com>
   9  *
  10  * This library is free software; you can redistribute it and/or
  11  * modify it under the terms of the GNU Lesser General Public
  12  * License as published by the Free Software Foundation; either
  13  * version 2.1 of the License, or (at your option) any later version.
  14  *
  15  * This library is distributed in the hope that it will be useful,
  16  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  17  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  18  * Lesser General Public License for more details.
  19  *
  20  * You should have received a copy of the GNU Lesser General Public
  21  * License along with this library; if not, see <http://www.gnu.org/licenses/>.
  22  *
  23  */
  24
  25 #include "qemu/osdep.h"
  26 #include "hw/virtio/virtio-bus.h"
  27 #include "sysemu/cryptodev-vhost.h"
  28
  29 #ifdef CONFIG_VHOST_CRYPTO
  30 #include "qapi/error.h"
  31 #include "qemu/error-report.h"
  32 #include "hw/virtio/virtio-crypto.h"
  33 #include "sysemu/cryptodev-vhost-user.h"
  34
  35 uint64_t
  36 cryptodev_vhost_get_max_queues(
  37                         CryptoDevBackendVhost *crypto)
  38 {
  39     return crypto->dev.max_queues;
  40 }
  41
  42 void cryptodev_vhost_cleanup(CryptoDevBackendVhost *crypto)
  43 {
  44     vhost_dev_cleanup(&crypto->dev);
  45     g_free(crypto);
  46 }
  47
  48 struct CryptoDevBackendVhost *
  49 cryptodev_vhost_init(
  50              CryptoDevBackendVhostOptions *options)
  51 {
  52     int r;
  53     CryptoDevBackendVhost *crypto;
  54     Error *local_err = NULL;
  55
  56     crypto = g_new(CryptoDevBackendVhost, 1);
  57     crypto->dev.max_queues = 1;
  58     crypto->dev.nvqs = 1;
  59     crypto->dev.vqs = crypto->vqs;
  60
  61     crypto->cc = options->cc;
  62
  63     crypto->dev.protocol_features = 0;
  64     crypto->backend = -1;
  65
  66     /* vhost-user needs vq_index to initiate a specific queue pair */
  67     crypto->dev.vq_index = crypto->cc->queue_index * crypto->dev.nvqs;
  68
  69     r = vhost_dev_init(&crypto->dev, options->opaque, options->backend_type, 0,
  70                        &local_err);
  71     if (r < 0) {
  72         error_report_err(local_err);
  73         goto fail;
  74     }
  75
  76     return crypto;
  77 fail:
  78     g_free(crypto);
  79     return NULL;
  80 }
  81
  82 static int
  83 cryptodev_vhost_start_one(CryptoDevBackendVhost *crypto,
  84                                   VirtIODevice *dev)
  85 {
  86     int r;
  87
  88     crypto->dev.nvqs = 1;
  89     crypto->dev.vqs = crypto->vqs;
  90
  91     r = vhost_dev_enable_notifiers(&crypto->dev, dev);
  92     if (r < 0) {
  93         goto fail_notifiers;
  94     }
  95
  96     r = vhost_dev_start(&crypto->dev, dev, false);
  97     if (r < 0) {
  98         goto fail_start;
  99     }
 100
 101     return 0;
 102
 103 fail_start:
 104     vhost_dev_disable_notifiers(&crypto->dev, dev);
 105 fail_notifiers:
 106     return r;
 107 }
 108
 109 static void
 110 cryptodev_vhost_stop_one(CryptoDevBackendVhost *crypto,
 111                                  VirtIODevice *dev)
 112 {
 113     vhost_dev_stop(&crypto->dev, dev, false);
 114     vhost_dev_disable_notifiers(&crypto->dev, dev);
 115 }
 116
 117 CryptoDevBackendVhost *
 118 cryptodev_get_vhost(CryptoDevBackendClient *cc,
 119                             CryptoDevBackend *b,
 120                             uint16_t queue)
 121 {
 122     CryptoDevBackendVhost *vhost_crypto = NULL;
 123
 124     if (!cc) {
 125         return NULL;
 126     }
 127
 128     switch (cc->type) {
 129 #if defined(CONFIG_VHOST_USER) && defined(CONFIG_LINUX)
 130     case QCRYPTODEV_BACKEND_TYPE_VHOST_USER:
 131         vhost_crypto = cryptodev_vhost_user_get_vhost(cc, b, queue);
 132         break;
 133 #endif
 134     default:
 135         break;
 136     }
 137
 138     return vhost_crypto;
 139 }
 140
 141 static void
 142 cryptodev_vhost_set_vq_index(CryptoDevBackendVhost *crypto,
 143                                      int vq_index)
 144 {
 145     crypto->dev.vq_index = vq_index;
 146 }
 147
 148 static int
 149 vhost_set_vring_enable(CryptoDevBackendClient *cc,
 150                             CryptoDevBackend *b,
 151                             uint16_t queue, int enable)
 152 {
 153     CryptoDevBackendVhost *crypto =
 154                        cryptodev_get_vhost(cc, b, queue);
 155     const VhostOps *vhost_ops;
 156
 157     cc->vring_enable = enable;
 158
 159     if (!crypto) {
 160         return 0;
 161     }
 162
 163     vhost_ops = crypto->dev.vhost_ops;
 164     if (vhost_ops->vhost_set_vring_enable) {
 165         return vhost_ops->vhost_set_vring_enable(&crypto->dev, enable);
 166     }
 167
 168     return 0;
 169 }
 170
 171 int cryptodev_vhost_start(VirtIODevice *dev, int total_queues)
 172 {
 173     VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(dev);
 174     BusState *qbus = BUS(qdev_get_parent_bus(DEVICE(dev)));
 175     VirtioBusState *vbus = VIRTIO_BUS(qbus);
 176     VirtioBusClass *k = VIRTIO_BUS_GET_CLASS(vbus);
 177     int r, e;
 178     int i;
 179     CryptoDevBackend *b = vcrypto->cryptodev;
 180     CryptoDevBackendVhost *vhost_crypto;
 181     CryptoDevBackendClient *cc;
 182
 183     if (!k->set_guest_notifiers) {
 184         error_report("binding does not support guest notifiers");
 185         return -ENOSYS;
 186     }
 187
 188     for (i = 0; i < total_queues; i++) {
 189         cc = b->conf.peers.ccs[i];
 190
 191         vhost_crypto = cryptodev_get_vhost(cc, b, i);
 192         cryptodev_vhost_set_vq_index(vhost_crypto, i);
 193
 194         /* Suppress the masking guest notifiers on vhost user
 195          * because vhost user doesn't interrupt masking/unmasking
 196          * properly.
 197          */
 198         if (cc->type == QCRYPTODEV_BACKEND_TYPE_VHOST_USER) {
 199             dev->use_guest_notifier_mask = false;
 200         }
 201      }
 202
 203     r = k->set_guest_notifiers(qbus->parent, total_queues, true);
 204     if (r < 0) {
 205         error_report("error binding guest notifier: %d", -r);
 206         goto err;
 207     }
 208
 209     for (i = 0; i < total_queues; i++) {
 210         cc = b->conf.peers.ccs[i];
 211
 212         vhost_crypto = cryptodev_get_vhost(cc, b, i);
 213         r = cryptodev_vhost_start_one(vhost_crypto, dev);
 214
 215         if (r < 0) {
 216             goto err_start;
 217         }
 218
 219         if (cc->vring_enable) {
 220             /* restore vring enable state */
 221             r = vhost_set_vring_enable(cc, b, i, cc->vring_enable);
 222
 223             if (r < 0) {
 224                 goto err_start;
 225             }
 226         }
 227     }
 228
 229     return 0;
 230
 231 err_start:
 232     while (--i >= 0) {
 233         cc = b->conf.peers.ccs[i];
 234         vhost_crypto = cryptodev_get_vhost(cc, b, i);
 235         cryptodev_vhost_stop_one(vhost_crypto, dev);
 236     }
 237     e = k->set_guest_notifiers(qbus->parent, total_queues, false);
 238     if (e < 0) {
 239         error_report("vhost guest notifier cleanup failed: %d", e);
 240     }
 241 err:
 242     return r;
 243 }
 244
 245 void cryptodev_vhost_stop(VirtIODevice *dev, int total_queues)
 246 {
 247     BusState *qbus = BUS(qdev_get_parent_bus(DEVICE(dev)));
 248     VirtioBusState *vbus = VIRTIO_BUS(qbus);
 249     VirtioBusClass *k = VIRTIO_BUS_GET_CLASS(vbus);
 250     VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(dev);
 251     CryptoDevBackend *b = vcrypto->cryptodev;
 252     CryptoDevBackendVhost *vhost_crypto;
 253     CryptoDevBackendClient *cc;
 254     size_t i;
 255     int r;
 256
 257     for (i = 0; i < total_queues; i++) {
 258         cc = b->conf.peers.ccs[i];
 259
 260         vhost_crypto = cryptodev_get_vhost(cc, b, i);
 261         cryptodev_vhost_stop_one(vhost_crypto, dev);
 262     }
 263
 264     r = k->set_guest_notifiers(qbus->parent, total_queues, false);
 265     if (r < 0) {
 266         error_report("vhost guest notifier cleanup failed: %d", r);
 267     }
 268     assert(r >= 0);
 269 }
 270
 271 void cryptodev_vhost_virtqueue_mask(VirtIODevice *dev,
 272                                            int queue,
 273                                            int idx, bool mask)
 274 {
 275     VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(dev);
 276     CryptoDevBackend *b = vcrypto->cryptodev;
 277     CryptoDevBackendVhost *vhost_crypto;
 278     CryptoDevBackendClient *cc;
 279
 280     assert(queue < MAX_CRYPTO_QUEUE_NUM);
 281
 282     cc = b->conf.peers.ccs[queue];
 283     vhost_crypto = cryptodev_get_vhost(cc, b, queue);
 284
 285     vhost_virtqueue_mask(&vhost_crypto->dev, dev, idx, mask);
 286 }
 287
 288 bool cryptodev_vhost_virtqueue_pending(VirtIODevice *dev,
 289                                               int queue, int idx)
 290 {
 291     VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(dev);
 292     CryptoDevBackend *b = vcrypto->cryptodev;
 293     CryptoDevBackendVhost *vhost_crypto;
 294     CryptoDevBackendClient *cc;
 295
 296     assert(queue < MAX_CRYPTO_QUEUE_NUM);
 297
 298     cc = b->conf.peers.ccs[queue];
 299     vhost_crypto = cryptodev_get_vhost(cc, b, queue);
 300
 301     return vhost_virtqueue_pending(&vhost_crypto->dev, idx);
 302 }
 303
 304 #else
 305 uint64_t
 306 cryptodev_vhost_get_max_queues(CryptoDevBackendVhost *crypto)
 307 {
 308     return 0;
 309 }
 310
 311 void cryptodev_vhost_cleanup(CryptoDevBackendVhost *crypto)
 312 {
 313 }
 314
 315 struct CryptoDevBackendVhost *
 316 cryptodev_vhost_init(CryptoDevBackendVhostOptions *options)
 317 {
 318     return NULL;
 319 }
 320
 321 CryptoDevBackendVhost *
 322 cryptodev_get_vhost(CryptoDevBackendClient *cc,
 323                     CryptoDevBackend *b,
 324                     uint16_t queue)
 325 {
 326     return NULL;
 327 }
 328
 329 int cryptodev_vhost_start(VirtIODevice *dev, int total_queues)
 330 {
 331     return -1;
 332 }
 333
 334 void cryptodev_vhost_stop(VirtIODevice *dev, int total_queues)
 335 {
 336 }
 337
 338 void cryptodev_vhost_virtqueue_mask(VirtIODevice *dev,
 339                                     int queue,
 340                                     int idx, bool mask)
 341 {
 342 }
 343
 344 bool cryptodev_vhost_virtqueue_pending(VirtIODevice *dev,
 345                                        int queue, int idx)
 346 {
 347     return false;
 348 }
 349 #endif