00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018 #ifndef _stub_policy_hh
00019 #define _stub_policy_hh
00020
00021 #include "BrokerS.h"
00022
00023
00024
00025
00026 class StubPolicy : public POA_Broker::Policy
00027 {
00028
00029 public:
00030
00031
00032
00033
00034
00035
00036 StubPolicy(const char *name)
00037 {
00038 this->sp_Name = name;
00039 };
00040
00041
00042
00043
00044 virtual ~StubPolicy()
00045 {
00046 };
00047
00048
00049
00050
00051 char *Name(void)
00052 throw (CORBA::SystemException)
00053 {
00054 CORBA::String_var retval;
00055
00056 retval = this->sp_Name;
00057 return( retval._retn() );
00058 }
00059
00060
00061
00062
00063
00064
00065 void AddTask(Broker::Task_ptr task)
00066 throw (CORBA::SystemException)
00067 {
00068 unsigned int slot;
00069
00070 slot = this->sp_Tasks.length();
00071 this->sp_Tasks.length(slot + 1);
00072 this->sp_Tasks[slot] = task;
00073 };
00074
00075
00076
00077
00078
00079
00080 void RemoveTask(Broker::Task_ptr task)
00081 throw (CORBA::SystemException)
00082 {
00083 unsigned int lpc;
00084 int slot;
00085
00086 slot = this->TaskIndex(task);
00087 for( lpc = (unsigned int)slot;
00088 lpc < (this->sp_Tasks.length() - 1);
00089 lpc++ )
00090 {
00091 this->sp_Tasks[lpc] = this->sp_Tasks[lpc + 1];
00092 }
00093 this->sp_Tasks.length(this->sp_Tasks.length() - 1);
00094 };
00095
00096
00097
00098
00099
00100
00101 void Activate(const Broker::TaskList &tasks)
00102 throw (CORBA::SystemException)
00103 {
00104 unsigned int lpc;
00105
00106 this->sp_Tasks.length(tasks.length());
00107 for( lpc = 0; lpc < tasks.length(); lpc++ )
00108 {
00109 this->sp_Tasks[lpc] = tasks[lpc];
00110 }
00111 };
00112
00113
00114
00115
00116 void Deactivate(void)
00117 throw (CORBA::SystemException)
00118 {
00119 this->sp_Tasks.length(0);
00120 };
00121
00122
00123
00124
00125
00126
00127
00128
00129
00130 void ChangeTaskCPU(Broker::RealTimeTask_ptr task,
00131 CORBA::ULong ct,
00132 CORBA::ULong status,
00133 CORBA::ULong advice)
00134 throw (CORBA::SystemException, Broker::InvalidState)
00135 {
00136 task->SetComputeTime(advice);
00137 };
00138
00139
00140
00141
00142
00143
00144
00145
00146 int TaskIndex(Broker::Task_ptr task)
00147 {
00148 unsigned int lpc;
00149 int retval = -1;
00150
00151 for( lpc = 0;
00152 (lpc < this->sp_Tasks.length()) && (retval == -1);
00153 lpc++ )
00154 {
00155 if( this->sp_Tasks[lpc]->_is_equivalent(task) )
00156 {
00157 retval = lpc;
00158 }
00159 }
00160 return( retval );
00161 }
00162
00163
00164 CORBA::String_var sp_Name;
00165
00166 Broker::TaskList sp_Tasks;
00167
00168 };
00169
00170 #endif