Home
last modified time | relevance | path

Searched refs:msgSize (Results 1 – 25 of 33) sorted by relevance

12

/ohos5.0/base/hiviewdfx/hilog/frameworks/libhilog/ioctl/
H A Dlog_ioctl.cpp79 if (msgSize == 0) { in ReceiveProcTagStats()
88 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in ReceiveProcTagStats()
110 if (msgSize == 0) { in ReceiveProcLogTypeStats()
118 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in ReceiveProcLogTypeStats()
140 if (msgSize == 0) { in ReceiveProcStats()
148 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in ReceiveProcStats()
181 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in ReceiveDomainTagStats()
204 if (msgSize == 0) { in ReceiveDomainStats()
212 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in ReceiveDomainStats()
234 if (msgSize == 0) { in ReceiveLogTypeDomainStats()
[all …]
/ohos5.0/base/startup/init/services/param/linux/
H A Dparam_request.c150 ssize_t sendLen = send(clientFd, (char *)request, request->msgSize, 0); in StartRequest()
175 size_t msgSize = sizeof(ParamMsgContent); in SystemSetParameter_() local
176 msgSize = (msgSize < RECV_BUFFER_MAX) ? RECV_BUFFER_MAX : msgSize; in SystemSetParameter_()
184 request->msgSize = offset + sizeof(ParamMessage); in SystemSetParameter_()
231 size_t msgSize = RECV_BUFFER_MAX; in SystemSaveParameters() local
241 request->msgSize = offset + sizeof(ParamMessage); in SystemSaveParameters()
261 msgSize = (msgSize < RECV_BUFFER_MAX) ? RECV_BUFFER_MAX : msgSize; in SystemWaitParameter()
265 msgSize += PARAM_ALIGN(strlen(value) + 1); in SystemWaitParameter()
266 request = (ParamMessage *)CreateParamMessage(MSG_WAIT_PARAM, name, msgSize); in SystemWaitParameter()
270 msgSize += PARAM_ALIGN(1); in SystemWaitParameter()
[all …]
H A Dparam_message.c48 uint32_t bufferSize = request->msgSize - sizeof(ParamMessage); in FillParamMsgContent()
51 return -1, "Invalid msgSize %u offset %u %d", request->msgSize, offset, type); in FillParamMsgContent()
65 ParamMessage *CreateParamMessage(int type, const char *name, uint32_t msgSize) in CreateParamMessage() argument
68 PARAM_CHECK(msgSize < PARAM_BUFFER_MAX, return NULL, "Invalid msg size %u", msgSize); in CreateParamMessage()
69 uint32_t size = msgSize; in CreateParamMessage()
70 if (msgSize < sizeof(ParamMessage)) { in CreateParamMessage()
77 msg->msgSize = size; in CreateParamMessage()
89 if ((*offset + sizeof(ParamMessage) + sizeof(ParamMsgContent)) >= msg->msgSize) { in GetNextContent()
H A Dparam_msgadp.c37 if ((nread - curr < msg->msgSize) || in OnReceiveRequest()
39 (msg->msgSize < sizeof(ParamMessage))) { in OnReceiveRequest()
42 curr += msg->msgSize; in OnReceiveRequest()
92 uint32_t dataSize = msg->msgSize; in ParamTaskSendMsg()
H A Dparam_message.h59 uint32_t msgSize; member
100 ParamMessage *CreateParamMessage(int type, const char *name, uint32_t msgSize);
H A Dparam_service.c94 response->msg.msgSize = sizeof(ParamResponseMessage); in SendResponseMsg()
104 uint32_t msgSize = sizeof(ParamMessage) + PARAM_ALIGN(strlen(content) + 1); in SendWatcherNotifyMessage() local
105 ParamMessage *msg = (ParamMessage *)CreateParamMessage(MSG_NOTIFY_PARAM, "*", msgSize); in SendWatcherNotifyMessage()
131 msg->msgSize = sizeof(ParamMessage) + offset; in SendWatcherNotifyMessage()
134 msg->id.msgId, msg->msgSize, content); in SendWatcherNotifyMessage()
335 PARAM_CHECK((msg != NULL) && (msg->msgSize >= sizeof(ParamMessage)), return -1, "Invalid msg"); in ProcessMessage()
/ohos5.0/base/hiviewdfx/hilog/services/hilogd/
H A Dservice_controller.cpp222 if (msgSize == 0) { in SendLogTypeDomainStats()
229 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in SendLogTypeDomainStats()
246 m_communicationSocket->Write(tmp, msgSize); in SendLogTypeDomainStats()
263 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in SendDomainStats()
306 if (msgSize == 0) { in SendProcStats()
313 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in SendProcStats()
344 m_communicationSocket->Write(tmp, msgSize); in SendProcStats()
361 if (msgSize == 0) { in SendProcLogTypeStats()
368 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in SendProcLogTypeStats()
403 if (msgSize == 0) { in SendTagStats()
[all …]
/ohos5.0/base/security/huks/frameworks/huks_standard/main/crypto_engine/mbedtls/src/
H A Dhks_crypto_ed25519.c39 #define ED25519_SIGN(sig, msgData, msgSize, pub, priv) ED25519_sign((sig), (msgData), (msgSize), (p… argument
40 #define ED25519_VERIFY(msgData, msgSize, sig, pub) ED25519_verify((msgData), (msgSize), (sig), (pub… argument
44 #define ED25519_SIGN(sig, msgData, msgSize, pub, priv) \ argument
45 ossl_ed25519_sign((sig), (msgData), (msgSize), (pub), (priv), NULL, NULL)
46 #define ED25519_VERIFY(msgData, msgSize, sig, pub) ossl_ed25519_verify((msgData), (msgSize), (sig),… argument
/ohos5.0/drivers/peripheral/pin_auth/hdi_service/main/src/
H A Dcollector_func.c166 …64_t scheduleId, const uint8_t *extraInfo, uint32_t extraInfoSize, uint8_t *msg, uint32_t *msgSize) in DoCollect() argument
170 (msg == NULL) || (msgSize == NULL) || ((*msgSize) == 0)) { in DoCollect()
193 result = FormatTlvMsg(attribute, g_keyPair, msg, msgSize); in DoCollect()
265 int32_t DoSendMessageToCollector(uint64_t scheduleId, const uint8_t *msg, uint32_t msgSize, AlgoPar… in DoSendMessageToCollector() argument
269 (msg == NULL) || (msgSize == 0) || (algoParam == NULL)) { in DoSendMessageToCollector()
274 …sult = VerifyAndGetDataAttribute(scheduleId, &data, g_collectorSchedule->peerPubKey, msg, msgSize); in DoSendMessageToCollector()
386 uint64_t scheduleId, uint8_t *pinData, uint32_t pinDataSize, uint8_t *msg, uint32_t *msgSize) in DoSetDataToCollector() argument
392 … (pinData == NULL) || (pinDataSize != CONST_PIN_DATA_LEN) || (msg == NULL) || ((*msgSize) == 0)) { in DoSetDataToCollector()
408 result = FormatTlvMsg(attribute, g_keyPair, msg, msgSize); in DoSetDataToCollector()
H A Dexecutor_func_common.c157 int32_t FormatTlvMsg(const Attribute *data, const KeyPair *keyPair, uint8_t *msg, uint32_t *msgSize) in FormatTlvMsg() argument
159 if ((data == NULL) || !IsEd25519KeyPairValid(keyPair) || (msg == NULL) || (msgSize == NULL)) { in FormatTlvMsg()
165 .len = *msgSize, in FormatTlvMsg()
185 uint8Array.len = *msgSize; in FormatTlvMsg()
191 *msgSize = uint8Array.len; in FormatTlvMsg()
198 static Attribute *GetRootAttributeFromTlv(const uint8_t *msg, uint32_t msgSize) in GetRootAttributeFromTlv() argument
202 .len = msgSize, in GetRootAttributeFromTlv()
240 … uint64_t scheduleId, Attribute **data, const Buffer *pubKey, const uint8_t *msg, uint32_t msgSize) in VerifyAndGetDataAttribute() argument
247 Attribute *attributeRoot = GetRootAttributeFromTlv(msg, msgSize); in VerifyAndGetDataAttribute()
/ohos5.0/drivers/peripheral/pin_auth/hdi_service/main/inc/
H A Dcollector_func.h30 …4_t scheduleId, const uint8_t *extraInfo, uint32_t extraInfoSize, uint8_t *msg, uint32_t *msgSize);
32 int32_t DoSendMessageToCollector(uint64_t scheduleId, const uint8_t *msg, uint32_t msgSize, AlgoPar…
34 …int64_t scheduleId, uint8_t *pinData, const uint32_t pinDataSize, uint8_t *msg, uint32_t *msgSize);
H A Dexecutor_func_common.h77 int32_t FormatTlvMsg(const Attribute *data, const KeyPair *keyPair, uint8_t *msg, uint32_t *msgSize…
79 …uint64_t scheduleId, Attribute **data, const Buffer *pubKey, const uint8_t *msg, uint32_t msgSize);
/ohos5.0/foundation/arkui/ace_engine_lite/frameworks/native_engine/async/
H A Dmessage_queue_utils.cpp49 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()
/ohos5.0/foundation/multimedia/media_foundation/engine/include/foundation/utils/
H A Dbuffer_pool.h56 …void Init(size_t msgSize = DEFAULT_FRAME_SIZE, Plugin::BufferMetaType type = Plugin::BufferMetaTyp…
59 if (msgSize_ == msgSize && align == align_) {
63 msgSize_ = msgSize;
68 buf->AllocMemory(nullptr, msgSize);
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
H A Dsnapshot.cpp169 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()
/ohos5.0/drivers/hdf_core/framework/support/platform/src/i2c/
H A Di2c_msg.c45 size_t msgSize = sizeof(struct I2cMsg) * count; in RebuildMsgs() local
48 msgs = OsalMemCalloc(msgSize + sizeof(void *)); in RebuildMsgs()
53 bufReply = (uint8_t **)((uint8_t *)msgs + msgSize); in RebuildMsgs()
/ohos5.0/base/startup/init/test/unittest/param/
H A Dwatcher_proxy_unittest.cpp169 uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + value.size(); in TestProcessWatcherMessage() local
170 msgSize = PARAM_ALIGN(msgSize); // align in TestProcessWatcherMessage()
171 std::vector<char> buffer(msgSize, 0); in TestProcessWatcherMessage()
175 msg->msgSize = msgSize; in TestProcessWatcherMessage()
H A Dparamservice_unittest.cpp321 …uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + PARAM_ALIGN(strlen(value) + 1); in TestServiceProcessMessage() local
322 ParamMessage *request = (ParamMessage *)CreateParamMessage(MSG_SET_PARAM, name, msgSize); in TestServiceProcessMessage()
344 uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + sizeof(ParamMsgContent) in AddWatch() local
346 … ParamMessage *request = (ParamMessage *)(ParamMessage *)CreateParamMessage(type, name, msgSize); in AddWatch()
358 request->msgSize = offset + sizeof(ParamMessage); in AddWatch()
H A Dparam_unittest.cpp565 const int msgSize = sizeof(ParamMessage) + 128; // 128 TEST variable
566 ParamMessage *msg = CreateParamMessage(0, nullptr, msgSize);
572 "555555555555555555555555555555555555555555555555555555555555555555555", msgSize);
576 msg = CreateParamMessage(0, "22222222222222222222222222222222222222222", msgSize);
587 ret = FillParamMsgContent(msg, &start, 0, "22222", msgSize);
592 msg->msgSize = start + sizeof(ParamMessage);
/ohos5.0/foundation/arkui/ace_engine_lite/frameworks/tools/qt/simulator/jsfwk/targets/simulator/mock/
H A Dmessage_queue_utils.cpp26 QueueHandler MessageQueueUtils::CreateMessageQueue(uint32_t capacity, uint32_t msgSize) in CreateMessageQueue() argument
29 (void)(msgSize); in CreateMessageQueue()
/ohos5.0/foundation/ability/ability_runtime/services/appmgr/src/
H A Dapp_spawn_msg_wrapper.cpp85 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()
/ohos5.0/foundation/communication/dsoftbus/core/common/message_handler/
H A Dmessage_handler.c47 unsigned int msgSize; member
141 context->msgSize--; in LoopTask()
146 … context->name, msg->handler ? msg->handler->name : "null", msg->what, msg->arg1, context->msgSize, in LoopTask()
233 context->msgSize); in DumpLooperLocked()
333 context->msgSize++; in PostMessageAtTime()
403 context->msgSize--; in LoopRemoveMessageCustom()
/ohos5.0/foundation/communication/dsoftbus/core/authentication/src/
H A Dauth_session_message.c288 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()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_engine.cpp518 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()
/ohos5.0/base/startup/init/interfaces/innerkits/control_fd/
H A Dcontrol_fd.h76 uint16_t msgSize; member

12