From 58edd8b23ce7d804c1e88eecde6fb42830034946 Mon Sep 17 00:00:00 2001 From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com> Date: 星期五, 01 八月 2025 16:35:15 +0800 Subject: [PATCH] 1.千传模式,待测; --- SourceCode/Bond/Servo/HsmsPassive.h | 13 +++++++++++++ 1 files changed, 13 insertions(+), 0 deletions(-) diff --git a/SourceCode/Bond/Servo/HsmsPassive.h b/SourceCode/Bond/Servo/HsmsPassive.h index 6b7fe92..3fa3b73 100644 --- a/SourceCode/Bond/Servo/HsmsPassive.h +++ b/SourceCode/Bond/Servo/HsmsPassive.h @@ -5,6 +5,7 @@ #include <functional> #include <vector> #include <map> +#include <set> #include "CCollectionEvent.h" @@ -141,7 +142,11 @@ void OnTimer(UINT nTimerid); void setActionTimeout(int nSecond); int init(CModel* pModel, const char* pszName, unsigned int port); + int loadCacheFromFile(const char* pszFilepath); + int saveCache(); int term(); + int serialize(char* pszBuffer, int nBufferSize); + int unserialize(const char* pszBuffer, int nBufferSize); public: /* request开头的函数为主动发送数据的函数 */ @@ -164,7 +169,9 @@ int replyLinkEventReport(IMessage* pRecv); int replyEanbleDisableEventReport(IMessage* pRecv); int replyCommand(IMessage* pRecv); + int replyConfigureSpooling(IMessage* pRecv); int replyEanbleDisableAlarmReport(IMessage* pRecv); + int replyPurgeSpooledData(IMessage* pRecv); int replyQueryPPIDList(IMessage* pRecv); int replyTerminalDisplay(IMessage* pRecv); @@ -187,6 +194,7 @@ CRITICAL_SECTION m_criticalSection; std::list<CHsmsAction*> m_listAction; std::list<CHsmsAction*> m_listActionSent; + std::list<CHsmsAction*> m_listActionSpooling; private: SECSListener m_listener; @@ -194,6 +202,8 @@ HANDLE m_hCimWorkEvent; HANDLE m_hCimWorkThreadHandle; unsigned m_nCimWorkThrdaddr; + std::string m_strCacheFilepath; + CHsmsAction* m_pActiveAction; private: // CVariable vector @@ -204,5 +214,8 @@ // CollectionEvent vector std::vector<SERVO::CCollectionEvent*> m_collectionEvents; + + // Spooling Config + std::map<uint16_t, std::set<uint16_t>> m_spoolingConfig; }; -- Gitblit v1.9.3