/test/testfwk/developer_test/aw/cxx/distributed/ |
D | distributed_major.cpp | 291 bool DistributeTestEnvironment::SendMessage(size_t devNo, const std::string &strMsg, int msgLen, in SendMessage() argument 295 if ((msgLen + DST_COMMAND_HEAD_LEN) <= MAX_BUFF_LEN) { in SendMessage() 299 …et = memcpy_s(pCmdTest->alignmentCmd, MAX_BUFF_LEN - DST_COMMAND_HEAD_LEN, strMsg.c_str(), msgLen); in SendMessage() 303 pCmdTest->len = msgLen; in SendMessage() 304 breturn = SendToAgent(devNo, DST_COMMAND_MSG, pCmdTest, msgLen, onProcessReturnMsg); in SendMessage() 311 bool DistributeTestEnvironment::Notify(size_t devNo, const std::string &strMsg, int msgLen) in Notify() argument 314 if (msgLen < 0 || msgLen >= dstMax) { in Notify() 319 if ((msgLen + DST_COMMAND_HEAD_LEN) <= MAX_BUFF_LEN) { in Notify() 323 errno_t ret = memcpy_s(pCmdTest->alignmentCmd, dstMax, strMsg.c_str(), msgLen); in Notify() 327 pCmdTest->alignmentCmd[msgLen] = 0; in Notify() [all …]
|
D | distributed_major.h | 46 bool SendMessage(size_t devNo, const std::string &strMsg, int msgLen, 49 bool Notify(size_t devNo, const std::string &strMsg, int msgLen); 90 bool Notify(AGENT_NO devNo, const std::string ¬ifyType, const std::string &msg, int msgLen);
|
D | distributed_agent.h | 53 …virtual int OnProcessMsg(const std::string &strMsg, int msgLen, std::string &strReturnValue, int r… 54 virtual int OnNotify(const std::string ¬ifyType, const std::string &msg, int msgLen);
|
D | distributed_agent.cpp | 306 int DistributedAgent::OnProcessMsg(const std::string &strMsg, int msgLen, in OnProcessMsg() argument 403 int DistributedAgent::OnNotify(const std::string ¬ifyType, const std::string &msg, int msgLen) in OnNotify() argument 408 if (msgLen < 0) { in OnNotify()
|
/test/xts/hats/hdf/wlan/hdi_service/ |
D | wlan_callback_impl.c | 97 …int32_t WlanCallbackNetlinkMessage(struct IWlanCallback *self, const uint8_t *msg, uint32_t msgLen) in WlanCallbackNetlinkMessage() argument 107 for (i = 0; i < msgLen; i++) { in WlanCallbackNetlinkMessage()
|
/test/xts/device_attest_lite/services/core/network/ |
D | attest_coap.c | 352 size_t msgLen = 0; in CoapCopyMessage() local 358 if ((ret = CoapGetExtensionLen(len, &msgLen)) != 0) { in CoapCopyMessage() 371 pkt->len = buf->len + msgLen; in CoapCopyMessage()
|
D | attest_network.c | 884 uint8_t msgLen = ((msgLenTkl[0] & 0xF0) >> COAP_BITS_HEADER_LEN); in DecodeLenTkl() local 886 coapPkt->hdr.len = msgLen; in DecodeLenTkl() 891 if ((ret = CoapGetExtensionLen(msgLen, &extendedLengthSize)) != 0) { in DecodeLenTkl() 894 if ((ret = DecodeExtendedLength(session, msgLen, extendedLengthSize, &extendedLength)) != 0) { in DecodeLenTkl()
|
/test/xts/device_attest/services/core/network/ |
D | attest_network.c | 834 uint32_t msgLen = headerLen + bodyLen + 1; in BuildHttpsMsg() local 835 char *msg = (char *)ATTEST_MEM_MALLOC(msgLen); in BuildHttpsMsg() 841 int32_t ret = memcpy_s(msg, msgLen, header, headerLen); in BuildHttpsMsg() 847 ret = memcpy_s(msg + headerLen, msgLen - headerLen, body, bodyLen); in BuildHttpsMsg()
|
/test/xts/acts/kernel_lite/net_posix/src/ |
D | ActsNetTest.cpp | 1138 unsigned int msgLen = strlen(msg); variable 1139 ret = sendto(udpFd, msg, msgLen, 0, (struct sockaddr*)&clnAddr, (socklen_t)sizeof(clnAddr)); 1141 EXPECT_EQ(msgLen, (unsigned int)ret); 1145 EXPECT_EQ(msgLen, (unsigned int)bytes);
|