]> arthur.barton.de Git - netatalk.git/blob - libatalk/adouble/ad_open.c
adouble:ea VFS stuff
[netatalk.git] / libatalk / adouble / ad_open.c
1 /*
2  * Copyright (c) 1999 Adrian Sun (asun@u.washington.edu)
3  * Copyright (c) 1990,1991 Regents of The University of Michigan.
4  * Copyright (c) 2010 Frank Lahm
5  *
6  * All Rights Reserved.
7  *
8  * Permission to use, copy, modify, and distribute this software and
9  * its documentation for any purpose and without fee is hereby granted,
10  * provided that the above copyright notice appears in all copies and
11  * that both that copyright notice and this permission notice appear
12  * in supporting documentation, and that the name of The University
13  * of Michigan not be used in advertising or publicity pertaining to
14  * distribution of the software without specific, written prior
15  * permission. This software is supplied as is without expressed or
16  * implied warranties of any kind.
17  *
18  *  Research Systems Unix Group
19  *  The University of Michigan
20  *  c/o Mike Clark
21  *  535 W. William Street
22  *  Ann Arbor, Michigan
23  *  +1-313-763-0525
24  *  netatalk@itd.umich.edu
25  *
26  */
27
28 /*!
29  * @file
30  * Part of Netatalk's AppleDouble implementatation
31  * @sa include/atalk/adouble.h
32  */
33
34 #ifdef HAVE_CONFIG_H
35 #include "config.h"
36 #endif /* HAVE_CONFIG_H */
37
38 #include <errno.h>
39 #include <sys/param.h>
40 #include <stdlib.h>
41 #include <string.h>
42 #include <stdarg.h>
43 #include <arpa/inet.h>
44
45 #include <atalk/logger.h>
46 #include <atalk/adouble.h>
47 #include <atalk/util.h>
48 #include <atalk/ea.h>
49 #include <atalk/bstrlib.h>
50 #include <atalk/bstradd.h>
51 #include <atalk/compat.h>
52 #include <atalk/errchk.h>
53 #include <atalk/volume.h>
54
55 #include "ad_lock.h"
56
57 #define ADEDOFF_MAGIC        (0)
58 #define ADEDOFF_VERSION      (ADEDOFF_MAGIC + ADEDLEN_MAGIC)
59 #define ADEDOFF_FILLER       (ADEDOFF_VERSION + ADEDLEN_VERSION)
60 #define ADEDOFF_NENTRIES     (ADEDOFF_FILLER + ADEDLEN_FILLER)
61
62 /* initial lengths of some of the fields */
63 #define ADEDLEN_INIT     0
64
65 /* i stick things in a slightly different order than their eid order in
66  * case i ever want to separate RootInfo behaviour from the rest of the
67  * stuff. */
68
69 /* ad:v2 */
70 #define ADEDOFF_NAME_V2      (AD_HEADER_LEN + ADEID_NUM_V2*AD_ENTRY_LEN)
71 #define ADEDOFF_COMMENT_V2   (ADEDOFF_NAME_V2 + ADEDLEN_NAME)
72 #define ADEDOFF_FILEDATESI   (ADEDOFF_COMMENT_V2 + ADEDLEN_COMMENT)
73 #define ADEDOFF_FINDERI_V2   (ADEDOFF_FILEDATESI + ADEDLEN_FILEDATESI)
74 #define ADEDOFF_DID          (ADEDOFF_FINDERI_V2 + ADEDLEN_FINDERI)
75 #define ADEDOFF_AFPFILEI     (ADEDOFF_DID + ADEDLEN_DID)
76 #define ADEDOFF_SHORTNAME    (ADEDOFF_AFPFILEI + ADEDLEN_AFPFILEI)
77 #define ADEDOFF_PRODOSFILEI  (ADEDOFF_SHORTNAME + ADEDLEN_SHORTNAME)
78 #define ADEDOFF_PRIVDEV      (ADEDOFF_PRODOSFILEI + ADEDLEN_PRODOSFILEI)
79 #define ADEDOFF_PRIVINO      (ADEDOFF_PRIVDEV + ADEDLEN_PRIVDEV)
80 #define ADEDOFF_PRIVSYN      (ADEDOFF_PRIVINO + ADEDLEN_PRIVINO)
81 #define ADEDOFF_PRIVID       (ADEDOFF_PRIVSYN + ADEDLEN_PRIVSYN)
82 #define ADEDOFF_RFORK_V2     (ADEDOFF_PRIVID + ADEDLEN_PRIVID)
83
84 /* ad:ea */
85 #define ADEDOFF_FINDERI_EA   (AD_HEADER_LEN + ADEID_NUM_EA * AD_ENTRY_LEN)
86 #define ADEDOFF_COMMENT_EA   (ADEDOFF_FINDERI_EA + ADEDLEN_FINDERI)
87 #define ADEDOFF_FILEDATESI_EA (ADEDOFF_COMMENT_EA + ADEDLEN_COMMENT)
88 #define ADEDOFF_AFPFILEI_EA  (ADEDOFF_FILEDATESI_EA + ADEDLEN_FILEDATESI)
89
90 /* this is to prevent changing timezones from causing problems with
91    localtime volumes. the screw-up is 30 years. we use a delta of 5 years */
92 #define TIMEWARP_DELTA 157680000
93
94 struct entry {
95     uint32_t id, offset, len;
96 };
97
98 /* --------------------------- */
99 static uid_t default_uid = -1;
100
101 /* Forward declarations */
102 static int ad_mkrf(const char *path);
103 static int ad_header_read(const char *path, struct adouble *ad, struct stat *hst);
104 static int ad_header_upgrade(struct adouble *ad, const char *name);
105
106 static int ad_mkrf_ea(const char *path);
107 static int ad_header_read_ea(const char *path, struct adouble *ad, struct stat *hst);
108 static int ad_header_upgrade_ea(struct adouble *ad, const char *name);
109
110
111 static const char *ad_path_osx(const char *path, int adflags);
112 static int ad_mkrf_osx(const char *path);
113
114
115 static struct adouble_fops ad_adouble = {
116     &ad_path,
117     &ad_mkrf,
118     &ad_rebuild_adouble_header,
119     &ad_header_read,
120     &ad_header_upgrade,
121 };
122
123 static struct adouble_fops ad_adouble_ea = {
124 #ifdef HAVE_EAFD
125     &ad_path_ea,
126     &ad_mkrf_ea,
127 #else
128     &ad_path_osx,
129     &ad_mkrf_osx,
130 #endif
131     &ad_rebuild_adouble_header,
132     &ad_header_read_ea,
133     &ad_header_upgrade_ea,
134 };
135
136 static struct adouble_fops ad_osx = {
137     &ad_path_osx,
138     &ad_mkrf_osx,
139     &ad_rebuild_adouble_header,
140     &ad_header_read,
141     &ad_header_upgrade,
142 };
143
144 static const struct entry entry_order2[ADEID_NUM_V2 + 1] = {
145     {ADEID_NAME,        ADEDOFF_NAME_V2,     ADEDLEN_INIT},
146     {ADEID_COMMENT,     ADEDOFF_COMMENT_V2,  ADEDLEN_INIT},
147     {ADEID_FILEDATESI,  ADEDOFF_FILEDATESI,  ADEDLEN_FILEDATESI},
148     {ADEID_FINDERI,     ADEDOFF_FINDERI_V2,  ADEDLEN_FINDERI},
149     {ADEID_DID,         ADEDOFF_DID,         ADEDLEN_DID},
150     {ADEID_AFPFILEI,    ADEDOFF_AFPFILEI,    ADEDLEN_AFPFILEI},
151     {ADEID_SHORTNAME,   ADEDOFF_SHORTNAME,   ADEDLEN_INIT},
152     {ADEID_PRODOSFILEI, ADEDOFF_PRODOSFILEI, ADEDLEN_PRODOSFILEI},
153     {ADEID_PRIVDEV,     ADEDOFF_PRIVDEV,     ADEDLEN_INIT},
154     {ADEID_PRIVINO,     ADEDOFF_PRIVINO,     ADEDLEN_INIT},
155     {ADEID_PRIVSYN,     ADEDOFF_PRIVSYN,     ADEDLEN_INIT},
156     {ADEID_PRIVID,      ADEDOFF_PRIVID,      ADEDLEN_INIT},
157     {ADEID_RFORK,       ADEDOFF_RFORK_V2,    ADEDLEN_INIT},
158     {0, 0, 0}
159 };
160
161 /* Using Extended Attributes */
162 static const struct entry entry_order_ea[ADEID_NUM_EA + 1] = {
163     {ADEID_FINDERI,    ADEDOFF_FINDERI_EA,    ADEDLEN_FINDERI},
164     {ADEID_COMMENT,    ADEDOFF_COMMENT_EA,    ADEDLEN_INIT},
165     {ADEID_FILEDATESI, ADEDOFF_FILEDATESI_EA, ADEDLEN_FILEDATESI},
166     {ADEID_AFPFILEI,   ADEDOFF_AFPFILEI_EA,   ADEDLEN_AFPFILEI},
167     {ADEID_PRIVID,     ADEDOFF_PRIVID,        ADEDLEN_INIT},
168     {0, 0, 0}
169 };
170
171 /* fallback for EAs */
172 static const struct entry entry_order_osx[ADEID_NUM_OSX +1] = {
173     {ADEID_FINDERI, ADEDOFF_FINDERI_OSX, ADEDLEN_FINDERI},
174     {ADEID_RFORK, ADEDOFF_RFORK_OSX, ADEDLEN_INIT},
175     {0, 0, 0}
176 };
177
178 #define ADFLAGS2LOGSTRBUFSIZ 128
179 const char *adflags2logstr(int adflags)
180 {
181     int first = 1;
182     static char buf[ADFLAGS2LOGSTRBUFSIZ];
183
184     buf[0] = 0;
185
186     if (adflags & ADFLAGS_DF) {
187         strlcat(buf, "DF", ADFLAGS2LOGSTRBUFSIZ);
188         first = 0;
189     }
190     if (adflags & ADFLAGS_RF) {
191         if (!first)
192             strlcat(buf, "|", ADFLAGS2LOGSTRBUFSIZ);
193         strlcat(buf, "RF", ADFLAGS2LOGSTRBUFSIZ);
194         first = 0;
195     }
196     if (adflags & ADFLAGS_HF) {
197         if (!first)
198             strlcat(buf, "|", ADFLAGS2LOGSTRBUFSIZ);
199         strlcat(buf, "HF", ADFLAGS2LOGSTRBUFSIZ);
200         first = 0;
201     }
202     if (adflags & ADFLAGS_NOHF) {
203         if (!first)
204             strlcat(buf, "|", ADFLAGS2LOGSTRBUFSIZ);
205         strlcat(buf, "NOHF", ADFLAGS2LOGSTRBUFSIZ);
206         first = 0;
207     }
208     if (adflags & ADFLAGS_DIR) {
209         if (!first)
210             strlcat(buf, "|", ADFLAGS2LOGSTRBUFSIZ);
211         strlcat(buf, "DIR", ADFLAGS2LOGSTRBUFSIZ);
212         first = 0;
213     }
214     if (adflags & ADFLAGS_CHECK_OF) {
215         if (!first)
216             strlcat(buf, "|", ADFLAGS2LOGSTRBUFSIZ);
217         strlcat(buf, "OF", ADFLAGS2LOGSTRBUFSIZ);
218         first = 0;
219     }
220     if (adflags & ADFLAGS_RDWR) {
221         if (!first)
222             strlcat(buf, "|", ADFLAGS2LOGSTRBUFSIZ);
223         strlcat(buf, "O_RDWR", ADFLAGS2LOGSTRBUFSIZ);
224         first = 0;
225     }
226     if (adflags & ADFLAGS_RDONLY) {
227         if (!first)
228             strlcat(buf, "|", ADFLAGS2LOGSTRBUFSIZ);
229         strlcat(buf, "O_RDONLY", ADFLAGS2LOGSTRBUFSIZ);
230         first = 0;
231     }
232     if (adflags & ADFLAGS_CREATE) {
233         if (!first)
234             strlcat(buf, "|", ADFLAGS2LOGSTRBUFSIZ);
235         strlcat(buf, "O_CREAT", ADFLAGS2LOGSTRBUFSIZ);
236         first = 0;
237     }
238     if (adflags & ADFLAGS_EXCL) {
239         if (!first)
240             strlcat(buf, "|", ADFLAGS2LOGSTRBUFSIZ);
241         strlcat(buf, "O_EXCL", ADFLAGS2LOGSTRBUFSIZ);
242         first = 0;
243     }
244     if (adflags & ADFLAGS_TRUNC) {
245         if (!first)
246             strlcat(buf, "|", ADFLAGS2LOGSTRBUFSIZ);
247         strlcat(buf, "O_TRUNC", ADFLAGS2LOGSTRBUFSIZ);
248         first = 0;
249     }
250
251     return buf;
252 }
253
254 static uint32_t get_eid(uint32_t eid)
255 {
256     if (eid <= 15)
257         return eid;
258     if (eid == AD_DEV)
259         return ADEID_PRIVDEV;
260     if (eid == AD_INO)
261         return ADEID_PRIVINO;
262     if (eid == AD_SYN)
263         return ADEID_PRIVSYN;
264     if (eid == AD_ID)
265         return ADEID_PRIVID;
266
267     return 0;
268 }
269
270 /* ----------------------------------- */
271 static int new_ad_header(struct adouble *ad, const char *path, struct stat *stp, int adflags)
272 {
273     const struct entry  *eid;
274     uint16_t            ashort;
275     struct stat         st;
276
277     LOG(log_debug, logtype_default, "new_ad_header(\"%s\")", path);
278
279     if (stp == NULL) {
280         stp = &st;
281         if (lstat(path, &st) != 0)
282             return -1;
283     }
284
285     ad->ad_magic = AD_MAGIC;
286     ad->ad_version = ad->ad_vers & 0x0f0000;
287     if (!ad->ad_version) {
288         ad->ad_version = AD_VERSION;
289     }
290
291
292     memset(ad->ad_data, 0, sizeof(ad->ad_data));
293
294     if (ad->ad_vers == AD_VERSION2)
295         eid = entry_order2;
296     else if (ad->ad_vers == AD_VERSION_EA)
297         eid = entry_order_ea;
298     else if (ad->ad_vers == AD_VERSION2_OSX)
299         eid = entry_order_osx;
300     else {
301         return -1;
302     }
303
304     while (eid->id) {
305         ad->ad_eid[eid->id].ade_off = eid->offset;
306         ad->ad_eid[eid->id].ade_len = eid->len;
307         eid++;
308     }
309
310     /* put something sane in the directory finderinfo */
311     if (ad->ad_vers != AD_VERSION2_OSX) {
312         if ((adflags & ADFLAGS_DIR)) {
313             /* set default view */
314             ashort = htons(FINDERINFO_CLOSEDVIEW);
315             memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRVIEWOFF, &ashort, sizeof(ashort));
316         } else {
317             /* set default creator/type fields */
318             memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRTYPEOFF,"\0\0\0\0", 4);
319             memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRCREATOFF,"\0\0\0\0", 4);
320         }
321
322         /* make things invisible */
323         if ((ad->ad_options & ADVOL_INVDOTS) && (*path == '.')) {
324             ashort = htons(ATTRBIT_INVISIBLE);
325             ad_setattr(ad, ashort);
326             ashort = htons(FINDERINFO_INVISIBLE);
327             memcpy(ad_entry(ad, ADEID_FINDERI) + FINDERINFO_FRFLAGOFF, &ashort, sizeof(ashort));
328         }
329
330         /* put something sane in the date fields */
331         ad_setdate(ad, AD_DATE_CREATE | AD_DATE_UNIX, stp->st_mtime);
332         ad_setdate(ad, AD_DATE_MODIFY | AD_DATE_UNIX, stp->st_mtime);
333         ad_setdate(ad, AD_DATE_ACCESS | AD_DATE_UNIX, stp->st_mtime);
334         ad_setdate(ad, AD_DATE_BACKUP, AD_DATE_START);
335     }
336     return 0;
337 }
338
339 /* -------------------------------------
340    read in the entries
341 */
342 static void parse_entries(struct adouble *ad, char *buf, uint16_t nentries)
343 {
344     uint32_t   eid, len, off;
345     int        warning = 0;
346
347     /* now, read in the entry bits */
348     for (; nentries > 0; nentries-- ) {
349         memcpy(&eid, buf, sizeof( eid ));
350         eid = get_eid(ntohl(eid));
351         buf += sizeof( eid );
352         memcpy(&off, buf, sizeof( off ));
353         off = ntohl( off );
354         buf += sizeof( off );
355         memcpy(&len, buf, sizeof( len ));
356         len = ntohl( len );
357         buf += sizeof( len );
358
359         if (eid
360             && eid < ADEID_MAX
361             && off < sizeof(ad->ad_data)
362             && (off + len <= sizeof(ad->ad_data) || eid == ADEID_RFORK)) {
363             ad->ad_eid[ eid ].ade_off = off;
364             ad->ad_eid[ eid ].ade_len = len;
365         } else if (!warning) {
366             warning = 1;
367             LOG(log_warning, logtype_default, "parse_entries: bogus eid: %d", eid);
368         }
369     }
370 }
371
372 /* this reads enough of the header so that we can figure out all of
373  * the entry lengths and offsets. once that's done, we just read/mmap
374  * the rest of the header in.
375  *
376  * NOTE: we're assuming that the resource fork is kept at the end of
377  *       the file. also, mmapping won't work for the hfs fs until it
378  *       understands how to mmap header files. */
379 static int ad_header_read(const char *path _U_, struct adouble *ad, struct stat *hst)
380 {
381     char                *buf = ad->ad_data;
382     uint16_t            nentries;
383     int                 len;
384     ssize_t             header_len;
385     struct stat         st;
386
387     /* read the header */
388     if ((header_len = adf_pread( ad->ad_mdp, buf, AD_DATASZ, 0)) < 0) {
389         return -1;
390     }
391     if (header_len < AD_HEADER_LEN) {
392         errno = EIO;
393         return -1;
394     }
395
396     memcpy(&ad->ad_magic, buf, sizeof( ad->ad_magic ));
397     memcpy(&ad->ad_version, buf + ADEDOFF_VERSION, sizeof( ad->ad_version ));
398     ad->ad_magic = ntohl( ad->ad_magic );
399     ad->ad_version = ntohl( ad->ad_version );
400
401     if ((ad->ad_magic != AD_MAGIC) || (ad->ad_version != AD_VERSION2)) {
402         LOG(log_error, logtype_default, "ad_open: can't parse AppleDouble header.");
403         errno = EIO;
404         return -1;
405     }
406
407     memcpy(&nentries, buf + ADEDOFF_NENTRIES, sizeof( nentries ));
408     nentries = ntohs( nentries );
409
410     /* read in all the entry headers. if we have more than the
411      * maximum, just hope that the rfork is specified early on. */
412     len = nentries*AD_ENTRY_LEN;
413
414     if (len + AD_HEADER_LEN > sizeof(ad->ad_data))
415         len = sizeof(ad->ad_data) - AD_HEADER_LEN;
416
417     buf += AD_HEADER_LEN;
418     if (len > header_len - AD_HEADER_LEN) {
419         LOG(log_error, logtype_default, "ad_header_read: can't read entry info.");
420         errno = EIO;
421         return -1;
422     }
423
424     /* figure out all of the entry offsets and lengths. if we aren't
425      * able to read a resource fork entry, bail. */
426     nentries = len / AD_ENTRY_LEN;
427     parse_entries(ad, buf, nentries);
428     if (!ad_getentryoff(ad, ADEID_RFORK)
429         || (ad_getentryoff(ad, ADEID_RFORK) > sizeof(ad->ad_data))
430         ) {
431         LOG(log_error, logtype_default, "ad_header_read: problem with rfork entry offset.");
432         errno = EIO;
433         return -1;
434     }
435
436     if (ad_getentryoff(ad, ADEID_RFORK) > header_len) {
437         LOG(log_error, logtype_default, "ad_header_read: can't read in entries.");
438         errno = EIO;
439         return -1;
440     }
441
442     if (hst == NULL) {
443         hst = &st;
444         if (fstat(ad->ad_mdp->adf_fd, &st) < 0) {
445             return 1; /* fail silently */
446         }
447     }
448
449     ad->ad_rlen = hst->st_size - ad_getentryoff(ad, ADEID_RFORK);
450
451     return 0;
452 }
453
454 /* Read an ._ file, only uses the resofork, finderinfo is taken from EA */
455 static int ad_header_read_osx(const char *path _U_, struct adouble *ad, struct stat *hst)
456 {
457     EC_INIT;
458     struct adouble      adosx;
459     char                *buf = &adosx.ad_data[0];
460     uint16_t            nentries;
461     int                 len;
462     ssize_t             header_len;
463     struct stat         st;
464
465     memset(buf, 0, sizeof(adosx.ad_data));
466
467     /* read the header */
468     EC_NEG1( header_len = adf_pread(ad->ad_rfp, buf, AD_DATASZ_OSX, 0) );
469
470     if (header_len < AD_HEADER_LEN) {
471         errno = EIO;
472         return -1;
473     }
474
475     memcpy(&adosx.ad_magic, buf, sizeof(adosx.ad_magic));
476     memcpy(&adosx.ad_version, buf + ADEDOFF_VERSION, sizeof(adosx.ad_version));
477     adosx.ad_magic = ntohl(adosx.ad_magic);
478     adosx.ad_version = ntohl(adosx.ad_version);
479
480     if ((adosx.ad_magic != AD_MAGIC) || (adosx.ad_version != AD_VERSION2)) {
481         LOG(log_error, logtype_afpd, "ad_header_read_osx: can't parse AppleDouble header");
482         errno = EIO;
483         return -1;
484     }
485
486     memcpy(&nentries, buf + ADEDOFF_NENTRIES, sizeof( nentries ));
487     nentries = ntohs(nentries);
488     len = nentries * AD_ENTRY_LEN;
489
490     if (len + AD_HEADER_LEN > sizeof(adosx.ad_data))
491         len = sizeof(adosx.ad_data) - AD_HEADER_LEN;
492
493     buf += AD_HEADER_LEN;
494     if (len > header_len - AD_HEADER_LEN) {
495         LOG(log_error, logtype_afpd, "ad_header_read_osx: can't read entry info.");
496         errno = EIO;
497         return -1;
498     }
499
500     nentries = len / AD_ENTRY_LEN;
501     parse_entries(&adosx, buf, nentries);
502
503     if (ad_getentryoff(&adosx, ADEID_RFORK) == 0
504         || ad_getentryoff(&adosx, ADEID_RFORK) > sizeof(ad->ad_data)
505         || ad_getentryoff(&adosx, ADEID_RFORK) > header_len
506         ) {
507         LOG(log_error, logtype_afpd, "ad_header_read_osx: problem with rfork entry offset.");
508         errno = EIO;
509         return -1;
510     }
511
512     if (hst == NULL) {
513         hst = &st;
514         EC_NEG1( fstat(ad_reso_fileno(ad), &st) );
515     }
516
517     ad_setentryoff(ad, ADEID_RFORK, ad_getentryoff(&adosx, ADEID_RFORK));
518     ad->ad_rlen = hst->st_size - ad_getentryoff(ad, ADEID_RFORK);
519
520 EC_CLEANUP:
521     EC_EXIT;
522 }
523
524 static int ad_header_read_ea(const char *path, struct adouble *ad, struct stat *hst _U_)
525 {
526     uint16_t nentries;
527     int      len;
528     ssize_t  header_len;
529     char     *buf = ad->ad_data;
530
531     /* read the header */
532     if ((ad_meta_fileno(ad) == -1)
533         && (ad->ad_adflags & ADFLAGS_RDWR)) {
534         LOG(log_error, logtype_default, "ad_header_read_ea: need filedescriptor for rw access");
535         return -1;
536     }
537
538     if (ad_meta_fileno(ad) != -1)
539         header_len = sys_fgetxattr(ad_meta_fileno(ad), AD_EA_META, ad->ad_data, AD_DATASZ_EA);
540     else
541         header_len = sys_lgetxattr(path, AD_EA_META, ad->ad_data, AD_DATASZ_EA);
542     if (header_len < 1) {
543         LOG(log_debug, logtype_default, "ad_header_read_ea: %s", strerror(errno));
544         return -1;
545     }
546
547     if (header_len < AD_HEADER_LEN) {
548         LOG(log_error, logtype_default, "ad_header_read_ea: bogus AppleDouble header.");
549         errno = EIO;
550         return -1;
551     }
552
553     memcpy(&ad->ad_magic, buf, sizeof( ad->ad_magic ));
554     memcpy(&ad->ad_version, buf + ADEDOFF_VERSION, sizeof( ad->ad_version ));
555
556     ad->ad_magic = ntohl( ad->ad_magic );
557     ad->ad_version = ntohl( ad->ad_version );
558
559     if ((ad->ad_magic != AD_MAGIC) || (ad->ad_version != AD_VERSION2)) {
560         LOG(log_error, logtype_default, "ad_header_read_ea: wrong magic or version");
561         errno = EIO;
562         return -1;
563     }
564
565     memcpy(&nentries, buf + ADEDOFF_NENTRIES, sizeof( nentries ));
566     nentries = ntohs( nentries );
567
568     /* Protect against bogus nentries */
569     len = nentries * AD_ENTRY_LEN;
570     if (len + AD_HEADER_LEN > sizeof(ad->ad_data))
571         len = sizeof(ad->ad_data) - AD_HEADER_LEN;
572     if (len > header_len - AD_HEADER_LEN) {
573         LOG(log_error, logtype_default, "ad_header_read_ea: can't read entry info.");
574         errno = EIO;
575         return -1;
576     }
577     nentries = len / AD_ENTRY_LEN;
578
579     /* Now parse entries */
580     parse_entries(ad, buf + AD_HEADER_LEN, nentries);
581
582     return 0;
583 }
584
585 /*!
586  * Takes a path to an AppleDouble file and creates the parrent .AppleDouble directory
587  *
588  * Example:
589  * path: "/path/.AppleDouble/file"
590  * => mkdir("/path/.AppleDouble/") (in ad_mkdir())
591  */
592 static int ad_mkrf(const char *path)
593 {
594     char *slash;
595     /*
596      * Probably .AppleDouble doesn't exist, try to mkdir it.
597      */
598     if (NULL == ( slash = strrchr( path, '/' )) ) {
599         return -1;
600     }
601     *slash = '\0';
602     errno = 0;
603     if ( ad_mkdir( path, 0777 ) < 0 ) {
604         return -1;
605     }
606     *slash = '/';
607     return 0;
608 }
609
610 static int ad_mkrf_ea(const char *path _U_)
611 {
612     AFP_PANIC("ad_mkrf_ea: dont use");
613     return 0;
614 }
615
616 static int ad_mkrf_osx(const char *path _U_)
617 {
618     return 0;
619 }
620
621 /* ----------------
622    if we are root change path user/ group
623    It can be a native function for BSD cf. FAQ.Q10
624    path:  pathname to chown
625    stbuf: parent directory inode
626
627    use fstat and fchown or lchown with linux?
628 */
629 #define EMULATE_SUIDDIR
630
631 static int ad_chown(const char *path, struct stat *stbuf)
632 {
633     int ret = 0;
634 #ifdef EMULATE_SUIDDIR
635     uid_t id;
636
637     if (default_uid != (uid_t)-1) {
638         /* we are root (admin) */
639         id = (default_uid)?default_uid:stbuf->st_uid;
640         ret = lchown( path, id, stbuf->st_gid );
641     }
642 #endif
643     return ret;
644 }
645
646 #define DEFMASK 07700   /* be conservative */
647
648 /* ----------------
649    return access right and inode of path parent directory
650 */
651 static int ad_mode_st(const char *path, mode_t *mode, struct stat *stbuf)
652 {
653     if (*mode == 0) {
654         return -1;
655     }
656     if (ad_stat(path, stbuf) != 0) {
657         *mode &= DEFMASK;
658         return -1;
659     }
660     *mode &= stbuf->st_mode;
661     return 0;
662 }
663
664 /* --------------------------- */
665 static int ad_header_upgrade(struct adouble *ad _U_, const char *name _U_)
666 {
667     return 0;
668 }
669
670 static int ad_header_upgrade_ea(struct adouble *ad _U_, const char *name _U_)
671 {
672     AFP_PANIC("ad_header_upgrade_ea: dont use");
673     return 0;
674 }
675
676 /*!
677  * Error handling for adouble header(=metadata) file open error
678  *
679  * We're called because opening ADFLAGS_HF caused an error.
680  * 1. In case ad_open is called with ADFLAGS_NOHF the error is suppressed.
681  * 2. If ad_open was called with ADFLAGS_DF we may have opened the datafork and thus
682  *    ought to close it before returning with an error condition.
683  */
684 static int ad_error(struct adouble *ad, int adflags)
685 {
686     int err = errno;
687     if (adflags & ADFLAGS_NOHF) { /* 1 */
688         ad->ad_adflags &= ~ADFLAGS_HF;
689         return 0;
690     }
691     if (adflags & ADFLAGS_DF) { /* 2 */
692         ad_close( ad, ADFLAGS_DF );
693         err = errno;
694     }
695     return -1 ;
696 }
697
698 /* Map ADFLAGS to open() flags */
699 static int ad2openflags(int adflags)
700 {
701     int oflags = 0;
702
703     if (adflags & ADFLAGS_RDWR)
704         oflags |= O_RDWR;
705     if (adflags & ADFLAGS_RDONLY) {
706         if (adflags & ADFLAGS_SETSHRMD)
707             oflags |= O_RDWR;
708         else
709             oflags |= O_RDONLY;
710     }
711     if (adflags & ADFLAGS_CREATE)
712         oflags |= O_CREAT;
713     if (adflags & ADFLAGS_EXCL)
714         oflags |= O_EXCL;
715     if (adflags & ADFLAGS_TRUNC)
716         oflags |= O_TRUNC;
717
718     return oflags;
719 }
720
721 static int ad_open_df(const char *path, int adflags, mode_t mode, struct adouble *ad)
722 {
723     struct stat st_dir;
724     int         oflags;
725     mode_t      admode;
726     int         st_invalid = -1;
727     ssize_t     lsz;
728
729     LOG(log_debug, logtype_default, "ad_open_df(\"%s\", %04o)",
730         fullpathname(path), mode);
731
732     if (ad_data_fileno(ad) != -1) {
733         /* the file is already open, but we want write access: */
734         if ((adflags & ADFLAGS_RDWR)
735             /* and it was denied the first time: */
736             && (ad->ad_data_fork.adf_flags & O_RDONLY)) {
737                 errno = EACCES;
738                 return -1;
739             }
740         /* it's not new anymore */
741         ad->ad_data_fork.adf_flags &= ~( O_TRUNC | O_CREAT );
742         ad->ad_data_fork.adf_refcount++;
743         return 0;
744     }
745
746     oflags = O_NOFOLLOW | ad2openflags(adflags);
747
748     admode = mode;
749     if ((adflags & ADFLAGS_CREATE)) {
750         st_invalid = ad_mode_st(path, &admode, &st_dir);
751         if ((ad->ad_options & ADVOL_UNIXPRIV))
752             admode = mode;
753     }
754
755     ad->ad_data_fork.adf_fd = open(path, oflags, admode);
756
757     if (ad->ad_data_fork.adf_fd == -1) {
758         switch (errno) {
759         case EACCES:
760         case EPERM:
761         case EROFS:
762             if ((adflags & ADFLAGS_SETSHRMD) && (adflags & ADFLAGS_RDONLY)) {
763                 oflags &= ~O_RDWR;
764                 oflags |= O_RDONLY;
765                 if ((ad->ad_data_fork.adf_fd = open(path, oflags, admode)) == -1)
766                     return -1;
767                 break;
768             }
769             return -1;
770         case OPEN_NOFOLLOW_ERRNO:
771             ad->ad_data_fork.adf_syml = malloc(MAXPATHLEN+1);
772             if ((lsz = readlink(path, ad->ad_data_fork.adf_syml, MAXPATHLEN)) <= 0) {
773                 free(ad->ad_data_fork.adf_syml);
774                 return -1;
775             }
776             ad->ad_data_fork.adf_syml[lsz] = 0;
777             ad->ad_data_fork.adf_fd = -2; /* -2 means its a symlink */
778             break;
779         default:
780             return -1;
781         }
782     }
783
784     if (!st_invalid)
785         ad_chown(path, &st_dir); /* just created, set owner if admin (root) */
786
787     ad->ad_data_fork.adf_flags = oflags;
788     adf_lock_init(&ad->ad_data_fork);
789     ad->ad_data_fork.adf_refcount++;
790
791     return 0;
792 }
793
794 /* TODO: error handling */
795 static int ad_open_hf_v2(const char *path, int adflags, mode_t mode, struct adouble *ad)
796 {
797     struct stat st_dir;
798     struct stat st_meta;
799     struct stat *pst = NULL;
800     const char  *ad_p;
801     int         oflags, nocreatflags;
802     mode_t      admode;
803     int         st_invalid = -1;
804
805     if (ad_meta_fileno(ad) != -1) {
806         /* the file is already open, but we want write access: */
807         if ((adflags & ADFLAGS_RDWR) &&
808             /* and it was already denied: */
809             (ad->ad_mdp->adf_flags & O_RDONLY)) {
810             errno = EACCES;
811             return -1;
812         }
813         ad_refresh(path, ad);
814         /* it's not new anymore */
815         ad->ad_mdp->adf_flags &= ~( O_TRUNC | O_CREAT );
816         ad->ad_mdp->adf_refcount++;
817         return 0;
818     }
819
820     ad_p = ad->ad_ops->ad_path(path, adflags);
821     oflags = O_NOFOLLOW | ad2openflags(adflags);
822     nocreatflags = oflags & ~(O_CREAT | O_EXCL);
823
824     ad->ad_mdp->adf_fd = open(ad_p, nocreatflags);
825
826     if (ad->ad_mdp->adf_fd != -1) {
827         ad->ad_mdp->adf_flags = nocreatflags;
828     } else {
829         switch (errno) {
830         case EACCES:
831         case EPERM:
832         case EROFS:
833             if ((adflags & ADFLAGS_RDONLY) && (adflags & ADFLAGS_SETSHRMD)) {
834                 nocreatflags &= ~O_RDWR;
835                 nocreatflags |= O_RDONLY;
836                 if ((ad->ad_mdp->adf_fd = open(ad_p, nocreatflags)) == -1)
837                     return -1;
838                 ad->ad_mdp->adf_flags = nocreatflags;
839                 break;
840             }
841             return -1;
842         case ENOENT:
843             if (!(oflags & O_CREAT))
844                 return ad_error(ad, adflags);
845             /*
846              * We're expecting to create a new adouble header file here
847              */
848             LOG(log_debug, logtype_default, "ad_open(\"%s\"): creating adouble file",
849                 fullpathname(path));
850             admode = mode;
851             errno = 0;
852             st_invalid = ad_mode_st(ad_p, &admode, &st_dir);
853             if ((ad->ad_options & ADVOL_UNIXPRIV))
854                 admode = mode;
855             admode = ad_hf_mode(admode);
856             if ((errno == ENOENT) && (ad->ad_vers != AD_VERSION2_OSX)) {
857                 if (ad->ad_ops->ad_mkrf( ad_p) < 0) {
858                     return ad_error(ad, adflags);
859                 }
860                 admode = mode;
861                 st_invalid = ad_mode_st(ad_p, &admode, &st_dir);
862                 if ((ad->ad_options & ADVOL_UNIXPRIV))
863                     admode = mode;
864                 admode = ad_hf_mode(admode);
865             }
866
867             /* retry with O_CREAT */
868             ad->ad_mdp->adf_fd = open(ad_p, oflags, admode);
869             if ( ad->ad_mdp->adf_fd < 0 )
870                 return ad_error(ad, adflags);
871
872             ad->ad_mdp->adf_flags = oflags;
873             /* just created, set owner if admin owner (root) */
874             if (!st_invalid)
875                 ad_chown(ad_p, &st_dir);
876             break;
877         default:
878             return -1;
879         }
880     }
881
882     if (!(ad->ad_mdp->adf_flags & O_CREAT)) {
883         /* check for 0 length files, treat them as new. */
884         if (fstat(ad->ad_mdp->adf_fd, &st_meta) == 0) {
885             if (st_meta.st_size == 0)
886                 ad->ad_mdp->adf_flags |= O_TRUNC;
887             else
888                 /* we have valid data in st_meta stat structure, reused it in ad_header_read */
889                 pst = &st_meta;
890         }
891     }
892
893     adf_lock_init(ad->ad_mdp);
894     ad->ad_mdp->adf_refcount = 1;
895
896     if ((ad->ad_mdp->adf_flags & ( O_TRUNC | O_CREAT ))) {
897         /* This is a new adouble header file, create it */
898         if (new_ad_header(ad, path, pst, adflags) < 0) {
899             int err = errno;
900             /* the file is already deleted, perm, whatever, so return an error */
901             ad_close(ad, adflags);
902             errno = err;
903             return -1;
904         }
905         ad_flush(ad);
906     } else {
907         /* Read the adouble header in and parse it.*/
908         if (ad->ad_ops->ad_header_read(path, ad, pst) < 0
909             || ad->ad_ops->ad_header_upgrade(ad, ad_p) < 0) {
910             int err = errno;
911             ad_close(ad, adflags);
912             errno = err;
913             return -1;
914         }
915     }
916
917     return 0;
918 }
919
920 /* TODO: error handling */
921 static int ad_open_hf_ea(const char *path, int adflags, int mode, struct adouble *ad)
922 {
923     ssize_t rforklen;
924     int oflags;
925
926     LOG(log_debug, logtype_default, "ad_open_hf_ea(\"%s\", %s, %04o)",
927         path, adflags2logstr(adflags), mode);
928
929     oflags = O_NOFOLLOW | (ad2openflags(adflags) & ~(O_CREAT | O_TRUNC));
930
931     if (ad_meta_fileno(ad) != -1) {
932         /* the file is already open, but we want write access: */
933         if ((adflags & ADFLAGS_RDWR) &&
934             /* and it was already denied: */
935             (ad->ad_mdp->adf_flags & O_RDONLY)) {
936             LOG(log_error, logtype_default, "ad_open_hf_ea(%s): rw request for ro file: %s",
937                 fullpathname(path), strerror(errno));
938             errno = EACCES;
939             return -1;
940         }
941         /* it's not new anymore */
942         ad->ad_mdp->adf_flags &= ~( O_TRUNC | O_CREAT );
943         ad->ad_mdp->adf_refcount++;
944     } else {
945         if (adflags & ADFLAGS_RDWR) {
946             /* Fo a RDONLY adouble we just use sys_lgetxattr instead if sys_fgetxattr */
947             if (adflags & ADFLAGS_DIR)
948                 /* For directories we open the directory RDONYL so we can later fchdir()  */
949                 oflags = (oflags & ~O_RDWR) | O_RDONLY;
950             LOG(log_debug, logtype_default, "ad_open_hf_ea(\"%s\"): opening base file for meta adouble EA", path);
951             if ((ad_meta_fileno(ad) = open(path, oflags)) == -1)
952                 goto error;
953             ad->ad_mdp->adf_flags = oflags;
954         }
955         ad->ad_mdp->adf_refcount = 1;
956     }
957
958     /* Read the adouble header in and parse it.*/
959     if (ad->ad_ops->ad_header_read(path, ad, NULL) != 0) {
960         LOG(log_error, logtype_default, "ad_open_hf_ea: no EA adouble");
961
962         if (!(adflags & ADFLAGS_CREATE))
963             goto error;
964
965         LOG(log_debug, logtype_default, "ad_open_hf_ea(\"%s\"): creating metadata EA", path);
966
967         /* It doesnt exist, EPERM or another error */
968         if (!(errno == ENOATTR || errno == ENOENT)) {
969             LOG(log_error, logtype_default, "ad_open_hf_ea: unexpected: %s", strerror(errno));
970             goto error;
971         }
972
973         /* Create one */
974         if (new_ad_header(ad, path, NULL, adflags) < 0) {
975             LOG(log_error, logtype_default, "ad_open_hf_ea: can't create new header: %s",
976                 fullpathname(path));
977             goto error;
978         }
979         ad->ad_mdp->adf_flags |= O_CREAT; /* mark as just created */
980         ad_flush(ad);
981         LOG(log_debug, logtype_default, "ad_open_hf_ea(\"%s\"): created metadata EA", path);
982     }
983
984     /* TODO: ad_rlen calculation */
985     ad->ad_rlen = 0;
986
987     return 0;
988
989 error:
990     if (ad_meta_fileno(ad) != -1) {
991         close(ad_meta_fileno(ad));
992         ad_meta_fileno(ad) = -1;
993         ad->ad_mdp->adf_refcount = 0;
994     }
995     return ad_error(ad, adflags);
996 }
997
998 static int ad_open_hf(const char *path, int adflags, int mode, struct adouble *ad)
999 {
1000     int ret = 0;
1001
1002     LOG(log_debug, logtype_default, "ad_open_hf(\"%s\", %04o)", path, mode);
1003
1004     memset(ad->ad_eid, 0, sizeof( ad->ad_eid ));
1005     ad->ad_rlen = 0;
1006
1007     switch (ad->ad_vers) {
1008     case AD_VERSION2:
1009         ret = ad_open_hf_v2(path, adflags, mode, ad);
1010         break;
1011     case AD_VERSION_EA:
1012         ret = ad_open_hf_ea(path, adflags, mode, ad);
1013         break;
1014     default:
1015         ret = -1;
1016         break;
1017     }
1018
1019     if (ret != 0) {
1020         return ad_error(ad, adflags);
1021     }
1022     return ret;
1023 }
1024
1025
1026 /*!
1027  * Open ressource fork
1028  *
1029  * Only for adouble:ea, a nullop otherwise because adouble:v2 has the ressource fork as part
1030  * of the adouble file which is openend by ADFLAGS_HF.
1031  */
1032 static int ad_open_rf(const char *path, int adflags, int mode, struct adouble *ad)
1033 {
1034     EC_INIT;
1035     int oflags;
1036     int closeflags = adflags & (ADFLAGS_DF | ADFLAGS_HF);
1037     ssize_t rlen;
1038 #ifndef HAVE_EAFD
1039     const char *rfpath;
1040     struct stat st;
1041 #endif
1042
1043     if (ad->ad_vers != AD_VERSION_EA)
1044         return 0;
1045
1046     LOG(log_debug, logtype_default, "ad_open_rf(\"%s\", %04o)", path, mode);
1047
1048     oflags = O_NOFOLLOW | (ad2openflags(adflags) & ~O_CREAT);
1049
1050     if (ad_reso_fileno(ad) != -1) {
1051         /* the file is already open, but we want write access: */
1052         if ((adflags & ADFLAGS_RDWR)
1053             /* and it was already denied: */
1054             && (ad->ad_rfp->adf_flags & O_RDONLY)) {
1055             errno = EACCES;
1056             return -1;
1057         }
1058         ad->ad_rfp->adf_flags &= ~( O_TRUNC | O_CREAT );
1059         ad->ad_rfp->adf_refcount++;
1060         return 0;
1061     }
1062 #ifdef HAVE_EAFD
1063     if ((ad_reso_fileno(ad) = sys_getxattrfd(path, oflags)) == -1) {
1064         if (!(adflags & ADFLAGS_CREATE))
1065             EC_FAIL;
1066         oflags |= O_CREAT;
1067         EC_NEG1_LOG( ad_reso_fileno(ad) = sys_getxattrfd(path, oflags, 0666) ); 
1068     }
1069 #else
1070     EC_NULL_LOG( rfpath = ad->ad_ops->ad_path(path, adflags) );
1071     if ((ad_reso_fileno(ad) = open(rfpath, oflags)) == -1) {
1072         if (!(adflags & ADFLAGS_CREATE))
1073             EC_FAIL;
1074         oflags |= O_CREAT;
1075         EC_NEG1_LOG( ad_reso_fileno(ad) = open(rfpath, oflags, mode) );
1076         LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): created adouble rfork: \"%s\"",
1077             path, rfpath);
1078     }
1079 #endif
1080
1081     ad->ad_rfp->adf_refcount = 1;
1082     ad->ad_rfp->adf_flags = oflags;
1083
1084 #ifndef HAVE_EAFD
1085     EC_ZERO_LOG( fstat(ad_reso_fileno(ad), &st) );
1086     if (ad->ad_rfp->adf_flags & O_CREAT) {
1087         /* This is a new adouble header file, create it */
1088         LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): created adouble rfork, initializing: \"%s\"",
1089             path, rfpath);
1090 //        EC_NEG1_LOG( new_ad_header(ad, rfpath, &st, adflags) );
1091         LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): created adouble rfork, flushing: \"%s\"",
1092             path, rfpath);
1093         ad_flush(ad);
1094     } else {
1095         /* Read the adouble header */
1096         LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): reading adouble rfork: \"%s\"",
1097             path, rfpath);
1098         EC_NEG1_LOG( ad_header_read_osx(NULL, ad, &st) );
1099     }
1100 #endif
1101
1102 EC_CLEANUP:
1103     if (ret != 0) {
1104         if (ad_reso_fileno(ad) != -1) {
1105             close(ad_reso_fileno(ad));
1106             ad_reso_fileno(ad) = -1;
1107             ad->ad_rfp->adf_refcount = 0;
1108         }
1109         int err = errno;
1110         (void)ad_close(ad, closeflags);
1111         errno = err;
1112         ad->ad_rlen = 0;
1113     }
1114
1115     LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): END", path);
1116
1117     EC_EXIT;
1118 }
1119
1120 /***********************************************************************************
1121  * API functions
1122  ********************************************************************************* */
1123
1124 const char *ad_path_ea( const char *path, int adflags _U_)
1125 {
1126     return path;
1127 }
1128
1129 const char *ad_path_osx(const char *path, int adflags _U_)
1130 {
1131     static char pathbuf[ MAXPATHLEN + 1];
1132     char    c, *slash, buf[MAXPATHLEN + 1];
1133
1134     if (!strcmp(path,".")) {
1135         /* fixme */
1136         getcwd(buf, MAXPATHLEN);
1137     }
1138     else {
1139         strlcpy(buf, path, MAXPATHLEN +1);
1140     }
1141     if (NULL != ( slash = strrchr( buf, '/' )) ) {
1142         c = *++slash;
1143         *slash = '\0';
1144         strlcpy( pathbuf, buf, MAXPATHLEN +1);
1145         *slash = c;
1146     } else {
1147         pathbuf[ 0 ] = '\0';
1148         slash = buf;
1149     }
1150     strlcat( pathbuf, "._", MAXPATHLEN  +1);
1151     strlcat( pathbuf, slash, MAXPATHLEN +1);
1152     return pathbuf;
1153 }
1154
1155 /*
1156  * Put the .AppleDouble where it needs to be:
1157  *
1158  *      /   a/.AppleDouble/b
1159  *  a/b
1160  *      \   b/.AppleDouble/.Parent
1161  *
1162  * FIXME: should do something for pathname > MAXPATHLEN
1163  */
1164 const char *ad_path( const char *path, int adflags)
1165 {
1166     static char pathbuf[ MAXPATHLEN + 1];
1167     const char *slash;
1168     size_t  l ;
1169
1170     if ( adflags & ADFLAGS_DIR ) {
1171         l = strlcpy( pathbuf, path, sizeof(pathbuf));
1172
1173         if ( l && l < MAXPATHLEN) {
1174             pathbuf[l++] = '/';
1175         }
1176         strlcpy(pathbuf +l, ".AppleDouble/.Parent", sizeof(pathbuf) -l);
1177     } else {
1178         if (NULL != ( slash = strrchr( path, '/' )) ) {
1179             slash++;
1180             l = slash - path;
1181             /* XXX we must return NULL here and test in the caller */
1182             if (l > MAXPATHLEN)
1183                 l = MAXPATHLEN;
1184             memcpy( pathbuf, path, l);
1185         } else {
1186             l = 0;
1187             slash = path;
1188         }
1189         l += strlcpy( pathbuf +l, ".AppleDouble/", sizeof(pathbuf) -l);
1190         strlcpy( pathbuf + l, slash, sizeof(pathbuf) -l);
1191     }
1192
1193     return( pathbuf );
1194 }
1195
1196 /* -------------------------
1197  * Support inherited protection modes for AppleDouble files.  The supplied
1198  * mode is ANDed with the parent directory's mask value in lieu of "umask",
1199  * and that value is returned.
1200  */
1201 char *ad_dir(const char *path)
1202 {
1203     static char     modebuf[ MAXPATHLEN + 1];
1204     char        *slash;
1205     /*
1206      * For a path with directories in it, remove the final component
1207      * (path or subdirectory name) to get the name we want to stat.
1208      * For a path which is just a filename, use "." instead.
1209      */
1210     slash = strrchr( path, '/' );
1211     if (slash) {
1212         size_t len;
1213
1214         len = slash - path;
1215         if (len >= MAXPATHLEN) {
1216             errno = ENAMETOOLONG;
1217             return NULL;  /* can't do it */
1218         }
1219         memcpy( modebuf, path, len );
1220         modebuf[len] = '\0';
1221         /* is last char a '/' ? */
1222         if (slash[1] == 0) {
1223             slash = modebuf+ len;
1224             /* remove them */
1225             while (modebuf < slash && slash[-1] == '/') {
1226                 --slash;
1227             }
1228             if (modebuf == slash) {
1229                 goto use_cur;
1230             }
1231             *slash = '\0';
1232             while (modebuf < slash && *slash != '/') {
1233                 --slash;
1234             }
1235             if (modebuf == slash) {
1236                 goto use_cur;
1237             }
1238             *slash = '\0';      /* remove pathname component */
1239         }
1240         return modebuf;
1241     }
1242 use_cur:
1243     modebuf[0] = '.';   /* use current directory */
1244     modebuf[1] = '\0';
1245     return modebuf;
1246 }
1247
1248 int ad_setfuid(const uid_t id)
1249 {
1250     default_uid = id;
1251     return 0;
1252 }
1253
1254 /* ---------------- */
1255 uid_t ad_getfuid(void)
1256 {
1257     return default_uid;
1258 }
1259
1260 /* ----------------
1261    stat path parent directory
1262 */
1263 int ad_stat(const char *path, struct stat *stbuf)
1264 {
1265     char *p;
1266
1267     p = ad_dir(path);
1268     if (!p)
1269         return -1;
1270     return lstat( p, stbuf );
1271 }
1272
1273 /* ----------------
1274    return access right of path parent directory
1275 */
1276 int ad_mode( const char *path, mode_t mode)
1277 {
1278     struct stat     stbuf;
1279     ad_mode_st(path, &mode, &stbuf);
1280     return mode;
1281 }
1282
1283 /*
1284  * Use mkdir() with mode bits taken from ad_mode().
1285  */
1286 int ad_mkdir( const char *path, mode_t mode)
1287 {
1288     int ret;
1289     int st_invalid;
1290     struct stat stbuf;
1291
1292     LOG(log_debug, logtype_default, "ad_mkdir(\"%s\", %04o) {cwd: \"%s\"}",
1293         path, mode, getcwdpath());
1294
1295     st_invalid = ad_mode_st(path, &mode, &stbuf);
1296     ret = mkdir( path, mode );
1297     if (ret || st_invalid)
1298         return ret;
1299     ad_chown(path, &stbuf);
1300
1301     return ret;
1302 }
1303
1304 static void ad_init_func(struct adouble *ad)
1305 {
1306     switch (ad->ad_vers) {
1307     case AD_VERSION2:
1308         ad->ad_ops = &ad_adouble;
1309         ad->ad_rfp = &ad->ad_resource_fork;
1310         ad->ad_mdp = &ad->ad_resource_fork;
1311         break;
1312     case AD_VERSION_EA:
1313         ad->ad_ops = &ad_adouble_ea;
1314         ad->ad_rfp = &ad->ad_resource_fork;
1315         ad->ad_mdp = &ad->ad_data_fork;
1316         break;
1317     default:
1318         AFP_PANIC("ad_init: unknown AD version");
1319     }
1320
1321
1322     ad_data_fileno(ad) = -1;
1323     ad_reso_fileno(ad) = -1;
1324     ad_meta_fileno(ad) = -1;
1325     ad->ad_refcount = 1;
1326     return;
1327 }
1328
1329 void ad_init_old(struct adouble *ad, int flags, int options)
1330 {
1331     memset(ad, 0, sizeof(struct adouble));
1332     ad->ad_vers = flags;
1333     ad->ad_options = options;
1334     ad_init_func(ad);
1335 }
1336
1337 void ad_init(struct adouble *ad, const struct vol * restrict vol)
1338 {
1339     memset(ad, 0, sizeof(struct adouble));
1340     ad->ad_vers = vol->v_adouble;
1341     ad->ad_options = vol->v_ad_options;
1342     ad_init_func(ad);
1343 }
1344
1345 /*!
1346  * Open data-, metadata(header)- or ressource fork
1347  *
1348  * ad_open(struct adouble *ad, const char *path, int adflags, int flags)
1349  * ad_open(struct adouble *ad, const char *path, int adflags, int flags, mode_t mode)
1350  *
1351  * You must call ad_init() before ad_open, usually you'll just call it like this: \n
1352  * @code
1353  *      struct adoube ad;
1354  *      ad_init(&ad, vol->v_adouble, vol->v_ad_options);
1355  * @endcode
1356  *
1357  * Open a files data fork, metadata fork or ressource fork.
1358  *
1359  * @param ad        (rw) pointer to struct adouble
1360  * @param path      (r)  Path to file or directory
1361  * @param adflags   (r)  Flags specifying which fork to open, can be or'd:
1362  *                         ADFLAGS_DF:        open data fork
1363  *                         ADFLAGS_RF:        open ressource fork
1364  *                         ADFLAGS_HF:        open header (metadata) file
1365  *                         ADFLAGS_NOHF:      it's not an error if header file couldn't be created
1366  *                         ADFLAGS_DIR:       if path is a directory you MUST or ADFLAGS_DIR to adflags
1367  *
1368  *                       Access mode for the forks:
1369  *                         ADFLAGS_RDONLY:    open read only
1370  *                         ADFLAGS_RDWR:      open read write
1371  *
1372  *                       Creation flags:
1373  *                         ADFLAGS_CREATE:    create if not existing
1374  *                         ADFLAGS_TRUNC:     truncate
1375  *
1376  *                       Special flags:
1377  *                         ADFLAGS_CHECK_OF:  check for open forks from us and other afpd's
1378  *                         ADFLAGS_SETSHRMD:  this adouble struct will be used to set sharemode locks.
1379  *                                            This basically results in the files being opened RW instead of RDONLY.
1380  * @param mode      (r)  mode used with O_CREATE
1381  *
1382  * The open mode flags (rw vs ro) have to take into account all the following requirements:
1383  * - we remember open fds for files because me must avoid a single close releasing fcntl locks for other
1384  *   fds of the same file
1385  *
1386  * @returns 0 on success, any other value indicates an error
1387  */
1388 int ad_open(struct adouble *ad, const char *path, int adflags, ...)
1389 {
1390     EC_INIT;
1391     va_list args;
1392     mode_t mode = 0;
1393
1394     LOG(log_debug, logtype_default, "ad_open(\"%s\", %s)",
1395         fullpathname(path), adflags2logstr(adflags));
1396
1397     if (adflags & ADFLAGS_CHECK_OF)
1398         /* Checking for open forks requires sharemode lock support (ie RDWR instead of RDONLY) */
1399         adflags |= ADFLAGS_SETSHRMD;
1400
1401     if ((ad->ad_vers == AD_VERSION_EA) && (adflags & ADFLAGS_SETSHRMD))
1402         /* adouble:ea sets sharemode locks on the datafork */
1403         adflags |= ADFLAGS_DF;
1404
1405     if (ad->ad_inited != AD_INITED) {
1406         ad->ad_adflags = adflags;
1407         ad->ad_inited = AD_INITED;
1408     } else {
1409         ad->ad_open_forks = ((ad->ad_data_fork.adf_refcount > 0) ? ATTRBIT_DOPEN : 0);
1410         if (ad->ad_resource_fork.adf_refcount > 0)
1411             ad->ad_open_forks |= ATTRBIT_ROPEN;
1412     }
1413
1414     va_start(args, adflags);
1415     if (adflags & ADFLAGS_CREATE)
1416         mode = va_arg(args, mode_t);
1417     va_end(args);
1418
1419     if (adflags & ADFLAGS_DF) {
1420         EC_ZERO( ad_open_df(path, adflags, mode, ad) );
1421         ad->ad_adflags |= ADFLAGS_DF;
1422     }
1423
1424     if (adflags & ADFLAGS_HF) {
1425         EC_ZERO( ad_open_hf(path, adflags, mode, ad) );
1426         ad->ad_adflags |= ADFLAGS_HF;
1427     }
1428
1429     if (adflags & ADFLAGS_RF) {
1430         EC_ZERO( ad_open_rf(path, adflags, mode, ad) );
1431         ad->ad_adflags |= ADFLAGS_RF;
1432     }
1433
1434     if (adflags & ADFLAGS_CHECK_OF) {
1435         ad->ad_open_forks |= ad_openforks(ad, ad->ad_open_forks);
1436     }
1437
1438 EC_CLEANUP:
1439     return ret;
1440 }
1441
1442 /*!
1443  * @brief open metadata, possibly as root
1444  *
1445  * Return only metadata but try very hard ie at first try as user, then try as root.
1446  *
1447  * @param name  name of file/dir
1448  * @param flags ADFLAGS_DIR: name is a directory \n
1449  *              ADFLAGS_CHECK_OF: test if name is open by us or another afpd process
1450  *
1451  * @param adp   pointer to struct adouble
1452  */
1453 int ad_metadata(const char *name, int flags, struct adouble *adp)
1454 {
1455     uid_t uid;
1456     int   ret, err, oflags;
1457
1458     /* Sanitize flags */
1459     oflags = (flags & (ADFLAGS_CHECK_OF | ADFLAGS_DIR)) | ADFLAGS_HF | ADFLAGS_RDONLY;    
1460
1461     if ((ret = ad_open(adp, name, oflags)) < 0 && errno == EACCES) {
1462         uid = geteuid();
1463         if (seteuid(0)) {
1464             LOG(log_error, logtype_default, "ad_metadata(%s): seteuid failed %s", name, strerror(errno));
1465             errno = EACCES;
1466             return -1;
1467         }
1468         /* we are root open read only */
1469         ret = ad_open(adp, name, oflags);
1470         err = errno;
1471         if ( seteuid(uid) < 0) {
1472             LOG(log_error, logtype_default, "ad_metadata: can't seteuid back");
1473             exit(EXITERR_SYS);
1474         }
1475         errno = err;
1476     }
1477
1478     return ret;
1479 }
1480
1481 /*
1482  * @brief openat like wrapper for ad_metadata
1483  */
1484 int ad_metadataat(int dirfd, const char *name, int flags, struct adouble *adp)
1485 {
1486     int ret = 0;
1487     int cwdfd = -1;
1488
1489     if (dirfd != -1) {
1490         if ((cwdfd = open(".", O_RDONLY) == -1) || (fchdir(dirfd) != 0)) {
1491             ret = -1;
1492             goto exit;
1493         }
1494     }
1495
1496     if (ad_metadata(name, flags, adp) < 0) {
1497         ret = -1;
1498         goto exit;
1499     }
1500
1501     if (dirfd != -1) {
1502         if (fchdir(cwdfd) != 0) {
1503             LOG(log_error, logtype_afpd, "ad_openat: cant chdir back, exiting");
1504             exit(EXITERR_SYS);
1505         }
1506     }
1507
1508 exit:
1509     if (cwdfd != -1)
1510         close(cwdfd);
1511
1512     return ret;
1513
1514 }
1515
1516 int ad_refresh(const char *path, struct adouble *ad)
1517 {
1518     switch (ad->ad_vers) {
1519     case AD_VERSION2:
1520         if (ad_meta_fileno(ad) == -1)
1521             return -1;
1522         return ad->ad_ops->ad_header_read(NULL, ad, NULL);
1523         break;
1524     case AD_VERSION_EA:
1525 #ifdef HAVE_EAFD
1526         if (AD_META_OPEN(ad)) {
1527             if (ad_data_fileno(ad) == -1)
1528                 return -1;
1529             // TODO: read meta EA
1530         }
1531
1532         if (AD_RSRC_OPEN(ad)) {
1533             if (ad_reso_fileno(ad) == -1)
1534                 return -1;
1535             ssize_t len;
1536             if ((len = fstat(ad_reso_fileno(ad))) == -1)
1537                 return -1;
1538             ad->ad_rlen = len;
1539         }
1540 #else
1541         if (AD_META_OPEN(ad)) {
1542             if (ad_data_fileno(ad) == -1)
1543                 return -1;
1544             // TODO: read meta EA
1545         }
1546         if (AD_RSRC_OPEN(ad)) {
1547             if (ad_reso_fileno(ad) == -1)
1548                 return -1;
1549             if (ad_header_read_osx(path, ad, NULL) < 0)
1550                 return -1;
1551         }
1552 #endif
1553         return ad->ad_ops->ad_header_read(path, ad, NULL);
1554         break;
1555     default:
1556         return -1;
1557         break;
1558     }
1559
1560 }
1561
1562 int ad_openat(struct adouble  *ad,
1563               int dirfd,  /* dir fd openat like */
1564               const char *path,
1565               int adflags, ...)
1566 {
1567     EC_INIT;
1568     int cwdfd = -1;
1569     va_list args;
1570     mode_t mode;
1571
1572     if (dirfd != -1) {
1573         if ((cwdfd = open(".", O_RDONLY) == -1) || (fchdir(dirfd) != 0))
1574             EC_FAIL;
1575     }
1576
1577     va_start(args, adflags);
1578     if (adflags & ADFLAGS_CREATE)
1579         mode = va_arg(args, mode_t);
1580     va_end(args);
1581
1582     EC_NEG1( ad_open(ad, path, adflags, mode) );
1583
1584     if (dirfd != -1) {
1585         if (fchdir(cwdfd) != 0) {
1586             AFP_PANIC("ad_openat: cant chdir back");
1587         }
1588     }
1589
1590 EC_CLEANUP:
1591     if (cwdfd != -1)
1592         close(cwdfd);
1593
1594     return ret;
1595 }