a92eb153335cd29644434babd4cee17348abd179
[ira/wip.git] / source / lib / util_file.c
1 /*
2  * Unix SMB/Netbios implementation. Version 1.9. SMB parameters and setup
3  * Copyright (C) Andrew Tridgell 1992-1998 Modified by Jeremy Allison 1995.
4  * 
5  * This program is free software; you can redistribute it and/or modify it under
6  * the terms of the GNU General Public License as published by the Free
7  * Software Foundation; either version 2 of the License, or (at your option)
8  * any later version.
9  * 
10  * This program is distributed in the hope that it will be useful, but WITHOUT
11  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
12  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
13  * more details.
14  * 
15  * You should have received a copy of the GNU General Public License along with
16  * this program; if not, write to the Free Software Foundation, Inc., 675
17  * Mass Ave, Cambridge, MA 02139, USA.
18  */
19
20 #include "includes.h"
21
22 extern int DEBUGLEVEL;
23
24 static int gotalarm;
25
26 /***************************************************************
27  Signal function to tell us we timed out.
28 ****************************************************************/
29
30 static void gotalarm_sig(void)
31 {
32   gotalarm = 1;
33 }
34
35 /***************************************************************
36  Lock or unlock a fd for a known lock type. Abandon after waitsecs 
37  seconds.
38 ****************************************************************/
39
40 BOOL do_file_lock(int fd, int waitsecs, int type)
41 {
42   SMB_STRUCT_FLOCK lock;
43   int             ret;
44
45   gotalarm = 0;
46   CatchSignal(SIGALRM, SIGNAL_CAST gotalarm_sig);
47
48   lock.l_type = type;
49   lock.l_whence = SEEK_SET;
50   lock.l_start = 0;
51   lock.l_len = 1;
52   lock.l_pid = 0;
53
54   alarm(waitsecs);
55   ret = fcntl(fd, SMB_F_SETLKW, &lock);
56   alarm(0);
57   CatchSignal(SIGALRM, SIGNAL_CAST SIG_DFL);
58
59   if (gotalarm) {
60     DEBUG(0, ("do_file_lock: failed to %s file.\n",
61                 type == F_UNLCK ? "unlock" : "lock"));
62     return False;
63   }
64
65   return (ret == 0);
66 }
67
68
69 /***************************************************************
70  Lock an fd. Abandon after waitsecs seconds.
71 ****************************************************************/
72
73 BOOL file_lock(int fd, int type, int secs, int *plock_depth)
74 {
75   if (fd < 0)
76     return False;
77
78   (*plock_depth)++;
79
80   if ((*plock_depth) == 0)
81   {
82     if (!do_file_lock(fd, secs, type)) {
83       DEBUG(10,("file_lock: locking file failed, error = %s.\n",
84                  strerror(errno)));
85       return False;
86     }
87   }
88
89   return True;
90 }
91
92 /***************************************************************
93  Unlock an fd. Abandon after waitsecs seconds.
94 ****************************************************************/
95
96 BOOL file_unlock(int fd, int *plock_depth)
97 {
98   BOOL ret=True;
99
100   if(*plock_depth == 1)
101     ret = do_file_lock(fd, 5, F_UNLCK);
102
103   (*plock_depth)--;
104
105   if(!ret)
106     DEBUG(10,("file_unlock: unlocking file failed, error = %s.\n",
107                  strerror(errno)));
108   return ret;
109 }
110
111 /***************************************************************
112  locks a file for enumeration / modification.
113  update to be set = True if modification is required.
114 ****************************************************************/
115
116 void *startfilepwent(char *pfile, char *s_readbuf, int bufsize,
117                                 int *file_lock_depth, BOOL update)
118 {
119   FILE *fp = NULL;
120
121   if (!*pfile)
122  {
123     DEBUG(0, ("startfilepwent: No file set\n"));
124     return (NULL);
125   }
126   DEBUG(10, ("startfilepwent: opening file %s\n", pfile));
127
128   fp = sys_fopen(pfile, update ? "r+b" : "rb");
129
130   if (fp == NULL) {
131     DEBUG(0, ("startfilepwent: unable to open file %s\n", pfile));
132     return NULL;
133   }
134
135   /* Set a buffer to do more efficient reads */
136   setvbuf(fp, s_readbuf, _IOFBF, bufsize);
137
138   if (!file_lock(fileno(fp), (update ? F_WRLCK : F_RDLCK), 5, file_lock_depth))
139   {
140     DEBUG(0, ("startfilepwent: unable to lock file %s\n", pfile));
141     fclose(fp);
142     return NULL;
143   }
144
145   /* Make sure it is only rw by the owner */
146   chmod(pfile, 0600);
147
148   /* We have a lock on the file. */
149   return (void *)fp;
150 }
151
152 /***************************************************************
153  End enumeration of the file.
154 ****************************************************************/
155 void endfilepwent(void *vp, int *file_lock_depth)
156 {
157   FILE *fp = (FILE *)vp;
158
159   file_unlock(fileno(fp), file_lock_depth);
160   fclose(fp);
161   DEBUG(7, ("endfilepwent: closed file.\n"));
162 }
163
164 /*************************************************************************
165  Return the current position in the file list as an SMB_BIG_UINT.
166  This must be treated as an opaque token.
167 *************************************************************************/
168 SMB_BIG_UINT getfilepwpos(void *vp)
169 {
170   return (SMB_BIG_UINT)sys_ftell((FILE *)vp);
171 }
172
173 /*************************************************************************
174  Set the current position in the file list from an SMB_BIG_UINT.
175  This must be treated as an opaque token.
176 *************************************************************************/
177 BOOL setfilepwpos(void *vp, SMB_BIG_UINT tok)
178 {
179   return !sys_fseek((FILE *)vp, (SMB_OFF_T)tok, SEEK_SET);
180 }
181
182 /*************************************************************************
183  gets a line out of a file.
184  line is of format "xxxx:xxxxxx:xxxxx:".
185  lines with "#" at the front are ignored.
186 *************************************************************************/
187 int getfileline(void *vp, char *linebuf, int linebuf_size)
188 {
189         /* Static buffers we will return. */
190         FILE *fp = (FILE *)vp;
191         unsigned char   c;
192         unsigned char  *p;
193         size_t            linebuf_len;
194
195         if (fp == NULL)
196         {
197                 DEBUG(0,("getfileline: Bad file pointer.\n"));
198                 return -1;
199         }
200
201         /*
202          * Scan the file, a line at a time.
203          */
204         while (!feof(fp))
205         {
206                 linebuf[0] = '\0';
207
208                 fgets(linebuf, linebuf_size, fp);
209                 if (ferror(fp))
210                 {
211                         return -1;
212                 }
213
214                 /*
215                  * Check if the string is terminated with a newline - if not
216                  * then we must keep reading and discard until we get one.
217                  */
218
219                 linebuf_len = strlen(linebuf);
220                 if (linebuf_len == 0)
221                 {
222                         linebuf[0] = '\0';
223                         return 0;
224                 }
225
226                 if (linebuf[linebuf_len - 1] != '\n')
227                 {
228                         c = '\0';
229                         while (!ferror(fp) && !feof(fp))
230                         {
231                                 c = fgetc(fp);
232                                 if (c == '\n')
233                                 {
234                                         break;
235                                 }
236                         }
237                 }
238                 else
239                 {
240                         linebuf[linebuf_len - 1] = '\0';
241                 }
242
243 #ifdef DEBUG_PASSWORD
244                 DEBUG(100, ("getfileline: got line |%s|\n", linebuf));
245 #endif
246                 if ((linebuf[0] == 0) && feof(fp))
247                 {
248                         DEBUG(4, ("getfileline: end of file reached\n"));
249                         return 0;
250                 }
251
252                 if (linebuf[0] == '#' || linebuf[0] == '\0')
253                 {
254                         DEBUG(6, ("getfileline: skipping comment or blank line\n"));
255                         continue;
256                 }
257
258                 p = (unsigned char *) strchr_m(linebuf, ':');
259                 if (p == NULL)
260                 {
261                         DEBUG(0, ("getfileline: malformed line entry (no :)\n"));
262                         continue;
263                 }
264                 return linebuf_len;
265         }
266         return -1;
267 }
268
269
270 /****************************************************************************
271 read a line from a file with possible \ continuation chars. 
272 Blanks at the start or end of a line are stripped.
273 The string will be allocated if s2 is NULL
274 ****************************************************************************/
275 char *fgets_slash(char *s2,int maxlen,FILE *f)
276 {
277   char *s=s2;
278   int len = 0;
279   int c;
280   BOOL start_of_line = True;
281
282   if (feof(f))
283     return(NULL);
284
285   if (maxlen <2) return(NULL);
286
287   if (!s2)
288     {
289       maxlen = MIN(maxlen,8);
290       s = (char *)Realloc(s,maxlen);
291     }
292
293   if (!s) return(NULL);
294
295   *s = 0;
296
297   while (len < maxlen-1)
298     {
299       c = getc(f);
300       switch (c)
301         {
302         case '\r':
303           break;
304         case '\n':
305           while (len > 0 && s[len-1] == ' ')
306             {
307               s[--len] = 0;
308             }
309           if (len > 0 && s[len-1] == '\\')
310             {
311               s[--len] = 0;
312               start_of_line = True;
313               break;
314             }
315           return(s);
316         case EOF:
317           if (len <= 0 && !s2) 
318             free(s);
319           return(len>0?s:NULL);
320         case ' ':
321           if (start_of_line)
322             break;
323         default:
324           start_of_line = False;
325           s[len++] = c;
326           s[len] = 0;
327         }
328       if (!s2 && len > maxlen-3)
329         {
330           maxlen *= 2;
331           s = (char *)Realloc(s,maxlen);
332           if (!s) return(NULL);
333         }
334     }
335   return(s);
336 }
337
338
339 /****************************************************************************
340 load from a pipe into memory
341 ****************************************************************************/
342 char *file_pload(char *syscmd, size_t *size)
343 {
344         int fd, n;
345         char *p;
346         pstring buf;
347         size_t total;
348         
349         fd = sys_popen(syscmd);
350         if (fd == -1) return NULL;
351
352         p = NULL;
353         total = 0;
354
355         while ((n = read(fd, buf, sizeof(buf))) > 0) {
356                 p = Realloc(p, total + n + 1);
357                 if (!p) {
358                         close(fd);
359                         return NULL;
360                 }
361                 memcpy(p+total, buf, n);
362                 total += n;
363         }
364         if (p) p[total] = 0;
365
366         sys_pclose(fd);
367
368         if (size) *size = total;
369
370         return p;
371 }
372
373 /****************************************************************************
374 load a file into memory from a fd.
375 ****************************************************************************/ 
376
377 char *fd_load(int fd, size_t *size)
378 {
379         SMB_STRUCT_STAT sbuf;
380         char *p;
381
382         if (sys_fstat(fd, &sbuf) != 0) return NULL;
383
384         p = (char *)malloc(sbuf.st_size+1);
385         if (!p) return NULL;
386
387         if (read(fd, p, sbuf.st_size) != sbuf.st_size) {
388                 free(p);
389                 return NULL;
390         }
391         p[sbuf.st_size] = 0;
392
393         if (size) *size = sbuf.st_size;
394
395         return p;
396 }
397
398 /****************************************************************************
399 load a file into memory
400 ****************************************************************************/
401 char *file_load(char *fname, size_t *size)
402 {
403         int fd;
404         char *p;
405
406         if (!fname || !*fname) return NULL;
407         
408         fd = open(fname,O_RDONLY);
409         if (fd == -1) return NULL;
410
411         p = fd_load(fd, size);
412
413         close(fd);
414
415         return p;
416 }
417
418
419 /****************************************************************************
420 parse a buffer into lines
421 ****************************************************************************/
422 static char **file_lines_parse(char *p, size_t size, int *numlines)
423 {
424         int i;
425         char *s, **ret;
426
427         if (!p) return NULL;
428
429         for (s = p, i=0; s < p+size; s++) {
430                 if (s[0] == '\n') i++;
431         }
432
433         ret = (char **)malloc(sizeof(ret[0])*(i+2));
434         if (!ret) {
435                 free(p);
436                 return NULL;
437         }       
438         memset(ret, 0, sizeof(ret[0])*(i+2));
439         if (numlines) *numlines = i;
440
441         ret[0] = p;
442         for (s = p, i=0; s < p+size; s++) {
443                 if (s[0] == '\n') {
444                         s[0] = 0;
445                         i++;
446                         ret[i] = s+1;
447                 }
448                 if (s[0] == '\r') s[0] = 0;
449         }
450
451         return ret;
452 }
453
454
455 /****************************************************************************
456 load a file into memory and return an array of pointers to lines in the file
457 must be freed with file_lines_free(). 
458 ****************************************************************************/
459 char **file_lines_load(char *fname, int *numlines)
460 {
461         char *p;
462         size_t size;
463
464         p = file_load(fname, &size);
465         if (!p) return NULL;
466
467         return file_lines_parse(p, size, numlines);
468 }
469
470 /****************************************************************************
471 load a fd into memory and return an array of pointers to lines in the file
472 must be freed with file_lines_free(). If convert is true calls unix_to_dos on
473 the list.
474 ****************************************************************************/
475 char **fd_lines_load(int fd, int *numlines)
476 {
477         char *p;
478         size_t size;
479
480         p = fd_load(fd, &size);
481         if (!p) return NULL;
482
483         return file_lines_parse(p, size, numlines);
484 }
485
486
487 /****************************************************************************
488 load a pipe into memory and return an array of pointers to lines in the data
489 must be freed with file_lines_free(). 
490 ****************************************************************************/
491 char **file_lines_pload(char *syscmd, int *numlines)
492 {
493         char *p;
494         size_t size;
495
496         p = file_pload(syscmd, &size);
497         if (!p) return NULL;
498
499         return file_lines_parse(p, size, numlines);
500 }
501
502 /****************************************************************************
503 free lines loaded with file_lines_load
504 ****************************************************************************/
505 void file_lines_free(char **lines)
506 {
507         if (!lines) return;
508         free(lines[0]);
509         free(lines);
510 }
511
512
513 /****************************************************************************
514 take a lislist of lines and modify them to produce a list where \ continues
515 a line
516 ****************************************************************************/
517 void file_lines_slashcont(char **lines)
518 {
519         int i, j;
520
521         for (i=0; lines[i];) {
522                 int len = strlen(lines[i]);
523                 if (lines[i][len-1] == '\\') {
524                         lines[i][len-1] = ' ';
525                         if (lines[i+1]) {
526                                 char *p = &lines[i][len];
527                                 while (p < lines[i+1]) *p++ = ' ';
528                                 for (j = i+1; lines[j]; j++) lines[j] = lines[j+1];
529                         }
530                 } else {
531                         i++;
532                 }
533         }
534 }