diff options
author | Shehjar Tikoo <shehjart@gluster.com> | 2010-08-10 02:41:54 +0000 |
---|---|---|
committer | Anand V. Avati <avati@dev.gluster.com> | 2010-08-10 02:44:22 -0700 |
commit | 0af39ff8d03173a7ba3df1b13476b7ed447131aa (patch) | |
tree | 2180ff57269b73aa8fee6a5802a8d5d4a169f624 /xlators/nfs/lib | |
parent | b0304d47f67aa8fa677e4898fa46b96df88c8322 (diff) |
nfs, nfs/rpc: Rename functions to prevent gfrpcsvc conflict
Signed-off-by: Shehjar Tikoo <shehjart@gluster.com>
Signed-off-by: Anand V. Avati <avati@dev.gluster.com>
BUG: 1274 (nfs fails to start)
URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=1274
Diffstat (limited to 'xlators/nfs/lib')
-rw-r--r-- | xlators/nfs/lib/src/auth-null.c | 19 | ||||
-rw-r--r-- | xlators/nfs/lib/src/auth-unix.c | 23 | ||||
-rw-r--r-- | xlators/nfs/lib/src/msg-nfs3.c | 194 | ||||
-rw-r--r-- | xlators/nfs/lib/src/rpc-socket.c | 34 | ||||
-rw-r--r-- | xlators/nfs/lib/src/rpc-socket.h | 22 | ||||
-rw-r--r-- | xlators/nfs/lib/src/rpcsvc-auth.c | 66 | ||||
-rw-r--r-- | xlators/nfs/lib/src/rpcsvc.c | 682 | ||||
-rw-r--r-- | xlators/nfs/lib/src/rpcsvc.h | 151 | ||||
-rw-r--r-- | xlators/nfs/lib/src/xdr-common.h | 14 | ||||
-rw-r--r-- | xlators/nfs/lib/src/xdr-rpc.c | 44 | ||||
-rw-r--r-- | xlators/nfs/lib/src/xdr-rpc.h | 54 |
11 files changed, 676 insertions, 627 deletions
diff --git a/xlators/nfs/lib/src/auth-null.c b/xlators/nfs/lib/src/auth-null.c index b162db112..a98d47280 100644 --- a/xlators/nfs/lib/src/auth-null.c +++ b/xlators/nfs/lib/src/auth-null.c @@ -29,7 +29,7 @@ int -auth_null_request_init (rpcsvc_request_t *req, void *priv) +nfs_auth_null_request_init (rpcsvc_request_t *req, void *priv) { if (!req) return -1; @@ -43,29 +43,30 @@ auth_null_request_init (rpcsvc_request_t *req, void *priv) return 0; } -int auth_null_authenticate (rpcsvc_request_t *req, void *priv) +int +nfs_auth_null_authenticate (rpcsvc_request_t *req, void *priv) { /* Always succeed. */ return RPCSVC_AUTH_ACCEPT; } -rpcsvc_auth_ops_t auth_null_ops = { +rpcsvc_auth_ops_t nfs_auth_null_ops = { .conn_init = NULL, - .request_init = auth_null_request_init, - .authenticate = auth_null_authenticate + .request_init = nfs_auth_null_request_init, + .authenticate = nfs_auth_null_authenticate }; -rpcsvc_auth_t rpcsvc_auth_null = { +rpcsvc_auth_t nfs_rpcsvc_auth_null = { .authname = "AUTH_NULL", .authnum = AUTH_NULL, - .authops = &auth_null_ops, + .authops = &nfs_auth_null_ops, .authprivate = NULL }; rpcsvc_auth_t * -rpcsvc_auth_null_init (rpcsvc_t *svc, dict_t *options) +nfs_rpcsvc_auth_null_init (rpcsvc_t *svc, dict_t *options) { - return &rpcsvc_auth_null; + return &nfs_rpcsvc_auth_null; } diff --git a/xlators/nfs/lib/src/auth-unix.c b/xlators/nfs/lib/src/auth-unix.c index 0eaf06866..a3e9c83ba 100644 --- a/xlators/nfs/lib/src/auth-unix.c +++ b/xlators/nfs/lib/src/auth-unix.c @@ -31,7 +31,7 @@ int -auth_unix_request_init (rpcsvc_request_t *req, void *priv) +nfs_auth_unix_request_init (rpcsvc_request_t *req, void *priv) { if (!req) return -1; @@ -42,7 +42,8 @@ auth_unix_request_init (rpcsvc_request_t *req, void *priv) return 0; } -int auth_unix_authenticate (rpcsvc_request_t *req, void *priv) +int +nfs_auth_unix_authenticate (rpcsvc_request_t *req, void *priv) { int ret = RPCSVC_AUTH_REJECT; struct authunix_parms aup; @@ -51,8 +52,8 @@ int auth_unix_authenticate (rpcsvc_request_t *req, void *priv) if (!req) return ret; - ret = xdr_to_auth_unix_cred (req->cred.authdata, req->cred.datalen, - &aup, machname, req->auxgids); + ret = nfs_xdr_to_auth_unix_cred (req->cred.authdata, req->cred.datalen, + &aup, machname, req->auxgids); if (ret == -1) { ret = RPCSVC_AUTH_REJECT; goto err; @@ -69,23 +70,23 @@ err: return ret; } -rpcsvc_auth_ops_t auth_unix_ops = { +rpcsvc_auth_ops_t nfs_auth_unix_ops = { .conn_init = NULL, - .request_init = auth_unix_request_init, - .authenticate = auth_unix_authenticate + .request_init = nfs_auth_unix_request_init, + .authenticate = nfs_auth_unix_authenticate }; -rpcsvc_auth_t rpcsvc_auth_unix = { +rpcsvc_auth_t nfs_rpcsvc_auth_unix = { .authname = "AUTH_UNIX", .authnum = AUTH_UNIX, - .authops = &auth_unix_ops, + .authops = &nfs_auth_unix_ops, .authprivate = NULL }; rpcsvc_auth_t * -rpcsvc_auth_unix_init (rpcsvc_t *svc, dict_t *options) +nfs_rpcsvc_auth_unix_init (rpcsvc_t *svc, dict_t *options) { - return &rpcsvc_auth_unix; + return &nfs_rpcsvc_auth_unix; } diff --git a/xlators/nfs/lib/src/msg-nfs3.c b/xlators/nfs/lib/src/msg-nfs3.c index 3eefd4c98..9ad499364 100644 --- a/xlators/nfs/lib/src/msg-nfs3.c +++ b/xlators/nfs/lib/src/msg-nfs3.c @@ -56,7 +56,7 @@ xdr_to_mountpath (struct iovec outpath, struct iovec inmsg) goto ret; } - ret = xdr_decoded_length (xdr); + ret = nfs_xdr_decoded_length (xdr); ret: return ret; @@ -64,7 +64,7 @@ ret: ssize_t -xdr_serialize_generic (struct iovec outmsg, void *res, xdrproc_t proc) +nfs_xdr_serialize_generic (struct iovec outmsg, void *res, xdrproc_t proc) { ssize_t ret = -1; XDR xdr; @@ -80,7 +80,7 @@ xdr_serialize_generic (struct iovec outmsg, void *res, xdrproc_t proc) goto ret; } - ret = xdr_encoded_length (xdr); + ret = nfs_xdr_encoded_length (xdr); ret: return ret; @@ -88,7 +88,7 @@ ret: ssize_t -xdr_to_generic (struct iovec inmsg, void *args, xdrproc_t proc) +nfs_xdr_to_generic (struct iovec inmsg, void *args, xdrproc_t proc) { XDR xdr; ssize_t ret = -1; @@ -104,15 +104,15 @@ xdr_to_generic (struct iovec inmsg, void *args, xdrproc_t proc) goto ret; } - ret = xdr_decoded_length (xdr); + ret = nfs_xdr_decoded_length (xdr); ret: return ret; } ssize_t -xdr_to_generic_payload (struct iovec inmsg, void *args, xdrproc_t proc, - struct iovec *pendingpayload) +nfs_xdr_to_generic_payload (struct iovec inmsg, void *args, xdrproc_t proc, + struct iovec *pendingpayload) { XDR xdr; ssize_t ret = -1; @@ -128,11 +128,11 @@ xdr_to_generic_payload (struct iovec inmsg, void *args, xdrproc_t proc, goto ret; } - ret = xdr_decoded_length (xdr); + ret = nfs_xdr_decoded_length (xdr); if (pendingpayload) { - pendingpayload->iov_base = xdr_decoded_remaining_addr (xdr); - pendingpayload->iov_len = xdr_decoded_remaining_len (xdr); + pendingpayload->iov_base = nfs_xdr_decoded_remaining_addr (xdr); + pendingpayload->iov_len = nfs_xdr_decoded_remaining_len (xdr); } ret: @@ -147,135 +147,140 @@ ret: ssize_t xdr_serialize_mountres3 (struct iovec outmsg, mountres3 *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_mountres3); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_mountres3); } ssize_t xdr_serialize_mountbody (struct iovec outmsg, mountbody *mb) { - return xdr_serialize_generic (outmsg, (void *)mb, - (xdrproc_t)xdr_mountbody); + return nfs_xdr_serialize_generic (outmsg, (void *)mb, + (xdrproc_t)xdr_mountbody); } ssize_t xdr_serialize_mountlist (struct iovec outmsg, mountlist *ml) { - return xdr_serialize_generic (outmsg, (void *)ml, - (xdrproc_t)xdr_mountlist); + return nfs_xdr_serialize_generic (outmsg, (void *)ml, + (xdrproc_t)xdr_mountlist); } ssize_t xdr_serialize_mountstat3 (struct iovec outmsg, mountstat3 *m) { - return xdr_serialize_generic (outmsg, (void *)m, - (xdrproc_t)xdr_mountstat3); + return nfs_xdr_serialize_generic (outmsg, (void *)m, + (xdrproc_t)xdr_mountstat3); } ssize_t xdr_to_getattr3args (struct iovec inmsg, getattr3args *ga) { - return xdr_to_generic (inmsg, (void *)ga,(xdrproc_t)xdr_getattr3args); + return nfs_xdr_to_generic (inmsg, (void *)ga, + (xdrproc_t)xdr_getattr3args); } ssize_t xdr_serialize_getattr3res (struct iovec outmsg, getattr3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_getattr3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_getattr3res); } ssize_t xdr_serialize_setattr3res (struct iovec outmsg, setattr3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_setattr3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_setattr3res); } ssize_t xdr_to_setattr3args (struct iovec inmsg, setattr3args *sa) { - return xdr_to_generic (inmsg, (void *)sa, (xdrproc_t)xdr_setattr3args); + return nfs_xdr_to_generic (inmsg, (void *)sa, + (xdrproc_t)xdr_setattr3args); } ssize_t xdr_serialize_lookup3res (struct iovec outmsg, lookup3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_lookup3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_lookup3res); } ssize_t xdr_to_lookup3args (struct iovec inmsg, lookup3args *la) { - return xdr_to_generic (inmsg, (void *)la, (xdrproc_t)xdr_lookup3args); + return nfs_xdr_to_generic (inmsg, (void *)la, + (xdrproc_t)xdr_lookup3args); } ssize_t xdr_to_access3args (struct iovec inmsg, access3args *ac) { - return xdr_to_generic (inmsg,(void *)ac, (xdrproc_t)xdr_access3args); + return nfs_xdr_to_generic (inmsg,(void *)ac, + (xdrproc_t)xdr_access3args); } ssize_t xdr_serialize_access3res (struct iovec outmsg, access3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_access3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_access3res); } ssize_t xdr_to_readlink3args (struct iovec inmsg, readlink3args *ra) { - return xdr_to_generic (inmsg, (void *)ra, (xdrproc_t)xdr_readlink3args); + return nfs_xdr_to_generic (inmsg, (void *)ra, + (xdrproc_t)xdr_readlink3args); } ssize_t xdr_serialize_readlink3res (struct iovec outmsg, readlink3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_readlink3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_readlink3res); } ssize_t xdr_to_read3args (struct iovec inmsg, read3args *ra) { - return xdr_to_generic (inmsg, (void *)ra, (xdrproc_t)xdr_read3args); + return nfs_xdr_to_generic (inmsg, (void *)ra, (xdrproc_t)xdr_read3args); } ssize_t xdr_serialize_read3res (struct iovec outmsg, read3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_read3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_read3res); } ssize_t xdr_serialize_read3res_nocopy (struct iovec outmsg, read3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_read3res_nocopy); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_read3res_nocopy); } ssize_t xdr_to_write3args (struct iovec inmsg, write3args *wa) { - return xdr_to_generic (inmsg, (void *)wa,(xdrproc_t)xdr_write3args); + return nfs_xdr_to_generic (inmsg, (void *)wa,(xdrproc_t)xdr_write3args); } @@ -283,224 +288,237 @@ ssize_t xdr_to_write3args_nocopy (struct iovec inmsg, write3args *wa, struct iovec *payload) { - return xdr_to_generic_payload (inmsg, (void *)wa, - (xdrproc_t)xdr_write3args, payload); + return nfs_xdr_to_generic_payload (inmsg, (void *)wa, + (xdrproc_t)xdr_write3args, payload); } ssize_t xdr_serialize_write3res (struct iovec outmsg, write3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_write3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_write3res); } ssize_t xdr_to_create3args (struct iovec inmsg, create3args *ca) { - return xdr_to_generic (inmsg, (void *)ca, (xdrproc_t)xdr_create3args); + return nfs_xdr_to_generic (inmsg, (void *)ca, + (xdrproc_t)xdr_create3args); } ssize_t xdr_serialize_create3res (struct iovec outmsg, create3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_create3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_create3res); } ssize_t xdr_serialize_mkdir3res (struct iovec outmsg, mkdir3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_mkdir3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_mkdir3res); } ssize_t xdr_to_mkdir3args (struct iovec inmsg, mkdir3args *ma) { - return xdr_to_generic (inmsg, (void *)ma, (xdrproc_t)xdr_mkdir3args); + return nfs_xdr_to_generic (inmsg, (void *)ma, + (xdrproc_t)xdr_mkdir3args); } ssize_t xdr_to_symlink3args (struct iovec inmsg, symlink3args *sa) { - return xdr_to_generic (inmsg, (void *)sa, (xdrproc_t)xdr_symlink3args); + return nfs_xdr_to_generic (inmsg, (void *)sa, + (xdrproc_t)xdr_symlink3args); } ssize_t xdr_serialize_symlink3res (struct iovec outmsg, symlink3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_symlink3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_symlink3res); } ssize_t xdr_to_mknod3args (struct iovec inmsg, mknod3args *ma) { - return xdr_to_generic (inmsg, (void *)ma, (xdrproc_t)xdr_mknod3args); + return nfs_xdr_to_generic (inmsg, (void *)ma, + (xdrproc_t)xdr_mknod3args); } ssize_t xdr_serialize_mknod3res (struct iovec outmsg, mknod3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_mknod3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_mknod3res); } ssize_t xdr_to_remove3args (struct iovec inmsg, remove3args *ra) { - return xdr_to_generic (inmsg, (void *)ra, (xdrproc_t)xdr_remove3args); + return nfs_xdr_to_generic (inmsg, (void *)ra, + (xdrproc_t)xdr_remove3args); } ssize_t xdr_serialize_remove3res (struct iovec outmsg, remove3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_remove3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_remove3res); } ssize_t xdr_to_rmdir3args (struct iovec inmsg, rmdir3args *ra) { - return xdr_to_generic (inmsg, (void *)ra, (xdrproc_t)xdr_rmdir3args); + return nfs_xdr_to_generic (inmsg, (void *)ra, + (xdrproc_t)xdr_rmdir3args); } ssize_t xdr_serialize_rmdir3res (struct iovec outmsg, rmdir3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_rmdir3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_rmdir3res); } ssize_t xdr_serialize_rename3res (struct iovec outmsg, rename3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_rename3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_rename3res); } ssize_t xdr_to_rename3args (struct iovec inmsg, rename3args *ra) { - return xdr_to_generic (inmsg, (void *)ra, (xdrproc_t)xdr_rename3args); + return nfs_xdr_to_generic (inmsg, (void *)ra, + (xdrproc_t)xdr_rename3args); } ssize_t xdr_serialize_link3res (struct iovec outmsg, link3res *li) { - return xdr_serialize_generic (outmsg, (void *)li, - (xdrproc_t)xdr_link3res); + return nfs_xdr_serialize_generic (outmsg, (void *)li, + (xdrproc_t)xdr_link3res); } ssize_t xdr_to_link3args (struct iovec inmsg, link3args *la) { - return xdr_to_generic (inmsg, (void *)la, (xdrproc_t)xdr_link3args); + return nfs_xdr_to_generic (inmsg, (void *)la, (xdrproc_t)xdr_link3args); } ssize_t xdr_to_readdir3args (struct iovec inmsg, readdir3args *rd) { - return xdr_to_generic (inmsg, (void *)rd, (xdrproc_t)xdr_readdir3args); + return nfs_xdr_to_generic (inmsg, (void *)rd, + (xdrproc_t)xdr_readdir3args); } ssize_t xdr_serialize_readdir3res (struct iovec outmsg, readdir3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_readdir3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_readdir3res); } ssize_t xdr_to_readdirp3args (struct iovec inmsg, readdirp3args *rp) { - return xdr_to_generic (inmsg, (void *)rp, (xdrproc_t)xdr_readdirp3args); + return nfs_xdr_to_generic (inmsg, (void *)rp, + (xdrproc_t)xdr_readdirp3args); } ssize_t xdr_serialize_readdirp3res (struct iovec outmsg, readdirp3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_readdirp3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_readdirp3res); } ssize_t xdr_to_fsstat3args (struct iovec inmsg, fsstat3args *fa) { - return xdr_to_generic (inmsg, (void *)fa, (xdrproc_t)xdr_fsstat3args); + return nfs_xdr_to_generic (inmsg, (void *)fa, + (xdrproc_t)xdr_fsstat3args); } ssize_t xdr_serialize_fsstat3res (struct iovec outmsg, fsstat3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_fsstat3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_fsstat3res); } ssize_t xdr_to_fsinfo3args (struct iovec inmsg, fsinfo3args *fi) { - return xdr_to_generic (inmsg, (void *)fi, (xdrproc_t)xdr_fsinfo3args); + return nfs_xdr_to_generic (inmsg, (void *)fi, + (xdrproc_t)xdr_fsinfo3args); } ssize_t xdr_serialize_fsinfo3res (struct iovec outmsg, fsinfo3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_fsinfo3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_fsinfo3res); } ssize_t xdr_to_pathconf3args (struct iovec inmsg, pathconf3args *pc) { - return xdr_to_generic (inmsg, (void *)pc, (xdrproc_t)xdr_pathconf3args);} + return nfs_xdr_to_generic (inmsg, (void *)pc, + (xdrproc_t)xdr_pathconf3args);} ssize_t xdr_serialize_pathconf3res (struct iovec outmsg, pathconf3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_pathconf3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_pathconf3res); } ssize_t xdr_to_commit3args (struct iovec inmsg, commit3args *ca) { - return xdr_to_generic (inmsg, (void *)ca, (xdrproc_t)xdr_commit3args); + return nfs_xdr_to_generic (inmsg, (void *)ca, + (xdrproc_t)xdr_commit3args); } ssize_t xdr_serialize_commit3res (struct iovec outmsg, commit3res *res) { - return xdr_serialize_generic (outmsg, (void *)res, - (xdrproc_t)xdr_commit3res); + return nfs_xdr_serialize_generic (outmsg, (void *)res, + (xdrproc_t)xdr_commit3res); } @@ -519,7 +537,7 @@ xdr_serialize_exports (struct iovec outmsg, exports *elist) if (!xdr_exports (&xdr, elist)) goto ret; - ret = xdr_decoded_length (xdr); + ret = nfs_xdr_decoded_length (xdr); ret: return ret; @@ -529,8 +547,8 @@ ret: ssize_t xdr_serialize_nfsstat3 (struct iovec outmsg, nfsstat3 *s) { - return xdr_serialize_generic (outmsg, (void *)s, - (xdrproc_t)xdr_nfsstat3); + return nfs_xdr_serialize_generic (outmsg, (void *)s, + (xdrproc_t)xdr_nfsstat3); } diff --git a/xlators/nfs/lib/src/rpc-socket.c b/xlators/nfs/lib/src/rpc-socket.c index 01f114a85..aacf7ff03 100644 --- a/xlators/nfs/lib/src/rpc-socket.c +++ b/xlators/nfs/lib/src/rpc-socket.c @@ -38,10 +38,10 @@ #include <netinet/tcp.h> static int -rpcsvc_socket_server_get_local_socket (int addrfam, char *listenhost, - uint16_t listenport, - struct sockaddr *addr, - socklen_t *addr_len) +nfs_rpcsvc_socket_server_get_local_socket (int addrfam, char *listenhost, + uint16_t listenport, + struct sockaddr *addr, + socklen_t *addr_len) { struct addrinfo hints, *res = 0; char service[NI_MAXSERV]; @@ -76,7 +76,7 @@ err: int -rpcsvc_socket_listen (int addrfam, char *listenhost, uint16_t listenport) +nfs_rpcsvc_socket_listen (int addrfam, char *listenhost, uint16_t listenport) { int sock = -1; struct sockaddr_storage sockaddr; @@ -85,9 +85,10 @@ rpcsvc_socket_listen (int addrfam, char *listenhost, uint16_t listenport) int ret = -1; int opt = 1; - ret = rpcsvc_socket_server_get_local_socket (addrfam, listenhost, - listenport,SA (&sockaddr), - &sockaddr_len); + ret = nfs_rpcsvc_socket_server_get_local_socket (addrfam, listenhost, + listenport, + SA (&sockaddr), + &sockaddr_len); if (ret == -1) return ret; @@ -149,7 +150,7 @@ err: int -rpcsvc_socket_accept (int listenfd) +nfs_rpcsvc_socket_accept (int listenfd) { int new_sock = -1; struct sockaddr_storage new_sockaddr = {0, }; @@ -197,7 +198,7 @@ err: } ssize_t -rpcsvc_socket_read (int sockfd, char *readaddr, size_t readsize) +nfs_rpcsvc_socket_read (int sockfd, char *readaddr, size_t readsize) { ssize_t dataread = 0; ssize_t readlen = -1; @@ -226,7 +227,7 @@ rpcsvc_socket_read (int sockfd, char *readaddr, size_t readsize) ssize_t -rpcsvc_socket_write (int sockfd, char *buffer, size_t size) +nfs_rpcsvc_socket_write (int sockfd, char *buffer, size_t size) { size_t writelen = -1; ssize_t written = 0; @@ -255,7 +256,7 @@ rpcsvc_socket_write (int sockfd, char *buffer, size_t size) int -rpcsvc_socket_peername (int sockfd, char *hostname, int hostlen) +nfs_rpcsvc_socket_peername (int sockfd, char *hostname, int hostlen) { struct sockaddr sa; socklen_t sl = sizeof (sa); @@ -282,8 +283,8 @@ err: int -rpcsvc_socket_peeraddr (int sockfd, char *addrstr, int addrlen, - struct sockaddr *returnsa, socklen_t sasize) +nfs_rpcsvc_socket_peeraddr (int sockfd, char *addrstr, int addrlen, + struct sockaddr *returnsa, socklen_t sasize) { struct sockaddr sa; int ret = EAI_FAIL; @@ -323,8 +324,9 @@ err: int -rpcsvc_socket_block_tx (int sockfd) +nfs_rpcsvc_socket_block_tx (int sockfd) { + int ret = -1; int on = 1; @@ -341,7 +343,7 @@ rpcsvc_socket_block_tx (int sockfd) int -rpcsvc_socket_unblock_tx (int sockfd) +nfs_rpcsvc_socket_unblock_tx (int sockfd) { int ret = -1; int off = 0; diff --git a/xlators/nfs/lib/src/rpc-socket.h b/xlators/nfs/lib/src/rpc-socket.h index 3a50c97a9..d95e5ddd6 100644 --- a/xlators/nfs/lib/src/rpc-socket.h +++ b/xlators/nfs/lib/src/rpc-socket.h @@ -17,8 +17,8 @@ <http://www.gnu.org/licenses/>. */ -#ifndef _RPCSVC_SOCKET_H_ -#define _RPCSVC_SOCKET_H_ +#ifndef _NFS_RPCSVC_SOCKET_H_ +#define _NFS_RPCSVC_SOCKET_H_ #ifndef _CONFIG_H #define _CONFIG_H @@ -40,26 +40,26 @@ #define SA(ptr) ((struct sockaddr *)ptr) #define GF_RPCSVC_SOCK "rpc-socket" extern int -rpcsvc_socket_listen (int addrfam, char *listenhost, uint16_t listenport); +nfs_rpcsvc_socket_listen (int addrfam, char *listenhost, uint16_t listenport); extern int -rpcsvc_socket_accept (int listenfd); +nfs_rpcsvc_socket_accept (int listenfd); extern ssize_t -rpcsvc_socket_read (int sockfd, char *readaddr, size_t readsize); +nfs_rpcsvc_socket_read (int sockfd, char *readaddr, size_t readsize); extern ssize_t -rpcsvc_socket_write (int sockfd, char *buffer, size_t size); +nfs_rpcsvc_socket_write (int sockfd, char *buffer, size_t size); extern int -rpcsvc_socket_peername (int sockfd, char *hostname, int hostlen); +nfs_rpcsvc_socket_peername (int sockfd, char *hostname, int hostlen); extern int -rpcsvc_socket_peeraddr (int sockfd, char *addrstr, int addrlen, - struct sockaddr *returnsa, socklen_t sasize); +nfs_rpcsvc_socket_peeraddr (int sockfd, char *addrstr, int addrlen, + struct sockaddr *returnsa, socklen_t sasize); extern int -rpcsvc_socket_block_tx (int sockfd); +nfs_rpcsvc_socket_block_tx (int sockfd); extern int -rpcsvc_socket_unblock_tx (int sockfd); +nfs_rpcsvc_socket_unblock_tx (int sockfd); #endif diff --git a/xlators/nfs/lib/src/rpcsvc-auth.c b/xlators/nfs/lib/src/rpcsvc-auth.c index f61fe91d0..b3e2e36a3 100644 --- a/xlators/nfs/lib/src/rpcsvc-auth.c +++ b/xlators/nfs/lib/src/rpcsvc-auth.c @@ -22,14 +22,14 @@ #include "dict.h" extern rpcsvc_auth_t * -rpcsvc_auth_null_init (rpcsvc_t *svc, dict_t *options); +nfs_rpcsvc_auth_null_init (rpcsvc_t *svc, dict_t *options); extern rpcsvc_auth_t * -rpcsvc_auth_unix_init (rpcsvc_t *svc, dict_t *options); +nfs_rpcsvc_auth_unix_init (rpcsvc_t *svc, dict_t *options); int -rpcsvc_auth_add_initer (struct list_head *list, char *idfier, - rpcsvc_auth_initer_t init) +nfs_rpcsvc_auth_add_initer (struct list_head *list, char *idfier, + rpcsvc_auth_initer_t init) { struct rpcsvc_auth_list *new = NULL; @@ -52,21 +52,21 @@ rpcsvc_auth_add_initer (struct list_head *list, char *idfier, int -rpcsvc_auth_add_initers (rpcsvc_t *svc) +nfs_rpcsvc_auth_add_initers (rpcsvc_t *svc) { int ret = -1; - ret = rpcsvc_auth_add_initer (&svc->authschemes, "auth-unix", - (rpcsvc_auth_initer_t) - rpcsvc_auth_unix_init); + ret = nfs_rpcsvc_auth_add_initer (&svc->authschemes, "auth-unix", + (rpcsvc_auth_initer_t) + nfs_rpcsvc_auth_unix_init); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to add AUTH_UNIX"); goto err; } - ret = rpcsvc_auth_add_initer (&svc->authschemes, "auth-null", - (rpcsvc_auth_initer_t) - rpcsvc_auth_null_init); + ret = nfs_rpcsvc_auth_add_initer (&svc->authschemes, "auth-null", + (rpcsvc_auth_initer_t) + nfs_rpcsvc_auth_null_init); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to add AUTH_NULL"); goto err; @@ -79,8 +79,8 @@ err: int -rpcsvc_auth_init_auth (rpcsvc_t *svc, dict_t *options, - struct rpcsvc_auth_list *authitem) +nfs_rpcsvc_auth_init_auth (rpcsvc_t *svc, dict_t *options, + struct rpcsvc_auth_list *authitem) { int ret = -1; @@ -112,7 +112,7 @@ err: int -rpcsvc_auth_init_auths (rpcsvc_t *svc, dict_t *options) +nfs_rpcsvc_auth_init_auths (rpcsvc_t *svc, dict_t *options) { int ret = -1; struct rpcsvc_auth_list *auth = NULL; @@ -138,7 +138,7 @@ rpcsvc_auth_init_auths (rpcsvc_t *svc, dict_t *options) ret = dict_set_dynstr (options, "rpc-auth.auth-unix", "on"); list_for_each_entry_safe (auth, tmp, &svc->authschemes, authlist) { - ret = rpcsvc_auth_init_auth (svc, options, auth); + ret = nfs_rpcsvc_auth_init_auth (svc, options, auth); if (ret == -1) goto err; } @@ -150,20 +150,20 @@ err: } int -rpcsvc_auth_init (rpcsvc_t *svc, dict_t *options) +nfs_rpcsvc_auth_init (rpcsvc_t *svc, dict_t *options) { int ret = -1; if ((!svc) || (!options)) return -1; - ret = rpcsvc_auth_add_initers (svc); + ret = nfs_rpcsvc_auth_add_initers (svc); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to add initers"); goto out; } - ret = rpcsvc_auth_init_auths (svc, options); + ret = nfs_rpcsvc_auth_init_auths (svc, options); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to init auth schemes"); goto out; @@ -175,7 +175,7 @@ out: rpcsvc_auth_t * -__rpcsvc_auth_get_handler (rpcsvc_request_t *req) +__nfs_rpcsvc_auth_get_handler (rpcsvc_request_t *req) { int ret = -1; struct rpcsvc_auth_list *auth = NULL; @@ -185,7 +185,7 @@ __rpcsvc_auth_get_handler (rpcsvc_request_t *req) if (!req) return NULL; - svc = rpcsvc_request_service (req); + svc = nfs_rpcsvc_request_service (req); if (list_empty (&svc->authschemes)) { gf_log (GF_RPCSVC, GF_LOG_WARNING, "No authentication!"); ret = 0; @@ -209,11 +209,11 @@ err: } rpcsvc_auth_t * -rpcsvc_auth_get_handler (rpcsvc_request_t *req) +nfs_rpcsvc_auth_get_handler (rpcsvc_request_t *req) { rpcsvc_auth_t *auth = NULL; - auth = __rpcsvc_auth_get_handler (req); + auth = __nfs_rpcsvc_auth_get_handler (req); if (auth) goto ret; @@ -225,14 +225,14 @@ rpcsvc_auth_get_handler (rpcsvc_request_t *req) */ req->cred.flavour = AUTH_NULL; req->verf.flavour = AUTH_NULL; - auth = __rpcsvc_auth_get_handler (req); + auth = __nfs_rpcsvc_auth_get_handler (req); ret: return auth; } int -rpcsvc_auth_request_init (rpcsvc_request_t *req) +nfs_rpcsvc_auth_request_init (rpcsvc_request_t *req) { int ret = -1; rpcsvc_auth_t *auth = NULL; @@ -240,7 +240,7 @@ rpcsvc_auth_request_init (rpcsvc_request_t *req) if (!req) return -1; - auth = rpcsvc_auth_get_handler (req); + auth = nfs_rpcsvc_auth_get_handler (req); if (!auth) goto err; ret = 0; @@ -254,7 +254,7 @@ err: int -rpcsvc_authenticate (rpcsvc_request_t *req) +nfs_rpcsvc_authenticate (rpcsvc_request_t *req) { int ret = RPCSVC_AUTH_REJECT; rpcsvc_auth_t *auth = NULL; @@ -263,14 +263,14 @@ rpcsvc_authenticate (rpcsvc_request_t *req) if (!req) return ret; - minauth = rpcsvc_request_prog_minauth (req); - if (minauth > rpcsvc_request_cred_flavour (req)) { + minauth = nfs_rpcsvc_request_prog_minauth (req); + if (minauth > nfs_rpcsvc_request_cred_flavour (req)) { gf_log (GF_RPCSVC, GF_LOG_DEBUG, "Auth too weak"); - rpcsvc_request_set_autherr (req, AUTH_TOOWEAK); + nfs_rpcsvc_request_set_autherr (req, AUTH_TOOWEAK); goto err; } - auth = rpcsvc_auth_get_handler (req); + auth = nfs_rpcsvc_auth_get_handler (req); if (!auth) { gf_log (GF_RPCSVC, GF_LOG_DEBUG, "No auth handler found"); goto err; @@ -285,7 +285,7 @@ err: int -rpcsvc_auth_array (rpcsvc_t *svc, char *volname, int *autharr, int arrlen) +nfs_rpcsvc_auth_array (rpcsvc_t *svc, char *volname, int *autharr, int arrlen) { int count = 0; int gen = RPCSVC_AUTH_REJECT; @@ -361,7 +361,7 @@ rpcsvc_auth_array (rpcsvc_t *svc, char *volname, int *autharr, int arrlen) } GF_FREE (srchstr); - final = rpcsvc_combine_gen_spec_volume_checks (gen, spec); + final = nfs_rpcsvc_combine_gen_spec_volume_checks (gen, spec); if (final == RPCSVC_AUTH_ACCEPT) { autharr[count] = auth->auth->authnum; ++count; @@ -374,7 +374,7 @@ err: gid_t * -rpcsvc_auth_unix_auxgids (rpcsvc_request_t *req, int *arrlen) +nfs_rpcsvc_auth_unix_auxgids (rpcsvc_request_t *req, int *arrlen) { if ((!req) || (!arrlen)) return NULL; diff --git a/xlators/nfs/lib/src/rpcsvc.c b/xlators/nfs/lib/src/rpcsvc.c index 4ea008b88..0a105ab0d 100644 --- a/xlators/nfs/lib/src/rpcsvc.c +++ b/xlators/nfs/lib/src/rpcsvc.c @@ -46,7 +46,7 @@ #include <stdio.h> -#define rpcsvc_alloc_request(con, request) \ +#define nfs_rpcsvc_alloc_request(con, request) \ do { \ request = (rpcsvc_request_t *) mem_get ((con)->rxpool); \ memset (request, 0, sizeof (rpcsvc_request_t)); \ @@ -54,7 +54,7 @@ /* The generic event handler for every stage */ void * -rpcsvc_stage_proc (void *arg) +nfs_rpcsvc_stage_proc (void *arg) { rpcsvc_stage_t *stg = (rpcsvc_stage_t *)arg; @@ -67,7 +67,7 @@ rpcsvc_stage_proc (void *arg) rpcsvc_stage_t * -rpcsvc_stage_init (rpcsvc_t *svc) +nfs_rpcsvc_stage_init (rpcsvc_t *svc) { rpcsvc_stage_t *stg = NULL; int ret = -1; @@ -94,7 +94,7 @@ rpcsvc_stage_init (rpcsvc_t *svc) gf_log (GF_RPCSVC, GF_LOG_WARNING, "Using default thread stack size"); - ret = pthread_create (&stg->tid, &stgattr, rpcsvc_stage_proc, + ret = pthread_create (&stg->tid, &stgattr, nfs_rpcsvc_stage_proc, (void *)stg); if (ret != 0) { ret = -1; @@ -115,7 +115,7 @@ free_stg: int -rpcsvc_init_options (rpcsvc_t *svc, dict_t *options) +nfs_rpcsvc_init_options (rpcsvc_t *svc, dict_t *options) { svc->memfactor = RPCSVC_DEFAULT_MEMFACTOR; return 0; @@ -127,7 +127,7 @@ rpcsvc_init_options (rpcsvc_t *svc, dict_t *options) * to come in. */ rpcsvc_t * -rpcsvc_init (glusterfs_ctx_t *ctx, dict_t *options) +nfs_rpcsvc_init (glusterfs_ctx_t *ctx, dict_t *options) { rpcsvc_t *svc = NULL; int ret = -1; @@ -143,13 +143,13 @@ rpcsvc_init (glusterfs_ctx_t *ctx, dict_t *options) INIT_LIST_HEAD (&svc->stages); INIT_LIST_HEAD (&svc->authschemes); - ret = rpcsvc_init_options (svc, options); + ret = nfs_rpcsvc_init_options (svc, options); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to init options"); goto free_svc; } - ret = rpcsvc_auth_init (svc, options); + ret = nfs_rpcsvc_auth_init (svc, options); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to init " "authentication"); @@ -157,7 +157,7 @@ rpcsvc_init (glusterfs_ctx_t *ctx, dict_t *options) } ret = -1; - svc->defaultstage = rpcsvc_stage_init (svc); + svc->defaultstage = nfs_rpcsvc_stage_init (svc); if (!svc->defaultstage) { gf_log (GF_RPCSVC, GF_LOG_ERROR,"RPC service init failed."); goto free_svc; @@ -182,7 +182,7 @@ free_svc: * function selects one from among all the stages. */ rpcsvc_stage_t * -rpcsvc_select_stage (rpcsvc_t *rpcservice) +nfs_rpcsvc_select_stage (rpcsvc_t *rpcservice) { if (!rpcservice) return NULL; @@ -192,7 +192,7 @@ rpcsvc_select_stage (rpcsvc_t *rpcservice) int -rpcsvc_conn_peer_check_search (dict_t *options, char *pattern, char *clstr) +nfs_rpcsvc_conn_peer_check_search (dict_t *options, char *pattern, char *clstr) { int ret = -1; char *addrtok = NULL; @@ -234,7 +234,7 @@ err: int -rpcsvc_conn_peer_check_allow (dict_t *options, char *volname, char *clstr) +nfs_rpcsvc_conn_peer_check_allow (dict_t *options, char *volname, char *clstr) { int ret = RPCSVC_AUTH_DONTCARE; char *srchstr = NULL; @@ -257,7 +257,7 @@ rpcsvc_conn_peer_check_allow (dict_t *options, char *volname, char *clstr) } else srchstr = globalrule; - ret = rpcsvc_conn_peer_check_search (options, srchstr, clstr); + ret = nfs_rpcsvc_conn_peer_check_search (options, srchstr, clstr); if (volname) GF_FREE (srchstr); @@ -270,7 +270,7 @@ out: } int -rpcsvc_conn_peer_check_reject (dict_t *options, char *volname, char *clstr) +nfs_rpcsvc_conn_peer_check_reject (dict_t *options, char *volname, char *clstr) { int ret = RPCSVC_AUTH_DONTCARE; char *srchstr = NULL; @@ -280,7 +280,8 @@ rpcsvc_conn_peer_check_reject (dict_t *options, char *volname, char *clstr) return ret; if (volname) { - ret = gf_asprintf (&srchstr, "rpc-auth.addr.%s.reject", volname); + ret = gf_asprintf (&srchstr, "rpc-auth.addr.%s.reject", + volname); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "asprintf failed"); ret = RPCSVC_AUTH_REJECT; @@ -289,7 +290,7 @@ rpcsvc_conn_peer_check_reject (dict_t *options, char *volname, char *clstr) } else srchstr = generalrule; - ret = rpcsvc_conn_peer_check_search (options, srchstr, clstr); + ret = nfs_rpcsvc_conn_peer_check_search (options, srchstr, clstr); if (volname) GF_FREE (srchstr); @@ -318,7 +319,7 @@ out: * | D | R | R | */ int -rpcsvc_combine_allow_reject_volume_check (int allow, int reject) +nfs_rpcsvc_combine_allow_reject_volume_check (int allow, int reject) { int final = RPCSVC_AUTH_REJECT; @@ -360,7 +361,7 @@ rpcsvc_combine_allow_reject_volume_check (int allow, int reject) * | R | R | R | */ int -rpcsvc_combine_gen_spec_addr_checks (int gen, int spec) +nfs_rpcsvc_combine_gen_spec_addr_checks (int gen, int spec) { int final = RPCSVC_AUTH_REJECT; @@ -403,7 +404,7 @@ rpcsvc_combine_gen_spec_addr_checks (int gen, int spec) * | R | R | R | */ int -rpcsvc_combine_gen_spec_volume_checks (int gen, int spec) +nfs_rpcsvc_combine_gen_spec_volume_checks (int gen, int spec) { int final = RPCSVC_AUTH_REJECT; @@ -432,8 +433,8 @@ rpcsvc_combine_gen_spec_volume_checks (int gen, int spec) int -rpcsvc_conn_peer_check_name (dict_t *options, char *volname, - rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_peer_check_name (dict_t *options, char *volname, + rpcsvc_conn_t *conn) { int ret = RPCSVC_AUTH_REJECT; int aret = RPCSVC_AUTH_REJECT; @@ -443,7 +444,7 @@ rpcsvc_conn_peer_check_name (dict_t *options, char *volname, if (!conn) return ret; - ret = rpcsvc_conn_peername (conn, clstr, RPCSVC_PEER_STRLEN); + ret = nfs_rpcsvc_conn_peername (conn, clstr, RPCSVC_PEER_STRLEN); if (ret != 0) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to get remote addr: " "%s", gai_strerror (ret)); @@ -451,10 +452,10 @@ rpcsvc_conn_peer_check_name (dict_t *options, char *volname, goto err; } - aret = rpcsvc_conn_peer_check_allow (options, volname, clstr); - rjret = rpcsvc_conn_peer_check_reject (options, volname, clstr); + aret = nfs_rpcsvc_conn_peer_check_allow (options, volname, clstr); + rjret = nfs_rpcsvc_conn_peer_check_reject (options, volname, clstr); - ret = rpcsvc_combine_allow_reject_volume_check (aret, rjret); + ret = nfs_rpcsvc_combine_allow_reject_volume_check (aret, rjret); err: return ret; @@ -462,7 +463,8 @@ err: int -rpcsvc_conn_peer_check_addr (dict_t *options, char *volname,rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_peer_check_addr (dict_t *options, char *volname, + rpcsvc_conn_t *conn) { int ret = RPCSVC_AUTH_REJECT; int aret = RPCSVC_AUTH_DONTCARE; @@ -472,7 +474,8 @@ rpcsvc_conn_peer_check_addr (dict_t *options, char *volname,rpcsvc_conn_t *conn) if (!conn) return ret; - ret = rpcsvc_conn_peeraddr (conn, clstr, RPCSVC_PEER_STRLEN, NULL, 0); + ret = nfs_rpcsvc_conn_peeraddr (conn, clstr, RPCSVC_PEER_STRLEN, NULL, + 0); if (ret != 0) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to get remote addr: " "%s", gai_strerror (ret)); @@ -480,18 +483,18 @@ rpcsvc_conn_peer_check_addr (dict_t *options, char *volname,rpcsvc_conn_t *conn) goto err; } - aret = rpcsvc_conn_peer_check_allow (options, volname, clstr); - rjret = rpcsvc_conn_peer_check_reject (options, volname, clstr); + aret = nfs_rpcsvc_conn_peer_check_allow (options, volname, clstr); + rjret = nfs_rpcsvc_conn_peer_check_reject (options, volname, clstr); - ret = rpcsvc_combine_allow_reject_volume_check (aret, rjret); + ret = nfs_rpcsvc_combine_allow_reject_volume_check (aret, rjret); err: return ret; } int -rpcsvc_conn_check_volume_specific (dict_t *options, char *volname, - rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_check_volume_specific (dict_t *options, char *volname, + rpcsvc_conn_t *conn) { int namechk = RPCSVC_AUTH_REJECT; int addrchk = RPCSVC_AUTH_REJECT; @@ -515,11 +518,13 @@ rpcsvc_conn_check_volume_specific (dict_t *options, char *volname, * specific which will over-ride the network address rules. */ if (namelookup) - namechk = rpcsvc_conn_peer_check_name (options, volname, conn); - addrchk = rpcsvc_conn_peer_check_addr (options, volname, conn); + namechk = nfs_rpcsvc_conn_peer_check_name (options, volname, + conn); + addrchk = nfs_rpcsvc_conn_peer_check_addr (options, volname, conn); if (namelookup) - ret = rpcsvc_combine_gen_spec_addr_checks (addrchk, namechk); + ret = nfs_rpcsvc_combine_gen_spec_addr_checks (addrchk, + namechk); else ret = addrchk; @@ -528,7 +533,7 @@ rpcsvc_conn_check_volume_specific (dict_t *options, char *volname, int -rpcsvc_conn_check_volume_general (dict_t *options, rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_check_volume_general (dict_t *options, rpcsvc_conn_t *conn) { int addrchk = RPCSVC_AUTH_REJECT; int namechk = RPCSVC_AUTH_REJECT; @@ -552,11 +557,12 @@ rpcsvc_conn_check_volume_general (dict_t *options, rpcsvc_conn_t *conn) * specific which will over-ride the network address rules. */ if (namelookup) - namechk = rpcsvc_conn_peer_check_name (options, NULL, conn); - addrchk = rpcsvc_conn_peer_check_addr (options, NULL, conn); + namechk = nfs_rpcsvc_conn_peer_check_name (options, NULL, conn); + addrchk = nfs_rpcsvc_conn_peer_check_addr (options, NULL, conn); if (namelookup) - ret = rpcsvc_combine_gen_spec_addr_checks (addrchk, namechk); + ret = nfs_rpcsvc_combine_gen_spec_addr_checks (addrchk, + namechk); else ret = addrchk; @@ -564,7 +570,7 @@ rpcsvc_conn_check_volume_general (dict_t *options, rpcsvc_conn_t *conn) } int -rpcsvc_conn_peer_check (dict_t *options, char *volname, rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_peer_check (dict_t *options, char *volname, rpcsvc_conn_t *conn) { int general_chk = RPCSVC_AUTH_REJECT; int specific_chk = RPCSVC_AUTH_REJECT; @@ -572,16 +578,17 @@ rpcsvc_conn_peer_check (dict_t *options, char *volname, rpcsvc_conn_t *conn) if ((!options) || (!volname) || (!conn)) return RPCSVC_AUTH_REJECT; - general_chk = rpcsvc_conn_check_volume_general (options, conn); - specific_chk = rpcsvc_conn_check_volume_specific (options, volname, - conn); + general_chk = nfs_rpcsvc_conn_check_volume_general (options, conn); + specific_chk = nfs_rpcsvc_conn_check_volume_specific (options, volname, + conn); - return rpcsvc_combine_gen_spec_volume_checks (general_chk,specific_chk); + return nfs_rpcsvc_combine_gen_spec_volume_checks (general_chk, + specific_chk); } char * -rpcsvc_volume_allowed (dict_t *options, char *volname) +nfs_rpcsvc_volume_allowed (dict_t *options, char *volname) { char globalrule[] = "rpc-auth.addr.allow"; char *srchstr = NULL; @@ -611,7 +618,7 @@ out: /* Initialize the core of a connection */ rpcsvc_conn_t * -rpcsvc_conn_init (rpcsvc_t *svc, rpcsvc_program_t *prog, int sockfd) +nfs_rpcsvc_conn_init (rpcsvc_t *svc, rpcsvc_program_t *prog, int sockfd) { rpcsvc_conn_t *conn = NULL; int ret = -1; @@ -668,7 +675,7 @@ free_conn: void -rpcsvc_conn_destroy (rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_destroy (rpcsvc_conn_t *conn) { mem_pool_destroy (conn->txpool); mem_pool_destroy (conn->rxpool); @@ -683,7 +690,7 @@ rpcsvc_conn_destroy (rpcsvc_conn_t *conn) int -__rpcsvc_conn_unref (rpcsvc_conn_t *conn) +__nfs_rpcsvc_conn_unref (rpcsvc_conn_t *conn) { --conn->connref; return conn->connref; @@ -691,7 +698,7 @@ __rpcsvc_conn_unref (rpcsvc_conn_t *conn) void -__rpcsvc_conn_deinit (rpcsvc_conn_t *conn) +__nfs_rpcsvc_conn_deinit (rpcsvc_conn_t *conn) { if (!conn) return; @@ -701,7 +708,7 @@ __rpcsvc_conn_deinit (rpcsvc_conn_t *conn) conn->eventidx); } - if (rpcsvc_conn_check_active (conn)) { + if (nfs_rpcsvc_conn_check_active (conn)) { gf_log (GF_RPCSVC, GF_LOG_DEBUG, "Connection de-activated:" " sockfd: %d", conn->sockfd); conn->connstate = RPCSVC_CONNSTATE_DISCONNECTED; @@ -715,7 +722,7 @@ __rpcsvc_conn_deinit (rpcsvc_conn_t *conn) void -rpcsvc_conn_deinit (rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_deinit (rpcsvc_conn_t *conn) { int ref = 0; @@ -724,20 +731,20 @@ rpcsvc_conn_deinit (rpcsvc_conn_t *conn) pthread_mutex_lock (&conn->connlock); { - __rpcsvc_conn_deinit (conn); - ref = __rpcsvc_conn_unref (conn); + __nfs_rpcsvc_conn_deinit (conn); + ref = __nfs_rpcsvc_conn_unref (conn); } pthread_mutex_unlock (&conn->connlock); if (ref == 0) - rpcsvc_conn_destroy (conn); + nfs_rpcsvc_conn_destroy (conn); return; } void -rpcsvc_conn_unref (rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_unref (rpcsvc_conn_t *conn) { int ref = 0; if (!conn) @@ -745,17 +752,17 @@ rpcsvc_conn_unref (rpcsvc_conn_t *conn) pthread_mutex_lock (&conn->connlock); { - ref = __rpcsvc_conn_unref (conn); + ref = __nfs_rpcsvc_conn_unref (conn); } pthread_mutex_unlock (&conn->connlock); if (ref == 0) - rpcsvc_conn_destroy (conn); + nfs_rpcsvc_conn_destroy (conn); } int -rpcsvc_conn_active (rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_active (rpcsvc_conn_t *conn) { int status = 0; @@ -764,7 +771,7 @@ rpcsvc_conn_active (rpcsvc_conn_t *conn) pthread_mutex_lock (&conn->connlock); { - status = rpcsvc_conn_check_active (conn); + status = nfs_rpcsvc_conn_check_active (conn); } pthread_mutex_unlock (&conn->connlock); @@ -774,7 +781,7 @@ rpcsvc_conn_active (rpcsvc_conn_t *conn) void -rpcsvc_conn_ref (rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_ref (rpcsvc_conn_t *conn) { if (!conn) return; @@ -790,7 +797,7 @@ rpcsvc_conn_ref (rpcsvc_conn_t *conn) void -rpcsvc_conn_state_init (rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_state_init (rpcsvc_conn_t *conn) { if (!conn) return; @@ -802,7 +809,7 @@ rpcsvc_conn_state_init (rpcsvc_conn_t *conn) /* Builds a rpcsvc_conn_t with the aim of listening on it. */ rpcsvc_conn_t * -rpcsvc_conn_listen_init (rpcsvc_t *svc, rpcsvc_program_t *newprog) +nfs_rpcsvc_conn_listen_init (rpcsvc_t *svc, rpcsvc_program_t *newprog) { rpcsvc_conn_t *conn = NULL; int sock = -1; @@ -810,16 +817,16 @@ rpcsvc_conn_listen_init (rpcsvc_t *svc, rpcsvc_program_t *newprog) if (!newprog) return NULL; - sock = rpcsvc_socket_listen (newprog->progaddrfamily, newprog->proghost, - newprog->progport); + sock = nfs_rpcsvc_socket_listen (newprog->progaddrfamily, + newprog->proghost, newprog->progport); if (sock == -1) goto err; - conn = rpcsvc_conn_init (svc, newprog, sock); + conn = nfs_rpcsvc_conn_init (svc, newprog, sock); if (!conn) goto sock_close_err; - rpcsvc_conn_state_init (conn); + nfs_rpcsvc_conn_state_init (conn); sock_close_err: if (!conn) close (sock); @@ -829,7 +836,7 @@ err: } void -rpcsvc_record_init (rpcsvc_record_state_t *rs, struct iobuf_pool *pool) +nfs_rpcsvc_record_init (rpcsvc_record_state_t *rs, struct iobuf_pool *pool) { if (!rs) return; @@ -865,7 +872,8 @@ rpcsvc_record_init (rpcsvc_record_state_t *rs, struct iobuf_pool *pool) int -rpcsvc_conn_privport_check (rpcsvc_t *svc, char *volname, rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_privport_check (rpcsvc_t *svc, char *volname, + rpcsvc_conn_t *conn) { struct sockaddr_in sa; int ret = RPCSVC_AUTH_REJECT; @@ -880,8 +888,8 @@ rpcsvc_conn_privport_check (rpcsvc_t *svc, char *volname, rpcsvc_conn_t *conn) if ((!svc) || (!volname) || (!conn)) return ret; - ret = rpcsvc_conn_peeraddr (conn, NULL, 0, (struct sockaddr *)&sa, - sasize); + ret = nfs_rpcsvc_conn_peeraddr (conn, NULL, 0, (struct sockaddr *)&sa, + sasize); if (ret != 0) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to get peer addr: %s", gai_strerror (ret)); @@ -941,8 +949,8 @@ rpcsvc_conn_privport_check (rpcsvc_t *svc, char *volname, rpcsvc_conn_t *conn) " read rpc-auth.ports.insecure value"); } - ret = rpcsvc_combine_gen_spec_volume_checks (globalinsecure, - exportinsecure); + ret = nfs_rpcsvc_combine_gen_spec_volume_checks (globalinsecure, + exportinsecure); if (ret == RPCSVC_AUTH_ACCEPT) gf_log (GF_RPCSVC, GF_LOG_DEBUG, "Unprivileged port allowed"); else @@ -956,26 +964,26 @@ err: /* Inits a rpcsvc_conn_t after accepting the connection. */ rpcsvc_conn_t * -rpcsvc_conn_accept_init (rpcsvc_t *svc, int listenfd, - rpcsvc_program_t *destprog) +nfs_rpcsvc_conn_accept_init (rpcsvc_t *svc, int listenfd, + rpcsvc_program_t *destprog) { rpcsvc_conn_t *newconn = NULL; int sock = -1; int ret = -1; - sock = rpcsvc_socket_accept (listenfd); + sock = nfs_rpcsvc_socket_accept (listenfd); if (sock == -1) goto err; - newconn = rpcsvc_conn_init (svc, destprog, sock); + newconn = nfs_rpcsvc_conn_init (svc, destprog, sock); if (!newconn) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to init conn object"); ret = -1; goto err; } - rpcsvc_record_init (&newconn->rstate, svc->ctx->iobuf_pool); - rpcsvc_conn_state_init (newconn); + nfs_rpcsvc_record_init (&newconn->rstate, svc->ctx->iobuf_pool); + nfs_rpcsvc_conn_state_init (newconn); if (destprog->conn_init) destprog->conn_init (destprog->private, newconn); ret = 0; @@ -995,8 +1003,8 @@ err: * should be handed to the handler when running in this particular stage. */ int -rpcsvc_stage_conn_associate (rpcsvc_stage_t *stg, rpcsvc_conn_t *conn, - event_handler_t handler, void *data) +nfs_rpcsvc_stage_conn_associate (rpcsvc_stage_t *stg, rpcsvc_conn_t *conn, + event_handler_t handler, void *data) { int ret = -1; @@ -1017,16 +1025,16 @@ err: /* Depending on the state we're in, return the size of the next read request. */ size_t -rpcsvc_record_read_size (rpcsvc_record_state_t *rs) +nfs_rpcsvc_record_read_size (rpcsvc_record_state_t *rs) { size_t toread = -1; if (!rs) return -1; - if (rpcsvc_record_readfraghdr (rs)) + if (nfs_rpcsvc_record_readfraghdr (rs)) toread = rs->remainingfraghdr; - else if (rpcsvc_record_readfrag (rs)) + else if (nfs_rpcsvc_record_readfrag (rs)) toread = rs->remainingfrag; else toread = RPCSVC_CONN_READ; @@ -1036,7 +1044,7 @@ rpcsvc_record_read_size (rpcsvc_record_state_t *rs) uint32_t -rpcsvc_record_extract_fraghdr (char *fraghdr) +nfs_rpcsvc_record_extract_fraghdr (char *fraghdr) { uint32_t hdr = 0; if (!fraghdr) @@ -1050,7 +1058,8 @@ rpcsvc_record_extract_fraghdr (char *fraghdr) ssize_t -rpcsvc_record_read_complete_fraghdr (rpcsvc_record_state_t *rs,ssize_t dataread) +nfs_rpcsvc_record_read_complete_fraghdr (rpcsvc_record_state_t *rs, + ssize_t dataread) { uint32_t remhdr = 0; char *fraghdrstart = NULL; @@ -1058,11 +1067,11 @@ rpcsvc_record_read_complete_fraghdr (rpcsvc_record_state_t *rs,ssize_t dataread) fraghdrstart = &rs->fragheader[0]; remhdr = rs->remainingfraghdr; - fraghdr = rpcsvc_record_extract_fraghdr (fraghdrstart); + fraghdr = nfs_rpcsvc_record_extract_fraghdr (fraghdrstart); rs->fragsize = RPCSVC_FRAGSIZE (fraghdr); gf_log (GF_RPCSVC, GF_LOG_TRACE, "Received fragment size: %d", rs->fragsize); - if (rpcsvc_record_vectored (rs)) { + if (nfs_rpcsvc_record_vectored (rs)) { gf_log (GF_RPCSVC, GF_LOG_TRACE, "Vectored RPC header," " remaining: %d", RPCSVC_BARERPC_MSGSZ); rs->remainingfrag = RPCSVC_BARERPC_MSGSZ; @@ -1082,7 +1091,8 @@ rpcsvc_record_read_complete_fraghdr (rpcsvc_record_state_t *rs,ssize_t dataread) ssize_t -rpcsvc_record_read_partial_fraghdr (rpcsvc_record_state_t *rs, ssize_t dataread) +nfs_rpcsvc_record_read_partial_fraghdr (rpcsvc_record_state_t *rs, + ssize_t dataread) { /* In case we got less than even the remaining header size, @@ -1090,7 +1100,7 @@ rpcsvc_record_read_partial_fraghdr (rpcsvc_record_state_t *rs, ssize_t dataread) * bytes to come in. */ rs->remainingfraghdr -= dataread; - rpcsvc_record_update_currenthdr (rs, dataread); + nfs_rpcsvc_record_update_currenthdr (rs, dataread); dataread = 0; gf_log (GF_RPCSVC, GF_LOG_TRACE, "Fragment header remaining: %d", rs->remainingfraghdr); @@ -1100,7 +1110,7 @@ rpcsvc_record_read_partial_fraghdr (rpcsvc_record_state_t *rs, ssize_t dataread) ssize_t -rpcsvc_record_update_fraghdr (rpcsvc_record_state_t *rs, ssize_t dataread) +nfs_rpcsvc_record_update_fraghdr (rpcsvc_record_state_t *rs, ssize_t dataread) { if ((!rs) || (dataread <= 0)) return -1; @@ -1108,7 +1118,7 @@ rpcsvc_record_update_fraghdr (rpcsvc_record_state_t *rs, ssize_t dataread) /* Why are we even here, we're not supposed to be in the fragment * header processing state. */ - if (!rpcsvc_record_readfraghdr(rs)) { + if (!nfs_rpcsvc_record_readfraghdr(rs)) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "record state inconsistent" ": request to update frag header when state is not" "RPCSVC_READ_FRAGHDR"); @@ -1127,15 +1137,18 @@ rpcsvc_record_update_fraghdr (rpcsvc_record_state_t *rs, ssize_t dataread) /* We've definitely got the full header now and may be even more. */ if (dataread >= rs->remainingfraghdr) - dataread = rpcsvc_record_read_complete_fraghdr (rs, dataread); + dataread = nfs_rpcsvc_record_read_complete_fraghdr (rs, + dataread); else - dataread = rpcsvc_record_read_partial_fraghdr (rs, dataread); + dataread = nfs_rpcsvc_record_read_partial_fraghdr (rs, + dataread); return dataread; } ssize_t -rpcsvc_record_read_complete_frag (rpcsvc_record_state_t *rs, ssize_t dataread) +nfs_rpcsvc_record_read_complete_frag (rpcsvc_record_state_t *rs, + ssize_t dataread) { uint32_t remfrag; @@ -1162,12 +1175,13 @@ rpcsvc_record_read_complete_frag (rpcsvc_record_state_t *rs, ssize_t dataread) ssize_t -rpcsvc_record_read_partial_frag (rpcsvc_record_state_t *rs, ssize_t dataread) +nfs_rpcsvc_record_read_partial_frag (rpcsvc_record_state_t *rs, + ssize_t dataread) { /* Just take whatever has come through the current network buffer. */ rs->remainingfrag -= dataread; - rpcsvc_record_update_currentfrag (rs, dataread); + nfs_rpcsvc_record_update_currentfrag (rs, dataread); /* Since we know we're consuming the whole buffer from dataread * simply setting to 0 zero is fine. */ @@ -1179,12 +1193,12 @@ rpcsvc_record_read_partial_frag (rpcsvc_record_state_t *rs, ssize_t dataread) ssize_t -rpcsvc_record_update_frag (rpcsvc_record_state_t *rs, ssize_t dataread) +nfs_rpcsvc_record_update_frag (rpcsvc_record_state_t *rs, ssize_t dataread) { if ((!rs) || (dataread <= 0)) return -1; - if (!rpcsvc_record_readfrag (rs)) { + if (!nfs_rpcsvc_record_readfrag (rs)) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "record state inconsistent" ": request to update fragment when record state is not" "RPCSVC_READ_FRAG."); @@ -1200,9 +1214,9 @@ rpcsvc_record_update_frag (rpcsvc_record_state_t *rs, ssize_t dataread) /* We've read in more data than the current fragment requires. */ if (dataread >= rs->remainingfrag) - dataread = rpcsvc_record_read_complete_frag (rs, dataread); + dataread = nfs_rpcsvc_record_read_complete_frag (rs, dataread); else - dataread = rpcsvc_record_read_partial_frag (rs, dataread); + dataread = nfs_rpcsvc_record_read_partial_frag (rs, dataread); return dataread; } @@ -1213,7 +1227,7 @@ rpcsvc_record_update_frag (rpcsvc_record_state_t *rs, ssize_t dataread) * of the pointers below are NULL. */ rpcsvc_actor_t * -rpcsvc_program_actor (rpcsvc_conn_t *conn, rpcsvc_request_t *req) +nfs_rpcsvc_program_actor (rpcsvc_conn_t *conn, rpcsvc_request_t *req) { rpcsvc_program_t *program = NULL; int err = SYSTEM_ERR; @@ -1273,8 +1287,8 @@ err: rpcsvc_txbuf_t * -rpcsvc_init_txbuf (rpcsvc_conn_t *conn, struct iovec msg, struct iobuf *iob, - struct iobref *iobref, int txflags) +nfs_rpcsvc_init_txbuf (rpcsvc_conn_t *conn, struct iovec msg, struct iobuf *iob, + struct iobref *iobref, int txflags) { rpcsvc_txbuf_t *txbuf = NULL; @@ -1301,15 +1315,15 @@ rpcsvc_init_txbuf (rpcsvc_conn_t *conn, struct iovec msg, struct iobuf *iob, int -rpcsvc_conn_append_txlist (rpcsvc_conn_t *conn, struct iovec msg, - struct iobuf *iob, int txflags) +nfs_rpcsvc_conn_append_txlist (rpcsvc_conn_t *conn, struct iovec msg, + struct iobuf *iob, int txflags) { rpcsvc_txbuf_t *txbuf = NULL; if ((!conn) || (!msg.iov_base) || (!iob)) return -1; - txbuf = rpcsvc_init_txbuf (conn, msg, iob, NULL, txflags); + txbuf = nfs_rpcsvc_init_txbuf (conn, msg, iob, NULL, txflags); if (!txbuf) return -1; @@ -1319,22 +1333,22 @@ rpcsvc_conn_append_txlist (rpcsvc_conn_t *conn, struct iovec msg, void -rpcsvc_set_lastfrag (uint32_t *fragsize) { +nfs_rpcsvc_set_lastfrag (uint32_t *fragsize) { (*fragsize) |= 0x80000000U; } void -rpcsvc_set_frag_header_size (uint32_t size, char *haddr) +nfs_rpcsvc_set_frag_header_size (uint32_t size, char *haddr) { size = htonl (size); memcpy (haddr, &size, sizeof (size)); } void -rpcsvc_set_last_frag_header_size (uint32_t size, char *haddr) +nfs_rpcsvc_set_last_frag_header_size (uint32_t size, char *haddr) { - rpcsvc_set_lastfrag (&size); - rpcsvc_set_frag_header_size (size, haddr); + nfs_rpcsvc_set_lastfrag (&size); + nfs_rpcsvc_set_frag_header_size (size, haddr); } @@ -1342,8 +1356,8 @@ rpcsvc_set_last_frag_header_size (uint32_t size, char *haddr) * encode the RPC record header into the buffer pointed by recordstart. */ struct iovec -rpcsvc_record_build_header (char *recordstart, size_t rlen, - struct rpc_msg reply, size_t payload) +nfs_rpcsvc_record_build_header (char *recordstart, size_t rlen, + struct rpc_msg reply, size_t payload) { struct iovec replyhdr; struct iovec txrecord = {0, 0}; @@ -1353,8 +1367,8 @@ rpcsvc_record_build_header (char *recordstart, size_t rlen, /* After leaving aside the 4 bytes for the fragment header, lets * encode the RPC reply structure into the buffer given to us. */ - ret = rpc_reply_to_xdr (&reply,(recordstart + RPCSVC_FRAGHDR_SIZE), - rlen, &replyhdr); + ret = nfs_rpc_reply_to_xdr (&reply,(recordstart + RPCSVC_FRAGHDR_SIZE), + rlen, &replyhdr); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to create RPC reply"); goto err; @@ -1368,7 +1382,7 @@ rpcsvc_record_build_header (char *recordstart, size_t rlen, * we just set this fragment as the first and last fragment for this * record. */ - rpcsvc_set_last_frag_header_size (fraglen, recordstart); + nfs_rpcsvc_set_last_frag_header_size (fraglen, recordstart); /* Even though the RPC record starts at recordstart+RPCSVC_FRAGHDR_SIZE * we need to transmit the record with the fragment header, which starts @@ -1389,9 +1403,9 @@ err: int -rpcsvc_conn_submit (rpcsvc_conn_t *conn, struct iovec hdr, - struct iobuf *hdriob, struct iovec msgvec, - struct iobuf *msgiob) +nfs_rpcsvc_conn_submit (rpcsvc_conn_t *conn, struct iovec hdr, + struct iobuf *hdriob, struct iovec msgvec, + struct iobuf *msgiob) { int ret = -1; @@ -1405,13 +1419,13 @@ rpcsvc_conn_submit (rpcsvc_conn_t *conn, struct iovec hdr, */ pthread_mutex_lock (&conn->connlock); { - if (!rpcsvc_conn_check_active (conn)) { + if (!nfs_rpcsvc_conn_check_active (conn)) { gf_log (GF_RPCSVC, GF_LOG_DEBUG, "Connection inactive"); goto unlock_err; } - ret = rpcsvc_conn_append_txlist (conn, hdr, hdriob, - RPCSVC_TXB_FIRST); + ret = nfs_rpcsvc_conn_append_txlist (conn, hdr, hdriob, + RPCSVC_TXB_FIRST); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to append " "header to transmission list"); @@ -1423,8 +1437,9 @@ rpcsvc_conn_submit (rpcsvc_conn_t *conn, struct iovec hdr, */ ret = 0; if (msgiob) - ret = rpcsvc_conn_append_txlist (conn, msgvec, msgiob, - RPCSVC_TXB_LAST); + ret = nfs_rpcsvc_conn_append_txlist (conn, msgvec, + msgiob, + RPCSVC_TXB_LAST); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to append" " payload to transmission list"); @@ -1450,22 +1465,24 @@ err: int -rpcsvc_fill_reply (rpcsvc_request_t *req, struct rpc_msg *reply) +nfs_rpcsvc_fill_reply (rpcsvc_request_t *req, struct rpc_msg *reply) { rpcsvc_program_t *prog = NULL; if ((!req) || (!reply)) return -1; - prog = rpcsvc_request_program (req); - rpc_fill_empty_reply (reply, req->xid); + prog = nfs_rpcsvc_request_program (req); + nfs_rpc_fill_empty_reply (reply, req->xid); if (req->rpc_stat == MSG_DENIED) - rpc_fill_denied_reply (reply, req->rpc_err, req->auth_err); + nfs_rpc_fill_denied_reply (reply, req->rpc_err, req->auth_err); else if (req->rpc_stat == MSG_ACCEPTED) - rpc_fill_accepted_reply (reply, req->rpc_err, prog->proglowvers, - prog->proghighvers, req->verf.flavour, - req->verf.datalen, - req->verf.authdata); + nfs_rpc_fill_accepted_reply (reply, req->rpc_err, + prog->proglowvers, + prog->proghighvers, + req->verf.flavour, + req->verf.datalen, + req->verf.authdata); else gf_log (GF_RPCSVC, GF_LOG_ERROR, "Invalid rpc_stat value"); @@ -1482,8 +1499,8 @@ rpcsvc_fill_reply (rpcsvc_request_t *req, struct rpc_msg *reply) * we should account for the length of that buffer in the RPC fragment header. */ struct iobuf * -rpcsvc_record_build_record (rpcsvc_request_t *req, size_t payload, - struct iovec *recbuf) +nfs_rpcsvc_record_build_record (rpcsvc_request_t *req, size_t payload, + struct iovec *recbuf) { struct rpc_msg reply; struct iobuf *replyiob = NULL; @@ -1500,7 +1517,7 @@ rpcsvc_record_build_record (rpcsvc_request_t *req, size_t payload, * layer can use. */ conn = req->conn; - svc = rpcsvc_conn_rpcsvc (conn); + svc = nfs_rpcsvc_conn_rpcsvc (conn); replyiob = iobuf_get (svc->ctx->iobuf_pool); pagesize = iobpool_pagesize ((struct iobuf_pool *)svc->ctx->iobuf_pool); if (!replyiob) { @@ -1511,9 +1528,9 @@ rpcsvc_record_build_record (rpcsvc_request_t *req, size_t payload, record = iobuf_ptr (replyiob); /* Now we have it. */ /* Fill the rpc structure and XDR it into the buffer got above. */ - rpcsvc_fill_reply (req, &reply); - recordhdr = rpcsvc_record_build_header (record, pagesize, reply, - payload); + nfs_rpcsvc_fill_reply (req, &reply); + recordhdr = nfs_rpcsvc_record_build_header (record, pagesize, reply, + payload); if (!recordhdr.iov_base) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to build record " " header"); @@ -1557,8 +1574,8 @@ err_exit: */ int -rpcsvc_submit_generic (rpcsvc_request_t *req, struct iovec msgvec, - struct iobuf *msg) +nfs_rpcsvc_submit_generic (rpcsvc_request_t *req, struct iovec msgvec, + struct iobuf *msg) { int ret = -1; struct iobuf *replyiob = NULL; @@ -1571,7 +1588,8 @@ rpcsvc_submit_generic (rpcsvc_request_t *req, struct iovec msgvec, conn = req->conn; gf_log (GF_RPCSVC, GF_LOG_TRACE, "Tx message: %zu", msgvec.iov_len); /* Build the buffer containing the encoded RPC reply. */ - replyiob = rpcsvc_record_build_record (req, msgvec.iov_len, &recordhdr); + replyiob = nfs_rpcsvc_record_build_record (req, msgvec.iov_len, + &recordhdr); if (!replyiob) { gf_log (GF_RPCSVC, GF_LOG_ERROR,"Reply record creation failed"); goto disconnect_exit; @@ -1584,7 +1602,7 @@ rpcsvc_submit_generic (rpcsvc_request_t *req, struct iovec msgvec, */ if (msg) iobuf_ref (msg); - ret = rpcsvc_conn_submit (conn, recordhdr, replyiob, msgvec, msg); + ret = nfs_rpcsvc_conn_submit (conn, recordhdr, replyiob, msgvec, msg); mem_put (conn->rxpool, req); if (ret == -1) { @@ -1604,18 +1622,18 @@ disconnect_exit: * no actor was called, we will be losing the ref held for the RPC * layer. */ - if ((rpcsvc_request_accepted (req)) && - (rpcsvc_request_accepted_success (req))) - rpcsvc_conn_unref (conn); + if ((nfs_rpcsvc_request_accepted (req)) && + (nfs_rpcsvc_request_accepted_success (req))) + nfs_rpcsvc_conn_unref (conn); return ret; } int -rpcsvc_request_attach_vector (rpcsvc_request_t *req, struct iovec msgvec, - struct iobuf *iob, struct iobref *iobref, - int finalvector) +nfs_rpcsvc_request_attach_vector (rpcsvc_request_t *req, struct iovec msgvec, + struct iobuf *iob, struct iobref *iobref, + int finalvector) { rpcsvc_txbuf_t *txb = NULL; int txflags = 0; @@ -1629,7 +1647,7 @@ rpcsvc_request_attach_vector (rpcsvc_request_t *req, struct iovec msgvec, /* We only let the user decide whether this is the last vector for the * record, since the first vector is always the RPC header. */ - txb = rpcsvc_init_txbuf (req->conn, msgvec, iob, iobref, txflags); + txb = nfs_rpcsvc_init_txbuf (req->conn, msgvec, iob, iobref, txflags); if (!txb) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Could not init tx buf"); return -1; @@ -1647,15 +1665,15 @@ rpcsvc_request_attach_vector (rpcsvc_request_t *req, struct iovec msgvec, int -rpcsvc_request_attach_vectors (rpcsvc_request_t *req, struct iovec *payload, - int vcount, struct iobref *piobref) +nfs_rpcsvc_request_attach_vectors (rpcsvc_request_t *req, struct iovec *payload, + int vcount, struct iobref *piobref) { int c = 0; int ret = -1; for (;c < (vcount-1); c++) { - ret = rpcsvc_request_attach_vector (req, payload[c], NULL, - piobref, 0); + ret = nfs_rpcsvc_request_attach_vector (req, payload[c], NULL, + piobref, 0); if (ret < 0) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to attach " "vector"); @@ -1663,8 +1681,8 @@ rpcsvc_request_attach_vectors (rpcsvc_request_t *req, struct iovec *payload, } } - ret = rpcsvc_request_attach_vector (req, payload[vcount-1], NULL, - piobref, 1); + ret = nfs_rpcsvc_request_attach_vector (req, payload[vcount-1], NULL, + piobref, 1); if (ret < 0) gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to attach final vec"); @@ -1674,7 +1692,7 @@ out: int -rpcsvc_submit_vectors (rpcsvc_request_t *req) +nfs_rpcsvc_submit_vectors (rpcsvc_request_t *req) { int ret = -1; struct iobuf *replyiob = NULL; @@ -1685,15 +1703,15 @@ rpcsvc_submit_vectors (rpcsvc_request_t *req) return -1; /* Build the buffer containing the encoded RPC reply. */ - replyiob = rpcsvc_record_build_record (req, req->payloadsize, - &recordhdr); + replyiob = nfs_rpcsvc_record_build_record (req, req->payloadsize, + &recordhdr); if (!replyiob) { gf_log (GF_RPCSVC, GF_LOG_ERROR,"Reply record creation failed"); goto disconnect_exit; } - rpctxb = rpcsvc_init_txbuf (req->conn, recordhdr, replyiob, NULL, - RPCSVC_TXB_FIRST); + rpctxb = nfs_rpcsvc_init_txbuf (req->conn, recordhdr, replyiob, NULL, + RPCSVC_TXB_FIRST); if (!rpctxb) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to create tx buf"); goto disconnect_exit; @@ -1715,7 +1733,7 @@ disconnect_exit: * response to the ref that is performed on the conn when a request is * handed to the RPC program. */ - rpcsvc_conn_unref (req->conn); + nfs_rpcsvc_conn_unref (req->conn); if (ret == -1) iobuf_unref (replyiob); @@ -1725,7 +1743,7 @@ disconnect_exit: int -rpcsvc_error_reply (rpcsvc_request_t *req) +nfs_rpcsvc_error_reply (rpcsvc_request_t *req) { struct iovec dummyvec = {0, }; @@ -1735,13 +1753,13 @@ rpcsvc_error_reply (rpcsvc_request_t *req) /* At this point the req should already have been filled with the * appropriate RPC error numbers. */ - return rpcsvc_submit_generic (req, dummyvec, NULL); + return nfs_rpcsvc_submit_generic (req, dummyvec, NULL); } rpcsvc_request_t * -rpcsvc_request_init (rpcsvc_conn_t *conn, struct rpc_msg *callmsg, - struct iovec progmsg, rpcsvc_request_t *req) +nfs_rpcsvc_request_init (rpcsvc_conn_t *conn, struct rpc_msg *callmsg, + struct iovec progmsg, rpcsvc_request_t *req) { if ((!conn) || (!callmsg)|| (!req)) return NULL; @@ -1749,10 +1767,10 @@ rpcsvc_request_init (rpcsvc_conn_t *conn, struct rpc_msg *callmsg, /* We start a RPC request as always denied. */ req->rpc_stat = MSG_DENIED; - req->xid = rpc_call_xid (callmsg); - req->prognum = rpc_call_program (callmsg); - req->progver = rpc_call_progver (callmsg); - req->procnum = rpc_call_progproc (callmsg); + req->xid = nfs_rpc_call_xid (callmsg); + req->prognum = nfs_rpc_call_program (callmsg); + req->progver = nfs_rpc_call_progver (callmsg); + req->procnum = nfs_rpc_call_progproc (callmsg); req->conn = conn; req->msg = progmsg; req->recordiob = conn->rstate.activeiob; @@ -1763,19 +1781,19 @@ rpcsvc_request_init (rpcsvc_conn_t *conn, struct rpc_msg *callmsg, * been copied into the required sections of the req structure, * we just need to fill in the meta-data about it now. */ - req->cred.flavour = rpc_call_cred_flavour (callmsg); - req->cred.datalen = rpc_call_cred_len (callmsg); - req->verf.flavour = rpc_call_verf_flavour (callmsg); - req->verf.datalen = rpc_call_verf_len (callmsg); + req->cred.flavour = nfs_rpc_call_cred_flavour (callmsg); + req->cred.datalen = nfs_rpc_call_cred_len (callmsg); + req->verf.flavour = nfs_rpc_call_verf_flavour (callmsg); + req->verf.datalen = nfs_rpc_call_verf_len (callmsg); /* AUTH */ - rpcsvc_auth_request_init (req); + nfs_rpcsvc_auth_request_init (req); return req; } rpcsvc_request_t * -rpcsvc_request_create (rpcsvc_conn_t *conn) +nfs_rpcsvc_request_create (rpcsvc_conn_t *conn) { char *msgbuf = NULL; struct rpc_msg rpcmsg; @@ -1792,43 +1810,45 @@ rpcsvc_request_create (rpcsvc_conn_t *conn) * This avoids a need to keep a temp buffer into which the auth data * would've been copied otherwise. */ - rpcsvc_alloc_request (conn, req); + nfs_rpcsvc_alloc_request (conn, req); if (!req) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed to alloc request"); goto err; } msgbuf = iobuf_ptr (conn->rstate.activeiob); - ret = xdr_to_rpc_call (msgbuf, conn->rstate.recordsize, &rpcmsg, - &progmsg, req->cred.authdata,req->verf.authdata); + ret = nfs_xdr_to_rpc_call (msgbuf, conn->rstate.recordsize, &rpcmsg, + &progmsg, req->cred.authdata, + req->verf.authdata); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "RPC call decoding failed"); - rpcsvc_request_seterr (req, GARBAGE_ARGS); + nfs_rpcsvc_request_seterr (req, GARBAGE_ARGS); goto err; } ret = -1; - rpcsvc_request_init (conn, &rpcmsg, progmsg, req); + nfs_rpcsvc_request_init (conn, &rpcmsg, progmsg, req); gf_log (GF_RPCSVC, GF_LOG_DEBUG, "RPC XID: %lx, Ver: %ld, Program: %ld," - " ProgVers: %ld, Proc: %ld", rpc_call_xid (&rpcmsg), - rpc_call_rpcvers (&rpcmsg), rpc_call_program (&rpcmsg), - rpc_call_progver (&rpcmsg), rpc_call_progproc (&rpcmsg)); + " ProgVers: %ld, Proc: %ld", nfs_rpc_call_xid (&rpcmsg), + nfs_rpc_call_rpcvers (&rpcmsg), nfs_rpc_call_program (&rpcmsg), + nfs_rpc_call_progver (&rpcmsg), + nfs_rpc_call_progproc (&rpcmsg)); - if (rpc_call_rpcvers (&rpcmsg) != 2) { + if (nfs_rpc_call_rpcvers (&rpcmsg) != 2) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "RPC version not supported"); - rpcsvc_request_seterr (req, RPC_MISMATCH); + nfs_rpcsvc_request_seterr (req, RPC_MISMATCH); goto err; } - ret = rpcsvc_authenticate (req); + ret = nfs_rpcsvc_authenticate (req); if (ret == RPCSVC_AUTH_REJECT) { /* No need to set auth_err, that is the responsibility of * the authentication handler since only that know what exact * error happened. */ - rpcsvc_request_seterr (req, AUTH_ERROR); + nfs_rpcsvc_request_seterr (req, AUTH_ERROR); gf_log (GF_RPCSVC, GF_LOG_ERROR, "Failed authentication"); ret = -1; goto err; @@ -1842,7 +1862,7 @@ rpcsvc_request_create (rpcsvc_conn_t *conn) ret = 0; err: if (ret == -1) { - ret = rpcsvc_error_reply (req); + ret = nfs_rpcsvc_error_reply (req); req = NULL; } @@ -1851,7 +1871,7 @@ err: int -rpcsvc_handle_rpc_call (rpcsvc_conn_t *conn) +nfs_rpcsvc_handle_rpc_call (rpcsvc_conn_t *conn) { rpcsvc_actor_t *actor = NULL; rpcsvc_request_t *req = NULL; @@ -1860,25 +1880,25 @@ rpcsvc_handle_rpc_call (rpcsvc_conn_t *conn) if (!conn) return -1; - req = rpcsvc_request_create (conn); + req = nfs_rpcsvc_request_create (conn); if (!req) goto err; - if (!rpcsvc_request_accepted (req)) + if (!nfs_rpcsvc_request_accepted (req)) goto err_reply; - actor = rpcsvc_program_actor (conn, req); + actor = nfs_rpcsvc_program_actor (conn, req); if (!actor) goto err_reply; if ((actor) && (actor->actor)) { - rpcsvc_conn_ref (conn); + nfs_rpcsvc_conn_ref (conn); ret = actor->actor (req); } err_reply: if (ret == RPCSVC_ACTOR_ERROR) - ret = rpcsvc_error_reply (req); + ret = nfs_rpcsvc_error_reply (req); /* No need to propagate error beyond this function since the reply * has now been queued. */ @@ -1887,17 +1907,17 @@ err: return ret; } -#define rpc_call_cred_addr(rs) (iobuf_ptr ((rs)->activeiob) + RPCSVC_BARERPC_MSGSZ - 4) +#define nfs_rpc_call_cred_addr(rs) (iobuf_ptr ((rs)->activeiob) + RPCSVC_BARERPC_MSGSZ - 4) uint32_t -rpcsvc_call_credlen (rpcsvc_record_state_t *rs) +nfs_rpcsvc_call_credlen (rpcsvc_record_state_t *rs) { char *credaddr = NULL; uint32_t credlen_nw = 0; uint32_t credlen_host = 0; /* Position to the start of the credential length field. */ - credaddr = rpc_call_cred_addr (rs); + credaddr = nfs_rpc_call_cred_addr (rs); credlen_nw = *(uint32_t *)credaddr; credlen_host = ntohl (credlen_nw); @@ -1905,7 +1925,7 @@ rpcsvc_call_credlen (rpcsvc_record_state_t *rs) } uint32_t -rpcsvc_call_verflen (rpcsvc_record_state_t *rs) +nfs_rpcsvc_call_verflen (rpcsvc_record_state_t *rs) { char *verfaddr = NULL; uint32_t verflen_nw = 0; @@ -1913,8 +1933,8 @@ rpcsvc_call_verflen (rpcsvc_record_state_t *rs) uint32_t credlen = 0; /* Position to the start of the verifier length field. */ - credlen = rpcsvc_call_credlen (rs); - verfaddr = (rpc_call_cred_addr (rs) + 4 + credlen); + credlen = nfs_rpcsvc_call_credlen (rs); + verfaddr = (nfs_rpc_call_cred_addr (rs) + 4 + credlen); verflen_nw = *(uint32_t *)verfaddr; verflen_host = ntohl (verflen_nw); @@ -1923,18 +1943,18 @@ rpcsvc_call_verflen (rpcsvc_record_state_t *rs) void -rpcsvc_update_vectored_verf (rpcsvc_record_state_t *rs) +nfs_rpcsvc_update_vectored_verf (rpcsvc_record_state_t *rs) { if (!rs) return; - rs->recordsize += rpcsvc_call_verflen (rs); + rs->recordsize += nfs_rpcsvc_call_verflen (rs); return; } void -rpcsvc_handle_vectored_prep_rpc_call (rpcsvc_conn_t *conn) +nfs_rpcsvc_handle_vectored_prep_rpc_call (rpcsvc_conn_t *conn) { rpcsvc_actor_t *actor = NULL; rpcsvc_request_t *req = NULL; @@ -1955,31 +1975,31 @@ rpcsvc_handle_vectored_prep_rpc_call (rpcsvc_conn_t *conn) */ rs->remainingfrag = rs->fragsize - rs->recordsize; rs->vecstate = RPCSVC_VECTOR_IGNORE; - req = rpcsvc_request_create (conn); - svc = rpcsvc_conn_rpcsvc (conn); + req = nfs_rpcsvc_request_create (conn); + svc = nfs_rpcsvc_conn_rpcsvc (conn); if (!req) goto err; - if (!rpcsvc_request_accepted (req)) + if (!nfs_rpcsvc_request_accepted (req)) goto err_reply; - actor = rpcsvc_program_actor (conn, req); + actor = nfs_rpcsvc_program_actor (conn, req); if (!actor) goto err_reply; if (!actor->vector_sizer) { ret = -1; - rpcsvc_request_seterr (req, PROC_UNAVAIL); + nfs_rpcsvc_request_seterr (req, PROC_UNAVAIL); goto err_reply; } - rpcsvc_conn_ref (conn); + nfs_rpcsvc_conn_ref (conn); ret = actor->vector_sizer (req, &remfrag, &newbuf); - rpcsvc_conn_unref (conn); + nfs_rpcsvc_conn_unref (conn); if (ret == RPCSVC_ACTOR_ERROR) { ret = -1; - rpcsvc_request_seterr (req, SYSTEM_ERR); + nfs_rpcsvc_request_seterr (req, SYSTEM_ERR); goto err_reply; } @@ -1998,7 +2018,7 @@ rpcsvc_handle_vectored_prep_rpc_call (rpcsvc_conn_t *conn) err_reply: if (ret == -1) - ret = rpcsvc_error_reply (req); + ret = nfs_rpcsvc_error_reply (req); /* No need to propagate error beyond this function since the reply * has now been queued. */ @@ -2009,7 +2029,7 @@ err: void -rpcsvc_update_vectored_verfsz (rpcsvc_conn_t *conn) +nfs_rpcsvc_update_vectored_verfsz (rpcsvc_conn_t *conn) { rpcsvc_record_state_t *rs = NULL; uint32_t verflen = 0; @@ -2019,7 +2039,7 @@ rpcsvc_update_vectored_verfsz (rpcsvc_conn_t *conn) rs = &conn->rstate; - verflen = rpcsvc_call_verflen (rs); + verflen = nfs_rpcsvc_call_verflen (rs); rs->recordsize += 8; if (verflen > 0) { rs->remainingfrag = verflen; @@ -2028,7 +2048,7 @@ rpcsvc_update_vectored_verfsz (rpcsvc_conn_t *conn) rs->vecstate = RPCSVC_VECTOR_READVERF; } else { gf_log (GF_RPCSVC, GF_LOG_TRACE, "Vectored RPC preparing call"); - rpcsvc_handle_vectored_prep_rpc_call (conn); + nfs_rpcsvc_handle_vectored_prep_rpc_call (conn); } return; @@ -2036,14 +2056,14 @@ rpcsvc_update_vectored_verfsz (rpcsvc_conn_t *conn) void -rpcsvc_update_vectored_cred (rpcsvc_record_state_t *rs) +nfs_rpcsvc_update_vectored_cred (rpcsvc_record_state_t *rs) { uint32_t credlen = 0; if (!rs) return; - credlen = rpcsvc_call_credlen (rs); + credlen = nfs_rpcsvc_call_credlen (rs); /* Update remainingfrag to read the 8 bytes needed for * reading verf flavour and verf len. */ @@ -2057,14 +2077,14 @@ rpcsvc_update_vectored_cred (rpcsvc_record_state_t *rs) } void -rpcsvc_update_vectored_barerpc (rpcsvc_record_state_t *rs) +nfs_rpcsvc_update_vectored_barerpc (rpcsvc_record_state_t *rs) { uint32_t credlen = 0; if (!rs) return; - credlen = rpcsvc_call_credlen (rs); + credlen = nfs_rpcsvc_call_credlen (rs); rs->recordsize = RPCSVC_BARERPC_MSGSZ; if (credlen == 0) { rs->remainingfrag = 8; @@ -2083,7 +2103,7 @@ rpcsvc_update_vectored_barerpc (rpcsvc_record_state_t *rs) void -rpcsvc_handle_vectored_rpc_call (rpcsvc_conn_t *conn) +nfs_rpcsvc_handle_vectored_rpc_call (rpcsvc_conn_t *conn) { rpcsvc_actor_t *actor = NULL; rpcsvc_request_t *req = NULL; @@ -2099,28 +2119,28 @@ rpcsvc_handle_vectored_rpc_call (rpcsvc_conn_t *conn) rs = &conn->rstate; req = conn->vectoredreq; - svc = rpcsvc_conn_rpcsvc (conn); + svc = nfs_rpcsvc_conn_rpcsvc (conn); if (!req) goto err; - actor = rpcsvc_program_actor (conn, req); + actor = nfs_rpcsvc_program_actor (conn, req); if (!actor) goto err_reply; if (!actor->vector_sizer) { ret = -1; - rpcsvc_request_seterr (req, PROC_UNAVAIL); + nfs_rpcsvc_request_seterr (req, PROC_UNAVAIL); goto err_reply; } req->msg.iov_len = (unsigned long)((long)rs->fragcurrent - (long)req->msg.iov_base); - rpcsvc_conn_ref (conn); + nfs_rpcsvc_conn_ref (conn); ret = actor->vector_sizer (req, &remfrag, &newbuf); - rpcsvc_conn_unref (conn); + nfs_rpcsvc_conn_unref (conn); if (ret == RPCSVC_ACTOR_ERROR) { ret = -1; - rpcsvc_request_seterr (req, SYSTEM_ERR); + nfs_rpcsvc_request_seterr (req, SYSTEM_ERR); goto err_reply; } @@ -2140,7 +2160,7 @@ rpcsvc_handle_vectored_rpc_call (rpcsvc_conn_t *conn) ret = 0; err_reply: if (ret == -1) - ret = rpcsvc_error_reply (req); + ret = nfs_rpcsvc_error_reply (req); /* No need to propagate error beyond this function since the reply * has now been queued. */ @@ -2152,7 +2172,7 @@ err: void -rpcsvc_record_vectored_call_actor (rpcsvc_conn_t *conn) +nfs_rpcsvc_record_vectored_call_actor (rpcsvc_conn_t *conn) { rpcsvc_actor_t *actor = NULL; rpcsvc_request_t *req = NULL; @@ -2165,27 +2185,27 @@ rpcsvc_record_vectored_call_actor (rpcsvc_conn_t *conn) rs = &conn->rstate; req = conn->vectoredreq; - svc = rpcsvc_conn_rpcsvc (conn); + svc = nfs_rpcsvc_conn_rpcsvc (conn); if (!req) goto err; - actor = rpcsvc_program_actor (conn, req); + actor = nfs_rpcsvc_program_actor (conn, req); if (!actor) goto err_reply; if (actor->vector_actor) { - rpcsvc_conn_ref (conn); + nfs_rpcsvc_conn_ref (conn); ret = actor->vector_actor (req, rs->vectoriob); } else { - rpcsvc_request_seterr (req, PROC_UNAVAIL); + nfs_rpcsvc_request_seterr (req, PROC_UNAVAIL); gf_log (GF_RPCSVC, GF_LOG_ERROR, "No vectored handler present"); ret = RPCSVC_ACTOR_ERROR; } err_reply: if (ret == RPCSVC_ACTOR_ERROR) - ret = rpcsvc_error_reply (req); + ret = nfs_rpcsvc_error_reply (req); /* No need to propagate error beyond this function since the reply * has now been queued. */ @@ -2197,7 +2217,7 @@ err: ssize_t -rpcsvc_update_vectored_state (rpcsvc_conn_t *conn) +nfs_rpcsvc_update_vectored_state (rpcsvc_conn_t *conn) { rpcsvc_record_state_t *rs = NULL; rpcsvc_t *svc = NULL; @@ -2215,26 +2235,26 @@ rpcsvc_update_vectored_state (rpcsvc_conn_t *conn) */ rs = &conn->rstate; - if (rpcsvc_record_vectored_baremsg (rs)) - rpcsvc_update_vectored_barerpc (rs); - else if (rpcsvc_record_vectored_cred (rs)) - rpcsvc_update_vectored_cred (rs); - else if (rpcsvc_record_vectored_verfsz (rs)) - rpcsvc_update_vectored_verfsz (conn); - else if (rpcsvc_record_vectored_verfread (rs)) { - rpcsvc_update_vectored_verf (rs); + if (nfs_rpcsvc_record_vectored_baremsg (rs)) + nfs_rpcsvc_update_vectored_barerpc (rs); + else if (nfs_rpcsvc_record_vectored_cred (rs)) + nfs_rpcsvc_update_vectored_cred (rs); + else if (nfs_rpcsvc_record_vectored_verfsz (rs)) + nfs_rpcsvc_update_vectored_verfsz (conn); + else if (nfs_rpcsvc_record_vectored_verfread (rs)) { + nfs_rpcsvc_update_vectored_verf (rs); gf_log (GF_RPCSVC, GF_LOG_TRACE, "Vectored RPC preparing call"); - rpcsvc_handle_vectored_prep_rpc_call (conn); - } else if (rpcsvc_record_vectored_readprochdr (rs)) - rpcsvc_handle_vectored_rpc_call (conn); - else if (rpcsvc_record_vectored_ignore (rs)) { - svc = rpcsvc_conn_rpcsvc (conn); - rpcsvc_record_init (rs, svc->ctx->iobuf_pool); - } else if (rpcsvc_record_vectored_readvec (rs)) { - svc = rpcsvc_conn_rpcsvc (conn); + nfs_rpcsvc_handle_vectored_prep_rpc_call (conn); + } else if (nfs_rpcsvc_record_vectored_readprochdr (rs)) + nfs_rpcsvc_handle_vectored_rpc_call (conn); + else if (nfs_rpcsvc_record_vectored_ignore (rs)) { + svc = nfs_rpcsvc_conn_rpcsvc (conn); + nfs_rpcsvc_record_init (rs, svc->ctx->iobuf_pool); + } else if (nfs_rpcsvc_record_vectored_readvec (rs)) { + svc = nfs_rpcsvc_conn_rpcsvc (conn); gf_log (GF_RPCSVC, GF_LOG_TRACE, "Vectored RPC vector read"); - rpcsvc_record_vectored_call_actor (conn); - rpcsvc_record_init (rs, svc->ctx->iobuf_pool); + nfs_rpcsvc_record_vectored_call_actor (conn); + nfs_rpcsvc_record_init (rs, svc->ctx->iobuf_pool); } return 0; @@ -2242,10 +2262,11 @@ rpcsvc_update_vectored_state (rpcsvc_conn_t *conn) ssize_t -rpcsvc_record_read_partial_frag (rpcsvc_record_state_t *rs, ssize_t dataread); +nfs_rpcsvc_record_read_partial_frag (rpcsvc_record_state_t *rs, + ssize_t dataread); ssize_t -rpcsvc_update_vectored_msg (rpcsvc_conn_t *conn, ssize_t dataread) +nfs_rpcsvc_update_vectored_msg (rpcsvc_conn_t *conn, ssize_t dataread) { if (!conn) @@ -2262,7 +2283,7 @@ rpcsvc_update_vectored_msg (rpcsvc_conn_t *conn, ssize_t dataread) * rstate to be RPCSVC_BARERPC_MSGSZ for the purpose of a vectored * fragment. */ - return rpcsvc_record_read_partial_frag (&conn->rstate, dataread); + return nfs_rpcsvc_record_read_partial_frag (&conn->rstate, dataread); } /* FIX: As a first version of vectored reading, I am assuming dataread will @@ -2271,7 +2292,7 @@ rpcsvc_update_vectored_msg (rpcsvc_conn_t *conn, ssize_t dataread) * poll_in. */ ssize_t -rpcsvc_handle_vectored_frag (rpcsvc_conn_t *conn, ssize_t dataread) +nfs_rpcsvc_handle_vectored_frag (rpcsvc_conn_t *conn, ssize_t dataread) { if (!conn) return dataread; @@ -2287,11 +2308,11 @@ rpcsvc_handle_vectored_frag (rpcsvc_conn_t *conn, ssize_t dataread) * to, as a first step, identify which (program, actor) we need to call. */ - dataread = rpcsvc_update_vectored_msg (conn, dataread); + dataread = nfs_rpcsvc_update_vectored_msg (conn, dataread); if (conn->rstate.remainingfrag == 0) { gf_log (GF_RPCSVC, GF_LOG_TRACE, "Vectored frag complete"); - dataread = rpcsvc_update_vectored_state (conn); + dataread = nfs_rpcsvc_update_vectored_state (conn); } return dataread; @@ -2299,7 +2320,7 @@ rpcsvc_handle_vectored_frag (rpcsvc_conn_t *conn, ssize_t dataread) int -rpcsvc_record_update_state (rpcsvc_conn_t *conn, ssize_t dataread) +nfs_rpcsvc_record_update_state (rpcsvc_conn_t *conn, ssize_t dataread) { rpcsvc_record_state_t *rs = NULL; rpcsvc_t *svc = NULL; @@ -2312,10 +2333,10 @@ rpcsvc_record_update_state (rpcsvc_conn_t *conn, ssize_t dataread) * start of the area into which dataread number of bytes were read. */ - if (rpcsvc_record_readfraghdr(rs)) - dataread = rpcsvc_record_update_fraghdr (rs, dataread); + if (nfs_rpcsvc_record_readfraghdr(rs)) + dataread = nfs_rpcsvc_record_update_fraghdr (rs, dataread); - if (rpcsvc_record_readfrag(rs)) { + if (nfs_rpcsvc_record_readfrag(rs)) { /* The minimum needed for triggering the vectored handler is * the frag size field. The fragsize member remains set to this * size till this request is completely extracted from the @@ -2326,12 +2347,13 @@ rpcsvc_record_update_state (rpcsvc_conn_t *conn, ssize_t dataread) * condition as the flag to tell us that this is a vectored * fragment. */ - if ((dataread > 0) && (rpcsvc_record_vectored (rs))) { + if ((dataread > 0) && (nfs_rpcsvc_record_vectored (rs))) { gf_log (GF_RPCSVC, GF_LOG_TRACE, "Vectored frag"); - dataread = rpcsvc_handle_vectored_frag (conn, dataread); + dataread = nfs_rpcsvc_handle_vectored_frag (conn, + dataread); } else if (dataread > 0) { gf_log (GF_RPCSVC, GF_LOG_TRACE, "Regular frag"); - dataread = rpcsvc_record_update_frag (rs, dataread); + dataread = nfs_rpcsvc_record_update_frag (rs, dataread); } } @@ -2351,11 +2373,11 @@ rpcsvc_record_update_state (rpcsvc_conn_t *conn, ssize_t dataread) * XDR formatted buffer in activeiob followed by the upcall to the * protocol actor. */ - if ((rpcsvc_record_readfraghdr(rs)) && (rs->islastfrag)) { + if ((nfs_rpcsvc_record_readfraghdr(rs)) && (rs->islastfrag)) { gf_log (GF_RPCSVC, GF_LOG_TRACE, "Full Record Received."); - rpcsvc_handle_rpc_call (conn); - svc = rpcsvc_conn_rpcsvc (conn); - rpcsvc_record_init (rs, svc->ctx->iobuf_pool); + nfs_rpcsvc_handle_rpc_call (conn); + svc = nfs_rpcsvc_conn_rpcsvc (conn); + nfs_rpcsvc_record_init (rs, svc->ctx->iobuf_pool); } return 0; @@ -2363,40 +2385,40 @@ rpcsvc_record_update_state (rpcsvc_conn_t *conn, ssize_t dataread) char * -rpcsvc_record_read_addr (rpcsvc_record_state_t *rs) +nfs_rpcsvc_record_read_addr (rpcsvc_record_state_t *rs) { - if (rpcsvc_record_readfraghdr (rs)) - return rpcsvc_record_currenthdr_addr (rs); - else if (rpcsvc_record_readfrag (rs)) - return rpcsvc_record_currentfrag_addr (rs); + if (nfs_rpcsvc_record_readfraghdr (rs)) + return nfs_rpcsvc_record_currenthdr_addr (rs); + else if (nfs_rpcsvc_record_readfrag (rs)) + return nfs_rpcsvc_record_currentfrag_addr (rs); return NULL; } int -rpcsvc_conn_data_poll_in (rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_data_poll_in (rpcsvc_conn_t *conn) { ssize_t dataread = -1; size_t readsize = 0; char *readaddr = NULL; int ret = -1; - readaddr = rpcsvc_record_read_addr (&conn->rstate); + readaddr = nfs_rpcsvc_record_read_addr (&conn->rstate); if (!readaddr) goto err; - readsize = rpcsvc_record_read_size (&conn->rstate); + readsize = nfs_rpcsvc_record_read_size (&conn->rstate); if (readsize == -1) goto err; - dataread = rpcsvc_socket_read (conn->sockfd, readaddr, readsize); - gf_log (GF_RPCSVC, GF_LOG_TRACE, "conn: 0x%lx, readsize: %zu, dataread: %zd", - (long)conn, readsize, dataread); + dataread = nfs_rpcsvc_socket_read (conn->sockfd, readaddr, readsize); + gf_log (GF_RPCSVC, GF_LOG_TRACE, "conn: 0x%lx, readsize: %zu, dataread:" + "%zd", (long)conn, readsize, dataread); if (dataread > 0) - ret = rpcsvc_record_update_state (conn, dataread); + ret = nfs_rpcsvc_record_update_state (conn, dataread); err: return ret; @@ -2404,16 +2426,16 @@ err: int -rpcsvc_conn_data_poll_err (rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_data_poll_err (rpcsvc_conn_t *conn) { gf_log (GF_RPCSVC, GF_LOG_TRACE, "Received error event"); - rpcsvc_conn_deinit (conn); + nfs_rpcsvc_conn_deinit (conn); return 0; } int -__rpcsvc_conn_data_poll_out (rpcsvc_conn_t *conn) +__nfs_rpcsvc_conn_data_poll_out (rpcsvc_conn_t *conn) { rpcsvc_txbuf_t *txbuf = NULL; rpcsvc_txbuf_t *tmp = NULL; @@ -2432,14 +2454,14 @@ tx_remaining: if (txbuf->txbehave & RPCSVC_TXB_FIRST) { gf_log (GF_RPCSVC, GF_LOG_TRACE, "First Tx Buf"); - rpcsvc_socket_block_tx (conn->sockfd); + nfs_rpcsvc_socket_block_tx (conn->sockfd); } - written = rpcsvc_socket_write (conn->sockfd, writeaddr, - writesize); + written = nfs_rpcsvc_socket_write (conn->sockfd, writeaddr, + writesize); if (txbuf->txbehave & RPCSVC_TXB_LAST) { gf_log (GF_RPCSVC, GF_LOG_TRACE, "Last Tx Buf"); - rpcsvc_socket_unblock_tx (conn->sockfd); + nfs_rpcsvc_socket_unblock_tx (conn->sockfd); } gf_log (GF_RPCSVC, GF_LOG_TRACE, "conn: 0x%lx, Tx request: %zu," " Tx sent: %zd", (long)conn, writesize, written); @@ -2476,7 +2498,7 @@ tx_remaining: /* If we've broken out of the loop above then we must unblock * the transmission now. */ - rpcsvc_socket_unblock_tx (conn->sockfd); + nfs_rpcsvc_socket_unblock_tx (conn->sockfd); if (list_empty (&conn->txbufs)) conn->eventidx = event_select_on (conn->stage->eventpool, conn->sockfd, conn->eventidx, @@ -2487,7 +2509,7 @@ tx_remaining: int -rpcsvc_conn_data_poll_out (rpcsvc_conn_t *conn) +nfs_rpcsvc_conn_data_poll_out (rpcsvc_conn_t *conn) { if (!conn) return -1; @@ -2495,7 +2517,7 @@ rpcsvc_conn_data_poll_out (rpcsvc_conn_t *conn) pthread_mutex_lock (&conn->connlock); { - __rpcsvc_conn_data_poll_out (conn); + __nfs_rpcsvc_conn_data_poll_out (conn); } pthread_mutex_unlock (&conn->connlock); @@ -2504,8 +2526,8 @@ rpcsvc_conn_data_poll_out (rpcsvc_conn_t *conn) int -rpcsvc_conn_data_handler (int fd, int idx, void *data, int poll_in, int poll_out - , int poll_err) +nfs_rpcsvc_conn_data_handler (int fd, int idx, void *data, int poll_in, + int poll_out, int poll_err) { rpcsvc_conn_t *conn = NULL; int ret = 0; @@ -2516,28 +2538,28 @@ rpcsvc_conn_data_handler (int fd, int idx, void *data, int poll_in, int poll_out conn = (rpcsvc_conn_t *)data; if (poll_out) - ret = rpcsvc_conn_data_poll_out (conn); + ret = nfs_rpcsvc_conn_data_poll_out (conn); if (poll_err) { - ret = rpcsvc_conn_data_poll_err (conn); + ret = nfs_rpcsvc_conn_data_poll_err (conn); return 0; } if (poll_in) { ret = 0; - ret = rpcsvc_conn_data_poll_in (conn); + ret = nfs_rpcsvc_conn_data_poll_in (conn); } if (ret == -1) - rpcsvc_conn_data_poll_err (conn); + nfs_rpcsvc_conn_data_poll_err (conn); return 0; } int -rpcsvc_conn_listening_handler (int fd, int idx, void *data, int poll_in, - int poll_out, int poll_err) +nfs_rpcsvc_conn_listening_handler (int fd, int idx, void *data, int poll_in, + int poll_out, int poll_err) { rpcsvc_conn_t *newconn = NULL; rpcsvc_stage_t *selectedstage = NULL; @@ -2551,22 +2573,23 @@ rpcsvc_conn_listening_handler (int fd, int idx, void *data, int poll_in, conn = (rpcsvc_conn_t *)data; prog = (rpcsvc_program_t *)conn->program; - svc = rpcsvc_conn_rpcsvc (conn); - newconn = rpcsvc_conn_accept_init (svc, fd, prog); + svc = nfs_rpcsvc_conn_rpcsvc (conn); + newconn = nfs_rpcsvc_conn_accept_init (svc, fd, prog); if (!newconn) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "failed to accept connection"); goto err; } - selectedstage = rpcsvc_select_stage (svc); + selectedstage = nfs_rpcsvc_select_stage (svc); if (!selectedstage) goto close_err; /* Now that we've accepted the connection, we need to associate * its events to a stage. */ - ret = rpcsvc_stage_conn_associate (selectedstage, newconn, - rpcsvc_conn_data_handler, newconn); + ret = nfs_rpcsvc_stage_conn_associate (selectedstage, newconn, + nfs_rpcsvc_conn_data_handler, + newconn); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "could not associated stage " " with new connection"); @@ -2578,7 +2601,7 @@ rpcsvc_conn_listening_handler (int fd, int idx, void *data, int poll_in, ret = 0; close_err: if (ret == -1) - rpcsvc_conn_unref (newconn); + nfs_rpcsvc_conn_unref (newconn); err: return ret; @@ -2587,7 +2610,7 @@ err: /* Register the program with the local portmapper service. */ int -rpcsvc_program_register_portmap (rpcsvc_program_t *newprog) +nfs_rpcsvc_program_register_portmap (rpcsvc_program_t *newprog) { if (!newprog) return -1; @@ -2604,7 +2627,7 @@ rpcsvc_program_register_portmap (rpcsvc_program_t *newprog) int -rpcsvc_program_unregister_portmap (rpcsvc_program_t *prog) +nfs_rpcsvc_program_unregister_portmap (rpcsvc_program_t *prog) { if (!prog) return -1; @@ -2620,7 +2643,8 @@ rpcsvc_program_unregister_portmap (rpcsvc_program_t *prog) int -rpcsvc_stage_program_register (rpcsvc_stage_t *stg, rpcsvc_program_t *newprog) +nfs_rpcsvc_stage_program_register (rpcsvc_stage_t *stg, + rpcsvc_program_t *newprog) { rpcsvc_conn_t *newconn = NULL; rpcsvc_t *svc = NULL; @@ -2628,18 +2652,18 @@ rpcsvc_stage_program_register (rpcsvc_stage_t *stg, rpcsvc_program_t *newprog) if ((!stg) || (!newprog)) return -1; - svc = rpcsvc_stage_service (stg); + svc = nfs_rpcsvc_stage_service (stg); /* Create a listening socket */ - newconn = rpcsvc_conn_listen_init (svc, newprog); + newconn = nfs_rpcsvc_conn_listen_init (svc, newprog); if (!newconn) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "could not create listening" " connection"); return -1; } - if ((rpcsvc_stage_conn_associate (stg, newconn, - rpcsvc_conn_listening_handler, - newconn)) == -1) { + if ((nfs_rpcsvc_stage_conn_associate (stg, newconn, + nfs_rpcsvc_conn_listening_handler, + newconn)) == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR,"could not associate stage with" " listening connection"); return -1; @@ -2650,7 +2674,7 @@ rpcsvc_stage_program_register (rpcsvc_stage_t *stg, rpcsvc_program_t *newprog) int -rpcsvc_program_register (rpcsvc_t *svc, rpcsvc_program_t program) +nfs_rpcsvc_program_register (rpcsvc_t *svc, rpcsvc_program_t program) { rpcsvc_program_t *newprog = NULL; rpcsvc_stage_t *selectedstage = NULL; @@ -2659,7 +2683,7 @@ rpcsvc_program_register (rpcsvc_t *svc, rpcsvc_program_t program) if (!svc) return -1; - newprog = GF_CALLOC (1, sizeof(*newprog), gf_common_mt_rpcsvc_program_t); + newprog = GF_CALLOC (1, sizeof(*newprog),gf_common_mt_rpcsvc_program_t); if (!newprog) return -1; @@ -2667,16 +2691,16 @@ rpcsvc_program_register (rpcsvc_t *svc, rpcsvc_program_t program) goto free_prog; memcpy (newprog, &program, sizeof (program)); - selectedstage = rpcsvc_select_stage (svc); + selectedstage = nfs_rpcsvc_select_stage (svc); - ret = rpcsvc_stage_program_register (selectedstage, newprog); + ret = nfs_rpcsvc_stage_program_register (selectedstage, newprog); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "stage registration of program" " failed"); goto free_prog; } - ret = rpcsvc_program_register_portmap (newprog); + ret = nfs_rpcsvc_program_register_portmap (newprog); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "portmap registration of" " program failed"); @@ -2706,18 +2730,18 @@ free_prog: * we must perform NULL checks before calling the generic submit. */ int -rpcsvc_submit_message (rpcsvc_request_t *req, struct iovec msgvec, - struct iobuf *msg) +nfs_rpcsvc_submit_message (rpcsvc_request_t *req, struct iovec msgvec, + struct iobuf *msg) { if ((!req) || (!req->conn) || (!msg) || (!msgvec.iov_base)) return -1; - return rpcsvc_submit_generic (req, msgvec, msg); + return nfs_rpcsvc_submit_generic (req, msgvec, msg); } int -rpcsvc_program_unregister (rpcsvc_t *svc, rpcsvc_program_t prog) +nfs_rpcsvc_program_unregister (rpcsvc_t *svc, rpcsvc_program_t prog) { int ret = -1; @@ -2725,7 +2749,7 @@ rpcsvc_program_unregister (rpcsvc_t *svc, rpcsvc_program_t prog) return -1; /* TODO: De-init the listening connection for this program. */ - ret = rpcsvc_program_unregister_portmap (&prog); + ret = nfs_rpcsvc_program_unregister_portmap (&prog); if (ret == -1) { gf_log (GF_RPCSVC, GF_LOG_ERROR, "portmap unregistration of" " program failed"); @@ -2748,23 +2772,23 @@ err: int -rpcsvc_conn_peername (rpcsvc_conn_t *conn, char *hostname, int hostlen) +nfs_rpcsvc_conn_peername (rpcsvc_conn_t *conn, char *hostname, int hostlen) { if (!conn) return -1; - return rpcsvc_socket_peername (conn->sockfd, hostname, hostlen); + return nfs_rpcsvc_socket_peername (conn->sockfd, hostname, hostlen); } int -rpcsvc_conn_peeraddr (rpcsvc_conn_t *conn, char *addrstr, int addrlen, - struct sockaddr *sa, socklen_t sasize) +nfs_rpcsvc_conn_peeraddr (rpcsvc_conn_t *conn, char *addrstr, int addrlen, + struct sockaddr *sa, socklen_t sasize) { if (!conn) return -1; - return rpcsvc_socket_peeraddr (conn->sockfd, addrstr, addrlen, sa, - sasize); + return nfs_rpcsvc_socket_peeraddr (conn->sockfd, addrstr, addrlen, sa, + sasize); } diff --git a/xlators/nfs/lib/src/rpcsvc.h b/xlators/nfs/lib/src/rpcsvc.h index a77021ac4..a56b70d4e 100644 --- a/xlators/nfs/lib/src/rpcsvc.h +++ b/xlators/nfs/lib/src/rpcsvc.h @@ -17,8 +17,8 @@ <http://www.gnu.org/licenses/>. */ -#ifndef _RPCSVC_H -#define _RPCSVC_H +#ifndef _NFS_RPCSVC_H +#define _NFS_RPCSVC_H #ifndef _CONFIG_H @@ -43,7 +43,7 @@ #define NGRPS RPCAUTH_UNIXGIDS #endif -#define GF_RPCSVC "rpc-service" +#define GF_RPCSVC "nfsrpc" #define RPCSVC_THREAD_STACK_SIZE ((size_t)(1024 * GF_UNIT_KB)) #define RPCSVC_DEFAULT_MEMFACTOR 15 @@ -87,14 +87,14 @@ #define RPCSVC_VECTOR_READVEC 1007 #define RPCSVC_VECTOR_READPROCHDR 1008 -#define rpcsvc_record_vectored_baremsg(rs) (((rs)->state == RPCSVC_READ_FRAG) && (rs)->vecstate == 0) -#define rpcsvc_record_vectored_cred(rs) ((rs)->vecstate == RPCSVC_VECTOR_READCRED) -#define rpcsvc_record_vectored_verfsz(rs) ((rs)->vecstate == RPCSVC_VECTOR_READVERFSZ) -#define rpcsvc_record_vectored_verfread(rs) ((rs)->vecstate == RPCSVC_VECTOR_READVERF) -#define rpcsvc_record_vectored_ignore(rs) ((rs)->vecstate == RPCSVC_VECTOR_IGNORE) -#define rpcsvc_record_vectored_readvec(rs) ((rs)->vecstate == RPCSVC_VECTOR_READVEC) -#define rpcsvc_record_vectored_readprochdr(rs) ((rs)->vecstate == RPCSVC_VECTOR_READPROCHDR) -#define rpcsvc_record_vectored(rs) ((rs)->fragsize > RPCSVC_VECTORED_FRAGSZ) +#define nfs_rpcsvc_record_vectored_baremsg(rs) (((rs)->state == RPCSVC_READ_FRAG) && (rs)->vecstate == 0) +#define nfs_rpcsvc_record_vectored_cred(rs) ((rs)->vecstate == RPCSVC_VECTOR_READCRED) +#define nfs_rpcsvc_record_vectored_verfsz(rs) ((rs)->vecstate == RPCSVC_VECTOR_READVERFSZ) +#define nfs_rpcsvc_record_vectored_verfread(rs) ((rs)->vecstate == RPCSVC_VECTOR_READVERF) +#define nfs_rpcsvc_record_vectored_ignore(rs) ((rs)->vecstate == RPCSVC_VECTOR_IGNORE) +#define nfs_rpcsvc_record_vectored_readvec(rs) ((rs)->vecstate == RPCSVC_VECTOR_READVEC) +#define nfs_rpcsvc_record_vectored_readprochdr(rs) ((rs)->vecstate == RPCSVC_VECTOR_READPROCHDR) +#define nfs_rpcsvc_record_vectored(rs) ((rs)->fragsize > RPCSVC_VECTORED_FRAGSZ) /* Includes bytes up to and including the credential length field. The credlen * will be followed by @credlen bytes of credential data which will have to be * read separately by the vectored reader. After the credentials comes the @@ -102,10 +102,10 @@ * verf flavour and verflen. */ #define RPCSVC_BARERPC_MSGSZ 32 -#define rpcsvc_record_readfraghdr(rs) ((rs)->state == RPCSVC_READ_FRAGHDR) -#define rpcsvc_record_readfrag(rs) ((rs)->state == RPCSVC_READ_FRAG) +#define nfs_rpcsvc_record_readfraghdr(rs) ((rs)->state == RPCSVC_READ_FRAGHDR) +#define nfs_rpcsvc_record_readfrag(rs) ((rs)->state == RPCSVC_READ_FRAG) -#define rpcsvc_conn_rpcsvc(conn) ((conn)->stage->svc) +#define nfs_rpcsvc_conn_rpcsvc(conn) ((conn)->stage->svc) #define RPCSVC_LOWVERS 2 #define RPCSVC_HIGHVERS 2 @@ -197,7 +197,7 @@ typedef struct rpcsvc_record_state { #define RPCSVC_CONNSTATE_CONNECTED 1 #define RPCSVC_CONNSTATE_DISCONNECTED 2 -#define rpcsvc_conn_check_active(conn) ((conn)->connstate==RPCSVC_CONNSTATE_CONNECTED) +#define nfs_rpcsvc_conn_check_active(conn) ((conn)->connstate==RPCSVC_CONNSTATE_CONNECTED) typedef struct rpcsvc_request rpcsvc_request_t; /* Contains the state for each connection that is used for transmitting and @@ -275,7 +275,7 @@ typedef struct rpcsvc_auth_data { char authdata[RPCSVC_MAX_AUTH_BYTES]; } rpcsvc_auth_data_t; -#define rpcsvc_auth_flavour(au) ((au).flavour) +#define nfs_rpcsvc_auth_flavour(au) ((au).flavour) /* The container for the RPC call handed up to an actor. * Dynamically allocated. Lives till the call reply is completely @@ -366,28 +366,28 @@ struct rpcsvc_request { }; -#define rpcsvc_request_program(req) ((rpcsvc_program_t *)((req)->conn->program)) -#define rpcsvc_request_program_private(req) (((rpcsvc_program_t *)((req)->conn->program))->private) -#define rpcsvc_request_conn(req) (req)->conn -#define rpcsvc_request_accepted(req) ((req)->rpc_stat == MSG_ACCEPTED) -#define rpcsvc_request_accepted_success(req) ((req)->rpc_err == SUCCESS) -#define rpcsvc_request_uid(req) ((req)->uid) -#define rpcsvc_request_gid(req) ((req)->gid) -#define rpcsvc_stage_service(stg) ((rpcsvc_t *)((stg)->svc)) -#define rpcsvc_conn_stage(conn) ((conn)->stage) -#define rpcsvc_request_service(req) (rpcsvc_stage_service(rpcsvc_conn_stage(rpcsvc_request_conn(req)))) -#define rpcsvc_request_prog_minauth(req) (rpcsvc_request_program(req)->min_auth) -#define rpcsvc_request_cred_flavour(req) (rpcsvc_auth_flavour(req->cred)) -#define rpcsvc_request_verf_flavour(req) (rpcsvc_auth_flavour(req->verf)) - -#define rpcsvc_request_uid(req) ((req)->uid) -#define rpcsvc_request_gid(req) ((req)->gid) -#define rpcsvc_request_private(req) ((req)->private) -#define rpcsvc_request_xid(req) ((req)->xid) -#define rpcsvc_request_set_private(req,prv) (req)->private = (void *)(prv) -#define rpcsvc_request_record_iob(rq) ((rq)->recordiob) -#define rpcsvc_request_record_ref(req) (iobuf_ref ((req)->recordiob)) -#define rpcsvc_request_record_unref(req) (iobuf_unref ((req)->recordiob)) +#define nfs_rpcsvc_request_program(req) ((rpcsvc_program_t *)((req)->conn->program)) +#define nfs_rpcsvc_request_program_private(req) (((rpcsvc_program_t *)((req)->conn->program))->private) +#define nfs_rpcsvc_request_conn(req) (req)->conn +#define nfs_rpcsvc_request_accepted(req) ((req)->rpc_stat == MSG_ACCEPTED) +#define nfs_rpcsvc_request_accepted_success(req) ((req)->rpc_err == SUCCESS) +#define nfs_rpcsvc_request_uid(req) ((req)->uid) +#define nfs_rpcsvc_request_gid(req) ((req)->gid) +#define nfs_rpcsvc_stage_service(stg) ((rpcsvc_t *)((stg)->svc)) +#define nfs_rpcsvc_conn_stage(conn) ((conn)->stage) +#define nfs_rpcsvc_request_service(req) (nfs_rpcsvc_stage_service(nfs_rpcsvc_conn_stage(nfs_rpcsvc_request_conn(req)))) +#define nfs_rpcsvc_request_prog_minauth(req) (nfs_rpcsvc_request_program(req)->min_auth) +#define nfs_rpcsvc_request_cred_flavour(req) (nfs_rpcsvc_auth_flavour(req->cred)) +#define nfs_rpcsvc_request_verf_flavour(req) (nfs_rpcsvc_auth_flavour(req->verf)) + +#define nfs_rpcsvc_request_uid(req) ((req)->uid) +#define nfs_rpcsvc_request_gid(req) ((req)->gid) +#define nfs_rpcsvc_request_private(req) ((req)->private) +#define nfs_rpcsvc_request_xid(req) ((req)->xid) +#define nfs_rpcsvc_request_set_private(req,prv) (req)->private = (void *)(prv) +#define nfs_rpcsvc_request_record_iob(rq) ((rq)->recordiob) +#define nfs_rpcsvc_request_record_ref(req) (iobuf_ref ((req)->recordiob)) +#define nfs_rpcsvc_request_record_unref(req) (iobuf_unref ((req)->recordiob)) #define RPCSVC_ACTOR_SUCCESS 0 @@ -533,34 +533,34 @@ typedef struct rpc_svc_state { * procedure handlers. */ extern int -rpcsvc_program_register (rpcsvc_t *svc, rpcsvc_program_t program); +nfs_rpcsvc_program_register (rpcsvc_t *svc, rpcsvc_program_t program); extern int -rpcsvc_program_unregister (rpcsvc_t *svc, rpcsvc_program_t program); +nfs_rpcsvc_program_unregister (rpcsvc_t *svc, rpcsvc_program_t program); /* Inits the global RPC service data structures. * Called in main. */ extern rpcsvc_t * -rpcsvc_init (glusterfs_ctx_t *ctx, dict_t *options); +nfs_rpcsvc_init (glusterfs_ctx_t *ctx, dict_t *options); extern int -rpcsvc_submit_message (rpcsvc_request_t * req, struct iovec msg, - struct iobuf *iob); +nfs_rpcsvc_submit_message (rpcsvc_request_t * req, struct iovec msg, + struct iobuf *iob); int -rpcsvc_submit_generic (rpcsvc_request_t *req, struct iovec msgvec, - struct iobuf *msg); -#define rpcsvc_record_currentfrag_addr(rs) ((rs)->fragcurrent) -#define rpcsvc_record_currenthdr_addr(rs) ((rs)->hdrcurrent) +nfs_rpcsvc_submit_generic (rpcsvc_request_t *req, struct iovec msgvec, + struct iobuf *msg); +#define nfs_rpcsvc_record_currentfrag_addr(rs) ((rs)->fragcurrent) +#define nfs_rpcsvc_record_currenthdr_addr(rs) ((rs)->hdrcurrent) -#define rpcsvc_record_update_currentfrag(rs, size) \ +#define nfs_rpcsvc_record_update_currentfrag(rs, size) \ do { \ (rs)->fragcurrent += size; \ } while (0) \ -#define rpcsvc_record_update_currenthdr(rs, size) \ +#define nfs_rpcsvc_record_update_currenthdr(rs, size) \ do { \ (rs)->hdrcurrent += size; \ } while (0) \ @@ -616,7 +616,7 @@ typedef struct rpcsvc_txbuf { } rpcsvc_txbuf_t; extern int -rpcsvc_error_reply (rpcsvc_request_t *req); +nfs_rpcsvc_error_reply (rpcsvc_request_t *req); #define RPCSVC_PEER_STRLEN 1024 #define RPCSVC_AUTH_ACCEPT 1 @@ -624,33 +624,36 @@ rpcsvc_error_reply (rpcsvc_request_t *req); #define RPCSVC_AUTH_DONTCARE 3 extern int -rpcsvc_conn_peername (rpcsvc_conn_t *conn, char *hostname, int hostlen); +nfs_rpcsvc_conn_peername (rpcsvc_conn_t *conn, char *hostname, int hostlen); extern int -rpcsvc_conn_peeraddr (rpcsvc_conn_t *conn, char *addrstr, int addrlen, - struct sockaddr *returnsa, socklen_t sasize); +nfs_rpcsvc_conn_peeraddr (rpcsvc_conn_t *conn, char *addrstr, int addrlen, + struct sockaddr *returnsa, socklen_t sasize); extern int -rpcsvc_conn_peer_check (dict_t *options, char *volname, rpcsvc_conn_t *conn); +nfs_rpcsvc_conn_peer_check (dict_t *options, char *volname,rpcsvc_conn_t *conn); extern int -rpcsvc_conn_privport_check (rpcsvc_t *svc, char *volname, rpcsvc_conn_t *conn); -#define rpcsvc_request_seterr(req, err) (req)->rpc_err = err -#define rpcsvc_request_set_autherr(req, err) (req)->auth_err = err +nfs_rpcsvc_conn_privport_check (rpcsvc_t *svc, char *volname, + rpcsvc_conn_t *conn); +#define nfs_rpcsvc_request_seterr(req, err) (req)->rpc_err = err +#define nfs_rpcsvc_request_set_autherr(req, err) (req)->auth_err = err extern void -rpcsvc_conn_deinit (rpcsvc_conn_t *conn); -extern void rpcsvc_conn_ref (rpcsvc_conn_t *conn); -extern void rpcsvc_conn_unref (rpcsvc_conn_t *conn); +nfs_rpcsvc_conn_deinit (rpcsvc_conn_t *conn); +extern void nfs_rpcsvc_conn_ref (rpcsvc_conn_t *conn); +extern void nfs_rpcsvc_conn_unref (rpcsvc_conn_t *conn); -extern int rpcsvc_submit_vectors (rpcsvc_request_t *req); +extern int nfs_rpcsvc_submit_vectors (rpcsvc_request_t *req); -extern int rpcsvc_request_attach_vector (rpcsvc_request_t *req, - struct iovec msgvec, struct iobuf *iob, - struct iobref *ioref, int finalvector); +extern int nfs_rpcsvc_request_attach_vector (rpcsvc_request_t *req, + struct iovec msgvec, + struct iobuf *iob, + struct iobref *ioref, + int finalvector); extern int -rpcsvc_request_attach_vectors (rpcsvc_request_t *req, struct iovec *payload, - int vcount, struct iobref *piobref); +nfs_rpcsvc_request_attach_vectors (rpcsvc_request_t *req, struct iovec *payload, + int vcount, struct iobref *piobref); typedef int (*auth_init_conn) (rpcsvc_conn_t *conn, void *priv); typedef int (*auth_init_request) (rpcsvc_request_t *req, void *priv); @@ -691,19 +694,19 @@ struct rpcsvc_auth_list { }; extern int -rpcsvc_auth_request_init (rpcsvc_request_t *req); +nfs_rpcsvc_auth_request_init (rpcsvc_request_t *req); extern int -rpcsvc_auth_init (rpcsvc_t *svc, dict_t *options); +nfs_rpcsvc_auth_init (rpcsvc_t *svc, dict_t *options); extern int -rpcsvc_auth_conn_init (rpcsvc_conn_t *conn); +nfs_rpcsvc_auth_conn_init (rpcsvc_conn_t *conn); extern int -rpcsvc_authenticate (rpcsvc_request_t *req); +nfs_rpcsvc_authenticate (rpcsvc_request_t *req); extern int -rpcsvc_auth_array (rpcsvc_t *svc, char *volname, int *autharr, int arrlen); +nfs_rpcsvc_auth_array (rpcsvc_t *svc, char *volname, int *autharr, int arrlen); /* If the request has been sent using AUTH_UNIX, this function returns the * auxiliary gids as an array, otherwise, it returns NULL. @@ -711,11 +714,11 @@ rpcsvc_auth_array (rpcsvc_t *svc, char *volname, int *autharr, int arrlen); * authentication code even further to support mode auth schemes. */ extern gid_t * -rpcsvc_auth_unix_auxgids (rpcsvc_request_t *req, int *arrlen); +nfs_rpcsvc_auth_unix_auxgids (rpcsvc_request_t *req, int *arrlen); extern int -rpcsvc_combine_gen_spec_volume_checks (int gen, int spec); +nfs_rpcsvc_combine_gen_spec_volume_checks (int gen, int spec); extern char * -rpcsvc_volume_allowed (dict_t *options, char *volname); +nfs_rpcsvc_volume_allowed (dict_t *options, char *volname); #endif diff --git a/xlators/nfs/lib/src/xdr-common.h b/xlators/nfs/lib/src/xdr-common.h index 50a57ade9..0f60cd2c9 100644 --- a/xlators/nfs/lib/src/xdr-common.h +++ b/xlators/nfs/lib/src/xdr-common.h @@ -17,8 +17,8 @@ <http://www.gnu.org/licenses/>. */ -#ifndef _XDR_COMMON_H_ -#define _XDR_COMMON_H_ +#ifndef _NFS_XDR_COMMON_H_ +#define _NFS_XDR_COMMON_H_ #ifndef _CONFIG_H #define _CONFIG_H @@ -26,23 +26,23 @@ #endif #include <rpc/rpc.h> -#define XDR_BYTES_PER_UNIT 4 +#define NFS_XDR_BYTES_PER_UNIT 4 /* Returns the address of the byte that follows the * last byte used for decoding the previous xdr component. * For eg, once the RPC call for NFS has been decoded, thie macro will return * the address from which the NFS header starts. */ -#define xdr_decoded_remaining_addr(xdr) ((&xdr)->x_private) +#define nfs_xdr_decoded_remaining_addr(xdr) ((&xdr)->x_private) /* Returns the length of the remaining record after the previous decode * operation completed. */ -#define xdr_decoded_remaining_len(xdr) ((&xdr)->x_handy) +#define nfs_xdr_decoded_remaining_len(xdr) ((&xdr)->x_handy) /* Returns the number of bytes used by the last encode operation. */ -#define xdr_encoded_length(xdr) (((size_t)(&xdr)->x_private) - ((size_t)(&xdr)->x_base)) +#define nfs_xdr_encoded_length(xdr) (((size_t)(&xdr)->x_private) - ((size_t)(&xdr)->x_base)) -#define xdr_decoded_length(xdr) (((size_t)(&xdr)->x_private) - ((size_t)(&xdr)->x_base)) +#define nfs_xdr_decoded_length(xdr) (((size_t)(&xdr)->x_private) - ((size_t)(&xdr)->x_base)) #endif diff --git a/xlators/nfs/lib/src/xdr-rpc.c b/xlators/nfs/lib/src/xdr-rpc.c index 071462242..b61b4db1f 100644 --- a/xlators/nfs/lib/src/xdr-rpc.c +++ b/xlators/nfs/lib/src/xdr-rpc.c @@ -39,8 +39,8 @@ * The remaining payload is returned into payload. */ int -xdr_to_rpc_call (char *msgbuf, size_t len, struct rpc_msg *call, - struct iovec *payload, char *credbytes, char *verfbytes) +nfs_xdr_to_rpc_call (char *msgbuf, size_t len, struct rpc_msg *call, + struct iovec *payload, char *credbytes, char *verfbytes) { XDR xdr; char opaquebytes[MAX_AUTH_BYTES]; @@ -68,8 +68,8 @@ xdr_to_rpc_call (char *msgbuf, size_t len, struct rpc_msg *call, return -1; if (payload) { - payload->iov_base = xdr_decoded_remaining_addr (xdr); - payload->iov_len = xdr_decoded_remaining_len (xdr); + payload->iov_base = nfs_xdr_decoded_remaining_addr (xdr); + payload->iov_len = nfs_xdr_decoded_remaining_len (xdr); } return 0; @@ -77,14 +77,14 @@ xdr_to_rpc_call (char *msgbuf, size_t len, struct rpc_msg *call, bool_t -true_func (XDR *s, caddr_t *a) +nfs_true_func (XDR *s, caddr_t *a) { return TRUE; } int -rpc_fill_empty_reply (struct rpc_msg *reply, uint32_t xid) +nfs_rpc_fill_empty_reply (struct rpc_msg *reply, uint32_t xid) { if (!reply) return -1; @@ -100,7 +100,7 @@ rpc_fill_empty_reply (struct rpc_msg *reply, uint32_t xid) } int -rpc_fill_denied_reply (struct rpc_msg *reply, int rjstat, int auth_err) +nfs_rpc_fill_denied_reply (struct rpc_msg *reply, int rjstat, int auth_err) { if (!reply) return -1; @@ -122,8 +122,8 @@ rpc_fill_denied_reply (struct rpc_msg *reply, int rjstat, int auth_err) int -rpc_fill_accepted_reply (struct rpc_msg *reply, int arstat, int proglow, - int proghigh, int verf, int len, char *vdata) +nfs_rpc_fill_accepted_reply (struct rpc_msg *reply, int arstat, int proglow, + int proghigh, int verf, int len, char *vdata) { if (!reply) return -1; @@ -142,7 +142,7 @@ rpc_fill_accepted_reply (struct rpc_msg *reply, int arstat, int proglow, /* This is a hack. I'd really like to build a custom * XDR library because Sun RPC interface is not very flexible. */ - reply->acpted_rply.ar_results.proc = (xdrproc_t)true_func; + reply->acpted_rply.ar_results.proc = (xdrproc_t)nfs_true_func; reply->acpted_rply.ar_results.where = NULL; } @@ -150,8 +150,8 @@ rpc_fill_accepted_reply (struct rpc_msg *reply, int arstat, int proglow, } int -rpc_reply_to_xdr (struct rpc_msg *reply, char *dest, size_t len, - struct iovec *dst) +nfs_rpc_reply_to_xdr (struct rpc_msg *reply, char *dest, size_t len, + struct iovec *dst) { XDR xdr; @@ -163,15 +163,15 @@ rpc_reply_to_xdr (struct rpc_msg *reply, char *dest, size_t len, return -1; dst->iov_base = dest; - dst->iov_len = xdr_encoded_length (xdr); + dst->iov_len = nfs_xdr_encoded_length (xdr); return 0; } int -xdr_to_auth_unix_cred (char *msgbuf, int msglen, struct authunix_parms *au, - char *machname, gid_t *gids) +nfs_xdr_to_auth_unix_cred (char *msgbuf, int msglen, struct authunix_parms *au, + char *machname, gid_t *gids) { XDR xdr; @@ -194,13 +194,13 @@ xdr_to_auth_unix_cred (char *msgbuf, int msglen, struct authunix_parms *au, } ssize_t -xdr_length_round_up (size_t len, size_t bufsize) +nfs_xdr_length_round_up (size_t len, size_t bufsize) { int roundup = 0; - roundup = len % XDR_BYTES_PER_UNIT; + roundup = len % NFS_XDR_BYTES_PER_UNIT; if (roundup > 0) - roundup = XDR_BYTES_PER_UNIT - roundup; + roundup = NFS_XDR_BYTES_PER_UNIT - roundup; if ((roundup > 0) && ((roundup + len) <= bufsize)) len += roundup; @@ -209,18 +209,18 @@ xdr_length_round_up (size_t len, size_t bufsize) } int -xdr_bytes_round_up (struct iovec *vec, size_t bufsize) +nfs_xdr_bytes_round_up (struct iovec *vec, size_t bufsize) { - vec->iov_len = xdr_length_round_up (vec->iov_len, bufsize); + vec->iov_len = nfs_xdr_length_round_up (vec->iov_len, bufsize); return 0; } void -xdr_vector_round_up (struct iovec *vec, int vcount, uint32_t count) +nfs_xdr_vector_round_up (struct iovec *vec, int vcount, uint32_t count) { uint32_t round_count = 0; - round_count = xdr_length_round_up (count, 1048576); + round_count = nfs_xdr_length_round_up (count, 1048576); round_count -= count; if (round_count == 0) return; diff --git a/xlators/nfs/lib/src/xdr-rpc.h b/xlators/nfs/lib/src/xdr-rpc.h index 48acdaa43..f8dbd33b7 100644 --- a/xlators/nfs/lib/src/xdr-rpc.h +++ b/xlators/nfs/lib/src/xdr-rpc.h @@ -17,8 +17,8 @@ <http://www.gnu.org/licenses/>. */ -#ifndef _XDR_RPC_H -#define _XDR_RPC_H_ +#ifndef _NFS_XDR_RPC_H +#define _NFS_XDR_RPC_H_ #ifndef _CONFIG_H #define _CONFIG_H @@ -35,48 +35,48 @@ * that contains everything an RPC call needs to work. */ extern int -xdr_to_rpc_call (char *msgbuf, size_t len, struct rpc_msg *call, - struct iovec *payload, char *credbytes, char *verfbytes); +nfs_xdr_to_rpc_call (char *msgbuf, size_t len, struct rpc_msg *call, + struct iovec *payload, char *credbytes, char *verfbytes); extern int -rpc_fill_empty_reply (struct rpc_msg *reply, uint32_t xid); +nfs_rpc_fill_empty_reply (struct rpc_msg *reply, uint32_t xid); extern int -rpc_fill_denied_reply (struct rpc_msg *reply, int rjstat, int auth_err); +nfs_rpc_fill_denied_reply (struct rpc_msg *reply, int rjstat, int auth_err); extern int -rpc_fill_accepted_reply (struct rpc_msg *reply, int arstat, int proglow, - int proghigh, int verf, int len, char *vdata); +nfs_rpc_fill_accepted_reply (struct rpc_msg *reply, int arstat, int proglow, + int proghigh, int verf, int len, char *vdata); extern int -rpc_reply_to_xdr (struct rpc_msg *reply, char *dest, size_t len, - struct iovec *dst); +nfs_rpc_reply_to_xdr (struct rpc_msg *reply, char *dest, size_t len, + struct iovec *dst); extern int -xdr_to_auth_unix_cred (char *msgbuf, int msglen, struct authunix_parms *au, - char *machname, gid_t *gids); +nfs_xdr_to_auth_unix_cred (char *msgbuf, int msglen, struct authunix_parms *au, + char *machname, gid_t *gids); /* Macros that simplify accesing the members of an RPC call structure. */ -#define rpc_call_xid(call) ((call)->rm_xid) -#define rpc_call_direction(call) ((call)->rm_direction) -#define rpc_call_rpcvers(call) ((call)->ru.RM_cmb.cb_rpcvers) -#define rpc_call_program(call) ((call)->ru.RM_cmb.cb_prog) -#define rpc_call_progver(call) ((call)->ru.RM_cmb.cb_vers) -#define rpc_call_progproc(call) ((call)->ru.RM_cmb.cb_proc) -#define rpc_opaque_auth_flavour(oa) ((oa)->oa_flavor) -#define rpc_opaque_auth_len(oa) ((oa)->oa_length) +#define nfs_rpc_call_xid(call) ((call)->rm_xid) +#define nfs_rpc_call_direction(call) ((call)->rm_direction) +#define nfs_rpc_call_rpcvers(call) ((call)->ru.RM_cmb.cb_rpcvers) +#define nfs_rpc_call_program(call) ((call)->ru.RM_cmb.cb_prog) +#define nfs_rpc_call_progver(call) ((call)->ru.RM_cmb.cb_vers) +#define nfs_rpc_call_progproc(call) ((call)->ru.RM_cmb.cb_proc) +#define nfs_rpc_opaque_auth_flavour(oa) ((oa)->oa_flavor) +#define nfs_rpc_opaque_auth_len(oa) ((oa)->oa_length) -#define rpc_call_cred_flavour(call) (rpc_opaque_auth_flavour ((&(call)->ru.RM_cmb.cb_cred))) -#define rpc_call_cred_len(call) (rpc_opaque_auth_len ((&(call)->ru.RM_cmb.cb_cred))) +#define nfs_rpc_call_cred_flavour(call) (nfs_rpc_opaque_auth_flavour ((&(call)->ru.RM_cmb.cb_cred))) +#define nfs_rpc_call_cred_len(call) (nfs_rpc_opaque_auth_len ((&(call)->ru.RM_cmb.cb_cred))) -#define rpc_call_verf_flavour(call) (rpc_opaque_auth_flavour ((&(call)->ru.RM_cmb.cb_verf))) -#define rpc_call_verf_len(call) (rpc_opaque_auth_len ((&(call)->ru.RM_cmb.cb_verf))) +#define nfs_rpc_call_verf_flavour(call) (nfs_rpc_opaque_auth_flavour ((&(call)->ru.RM_cmb.cb_verf))) +#define nfs_rpc_call_verf_len(call) (nfs_rpc_opaque_auth_len ((&(call)->ru.RM_cmb.cb_verf))) extern int -xdr_bytes_round_up (struct iovec *vec, size_t bufsize); +nfs_xdr_bytes_round_up (struct iovec *vec, size_t bufsize); extern ssize_t -xdr_length_round_up (size_t len, size_t bufsize); +nfs_xdr_length_round_up (size_t len, size_t bufsize); void -xdr_vector_round_up (struct iovec *vec, int vcount, uint32_t count); +nfs_xdr_vector_round_up (struct iovec *vec, int vcount, uint32_t count); #endif |