667b057cd7
PR-URL: https://github.com/nodejs/node/pull/53464 Reviewed-By: Chemi Atlow <chemi@atlow.co.il> Reviewed-By: Marco Ippolito <marcoippolito54@gmail.com> Reviewed-By: Rafael Gonzaga <rafael.nunu@hotmail.com> Reviewed-By: James M Snell <jasnell@gmail.com>
58 lines
1.2 KiB
C++
58 lines
1.2 KiB
C++
/*
|
|
* Copyright (C) 2024 Intel Corporation. All rights reserved.
|
|
* Authors:
|
|
* Gustavo A Espinoza <gustavo.adolfo.espinoza.quintero@intel.com>
|
|
* <gustavoaespinozaq@hotmail.com>
|
|
*
|
|
* For conditions of distribution and use, see copyright notice in zlib.h
|
|
*/
|
|
#include <qat/cpa.h>
|
|
#include <qat/icp_sal_poll.h>
|
|
|
|
#include "qat_task.hpp"
|
|
|
|
namespace qat
|
|
{
|
|
|
|
QATTask::QATTask(std::shared_ptr<Instance> &qat_instance,
|
|
std::unique_ptr<IOBuffers> &&buffers,
|
|
std::unique_ptr<CpaDcRqResults> &&dc_results):
|
|
qat_instance_(qat_instance),
|
|
io_buffers_(std::move(buffers)),
|
|
dc_results_(std::move(dc_results)),
|
|
completed_(false)
|
|
{
|
|
}
|
|
|
|
void QATTask::WaitCompletion()
|
|
{
|
|
if (completed_) {
|
|
return;
|
|
}
|
|
|
|
while (!completed_) {
|
|
icp_sal_DcPollInstance(qat_instance_->GetHandle(), 0);
|
|
}
|
|
}
|
|
|
|
IOBuffers *QATTask::GetBuffers()
|
|
{
|
|
return io_buffers_.get();
|
|
}
|
|
|
|
CpaDcRqResults *QATTask::GetResults()
|
|
{
|
|
return dc_results_.get();
|
|
}
|
|
|
|
void dc_callback(void *callback_tag, CpaStatus status)
|
|
{
|
|
if (!callback_tag) {
|
|
return;
|
|
}
|
|
// Ugly and dangerous
|
|
QATTask* task = static_cast<QATTask*>(callback_tag);
|
|
task->completed_ = true;
|
|
}
|
|
|
|
} |