qemu/hw/virtio/virtio-crypto.c
<<
>>
Prefs
   1/*
   2 * Virtio crypto Support
   3 *
   4 * Copyright (c) 2016 HUAWEI TECHNOLOGIES CO., LTD.
   5 *
   6 * Authors:
   7 *    Gonglei <arei.gonglei@huawei.com>
   8 *
   9 * This work is licensed under the terms of the GNU GPL, version 2 or
  10 * (at your option) any later version.  See the COPYING file in the
  11 * top-level directory.
  12 */
  13#include "qemu/osdep.h"
  14#include "qemu/iov.h"
  15#include "hw/qdev.h"
  16#include "qapi/error.h"
  17#include "qemu/error-report.h"
  18
  19#include "hw/virtio/virtio.h"
  20#include "hw/virtio/virtio-crypto.h"
  21#include "hw/virtio/virtio-access.h"
  22#include "standard-headers/linux/virtio_ids.h"
  23
  24#define VIRTIO_CRYPTO_VM_VERSION 1
  25
  26/*
  27 * Transfer virtqueue index to crypto queue index.
  28 * The control virtqueue is after the data virtqueues
  29 * so the input value doesn't need to be adjusted
  30 */
  31static inline int virtio_crypto_vq2q(int queue_index)
  32{
  33    return queue_index;
  34}
  35
  36static int
  37virtio_crypto_cipher_session_helper(VirtIODevice *vdev,
  38           CryptoDevBackendSymSessionInfo *info,
  39           struct virtio_crypto_cipher_session_para *cipher_para,
  40           struct iovec **iov, unsigned int *out_num)
  41{
  42    VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(vdev);
  43    unsigned int num = *out_num;
  44
  45    info->cipher_alg = ldl_le_p(&cipher_para->algo);
  46    info->key_len = ldl_le_p(&cipher_para->keylen);
  47    info->direction = ldl_le_p(&cipher_para->op);
  48    DPRINTF("cipher_alg=%" PRIu32 ", info->direction=%" PRIu32 "\n",
  49             info->cipher_alg, info->direction);
  50
  51    if (info->key_len > vcrypto->conf.max_cipher_key_len) {
  52        error_report("virtio-crypto length of cipher key is too big: %u",
  53                     info->key_len);
  54        return -VIRTIO_CRYPTO_ERR;
  55    }
  56    /* Get cipher key */
  57    if (info->key_len > 0) {
  58        size_t s;
  59        DPRINTF("keylen=%" PRIu32 "\n", info->key_len);
  60
  61        info->cipher_key = g_malloc(info->key_len);
  62        s = iov_to_buf(*iov, num, 0, info->cipher_key, info->key_len);
  63        if (unlikely(s != info->key_len)) {
  64            virtio_error(vdev, "virtio-crypto cipher key incorrect");
  65            return -EFAULT;
  66        }
  67        iov_discard_front(iov, &num, info->key_len);
  68        *out_num = num;
  69    }
  70
  71    return 0;
  72}
  73
  74static int64_t
  75virtio_crypto_create_sym_session(VirtIOCrypto *vcrypto,
  76               struct virtio_crypto_sym_create_session_req *sess_req,
  77               uint32_t queue_id,
  78               uint32_t opcode,
  79               struct iovec *iov, unsigned int out_num)
  80{
  81    VirtIODevice *vdev = VIRTIO_DEVICE(vcrypto);
  82    CryptoDevBackendSymSessionInfo info;
  83    int64_t session_id;
  84    int queue_index;
  85    uint32_t op_type;
  86    Error *local_err = NULL;
  87    int ret;
  88
  89    memset(&info, 0, sizeof(info));
  90    op_type = ldl_le_p(&sess_req->op_type);
  91    info.op_type = op_type;
  92    info.op_code = opcode;
  93
  94    if (op_type == VIRTIO_CRYPTO_SYM_OP_CIPHER) {
  95        ret = virtio_crypto_cipher_session_helper(vdev, &info,
  96                           &sess_req->u.cipher.para,
  97                           &iov, &out_num);
  98        if (ret < 0) {
  99            goto err;
 100        }
 101    } else if (op_type == VIRTIO_CRYPTO_SYM_OP_ALGORITHM_CHAINING) {
 102        size_t s;
 103        /* cipher part */
 104        ret = virtio_crypto_cipher_session_helper(vdev, &info,
 105                           &sess_req->u.chain.para.cipher_param,
 106                           &iov, &out_num);
 107        if (ret < 0) {
 108            goto err;
 109        }
 110        /* hash part */
 111        info.alg_chain_order = ldl_le_p(
 112                                     &sess_req->u.chain.para.alg_chain_order);
 113        info.add_len = ldl_le_p(&sess_req->u.chain.para.aad_len);
 114        info.hash_mode = ldl_le_p(&sess_req->u.chain.para.hash_mode);
 115        if (info.hash_mode == VIRTIO_CRYPTO_SYM_HASH_MODE_AUTH) {
 116            info.hash_alg = ldl_le_p(&sess_req->u.chain.para.u.mac_param.algo);
 117            info.auth_key_len = ldl_le_p(
 118                             &sess_req->u.chain.para.u.mac_param.auth_key_len);
 119            info.hash_result_len = ldl_le_p(
 120                           &sess_req->u.chain.para.u.mac_param.hash_result_len);
 121            if (info.auth_key_len > vcrypto->conf.max_auth_key_len) {
 122                error_report("virtio-crypto length of auth key is too big: %u",
 123                             info.auth_key_len);
 124                ret = -VIRTIO_CRYPTO_ERR;
 125                goto err;
 126            }
 127            /* get auth key */
 128            if (info.auth_key_len > 0) {
 129                DPRINTF("auth_keylen=%" PRIu32 "\n", info.auth_key_len);
 130                info.auth_key = g_malloc(info.auth_key_len);
 131                s = iov_to_buf(iov, out_num, 0, info.auth_key,
 132                               info.auth_key_len);
 133                if (unlikely(s != info.auth_key_len)) {
 134                    virtio_error(vdev,
 135                          "virtio-crypto authenticated key incorrect");
 136                    ret = -EFAULT;
 137                    goto err;
 138                }
 139                iov_discard_front(&iov, &out_num, info.auth_key_len);
 140            }
 141        } else if (info.hash_mode == VIRTIO_CRYPTO_SYM_HASH_MODE_PLAIN) {
 142            info.hash_alg = ldl_le_p(
 143                             &sess_req->u.chain.para.u.hash_param.algo);
 144            info.hash_result_len = ldl_le_p(
 145                        &sess_req->u.chain.para.u.hash_param.hash_result_len);
 146        } else {
 147            /* VIRTIO_CRYPTO_SYM_HASH_MODE_NESTED */
 148            error_report("unsupported hash mode");
 149            ret = -VIRTIO_CRYPTO_NOTSUPP;
 150            goto err;
 151        }
 152    } else {
 153        /* VIRTIO_CRYPTO_SYM_OP_NONE */
 154        error_report("unsupported cipher op_type: VIRTIO_CRYPTO_SYM_OP_NONE");
 155        ret = -VIRTIO_CRYPTO_NOTSUPP;
 156        goto err;
 157    }
 158
 159    queue_index = virtio_crypto_vq2q(queue_id);
 160    session_id = cryptodev_backend_sym_create_session(
 161                                     vcrypto->cryptodev,
 162                                     &info, queue_index, &local_err);
 163    if (session_id >= 0) {
 164        DPRINTF("create session_id=%" PRIu64 " successfully\n",
 165                session_id);
 166
 167        ret = session_id;
 168    } else {
 169        if (local_err) {
 170            error_report_err(local_err);
 171        }
 172        ret = -VIRTIO_CRYPTO_ERR;
 173    }
 174
 175err:
 176    g_free(info.cipher_key);
 177    g_free(info.auth_key);
 178    return ret;
 179}
 180
 181static uint8_t
 182virtio_crypto_handle_close_session(VirtIOCrypto *vcrypto,
 183         struct virtio_crypto_destroy_session_req *close_sess_req,
 184         uint32_t queue_id)
 185{
 186    int ret;
 187    uint64_t session_id;
 188    uint32_t status;
 189    Error *local_err = NULL;
 190
 191    session_id = ldq_le_p(&close_sess_req->session_id);
 192    DPRINTF("close session, id=%" PRIu64 "\n", session_id);
 193
 194    ret = cryptodev_backend_sym_close_session(
 195              vcrypto->cryptodev, session_id, queue_id, &local_err);
 196    if (ret == 0) {
 197        status = VIRTIO_CRYPTO_OK;
 198    } else {
 199        if (local_err) {
 200            error_report_err(local_err);
 201        } else {
 202            error_report("destroy session failed");
 203        }
 204        status = VIRTIO_CRYPTO_ERR;
 205    }
 206
 207    return status;
 208}
 209
 210static void virtio_crypto_handle_ctrl(VirtIODevice *vdev, VirtQueue *vq)
 211{
 212    VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(vdev);
 213    struct virtio_crypto_op_ctrl_req ctrl;
 214    VirtQueueElement *elem;
 215    struct iovec *in_iov;
 216    struct iovec *out_iov;
 217    unsigned in_num;
 218    unsigned out_num;
 219    uint32_t queue_id;
 220    uint32_t opcode;
 221    struct virtio_crypto_session_input input;
 222    int64_t session_id;
 223    uint8_t status;
 224    size_t s;
 225
 226    for (;;) {
 227        elem = virtqueue_pop(vq, sizeof(VirtQueueElement));
 228        if (!elem) {
 229            break;
 230        }
 231        if (elem->out_num < 1 || elem->in_num < 1) {
 232            virtio_error(vdev, "virtio-crypto ctrl missing headers");
 233            virtqueue_detach_element(vq, elem, 0);
 234            g_free(elem);
 235            break;
 236        }
 237
 238        out_num = elem->out_num;
 239        out_iov = elem->out_sg;
 240        in_num = elem->in_num;
 241        in_iov = elem->in_sg;
 242        if (unlikely(iov_to_buf(out_iov, out_num, 0, &ctrl, sizeof(ctrl))
 243                    != sizeof(ctrl))) {
 244            virtio_error(vdev, "virtio-crypto request ctrl_hdr too short");
 245            virtqueue_detach_element(vq, elem, 0);
 246            g_free(elem);
 247            break;
 248        }
 249        iov_discard_front(&out_iov, &out_num, sizeof(ctrl));
 250
 251        opcode = ldl_le_p(&ctrl.header.opcode);
 252        queue_id = ldl_le_p(&ctrl.header.queue_id);
 253
 254        switch (opcode) {
 255        case VIRTIO_CRYPTO_CIPHER_CREATE_SESSION:
 256            memset(&input, 0, sizeof(input));
 257            session_id = virtio_crypto_create_sym_session(vcrypto,
 258                             &ctrl.u.sym_create_session,
 259                             queue_id, opcode,
 260                             out_iov, out_num);
 261            /* Serious errors, need to reset virtio crypto device */
 262            if (session_id == -EFAULT) {
 263                virtqueue_detach_element(vq, elem, 0);
 264                break;
 265            } else if (session_id == -VIRTIO_CRYPTO_NOTSUPP) {
 266                stl_le_p(&input.status, VIRTIO_CRYPTO_NOTSUPP);
 267            } else if (session_id == -VIRTIO_CRYPTO_ERR) {
 268                stl_le_p(&input.status, VIRTIO_CRYPTO_ERR);
 269            } else {
 270                /* Set the session id */
 271                stq_le_p(&input.session_id, session_id);
 272                stl_le_p(&input.status, VIRTIO_CRYPTO_OK);
 273            }
 274
 275            s = iov_from_buf(in_iov, in_num, 0, &input, sizeof(input));
 276            if (unlikely(s != sizeof(input))) {
 277                virtio_error(vdev, "virtio-crypto input incorrect");
 278                virtqueue_detach_element(vq, elem, 0);
 279                break;
 280            }
 281            virtqueue_push(vq, elem, sizeof(input));
 282            virtio_notify(vdev, vq);
 283            break;
 284        case VIRTIO_CRYPTO_CIPHER_DESTROY_SESSION:
 285        case VIRTIO_CRYPTO_HASH_DESTROY_SESSION:
 286        case VIRTIO_CRYPTO_MAC_DESTROY_SESSION:
 287        case VIRTIO_CRYPTO_AEAD_DESTROY_SESSION:
 288            status = virtio_crypto_handle_close_session(vcrypto,
 289                   &ctrl.u.destroy_session, queue_id);
 290            /* The status only occupy one byte, we can directly use it */
 291            s = iov_from_buf(in_iov, in_num, 0, &status, sizeof(status));
 292            if (unlikely(s != sizeof(status))) {
 293                virtio_error(vdev, "virtio-crypto status incorrect");
 294                virtqueue_detach_element(vq, elem, 0);
 295                break;
 296            }
 297            virtqueue_push(vq, elem, sizeof(status));
 298            virtio_notify(vdev, vq);
 299            break;
 300        case VIRTIO_CRYPTO_HASH_CREATE_SESSION:
 301        case VIRTIO_CRYPTO_MAC_CREATE_SESSION:
 302        case VIRTIO_CRYPTO_AEAD_CREATE_SESSION:
 303        default:
 304            error_report("virtio-crypto unsupported ctrl opcode: %d", opcode);
 305            memset(&input, 0, sizeof(input));
 306            stl_le_p(&input.status, VIRTIO_CRYPTO_NOTSUPP);
 307            s = iov_from_buf(in_iov, in_num, 0, &input, sizeof(input));
 308            if (unlikely(s != sizeof(input))) {
 309                virtio_error(vdev, "virtio-crypto input incorrect");
 310                virtqueue_detach_element(vq, elem, 0);
 311                break;
 312            }
 313            virtqueue_push(vq, elem, sizeof(input));
 314            virtio_notify(vdev, vq);
 315
 316            break;
 317        } /* end switch case */
 318
 319        g_free(elem);
 320    } /* end for loop */
 321}
 322
 323static void virtio_crypto_init_request(VirtIOCrypto *vcrypto, VirtQueue *vq,
 324                                VirtIOCryptoReq *req)
 325{
 326    req->vcrypto = vcrypto;
 327    req->vq = vq;
 328    req->in = NULL;
 329    req->in_iov = NULL;
 330    req->in_num = 0;
 331    req->in_len = 0;
 332    req->flags = CRYPTODEV_BACKEND_ALG__MAX;
 333    req->u.sym_op_info = NULL;
 334}
 335
 336static void virtio_crypto_free_request(VirtIOCryptoReq *req)
 337{
 338    if (req) {
 339        if (req->flags == CRYPTODEV_BACKEND_ALG_SYM) {
 340            size_t max_len;
 341            CryptoDevBackendSymOpInfo *op_info = req->u.sym_op_info;
 342
 343            max_len = op_info->iv_len +
 344                      op_info->aad_len +
 345                      op_info->src_len +
 346                      op_info->dst_len +
 347                      op_info->digest_result_len;
 348
 349            /* Zeroize and free request data structure */
 350            memset(op_info, 0, sizeof(*op_info) + max_len);
 351            g_free(op_info);
 352        }
 353        g_free(req);
 354    }
 355}
 356
 357static void
 358virtio_crypto_sym_input_data_helper(VirtIODevice *vdev,
 359                VirtIOCryptoReq *req,
 360                uint32_t status,
 361                CryptoDevBackendSymOpInfo *sym_op_info)
 362{
 363    size_t s, len;
 364
 365    if (status != VIRTIO_CRYPTO_OK) {
 366        return;
 367    }
 368
 369    len = sym_op_info->src_len;
 370    /* Save the cipher result */
 371    s = iov_from_buf(req->in_iov, req->in_num, 0, sym_op_info->dst, len);
 372    if (s != len) {
 373        virtio_error(vdev, "virtio-crypto dest data incorrect");
 374        return;
 375    }
 376
 377    iov_discard_front(&req->in_iov, &req->in_num, len);
 378
 379    if (sym_op_info->op_type ==
 380                      VIRTIO_CRYPTO_SYM_OP_ALGORITHM_CHAINING) {
 381        /* Save the digest result */
 382        s = iov_from_buf(req->in_iov, req->in_num, 0,
 383                         sym_op_info->digest_result,
 384                         sym_op_info->digest_result_len);
 385        if (s != sym_op_info->digest_result_len) {
 386            virtio_error(vdev, "virtio-crypto digest result incorrect");
 387        }
 388    }
 389}
 390
 391static void virtio_crypto_req_complete(VirtIOCryptoReq *req, uint8_t status)
 392{
 393    VirtIOCrypto *vcrypto = req->vcrypto;
 394    VirtIODevice *vdev = VIRTIO_DEVICE(vcrypto);
 395
 396    if (req->flags == CRYPTODEV_BACKEND_ALG_SYM) {
 397        virtio_crypto_sym_input_data_helper(vdev, req, status,
 398                                            req->u.sym_op_info);
 399    }
 400    stb_p(&req->in->status, status);
 401    virtqueue_push(req->vq, &req->elem, req->in_len);
 402    virtio_notify(vdev, req->vq);
 403}
 404
 405static VirtIOCryptoReq *
 406virtio_crypto_get_request(VirtIOCrypto *s, VirtQueue *vq)
 407{
 408    VirtIOCryptoReq *req = virtqueue_pop(vq, sizeof(VirtIOCryptoReq));
 409
 410    if (req) {
 411        virtio_crypto_init_request(s, vq, req);
 412    }
 413    return req;
 414}
 415
 416static CryptoDevBackendSymOpInfo *
 417virtio_crypto_sym_op_helper(VirtIODevice *vdev,
 418           struct virtio_crypto_cipher_para *cipher_para,
 419           struct virtio_crypto_alg_chain_data_para *alg_chain_para,
 420           struct iovec *iov, unsigned int out_num)
 421{
 422    VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(vdev);
 423    CryptoDevBackendSymOpInfo *op_info;
 424    uint32_t src_len = 0, dst_len = 0;
 425    uint32_t iv_len = 0;
 426    uint32_t aad_len = 0, hash_result_len = 0;
 427    uint32_t hash_start_src_offset = 0, len_to_hash = 0;
 428    uint32_t cipher_start_src_offset = 0, len_to_cipher = 0;
 429
 430    uint64_t max_len, curr_size = 0;
 431    size_t s;
 432
 433    /* Plain cipher */
 434    if (cipher_para) {
 435        iv_len = ldl_le_p(&cipher_para->iv_len);
 436        src_len = ldl_le_p(&cipher_para->src_data_len);
 437        dst_len = ldl_le_p(&cipher_para->dst_data_len);
 438    } else if (alg_chain_para) { /* Algorithm chain */
 439        iv_len = ldl_le_p(&alg_chain_para->iv_len);
 440        src_len = ldl_le_p(&alg_chain_para->src_data_len);
 441        dst_len = ldl_le_p(&alg_chain_para->dst_data_len);
 442
 443        aad_len = ldl_le_p(&alg_chain_para->aad_len);
 444        hash_result_len = ldl_le_p(&alg_chain_para->hash_result_len);
 445        hash_start_src_offset = ldl_le_p(
 446                         &alg_chain_para->hash_start_src_offset);
 447        cipher_start_src_offset = ldl_le_p(
 448                         &alg_chain_para->cipher_start_src_offset);
 449        len_to_cipher = ldl_le_p(&alg_chain_para->len_to_cipher);
 450        len_to_hash = ldl_le_p(&alg_chain_para->len_to_hash);
 451    } else {
 452        return NULL;
 453    }
 454
 455    max_len = (uint64_t)iv_len + aad_len + src_len + dst_len + hash_result_len;
 456    if (unlikely(max_len > vcrypto->conf.max_size)) {
 457        virtio_error(vdev, "virtio-crypto too big length");
 458        return NULL;
 459    }
 460
 461    op_info = g_malloc0(sizeof(CryptoDevBackendSymOpInfo) + max_len);
 462    op_info->iv_len = iv_len;
 463    op_info->src_len = src_len;
 464    op_info->dst_len = dst_len;
 465    op_info->aad_len = aad_len;
 466    op_info->digest_result_len = hash_result_len;
 467    op_info->hash_start_src_offset = hash_start_src_offset;
 468    op_info->len_to_hash = len_to_hash;
 469    op_info->cipher_start_src_offset = cipher_start_src_offset;
 470    op_info->len_to_cipher = len_to_cipher;
 471    /* Handle the initilization vector */
 472    if (op_info->iv_len > 0) {
 473        DPRINTF("iv_len=%" PRIu32 "\n", op_info->iv_len);
 474        op_info->iv = op_info->data + curr_size;
 475
 476        s = iov_to_buf(iov, out_num, 0, op_info->iv, op_info->iv_len);
 477        if (unlikely(s != op_info->iv_len)) {
 478            virtio_error(vdev, "virtio-crypto iv incorrect");
 479            goto err;
 480        }
 481        iov_discard_front(&iov, &out_num, op_info->iv_len);
 482        curr_size += op_info->iv_len;
 483    }
 484
 485    /* Handle additional authentication data if exists */
 486    if (op_info->aad_len > 0) {
 487        DPRINTF("aad_len=%" PRIu32 "\n", op_info->aad_len);
 488        op_info->aad_data = op_info->data + curr_size;
 489
 490        s = iov_to_buf(iov, out_num, 0, op_info->aad_data, op_info->aad_len);
 491        if (unlikely(s != op_info->aad_len)) {
 492            virtio_error(vdev, "virtio-crypto additional auth data incorrect");
 493            goto err;
 494        }
 495        iov_discard_front(&iov, &out_num, op_info->aad_len);
 496
 497        curr_size += op_info->aad_len;
 498    }
 499
 500    /* Handle the source data */
 501    if (op_info->src_len > 0) {
 502        DPRINTF("src_len=%" PRIu32 "\n", op_info->src_len);
 503        op_info->src = op_info->data + curr_size;
 504
 505        s = iov_to_buf(iov, out_num, 0, op_info->src, op_info->src_len);
 506        if (unlikely(s != op_info->src_len)) {
 507            virtio_error(vdev, "virtio-crypto source data incorrect");
 508            goto err;
 509        }
 510        iov_discard_front(&iov, &out_num, op_info->src_len);
 511
 512        curr_size += op_info->src_len;
 513    }
 514
 515    /* Handle the destination data */
 516    op_info->dst = op_info->data + curr_size;
 517    curr_size += op_info->dst_len;
 518
 519    DPRINTF("dst_len=%" PRIu32 "\n", op_info->dst_len);
 520
 521    /* Handle the hash digest result */
 522    if (hash_result_len > 0) {
 523        DPRINTF("hash_result_len=%" PRIu32 "\n", hash_result_len);
 524        op_info->digest_result = op_info->data + curr_size;
 525    }
 526
 527    return op_info;
 528
 529err:
 530    g_free(op_info);
 531    return NULL;
 532}
 533
 534static int
 535virtio_crypto_handle_sym_req(VirtIOCrypto *vcrypto,
 536               struct virtio_crypto_sym_data_req *req,
 537               CryptoDevBackendSymOpInfo **sym_op_info,
 538               struct iovec *iov, unsigned int out_num)
 539{
 540    VirtIODevice *vdev = VIRTIO_DEVICE(vcrypto);
 541    uint32_t op_type;
 542    CryptoDevBackendSymOpInfo *op_info;
 543
 544    op_type = ldl_le_p(&req->op_type);
 545
 546    if (op_type == VIRTIO_CRYPTO_SYM_OP_CIPHER) {
 547        op_info = virtio_crypto_sym_op_helper(vdev, &req->u.cipher.para,
 548                                              NULL, iov, out_num);
 549        if (!op_info) {
 550            return -EFAULT;
 551        }
 552        op_info->op_type = op_type;
 553    } else if (op_type == VIRTIO_CRYPTO_SYM_OP_ALGORITHM_CHAINING) {
 554        op_info = virtio_crypto_sym_op_helper(vdev, NULL,
 555                                              &req->u.chain.para,
 556                                              iov, out_num);
 557        if (!op_info) {
 558            return -EFAULT;
 559        }
 560        op_info->op_type = op_type;
 561    } else {
 562        /* VIRTIO_CRYPTO_SYM_OP_NONE */
 563        error_report("virtio-crypto unsupported cipher type");
 564        return -VIRTIO_CRYPTO_NOTSUPP;
 565    }
 566
 567    *sym_op_info = op_info;
 568
 569    return 0;
 570}
 571
 572static int
 573virtio_crypto_handle_request(VirtIOCryptoReq *request)
 574{
 575    VirtIOCrypto *vcrypto = request->vcrypto;
 576    VirtIODevice *vdev = VIRTIO_DEVICE(vcrypto);
 577    VirtQueueElement *elem = &request->elem;
 578    int queue_index = virtio_crypto_vq2q(virtio_get_queue_index(request->vq));
 579    struct virtio_crypto_op_data_req req;
 580    int ret;
 581    struct iovec *in_iov;
 582    struct iovec *out_iov;
 583    unsigned in_num;
 584    unsigned out_num;
 585    uint32_t opcode;
 586    uint8_t status = VIRTIO_CRYPTO_ERR;
 587    uint64_t session_id;
 588    CryptoDevBackendSymOpInfo *sym_op_info = NULL;
 589    Error *local_err = NULL;
 590
 591    if (elem->out_num < 1 || elem->in_num < 1) {
 592        virtio_error(vdev, "virtio-crypto dataq missing headers");
 593        return -1;
 594    }
 595
 596    out_num = elem->out_num;
 597    out_iov = elem->out_sg;
 598    in_num = elem->in_num;
 599    in_iov = elem->in_sg;
 600    if (unlikely(iov_to_buf(out_iov, out_num, 0, &req, sizeof(req))
 601                != sizeof(req))) {
 602        virtio_error(vdev, "virtio-crypto request outhdr too short");
 603        return -1;
 604    }
 605    iov_discard_front(&out_iov, &out_num, sizeof(req));
 606
 607    if (in_iov[in_num - 1].iov_len <
 608            sizeof(struct virtio_crypto_inhdr)) {
 609        virtio_error(vdev, "virtio-crypto request inhdr too short");
 610        return -1;
 611    }
 612    /* We always touch the last byte, so just see how big in_iov is. */
 613    request->in_len = iov_size(in_iov, in_num);
 614    request->in = (void *)in_iov[in_num - 1].iov_base
 615              + in_iov[in_num - 1].iov_len
 616              - sizeof(struct virtio_crypto_inhdr);
 617    iov_discard_back(in_iov, &in_num, sizeof(struct virtio_crypto_inhdr));
 618
 619    /*
 620     * The length of operation result, including dest_data
 621     * and digest_result if exists.
 622     */
 623    request->in_num = in_num;
 624    request->in_iov = in_iov;
 625
 626    opcode = ldl_le_p(&req.header.opcode);
 627    session_id = ldq_le_p(&req.header.session_id);
 628
 629    switch (opcode) {
 630    case VIRTIO_CRYPTO_CIPHER_ENCRYPT:
 631    case VIRTIO_CRYPTO_CIPHER_DECRYPT:
 632        ret = virtio_crypto_handle_sym_req(vcrypto,
 633                         &req.u.sym_req,
 634                         &sym_op_info,
 635                         out_iov, out_num);
 636        /* Serious errors, need to reset virtio crypto device */
 637        if (ret == -EFAULT) {
 638            return -1;
 639        } else if (ret == -VIRTIO_CRYPTO_NOTSUPP) {
 640            virtio_crypto_req_complete(request, VIRTIO_CRYPTO_NOTSUPP);
 641            virtio_crypto_free_request(request);
 642        } else {
 643            sym_op_info->session_id = session_id;
 644
 645            /* Set request's parameter */
 646            request->flags = CRYPTODEV_BACKEND_ALG_SYM;
 647            request->u.sym_op_info = sym_op_info;
 648            ret = cryptodev_backend_crypto_operation(vcrypto->cryptodev,
 649                                    request, queue_index, &local_err);
 650            if (ret < 0) {
 651                status = -ret;
 652                if (local_err) {
 653                    error_report_err(local_err);
 654                }
 655            } else { /* ret == VIRTIO_CRYPTO_OK */
 656                status = ret;
 657            }
 658            virtio_crypto_req_complete(request, status);
 659            virtio_crypto_free_request(request);
 660        }
 661        break;
 662    case VIRTIO_CRYPTO_HASH:
 663    case VIRTIO_CRYPTO_MAC:
 664    case VIRTIO_CRYPTO_AEAD_ENCRYPT:
 665    case VIRTIO_CRYPTO_AEAD_DECRYPT:
 666    default:
 667        error_report("virtio-crypto unsupported dataq opcode: %u",
 668                     opcode);
 669        virtio_crypto_req_complete(request, VIRTIO_CRYPTO_NOTSUPP);
 670        virtio_crypto_free_request(request);
 671    }
 672
 673    return 0;
 674}
 675
 676static void virtio_crypto_handle_dataq(VirtIODevice *vdev, VirtQueue *vq)
 677{
 678    VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(vdev);
 679    VirtIOCryptoReq *req;
 680
 681    while ((req = virtio_crypto_get_request(vcrypto, vq))) {
 682        if (virtio_crypto_handle_request(req) < 0) {
 683            virtqueue_detach_element(req->vq, &req->elem, 0);
 684            virtio_crypto_free_request(req);
 685            break;
 686        }
 687    }
 688}
 689
 690static void virtio_crypto_dataq_bh(void *opaque)
 691{
 692    VirtIOCryptoQueue *q = opaque;
 693    VirtIOCrypto *vcrypto = q->vcrypto;
 694    VirtIODevice *vdev = VIRTIO_DEVICE(vcrypto);
 695
 696    /* This happens when device was stopped but BH wasn't. */
 697    if (!vdev->vm_running) {
 698        return;
 699    }
 700
 701    /* Just in case the driver is not ready on more */
 702    if (unlikely(!(vdev->status & VIRTIO_CONFIG_S_DRIVER_OK))) {
 703        return;
 704    }
 705
 706    for (;;) {
 707        virtio_crypto_handle_dataq(vdev, q->dataq);
 708        virtio_queue_set_notification(q->dataq, 1);
 709
 710        /* Are we done or did the guest add more buffers? */
 711        if (virtio_queue_empty(q->dataq)) {
 712            break;
 713        }
 714
 715        virtio_queue_set_notification(q->dataq, 0);
 716    }
 717}
 718
 719static void
 720virtio_crypto_handle_dataq_bh(VirtIODevice *vdev, VirtQueue *vq)
 721{
 722    VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(vdev);
 723    VirtIOCryptoQueue *q =
 724         &vcrypto->vqs[virtio_crypto_vq2q(virtio_get_queue_index(vq))];
 725
 726    /* This happens when device was stopped but VCPU wasn't. */
 727    if (!vdev->vm_running) {
 728        return;
 729    }
 730    virtio_queue_set_notification(vq, 0);
 731    qemu_bh_schedule(q->dataq_bh);
 732}
 733
 734static uint64_t virtio_crypto_get_features(VirtIODevice *vdev,
 735                                           uint64_t features,
 736                                           Error **errp)
 737{
 738    return features;
 739}
 740
 741static void virtio_crypto_reset(VirtIODevice *vdev)
 742{
 743    VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(vdev);
 744    /* multiqueue is disabled by default */
 745    vcrypto->curr_queues = 1;
 746    if (!cryptodev_backend_is_ready(vcrypto->cryptodev)) {
 747        vcrypto->status &= ~VIRTIO_CRYPTO_S_HW_READY;
 748    } else {
 749        vcrypto->status |= VIRTIO_CRYPTO_S_HW_READY;
 750    }
 751}
 752
 753static void virtio_crypto_init_config(VirtIODevice *vdev)
 754{
 755    VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(vdev);
 756
 757    vcrypto->conf.crypto_services =
 758                     vcrypto->conf.cryptodev->conf.crypto_services;
 759    vcrypto->conf.cipher_algo_l =
 760                     vcrypto->conf.cryptodev->conf.cipher_algo_l;
 761    vcrypto->conf.cipher_algo_h =
 762                     vcrypto->conf.cryptodev->conf.cipher_algo_h;
 763    vcrypto->conf.hash_algo = vcrypto->conf.cryptodev->conf.hash_algo;
 764    vcrypto->conf.mac_algo_l = vcrypto->conf.cryptodev->conf.mac_algo_l;
 765    vcrypto->conf.mac_algo_h = vcrypto->conf.cryptodev->conf.mac_algo_h;
 766    vcrypto->conf.aead_algo = vcrypto->conf.cryptodev->conf.aead_algo;
 767    vcrypto->conf.max_cipher_key_len =
 768                  vcrypto->conf.cryptodev->conf.max_cipher_key_len;
 769    vcrypto->conf.max_auth_key_len =
 770                  vcrypto->conf.cryptodev->conf.max_auth_key_len;
 771    vcrypto->conf.max_size = vcrypto->conf.cryptodev->conf.max_size;
 772}
 773
 774static void virtio_crypto_device_realize(DeviceState *dev, Error **errp)
 775{
 776    VirtIODevice *vdev = VIRTIO_DEVICE(dev);
 777    VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(dev);
 778    int i;
 779
 780    vcrypto->cryptodev = vcrypto->conf.cryptodev;
 781    if (vcrypto->cryptodev == NULL) {
 782        error_setg(errp, "'cryptodev' parameter expects a valid object");
 783        return;
 784    } else if (cryptodev_backend_is_used(vcrypto->cryptodev)) {
 785        char *path = object_get_canonical_path_component(OBJECT(vcrypto->conf.cryptodev));
 786        error_setg(errp, "can't use already used cryptodev backend: %s", path);
 787        g_free(path);
 788        return;
 789    }
 790
 791    vcrypto->max_queues = MAX(vcrypto->cryptodev->conf.peers.queues, 1);
 792    if (vcrypto->max_queues + 1 > VIRTIO_QUEUE_MAX) {
 793        error_setg(errp, "Invalid number of queues (= %" PRIu32 "), "
 794                   "must be a positive integer less than %d.",
 795                   vcrypto->max_queues, VIRTIO_QUEUE_MAX);
 796        return;
 797    }
 798
 799    virtio_init(vdev, "virtio-crypto", VIRTIO_ID_CRYPTO, vcrypto->config_size);
 800    vcrypto->curr_queues = 1;
 801    vcrypto->vqs = g_malloc0(sizeof(VirtIOCryptoQueue) * vcrypto->max_queues);
 802    for (i = 0; i < vcrypto->max_queues; i++) {
 803        vcrypto->vqs[i].dataq =
 804                 virtio_add_queue(vdev, 1024, virtio_crypto_handle_dataq_bh);
 805        vcrypto->vqs[i].dataq_bh =
 806                 qemu_bh_new(virtio_crypto_dataq_bh, &vcrypto->vqs[i]);
 807        vcrypto->vqs[i].vcrypto = vcrypto;
 808    }
 809
 810    vcrypto->ctrl_vq = virtio_add_queue(vdev, 64, virtio_crypto_handle_ctrl);
 811    if (!cryptodev_backend_is_ready(vcrypto->cryptodev)) {
 812        vcrypto->status &= ~VIRTIO_CRYPTO_S_HW_READY;
 813    } else {
 814        vcrypto->status |= VIRTIO_CRYPTO_S_HW_READY;
 815    }
 816
 817    virtio_crypto_init_config(vdev);
 818    cryptodev_backend_set_used(vcrypto->cryptodev, true);
 819}
 820
 821static void virtio_crypto_device_unrealize(DeviceState *dev, Error **errp)
 822{
 823    VirtIODevice *vdev = VIRTIO_DEVICE(dev);
 824    VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(dev);
 825    VirtIOCryptoQueue *q;
 826    int i, max_queues;
 827
 828    max_queues = vcrypto->multiqueue ? vcrypto->max_queues : 1;
 829    for (i = 0; i < max_queues; i++) {
 830        virtio_del_queue(vdev, i);
 831        q = &vcrypto->vqs[i];
 832        qemu_bh_delete(q->dataq_bh);
 833    }
 834
 835    g_free(vcrypto->vqs);
 836
 837    virtio_cleanup(vdev);
 838    cryptodev_backend_set_used(vcrypto->cryptodev, false);
 839}
 840
 841static const VMStateDescription vmstate_virtio_crypto = {
 842    .name = "virtio-crypto",
 843    .unmigratable = 1,
 844    .minimum_version_id = VIRTIO_CRYPTO_VM_VERSION,
 845    .version_id = VIRTIO_CRYPTO_VM_VERSION,
 846    .fields = (VMStateField[]) {
 847        VMSTATE_VIRTIO_DEVICE,
 848        VMSTATE_END_OF_LIST()
 849    },
 850};
 851
 852static Property virtio_crypto_properties[] = {
 853    DEFINE_PROP_LINK("cryptodev", VirtIOCrypto, conf.cryptodev,
 854                     TYPE_CRYPTODEV_BACKEND, CryptoDevBackend *),
 855    DEFINE_PROP_END_OF_LIST(),
 856};
 857
 858static void virtio_crypto_get_config(VirtIODevice *vdev, uint8_t *config)
 859{
 860    VirtIOCrypto *c = VIRTIO_CRYPTO(vdev);
 861    struct virtio_crypto_config crypto_cfg = {};
 862
 863    /*
 864     * Virtio-crypto device conforms to VIRTIO 1.0 which is always LE,
 865     * so we can use LE accessors directly.
 866     */
 867    stl_le_p(&crypto_cfg.status, c->status);
 868    stl_le_p(&crypto_cfg.max_dataqueues, c->max_queues);
 869    stl_le_p(&crypto_cfg.crypto_services, c->conf.crypto_services);
 870    stl_le_p(&crypto_cfg.cipher_algo_l, c->conf.cipher_algo_l);
 871    stl_le_p(&crypto_cfg.cipher_algo_h, c->conf.cipher_algo_h);
 872    stl_le_p(&crypto_cfg.hash_algo, c->conf.hash_algo);
 873    stl_le_p(&crypto_cfg.mac_algo_l, c->conf.mac_algo_l);
 874    stl_le_p(&crypto_cfg.mac_algo_h, c->conf.mac_algo_h);
 875    stl_le_p(&crypto_cfg.aead_algo, c->conf.aead_algo);
 876    stl_le_p(&crypto_cfg.max_cipher_key_len, c->conf.max_cipher_key_len);
 877    stl_le_p(&crypto_cfg.max_auth_key_len, c->conf.max_auth_key_len);
 878    stq_le_p(&crypto_cfg.max_size, c->conf.max_size);
 879
 880    memcpy(config, &crypto_cfg, c->config_size);
 881}
 882
 883static void virtio_crypto_class_init(ObjectClass *klass, void *data)
 884{
 885    DeviceClass *dc = DEVICE_CLASS(klass);
 886    VirtioDeviceClass *vdc = VIRTIO_DEVICE_CLASS(klass);
 887
 888    dc->props = virtio_crypto_properties;
 889    dc->vmsd = &vmstate_virtio_crypto;
 890    set_bit(DEVICE_CATEGORY_MISC, dc->categories);
 891    vdc->realize = virtio_crypto_device_realize;
 892    vdc->unrealize = virtio_crypto_device_unrealize;
 893    vdc->get_config = virtio_crypto_get_config;
 894    vdc->get_features = virtio_crypto_get_features;
 895    vdc->reset = virtio_crypto_reset;
 896}
 897
 898static void virtio_crypto_instance_init(Object *obj)
 899{
 900    VirtIOCrypto *vcrypto = VIRTIO_CRYPTO(obj);
 901
 902    /*
 903     * The default config_size is sizeof(struct virtio_crypto_config).
 904     * Can be overriden with virtio_crypto_set_config_size.
 905     */
 906    vcrypto->config_size = sizeof(struct virtio_crypto_config);
 907}
 908
 909static const TypeInfo virtio_crypto_info = {
 910    .name = TYPE_VIRTIO_CRYPTO,
 911    .parent = TYPE_VIRTIO_DEVICE,
 912    .instance_size = sizeof(VirtIOCrypto),
 913    .instance_init = virtio_crypto_instance_init,
 914    .class_init = virtio_crypto_class_init,
 915};
 916
 917static void virtio_register_types(void)
 918{
 919    type_register_static(&virtio_crypto_info);
 920}
 921
 922type_init(virtio_register_types)
 923