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
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
#include "../Scheduler.h"
#include "tao/RTScheduling/RTScheduler_Manager.h"
#include "tao/ORB.h"
#include "Thread_Action.h"
#include "ace/Thread_Manager.h"
#include "ace/SString.h"
int
ACE_TMAIN(int argc, ACE_TCHAR *argv[])
{
CORBA::ORB_var orb;
RTScheduling::Current_var current;
const char * name = 0;
CORBA::Policy_ptr sched_param = 0;
CORBA::Policy_ptr implicit_sched_param = 0;
Test_Thread_Action thread_action;
try
{
orb = CORBA::ORB_init (argc,
argv);
CORBA::Object_var manager_obj = orb->resolve_initial_references ("RTSchedulerManager");
TAO_RTScheduler_Manager_var manager = TAO_RTScheduler_Manager::_narrow (manager_obj.in ());
TAO_Scheduler* scheduler;
ACE_NEW_RETURN (scheduler,
TAO_Scheduler (orb.in ()),
-1);
RTScheduling::Scheduler_var safe_scheduler = scheduler;
manager->rtscheduler (scheduler);
CORBA::Object_var current_obj = orb->resolve_initial_references ("RTScheduler_Current");
current = RTScheduling::Current::_narrow (current_obj.in ());
try
{
ACE_DEBUG ((LM_DEBUG,
"Invoking DT spawn without calling begin_scheduling_segment...\n"));
ACE_CString data ("Harry Potter");
RTScheduling::DistributableThread_var dt =
current->spawn (&thread_action,
const_cast<char *> (data.c_str ()),
name,
sched_param,
implicit_sched_param,
0,
0);
}
catch (const CORBA::BAD_INV_ORDER& )
{
ACE_DEBUG ((LM_DEBUG,
"Spawn should be in the context of a Scheduling Segment - Expected Exception\n"));
}
catch (const CORBA::Exception& ex)
{
ex._tao_print_exception ("\n");
}
ACE_DEBUG ((LM_DEBUG,
"Start - Scheduling Segment...\n"));
current->begin_scheduling_segment ("Potter",
sched_param,
implicit_sched_param);
size_t count = 0;
RTScheduling::Current::IdType_var id = current->id ();
ACE_OS::memcpy (&count,
id->get_buffer (),
id->length ());
ACE_DEBUG ((LM_DEBUG,
"The Current DT Guid is %d\n",
count));
//Initialize data to be passed to the Thread_Action::do method
Data spawn_data;
spawn_data.data = "Harry Potter";
spawn_data.current = RTScheduling::Current::_duplicate (current.in ());
ACE_DEBUG ((LM_DEBUG,
"Spawning a new DT...\n"));
RTScheduling::DistributableThread_var dt =
current->spawn (&thread_action,
&spawn_data,
"Chamber of Secrets",
sched_param,
implicit_sched_param,
0,
0);
current->end_scheduling_segment (name);
ACE_DEBUG ((LM_DEBUG,
"End - Scheduling Segment %d\n",
count));
ACE_Thread_Manager::instance ()->wait ();
orb->destroy ();
}
catch (const CORBA::Exception& ex)
{
ex._tao_print_exception ("Caught Exception\n");
}
return 0;
}
|
