Lines Matching refs:m_mappedPlainLogFile

69     m_mappedPlainLogFile = nullptr;  in LogPersister()
181 munmap(m_mappedPlainLogFile, sizeof(LogPersisterBuffer)); in Deinit()
211m_mappedPlainLogFile = reinterpret_cast<LogPersisterBuffer*>(mmap(nullptr, sizeof(LogPersisterBuff… in PrepareUncompressedFile()
217 if (m_mappedPlainLogFile == MAP_FAILED) { in PrepareUncompressedFile()
224 std::cout << " Recovered persister, Offset=" << m_mappedPlainLogFile->offset << "\n"; in PrepareUncompressedFile()
227 auto compressionResult = m_compressor->Compress(*m_mappedPlainLogFile, *m_compressBuffer); in PrepareUncompressedFile()
234 m_mappedPlainLogFile->offset = 0; in PrepareUncompressedFile()
247 uint32_t remainingSpace = MAX_PERSISTER_BUFFER_SIZE - m_mappedPlainLogFile->offset; in WriteUncompressedLogs()
251 char* currentContentPos = m_mappedPlainLogFile->content + m_mappedPlainLogFile->offset; in WriteUncompressedLogs()
257 m_mappedPlainLogFile->offset += logLine.length(); in WriteUncompressedLogs()
289 auto compressionResult = m_compressor->Compress(*m_mappedPlainLogFile, *m_compressBuffer); in WriteLogData()
303 if (m_mappedPlainLogFile->offset == 0) in WriteCompressedLogs()
306 m_plainLogSize += m_mappedPlainLogFile->offset; in WriteCompressedLogs()
312 m_mappedPlainLogFile->offset = 0; in WriteCompressedLogs()
352 (void)m_compressor->Compress(*m_mappedPlainLogFile, *m_compressBuffer); in ReceiveLogLoop()
358 (void)m_compressor->Compress(*m_mappedPlainLogFile, *m_compressBuffer); in ReceiveLogLoop()
428 … (void)logPersisterPtr->m_compressor->Compress(*(logPersisterPtr->m_mappedPlainLogFile), in Refresh()