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
|
/**
* @file Stock_Database.h
* @author Shanshan Jiang <shanshan.jiang@vanderbilt.edu>
* @author William R. Otte <wotte@dre.vanderbilt.edu>
* @author Douglas C. Schmidt <schmidt@dre.vanderbilt.edu>
*/
#ifndef STOCK_DATABASE_H_
#define STOCK_DATABASE_H_
// ACE headers
#include "ace/Task.h"
// TAO headrs
// #include "tao/orbconf.h"
// STL headers
#include <map>
#include <string>
/**
* @class Stock_Database
* @brief This class is used to install, update and publish the information of
* all the stocks. It uses the singleton design pattern.
* The parameter type may be any type that has a method called "updated_stocks" and
* accepts a std::vector of std::strings as an argument.
*/
template <typename CALLBACK>
class Stock_Database : public ACE_Task_Base
{
public:
/// Default constructor
/// Initializes the stock database with MSFT, IBM, and INTEL.
/// @param the rate at which to perform updates
Stock_Database (u_int rate = 1);
/// Constructor.
/// @param file The name of a file to read initial stocks and values from.
Stock_Database (const char *file, u_int rate = 1);
typedef std::map <std::string,
unsigned int> Init_Map;
/// Constructor
/// @param stockmap A map containing stocks and initial values. An initial value
/// of 0 will be assigned a random start value.
Stock_Database (const Init_Map &stockmap, u_int rate = 0);
typedef std::string Cookie;
/**
* Register a callback object with the database. The callback object must have
* the () operator defined accepting a std::vector of strings as the argument.
* @returns A cookie to identify the registration
*/
Cookie register_callback (CALLBACK &obj);
/**
* Removes a callback from the notification queue.
* @returns false if the provided cookie is not found.
*/
bool remove_callback (const Cookie &);
/// Raised if an invalid stock name is requested.
class Invalid_Stock {};
struct StockInfo
{
StockInfo (void)
: name_(""), high_ (0), low_ (0), last_ (0)
{};
StockInfo (const std::string name)
: name_ (name), high_ (0), low_(0), last_(0)
{};
std::string name_;
int high_;
int low_;
int last_;
};
/**
* Create a StockInfo object stored in the database with the given name.
*
* @param name The name of the stock.
* @return A StockInfo object.
*/
StockInfo get_stock_info (const char *name);
/**
* This function is used to calculate the new high, low and last values
* for each stock in the stock database randomly.
*/
virtual int svc (void);
/// Change the rate at which database updates are made
void update_rate (u_int rate);
/// Launch the active object
void start (void);
/// Stop the active object
void stop (void);
typedef std::map <std::string, StockInfo> Stock_Map;
/// This method is not intended to be called by clients of this class,
/// it is public only by necessity.
virtual int handle_signal (int signum,
siginfo_t * = 0,
ucontext_t * = 0);
typedef std::map <Cookie, CALLBACK *> Callback_Map;
private:
/// The filname initialized from, if any.
const std::string filename_;
/// Keep track of the stock names and information about them.
Stock_Map stock_map_;
/// Lock to protect concurrent access to the <stock_map_>.
ACE_RW_Thread_Mutex lock_;
/// Rate at which updates are made.
u_int rate_;
Callback_Map callbacks_;
bool active_;
};
#include "Stock_Database.tpp"
//typedef ACE_Singleton<Stock_Database, TAO_SYNCH_MUTEX> Stock_Database_Singleton;
//#define STOCK_DATABASE Stock_Database_Singleton::instance()
#endif // !defined STOCK_DATABASE_H_
|
