Searched refs:recvMsg (Results 1 – 7 of 7) sorted by relevance
44 type recvMsg struct { struct58 c chan recvMsg60 backlog []recvMsg66 c: make(chan recvMsg, 1),71 func (b *recvBuffer) put(r recvMsg) {97 b.backlog[0] = recvMsg{}109 func (b *recvBuffer) get() <-chan recvMsg {367 func (s *Stream) write(m recvMsg) {
382 s.buf.put(recvMsg{data: buf[:n:n]})386 s.buf.put(recvMsg{err: mapRecvMsgError(err)})
516 s.write(recvMsg{err: err})654 s.write(recvMsg{err: err})888 s.write(recvMsg{data: data})
599 s.write(recvMsg{data: data})605 s.write(recvMsg{err: io.EOF})
451 func (p *parser) recvMsg(maxReceiveMessageSize int) (pf payloadFormat, msg []byte, err error) { func578 pf, d, err := p.recvMsg(maxReceiveMessageSize)
408 return cs.attempt.recvMsg(m)512 func (a *csAttempt) recvMsg(m interface{}) (err error) { func
931 pf, req, err := p.recvMsg(s.opts.maxReceiveMessageSize)