diff options
Diffstat (limited to 'net/sunrpc/clnt.c')
-rw-r--r-- | net/sunrpc/clnt.c | 14 |
1 files changed, 8 insertions, 6 deletions
diff --git a/net/sunrpc/clnt.c b/net/sunrpc/clnt.c index b23c0d328c9c..25cba94c5683 100644 --- a/net/sunrpc/clnt.c +++ b/net/sunrpc/clnt.c | |||
@@ -644,24 +644,26 @@ call_reserveresult(struct rpc_task *task) | |||
644 | 644 | ||
645 | /* | 645 | /* |
646 | * 2. Allocate the buffer. For details, see sched.c:rpc_malloc. | 646 | * 2. Allocate the buffer. For details, see sched.c:rpc_malloc. |
647 | * (Note: buffer memory is freed in rpc_task_release). | 647 | * (Note: buffer memory is freed in xprt_release). |
648 | */ | 648 | */ |
649 | static void | 649 | static void |
650 | call_allocate(struct rpc_task *task) | 650 | call_allocate(struct rpc_task *task) |
651 | { | 651 | { |
652 | struct rpc_rqst *req = task->tk_rqstp; | ||
653 | struct rpc_xprt *xprt = task->tk_xprt; | ||
652 | unsigned int bufsiz; | 654 | unsigned int bufsiz; |
653 | 655 | ||
654 | dprintk("RPC: %4d call_allocate (status %d)\n", | 656 | dprintk("RPC: %4d call_allocate (status %d)\n", |
655 | task->tk_pid, task->tk_status); | 657 | task->tk_pid, task->tk_status); |
656 | task->tk_action = call_bind; | 658 | task->tk_action = call_bind; |
657 | if (task->tk_buffer) | 659 | if (req->rq_buffer) |
658 | return; | 660 | return; |
659 | 661 | ||
660 | /* FIXME: compute buffer requirements more exactly using | 662 | /* FIXME: compute buffer requirements more exactly using |
661 | * auth->au_wslack */ | 663 | * auth->au_wslack */ |
662 | bufsiz = task->tk_msg.rpc_proc->p_bufsiz + RPC_SLACK_SPACE; | 664 | bufsiz = task->tk_msg.rpc_proc->p_bufsiz + RPC_SLACK_SPACE; |
663 | 665 | ||
664 | if (rpc_malloc(task, bufsiz << 1) != NULL) | 666 | if (xprt->ops->buf_alloc(task, bufsiz << 1) != NULL) |
665 | return; | 667 | return; |
666 | printk(KERN_INFO "RPC: buffer allocation failed for task %p\n", task); | 668 | printk(KERN_INFO "RPC: buffer allocation failed for task %p\n", task); |
667 | 669 | ||
@@ -704,14 +706,14 @@ call_encode(struct rpc_task *task) | |||
704 | task->tk_pid, task->tk_status); | 706 | task->tk_pid, task->tk_status); |
705 | 707 | ||
706 | /* Default buffer setup */ | 708 | /* Default buffer setup */ |
707 | bufsiz = task->tk_bufsize >> 1; | 709 | bufsiz = req->rq_bufsize >> 1; |
708 | sndbuf->head[0].iov_base = (void *)task->tk_buffer; | 710 | sndbuf->head[0].iov_base = (void *)req->rq_buffer; |
709 | sndbuf->head[0].iov_len = bufsiz; | 711 | sndbuf->head[0].iov_len = bufsiz; |
710 | sndbuf->tail[0].iov_len = 0; | 712 | sndbuf->tail[0].iov_len = 0; |
711 | sndbuf->page_len = 0; | 713 | sndbuf->page_len = 0; |
712 | sndbuf->len = 0; | 714 | sndbuf->len = 0; |
713 | sndbuf->buflen = bufsiz; | 715 | sndbuf->buflen = bufsiz; |
714 | rcvbuf->head[0].iov_base = (void *)((char *)task->tk_buffer + bufsiz); | 716 | rcvbuf->head[0].iov_base = (void *)((char *)req->rq_buffer + bufsiz); |
715 | rcvbuf->head[0].iov_len = bufsiz; | 717 | rcvbuf->head[0].iov_len = bufsiz; |
716 | rcvbuf->tail[0].iov_len = 0; | 718 | rcvbuf->tail[0].iov_len = 0; |
717 | rcvbuf->page_len = 0; | 719 | rcvbuf->page_len = 0; |