| /tools/tradefederation/core/tests/src/com/android/tradefed/util/ |
| D | StreamUtilTest.java | 20 import com.android.tradefed.util.StreamUtil;
45 final ByteArrayList output = StreamUtil.getByteArrayListFromStream(stream); in testGetByteArrayListFromSource()
61 final ByteArrayList output = StreamUtil.getByteArrayListFromStream( in testGetByteArrayListFromStream()
78 final String output = StreamUtil.getStringFromStream(stream); in testGetStringFromSource()
90 output = StreamUtil.getBufferedReaderFromStreamSrc(source); in testGetBufferedReaderFromInputStream()
105 assertEquals(3, StreamUtil.countLinesFromSource(source)); in testCountLinesFromSource()
113 final String output = StreamUtil.getStringFromStream( in testGetStringFromStream()
126 String actualMd5 = StreamUtil.calculateMd5(inputSource); in testCalculateMd5()
134 StreamUtil.copyStreams(bais, baos); in testCopyStreams()
145 StreamUtil.copyStreamToWriter(bais, writer); in testCopyStreamToWriter()
|
| D | SubprocessTestResultsParserTest.java | 117 StreamUtil.close(resultParser); in testParse_randomEvents()
155 StreamUtil.close(resultParser); in testParse_invalidEventOrder()
190 StreamUtil.close(resultParser); in testParse_testNotStarted()
229 StreamUtil.close(resultParser); in testParse_noTimeStamp()
262 StreamUtil.close(resultParser); in testParse_invocationFailed()
300 StreamUtil.close(socket); in testParser_receiveFromSocket()
304 StreamUtil.close(resultParser); in testParser_receiveFromSocket()
305 StreamUtil.close(socket); in testParser_receiveFromSocket()
322 StreamUtil.close(resultParser); in testParser_failToJoin()
350 StreamUtil.close(resultParser); in testParse_testTag()
[all …]
|
| D | FixedByteArrayOutputStreamTest.java | 55 StreamUtil.copyStreams(mOutStream.getData(), baos); in writeTextIntoStreamAndReturn()
117 StreamUtil.copyStreams(mOutStream.getData(), baos); in testLessThanBufferWithOffset()
136 StreamUtil.copyStreams(mOutStream.getData(), baos); in testWriteWithOffsetAndWrap()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/ |
| D | TarUtil.java | 86 StreamUtil.close(outputFileStream); in unTar()
94 StreamUtil.close(debInputStream); in unTar()
95 StreamUtil.close(is); in unTar()
123 StreamUtil.close(in); in unGzip()
124 StreamUtil.close(out); in unGzip()
149 StreamUtil.close(in); in gzip()
150 StreamUtil.close(out); in gzip()
170 StreamUtil.cancel(inputStream); in extractAndLog()
186 StreamUtil.cancel(s); in extractAndLog()
|
| D | SerializationUtil.java | 49 StreamUtil.close(out); in serialize()
50 StreamUtil.close(fileOut); in serialize()
73 StreamUtil.close(in); in deserialize()
74 StreamUtil.close(fileIn); in deserialize()
|
| D | LogcatUpdaterEventParser.java | 291 StreamUtil.cancel(mCurrentLogcatData); in refreshLogcatStream()
301 StreamUtil.close(mStreamReader); in close()
302 StreamUtil.cancel(mCurrentLogcatData); in close()
303 StreamUtil.close(mCurrentInputStream); in close()
304 StreamUtil.close(mCurrentStreamReader); in close()
|
| D | ZipUtil.java | 170 StreamUtil.close(out); in createZip()
218 StreamUtil.close(out); in createZip()
295 StreamUtil.close(out); in gzipFile()
311 StreamUtil.copyStreams(inputStream, out); in writeToStream()
313 StreamUtil.close(inputStream); in writeToStream()
|
| D | PropertyChanger.java | 73 StreamUtil.close(br); in changeProperties()
74 StreamUtil.close(bw); in changeProperties()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/result/ |
| D | LogFileSaverTest.java | 22 import com.android.tradefed.util.StreamUtil;
138 String timestamp = StreamUtil.getStringFromStream(new FileInputStream(retentionFile)); in testGetFileDir_retention()
190 String actualLogString = StreamUtil.getStringFromStream(gzipStream); in testSaveAndGZipLogData()
193 StreamUtil.close(gzipStream); in testSaveAndGZipLogData()
215 String actualLogString = StreamUtil.getStringFromStream(zipFile.getInputStream( in testSaveAndZipLogData()
246 StreamUtil.copyStreams(mockInput, gzipOutStream); in testCreateAndGZipLogData()
247 StreamUtil.close(gzipOutStream); in testCreateAndGZipLogData()
252 String actualLogString = StreamUtil.getStringFromStream(gzipInputStream); in testCreateAndGZipLogData()
255 StreamUtil.close(gzipInputStream); in testCreateAndGZipLogData()
276 StreamUtil.close(logFileReader); in testSaveLogDataRaw()
|
| D | FileSystemLogSaverTest.java | 26 import com.android.tradefed.util.StreamUtil;
153 String timestamp = StreamUtil.getStringFromStream(new FileInputStream(retentionFile)); in testGetFileDir_retention()
184 String actualLogString = StreamUtil.getStringFromStream(zipFile.getInputStream( in testSaveLogData_uncompressed()
188 StreamUtil.close(logFileReader); in testSaveLogData_uncompressed()
219 StreamUtil.close(logFileReader); in testSaveLogData_compressed()
247 StreamUtil.close(logFileReader); in testSaveLogDataRaw()
|
| /tools/tradefederation/core/src/com/android/tradefed/result/ |
| D | JUnit4ResultForwarder.java | 22 import com.android.tradefed.util.StreamUtil;
94 StreamUtil.cancel(log.mDataStream); in testFinished()
130 mListener.testAssumptionFailure(testid, StreamUtil.getStackTrace(t)); in handleFailures()
132 mListener.testFailed(testid, StreamUtil.getStackTrace(t)); in handleFailures()
137 mListener.testFailed(testid, StreamUtil.getStackTrace(multiException)); in handleFailures()
|
| D | FileMetadataCollector.java | 24 import com.android.tradefed.util.StreamUtil;
83 StreamUtil.cancel(source); in invocationEnded()
84 StreamUtil.close(stream); in invocationEnded()
|
| /tools/tradefederation/core/prod-tests/src/com/android/framework/tests/ |
| D | BandwidthUtils.java | 21 import com.android.tradefed.util.StreamUtil;
71 String tmp = StreamUtil.getStringFromStream(fStream); in parseUidStats()
101 StreamUtil.close(fStream); in parseUidStats()
114 String tmp = StreamUtil.getStringFromStream(fStream); in parseNetDevStats()
135 StreamUtil.close(fStream); in parseNetDevStats()
|
| /tools/tradefederation/core/prod-tests/src/com/android/sdk/ |
| D | EmulatorBootTest.java | 37 import com.android.tradefed.util.StreamUtil;
111 listener.testFailed(bootTest, StreamUtil.getStackTrace(b)); in run()
117 listener.testFailed(bootTest, StreamUtil.getStackTrace(e)); in run()
120 listener.testFailed(bootTest, StreamUtil.getStackTrace(e)); in run()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/net/ |
| D | HttpHelper.java | 24 import com.android.tradefed.util.StreamUtil;
122 StreamUtil.close(remote); in doGet()
135 StreamUtil.copyStreams(remote, outputStream); in doGet()
137 StreamUtil.close(remote); in doGet()
151 StreamUtil.close(remote); in doGetIgnore()
399 StreamUtil.close(outputStream); in run()
400 StreamUtil.close(inputStream); in run()
401 StreamUtil.close(outputStreamWriter); in run()
|
| /tools/tradefederation/core/src/com/android/tradefed/device/ |
| D | LargeOutputReceiver.java | 27 import com.android.tradefed.util.StreamUtil;
109 StreamUtil.copyStreams(fullStream, os); in getData()
131 StreamUtil.close(fullStream); in getData()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/testtype/suite/ |
| D | TestSuiteInfoTest.java | 21 import com.android.tradefed.util.StreamUtil;
77 StreamUtil.close(stream); in testLoadConfig()
|
| /tools/tradefederation/core/src/com/android/tradefed/suite/checker/ |
| D | ActivityStatusChecker.java | 26 import com.android.tradefed.util.StreamUtil;
54 StreamUtil.cancel(screen); in isFrontActivityLauncher()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/log/ |
| D | FileLoggerTest.java | 25 import com.android.tradefed.util.StreamUtil;
83 StreamUtil.close(logFileReader); in testLogToLogger()
84 StreamUtil.cancel(logSource); in testLogToLogger()
|
| /tools/tradefederation/core/src/com/android/tradefed/sandbox/ |
| D | TradefedSandbox.java | 36 import com.android.tradefed.util.StreamUtil;
166 StreamUtil.close(mEventParser); in tearDown()
167 StreamUtil.close(mStdout); in tearDown()
168 StreamUtil.close(mStderr); in tearDown()
246 StreamUtil.close(mEventParser); in prepareConfiguration()
|
| /tools/tradefederation/core/tests/src/com/android/tradefed/config/gcs/ |
| D | GCSConfigurationServerTest.java | 20 import com.android.tradefed.util.StreamUtil;
81 Assert.assertEquals(CONFIG, StreamUtil.getStringFromStream(input)); in testGetConfig()
|
| D | GCSConfigurationFactoryTest.java | 24 import com.android.tradefed.util.StreamUtil;
104 String content = StreamUtil.getStringFromStream(input); in testGetConfigStream()
124 String content = StreamUtil.getStringFromStream(input); in testGetConfigStream_bundled()
|
| /tools/tradefederation/core/src/com/android/tradefed/log/ |
| D | LogReceiver.java | 24 import com.android.tradefed.util.StreamUtil;
84 StreamUtil.cancel(stream); in postLog()
|
| D | FileLogger.java | 27 import com.android.tradefed.util.StreamUtil;
229 StreamUtil.flushAndCloseStream(stream); in doCloseLog()
243 StreamUtil.copyStreams(inputStream, mLogStream); in dumpToLog()
|
| /tools/tradefederation/core/src/com/android/tradefed/testtype/ |
| D | NoisyDryRunTest.java | 33 import com.android.tradefed.util.StreamUtil;
75 listener.testFailed(parseFileTest, StreamUtil.getStackTrace(e)); in testCommandFile()
134 listener.testFailed(parseCmdTest, StreamUtil.getStackTrace(e)); in testCommandLines()
|