X-Git-Url: https://arthur.barton.de/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=etc%2Fafpd%2Fafp_config.c;h=4b451527c87230584a783d5713c361498d36ab6c;hb=b0bcb8f6b0571592a50ce039882c9319e012a270;hp=b4631e8cbf24d3c97f3e646c3df6ac3549dd3972;hpb=5ee4cf1e95071dea98a833ca37d24899cd899978;p=netatalk.git diff --git a/etc/afpd/afp_config.c b/etc/afpd/afp_config.c index b4631e8c..4b451527 100644 --- a/etc/afpd/afp_config.c +++ b/etc/afpd/afp_config.c @@ -1,6 +1,4 @@ /* - * $Id: afp_config.c,v 1.26 2009-02-02 11:55:00 franklahm Exp $ - * * Copyright (c) 1997 Adrian Sun (asun@zoology.washington.edu) * All Rights Reserved. See COPYRIGHT. */ @@ -13,51 +11,34 @@ #include #include #include - -/* STDC check */ -#if STDC_HEADERS #include -#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 -#endif /* HAVE_UNISTD_H */ #include -#include -#include - #include #include #include +#ifdef USE_SRVLOC +#include +#endif /* USE_SRVLOC */ + +#include +#include #include -#include -#include -#include #include #include #include -#ifdef USE_SRVLOC -#include -#endif /* USE_SRVLOC */ -#ifdef HAVE_NFSv4_ACLS + +#ifdef HAVE_LDAP #include #endif -#include "globals.h" +#include #include "afp_config.h" #include "uam_auth.h" #include "status.h" +#include "volume.h" +#include "afp_zeroconf.h" #define LINESIZE 1024 @@ -80,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); @@ -96,6 +68,9 @@ 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 @@ -111,13 +86,10 @@ static char * srvloc_encode(const struct afp_options *options, const char *name) char *conv_name; unsigned char *p; unsigned int i = 0; -#ifndef NO_DDP - char *Obj, *Type = "", *Zone = ""; -#endif /* Convert name to maccharset */ if ((size_t)-1 ==(convert_string_allocate( options->unixcharset, options->maccharset, - name, strlen(name), &conv_name)) ) + name, -1, &conv_name)) ) return (char*)name; /* Escape characters */ @@ -142,24 +114,15 @@ static char * srvloc_encode(const struct afp_options *options, const char *name) } buf[i] = '\0'; -#ifndef NO_DDP - /* Add ZONE, */ - if (nbp_name(options->server, &Obj, &Type, &Zone )) { - LOG(log_error, logtype_afpd, "srvloc_encode: can't parse %s", options->server ); - } - else { - snprintf( buf+i, sizeof(buf)-i-1 ,"&ZONE=%s", Zone); - } -#endif 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; @@ -192,157 +155,34 @@ static void dsi_cleanup(const AFPConfig *config) srvloc_dereg_err: dsi->srvloc_url[0] = '\0'; SLPClose(hslp); -} #endif /* USE_SRVLOC */ - -#ifndef NO_DDP -static void asp_cleanup(const AFPConfig *config) -{ - /* we need to stop tickle handler */ - asp_stop_tickle(); - 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))) { - LOG(log_error, logtype_afpd, "main: asp_getsession: %s", strerror(errno) ); - exit( EXITERR_CLNT ); - } + 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))) { - LOG(log_error, logtype_afpd, "main: dsi_getsession: %s", strerror(errno) ); - exit( EXITERR_CLNT ); + 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 = "*"; - char *convname = NULL; - - if ((config = (AFPConfig *) calloc(1, sizeof(AFPConfig))) == NULL) - return NULL; - - if ((atp = atp_open(ATADDR_ANYPORT, &options->ddpaddr)) == NULL) { - LOG(log_error, logtype_afpd, "main: atp_open: %s", strerror(errno) ); - free(config); - return NULL; - } - - if ((asp = asp_init( atp )) == NULL) { - LOG(log_error, logtype_afpd, "main: asp_init: %s", strerror(errno) ); - atp_close(atp); - free(config); - return NULL; - } - - /* register asp server */ - Obj = (char *) options->hostname; - if (options->server && (size_t)-1 ==(convert_string_allocate( options->unixcharset, options->maccharset, - options->server, strlen(options->server), &convname)) ) { - if ((convname = strdup(options->server)) == NULL ) { - LOG(log_error, logtype_afpd, "malloc: %s", strerror(errno) ); - goto serv_free_return; - } - } - - if (nbp_name(convname, &Obj, &Type, &Zone )) { - LOG(log_error, logtype_afpd, "main: can't parse %s", options->server ); - goto serv_free_return; - } - if (convname) - free (convname); - - /* 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 ) { - LOG(log_error, logtype_afpd, "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; - } - - LOG(log_info, logtype_afpd, "%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, @@ -351,20 +191,17 @@ 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; - int afp_port = 548; - char *srvloc_hostname, *hostname; -#endif /* USE_SRVLOC */ if ((config = (AFPConfig *) calloc(1, sizeof(AFPConfig))) == NULL) { 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, @@ -373,20 +210,27 @@ static AFPConfig *DSIConfigInit(const struct afp_options *options, free(config); return NULL; } + dsi->dsireadbuf = options->dsireadbuf; if (options->flags & OPTION_PROXY) { - LOG(log_info, logtype_afpd, "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 { - LOG(log_info, logtype_afpd, "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 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"); @@ -399,10 +243,7 @@ static AFPConfig *DSIConfigInit(const struct afp_options *options, * 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 (afpovertcp != NULL) { - afp_port = afpovertcp->s_port; - } + 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) { @@ -410,20 +251,22 @@ static AFPConfig *DSIConfigInit(const struct afp_options *options, p = strchr(hostname, ':'); } else - hostname = inet_ntoa(dsi->server.sin_addr); + hostname = getip_string((struct sockaddr *)&dsi->server); + srvloc_hostname = srvloc_encode(options, (options->server ? options->server : options->hostname)); - if (strlen(srvloc_hostname) > (sizeof(dsi->srvloc_url) - strlen(hostname) - 21)) { + 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; } - if ((p) || dsi->server.sin_port == afp_port) { - sprintf(dsi->srvloc_url, "afp://%s/?NAME=%s", hostname, srvloc_hostname); - } - else { - sprintf(dsi->srvloc_url, "afp://%s:%d/?NAME=%s", hostname, ntohs(dsi->server.sin_port), srvloc_hostname); - } err = SLPReg(hslp, dsi->srvloc_url, @@ -446,13 +289,13 @@ static AFPConfig *DSIConfigInit(const struct afp_options *options, } 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; @@ -469,19 +312,16 @@ srvloc_reg_err: (*refcount)++; config->server_start = dsi_start; -#ifdef USE_SRVLOC - config->server_cleanup = dsi_cleanup; -#endif 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 *) @@ -490,12 +330,8 @@ static AFPConfig *AFPConfigInit(const struct afp_options *options, 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. */ @@ -506,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 @@ -521,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; } @@ -541,7 +372,6 @@ AFPConfig *configinit(struct afp_options *cmdline) struct afp_options options; AFPConfig *config=NULL, *first = NULL; - status_reset(); /* if config file doesn't exist, load defaults */ if ((fp = fopen(cmdline->configfile, "r")) == NULL) { @@ -550,8 +380,6 @@ AFPConfig *configinit(struct afp_options *cmdline) return AFPConfigInit(cmdline, cmdline); } - LOG(log_debug, logtype_afpd, "Loading ConfigFile"); - /* scan in the configuration file */ len = 0; while (!feof(fp)) { @@ -577,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; @@ -586,26 +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) first = AFPConfigInit(cmdline, cmdline); -#ifdef HAVE_NFSv4_ACLS - /* Parse ldap.conf */ - LOG(log_debug, logtype_afpd, "Start parsing ldap.conf"); - acl_ldap_readconfig(_PATH_ACL_LDAPCONF); - LOG(log_debug, logtype_afpd, "Finished parsing ldap.conf"); - - /* If we have a good LDAP config, enable UUID option for all apfd's */ - config = first; - while(config) { - if (ldap_config_valid) - config->obj.options.flags |= OPTION_UUID; - config = config->next; + /* 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); } -#endif return first; }