Searched refs:SubscribeRequest (Results 1 – 7 of 7) sorted by relevance
211 class SubscribeRequest : public ControlRequestPacket {213 SubscribeRequest() {}; in SubscribeRequest() function214 ~SubscribeRequest() override {}; in ~SubscribeRequest()
477 void SubscribeRequest::SetQuery(const QuerySyncObject &query) in SetQuery()482 QuerySyncObject SubscribeRequest::GetQuery() const in GetQuery()487 uint32_t SubscribeRequest::CalculateLen() const in CalculateLen()502 bool SubscribeRequest::IsAutoSubscribe() const in IsAutoSubscribe()
317 flag = SubscribeRequest::IS_AUTO_SUBSCRIBE; in FillControlRequestPacket()357 const SubscribeRequest *subPacket = inMsg->GetObject<SubscribeRequest>(); in IsNeedTriggerQueryAutoSync()
682 auto packet = inMsg->GetObject<SubscribeRequest>(); in SubscribeCalculateLen()692 auto packet = inMsg->GetObject<SubscribeRequest>(); in SubscribeSerialization()714 auto packet = new (std::nothrow) SubscribeRequest(); in SubscribeDeSerialization()
244 int SubscribeRequestRecvPre(SingleVerSyncTaskContext *context, const SubscribeRequest *packet,
1794 ControlRequestPacket* packet = new (std::nothrow) SubscribeRequest(); in ControlCmdStart()1976 …ataSync::SubscribeRequestRecvPre(SingleVerSyncTaskContext *context, const SubscribeRequest *packet, in SubscribeRequestRecvPre()2010 const SubscribeRequest *packet = message->GetObject<SubscribeRequest>(); in SubscribeRequestRecv()2057 const SubscribeRequest *packet = message->GetObject<SubscribeRequest>(); in UnsubscribeRequestRecv()
273 auto packet = new (std::nothrow) SubscribeRequest;309 auto outPacket = outMsg.GetObject<SubscribeRequest>();