| /base/hiviewdfx/hilog/frameworks/libhilog/ioctl/ |
| D | log_ioctl.cpp | 78 int msgSize = pStats.tagNum * sizeof(TagStatsRsp); in ReceiveProcTagStats() local
79 if (msgSize == 0) { in ReceiveProcTagStats()
83 char* tmp = new (std::nothrow) char[msgSize]; in ReceiveProcTagStats()
88 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in ReceiveProcTagStats()
93 if (GetRsp(tmp, msgSize) != RET_SUCCESS) { in ReceiveProcTagStats()
109 int msgSize = pStats.typeNum * sizeof(LogTypeStatsRsp); in ReceiveProcLogTypeStats() local
110 if (msgSize == 0) { in ReceiveProcLogTypeStats()
113 char* tmp = new (std::nothrow) char[msgSize]; in ReceiveProcLogTypeStats()
118 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in ReceiveProcLogTypeStats()
123 if (GetRsp(tmp, msgSize) != RET_SUCCESS) { in ReceiveProcLogTypeStats()
[all …]
|
| /base/startup/init/services/param/linux/ |
| D | param_message.c | 48 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()
|
| D | param_request.c | 143 ssize_t sendLen = send(clientFd, (char *)request, request->msgSize, 0); in StartRequest()
167 size_t msgSize = sizeof(ParamMsgContent); in SystemSetParameter_() local
168 msgSize = (msgSize < RECV_BUFFER_MAX) ? RECV_BUFFER_MAX : msgSize; in SystemSetParameter_()
170 ParamMessage *request = (ParamMessage *)CreateParamMessage(MSG_SET_PARAM, name, msgSize); in SystemSetParameter_()
176 request->msgSize = offset + sizeof(ParamMessage); in SystemSetParameter_()
226 …uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + sizeof(ParamMsgContent) + size… in SystemWaitParameter() local
227 msgSize = (msgSize < RECV_BUFFER_MAX) ? RECV_BUFFER_MAX : msgSize; in SystemWaitParameter()
231 msgSize += PARAM_ALIGN(strlen(value) + 1); in SystemWaitParameter()
232 request = (ParamMessage *)CreateParamMessage(MSG_WAIT_PARAM, name, msgSize); in SystemWaitParameter()
236 msgSize += PARAM_ALIGN(1); in SystemWaitParameter()
[all …]
|
| D | param_msgadp.c | 37 if (((msg->msgSize + curr) > nread) in OnReceiveRequest()
39 || (msg->msgSize < sizeof(ParamMessage))) { in OnReceiveRequest()
42 curr += msg->msgSize; in OnReceiveRequest()
92 uint32_t dataSize = msg->msgSize; in ParamTaskSendMsg()
|
| D | param_message.h | 58 uint32_t msgSize; member
99 ParamMessage *CreateParamMessage(int type, const char *name, uint32_t msgSize);
|
| D | param_service.c | 92 response->msg.msgSize = sizeof(ParamResponseMessage); in SendResponseMsg()
102 uint32_t msgSize = sizeof(ParamMessage) + PARAM_ALIGN(strlen(content) + 1); in SendWatcherNotifyMessage() local
103 ParamMessage *msg = (ParamMessage *)CreateParamMessage(MSG_NOTIFY_PARAM, "*", msgSize); in SendWatcherNotifyMessage()
129 msg->msgSize = sizeof(ParamMessage) + offset; in SendWatcherNotifyMessage()
132 msg->id.msgId, msg->msgSize, content); in SendWatcherNotifyMessage()
311 PARAM_CHECK((msg != NULL) && (msg->msgSize >= sizeof(ParamMessage)), return -1, "Invalid msg"); in ProcessMessage()
|
| /base/hiviewdfx/hilog/services/hilogd/ |
| D | service_controller.cpp | 209 int msgSize = typeNum * sizeof(LogTypeDomainStatsRsp); in SendLogTypeDomainStats() local
210 if (msgSize == 0) { in SendLogTypeDomainStats()
213 char* tmp = new (std::nothrow) char[msgSize]; in SendLogTypeDomainStats()
217 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in SendLogTypeDomainStats()
234 m_communicationSocket->Write(tmp, msgSize); in SendLogTypeDomainStats()
246 int msgSize = dt.size() * sizeof(DomainStatsRsp); in SendDomainStats() local
247 char *tmp = new (std::nothrow) char[msgSize]; in SendDomainStats()
251 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in SendDomainStats()
271 m_communicationSocket->Write(tmp, msgSize); in SendDomainStats()
293 int msgSize = pTable.size() * sizeof(ProcStatsRsp); in SendProcStats() local
[all …]
|
| /base/security/huks/frameworks/huks_standard/main/crypto_engine/mbedtls/src/ |
| D | hks_crypto_ed25519.c | 39 #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
|
| /base/startup/init/test/unittest/param/ |
| D | watcher_proxy_unittest.cpp | 169 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()
|
| D | paramservice_unittest.cpp | 322 …uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + PARAM_ALIGN(strlen(value) + 1); in TestServiceProcessMessage() local
323 ParamMessage *request = (ParamMessage *)CreateParamMessage(MSG_SET_PARAM, name, msgSize); in TestServiceProcessMessage()
345 uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + sizeof(ParamMsgContent) in AddWatch() local
347 … ParamMessage *request = (ParamMessage *)(ParamMessage *)CreateParamMessage(type, name, msgSize); in AddWatch()
359 request->msgSize = offset + sizeof(ParamMessage); in AddWatch()
|
| D | param_unittest.cpp | 567 const int msgSize = sizeof(ParamMessage) + 128; // 128 TEST variable
568 ParamMessage *msg = CreateParamMessage(0, nullptr, msgSize);
574 "555555555555555555555555555555555555555555555555555555555555555555555", msgSize);
578 msg = CreateParamMessage(0, "22222222222222222222222222222222222222222", msgSize);
589 ret = FillParamMsgContent(msg, &start, 0, "22222", msgSize);
594 msg->msgSize = start + sizeof(ParamMessage);
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| D | control_fd.h | 73 uint16_t msgSize; member
|
| D | control_fd_client.c | 133 message->msgSize = bufferSize; in SendCmdMessage()
|
| /base/startup/init/services/param/watcher/proxy/ |
| D | watcher_manager.cpp | 146 request->msgSize = sizeof(ParamMessage); in SendMessage()
150 ssize_t sendLen = send(serverFd_, (char *)request, request->msgSize, 0); in SendMessage()
265 if ((msg->msgSize > dataLen) || ((curr + msg->msgSize) > dataLen)) { in RunLoop()
269 curr += msg->msgSize; in RunLoop()
|