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
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
// $Id$
//
// ============================================================================
//
// = LIBRARY
// examples
//
// = FILENAME
// test_registry_changes.cpp
//
// = DESCRIPTION
//
// This application tests the working of Reactor when users are
// interested in monitoring changes in the registry.
//
// = AUTHOR
// Irfan Pyarali
//
// ============================================================================
#include "ace/Reactor.h"
#include "ace/Registry.h"
ACE_RCSID(WFMO_Reactor, test_registry_changes, "$Id$")
static int stop_test = 0;
static HKEY context_to_monitor = HKEY_CURRENT_USER;
static const ACE_TCHAR *temp_context_name = ACE_TEXT ("ACE temporary context");
class Event_Handler : public ACE_Event_Handler
{
public:
Event_Handler (ACE_Reactor &reactor);
~Event_Handler (void);
int handle_signal (int signum, siginfo_t * = 0, ucontext_t * = 0);
int handle_close (ACE_HANDLE handle,
ACE_Reactor_Mask close_mask);
ACE_Registry::Naming_Context &context (void);
private:
ACE_Auto_Event event_;
ACE_Registry::Naming_Context context_;
};
Event_Handler::Event_Handler (ACE_Reactor &reactor)
: context_ (context_to_monitor)
{
this->reactor (&reactor);
if (::RegNotifyChangeKeyValue (this->context_.key (), // handle of key to watch
FALSE, // flag for subkey notification
REG_NOTIFY_CHANGE_NAME, // changes to be reported
this->event_.handle (), // handle of signaled event
TRUE // flag for asynchronous reporting
) != ERROR_SUCCESS)
ACE_ERROR ((LM_ERROR, "RegNotifyChangeKeyValue could not be setup\n"));
if (this->reactor ()->register_handler (this,
this->event_.handle ()) != 0)
ACE_ERROR ((LM_ERROR, "Registration with Reactor could not be done\n"));
}
Event_Handler::~Event_Handler (void)
{
}
int
Event_Handler::handle_signal (int signum, siginfo_t *, ucontext_t *)
{
if (stop_test)
this->reactor ()->close ();
else if (::RegNotifyChangeKeyValue (this->context_.key (), // handle of key to watch
FALSE, // flag for subkey notification
REG_NOTIFY_CHANGE_NAME, // changes to be reported
this->event_.handle (), // handle of signaled event
TRUE // flag for asynchronous reporting
) != ERROR_SUCCESS)
ACE_ERROR ((LM_ERROR,
"RegNotifyChangeKeyValue could not be setup\n"));
return 0;
}
int
Event_Handler::handle_close (ACE_HANDLE handle,
ACE_Reactor_Mask close_mask)
{
ACE_DEBUG ((LM_DEBUG, "Event_Handler removed from Reactor\n"));
return 0;
}
ACE_Registry::Naming_Context &
Event_Handler::context (void)
{
return this->context_;
}
void
worker (Event_Handler *event_handler)
{
ACE_DEBUG ((LM_DEBUG, "(%t) Thread creation\n"));
ACE_DEBUG ((LM_DEBUG, "(%t) Thread creating temporary registry entry\n"));
ACE_Registry::Naming_Context temp_context;
int result = event_handler->context ().bind_new_context (temp_context_name,
temp_context);
if (result == -1)
ACE_ERROR ((LM_ERROR, "Error in creating %s: %p\n", temp_context_name, "bind_new_context"));
else
{
ACE_DEBUG ((LM_DEBUG, "(%t) Thread sleeping\n"));
ACE_OS::sleep (3);
ACE_DEBUG ((LM_DEBUG, "(%t) Thread removing registry entry\n"));
stop_test = 1;
event_handler->context ().unbind_context (temp_context_name);
}
}
int
main (int, char *[])
{
ACE_Reactor reactor;
Event_Handler handler (reactor);
int result = ACE_OS::thr_create ((ACE_THR_FUNC) worker, &handler, 0, 0);
ACE_ASSERT (result == 0);
for (result = 0; result != -1; result = reactor.handle_events ())
continue;
return 0;
}
|
