crypto/aesni_gcm: add dynamic logging
[dpdk.git] / drivers / crypto / aesni_gcm / aesni_gcm_pmd_ops.c
1 /* SPDX-License-Identifier: BSD-3-Clause
2  * Copyright(c) 2016 Intel Corporation
3  */
4
5 #include <string.h>
6
7 #include <rte_common.h>
8 #include <rte_malloc.h>
9 #include <rte_cryptodev_pmd.h>
10
11 #include "aesni_gcm_pmd_private.h"
12
13 static const struct rte_cryptodev_capabilities aesni_gcm_pmd_capabilities[] = {
14         {       /* AES GMAC (AUTH) */
15                 .op = RTE_CRYPTO_OP_TYPE_SYMMETRIC,
16                 {.sym = {
17                         .xform_type = RTE_CRYPTO_SYM_XFORM_AUTH,
18                         {.auth = {
19                                 .algo = RTE_CRYPTO_AUTH_AES_GMAC,
20                                 .block_size = 16,
21                                 .key_size = {
22                                         .min = 16,
23                                         .max = 32,
24                                         .increment = 8
25                                 },
26                                 .digest_size = {
27                                         .min = 8,
28                                         .max = 16,
29                                         .increment = 4
30                                 },
31                                 .iv_size = {
32                                         .min = 12,
33                                         .max = 12,
34                                         .increment = 0
35                                 }
36                         }, }
37                 }, }
38         },
39         {       /* AES GCM */
40                 .op = RTE_CRYPTO_OP_TYPE_SYMMETRIC,
41                 {.sym = {
42                         .xform_type = RTE_CRYPTO_SYM_XFORM_AEAD,
43                         {.aead = {
44                                 .algo = RTE_CRYPTO_AEAD_AES_GCM,
45                                 .block_size = 16,
46                                 .key_size = {
47                                         .min = 16,
48                                         .max = 32,
49                                         .increment = 8
50                                 },
51                                 .digest_size = {
52                                         .min = 8,
53                                         .max = 16,
54                                         .increment = 4
55                                 },
56                                 .aad_size = {
57                                         .min = 0,
58                                         .max = 65535,
59                                         .increment = 1
60                                 },
61                                 .iv_size = {
62                                         .min = 12,
63                                         .max = 12,
64                                         .increment = 0
65                                 }
66                         }, }
67                 }, }
68         },
69         RTE_CRYPTODEV_END_OF_CAPABILITIES_LIST()
70 };
71
72 /** Configure device */
73 static int
74 aesni_gcm_pmd_config(__rte_unused struct rte_cryptodev *dev,
75                 __rte_unused struct rte_cryptodev_config *config)
76 {
77         return 0;
78 }
79
80 /** Start device */
81 static int
82 aesni_gcm_pmd_start(__rte_unused struct rte_cryptodev *dev)
83 {
84         return 0;
85 }
86
87 /** Stop device */
88 static void
89 aesni_gcm_pmd_stop(__rte_unused struct rte_cryptodev *dev)
90 {
91 }
92
93 /** Close device */
94 static int
95 aesni_gcm_pmd_close(__rte_unused struct rte_cryptodev *dev)
96 {
97         return 0;
98 }
99
100
101 /** Get device statistics */
102 static void
103 aesni_gcm_pmd_stats_get(struct rte_cryptodev *dev,
104                 struct rte_cryptodev_stats *stats)
105 {
106         int qp_id;
107
108         for (qp_id = 0; qp_id < dev->data->nb_queue_pairs; qp_id++) {
109                 struct aesni_gcm_qp *qp = dev->data->queue_pairs[qp_id];
110
111                 stats->enqueued_count += qp->qp_stats.enqueued_count;
112                 stats->dequeued_count += qp->qp_stats.dequeued_count;
113
114                 stats->enqueue_err_count += qp->qp_stats.enqueue_err_count;
115                 stats->dequeue_err_count += qp->qp_stats.dequeue_err_count;
116         }
117 }
118
119 /** Reset device statistics */
120 static void
121 aesni_gcm_pmd_stats_reset(struct rte_cryptodev *dev)
122 {
123         int qp_id;
124
125         for (qp_id = 0; qp_id < dev->data->nb_queue_pairs; qp_id++) {
126                 struct aesni_gcm_qp *qp = dev->data->queue_pairs[qp_id];
127
128                 memset(&qp->qp_stats, 0, sizeof(qp->qp_stats));
129         }
130 }
131
132
133 /** Get device info */
134 static void
135 aesni_gcm_pmd_info_get(struct rte_cryptodev *dev,
136                 struct rte_cryptodev_info *dev_info)
137 {
138         struct aesni_gcm_private *internals = dev->data->dev_private;
139
140         if (dev_info != NULL) {
141                 dev_info->driver_id = dev->driver_id;
142                 dev_info->feature_flags = dev->feature_flags;
143                 dev_info->capabilities = aesni_gcm_pmd_capabilities;
144
145                 dev_info->max_nb_queue_pairs = internals->max_nb_queue_pairs;
146                 dev_info->sym.max_nb_sessions = internals->max_nb_sessions;
147         }
148 }
149
150 /** Release queue pair */
151 static int
152 aesni_gcm_pmd_qp_release(struct rte_cryptodev *dev, uint16_t qp_id)
153 {
154         if (dev->data->queue_pairs[qp_id] != NULL) {
155                 rte_free(dev->data->queue_pairs[qp_id]);
156                 dev->data->queue_pairs[qp_id] = NULL;
157         }
158         return 0;
159 }
160
161 /** set a unique name for the queue pair based on it's name, dev_id and qp_id */
162 static int
163 aesni_gcm_pmd_qp_set_unique_name(struct rte_cryptodev *dev,
164                 struct aesni_gcm_qp *qp)
165 {
166         unsigned n = snprintf(qp->name, sizeof(qp->name),
167                         "aesni_gcm_pmd_%u_qp_%u",
168                         dev->data->dev_id, qp->id);
169
170         if (n >= sizeof(qp->name))
171                 return -1;
172
173         return 0;
174 }
175
176 /** Create a ring to place process packets on */
177 static struct rte_ring *
178 aesni_gcm_pmd_qp_create_processed_pkts_ring(struct aesni_gcm_qp *qp,
179                 unsigned ring_size, int socket_id)
180 {
181         struct rte_ring *r;
182
183         r = rte_ring_lookup(qp->name);
184         if (r) {
185                 if (rte_ring_get_size(r) >= ring_size) {
186                         AESNI_GCM_LOG(INFO, "Reusing existing ring %s for processed"
187                                 " packets", qp->name);
188                         return r;
189                 }
190                 AESNI_GCM_LOG(ERR, "Unable to reuse existing ring %s for processed"
191                                 " packets", qp->name);
192                 return NULL;
193         }
194
195         return rte_ring_create(qp->name, ring_size, socket_id,
196                         RING_F_SP_ENQ | RING_F_SC_DEQ);
197 }
198
199 /** Setup a queue pair */
200 static int
201 aesni_gcm_pmd_qp_setup(struct rte_cryptodev *dev, uint16_t qp_id,
202                 const struct rte_cryptodev_qp_conf *qp_conf,
203                 int socket_id, struct rte_mempool *session_pool)
204 {
205         struct aesni_gcm_qp *qp = NULL;
206         struct aesni_gcm_private *internals = dev->data->dev_private;
207
208         /* Free memory prior to re-allocation if needed. */
209         if (dev->data->queue_pairs[qp_id] != NULL)
210                 aesni_gcm_pmd_qp_release(dev, qp_id);
211
212         /* Allocate the queue pair data structure. */
213         qp = rte_zmalloc_socket("AES-NI PMD Queue Pair", sizeof(*qp),
214                                         RTE_CACHE_LINE_SIZE, socket_id);
215         if (qp == NULL)
216                 return (-ENOMEM);
217
218         qp->id = qp_id;
219         dev->data->queue_pairs[qp_id] = qp;
220
221         if (aesni_gcm_pmd_qp_set_unique_name(dev, qp))
222                 goto qp_setup_cleanup;
223
224         qp->ops = (const struct aesni_gcm_ops *)gcm_ops[internals->vector_mode];
225
226         qp->processed_pkts = aesni_gcm_pmd_qp_create_processed_pkts_ring(qp,
227                         qp_conf->nb_descriptors, socket_id);
228         if (qp->processed_pkts == NULL)
229                 goto qp_setup_cleanup;
230
231         qp->sess_mp = session_pool;
232
233         memset(&qp->qp_stats, 0, sizeof(qp->qp_stats));
234
235         return 0;
236
237 qp_setup_cleanup:
238         if (qp)
239                 rte_free(qp);
240
241         return -1;
242 }
243
244 /** Start queue pair */
245 static int
246 aesni_gcm_pmd_qp_start(__rte_unused struct rte_cryptodev *dev,
247                 __rte_unused uint16_t queue_pair_id)
248 {
249         return -ENOTSUP;
250 }
251
252 /** Stop queue pair */
253 static int
254 aesni_gcm_pmd_qp_stop(__rte_unused struct rte_cryptodev *dev,
255                 __rte_unused uint16_t queue_pair_id)
256 {
257         return -ENOTSUP;
258 }
259
260 /** Return the number of allocated queue pairs */
261 static uint32_t
262 aesni_gcm_pmd_qp_count(struct rte_cryptodev *dev)
263 {
264         return dev->data->nb_queue_pairs;
265 }
266
267 /** Returns the size of the aesni gcm session structure */
268 static unsigned
269 aesni_gcm_pmd_session_get_size(struct rte_cryptodev *dev __rte_unused)
270 {
271         return sizeof(struct aesni_gcm_session);
272 }
273
274 /** Configure a aesni gcm session from a crypto xform chain */
275 static int
276 aesni_gcm_pmd_session_configure(struct rte_cryptodev *dev __rte_unused,
277                 struct rte_crypto_sym_xform *xform,
278                 struct rte_cryptodev_sym_session *sess,
279                 struct rte_mempool *mempool)
280 {
281         void *sess_private_data;
282         int ret;
283         struct aesni_gcm_private *internals = dev->data->dev_private;
284
285         if (unlikely(sess == NULL)) {
286                 AESNI_GCM_LOG(ERR, "invalid session struct");
287                 return -EINVAL;
288         }
289
290         if (rte_mempool_get(mempool, &sess_private_data)) {
291                 AESNI_GCM_LOG(ERR,
292                                 "Couldn't get object from session mempool");
293                 return -ENOMEM;
294         }
295         ret = aesni_gcm_set_session_parameters(gcm_ops[internals->vector_mode],
296                                 sess_private_data, xform);
297         if (ret != 0) {
298                 AESNI_GCM_LOG(ERR, "failed configure session parameters");
299
300                 /* Return session to mempool */
301                 rte_mempool_put(mempool, sess_private_data);
302                 return ret;
303         }
304
305         set_session_private_data(sess, dev->driver_id,
306                         sess_private_data);
307
308         return 0;
309 }
310
311 /** Clear the memory of session so it doesn't leave key material behind */
312 static void
313 aesni_gcm_pmd_session_clear(struct rte_cryptodev *dev,
314                 struct rte_cryptodev_sym_session *sess)
315 {
316         uint8_t index = dev->driver_id;
317         void *sess_priv = get_session_private_data(sess, index);
318
319         /* Zero out the whole structure */
320         if (sess_priv) {
321                 memset(sess_priv, 0, sizeof(struct aesni_gcm_session));
322                 struct rte_mempool *sess_mp = rte_mempool_from_obj(sess_priv);
323                 set_session_private_data(sess, index, NULL);
324                 rte_mempool_put(sess_mp, sess_priv);
325         }
326 }
327
328 struct rte_cryptodev_ops aesni_gcm_pmd_ops = {
329                 .dev_configure          = aesni_gcm_pmd_config,
330                 .dev_start              = aesni_gcm_pmd_start,
331                 .dev_stop               = aesni_gcm_pmd_stop,
332                 .dev_close              = aesni_gcm_pmd_close,
333
334                 .stats_get              = aesni_gcm_pmd_stats_get,
335                 .stats_reset            = aesni_gcm_pmd_stats_reset,
336
337                 .dev_infos_get          = aesni_gcm_pmd_info_get,
338
339                 .queue_pair_setup       = aesni_gcm_pmd_qp_setup,
340                 .queue_pair_release     = aesni_gcm_pmd_qp_release,
341                 .queue_pair_start       = aesni_gcm_pmd_qp_start,
342                 .queue_pair_stop        = aesni_gcm_pmd_qp_stop,
343                 .queue_pair_count       = aesni_gcm_pmd_qp_count,
344
345                 .session_get_size       = aesni_gcm_pmd_session_get_size,
346                 .session_configure      = aesni_gcm_pmd_session_configure,
347                 .session_clear          = aesni_gcm_pmd_session_clear
348 };
349
350 struct rte_cryptodev_ops *rte_aesni_gcm_pmd_ops = &aesni_gcm_pmd_ops;