blob: 8280f3f4862b3ce1ca4fe0dd8c795198eaed7702 (
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
|
#ifndef Thread_Action_H
#define Thread_Action_H
#include "tao/RTScheduling/RTScheduler.h"
#include "ace/Log_Msg.h"
#include "ace/OS_NS_string.h"
#include "ace/SString.h"
class Data
{
public:
ACE_CString data;
RTScheduling::Current_var current;
};
class Test_Thread_Action:
public RTScheduling::ThreadAction
{
public:
Test_Thread_Action (void);
virtual void _cxx_do (CORBA::VoidData data);
};
#endif /*Thread_Action_H*/
Test_Thread_Action::Test_Thread_Action (void)
{
}
void
Test_Thread_Action::_cxx_do (CORBA::VoidData data)
{
Data* tmp = (Data*) data;
ACE_DEBUG ((LM_DEBUG,
"Test_Thread_Action::do %C\n",
tmp->data.c_str ()));
size_t count = 0;
RTScheduling::Current::IdType_var id = tmp->current->id ();
ACE_OS::memcpy (&count,
id->get_buffer (),
id->length ());
ACE_DEBUG ((LM_DEBUG,
"The spawned DT Guid is %d\n",
count));
RTScheduling::Current::NameList_var segment_name_list =
tmp->current->current_scheduling_segment_names ();
ACE_DEBUG ((LM_DEBUG,
"Segment Names for DT %d:\n",
count));
for (unsigned int i = 0; i < segment_name_list->length (); i++)
{
ACE_DEBUG ((LM_DEBUG,
"%C\n",
(*segment_name_list)[i].in ()));
}
}
|
