Lines Matching defs:task
64 MyTask *task;
175 static inline int StartTimerForCheckMsg(MyTask *task)
187 static int SendMessage(LoopHandle loop, TaskHandle task, const char *message)
204 LE_FreeBuffer(loop, task, handle);
209 LE_STATUS status = LE_Send(loop, task, handle, strlen(message) + 1);
253 MyTask *task = (MyTask *)LE_GetUserData(taskHandle);
254 if (task == NULL) {
255 printf("Invalid task \n");
262 MyTask *task = (MyTask *)LE_GetUserData(taskHandle);
263 if (task == NULL) {
264 printf("Invalid task \n");
267 printf("task id: %d\n", task->id);
273 MyTask *task = (MyTask *)LE_GetUserData(taskHandle);
274 if (task == NULL) {
275 printf("Invalid task \n");
284 task->id, msg->msgId, msg->msgType, msg->buffer);
415 static int SendResponse(const MyTask *task, const Message *msg, int result, pid_t pid)
418 task->id, result, pid);
431 return LE_Send(LE_GetDefaultLoop(), task->stream, handle, bufferSize);
483 static void ProcessReqMsg(MyTask *task, MsgNode *message)
487 SendResponse(task, &message->msgHeader, ret, 0);
492 message->task = task;
577 static MsgNode *ProcessBegetctlMsg(MyTask *task, MsgNode *message)
600 static void ProcessBegetMsg(MyTask *task, MsgNode *message)
606 SendResponse(task, msg, DEBUG_MODE_NOT_SUPPORT, 0);
610 ProcessReqMsg(task, msgNode);
615 static void ProcessRecvMsg(MyTask *task, MsgNode *message)
620 if (task->receiverCtx.nextMsgId != msg->msgId) {
621 printf("Invalid msg id %u %u \n", task->receiverCtx.nextMsgId, msg->msgId);
623 task->receiverCtx.nextMsgId++;
630 SendResponse(task, msg, ret == 0 ? result.result : ret, result.pid);
635 ProcessReqMsg(task, message);
639 SendResponse(task, msg, 0, 0);
643 ProcessBegetMsg(task, message);
647 SendResponse(task, msg, MIN_TIME, MAX_TIME);
651 ret = ProcessRemountMsg(task, message);
652 SendResponse(task, msg, ret, 0);
655 ProcessRestartMsg(task, message);
658 SendResponse(task, msg, MSG_INVALID, 0);
666 MyTask *task = (MyTask *)LE_GetUserData(taskHandle);
667 if (task == NULL) {
681 Message *message = task->ctx.incompleteMsg; // incomplete msg
682 task->ctx.incompleteMsg = NULL;
686 task->id, *(uint32_t *)(buffer + currLen), buffLen - currLen);
689 &message, &task->ctx.msgRecvLen, &reminder);
694 if (task->ctx.msgRecvLen != message->msgLen) { // recv complete msg
695 task->ctx.incompleteMsg = message;
699 task->ctx.msgRecvLen = 0;
700 if (task->ctx.timer) {
701 LE_StopTimer(LE_GetDefaultLoop(), task->ctx.timer);
702 task->ctx.timer = NULL;
709 (void)ProcessRecvMsg(task, message);
714 if (task->ctx.incompleteMsg != NULL) { // Start the detection timer
715 ret = StartTimerForCheckMsg(task);