1 | /* |
2 | * Legal Notice |
3 | * |
4 | * This document and associated source code (the "Work") is a part of a |
5 | * benchmark specification maintained by the TPC. |
6 | * |
7 | * The TPC reserves all right, title, and interest to the Work as provided |
8 | * under U.S. and international laws, including without limitation all patent |
9 | * and trademark rights therein. |
10 | * |
11 | * No Warranty |
12 | * |
13 | * 1.1 TO THE MAXIMUM EXTENT PERMITTED BY APPLICABLE LAW, THE INFORMATION |
14 | * CONTAINED HEREIN IS PROVIDED "AS IS" AND WITH ALL FAULTS, AND THE |
15 | * AUTHORS AND DEVELOPERS OF THE WORK HEREBY DISCLAIM ALL OTHER |
16 | * WARRANTIES AND CONDITIONS, EITHER EXPRESS, IMPLIED OR STATUTORY, |
17 | * INCLUDING, BUT NOT LIMITED TO, ANY (IF ANY) IMPLIED WARRANTIES, |
18 | * DUTIES OR CONDITIONS OF MERCHANTABILITY, OF FITNESS FOR A PARTICULAR |
19 | * PURPOSE, OF ACCURACY OR COMPLETENESS OF RESPONSES, OF RESULTS, OF |
20 | * WORKMANLIKE EFFORT, OF LACK OF VIRUSES, AND OF LACK OF NEGLIGENCE. |
21 | * ALSO, THERE IS NO WARRANTY OR CONDITION OF TITLE, QUIET ENJOYMENT, |
22 | * QUIET POSSESSION, CORRESPONDENCE TO DESCRIPTION OR NON-INFRINGEMENT |
23 | * WITH REGARD TO THE WORK. |
24 | * 1.2 IN NO EVENT WILL ANY AUTHOR OR DEVELOPER OF THE WORK BE LIABLE TO |
25 | * ANY OTHER PARTY FOR ANY DAMAGES, INCLUDING BUT NOT LIMITED TO THE |
26 | * COST OF PROCURING SUBSTITUTE GOODS OR SERVICES, LOST PROFITS, LOSS |
27 | * OF USE, LOSS OF DATA, OR ANY INCIDENTAL, CONSEQUENTIAL, DIRECT, |
28 | * INDIRECT, OR SPECIAL DAMAGES WHETHER UNDER CONTRACT, TORT, WARRANTY, |
29 | * OR OTHERWISE, ARISING IN ANY WAY OUT OF THIS OR ANY OTHER AGREEMENT |
30 | * RELATING TO THE WORK, WHETHER OR NOT SUCH AUTHOR OR DEVELOPER HAD |
31 | * ADVANCE NOTICE OF THE POSSIBILITY OF SUCH DAMAGES. |
32 | * |
33 | * Contributors |
34 | * - Doug Johnson |
35 | */ |
36 | |
37 | /****************************************************************************** |
38 | * Description: Class that implements the ticker tape functionality of |
39 | * the market. This class handles the batching up of |
40 | * individual ticker entries into a batch suitable for the |
41 | * Market-Feed transaction. For each "real" trade result |
42 | * that gets added to the ticker, a number of artificial |
43 | * entries are padded into the batch. |
44 | ******************************************************************************/ |
45 | |
46 | #ifndef MEE_TICKER_TAPE_H |
47 | #define MEE_TICKER_TAPE_H |
48 | |
49 | #include "utilities/EGenUtilities_stdafx.h" |
50 | #include "TxnHarnessStructs.h" |
51 | #include "TimerWheel.h" |
52 | #include "MEESUTInterface.h" |
53 | #include "MEEPriceBoard.h" |
54 | |
55 | #include "input/DataFileTypes.h" |
56 | |
57 | namespace TPCE { |
58 | |
59 | class CMEETickerTape { |
60 | private: |
61 | CMEESUTInterface *m_pSUT; |
62 | CMEEPriceBoard *m_pPriceBoard; |
63 | TMarketFeedTxnInput m_TxnInput; |
64 | INT32 m_BatchIndex; |
65 | INT32 m_BatchDuplicates; |
66 | CRandom m_rnd; |
67 | bool m_Enabled; |
68 | const StatusTypeDataFile_t &m_StatusType; |
69 | const TradeTypeDataFile_t &m_TradeType; |
70 | |
71 | static const int LIMIT_TRIGGER_TRADE_QTY; |
72 | static const int RANDOM_TRADE_QTY_1; |
73 | static const int RANDOM_TRADE_QTY_2; |
74 | |
75 | CTimerWheel<TTickerEntry, CMEETickerTape, 900, 1000> m_LimitOrderTimers; // Size wheel for 900 seconds with 1,000 |
76 | // millisecond resolution. |
77 | queue<PTickerEntry> m_InTheMoneyLimitOrderQ; |
78 | |
79 | CDateTime *m_pBaseTime; |
80 | CDateTime *m_pCurrentTime; |
81 | |
82 | void AddToBatch(PTickerEntry pTickerEntry); |
83 | void AddArtificialEntries(void); |
84 | void AddLimitTrigger(PTickerEntry pTickerEntry); |
85 | |
86 | // Performs initialization common to all constructors. |
87 | void Initialize(void); |
88 | |
89 | public: |
90 | // Constructor - use default RNG seed |
91 | CMEETickerTape(CMEESUTInterface *pSUT, CMEEPriceBoard *pPriceBoard, CDateTime *pBaseTime, CDateTime *pCurrentTime, |
92 | const DataFileManager &inputFiles); |
93 | |
94 | // Constructor - RNG seed provided |
95 | CMEETickerTape(CMEESUTInterface *pSUT, CMEEPriceBoard *pPriceBoard, CDateTime *pBaseTime, CDateTime *pCurrentTime, |
96 | RNGSEED RNGSeed, const DataFileManager &inputFiles); |
97 | |
98 | ~CMEETickerTape(void); |
99 | |
100 | void AddEntry(PTickerEntry pTickerEntry); |
101 | void PostLimitOrder(PTradeRequest pTradeRequest); |
102 | bool DisableTicker(void); |
103 | bool EnableTicker(void); |
104 | eTradeTypeID ConvertTradeTypeIdToEnum(char *pTradeType); |
105 | |
106 | RNGSEED GetRNGSeed(void); |
107 | void SetRNGSeed(RNGSEED RNGSeed); |
108 | }; |
109 | |
110 | } // namespace TPCE |
111 | |
112 | #endif // MEE_TICKER_TAPE_H |
113 | |