CAReplayDatabase.hpp File Reference

#include "CAMutex.hpp"
#include "CAThread.hpp"

Include dependency graph for CAReplayDatabase.hpp:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	__t_replay_database_entry
struct	__t_replay_database_heap
struct	__t_database_info
class	CAReplayDatabase

Macros
#define	REPLAY_DB_ENTRIES_PER_HEAP   1000
#define	SECONDS_PER_INTERVALL   600

Typedefs
typedef struct __t_replay_database_entry	t_replay_databaseEntry
typedef t_replay_databaseEntry *	LP_replay_databaseEntry
typedef struct __t_replay_database_heap	t_replay_databaseHeap
typedef struct __t_database_info	t_replay_databaseInfo

Functions
THREAD_RETURN	replaydb_loopMaintenance (void *param)

Macro Definition Documentation

REPLAY_DB_ENTRIES_PER_HEAP

#define REPLAY_DB_ENTRIES_PER_HEAP   1000

Definition at line 42 of file CAReplayDatabase.hpp.

SECONDS_PER_INTERVALL

#define SECONDS_PER_INTERVALL   600

Definition at line 60 of file CAReplayDatabase.hpp.

Typedef Documentation

LP_replay_databaseEntry

typedef t_replay_databaseEntry* LP_replay_databaseEntry

Definition at line 40 of file CAReplayDatabase.hpp.

t_replay_databaseEntry

typedef struct __t_replay_database_entry t_replay_databaseEntry

t_replay_databaseHeap

typedef struct __t_replay_database_heap t_replay_databaseHeap

t_replay_databaseInfo

typedef struct __t_database_info t_replay_databaseInfo

Function Documentation

replaydb_loopMaintenance()

THREAD_RETURN replaydb_loopMaintenance

(

void *

param

)

Definition at line 111 of file CAReplayDatabase.cpp.

  {
    INIT_STACK;
    BEGIN_STACK("CADatabase::db_loopMaintenance");
    
    CAReplayDatabase* pDatabase=(CAReplayDatabase*)param;
    tReplayTimestamp rt;
    pDatabase->getCurrentReplayTimestamp(rt);
    pDatabase->m_currentClock=rt.interval;
    while(pDatabase->m_bRun)
      {
        sSleep(10);
        SINT32 secondsTilNextClock=((pDatabase->m_currentClock+1)*SECONDS_PER_INTERVALL)+pDatabase->m_refTime-time(NULL);
        if(secondsTilNextClock<=0&&pDatabase->m_bRun)
          pDatabase->nextClock();
      }
      
    FINISH_STACK("CADatabase::db_loopMaintenance");
      
    THREAD_RETURN_SUCCESS;
  }