/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
- *
+ *
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
-#ifndef __CM_VOLUME_H_ENV__
-#define __CM_VOLUME_H_ENV__ 1
+#ifndef OPENAFS_WINNT_AFSD_CM_VOLUME_H
+#define OPENAFS_WINNT_AFSD_CM_VOLUME_H 1
+
+#include <opr/jhash.h>
#define VL_MAXNAMELEN 65
#define CM_VOLUME_MAGIC ('V' | 'O' <<8 | 'L'<<16 | 'M'<<24)
-/*
+/*
*
*/
cm_serverRef_t *serversp; /* by cm_serverLock */
enum volstatus state; /* by rw */
afs_uint32 flags; /* by rw */
+ afs_uint32 qflags; /* by cm_volumeLock */
} cm_vol_state_t;
/* RWVOL, ROVOL, BACKVOL are defined in cm.h */
#define NUM_VOL_TYPES 3
+#define CM_VOL_STATE_FLAG_REPLICATED 1
+
typedef struct cm_volume {
osi_queue_t q; /* LRU queue; cm_volumeLock */
+ afs_uint32 qflags; /* by cm_volumeLock */
afs_uint32 magic;
struct cm_volume *allNextp; /* allVolumes; by cm_volumeLock */
struct cm_volume *nameNextp; /* volumeNameHashTable; by cm_volumeLock */
afs_int32 refCount; /* by Interlocked operations */
struct cm_server *cbServerpRO; /* server granting RO callback; by cm_scacheLock */
time_t cbExpiresRO; /* latest RO expiration time; by cm_scacheLock */
+ time_t creationDateRO; /* latest volume creation date; 0 if unknown; by cm_scacheLock */
+ time_t lastUpdateTime; /* most recent volume location update cm_volumeLock */
} cm_volume_t;
#define CM_VOLUMEFLAG_RESET 1 /* reload this info on next use */
-#define CM_VOLUMEFLAG_IN_HASH 2
-#define CM_VOLUMEFLAG_IN_LRU_QUEUE 4
#define CM_VOLUMEFLAG_UPDATING_VL 8
#define CM_VOLUMEFLAG_DFS_VOLUME 16
+#define CM_VOLUMEFLAG_NOEXIST 32
+
+#define CM_VOLUME_QFLAG_IN_HASH 1
+#define CM_VOLUME_QFLAG_IN_LRU_QUEUE 2
typedef struct cm_volumeRef {
struct cm_volumeRef * next;
extern void cm_InitVolume(int newFile, long maxVols);
-extern long cm_FindVolumeByName(struct cm_cell *cellp, char *volNamep,
- struct cm_user *userp, struct cm_req *reqp,
+extern long cm_FindVolumeByName(struct cm_cell *cellp, char *volNamep,
+ struct cm_user *userp, struct cm_req *reqp,
afs_uint32 flags, cm_volume_t **outVolpp);
extern long cm_FindVolumeByID(struct cm_cell *cellp, afs_uint32 volumeID,
- cm_user_t *userp, cm_req_t *reqp,
+ cm_user_t *userp, cm_req_t *reqp,
afs_uint32 flags, cm_volume_t **outVolpp);
#define CM_GETVOL_FLAG_CREATE 1
* doesn't necessarily know the cell in the case of a multihomed server
* contacting us from a mystery address.
*/
-#define CM_VOLUME_ID_HASH(volid) ((unsigned long) volid \
- % cm_data.volumeHashTableSize)
+
+#define CM_VOLUME_ID_HASH(volid) \
+ (opr_jhash_int((volid), 0) & (cm_data.volumeHashTableSize - 1))
#define CM_VOLUME_NAME_HASH(name) (SDBMHash(name) % cm_data.volumeHashTableSize)
extern long cm_ForceUpdateVolume(struct cm_fid *fidp, cm_user_t *userp,
cm_req_t *reqp);
-extern cm_serverRef_t **cm_GetVolServers(cm_volume_t *volp, afs_uint32 volume,
+extern cm_serverRef_t **cm_GetVolServers(cm_volume_t *volp, afs_uint32 volume,
cm_user_t *userp, cm_req_t *reqp);
extern void cm_ChangeRankVolume(cm_server_t *tsp);
-extern void cm_RefreshVolumes(void);
+extern void cm_RefreshVolumes(int lifetime);
extern long cm_ValidateVolume(void);
extern long cm_CheckOfflineVolume(cm_volume_t *volp, afs_uint32 volID);
-extern void cm_CheckOfflineVolumeState(cm_volume_t *volp, cm_vol_state_t *statep,
- afs_uint32 volID, afs_uint32 *onlinep,
+extern void cm_CheckOfflineVolumeState(cm_volume_t *volp, cm_vol_state_t *statep,
+ afs_uint32 volID, afs_uint32 *onlinep,
afs_uint32 *volumeUpdatedp);
extern void cm_UpdateVolumeStatus(cm_volume_t *volp, afs_uint32 volID);
extern cm_vol_state_t * cm_VolumeStateByName(cm_volume_t *volp, char *volname);
+extern afs_int32 cm_VolumeType(cm_volume_t *volp, afs_uint32 id);
+
extern osi_rwlock_t cm_volumeLock;
-#endif /* __CM_VOLUME_H_ENV__ */
+#endif /* OPENAFS_WINNT_AFSD_CM_VOLUME_H */