multiTaskControllerComponent.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2010 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/



#pragma once

#include "vrfobjcore/vrfobjcoreDefines.h"
#include "vrfobjcore/taskCtlrCmpnt.h"
#include "vrftasks/radioMsgTypes.h"

class DT_DLL_vrfobjcore DtMultiTaskControllerComponent : public DtTaskControllerComponent
{

public:

   DtMultiTaskControllerComponent(const DtString& name, DtVrfObject* owner, 
      DtSimManager* simManager, 
      DtComponentDescriptor* compDesc = 0,
      DtReaderWriterRegistry* parentRegistry = 0);

   virtual ~DtMultiTaskControllerComponent();

   virtual bool init();

   virtual void postTick();

   virtual bool beginProcessingTask(const DtTaskMessage& task, 
      DtSimTaskStatePtr taskState);

   virtual void taskComplete(int taskId, bool success);

   virtual void clearTask(int taskId);

   virtual void suspendTask(int taskId);

   virtual DtTaskMessage* currentTaskMessage(int taskId);

   virtual DtSimTaskStatePtr currentTaskState(int taskId) const;

   virtual int sendSubtask(DtSimTask& task, int taskId);

   virtual int sendTask(DtSimTask& task, const DtString& receiver, int taskId, bool actAsSubtask = true);

   virtual void clearSubtask(int subtaskId, int taskId);

   virtual void addPendingSubtaskId(int subtaskId, int taskId);

   virtual bool findPendingSubtaskId(int subtaskId, int taskId);

   virtual void removePendingSubtaskId(int subtaskId, int taskId);

   virtual DtSubtaskStatusEntry* subtaskStatus(int subtaskId, int taskId);
      
   virtual void removeAllPendingSubtaskIds(int taskId);

   virtual std::vector<int> currentPendingSubstaskIds(int taskId) const;

   virtual bool decideToGiveUpTask() const;

   virtual void giveUpTask();

   virtual bool taskActive(int taskId) const;

   virtual bool clearTopLevelTasks();

   virtual void clearConflictingTopLevelTasks(const DtSimTaskMessageType& conflictType);

   virtual void clearTasksByType(const DtSimTaskMessageType& taskType);

   virtual void clearTaskById(int taskId);

   virtual DtSuspendedTaskInfo* suspendTaskById(int taskId); 

   virtual std::list<DtTaskMessage*> currentTaskMessages() const;

   virtual DtTaskWithTaskStateListPtr topLevelTasks() const;

   virtual void setScriptTickPeriod(const DtString& scriptId, double period);

protected:
   virtual void addCurrentTaskMessage(const DtTaskMessage* taskMessage);
   virtual void clearCurrentTaskMessage(int taskId);

   virtual void clearPendingSubtasks(int taskId);

   virtual void clearSubtasksByType(const DtSimTaskMessageType& taskType, int taskId);

   virtual int taskIdWhichStartedSubtask(int subtaskId);
};