4 * The kernel statd client.
6 * Copyright (C) 1996, Olaf Kirch <okir@monad.swb.de>
9 #include <linux/types.h>
10 #include <linux/utsname.h>
11 #include <linux/kernel.h>
12 #include <linux/sunrpc/clnt.h>
13 #include <linux/sunrpc/svc.h>
14 #include <linux/lockd/lockd.h>
15 #include <linux/lockd/sm_inter.h>
18 #define NLMDBG_FACILITY NLMDBG_MONITOR
20 static struct rpc_clnt
* nsm_create(void);
22 static struct rpc_program nsm_program
;
30 * Common procedure for SM_MON/SM_UNMON calls
33 nsm_mon_unmon(struct nsm_handle
*nsm
, u32 proc
, struct nsm_res
*res
)
35 struct rpc_clnt
*clnt
;
38 struct rpc_message msg
= {
45 status
= PTR_ERR(clnt
);
49 memset(&args
, 0, sizeof(args
));
50 args
.addr
= nsm
->sm_addr
.sin_addr
.s_addr
;
51 args
.prog
= NLM_PROGRAM
;
53 args
.proc
= NLMPROC_NSM_NOTIFY
;
54 memset(res
, 0, sizeof(*res
));
56 msg
.rpc_proc
= &clnt
->cl_procinfo
[proc
];
57 status
= rpc_call_sync(clnt
, &msg
, 0);
59 printk(KERN_DEBUG
"nsm_mon_unmon: rpc failed, status=%d\n",
68 * Set up monitoring of a remote host
71 nsm_monitor(struct nlm_host
*host
)
73 struct nsm_handle
*nsm
= host
->h_nsmhandle
;
77 dprintk("lockd: nsm_monitor(%s)\n", host
->h_name
);
80 if (nsm
->sm_monitored
)
83 status
= nsm_mon_unmon(nsm
, SM_MON
, &res
);
85 if (status
< 0 || res
.status
!= 0)
86 printk(KERN_NOTICE
"lockd: cannot monitor %s\n", host
->h_name
);
88 nsm
->sm_monitored
= 1;
93 * Cease to monitor remote host
96 nsm_unmonitor(struct nlm_host
*host
)
98 struct nsm_handle
*nsm
= host
->h_nsmhandle
;
104 host
->h_nsmhandle
= NULL
;
106 if (atomic_read(&nsm
->sm_count
) == 1
107 && nsm
->sm_monitored
&& !nsm
->sm_sticky
) {
108 dprintk("lockd: nsm_unmonitor(%s)\n", host
->h_name
);
110 status
= nsm_mon_unmon(nsm
, SM_UNMON
, &res
);
112 printk(KERN_NOTICE
"lockd: cannot unmonitor %s\n",
115 nsm
->sm_monitored
= 0;
122 * Create NSM client for the local host
124 static struct rpc_clnt
*
127 struct sockaddr_in sin
= {
128 .sin_family
= AF_INET
,
129 .sin_addr
.s_addr
= htonl(INADDR_LOOPBACK
),
132 struct rpc_create_args args
= {
133 .protocol
= IPPROTO_UDP
,
134 .address
= (struct sockaddr
*)&sin
,
135 .addrsize
= sizeof(sin
),
136 .servername
= "localhost",
137 .program
= &nsm_program
,
138 .version
= SM_VERSION
,
139 .authflavor
= RPC_AUTH_NULL
,
140 .flags
= (RPC_CLNT_CREATE_ONESHOT
),
143 return rpc_create(&args
);
147 * XDR functions for NSM.
151 xdr_encode_common(struct rpc_rqst
*rqstp
, u32
*p
, struct nsm_args
*argp
)
156 * Use the dotted-quad IP address of the remote host as
157 * identifier. Linux statd always looks up the canonical
158 * hostname first for whatever remote hostname it receives,
159 * so this works alright.
161 sprintf(buffer
, "%u.%u.%u.%u", NIPQUAD(argp
->addr
));
162 if (!(p
= xdr_encode_string(p
, buffer
))
163 || !(p
= xdr_encode_string(p
, utsname()->nodename
)))
164 return ERR_PTR(-EIO
);
165 *p
++ = htonl(argp
->prog
);
166 *p
++ = htonl(argp
->vers
);
167 *p
++ = htonl(argp
->proc
);
173 xdr_encode_mon(struct rpc_rqst
*rqstp
, u32
*p
, struct nsm_args
*argp
)
175 p
= xdr_encode_common(rqstp
, p
, argp
);
179 /* Surprise - there may even be room for an IPv6 address now */
184 rqstp
->rq_slen
= xdr_adjust_iovec(rqstp
->rq_svec
, p
);
189 xdr_encode_unmon(struct rpc_rqst
*rqstp
, u32
*p
, struct nsm_args
*argp
)
191 p
= xdr_encode_common(rqstp
, p
, argp
);
194 rqstp
->rq_slen
= xdr_adjust_iovec(rqstp
->rq_svec
, p
);
199 xdr_decode_stat_res(struct rpc_rqst
*rqstp
, u32
*p
, struct nsm_res
*resp
)
201 resp
->status
= ntohl(*p
++);
202 resp
->state
= ntohl(*p
++);
203 dprintk("nsm: xdr_decode_stat_res status %d state %d\n",
204 resp
->status
, resp
->state
);
209 xdr_decode_stat(struct rpc_rqst
*rqstp
, u32
*p
, struct nsm_res
*resp
)
211 resp
->state
= ntohl(*p
++);
215 #define SM_my_name_sz (1+XDR_QUADLEN(SM_MAXSTRLEN))
216 #define SM_my_id_sz (3+1+SM_my_name_sz)
217 #define SM_mon_id_sz (1+XDR_QUADLEN(20)+SM_my_id_sz)
218 #define SM_mon_sz (SM_mon_id_sz+4)
219 #define SM_monres_sz 2
220 #define SM_unmonres_sz 1
223 # define MAX(a, b) (((a) > (b))? (a) : (b))
226 static struct rpc_procinfo nsm_procedures
[] = {
229 .p_encode
= (kxdrproc_t
) xdr_encode_mon
,
230 .p_decode
= (kxdrproc_t
) xdr_decode_stat_res
,
231 .p_bufsiz
= MAX(SM_mon_sz
, SM_monres_sz
) << 2,
237 .p_encode
= (kxdrproc_t
) xdr_encode_unmon
,
238 .p_decode
= (kxdrproc_t
) xdr_decode_stat
,
239 .p_bufsiz
= MAX(SM_mon_id_sz
, SM_unmonres_sz
) << 2,
240 .p_statidx
= SM_UNMON
,
241 .p_name
= "UNMONITOR",
245 static struct rpc_version nsm_version1
= {
247 .nrprocs
= ARRAY_SIZE(nsm_procedures
),
248 .procs
= nsm_procedures
251 static struct rpc_version
* nsm_version
[] = {
255 static struct rpc_stat nsm_stats
;
257 static struct rpc_program nsm_program
= {
259 .number
= SM_PROGRAM
,
260 .nrvers
= ARRAY_SIZE(nsm_version
),
261 .version
= nsm_version
,