diff --git a/src/platform/datapath_kqueue.c b/src/platform/datapath_kqueue.c index cbd7921e19..e5a441ed3c 100644 --- a/src/platform/datapath_kqueue.c +++ b/src/platform/datapath_kqueue.c @@ -1311,11 +1311,13 @@ CxPlatSocketContextSendComplete( } void -CxPlatDataPathSocketProcessIoCompletion( - _In_ CXPLAT_SOCKET_CONTEXT* SocketContext, +CxPlatSocketContextIoEventComplete( _In_ CXPLAT_CQE* Cqe ) { + CXPLAT_SOCKET_CONTEXT* SocketContext = + CXPLAT_CONTAINING_RECORD(CxPlatCqeGetSqe(Cqe), CXPLAT_SOCKET_CONTEXT, IoSqe); + if (!CxPlatRundownAcquire(&SocketContext->UpcallRundown)) { return; }