blob: e0de0ef0a8ebbd4e4d9d8ab05b486e7b5903bf38 (
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
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
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
/* -*- C++ -*- */
// $Id$
// ============================================================================
//
// = FILENAME
// Notify_Service.h
//
// = AUTHORS
// Pradeep Gore <pradeep@cs.wustl.edu>
// Service options code by Wei Chiang <Wei.Chiang@nokia.com>.
//
// = DESCRIPTION
// Notification Service front end.
//
// ============================================================================
#ifndef NOTIFY_SERVICE_H
#define NOTIFY_SERVICE_H
#include /**/ "ace/pre.h"
#include "ace/Task.h"
#include "tao/PortableServer/PortableServer.h"
#include "orbsvcs/CosNotifyChannelAdminC.h"
#include "orbsvcs/CosNamingC.h"
#include "../orbsvcs/Notify/CosNotify_Initializer.h"
#include "ace/SString.h"
class TAO_Notify_Service;
#define NOTIFY_KEY "NotifyEventChannelFactory"
#define NOTIFY_CHANNEL_NAME "NotifyEventChannel"
class Worker : public ACE_Task_Base
{
// = TITLE
// Run a server thread
//
// = DESCRIPTION
// Use the ACE_Task_Base class to run server threads
//
public:
Worker (void);
// ctor
void orb (CORBA::ORB_ptr orb);
virtual int svc (void);
// The thread entry point.
private:
CORBA::ORB_var orb_;
// The orb
};
class TAO_Notify_Service_Driver
{
// = TITLE
// Notify_Service
//
// = DESCRIPTION
// Implementation of the Notification Service front end.
public:
// = Initialization and termination methods.
TAO_Notify_Service_Driver (void);
// Constructor.
virtual ~TAO_Notify_Service_Driver (void);
// Destructor.
int init (int argc, ACE_TCHAR *argv[]
ACE_ENV_ARG_DECL);
// Initializes the Service.
// Returns 0 on success, -1 on error.
int run (ACE_ENV_SINGLE_ARG_DECL);
// run the Service.
// Returns 0 on success, -1 on error.
void shutdown (ACE_ENV_SINGLE_ARG_DECL_WITH_DEFAULTS);
// Shutdown the Service.
// Returns 0 on success, -1 on error.
// CosNotifyChannelAdmin::EventChannelFactory_var obj;
//
protected:
int init_ORB (int& argc, ACE_TCHAR *argv []
ACE_ENV_ARG_DECL);
// initialize the ORB.
TAO_Notify_Service* notify_service_;
int resolve_naming_service (ACE_ENV_SINGLE_ARG_DECL);
// Resolve the naming service.
int parse_args (int& argc, ACE_TCHAR *argv []);
// Parses the command line arguments.
// = Data members
int bootstrap_;
// 1: this service is bootstrappable
int use_name_svc_;
// 1: register itself with the name service
int register_ec_;
// 1:
FILE *ior_output_file_;
// File where the IOR of the server object is stored.
ACE_CString notify_factory_name_;
// The Factory name.
ACE_CString notify_channel_name_;
// The Factory name.
int register_event_channel_;
// 1: create an event channel and registers it with the Naming Service with
// the name <notify_channel_name_>
CosNotifyChannelAdmin::EventChannelFactory_var notify_factory_;
// The Factory.
CORBA::ORB_var orb_;
// The ORB that we use.
PortableServer::POA_var poa_;
// Reference to the root poa.
#if defined (TAO_NOTIFY_USE_NAMING_CONTEXT)
CosNaming::NamingContext_var naming_;
#else
CosNaming::NamingContextExt_var naming_;
#endif /* TAO_NOTIFY_USE_NAMING_CONTEXT */
// A naming context.
Worker worker_;
// Worker for TP reactor mode.
int nthreads_;
// Number of worker threads.
};
#include /**/ "ace/post.h"
#endif /* NOTIFY_SERVICE_H */
|
