#include <vnet/vnet.h>
#include <vnet/ip/ip.h>
#include <vnet/api_errno.h>
-#include <vnet/ipsec/ipsec.h>
#include <vlib/node_funcs.h>
#include <openssl/engine.h>
#include <tlsopenssl/tls_openssl.h>
openssl_evt_t ***evt_pool;
openssl_async_status_t *status;
void (*polling) (void);
+ void (*polling_conf) (void);
u8 start_polling;
ENGINE *engine;
void qat_polling ();
void qat_pre_init ();
+void qat_polling_config ();
void dasync_polling ();
struct engine_polling
char *engine;
void (*polling) (void);
void (*pre_init) (void);
+ void (*polling_conf) (void);
};
struct engine_polling engine_list[] = {
- {"qat", qat_polling, qat_pre_init},
- {"dasync", dasync_polling, NULL}
+ {"qat", qat_polling, qat_pre_init, qat_polling_config},
+ {"dasync", dasync_polling, NULL, NULL}
};
openssl_async_t openssl_async_main;
if (!strcmp (engine_list[i].engine, engine_name))
{
om->polling = engine_list[i].polling;
+ om->polling_conf = engine_list[i].polling_conf;
registered = i;
}
if (!(*evt))
*evt = clib_mem_alloc (sizeof (openssl_evt_t));
- memset (*evt, 0, sizeof (openssl_evt_t));
+ clib_memset (*evt, 0, sizeof (openssl_evt_t));
(*evt)->event_index = evt - tm->evt_pool[thread_index];
return ((*evt)->event_index);
}
int *config;
config = &om->status[thread_index].poll_config;
- if (*config)
+ if (PREDICT_TRUE (*config))
return;
ENGINE_ctrl_cmd (om->engine, "SET_INSTANCE_FOR_THREAD", thread_index,
if (om->start_polling)
{
- qat_polling_config ();
ENGINE_ctrl_cmd (om->engine, "POLL", 0, &poll_status, NULL, 0);
}
}
vlib_frame_t * f)
{
u8 thread_index;
+ openssl_async_t *om = &openssl_async_main;
+ if (om->polling_conf)
+ (*om->polling_conf) ();
thread_index = vlib_get_thread_index ();
- openssl_async_polling ();
-
- tls_resume_from_crypto (thread_index);
+ if (pool_elts (om->evt_pool[thread_index]) > 0)
+ {
+ openssl_async_polling ();
+ tls_resume_from_crypto (thread_index);
+ }
return 0;
}