]> arthur.barton.de Git - netatalk.git/blobdiff - etc/afpd/afp_config.c
Merge master
[netatalk.git] / etc / afpd / afp_config.c
index df606d089d073d96e90e14a107c82fa9d4098f43..8c997ebe94f7999e0e51b248a304e95fd38997da 100644 (file)
@@ -1,6 +1,4 @@
 /*
- * $Id: afp_config.c,v 1.12 2001-12-16 18:52:46 jmarcus Exp $
- *
  * Copyright (c) 1997 Adrian Sun (asun@zoology.washington.edu)
  * All Rights Reserved.  See COPYRIGHT.
  */
 #include <stdlib.h>
 #include <string.h>
 #include <errno.h>
-
-/* STDC check */
-#if STDC_HEADERS
 #include <string.h>
-#else /* STDC_HEADERS */
-#ifndef HAVE_STRCHR
-#define strchr index
-#define strrchr index
-#endif /* HAVE_STRCHR */
-char *strchr (), *strrchr ();
-#ifndef HAVE_MEMCPY
-#define memcpy(d,s,n) bcopy ((s), (d), (n))
-#define memmove(d,s,n) bcopy ((s), (d), (n))
-#endif /* ! HAVE_MEMCPY */
-#endif /* STDC_HEADERS */
-
-#ifdef HAVE_UNISTD_H
 #include <unistd.h>
-#endif /* HAVE_UNISTD_H */
 #include <ctype.h>
-#include <syslog.h>
-
 #include <sys/socket.h>
 #include <netinet/in.h>
 #include <arpa/inet.h>
 
+#ifdef USE_SRVLOC
+#include <slp.h>
+#endif /* USE_SRVLOC */
+
+#include <atalk/logger.h>
+#include <atalk/util.h>
 #include <atalk/dsi.h>
-#include <atalk/atp.h>
-#include <atalk/asp.h>
-#include <atalk/nbp.h>
 #include <atalk/afp.h>
 #include <atalk/compat.h>
 #include <atalk/server_child.h>
-#ifdef USE_SRVLOC
-#include <slp.h>
-static char srvloc_url[512];
-#endif /* USE_SRVLOC */
+
+#ifdef HAVE_LDAP
+#include <atalk/ldapconfig.h>
+#endif
 
 #include "globals.h"
 #include "afp_config.h"
 #include "uam_auth.h"
 #include "status.h"
+#include "volume.h"
+#include "afp_zeroconf.h"
 
 #define LINESIZE 1024  
 
@@ -77,15 +61,6 @@ void configfree(AFPConfig *configs, const AFPConfig *config)
         }
 
         switch (p->obj.proto) {
-#ifndef NO_DDP
-        case AFPPROTO_ASP:
-            free(p->obj.Obj);
-            free(p->obj.Type);
-            free(p->obj.Zone);
-            atp_close(((ASP) p->obj.handle)->asp_atp);
-            free(p->obj.handle);
-            break;
-#endif /* no afp/asp */
         case AFPPROTO_DSI:
             close(p->fd);
             free(p->obj.handle);
@@ -93,180 +68,121 @@ void configfree(AFPConfig *configs, const AFPConfig *config)
         }
         free(p);
     }
+
+    /* the master loaded the volumes for zeroconf, get rid of that */
+    unload_volumes_and_extmap();
 }
 
 #ifdef USE_SRVLOC
