Print this page
11083 support NFS server in zone
Portions contributed by: Dan Kruchinin <dan.kruchinin@nexenta.com>
Portions contributed by: Stepan Zastupov <stepan.zastupov@gmail.com>
Portions contributed by: Joyce McIntosh <joyce.mcintosh@nexenta.com>
Portions contributed by: Mike Zeller <mike@mikezeller.net>
Portions contributed by: Dan McDonald <danmcd@joyent.com>
Portions contributed by: Gordon Ross <gordon.w.ross@gmail.com>
Portions contributed by: Vitaliy Gusev <gusev.vitaliy@gmail.com>
Reviewed by: Rick McNeal <rick.mcneal@nexenta.com>
Reviewed by: Rob Gittins <rob.gittins@nexenta.com>
Reviewed by: Sanjay Nadkarni <sanjay.nadkarni@nexenta.com>
Reviewed by: Jason King <jbk@joyent.com>
Reviewed by: C Fraire <cfraire@me.com>
Change-Id: I22f289d357503f9b48a0bc2482cc4328a6d43d16
| Split |
Close |
| Expand all |
| Collapse all |
--- old/usr/src/uts/common/klm/nlm_impl.h
+++ new/usr/src/uts/common/klm/nlm_impl.h
1 1 /*
2 2 * Copyright (c) 2008 Isilon Inc http://www.isilon.com/
3 3 * Authors: Doug Rabson <dfr@rabson.org>
4 4 * Developed with Red Inc: Alfred Perlstein <alfred@freebsd.org>
5 5 *
6 6 * Redistribution and use in source and binary forms, with or without
7 7 * modification, are permitted provided that the following conditions
8 8 * are met:
9 9 * 1. Redistributions of source code must retain the above copyright
10 10 * notice, this list of conditions and the following disclaimer.
11 11 * 2. Redistributions in binary form must reproduce the above copyright
12 12 * notice, this list of conditions and the following disclaimer in the
13 13 * documentation and/or other materials provided with the distribution.
14 14 *
15 15 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
16 16 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
17 17 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
18 18 * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
19 19 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
20 20 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
21 21 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
22 22 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
23 23 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
24 24 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
25 25 * SUCH DAMAGE.
26 26 *
27 27 * $FreeBSD$
28 28 */
29 29
30 30 /*
31 31 * Copyright 2012 Nexenta Systems, Inc. All rights reserved.
32 32 * Copyright (c) 2012 by Delphix. All rights reserved.
33 33 */
34 34
35 35 /*
36 36 * NFS Lock Manager (NLM) private declarations, etc.
37 37 *
38 38 * Source code derived from FreeBSD nlm.h
39 39 */
40 40
41 41 #ifndef _NLM_NLM_H_
42 42 #define _NLM_NLM_H_
43 43
44 44 #include <sys/cmn_err.h>
45 45 #include <sys/queue.h>
46 46 #include <sys/modhash.h>
47 47 #include <sys/avl.h>
48 48
49 49 #define RPC_MSGOUT(args...) cmn_err(CE_NOTE, args)
50 50 #define NLM_ERR(...) cmn_err(CE_NOTE, __VA_ARGS__)
51 51 #define NLM_WARN(...) cmn_err(CE_WARN, __VA_ARGS__)
52 52
53 53 #ifndef SEEK_SET
54 54 #define SEEK_SET 0
55 55 #endif
56 56 #ifndef SEEK_CUR
57 57 #define SEEK_CUR 1
58 58 #endif
59 59 #ifndef SEEK_END
60 60 #define SEEK_END 2
61 61 #endif
62 62
63 63 /*
64 64 * Maximum offset supported by NLM calls using the older
65 65 * (32-bit) versions of the protocol.
66 66 */
67 67 #define MAX_UOFF32 0xffffffffULL
68 68
69 69 struct nlm_host;
70 70 struct vnode;
71 71 struct exportinfo;
72 72 struct shrlock;
73 73 struct _kthread;
74 74
75 75 /*
76 76 * How to read the code: probably the best point to start
77 77 * it the nlm_host structure that is sort of most major
78 78 * structure in klmmod. nlm_host is closely tied with all
79 79 * other NLM structures.
80 80 *
81 81 * There're three major locks we use inside NLM:
82 82 * 1) Global read-write lock (lm_lck) that is used to
83 83 * protect operations with sysid allocation and
84 84 * management of zone globals structures for each
85 85 * zone.
86 86 * 2) Zone global lock: (nlm_globals->lock) is a mutex
87 87 * used to protect all operations inside particular
88 88 * zone.
89 89 * 3) Host's lock: (nlm_host->nh_lock) is per-host mutex
90 90 * used to protect host's internal fields and all
91 91 * operations with the given host.
92 92 *
93 93 * Locks order _must_ obey the following scheme:
94 94 * lm_lck then nlm_globals->lock then nlm_host->nh_lock
95 95 *
96 96 * Locks:
97 97 * (g) locked by lm_lck
98 98 * (z) locked by nlm_globals->lock
99 99 * (l) locked by host->nh_lock
100 100 * (c) const until freeing
101 101 */
102 102
103 103 /*
104 104 * Callback functions for nlm_do_lock() and others.
105 105 *
106 106 * Calls to nlm_do_lock are unusual, because it needs to handle
107 107 * the reply itself, instead of letting it happen the normal way.
108 108 * It also needs to make an RPC call _back_ to the client when a
109 109 * blocked lock request completes.
110 110 *
111 111 * We pass three callback functions to nlm_do_lock:
112 112 * nlm_reply_cb: send a normal RPC reply
113 113 * nlm_res_cb: do a _res (message style) RPC (call)
114 114 * nlm_testargs_cb: do a "granted" RPC call (after blocking)
115 115 * Only one of the 1st or 2nd is used.
116 116 * The 3rd is used only for blocking
117 117 *
118 118 * We also use callback functions for all the _msg variants
119 119 * of the NLM svc calls, where the reply is a reverse call.
120 120 * The nlm_testres_cb is used by the _test_msg svc calls.
121 121 * The nlm_res_cb type is used by the other _msg calls.
122 122 */
123 123 typedef bool_t (*nlm_reply_cb)(SVCXPRT *, nlm4_res *);
124 124 typedef enum clnt_stat (*nlm_res_cb)(nlm4_res *, void *, CLIENT *);
125 125 typedef enum clnt_stat (*nlm_testargs_cb)(nlm4_testargs *, void *, CLIENT *);
126 126 typedef enum clnt_stat (*nlm_testres_cb)(nlm4_testres *, void *, CLIENT *);
127 127
128 128 /*
129 129 * NLM sleeping lock request.
130 130 *
131 131 * Sleeping lock requests are server side only objects
132 132 * that are created when client asks server to add new
133 133 * sleeping lock and when this lock needs to block.
134 134 * Server keeps a track of these requests in order to be
135 135 * able to cancel them or clean them up.
136 136 *
137 137 * Sleeping lock requests are closely tiled with particular
138 138 * vnode or, strictly speaking, NLM vhold object that holds
139 139 * the vnode.
140 140 *
141 141 * struct nlm_slreq:
142 142 * nsr_fl: an information about file lock
143 143 * nsr_link: a list node to store lock requests
144 144 * in vhold object.
145 145 */
146 146 struct nlm_slreq {
147 147 struct flock64 nsr_fl;
148 148 TAILQ_ENTRY(nlm_slreq) nsr_link;
149 149 };
150 150 TAILQ_HEAD(nlm_slreq_list, nlm_slreq);
151 151
152 152 /*
153 153 * NLM vhold object is a sort of wrapper on vnodes remote
154 154 * clients have locked (or added share reservation)
155 155 * on NLM server. Vhold keeps vnode held (by VN_HOLD())
156 156 * while vnode has any locks or shares made by parent host.
157 157 * Vholds are used for two purposes:
158 158 * 1) Hold vnode (with VN_HOLD) while it has any locks;
159 159 * 2) Keep a track of all vnodes remote host touched
160 160 * with lock/share operations on NLM server, so that NLM
161 161 * can know what vnodes are potentially locked;
162 162 *
163 163 * Vholds are used on server side only. For server side it's really
164 164 * important to keep vnodes held while they potentially have
165 165 * any locks/shares. In contrast, it's not important for clinet
166 166 * side at all. When particular vnode comes to the NLM client side
167 167 * code, it's already held (VN_HOLD) by the process calling
168 168 * lock/share function (it's referenced because client calls open()
169 169 * before making locks or shares).
170 170 *
171 171 * Each NLM host object has a collection of vholds associated
172 172 * with vnodes host touched earlier by adding locks or shares.
173 173 * Having this collection allows us to decide if host is still
174 174 * in use. When it has any vhold objects it's considered to be
175 175 * in use. Otherwise we're free to destroy it.
176 176 *
177 177 * Vholds are destroyed by the NLM garbage collecter thread that
178 178 * periodically checks whether they have any locks or shares.
179 179 * Checking occures when parent host is untouched by client
180 180 * or server for some period of time.
181 181 *
182 182 * struct nlm_vhold:
183 183 * nv_vp: a pointer to vnode that is hold by given nlm_vhold
184 184 * nv_refcnt: reference counter (non zero when vhold is inuse)
185 185 * nv_slreqs: sleeping lock requests that were made on the nv_vp
186 186 * nv_link: list node to store vholds in host's nh_vnodes_list
187 187 */
188 188 struct nlm_vhold {
189 189 vnode_t *nv_vp; /* (c) */
190 190 int nv_refcnt; /* (l) */
191 191 struct nlm_slreq_list nv_slreqs; /* (l) */
192 192 TAILQ_ENTRY(nlm_vhold) nv_link; /* (l) */
193 193 };
194 194 TAILQ_HEAD(nlm_vhold_list, nlm_vhold);
195 195
196 196 /*
197 197 * Client side sleeping lock state.
198 198 * - NLM_SL_BLOCKED: some thread is blocked on this lock
199 199 * - NLM_SL_GRANTED: server granted us the lock
200 200 * - NLM_SL_CANCELLED: the lock is cancelled (i.e. invalid/inactive)
201 201 */
202 202 typedef enum nlm_slock_state {
203 203 NLM_SL_UNKNOWN = 0,
204 204 NLM_SL_BLOCKED,
205 205 NLM_SL_GRANTED,
206 206 NLM_SL_CANCELLED
207 207 } nlm_slock_state_t;
208 208
209 209 /*
210 210 * A client side sleeping lock request (set by F_SETLKW)
211 211 * stored in nlm_slocks collection of nlm_globals.
212 212 *
213 213 * struct nlm_slock
214 214 * nsl_state: Sleeping lock state.
215 215 * (see nlm_slock_state for more information)
216 216 * nsl_cond: Condvar that is used when sleeping lock
217 217 * needs to wait for a GRANT callback
218 218 * or cancellation event.
219 219 * nsl_lock: nlm4_lock structure that is sent to the server
220 220 * nsl_fh: Filehandle that corresponds to nw_vp
221 221 * nsl_host: A host owning this sleeping lock
222 222 * nsl_vp: A vnode sleeping lock is waiting on.
223 223 * nsl_link: A list node for nlm_globals->nlm_slocks list.
224 224 */
225 225 struct nlm_slock {
226 226 nlm_slock_state_t nsl_state; /* (z) */
227 227 kcondvar_t nsl_cond; /* (z) */
228 228 nlm4_lock nsl_lock; /* (c) */
229 229 struct netobj nsl_fh; /* (c) */
230 230 struct nlm_host *nsl_host; /* (c) */
231 231 struct vnode *nsl_vp; /* (c) */
232 232 TAILQ_ENTRY(nlm_slock) nsl_link; /* (z) */
233 233 };
234 234 TAILQ_HEAD(nlm_slock_list, nlm_slock);
235 235
236 236 /*
237 237 * Share reservation description. NLM tracks all active
238 238 * share reservations made by the client side, so that
239 239 * they can be easily recovered if remote NLM server
240 240 * reboots. Share reservations tracking is also useful
241 241 * when NLM needs to determine whether host owns any
242 242 * resources on the system and can't be destroyed.
243 243 *
244 244 * nlm_shres:
245 245 * ns_shr: share reservation description
246 246 * ns_vp: a pointer to vnode where share reservation is located
247 247 * ns_next: next nlm_shres instance (or NULL if next item isn't
248 248 * present).
249 249 */
250 250 struct nlm_shres {
251 251 struct shrlock *ns_shr;
252 252 vnode_t *ns_vp;
253 253 struct nlm_shres *ns_next;
254 254 };
255 255
256 256 /*
257 257 * NLM RPC handle object.
258 258 *
259 259 * In kRPC subsystem it's unsafe to use one RPC handle by
260 260 * several threads simultaneously. It was designed so that
261 261 * each thread has to create an RPC handle that it'll use.
262 262 * RPC handle creation can be quite expensive operation, especially
263 263 * with session oriented protocols (such as TCP) that need to
264 264 * establish session at first. NLM RPC handle object is a sort of
265 265 * wrapper on kRPC handle object that can be cached and used in
266 266 * future. We store all created RPC handles for given host in a
267 267 * host's RPC handles cache, so that to make new requests threads
268 268 * can simply take ready objects from the cache. That improves
269 269 * NLM performance.
270 270 *
271 271 * nlm_rpc_t:
272 272 * nr_handle: a kRPC handle itself.
273 273 * nr_vers: a version of NLM protocol kRPC handle was
274 274 * created for.
275 275 * nr_link: a list node to store NLM RPC handles in the host
276 276 * RPC handles cache.
277 277 */
278 278 typedef struct nlm_rpc {
279 279 CLIENT *nr_handle; /* (l) */
280 280 rpcvers_t nr_vers; /* (c) */
281 281 TAILQ_ENTRY(nlm_rpc) nr_link; /* (l) */
282 282 } nlm_rpc_t;
283 283 TAILQ_HEAD(nlm_rpch_list, nlm_rpc);
284 284
285 285 /*
286 286 * Describes the state of NLM host's RPC binding.
287 287 * RPC binding can be in one of three states:
288 288 * 1) NRPCB_NEED_UPDATE:
289 289 * Binding is either not initialized or stale.
290 290 * 2) NRPCB_UPDATE_INPROGRESS:
291 291 * When some thread updates host's RPC binding,
292 292 * it sets binding's state to NRPCB_UPDATE_INPROGRESS
293 293 * which denotes that other threads must wait until
294 294 * update process is finished.
295 295 * 3) NRPCB_UPDATED:
296 296 * Denotes that host's RPC binding is both initialized
297 297 * and fresh.
298 298 */
299 299 enum nlm_rpcb_state {
300 300 NRPCB_NEED_UPDATE = 0,
301 301 NRPCB_UPDATE_INPROGRESS,
302 302 NRPCB_UPDATED
303 303 };
304 304
305 305 /*
306 306 * NLM host flags
307 307 */
308 308 #define NLM_NH_MONITORED 0x01
309 309 #define NLM_NH_RECLAIM 0x02
310 310 #define NLM_NH_INIDLE 0x04
311 311 #define NLM_NH_SUSPEND 0x08
312 312
313 313 /*
314 314 * NLM host object is the most major structure in NLM.
315 315 * It identifies remote client or remote server or both.
316 316 * NLM host object keep a track of all vnodes client/server
317 317 * locked and all sleeping locks it has. All lock/unlock
318 318 * operations are done using host object.
319 319 *
320 320 * nlm_host:
321 321 * nh_lock: a mutex protecting host object fields
322 322 * nh_refs: reference counter. Identifies how many threads
323 323 * uses this host object.
324 324 * nh_link: a list node for keeping host in zone-global list.
325 325 * nh_by_addr: an AVL tree node for keeping host in zone-global tree.
326 326 * Host can be looked up in the tree by <netid, address>
327 327 * pair.
328 328 * nh_name: host name.
329 329 * nh_netid: netid string identifying type of transport host uses.
330 330 * nh_knc: host's knetconfig (used by kRPC subsystem).
331 331 * nh_addr: host's address (either IPv4 or IPv6).
332 332 * nh_sysid: unique sysid associated with this host.
333 333 * nh_state: last seen host's state reported by NSM.
334 334 * nh_flags: ORed host flags.
335 335 * nh_idle_timeout: host idle timeout. When expired host is freed.
336 336 * nh_recl_cv: condition variable used for reporting that reclamation
337 337 * process is finished.
338 338 * nh_rpcb_cv: condition variable that is used to make sure
339 339 * that only one thread renews host's RPC binding.
340 340 * nh_rpcb_ustat: error code returned by RPC binding update operation.
341 341 * nh_rpcb_state: host's RPC binding state (see enum nlm_rpcb_state
342 342 * for more details).
343 343 * nh_rpchc: host's RPC handles cache.
344 344 * nh_vholds_by_vp: a hash table of all vholds host owns. (used for lookup)
345 345 * nh_vholds_list: a linked list of all vholds host owns. (used for iteration)
346 346 * nh_shrlist: a list of all active share resevations on the client side.
347 347 * nh_reclaimer: a pointer to reclamation thread (kthread_t)
348 348 * NULL if reclamation thread doesn't exist
349 349 */
350 350 struct nlm_host {
351 351 kmutex_t nh_lock; /* (c) */
352 352 volatile uint_t nh_refs; /* (z) */
353 353 TAILQ_ENTRY(nlm_host) nh_link; /* (z) */
354 354 avl_node_t nh_by_addr; /* (z) */
355 355 char *nh_name; /* (c) */
356 356 char *nh_netid; /* (c) */
357 357 struct knetconfig nh_knc; /* (c) */
358 358 struct netbuf nh_addr; /* (c) */
359 359 sysid_t nh_sysid; /* (c) */
360 360 int32_t nh_state; /* (z) */
361 361 clock_t nh_idle_timeout; /* (z) */
362 362 uint8_t nh_flags; /* (z) */
363 363 kcondvar_t nh_recl_cv; /* (z) */
364 364 kcondvar_t nh_rpcb_cv; /* (l) */
365 365 enum clnt_stat nh_rpcb_ustat; /* (l) */
366 366 enum nlm_rpcb_state nh_rpcb_state; /* (l) */
367 367 struct nlm_rpch_list nh_rpchc; /* (l) */
368 368 mod_hash_t *nh_vholds_by_vp; /* (l) */
369 369 struct nlm_vhold_list nh_vholds_list; /* (l) */
370 370 struct nlm_shres *nh_shrlist; /* (l) */
371 371 kthread_t *nh_reclaimer; /* (l) */
372 372 };
373 373 TAILQ_HEAD(nlm_host_list, nlm_host);
374 374
375 375 /*
376 376 * nlm_nsm structure describes RPC client handle that can be
377 377 * used to communicate with local NSM via kRPC.
378 378 *
379 379 * We need to wrap handle with nlm_nsm structure because kRPC
380 380 * can not share one handle between several threads. It's assumed
381 381 * that NLM uses only one NSM handle per zone, thus all RPC operations
382 382 * on NSM's handle are serialized using nlm_nsm->sem semaphore.
383 383 *
384 384 * nlm_nsm also contains refcnt field used for reference counting.
385 385 * It's used because there exist a possibility of simultaneous
386 386 * execution of NLM shutdown operation and host monitor/unmonitor
387 387 * operations.
388 388 *
389 389 * struct nlm_nsm:
390 390 * ns_sem: a semaphore for serialization network operations to statd
391 391 * ns_knc: a kneconfig describing transport that is used for communication
392 392 * ns_addr: an address of local statd we're talking to
393 393 * ns_handle: an RPC handle used for talking to local statd using the status
394 394 * monitor protocol (SM_PROG)
395 395 * ns_addr_handle: an RPC handle used for talking to local statd using the
396 396 * address registration protocol (NSM_ADDR_PROGRAM)
397 397 */
398 398 struct nlm_nsm {
399 399 ksema_t ns_sem;
400 400 struct knetconfig ns_knc; /* (c) */
401 401 struct netbuf ns_addr; /* (c) */
402 402 CLIENT *ns_handle; /* (c) */
403 403 CLIENT *ns_addr_handle; /* (c) */
404 404 };
405 405
406 406 /*
407 407 * Could use flock.h flk_nlm_status_t instead, but
408 408 * prefer our own enum with initial zero...
409 409 */
410 410 typedef enum {
411 411 NLM_ST_DOWN = 0,
412 412 NLM_ST_STOPPING,
413 413 NLM_ST_UP,
414 414 NLM_ST_STARTING
415 415 } nlm_run_status_t;
416 416
417 417 /*
418 418 * nlm_globals structure allows NLM be zone aware. The structure
419 419 * collects all "global variables" NLM has for each zone.
420 420 *
421 421 * struct nlm_globals:
422 422 * lock: mutex protecting all operations inside given zone
423 423 * grace_threshold: grace period expiration time (in ticks)
424 424 * lockd_pid: PID of lockd user space daemon
425 425 * run_status: run status of klmmod inside given zone
426 426 * nsm_state: state obtained from local statd during klmmod startup
427 427 * nlm_gc_thread: garbage collector thread
428 428 * nlm_gc_sched_cv: condvar that can be signalled to wakeup GC
429 429 * nlm_gc_finish_cv: condvar that is signalled just before GC thread exits
430 430 * nlm_nsm: an object describing RPC handle used for talking to local statd
431 431 * nlm_hosts_tree: an AVL tree of all hosts in the given zone
432 432 * (used for hosts lookup by <netid, address> pair)
433 433 * nlm_hosts_hash: a hash table of all hosts in the given zone
434 434 * (used for hosts lookup by sysid)
435 435 * nlm_idle_hosts: a list of all hosts that are idle state (i.e. unused)
436 436 * nlm_slocks: a list of all client-side sleeping locks in the zone
437 437 * cn_idle_tmo: a value of idle timeout (in seconds) obtained from lockd
438 438 * grace_period: a value of grace period (in seconds) obtained from lockd
439 439 * retrans_tmo: a value of retransmission timeout (in seconds) obtained
440 440 * from lockd.
441 441 * clean_lock: mutex used to serialize clear_locks calls.
442 442 * nlm_link: a list node used for keeping all nlm_globals objects
443 443 * in one global linked list.
444 444 */
445 445 struct nlm_globals {
446 446 kmutex_t lock;
447 447 clock_t grace_threshold; /* (z) */
448 448 pid_t lockd_pid; /* (z) */
449 449 nlm_run_status_t run_status; /* (z) */
450 450 int32_t nsm_state; /* (z) */
451 451 kthread_t *nlm_gc_thread; /* (z) */
|
↓ open down ↓ |
451 lines elided |
↑ open up ↑ |
452 452 kcondvar_t nlm_gc_sched_cv; /* (z) */
453 453 kcondvar_t nlm_gc_finish_cv; /* (z) */
454 454 struct nlm_nsm nlm_nsm; /* (z) */
455 455 avl_tree_t nlm_hosts_tree; /* (z) */
456 456 mod_hash_t *nlm_hosts_hash; /* (z) */
457 457 struct nlm_host_list nlm_idle_hosts; /* (z) */
458 458 struct nlm_slock_list nlm_slocks; /* (z) */
459 459 int cn_idle_tmo; /* (z) */
460 460 int grace_period; /* (z) */
461 461 int retrans_tmo; /* (z) */
462 + zoneid_t nlm_zoneid; /* (c) */
462 463 kmutex_t clean_lock; /* (c) */
463 464 TAILQ_ENTRY(nlm_globals) nlm_link; /* (g) */
464 465 };
465 466 TAILQ_HEAD(nlm_globals_list, nlm_globals);
466 467
467 468
468 469 /*
469 470 * This is what we pass as the "owner handle" for NLM_LOCK.
470 471 * This lets us find the blocked lock in NLM_GRANTED.
471 472 * It also exposes on the wire what we're using as the
472 473 * sysid for any server, which can be very helpful for
473 474 * problem diagnosis. (Observability is good).
474 475 */
475 476 struct nlm_owner_handle {
476 477 sysid_t oh_sysid; /* of remote host */
477 478 };
478 479
479 480 /*
480 481 * Number retries NLM RPC call is repeatead in case of failure.
481 482 * (used in case of conectionless transport).
482 483 */
483 484 #define NLM_RPC_RETRIES 5
484 485
485 486 /*
486 487 * Klmmod global variables
487 488 */
488 489 extern krwlock_t lm_lck;
489 490 extern zone_key_t nlm_zone_key;
490 491
491 492 /*
492 493 * NLM interface functions (called directly by
493 494 * either klmmod or klmpos)
494 495 */
495 496 extern int nlm_frlock(struct vnode *, int, struct flock64 *, int, u_offset_t,
496 497 struct cred *, struct netobj *, struct flk_callback *, int);
497 498 extern int nlm_shrlock(struct vnode *, int, struct shrlock *, int,
498 499 struct netobj *, int);
499 500 extern int nlm_safemap(const vnode_t *);
500 501 extern int nlm_safelock(vnode_t *, const struct flock64 *, cred_t *);
501 502 extern int nlm_has_sleep(const vnode_t *);
502 503 extern void nlm_register_lock_locally(struct vnode *, struct nlm_host *,
503 504 struct flock64 *, int, u_offset_t);
504 505 int nlm_vp_active(const vnode_t *vp);
505 506 void nlm_sysid_free(sysid_t);
506 507 int nlm_vp_active(const vnode_t *);
507 508 void nlm_unexport(struct exportinfo *);
508 509
509 510 /*
510 511 * NLM startup/shutdown
511 512 */
512 513 int nlm_svc_starting(struct nlm_globals *, struct file *,
513 514 const char *, struct knetconfig *);
514 515 void nlm_svc_stopping(struct nlm_globals *);
515 516 int nlm_svc_add_ep(struct file *, const char *, struct knetconfig *);
516 517
517 518 /*
518 519 * NLM suspend/resume
519 520 */
520 521 void nlm_cprsuspend(void);
521 522 void nlm_cprresume(void);
522 523
523 524 /*
524 525 * NLM internal functions for initialization.
525 526 */
526 527 void nlm_init(void);
527 528 void nlm_rpc_init(void);
528 529 void nlm_rpc_cache_destroy(struct nlm_host *);
529 530 void nlm_globals_register(struct nlm_globals *);
530 531 void nlm_globals_unregister(struct nlm_globals *);
531 532 sysid_t nlm_sysid_alloc(void);
532 533
533 534 /*
534 535 * Client reclamation/cancelation
535 536 */
536 537 void nlm_reclaim_client(struct nlm_globals *, struct nlm_host *);
537 538 void nlm_client_cancel_all(struct nlm_globals *, struct nlm_host *);
538 539
539 540 /* (nlm_rpc_clnt.c) */
540 541 enum clnt_stat nlm_null_rpc(CLIENT *, rpcvers_t);
541 542 enum clnt_stat nlm_test_rpc(nlm4_testargs *, nlm4_testres *,
542 543 CLIENT *, rpcvers_t);
543 544 enum clnt_stat nlm_lock_rpc(nlm4_lockargs *, nlm4_res *,
544 545 CLIENT *, rpcvers_t);
545 546 enum clnt_stat nlm_cancel_rpc(nlm4_cancargs *, nlm4_res *,
546 547 CLIENT *, rpcvers_t);
547 548 enum clnt_stat nlm_unlock_rpc(nlm4_unlockargs *, nlm4_res *,
548 549 CLIENT *, rpcvers_t);
549 550 enum clnt_stat nlm_share_rpc(nlm4_shareargs *, nlm4_shareres *,
550 551 CLIENT *, rpcvers_t);
551 552 enum clnt_stat nlm_unshare_rpc(nlm4_shareargs *, nlm4_shareres *,
552 553 CLIENT *, rpcvers_t);
553 554
554 555
555 556 /*
556 557 * RPC service functions.
557 558 * nlm_dispatch.c
558 559 */
559 560 void nlm_prog_3(struct svc_req *rqstp, SVCXPRT *transp);
560 561 void nlm_prog_4(struct svc_req *rqstp, SVCXPRT *transp);
561 562
562 563 /*
563 564 * Functions for working with knetconfigs (nlm_netconfig.c)
564 565 */
565 566 const char *nlm_knc_to_netid(struct knetconfig *);
566 567 int nlm_knc_from_netid(const char *, struct knetconfig *);
567 568
568 569 /*
569 570 * NLM host functions (nlm_impl.c)
570 571 */
571 572 struct nlm_host *nlm_host_findcreate(struct nlm_globals *, char *,
572 573 const char *, struct netbuf *);
573 574 struct nlm_host *nlm_host_find(struct nlm_globals *,
574 575 const char *, struct netbuf *);
575 576 struct nlm_host *nlm_host_find_by_sysid(struct nlm_globals *, sysid_t);
576 577 void nlm_host_release(struct nlm_globals *, struct nlm_host *);
577 578
578 579 void nlm_host_monitor(struct nlm_globals *, struct nlm_host *, int);
579 580 void nlm_host_unmonitor(struct nlm_globals *, struct nlm_host *);
580 581
581 582 void nlm_host_notify_server(struct nlm_host *, int32_t);
582 583 void nlm_host_notify_client(struct nlm_host *, int32_t);
583 584
584 585 int nlm_host_get_state(struct nlm_host *);
585 586
586 587 struct nlm_vhold *nlm_vhold_get(struct nlm_host *, vnode_t *);
587 588 void nlm_vhold_release(struct nlm_host *, struct nlm_vhold *);
588 589 struct nlm_vhold *nlm_vhold_find_locked(struct nlm_host *, const vnode_t *);
589 590
590 591 struct nlm_slock *nlm_slock_register(struct nlm_globals *,
591 592 struct nlm_host *, struct nlm4_lock *, struct vnode *);
592 593 void nlm_slock_unregister(struct nlm_globals *, struct nlm_slock *);
593 594 int nlm_slock_wait(struct nlm_globals *, struct nlm_slock *, uint_t);
594 595 int nlm_slock_grant(struct nlm_globals *,
595 596 struct nlm_host *, struct nlm4_lock *);
596 597 void nlm_host_cancel_slocks(struct nlm_globals *, struct nlm_host *);
597 598
598 599 int nlm_slreq_register(struct nlm_host *,
599 600 struct nlm_vhold *, struct flock64 *);
600 601 int nlm_slreq_unregister(struct nlm_host *,
601 602 struct nlm_vhold *, struct flock64 *);
602 603
603 604 void nlm_shres_track(struct nlm_host *, vnode_t *, struct shrlock *);
604 605 void nlm_shres_untrack(struct nlm_host *, vnode_t *, struct shrlock *);
605 606 struct nlm_shres *nlm_get_active_shres(struct nlm_host *);
606 607 void nlm_free_shrlist(struct nlm_shres *);
607 608
608 609 int nlm_host_wait_grace(struct nlm_host *);
609 610 int nlm_host_cmp(const void *, const void *);
610 611 void nlm_copy_netobj(struct netobj *, struct netobj *);
611 612
612 613 int nlm_host_get_rpc(struct nlm_host *, int, nlm_rpc_t **);
613 614 void nlm_host_rele_rpc(struct nlm_host *, nlm_rpc_t *);
614 615
615 616 /*
616 617 * NLM server functions (nlm_service.c)
617 618 */
618 619 int nlm_vp_active(const vnode_t *vp);
619 620 void nlm_do_notify1(nlm_sm_status *, void *, struct svc_req *);
620 621 void nlm_do_notify2(nlm_sm_status *, void *, struct svc_req *);
621 622 void nlm_do_test(nlm4_testargs *, nlm4_testres *,
622 623 struct svc_req *, nlm_testres_cb);
623 624 void nlm_do_lock(nlm4_lockargs *, nlm4_res *, struct svc_req *,
624 625 nlm_reply_cb, nlm_res_cb, nlm_testargs_cb);
625 626 void nlm_do_cancel(nlm4_cancargs *, nlm4_res *,
626 627 struct svc_req *, nlm_res_cb);
627 628 void nlm_do_unlock(nlm4_unlockargs *, nlm4_res *,
628 629 struct svc_req *, nlm_res_cb);
629 630 void nlm_do_granted(nlm4_testargs *, nlm4_res *,
630 631 struct svc_req *, nlm_res_cb);
631 632 void nlm_do_share(nlm4_shareargs *, nlm4_shareres *, struct svc_req *);
632 633 void nlm_do_unshare(nlm4_shareargs *, nlm4_shareres *, struct svc_req *);
633 634 void nlm_do_free_all(nlm4_notify *, void *, struct svc_req *);
634 635
635 636 /*
636 637 * NLM RPC functions
637 638 */
638 639 enum clnt_stat nlm_clnt_call(CLIENT *, rpcproc_t, xdrproc_t,
639 640 caddr_t, xdrproc_t, caddr_t, struct timeval);
640 641 bool_t nlm_caller_is_local(SVCXPRT *);
641 642
642 643 #endif /* _NLM_NLM_H_ */
|
↓ open down ↓ |
171 lines elided |
↑ open up ↑ |
XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX