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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 金融证券系统 > 查看源码
TSCache.h
资源名称：NetTS.rar　[点击查看]
上传用户：nameszq
上传日期：2014-08-12
资源大小：336k
文件大小：2k
源码类别：

金融证券系统

开发平台：

Visual C++

TSCache.h：源码内容
  1. // TSCache.h: interface for the CTSCache class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #if !defined(AFX_TSCACHE_H__61CC5EB5_4560_4F34_A6DA_AA35B09D79EC__INCLUDED_)
  6. #define AFX_TSCACHE_H__61CC5EB5_4560_4F34_A6DA_AA35B09D79EC__INCLUDED_
  8. #if _MSC_VER > 1000
  9. #pragma once
  10. #endif // _MSC_VER > 1000
  12. #include "Stockdrv.h"
  13. #include "SPTime.h"
  15. typedef struct _ts_packet_t {
  16. UINT m_nMsgType;
  17. PRCV_DATA m_pRCV_DATA;
  18. } TS_PACKET, PTS_PACKET;
  19. typedef CArray< TS_PACKET, TS_PACKET &> CTSPacketArray;
  21. class CTSCache  
  22. {
  23. public:
  24. CTSCache();
  25. virtual ~CTSCache();
  27. void SetLocalLatest(CSPTime t);
  28. CSPTime GetLocalLatest();
  30. static CTSCache & GetInstance();
  32. void ClearReceiveBuffer() { m_nBufLen = 0; }
  34. // decode net received data
  35. int OnReceive( BYTE * buf, size_t len );
  36. int DecodePacket( );
  37. int FindFirstPacketLength( );
  38. size_t AlignBuffer( int nStart, BOOL bRemovePrev );
  39. int TryGetPacket( int nPacketLen );
  40. int DiscardPacket( int nPacketLen );
  42. // packets operation
  43. BOOL PushPacket( UINT nMsgType, PRCV_DATA pRCV_DATA );
  44. BOOL PopPacket( UINT & nMsgType, PRCV_DATA & pRCV_DATA );
  45. void FreePacket( PRCV_DATA pRCV_DATA );
  47. // set report
  48. BOOL StoreReports( );
  49. BOOL LoadReports( );
  50. BOOL ReserveReportsSize( int size );
  51. BOOL PushReport( int nNo, RCV_REPORT_STRUCTEx * pBuf );
  52. BOOL PushReport( char * pszStockCode, RCV_REPORT_STRUCTEx * pBuf );
  53. int  PushReport( RCV_REPORT_STRUCTEx * pBuf, int size );
  55. // get report
  56. int  GetTotalNumber();
  57. BOOL GetStockByNoEx( int nNo, RCV_REPORT_STRUCTEx * pBuf );
  58. BOOL GetStockByCodeEx(char * pszStockCode,int nMarket,RCV_REPORT_STRUCTEx * pBuf);
  60. protected:
  61. CSPTime m_tmLocalLatest;
  63. BYTE m_buffer[0x80000]; // 512k bytes buffer
  64. size_t m_nBufLen;
  65. CCriticalSection m_mutexBuffer;
  67. CTSPacketArray m_aPackets;
  68. CCriticalSection m_mutexPackets;
  70. CMapStringToPtr m_mapReports;
  71. CArray<RCV_REPORT_STRUCTEx, RCV_REPORT_STRUCTEx &> m_aReports;
  72. CCriticalSection m_mutexReports;
  73. };
  75. #endif // !defined(AFX_TSCACHE_H__61CC5EB5_4560_4F34_A6DA_AA35B09D79EC__INCLUDED_)