Method openBlob

src/remote/client/interface.cpp:5877–6079

IBlob* Attachment::openBlob(CheckStatusWrapper* status, ITransaction* apiTra, ISC_QUAD* id,
	unsigned int bpb_length, const unsigned char* bpb)
{
/**************************************
 *
 *	g d s _ o p e n _ b l o b 2
 *
 **************************************
 *
 * Functional description
 *	Open an existing blob.
 *
 **************************************/
	try
	{
		reset(status);

		CHECK_HANDLE(rdb, isc_bad_db_handle);
		rem_port* port = rdb->rdb_port;
		RefMutexGuard portGuard(*port->port_sync, FB_FUNCTION);

		Rtr* transaction = remoteTransaction(apiTra);
		CHECK_HANDLE(transaction, isc_bad_trans_handle);

		for (Rbl* blob = transaction->rtr_blobs.locate(*id); blob;
			 blob = transaction->rtr_blobs.getNext())
		{
			if (blob->rbl_blob_id != *id)
				break;

			if (!(blob->rbl_flags & Rbl::CACHED))
				continue;

			if (bpb_length)
			{
				if (!(blob->rbl_flags & Rbl::USED))
					release_blob(blob);
				break;
			}

			if (blob->rbl_flags & Rbl::USED)
				break;

			blob->rbl_flags |= Rbl::USED;

			Blob* iBlob = FB_NEW Blob(blob);
			iBlob->addRef();
			return iBlob;
		}

		// Validate data length

		CHECK_LENGTH(port, bpb_length);

		PACKET* packet = &rdb->rdb_packet;
		packet->p_operation = op_open_blob2;
		P_BLOB* p_blob = &packet->p_blob;
		p_blob->p_blob_transaction = transaction->rtr_id;