blob: ff05025cf66da1ebf6bcf7c96d6eb442a64bdbd2 (
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
// file : Gate.h
// author : Boris Kolpackov <boris@dre.vanderbilt.edu>
// cvs-id : $Id$
#ifndef GATE_H
#define GATE_H
#include "ace/OS.h"
#include "ace/INET_Addr.h"
#include "ace/UUID.h"
#include "ace/Thread_Mutex.h"
#include "ace/Thread_Manager.h"
#include "tao/corba.h"
#include "orbsvcs/CosNotificationC.h"
#include "orbsvcs/CosNotifyChannelAdminC.h"
#include "orbsvcs/CosNotifyCommC.h"
#include "orbsvcs/CosNotifyCommS.h"
#include "ace/RMCast/Socket.h"
#include "Export.h"
class Gate_Export Gate : public POA_CosNotifyComm::StructuredPushConsumer
{
public:
virtual
~Gate ();
Gate (ACE_INET_Addr const& group,
CosNotifyChannelAdmin::EventChannel_ptr ch);
Gate (ACE_INET_Addr const& group,
CosNotifyChannelAdmin::ConsumerAdmin_ptr consumer_admin,
CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin);
private:
void
init (CosNotifyChannelAdmin::ConsumerAdmin_ptr consumer_admin,
CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin);
static ACE_THR_FUNC_RETURN
tracker_thunk (void* arg);
void
tracker ();
private:
// NotifyPublish interface.
//
virtual void
offer_change (CosNotification::EventTypeSeq const&,
CosNotification::EventTypeSeq const&);
// StructuredPushSupplier interface.
//
virtual void
push_structured_event (CosNotification::StructuredEvent const& e);
virtual void
disconnect_structured_push_consumer (void);
private:
ACE_thread_t thread_;
CosNotifyChannelAdmin::ProxyID consumer_id_;
CosNotifyChannelAdmin::StructuredProxyPushConsumer_var consumer_;
CosNotifyChannelAdmin::ProxyID supplier_id_;
CosNotifyChannelAdmin::StructuredProxyPushSupplier_var supplier_;
ACE_RMCast::Socket socket_;
CORBA::String_var id_;
typedef ACE_SYNCH_MUTEX Mutex;
typedef ACE_Guard<Mutex> Lock;
bool stop_;
Mutex mutex_;
ACE_Thread_Manager thread_mgr_;
};
#endif // GATE_H
|
