Home
last modified time | relevance | path

Searched refs:Message (Results 1 – 25 of 1058) sorted by relevance

12345678910>>...43

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_serialize_manager.h38 static uint32_t CalculateLen(const Message *inMsg);
42 static bool IsPacketValid(const Message *inMsg);
50 static uint32_t CalculateDataLen(const Message *inMsg);
51 static uint32_t CalculateControlLen(const Message *inMsg);
57 static int DataPacketCalculateLen(const Message *inMsg, uint32_t &len);
68 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
75 static int ControlPacketCalculateLen(const Message *inMsg, uint32_t &len);
79 static int AckControlPacketCalculateLen(const Message *inMsg, uint32_t &len);
85 static int SubscribeCalculateLen(const Message *inMsg, uint32_t &len);
92 static uint32_t ISyncPacketCalculateLen(const Message *inMsg);
[all …]
H A Dsingle_ver_sync_state_machine.h85 int HandleDataRequestRecv(const Message *inMsg);
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 *inMsg);
189 int HandleDataAckRecv(const Message *inMsg);
195 bool IsPacketValid(const Message *inMsg) const;
201 int MessageCallbackPre(const Message *inMsg);
[all …]
H A Dsingle_ver_data_sync.h70 int TryContinueSync(SingleVerSyncTaskContext *context, const Message *message);
84 bool AckPacketIdCheck(const Message *message);
86 int AckRecv(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);
114 void SendFinishedDataAck(SingleVerSyncTaskContext *context, const Message *message);
198 int DataRequestRecvPre(SingleVerSyncTaskContext *context, const Message *message);
206 int RunPermissionCheck(SingleVerSyncTaskContext *context, const Message *message,
216 int CheckSchemaStrategy(SingleVerSyncTaskContext *context, const Message *message);
[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_;
66 std::map<uint32_t, Message *> messageMap_;
/ohos5.0/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_t what, int32_t arg1, int32_t arg2, float arg3, const std::string &obj) in Message() function in OHOS::IntellVoiceUtils::Message
47 Message::Message(uint32_t what, std::shared_ptr<void> obj2) : what_(what), obj2_(obj2) in Message() function in OHOS::IntellVoiceUtils::Message
51 Message::Message(uint32_t what, std::shared_ptr<void> obj2, std::shared_ptr<void> obj3) in Message() function in OHOS::IntellVoiceUtils::Message
56 Message::Message(uint32_t what, void* voidPtr) : what_(what), voidPtr_(voidPtr) in Message() function in OHOS::IntellVoiceUtils::Message
60 Message::Message(uint32_t what, int32_t arg1, void* voidPtr) : what_(what), arg1_(arg1), voidPtr_(v… in Message() function in OHOS::IntellVoiceUtils::Message
64 Message::~Message() in ~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);
39 Message(uint32_t what, std::shared_ptr<void> obj2);
41 Message(uint32_t what, void* voidPtr);
42 Message(uint32_t what, int32_t arg1, void* voidPtr);
43 ~Message();
62 std::shared_ptr<Message> ReceiveMsg(); argument
63 bool SendMsg(std::shared_ptr<Message> msg);
[all …]
/ohos5.0/base/inputmethod/imf/common/include/
H A Dmessage.h26 class Message {
30 Message(int32_t msgId, MessageParcel *msgContent);
31 explicit Message(const Message &msg);
32 Message &operator=(const Message &msg);
33 ~Message();
36 Message(const Message &&);
37 Message &operator=(const Message &&);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_common.cpp112 funcForGiantMsg.computeFunc = [](const Message *inMsg)->uint32_t{ in RegFuncForGiantMsg()
181 Message *BuildRegedTinyMessage() in BuildRegedTinyMessage()
188 Message *outMsg = new (nothrow) Message(REGED_TINY_MSG_ID); in BuildRegedTinyMessage()
210 Message *BuildRegedHugeMessage() in BuildRegedHugeMessage()
217 Message *outMsg = new (nothrow) Message(REGED_HUGE_MSG_ID); in BuildRegedHugeMessage()
239 Message *BuildRegedGiantMessage(uint32_t length) in BuildRegedGiantMessage()
251 Message *outMsg = new (nothrow) Message(REGED_GIANT_MSG_ID); in BuildRegedGiantMessage()
280 Message *BuildRegedOverSizeMessage() in BuildRegedOverSizeMessage()
287 Message *outMsg = new (nothrow) Message(REGED_OVERSIZE_MSG_ID); in BuildRegedOverSizeMessage()
308 Message *BuildUnRegedTinyMessage() in BuildUnRegedTinyMessage()
[all …]
H A Ddistributeddb_communicator_send_receive_test.cpp111 static Message *BuildAppLayerFrameMessage() in BuildAppLayerFrameMessage()
116 DistributedDB::Message *message = nullptr; in BuildAppLayerFrameMessage()
132 Message *recvMsgForAA = nullptr;
134 Message *recvMsgForBA = nullptr;
136 Message *recvMsgForBB = nullptr;
159 Message *msgForAA = BuildRegedTinyMessage();
180 Message *msgForBB = BuildRegedTinyMessage();
473 Message *msgForBA = BuildRegedTinyMessage();
534 Message *msgForBA = BuildRegedTinyMessage();
713 Message *recvMsgForAA = nullptr;
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
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);
96 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
98 static int AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
102 static bool IsPacketValid(const Message *inMsg, uint16_t messageType);
106 int Send(const DeviceID &deviceId, const Message *inMsg);
[all …]
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);
106 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
112 static bool IsPacketValid(const Message *inMsg, uint16_t messageType);
118 int Send(const DeviceID &deviceId, const Message *inMsg);
[all …]
H A Dmulti_ver_sync_state_machine.h47 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;
/ohos5.0/docs/en/application-dev/reference/apis-core-file-kit/
H A Derrorcode-filemanagement.md19 **Error Message**
37 **Error Message**
51 **Error Message**
67 **Error Message**
83 **Error Message**
97 **Error Message**
111 **Error Message**
125 **Error Message**
141 **Error Message**
155 **Error Message**
[all …]
/ohos5.0/base/inputmethod/imf/common/src/
H A Dmessage.cpp24 Message::Message(int32_t msgId, MessageParcel *msgContent) in Message() function in OHOS::MiscServices::Message
36 Message::Message(const Message &msg) in Message() function in OHOS::MiscServices::Message
50 Message &Message::operator=(const Message &msg) in operator =()
68 Message::~Message() in ~Message()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommit_history_sync.h95 static int Serialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
97 static int DeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
99 static uint32_t CalculateLen(const Message *inMsg);
101 void TimeOutCallback(MultiVerSyncTaskContext *context, const Message *message) const;
105 int RequestRecvCallback(const MultiVerSyncTaskContext *context, const Message *message);
107 int AckRecvCallback(MultiVerSyncTaskContext *context, const Message *message);
110 static int RequestPacketCalculateLen(const Message *inMsg, uint32_t &len);
116 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
122 static bool IsPacketValid(const Message *inMsg, uint16_t messageType);
124 int Send(const DeviceID &deviceId, const Message *inMsg);
[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);
187 static int AckPacketSerialization(uint8_t *buffer, uint32_t length, const Message *inMsg);
191 static int AckPacketDeSerialization(const uint8_t *buffer, uint32_t length, Message *inMsg);
193 static int RequestPacketCalculateLen(const Message *inMsg, uint32_t &len);
195 static int AckPacketCalculateLen(const Message *inMsg, uint32_t &len);
234 int AckMsgCheck(const Message *message, ISyncTaskContext *context) const;
245 int SendAck(const Message *inMsg, const AbilitySyncAckPacket &ackPacket, bool isAckNotify);
[all …]
/ohos5.0/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::Finish() in Finish()
54 std::shared_future<void> GraphicsTask::Message::GetFuture() in GetFuture()
83 Message& msg = messageQueue_.emplace(std::move(task)); in PushAsyncMessage()
135 Message msg(std::move(messageQueue_.front())); in EngineThread()
/ohos5.0/foundation/ability/ability_runtime/interfaces/inner_api/app_manager/src/appmgr/
H A Dams_mgr_stub.cpp90 case static_cast<uint32_t>(IAmsMgr::Message::LOAD_ABILITY): in OnRemoteRequestInnerFirst()
92 case static_cast<uint32_t>(IAmsMgr::Message::TERMINATE_ABILITY): in OnRemoteRequestInnerFirst()
94 case static_cast<uint32_t>(IAmsMgr::Message::UPDATE_ABILITY_STATE): in OnRemoteRequestInnerFirst()
108 case static_cast<uint32_t>(IAmsMgr::Message::KILL_APPLICATION): in OnRemoteRequestInnerFirst()
116 case static_cast<uint32_t>(IAmsMgr::Message::KILL_APPLICATION_SELF): in OnRemoteRequestInnerFirst()
140 case static_cast<uint32_t>(IAmsMgr::Message::SET_CURRENT_USER_ID): in OnRemoteRequestInnerSecond()
150 case static_cast<uint32_t>(IAmsMgr::Message::ATTACH_APP_DEBUG): in OnRemoteRequestInnerSecond()
152 case static_cast<uint32_t>(IAmsMgr::Message::DETACH_APP_DEBUG): in OnRemoteRequestInnerSecond()
174 case static_cast<uint32_t>(IAmsMgr::Message::IS_ATTACH_DEBUG): in OnRemoteRequestInnerThird()
190 case static_cast<uint32_t>(IAmsMgr::Message::GET_CONFIGURATION): in OnRemoteRequestInnerThird()
[all …]
H A Dapp_scheduler_host.cpp109 case static_cast<uint32_t>(IAppScheduler::Message::SCHEDULE_CLEAR_PAGE_STACK): in OnRemoteRequestInnerSecond()
111 case static_cast<uint32_t>(IAppScheduler::Message::SCHEDULE_ACCEPT_WANT): in OnRemoteRequestInnerSecond()
125 case static_cast<uint32_t>(IAppScheduler::Message::SCHEDULE_NOTIFY_FAULT): in OnRemoteRequestInnerSecond()
135 case static_cast<uint32_t>(IAppScheduler::Message::APP_GC_STATE_CHANGE): in OnRemoteRequestInnerThird()
137 case static_cast<uint32_t>(IAppScheduler::Message::SCHEDULE_ATTACH_APP_DEBUG): in OnRemoteRequestInnerThird()
139 case static_cast<uint32_t>(IAppScheduler::Message::SCHEDULE_DETACH_APP_DEBUG): in OnRemoteRequestInnerThird()
143 case static_cast<uint32_t>(IAppScheduler::Message::SCHEDULE_DUMP_IPC_START): in OnRemoteRequestInnerThird()
145 case static_cast<uint32_t>(IAppScheduler::Message::SCHEDULE_DUMP_IPC_STOP): in OnRemoteRequestInnerThird()
147 case static_cast<uint32_t>(IAppScheduler::Message::SCHEDULE_DUMP_IPC_STAT): in OnRemoteRequestInnerThird()
149 case static_cast<uint32_t>(IAppScheduler::Message::SCHEDULE_DUMP_FFRT): in OnRemoteRequestInnerThird()
[all …]
H A Dapplication_state_observer_stub.cpp35 switch (static_cast<Message>(code)) { in OnRemoteRequest()
38 case Message::TRANSACT_ON_ABILITY_STATE_CHANGED: in OnRemoteRequest()
42 case Message::TRANSACT_ON_PROCESS_CREATED: in OnRemoteRequest()
44 case Message::TRANSACT_ON_PROCESS_STATE_CHANGED: in OnRemoteRequest()
46 case Message::TRANSACT_ON_PROCESS_DIED: in OnRemoteRequest()
50 case Message::TRANSACT_ON_APP_STATE_CHANGED: in OnRemoteRequest()
52 case Message::TRANSACT_ON_PROCESS_REUSED: in OnRemoteRequest()
54 case Message::TRANSACT_ON_APP_STARTED: in OnRemoteRequest()
56 case Message::TRANSACT_ON_APP_STOPPED: in OnRemoteRequest()
58 case Message::TRANSACT_ON_PAGE_SHOW: in OnRemoteRequest()
[all …]
/ohos5.0/docs/en/application-dev/reference/apis-image-kit/
H A Derrorcode-image.md10 **Error Message**
24 **Error Message**
42 **Error Message**
59 **Error Message**
75 **Error Message**
91 **Error Message**
108 **Error Message**
124 **Error Message**
138 **Error Message**
152 **Error Message**
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_msg_schedule_test.cpp78 DistributedDB::Message *message = nullptr;
127 DistributedDB::Message *message = nullptr;
170 DistributedDB::Message *message = nullptr;
238 DistributedDB::Message *message = nullptr;
247 DistributedDB::Message *message = nullptr;
297 DistributedDB::Message *message = nullptr;
304 DistributedDB::Message *message = nullptr;
354 DistributedDB::Message *message = nullptr;
374 DistributedDB::Message *message = nullptr;
420 DistributedDB::Message *message = nullptr;
[all …]
/ohos5.0/foundation/graphic/graphic_3d/3d_widget_adapter/include/
H A Dgraphics_task.h29 class Message {
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_;
/ohos5.0/foundation/ability/form_fwk/interfaces/inner_api/src/
H A Dform_mgr_stub.cpp83 case static_cast<uint32_t>(IFormMgr::Message::FORM_MGR_ADD_FORM): in OnRemoteRequestFirst()
85 case static_cast<uint32_t>(IFormMgr::Message::FORM_MGR_DELETE_FORM): in OnRemoteRequestFirst()
87 case static_cast<uint32_t>(IFormMgr::Message::FORM_MGR_RELEASE_FORM): in OnRemoteRequestFirst()
89 case static_cast<uint32_t>(IFormMgr::Message::FORM_MGR_UPDATE_FORM): in OnRemoteRequestFirst()
91 case static_cast<uint32_t>(IFormMgr::Message::FORM_MGR_REQUEST_FORM): in OnRemoteRequestFirst()
95 case static_cast<uint32_t>(IFormMgr::Message::FORM_MGR_CAST_TEMP_FORM): in OnRemoteRequestFirst()
109 case static_cast<uint32_t>(IFormMgr::Message::FORM_MGR_MESSAGE_EVENT): in OnRemoteRequestFirst()
147 case static_cast<uint32_t>(IFormMgr::Message::FORM_MGR_ROUTER_EVENT): in OnRemoteRequestSecond()
153 case static_cast<uint32_t>(IFormMgr::Message::FORM_MGR_SHARE_FORM): in OnRemoteRequestSecond()
185 case static_cast<uint32_t>(IFormMgr::Message::FORM_MGR_ACQUIRE_DATA): in OnRemoteRequestThird()
[all …]
H A Dform_mgr_proxy.cpp119 IFormMgr::Message::FORM_MGR_DELETE_FORM, in DeleteForm()
148 IFormMgr::Message::FORM_MGR_STOP_RENDERING_FORM, in StopRenderingForm()
189 IFormMgr::Message::FORM_MGR_RELEASE_FORM, in ReleaseForm()
225 IFormMgr::Message::FORM_MGR_UPDATE_FORM, in UpdateForm()
292 IFormMgr::Message::FORM_MGR_RELEASE_RENDERER, in ReleaseRenderer()
329 IFormMgr::Message::FORM_MGR_REQUEST_PUBLISH_FORM, in RequestPublishForm()
434 IFormMgr::Message::FORM_MGR_LIFECYCLE_UPDATE, in LifecycleUpdate()
477 IFormMgr::Message::FORM_MGR_REQUEST_FORM, in RequestForm()
596 IFormMgr::Message::FORM_MGR_CAST_TEMP_FORM, in CastTempForm()
1030 IFormMgr::Message::FORM_MGR_ACQUIRE_FORM_STATE, in AcquireFormState()
[all …]

12345678910>>...43