funeth_ktls.c 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155
  1. // SPDX-License-Identifier: (GPL-2.0-only OR BSD-3-Clause)
  2. #include "funeth.h"
  3. #include "funeth_ktls.h"
  4. static int fun_admin_ktls_create(struct funeth_priv *fp, unsigned int id)
  5. {
  6. struct fun_admin_ktls_create_req req = {
  7. .common = FUN_ADMIN_REQ_COMMON_INIT2(FUN_ADMIN_OP_KTLS,
  8. sizeof(req)),
  9. .subop = FUN_ADMIN_SUBOP_CREATE,
  10. .id = cpu_to_be32(id),
  11. };
  12. return fun_submit_admin_sync_cmd(fp->fdev, &req.common, NULL, 0, 0);
  13. }
  14. static int fun_ktls_add(struct net_device *netdev, struct sock *sk,
  15. enum tls_offload_ctx_dir direction,
  16. struct tls_crypto_info *crypto_info,
  17. u32 start_offload_tcp_sn)
  18. {
  19. struct funeth_priv *fp = netdev_priv(netdev);
  20. struct fun_admin_ktls_modify_req req = {
  21. .common = FUN_ADMIN_REQ_COMMON_INIT2(FUN_ADMIN_OP_KTLS,
  22. sizeof(req)),
  23. .subop = FUN_ADMIN_SUBOP_MODIFY,
  24. .id = cpu_to_be32(fp->ktls_id),
  25. .tcp_seq = cpu_to_be32(start_offload_tcp_sn),
  26. };
  27. struct fun_admin_ktls_modify_rsp rsp;
  28. struct fun_ktls_tx_ctx *tx_ctx;
  29. int rc;
  30. if (direction != TLS_OFFLOAD_CTX_DIR_TX)
  31. return -EOPNOTSUPP;
  32. if (crypto_info->version == TLS_1_2_VERSION)
  33. req.version = FUN_KTLS_TLSV2;
  34. else
  35. return -EOPNOTSUPP;
  36. switch (crypto_info->cipher_type) {
  37. case TLS_CIPHER_AES_GCM_128: {
  38. struct tls12_crypto_info_aes_gcm_128 *c = (void *)crypto_info;
  39. req.cipher = FUN_KTLS_CIPHER_AES_GCM_128;
  40. memcpy(req.key, c->key, sizeof(c->key));
  41. memcpy(req.iv, c->iv, sizeof(c->iv));
  42. memcpy(req.salt, c->salt, sizeof(c->salt));
  43. memcpy(req.record_seq, c->rec_seq, sizeof(c->rec_seq));
  44. break;
  45. }
  46. default:
  47. return -EOPNOTSUPP;
  48. }
  49. rc = fun_submit_admin_sync_cmd(fp->fdev, &req.common, &rsp,
  50. sizeof(rsp), 0);
  51. memzero_explicit(&req, sizeof(req));
  52. if (rc)
  53. return rc;
  54. tx_ctx = tls_driver_ctx(sk, direction);
  55. tx_ctx->tlsid = rsp.tlsid;
  56. tx_ctx->next_seq = start_offload_tcp_sn;
  57. atomic64_inc(&fp->tx_tls_add);
  58. return 0;
  59. }
  60. static void fun_ktls_del(struct net_device *netdev,
  61. struct tls_context *tls_ctx,
  62. enum tls_offload_ctx_dir direction)
  63. {
  64. struct funeth_priv *fp = netdev_priv(netdev);
  65. struct fun_admin_ktls_modify_req req;
  66. struct fun_ktls_tx_ctx *tx_ctx;
  67. if (direction != TLS_OFFLOAD_CTX_DIR_TX)
  68. return;
  69. tx_ctx = __tls_driver_ctx(tls_ctx, direction);
  70. req.common = FUN_ADMIN_REQ_COMMON_INIT2(FUN_ADMIN_OP_KTLS,
  71. offsetof(struct fun_admin_ktls_modify_req, tcp_seq));
  72. req.subop = FUN_ADMIN_SUBOP_MODIFY;
  73. req.flags = cpu_to_be16(FUN_KTLS_MODIFY_REMOVE);
  74. req.id = cpu_to_be32(fp->ktls_id);
  75. req.tlsid = tx_ctx->tlsid;
  76. fun_submit_admin_sync_cmd(fp->fdev, &req.common, NULL, 0, 0);
  77. atomic64_inc(&fp->tx_tls_del);
  78. }
  79. static int fun_ktls_resync(struct net_device *netdev, struct sock *sk, u32 seq,
  80. u8 *rcd_sn, enum tls_offload_ctx_dir direction)
  81. {
  82. struct funeth_priv *fp = netdev_priv(netdev);
  83. struct fun_admin_ktls_modify_req req;
  84. struct fun_ktls_tx_ctx *tx_ctx;
  85. int rc;
  86. if (direction != TLS_OFFLOAD_CTX_DIR_TX)
  87. return -EOPNOTSUPP;
  88. tx_ctx = tls_driver_ctx(sk, direction);
  89. req.common = FUN_ADMIN_REQ_COMMON_INIT2(FUN_ADMIN_OP_KTLS,
  90. offsetof(struct fun_admin_ktls_modify_req, key));
  91. req.subop = FUN_ADMIN_SUBOP_MODIFY;
  92. req.flags = 0;
  93. req.id = cpu_to_be32(fp->ktls_id);
  94. req.tlsid = tx_ctx->tlsid;
  95. req.tcp_seq = cpu_to_be32(seq);
  96. req.version = 0;
  97. req.cipher = 0;
  98. memcpy(req.record_seq, rcd_sn, sizeof(req.record_seq));
  99. atomic64_inc(&fp->tx_tls_resync);
  100. rc = fun_submit_admin_sync_cmd(fp->fdev, &req.common, NULL, 0, 0);
  101. if (!rc)
  102. tx_ctx->next_seq = seq;
  103. return rc;
  104. }
  105. static const struct tlsdev_ops fun_ktls_ops = {
  106. .tls_dev_add = fun_ktls_add,
  107. .tls_dev_del = fun_ktls_del,
  108. .tls_dev_resync = fun_ktls_resync,
  109. };
  110. int fun_ktls_init(struct net_device *netdev)
  111. {
  112. struct funeth_priv *fp = netdev_priv(netdev);
  113. int rc;
  114. rc = fun_admin_ktls_create(fp, netdev->dev_port);
  115. if (rc)
  116. return rc;
  117. fp->ktls_id = netdev->dev_port;
  118. netdev->tlsdev_ops = &fun_ktls_ops;
  119. netdev->hw_features |= NETIF_F_HW_TLS_TX;
  120. netdev->features |= NETIF_F_HW_TLS_TX;
  121. return 0;
  122. }
  123. void fun_ktls_cleanup(struct funeth_priv *fp)
  124. {
  125. if (fp->ktls_id == FUN_HCI_ID_INVALID)
  126. return;
  127. fun_res_destroy(fp->fdev, FUN_ADMIN_OP_KTLS, 0, fp->ktls_id);
  128. fp->ktls_id = FUN_HCI_ID_INVALID;
  129. }