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
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = LIBRARY
// EventComm
//
// = FILENAME
// Event_Comm_i.h
//
// = DESCRIPTION
// Class interface for the implementation of the distributed
// event notification mechanism.
//
// = AUTHOR
// Douglas C. Schmidt (schmidt@cs.wustl.edu) and Pradeep Gore
// <pradeep@cs.wustl.edu>
//
// ============================================================================
#ifndef _EVENT_COMM_I_H
#define _EVENT_COMM_I_H
#include "ace/Map_Manager.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "ace/Synch.h"
#include "ace/SString.h"
#include "Event_CommS.h"
class ShutdownCallback
{
// = TITLE
// Helper callback class to shutdown the application.
public:
virtual void close (void) = 0;
// This method is to be called to shutdown the application.
};
class Consumer_i : public POA_Event_Comm::Consumer
{
// = TITLE
// Defines the implementation class for event <Consumers>.
public:
// = Initialization and termination methods.
Consumer_i (void);
// Constructor.
~Consumer_i (void);
// Destructor.
void set_reactor (ACE_Reactor *reactor);
// set the <ACE_Reactor> to use when quitting.
virtual void push (const Event_Comm::Event & event,
CORBA::Environment &TAO_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException));
// Pass the <event> to the <Consumer>.
virtual void disconnect (const char * reason,
CORBA::Environment &TAO_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException));
// Disconnect the <Consumer> from the <Notifier>, giving it the
// <reason>.
void set (ShutdownCallback *_shutdown);
// Set the Shutdown callback.
private:
ShutdownCallback *shutdown;
// The callback to shutdown the consumer application.
};
// Forward reference.
class Consumer_Entry;
class Notifier_i : public POA_Event_Comm::Notifier
{
// = TITLE
// Defines the implementation class for event <Notifiers>.
public:
enum
{
DEFAULT_SIZE = 1024
// Default max number of Event_Comm::Consumers.
};
Notifier_i (size_t size_hint = Notifier_i::DEFAULT_SIZE);
// Initialize a Notifier_i object with the specified size hint.
virtual void disconnect (const char *reason,
CORBA::Environment &TAO_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException));
// Disconnect all the receivers, giving them the <reason>.
virtual void push (const Event_Comm::Event &event,
CORBA::Environment &TAO_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException));
// Send the <event> to all the consumers who have subscribed and who
// match the filtering criteria.
virtual void subscribe (Event_Comm::Consumer_ptr Consumer,
const char * filtering_criteria,
CORBA::Environment &TAO_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException));
// Subscribe the <Consumer> to receive events that match
// <filtering_criteria> applied by the <Notifier>.
void unsubscribe (Event_Comm::Consumer *consumer,
const char *filtering_criteria,
CORBA::Environment &TAO_TRY_ENV)
ACE_THROW_SPEC ((CORBA::SystemException));
// Unsubscribe the <Consumer>.
private:
typedef ACE_Map_Manager <Event_Comm::Consumer_ptr, Consumer_Entry *, ACE_Null_Mutex>
MAP_MANAGER;
typedef ACE_Map_Iterator <Event_Comm::Consumer_ptr, Consumer_Entry *, ACE_Null_Mutex>
MAP_ITERATOR;
typedef ACE_Map_Entry <Event_Comm::Consumer_ptr, Consumer_Entry *>
MAP_ENTRY;
MAP_MANAGER map_;
// Table that maps a <Event_Comm::Consumer *> to a <Consumer_Entry *>.
};
#endif /* _EVENT_COMM_I_H */
|
