]> arthur.barton.de Git - netatalk.git/blob - etc/afpd/file.c
Various fixes for adouble:v2
[netatalk.git] / etc / afpd / file.c
1 /*
2  * Copyright (c) 1990,1993 Regents of The University of Michigan.
3  * All Rights Reserved.  See COPYRIGHT.
4  */
5
6 #ifdef HAVE_CONFIG_H
7 #include "config.h"
8 #endif /* HAVE_CONFIG_H */
9
10 #include <stdio.h>
11 #include <stdlib.h>
12
13 #include <string.h>
14 #include <utime.h>
15 #include <errno.h>
16 #include <sys/param.h>
17
18 #include <atalk/adouble.h>
19 #include <atalk/vfs.h>
20 #include <atalk/logger.h>
21 #include <atalk/afp.h>
22 #include <atalk/util.h>
23 #include <atalk/cnid.h>
24 #include <atalk/unix.h>
25 #include <atalk/globals.h>
26 #include <atalk/fce_api.h>
27
28 #include "directory.h"
29 #include "dircache.h"
30 #include "desktop.h"
31 #include "volume.h"
32 #include "fork.h"
33 #include "file.h"
34 #include "filedir.h"
35 #include "unix.h"
36
37 /* the format for the finderinfo fields (from IM: Toolbox Essentials):
38  * field         bytes        subfield    bytes
39  * 
40  * files:
41  * ioFlFndrInfo  16      ->       type    4  type field
42  *                             creator    4  creator field
43  *                               flags    2  finder flags:
44  *                                           alias, bundle, etc.
45  *                            location    4  location in window
46  *                              folder    2  window that contains file
47  * 
48  * ioFlXFndrInfo 16      ->     iconID    2  icon id
49  *                              unused    6  reserved 
50  *                              script    1  script system
51  *                              xflags    1  reserved
52  *                           commentID    2  comment id
53  *                           putawayID    4  home directory id
54  */
55
56 const u_char ufinderi[ADEDLEN_FINDERI] = {
57                               0, 0, 0, 0, 0, 0, 0, 0,
58                               1, 0, 0, 0, 0, 0, 0, 0,
59                               0, 0, 0, 0, 0, 0, 0, 0,
60                               0, 0, 0, 0, 0, 0, 0, 0
61                           };
62
63 static const u_char old_ufinderi[] = {
64                               'T', 'E', 'X', 'T', 'U', 'N', 'I', 'X'
65                           };
66
67 /* ---------------------- 
68 */
69 static int default_type(void *finder) 
70 {
71     if (!memcmp(finder, ufinderi, 8) || !memcmp(finder, old_ufinderi, 8))
72         return 1;
73     return 0;
74 }
75
76 /* FIXME path : unix or mac name ? (for now it's unix name ) */
77 void *get_finderinfo(const struct vol *vol, const char *upath, struct adouble *adp, void *data, int islink)
78 {
79     struct extmap       *em;
80     void                *ad_finder = NULL;
81     int                 chk_ext = 0;
82     
83     if (adp)
84         ad_finder = ad_entry(adp, ADEID_FINDERI);
85
86     if (ad_finder) {
87         memcpy(data, ad_finder, ADEDLEN_FINDERI);
88         /* default type ? */
89         if (default_type(ad_finder)) 
90             chk_ext = 1;
91     }
92     else {
93         memcpy(data, ufinderi, ADEDLEN_FINDERI);
94         chk_ext = 1;
95         if (vol_inv_dots(vol) && *upath == '.') { /* make it invisible */
96             uint16_t ashort;
97             
98             ashort = htons(FINDERINFO_INVISIBLE);
99             memcpy((char *)data + FINDERINFO_FRFLAGOFF, &ashort, sizeof(ashort));
100         }
101     }
102
103     if (islink){
104         uint16_t linkflag;
105         memcpy(&linkflag, (char *)data + FINDERINFO_FRFLAGOFF, 2);
106         linkflag |= htons(FINDERINFO_ISALIAS);
107         memcpy((char *)data + FINDERINFO_FRFLAGOFF, &linkflag, 2);
108         memcpy((char *)data + FINDERINFO_FRTYPEOFF,"slnk",4); 
109         memcpy((char *)data + FINDERINFO_FRCREATOFF,"rhap",4); 
110         chk_ext = 0;
111     }
112
113     /** Only enter if no appledouble information and no finder information found. */
114     if (chk_ext && (em = getextmap( upath ))) {
115         memcpy(data, em->em_type, sizeof( em->em_type ));
116         memcpy((char *)data + 4, em->em_creator, sizeof(em->em_creator));
117     }
118     return data;
119 }
120
121 /* ---------------------
122 */
123 char *set_name(const struct vol *vol, char *data, cnid_t pid, char *name, cnid_t id, uint32_t utf8) 
124 {
125     uint32_t   aint;
126     char        *tp = NULL;
127     char        *src = name;
128     aint = strlen( name );
129
130     if (!utf8) {
131         /* want mac name */
132         if (utf8_encoding()) {
133             /* but name is an utf8 mac name */
134             char *u, *m;
135            
136             /* global static variable... */
137             tp = strdup(name);
138             if (!(u = mtoupath(vol, name, pid, 1)) || !(m = utompath(vol, u, id, 0))) {
139                aint = 0;
140             }
141             else {
142                 aint = strlen(m);
143                 src = m;
144             }
145             
146         }
147         if (aint > MACFILELEN)
148             aint = MACFILELEN;
149         *data++ = aint;
150     }
151     else {
152         uint16_t temp;
153
154         if (aint > UTF8FILELEN_EARLY)  /* FIXME safeguard, anyway if no ascii char it's game over*/
155            aint = UTF8FILELEN_EARLY;
156
157         utf8 = vol->v_kTextEncoding;
158         memcpy(data, &utf8, sizeof(utf8));
159         data += sizeof(utf8);
160         
161         temp = htons(aint);
162         memcpy(data, &temp, sizeof(temp));
163         data += sizeof(temp);
164     }
165
166     memcpy( data, src, aint );
167     data += aint;
168     if (tp) {
169         strcpy(name, tp);
170         free(tp);
171     }
172     return data;
173 }
174
175 /*
176  * FIXME: PDINFO is UTF8 and doesn't need adp
177 */
178 #define PARAM_NEED_ADP(b) ((b) & ((1 << FILPBIT_ATTR)  |\
179                                   (1 << FILPBIT_CDATE) |\
180                                   (1 << FILPBIT_MDATE) |\
181                                   (1 << FILPBIT_BDATE) |\
182                                   (1 << FILPBIT_FINFO) |\
183                                   (1 << FILPBIT_RFLEN) |\
184                                   (1 << FILPBIT_EXTRFLEN) |\
185                                   (1 << FILPBIT_PDINFO) |\
186                                   (1 << FILPBIT_FNUM) |\
187                                   (1 << FILPBIT_UNIXPR)))
188
189 /*!
190  * @brief Get CNID for did/upath args both from database and adouble file
191  *
192  * 1. Get the objects CNID as stored in its adouble file
193  * 2. Get the objects CNID from the database
194  * 3. If there's a problem with a "dbd" database, fallback to "tdb" in memory
195  * 4. In case 2 and 3 differ, store 3 in the adouble file
196  *
197  * @param vol    (rw) volume
198  * @param adp    (rw) adouble struct of object upath, might be NULL
199  * @param st     (r) stat of upath, must NOT be NULL
200  * @param did    (r) parent CNID of upath
201  * @param upath  (r) name of object
202  * @param len    (r) strlen of upath
203  */
204 uint32_t get_id(struct vol *vol,
205                 struct adouble *adp, 
206                 const struct stat *st,
207                 const cnid_t did,
208                 const char *upath,
209                 const int len) 
210 {
211     static int first = 1;       /* mark if this func is called the first time */
212     uint32_t adcnid;
213     uint32_t dbcnid = CNID_INVALID;
214
215 restart:
216     if (vol->v_cdb != NULL) {
217         /* prime aint with what we think is the cnid, set did to zero for
218            catching moved files */
219         adcnid = ad_getid(adp, st->st_dev, st->st_ino, 0, vol->v_stamp); /* (1) */
220
221             dbcnid = cnid_add(vol->v_cdb, st, did, upath, len, adcnid); /* (2) */
222             /* Throw errors if cnid_add fails. */
223             if (dbcnid == CNID_INVALID) {
224             switch (errno) {
225             case CNID_ERR_CLOSE: /* the db is closed */
226                 break;
227             case CNID_ERR_PARAM:
228                 LOG(log_error, logtype_afpd, "get_id: Incorrect parameters passed to cnid_add");
229                 afp_errno = AFPERR_PARAM;
230                 goto exit;
231             case CNID_ERR_PATH:
232                 afp_errno = AFPERR_PARAM;
233                 goto exit;
234             default:
235                 /* Close CNID backend if "dbd" and switch to temp in-memory "tdb" */
236                 /* we have to do it here for "dbd" because it uses "lazy opening" */
237                 /* In order to not end in a loop somehow with goto restart below  */
238                 /*  */
239                 if (first && (strcmp(vol->v_cnidscheme, "dbd") == 0)) { /* (3) */
240                     cnid_close(vol->v_cdb);
241                     free(vol->v_cnidscheme);
242                     vol->v_cnidscheme = strdup("tdb");
243
244                     int flags = CNID_FLAG_MEMORY;
245                     if ((vol->v_flags & AFPVOL_NODEV)) {
246                         flags |= CNID_FLAG_NODEV;
247                     }
248                     LOG(log_error, logtype_afpd, "Reopen volume %s using in memory temporary CNID DB.",
249                         vol->v_path);
250                     vol->v_cdb = cnid_open(vol->v_path, vol->v_umask, "tdb", flags, NULL, NULL);
251                     if (vol->v_cdb) {
252                         /* deactivate cnid caching/storing in AppleDouble files and set ro mode*/
253                         vol->v_flags &= ~AFPVOL_CACHE;
254                         vol->v_flags |= AFPVOL_RO;
255 #ifdef SERVERTEXT
256                         /* kill ourself with SIGUSR2 aka msg pending */
257                         setmessage("Something wrong with the volume's CNID DB, using temporary CNID DB instead."
258                                    "Check server messages for details. Switching to read-only mode.");
259                         kill(getpid(), SIGUSR2);
260 #endif
261                         goto restart; /* not try again with the temp CNID db */
262                     } else {
263 #ifdef SERVERTEXT
264                         setmessage("Something wrong with the volume's CNID DB, using temporary CNID DB failed too!"
265                                    "Check server messages for details, can't recover from this state!");
266 #endif
267                     }
268                 }
269                 afp_errno = AFPERR_MISC;
270                 goto exit;
271             }
272         }
273         else if (adp && (adcnid != dbcnid)) { /* 4 */
274             /* Update the ressource fork. For a folder adp is always null */
275             LOG(log_debug, logtype_afpd, "get_id(%s/%s): calling ad_setid(old: %u, new: %u)",
276                 getcwdpath(), upath, htonl(adcnid), htonl(dbcnid));
277             if (ad_setid(adp, st->st_dev, st->st_ino, dbcnid, did, vol->v_stamp)) {
278                 ad_flush(adp);
279             }
280         }
281     }
282
283 exit:
284     first = 0;
285     return dbcnid;
286 }
287              
288 /* -------------------------- */
289 int getmetadata(struct vol *vol,
290                  uint16_t bitmap,
291                  struct path *path, struct dir *dir, 
292                  char *buf, size_t *buflen, struct adouble *adp)
293 {
294     char                *data, *l_nameoff = NULL, *upath;
295     char                *utf_nameoff = NULL;
296     int                 bit = 0;
297     uint32_t            aint;
298     cnid_t              id = 0;
299     uint16_t            ashort;
300     u_char              achar, fdType[4];
301     uint32_t           utf8 = 0;
302     struct stat         *st;
303     struct maccess      ma;
304
305     LOG(log_debug, logtype_afpd, "getmetadata(\"%s\")", path->u_name);
306
307     upath = path->u_name;
308     st = &path->st;
309     data = buf;
310
311     if ( ((bitmap & ( (1 << FILPBIT_FINFO)|(1 << FILPBIT_LNAME)|(1 <<FILPBIT_PDINFO) ) ) && !path->m_name)
312          || (bitmap & ( (1 << FILPBIT_LNAME) ) && utf8_encoding()) /* FIXME should be m_name utf8 filename */
313          || (bitmap & (1 << FILPBIT_FNUM))) {
314         if (!path->id) {
315             bstring fullpath;
316             struct dir *cachedfile;
317             int len = strlen(upath);
318             if ((cachedfile = dircache_search_by_name(vol, dir, upath, len)) != NULL)
319                 id = cachedfile->d_did;
320             else {
321                 id = get_id(vol, adp, st, dir->d_did, upath, len);
322
323                 /* Add it to the cache */
324                 LOG(log_debug, logtype_afpd, "getmetadata: caching: did:%u, \"%s\", cnid:%u",
325                     ntohl(dir->d_did), upath, ntohl(id));
326
327                 /* Get macname from unixname first */
328                 if (path->m_name == NULL) {
329                     if ((path->m_name = utompath(vol, upath, id, utf8_encoding())) == NULL) {
330                         LOG(log_error, logtype_afpd, "getmetadata: utompath error");
331                         return AFPERR_MISC;
332                     }
333                 }
334                 
335                 /* Build fullpath */
336                 if (((fullpath = bstrcpy(dir->d_fullpath)) == NULL)
337                     || (bconchar(fullpath, '/') != BSTR_OK)
338                     || (bcatcstr(fullpath, upath)) != BSTR_OK) {
339                     LOG(log_error, logtype_afpd, "getmetadata: fullpath: %s", strerror(errno));
340                     return AFPERR_MISC;
341                 }
342
343                 if ((cachedfile = dir_new(path->m_name, upath, vol, dir->d_did, id, fullpath, st)) == NULL) {
344                     LOG(log_error, logtype_afpd, "getmetadata: error from dir_new");
345                     return AFPERR_MISC;
346                 }
347
348                 if ((dircache_add(vol, cachedfile)) != 0) {
349                     LOG(log_error, logtype_afpd, "getmetadata: fatal dircache error");
350                     return AFPERR_MISC;
351                 }
352             }
353         } else {
354             id = path->id;
355         }
356
357         if (id == CNID_INVALID)
358             return afp_errno;
359
360         if (!path->m_name) {
361             path->m_name = utompath(vol, upath, id, utf8_encoding());
362         }
363     }
364     while ( bitmap != 0 ) {
365         while (( bitmap & 1 ) == 0 ) {
366             bitmap = bitmap>>1;
367             bit++;
368         }
369
370         switch ( bit ) {
371         case FILPBIT_ATTR :
372             if ( adp ) {
373                 ad_getattr(adp, &ashort);
374             } else if (vol_inv_dots(vol) && *upath == '.') {
375                 ashort = htons(ATTRBIT_INVISIBLE);
376             } else
377                 ashort = 0;
378 #if 0
379             /* FIXME do we want a visual clue if the file is read only
380              */
381             struct maccess      ma;
382             accessmode(vol, ".", &ma, dir , NULL);
383             if ((ma.ma_user & AR_UWRITE)) {
384                 accessmode(vol, upath, &ma, dir , st);
385                 if (!(ma.ma_user & AR_UWRITE)) {
386                         ashort |= htons(ATTRBIT_NOWRITE);
387                 }
388             }
389 #endif
390             memcpy(data, &ashort, sizeof( ashort ));
391             data += sizeof( ashort );
392             LOG(log_debug, logtype_afpd, "metadata('%s'): AFP Attributes: %04x",
393                 path->u_name, ntohs(ashort));
394             break;
395
396         case FILPBIT_PDID :
397             memcpy(data, &dir->d_did, sizeof( uint32_t ));
398             data += sizeof( uint32_t );
399             LOG(log_debug, logtype_afpd, "metadata('%s'):     Parent DID: %u",
400                 path->u_name, ntohl(dir->d_did));
401             break;
402
403         case FILPBIT_CDATE :
404             if (!adp || (ad_getdate(adp, AD_DATE_CREATE, &aint) < 0))
405                 aint = AD_DATE_FROM_UNIX(st->st_mtime);
406             memcpy(data, &aint, sizeof( aint ));
407             data += sizeof( aint );
408             break;
409
410         case FILPBIT_MDATE :
411             if ( adp && (ad_getdate(adp, AD_DATE_MODIFY, &aint) == 0)) {
412                 if ((st->st_mtime > AD_DATE_TO_UNIX(aint))) {
413                    aint = AD_DATE_FROM_UNIX(st->st_mtime);
414                 }
415             } else {
416                 aint = AD_DATE_FROM_UNIX(st->st_mtime);
417             }
418             memcpy(data, &aint, sizeof( int ));
419             data += sizeof( int );
420             break;
421
422         case FILPBIT_BDATE :
423             if (!adp || (ad_getdate(adp, AD_DATE_BACKUP, &aint) < 0))
424                 aint = AD_DATE_START;
425             memcpy(data, &aint, sizeof( int ));
426             data += sizeof( int );
427             break;
428
429         case FILPBIT_FINFO :
430                 get_finderinfo(vol, upath, adp, (char *)data,S_ISLNK(st->st_mode));
431             data += ADEDLEN_FINDERI;
432             break;
433
434         case FILPBIT_LNAME :
435             l_nameoff = data;
436             data += sizeof( uint16_t );
437             break;
438
439         case FILPBIT_SNAME :
440             memset(data, 0, sizeof(uint16_t));
441             data += sizeof( uint16_t );
442             break;
443
444         case FILPBIT_FNUM :
445             memcpy(data, &id, sizeof( id ));
446             data += sizeof( id );
447             LOG(log_debug, logtype_afpd, "metadata('%s'):           CNID: %u",
448                 path->u_name, ntohl(id));
449             break;
450
451         case FILPBIT_DFLEN :
452             if  (st->st_size > 0xffffffff)
453                aint = 0xffffffff;
454             else
455                aint = htonl( st->st_size );
456             memcpy(data, &aint, sizeof( aint ));
457             data += sizeof( aint );
458             break;
459
460         case FILPBIT_RFLEN :
461             if ( adp ) {
462                 if (adp->ad_rlen > 0xffffffff)
463                     aint = 0xffffffff;
464                 else
465                     aint = htonl( adp->ad_rlen);
466             } else {
467                 aint = 0;
468             }
469             memcpy(data, &aint, sizeof( aint ));
470             data += sizeof( aint );
471             break;
472
473             /* Current client needs ProDOS info block for this file.
474                Use simple heuristic and let the Mac "type" string tell
475                us what the PD file code should be.  Everything gets a
476                subtype of 0x0000 unless the original value was hashed
477                to "pXYZ" when we created it.  See IA, Ver 2.
478                <shirsch@adelphia.net> */
479         case FILPBIT_PDINFO :
480             if (afp_version >= 30) { /* UTF8 name */
481                 utf8 = kTextEncodingUTF8;
482                 utf_nameoff = data;
483                 data += sizeof( uint16_t );
484                 aint = 0;
485                 memcpy(data, &aint, sizeof( aint ));
486                 data += sizeof( aint );
487             }
488             else {
489                 if ( adp ) {
490                     memcpy(fdType, ad_entry( adp, ADEID_FINDERI ), 4 );
491
492                     if ( memcmp( fdType, "TEXT", 4 ) == 0 ) {
493                         achar = '\x04';
494                         ashort = 0x0000;
495                     }
496                     else if ( memcmp( fdType, "PSYS", 4 ) == 0 ) {
497                         achar = '\xff';
498                         ashort = 0x0000;
499                     }
500                     else if ( memcmp( fdType, "PS16", 4 ) == 0 ) {
501                         achar = '\xb3';
502                         ashort = 0x0000;
503                     }
504                     else if ( memcmp( fdType, "BINA", 4 ) == 0 ) {
505                         achar = '\x00';
506                         ashort = 0x0000;
507                     }
508                     else if ( fdType[0] == 'p' ) {
509                         achar = fdType[1];
510                         ashort = (fdType[2] * 256) + fdType[3];
511                     }
512                     else {
513                         achar = '\x00';
514                         ashort = 0x0000;
515                     }
516                 }
517                 else {
518                     achar = '\x00';
519                     ashort = 0x0000;
520                 }
521
522                 *data++ = achar;
523                 *data++ = 0;
524                 memcpy(data, &ashort, sizeof( ashort ));
525                 data += sizeof( ashort );
526                 memset(data, 0, sizeof( ashort ));
527                 data += sizeof( ashort );
528             }
529             break;
530         case FILPBIT_EXTDFLEN:
531             aint = htonl(st->st_size >> 32);
532             memcpy(data, &aint, sizeof( aint ));
533             data += sizeof( aint );
534             aint = htonl(st->st_size);
535             memcpy(data, &aint, sizeof( aint ));
536             data += sizeof( aint );
537             break;
538         case FILPBIT_EXTRFLEN:
539             aint = 0;
540             if (adp) 
541                 aint = htonl(adp->ad_rlen >> 32);
542             memcpy(data, &aint, sizeof( aint ));
543             data += sizeof( aint );
544             if (adp) 
545                 aint = htonl(adp->ad_rlen);
546             memcpy(data, &aint, sizeof( aint ));
547             data += sizeof( aint );
548             break;
549         case FILPBIT_UNIXPR :
550             /* accessmode may change st_mode with ACLs */
551             accessmode(vol, upath, &ma, dir , st);
552
553             aint = htonl(st->st_uid);
554             memcpy( data, &aint, sizeof( aint ));
555             data += sizeof( aint );
556             aint = htonl(st->st_gid);
557             memcpy( data, &aint, sizeof( aint ));
558             data += sizeof( aint );
559
560             /* FIXME: ugly hack
561                type == slnk indicates an OSX style symlink, 
562                we have to add S_IFLNK to the mode, otherwise
563                10.3 clients freak out. */
564
565             aint = st->st_mode;
566             if (adp) {
567                 memcpy(fdType, ad_entry( adp, ADEID_FINDERI ), 4 );
568                 if ( memcmp( fdType, "slnk", 4 ) == 0 ) {
569                     aint |= S_IFLNK;
570                 }
571             }
572             aint = htonl(aint);
573
574             memcpy( data, &aint, sizeof( aint ));
575             data += sizeof( aint );
576
577             *data++ = ma.ma_user;
578             *data++ = ma.ma_world;
579             *data++ = ma.ma_group;
580             *data++ = ma.ma_owner;
581             break;
582             
583         default :
584             return( AFPERR_BITMAP );
585         }
586         bitmap = bitmap>>1;
587         bit++;
588     }
589     if ( l_nameoff ) {
590         ashort = htons( data - buf );
591         memcpy(l_nameoff, &ashort, sizeof( ashort ));
592         data = set_name(vol, data, dir->d_did, path->m_name, id, 0);
593     }
594     if ( utf_nameoff ) {
595         ashort = htons( data - buf );
596         memcpy(utf_nameoff, &ashort, sizeof( ashort ));
597         data = set_name(vol, data, dir->d_did, path->m_name, id, utf8);
598     }
599     *buflen = data - buf;
600     return (AFP_OK);
601 }
602                 
603 /* ----------------------- */
604 int getfilparams(struct vol *vol,
605                  uint16_t bitmap,
606                  struct path *path, struct dir *dir, 
607                  char *buf, size_t *buflen )
608 {
609     struct adouble      ad, *adp;
610     int                 opened = 0;
611     int rc;    
612     int flags;
613
614     LOG(log_debug, logtype_afpd, "getfilparams(\"%s\")", path->u_name);
615
616     opened = PARAM_NEED_ADP(bitmap);
617     adp = NULL;
618
619     if (opened) {
620         char *upath;
621         flags = (bitmap & (1 << FILPBIT_ATTR)) ? ADFLAGS_CHECK_OF : 0;
622
623         adp = of_ad(vol, path, &ad);
624         upath = path->u_name;
625
626         if ( ad_metadata( upath, flags, adp) < 0 ) {
627             switch (errno) {
628             case EACCES:
629                 LOG(log_error, logtype_afpd, "getfilparams(%s): %s: check resource fork permission?",
630                 upath, strerror(errno));
631                 return AFPERR_ACCESS;
632             case EIO:
633                 LOG(log_error, logtype_afpd, "getfilparams(%s): bad resource fork", upath);
634                 /* fall through */
635             case ENOENT:
636             default:
637                 adp = NULL;
638                 break;
639             }
640         }
641     }
642     rc = getmetadata(vol, bitmap, path, dir, buf, buflen, adp);
643     ad_close(adp, ADFLAGS_HF | flags);
644
645     return( rc );
646 }
647
648 /* ----------------------------- */
649 int afp_createfile(AFPObj *obj, char *ibuf, size_t ibuflen _U_, char *rbuf _U_, size_t *rbuflen)
650 {
651     struct adouble      ad;
652     struct vol          *vol;
653     struct dir          *dir;
654     struct ofork        *of = NULL;
655     char                *path, *upath;
656     int                 creatf, did, openf, retvalue = AFP_OK;
657     uint16_t            vid;
658     struct path         *s_path;
659     
660     *rbuflen = 0;
661     ibuf++;
662     creatf = (unsigned char) *ibuf++;
663
664     memcpy(&vid, ibuf, sizeof( vid ));
665     ibuf += sizeof( vid );
666
667     if (NULL == ( vol = getvolbyvid( vid )) )
668         return( AFPERR_PARAM );
669
670     if (vol->v_flags & AFPVOL_RO)
671         return AFPERR_VLOCK;
672
673     memcpy(&did, ibuf, sizeof( did));
674     ibuf += sizeof( did );
675
676     if (NULL == ( dir = dirlookup( vol, did )) )
677         return afp_errno;
678
679     if (NULL == ( s_path = cname( vol, dir, &ibuf )) )
680         return get_afp_errno(AFPERR_PARAM);
681     if ( *s_path->m_name == '\0' )
682         return( AFPERR_BADTYPE );
683
684     upath = s_path->u_name;
685     ad_init(&ad, vol);
686     
687     /* if upath is deleted we already in trouble anyway */
688     if ((of = of_findname(s_path))) {
689         if (creatf)
690             return AFPERR_BUSY;
691         else
692             return AFPERR_EXIST;
693     }
694
695     if (creatf)
696         openf = ADFLAGS_RDWR | ADFLAGS_CREATE | ADFLAGS_TRUNC;
697     else
698         /* on a soft create, if the file is open then ad_open won't fail
699            because open syscall is not called */
700         openf = ADFLAGS_RDWR | ADFLAGS_CREATE | ADFLAGS_EXCL;
701
702     if (ad_open(&ad, upath, ADFLAGS_DF | ADFLAGS_HF | ADFLAGS_NOHF | openf, 0666) < 0) {
703         switch ( errno ) {
704         case EROFS:
705             return AFPERR_VLOCK;
706         case ENOENT : /* we were already in 'did folder' so chdir() didn't fail */
707             return ( AFPERR_NOOBJ );
708         case EEXIST :
709             return( AFPERR_EXIST );
710         case EACCES :
711             return( AFPERR_ACCESS );
712         case EDQUOT:
713         case ENOSPC :
714             return( AFPERR_DFULL );
715         default :
716             return( AFPERR_PARAM );
717         }
718     }
719     if ( ad_meta_fileno( &ad ) == -1 ) { /* Hard META / HF */
720          /* FIXME with hard create on an existing file, we already
721           * corrupted the data file.
722           */
723          netatalk_unlink( upath );
724          ad_close( &ad, ADFLAGS_DF );
725          return AFPERR_ACCESS;
726     }
727
728     path = s_path->m_name;
729     ad_setname(&ad, path);
730
731     struct stat st;
732     if (lstat(upath, &st) != 0) {
733         LOG(log_error, logtype_afpd, "afp_createfile(\"%s\"): stat: %s",
734             upath, strerror(errno));
735         ad_close(&ad, ADFLAGS_DF|ADFLAGS_HF);
736         return AFPERR_MISC;
737     }
738
739     (void)get_id(vol, &ad, &st, dir->d_did, upath, strlen(upath));
740
741     ad_flush(&ad);
742     ad_close(&ad, ADFLAGS_DF|ADFLAGS_HF );
743     fce_register_new_file(s_path);
744
745 createfile_done:
746     curdir->d_offcnt++;
747
748     setvoltime(obj, vol );
749
750     return (retvalue);
751 }
752
753 int afp_setfilparams(AFPObj *obj, char *ibuf, size_t ibuflen _U_, char *rbuf _U_, size_t *rbuflen)
754 {
755     struct vol  *vol;
756     struct dir  *dir;
757     struct path *s_path;
758     int         did, rc;
759     uint16_t    vid, bitmap;
760
761     *rbuflen = 0;
762     ibuf += 2;
763
764     memcpy(&vid, ibuf, sizeof( vid ));
765     ibuf += sizeof( vid );
766     if (NULL == ( vol = getvolbyvid( vid )) ) {
767         return( AFPERR_PARAM );
768     }
769
770     if (vol->v_flags & AFPVOL_RO)
771         return AFPERR_VLOCK;
772
773     memcpy(&did, ibuf, sizeof( did ));
774     ibuf += sizeof( did );
775     if (NULL == ( dir = dirlookup( vol, did )) ) {
776         return afp_errno; /* was AFPERR_NOOBJ */
777     }
778
779     memcpy(&bitmap, ibuf, sizeof( bitmap ));
780     bitmap = ntohs( bitmap );
781     ibuf += sizeof( bitmap );
782
783     if (NULL == ( s_path = cname( vol, dir, &ibuf )) ) {
784         return get_afp_errno(AFPERR_PARAM);
785     }
786
787     if (path_isadir(s_path)) {
788         return( AFPERR_BADTYPE ); /* it's a directory */
789     }
790
791     if ( s_path->st_errno != 0 ) {
792         return( AFPERR_NOOBJ );
793     }
794
795     if ((u_long)ibuf & 1 ) {
796         ibuf++;
797     }
798
799     if (AFP_OK == ( rc = setfilparams(vol, s_path, bitmap, ibuf )) ) {
800         setvoltime(obj, vol );
801     }
802
803     return( rc );
804 }
805
806 /*
807  * cf AFP3.0.pdf page 252 for change_mdate and change_parent_mdate logic  
808  * 
809 */
810 extern struct path Cur_Path;
811
812 int setfilparams(struct vol *vol,
813                  struct path *path, uint16_t f_bitmap, char *buf )
814 {
815     struct adouble      ad, *adp;
816     struct extmap       *em;
817     int                 bit, isad = 1, err = AFP_OK;
818     char                *upath;
819     u_char              achar, *fdType, xyy[4]; /* uninitialized, OK 310105 */
820     uint16_t            ashort, bshort, oshort;
821     uint32_t            aint;
822     uint32_t            upriv;
823     uint16_t           upriv_bit = 0;
824         struct utimbuf  ut;
825     int                 change_mdate = 0;
826     int                 change_parent_mdate = 0;
827     int                 newdate = 0;
828     struct timeval      tv;
829     uid_t               f_uid;
830     gid_t               f_gid;
831     uint16_t           bitmap = f_bitmap;
832     uint32_t           cdate,bdate;
833     u_char              finder_buf[32];
834     int symlinked = 0;
835
836 #ifdef DEBUG
837     LOG(log_debug9, logtype_afpd, "begin setfilparams:");
838 #endif /* DEBUG */
839
840     adp = of_ad(vol, path, &ad);
841     upath = path->u_name;
842
843     if (!vol_unix_priv(vol) && check_access(upath, OPENACC_WR ) < 0) {
844         return AFPERR_ACCESS;
845     }
846
847     /* with unix priv maybe we have to change adouble file priv first */
848     bit = 0;
849     while ( bitmap != 0 ) {
850         while (( bitmap & 1 ) == 0 ) {
851             bitmap = bitmap>>1;
852             bit++;
853         }
854         switch(  bit ) {
855         case FILPBIT_ATTR :
856             change_mdate = 1;
857             memcpy(&ashort, buf, sizeof( ashort ));
858             buf += sizeof( ashort );
859             break;
860         case FILPBIT_CDATE :
861             change_mdate = 1;
862             memcpy(&cdate, buf, sizeof(cdate));
863             buf += sizeof( cdate );
864             break;
865         case FILPBIT_MDATE :
866             memcpy(&newdate, buf, sizeof( newdate ));
867             buf += sizeof( newdate );
868             break;
869         case FILPBIT_BDATE :
870             change_mdate = 1;
871             memcpy(&bdate, buf, sizeof( bdate));
872             buf += sizeof( bdate );
873             break;
874         case FILPBIT_FINFO :
875             change_mdate = 1;
876             memcpy(finder_buf, buf, 32 );
877             if (memcmp(buf, "slnkrhap", 8) == 0 && !S_ISLNK(path->st.st_mode)) {
878                 int fp;
879                 ssize_t len;
880                 int erc=1;
881                 char buf[PATH_MAX+1];
882                 if ((fp = open(path->u_name, O_RDONLY)) >= 0) {
883                     if ((len = read(fp, buf, PATH_MAX+1))) {
884                         if (unlink(path->u_name) == 0) {
885                             buf[len] = 0;
886                             erc = symlink(buf, path->u_name);
887                             if (!erc)
888                                 of_stat(path);
889                         }
890                     }
891                     close(fp);
892                 }
893                 if (erc != 0) {
894                     err=AFPERR_BITMAP;
895                     goto setfilparam_done;
896                 }
897                 symlinked = 1;
898             }
899             buf += 32;
900             break;
901         case FILPBIT_UNIXPR :
902             if (!vol_unix_priv(vol)) {
903                 /* this volume doesn't use unix priv */
904                 err = AFPERR_BITMAP;
905                 bitmap = 0;
906                 break;
907             }
908             change_mdate = 1;
909             change_parent_mdate = 1;
910
911             memcpy( &aint, buf, sizeof( aint ));
912             f_uid = ntohl (aint);
913             buf += sizeof( aint );
914             memcpy( &aint, buf, sizeof( aint ));
915             f_gid = ntohl (aint);
916             buf += sizeof( aint );
917             setfilowner(vol, f_uid, f_gid, path);
918
919             memcpy( &upriv, buf, sizeof( upriv ));
920             buf += sizeof( upriv );
921             upriv = ntohl (upriv);
922             if ((upriv & S_IWUSR)) {
923                 setfilunixmode(vol, path, upriv);
924             }
925             else {
926                 /* do it later */
927                 upriv_bit = 1;
928             }
929             break;
930         case FILPBIT_PDINFO :
931             if (afp_version < 30) { /* else it's UTF8 name */
932                 achar = *buf;
933                 buf += 2;
934                 /* Keep special case to support crlf translations */
935                 if ((unsigned int) achar == 0x04) {
936                     fdType = (u_char *)"TEXT";
937                     buf += 2;
938                 } else {
939                     xyy[0] = ( u_char ) 'p';
940                     xyy[1] = achar;
941                     xyy[3] = *buf++;
942                     xyy[2] = *buf++;
943                     fdType = xyy;
944                 }
945                 break;
946             }
947             /* fallthrough */
948         default :
949             err = AFPERR_BITMAP;
950             /* break while loop */
951             bitmap = 0;
952             break;
953         }
954
955         bitmap = bitmap>>1;
956         bit++;
957     }
958
959     /* second try with adouble open 
960     */
961     if (ad_open(adp, upath, ADFLAGS_HF | ADFLAGS_RDWR | ADFLAGS_CREATE, 0666) < 0) {
962         LOG(log_debug, logtype_afpd, "setfilparams: ad_open_metadata error");
963         /*
964          * For some things, we don't need an adouble header:
965          * - change of modification date
966          * - UNIX privs (Bug-ID #2863424)
967          */
968         if (!symlinked && f_bitmap & ~(1<<FILPBIT_MDATE | 1<<FILPBIT_UNIXPR)) {
969             LOG(log_debug, logtype_afpd, "setfilparams: need adouble access");
970             return AFPERR_ACCESS;
971         }
972         LOG(log_debug, logtype_afpd, "setfilparams: no adouble perms, but only FILPBIT_MDATE and/or FILPBIT_UNIXPR");
973         isad = 0;
974     } else if ((ad_get_MD_flags( adp ) & O_CREAT) ) {
975         ad_setname(adp, path->m_name);
976     }
977     
978     bit = 0;
979     bitmap = f_bitmap;
980     while ( bitmap != 0 ) {
981         while (( bitmap & 1 ) == 0 ) {
982             bitmap = bitmap>>1;
983             bit++;
984         }
985
986         switch(  bit ) {
987         case FILPBIT_ATTR :
988             ad_getattr(adp, &bshort);
989             oshort = bshort;
990             if ( ntohs( ashort ) & ATTRBIT_SETCLR ) {
991                 bshort |= htons( ntohs( ashort ) & ~ATTRBIT_SETCLR );
992             } else {
993                 bshort &= ~ashort;
994             }
995             if ((bshort & htons(ATTRBIT_INVISIBLE)) != (oshort & htons(ATTRBIT_INVISIBLE)))
996                 change_parent_mdate = 1;
997             ad_setattr(adp, bshort);
998             break;
999         case FILPBIT_CDATE :
1000             ad_setdate(adp, AD_DATE_CREATE, cdate);
1001             break;
1002         case FILPBIT_MDATE :
1003             break;
1004         case FILPBIT_BDATE :
1005             ad_setdate(adp, AD_DATE_BACKUP, bdate);
1006             break;
1007         case FILPBIT_FINFO :
1008             if (default_type( ad_entry( adp, ADEID_FINDERI ))
1009                     && ( 
1010                      ((em = getextmap( path->m_name )) &&
1011                       !memcmp(finder_buf, em->em_type, sizeof( em->em_type )) &&
1012                       !memcmp(finder_buf + 4, em->em_creator,sizeof( em->em_creator)))
1013                      || ((em = getdefextmap()) &&
1014                       !memcmp(finder_buf, em->em_type, sizeof( em->em_type )) &&
1015                       !memcmp(finder_buf + 4, em->em_creator,sizeof( em->em_creator)))
1016             )) {
1017                 memcpy(finder_buf, ufinderi, 8 );
1018             }
1019             memcpy(ad_entry( adp, ADEID_FINDERI ), finder_buf, 32 );
1020             break;
1021         case FILPBIT_UNIXPR :
1022             if (upriv_bit) {
1023                 setfilunixmode(vol, path, upriv);
1024             }
1025             break;
1026         case FILPBIT_PDINFO :
1027             if (afp_version < 30) { /* else it's UTF8 name */
1028                 memcpy(ad_entry( adp, ADEID_FINDERI ), fdType, 4 );
1029                 memcpy(ad_entry( adp, ADEID_FINDERI ) + 4, "pdos", 4 );
1030                 break;
1031             }
1032             /* fallthrough */
1033         default :
1034             err = AFPERR_BITMAP;
1035             goto setfilparam_done;
1036         }
1037         bitmap = bitmap>>1;
1038         bit++;
1039     }
1040
1041 setfilparam_done:
1042     if (change_mdate && newdate == 0 && gettimeofday(&tv, NULL) == 0) {
1043        newdate = AD_DATE_FROM_UNIX(tv.tv_sec);
1044     }
1045     if (newdate) {
1046        if (isad)
1047           ad_setdate(adp, AD_DATE_MODIFY, newdate);
1048        ut.actime = ut.modtime = AD_DATE_TO_UNIX(newdate);
1049        utime(upath, &ut);
1050     }
1051
1052     if (isad) {
1053         ad_flush(adp);
1054         ad_close(adp, ADFLAGS_HF);
1055     }
1056
1057     if (change_parent_mdate && gettimeofday(&tv, NULL) == 0) {
1058         newdate = AD_DATE_FROM_UNIX(tv.tv_sec);
1059         bitmap = 1<<FILPBIT_MDATE;
1060         setdirparams(vol, &Cur_Path, bitmap, (char *)&newdate);
1061     }
1062
1063 #ifdef DEBUG
1064     LOG(log_debug9, logtype_afpd, "end setfilparams:");
1065 #endif /* DEBUG */
1066     return err;
1067 }
1068
1069 /*
1070  * renamefile and copyfile take the old and new unix pathnames
1071  * and the new mac name.
1072  *
1073  * sdir_fd     source dir fd to which src path is relative (for openat et al semantics)
1074  *             passing -1 means this is not used, src path is a full path
1075  * src         the source path 
1076  * dst         the dest filename in current dir
1077  * newname     the dest mac name
1078  * adp         adouble struct of src file, if open, or & zeroed one
1079  *
1080  */
1081 int renamefile(const struct vol *vol, int sdir_fd, char *src, char *dst, char *newname, struct adouble *adp)
1082 {
1083     int         rc;
1084
1085     LOG(log_debug, logtype_afpd,
1086         "renamefile: src[%d, \"%s\"] -> dst[\"%s\"]", sdir_fd, src, dst);
1087
1088     if ( unix_rename( sdir_fd, src, -1, dst ) < 0 ) {
1089         switch ( errno ) {
1090         case ENOENT :
1091             return( AFPERR_NOOBJ );
1092         case EPERM:
1093         case EACCES :
1094             return( AFPERR_ACCESS );
1095         case EROFS:
1096             return AFPERR_VLOCK;
1097         case EXDEV :                    /* Cross device move -- try copy */
1098            /* NOTE: with open file it's an error because after the copy we will 
1099             * get two files, it's fixable for our process (eg reopen the new file, get the
1100             * locks, and so on. But it doesn't solve the case with a second process
1101             */
1102             if (adp->ad_open_forks) {
1103                 /* FIXME  warning in syslog so admin'd know there's a conflict ?*/
1104                 return AFPERR_OLOCK; /* little lie */
1105             }
1106             if (AFP_OK != ( rc = copyfile(vol, vol, sdir_fd, src, dst, newname, NULL )) ) {
1107                 /* on error copyfile delete dest */
1108                 return( rc );
1109             }
1110             return deletefile(vol, sdir_fd, src, 0);
1111         default :
1112             return( AFPERR_PARAM );
1113         }
1114     }
1115
1116     if (vol->vfs->vfs_renamefile(vol, sdir_fd, src, dst) < 0 ) {
1117         int err;
1118         
1119         err = errno;        
1120         /* try to undo the data fork rename,
1121          * we know we are on the same device 
1122         */
1123         if (err) {
1124         unix_rename(-1, dst, sdir_fd, src ); 
1125             /* return the first error */
1126             switch ( err) {
1127             case ENOENT :
1128                 return AFPERR_NOOBJ;
1129             case EPERM:
1130             case EACCES :
1131                 return AFPERR_ACCESS ;
1132             case EROFS:
1133                 return AFPERR_VLOCK;
1134             default :
1135                 return AFPERR_PARAM ;
1136             }
1137         }
1138     }
1139
1140     /* don't care if we can't open the newly renamed ressource fork */
1141     if (ad_open(adp, dst, ADFLAGS_HF | ADFLAGS_RDWR) == 0) {
1142         ad_setname(adp, newname);
1143         ad_flush( adp );
1144         ad_close( adp, ADFLAGS_HF );
1145     }
1146
1147     return( AFP_OK );
1148 }
1149
1150 /* ---------------- 
1151    convert a Mac long name to an utf8 name,
1152 */
1153 size_t mtoUTF8(const struct vol *vol, const char *src, size_t srclen, char *dest, size_t destlen)
1154 {
1155 size_t    outlen;
1156
1157     if ((size_t)-1 == (outlen = convert_string ( vol->v_maccharset, CH_UTF8_MAC, src, srclen, dest, destlen)) ) {
1158         return -1;
1159     }
1160     return outlen;
1161 }
1162
1163 /* ---------------- */
1164 int copy_path_name(const struct vol *vol, char *newname, char *ibuf)
1165 {
1166 char        type = *ibuf;
1167 size_t      plen = 0;
1168 uint16_t   len16;
1169 uint32_t   hint;
1170
1171     if ( type != 2 && !(afp_version >= 30 && type == 3) ) {
1172         return -1;
1173     }
1174     ibuf++;
1175     switch (type) {
1176     case 2:
1177         if (( plen = (unsigned char)*ibuf++ ) != 0 ) {
1178             if (afp_version >= 30) {
1179                 /* convert it to UTF8 
1180                 */
1181                 if ((plen = mtoUTF8(vol, ibuf, plen, newname, AFPOBJ_TMPSIZ)) == (size_t)-1)
1182                    return -1;
1183             }
1184             else {
1185                 strncpy( newname, ibuf, plen );
1186                 newname[ plen ] = '\0';
1187             }
1188             if (strlen(newname) != plen) {
1189                 /* there's \0 in newname, e.g. it's a pathname not
1190                  * only a filename. 
1191                 */
1192                 return -1;
1193             }
1194         }
1195         break;
1196     case 3:
1197         memcpy(&hint, ibuf, sizeof(hint));
1198         ibuf += sizeof(hint);
1199            
1200         memcpy(&len16, ibuf, sizeof(len16));
1201         ibuf += sizeof(len16);
1202         plen = ntohs(len16);
1203         
1204         if (plen) {
1205             if (plen > AFPOBJ_TMPSIZ) {
1206                 return -1;
1207             }
1208             strncpy( newname, ibuf, plen );
1209             newname[ plen ] = '\0';
1210             if (strlen(newname) != plen) {
1211                 return -1;
1212             }
1213         }
1214         break;
1215     }
1216     return plen;
1217 }
1218
1219 /* -----------------------------------
1220 */
1221 int afp_copyfile(AFPObj *obj, char *ibuf, size_t ibuflen _U_, char *rbuf _U_, size_t *rbuflen)
1222 {
1223     struct vol  *s_vol, *d_vol;
1224     struct dir  *dir;
1225     char        *newname, *p, *upath;
1226     struct path *s_path;
1227     uint32_t    sdid, ddid;
1228     int         err, retvalue = AFP_OK;
1229     uint16_t    svid, dvid;
1230
1231     struct adouble ad, *adp;
1232     int denyreadset;
1233     
1234     *rbuflen = 0;
1235     ibuf += 2;
1236
1237     memcpy(&svid, ibuf, sizeof( svid ));
1238     ibuf += sizeof( svid );
1239     if (NULL == ( s_vol = getvolbyvid( svid )) ) {
1240         return( AFPERR_PARAM );
1241     }
1242
1243     memcpy(&sdid, ibuf, sizeof( sdid ));
1244     ibuf += sizeof( sdid );
1245     if (NULL == ( dir = dirlookup( s_vol, sdid )) ) {
1246         return afp_errno;
1247     }
1248
1249     memcpy(&dvid, ibuf, sizeof( dvid ));
1250     ibuf += sizeof( dvid );
1251     memcpy(&ddid, ibuf, sizeof( ddid ));
1252     ibuf += sizeof( ddid );
1253
1254     if (NULL == ( s_path = cname( s_vol, dir, &ibuf )) ) {
1255         return get_afp_errno(AFPERR_PARAM);
1256     }
1257     if ( path_isadir(s_path) ) {
1258         return( AFPERR_BADTYPE );
1259     }
1260
1261     /* don't allow copies when the file is open.
1262      * XXX: the spec only calls for read/deny write access.
1263      *      however, copyfile doesn't have any of that info,
1264      *      and locks need to stay coherent. as a result,
1265      *      we just balk if the file is opened already. */
1266
1267     adp = of_ad(s_vol, s_path, &ad);
1268
1269     if (ad_open(adp, s_path->u_name, ADFLAGS_DF | ADFLAGS_HF | ADFLAGS_NOHF | ADFLAGS_RDONLY | ADFLAGS_SETSHRMD) < 0) {
1270         return AFPERR_DENYCONF;
1271     }
1272     denyreadset = (ad_testlock(adp, ADEID_DFORK, AD_FILELOCK_DENY_RD) != 0 || 
1273                   ad_testlock(adp, ADEID_RFORK, AD_FILELOCK_DENY_RD) != 0 );
1274
1275     if (denyreadset) {
1276         retvalue = AFPERR_DENYCONF;
1277         goto copy_exit;
1278     }
1279
1280     newname = obj->newtmp;
1281     strcpy( newname, s_path->m_name );
1282
1283     p = ctoupath( s_vol, curdir, newname );
1284     if (!p) {
1285         retvalue = AFPERR_PARAM;
1286         goto copy_exit;
1287     }
1288
1289     if (NULL == ( d_vol = getvolbyvid( dvid )) ) {
1290         retvalue = AFPERR_PARAM;
1291         goto copy_exit;
1292     }
1293
1294     if (d_vol->v_flags & AFPVOL_RO) {
1295         retvalue = AFPERR_VLOCK;
1296         goto copy_exit;
1297     }
1298
1299     if (NULL == ( dir = dirlookup( d_vol, ddid )) ) {
1300         retvalue = afp_errno;
1301         goto copy_exit;
1302     }
1303
1304     if (( s_path = cname( d_vol, dir, &ibuf )) == NULL ) {
1305         retvalue = get_afp_errno(AFPERR_NOOBJ);
1306         goto copy_exit;
1307     }
1308     
1309     if ( *s_path->m_name != '\0' ) {
1310         retvalue =path_error(s_path, AFPERR_NOOBJ);
1311         goto copy_exit;
1312     }
1313
1314     /* one of the handful of places that knows about the path type */
1315     if (copy_path_name(d_vol, newname, ibuf) < 0) {
1316         retvalue = AFPERR_PARAM;
1317         goto copy_exit;
1318     }
1319     /* newname is always only a filename so curdir *is* its
1320      * parent folder
1321     */
1322     if (NULL == (upath = mtoupath(d_vol, newname, curdir->d_did, utf8_encoding()))) {
1323         retvalue =AFPERR_PARAM;
1324         goto copy_exit;
1325     }
1326
1327     if ( (err = copyfile(s_vol, d_vol, -1, p, upath , newname, adp)) < 0 ) {
1328         retvalue = err;
1329         goto copy_exit;
1330     }
1331     curdir->d_offcnt++;
1332
1333     setvoltime(obj, d_vol );
1334
1335 copy_exit:
1336     ad_close( adp, ADFLAGS_DF |ADFLAGS_HF | ADFLAGS_SETSHRMD);
1337     return( retvalue );
1338 }
1339
1340 /* ----------------------- */
1341 static int copy_all(const int dfd, const void *buf,
1342                                size_t buflen)
1343 {
1344     ssize_t cc;
1345
1346 #ifdef DEBUG
1347     LOG(log_debug9, logtype_afpd, "begin copy_all:");
1348 #endif /* DEBUG */
1349
1350     while (buflen > 0) {
1351         if ((cc = write(dfd, buf, buflen)) < 0) {
1352             switch (errno) {
1353             case EINTR:
1354                 continue;
1355             default:
1356                 return -1;
1357             }
1358         }
1359         buflen -= cc;
1360     }
1361
1362 #ifdef DEBUG
1363     LOG(log_debug9, logtype_afpd, "end copy_all:");
1364 #endif /* DEBUG */
1365
1366     return 0;
1367 }
1368
1369 /* -------------------------- 
1370  * copy only the fork data stream
1371 */
1372 static int copy_fork(int eid, struct adouble *add, struct adouble *ads)
1373 {
1374     ssize_t cc;
1375     int     err = 0;
1376     char    filebuf[8192];
1377     int     sfd, dfd;
1378     off_t   soff, doff;
1379
1380     if (eid == ADEID_DFORK) {
1381         sfd = ad_data_fileno(ads);
1382         dfd = ad_data_fileno(add);
1383     }
1384     else {
1385         sfd = ad_reso_fileno(ads);
1386         dfd = ad_reso_fileno(add);
1387     }        
1388
1389     soff = doff = ad_getentryoff(ads, eid);
1390
1391     if ((off_t)-1 == lseek(sfd, soff, SEEK_SET))
1392         return -1;
1393
1394     if ((off_t)-1 == lseek(dfd, doff, SEEK_SET))
1395         return -1;
1396         
1397 #if 0 /* ifdef SENDFILE_FLAVOR_LINUX */
1398     /* doesn't work With 2.6 FIXME, only check for EBADFD ? */
1399     off_t   offset = 0;
1400     size_t  size;
1401     struct stat         st;
1402     #define BUF 128*1024*1024
1403
1404     if (fstat(sfd, &st) == 0) {
1405         
1406         while (1) {
1407             if ( offset >= st.st_size) {
1408                return 0;
1409             }
1410             size = (st.st_size -offset > BUF)?BUF:st.st_size -offset;
1411             if ((cc = sys_sendfile(dfd, sfd, &offset, size)) < 0) {
1412                 switch (errno) {
1413                 case ENOSYS:
1414                 case EINVAL:  /* there's no guarantee that all fs support sendfile */
1415                     goto no_sendfile;
1416                 default:
1417                     return -1;
1418                 }
1419             }
1420         }
1421     }
1422     no_sendfile:
1423     lseek(sfd, offset, SEEK_SET);
1424 #endif 
1425
1426     while (1) {
1427         if ((cc = read(sfd, filebuf, sizeof(filebuf))) < 0) {
1428             if (errno == EINTR)
1429                 continue;
1430             err = -1;
1431             break;
1432         }
1433
1434         if (!cc || ((err = copy_all(dfd, filebuf, cc)) < 0)) {
1435             break;
1436         }
1437     }
1438     return err;
1439 }
1440
1441 /* ----------------------------------
1442  * if newname is NULL (from directory.c) we don't want to copy the resource fork.
1443  * because we are doing it elsewhere.
1444  * currently if newname is NULL then adp is NULL. 
1445  */
1446 int copyfile(const struct vol *s_vol,
1447              const struct vol *d_vol, 
1448              int sfd,
1449              char *src,
1450              char *dst,
1451              char *newname,
1452              struct adouble *adp)
1453 {
1454     struct adouble      ads, add;
1455     int                 err = 0;
1456     int                 ret_err = 0;
1457     int                 adflags;
1458     int                 stat_result;
1459     struct stat         st;
1460     
1461     LOG(log_debug, logtype_afpd, "copyfile(sfd:%d,s:'%s',d:'%s',n:'%s')",
1462         sfd, src, dst, newname);
1463
1464     if (adp == NULL) {
1465         ad_init(&ads, s_vol);
1466         adp = &ads;
1467     }
1468
1469     adflags = ADFLAGS_DF | ADFLAGS_RF | ADFLAGS_NORF;
1470
1471     if (ad_openat(adp, sfd, src, adflags | ADFLAGS_NOHF | ADFLAGS_RDONLY) < 0) {
1472         ret_err = errno;
1473         goto done;
1474     }
1475
1476     if (!AD_RSRC_OPEN(adp))
1477         /* no resource fork, don't create one for dst file */
1478         adflags &= ~ADFLAGS_RF;
1479
1480     stat_result = fstat(ad_data_fileno(adp), &st); /* saving stat exit code, thus saving us on one more stat later on */
1481
1482     if (stat_result < 0) {           
1483       /* unlikely but if fstat fails, the default file mode will be 0666. */
1484       st.st_mode = S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP | S_IROTH | S_IWOTH;
1485     }
1486
1487     ad_init(&add, d_vol);
1488     if (ad_open(&add, dst, adflags | ADFLAGS_RDWR | ADFLAGS_CREATE | ADFLAGS_EXCL, st.st_mode | S_IRUSR | S_IWUSR) < 0) {
1489         ret_err = errno;
1490         ad_close( adp, adflags );
1491         if (EEXIST != ret_err) {
1492             deletefile(d_vol, -1, dst, 0);
1493             goto done;
1494         }
1495         return AFPERR_EXIST;
1496     }
1497
1498 #if 0
1499     if (AD_RSRC_OPEN(adp))
1500         err = copy_fork(ADEID_RFORK, &add, adp);
1501 #endif
1502
1503     if (err == 0)
1504         err = copy_fork(ADEID_DFORK, &add, adp);
1505
1506     if (err == 0)
1507         err = d_vol->vfs->vfs_copyfile(d_vol, sfd, src, dst);
1508
1509     if (err < 0)
1510        ret_err = errno;
1511
1512     if (!ret_err && newname && (adflags & ADFLAGS_HF)) {
1513         /* set the new name in the resource fork */
1514         ad_copy_header(&add, adp);
1515         ad_setname(&add, newname);
1516         ad_flush( &add );
1517     }
1518     ad_close( adp, adflags );
1519
1520     if (ad_close( &add, adflags ) <0) {
1521        ret_err = errno;
1522     } 
1523
1524     if (ret_err) {
1525         deletefile(d_vol, -1, dst, 0);
1526     }
1527     else if (stat_result == 0) {
1528         /* set dest modification date to src date */
1529         struct utimbuf  ut;
1530
1531         ut.actime = ut.modtime = st.st_mtime;
1532         utime(dst, &ut);
1533         /* FIXME netatalk doesn't use resource fork file date
1534          * but maybe we should set its modtime too.
1535         */
1536     }
1537
1538 done:
1539     switch ( ret_err ) {
1540     case 0:
1541         return AFP_OK;
1542     case EDQUOT:
1543     case EFBIG:
1544     case ENOSPC:
1545         return AFPERR_DFULL;
1546     case ENOENT:
1547         return AFPERR_NOOBJ;
1548     case EACCES:
1549         return AFPERR_ACCESS;
1550     case EROFS:
1551         return AFPERR_VLOCK;
1552     }
1553     return AFPERR_PARAM;
1554 }
1555
1556
1557 /* -----------------------------------
1558    vol: not NULL delete cnid entry. then we are in curdir and file is a only filename
1559    checkAttrib:   1 check kFPDeleteInhibitBit (deletfile called by afp_delete)
1560
1561    when deletefile is called we don't have lock on it, file is closed (for us)
1562    untrue if called by renamefile
1563    
1564    ad_open always try to open file RDWR first and ad_lock takes care of
1565    WRITE lock on read only file.
1566 */
1567
1568 static int check_attrib(struct adouble *adp)
1569 {
1570 uint16_t   bshort = 0;
1571
1572         ad_getattr(adp, &bshort);
1573     /*
1574      * Does kFPDeleteInhibitBit (bit 8) set?
1575      */
1576         if ((bshort & htons(ATTRBIT_NODELETE))) {
1577                 return AFPERR_OLOCK;
1578         }
1579     if ((bshort & htons(ATTRBIT_DOPEN | ATTRBIT_ROPEN))) {
1580         return AFPERR_BUSY;
1581         }
1582         return 0;
1583 }
1584 /* 
1585  * dirfd can be used for unlinkat semantics
1586  */
1587 int deletefile(const struct vol *vol, int dirfd, char *file, int checkAttrib)
1588 {
1589     struct adouble      ad;
1590     struct adouble      *adp = NULL;
1591     int                 adflags, err = AFP_OK;
1592     int                 meta = 0;
1593
1594     LOG(log_debug, logtype_afpd, "deletefile('%s')", file);
1595
1596     ad_init(&ad, vol);
1597     if (checkAttrib) {
1598         /* was EACCESS error try to get only metadata */
1599         /* we never want to create a resource fork here, we are going to delete it 
1600          * moreover sometimes deletefile is called with a no existent file and 
1601          * ad_open would create a 0 byte resource fork
1602         */
1603         if ( ad_metadataat(dirfd, file, ADFLAGS_CHECK_OF, &ad) == 0 ) {
1604             if ((err = check_attrib(&ad))) {
1605                 ad_close(&ad, ADFLAGS_HF | ADFLAGS_CHECK_OF);
1606                return err;
1607             }
1608             meta = 1;
1609         }
1610     }
1611  
1612     /* try to open both forks at once */
1613     adflags = ADFLAGS_DF;
1614     if (ad_openat(&ad, dirfd, file, adflags | ADFLAGS_RF | ADFLAGS_NORF | ADFLAGS_RDONLY) < 0 ) {
1615         switch (errno) {
1616         case ENOENT:
1617             err = AFPERR_NOOBJ;
1618             goto end;
1619         case EACCES: /* maybe it's a file with no write mode for us */
1620             break;   /* was return AFPERR_ACCESS;*/
1621         case EROFS:
1622             err = AFPERR_VLOCK;
1623             goto end;
1624         default:
1625             err = AFPERR_PARAM;
1626             goto end;
1627         }
1628     }
1629     else {
1630         adp = &ad;
1631     }
1632
1633     if ( adp && AD_RSRC_OPEN(adp) != -1 ) { /* there's a resource fork */
1634         adflags |= ADFLAGS_RF;
1635         /* FIXME we have a pb here because we want to know if a file is open 
1636          * there's a 'priority inversion' if you can't open the ressource fork RW
1637          * you can delete it if it's open because you can't get a write lock.
1638          * 
1639          * ADLOCK_FILELOCK means the whole ressource fork, not only after the 
1640          * metadatas
1641          *
1642          * FIXME it doesn't work for RFORK open read only and fork open without deny mode
1643          */
1644         if (ad_tmplock(&ad, ADEID_RFORK, ADLOCK_WR |ADLOCK_FILELOCK, 0, 0, 0) < 0 ) {
1645             err = AFPERR_BUSY;
1646             goto end;
1647         }
1648     }
1649
1650     if (adp && ad_tmplock( &ad, ADEID_DFORK, ADLOCK_WR, 0, 0, 0 ) < 0) {
1651         LOG(log_error, logtype_afpd, "deletefile('%s'): ad_tmplock error: %s", file, strerror(errno));
1652         err = AFPERR_BUSY;
1653     } else if (!(err = vol->vfs->vfs_deletefile(vol, dirfd, file)) && !(err = netatalk_unlinkat(dirfd, file )) ) {
1654         cnid_t id;
1655         if (checkAttrib && (id = cnid_get(vol->v_cdb, curdir->d_did, file, strlen(file)))) {
1656             cnid_delete(vol->v_cdb, id);
1657         }
1658     }
1659
1660 end:
1661     if (meta)
1662         ad_close(&ad, ADFLAGS_HF | ADFLAGS_CHECK_OF);
1663
1664     if (adp)
1665         ad_close( &ad, adflags );  /* ad_close removes locks if any */
1666
1667     return err;
1668 }
1669
1670 /* ------------------------------------ */
1671 /* return a file id */
1672 int afp_createid(AFPObj *obj _U_, char *ibuf, size_t ibuflen _U_, char *rbuf, size_t *rbuflen)
1673 {
1674     struct stat         *st;
1675     struct vol          *vol;
1676     struct dir          *dir;
1677     char                *upath;
1678     int                 len;
1679     cnid_t              did, id;
1680     u_short             vid;
1681     struct path         *s_path;
1682
1683     *rbuflen = 0;
1684
1685     ibuf += 2;
1686
1687     memcpy(&vid, ibuf, sizeof(vid));
1688     ibuf += sizeof(vid);
1689
1690     if (NULL == ( vol = getvolbyvid( vid )) ) {
1691         return( AFPERR_PARAM);
1692     }
1693
1694     if (vol->v_cdb == NULL || !(vol->v_cdb->flags & CNID_FLAG_PERSISTENT)) {
1695         return AFPERR_NOOP;
1696     }
1697
1698     if (vol->v_flags & AFPVOL_RO)
1699         return AFPERR_VLOCK;
1700
1701     memcpy(&did, ibuf, sizeof( did ));
1702     ibuf += sizeof(did);
1703
1704     if (NULL == ( dir = dirlookup( vol, did )) ) {
1705         return afp_errno; /* was AFPERR_PARAM */
1706     }
1707
1708     if (NULL == ( s_path = cname( vol, dir, &ibuf )) ) {
1709         return get_afp_errno(AFPERR_NOOBJ); /* was AFPERR_PARAM */
1710     }
1711
1712     if ( path_isadir(s_path) ) {
1713         return( AFPERR_BADTYPE );
1714     }
1715
1716     upath = s_path->u_name;
1717     switch (s_path->st_errno) {
1718         case 0:
1719              break; /* success */
1720         case EPERM:
1721         case EACCES:
1722             return AFPERR_ACCESS;
1723         case ENOENT:
1724             return AFPERR_NOOBJ;
1725         default:
1726             return AFPERR_PARAM;
1727     }
1728     st = &s_path->st;
1729     if ((id = cnid_lookup(vol->v_cdb, st, did, upath, len = strlen(upath)))) {
1730         memcpy(rbuf, &id, sizeof(id));
1731         *rbuflen = sizeof(id);
1732         return AFPERR_EXISTID;
1733     }
1734
1735     if ((id = get_id(vol, NULL, st, did, upath, len)) != CNID_INVALID) {
1736         memcpy(rbuf, &id, sizeof(id));
1737         *rbuflen = sizeof(id);
1738         return AFP_OK;
1739     }
1740
1741     return afp_errno;
1742 }
1743
1744 /* ------------------------------- */
1745 struct reenum {
1746     struct vol *vol;
1747     cnid_t     did;
1748 };
1749
1750 static int reenumerate_loop(struct dirent *de, char *mname _U_, void *data)
1751 {
1752     struct path   path;
1753     struct reenum *param = data;
1754     struct vol    *vol = param->vol;  
1755     cnid_t        did  = param->did;
1756     cnid_t        aint;
1757     
1758     if ( lstat(de->d_name, &path.st) < 0 )
1759         return 0;
1760     
1761     /* update or add to cnid */
1762     aint = cnid_add(vol->v_cdb, &path.st, did, de->d_name, strlen(de->d_name), 0); /* ignore errors */
1763
1764     return 0;
1765 }
1766
1767 /* --------------------
1768  * Ok the db is out of synch with the dir.
1769  * but if it's a deleted file we don't want to do it again and again.
1770 */
1771 static int
1772 reenumerate_id(struct vol *vol, char *name, struct dir *dir)
1773 {
1774     int             ret;
1775     struct reenum   data;
1776     struct stat     st;
1777     
1778     if (vol->v_cdb == NULL) {
1779         return -1;
1780     }
1781     
1782     /* FIXME use of_statdir ? */
1783     if (lstat(name, &st)) {
1784         return -1;
1785     }
1786
1787     if (dirreenumerate(dir, &st)) {
1788         /* we already did it once and the dir haven't been modified */
1789         return dir->d_offcnt;
1790     }
1791     
1792     data.vol = vol;
1793     data.did = dir->d_did;
1794     if ((ret = for_each_dirent(vol, name, reenumerate_loop, (void *)&data)) >= 0) {
1795         setdiroffcnt(curdir, &st,  ret);
1796         dir->d_flags |= DIRF_CNID;
1797     }
1798
1799     return ret;
1800 }
1801
1802 /* ------------------------------
1803    resolve a file id */
1804 int afp_resolveid(AFPObj *obj _U_, char *ibuf, size_t ibuflen _U_, char *rbuf, size_t *rbuflen)
1805 {
1806     struct vol          *vol;
1807     struct dir          *dir;
1808     char                *upath;
1809     struct path         path;
1810     int                 err, retry=0;
1811     size_t              buflen;
1812     cnid_t              id, cnid;
1813     uint16_t            vid, bitmap;
1814
1815     static char buffer[12 + MAXPATHLEN + 1];
1816     int len = 12 + MAXPATHLEN + 1;
1817
1818     *rbuflen = 0;
1819     ibuf += 2;
1820
1821     memcpy(&vid, ibuf, sizeof(vid));
1822     ibuf += sizeof(vid);
1823
1824     if (NULL == ( vol = getvolbyvid( vid )) ) {
1825         return( AFPERR_PARAM);
1826     }
1827
1828     if (vol->v_cdb == NULL || !(vol->v_cdb->flags & CNID_FLAG_PERSISTENT)) {
1829         return AFPERR_NOOP;
1830     }
1831
1832     memcpy(&id, ibuf, sizeof( id ));
1833     ibuf += sizeof(id);
1834     cnid = id;
1835     
1836     if (!id) {
1837         /* some MacOS versions after a catsearch do a *lot* of afp_resolveid with 0 */
1838         return AFPERR_NOID;
1839     }
1840 retry:
1841     if (NULL == (upath = cnid_resolve(vol->v_cdb, &id, buffer, len)) ) {
1842         return AFPERR_NOID; /* was AFPERR_BADID, but help older Macs */
1843     }
1844
1845     if (NULL == ( dir = dirlookup( vol, id )) ) {
1846         return AFPERR_NOID; /* idem AFPERR_PARAM */
1847     }
1848     if (movecwd(vol, dir) < 0) {
1849         switch (errno) {
1850         case EACCES:
1851         case EPERM:
1852             return AFPERR_ACCESS;
1853         case ENOENT:
1854             return AFPERR_NOID;
1855         default:
1856             return AFPERR_PARAM;
1857         }
1858     }
1859
1860     memset(&path, 0, sizeof(path));
1861     path.u_name = upath;
1862     if ( of_stat(&path) < 0 ) {
1863 #ifdef ESTALE
1864         /* with nfs and our working directory is deleted */
1865         if (errno == ESTALE) {
1866             errno = ENOENT;
1867         }
1868 #endif  
1869         if ( errno == ENOENT && !retry) {
1870             /* cnid db is out of sync, reenumerate the directory and update ids */
1871             reenumerate_id(vol, ".", dir);
1872             id = cnid;
1873             retry = 1;
1874             goto retry;
1875         }
1876         switch (errno) {
1877         case EACCES:
1878         case EPERM:
1879             return AFPERR_ACCESS;
1880         case ENOENT:
1881             return AFPERR_NOID;
1882         default:
1883             return AFPERR_PARAM;
1884         }
1885     }
1886
1887     /* directories are bad */
1888     if (S_ISDIR(path.st.st_mode)) {
1889         /* OS9 and OSX don't return the same error code  */
1890         return (afp_version >=30)?AFPERR_NOID:AFPERR_BADTYPE;
1891     }
1892
1893     memcpy(&bitmap, ibuf, sizeof(bitmap));
1894     bitmap = ntohs( bitmap );
1895     if (NULL == (path.m_name = utompath(vol, upath, cnid, utf8_encoding()))) {
1896         return AFPERR_NOID;
1897     }
1898     path.id = cnid;
1899     if (AFP_OK != (err = getfilparams(vol, bitmap, &path , curdir, 
1900                             rbuf + sizeof(bitmap), &buflen))) {
1901         return err;
1902     }
1903     *rbuflen = buflen + sizeof(bitmap);
1904     memcpy(rbuf, ibuf, sizeof(bitmap));
1905
1906     return AFP_OK;
1907 }
1908
1909 /* ------------------------------ */
1910 int afp_deleteid(AFPObj *obj _U_, char *ibuf, size_t ibuflen _U_, char *rbuf _U_, size_t *rbuflen)
1911 {
1912     struct stat         st;
1913     struct vol          *vol;
1914     struct dir          *dir;
1915     char                *upath;
1916     int                 err;
1917     cnid_t              id;
1918     cnid_t              fileid;
1919     u_short             vid;
1920     static char buffer[12 + MAXPATHLEN + 1];
1921     int len = 12 + MAXPATHLEN + 1;
1922
1923     *rbuflen = 0;
1924     ibuf += 2;
1925
1926     memcpy(&vid, ibuf, sizeof(vid));
1927     ibuf += sizeof(vid);
1928
1929     if (NULL == ( vol = getvolbyvid( vid )) ) {
1930         return( AFPERR_PARAM);
1931     }
1932
1933     if (vol->v_cdb == NULL || !(vol->v_cdb->flags & CNID_FLAG_PERSISTENT)) {
1934         return AFPERR_NOOP;
1935     }
1936
1937     if (vol->v_flags & AFPVOL_RO)
1938         return AFPERR_VLOCK;
1939
1940     memcpy(&id, ibuf, sizeof( id ));
1941     ibuf += sizeof(id);
1942     fileid = id;
1943
1944     if (NULL == (upath = cnid_resolve(vol->v_cdb, &id, buffer, len)) ) {
1945         return AFPERR_NOID;
1946     }
1947
1948     if (NULL == ( dir = dirlookup( vol, id )) ) {
1949         if (afp_errno == AFPERR_NOOBJ) {
1950             err = AFPERR_NOOBJ;
1951             goto delete;
1952         }
1953         return( AFPERR_PARAM );
1954     }
1955
1956     err = AFP_OK;
1957     if ((movecwd(vol, dir) < 0) || (lstat(upath, &st) < 0)) {
1958         switch (errno) {
1959         case EACCES:
1960         case EPERM:
1961             return AFPERR_ACCESS;
1962 #ifdef ESTALE
1963         case ESTALE:
1964 #endif  
1965         case ENOENT:
1966             /* still try to delete the id */
1967             err = AFPERR_NOOBJ;
1968             break;
1969         default:
1970             return AFPERR_PARAM;
1971         }
1972     }
1973     else if (S_ISDIR(st.st_mode)) /* directories are bad */
1974         return AFPERR_BADTYPE;
1975
1976 delete:
1977     if (cnid_delete(vol->v_cdb, fileid)) {
1978         switch (errno) {
1979         case EROFS:
1980             return AFPERR_VLOCK;
1981         case EPERM:
1982         case EACCES:
1983             return AFPERR_ACCESS;
1984         default:
1985             return AFPERR_PARAM;
1986         }
1987     }
1988
1989     return err;
1990 }
1991
1992 /* ------------------------------ */
1993 static struct adouble *find_adouble(struct path *path, struct ofork **of, struct adouble *adp)
1994 {
1995     int             ret;
1996
1997     if (path->st_errno) {
1998         switch (path->st_errno) {
1999         case ENOENT:
2000             afp_errno = AFPERR_NOID;
2001             break;
2002         case EPERM:
2003         case EACCES:
2004             afp_errno = AFPERR_ACCESS;
2005             break;
2006         default:
2007             afp_errno = AFPERR_PARAM;
2008             break;
2009         }
2010         return NULL;
2011     }
2012     /* we use file_access both for legacy Mac perm and
2013      * for unix privilege, rename will take care of folder perms
2014     */
2015     if (file_access(path, OPENACC_WR ) < 0) {
2016         afp_errno = AFPERR_ACCESS;
2017         return NULL;
2018     }
2019     
2020     if ((*of = of_findname(path))) {
2021         /* reuse struct adouble so it won't break locks */
2022         adp = (*of)->of_ad;
2023     }
2024     else {
2025         ret = ad_open(adp, path->u_name, ADFLAGS_HF | ADFLAGS_RDWR);
2026         /* META and HF */
2027         if ( !ret && ad_reso_fileno(adp) != -1 && !(adp->ad_resource_fork.adf_flags & ( O_RDWR | O_WRONLY))) {
2028             /* from AFP spec.
2029              * The user must have the Read & Write privilege for both files in order to use this command.
2030              */
2031             ad_close(adp, ADFLAGS_HF);
2032             afp_errno = AFPERR_ACCESS;
2033             return NULL;
2034         }
2035     }
2036     return adp;
2037 }
2038
2039 #define APPLETEMP ".AppleTempXXXXXX"
2040
2041 int afp_exchangefiles(AFPObj *obj, char *ibuf, size_t ibuflen _U_, char *rbuf _U_, size_t *rbuflen)
2042 {
2043     struct stat         srcst, destst;
2044     struct vol          *vol;
2045     struct dir          *dir, *sdir;
2046     char                *spath, temp[17], *p;
2047     char                *supath, *upath;
2048     struct path         *path;
2049     int                 err;
2050     struct adouble      ads;
2051     struct adouble      add;
2052     struct adouble      *adsp = NULL;
2053     struct adouble      *addp = NULL;
2054     struct ofork        *s_of = NULL;
2055     struct ofork        *d_of = NULL;
2056     int                 crossdev;
2057     
2058     int                 slen, dlen;
2059     uint32_t            sid, did;
2060     uint16_t            vid;
2061
2062     uid_t              uid;
2063     gid_t              gid;
2064
2065     *rbuflen = 0;
2066     ibuf += 2;
2067
2068     memcpy(&vid, ibuf, sizeof(vid));
2069     ibuf += sizeof(vid);
2070
2071     if (NULL == ( vol = getvolbyvid( vid )) ) {
2072         return( AFPERR_PARAM);
2073     }
2074
2075     if ((vol->v_flags & AFPVOL_RO))
2076         return AFPERR_VLOCK;
2077
2078     /* source and destination dids */
2079     memcpy(&sid, ibuf, sizeof(sid));
2080     ibuf += sizeof(sid);
2081     memcpy(&did, ibuf, sizeof(did));
2082     ibuf += sizeof(did);
2083
2084     /* source file */
2085     if (NULL == (dir = dirlookup( vol, sid )) ) {
2086         return afp_errno; /* was AFPERR_PARAM */
2087     }
2088
2089     if (NULL == ( path = cname( vol, dir, &ibuf )) ) {
2090         return get_afp_errno(AFPERR_NOOBJ); 
2091     }
2092
2093     if ( path_isadir(path) ) {
2094         return AFPERR_BADTYPE;   /* it's a dir */
2095     }
2096
2097     /* save some stuff */
2098     srcst = path->st;
2099     sdir = curdir;
2100     spath = obj->oldtmp;
2101     supath = obj->newtmp;
2102     strcpy(spath, path->m_name);
2103     strcpy(supath, path->u_name); /* this is for the cnid changing */
2104     p = absupath( vol, sdir, supath);
2105     if (!p) {
2106         /* pathname too long */
2107         return AFPERR_PARAM ;
2108     }
2109     
2110     ad_init(&ads, vol);
2111     if (!(adsp = find_adouble( path, &s_of, &ads))) {
2112         return afp_errno;
2113     }
2114
2115     /* ***** from here we may have resource fork open **** */
2116     
2117     /* look for the source cnid. if it doesn't exist, don't worry about
2118      * it. */
2119     sid = cnid_lookup(vol->v_cdb, &srcst, sdir->d_did, supath,slen = strlen(supath));
2120
2121     if (NULL == ( dir = dirlookup( vol, did )) ) {
2122         err = afp_errno; /* was AFPERR_PARAM */
2123         goto err_exchangefile;
2124     }
2125
2126     if (NULL == ( path = cname( vol, dir, &ibuf )) ) {
2127         err = get_afp_errno(AFPERR_NOOBJ); 
2128         goto err_exchangefile;
2129     }
2130
2131     if ( path_isadir(path) ) {
2132         err = AFPERR_BADTYPE;
2133         goto err_exchangefile;
2134     }
2135
2136     /* FPExchangeFiles is the only call that can return the SameObj
2137      * error */
2138     if ((curdir == sdir) && strcmp(spath, path->m_name) == 0) {
2139         err = AFPERR_SAMEOBJ;
2140         goto err_exchangefile;
2141     }
2142
2143     ad_init(&add, vol);
2144     if (!(addp = find_adouble( path, &d_of, &add))) {
2145         err = afp_errno;
2146         goto err_exchangefile;
2147     }
2148     destst = path->st;
2149
2150     /* they are not on the same device and at least one is open
2151      * FIXME broken for for crossdev and adouble v2
2152      * return an error 
2153     */
2154     crossdev = (srcst.st_dev != destst.st_dev);
2155     if (/* (d_of || s_of)  && */ crossdev) {
2156         err = AFPERR_MISC;
2157         goto err_exchangefile;
2158     }
2159
2160     /* look for destination id. */
2161     upath = path->u_name;
2162     did = cnid_lookup(vol->v_cdb, &destst, curdir->d_did, upath, dlen = strlen(upath));
2163
2164     /* construct a temp name.
2165      * NOTE: the temp file will be in the dest file's directory. it
2166      * will also be inaccessible from AFP. */
2167     memcpy(temp, APPLETEMP, sizeof(APPLETEMP));
2168     if (!mktemp(temp)) {
2169         err = AFPERR_MISC;
2170         goto err_exchangefile;
2171     }
2172     
2173     if (crossdev) {
2174         /* FIXME we need to close fork for copy, both s_of and d_of are null */
2175        ad_close(adsp, ADFLAGS_HF);
2176        ad_close(addp, ADFLAGS_HF);
2177     }
2178
2179     /* now, quickly rename the file. we error if we can't. */
2180     if ((err = renamefile(vol, -1, p, temp, temp, adsp)) != AFP_OK)
2181         goto err_exchangefile;
2182     of_rename(vol, s_of, sdir, spath, curdir, temp);
2183
2184     /* rename destination to source */
2185     if ((err = renamefile(vol, -1, upath, p, spath, addp)) != AFP_OK)
2186         goto err_src_to_tmp;
2187     of_rename(vol, d_of, curdir, path->m_name, sdir, spath);
2188
2189     /* rename temp to destination */
2190     if ((err = renamefile(vol, -1, temp, upath, path->m_name, adsp)) != AFP_OK)
2191         goto err_dest_to_src;
2192     of_rename(vol, s_of, curdir, temp, curdir, path->m_name);
2193
2194     /* id's need switching. src -> dest and dest -> src. 
2195      * we need to re-stat() if it was a cross device copy.
2196     */
2197     if (sid)
2198         cnid_delete(vol->v_cdb, sid);
2199     if (did)
2200         cnid_delete(vol->v_cdb, did);
2201
2202     if ((did && ( (crossdev && lstat( upath, &srcst) < 0) || 
2203                 cnid_update(vol->v_cdb, did, &srcst, curdir->d_did,upath, dlen) < 0))
2204        ||
2205        (sid && ( (crossdev && lstat(p, &destst) < 0) ||
2206                 cnid_update(vol->v_cdb, sid, &destst, sdir->d_did,supath, slen) < 0))
2207     ) {
2208         switch (errno) {
2209         case EPERM:
2210         case EACCES:
2211             err = AFPERR_ACCESS;
2212             break;
2213         default:
2214             err = AFPERR_PARAM;
2215         }
2216         goto err_temp_to_dest;
2217     }
2218     
2219     /* here we need to reopen if crossdev */
2220     if (sid && ad_setid(addp, destst.st_dev, destst.st_ino,  sid, sdir->d_did, vol->v_stamp)) 
2221     {
2222        ad_flush( addp );
2223     }
2224         
2225     if (did && ad_setid(adsp, srcst.st_dev, srcst.st_ino,  did, curdir->d_did, vol->v_stamp)) 
2226     {
2227        ad_flush( adsp );
2228     }
2229
2230     /* change perms, src gets dest perm and vice versa */
2231
2232     uid = geteuid();
2233     gid = getegid();
2234     if (seteuid(0)) {
2235         LOG(log_error, logtype_afpd, "seteuid failed %s", strerror(errno));
2236         err = AFP_OK; /* ignore error */
2237         goto err_temp_to_dest;
2238     }
2239
2240     /*
2241      * we need to exchange ACL entries as well
2242      */
2243     /* exchange_acls(vol, p, upath); */
2244
2245     path->st = srcst;
2246     path->st_valid = 1;
2247     path->st_errno = 0;
2248     path->m_name = NULL;
2249     path->u_name = upath;
2250
2251     setfilunixmode(vol, path, destst.st_mode);
2252     setfilowner(vol, destst.st_uid, destst.st_gid, path);
2253
2254     path->st = destst;
2255     path->st_valid = 1;
2256     path->st_errno = 0;
2257     path->u_name = p;
2258
2259     setfilunixmode(vol, path, srcst.st_mode);
2260     setfilowner(vol, srcst.st_uid, srcst.st_gid, path);
2261
2262     if ( setegid(gid) < 0 || seteuid(uid) < 0) {
2263         LOG(log_error, logtype_afpd, "can't seteuid back %s", strerror(errno));
2264         exit(EXITERR_SYS);
2265     }
2266
2267     err = AFP_OK;
2268     goto err_exchangefile;
2269
2270     /* all this stuff is so that we can unwind a failed operation
2271      * properly. */
2272 err_temp_to_dest:
2273     /* rename dest to temp */
2274     renamefile(vol, -1, upath, temp, temp, adsp);
2275     of_rename(vol, s_of, curdir, upath, curdir, temp);
2276
2277 err_dest_to_src:
2278     /* rename source back to dest */
2279     renamefile(vol, -1, p, upath, path->m_name, addp);
2280     of_rename(vol, d_of, sdir, spath, curdir, path->m_name);
2281
2282 err_src_to_tmp:
2283     /* rename temp back to source */
2284     renamefile(vol, -1, temp, p, spath, adsp);
2285     of_rename(vol, s_of, curdir, temp, sdir, spath);
2286
2287 err_exchangefile:
2288     if ( !s_of && adsp && ad_meta_fileno(adsp) != -1 ) { /* META */
2289        ad_close(adsp, ADFLAGS_HF);
2290     }
2291     if ( !d_of && addp && ad_meta_fileno(addp) != -1 ) {/* META */
2292        ad_close(addp, ADFLAGS_HF);
2293     }
2294
2295     struct dir *cached;
2296     if ((cached = dircache_search_by_did(vol, sid)) != NULL)
2297         (void)dir_remove(vol, cached);
2298     if ((cached = dircache_search_by_did(vol, did)) != NULL)
2299         (void)dir_remove(vol, cached);
2300
2301     return err;
2302 }