Lines Matching refs:recv
472 if (!transport->recv.copied) {
473 if (buf->head[0].iov_len >= transport->recv.offset)
475 &transport->recv.xid,
476 transport->recv.offset);
477 transport->recv.copied = transport->recv.offset;
484 return transport->recv.fraghdr & cpu_to_be32(RPC_LAST_STREAM_FRAGMENT);
505 want = transport->recv.len - transport->recv.offset;
508 transport->recv.copied + want,
509 transport->recv.copied,
511 transport->recv.offset += read;
512 transport->recv.copied += read;
515 if (transport->recv.offset == transport->recv.len)
547 .iov_base = &transport->recv.fraghdr,
562 req = xprt_lookup_bc_request(xprt, transport->recv.xid);
567 if (transport->recv.copied && !req->rq_private_buf.len)
572 xprt_complete_bc_request(req, transport->recv.copied);
574 req->rq_private_buf.len = transport->recv.copied;
595 req = xprt_lookup_rqst(xprt, transport->recv.xid);
596 if (!req || (transport->recv.copied && !req->rq_private_buf.len)) {
607 xprt_complete_rqst(req->rq_task, transport->recv.copied);
609 req->rq_private_buf.len = transport->recv.copied;
623 if (transport->recv.len == 0) {
624 want = xs_read_stream_headersize(transport->recv.copied != 0);
626 transport->recv.offset);
629 transport->recv.offset = ret;
630 if (transport->recv.offset != want)
631 return transport->recv.offset;
632 transport->recv.len = be32_to_cpu(transport->recv.fraghdr) &
634 transport->recv.offset -= sizeof(transport->recv.fraghdr);
638 switch (be32_to_cpu(transport->recv.calldir)) {
649 transport->recv.calldir = cpu_to_be32(-1);
650 transport->recv.copied = -1;
655 if (transport->recv.offset < transport->recv.len) {
660 transport->recv.len - transport->recv.offset);
663 transport->recv.offset += ret;
665 if (transport->recv.offset != transport->recv.len)
670 transport->recv.copied = 0;
672 transport->recv.offset = 0;
673 transport->recv.len = 0;
739 transport->recv.offset = 0;
740 transport->recv.len = 0;
741 transport->recv.copied = 0;