1947 lines
44 KiB
C++
1947 lines
44 KiB
C++
// Task Manager
|
|
//
|
|
// -- jweier
|
|
|
|
#include "ICARUS.h"
|
|
#include <assert.h>
|
|
|
|
#define VALIDATE(a) if ( a == false ) return TASK_FAILED;
|
|
|
|
/*
|
|
=================================================
|
|
|
|
CTask
|
|
|
|
=================================================
|
|
*/
|
|
|
|
CTask::CTask( void )
|
|
{
|
|
}
|
|
|
|
CTask::~CTask( void )
|
|
{
|
|
}
|
|
|
|
CTask *CTask::Create( int GUID, CBlock *block )
|
|
{
|
|
CTask *task = new CTask;
|
|
|
|
//TODO: Emit warning
|
|
assert( task );
|
|
if ( task == NULL )
|
|
return NULL;
|
|
|
|
task->SetTimeStamp( 0 );
|
|
task->SetBlock( block );
|
|
task->SetGUID( GUID );
|
|
|
|
return task;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Free
|
|
-------------------------
|
|
*/
|
|
|
|
void CTask::Free( void )
|
|
{
|
|
//NOTENOTE: The block is not consumed by the task, it is the sequencer's job to clean blocks up
|
|
delete this;
|
|
}
|
|
|
|
/*
|
|
=================================================
|
|
|
|
CTaskGroup
|
|
|
|
=================================================
|
|
*/
|
|
|
|
CTaskGroup::CTaskGroup( void )
|
|
{
|
|
Init();
|
|
|
|
m_GUID = 0;
|
|
m_parent = NULL;
|
|
}
|
|
|
|
CTaskGroup::~CTaskGroup( void )
|
|
{
|
|
m_completedTasks.clear();
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
SetGUID
|
|
-------------------------
|
|
*/
|
|
|
|
void CTaskGroup::SetGUID( int GUID )
|
|
{
|
|
m_GUID = GUID;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Init
|
|
-------------------------
|
|
*/
|
|
|
|
void CTaskGroup::Init( void )
|
|
{
|
|
m_completedTasks.clear();
|
|
|
|
m_numTasks = 0;
|
|
m_numCompleted = 0;
|
|
m_parent = NULL;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Add
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskGroup::Add( CTask *task )
|
|
{
|
|
m_completedTasks[ task->GetGUID() ] = false;
|
|
m_numTasks++;
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
MarkTaskComplete
|
|
-------------------------
|
|
*/
|
|
|
|
bool CTaskGroup::MarkTaskComplete( int id )
|
|
{
|
|
if ( (m_completedTasks.find( id )) != m_completedTasks.end() )
|
|
{
|
|
m_completedTasks[ id ] = true;
|
|
m_numCompleted++;
|
|
|
|
//Release the extra baggage, we only need to know that we're done now
|
|
/*
|
|
if ( m_numCompleted == m_numTasks )
|
|
{
|
|
m_completedTasks.clear();
|
|
}
|
|
*/
|
|
|
|
return true;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
/*
|
|
=================================================
|
|
|
|
CTaskManager
|
|
|
|
=================================================
|
|
*/
|
|
|
|
CTaskManager::CTaskManager( void )
|
|
{
|
|
}
|
|
|
|
CTaskManager::~CTaskManager( void )
|
|
{
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Create
|
|
-------------------------
|
|
*/
|
|
|
|
CTaskManager *CTaskManager::Create( void )
|
|
{
|
|
return new CTaskManager;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Init
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Init( CSequencer *owner )
|
|
{
|
|
//TODO: Emit warning
|
|
if ( owner == NULL )
|
|
return TASK_FAILED;
|
|
|
|
m_owner = owner;
|
|
m_ownerID = owner->GetOwnerID();
|
|
m_curGroup = NULL;
|
|
m_GUID = 0;
|
|
m_numTasks = 0;
|
|
m_resident = false;
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Free
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Free( void )
|
|
{
|
|
taskGroup_v::iterator gi;
|
|
tasks_l::iterator ti;
|
|
|
|
//Clear out all pending tasks
|
|
for ( ti = m_tasks.begin(); ti != m_tasks.end(); ti++ )
|
|
{
|
|
(*ti)->Free();
|
|
}
|
|
|
|
m_tasks.clear();
|
|
|
|
//Clear out all taskGroups
|
|
for ( gi = m_taskGroups.begin(); gi != m_taskGroups.end(); gi++ )
|
|
{
|
|
delete (*gi);
|
|
}
|
|
|
|
m_taskGroups.clear();
|
|
m_taskGroupNameMap.clear();
|
|
m_taskGroupIDMap.clear();
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Flush
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Flush( void )
|
|
{
|
|
//FIXME: Rewrite
|
|
|
|
return true;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
AddTaskGroup
|
|
-------------------------
|
|
*/
|
|
|
|
CTaskGroup *CTaskManager::AddTaskGroup( const char *name )
|
|
{
|
|
CTaskGroup *group;
|
|
|
|
//Collect any garbage
|
|
taskGroupName_m::iterator tgni;
|
|
tgni = m_taskGroupNameMap.find( name );
|
|
|
|
if ( tgni != m_taskGroupNameMap.end() )
|
|
{
|
|
group = (*tgni).second;
|
|
|
|
//Clear it and just move on
|
|
group->Init();
|
|
|
|
return group;
|
|
}
|
|
|
|
//Allocate a new one
|
|
group = new CTaskGroup;;
|
|
|
|
//TODO: Emit warning
|
|
assert( group );
|
|
if ( group == NULL )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Unable to allocate task group \"%s\"\n", name );
|
|
return NULL;
|
|
}
|
|
|
|
//Setup the internal information
|
|
group->SetGUID( m_GUID++ );
|
|
|
|
//Add it to the list and associate it for retrieval later
|
|
m_taskGroups.insert( m_taskGroups.end(), group );
|
|
m_taskGroupNameMap[ name ] = group;
|
|
m_taskGroupIDMap[ group->GetGUID() ] = group;
|
|
|
|
return group;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
GetTaskGroup
|
|
-------------------------
|
|
*/
|
|
|
|
CTaskGroup *CTaskManager::GetTaskGroup( const char *name )
|
|
{
|
|
taskGroupName_m::iterator tgi;
|
|
|
|
tgi = m_taskGroupNameMap.find( name );
|
|
|
|
if ( tgi == m_taskGroupNameMap.end() )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_WARNING, "Could not find task group \"%s\"\n", name );
|
|
return NULL;
|
|
}
|
|
|
|
return (*tgi).second;
|
|
}
|
|
|
|
CTaskGroup *CTaskManager::GetTaskGroup( int id )
|
|
{
|
|
taskGroupID_m::iterator tgi;
|
|
|
|
tgi = m_taskGroupIDMap.find( id );
|
|
|
|
if ( tgi == m_taskGroupIDMap.end() )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_WARNING, "Could not find task group \"%d\"\n", id );
|
|
return NULL;
|
|
}
|
|
|
|
return (*tgi).second;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Update
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Update( void )
|
|
{
|
|
m_count = 0; //Needed for runaway init
|
|
m_resident = true;
|
|
|
|
int returnVal = Go();
|
|
|
|
m_resident = false;
|
|
|
|
return returnVal;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Check
|
|
-------------------------
|
|
*/
|
|
|
|
inline bool CTaskManager::Check( int targetID, CBlock *block, int memberNum )
|
|
{
|
|
if ( (block->GetMember( memberNum ))->GetID() == targetID )
|
|
return true;
|
|
|
|
return false;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
GetFloat
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::GetFloat( int entID, CBlock *block, int &memberNum, float &value )
|
|
{
|
|
char *name;
|
|
int type;
|
|
|
|
//See if this is a get() command replacement
|
|
if ( Check( ID_GET, block, memberNum ) )
|
|
{
|
|
//Update the member past the header id
|
|
memberNum++;
|
|
|
|
//get( TYPE, NAME )
|
|
type = (int) (*(float *) block->GetMemberData( memberNum++ ));
|
|
name = (char *) block->GetMemberData( memberNum++ );
|
|
|
|
//TODO: Emit warning
|
|
if ( type != TK_FLOAT )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Get() call tried to return a non-FLOAT parameter!\n" );
|
|
return false;
|
|
}
|
|
|
|
return (m_owner->GetInterface())->I_GetFloat( entID, type, name, &value );
|
|
}
|
|
|
|
//Look for a random() inline call
|
|
if ( Check( ID_RANDOM, block, memberNum ) )
|
|
{
|
|
float min, max;
|
|
|
|
memberNum++;
|
|
|
|
min = *(float *) block->GetMemberData( memberNum++ );
|
|
max = *(float *) block->GetMemberData( memberNum++ );
|
|
|
|
value = (m_owner->GetInterface())->I_Random( min, max );
|
|
|
|
return true;
|
|
}
|
|
|
|
//Look for a tag() inline call
|
|
if ( Check( ID_TAG, block, memberNum ) )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_WARNING, "Invalid use of \"tag\" inline. Not a valid replacement for type FLOAT\n" );
|
|
return false;
|
|
}
|
|
|
|
CBlockMember *bm = block->GetMember( memberNum );
|
|
|
|
if ( bm->GetID() == TK_INT )
|
|
{
|
|
value = (float) (*(int *) block->GetMemberData( memberNum++ ));
|
|
}
|
|
else if ( bm->GetID() == TK_FLOAT )
|
|
{
|
|
value = *(float *) block->GetMemberData( memberNum++ );
|
|
}
|
|
else
|
|
{
|
|
assert(0);
|
|
(m_owner->GetInterface())->I_DPrintf( WL_WARNING, "Unexpected value; expected type FLOAT\n" );
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
GetVector
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::GetVector( int entID, CBlock *block, int &memberNum, vector_t &value )
|
|
{
|
|
char *name;
|
|
int type, i;
|
|
|
|
//See if this is a get() command replacement
|
|
if ( Check( ID_GET, block, memberNum ) )
|
|
{
|
|
//Update the member past the header id
|
|
memberNum++;
|
|
|
|
//get( TYPE, NAME )
|
|
type = (int) (*(float *) block->GetMemberData( memberNum++ ));
|
|
name = (char *) block->GetMemberData( memberNum++ );
|
|
|
|
//TODO: Emit warning
|
|
if ( type != TK_VECTOR )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Get() call tried to return a non-VECTOR parameter!\n" );
|
|
}
|
|
|
|
return (m_owner->GetInterface())->I_GetVector( entID, type, name, value );
|
|
}
|
|
|
|
//Look for a random() inline call
|
|
if ( Check( ID_RANDOM, block, memberNum ) )
|
|
{
|
|
float min, max;
|
|
|
|
memberNum++;
|
|
|
|
min = *(float *) block->GetMemberData( memberNum++ );
|
|
max = *(float *) block->GetMemberData( memberNum++ );
|
|
|
|
for ( i = 0; i < 3; i++ )
|
|
{
|
|
value[i] = (float) (m_owner->GetInterface())->I_Random( min, max ); //FIXME: Just truncating it for now.. should be fine though
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
//Look for a tag() inline call
|
|
if ( Check( ID_TAG, block, memberNum ) )
|
|
{
|
|
char *tagName;
|
|
float tagLookup;
|
|
|
|
memberNum++;
|
|
VALIDATE ( Get( entID, block, memberNum, &tagName ) );
|
|
VALIDATE ( GetFloat( entID, block, memberNum, tagLookup ) );
|
|
|
|
if ( (m_owner->GetInterface())->I_GetTag( entID, tagName, (int) tagLookup, value ) == false)
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Unable to find tag \"%s\"!\n", tagName );
|
|
assert(0);
|
|
return TASK_FAILED;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
//Check for a real vector here
|
|
type = (int) (*(float *) block->GetMemberData( memberNum ));
|
|
|
|
if ( type != TK_VECTOR )
|
|
{
|
|
// (m_owner->GetInterface())->I_DPrintf( WL_WARNING, "Unexpected value; expected type VECTOR\n" );
|
|
return false;
|
|
}
|
|
|
|
memberNum++;
|
|
|
|
for ( i = 0; i < 3; i++ )
|
|
{
|
|
if ( GetFloat( entID, block, memberNum, value[i] ) == false )
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Get
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Get( int entID, CBlock *block, int &memberNum, char **value )
|
|
{
|
|
static char tempBuffer[128]; //FIXME: EEEK!
|
|
vector_t vector;
|
|
char *name, *tagName;
|
|
float tagLookup;
|
|
int type;
|
|
|
|
//Look for a get() inline call
|
|
if ( Check( ID_GET, block, memberNum ) )
|
|
{
|
|
//Update the member past the header id
|
|
memberNum++;
|
|
|
|
//get( TYPE, NAME )
|
|
type = (int) (*(float *) block->GetMemberData( memberNum++ ));
|
|
name = (char *) block->GetMemberData( memberNum++ );
|
|
|
|
//Format the return properly
|
|
//FIXME: This is probably doing double formatting in certain cases...
|
|
//FIXME: STRING MANAGEMENT NEEDS TO BE IMPLEMENTED, MY CURRENT SOLUTION IS NOT ACCEPTABLE!!
|
|
switch ( type )
|
|
{
|
|
case TK_STRING:
|
|
if ( ( m_owner->GetInterface())->I_GetString( entID, type, name, value ) == false )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Get() parameter \"%s\" could not be found!\n", name );
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
break;
|
|
|
|
case TK_FLOAT:
|
|
{
|
|
float temp;
|
|
|
|
if ( (m_owner->GetInterface())->I_GetFloat( entID, type, name, &temp ) == false )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Get() parameter \"%s\" could not be found!\n", name );
|
|
return false;
|
|
}
|
|
|
|
sprintf( (char *) tempBuffer, "%f", temp );
|
|
*value = (char *) tempBuffer;
|
|
}
|
|
|
|
return true;
|
|
break;
|
|
|
|
case TK_VECTOR:
|
|
{
|
|
vector_t vval;
|
|
|
|
if ( (m_owner->GetInterface())->I_GetVector( entID, type, name, vval ) == false )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Get() parameter \"%s\" could not be found!\n", name );
|
|
return false;
|
|
}
|
|
|
|
sprintf( (char *) tempBuffer, "%f %f %f", vval[0], vval[1], vval[2] );
|
|
*value = (char *) tempBuffer;
|
|
}
|
|
|
|
return true;
|
|
break;
|
|
|
|
default:
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Get() call tried to return an unknown type!\n" );
|
|
return false;
|
|
break;
|
|
}
|
|
}
|
|
|
|
//Look for a random() inline call
|
|
if ( Check( ID_RANDOM, block, memberNum ) )
|
|
{
|
|
float min, max, ret;
|
|
|
|
memberNum++;
|
|
|
|
min = *(float *) block->GetMemberData( memberNum++ );
|
|
max = *(float *) block->GetMemberData( memberNum++ );
|
|
|
|
ret = ( m_owner->GetInterface())->I_Random( min, max );
|
|
|
|
sprintf( (char *) tempBuffer, "%f", ret );
|
|
*value = (char *) tempBuffer;
|
|
|
|
return true;
|
|
}
|
|
|
|
//Look for a tag() inline call
|
|
if ( Check( ID_TAG, block, memberNum ) )
|
|
{
|
|
memberNum++;
|
|
VALIDATE ( Get( entID, block, memberNum, &tagName ) );
|
|
VALIDATE ( GetFloat( entID, block, memberNum, tagLookup ) );
|
|
|
|
if ( ( m_owner->GetInterface())->I_GetTag( entID, tagName, (int) tagLookup, vector ) == false)
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Unable to find tag \"%s\"!\n", tagName );
|
|
assert(0 && "Unable to find tag");
|
|
return false;
|
|
}
|
|
|
|
sprintf( (char *) tempBuffer, "%f %f %f", vector[0], vector[1], vector[2] );
|
|
*value = (char *) tempBuffer;
|
|
|
|
return true;
|
|
}
|
|
|
|
//Get an actual piece of data
|
|
|
|
CBlockMember *bm = block->GetMember( memberNum );
|
|
|
|
if ( bm->GetID() == TK_INT )
|
|
{
|
|
float fval = (float) (*(int *) block->GetMemberData( memberNum++ ));
|
|
sprintf( (char *) tempBuffer, "%f", fval );
|
|
*value = (char *) tempBuffer;
|
|
|
|
return true;
|
|
}
|
|
else if ( bm->GetID() == TK_FLOAT )
|
|
{
|
|
float fval = *(float *) block->GetMemberData( memberNum++ );
|
|
sprintf( (char *) tempBuffer, "%f", fval );
|
|
*value = (char *) tempBuffer;
|
|
|
|
return true;
|
|
}
|
|
else if ( bm->GetID() == TK_VECTOR )
|
|
{
|
|
vector_t vval;
|
|
|
|
memberNum++;
|
|
|
|
for ( int i = 0; i < 3; i++ )
|
|
{
|
|
if ( GetFloat( entID, block, memberNum, vval[i] ) == false )
|
|
return false;
|
|
|
|
sprintf( (char *) tempBuffer, "%f %f %f", vval[0], vval[1], vval[2] );
|
|
*value = (char *) tempBuffer;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
else if ( ( bm->GetID() == TK_STRING ) || ( bm->GetID() == TK_IDENTIFIER ) )
|
|
{
|
|
*value = (char *) block->GetMemberData( memberNum++ );
|
|
|
|
return true;
|
|
}
|
|
|
|
//TODO: Emit warning
|
|
assert( 0 );
|
|
(m_owner->GetInterface())->I_DPrintf( WL_WARNING, "Unexpected value; expected type STRING\n" );
|
|
|
|
return false;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Go
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Go( void )
|
|
{
|
|
CTask *task = NULL;
|
|
bool completed = false;
|
|
|
|
//Check for run away scripts
|
|
if ( m_count++ > RUNAWAY_LIMIT )
|
|
{
|
|
assert(0);
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Runaway loop detected!\n" );
|
|
return TASK_FAILED;
|
|
}
|
|
|
|
//If there are tasks to complete, do so
|
|
if ( m_tasks.empty() == false )
|
|
{
|
|
//Get the next task
|
|
task = PopTask( POP_BACK );
|
|
|
|
assert( task );
|
|
if ( task == NULL )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Invalid task found in Go()!\n" );
|
|
return TASK_FAILED;
|
|
}
|
|
|
|
//If this hasn't been stamped, do so
|
|
if ( task->GetTimeStamp() == 0 )
|
|
task->SetTimeStamp( ( m_owner->GetInterface())->I_GetTime() );
|
|
|
|
//Switch and call the proper function
|
|
switch( task->GetID() )
|
|
{
|
|
case ID_WAIT:
|
|
|
|
Wait( task, completed );
|
|
|
|
//Push it to consider it again on the next frame if not complete
|
|
if ( completed == false )
|
|
{
|
|
PushTask( task, PUSH_BACK );
|
|
return TASK_OK;
|
|
}
|
|
|
|
Completed( task->GetGUID() );
|
|
|
|
break;
|
|
|
|
case ID_WAITSIGNAL:
|
|
|
|
WaitSignal( task, completed );
|
|
|
|
//Push it to consider it again on the next frame if not complete
|
|
if ( completed == false )
|
|
{
|
|
PushTask( task, PUSH_BACK );
|
|
return TASK_OK;
|
|
}
|
|
|
|
Completed( task->GetGUID() );
|
|
|
|
break;
|
|
|
|
case ID_PRINT: //print( STRING )
|
|
Print( task );
|
|
break;
|
|
|
|
case ID_SOUND: //sound( name )
|
|
Sound( task );
|
|
break;
|
|
|
|
case ID_MOVE: //move ( ORIGIN, ANGLES, DURATION )
|
|
Move( task );
|
|
break;
|
|
|
|
case ID_ROTATE: //rotate( ANGLES, DURATION )
|
|
Rotate( task );
|
|
break;
|
|
|
|
case ID_KILL: //kill( NAME )
|
|
Kill( task );
|
|
break;
|
|
|
|
case ID_REMOVE: //remove( NAME )
|
|
Remove( task );
|
|
break;
|
|
|
|
case ID_CAMERA: //camera( ? )
|
|
Camera( task );
|
|
break;
|
|
|
|
case ID_SET: //set( NAME, ? )
|
|
Set( task );
|
|
break;
|
|
|
|
case ID_USE: //use( NAME )
|
|
Use( task );
|
|
break;
|
|
|
|
case ID_DECLARE://declare( TYPE, NAME )
|
|
DeclareVariable( task );
|
|
break;
|
|
|
|
case ID_FREE: //free( NAME )
|
|
FreeVariable( task );
|
|
break;
|
|
|
|
case ID_SIGNAL: //signal( NAME )
|
|
Signal( task );
|
|
break;
|
|
|
|
case ID_PLAY: //play ( NAME )
|
|
Play( task );
|
|
break;
|
|
|
|
default:
|
|
assert(0);
|
|
task->Free();
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Found unknown task type!\n" );
|
|
return TASK_FAILED;
|
|
break;
|
|
}
|
|
|
|
//Pump the sequencer for another task
|
|
CallbackCommand( task, TASK_RETURN_COMPLETE );
|
|
|
|
task->Free();
|
|
}
|
|
|
|
//FIXME: A command surge limiter could be implemented at this point to be sure a script doesn't
|
|
// execute too many commands in one cycle. This may, however, cause timing errors to surface.
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
SetCommand
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::SetCommand( CBlock *command, int type )
|
|
{
|
|
CTask *task = CTask::Create( m_GUID++, command );
|
|
|
|
//If this is part of a task group, add it in
|
|
if ( m_curGroup )
|
|
{
|
|
m_curGroup->Add( task );
|
|
}
|
|
|
|
//TODO: Emit warning
|
|
assert( task );
|
|
if ( task == NULL )
|
|
{
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Unable to allocate new task!\n" );
|
|
return TASK_FAILED;
|
|
}
|
|
|
|
PushTask( task, type );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
MarkTask
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::MarkTask( int id, int operation )
|
|
{
|
|
CTaskGroup *group = GetTaskGroup( id );
|
|
|
|
assert( group );
|
|
|
|
if ( group == NULL )
|
|
return TASK_FAILED;
|
|
|
|
if ( operation == TASK_START )
|
|
{
|
|
//Reset all the completion information
|
|
group->Init();
|
|
|
|
group->SetParent( m_curGroup );
|
|
m_curGroup = group;
|
|
}
|
|
else if ( operation == TASK_END )
|
|
{
|
|
assert( m_curGroup );
|
|
if ( m_curGroup == NULL )
|
|
return TASK_FAILED;
|
|
|
|
m_curGroup = m_curGroup->GetParent();
|
|
}
|
|
|
|
#ifdef _DEBUG
|
|
else
|
|
{
|
|
assert(0);
|
|
}
|
|
#endif
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Completed
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Completed( int id )
|
|
{
|
|
taskGroup_v::iterator tgi;
|
|
|
|
//Mark the task as completed
|
|
for ( tgi = m_taskGroups.begin(); tgi != m_taskGroups.end(); tgi++ )
|
|
{
|
|
//If this returns true, then the task was marked properly
|
|
if ( (*tgi)->MarkTaskComplete( id ) )
|
|
break;
|
|
}
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
CallbackCommand
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::CallbackCommand( CTask *task, int returnCode )
|
|
{
|
|
if ( m_owner->Callback( this, task->GetBlock(), returnCode ) == SEQ_OK )
|
|
return Go( );
|
|
|
|
assert(0);
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Command callback failure!\n" );
|
|
return TASK_FAILED;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
RecallTask
|
|
-------------------------
|
|
*/
|
|
|
|
CBlock *CTaskManager::RecallTask( void )
|
|
{
|
|
CTask *task;
|
|
|
|
task = PopTask( POP_BACK );
|
|
|
|
if ( task )
|
|
{
|
|
return task->GetBlock();
|
|
}
|
|
|
|
return NULL;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
PushTask
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::PushTask( CTask *task, int flag )
|
|
{
|
|
assert( (flag == PUSH_FRONT) || (flag == PUSH_BACK) );
|
|
|
|
switch ( flag )
|
|
{
|
|
case PUSH_FRONT:
|
|
m_tasks.insert(m_tasks.begin(), task);
|
|
m_numTasks++;
|
|
|
|
return TASK_OK;
|
|
break;
|
|
|
|
case PUSH_BACK:
|
|
m_tasks.insert(m_tasks.end(), task);
|
|
m_numTasks++;
|
|
|
|
return TASK_OK;
|
|
break;
|
|
}
|
|
|
|
//Invalid flag
|
|
return SEQ_FAILED;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
PopTask
|
|
-------------------------
|
|
*/
|
|
|
|
CTask *CTaskManager::PopTask( int flag )
|
|
{
|
|
CTask *task;
|
|
|
|
assert( (flag == POP_FRONT) || (flag == POP_BACK) );
|
|
|
|
if ( m_tasks.empty() )
|
|
return NULL;
|
|
|
|
switch ( flag )
|
|
{
|
|
case POP_FRONT:
|
|
task = m_tasks.front();
|
|
m_tasks.pop_front();
|
|
m_numTasks--;
|
|
|
|
return task;
|
|
break;
|
|
|
|
case POP_BACK:
|
|
task = m_tasks.back();
|
|
m_tasks.pop_back();
|
|
m_numTasks--;
|
|
|
|
return task;
|
|
break;
|
|
}
|
|
|
|
//Invalid flag
|
|
return NULL;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
GetCurrentTask
|
|
-------------------------
|
|
*/
|
|
|
|
CBlock *CTaskManager::GetCurrentTask( void )
|
|
{
|
|
CTask *task = PopTask( POP_BACK );
|
|
|
|
if ( task == NULL )
|
|
return NULL;
|
|
|
|
return task->GetBlock();
|
|
}
|
|
|
|
/*
|
|
=================================================
|
|
|
|
Task Functions
|
|
|
|
=================================================
|
|
*/
|
|
|
|
int CTaskManager::Wait( CTask *task, bool &completed )
|
|
{
|
|
CBlockMember *bm;
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal;
|
|
float dwtime;
|
|
int memberNum = 0;
|
|
|
|
completed = false;
|
|
|
|
bm = block->GetMember( 0 );
|
|
|
|
//Check if this is a task completion wait
|
|
if ( bm->GetID() == TK_STRING )
|
|
{
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
|
|
if ( task->GetTimeStamp() == (m_owner->GetInterface())->I_GetTime() )
|
|
{
|
|
//Print out the debug info
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d wait(\"%s\"); [%d]", m_ownerID, sVal, task->GetTimeStamp() );
|
|
}
|
|
|
|
CTaskGroup *group = GetTaskGroup( sVal );
|
|
|
|
if ( group == NULL )
|
|
{
|
|
//TODO: Emit warning
|
|
completed = false;
|
|
return TASK_FAILED;
|
|
}
|
|
|
|
completed = group->Complete();
|
|
}
|
|
else //Otherwise it's a time completion wait
|
|
{
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, dwtime ) );
|
|
|
|
if ( task->GetTimeStamp() == (m_owner->GetInterface())->I_GetTime() )
|
|
{
|
|
//Print out the debug info
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d wait( %d ); [%d]", m_ownerID, (int) dwtime, task->GetTimeStamp() );
|
|
}
|
|
|
|
if ( (task->GetTimeStamp() + dwtime) < ((m_owner->GetInterface())->I_GetTime()) )
|
|
completed = true;
|
|
}
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
WaitSignal
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::WaitSignal( CTask *task, bool &completed )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal;
|
|
int memberNum = 0;
|
|
|
|
completed = false;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
|
|
if ( task->GetTimeStamp() == (m_owner->GetInterface())->I_GetTime() )
|
|
{
|
|
//Print out the debug info
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d waitsignal(\"%s\"); [%d]", m_ownerID, sVal, task->GetTimeStamp() );
|
|
}
|
|
|
|
if ( (m_owner->GetOwner())->CheckSignal( sVal ) )
|
|
{
|
|
completed = true;
|
|
(m_owner->GetOwner())->ClearSignal( sVal );
|
|
}
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Print
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Print( CTask *task )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal;
|
|
int memberNum = 0;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d print(\"%s\"); [%d]", m_ownerID, sVal, task->GetTimeStamp() );
|
|
|
|
(m_owner->GetInterface())->I_CenterPrint( sVal );
|
|
|
|
Completed( task->GetGUID() );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Sound
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Sound( CTask *task )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal, *sVal2;
|
|
int memberNum = 0;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal2 ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d sound(\"%s\", \"%s\"); [%d]", m_ownerID, sVal, sVal2, task->GetTimeStamp() );
|
|
|
|
//Only instantly complete if the user has requested it
|
|
if( (m_owner->GetInterface())->I_PlaySound( task->GetGUID(), m_ownerID, sVal2, sVal ) )
|
|
Completed( task->GetGUID() );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Rotate
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Rotate( CTask *task )
|
|
{
|
|
vector_t vector;
|
|
CBlock *block = task->GetBlock();
|
|
char *tagName;
|
|
float tagLookup, duration;
|
|
int memberNum = 0;
|
|
|
|
//Check for a tag reference
|
|
if ( Check( ID_TAG, block, memberNum ) )
|
|
{
|
|
memberNum++;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &tagName ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, tagLookup ) );
|
|
|
|
if ( (m_owner->GetInterface())->I_GetTag( m_ownerID, tagName, (int) tagLookup, vector ) == false )
|
|
{
|
|
//TODO: Emit warning
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Unable to find tag \"%s\"!\n", tagName );
|
|
assert(0);
|
|
return TASK_FAILED;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
//Get a normal vector
|
|
VALIDATE( GetVector( m_ownerID, block, memberNum, vector ) );
|
|
}
|
|
|
|
//Find the duration
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, duration ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d rotate( <%f,%f,%f>, %d); [%d]", m_ownerID, vector[0], vector[1], vector[2], (int) duration, task->GetTimeStamp() );
|
|
(m_owner->GetInterface())->I_Lerp2Angles( task->GetGUID(), m_ownerID, vector, duration );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Remove
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Remove( CTask *task )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal;
|
|
int memberNum = 0;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d remove(\"%s\"); [%d]", m_ownerID, sVal, task->GetTimeStamp() );
|
|
(m_owner->GetInterface())->I_Remove( m_ownerID, sVal );
|
|
|
|
Completed( task->GetGUID() );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Camera
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Camera( CTask *task )
|
|
{
|
|
interface_export_t *ie = ( m_owner->GetInterface() );
|
|
CBlock *block = task->GetBlock();
|
|
vector_t vector, vector2;
|
|
float type, fVal, fVal2, fVal3;
|
|
char *sVal;
|
|
int memberNum = 0;
|
|
|
|
//Get the camera function type
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, type ) );
|
|
|
|
switch ( (int) type )
|
|
{
|
|
case TYPE_PAN:
|
|
|
|
VALIDATE( GetVector( m_ownerID, block, memberNum, vector ) );
|
|
VALIDATE( GetVector( m_ownerID, block, memberNum, vector2 ) );
|
|
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( PAN, <%f %f %f>, <%f %f %f>, %f); [%d]", m_ownerID, vector[0], vector[1], vector[2], vector2[0], vector2[1], vector2[2], fVal, task->GetTimeStamp() );
|
|
ie->I_CameraPan( vector, vector2, fVal );
|
|
break;
|
|
|
|
case TYPE_ZOOM:
|
|
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal2 ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( ZOOM, %f, %f); [%d]", m_ownerID, fVal, fVal2, task->GetTimeStamp() );
|
|
ie->I_CameraZoom( fVal, fVal2 );
|
|
break;
|
|
|
|
case TYPE_MOVE:
|
|
|
|
VALIDATE( GetVector( m_ownerID, block, memberNum, vector ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( MOVE, <%f %f %f>, %f); [%d]", m_ownerID, vector[0], vector[1], vector[2], fVal, task->GetTimeStamp() );
|
|
ie->I_CameraMove( vector, fVal );
|
|
break;
|
|
|
|
case TYPE_ROLL:
|
|
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal2 ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( ROLL, %f, %f); [%d]", m_ownerID, fVal, fVal2, task->GetTimeStamp() );
|
|
ie->I_CameraRoll( fVal, fVal2 );
|
|
|
|
break;
|
|
|
|
case TYPE_FOLLOW:
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal2 ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( FOLLOW, \"%s\", %f, %f); [%d]", m_ownerID, sVal, fVal, fVal2, task->GetTimeStamp() );
|
|
ie->I_CameraFollow( (const char *) sVal, fVal, fVal2 );
|
|
|
|
break;
|
|
|
|
case TYPE_TRACK:
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal2 ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( TRACK, \"%s\", %f, %f); [%d]", m_ownerID, sVal, fVal, fVal2, task->GetTimeStamp() );
|
|
ie->I_CameraTrack( (const char *) sVal, fVal, fVal2 );
|
|
break;
|
|
|
|
case TYPE_DISTANCE:
|
|
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal2 ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( DISTANCE, %f, %f); [%d]", m_ownerID, fVal, fVal2, task->GetTimeStamp() );
|
|
ie->I_CameraDistance( fVal, fVal2 );
|
|
break;
|
|
|
|
case TYPE_FADE:
|
|
|
|
VALIDATE( GetVector( m_ownerID, block, memberNum, vector ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal ) );
|
|
|
|
VALIDATE( GetVector( m_ownerID, block, memberNum, vector2 ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal2 ) );
|
|
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal3 ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( FADE, <%f %f %f>, %f, <%f %f %f>, %f, %f); [%d]", m_ownerID, vector[0], vector[1], vector[2], fVal, vector2[0], vector2[1], vector2[2], fVal2, fVal3, task->GetTimeStamp() );
|
|
ie->I_CameraFade( vector[0], vector[1], vector[2], fVal, vector2[0], vector2[1], vector2[2], fVal2, fVal3 );
|
|
break;
|
|
|
|
case TYPE_PATH:
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( PATH, \"%s\"); [%d]", m_ownerID, sVal, task->GetTimeStamp() );
|
|
ie->I_CameraPath( sVal );
|
|
break;
|
|
|
|
case TYPE_ENABLE:
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( ENABLE ); [%d]", m_ownerID, task->GetTimeStamp() );
|
|
ie->I_CameraEnable();
|
|
break;
|
|
|
|
case TYPE_DISABLE:
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( DISABLE ); [%d]", m_ownerID, task->GetTimeStamp() );
|
|
ie->I_CameraDisable();
|
|
break;
|
|
|
|
case TYPE_SHAKE:
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal ) );
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal2 ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d camera( SHAKE, %f, %f ); [%d]", m_ownerID, fVal, fVal2, task->GetTimeStamp() );
|
|
ie->I_CameraShake( fVal, (int) fVal2 );
|
|
break;
|
|
}
|
|
|
|
Completed( task->GetGUID() );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Move
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Move( CTask *task )
|
|
{
|
|
vector_t vector, vector2;
|
|
CBlock *block = task->GetBlock();
|
|
float duration;
|
|
int memberNum = 0;
|
|
|
|
//Get the goal position
|
|
VALIDATE( GetVector( m_ownerID, block, memberNum, vector ) );
|
|
|
|
//Check for possible angles field
|
|
if ( GetVector( m_ownerID, block, memberNum, vector2 ) == false )
|
|
{
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, duration ) );
|
|
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d move( <%f %f %f>, %d ); [%d]", m_ownerID, vector[0], vector[1], vector[2], duration, task->GetTimeStamp() );
|
|
(m_owner->GetInterface())->I_Lerp2Pos( task->GetGUID(), m_ownerID, vector, NULL, duration );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
//Get the duration and make the call
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, duration ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d move( <%f %f %f>, <%f %f %f>, %d ); [%d]", m_ownerID, vector[0], vector[1], vector[2], vector2[0], vector2[1], vector2[2], duration, task->GetTimeStamp() );
|
|
(m_owner->GetInterface())->I_Lerp2Pos( task->GetGUID(), m_ownerID, vector, vector2, duration );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Kill
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Kill( CTask *task )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal;
|
|
int memberNum = 0;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d kill( \"%s\" ); [%d]", m_ownerID, sVal, task->GetTimeStamp() );
|
|
(m_owner->GetInterface())->I_Kill( m_ownerID, sVal );
|
|
|
|
Completed( task->GetGUID() );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Set
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Set( CTask *task )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal, *sVal2;
|
|
int memberNum = 0;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal2 ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d set( \"%s\", \"%s\" ); [%d]", m_ownerID, sVal, sVal2, task->GetTimeStamp() );
|
|
(m_owner->GetInterface())->I_Set( task->GetGUID(), m_ownerID, sVal, sVal2 );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Use
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Use( CTask *task )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal;
|
|
int memberNum = 0;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d use( \"%s\" ); [%d]", m_ownerID, sVal, task->GetTimeStamp() );
|
|
(m_owner->GetInterface())->I_Use( m_ownerID, sVal );
|
|
|
|
Completed( task->GetGUID() );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
DeclareVariable
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::DeclareVariable( CTask *task )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal;
|
|
int memberNum = 0;
|
|
float fVal;
|
|
|
|
VALIDATE( GetFloat( m_ownerID, block, memberNum, fVal ) );
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d declare( %d, \"%s\" ); [%d]", m_ownerID, (int) fVal, sVal, task->GetTimeStamp() );
|
|
(m_owner->GetInterface())->I_DeclareVariable( (int) fVal, sVal );
|
|
|
|
Completed( task->GetGUID() );
|
|
|
|
return TASK_OK;
|
|
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
FreeVariable
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::FreeVariable( CTask *task )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal;
|
|
int memberNum = 0;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d free( \"%s\" ); [%d]", m_ownerID, sVal, task->GetTimeStamp() );
|
|
(m_owner->GetInterface())->I_FreeVariable( sVal );
|
|
|
|
Completed( task->GetGUID() );
|
|
|
|
return TASK_OK;
|
|
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Signal
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Signal( CTask *task )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal;
|
|
int memberNum = 0;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d signal( \"%s\" ); [%d]", m_ownerID, sVal, task->GetTimeStamp() );
|
|
m_owner->GetOwner()->Signal( (const char *) sVal );
|
|
|
|
Completed( task->GetGUID() );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Play
|
|
-------------------------
|
|
*/
|
|
|
|
int CTaskManager::Play( CTask *task )
|
|
{
|
|
CBlock *block = task->GetBlock();
|
|
char *sVal, *sVal2;
|
|
int memberNum = 0;
|
|
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal ) );
|
|
VALIDATE( Get( m_ownerID, block, memberNum, &sVal2 ) );
|
|
|
|
(m_owner->GetInterface())->I_DPrintf( WL_DEBUG, "%4d play( \"%s\", \"%s\" ); [%d]", m_ownerID, sVal, sVal2, task->GetTimeStamp() );
|
|
(m_owner->GetInterface())->I_Play( task->GetGUID(), m_ownerID, (const char *) sVal, (const char *) sVal2 );
|
|
|
|
return TASK_OK;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
SaveCommand
|
|
-------------------------
|
|
*/
|
|
|
|
//FIXME: ARGH! This is duplicated from CSequence because I can't directly link it any other way...
|
|
|
|
int CTaskManager::SaveCommand( CBlock *block )
|
|
{
|
|
unsigned char flags;
|
|
int numMembers, bID, size;
|
|
CBlockMember *bm;
|
|
|
|
//Save out the block ID
|
|
bID = block->GetBlockID();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'BLID', &bID, sizeof ( bID ) );
|
|
|
|
//Save out the block's flags
|
|
flags = block->GetFlags();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'BFLG', &flags, sizeof ( flags ) );
|
|
|
|
//Save out the number of members to read
|
|
numMembers = block->GetNumMembers();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'BNUM', &numMembers, sizeof ( numMembers ) );
|
|
|
|
for ( int i = 0; i < numMembers; i++ )
|
|
{
|
|
bm = block->GetMember( i );
|
|
|
|
//Save the block id
|
|
bID = bm->GetID();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'BMID', &bID, sizeof ( bID ) );
|
|
|
|
//Save out the data size
|
|
size = bm->GetSize();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'BSIZ', &size, sizeof( size ) );
|
|
|
|
//Save out the raw data
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'BMEM', bm->GetData(), size );
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Save
|
|
-------------------------
|
|
*/
|
|
|
|
void CTaskManager::Save( void )
|
|
{
|
|
CTaskGroup *taskGroup;
|
|
const char *name;
|
|
CBlock *block;
|
|
DWORD timeStamp;
|
|
bool completed;
|
|
int id, numCommands;
|
|
int numWritten;
|
|
|
|
//Save the taskmanager's GUID
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TMID', &m_GUID, sizeof( m_GUID ) ); //FIXME: This can be reconstructed
|
|
|
|
//Save out the number of tasks that will follow
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TSK#', &m_numTasks, sizeof( m_numTasks ) );
|
|
|
|
//Save out all the tasks
|
|
tasks_l::iterator ti;
|
|
|
|
STL_ITERATE( ti, m_tasks )
|
|
{
|
|
//Save the GUID
|
|
id = (*ti)->GetGUID();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TKID', &id, sizeof ( id ) );
|
|
|
|
//Save the timeStamp (FIXME: Although, this is going to be worthless if time is not consistent...)
|
|
timeStamp = (*ti)->GetTimeStamp();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TKTS', &timeStamp, sizeof ( timeStamp ) );
|
|
|
|
//Save out the block
|
|
block = (*ti)->GetBlock();
|
|
SaveCommand( block );
|
|
}
|
|
|
|
//Save out the number of task groups
|
|
int numTaskGroups = m_taskGroups.size();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TG#G', &numTaskGroups, sizeof( numTaskGroups ) );
|
|
//Save out the IDs of all the task groups
|
|
numWritten = 0;
|
|
taskGroup_v::iterator tgi;
|
|
STL_ITERATE( tgi, m_taskGroups )
|
|
{
|
|
id = (*tgi)->GetGUID();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TKG#', &id, sizeof( id ) );
|
|
numWritten++;
|
|
}
|
|
assert (numWritten == numTaskGroups);
|
|
|
|
//Save out the task groups
|
|
numWritten = 0;
|
|
STL_ITERATE( tgi, m_taskGroups )
|
|
{
|
|
//Save out the parent
|
|
id = ( (*tgi)->GetParent() == NULL ) ? -1 : ((*tgi)->GetParent())->GetGUID();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TKGP', &id, sizeof( id ) );
|
|
|
|
//Save out the number of commands
|
|
numCommands = (*tgi)->m_numTasks;
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TGNC', &numCommands, sizeof( numCommands ) );
|
|
|
|
//Save out the command map
|
|
CTaskGroup::taskCallback_m::iterator tci;
|
|
|
|
STL_ITERATE( tci, (*tgi)->m_completedTasks )
|
|
{
|
|
//Write out the ID
|
|
id = (*tci).first;
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'GMID', &id, sizeof( id ) );
|
|
|
|
//Write out the state of completion
|
|
completed = (*tci).second;
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'GMDN', &completed, sizeof( completed ) );
|
|
}
|
|
|
|
//Save out the number of completed commands
|
|
id = (*tgi)->m_numCompleted;
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TGDN', &id, sizeof( id ) ); //FIXME: This can be reconstructed
|
|
numWritten++;
|
|
}
|
|
assert (numWritten == numTaskGroups);
|
|
|
|
//Only bother if we've got tasks present
|
|
if ( m_taskGroups.size() )
|
|
{
|
|
//Save out the currently active group
|
|
int curGroupID = ( m_curGroup == NULL ) ? -1 : m_curGroup->GetGUID();
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TGCG', &curGroupID, sizeof( curGroupID ) );
|
|
}
|
|
|
|
//Save out the task group name maps
|
|
taskGroupName_m::iterator tmi;
|
|
numWritten = 0;
|
|
STL_ITERATE( tmi, m_taskGroupNameMap )
|
|
{
|
|
name = ((*tmi).first).c_str();
|
|
|
|
//Make sure this is a valid string
|
|
assert( ( name != NULL ) && ( name[0] != NULL ) );
|
|
|
|
int length = strlen( name ) + 1;
|
|
|
|
//Save out the string size
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TGNL', &length, sizeof ( length ) );
|
|
|
|
//Write out the string
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TGNS', (void *) name, length );
|
|
|
|
taskGroup = (*tmi).second;
|
|
|
|
id = taskGroup->GetGUID();
|
|
|
|
//Write out the ID
|
|
(m_owner->GetInterface())->I_WriteSaveData( 'TGNI', &id, sizeof( id ) );
|
|
numWritten++;
|
|
}
|
|
assert (numWritten == numTaskGroups);
|
|
}
|
|
|
|
/*
|
|
-------------------------
|
|
Load
|
|
-------------------------
|
|
*/
|
|
|
|
void CTaskManager::Load( void )
|
|
{
|
|
unsigned char flags;
|
|
CTaskGroup *taskGroup;
|
|
CBlock *block;
|
|
CTask *task;
|
|
DWORD timeStamp;
|
|
bool completed;
|
|
void *bData;
|
|
int id, numTasks, numMembers;
|
|
int bID, bSize;
|
|
|
|
//Get the GUID
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TMID', &m_GUID, sizeof( m_GUID ) );
|
|
|
|
//Get the number of tasks to follow
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TSK#', &numTasks, sizeof( numTasks ) );
|
|
|
|
//Reload all the tasks
|
|
for ( int i = 0; i < numTasks; i++ )
|
|
{
|
|
task = new CTask;
|
|
|
|
assert( task );
|
|
|
|
//Get the GUID
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TKID', &id, sizeof( id ) );
|
|
task->SetGUID( id );
|
|
|
|
//Get the time stamp
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TKTS', &timeStamp, sizeof( timeStamp ) );
|
|
task->SetTimeStamp( timeStamp );
|
|
|
|
//
|
|
// BLOCK LOADING
|
|
//
|
|
|
|
//Get the block ID and create a new container
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'BLID', &id, sizeof( id ) );
|
|
block = new CBlock;
|
|
|
|
block->Create( id );
|
|
|
|
//Read the block's flags
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'BFLG', &flags, sizeof( flags ) );
|
|
block->SetFlags( flags );
|
|
|
|
//Get the number of block members
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'BNUM', &numMembers, sizeof( numMembers ) );
|
|
|
|
for ( int j = 0; j < numMembers; j++ )
|
|
{
|
|
//Get the member ID
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'BMID', &bID, sizeof( bID ) );
|
|
|
|
//Get the member size
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'BSIZ', &bSize, sizeof( bSize ) );
|
|
|
|
//Get the member's data
|
|
if ( ( bData = malloc( bSize ) ) == NULL )
|
|
{
|
|
assert( 0 );
|
|
return;
|
|
}
|
|
|
|
//Get the actual raw data
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'BMEM', bData, bSize );
|
|
|
|
//Write out the correct type
|
|
switch ( bID )
|
|
{
|
|
case TK_FLOAT:
|
|
block->Write( TK_FLOAT, *(float *) bData );
|
|
break;
|
|
|
|
case TK_IDENTIFIER:
|
|
block->Write( TK_IDENTIFIER, (char *) bData );
|
|
break;
|
|
|
|
case TK_STRING:
|
|
block->Write( TK_STRING, (char *) bData );
|
|
break;
|
|
|
|
case TK_VECTOR:
|
|
block->Write( TK_VECTOR, *(vec3_t *) bData );
|
|
break;
|
|
|
|
case ID_RANDOM:
|
|
block->Write( ID_RANDOM, ID_RANDOM );
|
|
break;
|
|
|
|
case ID_TAG:
|
|
block->Write( ID_TAG, (float) ID_TAG );
|
|
break;
|
|
|
|
default:
|
|
(m_owner->GetInterface())->I_DPrintf( WL_ERROR, "Invalid Block id %d\n", bID);
|
|
assert( 0 );
|
|
//Get rid of the temp memory
|
|
/* free( bData );
|
|
return;
|
|
*/ break;
|
|
}
|
|
|
|
//Get rid of the temp memory
|
|
free( bData );
|
|
}
|
|
|
|
task->SetBlock( block );
|
|
|
|
STL_INSERT( m_tasks, task );
|
|
m_numTasks++;
|
|
}
|
|
|
|
//Load the task groups
|
|
int numTaskGroups;
|
|
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TG#G', &numTaskGroups, sizeof( numTaskGroups ) );
|
|
|
|
if ( numTaskGroups == 0 )
|
|
return;
|
|
|
|
int *taskIDs = new int[ numTaskGroups ];
|
|
|
|
//Get the task group IDs
|
|
for ( i = 0; i < numTaskGroups; i++ )
|
|
{
|
|
//Creat a new task group
|
|
taskGroup = new CTaskGroup;
|
|
assert( taskGroup );
|
|
|
|
//Get this task group's ID
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TKG#', &taskIDs[i], sizeof( taskIDs[i] ) );
|
|
taskGroup->m_GUID = taskIDs[i];
|
|
|
|
m_taskGroupIDMap[ taskIDs[i] ] = taskGroup;
|
|
|
|
STL_INSERT( m_taskGroups, taskGroup );
|
|
}
|
|
|
|
//Recreate and load the task groups
|
|
for ( i = 0; i < numTaskGroups; i++ )
|
|
{
|
|
taskGroup = GetTaskGroup( taskIDs[i] );
|
|
assert( taskGroup );
|
|
|
|
//Load the parent ID
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TKGP', &id, sizeof( id ) );
|
|
|
|
if ( id != -1 )
|
|
taskGroup->m_parent = ( GetTaskGroup( id ) != NULL ) ? GetTaskGroup( id ) : NULL;
|
|
|
|
//Get the number of commands in this group
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TGNC', &numMembers, sizeof( numMembers ) );
|
|
|
|
//Save the number of members
|
|
taskGroup->m_numTasks = numMembers;
|
|
|
|
//Get each command and its completion state
|
|
for ( int j = 0; j < numMembers; j++ )
|
|
{
|
|
//Get the ID
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'GMID', &id, sizeof( id ) );
|
|
|
|
//Write out the state of completion
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'GMDN', &completed, sizeof( completed ) );
|
|
|
|
//Save it out
|
|
taskGroup->m_completedTasks[ id ] = completed;
|
|
}
|
|
|
|
//Get the number of completed tasks
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TGDN', &taskGroup->m_numCompleted, sizeof( taskGroup->m_numCompleted ) );
|
|
}
|
|
|
|
//Reload the currently active group
|
|
int curGroupID;
|
|
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TGCG', &curGroupID, sizeof( curGroupID ) );
|
|
|
|
//Reload the map entries
|
|
for ( i = 0; i < numTaskGroups; i++ )
|
|
{
|
|
char name[1024];
|
|
int length;
|
|
|
|
//Get the size of the string
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TGNL', &length, sizeof( length ) );
|
|
|
|
//Get the string
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TGNS', &name, length );
|
|
|
|
//Get the id
|
|
(m_owner->GetInterface())->I_ReadSaveData( 'TGNI', &id, sizeof( id ) );
|
|
|
|
taskGroup = GetTaskGroup( id );
|
|
assert( taskGroup );
|
|
|
|
m_taskGroupNameMap[ name ] = taskGroup;
|
|
m_taskGroupIDMap[ taskGroup->GetGUID() ] = taskGroup;
|
|
}
|
|
|
|
m_curGroup = ( curGroupID == -1 ) ? NULL : m_taskGroupIDMap[curGroupID];
|
|
|
|
delete[] taskIDs;
|
|
}
|