Lines Matching refs:Base
36 Base::TryCloseHandle((uv_handle_t *)&tcpListen); in Stop()
63 Base::ReallocBuf(&context->ioBuf, &context->bufSize, sizeWanted); // sizeWanted default 6k in AcceptClient()
77 string ver = Base::GetVersion() + HDC_MSG_HASH; in AcceptClient()
134 string log = logInfo + Base::StringFormat(msg, vaArgs); in EchoClient()
202 …Base::WriteBinFile((UT_TMP_PATH + "/base-discover.result").c_str(), (uint8_t *)bufString.c_str(), … in OrderFindTargets()
252 Base::TryCloseHandle((const uv_handle_t *)req, Base::CloseTimerCallback); in OrderConnecTargetResult()
269 Base::ZeroBuf(hChannel->bufStd, 2); in NewConnectTry()
273 Base::TimerUvTask(loopMain, hChannel, OrderConnecTargetResult, 10); in NewConnectTry()
328 …Base::WriteBinFile((UT_TMP_PATH + "/base-list.result").c_str(), (uint8_t *)MESSAGE_SUCCESS.c_str(), in GetTargetList()
346 … Base::WriteBinFile((UT_TMP_PATH + "/base-any.result").c_str(), (uint8_t *)MESSAGE_SUCCESS.c_str(), in GetAnyTarget()
376 Base::SplitString(echo, string("\n"), filterStrings); in RemoveForward()
545 char **argv = Base::SplitCommandToArgs(parameters.c_str(), &argc); in HandleRemote()
657 … if (!isClosing && (hChannel->fdChildWorkTCP = Base::DuplicateUvSocket(&hChannel->hWorkTCP)) < 0) { in BindChannelToSession()
669 Base::DoNextLoop(loopMain, hChannel, [](const uint8_t flag, string &msg, const void *data) { in BindChannelToSession()
679 … Base::SendToStream((uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN], ctrl.data(), ctrl.size()); in BindChannelToSession()
736 string version = Base::GetVersion(); in ReportServerVersion()
806 …return Base::SendToStream((uv_stream_t *)&hSession->ctrlPipe[STREAM_MAIN], ctrlMsg.data(), ctrlMsg… in ChannelSendSessionCtrlMsg()