Method setupInlineBlob

src/remote/remote.cpp:980–1019

};

void Rtr::setupInlineBlob(P_INLINE_BLOB* p_blob)
{
	fb_assert(p_blob->p_tran_id == this->rtr_id);
	fb_assert(rtr_inline_blob);

	Rbl* blb = rtr_inline_blob;
	rtr_inline_blob = nullptr;

	fb_assert(blb->rbl_data.getCount() <= MAX_INLINE_BLOB_SIZE);
	fb_assert(blb->rbl_data.getCount() <= MAX_USHORT);

	blb->rbl_buffer_length = MIN(MAX_USHORT, blb->rbl_data.getCapacity());
	const ULONG cachedSize = blb->getCachedSize();
	if (!rtr_rdb->incBlobCache(cachedSize))
	{
		delete blb;
		return;
	}

	blb->rbl_blob_id = p_blob->p_blob_id;
	if (Rbl* old = rtr_blobs.locate(blb->rbl_blob_id))
	{
		// Blob with the same blob id already exists. It could be in use, or it
		// could be opened by user explicitly with custom BPB - thus delete new one.

		fb_assert(blb != old);
		delete blb;

		rtr_rdb->decBlobCache(cachedSize);
		return;
	}
	else
		rtr_blobs.add(blb);

	blb->rbl_info.parseInfo(p_blob->p_blob_info.cstr_length, p_blob->p_blob_info.cstr_address);

	blb->rbl_length = blb->rbl_data.getCount();
	blb->rbl_ptr = blb->rbl_buffer = blb->rbl_data.begin();
	blb->rbl_flags |= Rbl::EOF_PENDING;
}

void Rsr::saveException(const Exception& ex, bool overwrite)
{