Method initSegments

src/jrd/replication/ChangeLog.cpp:895–935

}

void ChangeLog::initSegments()
{
	clearSegments();

	const auto state = m_sharedMemory->getHeader();

	AutoPtr<PathUtils::DirIterator> iter;

	for (iter = PathUtils::newDirIterator(getPool(), m_config->journalDirectory);
		*iter; ++(*iter))
	{
		const auto filename = **iter;

		const auto fd = os_utils::openCreateSharedFile(filename.c_str(), O_BINARY);

		AutoPtr<Segment> segment(FB_NEW_POOL(getPool()) Segment(getPool(), filename, fd));

		if (!validateSegment(segment))
			continue;

		if (segment->getSequence() > state->sequence)
			segment->setState(SEGMENT_STATE_FREE);

		if (segment->getState() == SEGMENT_STATE_FREE)
		{
			segment->closeFile();

			if (segment->getSequence() + m_config->segmentCount <= state->sequence)
			{
				const PathName& fname = segment->getPathName();
				unlink(fname.c_str());
				continue;
			}
		}

		segment->addRef();
		m_segments.add(segment.release());
	}

	m_generation = state->generation;
}

void ChangeLog::clearSegments()
{