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
|
/* -*- 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)
//
// ============================================================================
#if !defined (_EVENT_COMM_I_H)
#define _EVENT_COMM_I_H
#include "ace/Map_Manager.h"
#include "ace/Synch.h"
#include "ace/SString.h"
#include "Event_CommS.h"
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.
virtual void push (
const Event_Comm::Event & event,
CORBA::Environment &TAO_TRY_ENV);
// Pass the <event> to the <Consumer>.
virtual void disconnect (
const char * reason,
CORBA::Environment &TAO_TRY_ENV);
// Disconnect the <Consumer> from the <Notifier>,
// giving it the <reason>.
};
// 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);
// Disconnect all the receivers, giving them the <reason>.
virtual void push (const Event_Comm::Event &event,
CORBA::Environment &TAO_TRY_ENV);
// 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);
// 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);
// Unsubscribe the <Consumer>.
private:
typedef ACE_Map_Manager <ACE_SString, Consumer_Entry *, ACE_Null_Mutex>
MAP_MANAGER;
typedef ACE_Map_Iterator <ACE_SString, Consumer_Entry *, ACE_Null_Mutex>
MAP_ITERATOR;
typedef ACE_Map_Entry <ACE_SString, Consumer_Entry *>
MAP_ENTRY;
MAP_MANAGER map_;
// Table that maps a <Event_Comm::Consumer *> to a <Consumer_Entry
// *>.
};
#endif /* _EVENT_COMM_I_H */
|
