Return-Path: Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S261474AbVB0SMo (ORCPT ); Sun, 27 Feb 2005 13:12:44 -0500 Received: (majordomo@vger.kernel.org) by vger.kernel.org id S261480AbVB0Rqc (ORCPT ); Sun, 27 Feb 2005 12:46:32 -0500 Received: from news.suse.de ([195.135.220.2]:11683 "EHLO Cantor.suse.de") by vger.kernel.org with ESMTP id S261462AbVB0RXF (ORCPT ); Sun, 27 Feb 2005 12:23:05 -0500 Message-Id: <20050227170313.091875000@blunzn.suse.de> References: <20050227165954.566746000@blunzn.suse.de> Date: Sun, 27 Feb 2005 18:00:00 +0100 From: Andreas Gruenbacher To: linux-kernel@vger.kernel.org, Neil Brown , Trond Myklebust Cc: Olaf Kirch , "Andries E. Brouwer" , Andrew Morton Subject: [nfsacl v2 06/16] Allow multiple programs to share the same transport Content-Disposition: inline; filename=nfsacl-allow-multiple-programs-to-share-the-same-transport.patch Sender: linux-kernel-owner@vger.kernel.org X-Mailing-List: linux-kernel@vger.kernel.org Content-Length: 4411 Lines: 120 Allow a clone of an RPC client (created with rpc_clone_client()) to change to another program. This allows the NFS and NFSACL programs to share the same transport. Signed-off-by: Andreas Gruenbacher Acked-by: Olaf Kirch Index: linux-2.6.11-rc5/include/linux/sunrpc/clnt.h =================================================================== --- linux-2.6.11-rc5.orig/include/linux/sunrpc/clnt.h +++ linux-2.6.11-rc5/include/linux/sunrpc/clnt.h @@ -22,6 +22,7 @@ * This defines an RPC port mapping */ struct rpc_portmap { + struct rpc_portmap *pm_parent; __u32 pm_prog; __u32 pm_vers; __u32 pm_prot; @@ -116,6 +117,8 @@ struct rpc_clnt *rpc_clone_client(struct int rpc_shutdown_client(struct rpc_clnt *); int rpc_destroy_client(struct rpc_clnt *); void rpc_release_client(struct rpc_clnt *); +void rpc_change_program(struct rpc_clnt *, struct rpc_program *, + int); void rpc_getport(struct rpc_task *, struct rpc_clnt *); int rpc_register(u32, u32, int, unsigned short, int *); Index: linux-2.6.11-rc5/net/sunrpc/clnt.c =================================================================== --- linux-2.6.11-rc5.orig/net/sunrpc/clnt.c +++ linux-2.6.11-rc5/net/sunrpc/clnt.c @@ -139,6 +139,7 @@ rpc_create_client(struct rpc_xprt *xprt, clnt->cl_maxproc = version->nrprocs; clnt->cl_protname = program->name; clnt->cl_pmap = &clnt->cl_pmap_default; + clnt->cl_pmap->pm_parent = clnt->cl_pmap; clnt->cl_port = xprt->addr.sin_port; clnt->cl_prog = program->number; clnt->cl_vers = version->number; @@ -207,6 +208,9 @@ rpc_clone_client(struct rpc_clnt *clnt) rpc_init_rtt(&new->cl_rtt_default, clnt->cl_xprt->timeout.to_initval); if (new->cl_auth) atomic_inc(&new->cl_auth->au_count); + new->cl_pmap = &new->cl_pmap_default; + new->cl_pmap->pm_parent = clnt->cl_pmap->pm_parent; + rpc_init_wait_queue(&new->cl_pmap_default.pm_bindwait, "bindwait"); return new; out_no_clnt: printk(KERN_INFO "RPC: out of memory in %s\n", __FUNCTION__); @@ -296,6 +300,25 @@ rpc_release_client(struct rpc_clnt *clnt } /* + * Change the program of a (usually cloned) client + */ +void +rpc_change_program(struct rpc_clnt *clnt, struct rpc_program *program, + int vers) +{ + struct rpc_version *version; + + BUG_ON(vers >= program->nrvers || !program->version[vers]); + version = program->version[vers]; + clnt->cl_procinfo = version->procs; + clnt->cl_maxproc = version->nrprocs; + clnt->cl_protname = program->name; + clnt->cl_prog = program->number; + clnt->cl_vers = version->number; + clnt->cl_stats = program->stats; +} + +/* * Default callback for async RPC calls */ static void Index: linux-2.6.11-rc5/net/sunrpc/pmap_clnt.c =================================================================== --- linux-2.6.11-rc5.orig/net/sunrpc/pmap_clnt.c +++ linux-2.6.11-rc5/net/sunrpc/pmap_clnt.c @@ -41,7 +41,7 @@ static spinlock_t pmap_lock = SPIN_LOCK void rpc_getport(struct rpc_task *task, struct rpc_clnt *clnt) { - struct rpc_portmap *map = clnt->cl_pmap; + struct rpc_portmap *map = clnt->cl_pmap->pm_parent; struct sockaddr_in *sap = &clnt->cl_xprt->addr; struct rpc_message msg = { .rpc_proc = &pmap_procedures[PMAP_GETPORT], @@ -132,7 +132,7 @@ static void pmap_getport_done(struct rpc_task *task) { struct rpc_clnt *clnt = task->tk_client; - struct rpc_portmap *map = clnt->cl_pmap; + struct rpc_portmap *map = clnt->cl_pmap->pm_parent; dprintk("RPC: %4d pmap_getport_done(status %d, port %d)\n", task->tk_pid, task->tk_status, clnt->cl_port); Index: linux-2.6.11-rc5/net/sunrpc/sunrpc_syms.c =================================================================== --- linux-2.6.11-rc5.orig/net/sunrpc/sunrpc_syms.c +++ linux-2.6.11-rc5/net/sunrpc/sunrpc_syms.c @@ -42,6 +42,7 @@ EXPORT_SYMBOL(rpc_release_task); /* RPC client functions */ EXPORT_SYMBOL(rpc_create_client); EXPORT_SYMBOL(rpc_clone_client); +EXPORT_SYMBOL(rpc_change_program); EXPORT_SYMBOL(rpc_destroy_client); EXPORT_SYMBOL(rpc_shutdown_client); EXPORT_SYMBOL(rpc_release_client); -- Andreas Gruenbacher SUSE Labs, SUSE LINUX PRODUCTS GMBH - To unsubscribe from this list: send the line "unsubscribe linux-kernel" in the body of a message to majordomo@vger.kernel.org More majordomo info at http://vger.kernel.org/majordomo-info.html Please read the FAQ at http://www.tux.org/lkml/