Lines Matching refs:Base
39 Base::TryCloseHandle((uv_handle_t *)&tcpListen); in Stop()
66 Base::ReallocBuf(&context->ioBuf, &context->bufSize, sizeWanted); // sizeWanted default 6k in AcceptClient()
80 string ver = Base::GetVersion() + HDC_MSG_HASH; in AcceptClient()
178 string log = logInfo + Base::StringFormat(msg, vaArgs); in EchoClient()
246 …Base::WriteBinFile((UT_TMP_PATH + "/base-discover.result").c_str(), (uint8_t *)bufString.c_str(), … in OrderFindTargets()
297 Base::TryCloseHandle((const uv_handle_t *)req, Base::CloseTimerCallback); in OrderConnecTargetResult()
322 Base::ZeroBuf(hChannel->bufStd, 2); in NewConnectTry()
326 Base::TimerUvTask(loopMain, hChannel, OrderConnecTargetResult, 10); in NewConnectTry()
381 …Base::WriteBinFile((UT_TMP_PATH + "/base-list.result").c_str(), (uint8_t *)MESSAGE_SUCCESS.c_str(), in GetTargetList()
399 … Base::WriteBinFile((UT_TMP_PATH + "/base-any.result").c_str(), (uint8_t *)MESSAGE_SUCCESS.c_str(), in GetAnyTarget()
429 Base::SplitString(echo, string("\n"), filterStrings); in RemoveForward()
598 char **argv = Base::SplitCommandToArgs(parameters.c_str(), &argc); in HandleRemote()
710 … if (!isClosing && (hChannel->fdChildWorkTCP = Base::DuplicateUvSocket(&hChannel->hWorkTCP)) < 0) { in BindChannelToSession()
722 Base::DoNextLoop(loopMain, hChannel, [](const uint8_t flag, string &msg, const void *data) { in BindChannelToSession()
732 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in BindChannelToSession()
789 string version = Base::GetVersion(); in ReportServerVersion()
859 return Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrlMsg.data(), ctrlMsg.size()) > 0; in ChannelSendSessionCtrlMsg()