etc/afpd/ofork.c

   1 /*
   2  * $Id: ofork.c,v 1.13 2002-04-22 07:46:00 rlewczuk Exp $
   3  *
   4  * Copyright (c) 1996 Regents of The University of Michigan.
   5  * All Rights Reserved.  See COPYRIGHT.
   6  */
   7
   8 #ifdef HAVE_CONFIG_H
   9 #include "config.h"
  10 #endif /* HAVE_CONFIG_H */
  11
  12 #include <stdio.h>
  13 #include <stdlib.h>
  14 #include <string.h>
  15 #include <sys/stat.h> /* works around a bug */
  16 #include <sys/param.h>
  17 #include <atalk/logger.h>
  18 #include <errno.h>
  19
  20 #include <atalk/adouble.h>
  21
  22 #include "globals.h"
  23 #include "volume.h"
  24 #include "directory.h"
  25 #include "fork.h"
  26
  27 /* we need to have a hashed list of oforks (by name). just hash
  28  * by first letter. */
  29 #define OFORK_HASHSIZE  64
  30 static struct ofork     *ofork_table[OFORK_HASHSIZE];
  31
  32 static struct ofork     **oforks = NULL;
  33 static int              nforks = 0;
  34 static u_short          lastrefnum = 0;
  35
  36
  37 /* OR some of each character for the hash*/
  38 static __inline__ unsigned long hashfn(const char *name)
  39 {
  40     unsigned long i = 0;
  41
  42     while (*name) {
  43         i = ((i << 4) | (8*sizeof(i) - 4)) ^ *name++;
  44     }
  45     return i & (OFORK_HASHSIZE - 1);
  46 }
  47
  48 static __inline__ void of_hash(struct ofork *of)
  49 {
  50     struct ofork **table;
  51
  52     table = &ofork_table[hashfn(of->of_name)];
  53     if ((of->next = *table) != NULL)
  54         (*table)->prevp = &of->next;
  55     *table = of;
  56     of->prevp = table;
  57 }
  58
  59 static __inline__ void of_unhash(struct ofork *of)
  60 {
  61     if (of->prevp) {
  62         if (of->next)
  63             of->next->prevp = of->prevp;
  64         *(of->prevp) = of->next;
  65     }
  66 }
  67
  68 void of_pforkdesc( f )
  69 FILE    *f;
  70 {
  71     u_short     ofrefnum;
  72
  73     if (!oforks)
  74         return;
  75
  76     for ( ofrefnum = 0; ofrefnum < nforks; ofrefnum++ ) {
  77         if ( oforks[ ofrefnum ] != NULL ) {
  78             fprintf( f, "%hu <%s>\n", ofrefnum, oforks[ ofrefnum ]->of_name);
  79         }
  80     }
  81 }
  82
  83 int of_flush(const struct vol *vol)
  84 {
  85     u_int16_t   refnum;
  86
  87     if (!oforks)
  88         return 0;
  89
  90     for ( refnum = 0; refnum < nforks; refnum++ ) {
  91         if (oforks[ refnum ] != NULL && (oforks[refnum]->of_vol == vol) &&
  92                 flushfork( oforks[ refnum ] ) < 0 ) {
  93             LOG(log_error, logtype_afpd, "of_flush: %s", strerror(errno) );
  94         }
  95     }
  96     return( 0 );
  97 }
  98
  99
 100 int of_rename(vol, olddir, oldpath, newdir, newpath)
 101 const struct vol *vol;
 102 struct dir *olddir, *newdir;
 103 const char *oldpath, *newpath;
 104 {
 105     struct ofork *of, *next, *d_ofork;
 106
 107     next = ofork_table[hashfn(oldpath)];
 108     while ((of = next)) {
 109         next = next->next; /* so we can unhash and still be all right. */
 110
 111         if ((vol == of->of_vol) && (olddir == of->of_dir) &&
 112                 (strcmp(of->of_name, oldpath) == 0)) {
 113             of_unhash(of);
 114             strncpy( of->of_name, newpath, of->of_namelen);
 115             of->of_d_prev->of_d_next = of->of_d_next;
 116             of->of_d_next->of_d_prev = of->of_d_prev;
 117             if (of->of_dir->d_ofork == of) {
 118                 of->of_dir->d_ofork = (of == of->of_d_next) ? NULL : of->of_d_next;
 119             }
 120             of->of_dir = newdir;
 121             if (!(d_ofork = newdir->d_ofork)) {
 122                 newdir->d_ofork = of;
 123                 of->of_d_next = of->of_d_prev = of;
 124             } else {
 125                 of->of_d_next = d_ofork;
 126                 of->of_d_prev = d_ofork->of_d_prev;
 127                 of->of_d_prev->of_d_next = of;
 128                 d_ofork->of_d_prev = of;
 129             }
 130             of_hash(of);
 131         }
 132     }
 133
 134     return AFP_OK;
 135 }
 136
 137 struct ofork *
 138             of_alloc(vol, dir, path, ofrefnum, eid, ad)
 139             struct vol          *vol;
 140 struct dir              *dir;
 141 char            *path;
 142 u_int16_t               *ofrefnum;
 143 const int           eid;
 144 struct adouble      *ad;
 145 {
 146     struct ofork        *of, *d_ofork;
 147     u_int16_t           refnum, of_refnum;
 148
 149     int                 i;
 150
 151     if (!oforks) {
 152         nforks = (getdtablesize() - 10) / 2;
 153         oforks = (struct ofork **) calloc(nforks, sizeof(struct ofork *));
 154         if (!oforks)
 155             return NULL;
 156     }
 157
 158     for ( refnum = ++lastrefnum, i = 0; i < nforks; i++, refnum++ ) {
 159         /* cf AFP3.0.pdf, File fork page 40 */
 160         if (!refnum)
 161             refnum++;
 162         if ( oforks[ refnum % nforks ] == NULL ) {
 163             break;
 164         }
 165     }
 166     /* grr, Apple and their 'uniquely identifies'
 167           the next line is a protection against
 168           of_alloc()
 169              refnum % nforks = 3
 170              lastrefnum = 3
 171              oforks[3] != NULL
 172              refnum = 4
 173              oforks[4] == NULL
 174              return 4
 175
 176           close(oforks[4])
 177
 178           of_alloc()
 179              refnum % nforks = 4
 180              ...
 181              return 4
 182          same if lastrefnum++ rather than ++lastrefnum.
 183     */
 184     lastrefnum = refnum;
 185     if ( i == nforks ) {
 186         LOG(log_error, logtype_afpd, "of_alloc: maximum number of forks exceeded.");
 187         return( NULL );
 188     }
 189
 190     of_refnum = refnum % nforks;
 191     if (( oforks[ of_refnum ] =
 192                 (struct ofork *)malloc( sizeof( struct ofork ))) == NULL ) {
 193         LOG(log_error, logtype_afpd, "of_alloc: malloc: %s", strerror(errno) );
 194         return NULL;
 195     }
 196     of = oforks[of_refnum];
 197
 198     /* see if we need to allocate space for the adouble struct */
 199     if (!ad) {
 200         ad = malloc( sizeof( struct adouble ) );
 201         if (!ad) {
 202             LOG(log_error, logtype_afpd, "of_alloc: malloc: %s", strerror(errno) );
 203             return NULL;
 204         }
 205
 206         /* initialize to zero. This is important to ensure that
 207            ad_open really does reinitialize the structure. */
 208         memset( ad, 0, sizeof( struct adouble ) );
 209     } else {
 210         /* Increase the refcount on this struct adouble. This is
 211            decremented again in oforc_dealloc. */
 212         ad->ad_refcount++;
 213     }
 214
 215     of->of_ad = ad;
 216
 217     of->of_vol = vol;
 218     of->of_dir = dir;
 219
 220     if (!(d_ofork = dir->d_ofork)) {
 221         dir->d_ofork = of;
 222         of->of_d_next = of->of_d_prev = of;
 223     } else {
 224         of->of_d_next = d_ofork;
 225         of->of_d_prev = d_ofork->of_d_prev;
 226         d_ofork->of_d_prev->of_d_next = of;
 227         d_ofork->of_d_prev = of;
 228     }
 229
 230     /* here's the deal: we allocate enough for the standard mac file length.
 231      * in the future, we'll reallocate in fairly large jumps in case
 232      * of long unicode names */
 233     if (( of->of_name =(char *)malloc(MACFILELEN + 1)) ==
 234             NULL ) {
 235         LOG(log_error, logtype_afpd, "of_alloc: malloc: %s", strerror(errno) );
 236         if (!ad)
 237             free(of->of_ad);
 238         free(of);
 239         oforks[ of_refnum ] = NULL;
 240         return NULL;
 241     }
 242     strncpy( of->of_name, path, of->of_namelen = MACFILELEN + 1);
 243     *ofrefnum = refnum;
 244     of->of_refnum = refnum;
 245     of_hash(of);
 246
 247     if (eid == ADEID_DFORK)
 248         of->of_flags = AFPFORK_DATA;
 249     else
 250         of->of_flags = AFPFORK_RSRC;
 251
 252     return( of );
 253 }
 254
 255 struct ofork *of_find(const u_int16_t ofrefnum )
 256 {
 257     if (!oforks || !nforks)
 258         return NULL;
 259
 260     return( oforks[ ofrefnum % nforks ] );
 261 }
 262
 263 struct ofork *
 264             of_findname(const struct vol *vol, const struct dir *dir, const char *name)
 265 {
 266     struct ofork *of;
 267
 268     for (of = ofork_table[hashfn(name)]; of; of = of->next) {
 269         if ((vol == of->of_vol) && (dir == of->of_dir) &&
 270                 (strcmp(of->of_name, name) == 0))
 271             return of;
 272     }
 273
 274     return NULL;
 275 }
 276
 277
 278 void of_dealloc( of )
 279 struct ofork    *of;
 280 {
 281     if (!oforks)
 282         return;
 283
 284     of_unhash(of);
 285
 286     /* detach ofork */
 287     of->of_d_prev->of_d_next = of->of_d_next;
 288     of->of_d_next->of_d_prev = of->of_d_prev;
 289     if (of->of_dir->d_ofork == of) {
 290         of->of_dir->d_ofork = (of == of->of_d_next) ? NULL : of->of_d_next;
 291     }
 292
 293     oforks[ of->of_refnum % nforks ] = NULL;
 294     free( of->of_name );
 295
 296     /* decrease refcount */
 297     of->of_ad->ad_refcount--;
 298
 299     if ( of->of_ad->ad_refcount <= 0) {
 300         free( of->of_ad);
 301     } else {/* someone's still using it. just free this user's locks */
 302         ad_unlock(of->of_ad, of->of_refnum);
 303     }
 304
 305     free( of );
 306 }