Lines Matching refs:hTask
80 bool HdcSessionBase::TryRemoveTask(HTaskInfo hTask) in TryRemoveTask() argument
82 if (hTask->taskFree) { in TryRemoveTask()
83 WRITE_LOG(LOG_WARN, "TryRemoveTask channelId:%u", hTask->channelId); in TryRemoveTask()
86 bool ret = RemoveInstanceTask(OP_REMOVE, hTask); in TryRemoveTask()
88 hTask->taskFree = true; in TryRemoveTask()
98 void HdcSessionBase::BeginRemoveTask(HTaskInfo hTask) in BeginRemoveTask() argument
101 if (hTask->taskStop || hTask->taskFree) { in BeginRemoveTask()
103 hTask->channelId, hTask->taskStop, hTask->taskFree); in BeginRemoveTask()
107 …WRITE_LOG(LOG_DEBUG, "BeginRemoveTask taskType:%d channelId:%u", hTask->taskType, hTask->channelId… in BeginRemoveTask()
108 bool ret = RemoveInstanceTask(OP_CLEAR, hTask); in BeginRemoveTask()
110 …G(LOG_INFO, "RemoveInstanceTask false taskType:%d channelId:%u", hTask->taskType, hTask->channelId… in BeginRemoveTask()
114 HTaskInfo hTask = (HTaskInfo)handle->data; in BeginRemoveTask() local
115 HdcSessionBase *thisClass = (HdcSessionBase *)hTask->ownerSessionClass; in BeginRemoveTask()
117 if (hTask->closeRetryCount == 0 || hTask->closeRetryCount > count) { in BeginRemoveTask()
119 … hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->taskType, hTask->channelId, hTask->sessionId); in BeginRemoveTask()
120 hTask->closeRetryCount = 1; in BeginRemoveTask()
122 hTask->closeRetryCount++; in BeginRemoveTask()
123 if (!thisClass->TryRemoveTask(hTask)) { in BeginRemoveTask()
124 WRITE_LOG(LOG_WARN, "TaskDelay TryRemoveTask false channelId:%u", hTask->channelId); in BeginRemoveTask()
127 WRITE_LOG(LOG_DEBUG, "TaskDelay task remove finish, channelId:%u", hTask->channelId); in BeginRemoveTask()
128 if (hTask != nullptr) { in BeginRemoveTask()
129 delete hTask; in BeginRemoveTask()
130 hTask = nullptr; in BeginRemoveTask()
134 …Base::TimerUvTask(hTask->runLoop, hTask, taskClassDeleteRetry, (GLOBAL_TIMEOUT * TIME_BASE) / UV_D… in BeginRemoveTask()
136 hTask->taskStop = true; in BeginRemoveTask()
153 HTaskInfo hTask = iter->second; in ClearOwnTasks() local
159 BeginRemoveTask(hTask); in ClearOwnTasks()
166 BeginRemoveTask(hTask); in ClearOwnTasks()
1224 HTaskInfo hTask = (HTaskInfo)v.second; in ReChildLoopForSessionClear() local
1226 if (hTask->closeRetryCount < GLOBAL_TIMEOUT / 2) { in ReChildLoopForSessionClear()
1232 hTask->closeRetryCount, GLOBAL_TIMEOUT, hTask->channelId, hTask->sessionId); in ReChildLoopForSessionClear()
1233 if (hTask->closeRetryCount++ >= GLOBAL_TIMEOUT) { in ReChildLoopForSessionClear()
1234 HdcSessionBase *thisClass = (HdcSessionBase *)hTask->ownerSessionClass; in ReChildLoopForSessionClear()
1235 hSession = thisClass->AdminSession(OP_QUERY, hTask->sessionId, nullptr); in ReChildLoopForSessionClear()
1236 thisClass->AdminTask(OP_VOTE_RESET, hSession, hTask->channelId, nullptr); in ReChildLoopForSessionClear()
1238 if (!hTask->taskFree) in ReChildLoopForSessionClear()