Home
last modified time | relevance | path

Searched refs:isStalled (Results 1 – 5 of 5) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DGzipInflatingBuffer.java184 private boolean isStalled = true; field in GzipInflatingBuffer
190 boolean isStalled() { in isStalled() method in GzipInflatingBuffer
192 return isStalled; in isStalled()
212 isStalled = false; in addGzippedBytes()
311 isStalled = in inflateBytes()
DMessageDeframer.java190 } else if (isStalled()) { in closeWhenComplete()
244 private boolean isStalled() { in isStalled() method in MessageDeframer
246 return fullStreamDecompressor.isStalled(); in isStalled()
295 if (closeWhenComplete && isStalled()) { in deliver()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DGzipInflatingBufferTest.java124 assertTrue("gzipInflatingBuffer is not stalled", gzipInflatingBuffer.isStalled()); in splitGzipStreamWorks()
192 assertTrue(gzipInflatingBuffer.isStalled()); in requestingTooManyBytesStillReturnsEndOfBlock()
221 assertFalse("gzipInflatingBuffer is stalled", gzipInflatingBuffer.isStalled()); in isStalledReturnsTrueAtEndOfStream()
225 assertTrue("gzipInflatingBuffer is not stalled", gzipInflatingBuffer.isStalled()); in isStalledReturnsTrueAtEndOfStream()
236 assertFalse("gzipInflatingBuffer is stalled", gzipInflatingBuffer.isStalled()); in isStalledReturnsFalseBetweenStreams()
240 assertTrue("gzipInflatingBuffer is not stalled", gzipInflatingBuffer.isStalled()); in isStalledReturnsFalseBetweenStreams()
253 assertFalse("gzipInflatingBuffer is stalled", gzipInflatingBuffer.isStalled()); in isStalledReturnsFalseBetweenSmallStreams()
258 assertTrue("gzipInflatingBuffer is not stalled", gzipInflatingBuffer.isStalled()); in isStalledReturnsFalseBetweenSmallStreams()
270 assertTrue("gzipInflatingBuffer is not stalled", gzipInflatingBuffer.isStalled()); in isStalledReturnsTrueWithPartialNextHeaderAvailable()
293 assertTrue("gzipInflatingBuffer is not stalled", gzipInflatingBuffer.isStalled()); in isStalledWorksWithAllHeaderFlags()
[all …]
/external/exoplayer/tree/library/core/src/main/java/com/google/android/exoplayer2/audio/
DAudioTrackPositionTracker.java308 public boolean isStalled(long writtenFrames) { in isStalled() method in AudioTrackPositionTracker
DDefaultAudioSink.java709 if (audioTrackPositionTracker.isStalled(getWrittenFrames())) { in handleBuffer()