Commit 1d8206b9 authored by Tom Tucker's avatar Tom Tucker Committed by J. Bruce Fields
Browse files

svc: Add an svc transport class 



The transport class (svc_xprt_class) represents a type of transport, e.g.
udp, tcp, rdma.  A transport class has a unique name and a set of transport
operations kept in the svc_xprt_ops structure.

A transport class can be dynamically registered and unregisterd. The
svc_xprt_class represents the module that implements the transport
type and keeps reference counts on the module to avoid unloading while
there are active users.

The endpoint (svc_xprt) is a generic, transport independent endpoint that can
be used to send and receive data for an RPC service. It inherits it's
operations from the transport class.

A transport driver module registers and unregisters itself with svc sunrpc
by calling svc_reg_xprt_class, and svc_unreg_xprt_class respectively.

Signed-off-by: default avatarTom Tucker <tom@opengridcomputing.com>
Acked-by: default avatarNeil Brown <neilb@suse.de>
Reviewed-by: default avatarChuck Lever <chuck.lever@oracle.com>
Reviewed-by: default avatarGreg Banks <gnb@sgi.com>
Signed-off-by: default avatarJ. Bruce Fields <bfields@citi.umich.edu>
parent cb5c7d66

include/linux/sunrpc/debug.h

+1 −0
Original line number Diff line number Diff line
@@ -21,6 +21,7 @@ 
#define RPCDBG_SCHED		0x0040

#define RPCDBG_TRANS		0x0080

#define RPCDBG_SVCSOCK		0x0100

#define RPCDBG_SVCXPRT		0x0100

#define RPCDBG_SVCDSP		0x0200

#define RPCDBG_MISC		0x0400

#define RPCDBG_CACHE		0x0800

include/linux/sunrpc/svc_xprt.h

0 → 100644
+31 −0
Original line number Diff line number Diff line 
/*

 * linux/include/linux/sunrpc/svc_xprt.h

 *

 * RPC server transport I/O

 */



#ifndef SUNRPC_SVC_XPRT_H

#define SUNRPC_SVC_XPRT_H



#include <linux/sunrpc/svc.h>



struct svc_xprt_ops {

};



struct svc_xprt_class {

	const char		*xcl_name;

	struct module		*xcl_owner;

	struct svc_xprt_ops	*xcl_ops;

	struct list_head	xcl_list;

};



struct svc_xprt {

	struct svc_xprt_class	*xpt_class;

	struct svc_xprt_ops	*xpt_ops;

};



int	svc_reg_xprt_class(struct svc_xprt_class *);

void	svc_unreg_xprt_class(struct svc_xprt_class *);

void	svc_xprt_init(struct svc_xprt_class *, struct svc_xprt *);



#endif /* SUNRPC_SVC_XPRT_H */

net/sunrpc/Makefile

+2 −1
Original line number Diff line number Diff line
@@ -11,6 +11,7 @@ sunrpc-y := clnt.o xprt.o socklib.o xprtsock.o sched.o \ 
	    auth.o auth_null.o auth_unix.o \

	    svc.o svcsock.o svcauth.o svcauth_unix.o \

	    rpcb_clnt.o timer.o xdr.o \

	    sunrpc_syms.o cache.o rpc_pipe.o

	    sunrpc_syms.o cache.o rpc_pipe.o \

	    svc_xprt.o

sunrpc-$(CONFIG_PROC_FS) += stats.o

sunrpc-$(CONFIG_SYSCTL) += sysctl.o

net/sunrpc/svc_xprt.c

0 → 100644
+83 −0
Original line number Diff line number Diff line 
/*

 * linux/net/sunrpc/svc_xprt.c

 *

 * Author: Tom Tucker <tom@opengridcomputing.com>

 */



#include <linux/sched.h>

#include <linux/errno.h>

#include <linux/fcntl.h>

#include <linux/net.h>

#include <linux/in.h>

#include <linux/inet.h>

#include <linux/udp.h>

#include <linux/tcp.h>

#include <linux/unistd.h>

#include <linux/slab.h>

#include <linux/netdevice.h>

#include <linux/skbuff.h>

#include <linux/file.h>

#include <linux/freezer.h>

#include <net/sock.h>

#include <net/checksum.h>

#include <net/ip.h>

#include <net/ipv6.h>

#include <net/tcp_states.h>

#include <linux/uaccess.h>

#include <asm/ioctls.h>



#include <linux/sunrpc/types.h>

#include <linux/sunrpc/clnt.h>

#include <linux/sunrpc/xdr.h>

#include <linux/sunrpc/svcsock.h>

#include <linux/sunrpc/stats.h>

#include <linux/sunrpc/svc_xprt.h>



#define RPCDBG_FACILITY	RPCDBG_SVCXPRT



/* List of registered transport classes */

static DEFINE_SPINLOCK(svc_xprt_class_lock);

static LIST_HEAD(svc_xprt_class_list);



int svc_reg_xprt_class(struct svc_xprt_class *xcl)

{

	struct svc_xprt_class *cl;

	int res = -EEXIST;



	dprintk("svc: Adding svc transport class '%s'\n", xcl->xcl_name);



	INIT_LIST_HEAD(&xcl->xcl_list);

	spin_lock(&svc_xprt_class_lock);

	/* Make sure there isn't already a class with the same name */

	list_for_each_entry(cl, &svc_xprt_class_list, xcl_list) {

		if (strcmp(xcl->xcl_name, cl->xcl_name) == 0)

			goto out;

	}

	list_add_tail(&xcl->xcl_list, &svc_xprt_class_list);

	res = 0;

out:

	spin_unlock(&svc_xprt_class_lock);

	return res;

}

EXPORT_SYMBOL_GPL(svc_reg_xprt_class);



void svc_unreg_xprt_class(struct svc_xprt_class *xcl)

{

	dprintk("svc: Removing svc transport class '%s'\n", xcl->xcl_name);

	spin_lock(&svc_xprt_class_lock);

	list_del_init(&xcl->xcl_list);

	spin_unlock(&svc_xprt_class_lock);

}

EXPORT_SYMBOL_GPL(svc_unreg_xprt_class);



/*

 * Called by transport drivers to initialize the transport independent

 * portion of the transport instance.

 */

void svc_xprt_init(struct svc_xprt_class *xcl, struct svc_xprt *xprt)

{

	memset(xprt, 0, sizeof(*xprt));

	xprt->xpt_class = xcl;

	xprt->xpt_ops = xcl->xcl_ops;

}

EXPORT_SYMBOL_GPL(svc_xprt_init);

CRA Git | Maintained and supported by SUSTech CRA and CCSE