Lines Matching refs:to
26 * If the call timed out, it may choose to retry the operation by
84 * xprt_reserve_xprt - serialize write access to transports
85 * @task: task that is requesting access to the transport
111 dprintk("RPC: %5u failed to lock transport %p\n",
134 * xprt_reserve_xprt_cong - serialize write access to transports
135 * @task: task that is requesting access to the transport
138 * integrated into the decision of whether a request is allowed to be
139 * woken up and given access to the transport.
161 dprintk("RPC: %5u failed to lock transport %p\n", task->tk_pid, xprt);
236 * xprt_release_xprt - allow other requests to use a transport
238 * @task: task that is releasing access to the transport
251 * xprt_release_xprt_cong - allow other requests to use a transport
253 * @task: task that is releasing access to the transport
255 * Note that "task" can be NULL. Another task is awoken to use the
275 * overflowed. Put the task to sleep if this is the case.
295 * that has been sleeping due to congestion
320 * @task: recently completed RPC request used to adjust window
323 * We use a time-smoothed congestion estimator to avoid heavy oscillation.
352 * @status: result code to plant in each task before waking it
364 * xprt_wait_for_buffer_space - wait for transport output buffer to clear
365 * @task: task to be put to sleep
399 * @task: task whose timeout is to be set
412 * @task: task whose timeout is to be set
431 struct rpc_timeout *to = &req->rq_xprt->timeout;
434 if (to->to_exponential)
435 req->rq_majortimeo <<= to->to_retries;
437 req->rq_majortimeo += to->to_increment * to->to_retries;
438 if (req->rq_majortimeo > to->to_maxval || req->rq_majortimeo == 0)
439 req->rq_majortimeo = to->to_maxval;
445 * @req: RPC request containing parameters to use for the adjustment
451 struct rpc_timeout *to = &xprt->timeout;
455 if (to->to_exponential)
458 req->rq_timeout += to->to_increment;
459 if (to->to_maxval && req->rq_timeout >= to->to_maxval)
460 req->rq_timeout = to->to_maxval;
463 req->rq_timeout = to->to_initval;
468 rpc_init_rtt(req->rq_task->tk_client->cl_rtt, to->to_initval);
492 * @xprt: transport to flag for disconnect
584 dprintk("RPC: %5u xprt_connect_status: error %d connecting to "
593 * xprt_lookup_rqst - find an RPC request corresponding to an XID
677 * @task: RPC task about to send a request
716 * We have to copy the iovec because sendmsg fiddles with its contents.
732 /* Add request to the receive list */
873 * @to: RPC timeout parameters to set up
878 void xprt_set_timeout(struct rpc_timeout *to, unsigned int retr, unsigned long incr)
880 to->to_initval =
881 to->to_increment = incr;
882 to->to_maxval = to->to_initval + (incr * retr);
883 to->to_retries = retr;
884 to->to_exponential = 0;
892 * @to: timeout parameters
895 struct rpc_xprt *xprt_create_transport(int proto, struct sockaddr *ap, size_t size, struct rpc_timeout *to)
902 xprt = xs_setup_udp(ap, size, to);
905 xprt = xs_setup_tcp(ap, size, to);
952 * @kref: kref for the transport to destroy
970 * xprt_put - release a reference to an RPC transport.
971 * @xprt: pointer to the transport
980 * xprt_get - return a reference to an RPC transport.
981 * @xprt: pointer to the transport