| /dports/net/freerdp/freerdp-2.5.0/server/shadow/ |
| H A D | shadow_subsystem.c | 83 if (!(subsystem->MsgPipe = MessagePipe_New())) in shadow_subsystem_init()
93 if (subsystem->MsgPipe) in shadow_subsystem_init()
95 MessagePipe_Free(subsystem->MsgPipe); in shadow_subsystem_init()
96 subsystem->MsgPipe = NULL; in shadow_subsystem_init()
126 if (subsystem->MsgPipe) in shadow_subsystem_uninit()
129 subsystem->MsgPipe->In->object.fnObjectFree = shadow_subsystem_free_queued_message; in shadow_subsystem_uninit()
130 MessageQueue_Clear(subsystem->MsgPipe->In); in shadow_subsystem_uninit()
131 subsystem->MsgPipe->Out->object.fnObjectFree = shadow_subsystem_free_queued_message; in shadow_subsystem_uninit()
132 MessageQueue_Clear(subsystem->MsgPipe->Out); in shadow_subsystem_uninit()
133 MessagePipe_Free(subsystem->MsgPipe); in shadow_subsystem_uninit()
[all …]
|
| H A D | shadow_client.c | 404 wMessagePipe* MsgPipe = client->subsystem->MsgPipe; in shadow_client_refresh_request() local
410 return MessageQueue_Dispatch(MsgPipe->In, &message); in shadow_client_refresh_request()
|
| /dports/emulators/ppsspp-qt5/ppsspp-1.12.3/Core/HLE/ |
| H A D | sceKernelMsgPipe.cpp | 143 ~MsgPipe() in ~MsgPipe() argument
707 MsgPipe *m = new MsgPipe(); in sceKernelCreateMsgPipe()
738 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelDeleteMsgPipe()
823 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelSendMsgPipe()
839 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelSendMsgPipeCB()
857 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelTrySendMsgPipe()
930 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelReceiveMsgPipe()
946 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelReceiveMsgPipeCB()
964 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelTryReceiveMsgPipe()
979 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelCancelMsgPipe()
[all …]
|
| /dports/emulators/ppsspp/ppsspp-1.12.3/Core/HLE/ |
| H A D | sceKernelMsgPipe.cpp | 143 ~MsgPipe() in ~MsgPipe() argument
707 MsgPipe *m = new MsgPipe(); in sceKernelCreateMsgPipe()
738 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelDeleteMsgPipe()
823 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelSendMsgPipe()
839 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelSendMsgPipeCB()
857 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelTrySendMsgPipe()
930 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelReceiveMsgPipe()
946 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelReceiveMsgPipeCB()
964 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelTryReceiveMsgPipe()
979 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelCancelMsgPipe()
[all …]
|
| /dports/emulators/libretro-ppsspp/ppsspp-1.12.3/Core/HLE/ |
| H A D | sceKernelMsgPipe.cpp | 143 ~MsgPipe() in ~MsgPipe() argument
707 MsgPipe *m = new MsgPipe(); in sceKernelCreateMsgPipe()
738 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelDeleteMsgPipe()
823 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelSendMsgPipe()
839 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelSendMsgPipeCB()
857 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelTrySendMsgPipe()
930 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelReceiveMsgPipe()
946 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelReceiveMsgPipeCB()
964 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelTryReceiveMsgPipe()
979 MsgPipe *m = kernelObjects.Get<MsgPipe>(uid, error); in sceKernelCancelMsgPipe()
[all …]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/p2p/ |
| H A D | message_test.go | 29 rw1, rw2 := MsgPipe()
53 rw1, rw2 := MsgPipe()
82 rw1, _ := MsgPipe()
|
| H A D | transport_test.go | 141 p1, p2 := MsgPipe()
|
| H A D | message.go | 157 func MsgPipe() (*MsgPipeRW, *MsgPipeRW) { func
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/eth/ |
| H A D | sync_test.go | 56 emptyPipeEth, fullPipeEth := p2p.MsgPipe()
72 emptyPipeSnap, fullPipeSnap := p2p.MsgPipe()
|
| H A D | handler_eth_test.go | 144 p2pNoFork, p2pProFork := p2p.MsgPipe()
175 p2pNoFork, p2pProFork = p2p.MsgPipe()
206 p2pNoFork, p2pProFork = p2p.MsgPipe()
256 p2pSrc, p2pSink := p2p.MsgPipe()
317 p2pSrc, p2pSink := p2p.MsgPipe()
405 sourcePipe, sinkPipe := p2p.MsgPipe()
519 p2pLocal, p2pRemote := p2p.MsgPipe()
628 sourcePipe, sinkPipe := p2p.MsgPipe()
695 p2pSrc, p2pSink := p2p.MsgPipe()
|
| /dports/net/freerdp/freerdp-2.5.0/server/shadow/Mac/ |
| H A D | mac_shadow.c | 530 wMessagePipe* MsgPipe; in mac_shadow_subsystem_thread() local
531 MsgPipe = subsystem->common.MsgPipe; in mac_shadow_subsystem_thread()
533 events[nCount++] = MessageQueue_Event(MsgPipe->In); in mac_shadow_subsystem_thread()
544 if (WaitForSingleObject(MessageQueue_Event(MsgPipe->In), 0) == WAIT_OBJECT_0) in mac_shadow_subsystem_thread()
546 if (MessageQueue_Peek(MsgPipe->In, &message, TRUE)) in mac_shadow_subsystem_thread()
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/eth/protocols/eth/ |
| H A D | peer_test.go | 42 app, net := p2p.MsgPipe()
|
| H A D | handshake_test.go | 73 app, net := p2p.MsgPipe()
|
| /dports/net/freerdp/freerdp-2.5.0/server/shadow/X11/ |
| H A D | x11_shadow.c | 902 wMessagePipe* MsgPipe; in x11_shadow_subsystem_thread() local
903 MsgPipe = subsystem->common.MsgPipe; in x11_shadow_subsystem_thread()
906 events[nCount++] = MessageQueue_Event(MsgPipe->In); in x11_shadow_subsystem_thread()
917 if (WaitForSingleObject(MessageQueue_Event(MsgPipe->In), 0) == WAIT_OBJECT_0) in x11_shadow_subsystem_thread()
919 if (MessageQueue_Peek(MsgPipe->In, &message, TRUE)) in x11_shadow_subsystem_thread()
1407 if (MessageQueue_PostQuit(subsystem->common.MsgPipe->In, 0)) in x11_shadow_subsystem_stop()
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/les/ |
| H A D | peer_test.go | 109 app, net := p2p.MsgPipe()
|
| H A D | ulc_test.go | 92 app, net := p2p.MsgPipe()
|
| H A D | test_helper.go | 405 app, net := p2p.MsgPipe()
465 app, net := p2p.MsgPipe()
529 app, net := p2p.MsgPipe()
|
| H A D | benchmark.go | 277 clientPipe, serverPipe := p2p.MsgPipe()
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/p2p/ |
| H A D | message.go | 149 func MsgPipe() (*MsgPipeRW, *MsgPipeRW) { func
|
| /dports/net/freerdp/freerdp-2.5.0/include/freerdp/server/ |
| H A D | shadow.h | 199 wMessagePipe* MsgPipe; member
|