Lines Matching refs:Base
39 Base::TryCloseHandle((uv_handle_t *)&tcpListen); in Stop()
69 Base::ReallocBuf(&context->ioBuf, &context->bufSize, sizeWanted); // sizeWanted default 6k in AcceptClient()
83 string ver = Base::GetVersion() + HDC_MSG_HASH; in AcceptClient()
181 string log = logInfo + Base::StringFormat(msg, vaArgs); in EchoClient()
253 …Base::WriteBinFile((UT_TMP_PATH + "/base-discover.result").c_str(), (uint8_t *)bufString.c_str(), … in OrderFindTargets()
304 Base::TryCloseHandle((const uv_handle_t *)req, Base::CloseTimerCallback); in OrderConnecTargetResult()
329 Base::ZeroBuf(hChannel->bufStd, 2); in NewConnectTry()
333 Base::TimerUvTask(loopMain, hChannel, OrderConnecTargetResult, 10); in NewConnectTry()
390 …Base::WriteBinFile((UT_TMP_PATH + "/base-list.result").c_str(), (uint8_t *)MESSAGE_SUCCESS.c_str(), in GetTargetList()
408 … Base::WriteBinFile((UT_TMP_PATH + "/base-any.result").c_str(), (uint8_t *)MESSAGE_SUCCESS.c_str(), in GetAnyTarget()
438 Base::SplitString(echo, string("\n"), filterStrings); in RemoveForward()
606 char **argv = Base::SplitCommandToArgs(parameters.c_str(), &argc); in HandleRemote()
719 … if (!isClosing && (hChannel->fdChildWorkTCP = Base::DuplicateUvSocket(&hChannel->hWorkTCP)) < 0) { in BindChannelToSession()
731 Base::DoNextLoop(loopMain, hChannel, [](const uint8_t flag, string &msg, const void *data) { in BindChannelToSession()
742 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in BindChannelToSession()
802 string version = Base::GetVersion(); in ReportServerVersion()
876 return Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrlMsg.data(), ctrlMsg.size()) > 0; in ChannelSendSessionCtrlMsg()