Searched refs:watcherTask (Results 1 – 4 of 4) sorted by relevance
40 if (client == g_paramService.watcherTask) { in OnClose()42 g_paramService.watcherTask = NULL; in OnClose()225 extData.stream = g_paramService.watcherTask; in ExecuteWatchTrigger_()290 PARAM_CHECK((g_paramService.watcherTask == NULL) || in HandleParamWatcherAdd()291 (g_paramService.watcherTask == worker), return -1, "Invalid watcher worker"); in HandleParamWatcherAdd()292 g_paramService.watcherTask = worker; in HandleParamWatcherAdd()380 g_paramService.watcherTask = client; in OnIncomingConnect()
58 WatcherTask *watcherTask = (WatcherTask *)baseTask; in DumpWatcherTaskInfo_() local59 printf("\tfd: %d \n", watcherTask->base.taskId.fd); in DumpWatcherTaskInfo_()
89 ParamTaskPtr watcherTask; member
304 EXPECT_NE(GetParamService()->watcherTask, nullptr); in CreateAndGetStreamTask()305 return GetParamService()->watcherTask; in CreateAndGetStreamTask()