Windows: improved idle dead time handling
[openafs.git] / src / WINNT / afsd / cm_volume.h
index 3cef972..1646300 100644 (file)
@@ -1,20 +1,22 @@
 /*
  * 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)
 
-/* 
+/*
  *
  */
 
@@ -25,13 +27,17 @@ typedef struct cm_vol_state {
     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 */
@@ -44,13 +50,17 @@ typedef struct cm_volume {
     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;
@@ -59,12 +69,12 @@ typedef struct cm_volumeRef {
 
 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
@@ -76,8 +86,9 @@ extern long cm_FindVolumeByID(struct cm_cell *cellp, afs_uint32 volumeID,
  * 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)
 
@@ -94,12 +105,12 @@ extern long cm_GetROVolumeID(cm_volume_t *volp);
 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);
 
@@ -127,8 +138,8 @@ extern void cm_CheckOfflineVolumes(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);
@@ -145,5 +156,7 @@ extern cm_vol_state_t * cm_VolumeStateByID(cm_volume_t *volp, afs_uint32 id);
 
 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 */