Home
last modified time | relevance | path

Searched refs:ControlCmdType (Results 1 – 4 of 4) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync_utils.cpp323 ControlCmdType SingleVerDataSyncUtils::GetControlCmdType(int mode) in GetControlCmdType()
326 return ControlCmdType::SUBSCRIBE_QUERY_CMD; in GetControlCmdType()
328 return ControlCmdType::UNSUBSCRIBE_QUERY_CMD; in GetControlCmdType()
330 return ControlCmdType::INVALID_CONTROL_CMD; in GetControlCmdType()
333 int SingleVerDataSyncUtils::GetModeByControlCmdType(ControlCmdType controlCmd) in GetModeByControlCmdType()
335 if (controlCmd == ControlCmdType::SUBSCRIBE_QUERY_CMD) { in GetModeByControlCmdType()
337 } else if (controlCmd == ControlCmdType::UNSUBSCRIBE_QUERY_CMD) { in GetModeByControlCmdType()
356 …if (controlCmdType == ControlCmdType::SUBSCRIBE_QUERY_CMD && inMsg->GetMessageType() == TYPE_REQUE… in IsNeedTriggerQueryAutoSync()
H A Dsingle_ver_data_sync_utils.h64 static ControlCmdType GetControlCmdType(int mode);
66 static int GetModeByControlCmdType(ControlCmdType controlCmd);
H A Dsingle_ver_data_sync.cpp1828 if (packet->GetcontrolCmdType() == ControlCmdType::SUBSCRIBE_QUERY_CMD) { in ControlCmdRequestRecv()
1830 } else if (packet->GetcontrolCmdType() == ControlCmdType::UNSUBSCRIBE_QUERY_CMD) { in ControlCmdRequestRecv()
1860 if (cmdType == ControlCmdType::SUBSCRIBE_QUERY_CMD) { in ControlCmdAckRecv()
1862 } else if (cmdType == ControlCmdType::UNSUBSCRIBE_QUERY_CMD) { in ControlCmdAckRecv()
1969 if (controlCmdType >= ControlCmdType::INVALID_CONTROL_CMD) { in ControlCmdRequestRecvPre()
1980 if (controlCmdType != ControlCmdType::SUBSCRIBE_QUERY_CMD) { in SubscribeRequestRecvPre()
1994 static_cast<ControlCmdType>(packet->GetcontrolCmdType())); in SubscribeRequestRecvPre()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dsync_types.h61 enum ControlCmdType { enum