| /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_request.c | 132 ssize_t sendLen = send(clientFd, (char *)request, request->msgSize, 0); in StartRequest()
153 size_t msgSize = sizeof(ParamMsgContent); in SystemSetParameter() local
154 msgSize = (msgSize < RECV_BUFFER_MAX) ? RECV_BUFFER_MAX : msgSize; in SystemSetParameter()
156 ParamMessage *request = (ParamMessage *)CreateParamMessage(MSG_SET_PARAM, name, msgSize); in SystemSetParameter()
162 request->msgSize = offset + sizeof(ParamMessage); in SystemSetParameter()
205 …uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + sizeof(ParamMsgContent) + size… in SystemWaitParameter() local
206 msgSize = (msgSize < RECV_BUFFER_MAX) ? RECV_BUFFER_MAX : msgSize; in SystemWaitParameter()
210 msgSize += PARAM_ALIGN(strlen(value) + 1); in SystemWaitParameter()
211 request = (ParamMessage *)CreateParamMessage(MSG_WAIT_PARAM, name, msgSize); in SystemWaitParameter()
215 msgSize += PARAM_ALIGN(1); in SystemWaitParameter()
[all …]
|
| 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()
63 ParamMessage *CreateParamMessage(int type, const char *name, uint32_t msgSize) in CreateParamMessage() argument
66 uint32_t size = msgSize; in CreateParamMessage()
67 if (msgSize < sizeof(ParamMessage)) { in CreateParamMessage()
74 msg->msgSize = size; in CreateParamMessage()
86 …f ((msg == NULL) || ((*offset + sizeof(ParamMessage) + sizeof(ParamMsgContent)) >= msg->msgSize)) { in GetNextContent()
|
| 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 | 96 response->msg.msgSize = sizeof(ParamResponseMessage); in SendResponseMsg()
106 uint32_t msgSize = sizeof(ParamMessage) + PARAM_ALIGN(strlen(content) + 1); in SendWatcherNotifyMessage() local
107 ParamMessage *msg = (ParamMessage *)CreateParamMessage(MSG_NOTIFY_PARAM, "*", msgSize); in SendWatcherNotifyMessage()
133 msg->msgSize = sizeof(ParamMessage) + offset; in SendWatcherNotifyMessage()
136 msg->id.msgId, msg->msgSize, content); in SendWatcherNotifyMessage()
314 PARAM_CHECK((msg != NULL) && (msg->msgSize >= sizeof(ParamMessage)), return -1, "Invalid msg"); in ProcessMessage()
|
| /base/hiviewdfx/hilog/services/hilogd/ |
| D | service_controller.cpp | 208 int msgSize = typeNum * sizeof(LogTypeDomainStatsRsp); in SendLogTypeDomainStats() local
209 if (msgSize == 0) { in SendLogTypeDomainStats()
212 char* tmp = new (std::nothrow) char[msgSize]; in SendLogTypeDomainStats()
216 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in SendLogTypeDomainStats()
233 m_communicationSocket->Write(tmp, msgSize); in SendLogTypeDomainStats()
245 int msgSize = dt.size() * sizeof(DomainStatsRsp); in SendDomainStats() local
246 char *tmp = new (std::nothrow) char[msgSize]; in SendDomainStats()
250 if (memset_s(tmp, msgSize, 0, msgSize) != 0) { in SendDomainStats()
270 m_communicationSocket->Write(tmp, msgSize); in SendDomainStats()
292 int msgSize = pTable.size() * sizeof(ProcStatsRsp); in SendProcStats() local
[all …]
|
| /base/startup/init/test/unittest/param/ |
| D | watcher_proxy_unittest.cpp | 141 uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + value.size(); in TestProcessWatcherMessage() local
142 msgSize = PARAM_ALIGN(msgSize); // align in TestProcessWatcherMessage()
143 std::vector<char> buffer(msgSize, 0); in TestProcessWatcherMessage()
147 msg->msgSize = msgSize; in TestProcessWatcherMessage()
|
| D | paramservice_unittest.cpp | 335 …uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + PARAM_ALIGN(strlen(value) + 1); in TestServiceProcessMessage() local
336 ParamMessage *request = (ParamMessage *)CreateParamMessage(MSG_SET_PARAM, name, msgSize); in TestServiceProcessMessage()
358 …uint32_t msgSize = sizeof(ParamMessage) + sizeof(ParamMsgContent) + PARAM_ALIGN(strlen(value) + 1); in AddWatch() local
359 … ParamMessage *request = (ParamMessage *)(ParamMessage *)CreateParamMessage(type, name, msgSize); in AddWatch()
|
| /base/startup/init/interfaces/innerkits/control_fd/ |
| D | control_fd.h | 73 uint16_t msgSize; member
|
| D | control_fd_client.c | 132 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()
256 if ((msg->msgSize > dataLen) || ((curr + msg->msgSize) > dataLen)) { in RunLoop()
260 curr += msg->msgSize; in RunLoop()
|