/openthread-latest/tests/scripts/thread-cert/ |
D | test_coap_observe.py | 74 response = self.nodes[ROUTER].coap_observe(mleid, 'test', con=con) 76 first_observe = response['observe'] 78 self.assertEqual(response['payload'], 'Test123') 79 self.assertEqual(response['source'], mleid) 91 response = self.nodes[ROUTER].coap_wait_response() 92 self.assertGreater(response['observe'], first_observe) 93 self.assertEqual(response['payload'], content) 94 self.assertEqual(response['source'], mleid) 100 response = self.nodes[ROUTER].coap_wait_response() 101 self.assertIsNone(response['observe']) [all …]
|
D | test_coap_block.py | 75 response = self.nodes[ROUTER].coap_get_block(mleid, 'test', size=32) 76 response_payload = response['payload']
|
D | mle.py | 237 def __init__(self, response): argument 238 self._response = response 241 def response(self): member in Response 247 return self.response == other.response 250 return "Response(response={})".format(hexlify(self.response)) 256 response = data.read() 257 return Response(response)
|
D | command.py | 494 response=CheckType.OPTIONAL, 510 check_mle_optional_tlv(command_msg, response, mle.Response) 623 response = assert_contains_tlv(tlvs, CheckType.CONTAIN, mesh_cop.DiscoveryResponse) 626 assert response.version == config.THREAD_VERSION_1_1 628 assert response.version == config.THREAD_VERSION_1_2 634 check_type = (CheckType.CONTAIN if response.native_flag else CheckType.OPTIONAL)
|
D | test_mle.py | 561 response = any_response() 563 response_obj = mle.Response(response) 566 actual_response = response_obj.response 569 self.assertEqual(response, actual_response) 576 response = any_response() 580 data = response 587 self.assertEqual(response, actual_response.response)
|
/openthread-latest/src/core/coap/ |
D | coap.cpp | 788 Message *response = nullptr; in ProcessBlock1Request() local 805 VerifyOrExit((response = NewMessage()) != nullptr, error = kErrorFailed); in ProcessBlock1Request() 806 response->Init(kTypeAck, kCodeContinue); in ProcessBlock1Request() 807 response->SetMessageId(aMessage.GetMessageId()); in ProcessBlock1Request() 808 … IgnoreReturnValue(response->SetToken(AsConst(aMessage).GetToken(), aMessage.GetTokenLength())); in ProcessBlock1Request() 810 response->SetBlockWiseBlockNumber(aMessage.GetBlockWiseBlockNumber()); in ProcessBlock1Request() 811 response->SetMoreBlocksFlag(aMessage.IsMoreBlocksFlagSet()); in ProcessBlock1Request() 812 response->SetBlockWiseBlockSize(aMessage.GetBlockWiseBlockSize()); in ProcessBlock1Request() 814 …SuccessOrExit(error = response->AppendBlockOption(Message::kBlockType1, response->GetBlockWiseBloc… in ProcessBlock1Request() 815 response->IsMoreBlocksFlagSet(), in ProcessBlock1Request() [all …]
|
/openthread-latest/tools/tcat_ble_client/cli/ |
D | base_commands.py | 84 response = await bless.send_with_resp(data) 85 if not response: 87 tlv_response = TLV.from_bytes(response) 238 response = await bless.send_with_resp(data) 239 if not response: 241 tlv_response = TLV.from_bytes(response) 270 response = await bless.send_with_resp(data) 271 if not response: 273 tlv_response = TLV.from_bytes(response) 302 response = await bless.send_with_resp(data) [all …]
|
/openthread-latest/tools/harness-simulation/harness/Thread_Harness/Sniffer/ |
D | SimSniffer.py | 259 …response = self._stub.Start(sniffer_pb2.StartRequest(channel=self.channel, includeEthernet=include… 260 if response.status != sniffer_pb2.OK: 261 raise RuntimeError('startSniffer error: %s' % sniffer_pb2.Status.Name(response.status)) 272 for response in self._stub.TransferPcapng(sniffer_pb2.TransferPcapngRequest()): 273 f.write(response.content) 281 response = self._stub.Stop(sniffer_pb2.StopRequest()) 282 if response.status != sniffer_pb2.OK: 283 raise RuntimeError('stopSniffer error: %s' % sniffer_pb2.Status.Name(response.status)) 297 response = self._stub.FilterNodes(request) 298 if response.status != sniffer_pb2.OK: [all …]
|
/openthread-latest/src/core/net/ |
D | dns_client.cpp | 589 for (const Response *response = this; response != nullptr; response = response->mNext) in GetServiceInfo() local 591 Name name(*response->mQuery, kNameOffsetInQuery); in GetServiceInfo() 596 info.ReadFrom(*response->mQuery); in GetServiceInfo() 604 IgnoreError(response->FindHostAddress(kAnswerSection, name, /* aIndex */ 0, in GetServiceInfo() 630 error = response->ReadServiceInfo(srvSection, name, aServiceInfo); in GetServiceInfo() 639 SuccessOrExit(error = response->ReadTxtRecord(txtSection, name, aServiceInfo)); in GetServiceInfo() 658 for (const Response *response = this; response != nullptr; response = response->mNext) in GetHostAddress() local 663 info.ReadFrom(*response->mQuery); in GetHostAddress() 678 error = response->FindHostAddress(section, Name(aHostName), aIndex, aAddress, aTtl); in GetHostAddress() 1217 Response response; in FinalizeQuery() local [all …]
|
D | dnssd_server.cpp | 157 Response response(GetInstance()); in ProcessQuery() local 178 SuccessOrExit(response.AllocateAndInitFrom(aRequest)); in ProcessQuery() 187 SuccessOrExit(rcode = response.AddQuestionsFrom(aRequest)); in ProcessQuery() 190 response.Log(); in ProcessQuery() 194 switch (response.ResolveBySrp()) in ProcessQuery() 210 ResolveByProxy(response, *aRequest.mMessageInfo); in ProcessQuery() 215 response.SetResponseCode(rcode); in ProcessQuery() 220 response.Send(*aRequest.mMessageInfo); in ProcessQuery() 1277 Response response(GetInstance()); in HandleDiscoveredServiceInstance() local 1279 RemoveQueryAndPrepareResponse(query, info, response); in HandleDiscoveredServiceInstance() [all …]
|
D | srp_server.cpp | 1465 Message *response = nullptr; in SendResponse() local 1470 response = GetSocket().NewMessage(); in SendResponse() 1471 VerifyOrExit(response != nullptr, error = kErrorNoBufs); in SendResponse() 1477 SuccessOrExit(error = response->Append(header)); in SendResponse() 1479 SuccessOrExit(error = GetSocket().SendTo(*response, aMessageInfo)); in SendResponse() 1494 FreeMessageOnError(response, error); in SendResponse() 1504 Message *response = nullptr; in SendResponse() local 1510 response = GetSocket().NewMessage(); in SendResponse() 1511 VerifyOrExit(response != nullptr, error = kErrorNoBufs); in SendResponse() 1518 SuccessOrExit(error = response->Append(header)); in SendResponse() [all …]
|
D | dns_dso.cpp | 1021 Message *response = NewMessage(); in SendErrorResponse() local 1024 VerifyOrExit(response != nullptr); in SendErrorResponse() 1031 SuccessOrExit(response->Prepend(header)); in SendErrorResponse() 1033 otPlatDsoSend(this, response); in SendErrorResponse() 1034 response = nullptr; in SendErrorResponse() 1037 FreeMessage(response); in SendErrorResponse()
|
/openthread-latest/src/core/meshcop/ |
D | tcat_agent.cpp | 372 bool response = false; in HandleSingleTlv() local 400 response = true; // true - to avoid response-with-status being sent. in HandleSingleTlv() 419 response = true; in HandleSingleTlv() 428 error = HandlePing(aIncomingMessage, aOutgoingMessage, offset, length, response); in HandleSingleTlv() 431 error = HandleGetNetworkName(aOutgoingMessage, response); in HandleSingleTlv() 434 error = HandleGetDeviceId(aOutgoingMessage, response); in HandleSingleTlv() 437 error = HandleGetExtPanId(aOutgoingMessage, response); in HandleSingleTlv() 440 error = HandleGetProvisioningUrl(aOutgoingMessage, response); in HandleSingleTlv() 452 error = HandleRequestRandomNumberChallenge(aOutgoingMessage, response); in HandleSingleTlv() 455 … error = HandleRequestPskdHash(aIncomingMessage, aOutgoingMessage, offset, length, response); in HandleSingleTlv() [all …]
|
D | dataset_manager.cpp | 536 Coap::Message *response = ProcessGetRequest(aMessage, kCheckSecurityPolicyFlags); in HandleGet() local 538 VerifyOrExit(response != nullptr); in HandleGet() 539 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*response, aMessageInfo)); in HandleGet() 545 FreeMessageOnError(response, error); in HandleGet() 555 Coap::Message *response = nullptr; in ProcessGetRequest() local 585 response = Get<Tmf::Agent>().NewPriorityResponseMessage(aRequest); in ProcessGetRequest() 586 VerifyOrExit(response != nullptr, error = kErrorNoBufs); in ProcessGetRequest() 605 SuccessOrExit(error = tlv->AppendTo(*response)); in ProcessGetRequest() 610 FreeAndNullMessageOnError(response, error); in ProcessGetRequest() 611 return response; in ProcessGetRequest()
|
D | border_agent.cpp | 732 Coap::Message *response = nullptr; in HandleTmfDatasetGet() local 743 …response = Get<ActiveDatasetManager>().ProcessGetRequest(aMessage, DatasetManager::kIgnoreSecurity… in HandleTmfDatasetGet() 748 …response = Get<PendingDatasetManager>().ProcessGetRequest(aMessage, DatasetManager::kIgnoreSecurit… in HandleTmfDatasetGet() 753 response = Get<NetworkData::Leader>().ProcessCommissionerGetRequest(aMessage); in HandleTmfDatasetGet() 760 VerifyOrExit(response != nullptr, error = kErrorParse); in HandleTmfDatasetGet() 762 SuccessOrExit(error = mCoapDtlsSession->SendMessage(*response)); in HandleTmfDatasetGet() 768 FreeMessageOnError(response, error); in HandleTmfDatasetGet()
|
/openthread-latest/src/cli/ |
D | README_COAP.md | 29 coap response from [fdde:ad00:beef:0:2780:9423:166c:1aac] with payload: 30 32 coap response from [fdde:ad00:beef:0:2780:9423:166c:1aac] 41 coap response sent 43 coap response sent 109 …non-con" for Non-confirmable (default). Use "block-<block-size>" if the response should be transfe… 138 - type: "request" for CoAP requests and "response" for CoAP responses.
|
D | README_COAPS.md | 52 coaps response from fdde:ad00:beef:0:9903:14b:27e0:5744 with payload: 68656c6c6f576f726c6400 55 coaps response from fdde:ad00:beef:0:9903:14b:27e0:5744 64 coaps response sent 66 coaps response sent 162 …non-con" for Non-confirmable (default). Use "block-<block-size>" if the response should be transfe…
|
/openthread-latest/src/posix/platform/ |
D | resolver.cpp | 196 char response[kMaxDnsMessageSize]; in ForwardResponse() local 201 VerifyOrExit((readSize = read(aTxn->mUdpFd, response, sizeof(response))) > 0); in ForwardResponse() 205 SuccessOrExit(error = otMessageAppend(message, response, readSize)); in ForwardResponse()
|
/openthread-latest/third_party/mbedtls/repo/programs/ |
D | README.md | 65 …ple DTLS client program, which sends one datagram to the server and reads one datagram in response. 67 …, which expects one datagram from the client and writes one datagram in response. This program sup… 71 …c`](ssl/ssl_client1.c): a simple HTTPS client that sends a fixed request and displays the response. 73 ….c): a simple HTTPS server using one process per client to send a fixed response. This program req… 77 …r.c): a simple HTTPS server using one thread per client to send a fixed response. This program req… 79 * [`ssl/ssl_server.c`](ssl/ssl_server.c): a simple HTTPS server that sends a fixed response. It ser… 85 …client2.c): an HTTPS client that sends a fixed request and displays the response, with options to … 87 * [`ssl/ssl_server2.c`](ssl/ssl_server2.c): an HTTPS server that sends a fixed response, with optio…
|
/openthread-latest/src/core/thread/ |
D | network_data_leader.cpp | 572 Coap::Message *response = nullptr; in ProcessCommissionerGetRequest() local 575 response = Get<Tmf::Agent>().NewPriorityResponseMessage(aMessage); in ProcessCommissionerGetRequest() 576 VerifyOrExit(response != nullptr, error = kErrorNoBufs); in ProcessCommissionerGetRequest() 594 SuccessOrExit(error = subTlv->AppendTo(*response)); in ProcessCommissionerGetRequest() 606 SuccessOrExit(error = response->AppendBytes(dataTlv->GetValue(), dataTlv->GetLength())); in ProcessCommissionerGetRequest() 611 FreeAndNullMessageOnError(response, error); in ProcessCommissionerGetRequest() 612 return response; in ProcessCommissionerGetRequest()
|
D | network_diagnostic.cpp | 793 Coap::Message *response = nullptr; in HandleTmf() local 800 response = Get<Tmf::Agent>().NewResponseMessage(aMessage); in HandleTmf() 801 VerifyOrExit(response != nullptr, error = kErrorNoBufs); in HandleTmf() 803 IgnoreError(response->SetPriority(aMessage.GetPriority())); in HandleTmf() 804 SuccessOrExit(error = AppendRequestedTlvs(aMessage, *response)); in HandleTmf() 805 SuccessOrExit(error = Get<Tmf::Agent>().SendMessage(*response, aMessageInfo)); in HandleTmf() 808 FreeMessageOnError(response, error); in HandleTmf()
|
/openthread-latest/src/core/api/ |
D | coap_api.cpp | 54 Coap::Message &response = AsCoapMessage(aResponse); in otCoapMessageInitResponse() local 57 response.Init(MapEnum(aType), MapEnum(aCode)); in otCoapMessageInitResponse() 58 response.SetMessageId(request.GetMessageId()); in otCoapMessageInitResponse() 60 return response.SetTokenFromMessage(request); in otCoapMessageInitResponse()
|
/openthread-latest/tests/scripts/expect/ |
D | tun-sntp.exp | 40 expect -re {SNTP response - Unix time: \d+ \(era: \d+\)}
|
/openthread-latest/tests/unit/ |
D | test_dns_client.cpp | 376 const Dns::Client::AddressResponse &response = AsCoreType(aResponse); in AddressCallback() local 388 SuccessOrQuit(response.GetHostName(sAddressInfo.mHostName, sizeof(sAddressInfo.mHostName))); in AddressCallback() 398 error = response.GetAddress(index, sAddressInfo.mHostAddresses[index], ttl); in AddressCallback() 431 const Dns::Client::BrowseResponse &response = AsCoreType(aResponse); in BrowseCallback() local 443 …SuccessOrQuit(response.GetServiceName(sBrowseInfo.mServiceName, sizeof(sBrowseInfo.mServiceName))); in BrowseCallback() 451 error = response.GetServiceInstance(index, instLabel, sizeof(instLabel)); in BrowseCallback() 497 const Dns::Client::ServiceResponse &response = AsCoreType(aResponse); in ServiceCallback() local 506 …SuccessOrQuit(response.GetServiceName(instLabel, sizeof(instLabel), serviceName, sizeof(serviceNam… in ServiceCallback() 514 SuccessOrQuit(response.GetServiceInfo(sResolveServiceInfo.mInfo)); in ServiceCallback() 521 error = response.GetHostAddress(sResolveServiceInfo.mInfo.mHostNameBuffer, index, in ServiceCallback()
|
D | test_srp_server.cpp | 1074 Message *response; in TestSrpClientDelayedResponse() local 1157 response = udpSocket.NewMessage(); in TestSrpClientDelayedResponse() 1158 VerifyOrQuit(response != nullptr); in TestSrpClientDelayedResponse() 1165 SuccessOrQuit(response->Append(header)); in TestSrpClientDelayedResponse() 1166 SuccessOrQuit(udpSocket.SendTo(*response, sServerMsgInfo)); in TestSrpClientDelayedResponse()
|