1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
|
/*
* nfsrpc.h -- RPC client APIs provided by support/nfs
*
* Copyright (C) 2008 Oracle Corporation. All rights reserved.
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* General Public License for more details.
*
* You should have received a copy of the GNU General Public
* License along with this program; if not, write to the
* Free Software Foundation, Inc.,
* 51 Franklin Street, Fifth Floor, Boston, MA 0211-1301 USA
*
*/
#ifndef __NFS_UTILS_NFSRPC_H
#define __NFS_UTILS_NFSRPC_H
#include <rpc/types.h>
#include <rpc/clnt.h>
/*
* IANA does not define an IP protocol number for RDMA transports.
* Choose an arbitrary value we can use locally.
*/
#define NFSPROTO_RDMA (3939)
/*
* Conventional RPC program numbers
*/
#ifndef RPCBPROG
#define RPCBPROG ((rpcprog_t)100000)
#endif
#ifndef PMAPPROG
#define PMAPPROG ((rpcprog_t)100000)
#endif
#ifndef NFSPROG
#define NFSPROG ((rpcprog_t)100003)
#endif
#ifndef MOUNTPROG
#define MOUNTPROG ((rpcprog_t)100005)
#endif
#ifndef NLMPROG
#define NLMPROG ((rpcprog_t)100021)
#endif
#ifndef NSMPROG
#define NSMPROG ((rpcprog_t)100024)
#endif
/**
* nfs_clear_rpc_createerr - zap all error reporting fields
*
*/
static inline void nfs_clear_rpc_createerr(void)
{
memset(&rpc_createerr, 0, sizeof(rpc_createerr));
}
/*
* Look up an RPC program name in /etc/rpc
*/
extern rpcprog_t nfs_getrpcbyname(const rpcprog_t, const char *table[]);
/*
* Acquire an RPC CLIENT * with an ephemeral source port
*/
extern CLIENT *nfs_get_rpcclient(const struct sockaddr *,
const socklen_t, const unsigned short,
const rpcprog_t, const rpcvers_t,
struct timeval *);
/*
* Acquire an RPC CLIENT * with a privileged source port
*/
extern CLIENT *nfs_get_priv_rpcclient( const struct sockaddr *,
const socklen_t, const unsigned short,
const rpcprog_t, const rpcvers_t,
struct timeval *);
/*
* Convert a netid to a protocol number and protocol family
*/
extern int nfs_get_proto(const char *netid, sa_family_t *family,
unsigned long *protocol);
/*
* Convert a protocol family and protocol name to a netid
*/
extern char *nfs_get_netid(const sa_family_t family,
const unsigned long protocol);
/*
* Convert a socket address to a universal address
*/
extern char *nfs_sockaddr2universal(const struct sockaddr *);
/*
* Extract port number from a universal address
*/
extern int nfs_universal2port(const char *);
/*
* Generic function that maps an RPC service tuple to an IP port
* number of the service on a remote post, and sends a NULL
* request to determine if the service is responding to requests
*/
extern int nfs_getport_ping(struct sockaddr *sap,
const socklen_t salen,
const rpcprog_t program,
const rpcvers_t version,
const unsigned short protocol);
/*
* Generic function that maps an RPC service tuple to an IP port
* number of the service on a remote host
*/
extern unsigned short nfs_getport(const struct sockaddr *,
const socklen_t, const rpcprog_t,
const rpcvers_t, const unsigned short);
/*
* Generic function that maps an RPC service tuple to an IP port
* number of the service on the local host
*/
extern unsigned short nfs_getlocalport(const rpcprot_t,
const rpcvers_t, const unsigned short);
/*
* Function to invoke an rpcbind v3/v4 GETADDR request
*/
extern unsigned short nfs_rpcb_getaddr(const struct sockaddr *,
const socklen_t,
const unsigned short,
const struct sockaddr *,
const rpcprog_t,
const rpcvers_t,
const unsigned short,
const struct timeval *);
/*
* Function to invoke a portmap GETPORT request
*/
extern unsigned long nfs_pmap_getport(const struct sockaddr_in *,
const unsigned short,
const unsigned long,
const unsigned long,
const unsigned long,
const struct timeval *);
/*
* Contact a remote RPC service to discover whether it is responding
* to requests.
*/
extern int nfs_rpc_ping(const struct sockaddr *sap,
const socklen_t salen,
const rpcprog_t program,
const rpcvers_t version,
const unsigned short protocol,
const struct timeval *timeout);
/* create AUTH_SYS handle with no supplemental groups */
extern AUTH * nfs_authsys_create(void);
#endif /* !__NFS_UTILS_NFSRPC_H */
|
