1 files changed, 138 insertions, 0 deletions
diff --git a/TAO/docs/tutorials/Quoter/RTCORBA/Stock_Database.h b/TAO/docs/tutorials/Quoter/RTCORBA/Stock_Database.h
new file mode 100644
index 00000000000..c6b5ccdc608
--- /dev/null
+++ b/TAO/docs/tutorials/Quoter/RTCORBA/Stock_Database.h
@@ -0,0 +1,138 @@
+// $Id$
+
+/**
+ * @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"
+
+// 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) throw (Invalid_Stock);
+  
+  /**
+   * 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, ACE_Thread_Mutex> Stock_Database_Singleton;
+//#define STOCK_DATABASE Stock_Database_Singleton::instance()
+
+#endif  // !defined STOCK_DATABASE_H_