Method reuseSegment

src/jrd/replication/ChangeLog.cpp:973–1032

}

ChangeLog::Segment* ChangeLog::reuseSegment(ChangeLog::Segment* segment)
{
	// Remove segment from the list

	FB_SIZE_T pos = 0;
	if (m_segments.find(segment, pos))
		m_segments.remove(pos);
	else
		fb_assert(false);

	// Save its original filename

	const PathName orgname = segment->getPathName();

	// Release the reference (thus destroying the segment)

	segment->release();

	// Increase the sequence

	const auto state = m_sharedMemory->getHeader();
	const auto sequence = state->sequence + 1;

	// Attempt to rename the backing file

	PathName newname;
	newname.printf(FILENAME_PATTERN, m_config->filePrefix.c_str(), sequence);
	newname = m_config->journalDirectory + newname;

	// If renaming fails, then we just create a new file.
	// The old segment will be reused later in this case.
	if (::rename(orgname.c_str(), newname.c_str()) < 0)
	{
#ifdef DEV_BUILD
		const auto err = ERRNO;

		string warn;
		warn.printf("Journal file %s rename to %s failed (error %d)",
					orgname.c_str(), newname.c_str(), err);

		logPrimaryWarning(m_config->dbName, warn);
#endif
		return createSegment();
	}

	// Re-open the segment using a new name and initialize it

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

	segment = FB_NEW_POOL(getPool()) Segment(getPool(), newname, fd);

	segment->init(sequence, m_guid);
	segment->addRef();

	m_segments.add(segment);
	state->generation++;
	state->sequence++;