Don't use pre-allocated static buffer for blobs (Rbl) to not waste a space in blobs cache by small blobs.

Author: hvlad

src/remote/client/interface.cpp

@@ -1866,7 +1866,7 @@ IBlob* Attachment::createBlob(CheckStatusWrapper* status, ITransaction* apiTra,
 		p_blob->p_blob_bpb.cstr_length = 0;
 		p_blob->p_blob_bpb.cstr_address = NULL;
 
-		Rbl* blob = FB_NEW Rbl();
+		Rbl* blob = FB_NEW Rbl(BLOB_LENGTH);
 		blob->rbl_blob_id = *blob_id = packet->p_resp.p_resp_blob_id;
 		blob->rbl_rdb = rdb;
 		blob->rbl_rtr = transaction;
@@ -6009,7 +6009,7 @@ IBlob* Attachment::openBlob(CheckStatusWrapper* status, ITransaction* apiTra, IS
 		//p_blob->p_blob_bpb.cstr_length = 0;
 		//p_blob->p_blob_bpb.cstr_address = NULL;
 
-		Rbl* blob = FB_NEW Rbl;
+		Rbl* blob = FB_NEW Rbl(BLOB_LENGTH);
 		blob->rbl_rdb = rdb;
 		blob->rbl_rtr = transaction;
 		blob->rbl_blob_id = *id;
@@ -9486,7 +9486,7 @@ static void release_blob( Rbl* blob)
 	if (blob->isCached())
 	{
 		// Assume buffer was not resized while blob was cached
-		rdb->decBlobCache(blob->rbl_data.getCapacity());
+		rdb->decBlobCache(blob->getCachedSize());
 	}
 	else
 		rdb->rdb_port->releaseObject(blob->rbl_id);

src/remote/protocol.cpp

@@ -1167,16 +1167,15 @@ bool_t xdr_protocol(RemoteXdr* xdrs, PACKET* p)
 
 				MAP(xdr_response, p_blob->p_blob_info);
 
-				Rbl* blb = tran->createInlineBlob();
+				AutoPtr<Rbl> blb = tran->createInlineBlob();
 				p_blob->p_blob_data = &blb->rbl_data;
 
 				if (!xdr_blobBuffer(xdrs, p_blob->p_blob_data))
 				{
 					tran->rtr_inline_blob = nullptr;
-					delete blb;
-
 					return P_FALSE(xdrs, p);
 				}
+				blb.release();
 			}
 
 			return P_TRUE(xdrs, p);

src/remote/remote.cpp

@@ -963,7 +963,7 @@ Rbl* Rtr::createInlineBlob()
 {
 	fb_assert(!rtr_inline_blob);
 
-	Rbl* blb = FB_NEW Rbl;
+	Rbl* blb = FB_NEW Rbl(0);
 
 	blb->rbl_rdb = rtr_rdb;
 	blb->rbl_rtr = this;
@@ -989,7 +989,7 @@ void Rtr::setupInlineBlob(P_INLINE_BLOB* p_blob)
 	fb_assert(blb->rbl_data.getCount() <= MAX_USHORT);
 
 	blb->rbl_buffer_length = MIN(MAX_USHORT, blb->rbl_data.getCapacity());
-	if (!rtr_rdb->incBlobCache(blb->rbl_data.getCapacity()))
+	if (!rtr_rdb->incBlobCache(blb->getCachedSize()))
 	{
 		delete blb;
 		return;
@@ -1005,7 +1005,7 @@ void Rtr::setupInlineBlob(P_INLINE_BLOB* p_blob)
 		fb_assert(blb != old);
 		delete blb;
 
-		rtr_rdb->decBlobCache(blb->rbl_data.getCapacity());
+		rtr_rdb->decBlobCache(blb->getCachedSize());
 		return;
 	}
 

src/remote/remote.h

@@ -283,9 +283,9 @@ struct RBlobInfo
 };
 
 // Used in XDR
-class RemBlobBuffer : public Firebird::HalfStaticArray<UCHAR, BLOB_LENGTH>
+class RemBlobBuffer : public Firebird::Array<UCHAR>
 {
-	using Firebird::HalfStaticArray<UCHAR, BLOB_LENGTH>::HalfStaticArray;
+	using Firebird::Array<UCHAR>::Array;
 };
 
 struct Rbl : public Firebird::GlobalStorage, public TypedHandle<rem_type_rbl>
@@ -319,11 +319,11 @@ struct Rbl : public Firebird::GlobalStorage, public TypedHandle<rem_type_rbl>
 	};
 
 public:
-	Rbl() :
+	Rbl(unsigned int initialSize) :
 		rbl_data(getPool()), rbl_rdb(0), rbl_rtr(0),
-		rbl_buffer(rbl_data.getBuffer(BLOB_LENGTH)), rbl_ptr(rbl_buffer), rbl_iface(NULL),
+		rbl_buffer(rbl_data.getBuffer(initialSize)), rbl_ptr(rbl_buffer), rbl_iface(NULL),
 		rbl_blob_id(NULL_BLOB), rbl_offset(0), rbl_id(0), rbl_flags(0),
-		rbl_buffer_length(BLOB_LENGTH), rbl_length(0), rbl_fragment_length(0),
+		rbl_buffer_length(initialSize), rbl_length(0), rbl_fragment_length(0),
 		rbl_source_interp(0), rbl_target_interp(0), rbl_self(NULL)
 	{ }
 
@@ -339,6 +339,7 @@ struct Rbl : public Firebird::GlobalStorage, public TypedHandle<rem_type_rbl>
 	static ISC_STATUS badHandle() { return isc_bad_segstr_handle; }
 
 	bool isCached() const { return rbl_flags & CACHED; }
+	unsigned getCachedSize() const { return sizeof(Rbl) + rbl_data.getCapacity(); }
 
 	static const SQUAD& generate(const void*, const Rbl* item) { return item->rbl_blob_id; }
 };

src/remote/server/server.cpp

@@ -4825,7 +4825,7 @@ ISC_STATUS rem_port::open_blob(P_OP op, P_BLOB* stuff, PACKET* sendL)
 	USHORT object = 0;
 	if (!(status_vector.getState() & IStatus::STATE_ERRORS))
 	{
-		Rbl* blob = FB_NEW Rbl;
+		Rbl* blob = FB_NEW Rbl(BLOB_LENGTH);
 #ifdef DEBUG_REMOTE_MEMORY
 		printf("open_blob(server)         allocate blob    %x\n", blob);
 #endif