| /external/webrtc/webrtc/test/testsupport/ |
| frame_writer.h | 24 class FrameWriter {
26 virtual ~FrameWriter() {}
45 class FrameWriterImpl : public FrameWriter {
|
| frame_writer_unittest.cc | 36 FrameWriter* frame_writer_;
|
| /external/webrtc/webrtc/test/testsupport/mock/ |
| mock_frame_writer.h | 21 class MockFrameWriter : public FrameWriter {
|
| /external/grpc-grpc-java/okhttp/third_party/okhttp/main/java/io/grpc/okhttp/internal/framed/ |
| Variant.java | 40 FrameWriter newWriter(BufferedSink sink, boolean client);
|
| FrameWriter.java | 29 public interface FrameWriter extends Closeable {
|
| Http2.java | 88 @Override public io.grpc.okhttp.internal.framed.FrameWriter newWriter(BufferedSink sink, boolean client) {
369 static final class Writer implements io.grpc.okhttp.internal.framed.FrameWriter {
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| Variant.java | 36 FrameWriter newWriter(BufferedSink sink, boolean client);
|
| FrameWriter.java | 25 public interface FrameWriter extends Closeable {
|
| Spdy3.java | 102 @Override public FrameWriter newWriter(BufferedSink sink, boolean client) {
287 static final class Writer implements FrameWriter {
|
| Http2.java | 83 @Override public FrameWriter newWriter(BufferedSink sink, boolean client) {
363 static final class Writer implements FrameWriter {
|
| FramedConnection.java | 60 // Socket writes are guarded by frameWriter.
65 // frameWriter (to do blocking I/O) and this (to create streams). Such
126 final FrameWriter frameWriter;
171 frameWriter = variant.newWriter(builder.sink, client);
259 synchronized (frameWriter) {
273 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId,
278 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders);
283 frameWriter.flush();
291 frameWriter.synReply(outFinished, streamId, alternating)
[all...] |
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| Variant.java | 38 FrameWriter newWriter(BufferedSink sink, boolean client);
|
| FrameWriter.java | 27 public interface FrameWriter extends Closeable {
|
| Spdy3.java | 104 @Override public FrameWriter newWriter(BufferedSink sink, boolean client) {
289 static final class Writer implements FrameWriter {
|
| Http2.java | 85 @Override public FrameWriter newWriter(BufferedSink sink, boolean client) {
365 static final class Writer implements FrameWriter {
|
| FramedConnection.java | 62 // Socket writes are guarded by frameWriter.
67 // frameWriter (to do blocking I/O) and this (to create streams). Such
128 final FrameWriter frameWriter;
173 frameWriter = variant.newWriter(builder.sink, client);
261 synchronized (frameWriter) {
275 frameWriter.synStream(outFinished, inFinished, streamId, associatedStreamId,
280 frameWriter.pushPromise(associatedStreamId, streamId, requestHeaders);
285 frameWriter.flush();
293 frameWriter.synReply(outFinished, streamId, alternating)
[all...] |
| /external/grpc-grpc-java/okhttp/src/test/java/io/grpc/okhttp/ |
| AsyncFrameWriterTest.java | 27 import io.grpc.okhttp.internal.framed.FrameWriter;
44 @Mock private FrameWriter frameWriter;
54 asyncFrameWriter.becomeConnected(frameWriter, socket);
63 verify(frameWriter, times(1)).ping(anyBoolean(), anyInt(), anyInt());
64 verify(frameWriter, times(1)).flush();
77 verify(frameWriter, times(2)).ping(anyBoolean(), anyInt(), anyInt());
78 verify(frameWriter, times(2)).flush();
90 InOrder inOrder = inOrder(frameWriter);
91 inOrder.verify(frameWriter, times(2)).ping(anyBoolean(), anyInt(), anyInt())
[all...] |
| /external/webrtc/webrtc/modules/video_coding/codecs/test/ |
| videoprocessor.h | 165 FrameWriter* frame_writer,
196 FrameWriter* frame_writer_;
|
| videoprocessor.cc | 44 FrameWriter* frame_writer,
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| AsyncFrameWriter.java | 22 import io.grpc.okhttp.internal.framed.FrameWriter;
33 class AsyncFrameWriter implements FrameWriter {
35 private FrameWriter frameWriter;
50 * Set the real frameWriter and the corresponding underlying socket, the socket is needed for
55 void becomeConnected(FrameWriter frameWriter, Socket socket) {
56 Preconditions.checkState(this.frameWriter == null,
58 this.frameWriter = Preconditions.checkNotNull(frameWriter, "frameWriter")
[all...] |
| OutboundFlowController.java | 26 import io.grpc.okhttp.internal.framed.FrameWriter;
39 private final FrameWriter frameWriter;
43 OutboundFlowController(OkHttpClientTransport transport, FrameWriter frameWriter) {
45 this.frameWriter = Preconditions.checkNotNull(frameWriter, "frameWriter");
152 frameWriter.flush();
382 int frameBytes = min(bytesToWrite, frameWriter.maxDataLength())
[all...] |
| OkHttpClientTransport.java | 62 import io.grpc.okhttp.internal.framed.FrameWriter;
144 private AsyncFrameWriter frameWriter;
184 private FrameWriter testFrameWriter;
239 FrameWriter testFrameWriter,
301 checkState(frameWriter != null);
326 frameWriter.ping(false, (int) (data >>> 32), (int) data);
342 frameWriter,
376 frameWriter.flush();
424 frameWriter = new AsyncFrameWriter(this, serializingExecutor);
425 outboundFlow = new OutboundFlowController(this, frameWriter);
[all...] |
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| MockSpdyPeer.java | 47 private FrameWriter frameWriter = variant.newWriter(bytesOut, client);
62 this.frameWriter = variant.newWriter(bytesOut, client);
71 return frameWriter.maxDataLength();
79 public FrameWriter sendFrame() {
81 return frameWriter;
98 public FrameWriter truncateLastFrame(int length) {
110 return frameWriter;
|
| /external/v8/src/ |
| deoptimizer.cc | 28 // {FrameWriter} offers a stack writer abstraction for writing
31 class FrameWriter {
34 FrameWriter(Deoptimizer* deoptimizer, FrameDescription* frame,
872 FrameWriter frame_writer(this, output_frame, trace_scope_);
[all...] |
| deoptimizer.h | 533 friend class FrameWriter;
[all...] |
