]> arthur.barton.de Git - netatalk.git/blobdiff - etc/afpd/afp_config.c
Merge 2-2
[netatalk.git] / etc / afpd / afp_config.c
index cd332a94715e66c5321f85761715c645dee2050d..a61fe1022f551ccc84b9fef03c860cfe16c51a30 100644 (file)
@@ -25,6 +25,9 @@
 #include <atalk/compat.h>
 #include <atalk/server_child.h>
 #include <atalk/globals.h>
+#include <atalk/errchk.h>
+#include <atalk/netatalk_conf.h>
+#include <atalk/fce_api.h>
 
 #ifdef HAVE_LDAP
 #include <atalk/ldapconfig.h>
 #include "volume.h"
 #include "afp_zeroconf.h"
 
-/* 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 ... */
-void configfree(AFPConfig *configs, const AFPConfig *config)
+
+/*!
+ * Free and cleanup all linked DSI objects from config
+ *
+ * Preserve object pointed to by "dsi".
+ * "dsi" can be NULL in which case all DSI objects _and_ the options object are freed 
+ */
+void configfree(AFPObj *obj, DSI *dsi)
 {
-    AFPConfig *p, *q;
+    DSI *p, *q;
 
-    for (p = configs; p; p = q) {
+    /* the master loaded the volumes for zeroconf, get rid of that */
+    unload_volumes(obj);
+
+    for (p = obj->dsi; p; p = q) {
         q = p->next;
-        if (p == config)
+        if (p == dsi)
             continue;
-
-        afp_options_free(&p->obj.options, p->defoptions);
-
-        switch (p->obj.proto) {
-        case AFPPROTO_DSI:
-            close(p->fd);
-            free(p->obj.dsi);
-            break;
-        }
+        close(p->socket);
         free(p);
     }
 
-    /* the master loaded the volumes for zeroconf, get rid of that */
-    unload_volumes_and_extmap();
-}
-
-
-static void dsi_cleanup(const AFPConfig *config)
-{
-    return;
-}
-
-static afp_child_t *dsi_start(AFPConfig *config, AFPConfig *configs,
-                              server_child *server_children)
-{
-    DSI *dsi = config->obj.dsi;
-    afp_child_t *child = NULL;
-
-    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 (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);
+    if (dsi) {
+        dsi->next = NULL;
+        obj->dsi = dsi;
+    } else {
+        afp_options_free(&obj->options);
     }
-
-    return child;
 }
 
-static AFPConfig *DSIConfigInit(const struct afp_options *options,
-                                unsigned char *refcount,
-                                const dsi_proto protocol)
+/*!
+ * Get everything running
+ */
+int configinit(AFPObj *obj)
 {
-    AFPConfig *config;
-    DSI *dsi;
-    char *p, *q;
-
-    if ((config = (AFPConfig *) calloc(1, sizeof(AFPConfig))) == NULL) {
-        LOG(log_error, logtype_afpd, "DSIConfigInit: malloc(config): %s", strerror(errno) );
-        return NULL;
-    }
+    EC_INIT;
+    DSI *dsi, **next = &obj->dsi;
+    char *p = NULL, *q = NULL, *savep;
+    const char *r;
 
-    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,
-                        0, options->server_quantum)) == NULL) {
-        LOG(log_error, logtype_afpd, "main: dsi_init: %s", strerror(errno) );
-        free(config);
-        return NULL;
-    }
-    dsi->dsireadbuf = options->dsireadbuf;
-
-    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);
-
-    config->dsi = dsi;
+    auth_load(obj->options.uampath, obj->options.uamlist);
+    set_signature(&obj->options);
 
-    memcpy(&config->obj.options, options, sizeof(struct afp_options));
-    /* get rid of any appletalk info. we use the fact that the DSI
-     * stuff is done after the ASP stuff. */
-    p = config->obj.options.server;
-    if (p && (q = strchr(p, ':')))
-        *q = '\0';
+    LOG(log_debug, logtype_afpd, "DSIConfigInit: hostname: %s, listen: %s, port: %s",
+        obj->options.hostname,
+        obj->options.listen ? obj->options.listen : "(default: hostname)",
+        obj->options.port);
 
