Lines Matching refs:hTask
80 bool HdcSessionBase::TryRemoveTask(HTaskInfo hTask) in TryRemoveTask() argument
82 if (hTask->taskFree) { in TryRemoveTask()
85 bool ret = RemoveInstanceTask(OP_REMOVE, hTask); in TryRemoveTask()
87 hTask->taskFree = true; in TryRemoveTask()
97 void HdcSessionBase::BeginRemoveTask(HTaskInfo hTask) in BeginRemoveTask() argument
100 if (hTask->taskStop || hTask->taskFree) { in BeginRemoveTask()
104 …WRITE_LOG(LOG_DEBUG, "BeginRemoveTask taskType:%d channelId:%u", hTask->taskType, hTask->channelId… in BeginRemoveTask()
105 bool ret = RemoveInstanceTask(OP_CLEAR, hTask); in BeginRemoveTask()
107 …G(LOG_INFO, "RemoveInstanceTask false taskType:%d channelId:%u", hTask->taskType, hTask->channelId… in BeginRemoveTask()
111 HTaskInfo hTask = (HTaskInfo)handle->data; in BeginRemoveTask() local
112 HdcSessionBase *thisClass = (HdcSessionBase *)hTask->ownerSessionClass; in BeginRemoveTask()
114 if (hTask->closeRetryCount == 0 || hTask->closeRetryCount > count) { in BeginRemoveTask()
116 … hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId); in BeginRemoveTask()
117 hTask->closeRetryCount = 1; in BeginRemoveTask()
119 hTask->closeRetryCount++; in BeginRemoveTask()
120 if (!thisClass->TryRemoveTask(hTask)) { in BeginRemoveTask()
123 WRITE_LOG(LOG_DEBUG, "TaskDelay task remove finish, channelId:%u", hTask->channelId); in BeginRemoveTask()
124 if (hTask != nullptr) { in BeginRemoveTask()
125 delete hTask; in BeginRemoveTask()
126 hTask = nullptr; in BeginRemoveTask()
130 …Base::TimerUvTask(hTask->runLoop, hTask, taskClassDeleteRetry, (GLOBAL_TIMEOUT * TIME_BASE) / UV_D… in BeginRemoveTask()
132 hTask->taskStop = true; in BeginRemoveTask()
149 HTaskInfo hTask = iter->second; in ClearOwnTasks() local
155 BeginRemoveTask(hTask); in ClearOwnTasks()
162 BeginRemoveTask(hTask); in ClearOwnTasks()
1202 HTaskInfo hTask = (HTaskInfo)v.second; in ReChildLoopForSessionClear() local
1204 if (hTask->closeRetryCount < GLOBAL_TIMEOUT / 2) { in ReChildLoopForSessionClear()
1210 hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->channelId, hTask->sessionId); in ReChildLoopForSessionClear()
1211 if (hTask->closeRetryCount++ >= GLOBAL_TIMEOUT) { in ReChildLoopForSessionClear()
1212 HdcSessionBase *thisClass = (HdcSessionBase *)hTask->ownerSessionClass; in ReChildLoopForSessionClear()
1213 hSession = thisClass->AdminSession(OP_QUERY, hTask->sessionId, nullptr); in ReChildLoopForSessionClear()
1214 thisClass->AdminTask(OP_VOTE_RESET, hSession, hTask->channelId, nullptr); in ReChildLoopForSessionClear()
1216 if (!hTask->taskFree) in ReChildLoopForSessionClear()