Home
last modified time | relevance | path

Searched refs:Message (Results 1 - 25 of 354) sorted by relevance

12345678910>>...15

/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/src/
H A Dmessage.cpp25 Message::Message() : Message(0, 0, 0, 0) {} in Message() function in OHOS::CastEngine::CastEngineService::Message
27 Message::Message(int what) : Message(what, 0, 0, 0) {} in Message() function in OHOS::CastEngine::CastEngineService::Message
29 Message::Message(int what, std::string strArg) : Message(what, 0, 0, 0, strArg) {} in Message() function in OHOS::CastEngine::CastEngineService::Message
31 Message function in OHOS::CastEngine::CastEngineService::Message
33 Message::Message(int what, int arg1, int arg2) : Message(what, arg1, arg2, 0) {} Message() function in OHOS::CastEngine::CastEngineService::Message
35 Message::Message(int what, int arg1, std::string strArg) : Message(what, arg1, 0, 0, strArg) {} Message() function in OHOS::CastEngine::CastEngineService::Message
37 Message::Message(int what, int arg1, int arg2, long uptimeMillis) : Message(what, arg1, arg2, uptimeMillis, "") {} Message() function in OHOS::CastEngine::CastEngineService::Message
39 Message::Message(int what, int arg1, int arg2, long uptimeMillis, std::string strArg) Message() function in OHOS::CastEngine::CastEngineService::Message
80 Message::Message(const Message &msg) Message() function in OHOS::CastEngine::CastEngineService::Message
[all...]
H A Dhandler.cpp28 Message msg; in Handler()
83 bool Handler::SendCastMessage(const Message &msg) in SendCastMessage()
92 std::sort(msgQueue_.begin(), msgQueue_.end(), std::greater<Message>()); in SendCastMessage()
99 return SendCastMessage(Message(what)); in SendCastMessage()
104 return SendCastMessage(Message(what, arg1)); in SendCastMessage()
109 return SendCastMessage(Message(what, arg1, arg2)); in SendCastMessage()
118 Message msg(what); in SendCastMessageDelayed()
123 void Handler::RemoveMessage(const Message &msg) in RemoveMessage()
163 void Handler::HandleMessageInner(const Message &msg) in HandleMessageInner()
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/src/
H A Dmessage.cpp25 Message::Message() : Message(0, 0, 0, 0) {} in Message() function in OHOS::CastEngine::CastEngineService::Message
27 Message::Message(int what) : Message(what, 0, 0, 0) {} in Message() function in OHOS::CastEngine::CastEngineService::Message
29 Message::Message(int what, std::string strArg) : Message(what, 0, 0, 0, strArg) {} in Message() function in OHOS::CastEngine::CastEngineService::Message
31 Message function in OHOS::CastEngine::CastEngineService::Message
33 Message::Message(int what, int arg1, int arg2) : Message(what, arg1, arg2, 0) {} Message() function in OHOS::CastEngine::CastEngineService::Message
35 Message::Message(int what, int arg1, std::string strArg) : Message(what, arg1, 0, 0, strArg) {} Message() function in OHOS::CastEngine::CastEngineService::Message
37 Message::Message(int what, int arg1, int arg2, long uptimeMillis) : Message(what, arg1, arg2, uptimeMillis, "") {} Message() function in OHOS::CastEngine::CastEngineService::Message
39 Message::Message(int what, int arg1, int arg2, long uptimeMillis, std::string strArg) Message() function in OHOS::CastEngine::CastEngineService::Message
80 Message::Message(const Message &msg) Message() function in OHOS::CastEngine::CastEngineService::Message
[all...]
H A Dhandler.cpp28 Message msg; in Handler()
83 bool Handler::SendCastMessage(const Message &msg) in SendCastMessage()
92 std::sort(msgQueue_.begin(), msgQueue_.end(), std::greater<Message>()); in SendCastMessage()
99 return SendCastMessage(Message(what)); in SendCastMessage()
104 return SendCastMessage(Message(what, arg1)); in SendCastMessage()
109 return SendCastMessage(Message(what, arg1, arg2)); in SendCastMessage()
118 Message msg(what); in SendCastMessageDelayed()
123 void Handler::RemoveMessage(const Message &msg) in RemoveMessage()
163 void Handler::HandleMessageInner(const Message &msg) in HandleMessageInner()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_serialize_manager.h34 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
36 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
38 static uint32_t CalculateLen(const Message *inMsg);
42 static bool IsPacketValid(const Message *inMsg);
44 static int DataSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
45 static int ControlSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
47 static int DataDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
48 static int ControlDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
50 static uint32_t CalculateDataLen(const Message *inMsg);
51 static uint32_t CalculateControlLen(const Message *inMs
[all...]
H A Dsingle_ver_data_message_schedule.h33 void PutMsg(Message *inMsg);
35 Message *MoveNextMsg(SingleVerSyncTaskContext *context, bool &isNeedHandle, bool &isNeedContinue);
36 void ScheduleInfoHandle(bool isNeedHandleStatus, bool isNeedClearMap, const Message *inMsg);
40 void UpdateMsgMapInner(std::queue<Message *> &msgTmpQueue);
41 int UpdateMsgMapIfNeed(Message *msg);
42 Message *GetMsgFromMap(bool &isNeedHandle);
43 Message *GetLastMsgFromQueue();
55 int GetPacketId(const Message *msg, uint64_t &packetId);
59 std::queue<Message *> msgQueue_;
64 // first:sequenceId second:Message*, dea
[all...]
H A Dsingle_ver_sync_state_machine.h79 // send Message to the StateMachine
80 int ReceiveMessageCallback(Message *inMsg) override;
85 int HandleDataRequestRecv(const Message *inMsg);
93 bool IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) override;
134 int TimeMarkSyncRecv(const Message *inMsg);
175 int HandleControlAckRecv(const Message *inMsg);
179 int AbilitySyncRecv(const Message *inMsg);
181 int DataPktRecv(Message *inMsg);
183 void ScheduleMsgAndHandle(Message *inMsg);
185 int ControlPktRecv(Message *inMs
[all...]
H A Dsingle_ver_data_sync.h70 int TryContinueSync(SingleVerSyncTaskContext *context, const Message *message);
82 int DataRequestRecv(SingleVerSyncTaskContext *context, const Message *message, WaterMark &pullEndWatermark);
84 bool AckPacketIdCheck(const Message *message);
86 int AckRecv(SingleVerSyncTaskContext *context, const Message *message);
91 virtual int SendDataAck(SingleVerSyncTaskContext *context, const Message *message, int32_t recvCode,
100 bool WaterMarkErrHandle(SyncType syncType, SingleVerSyncTaskContext *context, const Message *message);
104 int ControlCmdRequestRecv(SingleVerSyncTaskContext *context, const Message *message);
106 int ControlCmdAckRecv(SingleVerSyncTaskContext *context, const Message *message);
108 void PutDataMsg(Message *message);
110 Message *MoveNextDataMs
[all...]
/foundation/CastEngine/castengine_cast_plus_stream/src/utils/include/
H A Dmessage.h31 class Message { class
49 Message();
50 Message(const Message &msg);
51 Message &operator=(const Message &msg);
52 explicit Message(int what);
53 Message(int what, std::string strArg);
54 Message(int what, std::string deviceId, EventCode eventCode) : what_(what), in Message() function in OHOS::CastEngine::CastEngineService::Message
56 Message(in in Message()
[all...]
/foundation/CastEngine/castengine_cast_framework/service/src/session/src/utils/include/
H A Dmessage.h31 class Message { class
49 Message();
50 Message(const Message &msg);
51 Message &operator=(const Message &msg);
52 explicit Message(int what);
53 Message(int what, std::string strArg);
54 Message(int what, std::string deviceId, EventCode eventCode) : what_(what), in Message() function in OHOS::CastEngine::CastEngineService::Message
56 Message(in in Message()
[all...]
/foundation/ai/intelligent_voice_framework/utils/
H A Dmessage_queue.cpp24 Message::Message(uint32_t what) : what_(what), arg1_(0), arg2_(0) in Message() function in OHOS::IntellVoiceUtils::Message
28 Message::Message(uint32_t what, int32_t arg1) : what_(what), arg1_(arg1) in Message() function in OHOS::IntellVoiceUtils::Message
32 Message::Message(uint32_t what, int32_t arg1, int32_t arg2, float arg3) in Message() function in OHOS::IntellVoiceUtils::Message
37 Message::Message(uint32_t what, int32_t arg1, int32_t arg2, const std::string &obj) in Message() function in OHOS::IntellVoiceUtils::Message
42 Message::Message(uint32_ function in OHOS::IntellVoiceUtils::Message
47 Message::Message(uint32_t what, std::shared_ptr<void> obj2) : what_(what), obj2_(obj2) Message() function in OHOS::IntellVoiceUtils::Message
51 Message::Message(uint32_t what, std::shared_ptr<void> obj2, std::shared_ptr<void> obj3) Message() function in OHOS::IntellVoiceUtils::Message
56 Message::Message(uint32_t what, void* voidPtr) : what_(what), voidPtr_(voidPtr) Message() function in OHOS::IntellVoiceUtils::Message
60 Message::Message(uint32_t what, int32_t arg1, void* voidPtr) : what_(what), arg1_(arg1), voidPtr_(voidPtr) Message() function in OHOS::IntellVoiceUtils::Message
[all...]
H A Dmessage_queue.h32 struct Message { struct
34 explicit Message(uint32_t what);
35 Message(uint32_t what, int32_t arg1);
36 Message(uint32_t what, int32_t arg1, int32_t arg2, float arg3);
37 Message(uint32_t what, int32_t arg1, int32_t arg2, const std::string &obj);
38 Message(uint32_t what, int32_t arg1, int32_t arg2, float arg3, const std::string &obj);
39 Message(uint32_t what, std::shared_ptr<void> obj2);
40 Message(uint32_t what, std::shared_ptr<void> obj2, std::shared_ptr<void> obj3);
41 Message(uint32_t what, void* voidPtr);
42 Message(uint32_
[all...]
H A Dmsg_handle_thread.cpp47 bool MsgHandleThread::HandleMsg(Message &msg) in HandleMsg()
56 bool MsgHandleThread::SendMsg(Message msg) in SendMsg()
59 msgQue_.SendMsg(std::make_shared<Message>(msg)); in SendMsg()
68 bool MsgHandleThread::SendMsg(std::shared_ptr<Message> msg) in SendMsg()
78 bool MsgHandleThread::SendSynMsg(shared_ptr<Message> msg) in SendSynMsg()
100 void MsgHandleThread::SendbackMsg(Message msg) in SendbackMsg()
107 callbackMsgQue_->SendMsg(make_shared<Message>(msg)); in SendbackMsg()
116 shared_ptr<Message> msg = msgQue_.ReceiveMsg(); in Run()
H A Dmsg_handle_thread.h31 bool SendMsg(Message msg);
32 bool SendMsg(std::shared_ptr<Message> msg);
33 bool SendSynMsg(std::shared_ptr<Message> msg);
38 virtual bool HandleMsg(Message &msg);
39 virtual void SendbackMsg(Message msg);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_data_sync.h76 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
78 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
80 static uint32_t CalculateLen(const Message *inMsg);
82 void TimeOutCallback(MultiVerSyncTaskContext *context, const Message *message) const;
86 int RequestRecvCallback(const MultiVerSyncTaskContext *context, const Message *message);
88 int AckRecvCallback(MultiVerSyncTaskContext *context, const Message *message);
100 static int RequestPacketCalculateLen(const Message *inMsg, uint32_t &len);
102 static int RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
104 static int RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
106 static int AckPacketCalculateLen(const Message *inMs
[all...]
H A Dvalue_slice_sync.h75 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
77 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
79 static uint32_t CalculateLen(const Message *inMsg);
83 int RequestRecvCallback(const MultiVerSyncTaskContext *context, const Message *message);
85 int AckRecvCallback(const MultiVerSyncTaskContext *context, const Message *message);
90 static int RequestPacketCalculateLen(const Message *inMsg, uint32_t &len);
92 static int RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
94 static int RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
96 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
98 static int AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMs
[all...]
H A Dmulti_ver_sync_state_machine.h46 // send Message to the StateMachine
47 int ReceiveMessageCallback(Message *inMsg) override;
77 bool IsNeedTriggerQueryAutoSync(Message *inMsg, QuerySyncObject &query) override;
92 int MessageCallbackCheck(const Message *inMsg);
100 int TimeSyncPacketRecvCallback(const MultiVerSyncTaskContext *context, const Message *inMsg);
102 int CommitHistorySyncPktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg);
104 int MultiVerDataPktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg);
106 int ValueSlicePktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg);
112 bool IsPacketValid(const Message *inMsg) const;
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_common.cpp76 funcForTinyMsg.computeFunc = [](const Message *inMsg)->uint32_t{return TINY_SIZE;}; in RegFuncForTinyMsg()
77 funcForTinyMsg.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg)->int{ in RegFuncForTinyMsg()
82 funcForTinyMsg.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg)->int{ in RegFuncForTinyMsg()
94 funcForHugeMsg.computeFunc = [](const Message *inMsg)->uint32_t{return HUGE_SIZE;}; in RegFuncForHugeMsg()
95 funcForHugeMsg.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg)->int{ in RegFuncForHugeMsg()
100 funcForHugeMsg.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg)->int{ in RegFuncForHugeMsg()
112 funcForGiantMsg.computeFunc = [](const Message *inMsg)->uint32_t{ in RegFuncForGiantMsg()
119 funcForGiantMsg.serializeFunc = [](uint8_t *buffer, uint32_t length, const Message *inMsg)->int{ in RegFuncForGiantMsg()
133 funcForGiantMsg.deserializeFunc = [](const uint8_t *buffer, uint32_t length, Message *inMsg)->int{ in RegFuncForGiantMsg()
158 funcForOverSizeMsg.computeFunc = [](const Message *inMs in RegFuncForOverSizeMsg()
[all...]
/foundation/graphic/graphic_3d/3d_widget_adapter/src/
H A Dgraphics_task.cpp27 GraphicsTask::Message::Message(const std::function<Task>& task) in Message() function in OHOS::Render3D::GraphicsTask::Message
31 GraphicsTask::Message::Message(GraphicsTask::Message&& msg) in Message() function in OHOS::Render3D::GraphicsTask::Message
35 GraphicsTask::Message& GraphicsTask::Message::operator=(GraphicsTask::Message&& msg) in operator =()
43 void GraphicsTask::Message::Execute() in Execute()
49 void GraphicsTask::Message
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommit_history_sync.h97 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
99 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
101 static uint32_t CalculateLen(const Message *inMsg);
103 void TimeOutCallback(MultiVerSyncTaskContext *context, const Message *message) const;
107 int RequestRecvCallback(const MultiVerSyncTaskContext *context, const Message *message);
109 int AckRecvCallback(MultiVerSyncTaskContext *context, const Message *message);
112 static int RequestPacketCalculateLen(const Message *inMsg, uint32_t &len);
114 static int RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
116 static int RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
118 static int AckPacketCalculateLen(const Message *inMs
[all...]
H A Dability_sync.h164 int AckRecv(const Message *message, ISyncTaskContext *context);
166 int RequestRecv(const Message *message, ISyncTaskContext *context);
168 int AckNotifyRecv(const Message *message, ISyncTaskContext *context);
178 static uint32_t CalculateLen(const Message *inMsg);
180 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg); // register to communicator
182 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg); // register to communicator
185 static int RequestPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
187 static int AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
189 static int RequestPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
191 static int AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMs
[all...]
/foundation/graphic/graphic_3d/3d_widget_adapter/include/
H A Dgraphics_task.h29 class Message { class in OHOS::Render3D::GraphicsTask
31 explicit Message(const std::function<Task>& task);
32 Message(Message&& msg);
33 Message& operator=(Message&& msg);
34 ~Message() = default;
62 std::queue<Message> messageQueue_;
/foundation/communication/netmanager_ext/frameworks/native/ethernetclient/src/proxy/
H A Dinterface_state_callback_stub.cpp33 InterfaceStateCallback::Message msgCode = static_cast<InterfaceStateCallback::Message>(code); in OnRemoteRequest()
35 case InterfaceStateCallback::Message::INTERFACE_STATE_ADD: { in OnRemoteRequest()
39 case InterfaceStateCallback::Message::INTERFACE_STATE_REMOVE: { in OnRemoteRequest()
43 case InterfaceStateCallback::Message::INTERFACE_STATE_CHANGE: { in OnRemoteRequest()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/util/
H A Dmessage.h20 struct Message { struct
23 * @brief Construct a new Message object.
25 * @param what Message Identifier.
26 * @param arg1 Message first arg.
27 * @param arg2 Message second arg.
30 Message(int what, int arg1 = 0, void *arg2 = nullptr) : what_(what), arg1_(arg1), arg2_(arg2){}; in Message() function
33 * @brief Construct a new Message object.
37 Message() = default;
40 * @brief Destroy the Message object.
44 ~Message()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_msg_schedule_test.cpp78 DistributedDB::Message *message = nullptr; in HWTEST_F()
82 Message *msg = msgSchedule.MoveNextMsg(context, isNeedHandle, isNeedContinue); in HWTEST_F()
91 Message *msg = msgSchedule.MoveNextMsg(context, isNeedHandle, isNeedContinue); in HWTEST_F()
99 Message *msg = msgSchedule.MoveNextMsg(context, isNeedHandle, isNeedContinue); in HWTEST_F()
127 DistributedDB::Message *message = nullptr; in HWTEST_F()
135 Message *msg = msgSchedule.MoveNextMsg(context, isNeedHandle, isNeedContinue); in HWTEST_F()
170 DistributedDB::Message *message = nullptr; in HWTEST_F()
173 Message *msg = msgSchedule.MoveNextMsg(context, isNeedHandle, isNeedContinue); in HWTEST_F()
238 DistributedDB::Message *message = nullptr; in HWTEST_F()
241 Message *ms in HWTEST_F()
[all...]

Completed in 9 milliseconds

12345678910>>...15