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