Method copyTo

src/jrd/replication/ChangeLog.cpp:170–212

}

void ChangeLog::Segment::copyTo(const PathName& filename) const
{
	fb_assert(m_header != &m_builtinHeader);

	if (os_utils::lseek(m_handle, 0, SEEK_SET) != 0)
		raiseIOError("seek", m_filename.c_str(), ERRNO);

	const auto totalLength = m_header->hdr_length;
	fb_assert(totalLength > sizeof(SegmentHeader));

	const auto dstHandle = os_utils::openCreateSharedFile(filename.c_str(), O_TRUNC | O_BINARY);

	AutoFile dstFile(dstHandle);

	Vector<UCHAR, COPY_BLOCK_SIZE> buffer;
	const auto data = buffer.begin();

	for (FB_UINT64 offset = 0; offset < totalLength; offset += COPY_BLOCK_SIZE)
	{
		const auto remaining = totalLength - offset;
		const SINT64 length = MIN(remaining, COPY_BLOCK_SIZE);

		if (::read(m_handle, data, length) != length)
		{
			const ISC_STATUS errcode = ERRNO;

			dstFile.release();
			unlink(filename.c_str());
			raiseIOError("read", m_filename.c_str(), errcode);
		}

		if (::write(dstFile, data, length) != length)
		{
			const ISC_STATUS errcode = ERRNO;

			dstFile.release();
			unlink(filename.c_str());
			raiseIOError("write", filename.c_str(), errcode);
		}
	}

	flushFile(dstHandle);
}

void ChangeLog::Segment::append(ULONG length, const UCHAR* data)
{