Lines Matching refs:pPipe
137 oslPipe pPipe=0; in osl_createPipe() local
149 pPipe = osl_psz_createPipe(pszPipeName, Options, Security); in osl_createPipe()
157 return pPipe; in osl_createPipe()
170 oslPipe pPipe; in osl_psz_createPipe() local
198 pPipe= __osl_createPipeImpl(); in osl_psz_createPipe()
201 pPipe->m_Socket = socket(AF_UNIX, SOCK_STREAM, 0); in osl_psz_createPipe()
202 if ( pPipe->m_Socket < 0 ) in osl_psz_createPipe()
205 __osl_destroyPipeImpl(pPipe); in osl_psz_createPipe()
212 if ((Flags = fcntl(pPipe->m_Socket, F_GETFD, 0)) != -1) in osl_psz_createPipe()
215 if (fcntl(pPipe->m_Socket, F_SETFD, Flags) == -1) in osl_psz_createPipe()
241 if ( connect(pPipe->m_Socket,(struct sockaddr *)&addr,len) >= 0 ) in osl_psz_createPipe()
244 close (pPipe->m_Socket); in osl_psz_createPipe()
245 __osl_destroyPipeImpl(pPipe); in osl_psz_createPipe()
253 if ( bind(pPipe->m_Socket, (struct sockaddr *)&addr, len) < 0 ) in osl_psz_createPipe()
256 close (pPipe->m_Socket); in osl_psz_createPipe()
257 __osl_destroyPipeImpl(pPipe); in osl_psz_createPipe()
268 strncpy(pPipe->m_Name, name, sizeof(pPipe->m_Name)); in osl_psz_createPipe()
270 if ( listen(pPipe->m_Socket, 5) < 0 ) in osl_psz_createPipe()
274 close (pPipe->m_Socket); in osl_psz_createPipe()
275 __osl_destroyPipeImpl(pPipe); in osl_psz_createPipe()
279 return (pPipe); in osl_psz_createPipe()
285 if ( connect( pPipe->m_Socket, (struct sockaddr *)&addr, len) >= 0 ) in osl_psz_createPipe()
287 return (pPipe); in osl_psz_createPipe()
293 close (pPipe->m_Socket); in osl_psz_createPipe()
294 __osl_destroyPipeImpl(pPipe); in osl_psz_createPipe()
299 void SAL_CALL osl_acquirePipe( oslPipe pPipe ) in osl_acquirePipe() argument
301 osl_incrementInterlockedCount( &(pPipe->m_nRefCount) ); in osl_acquirePipe()
304 void SAL_CALL osl_releasePipe( oslPipe pPipe ) in osl_releasePipe() argument
307 if( 0 == pPipe ) in osl_releasePipe()
310 if( 0 == osl_decrementInterlockedCount( &(pPipe->m_nRefCount) ) ) in osl_releasePipe()
312 if( ! pPipe->m_bClosed ) in osl_releasePipe()
313 osl_closePipe( pPipe ); in osl_releasePipe()
315 __osl_destroyPipeImpl( pPipe ); in osl_releasePipe()
319 void SAL_CALL osl_closePipe( oslPipe pPipe ) in osl_closePipe() argument
329 if( ! pPipe ) in osl_closePipe()
334 if( pPipe->m_bClosed ) in osl_closePipe()
339 ConnFD = pPipe->m_Socket; in osl_closePipe()
346 if ( pPipe->m_bIsAccepting ) in osl_closePipe()
348 pPipe->m_bIsInShutdown = sal_True; in osl_closePipe()
349 pPipe->m_Socket = -1; in osl_closePipe()
353 OSL_TRACE("osl_destroyPipe : Pipe Name '%s'",pPipe->m_Name); in osl_closePipe()
356 strncpy(addr.sun_path, pPipe->m_Name, sizeof(addr.sun_path)); in osl_closePipe()
387 if ( strlen(pPipe->m_Name) > 0 ) in osl_closePipe()
389 unlink(pPipe->m_Name); in osl_closePipe()
391 pPipe->m_bClosed = sal_True; in osl_closePipe()
400 oslPipe SAL_CALL osl_acceptPipe(oslPipe pPipe) in osl_acceptPipe() argument
405 OSL_ASSERT(pPipe); in osl_acceptPipe()
406 if ( pPipe == 0 ) in osl_acceptPipe()
411 OSL_ASSERT(strlen(pPipe->m_Name) > 0); in osl_acceptPipe()
414 pPipe->m_bIsAccepting = sal_True; in osl_acceptPipe()
417 s = accept(pPipe->m_Socket, NULL, NULL); in osl_acceptPipe()
420 pPipe->m_bIsAccepting = sal_False; in osl_acceptPipe()
430 if ( pPipe->m_bIsInShutdown ) in osl_acceptPipe()
468 sal_Int32 SAL_CALL osl_receivePipe(oslPipe pPipe, in osl_receivePipe() argument
474 OSL_ASSERT(pPipe); in osl_receivePipe()
476 if ( pPipe == 0 ) in osl_receivePipe()
483 nRet = recv(pPipe->m_Socket, in osl_receivePipe()
499 sal_Int32 SAL_CALL osl_sendPipe(oslPipe pPipe, in osl_sendPipe() argument
505 OSL_ASSERT(pPipe); in osl_sendPipe()
507 if ( pPipe == 0 ) in osl_sendPipe()
514 nRet = send(pPipe->m_Socket, in osl_sendPipe()
531 oslPipeError SAL_CALL osl_getLastPipeError(oslPipe pPipe) in osl_getLastPipeError() argument
533 (void) pPipe; /* unused */ in osl_getLastPipeError()
538 sal_Int32 SAL_CALL osl_writePipe( oslPipe pPipe, const void *pBuffer , sal_Int32 n ) in osl_writePipe() argument
544 OSL_ASSERT(pPipe); in osl_writePipe()
549 RetVal= osl_sendPipe(pPipe, pBuffer, BytesToSend); in osl_writePipe()
565 sal_Int32 SAL_CALL osl_readPipe( oslPipe pPipe, void *pBuffer , sal_Int32 n ) in osl_readPipe() argument
571 OSL_ASSERT( pPipe ); in osl_readPipe()
575 RetVal= osl_receivePipe(pPipe, pBuffer, BytesToRead); in osl_readPipe()