]> arthur.barton.de Git - netatalk.git/blobdiff - etc/afpd/afp_config.c
New option parsing
[netatalk.git] / etc / afpd / afp_config.c
index 4b451527c87230584a783d5713c361498d36ab6c..cd332a94715e66c5321f85761715c645dee2050d 100644 (file)
 #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/afp.h>
 #include <atalk/compat.h>
 #include <atalk/server_child.h>
+#include <atalk/globals.h>
 
 #ifdef HAVE_LDAP
 #include <atalk/ldapconfig.h>
 #endif
 
-#include <atalk/globals.h>
 #include "afp_config.h"
 #include "uam_auth.h"
 #include "status.h"
 #include "volume.h"
 #include "afp_zeroconf.h"
 
-#define LINESIZE 1024  
-
 /* get rid of unneeded configurations. i use reference counts to deal
  * w/ multiple configs sharing the same afp_options. oh, to dream of
  * garbage collection ... */
@@ -54,16 +48,12 @@ void configfree(AFPConfig *configs, const AFPConfig *config)
         if (p == config)
             continue;
 
-        /* do a little reference counting */
-        if (--(*p->optcount) < 1) {
-            afp_options_free(&p->obj.options, p->defoptions);
-            free(p->optcount);
-        }
+        afp_options_free(&p->obj.options, p->defoptions);
 
         switch (p->obj.proto) {
         case AFPPROTO_DSI:
             close(p->fd);
-            free(p->obj.handle);
+            free(p->obj.dsi);
             break;
         }
         free(p);
@@ -73,95 +63,16 @@ void configfree(AFPConfig *configs, const AFPConfig *config)
     unload_volumes_and_extmap();
 }
 
-#ifdef USE_SRVLOC
-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 */
 
 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) {
-        LOG(log_error, logtype_afpd, "dsi_cleanup: Error opening SRVLOC handle");
-        goto srvloc_dereg_err;
-    }
-
-    err = SLPDereg(hslp,
-                   dsi->srvloc_url,
-                   SRVLOC_callback,
-                   &callbackerr);
-    if (err != SLP_OK) {
-        LOG(log_error, logtype_afpd, "dsi_cleanup: Error unregistering %s from SRVLOC", dsi->srvloc_url);
-        goto srvloc_dereg_err;
-    }
-
-    if (callbackerr != SLP_OK) {
-        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 */
+    return;
 }
 
 static afp_child_t *dsi_start(AFPConfig *config, AFPConfig *configs,
                               server_child *server_children)
 {
-    DSI *dsi = config->obj.handle;
+    DSI *dsi = config->obj.dsi;
     afp_child_t *child = NULL;
 
     if (!(child = dsi_getsession(dsi,
@@ -204,102 +115,17 @@ static AFPConfig *DSIConfigInit(const struct afp_options *options,
 
     if ((dsi = dsi_init(protocol, "afpd", options->hostname,
                         options->ipaddr, options->port,
-                        options->flags & OPTION_PROXY,
-                        options->server_quantum)) == NULL) {
+                        0, options->server_quantum)) == NULL) {
         LOG(log_error, logtype_afpd, "main: dsi_init: %s", strerror(errno) );
         free(config);
         return NULL;
     }
     dsi->dsireadbuf = options->dsireadbuf;
 
-    if (options->flags & OPTION_PROXY) {
-        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 {
-        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);
-    }
+    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
-    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);
-    }
-#endif /* USE_SRVLOC */
-
-    config->fd = dsi->serversock;
-    config->obj.handle = dsi;
-    config->obj.config = config;
-    config->obj.proto = AFPPROTO_DSI;
+    config->dsi = dsi;
 
     memcpy(&config->obj.options, options, sizeof(struct afp_options));
     /* get rid of any appletalk info. we use the fact that the DSI
@@ -308,10 +134,6 @@ srvloc_reg_err:
     if (p && (q = strchr(p, ':')))
         *q = '\0';
 
-    config->optcount = refcount;
-    (*refcount)++;
-
-    config->server_start = dsi_start;
     return config;
 }
 
@@ -333,28 +155,13 @@ static AFPConfig *AFPConfigInit(struct afp_options *options,
     /* set signature */
     set_signature(options);
 
-    /* handle dsi transports and dsi proxies. we only proxy
-     * for DSI connections. */
-
-    /* this should have something like the following:
-     * for (i=mindsi; i < maxdsi; i++)
-     *   if (options->transports & (1 << i) && 
-     *     (next = DSIConfigInit(options, refcount, i)))
-     *     next->defoptions = defoptions;
-     */
-    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
-       things multiple times if necessary. however, loading different
-       things with the same names will cause complaints. by not loading
-       in any uams with proxies, we prevent ddp connections from succeeding.
-    */
-    auth_load(options->uampath, options->uamlist);
+    if ((next = DSIConfigInit(options, refcount, DSI_TCPIP)))
+        /* load in all the authentication modules. we can load the same
+           things multiple times if necessary. however, loading different
+           things with the same names will cause complaints. by not loading
+           in any uams with proxies, we prevent ddp connections from succeeding.
+        */
+        auth_load(options->uampath, options->uamlist);
 
     /* this should be able to accept multiple dsi transports. i think
      * the only thing that gets affected is the net addresses. */
@@ -363,72 +170,35 @@ static AFPConfig *AFPConfigInit(struct afp_options *options,
     return next;
 }
 
-/* fill in the appropriate bits for each interface */
-AFPConfig *configinit(struct afp_options *cmdline)
+/*!
+ * Parse configfile and build AFPObj
+ */
+int configinit(AFPObj *AFPObj, const struct afp_options *defoptions)
 {
-    FILE *fp;
-    char buf[LINESIZE + 1], *p, have_option = 0;
-    size_t len;
-    struct afp_options options;
-    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);
-    }
+    int have_option = 0;
 
-    /* scan in the configuration file */
-    len = 0;
-    while (!feof(fp)) {
-       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;
-        while (p && isspace(*p))
-            p++;
-        if (!p || (*p == '\0'))
-            continue;
+    afp_options_duplicate(&AFPObj->options, defoptions);
 
-        have_option = 1;
+    if ((AFPObj->iniconfig = iniparser_load(AFPObj->options.configfile)) == NULL)
+        /* if config file doesn't exist, load defaults */
+        return AFPConfigInit(AFPObj);
 
-        memcpy(&options, cmdline, sizeof(options));
-        if (!afp_options_parseline(p, &options))
-            continue;
+    if (afp_options_parse(AFPObj) != 0)
+        return -1;
 
-        /* AFPConfigInit can return two linked configs due to DSI and ASP */
-        if (!first) {
-            if ((first = AFPConfigInit(&options, cmdline)))
-                config = first->next ? first->next : first;
-        } else if ((config->next = AFPConfigInit(&options, cmdline))) {
-            config = config->next->next ? config->next->next : config->next;
-        }
-    }
+    AFPConfigInit(AFPObj);
 
 #ifdef HAVE_LDAP
     /* Parse afp_ldap.conf */
-    acl_ldap_readconfig(_PATH_ACL_LDAPCONF);
+    acl_ldap_readconfig(AFPObj->iniconfig);
 #endif /* HAVE_LDAP */
 
     LOG(log_debug, logtype_afpd, "Finished parsing Config File");
-    fclose(fp);
-
-    if (!have_option)
-        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);
+    if (! (AFPObj->options.flags & OPTION_NOZEROCONF)) {
+        load_volumes(AFPObj);
+        zeroconf_register(AFPObj);
     }
 
     return first;