Lines Matching refs:LogPersister
59 std::recursive_mutex LogPersister::s_logPersistersMtx;
60 std::list<std::shared_ptr<LogPersister>> LogPersister::s_logPersisters;
62 std::shared_ptr<LogPersister> LogPersister::CreateLogPersister(HilogBuffer &buffer)
64 return std::shared_ptr<LogPersister>(new LogPersister(buffer));
67 LogPersister::LogPersister(HilogBuffer &buffer) : m_hilogBuffer(buffer)
74 LogPersister::~LogPersister()
80 int LogPersister::InitCompression()
105 int LogPersister::InitFileRotator(const PersistRecoveryInfo& info, bool restore)
127 int LogPersister::Init(const PersistRecoveryInfo& info, bool restore)
171 int LogPersister::Deinit()
194 int LogPersister::PrepareUncompressedFile(const std::string& parentPath, bool restore)
239 void LogPersister::NotifyNewLogAvailable()
244 bool LogPersister::WriteUncompressedLogs(std::string& logLine)
261 int LogPersister::WriteLogData(const HilogData& logData)
301 inline void LogPersister::WriteCompressedLogs()
315 void LogPersister::Start()
334 int LogPersister::ReceiveLogLoop()
364 int LogPersister::Query(std::list<LogPersistQueryResult> &results)
376 void LogPersister::FillInfo(LogPersistQueryResult &response)
387 int LogPersister::Kill(uint32_t id)
397 void LogPersister::Stop()
399 std::cout << "Exiting LogPersister!\n";
413 int LogPersister::Refresh(uint32_t id)
439 void LogPersister::Clear()
458 bool LogPersister::CheckRegistered(uint32_t id, const std::string& logPath)
462 [&](const std::shared_ptr<LogPersister>& logPersister) {
471 std::shared_ptr<LogPersister> LogPersister::GetLogPersisterById(uint32_t id)
476 [&](const std::shared_ptr<LogPersister>& logPersister) {
483 return std::shared_ptr<LogPersister>();
488 void LogPersister::RegisterLogPersister(const std::shared_ptr<LogPersister>& obj)
494 void LogPersister::DeregisterLogPersister(const std::shared_ptr<LogPersister>& obj)
502 [&](const std::shared_ptr<LogPersister>& logPersister) {