Annotation of fam/fam/NFSFileSystem.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 "config.h"
24: #include "NFSFileSystem.h"
25:
26: #include <assert.h>
27: #include <mntent.h>
28: #include <stdlib.h>
29: #include <stdio.h>
30: #include <string.h>
31:
32: #include "Log.h"
33: #include "ServerHost.h"
34:
35: #if HAVE_SYS_FS_NFS_CLNT_H
36: #include <rpc/types.h>
37: #include <sys/fs/nfs.h>
38: #include <sys/fs/nfs_clnt.h>
39: #else
40: #define ACREGMAX 60
41: #define ACREGMIN 3
42: #endif
43:
44: NFSFileSystem::NFSFileSystem(const mntent& mnt)
45: : FileSystem(mnt)
46: {
47: // Extract the host name from the fs name.
48:
49: const char *fsname = mnt.mnt_fsname;
50: const char *colon = strchr(fsname, ':');
51: if(colon == NULL)
52: {
53: // shouldn't happen, as this is checked in
54: // FileSystemTable::create_fs_by_name().
55: assert(colon);
56: colon = fsname;
57: }
58: char hostname[NAME_MAX + 1];
59: int hostnamelen = colon - fsname;
60: if(hostnamelen > NAME_MAX)
61: {
62: assert(hostnamelen <= NAME_MAX);
63: hostnamelen = NAME_MAX;
64: }
65: strncpy(hostname, fsname, hostnamelen);
66: hostname[hostnamelen] = '\0';
67:
68: // Look up the host by name.
69:
70: host = ServerHostRef(hostname);
71:
72: // Store the remote directory name. As a special case, "/"
73: // is translated to "" so it will prepend neatly to an absolute
74: // path.
75:
76: const char *dir_part = colon + 1;
77: if (!strcmp(dir_part, "/"))
78: dir_part++;
79: remote_dir_len = strlen(dir_part);
80: remote_dir = strcpy(new char[remote_dir_len + 1], dir_part);
81: local_dir_len = strlen(dir());
82:
83: // Figure out what the attribute cache time is. Look for the
84: // acregmin, acregmax, actimeo, and noac options in the mount
85: // options. Otherwise, use defaults.
86:
87: const char * opt = mnt.mnt_opts;
88:
89: bool f_noac = false;
90: bool f_actimeo = false;
91: bool f_acregmin = false;
92: bool f_acregmax = false;
93:
94: int actimeo;
95: int acregmin;
96: int acregmax;
97:
98: attr_cache_timeout = ACREGMAX;
99:
100: char * p;
101:
102: if (strstr(opt, "noac")) {
103: f_noac = true;
104: }
105: if ((p = strstr(opt, "actimeo")))
106: {
107: if (sscanf(p, "actimeo=%i", &actimeo) == 1) {
108: f_actimeo = true;
109: }
110: }
111:
112: if ((p = strstr(opt, "acregmin"))) {
113: if (sscanf(p, "acregmin=%i", &acregmin) == 1) {
114: f_acregmin = true;
115: }
116: }
117:
118: if ((p = strstr(opt, "acregmax"))) {
119: if (sscanf(p, "acregmax=%i", &acregmax) == 1) {
120: f_acregmax = true;
121: }
122: }
123:
124: if (f_noac) {
125: if (!f_actimeo && !f_acregmin && !f_acregmax) {
126: attr_cache_timeout = 0;
127: } else {
128: Log::error("Both noac and (actimeo, acregmin, or acregmax) "
129: "were set");
130: }
131: } else if (f_actimeo) {
132: if (!f_acregmin && !f_acregmax) {
133: attr_cache_timeout = actimeo;
134: } else {
135: Log::error("Both actimeo and (acregmin or acregmax) were set");
136: }
137: } else if (f_acregmax) {
138: if (f_acregmin) {
139: if (acregmin <= acregmax) {
140: attr_cache_timeout = acregmax;
141: } else {
142: Log::error("Both acregmax and acregmin were set, but "
143: "acregmin was greater than acregmax.");
144: }
145: } else {
146: if (ACREGMIN <= acregmax) {
147: attr_cache_timeout = acregmax;
148: } else {
149: Log::error("acregmax was less than the default for acregmin");
150: }
151: }
152: } else if (f_acregmin) {
153: if (acregmin < ACREGMAX) {
154: attr_cache_timeout = ACREGMAX;
155: } else {
156: attr_cache_timeout = acregmin;
157: }
158: } else {
159: attr_cache_timeout = ACREGMAX;
160: }
161: Log::debug("attr_cache_timout set to %i", attr_cache_timeout);
162: }
163:
164: NFSFileSystem::~NFSFileSystem()
165: {
166: ClientInterest *cip;
167: while ((cip = interests().first()) != NULL)
168: cip->findfilesystem();
169: delete [] remote_dir;
170: }
171:
172: bool
173: NFSFileSystem::dir_entries_scanned() const
174: {
175: return !host->is_connected();
176: }
177:
178:
179: int
180: NFSFileSystem::get_attr_cache_timeout() const
181: {
182: return attr_cache_timeout;
183: }
184:
185: //////////////////////////////////////////////////////////////////////////////
186: // High level interface
187:
188: Request
189: NFSFileSystem::hl_monitor(ClientInterest *ci, ClientInterest::Type type)
190: {
191: const char *path = ci->name();
192: assert(path[0] == '/');
193: char remote_path[PATH_MAX];
194: hl_map_path(remote_path, ci->name(), ci->cred());
195: return host->send_monitor(ci, type, remote_path);
196: }
197:
198: void
199: NFSFileSystem::hl_cancel(Request request)
200: {
201: host->send_cancel(request);
202: }
203:
204: void
205: NFSFileSystem::hl_suspend(Request request)
206: {
207: host->send_suspend(request);
208: }
209:
210: void
211: NFSFileSystem::hl_resume(Request request)
212: {
213: host->send_resume(request);
214: }
215:
216: void
217: NFSFileSystem::hl_map_path(char *remote_path, const char *path, const Cred& cr)
218: {
219: char local_path[PATH_MAX];
220: cr.become_user();
221: if (realpath(path, local_path))
222: { assert(!strncmp(local_path, dir(), local_dir_len));
223: (void) strcpy(remote_path, remote_dir);
224: (void) strcpy(remote_path + remote_dir_len,
225: local_path + local_dir_len);
226: }
227: else
228: {
229: // realpath failed -- remove components one at a time
230: // until it starts succeeding, then append the
231: // missing components to the path. Use remote_path
232: // for scratch space.
233:
234: (void) strcpy(remote_path, path);
235: char *p;
236: do {
237: p = strrchr(remote_path, '/');
238: assert(p);
239: *p = '\0';
240: } while (!realpath(remote_path, local_path));
241: (void) strcpy(remote_path, remote_dir);
242: (void) strcpy(remote_path + remote_dir_len,
243: local_path + local_dir_len);
244: (void) strcat(remote_path, path + (p - remote_path));
245: }
246:
247: // If we're famming a remote machine's root directory, then
248: // remote_path will be empty at this point. Make it "/" instead.
249: if (!*remote_path) {
250: strcpy(remote_path, "/");
251: }
252:
253: // Log::debug("NFSFileSystem::hl_map_path() mapped \"%s\" -> \"%s\"",
254: // path, remote_path);
255: }
256:
257: //////////////////////////////////////////////////////////////////////////////
258: // Low level interface: no implementation.
259:
260: void
261: NFSFileSystem::ll_monitor(Interest *, bool)
262: { }
263:
264: void
265: NFSFileSystem::ll_notify_created(Interest *)
266: { }
267:
268: void
269: NFSFileSystem::ll_notify_deleted(Interest *)
270: { }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/back.gif){kind=icon}
Return to NFSFileSystem.c++ CVS log ![[TXT]](/icons/text.gif){kind=icon}
![[DIR]](/icons/dir.gif){kind=icon}
Up to [Development] / fam / fam