| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | MessageFramerTest.java | 55 private MessageFramer framer; field in MessageFramerTest
74 framer = new MessageFramer(sink, allocator, statsTraceCtx); in setUp()
79 writeKnownLength(framer, new byte[]{3, 14}); in simplePayload()
81 framer.flush(); in simplePayload()
91 writeUnknownLength(framer, new byte[]{3, 14}); in simpleUnknownLengthPayload()
92 framer.flush(); in simpleUnknownLengthPayload()
103 writeKnownLength(framer, new byte[]{3}); in smallPayloadsShouldBeCombined()
105 writeKnownLength(framer, new byte[]{14}); in smallPayloadsShouldBeCombined()
107 framer.flush(); in smallPayloadsShouldBeCombined()
117 writeKnownLength(framer, new byte[]{3, 14, 1, 5, 9, 2, 6}); in closeCombinedWithFullSink()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractStream.java | 35 protected abstract Framer framer(); in framer() method in AbstractStream
45 framer().setMessageCompression(enable); in setMessageCompression()
52 if (!framer().isClosed()) { in writeMessage()
53 framer().writePayload(message); in writeMessage()
62 if (!framer().isClosed()) { in flush()
63 framer().flush(); in flush()
72 framer().close(); in endOfMessages()
77 framer().setCompressor(checkNotNull(compressor, "compressor")); in setCompressor()
82 if (framer().isClosed()) { in isReady()
|
| D | AbstractClientStream.java | 97 private final Framer framer; field in AbstractClientStream
117 framer = new MessageFramer(this, bufferAllocator, statsTraceCtx); in AbstractClientStream()
120 framer = new GetFramer(headers, statsTraceCtx); in AbstractClientStream()
133 framer.setMaxOutboundMessageSize(maxSize); in setMaxOutboundMessageSize()
171 protected final Framer framer() { in framer() method in AbstractClientStream
172 return framer; in framer()
|
| D | AbstractServerStream.java | 79 private final MessageFramer framer; field in AbstractServerStream
87 framer = new MessageFramer(this, bufferAllocator, statsTraceCtx); in AbstractServerStream()
100 protected final MessageFramer framer() { in framer() method in AbstractServerStream
101 return framer; in framer()
|
| /external/syzkaller/vendor/google.golang.org/grpc/transport/ |
| D | controlbuf.go | 345 framer *framer member
355 func newLoopyWriter(s side, fr *framer, cbuf *controlBuffer, bdpEst *bdpEstimator) *loopyWriter { argument
364 framer: fr,
422 if l.framer.writer.offset < minBatchSize {
427 l.framer.writer.Flush()
435 return l.framer.fr.WriteWindowUpdate(w.streamID, w.increment)
457 return l.framer.fr.WriteSettings(s.ss...)
464 return l.framer.fr.WriteSettingsAck()
556 err = l.framer.fr.WriteHeaders(http2.HeadersFrameParam{
563 err = l.framer.fr.WriteContinuation(
[all …]
|
| D | http2_server.go | 69 framer *framer member
141 framer := newFramer(conn, writeBufSize, readBufSize)
171 if err := framer.fr.WriteSettings(isettings...); err != nil {
176 if err := framer.fr.WriteWindowUpdate(0, delta); err != nil {
211 framer: framer,
243 t.framer.writer.Flush()
260 frame, err := t.framer.fr.ReadFrame()
275 t.loopy = newLoopyWriter(serverSide, t.framer, t.controlBuf, t.bdpEst)
434 frame, err := t.framer.fr.ReadFrame()
1043 if err := t.framer.fr.WriteGoAway(sid, g.code, g.debugData); err != nil {
[all …]
|
| D | http2_client.go | 65 framer *framer member
221 framer: newFramer(conn, writeBufSize, readBufSize),
282 err = t.framer.fr.WriteSettings(http2.Setting{
287 err = t.framer.fr.WriteSettings()
295 if err := t.framer.fr.WriteWindowUpdate(0, delta); err != nil {
300 t.framer.writer.Flush()
302 t.loopy = newLoopyWriter(clientSide, t.framer, t.controlBuf, t.bdpEst)
1117 frame, err := t.framer.fr.ReadFrame()
1135 frame, err := t.framer.fr.ReadFrame()
1149 …t.closeStream(s, streamErrorf(http2ErrConvTab[se.Code], "%v", t.framer.fr.ErrorDetail()), true, ht…
|
| D | http_util.go | 575 type framer struct { struct
580 func newFramer(conn net.Conn, writeBufferSize, readBufferSize int) *framer {
583 f := &framer{
|
| /external/python/cpython2/Tools/framer/framer/ |
| D | bases.py | 5 from framer import struct, template
6 from framer.function import Function, Method
7 from framer.member import member
8 from framer.slots import *
9 from framer.util import cstring, unindent
|
| D | member.py | 1 from framer import template
2 from framer.util import cstring, unindent
|
| D | function.py | 3 from framer import template
4 from framer.util import cstring, unindent
|
| /external/python/cpython2/Tools/framer/ |
| D | README.txt | 1 framer is a tool to generate boilerplate code for C extension types.
6 specification, framer can generate all the boilerplate C code,
|
| D | example.py | 3 from framer.bases import Module, Type
4 from framer.member import member
|
| /external/python/cpython3/Lib/ |
| D | pickle.py | 407 self.framer = _Framer(self._file_write)
408 self.write = self.framer.write
409 self._write_large_bytes = self.framer.write_large_bytes
436 self.framer.start_framing()
439 self.framer.end_framing()
486 self.framer.commit_frame()
731 elif n >= self.framer._FRAME_SIZE_TARGET:
746 elif n >= self.framer._FRAME_SIZE_TARGET:
|
| D | pickletools.py | 2291 pickler.framer.start_framing()
2305 frameless = len(data) > pickler.framer._FRAME_SIZE_TARGET
2306 pickler.framer.commit_frame(force=frameless)
2308 pickler.framer.file_write(data)
2311 pickler.framer.end_framing()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyHandlerTestBase.java | 248 MessageFramer framer = new MessageFramer( in grpcDataFrame() local
261 framer.writePayload(new ByteArrayInputStream(content)); in grpcDataFrame()
262 framer.flush(); in grpcDataFrame()
|
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| D | server.go | 384 sc.framer = fr
441 sc.framer.WriteGoAway(0, err, []byte(debug))
454 framer *Framer member
554 func (sc *serverConn) Framer() *Framer { return sc.framer }
700 f, err := sc.framer.ReadFrame()
|
| /external/jline/src/src/test/resources/jline/example/ |
| D | english.gz | |
| /external/cldr/tools/java/org/unicode/cldr/util/data/transforms/ |
| D | internal_raw_IPA.txt | 62527 framer %23996 frˈemər
|
| D | internal_raw_IPA-old.txt | 74125 framer %10817 frˈemər
|