blob: 3fb8ed12a825aa5bd53c6045aea09b3cc140b613 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Periodic_Task.h
*
* $Id$
*
* Base class for Periodic Tasks
*
* @author Pradeep Gore <pradeep@cs.wustl.edu>
*/
//=============================================================================
#ifndef PERIODIC_TASK_H
#define PERIODIC_TASK_H
#include "tao/RTCORBA/RTCORBA.h"
#include "tao/RTCORBA/Priority_Mapping_Manager.h"
#include "ace/Task.h"
#include "ace/SString.h"
#include "JobC.h"
#include "activity_export.h"
#include "ace/Arg_Shifter.h"
ACE_BEGIN_VERSIONED_NAMESPACE_DECL
class ACE_Barrier;
ACE_END_VERSIONED_NAMESPACE_DECL
class Task_Stats;
/**
* @class Periodic_Task
*
* @brief Periodic_Task executes jobs.
*
*/
class activity_Export Periodic_Task : public ACE_Task <ACE_SYNCH>
{
public:
/// = Initialization and termination code.
Periodic_Task (void);
~Periodic_Task ();
/// Init the state of this object.
int init_task (ACE_TArg_Shifter<char>& arg_shifter);
/// Activate this task, synch on the given barrier.
virtual int activate_task (ACE_Barrier* barrier, RTCORBA::PriorityMapping *priority_mapping) = 0;
/// Dump the stats collected.
void dump_stats (char* msg);
/// = Job get/set
/// Returns the name of the Job exec'ed by this Task.
const char* job (void);
/// Sets the Job to exec.
void job (Job_ptr job);
protected:
/// All tasks synch at this barrier.
ACE_Barrier* barrier_;
/// The Job to execute.
Job_var job_;
/// Name of the Job.
ACE_CString name_;
/// = Task parameters
/// see http://www.cis.ksu.edu/~neilsen/classes/cis721/lectures/lecture2/sld009.htm
/// The priority of this task.
RTCORBA::Priority task_priority_;
/// Period
unsigned long period_;
/// Worst case exec. time.
unsigned long exec_time_;
/// Phase
long phase_;
/// Number of times to exec. Job
int iter_;
/// A load factor supplied to each Job.
int load_;
/// = Stats house keeping
Task_Stats* task_stats_;
};
#endif /* PERIODIC_TASK_H */
|
