| /openthread-latest/tests/scripts/thread-cert/ |
| D | test_srp_register_services_diff_lease.py | 104 service = services[0] 105 self.assertEqual(service['fullname'], 'ins1._test._udp.default.service.arpa.') 106 self.assertEqual(service['deleted'], 'false') 107 self.assertEqual(int(service['ttl']), 60) 108 self.assertEqual(int(service['lease']), 60) 109 self.assertEqual(int(service['key-lease']), 800) 122 for service in server_services: 123 if service['fullname'] == 'ins1._test._udp.default.service.arpa.': 124 self.assertEqual(service['deleted'], 'false') 125 self.assertEqual(int(service['ttl']), 60) [all …]
|
| D | test_srp_register_500_services.py | 159 all_registered = all(service['state'] == 'Registered' for service in client_services) 169 for service in client_services: 170 self.assertEqual(service['name'], SERVICE_NAME) 171 self.assertEqual(service['state'], 'Registered') 172 self.assertEqual(int(service['port']), SERVICE_PORT) 173 self.assertIn(service['instance'], service_instance_names) 174 service_instance_names.discard(service['instance']) 184 for service in server_services: 185 self.assertEqual(service['name'], SERVICE_NAME) 186 self.assertIn(service['instance'], service_instance_names) [all …]
|
| D | test_dnssd_name_with_special_chars.py | 104 … service = client.dns_resolve_service(SPECIAL_INSTANCE_NAME, '_srv._udp.default.service.arpa') 105 self.__verify_service(service) 107 …service = client.dns_resolve_service(SPECIAL_INSTANCE_NAME.lower(), '_srv._udp.default.service.arp… 108 self.__verify_service(service) 110 def __verify_service(self, service): argument 111 logging.info('service discovered: %r', service) 112 self.assertEqual(service['port'], 1977) 113 self.assertEqual(service['host'], 'host1.default.service.arpa.')
|
| D | test_netdata_publisher.py | 133 def verify_anycast_service(self, service): argument 136 self.assertEqual(int(service[0]), THREAD_ENTERPRISE_NUMBER) 138 service_data = bytes.fromhex(service[1]) 143 self.assertEqual(service[3], 's') 147 for service in services: 148 self.verify_anycast_service(service) 150 def verify_unicast_service(self, service): argument 153 self.assertEqual(int(service[0]), THREAD_ENTERPRISE_NUMBER) 155 service_data = bytes.fromhex(service[1]) 159 self.assertEqual(service[3], 's') [all …]
|
| D | test_srp_many_services_mtu_check.py | 116 for service in client_services: 117 self.assertEqual(service['state'], 'Registered') 136 for service in server_services: 137 self.assertEqual(service['deleted'], 'true')
|
| D | test_network_data.py | 118 def convert_service_to_bytearray(service): argument 121 ((service.t & 0x01) << 7) | ((service.id) & 0x0F), 122 service.enterprise_number, 123 service.service_data_length, 124 ) + service.service_data + convert_service_sub_tlvs_to_bytearray(service.sub_tlvs)) 893 service = network_data.Service( 904 actual_t = service.t 913 service = network_data.Service( 924 actual_id = service.id 933 service = network_data.Service( [all …]
|
| /openthread-latest/tests/toranj/cli/ |
| D | test-400-srp-client-server.py | 95 service = services[0] variable 96 verify(service['instance'] == 'ins') 97 verify(service['name'] == '_test._udp') 98 verify(service['state'] == 'Registered') 99 verify(service['port'] == '777') 100 verify(service['priority'] == '2') 101 verify(service['weight'] == '1') 114 service = services[0] variable 115 verify(service['instance'] == 'ins') 116 verify(service['name'] == '_test._udp') [all …]
|
| D | cli.py | 764 service = {} 765 service['fullname'] = outputs.pop(0).strip() 766 name_labels = service['fullname'].split('.') 767 service['instance'] = name_labels[0] 768 service['name'] = '.'.join(name_labels[1:3]) 769 service['deleted'] = outputs.pop(0).strip().split(':')[1].strip() 770 if service['deleted'] == 'true': 771 service_list.append(service) 776 service[key_value[0].strip()] = key_value[1].strip() 779 service['TXT'] = [txt for txt in txt_entries if txt] [all …]
|
| /openthread-latest/src/cli/ |
| D | README_SRP.md | 57 Join the Thread Network and register a `_ipps._tcp` service: 80 > srp client service add my-service _ipps._tcp 12345 105 ### Verify the service status 107 Check if the host and service has been successfully registered on the client node: 113 > srp client service 114 instance:"my-service", name:"_ipps._tcp", state:Registered, port:12345, priority:0, weight:0 118 Make sure it shows `state:Registered` for both host and service commands. 120 Check the host & service on the server node: 124 my-host.default.service.arpa. 128 > srp server service [all …]
|
| D | README_SRP_CLIENT.md | 14 - [service](#service) 36 service 107 When service `ins2` is removed: 115 Removed service list: 126 Removed service list: 216 The possible states are (same value for service state): 324 ### service subsection 326 Usage: `srp client service` 331 > srp client service 337 ### service add [all …]
|
| D | README_SRP_SERVER.md | 18 - [service](#service) 40 service 110 default.service.arpa. 117 > srp server domain thread.service.arpa. 140 srp-api-test-1.default.service.arpa. 143 srp-api-test-0.default.service.arpa. 188 ### service subsection 190 Usage: `srp server service` 197 > srp server service 198 srp-api-test-1._ipps._tcp.default.service.arpa. [all …]
|
| D | cli_srp_server.cpp | 430 const otSrpServerService *service = nullptr; in Process() local 432 while ((service = otSrpServerHostGetNextService(host, service)) != nullptr) in Process() 434 bool isDeleted = otSrpServerServiceIsDeleted(service); in Process() 440 OutputLine("%s", otSrpServerServiceGetInstanceName(service)); in Process() 448 otSrpServerServiceGetLeaseInfo(service, &leaseInfo); in Process() 455 const char *subTypeName = otSrpServerServiceGetSubTypeServiceNameAt(service, index); in Process() 469 OutputLine(kIndentSize, "port: %u", otSrpServerServiceGetPort(service)); in Process() 470 OutputLine(kIndentSize, "priority: %u", otSrpServerServiceGetPriority(service)); in Process() 471 OutputLine(kIndentSize, "weight: %u", otSrpServerServiceGetWeight(service)); in Process() 472 OutputLine(kIndentSize, "ttl: %lu", ToUlong(otSrpServerServiceGetTtl(service))); in Process() [all …]
|
| D | cli_srp_client.cpp | 618 const otSrpClientService *service; in Process() local 622 …for (service = otSrpClientGetServices(GetInstancePtr()); service != nullptr; service = service->mN… in Process() 624 if ((aArgs[1] == service->mInstanceName) && (aArgs[2] == service->mName)) in Process() 630 VerifyOrExit(service != nullptr, error = OT_ERROR_NOT_FOUND); in Process() 634 … error = otSrpClientRemoveService(GetInstancePtr(), const_cast<otSrpClientService *>(service)); in Process() 638 …Exit(error = otSrpClientClearService(GetInstancePtr(), const_cast<otSrpClientService *>(service))); in Process() 641 … const_cast<otSrpClientService *>(service))); in Process() 968 for (const otSrpClientService *service = aRemovedServices; service != nullptr; service = next) in HandleCallback() local 970 next = service->mNext; in HandleCallback() 973 … const_cast<otSrpClientService *>(service))); in HandleCallback()
|
| D | cli_mdns.cpp | 274 otMdnsService service; in ProcessRegisterService() local 277 SuccessOrExit(error = ParseServiceArgs(aArgs, service, buffers)); in ProcessRegisterService() 279 OutputService(service); in ProcessRegisterService() 282 error = otMdnsRegisterService(GetInstancePtr(), &service, mRequestId, HandleRegisterationDone); in ProcessRegisterService() 458 otMdnsService service; in Process() local 460 memset(&service, 0, sizeof(service)); in Process() 462 service.mServiceInstance = aArgs[1].GetCString(); in Process() 464 service.mServiceType = aArgs[2].GetCString(); in Process() 467 error = otMdnsUnregisterService(GetInstancePtr(), &service); in Process() 533 otMdnsService service; in Process() local [all …]
|
| /openthread-latest/tools/harness-simulation/posix/etc/ |
| D | server.patch | 8 elif have service; then 9 sudo service rsyslog status || sudo service rsyslog start || die 'Failed to start rsyslog!' 10 sudo service dbus status || sudo service dbus start || die 'Failed to start dbus!' 12 …sudo service avahi-daemon status || sudo service avahi-daemon start || die 'Failed to start avahi!' 13 …sudo service otbr-agent status || sudo service otbr-agent start || die 'Failed to start otbr-agent… 14 …without WEB_GUI || sudo service otbr-web status || sudo service otbr-web start || die 'Failed to s… 15 + sudo service commissionerd status || sudo service commissionerd start || die 'Failed to st… 17 die 'Unable to find service manager. Try script/console to start in console mode!'
|
| /openthread-latest/src/core/net/ |
| D | srp_server.cpp | 359 for (const Service &service : aHost.mServices) in HasNameConflictsWith() local 367 if (host.HasService(service.GetInstanceName()) && (aHost.mKey != host.mKey)) in HasNameConflictsWith() 369 … LogWarn("Name conflict: service name %s has already been allocated", service.GetInstanceName()); in HasNameConflictsWith() 487 for (Service &service : aHost.mServices) in CommitSrpUpdate() 489 service.mLease = grantedLease; in CommitSrpUpdate() 490 service.mKeyLease = grantedKeyLease; in CommitSrpUpdate() 491 service.mTtl = grantedTtl; in CommitSrpUpdate() 492 service.mIsCommitted = true; in CommitSrpUpdate() 498 if (service.mIsDeleted) in CommitSrpUpdate() 502 … else if ((existingHost != nullptr) && existingHost->HasService(service.GetInstanceName())) in CommitSrpUpdate() [all …]
|
| D | srp_advertising_proxy.cpp | 113 for (Service &service : host.mServices) in Stop() 115 service.mAdvId = kInvalidRequestId; in Stop() 116 service.mIsRegistered = false; in Stop() 170 for (const Service &service : aHost.mServices) in UpdateAdvIdRangeOn() local 172 if (service.mKeyAdvId != kInvalidRequestId) in UpdateAdvIdRangeOn() 174 aHost.mAdvIdRange.Add(service.mKeyAdvId); in UpdateAdvIdRangeOn() 177 if (service.mAdvId != kInvalidRequestId) in UpdateAdvIdRangeOn() 179 aHost.mAdvIdRange.Add(service.mAdvId); in UpdateAdvIdRangeOn() 218 for (Service &service : aHost.mServices) in AdvertiseRemovalOf() 220 if (!service.mIsDeleted) in AdvertiseRemovalOf() [all …]
|
| D | srp_client.cpp | 846 for (Service &service : mServices) in RemoveHostAndServices() 848 UpdateServiceStateToRemove(service); in RemoveHostAndServices() 932 for (Service &service : mServices) in ChangeHostAndServiceStates() 934 if ((aMode == kForServicesAppendedInMessage) && !service.IsAppendedInMessage()) in ChangeHostAndServiceStates() 939 anyChanged |= service.SetState(aNewStates[service.GetState()]); in ChangeHostAndServiceStates() 1221 for (Service &service : mServices) in AppendServiceInstructions() 1223 service.MarkAsAppendedInMessage(); in AppendServiceInstructions() 1239 for (Service &service : mServices) in AppendServiceInstructions() 1241 uint32_t lease = DetermineLeaseInterval(service.GetLease(), mDefaultLease); in AppendServiceInstructions() 1242 … uint32_t keyLease = Max(DetermineLeaseInterval(service.GetKeyLease(), mDefaultKeyLease), lease); in AppendServiceInstructions() [all …]
|
| /openthread-latest/tests/scripts/thread-cert/border_router/ |
| D | test_advertising_proxy.py | 258 service = host.discover_mdns_service(service_instance, '_ipps._tcp', 'my-host') 259 self.assertIsNotNone(service) 260 self.assertEqual(service['instance'], service_instance) 261 self.assertEqual(service['name'], '_ipps._tcp') 262 self.assertEqual(service['port'], service_port) 263 self.assertEqual(service['priority'], 0) 264 self.assertEqual(service['weight'], 0) 265 self.assertEqual(service['host'], 'my-host') 266 self.assertEqual(len(service['addresses']), len(host_addrs)) 267 self.assertEqual(sorted(map(ipaddress.ip_address, service['addresses'])), [all …]
|
| D | test_publish_meshcop_service.py | 202 for service in services: 203 if service['txt']['nn'] == br.get_network_name(): 204 self.check_meshcop_service_by_data(br, service) 205 return service
|
| /openthread-latest/tests/unit/ |
| D | test_mdns.cpp | 2195 Core::Service service; in TestServiceReg() local 2209 service.mHostName = "myhost"; in TestServiceReg() 2210 service.mServiceInstance = "myservice"; in TestServiceReg() 2211 service.mServiceType = "_srv._udp"; in TestServiceReg() 2212 service.mSubTypeLabels = nullptr; in TestServiceReg() 2213 service.mSubTypeLabelsLength = 0; in TestServiceReg() 2214 service.mTxtData = kTxtData1; in TestServiceReg() 2215 service.mTxtDataLength = sizeof(kTxtData1); in TestServiceReg() 2216 service.mPort = 1234; in TestServiceReg() 2217 service.mPriority = 1; in TestServiceReg() [all …]
|
| D | test_srp_adv_proxy.cpp | 184 for (const Srp::Client::Service &service : srpClient.GetServices()) in otPlatDnssdRegisterService() local 186 if (StringMatch(service.GetInstanceName(), aService->mServiceInstance)) in otPlatDnssdRegisterService() 189 VerifyOrQuit(StringMatch(service.GetName(), aService->mServiceType)); in otPlatDnssdRegisterService() 190 VerifyOrQuit(service.GetPort() == aService->mPort); in otPlatDnssdRegisterService() 191 VerifyOrQuit(service.GetWeight() == aService->mWeight); in otPlatDnssdRegisterService() 192 VerifyOrQuit(service.GetPriority() == aService->mPriority); in otPlatDnssdRegisterService() 193 VerifyOrQuit(service.HasSubType() == (aService->mSubTypeLabelsLength != 0)); in otPlatDnssdRegisterService() 232 for (const Srp::Client::Service &service : srpClient.GetServices()) in otPlatDnssdUnregisterService() local 234 if (StringMatch(service.GetInstanceName(), aService->mServiceInstance)) in otPlatDnssdUnregisterService() 237 VerifyOrQuit(StringMatch(service.GetName(), aService->mServiceType)); in otPlatDnssdUnregisterService() [all …]
|
| /openthread-latest/tools/otci/tests/ |
| D | test_otci.py | 480 for service in srp_server_services: 481 if service['instance'] == 'ins1._ipps._tcp.default.service.arpa.': 482 self.assertEqual(False, service['deleted']) 483 self.assertEqual(1000, service['port']) 484 self.assertEqual(1, service['priority']) 485 self.assertEqual(1, service['weight']) 486 self.assertEqual('host1.default.service.arpa.', service['host']) 488 ipaddress.IPv6Address('2001::2')}, set(service['addresses'])) 489 … self.assertEqual({'txt11': b'val11', 'txt12': b'val12', 'txt13': True}, service['txt']) 490 elif service['instance'] == 'ins2._meshcop._udp.default.service.arpa.': [all …]
|
| /openthread-latest/src/core/thread/ |
| D | network_data.cpp | 277 const ServiceTlv *service = As<ServiceTlv>(cur); in Iterate() local 298 aConfig.mService->SetFrom(*service, *server); in Iterate() 353 ServiceConfig service; in ContainsService() local 355 while (GetNextService(iterator, aService.GetServerConfig().mRloc16, service) == kErrorNone) in ContainsService() 357 if (service == aService) in ContainsService() 377 ServiceConfig service; in ContainsEntriesFrom() local 381 config.mService = &service; in ContainsEntriesFrom() 493 ServiceConfig service; in FindRlocs() local 502 config.mService = &service; in FindRlocs() 534 AddRloc16ToRlocs(service.mServerConfig.mRloc16, aRlocs, aRoleFilter); in FindRlocs()
|
| D | network_data_leader_ftd.cpp | 390 const ServiceTlv *service = As<ServiceTlv>(cur); in Validate() local 393 VerifyOrExit(service->IsValid(), error = kErrorParse); in Validate() 395 service->GetServiceData(serviceData); in Validate() 399 VerifyOrExit(validatedSegment.FindService(service->GetEnterpriseNumber(), serviceData, in Validate() 403 SuccessOrExit(error = ValidateService(*service, aRloc16)); in Validate() 1003 const ServiceTlv *service; in FindServiceById() local 1006 while ((service = tlvIterator.Iterate<ServiceTlv>()) != nullptr) in FindServiceById() 1008 if (service->GetServiceId() == aServiceId) in FindServiceById() 1014 return service; in FindServiceById() 1060 ServiceTlv *service = As<ServiceTlv>(cur); in RemoveRloc() local [all …]
|