/*
 *	PROGRAM:	Dynamic SQL runtime support
 *	MODULE:		all.c
 *	DESCRIPTION:	Internal block allocator
 *
 * The contents of this file are subject to the Interbase Public
 * License Version 1.0 (the "License"); you may not use this file
 * except in compliance with the License. You may obtain a copy
 * of the License at http://www.Inprise.com/IPL.html
 *
 * Software distributed under the License is distributed on an
 * "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, either express
 * or implied. See the License for the specific language governing
 * rights and limitations under the License.
 *
 * The Original Code was created by Inprise Corporation
 * and its predecessors. Portions created by Inprise Corporation are
 * Copyright (C) Inprise Corporation.
 *
 * All Rights Reserved.
 * Contributor(s): ______________________________________.
 *	02 Nov 2001: Mike Nordell - Synch with FB1 changes.
 */

/**************************************************************
V4 Multi-threading changes.

-- direct calls to gds__ () & isc_ () entry points

	THREAD_EXIT;
	    gds__ () or isc_ () call.
	THREAD_ENTER;

-- calls through embedded GDML.

the following protocol will be used.  Care should be taken if
nested FOR loops are added.

    THREAD_EXIT;                // last statment before FOR loop 

    FOR ...............

	THREAD_ENTER;           // First statment in FOR loop
	.....some C code....
	.....some C code....
	THREAD_EXIT;            // last statment in FOR loop 

    END_FOR;

    THREAD_ENTER;               // First statment after FOR loop
***************************************************************/

#include "../dsql/all.h"
#include "firebird.h"
#include <string.h>
#include "../jrd/ib_stdio.h"
#include "../dsql/dsql.h"
#include "../dsql/node.h"
#include "../dsql/sym.h"
#include "gen/codes.h"
#include "../dsql/alld_proto.h"
#include "../dsql/errd_proto.h"
#include "../jrd/gds_proto.h"
#include "../jrd/thd_proto.h"

ASSERT_FILENAME			//Define things dsql/assert needed

#include "../include/fb_vector.h"

#ifdef SUPERSERVER
extern "C" {
extern SLONG trace_pools;
}
SLONG alld_delta_alloc = 0;
#endif

DsqlMemoryPool *DSQL_permanent_pool = 0;
typedef Firebird::vector<DsqlMemoryPool*> pool_vec_t;
static bool init_flag = false;
static Firebird::vector<DsqlMemoryPool*> *pools = 0;

// Microsoft MSVC bug workaround
#ifdef _MSC_VER
#define for if(0) {} else for
#endif


void ALLD_fini()
{
	if (!init_flag) {
		BUGCHECK ("ALLD_fini - finishing before starting");
	}

	for (pool_vec_t::iterator curr = pools->begin(); curr != pools->end(); ++curr)
	{
		if (*curr) {
			delete *curr;
		}
	}

	delete pools;
	pools = 0;
	delete DSQL_permanent_pool;
	DSQL_permanent_pool = 0;
	init_flag = false;
}


void ALLD_init()
{
	TSQL tdsql = GET_THREAD_DATA;

	if (!init_flag)
	{
		init_flag = true;
		DSQL_permanent_pool = FB_NEW(*getDefaultMemoryPool()) DsqlMemoryPool;
		pools = FB_NEW(*DSQL_permanent_pool) Firebird::vector<DsqlMemoryPool*>
					(10, *DSQL_permanent_pool, dsql_type_vec);
		tdsql->tsql_default = DSQL_permanent_pool;
	}
}

void DsqlMemoryPool::ALLD_push(BLK object, register DLLS * stack)
{
	TSQL tdsql = GET_THREAD_DATA;
	DsqlMemoryPool* pool = tdsql->tsql_default;

	DLLS node = pool->lls_cache.newBlock();
	node->lls_object = object;
	node->lls_next = *stack;
	*stack = node;
}


BLK DsqlMemoryPool::ALLD_pop(register DLLS *stack)
{
	DLLS node = *stack;
	*stack = node->lls_next;
	BLK object = node->lls_object;

	DsqlMemoryPool* pool = (DsqlMemoryPool*)MemoryPool::blk_pool(node);
	pool->lls_cache.returnBlock(node);

	return object;
}

DsqlMemoryPool::DsqlMemoryPool(int extSize, MemoryPool& p)
	:	MemoryPool(0, &p),
		lls_cache(*this)
{
	if (!DSQL_permanent_pool)
		return;
		
	for(pool_vec_t::iterator curr = pools->begin(); curr != pools->end(); ++curr)
	{
		if (!*curr)
		{
			*curr = this;
			return;
		}
	}

	pools->resize(pools->size() + 10);
	for(pool_vec_t::iterator curr = pools->begin(); curr != pools->end(); ++curr)
	{
		if (!*curr)
		{
			*curr = this;
			return;
		}
	}

	BUGCHECK ("ALLD_fini - finishing before starting");
}

DsqlMemoryPool::~DsqlMemoryPool()
{
	if (this == DSQL_permanent_pool)
		return;
		
	for(pool_vec_t::iterator curr = pools->begin(); curr != pools->end(); ++curr)
	{
		if (*curr == this)
		{
			*curr = 0;
			return;
		}
	}
}