Home
last modified time | relevance | path

Searched refs:message (Results 1 - 25 of 40) sorted by relevance

12

/drivers/hdf_core/framework/utils/src/
H A Dhdf_message_looper.c16 struct HdfMessage *message = NULL; in HdfMessageLooperStart() local
22 message = HdfMessageQueueNext(&looper->messageQueue); in HdfMessageLooperStart()
23 if (message != NULL) { in HdfMessageLooperStart()
24 HDF_LOGD("%{public}s received message %{public}d", __func__, message->messageId); in HdfMessageLooperStart()
25 if (message->messageId == MESSAGE_STOP_LOOP) { in HdfMessageLooperStart()
26 HdfMessageRecycle(message); in HdfMessageLooperStart()
30 } else if (message->target != NULL) { in HdfMessageLooperStart()
31 struct HdfMessageTask *task = message->target; in HdfMessageLooperStart()
32 task->DispatchMessage(task, message); in HdfMessageLooperStart()
45 struct HdfMessage *message = HdfMessageObtain(0); HdfMessageLooperStop() local
[all...]
H A Dosal_msg_queue.c32 struct HdfMessageQueue *queue, struct HdfMessage *message, long delayed) in HdfMessageQueueEnqueue()
34 if (queue == NULL || message == NULL) { in HdfMessageQueueEnqueue()
40 message->timeStamp += OsalGetSysTimeMs(); in HdfMessageQueueEnqueue()
45 if (next->timeStamp > message->timeStamp) { in HdfMessageQueueEnqueue()
46 HdfSListIteratorInsert(&it, &message->entry); in HdfMessageQueueEnqueue()
51 HdfSListAddTail(&queue->list, &message->entry); in HdfMessageQueueEnqueue()
60 struct HdfMessage *message = NULL; in HdfMessageQueueNext() local
66 message = (struct HdfMessage *)HdfSListIteratorNext(&it); in HdfMessageQueueNext()
67 if (message->timeStamp <= currentTime) { in HdfMessageQueueNext()
70 return message; in HdfMessageQueueNext()
31 HdfMessageQueueEnqueue( struct HdfMessageQueue *queue, struct HdfMessage *message, long delayed) HdfMessageQueueEnqueue() argument
[all...]
H A Dosal_message.c18 void HdfMessageRecycle(struct HdfMessage *message) in HdfMessageRecycle() argument
20 OsalMemFree(message); in HdfMessageRecycle()
25 struct HdfMessage *message = (struct HdfMessage *)listEntry; in HdfMessageDelete() local
26 if (message != NULL) { in HdfMessageDelete()
27 HdfMessageRecycle(message); in HdfMessageDelete()
/drivers/peripheral/camera/vdi_base/v4l2/src/stream_operator/
H A Dcapture_message.cpp70 void CaptureMessageOperator::SendMessage(std::shared_ptr<ICaptureMessage>& message) in SendMessage() argument
72 if (message == nullptr) { in SendMessage()
73 CAMERA_LOGE("message is nullptr"); in SendMessage()
80 auto it = messageBox_.find(message->GetMessageType()); in SendMessage()
82 messageBox_[message->GetMessageType()] = {{message}}; in SendMessage()
83 if (message->GetPeerMessageCount() == 1) { in SendMessage()
94 CAMERA_LOGE("unknown error, message is null"); in SendMessage()
97 if (message->GetTimestamp() == mit[0]->GetTimestamp() && in SendMessage()
98 message in SendMessage()
[all...]
H A Dstream_operator_vdi_impl.cpp599 void StreamOperatorVdiImpl::FillCaptureErrorInfo(std::vector<VdiCaptureErrorInfo> &info, MessageGroup message)
601 for (auto cm : message) {
611 void StreamOperatorVdiImpl::FillCaptureEndedInfo(std::vector<VdiCaptureEndedInfo> &info, MessageGroup message)
613 for (auto cm : message) {
623 void StreamOperatorVdiImpl::HandleCallbackMessage(MessageGroup &message)
625 if (message.empty()) {
628 CHECK_IF_PTR_NULL_RETURN_VOID(message[0]);
629 CaptureMessageType type = message[0]->GetMessageType();
633 for (auto cm : message) {
638 OnCaptureStarted(message[
[all...]
/drivers/hdf_core/framework/tools/hdf_dev_eco_tool/command_line/
H A Dhdf_tool_argument_parser.py18 def exit(self, status=0, message=None):
20 raise HdfToolException(message, CommandErrorCode.INTERFACE_ERROR)
23 def error(self, message):
24 self.exit(2, 'error: %s\n' % message)
/drivers/hdf_core/adapter/uhdf2/host/src/
H A Dhdf_device_thread.c43 HDF_LOGE("Unsupported message, message id is %{public}u", msg->messageId); in DeviceThreadMessageHandler()
58 struct HdfMessage *message = HdfMessageObtain(sizeof(struct HdfDeviceNode *)); in DeviceThreadAttach() local
59 if (message == NULL) { in DeviceThreadAttach()
60 HDF_LOGE("DeviceThreadAttach:obtain message error"); in DeviceThreadAttach()
63 message->messageId = DEVICE_SERVICE_MESSAGE_LAUNCH; in DeviceThreadAttach()
64 message->data[0] = (void *)device; in DeviceThreadAttach()
65 message->data[1] = (void *)service; in DeviceThreadAttach()
66 return task->SendMessage(task, message, true); in DeviceThreadAttach()
H A Ddevhost_service_full.c51 HDF_LOGE("DevHostServiceFullDispatchMessage unknown message %{public}d", msg->messageId); in DevHostServiceFullDispatchMessage()
67 struct HdfMessage *message = HdfMessageObtain(0); in DevHostServiceFullOpsDevice() local
68 if (message == NULL) { in DevHostServiceFullOpsDevice()
73 message->messageId = cmdCode; in DevHostServiceFullOpsDevice()
74 message->data[0] = (void *)parm; in DevHostServiceFullOpsDevice()
75 return task->SendMessage(task, message, true); in DevHostServiceFullOpsDevice()
/drivers/hdf_core/adapter/uhdf2/manager/src/
H A Ddevhost_service_proxy.c80 struct HdfMessage *message = HdfMessageObtain(sizeof(void *)); in DevHostServiceProxyOnRemoteDied() local
81 if (message == NULL) { in DevHostServiceProxyOnRemoteDied()
86 message->messageId = DEVMGR_MESSAGE_DEVHOST_DIED; in DevHostServiceProxyOnRemoteDied()
87 message->data[0] = (void *)(uintptr_t)proxy->hostId; in DevHostServiceProxyOnRemoteDied()
88 message->data[1] = (void *)service; in DevHostServiceProxyOnRemoteDied()
90 task->SendMessage(task, message, false); in DevHostServiceProxyOnRemoteDied()
/drivers/peripheral/camera/vdi_base/v4l2/src/offline_stream_operator/
H A Doffline_stream.cpp183 void OfflineStream::HandleMessage(MessageGroup& message) in HandleMessage() argument
185 if (message.empty()) { in HandleMessage()
188 CHECK_IF_PTR_NULL_RETURN_VOID(message[0]); in HandleMessage()
189 CaptureMessageType type = message[0]->GetMessageType(); in HandleMessage()
193 for (const auto& cm : message) { in HandleMessage()
201 OnCaptureError(message[0]->GetCaptureId(), info); in HandleMessage()
206 for (const auto& cm : message) { in HandleMessage()
214 OnCaptureEnded(message[0]->GetCaptureId(), info); in HandleMessage()
/drivers/hdf_core/adapter/khdf/liteos/model/network/wifi/
H A DMakefile84 MESSAGE_INCLUDE += -I $(PLATFORM_PATH)/include/message \
87 LOCAL_SRCS += $(PLATFORM_PATH)/src/message/nodes/local_node.c \
88 $(PLATFORM_PATH)/src/message/message_dispatcher.c \
89 $(PLATFORM_PATH)/src/message/message_router.c \
90 $(PLATFORM_PATH)/src/message/sidecar.c \
/drivers/peripheral/camera/vdi_base/common/buffer_manager/src/
H A Dbuffer_loop_tracking.cpp373 std::shared_ptr<BufferTrackingMessage> message = nullptr; in ReceiveMessage() local
377 message = messageQueue_.front(); in ReceiveMessage()
379 return message; in ReceiveMessage()
383 return message; in ReceiveMessage()
386 void BufferLoopTracking::SendBufferMovementMessage(const std::shared_ptr<BufferTrackingMessage>& message) in SendBufferMovementMessage() argument
389 messageQueue_.emplace_back(message); in SendBufferMovementMessage()
397 auto message = ReceiveMessage(); in HandleMessage() local
398 if (message == nullptr) { in HandleMessage()
402 auto stream = FindTrackingStream(message->trackingId); in HandleMessage()
404 CAMERA_LOGE("cannot handle stream %{public}d", message in HandleMessage()
[all...]
H A Dbuffer_tracking.cpp50 void BufferTracking::ReportBufferLocation(const std::shared_ptr<BufferTrackingMessage>& message) in ReportBufferLocation() argument
53 stalker.SendBufferMovementMessage(message); in ReportBufferLocation()
/drivers/hdf_core/framework/utils/include/
H A Dosal_message.h27 void HdfMessageRecycle(struct HdfMessage *message);
H A Dosal_msg_queue.h30 struct HdfMessageQueue *queue, struct HdfMessage *message, long delayed);
/drivers/peripheral/camera/vdi_base/v4l2/include/stream_operator/
H A Dstream_operator_vdi_impl.h59 void FillCaptureErrorInfo(std::vector<VdiCaptureErrorInfo> &info, MessageGroup message);
60 void FillCaptureEndedInfo(std::vector<VdiCaptureEndedInfo> &info, MessageGroup message);
61 void HandleCallbackMessage(MessageGroup &message);
/drivers/hdf_core/adapter/uhdf2/utils/include/
H A Dhdf_xcollie.h44 void TriggerTimerCount(const std::string &name, bool bTrigger, const std::string &message);
/drivers/hdf_core/adapter/uhdf2/utils/src/
H A Dhdf_xcollie.cpp48 void HdfXCollie::TriggerTimerCount(const std::string &name, bool bTrigger, const std::string &message)
/drivers/external_device_manager/interfaces/innerkits/
H A Ddriver_ext_mgr_types.h28 ErrMsg(UsbErrCode code = UsbErrCode::EDM_NOK, const std::string &message = "") : errCode(code), msg(message) {} in ErrMsg()
/drivers/peripheral/power/interfaces/hdi_service/src/
H A Drunning_lock_impl.cpp270 std::string message; in NotifyChanged() local
271 message.append("LOCKID=").append(std::to_string(lockid)) in NotifyChanged()
279 HDF_LOGI("runninglock message: %{public}s, timeout: %{public}d", message.c_str(), info.timeoutMs); in NotifyChanged()
281 g_iPowerRunningLockCallback->HandleRunningLockMessage(message); in NotifyChanged()
/drivers/peripheral/camera/vdi_base/common/include/
H A Dbuffer_tracking.h56 static void ReportBufferLocation(const std::shared_ptr<BufferTrackingMessage>& message);
/drivers/peripheral/camera/vdi_base/v4l2/include/offline_stream_operator/
H A Doffline_stream.h43 void HandleMessage(MessageGroup& message);
/drivers/hdf_core/framework/tools/hcs-view/hcsWebView/src/hcs/
H A Dlexer.js16 const { XMessage } = require('../message/XMessage');
404 dealWithError(message) {
405 XMessage.gi().send('error', message);
406 NapiLog.logError(message + "'");
/drivers/hdf_core/adapter/khdf/linux/test/
H A Dtest_khdf.mk37 -I$(srctree)/$(HDF_FRAMEWORK_TEST_ROOT)/model/network/wifi/unittest/message \
73 -I$(srctree)/$(HDF_FRAMEWORK_TEST_ROOT)/model/network/wifi/unittest/message \
/drivers/hdf_core/framework/tools/hdi-gen/parser/
H A Dparser.h212 void LogError(const std::string &message);
214 void LogError(const Token &token, const std::string &message);

Completed in 8 milliseconds

12