/tools/acloud/reconnect/ |
D | reconnect.py | 46 def _IsWebrtcEnable(instance, host_user, host_ssh_private_key_path, argument 60 if instance.islocal: 61 return instance.cf_runtime_cfg.enable_webrtc 62 ssh = ssh_object.Ssh(ip=ssh_object.IP(ip=instance.ip), user=host_user, 122 instance, argument 148 if instance.avd_type not in utils.AVD_PORT_DICT: 151 (instance.name, instance.avd_type)) 156 adb_cmd = AdbTools(instance.adb_port) 157 vnc_port = instance.vnc_port 158 adb_port = instance.adb_port [all …]
|
/tools/acloud/list/ |
D | instance_test.py | 36 from acloud.list import instance 88 self.Patch(instance.LocalInstance, "_GetDevidInfoFromCvdStatus", 90 local_instance = instance.LocalInstance("fake_config_path") 110 self.Patch(instance, "_IsProcessRunning", return_value=False) 111 local_instance = instance.LocalInstance("fake_config_path") 132 instance.LocalInstance._ParsingCvdFleetOutput(cvd_fleet_output), 141 self.assertEqual(instance._IsProcessRunning(process), True) 144 self.assertEqual(instance._IsProcessRunning(process), False) 156 self.Patch(instance.LocalInstance, "_GetDevidInfoFromCvdStatus", 163 local_instance = instance.LocalInstance("fake_config_path") [all …]
|
D | list_test.py | 29 from acloud.list import instance 46 self.Patch(instance, "_GetElapsedTime", return_value=0) 47 self.Patch(instance.RemoteInstance, "_GetZoneName") 48 self.Patch(instance.RemoteInstance, "_GetProjectName") 49 self.Patch(instance, "GetInstanceIP", return_value=ssh.IP()) 50 self.Patch(instance.RemoteInstance, "GetAdbVncPortFromSSHTunnel") 115 instance, "GetLocalInstanceIdByName", 117 self.Patch(instance, "GetLocalInstanceConfig", 119 self.Patch(instance, "GetDefaultCuttlefishConfig", 128 self.Patch(instance.LocalGoldfishInstance, "GetExistingInstances", [all …]
|
D | list.py | 30 from acloud.list import instance 52 return [instance.RemoteInstance(gce_instance) for gce_instance in instance_list] 153 ins_lock = instance.GetLocalInstanceLock(ins_id) 161 instances = instance.GetCuttleFishLocalInstances(cfg_path) 184 cfg_path = instance.GetLocalInstanceConfig(local_instance_id) 186 ins = instance.LocalInstance(cfg_path) 189 cfg_path = instance.GetDefaultCuttlefishConfig() 191 ins = instance.LocalInstance(cfg_path) 207 id_cfg_pairs = instance.GetAllLocalInstanceConfigs() 209 instance.LocalGoldfishInstance.GetExistingInstances()) [all …]
|
/tools/acloud/internal/lib/ |
D | gcompute_client.py | 624 def GetInstance(self, instance, zone): argument 636 project=self._project, zone=zone, instance=instance) 639 def AttachAccelerator(self, instance, zone, accelerator_count, argument 667 project=self._project, zone=zone, instance=instance, body=body) 675 logger.error("Attach instance failed: %s", instance) 678 accelerator_count, accelerator_type, instance) 680 def AttachDisk(self, instance, zone, **kwargs): argument 726 project=self._project, zone=zone, instance=instance, body=kwargs) 734 logger.error("Attach instance failed: %s", instance) 736 logger.info("Disk has been attached to instance %s.", instance) [all …]
|
D | android_compute_client.py | 182 def GetDataDiskName(cls, instance): argument 191 name = cls.DATA_DISK_NAME_FMT.format(instance=instance) 271 instance, argument 310 disk_args = self._GetDiskArgs(instance, image_name) 325 instance, image_name, self._machine_type, metadata, self._network, 329 def CheckBootFailure(self, serial_out, instance): argument 344 def CheckBoot(self, instance): argument 355 serial_out = self.GetSerialPortOutput(instance=instance, port=1) 356 self.CheckBootFailure(serial_out, instance) 366 def WaitForBoot(self, instance, boot_timeout_secs=None): argument [all …]
|
D | cvd_compute_client_multi_stage.py | 111 def CreateInstance(self, instance, image_name, image_project, argument 136 self._ip = self._CreateGceInstance(instance, image_name, image_project, 141 self._project, instance, self._zone) 155 self._all_failures[instance] = e 156 return instance 158 def _GetGCEHostName(self, instance): argument 176 def LaunchCvd(self, instance, avd_spec, base_dir, extra_args): argument 207 return {instance: error_msg} 240 self, instance=avd_spec.instance_name_to_reuse, zone=self._zone) 245 def _CreateGceInstance(self, instance, image_name, image_project, argument [all …]
|
D | cheeps_compute_client.py | 60 def CheckBootFailure(self, serial_out, instance): argument 66 def CreateInstance(self, instance, image_name, image_project, avd_spec): argument 98 self._project, instance, self._zone) 102 instance=instance,
|
D | goldfish_compute_client.py | 102 def CheckBootFailure(self, serial_out, instance): argument 151 instance, argument 201 disk_args = self._GetDiskArgs(instance, image_name, image_project, 251 instance=instance,
|
/tools/acloud/ |
D | README.md | 50 instance (running on a virtual machine in the cloud) and local instance 56 * Remote instance using an Android Build image (LKGB (Last Known Good Build) 62 * Remote instance using a locally built image (use `m` to build the image) 66 * Local instance using an Android Build image (LKGB for cuttlefish phone 69 > $ acloud create --local-instance 71 * Local instance using a locally built image (use `m` to build the image) 73 > $ acloud create --local-instance --local-image 92 … webrtc and acloud will automatically open the browser upon creation of a remote or local instance. 93 Acloud will also create a ssh tunnel to enable adb and webrtc connection to the instance. Other AVD… 103 * `--reuse-gce`: 'cuttlefish only' This can help users use their own instance. [all …]
|
/tools/acloud/delete/ |
D | delete.py | 62 for instance in instances_to_delete: 63 if instance.islocal: 64 if instance.avd_type == constants.TYPE_GF: 65 DeleteLocalGoldfishInstance(instance, delete_report) 66 elif instance.avd_type == constants.TYPE_CF: 67 DeleteLocalCuttlefishInstance(instance, delete_report) 70 instance.avd_type) 73 remote_instance_list.append(instance.name) 75 if instance.vnc_port: 76 utils.CleanupSSVncviewer(instance.vnc_port) [all …]
|
/tools/tradefederation/core/javatests/com/android/tradefed/testtype/suite/ |
D | TestSuiteInfoTest.java | 38 TestSuiteInfo instance = TestSuiteInfo.getInstance(); in testDefaultValues() local 39 if (instance.didLoadFromProperties()) { in testDefaultValues() 44 assertEquals("[stub build number]", instance.getBuildNumber()); in testDefaultValues() 45 assertEquals("[stub target arch]", instance.getTargetArchs().get(0)); in testDefaultValues() 46 assertEquals("[stub name]", instance.getName()); in testDefaultValues() 47 assertEquals("[stub fullname]", instance.getFullName()); in testDefaultValues() 48 assertEquals("[stub version]", instance.getVersion()); in testDefaultValues() 67 TestSuiteInfo instance = TestSuiteInfo.getInstance(); in testLoadConfig() local 69 Properties p = instance.loadSuiteInfo(stream); in testLoadConfig() 93 TestSuiteInfo instance = TestSuiteInfo.getInstance(); in testLoadConfig_multiArch() local [all …]
|
/tools/acloud/public/actions/ |
D | remote_instance_cf_device_factory.py | 61 instance = self.CreateGceInstance() 63 if instance in self.GetFailures(): 64 return instance 68 instance, self._avd_spec, cvd_utils.GCE_BASE_DIR, image_args) 72 self._SetFailures(instance, e) 75 instance, 76 instance in self.GetFailures() and not self._avd_spec.no_pull_log) 77 return instance 175 def _FindLogFiles(self, instance, download): argument 192 self._all_logs[instance] = logs [all …]
|
D | gce_device_factory.py | 75 instance = self._avd_spec.instance_name_to_reuse 77 instance = self._compute_client.GenerateInstanceName( 87 instance=instance, 91 ip = self._compute_client.GetInstanceIP(instance) 99 return instance 111 def _SetFailures(self, instance, error_msg): argument 120 self._all_failures[instance] = error_msg
|
D | remote_instance_fvp_device_factory.py | 37 instance = self.CreateGceInstance() 38 if instance in self.GetFailures(): 39 return instance 45 self._SetFailures(instance, e) 47 return instance
|
/tools/netsim/rust/proto/src/ |
D | frontend_grpc.rs | 508 let mut instance = s.clone(); in create_frontend_service() localVariable 511 instance.get_version(ctx, req, resp) in create_frontend_service() 513 let mut instance = s.clone(); in create_frontend_service() localVariable 516 instance.create_device(ctx, req, resp) in create_frontend_service() 518 let mut instance = s.clone(); in create_frontend_service() localVariable 521 instance.delete_chip(ctx, req, resp) in create_frontend_service() 523 let mut instance = s.clone(); in create_frontend_service() localVariable 526 instance.patch_device(ctx, req, resp) in create_frontend_service() 528 let mut instance = s.clone(); in create_frontend_service() localVariable 530 instance.reset(ctx, req, resp) in create_frontend_service() [all …]
|
/tools/acloud/internal/script/ |
D | create_extradisk.sh | 21 gcloud compute instances attach-disk instance-disk-creation --disk "${DISK_NAME}" --zone=${ZONE} --… 23 gcloud compute ssh instance-disk-creation --zone=${ZONE} --project=${PROJECT} --command "sudo mkfs.… 24 gcloud compute ssh instance-disk-creation --zone=${ZONE} --project=${PROJECT} --command "sudo mount… 25 gcloud compute ssh instance-disk-creation --zone=${ZONE} --project=${PROJECT} --command "ls /mnt" 26 gcloud compute ssh instance-disk-creation --zone=${ZONE} --project=${PROJECT} --command "sudo umoun… 28 gcloud compute instances detach-disk instance-disk-creation --disk "${DISK_NAME}" --zone=${ZONE} --…
|
/tools/acloud/pull/ |
D | pull.py | 41 def PullFileFromInstance(cfg, instance, file_name=None, no_prompts=False): argument 57 ssh = Ssh(ip=IP(ip=instance.ip), 62 PullLogs(ssh, log_files, instance.name) 114 def _GetDownloadLogFolder(instance): argument 123 log_folder = os.path.join(tempfile.gettempdir(), instance) 202 instance = list_instances.GetInstancesFromInstanceNames( 204 return PullFileFromInstance(cfg, instance[0], args.file_name, args.no_prompt)
|
/tools/test/connectivity/acts/framework/acts/libs/ |
D | version_selector.py | 159 self.instance = None 230 if self.instance is not None: 233 level = self.get_version(self.instance, *args, **kwargs) 265 if self.instance is None: 269 return func(self.instance, *args, **kwargs) 271 def __get__(self, instance, owner): argument 290 self.instance = instance
|
/tools/acloud/restart/ |
D | restart.py | 40 def RestartFromInstance(cfg, instance, instance_id, powerwash_data): argument 52 ssh = Ssh(ip=IP(ip=instance.ip), 57 instance_id, instance.name) 63 instance, 98 instance = list_instances.GetInstancesFromInstanceNames( 101 cfg, instance[0], args.instance_id, args.powerwash)
|
D | restart_test.py | 78 instance = mock.MagicMock() 79 instance.ip = "0.0.0.0" 80 instance.name = "ins-name" 86 restart.RestartFromInstance(cfg, instance, 1, True) 90 restart.RestartFromInstance(cfg, instance, 1, False) 96 restart.RestartFromInstance(cfg, instance, 1, False)
|
/tools/acloud/powerwash/ |
D | powerwash.py | 35 def PowerwashFromInstance(cfg, instance, instance_id): argument 46 ssh = Ssh(ip=IP(ip=instance.ip), 51 instance_id, instance.name) 85 instance = list_instances.GetInstancesFromInstanceNames( 87 return PowerwashFromInstance(cfg, instance[0], args.instance_id)
|
/tools/acloud/create/ |
D | cheeps_remote_image_remote_instance_test.py | 87 instance = cheeps_remote_image_remote_instance.CheepsRemoteImageRemoteInstance() 88 report = instance.Create(avd_spec, no_prompts=False) 92 instance=self.INSTANCE, 120 instance = cheeps_remote_image_remote_instance.CheepsRemoteImageRemoteInstance() 121 instance.Create(avd_spec, no_prompts=False) 125 instance=self.INSTANCE,
|
/tools/test/connectivity/acts/framework/acts/ |
D | test_decorators.py | 166 def __get__(self, instance, owner): argument 173 return _TestInfoBinding(self, instance) 331 def __init__(self, target, instance): argument 338 self.instance = instance 346 return self.target(self.instance, *args, **kwargs) 352 return self.target.gather(self.instance, *args, **kwargs)
|
/tools/test/connectivity/acts/framework/acts/controllers/ |
D | access_point.py | 608 instance = self._aps.get(identifier) 617 instance.hostapd.stop() 886 instance = self._aps.get(identifier) 888 instance.hostapd.channel_switch(channel_num) 894 instance = self._aps.get(identifier) 895 return instance.hostapd.get_current_channel() 901 instance = self._aps.get(identifier) 902 return instance.hostapd.get_stas() 909 instance = self._aps.get(identifier) 910 return instance.hostapd.get_sta_extended_capabilities(sta_mac) [all …]
|