1
|
1 /*****************************************************************************/
|
|
2 /* cache.c - contains the cache routines */
|
122
|
3 /* Copyright (C) 1998-2003 Brian Masney <masneyb@gftp.org> */
|
1
|
4 /* */
|
|
5 /* This program is free software; you can redistribute it and/or modify */
|
|
6 /* it under the terms of the GNU General Public License as published by */
|
|
7 /* the Free Software Foundation; either version 2 of the License, or */
|
|
8 /* (at your option) any later version. */
|
|
9 /* */
|
|
10 /* This program is distributed in the hope that it will be useful, */
|
|
11 /* but WITHOUT ANY WARRANTY; without even the implied warranty of */
|
|
12 /* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the */
|
|
13 /* GNU General Public License for more details. */
|
|
14 /* */
|
|
15 /* You should have received a copy of the GNU General Public License */
|
|
16 /* along with this program; if not, write to the Free Software */
|
|
17 /* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111 USA */
|
|
18 /*****************************************************************************/
|
|
19
|
|
20 #include "gftp.h"
|
33
|
21 static const char cvsid[] = "$Id$";
|
1
|
22
|
114
|
23 struct gftp_cache_entry_tag
|
|
24 {
|
|
25 char *url,
|
|
26 *file;
|
|
27 int server_type;
|
|
28
|
|
29 char *pos1,
|
|
30 *pos2;
|
|
31 };
|
|
32
|
|
33 typedef struct gftp_cache_entry_tag gftp_cache_entry;
|
|
34
|
|
35
|
|
36 static int
|
|
37 gftp_parse_cache_line (gftp_request * request, gftp_cache_entry * centry,
|
|
38 char *line)
|
|
39 {
|
|
40 char *pos;
|
|
41
|
|
42 memset (centry, 0, sizeof (*centry));
|
|
43
|
|
44 if ((pos = strchr (line, '\t')) == NULL || *(pos + 1) == '\0')
|
|
45 {
|
|
46 if (request != NULL)
|
186
|
47 request->logging_function (gftp_logging_error, request,
|
114
|
48 _("Error: Invalid line %s in cache index file\n"),
|
|
49 line);
|
|
50 return (-1);
|
|
51 }
|
|
52
|
|
53 centry->pos1 = pos;
|
|
54 *pos++ = '\0';
|
|
55 centry->url = line;
|
|
56 centry->file = pos;
|
|
57
|
|
58 if ((pos = strchr (pos, '\t')) == NULL || *(pos + 1) == '\0')
|
|
59 {
|
|
60 if (request != NULL)
|
186
|
61 request->logging_function (gftp_logging_error, request,
|
114
|
62 _("Error: Invalid line %s in cache index file\n"),
|
|
63 line);
|
|
64 return (-1);
|
|
65 }
|
|
66
|
|
67 centry->pos2 = pos;
|
|
68 *pos++ = '\0';
|
|
69 centry->server_type = strtol (pos, NULL, 10);
|
|
70
|
|
71 return (0);
|
|
72 }
|
|
73
|
|
74
|
182
|
75 static void
|
114
|
76 gftp_restore_cache_line (gftp_cache_entry * centry, char *line)
|
|
77 {
|
|
78 if (centry->pos1 != NULL)
|
|
79 *centry->pos1 = '\t';
|
|
80
|
|
81 if (centry->pos2 != NULL)
|
|
82 *centry->pos2 = '\t';
|
|
83 }
|
|
84
|
1
|
85
|
182
|
86 void
|
|
87 gftp_generate_cache_description (gftp_request * request, char *description,
|
|
88 size_t len, int ignore_directory)
|
|
89 {
|
|
90 g_snprintf (description, len, "%s://%s@%s:%d%s",
|
|
91 request->url_prefix,
|
|
92 request->username == NULL ? "" : request->username,
|
|
93 request->hostname == NULL ? "" : request->hostname,
|
|
94 request->port,
|
|
95 ignore_directory || request->directory == NULL ? "" : request->directory);
|
|
96 }
|
|
97
|
|
98
|
58
|
99 int
|
1
|
100 gftp_new_cache_entry (gftp_request * request)
|
|
101 {
|
58
|
102 char *cachedir, *tempstr, *temp1str;
|
|
103 int cache_fd, fd;
|
|
104 ssize_t ret;
|
1
|
105
|
|
106 cachedir = expand_path (BASE_CONF_DIR "/cache");
|
|
107 if (access (cachedir, F_OK) == -1)
|
|
108 {
|
58
|
109 if (mkdir (cachedir, S_IRUSR | S_IWUSR | S_IXUSR) < 0)
|
|
110 {
|
|
111 if (request != NULL)
|
186
|
112 request->logging_function (gftp_logging_error, request,
|
58
|
113 _("Error: Could not make directory %s: %s\n"),
|
|
114 cachedir, g_strerror (errno));
|
|
115
|
|
116 return (-1);
|
|
117 }
|
1
|
118 }
|
|
119
|
58
|
120 tempstr = g_strdup_printf ("%s/index.db", cachedir);
|
182
|
121 if ((fd = gftp_fd_open (request, tempstr, O_WRONLY | O_APPEND | O_CREAT,
|
|
122 S_IRUSR | S_IWUSR)) == -1)
|
1
|
123 {
|
58
|
124 g_free (tempstr);
|
1
|
125 g_free (cachedir);
|
58
|
126 return (-1);
|
1
|
127 }
|
182
|
128
|
58
|
129 g_free (tempstr);
|
1
|
130
|
58
|
131 tempstr = g_strdup_printf ("%s/cache.XXXXXX", cachedir);
|
1
|
132 if ((cache_fd = mkstemp (tempstr)) < 0)
|
58
|
133 {
|
|
134 g_free (tempstr);
|
|
135 if (request != NULL)
|
186
|
136 request->logging_function (gftp_logging_error, request,
|
58
|
137 _("Error: Cannot create temporary file: %s\n"),
|
|
138 g_strerror (errno));
|
|
139 return (-1);
|
|
140 }
|
1
|
141 g_free (cachedir);
|
|
142
|
58
|
143 lseek (fd, 0, SEEK_END);
|
114
|
144 temp1str = g_strdup_printf ("%s://%s@%s:%d%s\t%s\t%d\n",
|
87
|
145 request->url_prefix,
|
58
|
146 request->username == NULL ? "" : request->username,
|
|
147 request->hostname == NULL ? "" : request->hostname,
|
|
148 request->port,
|
|
149 request->directory == NULL ? "" : request->directory,
|
114
|
150 tempstr, request->server_type);
|
58
|
151 g_free (tempstr);
|
168
|
152 ret = gftp_fd_write (NULL, temp1str, strlen (temp1str), fd);
|
58
|
153 g_free (temp1str);
|
1
|
154
|
58
|
155 if (close (fd) != 0 || ret < 0)
|
1
|
156 {
|
58
|
157 if (request != NULL)
|
186
|
158 request->logging_function (gftp_logging_error, request,
|
58
|
159 _("Error closing file descriptor: %s\n"),
|
|
160 g_strerror (errno));
|
|
161
|
1
|
162 close (cache_fd);
|
58
|
163 return (-1);
|
1
|
164 }
|
|
165
|
58
|
166 return (cache_fd);
|
1
|
167 }
|
|
168
|
|
169
|
58
|
170 int
|
1
|
171 gftp_find_cache_entry (gftp_request * request)
|
|
172 {
|
114
|
173 char *indexfile, buf[BUFSIZ], description[BUFSIZ];
|
58
|
174 gftp_getline_buffer * rbuf;
|
114
|
175 gftp_cache_entry centry;
|
58
|
176 int indexfd, cachefd;
|
1
|
177
|
182
|
178 gftp_generate_cache_description (request, description, sizeof (description),
|
|
179 0);
|
1
|
180
|
|
181 indexfile = expand_path (BASE_CONF_DIR "/cache/index.db");
|
190
|
182 if ((indexfd = gftp_fd_open (NULL, indexfile, O_RDONLY, 0)) == -1)
|
1
|
183 {
|
|
184 g_free (indexfile);
|
58
|
185 return (-1);
|
1
|
186 }
|
|
187 g_free (indexfile);
|
|
188
|
58
|
189 rbuf = NULL;
|
60
|
190 while (gftp_get_line (NULL, &rbuf, buf, sizeof (buf), indexfd) > 0)
|
1
|
191 {
|
114
|
192 if (gftp_parse_cache_line (request, ¢ry, buf) < 0)
|
1
|
193 continue;
|
|
194
|
114
|
195 if (strcmp (description, centry.url) == 0)
|
1
|
196 {
|
58
|
197 if (close (indexfd) != 0)
|
|
198 {
|
|
199 if (request != NULL)
|
186
|
200 request->logging_function (gftp_logging_error, request,
|
58
|
201 _("Error closing file descriptor: %s\n"),
|
|
202 g_strerror (errno));
|
|
203 return (-1);
|
|
204 }
|
1
|
205
|
182
|
206 if ((cachefd = gftp_fd_open (request, centry.file, O_RDONLY, 0)) == -1)
|
|
207 return (-1);
|
58
|
208
|
|
209 if (lseek (cachefd, 0, SEEK_END) == 0)
|
1
|
210 {
|
58
|
211 close (cachefd);
|
|
212 return (-1);
|
1
|
213 }
|
58
|
214
|
|
215 if (lseek (cachefd, 0, SEEK_SET) == -1)
|
|
216 {
|
|
217 if (request != NULL)
|
186
|
218 request->logging_function (gftp_logging_error, request,
|
58
|
219 _("Error: Cannot seek on file %s: %s\n"),
|
114
|
220 centry.file, g_strerror (errno));
|
58
|
221
|
|
222 }
|
|
223
|
114
|
224 request->server_type = centry.server_type;
|
1
|
225 return (cachefd);
|
|
226 }
|
|
227 }
|
58
|
228 close (indexfd);
|
|
229 return (-1);
|
1
|
230 }
|
|
231
|
|
232
|
|
233 void
|
|
234 gftp_clear_cache_files (void)
|
|
235 {
|
114
|
236 char *indexfile, buf[BUFSIZ];
|
58
|
237 gftp_getline_buffer * rbuf;
|
114
|
238 gftp_cache_entry centry;
|
58
|
239 int indexfd;
|
1
|
240
|
|
241 indexfile = expand_path (BASE_CONF_DIR "/cache/index.db");
|
182
|
242 if ((indexfd = gftp_fd_open (NULL, indexfile, O_RDONLY, 0)) == -1)
|
1
|
243 {
|
|
244 g_free (indexfile);
|
|
245 return;
|
|
246 }
|
|
247
|
58
|
248 rbuf = NULL;
|
60
|
249 while (gftp_get_line (NULL, &rbuf, buf, sizeof (buf), indexfd) > 0)
|
1
|
250 {
|
114
|
251 if (gftp_parse_cache_line (NULL, ¢ry, buf) < 0)
|
|
252 continue;
|
1
|
253
|
114
|
254 unlink (centry.file);
|
1
|
255 }
|
|
256
|
58
|
257 close (indexfd);
|
1
|
258 unlink (indexfile);
|
|
259 g_free (indexfile);
|
|
260 }
|
|
261
|
|
262
|
|
263 void
|
182
|
264 gftp_delete_cache_entry (gftp_request * request, char *descr, int ignore_directory)
|
1
|
265 {
|
114
|
266 char *oldindexfile, *newindexfile, buf[BUFSIZ], description[BUFSIZ];
|
58
|
267 gftp_getline_buffer * rbuf;
|
114
|
268 gftp_cache_entry centry;
|
58
|
269 int indexfd, newfd;
|
47
|
270 int remove;
|
1
|
271
|
182
|
272 if (request != NULL)
|
|
273 {
|
|
274 gftp_generate_cache_description (request, description, sizeof (description),
|
|
275 ignore_directory);
|
|
276 }
|
|
277 else if (descr != NULL)
|
|
278 {
|
|
279 strncpy (description, descr, sizeof (description));
|
|
280 }
|
|
281 else
|
|
282 return;
|
1
|
283
|
|
284 oldindexfile = expand_path (BASE_CONF_DIR "/cache/index.db");
|
190
|
285 if ((indexfd = gftp_fd_open (NULL, oldindexfile, O_RDONLY, 0)) == -1)
|
1
|
286 {
|
|
287 g_free (oldindexfile);
|
|
288 return;
|
|
289 }
|
|
290
|
|
291 newindexfile = expand_path (BASE_CONF_DIR "/cache/index.db.new");
|
182
|
292 if ((newfd = gftp_fd_open (request, newindexfile, O_WRONLY | O_CREAT,
|
|
293 S_IRUSR | S_IWUSR)) == -1)
|
1
|
294 {
|
|
295 g_free (oldindexfile);
|
|
296 g_free (newindexfile);
|
|
297 return;
|
|
298 }
|
|
299
|
58
|
300 rbuf = NULL;
|
114
|
301 while (gftp_get_line (NULL, &rbuf, buf, sizeof (buf) - 1, indexfd) > 0)
|
1
|
302 {
|
114
|
303 if (gftp_parse_cache_line (request, ¢ry, buf) < 0)
|
|
304 continue;
|
1
|
305
|
47
|
306 remove = 0;
|
|
307 if (ignore_directory)
|
|
308 {
|
114
|
309 if (strncmp (centry.url, description, strlen (description)) == 0)
|
47
|
310 remove = 1;
|
|
311 }
|
|
312 else
|
|
313 {
|
114
|
314 if (strcmp (centry.url, description) == 0)
|
47
|
315 remove = 1;
|
|
316 }
|
|
317
|
|
318
|
|
319 if (remove)
|
114
|
320 unlink (centry.file);
|
1
|
321 else
|
|
322 {
|
114
|
323 /* Make sure we put the tabs back in the line. I do it this way
|
|
324 so that I don't have to allocate memory again for each line
|
|
325 as we read it */
|
|
326 gftp_restore_cache_line (¢ry, buf);
|
|
327
|
179
|
328 /* Make sure when we call gftp_get_line() that we pass the read size
|
|
329 as sizeof(buf) - 1 so that we'll have room to put the newline */
|
|
330 buf[strlen (buf)] = '\n';
|
|
331
|
168
|
332 if (gftp_fd_write (NULL, buf, strlen (buf), newfd) < 0)
|
58
|
333 break;
|
1
|
334 }
|
|
335 }
|
|
336
|
58
|
337 close (indexfd);
|
|
338 close (newfd);
|
1
|
339
|
|
340 unlink (oldindexfile);
|
|
341 rename (newindexfile, oldindexfile);
|
|
342
|
|
343 g_free (oldindexfile);
|
|
344 g_free (newindexfile);
|
|
345 }
|
|
346
|