66 static void SendMessage(const LoopHandle loopHandle, const TaskHandle taskHandle, const char *messa…  in SendMessage()
85 static void TestOnClose(const TaskHandle taskHandle)  in TestOnClose()
89 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper)  in TestHandleTaskEvent()
94 static void TestOnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread)  in TestOnReceiveRequest()
106 static void TestClientOnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread)  in TestClientOnReceiveRequest()
120 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer,…  in ProcessAsyncEvent()
128 static void TestSendMessageComplete(const TaskHandle taskHandle, BufferHandle handle)  in TestSendMessageComplete()
140 static int TestTcpIncomingConnect(LoopHandle loop, TaskHandle server)  in TestTcpIncomingConnect()
144     TaskHandle stream;  in TestTcpIncomingConnect()
157 static int TestPipIncomingConnect(LoopHandle loop, TaskHandle server)  in TestPipIncomingConnect()
161     TaskHandle stream;  in TestPipIncomingConnect()
174 static void TestConnectComplete(const TaskHandle client)  in TestConnectComplete()
179 static void TestDisConnectComplete(const TaskHandle client)  in TestDisConnectComplete()
235         TaskHandle tcpServer = nullptr;  in RunServer()
236         TaskHandle pipeServer = nullptr;  in RunServer()
276     TaskHandle CreateConnect(const char *tcpServer, uint32_t flags)  in CreateConnect()
283         TaskHandle task = nullptr;  in CreateConnect()
342     TaskHandle pipe = test.CreateConnect(PIPE_SERVER.c_str(), TASK_PIPE);
355     TaskHandle tcp = test.CreateConnect(TCP_SERVER.c_str(), TASK_TCP);
412     TaskHandle pip = test.CreateConnect(PIPE_SERVER.c_str(), TASK_PIPE);