Lines Matching refs:pEndpoint

32 DECLINLINE(void) pdmacFileAioMgrEpAddTaskList(PPDMASYNCCOMPLETIONENDPOINTFILE pEndpoint, PPDMACTASKFILE pTaskHead)
35 if (!pEndpoint->AioMgr.pReqsPendingHead)
37 Assert(!pEndpoint->AioMgr.pReqsPendingTail);
38 pEndpoint->AioMgr.pReqsPendingHead = pTaskHead;
42 Assert(pEndpoint->AioMgr.pReqsPendingTail);
43 pEndpoint->AioMgr.pReqsPendingTail->pNext = pTaskHead;
50 pEndpoint->AioMgr.pReqsPendingTail = pTaskHead;
58 PPDMASYNCCOMPLETIONENDPOINTFILE pEndpoint,
68 if (!pdmacEpIsTransferAllowed(&pEndpoint->Core, (uint32_t)pCurr->DataSeg.cbSeg, &msWhenNext))
80 rc = RTFileFlush(pEndpoint->hFile);
88 rc = RTFileReadAt(pEndpoint->hFile, pCurr->Off,
95 if (RT_UNLIKELY((uint64_t)pCurr->Off + pCurr->DataSeg.cbSeg > pEndpoint->cbFile))
97 ASMAtomicWriteU64(&pEndpoint->cbFile, pCurr->Off + pCurr->DataSeg.cbSeg);
98 RTFileSetSize(pEndpoint->hFile, pCurr->Off + pCurr->DataSeg.cbSeg);
101 rc = RTFileWriteAt(pEndpoint->hFile, pCurr->Off,
114 pdmacFileTaskFree(pEndpoint, pCurr);
120 pdmacFileAioMgrEpAddTaskList(pEndpoint, pTasks);
127 PPDMASYNCCOMPLETIONENDPOINTFILE pEndpoint)
130 PPDMACTASKFILE pTasks = pEndpoint->AioMgr.pReqsPendingHead;
132 pEndpoint->AioMgr.pReqsPendingHead = NULL;
133 pEndpoint->AioMgr.pReqsPendingTail = NULL;
137 rc = pdmacFileAioMgrFailsafeProcessEndpointTaskList(pAioMgr, pEndpoint, pTasks);
141 pTasks = pdmacFileEpGetNewTasks(pEndpoint);
144 rc = pdmacFileAioMgrFailsafeProcessEndpointTaskList(pAioMgr, pEndpoint, pTasks);
173 PPDMASYNCCOMPLETIONENDPOINTFILE pEndpoint = pAioMgr->pEndpointsHead;
174 while (pEndpoint)
177 rc = pdmacFileAioMgrFailsafeProcessEndpoint(pAioMgr, pEndpoint);
179 pEndpoint = pEndpoint->AioMgr.pEndpointNext;
189 PPDMASYNCCOMPLETIONENDPOINTFILE pEndpointNew = pAioMgr->BlockingEventData.AddEndpoint.pEndpoint;
212 PPDMASYNCCOMPLETIONENDPOINTFILE pEndpointRemove = pAioMgr->BlockingEventData.RemoveEndpoint.pEndpoint;
233 PPDMASYNCCOMPLETIONENDPOINTFILE pEndpointClose = pAioMgr->BlockingEventData.CloseEndpoint.pEndpoint;