| /foundation/arkui/ace_engine_lite/frameworks/tools/qt/simulator/jsfwk/targets/simulator/mock/ |
| H A D | message_queue_utils.cpp | 26 QueueHandler MessageQueueUtils::CreateMessageQueue(uint32_t capacity, uint32_t msgSize) in CreateMessageQueue() argument
29 (void)(msgSize); in CreateMessageQueue()
|
| /foundation/multimedia/media_foundation/engine/include/foundation/utils/ |
| H A D | buffer_pool.h | 56 void Init(size_t msgSize = DEFAULT_FRAME_SIZE, Plugin::BufferMetaType type = Plugin::BufferMetaType::AUDIO, in Init()
59 if (msgSize_ == msgSize && align == align_) { in Init()
63 msgSize_ = msgSize; in Init()
68 buf->AllocMemory(nullptr, msgSize); in Init()
|
| /foundation/arkui/ace_engine_lite/frameworks/native_engine/async/ |
| H A D | message_queue_utils.cpp | 49 QueueHandler MessageQueueUtils::CreateMessageQueue(uint32_t capacity, uint32_t msgSize) in CreateMessageQueue() argument
51 if (capacity == 0 || msgSize == 0) { in CreateMessageQueue()
59 osMessageQueueId_t queueId = osMessageQueueNew(capacity, msgSize, nullptr); in CreateMessageQueue()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
| H A D | snapshot.cpp | 169 uint32_t msgSize = *reinterpret_cast<const uint32_t *>(dataBuffer); in Create() local
170 if (msgSize >= totalSize || msgSize + sizeof(uint32_t) >= totalSize) { in Create()
176 bool ret = dataParcel.WriteBuffer(dataBuffer, msgSize); in Create()
186 dataBuffer += msgSize; in Create()
187 uint32_t remainSize = totalSize - msgSize - sizeof(uint32_t); in Create()
|
| /foundation/ability/ability_runtime/services/appmgr/src/ |
| H A D | app_spawn_msg_wrapper.cpp | 85 size_t msgSize = sizeof(AppSpawnMsg) + 1; in AssembleMsg() local
86 msg_ = static_cast<AppSpawnMsg *>(malloc(msgSize)); in AssembleMsg()
91 if (memset_s(msg_, msgSize, 0, msgSize) != EOK) { in AssembleMsg()
|
| /foundation/communication/dsoftbus/core/common/message_handler/ |
| H A D | message_handler.c | 47 unsigned int msgSize; member
141 context->msgSize--; in LoopTask()
145 PRIu64 ", msgSize=%{public}u, time=%{public}" PRId64, in LoopTask()
146 context->name, msg->handler ? msg->handler->name : "null", msg->what, msg->arg1, context->msgSize, in LoopTask()
232 COMM_LOGW(COMM_UTILS, "many messages left unprocessed, msgSize=%{public}u", in DumpLooperLocked()
233 context->msgSize); in DumpLooperLocked()
333 context->msgSize++; in PostMessageAtTime()
403 context->msgSize--; in LoopRemoveMessageCustom()
|
| /foundation/arkui/ace_engine_lite/interfaces/inner_api/builtin/async/ |
| H A D | message_queue_utils.h | 113 * @param [in] msgSize: message size in bytes
116 static QueueHandler CreateMessageQueue(uint32_t capacity, uint32_t msgSize);
|
| /foundation/communication/dsoftbus/core/authentication/src/ |
| H A D | auth_session_message.c | 288 uint32_t msgSize = 0; in ProcessDeviceInfoMessage() local
292 if (DecryptInner(&sessionKeyList, info->connInfo.type, &inDataInfo, &msg, &msgSize) != SOFTBUS_OK) { in ProcessDeviceInfoMessage()
300 AUTH_LOGI(AUTH_FSM, "before decompress, msgSize=%{public}u", msgSize); in ProcessDeviceInfoMessage()
301 if (DataDecompress((uint8_t *)msg, msgSize, &decompressData, &decompressLen) != SOFTBUS_OK) { in ProcessDeviceInfoMessage()
316 devInfo.len = msgSize; in ProcessDeviceInfoMessage()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_engine.cpp | 518 int msgSize = 0; in MessageReciveCallbackInner() local
520 msgSize = GetMsgSize(inMsg); in MessageReciveCallbackInner()
521 if (msgSize <= 0) { in MessageReciveCallbackInner()
529 if ((queueCacheSize_ + msgSize) > maxQueueCacheSize_) { in MessageReciveCallbackInner()
536 PutMsgIntoQueue(targetDev, inMsg, msgSize); in MessageReciveCallbackInner()
552 void SyncEngine::PutMsgIntoQueue(const std::string &targetDev, Message *inMsg, int msgSize) in PutMsgIntoQueue() argument
567 queueCacheSize_ += msgSize; in PutMsgIntoQueue()
|
| H A D | sync_engine.h | 184 void PutMsgIntoQueue(const std::string &targetDev, Message *inMsg, int msgSize);
|