dvander@2168: /**
dvander@2168:  * vim: set ts=4 :
dvander@2168:  * =============================================================================
dvander@2168:  * SourceMod
dvander@2168:  * Copyright (C) 2004-2008 AlliedModders LLC.  All rights reserved.
dvander@2168:  * =============================================================================
dvander@2168:  *
dvander@2168:  * This program is free software; you can redistribute it and/or modify it under
dvander@2168:  * the terms of the GNU General Public License, version 3.0, as published by the
dvander@2168:  * Free Software Foundation.
dvander@2168:  * 
dvander@2168:  * This program is distributed in the hope that it will be useful, but WITHOUT
dvander@2168:  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
dvander@2168:  * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
dvander@2168:  * details.
dvander@2168:  *
dvander@2168:  * You should have received a copy of the GNU General Public License along with
dvander@2168:  * this program.  If not, see <http://www.gnu.org/licenses/>.
dvander@2168:  *
dvander@2168:  * As a special exception, AlliedModders LLC gives you permission to link the
dvander@2168:  * code of this program (as well as its derivative works) to "Half-Life 2," the
dvander@2168:  * "Source Engine," the "SourcePawn JIT," and any Game MODs that run on software
dvander@2168:  * by the Valve Corporation.  You must obey the GNU General Public License in
dvander@2168:  * all respects for all other code used.  Additionally, AlliedModders LLC grants
dvander@2168:  * this exception to all derivative works.  AlliedModders LLC defines further
dvander@2168:  * exceptions, found in LICENSE.txt (as of this writing, version JULY-31-2007),
dvander@2168:  * or <http://www.sourcemod.net/license.php>.
dvander@2168:  *
dvander@2168:  * Version: $Id$
dvander@2168:  */
dvander@2168: 
dvander@2168: #include <assert.h>
dvander@2168: #include <stdarg.h>
dvander@2168: #include <string.h>
dvander@2168: #include "ForwardSys.h"
dvander@2168: #include "PluginSys.h"
dvander@2168: #include "ShareSys.h"
dvander@2168: #include "DebugReporter.h"
dvander@2168: 
dvander@2168: CForwardManager g_Forwards;
dvander@2168: 
dvander@2168: /**
dvander@2168:  * Genesis turns to its source, reduction occurs stepwise although the essence is all one.
dvander@2168:  * End of line.  FTL system check.
dvander@2168:  *
dvander@2168:  * :TODO: WHAT NEEDS TO BE TESTED IN THIS BEAST
dvander@2168:  * VARARG FUNCTIONS:
dvander@2168:  * - Pushing no varargs
dvander@2168:  */
dvander@2168: 
dvander@2168: // :TODO: IMPORTANT!!! The result pointer arg in the execute function maybe invalid if the forward fails
dvander@2168: // so later evaluation of this result may cause problems on higher levels of abstraction. DOCUMENT OR FIX ALL FORWARDS!
dvander@2168: 
dvander@2168: CForwardManager::~CForwardManager()
dvander@2168: {
dvander@2168: 	CStack<CForward *>::iterator iter;
dvander@2168: 	for (iter=m_FreeForwards.begin(); iter!=m_FreeForwards.end(); iter++)
dvander@2168: 	{
dvander@2168: 		delete (*iter);
dvander@2168: 	}
dvander@2168: 	m_FreeForwards.popall();
dvander@2168: }
dvander@2168: 
dvander@2168: void CForwardManager::OnSourceModAllInitialized()
dvander@2168: {
dvander@2168: 	g_PluginSys.AddPluginsListener(this);
dvander@2168: 	g_ShareSys.AddInterface(NULL, this);
dvander@2168: }
dvander@2168: 
dvander@2168: IForward *CForwardManager::CreateForward(const char *name, ExecType et, unsigned int num_params, const ParamType *types, ...)
dvander@2168: {
dvander@2168: 	CForward *fwd;
dvander@2168: 	va_list ap;
dvander@2168: 	va_start(ap, types);
dvander@2168: 	
dvander@2168: 	fwd = CForward::CreateForward(name, et, num_params, types, ap);
dvander@2168: 
dvander@2168: 	va_end(ap);
dvander@2168: 
dvander@2168: 	if (fwd)
dvander@2168: 	{
dvander@2168: 		g_PluginSys.AddFunctionsToForward(name, fwd);
dvander@2168: 
dvander@2168: 		m_managed.push_back(fwd);
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	return fwd;
dvander@2168: }
dvander@2168: 
dvander@2168: IChangeableForward *CForwardManager::CreateForwardEx(const char *name, ExecType et, int num_params, const ParamType *types, ...)
dvander@2168: {
dvander@2168: 	CForward *fwd;
dvander@2168: 	va_list ap;
dvander@2168: 	va_start(ap, types);
dvander@2168: 
dvander@2168: 	fwd = CForward::CreateForward(name, et, num_params, types, ap);
dvander@2168: 
dvander@2168: 	va_end(ap);
dvander@2168: 
dvander@2168: 	if (fwd)
dvander@2168: 	{
dvander@2168: 		m_unmanaged.push_back(fwd);
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	return fwd;
dvander@2168: }
dvander@2168: 
dvander@2168: void CForwardManager::OnPluginLoaded(IPlugin *plugin)
dvander@2168: {
dvander@2168: 	/* Attach any globally managed forwards */
dvander@2168: 	List<CForward *>::iterator iter;
dvander@2168: 	CForward *fwd;
dvander@2168: 
dvander@2168: 	for (iter=m_managed.begin(); iter!=m_managed.end(); iter++)
dvander@2168: 	{
dvander@2168: 		fwd = (*iter);
dvander@2168: 		IPluginFunction *pFunc = plugin->GetBaseContext()->GetFunctionByName(fwd->GetForwardName());
dvander@2168: 		if (pFunc)
dvander@2168: 		{
dvander@2168: 			fwd->AddFunction(pFunc);
dvander@2168: 		}
dvander@2168: 	}
dvander@2168: }
dvander@2168: 
dvander@2168: void CForwardManager::OnPluginUnloaded(IPlugin *plugin)
dvander@2168: {
dvander@2168: 	List<CForward *>::iterator iter;
dvander@2168: 	CForward *fwd;
dvander@2168: 
dvander@2168: 	for (iter=m_managed.begin(); iter!=m_managed.end(); iter++)
dvander@2168: 	{
dvander@2168: 		fwd = (*iter);
dvander@2168: 		fwd->RemoveFunctionsOfPlugin(plugin);
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	for (iter=m_unmanaged.begin(); iter!=m_unmanaged.end(); iter++)
dvander@2168: 	{
dvander@2168: 		fwd = (*iter);
dvander@2168: 		fwd->RemoveFunctionsOfPlugin(plugin);
dvander@2168: 	}
dvander@2168: }
dvander@2168: 
dvander@2168: IForward *CForwardManager::FindForward(const char *name, IChangeableForward **ifchng)
dvander@2168: {
dvander@2168: 	List<CForward *>::iterator iter;
dvander@2168: 	CForward *fwd;
dvander@2168: 
dvander@2168: 	for (iter=m_managed.begin(); iter!=m_managed.end(); iter++)
dvander@2168: 	{
dvander@2168: 		fwd = (*iter);
dvander@2168: 		if (strcmp(fwd->GetForwardName(), name) == 0)
dvander@2168: 		{
dvander@2168: 			if (ifchng)
dvander@2168: 			{
dvander@2168: 				*ifchng = NULL;
dvander@2168: 			}
dvander@2168: 			return fwd;
dvander@2168: 		}
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	for (iter=m_unmanaged.begin(); iter!=m_unmanaged.end(); iter++)
dvander@2168: 	{
dvander@2168: 		fwd = (*iter);
dvander@2168: 		if (strcmp(fwd->GetForwardName(), name) == 0)
dvander@2168: 		{
dvander@2168: 			if (ifchng)
dvander@2168: 			{
dvander@2168: 				*ifchng = fwd;
dvander@2168: 			}
dvander@2168: 			return fwd;
dvander@2168: 		}
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	if (ifchng)
dvander@2168: 	{
dvander@2168: 		*ifchng = NULL;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	return NULL;
dvander@2168: }
dvander@2168: 
dvander@2168: void CForwardManager::ReleaseForward(IForward *forward)
dvander@2168: {
dvander@2168: 	ForwardFree(static_cast<CForward *>(forward));
dvander@2168: }
dvander@2168: 
dvander@2168: void CForwardManager::ForwardFree(CForward *fwd)
dvander@2168: {
dvander@2168: 	if (fwd == NULL)
dvander@2168: 	{
dvander@2168: 		return;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	m_FreeForwards.push(fwd);
dvander@2168: 	m_managed.remove(fwd);
dvander@2168: }
dvander@2168: 
dvander@2168: CForward *CForwardManager::ForwardMake()
dvander@2168: {
dvander@2168: 	CForward *fwd;
dvander@2168: 	if (m_FreeForwards.empty())
dvander@2168: 	{
dvander@2168: 		fwd = new CForward;
dvander@2168: 	} else {
dvander@2168: 		fwd = m_FreeForwards.front();
dvander@2168: 		m_FreeForwards.pop();
dvander@2168: 	}
dvander@2168: 	return fwd;
dvander@2168: }
dvander@2168: 
dvander@2168: void CForwardManager::OnPluginPauseChange(IPlugin *plugin, bool paused)
dvander@2168: {
dvander@2168: 	/* No longer used */
dvander@2168: }
dvander@2168: 
dvander@2168: /*************************************
dvander@2168:  * ACTUAL FORWARD API IMPLEMENTATION *
dvander@2168:  *************************************/
dvander@2168: 
dvander@2168: CForward *CForward::CreateForward(const char *name, ExecType et, unsigned int num_params, const ParamType *types, va_list ap)
dvander@2168: {
dvander@2168: 	ParamType _types[SP_MAX_EXEC_PARAMS];
dvander@2168: 
dvander@2168: 	if (num_params > SP_MAX_EXEC_PARAMS)
dvander@2168: 	{
dvander@2168: 		return NULL;
dvander@2168: 	}
dvander@2168: 	
dvander@2168: 	if (types == NULL && num_params)
dvander@2168: 	{
dvander@2168: 		for (unsigned int i=0; i<num_params; i++)
dvander@2168: 		{
dvander@2168: 			_types[i] = (ParamType)va_arg(ap, int);
dvander@2168: 			if (_types[i] == Param_VarArgs && (i != num_params - 1))
dvander@2168: 			{
dvander@2168: 				return NULL;
dvander@2168: 			}
dvander@2168: 		}
dvander@2168: 		types = _types;
dvander@2168: 	} else {
dvander@2168: 		for (unsigned int i=0; i<num_params; i++)
dvander@2168: 		{
dvander@2168: 			_types[i] = types[i];
dvander@2168: 			if (types[i] == Param_VarArgs && (i != num_params - 1))
dvander@2168: 			{
dvander@2168: 				return NULL;
dvander@2168: 			}
dvander@2168: 		}
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	/* First parameter can never be varargs */
dvander@2168: 	if (num_params && _types[0] == Param_VarArgs)
dvander@2168: 	{
dvander@2168: 		return NULL;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	CForward *pForward = g_Forwards.ForwardMake();
dvander@2168: 	pForward->m_curparam = 0;
dvander@2168: 	pForward->m_ExecType = et;
dvander@2168: 	snprintf(pForward->m_name, FORWARDS_NAME_MAX, "%s", name ? name : "");
dvander@2168: 	
dvander@2168: 	for (unsigned int i=0; i<num_params; i++)
dvander@2168: 	{
dvander@2168: 		pForward->m_types[i] = _types[i];
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	if (num_params && _types[num_params-1] == Param_VarArgs)
dvander@2168: 	{
dvander@2168: 		pForward->m_varargs = num_params--;
dvander@2168: 	} else {
dvander@2168: 		pForward->m_varargs = false;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	pForward->m_numparams = num_params;
dvander@2168: 	pForward->m_errstate = SP_ERROR_NONE;
dvander@2168: 
dvander@2168: 	pForward->m_functions.clear();
dvander@2168: 
dvander@2168: 	return pForward;
dvander@2168: }
dvander@2168: 
dvander@2168: int CForward::Execute(cell_t *result, IForwardFilter *filter)
dvander@2168: {
dvander@2168: 	if (m_errstate)
dvander@2168: 	{
dvander@2168: 		int err = m_errstate;
dvander@2168: 		Cancel();
dvander@2168: 		return err;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	if (filter)
dvander@2168: 	{
dvander@2168: 		filter->OnExecuteBegin();
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	FuncIter iter = m_functions.begin();
dvander@2168: 	IPluginFunction *func;
dvander@2168: 	cell_t cur_result = 0;
dvander@2168: 	cell_t high_result = 0;
dvander@2168: 	int err;
dvander@2168: 	unsigned int failed=0, success=0;
dvander@2168: 	unsigned int num_params = m_curparam;
dvander@2168: 	FwdParamInfo temp_info[SP_MAX_EXEC_PARAMS];
dvander@2168: 	FwdParamInfo *param;
dvander@2168: 	ParamType type;
dvander@2168: 
dvander@2168: 	/* Save local, reset */
dvander@2168: 	memcpy(temp_info, m_params, sizeof(m_params));
dvander@2168: 	m_curparam = 0;
dvander@2168: 
dvander@2168: 	for (iter=m_functions.begin(); iter!=m_functions.end(); iter++)
dvander@2168: 	{
dvander@2168: 		func = (*iter);
dvander@2168: 
dvander@2168: 		for (unsigned int i=0; i<num_params; i++)
dvander@2168: 		{
dvander@2168: 			int err = SP_ERROR_PARAM;
dvander@2168: 			param = &temp_info[i];
dvander@2168: 			if (i >= m_numparams || m_types[i] == Param_Any)
dvander@2168: 			{
dvander@2168: 				type = param->pushedas;
dvander@2168: 			} else {
dvander@2168: 				type = m_types[i];
dvander@2168: 			}
dvander@2168: 			if ((i >= m_numparams) || (type & SP_PARAMFLAG_BYREF))
dvander@2168: 			{
dvander@2168: 				/* If we're byref or we're vararg, we always push everything by ref.
dvander@2168: 				 * Even if they're byval, we must push them byref.
dvander@2168: 				 */
dvander@2168: 				if (type == Param_String)
dvander@2168: 				{
dvander@2168: 					err = func->PushStringEx((char *)param->byref.orig_addr, param->byref.cells, param->byref.sz_flags, param->byref.flags);
dvander@2168: 				} else if (type == Param_Float || type == Param_Cell) {
dvander@2168: 					err = func->PushCellByRef(&param->val); 
dvander@2168: 				} else {
dvander@2168: 					err = func->PushArray(param->byref.orig_addr, param->byref.cells, param->byref.flags);
dvander@2168: 					assert(type == Param_Array || type == Param_FloatByRef || type == Param_CellByRef);
dvander@2168: 				}
dvander@2168: 			} else {
dvander@2168: 				/* If we're not byref or not vararg, our job is a bit easier. */
dvander@2168: 				assert(type == Param_Cell || type == Param_Float);
dvander@2168: 				err = func->PushCell(param->val);
dvander@2168: 			}
dvander@2168: 			if (err != SP_ERROR_NONE)
dvander@2168: 			{
dvander@2168: 				if (!filter || !filter->OnErrorReport(this, func, err))
dvander@2168: 				{
dvander@2168: 					g_DbgReporter.GenerateError(func->GetParentContext(), 
dvander@2168: 						func->GetFunctionID(), 
dvander@2168: 						err, 
dvander@2168: 						"Failed to push parameter while executing forward");
dvander@2168: 				}
dvander@2168: 				continue;
dvander@2168: 			}
dvander@2168: 		}
dvander@2168: 		
dvander@2168: 		/* Call the function and deal with the return value. */
dvander@2168: 		if ((err=func->Execute(&cur_result)) != SP_ERROR_NONE)
dvander@2168: 		{
dvander@2168: 			if (filter)
dvander@2168: 			{
dvander@2168: 				filter->OnErrorReport(this, func, err);
dvander@2168: 			}
dvander@2168: 			failed++;
dvander@2168: 		} else {
dvander@2168: 			success++;
dvander@2168: 			switch (m_ExecType)
dvander@2168: 			{
dvander@2168: 			case ET_Event:
dvander@2168: 				{
dvander@2168: 					if (cur_result > high_result)
dvander@2168: 					{
dvander@2168: 						high_result = cur_result;
dvander@2168: 					}
dvander@2168: 					break;
dvander@2168: 				}
dvander@2168: 			case ET_Hook:
dvander@2168: 				{
dvander@2168: 					if (cur_result > high_result)
dvander@2168: 					{
dvander@2168: 						high_result = cur_result;
dvander@2168: 						if ((ResultType)high_result == Pl_Stop)
dvander@2168: 						{
dvander@2168: 							goto done;
dvander@2168: 						}
dvander@2168: 					}
dvander@2168: 					break;
dvander@2168: 				}
dvander@2168: 			case ET_Custom:
dvander@2168: 				{
dvander@2168: 					if (filter)
dvander@2168: 					{
dvander@2168: 						if (filter->OnFunctionReturn(this, func, &cur_result) == Pl_Stop)
dvander@2168: 						{
dvander@2168: 							goto done;
dvander@2168: 						}
dvander@2168: 					}
dvander@2168: 					break;
dvander@2168: 				}
dvander@2168: 			default:
dvander@2168: 				{
dvander@2168: 					break;
dvander@2168: 				}
dvander@2168: 			}
dvander@2168: 		}
dvander@2168: 	}
dvander@2168: 
dvander@2168: done:
dvander@2168: 	if (success)
dvander@2168: 	{
dvander@2168: 		if (m_ExecType == ET_Event || m_ExecType == ET_Hook)
dvander@2168: 		{
dvander@2168: 			cur_result = high_result;
dvander@2168: 		} else if (m_ExecType == ET_Ignore) {
dvander@2168: 			cur_result = 0;
dvander@2168: 		}
dvander@2168: 		if (result)
dvander@2168: 		{
dvander@2168: 			*result = cur_result;
dvander@2168: 		}
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	if (filter)
dvander@2168: 	{
dvander@2168: 		filter->OnExecuteEnd(&cur_result, success, failed);
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	return SP_ERROR_NONE;
dvander@2168: }
dvander@2168: 
dvander@2168: int CForward::PushCell(cell_t cell)
dvander@2168: {
dvander@2168: 	if (m_curparam < m_numparams)
dvander@2168: 	{
dvander@2168: 		if (m_types[m_curparam] == Param_Any)
dvander@2168: 		{
dvander@2168: 			m_params[m_curparam].pushedas = Param_Cell;
dvander@2168: 		} else if (m_types[m_curparam] != Param_Cell) {
dvander@2168: 			return SetError(SP_ERROR_PARAM);
dvander@2168: 		}
dvander@2168: 	} else {
dvander@2168: 		if (!m_varargs || m_numparams > SP_MAX_EXEC_PARAMS)
dvander@2168: 		{
dvander@2168: 			return SetError(SP_ERROR_PARAMS_MAX);
dvander@2168: 		}
dvander@2168: 		m_params[m_curparam].pushedas = Param_Cell;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	m_params[m_curparam++].val = cell;
dvander@2168: 
dvander@2168: 	return SP_ERROR_NONE;
dvander@2168: }
dvander@2168: 
dvander@2168: int CForward::PushFloat(float number)
dvander@2168: {
dvander@2168: 	if (m_curparam < m_numparams)
dvander@2168: 	{
dvander@2168: 		if (m_types[m_curparam] == Param_Any)
dvander@2168: 		{
dvander@2168: 			m_params[m_curparam].pushedas = Param_Float;
dvander@2168: 		} else if (m_types[m_curparam] != Param_Float) {
dvander@2168: 			return SetError(SP_ERROR_PARAM);
dvander@2168: 		}
dvander@2168: 	} else {
dvander@2168: 		if (!m_varargs || m_numparams > SP_MAX_EXEC_PARAMS)
dvander@2168: 		{
dvander@2168: 			return SetError(SP_ERROR_PARAMS_MAX);
dvander@2168: 		}
dvander@2168: 		m_params[m_curparam].pushedas = Param_Float;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	m_params[m_curparam++].val = *(cell_t *)&number;
dvander@2168: 
dvander@2168: 	return SP_ERROR_NONE;
dvander@2168: }
dvander@2168: 
dvander@2168: int CForward::PushCellByRef(cell_t *cell, int flags)
dvander@2168: {
dvander@2168: 	if (m_curparam < m_numparams)
dvander@2168: 	{
dvander@2168: 		if (m_types[m_curparam] == Param_Any)
dvander@2168: 		{
dvander@2168: 			m_params[m_curparam].pushedas = Param_CellByRef;
dvander@2168: 		} else if (m_types[m_curparam] != Param_CellByRef) {
dvander@2168: 			return SetError(SP_ERROR_PARAM);
dvander@2168: 		}
dvander@2168: 	} else {
dvander@2168: 		if (!m_varargs || m_numparams > SP_MAX_EXEC_PARAMS)
dvander@2168: 		{
dvander@2168: 			return SetError(SP_ERROR_PARAMS_MAX);
dvander@2168: 		}
dvander@2168: 		m_params[m_curparam].pushedas = Param_CellByRef;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	_Int_PushArray(cell, 1, flags);
dvander@2168: 	m_curparam++;
dvander@2168: 
dvander@2168: 	return SP_ERROR_NONE;
dvander@2168: }
dvander@2168: 
dvander@2168: int CForward::PushFloatByRef(float *num, int flags)
dvander@2168: {
dvander@2168: 	if (m_curparam < m_numparams)
dvander@2168: 	{
dvander@2168: 		if (m_types[m_curparam] == Param_Any)
dvander@2168: 		{
dvander@2168: 			m_params[m_curparam].pushedas = Param_FloatByRef;
dvander@2168: 		} else if (m_types[m_curparam] != Param_FloatByRef) {
dvander@2168: 			return SetError(SP_ERROR_PARAM);
dvander@2168: 		}
dvander@2168: 	} else {
dvander@2168: 		if (!m_varargs || m_numparams > SP_MAX_EXEC_PARAMS)
dvander@2168: 		{
dvander@2168: 			return SetError(SP_ERROR_PARAMS_MAX);
dvander@2168: 		}
dvander@2168: 		m_params[m_curparam].pushedas = Param_FloatByRef;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	_Int_PushArray((cell_t *)num, 1, flags);
dvander@2168: 	m_curparam++;
dvander@2168: 
dvander@2168: 	return SP_ERROR_NONE;
dvander@2168: }
dvander@2168: 
dvander@2168: void CForward::_Int_PushArray(cell_t *inarray, unsigned int cells, int flags)
dvander@2168: {
dvander@2168: 	m_params[m_curparam].byref.cells = cells;
dvander@2168: 	m_params[m_curparam].byref.flags = flags;
dvander@2168: 	m_params[m_curparam].byref.orig_addr = inarray;
dvander@2168: }
dvander@2168: 
dvander@2168: int CForward::PushArray(cell_t *inarray, unsigned int cells, int flags)
dvander@2168: {
dvander@2168: 	/* We don't allow this here */
dvander@2168: 	if (!inarray)
dvander@2168: 	{
dvander@2168: 		return SetError(SP_ERROR_PARAM);
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	if (m_curparam < m_numparams)
dvander@2168: 	{
dvander@2168: 		if (m_types[m_curparam] == Param_Any)
dvander@2168: 		{
dvander@2168: 			m_params[m_curparam].pushedas = Param_Array;
dvander@2168: 		} else if (m_types[m_curparam] != Param_Array) {
dvander@2168: 			return SetError(SP_ERROR_PARAM);
dvander@2168: 		}
dvander@2168: 	} else {
dvander@2168: 		if (!m_varargs || m_curparam > SP_MAX_EXEC_PARAMS)
dvander@2168: 		{
dvander@2168: 			return SetError(SP_ERROR_PARAMS_MAX);
dvander@2168: 		}
dvander@2168: 		m_params[m_curparam].pushedas = Param_Array;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	_Int_PushArray(inarray, cells, flags);
dvander@2168: 
dvander@2168: 	m_curparam++;
dvander@2168: 
dvander@2168: 	return SP_ERROR_NONE;
dvander@2168: }
dvander@2168: 
dvander@2168: void CForward::_Int_PushString(cell_t *inarray, unsigned int cells, int sz_flags, int cp_flags)
dvander@2168: {
dvander@2168: 	m_params[m_curparam].byref.cells = cells;	/* Notice this contains the char count not cell count */
dvander@2168: 	m_params[m_curparam].byref.flags = cp_flags;
dvander@2168: 	m_params[m_curparam].byref.orig_addr = inarray;
dvander@2168: 	m_params[m_curparam].byref.sz_flags = sz_flags;
dvander@2168: }
dvander@2168: 
dvander@2168: int CForward::PushString(const char *string)
dvander@2168: {
dvander@2168: 	if (m_curparam < m_numparams)
dvander@2168: 	{
dvander@2168: 		if (m_types[m_curparam] == Param_Any)
dvander@2168: 		{
dvander@2168: 			m_params[m_curparam].pushedas = Param_String;
dvander@2168: 		} else if (m_types[m_curparam] != Param_String) {
dvander@2168: 			return SetError(SP_ERROR_PARAM);
dvander@2168: 		}
dvander@2168: 	} else {
dvander@2168: 		if (!m_varargs || m_curparam > SP_MAX_EXEC_PARAMS)
dvander@2168: 		{
dvander@2168: 			return SetError(SP_ERROR_PARAMS_MAX);
dvander@2168: 		}
dvander@2168: 		m_params[m_curparam].pushedas = Param_String;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	_Int_PushString((cell_t *)string, strlen(string)+1, SM_PARAM_STRING_COPY, 0);
dvander@2168: 	m_curparam++;
dvander@2168: 
dvander@2168: 	return SP_ERROR_NONE;
dvander@2168: }
dvander@2168: 
dvander@2168: int CForward::PushStringEx(char *buffer, size_t length, int sz_flags, int cp_flags)
dvander@2168: {
dvander@2168: 	if (m_curparam < m_numparams)
dvander@2168: 	{
dvander@2168: 		if (m_types[m_curparam] == Param_Any)
dvander@2168: 		{
dvander@2168: 			m_params[m_curparam].pushedas = Param_String;
dvander@2168: 		} else if (m_types[m_curparam] != Param_String) {
dvander@2168: 			return SetError(SP_ERROR_PARAM);
dvander@2168: 		}
dvander@2168: 	} else {
dvander@2168: 		if (!m_varargs || m_curparam > SP_MAX_EXEC_PARAMS)
dvander@2168: 		{
dvander@2168: 			return SetError(SP_ERROR_PARAMS_MAX);
dvander@2168: 		}
dvander@2168: 		m_params[m_curparam].pushedas = Param_String;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	_Int_PushString((cell_t *)buffer, length, sz_flags, cp_flags);
dvander@2168: 	m_curparam++;
dvander@2168: 
dvander@2168: 	return SP_ERROR_NONE;
dvander@2168: }
dvander@2168: 
dvander@2168: void CForward::Cancel()
dvander@2168: {
dvander@2168: 	if (!m_curparam)
dvander@2168: 	{
dvander@2168: 		return;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	m_curparam = 0;
dvander@2168: 	m_errstate = SP_ERROR_NONE;
dvander@2168: }
dvander@2168: 
dvander@2168: bool CForward::AddFunction(IPluginContext *pContext, funcid_t index)
dvander@2168: {
dvander@2168: 	IPluginFunction *pFunc = pContext->GetFunctionById(index);
dvander@2168: 
dvander@2168: 	if (!pFunc)
dvander@2168: 	{
dvander@2168: 		return false;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	return AddFunction(pFunc);
dvander@2168: }
dvander@2168: 
dvander@2168: bool CForward::RemoveFunction(IPluginContext *pContext, funcid_t index)
dvander@2168: {
dvander@2168: 	IPluginFunction *pFunc = pContext->GetFunctionById(index);
dvander@2168: 
dvander@2168: 	if (!pFunc)
dvander@2168: 	{
dvander@2168: 		return false;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	return RemoveFunction(pFunc);
dvander@2168: }
dvander@2168: 
dvander@2168: bool CForward::RemoveFunction(IPluginFunction *func)
dvander@2168: {
dvander@2168: 	bool found = false;
dvander@2168: 	FuncIter iter;
dvander@2168: 	List<IPluginFunction *> *lst;
dvander@2168: 
dvander@2168: 	if (func->IsRunnable())
dvander@2168: 	{
dvander@2168: 		lst = &m_functions;
dvander@2168: 	} else {
dvander@2168: 		lst = &m_paused;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	for (iter=m_functions.begin(); iter!=m_functions.end(); iter++)
dvander@2168: 	{
dvander@2168: 		if ((*iter) == func)
dvander@2168: 		{
dvander@2168: 			found = true;
dvander@2168: 			lst->erase(iter);
dvander@2168: 			break;
dvander@2168: 		}
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	/* Cancel a call, if any */
dvander@2168: 	if (found || m_curparam)
dvander@2168: 	{
dvander@2168: 		func->Cancel();
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	return found;
dvander@2168: }
dvander@2168: 
dvander@2168: unsigned int CForward::RemoveFunctionsOfPlugin(IPlugin *plugin)
dvander@2168: {
dvander@2168: 	FuncIter iter;
dvander@2168: 	IPluginFunction *func;
dvander@2168: 	unsigned int removed = 0;
dvander@2168: 	IPluginContext *pContext = plugin->GetBaseContext();
dvander@2168: 	for (iter=m_functions.begin(); iter!=m_functions.end();)
dvander@2168: 	{
dvander@2168: 		func = (*iter);
dvander@2168: 		if (func->GetParentContext() == pContext)
dvander@2168: 		{
dvander@2168: 			iter = m_functions.erase(iter);
dvander@2168: 			removed++;
dvander@2168: 		} else {
dvander@2168: 			iter++;
dvander@2168: 		}
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	return removed;
dvander@2168: }
dvander@2168: 
dvander@2168: bool CForward::AddFunction(IPluginFunction *func)
dvander@2168: {
dvander@2168: 	if (m_curparam)
dvander@2168: 	{
dvander@2168: 		return false;
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	if (func->IsRunnable())
dvander@2168: 	{
dvander@2168: 		m_functions.push_back(func);
dvander@2168: 	} else {
dvander@2168: 		m_paused.push_back(func);
dvander@2168: 	}
dvander@2168: 
dvander@2168: 	return true;
dvander@2168: }
dvander@2168: 
dvander@2168: const char *CForward::GetForwardName()
dvander@2168: {
dvander@2168: 	return m_name;
dvander@2168: }
dvander@2168: 
dvander@2168: unsigned int CForward::GetFunctionCount()
dvander@2168: {
dvander@2168: 	return m_functions.size();
dvander@2168: }
dvander@2168: 
dvander@2168: ExecType CForward::GetExecType()
dvander@2168: {
dvander@2168: 	return m_ExecType;
dvander@2168: }