blob: cdd7fb2b2226dcba5cc3946d0442f63dcc6c92c2 (
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
|
/* -*- C++ -*- */
//=============================================================================
/**
* @file Consumer_Handler.h
*
* Definition of the Callback_Qouter Consumer Client class, Consumer_Handler.
*
* @author Kirthika Parameswaran <kirthika@cs.wustl.edu>
*/
//=============================================================================
#ifndef CONSUMER_HANDLER_H
#define CONSUMER_HANDLER_H
#include "ConsumerC.h"
#include "NotifierC.h"
#include "Consumer_i.h"
#include "ace/Read_Buffer.h"
#if !defined (ACE_LACKS_PRAGMA_ONCE)
# pragma once
#endif /* ACE_LACKS_PRAGMA_ONCE */
#include "orbsvcs/Naming/Naming_Client.h"
#include "orbsvcs/CosNamingC.h"
#include "Consumer_Input_Handler.h"
#include "Consumer_Signal_Handler.h"
class Consumer_Input_Handler;
class Consumer_Signal_Handler;
/**
* @class Consumer_Handler
*
* @brief Callback Quoter Consumer Client class.
*
* Connects to the Callback Quoter server and
* registers the Consumer object with the it
* and receives the stock status from the Notifier.
*/
class Consumer_Handler
{
public:
// = Initialization and termination methods.
/// Constructor.
Consumer_Handler (void);
/// Destructor.
~Consumer_Handler (void);
/// Initialize the client communication with the server.
int init (int argc, ACE_TCHAR *argv[]);
/// Start the ORB object.
int run (void);
/// the name of the stock the consumer is interested in.
ACE_CString stock_name_;
/// the desired price of the stock.
int threshold_value_;
/// Server object ptr.
Notifier_var server_;
/// The consumer object.
Consumer_i *consumer_servant_;
/// Pointer to the consumer object registered with the ORB.
Callback_Quoter::Consumer_var consumer_var_;
/// This method gives the reactor pointer.
ACE_Reactor* reactor_used (void) const;
/// Flag which notes whether the consumer has got registered with the
/// Notifier-server.
int registered_;
/// Flag which notes whether the consumer has got unregistered from
/// the Notifier-server.
int unregistered_;
private:
/// Our orb.
CORBA::ORB_var orb_;
/// Function to read the server IOR from a file.
int read_ior (ACE_TCHAR *filename);
/// Parse the command line arguments. Returns 0 on success, -1 on
/// error.
int parse_args (void);
/// This method initialises the naming service and registers the
/// object with the POA.
int via_naming_service (void);
/// # of arguments on the command line.
int argc_;
/// arguments from command line.
ACE_TCHAR **argv_;
/// IOR of the obj ref of the server.
ACE_TCHAR *ior_;
/// Flag for server shutdown.
int shutdown_;
/// An instance of the name client used for resolving the factory
/// objects.
TAO_Naming_Client naming_services_client_;
/// This variable denotes whether the naming service
/// is used or not.
int use_naming_service_;
/// Reference to the input_event_handler.
Consumer_Input_Handler *consumer_input_handler_;
/// Reference to the signal_event_handler.
Consumer_Signal_Handler *consumer_signal_handler_;
/// Is the example interactive?
int interactive_;
};
#endif /* CONSUMER_HANDLER_H */
|
