]> arthur.barton.de Git - netatalk.git/blob - etc/afpd/dircache.c
Merge remote-tracking branch 'remotes/origin/branch-netatalk-2-1'
[netatalk.git] / etc / afpd / dircache.c
1 /*
2   Copyright (c) 2010 Frank Lahm <franklahm@gmail.com>
3
4   This program is free software; you can redistribute it and/or modify
5   it under the terms of the GNU General Public License as published by
6   the Free Software Foundation; either version 2 of the License, or
7   (at your option) any later version.
8
9   This program is distributed in the hope that it will be useful,
10   but WITHOUT ANY WARRANTY; without even the implied warranty of
11   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12   GNU General Public License for more details.
13 */
14
15 #ifdef HAVE_CONFIG_H
16 #include "config.h"
17 #endif /* HAVE_CONFIG_H */
18
19 #include <string.h>
20 #include <stdio.h>
21 #include <stdlib.h>
22 #include <errno.h>
23 #include <assert.h>
24 #include <time.h>
25
26 #include <atalk/util.h>
27 #include <atalk/cnid.h>
28 #include <atalk/logger.h>
29 #include <atalk/volume.h>
30 #include <atalk/directory.h>
31 #include <atalk/queue.h>
32 #include <atalk/bstrlib.h>
33 #include <atalk/bstradd.h>
34
35 #include "dircache.h"
36 #include "directory.h"
37 #include "hash.h"
38 #include "globals.h"
39
40 /*
41  * Directory Cache
42  * ===============
43  *
44  * Cache files and directories in a LRU cache.
45  *
46  * The directory cache caches directories and files(!). The main reason for having the cache
47  * is avoiding recursive walks up the path, querying the CNID database each time, when
48  * we have to calculate the location of eg directory with CNID 30, which is located in a dir with
49  * CNID 25, next CNID 20 and then CNID 2 (the volume root as per AFP spec).
50  * If all these dirs where in the cache, each database look up can be avoided. Additionally there's
51  * the element "fullpath" in struct dir, which is used to avoid the recursion in any case. Wheneveer
52  * a struct dir is initialized, the fullpath to the directory is stored there.
53  *
54  * In order to speed up the CNID query for files too, which eg happens when a directory is enumerated,
55  * files are stored too in the dircache. In order to differentiate between files and dirs, we re-use
56  * the element fullpath, which for files is always NULL.
57  *
58  * The most frequent codepatch that leads to caching is directory enumeration (cf enumerate.c):
59  * - if a element is a directory:
60  *   (1) the cache is searched by dircache_search_by_name()
61  *   (2) if it wasn't found a new struct dir is created and cached both from within dir_add()
62  * - for files the caching happens a little bit down the call chain:
63  *   (3) first getfilparams() is called, which calls
64  *   (4) getmetadata() where the cache is searched with dircache_search_by_name()
65  *   (5) if the element is not found
66  *   (6) get_id() queries the CNID from the database
67  *   (7) then a struct dir is initialized via dir_new() (note the fullpath arg is NULL)
68  *   (8) finally added to the cache with dircache_add()
69  * (2) of course does contain the steps 6,7 and 8.
70  *
71  * The dircache is a LRU cache, whenever it fills up we call dircache_evict internally which removes
72  * DIRCACHE_FREE_QUANTUM elements from the cache.
73  *
74  * There is only one cache for all volumes, so of course we use the volume id in hashing calculations.
75  *
76  * In order to avoid cache poisoning, we store the cached entries st_ctime from stat in
77  * struct dir.ctime_dircache. Later when we search the cache we compare the stored
78  * value with the result of a fresh stat. If the times differ, we remove the cached
79  * entry and return "no entry found in cache".
80  * A elements ctime changes when
81  *   1) the element is renamed
82  *      (we loose the cached entry here, but it will expire when the cache fills)
83  *   2) its a directory and an object has been created therein
84  *   3) the element is deleted and recreated under the same name
85  * Using ctime leads to cache eviction in case 2) where it wouldn't be necessary, because
86  * the dir itself (name, CNID, ...) hasn't changed, but there's no other way.
87  *
88  * Indexes
89  * =======
90  *
91  * The maximum dircache size is:
92  * max(DEFAULT_MAX_DIRCACHE_SIZE, min(size, MAX_POSSIBLE_DIRCACHE_SIZE)).
93  * It is a hashtable which we use to store "struct dir"s in. If the cache get full, oldest
94  * entries are evicted in chunks of DIRCACHE_FREE.
95  *
96  * We have/need two indexes:
97  * - a DID/name index on the main dircache, another hashtable
98  * - a queue index on the dircache, for evicting the oldest entries
99  *
100  * Debugging
101  * =========
102  *
103  * Sending SIGHUP to a afpd child causes it to dump the dircache to a file "/tmp/dircache.PID".
104  */
105
106 /********************************************************
107  * Local funcs and variables
108  ********************************************************/
109
110 /*****************************
111  *       the dircache        */
112
113 static hash_t       *dircache;        /* The actual cache */
114 static unsigned int dircache_maxsize; /* cache maximum size */
115
116 static struct dircache_stat {
117     unsigned long long lookups;
118     unsigned long long hits;
119     unsigned long long misses;
120     unsigned long long added;
121     unsigned long long removed;
122     unsigned long long expunged;
123     unsigned long long evicted;
124 } dircache_stat;
125
126 /* FNV 1a */
127 static hash_val_t hash_vid_did(const void *key)
128 {
129     const struct dir *k = (const struct dir *)key;
130     hash_val_t hash = 2166136261;
131
132     hash ^= k->d_vid >> 8;
133     hash *= 16777619;
134     hash ^= k->d_vid;
135     hash *= 16777619;
136
137     hash ^= k->d_did >> 24;
138     hash *= 16777619;
139     hash ^= (k->d_did >> 16) & 0xff;
140     hash *= 16777619;
141     hash ^= (k->d_did >> 8) & 0xff;
142     hash *= 16777619;
143     hash ^= (k->d_did >> 0) & 0xff;
144     hash *= 16777619;
145
146     return hash;
147 }
148
149 static int hash_comp_vid_did(const void *key1, const void *key2)
150 {
151     const struct dir *k1 = key1;
152     const struct dir *k2 = key2;
153
154     return !(k1->d_did == k2->d_did && k1->d_vid == k2->d_vid);
155 }
156
157 /**************************************************
158  * DID/name index on dircache (another hashtable) */
159
160 static hash_t *index_didname;
161
162 #undef get16bits
163 #if (defined(__GNUC__) && defined(__i386__)) || defined(__WATCOMC__)    \
164     || defined(_MSC_VER) || defined (__BORLANDC__) || defined (__TURBOC__)
165 #define get16bits(d) (*((const uint16_t *) (d)))
166 #endif
167
168 #if !defined (get16bits)
169 #define get16bits(d) ((((uint32_t)(((const uint8_t *)(d))[1])) << 8)    \
170                       +(uint32_t)(((const uint8_t *)(d))[0]) )
171 #endif
172
173 static hash_val_t hash_didname(const void *p)
174 {
175     const struct dir *key = (const struct dir *)p;
176     const unsigned char *data = key->d_u_name->data;
177     int len = key->d_u_name->slen;
178     hash_val_t hash = key->d_pdid + key->d_vid;
179     hash_val_t tmp;
180
181     int rem = len & 3;
182     len >>= 2;
183
184     /* Main loop */
185     for (;len > 0; len--) {
186         hash  += get16bits (data);
187         tmp    = (get16bits (data+2) << 11) ^ hash;
188         hash   = (hash << 16) ^ tmp;
189         data  += 2*sizeof (uint16_t);
190         hash  += hash >> 11;
191     }
192
193     /* Handle end cases */
194     switch (rem) {
195     case 3: hash += get16bits (data);
196         hash ^= hash << 16;
197         hash ^= data[sizeof (uint16_t)] << 18;
198         hash += hash >> 11;
199         break;
200     case 2: hash += get16bits (data);
201         hash ^= hash << 11;
202         hash += hash >> 17;
203         break;
204     case 1: hash += *data;
205         hash ^= hash << 10;
206         hash += hash >> 1;
207     }
208
209     /* Force "avalanching" of final 127 bits */
210     hash ^= hash << 3;
211     hash += hash >> 5;
212     hash ^= hash << 4;
213     hash += hash >> 17;
214     hash ^= hash << 25;
215     hash += hash >> 6;
216
217     return hash;
218 }
219
220 static int hash_comp_didname(const void *k1, const void *k2)
221 {
222     const struct dir *key1 = (const struct dir *)k1;
223     const struct dir *key2 = (const struct dir *)k2;
224
225     return ! (key1->d_vid == key2->d_vid
226               && key1->d_pdid == key2->d_pdid
227               && (bstrcmp(key1->d_u_name, key2->d_u_name) == 0) );
228 }
229
230 /***************************
231  * queue index on dircache */
232
233 static q_t *index_queue;    /* the index itself */
234 static unsigned long queue_count;
235
236 /*!
237  * @brief Remove a fixed number of (oldest) entries from the cache and indexes
238  *
239  * The default is to remove the 256 oldest entries from the cache.
240  * 1. Get the oldest entry
241  * 2. If it's in use ie open forks reference it or it's curdir requeue it,
242  *    dont remove it
243  * 3. Remove the dir from the main cache and the didname index
244  * 4. Free the struct dir structure and all its members
245  */
246 static void dircache_evict(void)
247 {
248     int i = DIRCACHE_FREE_QUANTUM;
249     struct dir *dir;
250
251     LOG(log_debug, logtype_afpd, "dircache: {starting cache eviction}");
252
253     while (i--) {
254         if ((dir = (struct dir *)dequeue(index_queue)) == NULL) { /* 1 */
255             dircache_dump();
256             AFP_PANIC("dircache_evict");
257         }
258         queue_count--;
259
260         if (curdir == dir) {                          /* 2 */
261             if ((dir->qidx_node = enqueue(index_queue, dir)) == NULL) {
262                 dircache_dump();
263                 AFP_PANIC("dircache_evict");
264             }
265             queue_count++;
266             continue;
267         }
268
269         dircache_remove(NULL, dir, DIRCACHE | DIDNAME_INDEX); /* 3 */
270         dir_free(dir);                                        /* 4 */
271     }
272
273     AFP_ASSERT(queue_count == dircache->hash_nodecount);
274     dircache_stat.evicted += DIRCACHE_FREE_QUANTUM;
275     LOG(log_debug, logtype_afpd, "dircache: {finished cache eviction}");
276 }
277
278
279 /********************************************************
280  * Interface
281  ********************************************************/
282
283 /*!
284  * @brief Search the dircache via a CNID for a directory
285  *
286  * Found cache entries are expunged if both the parent directory st_ctime and the objects
287  * st_ctime are modified.
288  * This func builds on the fact, that all our code only ever needs to and does search
289  * the dircache by CNID expecting directories to be returned, but not files.
290  * Thus
291  * (1) if we find a file (d_fullpath == NULL) for a given CNID we
292  *     (1a) remove it from the cache
293  *     (1b) return NULL indicating nothing found
294  * (2) we can then use d_fullpath to stat the directory
295  *
296  * @param vol      (r) pointer to struct vol
297  * @param cnid     (r) CNID of the directory to search
298  *
299  * @returns            Pointer to struct dir if found, else NULL
300  */
301 struct dir *dircache_search_by_did(const struct vol *vol, cnid_t cnid)
302 {
303     struct dir *cdir = NULL;
304     struct dir key;
305     struct stat st;
306     hnode_t *hn;
307
308     AFP_ASSERT(vol);
309     AFP_ASSERT(ntohl(cnid) >= CNID_START);
310
311     dircache_stat.lookups++;
312     key.d_vid = vol->v_vid;
313     key.d_did = cnid;
314     if ((hn = hash_lookup(dircache, &key)))
315         cdir = hnode_get(hn);
316
317     if (cdir) {
318         if (cdir->d_fullpath == NULL) { /* (1) */
319             LOG(log_debug, logtype_afpd, "dircache(cnid:%u): {not a directory:\"%s\"}",
320                 ntohl(cnid), cfrombstr(cdir->d_u_name));
321             (void)dir_remove(vol, cdir); /* (1a) */
322             dircache_stat.expunged++;
323             return NULL;        /* (1b) */
324
325         }
326         if (lstat(cfrombstr(cdir->d_fullpath), &st) != 0) {
327             LOG(log_debug, logtype_afpd, "dircache(cnid:%u): {missing:\"%s\"}",
328                 ntohl(cnid), cfrombstr(cdir->d_fullpath));
329             (void)dir_remove(vol, cdir);
330             dircache_stat.expunged++;
331             return NULL;
332         }
333         if (cdir->ctime_dircache != st.st_ctime) {
334             LOG(log_debug, logtype_afpd, "dircache(cnid:%u): {modified:\"%s\"}",
335                 ntohl(cnid), cfrombstr(cdir->d_u_name));
336             (void)dir_remove(vol, cdir);
337             dircache_stat.expunged++;
338             return NULL;
339         }
340         LOG(log_debug, logtype_afpd, "dircache(cnid:%u): {cached: path:\"%s\"}",
341             ntohl(cnid), cfrombstr(cdir->d_fullpath));
342         dircache_stat.hits++;
343     } else {
344         LOG(log_debug, logtype_afpd, "dircache(cnid:%u): {not in cache}", ntohl(cnid));
345         dircache_stat.misses++;
346     }
347     
348     return cdir;
349 }
350
351 /*!
352  * @brief Search the cache via did/name hashtable
353  *
354  * Found cache entries are expunged if both the parent directory st_ctime and the objects
355  * st_ctime are modified.
356  *
357  * @param vol      (r) volume
358  * @param dir      (r) directory
359  * @param name     (r) name (server side encoding)
360  * @parma len      (r) strlen of name
361  * @param ctime    (r) current st_ctime from stat
362  *
363  * @returns pointer to struct dir if found in cache, else NULL
364  */
365 struct dir *dircache_search_by_name(const struct vol *vol,
366                                     const struct dir *dir,
367                                     char *name,
368                                     int len,
369                                     time_t ctime)
370 {
371     struct dir *cdir = NULL;
372     struct dir key;
373
374     hnode_t *hn;
375     static_bstring uname = {-1, len, (unsigned char *)name};
376
377     AFP_ASSERT(vol);
378     AFP_ASSERT(dir);
379     AFP_ASSERT(name);
380     AFP_ASSERT(len == strlen(name));
381     AFP_ASSERT(len < 256);
382
383     dircache_stat.lookups++;
384     LOG(log_debug, logtype_afpd, "dircache_search_by_name(did:%u, \"%s\")",
385         ntohl(dir->d_did), name);
386
387     if (dir->d_did != DIRDID_ROOT_PARENT) {
388         key.d_vid = vol->v_vid;
389         key.d_pdid = dir->d_did;
390         key.d_u_name = &uname;
391
392         if ((hn = hash_lookup(index_didname, &key)))
393             cdir = hnode_get(hn);
394     }
395
396     if (cdir) {
397         if (cdir->ctime_dircache != ctime) {
398             LOG(log_debug, logtype_afpd, "dircache(did:%u,\"%s\"): {modified}",
399                 ntohl(dir->d_did), name);
400             (void)dir_remove(vol, cdir);
401             dircache_stat.expunged++;
402             return NULL;
403         }
404         LOG(log_debug, logtype_afpd, "dircache(did:%u,\"%s\"): {found in cache}",
405             ntohl(dir->d_did), name);
406         dircache_stat.hits++;
407     } else {
408         LOG(log_debug, logtype_afpd, "dircache(did:%u,\"%s\"): {not in cache}",
409             ntohl(dir->d_did), name);
410         dircache_stat.misses++;
411     }
412
413     return cdir;
414 }
415
416 /*!
417  * @brief create struct dir from struct path
418  *
419  * Add a struct dir to the cache and its indexes.
420  *
421  * @param dir   (r) pointer to parrent directory
422  *
423  * @returns 0 on success, -1 on error which should result in an abort
424  */
425 int dircache_add(const struct vol *vol,
426                  struct dir *dir)
427 {
428     struct dir *cdir = NULL;
429     struct dir key;
430     hnode_t *hn;
431
432     AFP_ASSERT(dir);
433     AFP_ASSERT(ntohl(dir->d_pdid) >= 2);
434     AFP_ASSERT(ntohl(dir->d_did) >= CNID_START);
435     AFP_ASSERT(dir->d_u_name);
436     AFP_ASSERT(dir->d_vid);
437     AFP_ASSERT(dircache->hash_nodecount <= dircache_maxsize);
438
439     /* Check if cache is full */
440     if (dircache->hash_nodecount == dircache_maxsize)
441         dircache_evict();
442
443     /* 
444      * Make sure we don't add duplicates
445      */
446
447     /* Search primary cache by CNID */
448     key.d_vid = dir->d_vid;
449     key.d_did = dir->d_did;
450     if ((hn = hash_lookup(dircache, &key))) {
451         /* Found an entry with the same CNID, delete it */
452         dir_remove(vol, hnode_get(hn));
453         dircache_stat.expunged++;
454     }
455     key.d_vid = vol->v_vid;
456     key.d_pdid = dir->d_did;
457     key.d_u_name = dir->d_u_name;
458     if ((hn = hash_lookup(index_didname, &key))) {
459         /* Found an entry with the same DID/name, delete it */
460         dir_remove(vol, hnode_get(hn));
461         dircache_stat.expunged++;
462     }
463
464     /* Add it to the main dircache */
465     if (hash_alloc_insert(dircache, dir, dir) == 0) {
466         dircache_dump();
467         exit(EXITERR_SYS);
468     }
469
470     /* Add it to the did/name index */
471     if (hash_alloc_insert(index_didname, dir, dir) == 0) {
472         dircache_dump();
473         exit(EXITERR_SYS);
474     }
475
476     /* Add it to the fifo queue index */
477     if ((dir->qidx_node = enqueue(index_queue, dir)) == NULL) {
478         dircache_dump();
479         exit(EXITERR_SYS);
480     } else {
481         queue_count++;
482     }
483
484     dircache_stat.added++;
485     LOG(log_debug, logtype_afpd, "dircache(did:%u,'%s'): {added}",
486         ntohl(dir->d_did), cfrombstr(dir->d_u_name));
487
488    AFP_ASSERT(queue_count == index_didname->hash_nodecount 
489            && queue_count == dircache->hash_nodecount);
490
491     return 0;
492 }
493
494 /*!
495   * @brief Remove an entry from the dircache
496   *
497   * Callers outside of dircache.c should call this with
498   * flags = QUEUE_INDEX | DIDNAME_INDEX | DIRCACHE.
499   */
500 void dircache_remove(const struct vol *vol _U_, struct dir *dir, int flags)
501 {
502     hnode_t *hn;
503
504     AFP_ASSERT(dir);
505     AFP_ASSERT((flags & ~(QUEUE_INDEX | DIDNAME_INDEX | DIRCACHE)) == 0);
506
507     if (flags & QUEUE_INDEX) {
508         /* remove it from the queue index */
509         dequeue(dir->qidx_node->prev); /* this effectively deletes the dequeued node */
510         queue_count--;
511     }
512
513     if (flags & DIDNAME_INDEX) {
514         if ((hn = hash_lookup(index_didname, dir)) == NULL) {
515             LOG(log_error, logtype_afpd, "dircache_remove(%u,\"%s\"): not in didname index", 
516                 ntohl(dir->d_did), cfrombstr(dir->d_u_name));
517             dircache_dump();
518             AFP_PANIC("dircache_remove");
519         }
520         hash_delete_free(index_didname, hn);
521     }
522
523     if (flags & DIRCACHE) {
524         if ((hn = hash_lookup(dircache, dir)) == NULL) {
525             LOG(log_error, logtype_afpd, "dircache_remove(%u,\"%s\"): not in dircache", 
526                 ntohl(dir->d_did), cfrombstr(dir->d_u_name));
527             dircache_dump();
528             AFP_PANIC("dircache_remove");
529         }
530         hash_delete_free(dircache, hn);
531     }
532
533     LOG(log_debug, logtype_afpd, "dircache(did:%u,\"%s\"): {removed}",
534         ntohl(dir->d_did), cfrombstr(dir->d_u_name));
535
536     dircache_stat.removed++;
537     AFP_ASSERT(queue_count == index_didname->hash_nodecount 
538                && queue_count == dircache->hash_nodecount);
539 }
540
541 /*!
542  * @brief Initialize the dircache and indexes
543  *
544  * This is called in child afpd initialisation. The maximum cache size will be
545  * max(DEFAULT_MAX_DIRCACHE_SIZE, min(size, MAX_POSSIBLE_DIRCACHE_SIZE)).
546  * It initializes a hashtable which we use to store a directory cache in.
547  * It also initializes two indexes:
548  * - a DID/name index on the main dircache
549  * - a queue index on the dircache
550  *
551  * @param size   (r) requested maximum size from afpd.conf
552  *
553  * @return 0 on success, -1 on error
554  */
555 int dircache_init(int reqsize)
556 {
557     dircache_maxsize = DEFAULT_MAX_DIRCACHE_SIZE;
558
559     /* Initialize the main dircache */
560     if (reqsize > DEFAULT_MAX_DIRCACHE_SIZE && reqsize < MAX_POSSIBLE_DIRCACHE_SIZE) {
561         while ((dircache_maxsize < MAX_POSSIBLE_DIRCACHE_SIZE) && (dircache_maxsize < reqsize))
562                dircache_maxsize *= 2;
563     }
564     if ((dircache = hash_create(dircache_maxsize, hash_comp_vid_did, hash_vid_did)) == NULL)
565         return -1;
566     
567     LOG(log_debug, logtype_afpd, "dircache_init: done. max dircache size: %u", dircache_maxsize);
568
569     /* Initialize did/name index hashtable */
570     if ((index_didname = hash_create(dircache_maxsize, hash_comp_didname, hash_didname)) == NULL)
571         return -1;
572
573     /* Initialize index queue */
574     if ((index_queue = queue_init()) == NULL)
575         return -1;
576     else
577         queue_count = 0;
578
579     /* Initialize index queue */
580     if ((invalid_dircache_entries = queue_init()) == NULL)
581         return -1;
582
583     /* As long as directory.c hasn't got its own initializer call, we do it for it */
584     rootParent.d_did = DIRDID_ROOT_PARENT;
585     rootParent.d_fullpath = bfromcstr("ROOT_PARENT");
586     rootParent.d_m_name = bfromcstr("ROOT_PARENT");
587     rootParent.d_u_name = rootParent.d_m_name;
588
589     return 0;
590 }
591
592 /*!
593  * Log dircache statistics
594  */
595 void log_dircache_stat(void)
596 {
597     LOG(log_info, logtype_afpd, "dircache statistics: "
598         "entries: %lu, lookups: %llu, hits: %llu, misses: %llu, added: %llu, removed: %llu, expunged: %llu, evicted: %llu",
599         queue_count,
600         dircache_stat.lookups,
601         dircache_stat.hits,
602         dircache_stat.misses,
603         dircache_stat.added,
604         dircache_stat.removed,
605         dircache_stat.expunged,
606         dircache_stat.evicted);
607 }
608
609 /*!
610  * @brief Dump dircache to /tmp/dircache.PID
611  */
612 void dircache_dump(void)
613 {
614     char tmpnam[64];
615     FILE *dump;
616     qnode_t *n = index_queue->next;
617     hnode_t *hn;
618     hscan_t hs;
619     const struct dir *dir;
620     int i;
621
622     LOG(log_warning, logtype_afpd, "Dumping directory cache...");
623
624     sprintf(tmpnam, "/tmp/dircache.%u", getpid());
625     if ((dump = fopen(tmpnam, "w+")) == NULL) {
626         LOG(log_error, logtype_afpd, "dircache_dump: %s", strerror(errno));
627         return;
628     }
629     setbuf(dump, NULL);
630
631     fprintf(dump, "Number of cache entries in LRU queue: %lu\n", queue_count);
632     fprintf(dump, "Configured maximum cache size: %u\n\n", dircache_maxsize);
633
634     fprintf(dump, "Primary CNID index:\n");
635     fprintf(dump, "       VID     DID    CNID STAT PATH\n");
636     fprintf(dump, "====================================================================\n");
637     hash_scan_begin(&hs, dircache);
638     i = 1;
639     while ((hn = hash_scan_next(&hs))) {
640         dir = hnode_get(hn);
641         fprintf(dump, "%05u: %3u  %6u  %6u %s    %s\n",
642                 i++,
643                 ntohs(dir->d_vid),
644                 ntohl(dir->d_pdid),
645                 ntohl(dir->d_did),
646                 dir->d_fullpath ? "d" : "f",
647                 cfrombstr(dir->d_u_name));
648     }
649
650     fprintf(dump, "\nSecondary DID/name index:\n");
651     fprintf(dump, "       VID     DID    CNID STAT PATH\n");
652     fprintf(dump, "====================================================================\n");
653     hash_scan_begin(&hs, index_didname);
654     i = 1;
655     while ((hn = hash_scan_next(&hs))) {
656         dir = hnode_get(hn);
657         fprintf(dump, "%05u: %3u  %6u  %6u %s    %s\n",
658                 i++,
659                 ntohs(dir->d_vid),
660                 ntohl(dir->d_pdid),
661                 ntohl(dir->d_did),
662                 dir->d_fullpath ? "d" : "f",
663                 cfrombstr(dir->d_u_name));
664     }
665
666     fprintf(dump, "\nLRU Queue:\n");
667     fprintf(dump, "       VID     DID    CNID STAT PATH\n");
668     fprintf(dump, "====================================================================\n");
669
670     for (i = 1; i <= queue_count; i++) {
671         if (n == index_queue)
672             break;
673         dir = (struct dir *)n->data;
674         fprintf(dump, "%05u: %3u  %6u  %6u %s    %s\n",
675                 i,
676                 ntohs(dir->d_vid),
677                 ntohl(dir->d_pdid),
678                 ntohl(dir->d_did),
679                 dir->d_fullpath ? "d" : "f",
680                 cfrombstr(dir->d_u_name));
681         n = n->next;
682     }
683
684     fprintf(dump, "\n");
685     fflush(dump);
686     return;
687 }