• Home
  • Raw
  • Download

Lines Matching refs:Base

25     WRITE_LOG(LOG_INFO, "Program running. %s Pid:%u", Base::GetVersion().c_str(), getpid());  in HdcSessionBase()
65 Base::TryCloseHandle((uv_handle_t *)&asyncMainLoop); in ~HdcSessionBase()
132 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseTimerCallback); in BeginRemoveTask()
134Base::TimerUvTask(hTask->runLoop, hTask, taskClassDeleteRetry, (GLOBAL_TIMEOUT * TIME_BASE) / UV_D… in BeginRemoveTask()
193 uv_close((uv_handle_t *)handle, Base::CloseIdleCallback); in ReMainLoopForInstanceClear()
196 Base::IdleUvTask(&loopMain, this, clearSessionsForFinish); in ReMainLoopForInstanceClear()
302 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseIdleCallback); in AsyncMainLoopTask()
313 Base::IdleUvTask(&thisClass->loopMain, param, AsyncMainLoopTask); in MainAsyncCallback()
400 uid = static_cast<uint32_t>(Base::GetRandom()); in GetSessionPseudoUid()
447 Base::CreateSocketPair(hSession->ctrlFd); in MallocSession()
467 Base::CreateSocketPair(hSession->dataFd); in MallocSession()
472 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN], HOST_SOCKETPAIR_SIZE); in MallocSession()
474 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN]); in MallocSession()
506 Base::CloseFd(hUSB->bulkIn); in FreeSessionByConnectType()
507 Base::CloseFd(hUSB->bulkOut); in FreeSessionByConnectType()
531 Base::CloseFd(hUART->devUartHandle); in FreeSessionByConnectType()
558 Base::TryCloseHandle((const uv_handle_t *)handle, Base::CloseIdleCallback); in FreeSessionFinally()
568 Base::TryCloseHandle((uv_handle_t *)handle); in FreeSessionContinue()
570 Base::CloseFd(hSession->ctrlFd[STREAM_MAIN]); in FreeSessionContinue()
571 Base::CloseFd(hSession->ctrlFd[STREAM_WORK]); in FreeSessionContinue()
577 Base::TryCloseHandle((uv_handle_t *)&hSession->hWorkTCP, true, closeSessionTCPHandle); in FreeSessionContinue()
584Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_MAIN], true, closeSessionTCPHandle… in FreeSessionContinue()
585Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_MAIN], true, closeSessionTCPHandle); in FreeSessionContinue()
588 Base::IdleUvTask(&loopMain, hSession, FreeSessionFinally); in FreeSessionContinue()
612 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in FreeSessionOpeate()
622 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseTimerCallback); in FreeSessionOpeate()
625 Base::TimerUvTask(&thisClass->loopMain, hSession, callbackCheckFreeSessionContinue); in FreeSessionOpeate()
629 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseTimerCallback); in FreeSessionOpeate()
647 Base::TimerUvTask(&loopMain, hSession, FreeSessionOpeate); in FreeSession()
827 …protectBuf.checkSum = (ENABLE_IO_CHECKSUM && dataSize > 0) ? Base::CalcCheckSum(data, dataSize) : … in Send()
887 …if (ENABLE_IO_CHECKSUM && protectBuf.checkSum != 0 && (protectBuf.checkSum != Base::CalcCheckSum(d… in DecryptPayload()
967 Base::ZeroBuf(bufToZero, hSession->bufSize - hSession->availTailIndex); in FetchIOBuf()
975 Base::ReallocBuf(&context->ioBuf, &context->bufSize, HDC_SOCKETPAIR_SIZE); in AllocCallback()
989 Base::TryCloseHandle((uv_handle_t *)req->handle); in FinishWriteSessionTCP()
1022 const int size = Base::GetMaxBufSize(); in ReadCtrlFromSession()
1024 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_MAIN], buf, size); in ReadCtrlFromSession()
1064 Base::SetTcpOptions((uv_tcp_t *)&hSession->hChildWorkTCP); in WorkThreadStartSession()
1086 handshake.version = Base::GetVersion() + HDC_MSG_HASH; in WorkThreadStartSession()
1139 Base::TryCloseHandle((uv_handle_t *)handle); in DispatchMainThreadCommand()
1150Base::TryCloseHandle((uv_handle_t *)&hSession->hChildWorkTCP, true, closeSessionChildThreadTCPHand… in DispatchMainThreadCommand()
1152 Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_WORK], true, in DispatchMainThreadCommand()
1154 Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_WORK], true, in DispatchMainThreadCommand()
1187 const int size = Base::GetMaxBufSize(); in ReadCtrlFromMain()
1189 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_WORK], buf, size); in ReadCtrlFromMain()
1242 uv_close((uv_handle_t *)handle, Base::CloseTimerCallback); in ReChildLoopForSessionClear()
1245Base::TimerUvTask(&hSession->childLoop, hSession, clearTaskForSessionFinish, (GLOBAL_TIMEOUT * TIM… in ReChildLoopForSessionClear()
1248 Base::TryCloseChildLoop(&hSession->childLoop, "Session childUV"); in ReChildLoopForSessionClear()
1278 string log = Base::StringFormat(msg, vaArgs); in LogMsg()