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