DAnCE
..
|
#include <Deployment_Completion.h>
Public Member Functions | |
Deployment_Completion (Deployment_Scheduler &sched) | |
virtual | ~Deployment_Completion (void) |
virtual void | update (const Event_Future &future) |
void | accept (Event_Future &future) |
bool | wait_on_completion (ACE_Time_Value *tv) |
Waits for completion of all events, with a timeout. | |
void | completed_events (Event_List &event_list) |
![]() | |
virtual | ~ACE_Future_Observer (void) |
virtual void | update (const ACE_Future< T > &future)=0 |
![]() | |
Completion_Counter_Base (unsigned int exec_count, unsigned int fail_count) | |
virtual | ~Completion_Counter_Base () |
void | decrement_exec_count () |
void | increment_fail_count (const char *error) |
unsigned int | exec_count () |
unsigned int | fail_count () |
bool | all_completed () |
const errors_type & | errors () const |
Protected Member Functions | |
virtual void | on_all_completed () |
virtual void | on_all_completed_with_failure () |
bool | single_threaded_wait_on_completion (ACE_Time_Value *tv) |
![]() | |
ACE_Future_Observer (void) | |
![]() | |
void | increment_exec_count () |
unsigned int | exec_count_i () |
unsigned int | fail_count_i () |
Private Attributes | |
Deployment_Scheduler & | sched_ |
TAO_SYNCH_MUTEX | mutex_ |
ACE_Condition< TAO_SYNCH_MUTEX > | condition_ |
Event_List | completed_events_ |
Additional Inherited Members | |
![]() | |
typedef TAO_SYNCH_MUTEX | lock_type |
typedef std::vector< std::string > | errors_type |
![]() | |
ACE_ALLOC_HOOK_DECLARE | |
DAnCE::Deployment_Completion::Deployment_Completion | ( | Deployment_Scheduler & | sched | ) |
|
virtual |
void DAnCE::Deployment_Completion::accept | ( | Event_Future & | future | ) |
void DAnCE::Deployment_Completion::completed_events | ( | Event_List & | event_list | ) |
|
protectedvirtual |
|
protectedvirtual |
|
protected |
|
virtual |
bool DAnCE::Deployment_Completion::wait_on_completion | ( | ACE_Time_Value * | tv | ) |
Waits for completion of all events, with a timeout.
|
private |
|
private |
|
private |
|
private |