Annotation of fam/fam/DirectoryScanner.c++, Revision 1.1.1.1
1.1 trev 1: // Copyright (C) 1999 Silicon Graphics, Inc. All Rights Reserved.
2: //
3: // This program is free software; you can redistribute it and/or modify it
4: // under the terms of version 2 of the GNU General Public License as
5: // published by the Free Software Foundation.
6: //
7: // This program is distributed in the hope that it would be useful, but
8: // WITHOUT ANY WARRANTY; without even the implied warranty of
9: // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. Further, any
10: // license provided herein, whether implied or otherwise, is limited to
11: // this program in accordance with the express provisions of the GNU
12: // General Public License. Patent licenses, if any, provided herein do not
13: // apply to combinations of this program with other product or programs, or
14: // any other product whatsoever. This program is distributed without any
15: // warranty that the program is delivered free of the rightful claim of any
16: // third person by way of infringement or the like. See the GNU General
17: // Public License for more details.
18: //
19: // You should have received a copy of the GNU General Public License along
20: // with this program; if not, write the Free Software Foundation, Inc., 59
21: // Temple Place - Suite 330, Boston MA 02111-1307, USA.
22:
23: #include "DirectoryScanner.h"
24:
25: #include <assert.h>
26: #include <string.h>
27: #include <errno.h>
28:
29: #include "Client.h"
30: #include "Directory.h"
31: #include "DirEntry.h"
32: #include "Log.h"
33:
34: //////////////////////////////////////////////////////////////////////////////
35:
36: DirectoryScanner::DirectoryScanner(Directory& d,
37: const Event& e, bool b,
38: DoneHandler dh, void *vp)
39: : directory(d), done_handler(dh), closure(vp), new_event(e),
40: scan_entries(b), dir(NULL), openErrno(0),
41: epp(&d.entries), discard(NULL)
42:
43: {
44: dir = opendir(d.name());
45: if (dir == NULL) {
46: openErrno = errno;
47: }
48: }
49:
50: DirectoryScanner::~DirectoryScanner()
51: {
52: if (dir)
53: closedir(dir);
54: }
55:
56: //////////////////////////////////////////////////////////////////////////////
57:
58: // return address of ptr to entry matching name
59:
60: DirEntry **
61: DirectoryScanner::match_name(DirEntry **epp, const char *name)
62: {
63: for (DirEntry *ep; ((ep = *epp) != NULL); epp = &ep->next)
64: if (!strcmp(ep->name(), name))
65: return epp;
66: return NULL;
67: }
68:
69: bool
70: DirectoryScanner::done()
71: {
72: #if HAVE_SGI_NOHANG
73: if (openErrno == ETIMEDOUT) {
74: // We got an nfs time out. We'll want to try again later.
75: directory.unhang();
76: Log::debug("openErrno == ETIMEDOUT");
77: (*done_handler)(closure);
78: return true;
79: }
80: #endif
81: bool ready = directory.client()->ready_for_events();
82:
83: directory.become_user();
84: if (!directory.chdir()) {
85: // Didn't have permission to read the directory. Send Delete events
86: // for its contents.
87: while (*epp && ready)
88: { DirEntry *ep = *epp;
89: *epp = ep->next;
90: ep->post_event(Event::Deleted);
91: ready = directory.client()->ready_for_events();
92: delete ep;
93: }
94: if (*epp || !ready)
95: return false;
96:
97: (*done_handler)(closure);
98: return true;
99: }
100:
101: while (dir && ready)
102: {
103: struct direct *dp = readdir(dir);
104: if (dp == NULL)
105: { closedir(dir);
106: dir = NULL;
107: break;
108: }
109:
110: // Ignore "." and "..".
111:
112: if (!strcmp(dp->d_name, ".") || !strcmp(dp->d_name, ".."))
113: continue;
114:
115: DirEntry *ep = *epp, **epp2;
116: if (ep && !strcmp(dp->d_name, ep->name()))
117: {
118: // Next entry in list matches. Do not change list.
119:
120: // Log::debug("checkdir match %s", dp->d_name);
121: }
122: else if ((epp2 = match_name(&discard, dp->d_name)) != NULL)
123: {
124: // Found in discard. Insert discarded entry before ep.
125:
126: // Log::debug("checkdir fdisc %s", dp->d_name);
127: ep = *epp2;
128: *epp2 = ep->next;
129: ep->next = *epp;
130: *epp = ep;
131: }
132: else if (ep && (epp2 = match_name(&ep->next, dp->d_name)))
133: {
134: // Found further in list. Prepend internode segment
135: // to discard.
136:
137: // Log::debug("checkdir furth %s", dp->d_name);
138: ep = *epp2;
139: *epp2 = discard;
140: discard = *epp;
141: *epp = ep;
142: }
143: else
144: {
145: // New entry. Insert.
146:
147: ep = new DirEntry(dp->d_name, &directory, *epp);
148: *epp = ep;
149: ep->post_event(new_event);
150: ready = directory.client()->ready_for_events();
151: epp = &ep->next;
152: continue; // Do not scan newly created entry.
153: }
154: if (scan_entries)
155: { ep->scan_no_chdir();
156: ready = directory.client()->ready_for_events();
157: }
158: epp = &ep->next;
159: }
160:
161: directory.chdir_root(); // chdir back to "/"
162:
163: while (*epp && ready)
164: { DirEntry *ep = *epp;
165: *epp = ep->next;
166: ep->post_event(Event::Deleted);
167: ready = directory.client()->ready_for_events();
168: delete ep;
169: }
170:
171: while (discard && ready)
172: { DirEntry *ep = discard;
173: discard = discard->next;
174: ep->post_event(Event::Deleted);
175: ready = directory.client()->ready_for_events();
176: delete ep;
177: }
178:
179: if (dir || *epp || discard || !ready)
180: return false;
181:
182: (*done_handler)(closure);
183: return true;
184: }
185:
186: //////////////////////////////////////////////////////////////////////////////
187: // Memory management. Maintain a cache of one DirectoryScanner to reduce
188: // heap stirring.
189:
190: DirectoryScanner *DirectoryScanner::cache;
191:
192: void *
193: DirectoryScanner::operator new (size_t size)
194: {
195: assert(size == sizeof (DirectoryScanner));
196: DirectoryScanner *p = cache ? cache : (DirectoryScanner *) new char[size];
197: if (cache)
198: cache = NULL;
199: return p;
200: }
201:
202: void
203: DirectoryScanner::operator delete (void *p)
204: {
205: assert(p != NULL);
206: if (cache)
207: delete [] cache;
208: cache = (DirectoryScanner *) p;
209: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/back.gif){kind=icon}
Return to DirectoryScanner.c++ CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [Development] / fam / fam