taglinefilesource code
rsock87fs/nfs/inode.crpc_closesock(sb->u.nfs_sb.s_server.rsock);
rsock192fs/nfs/inode.cif ((server->rsock = rpc_makesock(filp)) == NULL) {
rsock51fs/nfs/nfsiod.cif (rpc_reserve(server->rsock, &req->rq_rpcreq, 1) < 0) {
rsock68fs/nfs/nfsiod.crpc_release(req->rq_server->rsock, &req->rq_rpcreq);
rsock83fs/nfs/nfsiod.cresult = rpc_transmit(req->rq_server->rsock, &req->rq_rpcreq);
rsock1530fs/nfs/nfsroot.cs.rsock = rpc_makesock(nfs_file);
rsock67fs/nfs/rpcsock.crpc_insque(struct rpc_sock *rsock, struct rpc_wait *slot)
rsock69fs/nfs/rpcsock.cstruct rpc_wait  *next = rsock->pending;
rsock75fs/nfs/rpcsock.crsock->pending = slot;
rsock85fs/nfs/rpcsock.crpc_remque(struct rpc_sock *rsock, struct rpc_wait *slot)
rsock93fs/nfs/rpcsock.crsock->pending = next;
rsock99fs/nfs/rpcsock.cslot, rsock->pending);
rsock106fs/nfs/rpcsock.crpc_sendmsg(struct rpc_sock *rsock, struct iovec *iov, int nr, int len,
rsock109fs/nfs/rpcsock.cstruct socket  *sock = rsock->sock;
rsock132fs/nfs/rpcsock.crpc_recvmsg(struct rpc_sock *rsock, struct iovec *iov,
rsock135fs/nfs/rpcsock.cstruct socket  *sock = rsock->sock;
rsock161fs/nfs/rpcsock.crpc_select(struct rpc_sock *rsock)
rsock164fs/nfs/rpcsock.cstruct file  *file = rsock->file;
rsock192fs/nfs/rpcsock.crpc_reserve(struct rpc_sock *rsock, struct rpc_ioreq *req, int nocwait)
rsock198fs/nfs/rpcsock.cwhile (!(slot = rsock->free) || rsock->cong >= rsock->cwnd) {
rsock204fs/nfs/rpcsock.cinterruptible_sleep_on(&rsock->backlog);
rsock209fs/nfs/rpcsock.cif (rsock->shutdown)
rsock213fs/nfs/rpcsock.crsock->free = slot->w_next;
rsock214fs/nfs/rpcsock.crsock->cong += RPC_CWNDSCALE;  /* bump congestion value */
rsock229fs/nfs/rpcsock.crpc_release(struct rpc_sock *rsock, struct rpc_ioreq *req)
rsock237fs/nfs/rpcsock.cif (slot == rsock->pending && slot->w_next != NULL)
rsock242fs/nfs/rpcsock.crpc_remque(rsock, slot);
rsock243fs/nfs/rpcsock.cslot->w_next = rsock->free;
rsock244fs/nfs/rpcsock.crsock->free = slot;
rsock247fs/nfs/rpcsock.crsock->cong -= RPC_CWNDSCALE;
rsock248fs/nfs/rpcsock.cif (rsock->cong < rsock->cwnd && rsock->backlog)
rsock249fs/nfs/rpcsock.cwake_up(&rsock->backlog);
rsock250fs/nfs/rpcsock.cif (rsock->shutdown)
rsock251fs/nfs/rpcsock.cwake_up(&rsock->shutwait);
rsock261fs/nfs/rpcsock.crpc_cwnd_adjust(struct rpc_sock *rsock, int timeout)
rsock263fs/nfs/rpcsock.cunsigned long  cwnd = rsock->cwnd;
rsock266fs/nfs/rpcsock.cif (rsock->cong >= cwnd) {
rsock280fs/nfs/rpcsock.crsock->cong, rsock->cwnd, cwnd);
rsock282fs/nfs/rpcsock.crsock->cwnd = cwnd;
rsock302fs/nfs/rpcsock.crpc_send(struct rpc_sock *rsock, struct rpc_wait *slot)
rsock307fs/nfs/rpcsock.cif (rsock->shutdown)
rsock313fs/nfs/rpcsock.crpc_insque(rsock, slot);
rsock317fs/nfs/rpcsock.creturn rpc_sendmsg(rsock, iov, req->rq_snr, req->rq_slen,
rsock325fs/nfs/rpcsock.crpc_transmit(struct rpc_sock *rsock, struct rpc_ioreq *req)
rsock328fs/nfs/rpcsock.creturn rpc_send(rsock, req->rq_slot);
rsock335fs/nfs/rpcsock.crpc_grok(struct rpc_sock *rsock)
rsock345fs/nfs/rpcsock.cresult = rpc_recvmsg(rsock, iov, 1, sizeof(xid), MSG_PEEK);
rsock367fs/nfs/rpcsock.cfor (rovr = rsock->pending; rovr; rovr = rovr->w_next) {
rsock383fs/nfs/rpcsock.crpc_recvmsg(rsock, iov, 1, sizeof(xid), 0);
rsock391fs/nfs/rpcsock.cresult = rpc_recvmsg(rsock, iov, req->rq_rnr, req->rq_rlen, 0);
rsock405fs/nfs/rpcsock.crpc_recv(struct rpc_sock *rsock, struct rpc_wait *slot)
rsock412fs/nfs/rpcsock.cwhile (rsock->pending != slot) {
rsock419fs/nfs/rpcsock.cif (rsock->shutdown)
rsock426fs/nfs/rpcsock.cif ((result = rpc_select(rsock)) < 0) {
rsock432fs/nfs/rpcsock.cif ((result = rpc_grok(rsock)) < 0)
rsock446fs/nfs/rpcsock.crpc_doio(struct rpc_sock *rsock, struct rpc_ioreq *req,
rsock461fs/nfs/rpcsock.cresult = rpc_reserve(rsock, req, 0);
rsock469fs/nfs/rpcsock.crpc_insque(rsock, slot);
rsock480fs/nfs/rpcsock.cif (sent || (result = rpc_send(rsock, slot)) >= 0) {
rsock481fs/nfs/rpcsock.cresult = rpc_recv(rsock, slot);
rsock487fs/nfs/rpcsock.crpc_cwnd_adjust(rsock, 0);
rsock491fs/nfs/rpcsock.crpc_cwnd_adjust(rsock, 1);
rsock513fs/nfs/rpcsock.crpc_call(struct rpc_sock *rsock, struct rpc_ioreq *req,
rsock518fs/nfs/rpcsock.cresult = rpc_doio(rsock, req, strategy, 0);
rsock521fs/nfs/rpcsock.crpc_release(rsock, req);
rsock528fs/nfs/rpcsock.cstruct rpc_sock  *rsock;
rsock542fs/nfs/rpcsock.cif ((rsock = kmalloc(sizeof(struct rpc_sock), GFP_KERNEL)) == NULL)
rsock544fs/nfs/rpcsock.cmemset(rsock, 0, sizeof(*rsock)); /* Nnnngh! */
rsock546fs/nfs/rpcsock.crsock->sock = sock;
rsock547fs/nfs/rpcsock.crsock->inet = sk;
rsock548fs/nfs/rpcsock.crsock->file = file;
rsock549fs/nfs/rpcsock.crsock->cwnd = RPC_INITCWND;
rsock551fs/nfs/rpcsock.cdprintk("RPC: slots %p, %p, ...\n", rsock->waiting, rsock->waiting + 1);
rsock552fs/nfs/rpcsock.crsock->free = rsock->waiting;
rsock553fs/nfs/rpcsock.cfor (i = 0, slot = rsock->waiting; i < RPC_MAXREQS-1; i++, slot++)
rsock557fs/nfs/rpcsock.cdprintk("RPC: made socket %p\n", rsock);
rsock558fs/nfs/rpcsock.creturn rsock;
rsock562fs/nfs/rpcsock.crpc_closesock(struct rpc_sock *rsock)
rsock566fs/nfs/rpcsock.crsock->shutdown = 1;
rsock567fs/nfs/rpcsock.cwhile (rsock->pending || rsock->backlog) {
rsock568fs/nfs/rpcsock.cinterruptible_sleep_on(&rsock->shutwait);
rsock579fs/nfs/rpcsock.ckfree(rsock);
rsock90fs/nfs/sock.cresult = rpc_doio(server->rsock, req, &timeout, async);
rsock91fs/nfs/sock.crpc_release(server->rsock, req);  /* Release slot */
rsock9include/linux/nfs_fs_sb.hstruct rpc_sock *rsock;
rsock31include/linux/rpcsock.h#define RPC_CONGESTED(rsock)  ((rsock)->cong >= (rsock)->cwnd)