1 /* AFS volume management
3 * Copyright (C) 2002 Red Hat, Inc. All Rights Reserved.
4 * Written by David Howells (dhowells@redhat.com)
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public License
8 * as published by the Free Software Foundation; either version
9 * 2 of the License, or (at your option) any later version.
17 #include "kafstimod.h"
18 #include "kafsasyncd.h"
22 AFS_VLUPD_SLEEP
, /* sleeping waiting for update timer to fire */
23 AFS_VLUPD_PENDING
, /* on pending queue */
24 AFS_VLUPD_INPROGRESS
, /* op in progress */
25 AFS_VLUPD_BUSYSLEEP
, /* sleeping because server returned EBUSY */
26 } __attribute__((packed
)) afs_vlocation_upd_t
;
29 * entry in the cached volume location catalogue
31 struct afs_cache_vlocation
{
32 uint8_t name
[64]; /* volume name (lowercase, padded with NULs) */
33 uint8_t nservers
; /* number of entries used in servers[] */
34 uint8_t vidmask
; /* voltype mask for vid[] */
35 uint8_t srvtmask
[8]; /* voltype masks for servers[] */
36 #define AFS_VOL_VTM_RW 0x01 /* R/W version of the volume is available (on this server) */
37 #define AFS_VOL_VTM_RO 0x02 /* R/O version of the volume is available (on this server) */
38 #define AFS_VOL_VTM_BAK 0x04 /* backup version of the volume is available (on this server) */
40 afs_volid_t vid
[3]; /* volume IDs for R/W, R/O and Bak volumes */
41 struct in_addr servers
[8]; /* fileserver addresses */
42 time_t rtime
; /* last retrieval time */
45 #ifdef AFS_CACHING_SUPPORT
46 extern struct cachefs_index_def afs_vlocation_cache_index_def
;
50 * volume -> vnode hash table entry
52 struct afs_cache_vhash
{
53 afs_voltype_t vtype
; /* which volume variation */
54 uint8_t hash_bucket
; /* which hash bucket this represents */
55 } __attribute__((packed
));
57 #ifdef AFS_CACHING_SUPPORT
58 extern struct cachefs_index_def afs_volume_cache_index_def
;
62 * AFS volume location record
64 struct afs_vlocation
{
66 struct list_head link
; /* link in cell volume location list */
67 struct afs_timer timeout
; /* decaching timer */
68 struct afs_cell
*cell
; /* cell to which volume belongs */
69 #ifdef AFS_CACHING_SUPPORT
70 struct cachefs_cookie
*cache
; /* caching cookie */
72 struct afs_cache_vlocation vldb
; /* volume information DB record */
73 struct afs_volume
*vols
[3]; /* volume access record pointer (index by type) */
74 rwlock_t lock
; /* access lock */
75 unsigned long read_jif
; /* time at which last read from vlserver */
76 struct afs_timer upd_timer
; /* update timer */
77 struct afs_async_op upd_op
; /* update operation */
78 afs_vlocation_upd_t upd_state
; /* update state */
79 unsigned short upd_first_svix
; /* first server index during update */
80 unsigned short upd_curr_svix
; /* current server index during update */
81 unsigned short upd_rej_cnt
; /* ENOMEDIUM count during update */
82 unsigned short upd_busy_cnt
; /* EBUSY count during update */
83 unsigned short valid
; /* T if valid */
86 extern int afs_vlocation_lookup(struct afs_cell
*, const char *, unsigned,
87 struct afs_vlocation
**);
89 #define afs_get_vlocation(V) do { atomic_inc(&(V)->usage); } while(0)
91 extern void afs_put_vlocation(struct afs_vlocation
*);
92 extern void afs_vlocation_do_timeout(struct afs_vlocation
*);
95 * AFS volume access record
99 struct afs_cell
*cell
; /* cell to which belongs (unrefd ptr) */
100 struct afs_vlocation
*vlocation
; /* volume location */
101 #ifdef AFS_CACHING_SUPPORT
102 struct cachefs_cookie
*cache
; /* caching cookie */
104 afs_volid_t vid
; /* volume ID */
105 afs_voltype_t type
; /* type of volume */
106 char type_force
; /* force volume type (suppress R/O -> R/W) */
107 unsigned short nservers
; /* number of server slots filled */
108 unsigned short rjservers
; /* number of servers discarded due to -ENOMEDIUM */
109 struct afs_server
*servers
[8]; /* servers on which volume resides (ordered) */
110 struct rw_semaphore server_sem
; /* lock for accessing current server */
113 extern int afs_volume_lookup(const char *, struct afs_cell
*, int,
114 struct afs_volume
**);
116 #define afs_get_volume(V) do { atomic_inc(&(V)->usage); } while(0)
118 extern void afs_put_volume(struct afs_volume
*);
120 extern int afs_volume_pick_fileserver(struct afs_volume
*,
121 struct afs_server
**);
123 extern int afs_volume_release_fileserver(struct afs_volume
*,
124 struct afs_server
*, int);
126 #endif /* AFS_VOLUME_H */