]> arthur.barton.de Git - netatalk.git/blob - libatalk/adouble/ad_open.c
Correct handling of adflags NOXX for adouble:v2
[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 static int ad_open_rf_v2(const char *path, int adflags, int mode, struct adouble *ad)
1151 {
1152     /*
1153      * ad_open_hf_v2() does the work, but if it failed and adflags are ADFLAGS_NOHF | ADFLAGS_RF
1154      * ad_open_hf_v2() didn't give an error, but we're supposed to return a reso fork fd
1155      */
1156     if (!AD_RSRC_OPEN(ad) && !(adflags & ADFLAGS_NORF))
1157         return -1;
1158     return 0;
1159 }
1160
1161 static int ad_open_rf_ea(const char *path, int adflags, int mode, struct adouble *ad)
1162 {
1163     EC_INIT;
1164     int oflags;
1165     int opened = 0;
1166     int closeflags = adflags & (ADFLAGS_DF | ADFLAGS_HF);
1167     ssize_t rlen;
1168 #ifndef HAVE_EAFD
1169     const char *rfpath;
1170     struct stat st;
1171 #endif
1172
1173     LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): BEGIN", fullpathname(path));
1174
1175     oflags = O_NOFOLLOW | (ad2openflags(ad, ADFLAGS_RF, adflags) & ~O_CREAT);
1176
1177     if (ad_reso_fileno(ad) != -1) {
1178         /* the file is already open, but we want write access: */
1179         if ((oflags & O_RDWR)
1180             /* and it was already denied: */
1181             && (ad->ad_rfp->adf_flags & O_RDONLY)) {
1182             errno = EACCES;
1183             EC_FAIL;
1184         }
1185         ad->ad_rfp->adf_flags &= ~( O_TRUNC | O_CREAT );
1186         ad->ad_rfp->adf_refcount++;
1187         EC_NEG1_LOG( ad_reso_size(path, adflags, ad));
1188         goto EC_CLEANUP;
1189     }
1190 #ifdef HAVE_EAFD
1191     if (ad_meta_fileno(ad) == -1)
1192         EC_FAIL;
1193     if ((ad_reso_fileno(ad) = sys_getxattrfd(ad_meta_fileno(ad), AD_EA_RESO, oflags)) == -1) {
1194         if (!(adflags & ADFLAGS_CREATE)) {
1195             errno = ENOENT;
1196             EC_FAIL;
1197         }
1198         oflags |= O_CREAT;
1199         EC_NEG1_LOG( ad_reso_fileno(ad) = sys_getxattrfd(ad_meta_fileno(ad),
1200                                                          AD_EA_RESO, oflags, 0666) ); 
1201     }
1202 #else
1203     EC_NULL_LOG( rfpath = ad->ad_ops->ad_path(path, adflags) );
1204     if ((ad_reso_fileno(ad) = open(rfpath, oflags)) == -1) {
1205         if (!(adflags & ADFLAGS_CREATE))
1206             EC_FAIL;
1207         oflags |= O_CREAT;
1208         EC_NEG1_LOG( ad_reso_fileno(ad) = open(rfpath, oflags, mode) );
1209         LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): created adouble rfork: \"%s\"",
1210             path, rfpath);
1211     }
1212 #endif
1213     opened = 1;
1214     ad->ad_rfp->adf_refcount = 1;
1215     ad->ad_rfp->adf_flags = oflags;
1216
1217 #ifndef HAVE_EAFD
1218     EC_ZERO_LOG( fstat(ad_reso_fileno(ad), &st) );
1219     if (ad->ad_rfp->adf_flags & O_CREAT) {
1220         /* This is a new adouble header file, create it */
1221         LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): created adouble rfork, initializing: \"%s\"",
1222             path, rfpath);
1223         LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): created adouble rfork, flushing: \"%s\"",
1224             path, rfpath);
1225         ad_flush(ad);
1226     } else {
1227         /* Read the adouble header */
1228         LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): reading adouble rfork: \"%s\"",
1229             path, rfpath);
1230         EC_NEG1_LOG( ad_header_read_osx(NULL, ad, &st) );
1231     }
1232 #endif
1233
1234     (void)ad_reso_size(path, adflags, ad);
1235
1236 EC_CLEANUP:
1237     if (ret != 0) {
1238         if (opened && (ad_reso_fileno(ad) != -1)) {
1239             close(ad_reso_fileno(ad));
1240             ad_reso_fileno(ad) = -1;
1241             ad->ad_rfp->adf_refcount = 0;
1242         }
1243         if (adflags & ADFLAGS_NORF) {
1244             ret = 0;
1245         } else {
1246             int err = errno;
1247             (void)ad_close(ad, closeflags);
1248             errno = err;
1249         }
1250         ad->ad_rlen = 0;
1251     }
1252
1253     LOG(log_debug, logtype_default, "ad_open_rf(\"%s\"): END: %d", fullpathname(path), ret);
1254
1255     EC_EXIT;
1256 }
1257
1258 /*!
1259  * Open ressource fork
1260  */
1261 static int ad_open_rf(const char *path, int adflags, int mode, struct adouble *ad)
1262 {
1263     int ret = 0;
1264
1265     switch (ad->ad_vers) {
1266     case AD_VERSION2:
1267         ret = ad_open_rf_v2(path, adflags, mode, ad);
1268         break;
1269     case AD_VERSION_EA:
1270         ret = ad_open_rf_ea(path, adflags, mode, ad);
1271         break;
1272     default:
1273         ret = -1;
1274         break;
1275     }
1276
1277     return ret;
1278 }
1279
1280 /***********************************************************************************
1281  * API functions
1282  ********************************************************************************* */
1283
1284 off_t ad_getentryoff(const struct adouble *ad, int eid)
1285 {
1286     if (ad->ad_vers == AD_VERSION2)
1287         return ad->ad_eid[eid].ade_off;
1288
1289     switch (eid) {
1290     case ADEID_DFORK:
1291         return 0;
1292     case ADEID_RFORK:
1293 #ifdef HAVE_EAFD
1294         return 0;
1295 #else
1296         return ADEDOFF_RFORK_OSX;
1297 #endif
1298     default:
1299         return ad->ad_eid[eid].ade_off;
1300     }
1301     /* deadc0de */
1302     AFP_PANIC("What am I doing here?");
1303 }
1304
1305 const char *ad_path_ea( const char *path, int adflags _U_)
1306 {
1307     return path;
1308 }
1309
1310 const char *ad_path_osx(const char *path, int adflags _U_)
1311 {
1312     static char pathbuf[ MAXPATHLEN + 1];
1313     char    c, *slash, buf[MAXPATHLEN + 1];
1314
1315     if (!strcmp(path,".")) {
1316         /* fixme */
1317         getcwd(buf, MAXPATHLEN);
1318     }
1319     else {
1320         strlcpy(buf, path, MAXPATHLEN +1);
1321     }
1322     if (NULL != ( slash = strrchr( buf, '/' )) ) {
1323         c = *++slash;
1324         *slash = '\0';
1325         strlcpy( pathbuf, buf, MAXPATHLEN +1);
1326         *slash = c;
1327     } else {
1328         pathbuf[ 0 ] = '\0';
1329         slash = buf;
1330     }
1331     strlcat( pathbuf, "._", MAXPATHLEN  +1);
1332     strlcat( pathbuf, slash, MAXPATHLEN +1);
1333     return pathbuf;
1334 }
1335
1336 /*
1337  * Put the .AppleDouble where it needs to be:
1338  *
1339  *      /   a/.AppleDouble/b
1340  *  a/b
1341  *      \   b/.AppleDouble/.Parent
1342  *
1343  * FIXME: should do something for pathname > MAXPATHLEN
1344  */
1345 const char *ad_path( const char *path, int adflags)
1346 {
1347     static char pathbuf[ MAXPATHLEN + 1];
1348     const char *slash;
1349     size_t  l ;
1350
1351     if ( adflags & ADFLAGS_DIR ) {
1352         l = strlcpy( pathbuf, path, sizeof(pathbuf));
1353
1354         if ( l && l < MAXPATHLEN) {
1355             pathbuf[l++] = '/';
1356         }
1357         strlcpy(pathbuf +l, ".AppleDouble/.Parent", sizeof(pathbuf) -l);
1358     } else {
1359         if (NULL != ( slash = strrchr( path, '/' )) ) {
1360             slash++;
1361             l = slash - path;
1362             /* XXX we must return NULL here and test in the caller */
1363             if (l > MAXPATHLEN)
1364                 l = MAXPATHLEN;
1365             memcpy( pathbuf, path, l);
1366         } else {
1367             l = 0;
1368             slash = path;
1369         }
1370         l += strlcpy( pathbuf +l, ".AppleDouble/", sizeof(pathbuf) -l);
1371         strlcpy( pathbuf + l, slash, sizeof(pathbuf) -l);
1372     }
1373
1374     return( pathbuf );
1375 }
1376
1377 /* -------------------------
1378  * Support inherited protection modes for AppleDouble files.  The supplied
1379  * mode is ANDed with the parent directory's mask value in lieu of "umask",
1380  * and that value is returned.
1381  */
1382 char *ad_dir(const char *path)
1383 {
1384     static char     modebuf[ MAXPATHLEN + 1];
1385     char        *slash;
1386     /*
1387      * For a path with directories in it, remove the final component
1388      * (path or subdirectory name) to get the name we want to stat.
1389      * For a path which is just a filename, use "." instead.
1390      */
1391     slash = strrchr( path, '/' );
1392     if (slash) {
1393         size_t len;
1394
1395         len = slash - path;
1396         if (len >= MAXPATHLEN) {
1397             errno = ENAMETOOLONG;
1398             return NULL;  /* can't do it */
1399         }
1400         memcpy( modebuf, path, len );
1401         modebuf[len] = '\0';
1402         /* is last char a '/' ? */
1403         if (slash[1] == 0) {
1404             slash = modebuf+ len;
1405             /* remove them */
1406             while (modebuf < slash && slash[-1] == '/') {
1407                 --slash;
1408             }
1409             if (modebuf == slash) {
1410                 goto use_cur;
1411             }
1412             *slash = '\0';
1413             while (modebuf < slash && *slash != '/') {
1414                 --slash;
1415             }
1416             if (modebuf == slash) {
1417                 goto use_cur;
1418             }
1419             *slash = '\0';      /* remove pathname component */
1420         }
1421         return modebuf;
1422     }
1423 use_cur:
1424     modebuf[0] = '.';   /* use current directory */
1425     modebuf[1] = '\0';
1426     return modebuf;
1427 }
1428
1429 int ad_setfuid(const uid_t id)
1430 {
1431     default_uid = id;
1432     return 0;
1433 }
1434
1435 /* ---------------- */
1436 uid_t ad_getfuid(void)
1437 {
1438     return default_uid;
1439 }
1440
1441 /* ----------------
1442    stat path parent directory
1443 */
1444 int ad_stat(const char *path, struct stat *stbuf)
1445 {
1446     char *p;
1447
1448     p = ad_dir(path);
1449     if (!p)
1450         return -1;
1451     return lstat( p, stbuf );
1452 }
1453
1454 /* ----------------
1455    return access right of path parent directory
1456 */
1457 int ad_mode( const char *path, mode_t mode)
1458 {
1459     struct stat     stbuf;
1460     ad_mode_st(path, &mode, &stbuf);
1461     return mode;
1462 }
1463
1464 /*
1465  * Use mkdir() with mode bits taken from ad_mode().
1466  */
1467 int ad_mkdir( const char *path, mode_t mode)
1468 {
1469     int ret;
1470     int st_invalid;
1471     struct stat stbuf;
1472
1473     LOG(log_debug, logtype_default, "ad_mkdir(\"%s\", %04o) {cwd: \"%s\"}",
1474         path, mode, getcwdpath());
1475
1476     st_invalid = ad_mode_st(path, &mode, &stbuf);
1477     ret = mkdir( path, mode );
1478     if (ret || st_invalid)
1479         return ret;
1480     ad_chown(path, &stbuf);
1481
1482     return ret;
1483 }
1484
1485 static void ad_init_func(struct adouble *ad)
1486 {
1487     switch (ad->ad_vers) {
1488     case AD_VERSION2:
1489         ad->ad_ops = &ad_adouble;
1490         ad->ad_rfp = &ad->ad_resource_fork;
1491         ad->ad_mdp = &ad->ad_resource_fork;
1492         break;
1493     case AD_VERSION_EA:
1494         ad->ad_ops = &ad_adouble_ea;
1495         ad->ad_rfp = &ad->ad_resource_fork;
1496         ad->ad_mdp = &ad->ad_data_fork;
1497         break;
1498     default:
1499         AFP_PANIC("ad_init: unknown AD version");
1500     }
1501
1502
1503     ad_data_fileno(ad) = -1;
1504     ad_reso_fileno(ad) = -1;
1505     ad_meta_fileno(ad) = -1;
1506     ad->ad_refcount = 1;
1507     return;
1508 }
1509
1510 void ad_init_old(struct adouble *ad, int flags, int options)
1511 {
1512     memset(ad, 0, sizeof(struct adouble));
1513     ad->ad_vers = flags;
1514     ad->ad_options = options;
1515     ad_init_func(ad);
1516 }
1517
1518 void ad_init(struct adouble *ad, const struct vol * restrict vol)
1519 {
1520     memset(ad, 0, sizeof(struct adouble));
1521     ad->ad_vers = vol->v_adouble;
1522     ad->ad_options = vol->v_ad_options;
1523     ad_init_func(ad);
1524 }
1525
1526 /*!
1527  * Open data-, metadata(header)- or ressource fork
1528  *
1529  * ad_open(struct adouble *ad, const char *path, int adflags, int flags)
1530  * ad_open(struct adouble *ad, const char *path, int adflags, int flags, mode_t mode)
1531  *
1532  * You must call ad_init() before ad_open, usually you'll just call it like this: \n
1533  * @code
1534  *      struct adoube ad;
1535  *      ad_init(&ad, vol->v_adouble, vol->v_ad_options);
1536  * @endcode
1537  *
1538  * Open a files data fork, metadata fork or ressource fork.
1539  *
1540  * @param ad        (rw) pointer to struct adouble
1541  * @param path      (r)  Path to file or directory
1542  * @param adflags   (r)  Flags specifying which fork to open, can be or'd:
1543  *                         ADFLAGS_DF:        open data fork
1544  *                         ADFLAGS_RF:        open ressource fork
1545  *                         ADFLAGS_HF:        open header (metadata) file
1546  *                         ADFLAGS_NOHF:      it's not an error if header file couldn't be opened
1547  *                         ADFLAGS_NORF:      it's not an error if reso fork couldn't be opened
1548  *                         ADFLAGS_DIR:       if path is a directory you MUST or ADFLAGS_DIR to adflags
1549  *
1550  *                       Access mode for the forks:
1551  *                         ADFLAGS_RDONLY:    open read only
1552  *                         ADFLAGS_RDWR:      open read write
1553  *
1554  *                       Creation flags:
1555  *                         ADFLAGS_CREATE:    create if not existing
1556  *                         ADFLAGS_TRUNC:     truncate
1557  *
1558  *                       Special flags:
1559  *                         ADFLAGS_CHECK_OF:  check for open forks from us and other afpd's
1560  *                         ADFLAGS_SETSHRMD:  this adouble struct will be used to set sharemode locks.
1561  *                                            This basically results in the files being opened RW instead of RDONLY.
1562  * @param mode      (r)  mode used with O_CREATE
1563  *
1564  * The open mode flags (rw vs ro) have to take into account all the following requirements:
1565  * - we remember open fds for files because me must avoid a single close releasing fcntl locks for other
1566  *   fds of the same file
1567  *
1568  * @returns 0 on success, any other value indicates an error
1569  */
1570 int ad_open(struct adouble *ad, const char *path, int adflags, ...)
1571 {
1572     EC_INIT;
1573     va_list args;
1574     mode_t mode = 0;
1575
1576     LOG(log_debug, logtype_default,
1577         "ad_open(\"%s\", %s): BEGIN [dfd: %d (ref: %d), mfd: %d (ref: %d), rfd: %d (ref: %d)]",
1578         fullpathname(path), adflags2logstr(adflags),
1579         ad_data_fileno(ad), ad->ad_data_fork.adf_refcount,
1580         ad_meta_fileno(ad), ad->ad_mdp->adf_refcount,
1581         ad_reso_fileno(ad), ad->ad_rfp->adf_refcount);
1582
1583     if (adflags & ADFLAGS_CHECK_OF)
1584         /* Checking for open forks requires sharemode lock support (ie RDWR instead of RDONLY) */
1585         adflags |= ADFLAGS_SETSHRMD;
1586
1587     if (ad->ad_vers == AD_VERSION2) {
1588         if (adflags & ADFLAGS_SETSHRMD)
1589             /* sharemode locks are stored in the data fork, adouble:v2 needs this extra handling here */
1590             adflags |= ADFLAGS_DF;
1591         if (adflags & ADFLAGS_RF)
1592             adflags |= ADFLAGS_HF;
1593         if (adflags & ADFLAGS_NORF)
1594             adflags |= ADFLAGS_NOHF;
1595     }
1596
1597     if (ad->ad_inited != AD_INITED) {
1598         ad->ad_adflags = adflags;
1599         ad->ad_inited = AD_INITED;
1600     } else {
1601         ad->ad_open_forks = ((ad->ad_data_fork.adf_refcount > 0) ? ATTRBIT_DOPEN : 0);
1602         if (ad->ad_resource_fork.adf_refcount > 0)
1603             ad->ad_open_forks |= ATTRBIT_ROPEN;
1604     }
1605
1606     va_start(args, adflags);
1607     if (adflags & ADFLAGS_CREATE)
1608         mode = va_arg(args, mode_t);
1609     va_end(args);
1610
1611     if (adflags & ADFLAGS_DF) {
1612         EC_ZERO( ad_open_df(path, adflags, mode, ad) );
1613     }
1614
1615     if (adflags & ADFLAGS_HF) {
1616         EC_ZERO( ad_open_hf(path, adflags, mode, ad) );
1617     }
1618
1619     if (adflags & ADFLAGS_RF) {
1620         EC_ZERO( ad_open_rf(path, adflags, mode, ad) );
1621     }
1622
1623     if (adflags & ADFLAGS_CHECK_OF) {
1624         ad->ad_open_forks |= ad_openforks(ad, ad->ad_open_forks);
1625     }
1626
1627 EC_CLEANUP:
1628     LOG(log_debug, logtype_default,
1629         "ad_open(\"%s\"): END: %d [dfd: %d (ref: %d), mfd: %d (ref: %d), rfd: %d (ref: %d)]",
1630         fullpathname(path), ret,
1631         ad_data_fileno(ad), ad->ad_data_fork.adf_refcount,
1632         ad_meta_fileno(ad), ad->ad_mdp->adf_refcount,
1633         ad_reso_fileno(ad), ad->ad_rfp->adf_refcount);
1634
1635     EC_EXIT;
1636 }
1637
1638 /*!
1639  * @brief open metadata, possibly as root
1640  *
1641  * Return only metadata but try very hard ie at first try as user, then try as root.
1642  *
1643  * @param name  name of file/dir
1644  * @param flags ADFLAGS_DIR: name is a directory \n
1645  *              ADFLAGS_CHECK_OF: test if name is open by us or another afpd process
1646  *
1647  * @param adp   pointer to struct adouble
1648  */
1649 int ad_metadata(const char *name, int flags, struct adouble *adp)
1650 {
1651     uid_t uid;
1652     int   ret, err, oflags;
1653
1654     /* Sanitize flags */
1655     oflags = (flags & (ADFLAGS_CHECK_OF | ADFLAGS_DIR)) | ADFLAGS_HF | ADFLAGS_RDONLY;    
1656
1657     if ((ret = ad_open(adp, name, oflags)) < 0 && errno == EACCES) {
1658         uid = geteuid();
1659         if (seteuid(0)) {
1660             LOG(log_error, logtype_default, "ad_metadata(%s): seteuid failed %s", name, strerror(errno));
1661             errno = EACCES;
1662             return -1;
1663         }
1664         /* we are root open read only */
1665         ret = ad_open(adp, name, oflags);
1666         err = errno;
1667         if ( seteuid(uid) < 0) {
1668             LOG(log_error, logtype_default, "ad_metadata: can't seteuid back");
1669             exit(EXITERR_SYS);
1670         }
1671         errno = err;
1672     }
1673
1674     return ret;
1675 }
1676
1677 /*
1678  * @brief openat like wrapper for ad_metadata
1679  */
1680 int ad_metadataat(int dirfd, const char *name, int flags, struct adouble *adp)
1681 {
1682     int ret = 0;
1683     int cwdfd = -1;
1684
1685     if (dirfd != -1) {
1686         if ((cwdfd = open(".", O_RDONLY) == -1) || (fchdir(dirfd) != 0)) {
1687             ret = -1;
1688             goto exit;
1689         }
1690     }
1691
1692     if (ad_metadata(name, flags, adp) < 0) {
1693         ret = -1;
1694         goto exit;
1695     }
1696
1697     if (dirfd != -1) {
1698
1699         if (fchdir(cwdfd) != 0) {
1700             LOG(log_error, logtype_afpd, "ad_openat: cant chdir back, exiting");
1701             exit(EXITERR_SYS);
1702         }
1703     }
1704
1705 exit:
1706     if (cwdfd != -1)
1707         close(cwdfd);
1708
1709     return ret;
1710
1711 }
1712
1713 int ad_refresh(const char *path, struct adouble *ad)
1714 {
1715     switch (ad->ad_vers) {
1716     case AD_VERSION2:
1717         if (ad_meta_fileno(ad) == -1)
1718             return -1;
1719         return ad->ad_ops->ad_header_read(NULL, ad, NULL);
1720         break;
1721     case AD_VERSION_EA:
1722 #ifdef HAVE_EAFD
1723         if (AD_META_OPEN(ad)) {
1724             if (ad_data_fileno(ad) == -1)
1725                 return -1;
1726             // TODO: read meta EA
1727         }
1728
1729         if (AD_RSRC_OPEN(ad)) {
1730             if (ad_reso_fileno(ad) == -1)
1731                 return -1;
1732             struct stat st;
1733             if (fstat(ad_reso_fileno(ad), &st) == -1)
1734                 return -1;
1735             ad->ad_rlen = st.st_size;
1736         }
1737 #else
1738         if (AD_META_OPEN(ad)) {
1739             if (ad_data_fileno(ad) == -1)
1740                 return -1;
1741             // TODO: read meta EA
1742         }
1743         if (AD_RSRC_OPEN(ad)) {
1744             if (ad_reso_fileno(ad) == -1)
1745                 return -1;
1746             if (ad_header_read_osx(path, ad, NULL) < 0)
1747                 return -1;
1748         }
1749 #endif
1750         return ad->ad_ops->ad_header_read(path, ad, NULL);
1751         break;
1752     default:
1753         return -1;
1754         break;
1755     }
1756
1757 }
1758
1759 int ad_openat(struct adouble  *ad,
1760               int dirfd,  /* dir fd openat like */
1761               const char *path,
1762               int adflags, ...)
1763 {
1764     EC_INIT;
1765     int cwdfd = -1;
1766     va_list args;
1767     mode_t mode;
1768
1769     if (dirfd != -1) {
1770         if ((cwdfd = open(".", O_RDONLY) == -1) || (fchdir(dirfd) != 0))
1771             EC_FAIL;
1772     }
1773
1774     va_start(args, adflags);
1775     if (adflags & ADFLAGS_CREATE)
1776         mode = va_arg(args, mode_t);
1777     va_end(args);
1778
1779     EC_NEG1( ad_open(ad, path, adflags, mode) );
1780
1781     if (dirfd != -1) {
1782         if (fchdir(cwdfd) != 0) {
1783             AFP_PANIC("ad_openat: cant chdir back");
1784         }
1785     }
1786
1787 EC_CLEANUP:
1788     if (cwdfd != -1)
1789         close(cwdfd);
1790
1791     return ret;
1792 }