开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 金融证券系统 > 查看源码
request.cpp
资源名称：stkdataengine.rar　[点击查看]
上传用户：egreat
上传日期：2007-07-13
资源大小：29k
文件大小：3k
源码类别：

金融证券系统

开发平台：

Visual C++

request.cpp：源码内容
  2. #include "config.h"
  4. #include <vector>
  5. #include <set>
  6. #include <map>
  7. #include <queue>
  9. #include <boost/thread/detail/config.hpp>
  10. #include <boost/thread/thread.hpp>
  11. #include <boost/thread/recursive_mutex.hpp>
  12. #include <boost/smart_ptr.hpp>
  13. #include <boost/date_time/gregorian/gregorian.hpp>
  16. #include "tcpSocket.h"
  17. #include "stock.h"
  18. #include "request.h"
  20. namespace StockMarket
  21. {
  22. recursive_mutex req_queue_mutex;
  24. uint Request::seq_id = 1;
  25. bool Request::received = true;
  26. Request::Request() : first(true)
  27. {}
  28. Request::operator bool ()
  29. {
  30. if(first) 
  31. {
  32. first = false;
  33. return true;
  34. }
  35. else
  36. {
  37. return false;
  38. }
  39. }
  40. void Request::res_seq_id(uint id)
  41. {
  42. // 只有收到较后面的时候，才设置新值
  43. // ( 考虑到有些时候收发的顺序不同)
  44. if(id >= seq_id || id == 0) // id == 0 rewind
  45. {
  46. seq_id = id;
  47. received = true;
  48. }
  49. }
  50. bool Request::ready()
  51. {
  52. static uint cnt = 0;
  53. if(!received)
  54. {
  55. if((++cnt) % 20 == 0) // 等待 30 个周期还没有收到response，则重发
  56. {
  57. ++seq_id;
  58. return true;
  59. }
  60. }
  61. else
  62. {
  63. cnt = 1;
  64. }
  65. return received;
  66. }
  67. void Request::next()
  68. {
  69. if(received)
  70. {
  71. this->operator ++();
  72. ++seq_id;
  73. }
  74. }
  75. Request& Request::operator++()
  76. {
  77. return *this;
  78. }
  79. void Request::send(TcpSocket& soc)
  80. {
  81. ReqHead* pHead = (ReqHead*)buff();
  82. pHead->set_seq_id(seq_id);
  83. soc.SendBuf(buff(), len());
  84. received = false;
  85. }
  86. Request::~Request(){}
  88. ReqHead::ReqHead( ushort cmd_id, ushort packet_len/*the total packet len*/ = 0)
  89. {
  90. zip = 0x0c;
  91. seq_id = 0;
  92. packet_type = 1;
  93. len = len1 = packet_len - sizeof(ReqHead) + 2;
  94. cmd = cmd_id;
  95. }
  96. uint ReqHead::get_seq_id()
  97. {
  98. return seq_id;
  99. }
  100. void ReqHead::set_seq_id(uint id)
  101. {
  102. seq_id = id;
  103. }
  104. void ReqHead::set_len(ushort payload_len)
  105. {
  106. len = len1 = payload_len;
  107. }
  108. ushort ReqHead::get_len()
  109. {
  110. return len;
  111. }
  113. char* StockHeartBeat::buff()
  114. {
  115. return (char*)&s;
  116. }
  117. ulong StockHeartBeat::len()
  118. {
  119. return sizeof(StockHeartBeatStruct);
  120. }
  122. StockListReq::StockListReq(MarketInfo::MarketType market_code, ushort record_offset
  123. , ushort record_count, ushort record_total)
  124. : s(market_code, record_offset, record_count), total(record_total)
  125. {
  126. if(0 == record_total)
  127. {
  128. total = record_count;
  129. }
  130. }
  131. char* StockListReq::buff()
  132. {
  133. return (char*)&s;
  134. }
  135. ulong StockListReq::len()
  136. {
  137. return sizeof(StockListStruct);
  138. }
  140. StockListReq::operator bool ()
  141. {
  142. return s.offset < total;
  143. }
  144. StockListReq& StockListReq::operator ++ ()
  145. {
  146. if(s.offset + s.count < total)
  147. {
  148. s.offset = s.offset + s.count ;
  149. s.count = (total - s.offset) > s.count ? s.count : (total - s.offset);
  150. }
  151. else
  152. {
  153. s.offset = total;
  154. }
  155. return *this;
  156. }
  158. char* StockHoldChgReq::buff()
  159. {
  160. return (char*)&s;
  161. }
  162. ulong StockHoldChgReq::len()
  163. {
  164. return sizeof(ReqHead) + sizeof(ushort) + sizeof(StockHoldStruct) * s.count;
  165. }
  166. bool StockHoldChgReq::add_stock(const string& stock_code)
  167. {
  168. return s.add_one_stock(stock_code);
  169. }
  171. }