-    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(struct afp_options *options,
-                                const struct afp_options *defoptions)
-{
-    AFPConfig *next = NULL;
-    unsigned char *refcount;
+    /* obj->options->listen is of the from "IP[:port][,IP:[PORT], ...]" */
+    /* obj->options->port is the default port to listen (548) */
 
-    if ((refcount = (unsigned char *)
-                    calloc(1, sizeof(unsigned char))) == NULL) {
-        LOG(log_error, logtype_afpd, "AFPConfigInit: calloc(refcount): %s", strerror(errno) );
-        return NULL;
+    if (obj->options.listen) {
+        EC_NULL( q = p = strdup(obj->options.listen) );
+        EC_NULL( p = strtok_r(p, ", ", &savep) );
     }
 
-    /* set signature */
-    set_signature(options);
-
-    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. */
-    status_init(next, options);
-
-    return next;
-}
-
-/*!
- * Parse configfile and build AFPObj
- */
-int configinit(AFPObj *AFPObj, const struct afp_options *defoptions)
-{
-    int have_option = 0;
-
-    afp_options_duplicate(&AFPObj->options, defoptions);
+    while (1) {
+        if ((dsi = dsi_init(obj, obj->options.hostname, p, obj->options.port)) == NULL)
+            break;
 
-    if ((AFPObj->iniconfig = iniparser_load(AFPObj->options.configfile)) == NULL)
-        /* if config file doesn't exist, load defaults */
-        return AFPConfigInit(AFPObj);
+        status_init(obj, dsi);
+        *next = dsi;
+        next = &dsi->next;
+        dsi->AFPobj = obj;
 
-    if (afp_options_parse(AFPObj) != 0)
-        return -1;
+        LOG(log_note, logtype_afpd, "Netatalk AFP/TCP listening on %s:%d",
+            getip_string((struct sockaddr *)&dsi->server),
+            getip_port((struct sockaddr *)&dsi->server));
 
-    AFPConfigInit(AFPObj);
+        if (p)
+            /* p is NULL if ! obj->options.listen */
+            p = strtok_r(NULL, ", ", &savep);
+        if (!p)
+            break;
+    }
 
 #ifdef HAVE_LDAP
-    /* Parse afp_ldap.conf */
-    acl_ldap_readconfig(AFPObj->iniconfig);
+    /* Parse afp.conf */
+    acl_ldap_readconfig(obj->iniconfig);
 #endif /* HAVE_LDAP */
 
-    LOG(log_debug, logtype_afpd, "Finished parsing Config File");
-
     /* Now register with zeroconf, we also need the volumes for that */
-    if (! (AFPObj->options.flags & OPTION_NOZEROCONF)) {
-        load_volumes(AFPObj);
-        zeroconf_register(AFPObj);
+    if (! (obj->options.flags & OPTION_NOZEROCONF)) {
+        load_volumes(obj, NULL);
+        zeroconf_register(obj);
+    }
+
+    if ((r = iniparser_getstring(obj->iniconfig, INISEC_GLOBAL, "fce listener", NULL))) {
+               LOG(log_note, logtype_afpd, "Adding FCE listener: %s", r);
+               fce_add_udp_socket(r);
+    }
+    if ((r = iniparser_getstring(obj->iniconfig, INISEC_GLOBAL, "fce coalesce", NULL))) {
+               LOG(log_note, logtype_afpd, "Fce coalesce: %s", r);
+               fce_set_coalesce(r);
+    }
+    if ((r = iniparser_getstring(obj->iniconfig, INISEC_GLOBAL, "fce events", NULL))) {
+               LOG(log_note, logtype_afpd, "Fce events: %s", r);
+               fce_set_events(r);
     }
 
-    return first;
+EC_CLEANUP:
+    if (q)
+        free(q);
+    EC_EXIT;
 }