Method info

src/dsql/DsqlBatch.cpp:1022–1118

}

void DsqlBatch::info(thread_db* tdbb, unsigned int itemsLength, const unsigned char* items,
	unsigned int bufferLength, unsigned char* buffer)
{
	// Sanity check
	if (bufferLength < 3)	// bigger values will be processed by later code OK
	{
		if (bufferLength-- > 0)
		{
			*buffer++ = isc_info_truncated;
			if (bufferLength-- > 0)
				*buffer++ = isc_info_end;
		}
		return;
	}

	ClumpletReader it(ClumpletReader::InfoItems, items, itemsLength);
	ClumpletWriter out(ClumpletReader::InfoResponse, bufferLength - 1);		// place for isc_info_truncated / isc_info_end
	enum BufCloseState {BUF_OPEN, BUF_INTERNAL, BUF_END};
	BufCloseState closeOut = BUF_OPEN;

	try
	{
		bool flInfoLength = false;

		for (it.rewind(); !it.isEof(); it.moveNext())
		{
			UCHAR item = it.getClumpTag();
			if (item == isc_info_end)
				break;

			switch(item)
			{
			case IBatch::INF_BUFFER_BYTES_SIZE:
				out.insertInt(item, m_messages.getCapacity());
				break;
			case IBatch::INF_DATA_BYTES_SIZE:
				out.insertInt(item, FB_ALIGN(m_messages.getSize(), m_alignment));
				break;
			case IBatch::INF_BLOBS_BYTES_SIZE:
				if (m_blobs.getSize())
					out.insertInt(item, m_blobs.getSize());
				break;
			case IBatch::INF_BLOB_ALIGNMENT:
				out.insertInt(item, BLOB_STREAM_ALIGN);
				break;
			case IBatch::INF_BLOB_HEADER:
				out.insertInt(item, SIZEOF_BLOB_HEAD);
				break;
			case isc_info_length:
				flInfoLength = true;
				break;
			default:
				out.insertInt(isc_info_error, isc_infunk);
				break;
			}
		}

		// finalize writer