le_streamtask.c - OpenGrok cross reference for /base/startup/init/services/loopevent/task/le

Lines Matching defs:task
139     BaseTask *task = (BaseTask *)taskHandle;

140     DelTask((EventLoop *)loopHandle, task);

141     CloseTask(loopHandle, task);

142     if (task->taskId.fd > 0) {

143         close(task->taskId.fd);

147 static void DumpStreamServerTaskInfo_(const TaskHandle task)

149     INIT_CHECK(task != NULL, return);

150     BaseTask *baseTask = (BaseTask *)task;

161 static void DumpStreamConnectTaskInfo_(const TaskHandle task)

163     INIT_CHECK(task != NULL, return);

164     BaseTask *baseTask = (BaseTask *)task;

220     StreamServerTask *task = (StreamServerTask *)CreateTask(loopHandle, fd, &info->baseInfo,

222     LE_CHECK(task != NULL, close(fd);

223         return LE_NO_MEMORY, "Failed to create task");

224     task->base.handleEvent = HandleServerEvent_;

225     task->base.innerClose = HandleStreamTaskClose_;

226     task->base.dumpTaskInfo = DumpStreamServerTaskInfo_;

227     task->incommingConnect = info->incommingConnect;

228     loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);

229     ret = memcpy_s(task->server, strlen(info->server) + 1, info->server, strlen(info->server) + 1);

231     *taskHandle = (TaskHandle)task;

244     StreamClientTask *task = (StreamClientTask *)CreateTask(loopHandle, fd, &info->baseInfo, sizeof(StreamClientTask));

245     LE_CHECK(task != NULL, close(fd);

246         return LE_NO_MEMORY, "Failed to create task");

247     task->stream.base.handleEvent = HandleClientEvent_;

248     task->stream.base.innerClose = HandleStreamTaskClose_;

249     OH_ListInit(&task->stream.buffHead);

250     LoopMutexInit(&task->stream.mutex);

252     task->connectComplete = info->connectComplete;

253     task->sendMessageComplete = info->sendMessageComplete;

254     task->recvMessage = info->recvMessage;

255     task->disConnectComplete = info->disConnectComplete;

256     task->handleRecvMsg = info->handleRecvMsg;

258     loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);

259     *taskHandle = (TaskHandle)task;

274     StreamConnectTask *task = (StreamConnectTask *)CreateTask(

276     LE_CHECK(task != NULL, close(fd);

277         return LE_NO_MEMORY, "Failed to create task");

278     task->stream.base.handleEvent = HandleStreamEvent_;

279     task->stream.base.innerClose = HandleStreamTaskClose_;

280     task->stream.base.dumpTaskInfo = DumpStreamConnectTaskInfo_;

281     task->disConnectComplete = info->disConnectComplete;

282     task->sendMessageComplete = info->sendMessageComplete;

283     task->recvMessage = info->recvMessage;

284     task->serverTask = (StreamServerTask *)server;

285     task->handleRecvMsg = info->handleRecvMsg;

286     OH_ListInit(&task->stream.buffHead);

287     LoopMutexInit(&task->stream.mutex);

290         loop->addEvent(loop, (const BaseTask *)task, EVENT_READ);

292     *taskHandle = (TaskHandle)task;