Method archiveExecute

src/jrd/replication/ChangeLog.cpp:676–773

}

bool ChangeLog::archiveExecute(Segment* segment)
{
	if (m_config->archiveCommand.hasData())
	{
		segment->truncate();

		auto archiveCommand = m_config->archiveCommand;

		const auto filename = segment->getFileName();
		const auto pathname = m_config->journalDirectory + filename;

		const auto archpathname = m_config->archiveDirectory.hasData() ?
			m_config->archiveDirectory + filename : "";

		size_t pos;

		while ( (pos = archiveCommand.find(FILENAME_WILDCARD)) != string::npos)
			archiveCommand.replace(pos, strlen(FILENAME_WILDCARD), filename);

		while ( (pos = archiveCommand.find(PATHNAME_WILDCARD)) != string::npos)
			archiveCommand.replace(pos, strlen(PATHNAME_WILDCARD), pathname);

		while ( (pos = archiveCommand.find(ARCHPATHNAME_WILDCARD)) != string::npos)
			archiveCommand.replace(pos, strlen(ARCHPATHNAME_WILDCARD), archpathname);

		LockCheckout checkout(this);

		fb_assert(archiveCommand.hasData());
		const auto res = executeShell(archiveCommand);

		if (res)
		{
			string errorMsg;

			if (res < 0)
			{
				errorMsg.printf("Cannot execute journal archive command (error %d): %s",
								ERRNO, archiveCommand.c_str());
			}
			else
			{
				errorMsg.printf("Unexpected result (%d) while executing journal archive command: %s",
								res, archiveCommand.c_str());
			}

			logPrimaryError(m_config->dbName, errorMsg);
			return false;
		}
	}
	else if (m_config->archiveDirectory.hasData())
	{
		const auto filename = segment->getFileName();
		const auto archpathname = m_config->archiveDirectory + filename;

		struct stat statistics;
		if (os_utils::stat(archpathname.c_str(), &statistics) == 0)
		{
			if (statistics.st_size > (int) sizeof(SegmentHeader))