Home
last modified time | relevance | path

Searched refs:streamClosed (Results 1 – 21 of 21) sorted by relevance

/external/glide/library/src/main/java/com/bumptech/glide/load/resource/bitmap/
DRecyclableBufferedInputStream.java91 throw streamClosed(); in available()
96 private static IOException streamClosed() throws IOException { in streamClosed() method in RecyclableBufferedInputStream
225 throw streamClosed(); in read()
237 throw streamClosed(); in read()
273 throw streamClosed(); in read()
281 throw streamClosed(); in read()
316 throw streamClosed(); in read()
373 throw streamClosed(); in skip()
379 throw streamClosed(); in skip()
/external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
DTestStreamTracer.java97 protected final CountDownLatch streamClosed = new CountDownLatch(1); field in TestStreamTracer.TestBaseStreamTracer
102 streamClosed.await(); in await()
107 return streamClosed.await(timeout, timeUnit); in await()
156 public void streamClosed(Status status) { in streamClosed() method in TestStreamTracer.TestBaseStreamTracer
162 streamClosed.countDown(); in streamClosed()
DTestServerStreamTracer.java110 public void streamClosed(Status status) { in streamClosed() method in TestServerStreamTracer
111 delegate.streamClosed(status); in streamClosed()
DTestClientStreamTracer.java131 public void streamClosed(Status status) { in streamClosed() method in TestClientStreamTracer
132 delegate.streamClosed(status); in streamClosed()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java155 statsTraceCtx.streamClosed(capturedStatus);
288 private void streamClosed() {
367 clientStream.statsTraceCtx.streamClosed(clientNotifyStatus);
432 clientStream.statsTraceCtx.streamClosed(clientStatus);
440 streamClosed();
449 streamClosed();
468 clientStream.statsTraceCtx.streamClosed(clientStatus);
602 streamClosed();
623 serverStream.statsTraceCtx.streamClosed(serverTracerStatus);
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DCensusTracingModule.java300 volatile int streamClosed; field in CensusTracingModule.ServerTracer
325 public void streamClosed(io.grpc.Status status) { in streamClosed() method in CensusTracingModule.ServerTracer
331 if (streamClosed != 0) { in streamClosed()
334 streamClosed = 1; in streamClosed()
DStatsTraceContext.java144 public void streamClosed(Status status) { in streamClosed() method in StatsTraceContext
147 tracer.streamClosed(status); in streamClosed()
DAbstractServerStream.java335 statsTraceCtx.streamClosed(newStatus); in closeListener()
338 statsTraceCtx.streamClosed(closedStatus); in closeListener()
DCensusStatsModule.java477 private volatile int streamClosed; field in CensusStatsModule.ServerTracer
573 public void streamClosed(Status status) { in streamClosed() method in CensusStatsModule.ServerTracer
579 if (streamClosed != 0) { in streamClosed()
582 streamClosed = 1; in streamClosed()
DAbstractClientStream.java451 statsTraceCtx.streamClosed(status); in closeListener()
/external/apache-http/src/org/apache/http/conn/
DEofSensorWatcher.java89 boolean streamClosed(InputStream wrapped) in streamClosed() method
DBasicEofSensorWatcher.java101 public boolean streamClosed(InputStream wrapped) in streamClosed() method in BasicEofSensorWatcher
DBasicManagedEntity.java177 public boolean streamClosed(InputStream wrapped) in streamClosed() method in BasicManagedEntity
DEofSensorInputStream.java271 scws = eofWatcher.streamClosed(wrappedStream); in checkClose()
/external/oboe/apps/OboeTester/app/src/main/java/com/google/sample/oboe/manualtest/
DTestAudioActivity.java105 boolean streamClosed = false;
123 streamClosed = streamClosed || (status.state >= 12);
126 if (streamClosed) {
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DStreamTracer.java32 public void streamClosed(Status status) { in streamClosed() method in StreamTracer
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DCensusModulesTest.java395 tracer.streamClosed(Status.OK); in subtestClientBasicStatsDefaultContext()
444 clientStreamTracer.streamClosed(Status.OK); in clientBasicTracingDefaultSpan()
613 serverTracer.streamClosed(Status.OK); in subtestStatsHeadersPropagateTags()
854 tracer.streamClosed(Status.CANCELLED); in subtestServerBasicStatsNoHeaders()
909 serverStreamTracer.streamClosed(Status.CANCELLED); in serverBasicTracingNoHeaders()
943 serverStreamTracer.streamClosed(Status.CANCELLED); in serverTracingSampledToLocalSpanStore()
958 serverStreamTracer.streamClosed(Status.CANCELLED); in serverTracingNotSampledToLocalSpanStore_whenServerCallNotCreated()
/external/grpc-grpc-java/grpclb/src/main/java/io/grpc/grpclb/
DGrpclbClientLoadRecorder.java148 public void streamClosed(Status status) { in streamClosed() method in GrpclbClientLoadRecorder.StreamTracer
/external/grpc-grpc-java/grpclb/src/test/java/io/grpc/grpclb/
DGrpclbLoadBalancerTest.java508 tracer1.streamClosed(Status.CANCELLED); in loadReporting()
531 tracer3.streamClosed(Status.DEADLINE_EXCEEDED); in loadReporting()
546 tracer5.streamClosed(Status.OK); in loadReporting()
/external/apache-http/
Dart-profile131 HPLorg/apache/http/conn/BasicManagedEntity;->streamClosed(Ljava/io/InputStream;)Z
146 HPLorg/apache/http/conn/EofSensorWatcher;->streamClosed(Ljava/io/InputStream;)Z
/external/apache-http/api/
Dcurrent.txt1626 method @Deprecated public boolean streamClosed(java.io.InputStream) throws java.io.IOException;
1638 method @Deprecated public boolean streamClosed(java.io.InputStream) throws java.io.IOException;
1696 method @Deprecated public boolean streamClosed(java.io.InputStream) throws java.io.IOException;