IoUringEngn:assembleFrameReq: Implement and use callOriginalCallback

This commit is contained in:
2025-11-13 20:53:53 -04:00
parent 67923d5f86
commit a17072c8d9
@@ -520,7 +520,7 @@ public:
// Error: no slots succeeded - no data received successfully. // Error: no slots succeeded - no data received successfully.
if (context->loop.nSucceeded.load() == 0) if (context->loop.nSucceeded.load() == 0)
{ {
context->callOriginalCb(false, context->loop); context->callOriginalCallback(false, context->loop);
return; return;
} }
@@ -552,7 +552,7 @@ public:
<< ") > nTotal (" << context->loop.nTotal << ")\n"; << ") > nTotal (" << context->loop.nTotal << ")\n";
} }
context->callOriginalCb(true, context->loop); context->callOriginalCallback(true, context->loop);
return; return;
} }
@@ -560,7 +560,7 @@ public:
{ {
// Success: some slots succeeded (less than total) // Success: some slots succeeded (less than total)
// Note: dummy fill for un-assembled slots will be implemented later // Note: dummy fill for un-assembled slots will be implemented later
context->callOriginalCb(true, context->loop); context->callOriginalCallback(true, context->loop);
return; return;
} }
@@ -571,10 +571,15 @@ public:
<< ") < nTotal (" << context->loop.nTotal << ")" << std::endl; << ") < nTotal (" << context->loop.nTotal << ")" << std::endl;
} }
context->callOriginalCb(false, context->loop); context->callOriginalCallback(false, context->loop);
return; return;
} }
void callOriginalCallback(bool success, AsynchronousLoop loop)
{
callOriginalCb(success, loop);
}
public: public:
IoUringAssemblyEngine& engine; IoUringAssemblyEngine& engine;
AsynchronousLoop loop; AsynchronousLoop loop;