2 * linux/net/sunrpc/pmap.c
6 * Copyright (C) 1996, Olaf Kirch <okir@monad.swb.de>
9 #include <linux/config.h>
10 #include <linux/types.h>
11 #include <linux/socket.h>
12 #include <linux/kernel.h>
13 #include <linux/errno.h>
14 #include <linux/uio.h>
16 #include <linux/sunrpc/clnt.h>
17 #include <linux/sunrpc/xprt.h>
18 #include <linux/sunrpc/sched.h>
21 # define RPCDBG_FACILITY RPCDBG_PMAP
26 #define PMAP_GETPORT 3
28 static struct rpc_procinfo pmap_procedures
[];
29 static struct rpc_clnt
* pmap_create(char *, struct sockaddr_in
*, int, int);
30 static void pmap_getport_done(struct rpc_task
*);
31 static struct rpc_program pmap_program
;
32 static DEFINE_SPINLOCK(pmap_lock
);
35 * Obtain the port for a given RPC service on a given host. This one can
36 * be called for an ongoing RPC request.
39 rpc_getport(struct rpc_task
*task
, struct rpc_clnt
*clnt
)
41 struct rpc_portmap
*map
= clnt
->cl_pmap
;
42 struct sockaddr_in
*sap
= &clnt
->cl_xprt
->addr
;
43 struct rpc_message msg
= {
44 .rpc_proc
= &pmap_procedures
[PMAP_GETPORT
],
46 .rpc_resp
= &clnt
->cl_port
,
49 struct rpc_clnt
*pmap_clnt
;
50 struct rpc_task
*child
;
52 dprintk("RPC: %4d rpc_getport(%s, %d, %d, %d)\n",
53 task
->tk_pid
, clnt
->cl_server
,
54 map
->pm_prog
, map
->pm_vers
, map
->pm_prot
);
56 /* Autobind on cloned rpc clients is discouraged */
57 BUG_ON(clnt
->cl_parent
!= clnt
);
59 spin_lock(&pmap_lock
);
60 if (map
->pm_binding
) {
61 rpc_sleep_on(&map
->pm_bindwait
, task
, NULL
, NULL
);
62 spin_unlock(&pmap_lock
);
66 spin_unlock(&pmap_lock
);
68 pmap_clnt
= pmap_create(clnt
->cl_server
, sap
, map
->pm_prot
, 0);
69 if (IS_ERR(pmap_clnt
)) {
70 task
->tk_status
= PTR_ERR(pmap_clnt
);
76 * Note: rpc_new_child will release client after a failure.
78 if (!(child
= rpc_new_child(pmap_clnt
, task
)))
81 /* Setup the call info struct */
82 rpc_call_setup(child
, &msg
, 0);
84 /* ... and run the child task */
85 rpc_run_child(task
, child
, pmap_getport_done
);
89 spin_lock(&pmap_lock
);
91 rpc_wake_up(&map
->pm_bindwait
);
92 spin_unlock(&pmap_lock
);
96 #ifdef CONFIG_ROOT_NFS
98 rpc_getport_external(struct sockaddr_in
*sin
, __u32 prog
, __u32 vers
, int prot
)
100 struct rpc_portmap map
= {
106 struct rpc_clnt
*pmap_clnt
;
110 dprintk("RPC: rpc_getport_external(%u.%u.%u.%u, %d, %d, %d)\n",
111 NIPQUAD(sin
->sin_addr
.s_addr
), prog
, vers
, prot
);
113 sprintf(hostname
, "%u.%u.%u.%u", NIPQUAD(sin
->sin_addr
.s_addr
));
114 pmap_clnt
= pmap_create(hostname
, sin
, prot
, 0);
115 if (IS_ERR(pmap_clnt
))
116 return PTR_ERR(pmap_clnt
);
118 /* Setup the call info struct */
119 status
= rpc_call(pmap_clnt
, PMAP_GETPORT
, &map
, &map
.pm_port
, 0);
122 if (map
.pm_port
!= 0)
131 pmap_getport_done(struct rpc_task
*task
)
133 struct rpc_clnt
*clnt
= task
->tk_client
;
134 struct rpc_xprt
*xprt
= task
->tk_xprt
;
135 struct rpc_portmap
*map
= clnt
->cl_pmap
;
137 dprintk("RPC: %4d pmap_getport_done(status %d, port %d)\n",
138 task
->tk_pid
, task
->tk_status
, clnt
->cl_port
);
140 xprt
->ops
->set_port(xprt
, 0);
141 if (task
->tk_status
< 0) {
142 /* Make the calling task exit with an error */
143 task
->tk_action
= rpc_exit_task
;
144 } else if (clnt
->cl_port
== 0) {
145 /* Program not registered */
146 rpc_exit(task
, -EACCES
);
148 xprt
->ops
->set_port(xprt
, clnt
->cl_port
);
149 clnt
->cl_port
= htons(clnt
->cl_port
);
151 spin_lock(&pmap_lock
);
153 rpc_wake_up(&map
->pm_bindwait
);
154 spin_unlock(&pmap_lock
);
158 * Set or unset a port registration with the local portmapper.
159 * port == 0 means unregister, port != 0 means register.
162 rpc_register(u32 prog
, u32 vers
, int prot
, unsigned short port
, int *okay
)
164 struct sockaddr_in sin
;
165 struct rpc_portmap map
;
166 struct rpc_clnt
*pmap_clnt
;
169 dprintk("RPC: registering (%d, %d, %d, %d) with portmapper.\n",
170 prog
, vers
, prot
, port
);
172 sin
.sin_family
= AF_INET
;
173 sin
.sin_addr
.s_addr
= htonl(INADDR_LOOPBACK
);
174 pmap_clnt
= pmap_create("localhost", &sin
, IPPROTO_UDP
, 1);
175 if (IS_ERR(pmap_clnt
)) {
176 error
= PTR_ERR(pmap_clnt
);
177 dprintk("RPC: couldn't create pmap client. Error = %d\n", error
);
186 error
= rpc_call(pmap_clnt
, port
? PMAP_SET
: PMAP_UNSET
,
191 "RPC: failed to contact portmap (errno %d).\n",
194 dprintk("RPC: registration status %d/%d\n", error
, *okay
);
196 /* Client deleted automatically because cl_oneshot == 1 */
200 static struct rpc_clnt
*
201 pmap_create(char *hostname
, struct sockaddr_in
*srvaddr
, int proto
, int privileged
)
203 struct rpc_xprt
*xprt
;
204 struct rpc_clnt
*clnt
;
206 /* printk("pmap: create xprt\n"); */
207 xprt
= xprt_create_proto(proto
, srvaddr
, NULL
);
209 return (struct rpc_clnt
*)xprt
;
210 xprt
->ops
->set_port(xprt
, RPC_PMAP_PORT
);
214 /* printk("pmap: create clnt\n"); */
215 clnt
= rpc_new_client(xprt
, hostname
,
216 &pmap_program
, RPC_PMAP_VERSION
,
219 clnt
->cl_softrtry
= 1;
220 clnt
->cl_oneshot
= 1;
226 * XDR encode/decode functions for PMAP
229 xdr_encode_mapping(struct rpc_rqst
*req
, u32
*p
, struct rpc_portmap
*map
)
231 dprintk("RPC: xdr_encode_mapping(%d, %d, %d, %d)\n",
232 map
->pm_prog
, map
->pm_vers
, map
->pm_prot
, map
->pm_port
);
233 *p
++ = htonl(map
->pm_prog
);
234 *p
++ = htonl(map
->pm_vers
);
235 *p
++ = htonl(map
->pm_prot
);
236 *p
++ = htonl(map
->pm_port
);
238 req
->rq_slen
= xdr_adjust_iovec(req
->rq_svec
, p
);
243 xdr_decode_port(struct rpc_rqst
*req
, u32
*p
, unsigned short *portp
)
245 *portp
= (unsigned short) ntohl(*p
++);
250 xdr_decode_bool(struct rpc_rqst
*req
, u32
*p
, unsigned int *boolp
)
252 *boolp
= (unsigned int) ntohl(*p
++);
256 static struct rpc_procinfo pmap_procedures
[] = {
259 .p_encode
= (kxdrproc_t
) xdr_encode_mapping
,
260 .p_decode
= (kxdrproc_t
) xdr_decode_bool
,
265 .p_proc
= PMAP_UNSET
,
266 .p_encode
= (kxdrproc_t
) xdr_encode_mapping
,
267 .p_decode
= (kxdrproc_t
) xdr_decode_bool
,
272 .p_proc
= PMAP_GETPORT
,
273 .p_encode
= (kxdrproc_t
) xdr_encode_mapping
,
274 .p_decode
= (kxdrproc_t
) xdr_decode_port
,
280 static struct rpc_version pmap_version2
= {
283 .procs
= pmap_procedures
286 static struct rpc_version
* pmap_version
[] = {
292 static struct rpc_stat pmap_stats
;
294 static struct rpc_program pmap_program
= {
296 .number
= RPC_PMAP_PROGRAM
,
297 .nrvers
= ARRAY_SIZE(pmap_version
),
298 .version
= pmap_version
,
299 .stats
= &pmap_stats
,