Lines Matching defs:pHandle
95 TIMM_OSAL_PIPE *pHandle = TIMM_OSAL_NULL;
97 pHandle =
101 if (TIMM_OSAL_NULL == pHandle)
106 TIMM_OSAL_Memset(pHandle, 0x0, sizeof(TIMM_OSAL_PIPE));
108 pHandle->pfd[0] = -1;
109 pHandle->pfd[1] = -1;
110 if (SUCCESS != pipe(pHandle->pfd))
116 pHandle->pipeSize = pipeSize;
117 pHandle->messageSize = messageSize;
118 pHandle->isFixedMessage = isFixedMessage;
119 pHandle->messageCount = 0;
120 pHandle->totalBytesInPipe = 0;
122 *pPipe = (TIMM_OSAL_PTR) pHandle;
129 TIMM_OSAL_Free(pHandle);
147 TIMM_OSAL_PIPE *pHandle = (TIMM_OSAL_PIPE *) pPipe;
149 if (TIMM_OSAL_NULL == pHandle)
155 if (SUCCESS != close(pHandle->pfd[0]))
160 if (SUCCESS != close(pHandle->pfd[1]))
166 TIMM_OSAL_Free(pHandle);
187 TIMM_OSAL_PIPE *pHandle = (TIMM_OSAL_PIPE *) pPipe;
195 lSizeWritten = write(pHandle->pfd[1], pMessage, size);
205 pHandle->messageCount++;
206 pHandle->totalBytesInPipe += size;
231 TIMM_OSAL_PIPE *pHandle = (TIMM_OSAL_PIPE *) pPipe;
242 lSizeWritten = write(pHandle->pfd[1], pMessage, size);
251 pHandle->messageCount++;
254 if (pHandle->messageCount > 1)
258 (TIMM_OSAL_U8 *) TIMM_OSAL_Malloc(pHandle->
269 read(pHandle->pfd[0], tempPtr, pHandle->totalBytesInPipe);
273 write(pHandle->pfd[1], tempPtr,
274 pHandle->totalBytesInPipe);
283 pHandle->totalBytesInPipe += size;
310 TIMM_OSAL_PIPE *pHandle = (TIMM_OSAL_PIPE *) pPipe;
318 if ((pHandle->messageCount == 0) && (timeout == TIMM_OSAL_NO_SUSPEND))
332 *actualSize = lSizeRead = read(pHandle->pfd[0], pMessage, size);
342 pHandle->messageCount--;
343 pHandle->totalBytesInPipe -= size;
368 TIMM_OSAL_PIPE *pHandle = (TIMM_OSAL_PIPE *) pPipe;
370 status = NU_Reset_Pipe(&(pHandle->pipe));
396 TIMM_OSAL_PIPE *pHandle = (TIMM_OSAL_PIPE *) pPipe;
399 TIMM_OSAL_PIPE *pHandle = (TIMM_OSAL_PIPE *) pPipe;
400 PI_PCB *pipe = (PI_PCB *) & (pHandle->pipe);
411 if (pHandle->messageCount <= 0)
437 TIMM_OSAL_PIPE *pHandle = (TIMM_OSAL_PIPE *) pPipe;
440 TIMM_OSAL_PIPE *pHandle = (TIMM_OSAL_PIPE *) pPipe;
441 PI_PCB *pipe = (PI_PCB *) & (pHandle->pipe);
447 *count = pHandle->messageCount;
