Lines Matching refs:TaskHandle
66 static void SendMessage(const LoopHandle loopHandle, const TaskHandle taskHandle, const char *message, ...)
85 static void TestOnClose(const TaskHandle taskHandle)
89 static LE_STATUS TestHandleTaskEvent(const LoopHandle loop, const TaskHandle task, uint32_t oper)
94 static void TestOnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread)
106 static void TestClientOnReceiveRequest(const TaskHandle task, const uint8_t *buffer, uint32_t nread)
120 static void ProcessAsyncEvent(const TaskHandle taskHandle, uint64_t eventId, const uint8_t *buffer, uint32_t buffLen)
128 static void TestSendMessageComplete(const TaskHandle taskHandle, BufferHandle handle)
140 static int TestTcpIncomingConnect(LoopHandle loop, TaskHandle server)
144 TaskHandle stream;
157 static int TestPipIncomingConnect(LoopHandle loop, TaskHandle server)
161 TaskHandle stream;
174 static void TestConnectComplete(const TaskHandle client)
179 static void TestDisConnectComplete(const TaskHandle client)
235 TaskHandle tcpServer = nullptr;
236 TaskHandle pipeServer = nullptr;
276 TaskHandle CreateConnect(const char *tcpServer, uint32_t flags)
283 TaskHandle task = nullptr;
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);