• Home
  • Raw
  • Download

Lines Matching refs:channelId

526 bool HdcServer::FetchCommand(HSession hSession, const uint32_t channelId, const uint16_t command, u…  in FetchCommand()  argument
538 HChannel hChannel = sfc->AdminChannel(OP_QUERY_REF, channelId, nullptr); in FetchCommand()
543 WRITE_LOG(LOG_DEBUG, "Die channelId :%lu recv CMD_KERNEL_CHANNEL_CLOSE", channelId); in FetchCommand()
546 WRITE_LOG(LOG_DEBUG, "channelId :%lu die", channelId); in FetchCommand()
549 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &flag, 1); in FetchCommand()
553 WRITE_LOG(LOG_FATAL, "FetchCommand channelId:%u isDead", channelId); in FetchCommand()
566 WRITE_LOG(LOG_INFO, "CMD_KERNEL_ECHO size:%d channelId:%u", payloadSize - 1, channelId); in FetchCommand()
570 WRITE_LOG(LOG_DEBUG, "CMD_KERNEL_CHANNEL_CLOSE channelid:%u", channelId); in FetchCommand()
572 ClearOwnTasks(hSession, channelId); in FetchCommand()
574 sfc->PushAsyncMessage(channelId, ASYNC_FREE_CHANNEL, nullptr, 0); in FetchCommand()
577 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, payload, 1); in FetchCommand()
585 pdiNew->channelId = channelId; in FetchCommand()
617 ret = DispatchTaskData(hSessionByQuery, channelId, command, payload, payloadSize); in FetchCommand()
858 void HdcServer::AttachChannel(HSession hSession, const uint32_t channelId) in AttachChannel() argument
862 HChannel hChannel = hSfc->AdminChannel(OP_QUERY_REF, channelId, nullptr); in AttachChannel()
864 WRITE_LOG(LOG_DEBUG, "AttachChannel hChannel null channelId:%u", channelId); in AttachChannel()
875 buf, hChannel->channelId, hChannel->fdChildWorkTCP); in AttachChannel()
885 void HdcServer::DeatchChannel(HSession hSession, const uint32_t channelId) in DeatchChannel() argument
889 HChannel hChannel = hSfc->AdminChannel(OP_QUERY, channelId, nullptr); in DeatchChannel()
891 ClearOwnTasks(hSession, channelId); in DeatchChannel()
893 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &count, 1); in DeatchChannel()
894 WRITE_LOG(LOG_WARN, "DeatchChannel hChannel null channelId:%u", channelId); in DeatchChannel()
898 WRITE_LOG(LOG_DEBUG, "Childchannel has already freed, cid:%u", channelId); in DeatchChannel()
902 ClearOwnTasks(hSession, channelId); in DeatchChannel()
904 Send(hSession->sessionId, hChannel->channelId, CMD_KERNEL_CHANNEL_CLOSE, &count, 1); in DeatchChannel()
905 WRITE_LOG(LOG_DEBUG, "Childchannel begin close, cid:%u", hChannel->channelId); in DeatchChannel()
910 WRITE_LOG(LOG_DEBUG, "Childchannel free direct, cid:%u", hChannel->channelId); in DeatchChannel()
914 WRITE_LOG(LOG_DEBUG, "Childchannel loop is null, cid:%u", hChannel->channelId); in DeatchChannel()
919 WRITE_LOG(LOG_DEBUG, "Childchannel free callback, cid:%u", hChannel->channelId); in DeatchChannel()
924 bool HdcServer::ServerCommand(const uint32_t sessionId, const uint32_t channelId, const uint16_t co… in ServerCommand() argument
928 HChannel hChannel = hSfc->AdminChannel(OP_QUERY, channelId, nullptr); in ServerCommand()
933 return FetchCommand(hSession, channelId, command, bufPtr, size); in ServerCommand()
937 bool HdcServer::RedirectToTask(HTaskInfo hTaskInfo, HSession hSession, const uint32_t channelId, in RedirectToTask() argument