Lines Matching refs:pCtxInt
83 PRTFILEAIOCTXINTERNAL pCtxInt;
123 pReqInt->pCtxInt = NULL;
177 pReqInt->pCtxInt = NULL;
238 AssertMsg(VALID_PTR(pReqInt->pCtxInt),
241 ASMAtomicDecS32(&pReqInt->pCtxInt->cRequests);
279 PRTFILEAIOCTXINTERNAL pCtxInt;
283 pCtxInt = (PRTFILEAIOCTXINTERNAL)RTMemAllocZ(sizeof(RTFILEAIOCTXINTERNAL));
284 if (RT_UNLIKELY(!pCtxInt))
288 pCtxInt->iPort = port_create();
289 if (RT_LIKELY(pCtxInt->iPort > 0))
291 pCtxInt->fFlags = fFlags;
292 pCtxInt->u32Magic = RTFILEAIOCTX_MAGIC;
293 *phAioCtx = (RTFILEAIOCTX)pCtxInt;
297 RTMemFree(pCtxInt);
309 PRTFILEAIOCTXINTERNAL pCtxInt = hAioCtx;
310 RTFILEAIOCTX_VALID_RETURN(pCtxInt);
313 if (RT_UNLIKELY(pCtxInt->cRequests))
316 close(pCtxInt->iPort);
317 ASMAtomicUoWriteU32(&pCtxInt->u32Magic, RTFILEAIOCTX_MAGIC_DEAD);
318 RTMemFree(pCtxInt);
339 PRTFILEAIOCTXINTERNAL pCtxInt = hAioCtx;
340 RTFILEAIOCTX_VALID_RETURN(pCtxInt);
361 pReqInt->pCtxInt = NULL;
367 pReqInt->PortNotifier.portnfy_port = pCtxInt->iPort;
368 pReqInt->pCtxInt = pCtxInt;
396 pReqInt->pCtxInt = NULL;
407 ASMAtomicAddS32(&pCtxInt->cRequests, cReqsSubmit);
430 ASMAtomicIncS32(&pCtxInt->cRequests);
450 PRTFILEAIOCTXINTERNAL pCtxInt = hAioCtx;
451 RTFILEAIOCTX_VALID_RETURN(pCtxInt);
456 if ( RT_UNLIKELY(ASMAtomicReadS32(&pCtxInt->cRequests) == 0)
457 && !(pCtxInt->fFlags & RTFILEAIOCTX_FLAGS_WAIT_WITHOUT_PENDING_REQUESTS))
487 rcSol = port_getn(pCtxInt->iPort, &aPortEvents[0], cRequestsToWait, &cRequests, pTimeout);
500 port_alert(pCtxInt->iPort, PORT_ALERT_SET, 0, NULL);
547 ASMAtomicSubS32(&pCtxInt->cRequests, cRequestsCompleted);
555 PRTFILEAIOCTXINTERNAL pCtxInt = hAioCtx;
556 RTFILEAIOCTX_VALID_RETURN(pCtxInt);
558 rc = port_alert(pCtxInt->iPort, PORT_ALERT_UPDATE, AIO_CONTEXT_WAKEUP_EVENT, NULL);