Searched refs:receiverPipe (Results 1 – 6 of 6) sorted by relevance
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_core/platform/unix/dfile/ |
| H A D | sys_dfile.c | 31 if (pipe(session->receiverPipe) < 0) { in CreateReceiverPipe()
37 if (session->receiverPipe[PIPE_OUT] >= FD_SETSIZE) { in CreateReceiverPipe()
38 … LOGE(TAG, "pipe fd %d is too big for monitoring by select", session->receiverPipe[PIPE_OUT]); in CreateReceiverPipe()
43 int32_t flags = fcntl(session->receiverPipe[i], F_GETFL, 0); in CreateReceiverPipe()
50 int32_t ret = fcntl(session->receiverPipe[i], F_SETFL, flags); in CreateReceiverPipe()
58 CloseDesc(session->receiverPipe[PIPE_OUT]); in CreateReceiverPipe()
59 CloseDesc(session->receiverPipe[PIPE_IN]); in CreateReceiverPipe()
67 if (write(session->receiverPipe[PIPE_IN], ¬ify, sizeof(notify)) <= 0) { in NotifyPipeEvent()
|
| H A D | sys_dfile_session.c | 49 PipeDesc pipe = session->receiverPipe[PIPE_OUT]; in WaitSocketEvent()
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_core/platform/liteos/dfile/ |
| H A D | sys_dfile.c | 36 session->receiverPipe[PIPE_OUT] = fds.recvFd; in CreateReceiverPipe()
37 session->receiverPipe[PIPE_IN] = fds.sendFd; in CreateReceiverPipe()
46 if (write(session->receiverPipe[PIPE_IN], ¬ify, sizeof(notify)) <= 0) { in NotifyPipeEvent()
|
| H A D | sys_dfile_session.c | 49 PipeDesc pipe = session->receiverPipe[PIPE_OUT]; in WaitSocketEvent()
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/ |
| H A D | nstackx_dfile_session.h | 123 PipeDesc receiverPipe[PIPE_FD_NUM]; member
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/ |
| H A D | nstackx_dfile_session.c | 2043 if (session->receiverPipe[PIPE_OUT] != INVALID_PIPE_DESC) { in DestroyReceiverPipe()
2044 CloseDesc(session->receiverPipe[PIPE_OUT]); in DestroyReceiverPipe()
2045 session->receiverPipe[PIPE_OUT] = INVALID_PIPE_DESC; in DestroyReceiverPipe()
2047 if (session->receiverPipe[PIPE_IN] != INVALID_PIPE_DESC) { in DestroyReceiverPipe()
2048 CloseDesc(session->receiverPipe[PIPE_IN]); in DestroyReceiverPipe()
2049 session->receiverPipe[PIPE_IN] = INVALID_PIPE_DESC; in DestroyReceiverPipe()
|