Searched refs:maxReceiveMessageSize (Results 1 – 3 of 3) sorted by relevance
| /external/syzkaller/vendor/google.golang.org/grpc/ |
| D | rpc_util.go | 160 maxReceiveMessageSize *int member
293 c.maxReceiveMessageSize = &o.MaxRecvMsgSize
451 func (p *parser) recvMsg(maxReceiveMessageSize int) (pf payloadFormat, msg []byte, err error) {
465 if int(length) > maxReceiveMessageSize {
466 …urceExhausted, "grpc: received message larger than max (%d vs. %d)", length, maxReceiveMessageSize)
577 …c baseCodec, s *transport.Stream, dc Decompressor, m interface{}, maxReceiveMessageSize int, inPay…
578 pf, d, err := p.recvMsg(maxReceiveMessageSize)
609 if len(d) > maxReceiveMessageSize {
612 …urceExhausted, "grpc: received message larger than max (%d vs. %d)", len(d), maxReceiveMessageSize)
|
| D | stream.go | 175 …c.maxReceiveMessageSize = getMaxSize(mc.MaxRespSize, c.maxReceiveMessageSize, defaultClientMaxRece…
542 err = recv(a.p, cs.codec, a.s, a.dc, m, *cs.c.maxReceiveMessageSize, inPayload, a.decomp)
572 err = recv(a.p, cs.codec, a.s, a.dc, m, *cs.c.maxReceiveMessageSize, nil, a.decomp)
659 maxReceiveMessageSize int member
760 …if err := recv(ss.p, ss.codec, ss.s, ss.dc, m, ss.maxReceiveMessageSize, inPayload, ss.decomp); er…
|
| D | server.go | 127 maxReceiveMessageSize int member
141 maxReceiveMessageSize: defaultServerMaxReceiveMessageSize,
240 o.maxReceiveMessageSize = m
931 pf, req, err := p.recvMsg(s.opts.maxReceiveMessageSize)
992 if len(req) > s.opts.maxReceiveMessageSize {
995 …sted, "grpc: received message larger than max (%d vs. %d)", len(req), s.opts.maxReceiveMessageSize)
1108 maxReceiveMessageSize: s.opts.maxReceiveMessageSize,
|