• 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()
128 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseTimerCallback); in BeginRemoveTask()
130Base::TimerUvTask(hTask->runLoop, hTask, taskClassDeleteRetry, (GLOBAL_TIMEOUT * TIME_BASE) / UV_D… in BeginRemoveTask()
189 uv_close((uv_handle_t *)handle, Base::CloseIdleCallback); in ReMainLoopForInstanceClear()
192 Base::IdleUvTask(&loopMain, this, clearSessionsForFinish); in ReMainLoopForInstanceClear()
298 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseIdleCallback); in AsyncMainLoopTask()
309 Base::IdleUvTask(&thisClass->loopMain, param, AsyncMainLoopTask); in MainAsyncCallback()
396 uid = static_cast<uint32_t>(Base::GetRandom()); in GetSessionPseudoUid()
439 Base::CreateSocketPair(hSession->ctrlFd); in MallocSession()
459 Base::CreateSocketPair(hSession->dataFd); in MallocSession()
463 Base::SetTcpOptions(&hSession->dataPipe[STREAM_MAIN]); in MallocSession()
494 Base::CloseFd(hUSB->bulkIn); in FreeSessionByConnectType()
495 Base::CloseFd(hUSB->bulkOut); in FreeSessionByConnectType()
519 Base::CloseFd(hUART->devUartHandle); in FreeSessionByConnectType()
544 Base::TryCloseHandle((const uv_handle_t *)handle, Base::CloseIdleCallback); in FreeSessionFinally()
554 Base::TryCloseHandle((uv_handle_t *)handle); in FreeSessionContinue()
561 Base::TryCloseHandle((uv_handle_t *)&hSession->hWorkTCP, true, closeSessionTCPHandle); in FreeSessionContinue()
568Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_MAIN], true, closeSessionTCPHandle… in FreeSessionContinue()
569Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_MAIN], true, closeSessionTCPHandle); in FreeSessionContinue()
572 Base::IdleUvTask(&loopMain, hSession, FreeSessionFinally); in FreeSessionContinue()
595 Base::SendToPollFd(hSession->ctrlFd[STREAM_MAIN], ctrl.data(), ctrl.size()); in FreeSessionOpeate()
603 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseTimerCallback); in FreeSessionOpeate()
606 Base::TimerUvTask(&thisClass->loopMain, hSession, callbackCheckFreeSessionContinue); in FreeSessionOpeate()
610 Base::TryCloseHandle((uv_handle_t *)handle, Base::CloseTimerCallback); in FreeSessionOpeate()
627 Base::TimerUvTask(&loopMain, hSession, FreeSessionOpeate); in FreeSession()
810 …protectBuf.checkSum = (ENABLE_IO_CHECKSUM && dataSize > 0) ? Base::CalcCheckSum(data, dataSize) : … in Send()
870 …if (ENABLE_IO_CHECKSUM && protectBuf.checkSum != 0 && (protectBuf.checkSum != Base::CalcCheckSum(d… in DecryptPayload()
949 Base::ZeroBuf(bufToZero, hSession->bufSize - hSession->availTailIndex); in FetchIOBuf()
957 Base::ReallocBuf(&context->ioBuf, &context->bufSize, HDC_SOCKETPAIR_SIZE); in AllocCallback()
969 Base::TryCloseHandle((uv_handle_t *)req->handle); in FinishWriteSessionTCP()
1001 const int size = Base::GetMaxBufSize(); in ReadCtrlFromSession()
1003 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_WORK], buf, size); in ReadCtrlFromSession()
1043 Base::SetTcpOptions((uv_tcp_t *)&hSession->hChildWorkTCP); in WorkThreadStartSession()
1065 handshake.version = Base::GetVersion() + HDC_MSG_HASH; in WorkThreadStartSession()
1117 Base::TryCloseHandle((uv_handle_t *)handle); in DispatchMainThreadCommand()
1128Base::TryCloseHandle((uv_handle_t *)&hSession->hChildWorkTCP, true, closeSessionChildThreadTCPHand… in DispatchMainThreadCommand()
1130 Base::TryCloseHandle((uv_handle_t *)hSession->pollHandle[STREAM_WORK], true, in DispatchMainThreadCommand()
1132 Base::TryCloseHandle((uv_handle_t *)&hSession->dataPipe[STREAM_WORK], true, in DispatchMainThreadCommand()
1165 const int size = Base::GetMaxBufSize(); in ReadCtrlFromMain()
1167 ssize_t nread = Base::ReadFromFd(hSession->ctrlFd[STREAM_WORK], buf, size); in ReadCtrlFromMain()
1220 uv_close((uv_handle_t *)handle, Base::CloseTimerCallback); in ReChildLoopForSessionClear()
1223Base::TimerUvTask(&hSession->childLoop, hSession, clearTaskForSessionFinish, (GLOBAL_TIMEOUT * TIM… in ReChildLoopForSessionClear()
1226 Base::TryCloseLoop(&hSession->childLoop, "Session childUV"); in ReChildLoopForSessionClear()
1256 string log = Base::StringFormat(msg, vaArgs); in LogMsg()