Lines Matching refs:pPipe
78 oslPipe pPipe; in __osl_createPipeImpl() local
80 pPipe = (oslPipe) rtl_allocateZeroMemory(sizeof(struct oslPipeImpl)); in __osl_createPipeImpl()
82 pPipe->m_bClosed = sal_False; in __osl_createPipeImpl()
83 pPipe->m_Reference = 0; in __osl_createPipeImpl()
84 pPipe->m_Name = NULL; in __osl_createPipeImpl()
85 pPipe->m_File = INVALID_HANDLE_VALUE; in __osl_createPipeImpl()
86 pPipe->m_NamedObject = INVALID_HANDLE_VALUE; in __osl_createPipeImpl()
88 pPipe->m_ReadEvent = CreateEvent(NULL, TRUE, FALSE, NULL); in __osl_createPipeImpl()
89 pPipe->m_WriteEvent = CreateEvent(NULL, TRUE, FALSE, NULL); in __osl_createPipeImpl()
90 pPipe->m_AcceptEvent = CreateEvent(NULL, TRUE, FALSE, NULL); in __osl_createPipeImpl()
92 return pPipe; in __osl_createPipeImpl()
95 void __osl_destroyPipeImpl(oslPipe pPipe) in __osl_destroyPipeImpl() argument
97 if (pPipe != NULL) in __osl_destroyPipeImpl()
99 if ( pPipe->m_NamedObject != INVALID_HANDLE_VALUE && pPipe->m_NamedObject != NULL ) in __osl_destroyPipeImpl()
100 CloseHandle( pPipe->m_NamedObject ); in __osl_destroyPipeImpl()
102 if (pPipe->m_Security != NULL) in __osl_destroyPipeImpl()
104 rtl_freeMemory(pPipe->m_Security->lpSecurityDescriptor); in __osl_destroyPipeImpl()
105 rtl_freeMemory(pPipe->m_Security); in __osl_destroyPipeImpl()
108 CloseHandle(pPipe->m_ReadEvent); in __osl_destroyPipeImpl()
109 CloseHandle(pPipe->m_WriteEvent); in __osl_destroyPipeImpl()
110 CloseHandle(pPipe->m_AcceptEvent); in __osl_destroyPipeImpl()
112 if (pPipe->m_Name) in __osl_destroyPipeImpl()
113 rtl_uString_release(pPipe->m_Name); in __osl_destroyPipeImpl()
115 rtl_freeMemory(pPipe); in __osl_destroyPipeImpl()
130 oslPipe pPipe; in osl_createPipe() local
174 pPipe= __osl_createPipeImpl(); in osl_createPipe()
175 osl_incrementInterlockedCount(&(pPipe->m_Reference)); in osl_createPipe()
188 pPipe->m_NamedObject = CreateMutexW( NULL, FALSE, name->buffer ); in osl_createPipe()
199 pPipe->m_NamedObject = CreateMutexA( NULL, FALSE, pszTempBuffer ); in osl_createPipe()
202 if ( pPipe->m_NamedObject != INVALID_HANDLE_VALUE && pPipe->m_NamedObject != NULL ) in osl_createPipe()
206 pPipe->m_Security = pSecAttr; in osl_createPipe()
207 rtl_uString_assign(&pPipe->m_Name, name); in osl_createPipe()
212 pPipe->m_File = CreateNamedPipeW( in osl_createPipe()
219 pPipe->m_Security); in osl_createPipe()
221 if (pPipe->m_File != INVALID_HANDLE_VALUE) in osl_createPipe()
226 return pPipe; in osl_createPipe()
239 pPipe->m_File = CreateSimplePipe( pszTempBuffer ); in osl_createPipe()
241 if ( IsValidHandle(pPipe->m_File) ) in osl_createPipe()
246 return pPipe; in osl_createPipe()
252 CloseHandle( pPipe->m_NamedObject ); in osl_createPipe()
253 pPipe->m_NamedObject = INVALID_HANDLE_VALUE; in osl_createPipe()
271 pPipe->m_File = CreateFileW( in osl_createPipe()
280 if ( pPipe->m_File != INVALID_HANDLE_VALUE ) in osl_createPipe()
286 return (pPipe); in osl_createPipe()
305 pPipe->m_File = OpenSimplePipe( pszTempBuffer ); in osl_createPipe()
307 if ( IsValidHandle(pPipe->m_File) ) in osl_createPipe()
313 return (pPipe); in osl_createPipe()
319 __osl_destroyPipeImpl(pPipe); in osl_createPipe()
324 void SAL_CALL osl_acquirePipe( oslPipe pPipe ) in osl_acquirePipe() argument
326 osl_incrementInterlockedCount( &(pPipe->m_Reference) ); in osl_acquirePipe()
329 void SAL_CALL osl_releasePipe( oslPipe pPipe ) in osl_releasePipe() argument
333 if( 0 == pPipe ) in osl_releasePipe()
336 if( 0 == osl_decrementInterlockedCount( &(pPipe->m_Reference) ) ) in osl_releasePipe()
338 if( ! pPipe->m_bClosed ) in osl_releasePipe()
339 osl_closePipe( pPipe ); in osl_releasePipe()
341 __osl_destroyPipeImpl( pPipe ); in osl_releasePipe()
345 void SAL_CALL osl_closePipe( oslPipe pPipe ) in osl_closePipe() argument
347 if( pPipe && ! pPipe->m_bClosed ) in osl_closePipe()
349 pPipe->m_bClosed = sal_True; in osl_closePipe()
353 if (pPipe->m_File != INVALID_HANDLE_VALUE) in osl_closePipe()
356 DisconnectNamedPipe(pPipe->m_File); in osl_closePipe()
357 CloseHandle(pPipe->m_File); in osl_closePipe()
362 CloseSimplePipe( pPipe->m_File ); in osl_closePipe()
371 oslPipe SAL_CALL osl_acceptPipe(oslPipe pPipe) in osl_acceptPipe() argument
378 OSL_ASSERT(pPipe); in osl_acceptPipe()
386 OSL_ASSERT (pPipe->m_File != INVALID_HANDLE_VALUE); in osl_acceptPipe()
388 Event = pPipe->m_AcceptEvent; in osl_acceptPipe()
390 os.hEvent = pPipe->m_AcceptEvent; in osl_acceptPipe()
391 ResetEvent(pPipe->m_AcceptEvent); in osl_acceptPipe()
393 if ( !ConnectNamedPipe(pPipe->m_File, &os)) in osl_acceptPipe()
406 if( !GetOverlappedResult( pPipe->m_File, &os, &nBytesTransfered, TRUE ) ) in osl_acceptPipe()
432 rtl_uString_assign(&pAcceptedPipe->m_Name, pPipe->m_Name); in osl_acceptPipe()
433 pAcceptedPipe->m_File = pPipe->m_File; in osl_acceptPipe()
436 rtl_uString_newConcat(&path, temp, pPipe->m_Name); in osl_acceptPipe()
440 pPipe->m_File = in osl_acceptPipe()
456 rtl_uString_assign(&pAcceptedPipe->m_Name, pPipe->m_Name); in osl_acceptPipe()
457 pAcceptedPipe->m_File = pPipe->m_File; in osl_acceptPipe()
459 pAcceptedPipe->m_File = AcceptSimplePipeConnection( pPipe->m_File ); in osl_acceptPipe()
468 sal_Int32 SAL_CALL osl_receivePipe(oslPipe pPipe, in osl_receivePipe() argument
474 OSL_ASSERT(pPipe); in osl_receivePipe()
481 os.hEvent = pPipe->m_ReadEvent; in osl_receivePipe()
483 ResetEvent(pPipe->m_ReadEvent); in osl_receivePipe()
485 if (! ReadFile(pPipe->m_File, pBuffer, BytesToRead, &nBytes, &os) && in osl_receivePipe()
487 ! GetOverlappedResult(pPipe->m_File, &os, &nBytes, TRUE))) in osl_receivePipe()
500 pPipe->m_Error = osl_Pipe_E_ConnectionAbort; in osl_receivePipe()
506 BOOL fSuccess = ReadSimplePipe( pPipe->m_File, pBuffer, BytesToRead, &nBytes, TRUE ); in osl_receivePipe()
511 pPipe->m_Error = osl_Pipe_E_ConnectionAbort; in osl_receivePipe()
522 sal_Int32 SAL_CALL osl_sendPipe(oslPipe pPipe, in osl_sendPipe() argument
527 OSL_ASSERT(pPipe); in osl_sendPipe()
533 os.hEvent = pPipe->m_WriteEvent; in osl_sendPipe()
534 ResetEvent(pPipe->m_WriteEvent); in osl_sendPipe()
536 if (! WriteFile(pPipe->m_File, pBuffer, BytesToSend, &nBytes, &os) && in osl_sendPipe()
538 ! GetOverlappedResult(pPipe->m_File, &os, &nBytes, TRUE))) in osl_sendPipe()
545 pPipe->m_Error = osl_Pipe_E_ConnectionAbort; in osl_sendPipe()
550 BOOL fSuccess = WriteSimplePipe( pPipe->m_File, pBuffer, BytesToSend, &nBytes, TRUE ); in osl_sendPipe()
555 pPipe->m_Error = osl_Pipe_E_ConnectionAbort; in osl_sendPipe()
562 sal_Int32 SAL_CALL osl_writePipe( oslPipe pPipe, const void *pBuffer , sal_Int32 n ) in osl_writePipe() argument
568 OSL_ASSERT(pPipe); in osl_writePipe()
573 RetVal= osl_sendPipe(pPipe, pBuffer, BytesToSend); in osl_writePipe()
589 sal_Int32 SAL_CALL osl_readPipe( oslPipe pPipe, void *pBuffer , sal_Int32 n ) in osl_readPipe() argument
595 OSL_ASSERT( pPipe ); in osl_readPipe()
599 RetVal= osl_receivePipe(pPipe, pBuffer, BytesToRead); in osl_readPipe()
618 oslPipeError SAL_CALL osl_getLastPipeError(oslPipe pPipe) in osl_getLastPipeError() argument
622 if (pPipe != NULL) in osl_getLastPipeError()
624 Error = pPipe->m_Error; in osl_getLastPipeError()
625 pPipe->m_Error = osl_Pipe_E_None; in osl_getLastPipeError()