-static void SRVLOC_callback(SLPHandle hslp, SLPError errcode, void *cookie) {
+static void SRVLOC_callback(SLPHandle hslp _U_, SLPError errcode, void *cookie) {
     *(SLPError*)cookie = errcode;
 }
+
+static char hex[17] = "0123456789abcdef";
+
+static char * srvloc_encode(const struct afp_options *options, const char *name)
+{
+       static char buf[512];
+       char *conv_name;
+       unsigned char *p;
+       unsigned int i = 0;
+
+       /* Convert name to maccharset */
+        if ((size_t)-1 ==(convert_string_allocate( options->unixcharset, options->maccharset,
+                        name, -1, &conv_name)) )
+               return (char*)name;
+
+       /* Escape characters */
+       p = conv_name;
+       while (*p && i<(sizeof(buf)-4)) {
+           if (*p == '@')
+               break;
+           else if (isspace(*p)) {
+               buf[i++] = '%';
+               buf[i++] = '2';
+               buf[i++] = '0';
+               p++;
+           }   
+           else if ((!isascii(*p)) || *p <= 0x2f || *p == 0x3f ) {
+               buf[i++] = '%';
+               buf[i++] = hex[*p >> 4];
+               buf[i++] = hex[*p++ & 15];
+           }
+           else {
+               buf[i++] = *p++;
+           }
+       }
+       buf[i] = '\0';
+
+       free (conv_name);
+
+       return buf;
+}
 #endif /* USE_SRVLOC */
 
-#ifdef USE_SRVLOC
 static void dsi_cleanup(const AFPConfig *config)
 {
+#ifdef USE_SRVLOC
     SLPError err;
     SLPError callbackerr;
     SLPHandle hslp;
+    DSI *dsi = (DSI *)config->obj.handle;
+
+    /*  Do nothing if we didn't register.  */
+    if (!dsi || dsi->srvloc_url[0] == '\0')
+        return;
+
     err = SLPOpen("en", SLP_FALSE, &hslp);
     if (err != SLP_OK) {
-        syslog(LOG_ERR, "dsi_cleanup: Error opening SRVLOC handle");
+        LOG(log_error, logtype_afpd, "dsi_cleanup: Error opening SRVLOC handle");
         goto srvloc_dereg_err;
     }
 
     err = SLPDereg(hslp,
-                   srvloc_url,
+                   dsi->srvloc_url,
                    SRVLOC_callback,
                    &callbackerr);
     if (err != SLP_OK) {
-        syslog(LOG_ERR, "dsi_cleanup: Error unregistering %s from SRVLOC", srvloc_url);
+        LOG(log_error, logtype_afpd, "dsi_cleanup: Error unregistering %s from SRVLOC", dsi->srvloc_url);
         goto srvloc_dereg_err;
     }
 
     if (callbackerr != SLP_OK) {
-        syslog(LOG_ERR, "dsi_cleanup: Error in callback while trying to unregister %s from SRVLOC (%d)", srvloc_url, callbackerr);
+        LOG(log_error, logtype_afpd, "dsi_cleanup: Error in callback while trying to unregister %s from SRVLOC (%d)", dsi->srvloc_url, callbackerr);
         goto srvloc_dereg_err;
     }
 
 srvloc_dereg_err:
+    dsi->srvloc_url[0] = '\0';
     SLPClose(hslp);
-}
 #endif /* USE_SRVLOC */
-
-#ifndef NO_DDP
-static void asp_cleanup(const AFPConfig *config)
-{
-    nbp_unrgstr(config->obj.Obj, config->obj.Type, config->obj.Zone,
-                &config->obj.options.ddpaddr);
 }
 
-/* these two are almost identical. it should be possible to collapse them
- * into one with minimal junk. */
-static int asp_start(AFPConfig *config, AFPConfig *configs,
-                     server_child *server_children)
+static afp_child_t *dsi_start(AFPConfig *config, AFPConfig *configs,
+                              server_child *server_children)
 {
-    ASP asp;
-
-    if (!(asp = asp_getsession(config->obj.handle, server_children,
-                               config->obj.options.tickleval))) {
-        syslog( LOG_ERR, "main: asp_getsession: %s", strerror(errno) );
-        exit( 1 );
-    }
+    DSI *dsi = config->obj.handle;
+    afp_child_t *child = NULL;
 
-    if (asp->child) {
-        configfree(configs, config); /* free a bunch of stuff */
-        afp_over_asp(&config->obj);
-        exit (0);
-    }
-
-    return 0;
-}
-#endif /* no afp/asp */
-
-static int dsi_start(AFPConfig *config, AFPConfig *configs,
-                     server_child *server_children)
-{
-    DSI *dsi;
-
-    if (!(dsi = dsi_getsession(config->obj.handle, server_children,
-                               config->obj.options.tickleval))) {
-        syslog( LOG_ERR, "main: dsi_getsession: %s", strerror(errno) );
-        exit( 1 );
+    if (!(child = dsi_getsession(dsi,
+                                 server_children,
+                                 config->obj.options.tickleval))) {
+        LOG(log_error, logtype_afpd, "dsi_start: session error: %s", strerror(errno));
+        return NULL;
     }
 
     /* we've forked. */
-    if (dsi->child) {
+    if (parent_or_child == 1) {
         configfree(configs, config);
+        config->obj.ipc_fd = child->ipc_fds[1];
+        close(child->ipc_fds[0]); /* Close parent IPC fd */
+        free(child);
         afp_over_dsi(&config->obj); /* start a session */
         exit (0);
     }
 
-    return 0;
-}
-
-#ifndef NO_DDP
-static AFPConfig *ASPConfigInit(const struct afp_options *options,
-                                unsigned char *refcount)
-{
-    AFPConfig *config;
-    ATP atp;
-    ASP asp;
-    char *Obj, *Type = "AFPServer", *Zone = "*";
-
-    if ((config = (AFPConfig *) calloc(1, sizeof(AFPConfig))) == NULL)
-        return NULL;
-
-    if ((atp = atp_open(ATADDR_ANYPORT, &options->ddpaddr)) == NULL)  {
-        syslog( LOG_ERR, "main: atp_open: %s", strerror(errno) );
-        free(config);
-        return NULL;
-    }
-
-    if ((asp = asp_init( atp )) == NULL) {
-        syslog( LOG_ERR, "main: asp_init: %s", strerror(errno) );
-        atp_close(atp);
-        free(config);
-        return NULL;
-    }
-
-    /* register asp server */
-    Obj = (char *) options->hostname;
-    if (nbp_name(options->server, &Obj, &Type, &Zone )) {
-        syslog( LOG_ERR, "main: can't parse %s", options->server );
-        goto serv_free_return;
-    }
-
-    /* dup Obj, Type and Zone as they get assigned to a single internal
-     * buffer by nbp_name */
-    if ((config->obj.Obj  = strdup(Obj)) == NULL)
-        goto serv_free_return;
-
-    if ((config->obj.Type = strdup(Type)) == NULL) {
-        free(config->obj.Obj);
-        goto serv_free_return;
-    }
-
-    if ((config->obj.Zone = strdup(Zone)) == NULL) {
-        free(config->obj.Obj);
-        free(config->obj.Type);
-        goto serv_free_return;
-    }
-
-    /* make sure we're not registered */
-    nbp_unrgstr(Obj, Type, Zone, &options->ddpaddr);
-    if (nbp_rgstr( atp_sockaddr( atp ), Obj, Type, Zone ) < 0 ) {
-        syslog( LOG_ERR, "Can't register %s:%s@%s", Obj, Type, Zone );
-        free(config->obj.Obj);
-        free(config->obj.Type);
-        free(config->obj.Zone);
-        goto serv_free_return;
-    }
-
-    syslog( LOG_INFO, "%s:%s@%s started on %u.%u:%u (%s)", Obj, Type, Zone,
-            ntohs( atp_sockaddr( atp )->sat_addr.s_net ),
-            atp_sockaddr( atp )->sat_addr.s_node,
-            atp_sockaddr( atp )->sat_port, VERSION );
-
-    config->fd = atp_fileno(atp);
-    config->obj.handle = asp;
-    config->obj.config = config;
-    config->obj.proto = AFPPROTO_ASP;
-
-    memcpy(&config->obj.options, options, sizeof(struct afp_options));
-    config->optcount = refcount;
-    (*refcount)++;
-
-    config->server_start = asp_start;
-    config->server_cleanup = asp_cleanup;
-
-    return config;
-
-serv_free_return:
-                    asp_close(asp);
-    free(config);
-    return NULL;
+    return child;
 }
-#endif /* no afp/asp */
-
 
 static AFPConfig *DSIConfigInit(const struct afp_options *options,
                                 unsigned char *refcount,
@@ -275,85 +191,111 @@ static AFPConfig *DSIConfigInit(const struct afp_options *options,
     AFPConfig *config;
     DSI *dsi;
     char *p, *q;
-#ifdef USE_SRVLOC
-    SLPError err;
-    SLPError callbackerr;
-    SLPHandle hslp;
-    struct servent *afpovertcp;
-#endif /* USE_SRVLOC */
 
     if ((config = (AFPConfig *) calloc(1, sizeof(AFPConfig))) == NULL) {
-        syslog( LOG_ERR, "DSIConfigInit: malloc(config): %s", strerror(errno) );
+        LOG(log_error, logtype_afpd, "DSIConfigInit: malloc(config): %s", strerror(errno) );
         return NULL;
     }
 
+    LOG(log_debug, logtype_afpd, "DSIConfigInit: hostname: %s, ip/port: %s/%s, ",
+        options->hostname,
+        options->ipaddr ? options->ipaddr : "default",
+        options->port ? options->port : "548");
+
     if ((dsi = dsi_init(protocol, "afpd", options->hostname,
                         options->ipaddr, options->port,
                         options->flags & OPTION_PROXY,
                         options->server_quantum)) == NULL) {
-        syslog( LOG_ERR, "main: dsi_init: %s", strerror(errno) );
+        LOG(log_error, logtype_afpd, "main: dsi_init: %s", strerror(errno) );
         free(config);
         return NULL;
     }
+    dsi->dsireadbuf = options->dsireadbuf;
 
     if (options->flags & OPTION_PROXY) {
-        syslog(LOG_INFO, "ASIP proxy initialized for %s:%d (%s)",
-               inet_ntoa(dsi->server.sin_addr), ntohs(dsi->server.sin_port),
-               VERSION);
+        LOG(log_note, logtype_afpd, "AFP/TCP proxy initialized for %s:%d (%s)",
+            getip_string((struct sockaddr *)&dsi->server), getip_port((struct sockaddr *)&dsi->server), VERSION);
     } else {
-        syslog(LOG_INFO, "ASIP started on %s:%d(%d) (%s)",
-               inet_ntoa(dsi->server.sin_addr), ntohs(dsi->server.sin_port),
-               dsi->serversock, VERSION);
+        LOG(log_note, logtype_afpd, "AFP/TCP started, advertising %s:%d (%s)",
+            getip_string((struct sockaddr *)&dsi->server), getip_port((struct sockaddr *)&dsi->server), VERSION);
     }
 
 #ifdef USE_SRVLOC
-    err = SLPOpen("en", SLP_FALSE, &hslp);
-    if (err != SLP_OK) {
-        syslog(LOG_ERR, "DSIConfigInit: Error opening SRVLOC handle");
-        goto srvloc_reg_err;
-    }
-
-    /* XXX We don't want to tack on the port number if we don't have to.  Why?
-     * Well, this seems to break MacOS < 10.  If the user _really_ wants to
-     * use a non-default port, they can, but be aware, this server might not
-     * show up int the Network Browser. */
-    afpovertcp = getservbyname("afpovertcp", "tcp");
-    if (strlen(options->hostname) > (sizeof(srvloc_url) - strlen(inet_ntoa(dsi->server.sin_addr)) - 21)) {
-        syslog(LOG_ERR, "DSIConfigInit: Hostname is too long for SRVLOC");
-        goto srvloc_reg_err;
-    }
-    if (dsi->server.sin_port == afpovertcp->s_port) {
-        sprintf(srvloc_url, sizeof(srvloc_url), "afp://%s/?NAME=%s", inet_ntoa(dsi->server.sin_addr), options->hostname);
-    }
-    else {
-        sprintf(srvloc_url, sizeof(srvloc_url), "afp://%s:%d/?NAME=%s", inet_ntoa(dsi->server.sin_addr), ntohs(dsi->server.sin_port), options->hostname);
-    }
-
-    err = SLPReg(hslp,
-                 srvloc_url,
-                 SLP_LIFETIME_MAXIMUM,
-                 "",
-                 "",
-                 SLP_TRUE,
-                 SRVLOC_callback,
-                 &callbackerr);
-    if (err != SLP_OK) {
-        syslog(LOG_ERR, "DSIConfigInit: Error registering %s with SRVLOC", srvloc_url);
-        goto srvloc_reg_err;
-    }
-
-    if (callbackerr != SLP_OK) {
-        syslog(LOG_ERR, "DSIConfigInit: Error in callback trying to register %s with SRVLOC", srvloc_url);
-        goto srvloc_reg_err;
-    }
-
-    syslog(LOG_INFO, "Sucessfully registered %s with SRVLOC", srvloc_url);
+    dsi->srvloc_url[0] = '\0'; /*  Mark that we haven't registered.  */
+    if (!(options->flags & OPTION_NOSLP)) {
+        SLPError err;
+        SLPError callbackerr;
+        SLPHandle hslp;
+        unsigned int afp_port;
+        int   l;
+        char *srvloc_hostname;
+        const char *hostname;
+
+       err = SLPOpen("en", SLP_FALSE, &hslp);
+       if (err != SLP_OK) {
+           LOG(log_error, logtype_afpd, "DSIConfigInit: Error opening SRVLOC handle");
+           goto srvloc_reg_err;
+       }
+
+       /* XXX We don't want to tack on the port number if we don't have to.
+        * Why?
+        * Well, this seems to break MacOS < 10.  If the user _really_ wants to
+        * use a non-default port, they can, but be aware, this server might
+        * not show up int the Network Browser.
+        */
+       afp_port = getip_port((struct sockaddr *)&dsi->server);
+       /* If specified use the FQDN to register with srvloc, otherwise use IP. */
+       p = NULL;
+       if (options->fqdn) {
+           hostname = options->fqdn;
+           p = strchr(hostname, ':');
+       }       
+       else 
+           hostname = getip_string((struct sockaddr *)&dsi->server);
+
+       srvloc_hostname = srvloc_encode(options, (options->server ? options->server : options->hostname));
+
+       if ((p) || afp_port == 548) {
+           l = snprintf(dsi->srvloc_url, sizeof(dsi->srvloc_url), "afp://%s/?NAME=%s", hostname, srvloc_hostname);
+       }
+       else {
+           l = snprintf(dsi->srvloc_url, sizeof(dsi->srvloc_url), "afp://%s:%d/?NAME=%s", hostname, afp_port, srvloc_hostname);
+       }
+
+       if (l == -1 || l >= (int)sizeof(dsi->srvloc_url)) {
+           LOG(log_error, logtype_afpd, "DSIConfigInit: Hostname is too long for SRVLOC");
+           dsi->srvloc_url[0] = '\0';
+           goto srvloc_reg_err;
+       }
+
+       err = SLPReg(hslp,
+                    dsi->srvloc_url,
+                    SLP_LIFETIME_MAXIMUM,
+                    "afp",
+                    "",
+                    SLP_TRUE,
+                    SRVLOC_callback,
+                    &callbackerr);
+       if (err != SLP_OK) {
+           LOG(log_error, logtype_afpd, "DSIConfigInit: Error registering %s with SRVLOC", dsi->srvloc_url);
+           dsi->srvloc_url[0] = '\0';
+           goto srvloc_reg_err;
+       }
+
+       if (callbackerr != SLP_OK) {
+           LOG(log_error, logtype_afpd, "DSIConfigInit: Error in callback trying to register %s with SRVLOC", dsi->srvloc_url);
+           dsi->srvloc_url[0] = '\0';
+           goto srvloc_reg_err;
+       }
+
+       LOG(log_info, logtype_afpd, "Sucessfully registered %s with SRVLOC", dsi->srvloc_url);
+       config->server_cleanup = dsi_cleanup;
 
 srvloc_reg_err:
-    SLPClose(hslp);
+       SLPClose(hslp);
+    }
 #endif /* USE_SRVLOC */
 
-
     config->fd = dsi->serversock;
     config->obj.handle = dsi;
     config->obj.config = config;
@@ -370,33 +312,26 @@ srvloc_reg_err:
     (*refcount)++;
 
     config->server_start = dsi_start;
-#ifdef USE_SRVLOC
-    config->server_cleanup = dsi_cleanup;
-#endif /* USE_SRVLOC */
     return config;
 }
 
 /* allocate server configurations. this should really store the last
  * entry in config->last or something like that. that would make
  * supporting multiple dsi transports easier. */
-static AFPConfig *AFPConfigInit(const struct afp_options *options,
+static AFPConfig *AFPConfigInit(struct afp_options *options,
                                 const struct afp_options *defoptions)
 {
-    AFPConfig *config = NULL, *next = NULL;
+    AFPConfig *next = NULL;
     unsigned char *refcount;
 
     if ((refcount = (unsigned char *)
                     calloc(1, sizeof(unsigned char))) == NULL) {
-        syslog( LOG_ERR, "AFPConfigInit: calloc(refcount): %s", strerror(errno) );
+        LOG(log_error, logtype_afpd, "AFPConfigInit: calloc(refcount): %s", strerror(errno) );
         return NULL;
     }
 
-#ifndef NO_DDP
-    /* handle asp transports */
-    if ((options->transports & AFPTRANS_DDP) &&
-            (config = ASPConfigInit(options, refcount)))
-        config->defoptions = defoptions;
-#endif /* NO_DDP */
+    /* set signature */
+    set_signature(options);
 
     /* handle dsi transports and dsi proxies. we only proxy
      * for DSI connections. */
@@ -407,10 +342,11 @@ static AFPConfig *AFPConfigInit(const struct afp_options *options,
      *     (next = DSIConfigInit(options, refcount, i)))
      *     next->defoptions = defoptions;
      */
-    if ((options->transports & AFPTRANS_TCP) &&
-            (((options->flags & OPTION_PROXY) == 0) ||
-             ((options->flags & OPTION_PROXY) && config))
-            && (next = DSIConfigInit(options, refcount, DSI_TCPIP)))
+    if ( (options->transports & AFPTRANS_TCP)
+         &&
+         ((options->flags & OPTION_PROXY) == 0)
+         &&
+         (next = DSIConfigInit(options, refcount, DSI_TCPIP)))
         next->defoptions = defoptions;
 
     /* load in all the authentication modules. we can load the same
@@ -422,13 +358,7 @@ static AFPConfig *AFPConfigInit(const struct afp_options *options,
 
     /* this should be able to accept multiple dsi transports. i think
      * the only thing that gets affected is the net addresses. */
-    status_init(config, next, options);
-
-    /* attach dsi config to tail of asp config */
-    if (config) {
-        config->next = next;
-        return config;
-    }
+    status_init(next, options);
 
     return next;
 }
@@ -438,17 +368,29 @@ AFPConfig *configinit(struct afp_options *cmdline)
 {
     FILE *fp;
     char buf[LINESIZE + 1], *p, have_option = 0;
+    size_t len;
     struct afp_options options;
-    AFPConfig *config, *first = NULL;
+    AFPConfig *config=NULL, *first = NULL; 
 
     /* if config file doesn't exist, load defaults */
     if ((fp = fopen(cmdline->configfile, "r")) == NULL)
+    {
+        LOG(log_debug, logtype_afpd, "ConfigFile %s not found, assuming defaults",
+            cmdline->configfile);
         return AFPConfigInit(cmdline, cmdline);
+    }
 
     /* scan in the configuration file */
+    len = 0;
     while (!feof(fp)) {
-        if (!fgets(buf, sizeof(buf), fp) || buf[0] == '#')
+       if (!fgets(&buf[len], LINESIZE - len, fp) || buf[len] == '#')
             continue;
+       len = strlen(buf);
+       if ( len >= 2 && buf[len-2] == '\\' ) {
+           len -= 2;
+           continue;
+       } else
+           len = 0;
 
         /* a little pre-processing to get rid of spaces and end-of-lines */
         p = buf;
@@ -463,7 +405,7 @@ AFPConfig *configinit(struct afp_options *cmdline)
         if (!afp_options_parseline(p, &options))
             continue;
 
-        /* this should really get a head and a tail to simplify things. */
+        /* AFPConfigInit can return two linked configs due to DSI and ASP */
         if (!first) {
             if ((first = AFPConfigInit(&options, cmdline)))
                 config = first->next ? first->next : first;
@@ -472,10 +414,22 @@ AFPConfig *configinit(struct afp_options *cmdline)
         }
     }
 
+#ifdef HAVE_LDAP
+    /* Parse afp_ldap.conf */
+    acl_ldap_readconfig(_PATH_ACL_LDAPCONF);
+#endif /* HAVE_LDAP */
+
+    LOG(log_debug, logtype_afpd, "Finished parsing Config File");
     fclose(fp);
 
     if (!have_option)
-        return AFPConfigInit(cmdline, cmdline);
+        first = AFPConfigInit(cmdline, cmdline);
+
+    /* Now register with zeroconf, we also need the volumes for that */
+    if (! (first->obj.options.flags & OPTION_NOZEROCONF)) {
+        load_volumes(&first->obj);
+        zeroconf_register(first);
+    }
 
     return first;
 }