Home
last modified time | relevance | path

Searched refs:receiver (Results 1 – 25 of 61) sorted by relevance

123

/tools/tradefederation/core/javatests/com/android/tradefed/device/
DMockTestDeviceHelper.java45 IShellOutputReceiver receiver = invocation.getArgument(1); in injectShellResponse()
47 receiver.addOutput(inputData, 0, inputData.length); in injectShellResponse()
48 receiver.flush(); in injectShellResponse()
56 IShellOutputReceiver receiver = invocation.getArgument(1); in injectShellResponse()
58 receiver.addOutput(inputData, 0, inputData.length); in injectShellResponse()
59 receiver.flush(); in injectShellResponse()
90 IShellOutputReceiver receiver = invocation.getArgument(1); in injectShellResponse()
92 receiver.addOutput(inputData, 0, inputData.length); in injectShellResponse()
93 receiver.flush(); in injectShellResponse()
107 IShellOutputReceiver receiver = invocation.getArgument(1); in injectShellResponse()
[all …]
/tools/tradefederation/core/test_framework/com/android/tradefed/targetprep/
DNativeLeakCollector.java82 CollectingOutputReceiver receiver = new CollectingOutputReceiver(); in tearDown() local
84 writeToReceiver(String.format(OUTPUT_HEADER, allCommand), receiver); in tearDown() local
85 device.executeShellCommand(allCommand, receiver, mDumpTimeout, TimeUnit.MILLISECONDS, 1); in tearDown()
90 writeToReceiver(String.format(OUTPUT_HEADER, procCommand), receiver); in tearDown() local
91 device.executeShellCommand(procCommand, receiver, mAdditionalDumpTimeout, in tearDown()
95 if (receiver.getOutput() != null && !receiver.getOutput().isEmpty()) { in tearDown()
98 new ByteArrayInputStreamSource(receiver.getOutput().getBytes()); in tearDown()
102 CLog.w("No test logger available, printing output here:\n%s", receiver.getOutput()); in tearDown()
107 private void writeToReceiver (String msg, CollectingOutputReceiver receiver) { in writeToReceiver() argument
110 receiver.addOutput(msgBytes, 0, byteCount); in writeToReceiver()
DPushFileInvoker.java75 CollectingOutputReceiver receiver = new CollectingOutputReceiver(); in setUp() local
76 device.executeShellCommand(devicePath, receiver, in setUp()
78 CLog.d("Executed perf setup script\noutput:\n%s\nEND", receiver.getOutput()); in setUp()
/tools/netsim/testing/mobly/
Dble_gatt_test.py17 self.initiator, self.receiver = self.ads[:2]
21 self.receiver.debug_tag = 'receiver'
38 ble_utils.Discover(self.initiator, self.receiver)
39 ble_utils.Connect(self.initiator, self.receiver)
42 ble_utils.WriteCharacteristic(self.initiator, self.receiver)
43 ble_utils.Disconnect(self.initiator, self.receiver)
44 ble_utils.StopDiscover(self.initiator, self.receiver)
/tools/test/connectivity/acts_tests/tests/google/coex/stress_tests/
DCoexBtMultiProfileStressTest.py37 self.receiver = self.relay_devices[1]
44 self.receiver.setup()
45 self.receiver.power_on()
46 self.receiver.enter_pairing_mode()
52 self.receiver.clean_up()
69 self.pri_ad, self.receiver.mac_address,
83 self.pri_ad, self.receiver.mac_address,
86 self.receiver.mac_address))
/tools/tradefederation/core/javatests/com/android/tradefed/result/proto/
DStreamProtoResultReporterTest.java83 StreamProtoReceiver receiver = in testStream() local
90 "proto-report-port", Integer.toString(receiver.getSocketServerPort())); in testStream()
119 receiver.joinReceiver(5000); in testStream()
120 receiver.close(); in testStream()
161 assertNull(receiver.getError()); in testStream()
167 StreamProtoReceiver receiver = in testStream_stopParsing() local
172 "proto-report-port", Integer.toString(receiver.getSocketServerPort())); in testStream_stopParsing()
176 receiver.joinReceiver(100); in testStream_stopParsing()
181 receiver.close(); in testStream_stopParsing()
185 assertNull(receiver.getError()); in testStream_stopParsing()
[all …]
/tools/tradefederation/core/javatests/com/android/tradefed/result/
DLegacySubprocessResultsReporterTest.java71 SubprocessTestResultsParser receiver = in testPrintEvent_printToSocket() local
76 "subprocess-report-port", Integer.toString(receiver.getSocketServerPort())); in testPrintEvent_printToSocket()
84 receiver.joinReceiver(500); in testPrintEvent_printToSocket()
92 receiver.close(); in testPrintEvent_printToSocket()
103 SubprocessTestResultsParser receiver = in testPrintEvent_legacyMethodCalls() local
108 "subprocess-report-port", Integer.toString(receiver.getSocketServerPort())); in testPrintEvent_legacyMethodCalls()
117 receiver.joinReceiver(500); in testPrintEvent_legacyMethodCalls()
127 receiver.close(); in testPrintEvent_legacyMethodCalls()
DSubprocessResultsReporterTest.java118 SubprocessTestResultsParser receiver = in testPrintEvent_printToSocket() local
125 "subprocess-report-port", Integer.toString(receiver.getSocketServerPort())); in testPrintEvent_printToSocket()
131 receiver.joinReceiver(LONG_TIMEOUT_MS); in testPrintEvent_printToSocket()
138 receiver.close(); in testPrintEvent_printToSocket()
155 SubprocessTestResultsParser receiver = in testPrintEvent_printToSocket_StructuredFailures() local
164 "subprocess-report-port", Integer.toString(receiver.getSocketServerPort())); in testPrintEvent_printToSocket_StructuredFailures()
183 receiver.joinReceiver(LONG_TIMEOUT_MS); in testPrintEvent_printToSocket_StructuredFailures()
190 receiver.close(); in testPrintEvent_printToSocket_StructuredFailures()
230 try (SubprocessTestResultsParser receiver = in testTestLog() argument
232 receiver.setIgnoreTestLog(false); in testTestLog()
[all …]
/tools/netsim/rust/daemon/src/http_server/
Dthread_pool.rs40 let (sender, receiver) = mpsc::channel(); in new()
42 let receiver = Arc::new(Mutex::new(receiver)); in new() localVariable
47 workers.push(Worker::new(id, Arc::clone(&receiver))); in new()
83 fn new(id: usize, receiver: Arc<Mutex<mpsc::Receiver<Job>>>) -> Worker { in new()
87 let message = receiver.lock().expect("Failed to acquire lock on receiver").recv(); in new()
/tools/tradefederation/core/src/com/android/tradefed/device/metric/
DLogcatOnFailureCollector.java135 ILogcatReceiver receiver = mLogcatReceivers.get(device); in collectAndLog() local
137 if (receiver == null) { in collectAndLog()
148 receiver.getLogcatData(size, mOffset.get(device)), in collectAndLog()
155 ILogcatReceiver receiver = createLogcatReceiver(device); in initReceiver() local
156 mLogcatReceivers.put(device, receiver); in initReceiver()
157 receiver.start(); in initReceiver()
162 for (ILogcatReceiver receiver : mLogcatReceivers.values()) { in clearReceivers()
163 receiver.stop(); in clearReceivers()
164 receiver.clear(); in clearReceivers()
/tools/test/connectivity/acts_tests/acts_contrib/test_utils/abstract_devices/
Dwmm_transceiver.py227 (receiver, access_category, bandwidth,
232 server_port) = self._get_stream_resources(uuid, receiver, subnet)
237 receiver.identifier)
263 (receiver, access_category, bandwidth,
268 server_port) = self._get_stream_resources(uuid, receiver, subnet)
283 receiver.identifier)
462 def _get_stream_resources(self, uuid, receiver, subnet): argument
476 server_ip, server_port = self._get_server(receiver, uuid, subnet)
489 (receiver, server_port) = self._reserved_servers.pop(uuid)
490 receiver._release_server(server_port)
[all …]
/tools/tradefederation/core/test_framework/com/android/tradefed/util/statsd/
DMetricUtil.java86 final CollectingByteOutputReceiver receiver = new CollectingByteOutputReceiver(); in getStatsdMetadata() local
87 device.executeShellCommand(DUMP_STATSD_METADATA_CMD, receiver); in getStatsdMetadata()
88 return StatsdStatsReport.parser().parseFrom(receiver.getOutput()); in getStatsdMetadata()
104 final CollectingByteOutputReceiver receiver = new CollectingByteOutputReceiver(); in getReportByteArray() local
113 device.executeShellCommand(dumpCommand, receiver); in getReportByteArray()
114 return receiver.getOutput(); in getReportByteArray()
/tools/netsim/rust/daemon/src/wifi/
Dhwsim_attr_set.rs58 receiver: Option<MacAddress>, field
73 pub receiver: Option<MacAddress>, field
115 pub fn receiver(&mut self, receiver: &[u8; 6]) -> &mut Self { in receiver() method
117 address: *receiver,
121 self.receiver = Some(MacAddress::from(receiver));
188 receiver: self.receiver, in build()
206 self.receiver.map(|v| write!(f, "receiver: {}, ", v)); in fmt()
263 HwsimAttrAddrReceiver(child) => builder.receiver(&child.address),
306 assert!(attrs.receiver.is_none()); in test_attr_set_parse()
/tools/tradefederation/core/device_build_interfaces/com/android/tradefed/device/
DStubDevice.java178 InstallReceiver receiver, in installPackage() argument
188 InstallReceiver receiver, in installPackage() argument
221 String remoteFilePath, boolean reinstall, InstallReceiver receiver, String... extraArgs) in installRemotePackage() argument
230 InstallReceiver receiver, in installRemotePackage() argument
302 public void runEventLogService(LogReceiver receiver) in runEventLogService() argument
308 public void runLogService(String logname, LogReceiver receiver) in runLogService() argument
397 IShellOutputReceiver receiver, in executeShellCommand() argument
408 IShellOutputReceiver receiver, in executeShellCommand() argument
418 public void executeShellCommand(String command, IShellOutputReceiver receiver) in executeShellCommand() argument
431 String command, IShellOutputReceiver receiver, int maxTimeToOutputResponse) in executeShellCommand() argument
[all …]
/tools/tradefederation/core/src/com/android/tradefed/util/
DShellOutputReceiverStream.java39 public ShellOutputReceiverStream(@Nullable IShellOutputReceiver receiver) { in ShellOutputReceiverStream() argument
40 mReceiver = receiver; in ShellOutputReceiverStream()
44 @Nullable IShellOutputReceiver receiver, @Nullable FileOutputStream fileOutput) { in ShellOutputReceiverStream()
45 this(receiver); in ShellOutputReceiverStream()
DSimplePerfUtil.java109 public void executeCommand(String command, IShellOutputReceiver receiver) in executeCommand() argument
111 mDevice.executeShellCommand(commandStringPreparer(command), receiver); in executeCommand() local
131 public void executeCommand(String command, IShellOutputReceiver receiver, in executeCommand() argument
134 mDevice.executeShellCommand(commandStringPreparer(command), receiver, in executeCommand() local
DDeviceConcurrentUtil.java118 CollectingOutputReceiver receiver = new CollectingOutputReceiver(); in call() local
119 mDevice.executeShellCommand(mCommand, receiver, mTimeout, TimeUnit.MILLISECONDS, 1); in call()
120 String output = receiver.getOutput(); in call()
/tools/tradefederation/core/src/com/android/tradefed/device/
DNativeDeviceStateMonitor.java219 final CollectingOutputReceiver receiver = createOutputReceiver(); in waitForDeviceShell()
224 cmd, receiver, MAX_OP_TIME, TimeUnit.MILLISECONDS); in waitForDeviceShell()
225 String output = receiver.getOutput(); in waitForDeviceShell()
317 CollectingOutputReceiver receiver = new CollectingOutputReceiver(); in waitForBootComplete()
321 receiver, in waitForBootComplete()
324 String bootFlag = receiver.getOutput(); in waitForBootComplete()
394 final CollectingOutputReceiver receiver = createOutputReceiver(); in waitForStoreMount() local
431 checkCmd, receiver, MAX_OP_TIME, TimeUnit.MILLISECONDS); in waitForStoreMount()
437 String output = receiver.getOutput(); in waitForStoreMount()
477 CollectingOutputReceiver receiver = createOutputReceiver(); in getMountPoint() local
[all …]
DBatteryTemperature.java80 DumpsysBatteryTemperatureReceiver receiver = new DumpsysBatteryTemperatureReceiver(); in getBatteryTemperature() local
83 device.executeShellCommand("dumpsys battery", receiver); in getBatteryTemperature()
91 return receiver.getDeviceBatteryTemp(); in getBatteryTemperature()
DDeviceStateMonitor.java50 final CollectingOutputReceiver receiver = createOutputReceiver(); in waitForPmResponsive() local
53 getIDevice().executeShellCommand(cmd, receiver, MAX_OP_TIME, TimeUnit.MILLISECONDS); in waitForPmResponsive()
54 String output = receiver.getOutput(); in waitForPmResponsive()
/tools/metalava/metalava-model-testsuite/src/main/java/com/android/tools/metalava/model/testsuite/typeitem/
DCommonLambdaTypeItemTest.kt27 fun `Test lambda, no receiver, no params, unit return type`() { in Test lambda, no receiver, no params, unit return type()
54 fun `Test lambda, no receiver, String param, Int return type`() { in Test lambda, no receiver, String param, Int return type()
84 fun `Test lambda, no receiver, String param, nullable Int return type`() { in Test lambda, no receiver, String param, nullable Int return type()
114 fun `Test lambda, Number receiver, String array param, Int return type`() { in Test lambda, Number receiver, String array param, Int return type()
298 fun `Test suspend lambda no receiver`() { in Test suspend lambda no receiver()
331 fun `Test suspend lambda Number receiver`() { in Test suspend lambda Number receiver()
364 fun `Test suspend lambda no receiver, return Unit`() { in Test suspend lambda no receiver, return Unit()
/tools/tradefederation/contrib/src/com/android/media/tests/
DAudioLevelUtility.java35 final CollectingOutputReceiver receiver = new CollectingOutputReceiver(); in extractDeviceHeadsetLevelFromAdbShell() local
38 ADB_SHELL_DUMPSYS_AUDIO, receiver, 300, TimeUnit.MILLISECONDS, 1); in extractDeviceHeadsetLevelFromAdbShell()
39 final String shellOutput = receiver.getOutput(); in extractDeviceHeadsetLevelFromAdbShell()
/tools/tradefederation/core/test_framework/com/android/tradefed/testtype/rust/
DRustBinaryTest.java161 final Invocation invocation, IShellOutputReceiver receiver, final String... extraArgs) in runInvocation() argument
193 receiver, in runInvocation() local
218 CollectingOutputReceiver receiver = new CollectingOutputReceiver(); in runTest() local
219 runInvocation(invocation, receiver, "--list"); in runTest()
220 collectTestLines(receiver.getOutput().split("\n"), foundTests); in runTest()
/tools/tradefederation/core/javatests/com/android/tradefed/testtype/
DGTestBaseTest.java151 IShellOutputReceiver receiver = gTestBase.createResultParser("test1", listener); in testCreateResultParser() local
152 assertTrue(receiver instanceof GTestResultParser); in testCreateResultParser()
155 receiver = gTestBase.createResultParser("test1", listener); in testCreateResultParser()
156 assertTrue(receiver instanceof GTestListTestParser); in testCreateResultParser()
/tools/tradefederation/core/javatests/com/android/tradefed/util/
DLogcatEventParserTest.java169 IShellOutputReceiver receiver = in testEndToEnd()
172 receiver.addOutput(output.getBytes(), 0, output.getBytes().length); in testEndToEnd()
173 receiver.flush(); in testEndToEnd()

123