tag | line | file | source code |
rsock | 87 | fs/nfs/inode.c | rpc_closesock(sb->u.nfs_sb.s_server.rsock); |
rsock | 192 | fs/nfs/inode.c | if ((server->rsock = rpc_makesock(filp)) == NULL) { |
rsock | 51 | fs/nfs/nfsiod.c | if (rpc_reserve(server->rsock, &req->rq_rpcreq, 1) < 0) { |
rsock | 68 | fs/nfs/nfsiod.c | rpc_release(req->rq_server->rsock, &req->rq_rpcreq); |
rsock | 83 | fs/nfs/nfsiod.c | result = rpc_transmit(req->rq_server->rsock, &req->rq_rpcreq); |
rsock | 1530 | fs/nfs/nfsroot.c | s.rsock = rpc_makesock(nfs_file); |
rsock | 67 | fs/nfs/rpcsock.c | rpc_insque(struct rpc_sock *rsock, struct rpc_wait *slot) |
rsock | 69 | fs/nfs/rpcsock.c | struct rpc_wait *next = rsock->pending; |
rsock | 75 | fs/nfs/rpcsock.c | rsock->pending = slot; |
rsock | 85 | fs/nfs/rpcsock.c | rpc_remque(struct rpc_sock *rsock, struct rpc_wait *slot) |
rsock | 93 | fs/nfs/rpcsock.c | rsock->pending = next; |
rsock | 99 | fs/nfs/rpcsock.c | slot, rsock->pending); |
rsock | 106 | fs/nfs/rpcsock.c | rpc_sendmsg(struct rpc_sock *rsock, struct iovec *iov, int nr, int len, |
rsock | 109 | fs/nfs/rpcsock.c | struct socket *sock = rsock->sock; |
rsock | 132 | fs/nfs/rpcsock.c | rpc_recvmsg(struct rpc_sock *rsock, struct iovec *iov, |
rsock | 135 | fs/nfs/rpcsock.c | struct socket *sock = rsock->sock; |
rsock | 161 | fs/nfs/rpcsock.c | rpc_select(struct rpc_sock *rsock) |
rsock | 164 | fs/nfs/rpcsock.c | struct file *file = rsock->file; |
rsock | 192 | fs/nfs/rpcsock.c | rpc_reserve(struct rpc_sock *rsock, struct rpc_ioreq *req, int nocwait) |
rsock | 198 | fs/nfs/rpcsock.c | while (!(slot = rsock->free) || rsock->cong >= rsock->cwnd) { |
rsock | 204 | fs/nfs/rpcsock.c | interruptible_sleep_on(&rsock->backlog); |
rsock | 209 | fs/nfs/rpcsock.c | if (rsock->shutdown) |
rsock | 213 | fs/nfs/rpcsock.c | rsock->free = slot->w_next; |
rsock | 214 | fs/nfs/rpcsock.c | rsock->cong += RPC_CWNDSCALE; /* bump congestion value */ |
rsock | 229 | fs/nfs/rpcsock.c | rpc_release(struct rpc_sock *rsock, struct rpc_ioreq *req) |
rsock | 237 | fs/nfs/rpcsock.c | if (slot == rsock->pending && slot->w_next != NULL) |
rsock | 242 | fs/nfs/rpcsock.c | rpc_remque(rsock, slot); |
rsock | 243 | fs/nfs/rpcsock.c | slot->w_next = rsock->free; |
rsock | 244 | fs/nfs/rpcsock.c | rsock->free = slot; |
rsock | 247 | fs/nfs/rpcsock.c | rsock->cong -= RPC_CWNDSCALE; |
rsock | 248 | fs/nfs/rpcsock.c | if (rsock->cong < rsock->cwnd && rsock->backlog) |
rsock | 249 | fs/nfs/rpcsock.c | wake_up(&rsock->backlog); |
rsock | 250 | fs/nfs/rpcsock.c | if (rsock->shutdown) |
rsock | 251 | fs/nfs/rpcsock.c | wake_up(&rsock->shutwait); |
rsock | 261 | fs/nfs/rpcsock.c | rpc_cwnd_adjust(struct rpc_sock *rsock, int timeout) |
rsock | 263 | fs/nfs/rpcsock.c | unsigned long cwnd = rsock->cwnd; |
rsock | 266 | fs/nfs/rpcsock.c | if (rsock->cong >= cwnd) { |
rsock | 280 | fs/nfs/rpcsock.c | rsock->cong, rsock->cwnd, cwnd); |
rsock | 282 | fs/nfs/rpcsock.c | rsock->cwnd = cwnd; |
rsock | 302 | fs/nfs/rpcsock.c | rpc_send(struct rpc_sock *rsock, struct rpc_wait *slot) |
rsock | 307 | fs/nfs/rpcsock.c | if (rsock->shutdown) |
rsock | 313 | fs/nfs/rpcsock.c | rpc_insque(rsock, slot); |
rsock | 317 | fs/nfs/rpcsock.c | return rpc_sendmsg(rsock, iov, req->rq_snr, req->rq_slen, |
rsock | 325 | fs/nfs/rpcsock.c | rpc_transmit(struct rpc_sock *rsock, struct rpc_ioreq *req) |
rsock | 328 | fs/nfs/rpcsock.c | return rpc_send(rsock, req->rq_slot); |
rsock | 335 | fs/nfs/rpcsock.c | rpc_grok(struct rpc_sock *rsock) |
rsock | 345 | fs/nfs/rpcsock.c | result = rpc_recvmsg(rsock, iov, 1, sizeof(xid), MSG_PEEK); |
rsock | 367 | fs/nfs/rpcsock.c | for (rovr = rsock->pending; rovr; rovr = rovr->w_next) { |
rsock | 383 | fs/nfs/rpcsock.c | rpc_recvmsg(rsock, iov, 1, sizeof(xid), 0); |
rsock | 391 | fs/nfs/rpcsock.c | result = rpc_recvmsg(rsock, iov, req->rq_rnr, req->rq_rlen, 0); |
rsock | 405 | fs/nfs/rpcsock.c | rpc_recv(struct rpc_sock *rsock, struct rpc_wait *slot) |
rsock | 412 | fs/nfs/rpcsock.c | while (rsock->pending != slot) { |
rsock | 419 | fs/nfs/rpcsock.c | if (rsock->shutdown) |
rsock | 426 | fs/nfs/rpcsock.c | if ((result = rpc_select(rsock)) < 0) { |
rsock | 432 | fs/nfs/rpcsock.c | if ((result = rpc_grok(rsock)) < 0) |
rsock | 446 | fs/nfs/rpcsock.c | rpc_doio(struct rpc_sock *rsock, struct rpc_ioreq *req, |
rsock | 461 | fs/nfs/rpcsock.c | result = rpc_reserve(rsock, req, 0); |
rsock | 469 | fs/nfs/rpcsock.c | rpc_insque(rsock, slot); |
rsock | 480 | fs/nfs/rpcsock.c | if (sent || (result = rpc_send(rsock, slot)) >= 0) { |
rsock | 481 | fs/nfs/rpcsock.c | result = rpc_recv(rsock, slot); |
rsock | 487 | fs/nfs/rpcsock.c | rpc_cwnd_adjust(rsock, 0); |
rsock | 491 | fs/nfs/rpcsock.c | rpc_cwnd_adjust(rsock, 1); |
rsock | 513 | fs/nfs/rpcsock.c | rpc_call(struct rpc_sock *rsock, struct rpc_ioreq *req, |
rsock | 518 | fs/nfs/rpcsock.c | result = rpc_doio(rsock, req, strategy, 0); |
rsock | 521 | fs/nfs/rpcsock.c | rpc_release(rsock, req); |
rsock | 528 | fs/nfs/rpcsock.c | struct rpc_sock *rsock; |
rsock | 542 | fs/nfs/rpcsock.c | if ((rsock = kmalloc(sizeof(struct rpc_sock), GFP_KERNEL)) == NULL) |
rsock | 544 | fs/nfs/rpcsock.c | memset(rsock, 0, sizeof(*rsock)); /* Nnnngh! */ |
rsock | 546 | fs/nfs/rpcsock.c | rsock->sock = sock; |
rsock | 547 | fs/nfs/rpcsock.c | rsock->inet = sk; |
rsock | 548 | fs/nfs/rpcsock.c | rsock->file = file; |
rsock | 549 | fs/nfs/rpcsock.c | rsock->cwnd = RPC_INITCWND; |
rsock | 551 | fs/nfs/rpcsock.c | dprintk("RPC: slots %p, %p, ...\n", rsock->waiting, rsock->waiting + 1); |
rsock | 552 | fs/nfs/rpcsock.c | rsock->free = rsock->waiting; |
rsock | 553 | fs/nfs/rpcsock.c | for (i = 0, slot = rsock->waiting; i < RPC_MAXREQS-1; i++, slot++) |
rsock | 557 | fs/nfs/rpcsock.c | dprintk("RPC: made socket %p\n", rsock); |
rsock | 558 | fs/nfs/rpcsock.c | return rsock; |
rsock | 562 | fs/nfs/rpcsock.c | rpc_closesock(struct rpc_sock *rsock) |
rsock | 566 | fs/nfs/rpcsock.c | rsock->shutdown = 1; |
rsock | 567 | fs/nfs/rpcsock.c | while (rsock->pending || rsock->backlog) { |
rsock | 568 | fs/nfs/rpcsock.c | interruptible_sleep_on(&rsock->shutwait); |
rsock | 579 | fs/nfs/rpcsock.c | kfree(rsock); |
rsock | 90 | fs/nfs/sock.c | result = rpc_doio(server->rsock, req, &timeout, async); |
rsock | 91 | fs/nfs/sock.c | rpc_release(server->rsock, req); /* Release slot */ |
rsock | 9 | include/linux/nfs_fs_sb.h | struct rpc_sock *rsock; |
rsock | 31 | include/linux/rpcsock.h | #define RPC_CONGESTED(rsock) ((rsock)->cong >= (rsock)->cwnd) |