/* $NetBSD: conf.c,v 1.64.32.1 2023/10/02 17:22:10 martin Exp $ */ /*- * Copyright (c) 1997-2009 The NetBSD Foundation, Inc. * All rights reserved. * * This code is derived from software contributed to The NetBSD Foundation * by Simon Burge and Luke Mewburn. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. */ #include #ifndef lint __RCSID("$NetBSD: conf.c,v 1.64.32.1 2023/10/02 17:22:10 martin Exp $"); #endif /* not lint */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #ifdef KERBEROS5 #include #endif #include "extern.h" #include "pathnames.h" static char *strend(const char *, char *); static int filetypematch(char *, int); /* class defaults */ #define DEFAULT_LIMIT -1 /* unlimited connections */ #define DEFAULT_MAXFILESIZE -1 /* unlimited file size */ #define DEFAULT_MAXTIMEOUT 7200 /* 2 hours */ #define DEFAULT_TIMEOUT 900 /* 15 minutes */ #define DEFAULT_UMASK 027 /* rw-r----- */ /* * Initialise curclass to an `empty' state */ void init_curclass(void) { struct ftpconv *conv, *cnext; for (conv = curclass.conversions; conv != NULL; conv = cnext) { REASSIGN(conv->suffix, NULL); REASSIGN(conv->types, NULL); REASSIGN(conv->disable, NULL); REASSIGN(conv->command, NULL); cnext = conv->next; free(conv); } memset((char *)&curclass.advertise, 0, sizeof(curclass.advertise)); curclass.advertise.su_len = 0; /* `not used' */ REASSIGN(curclass.chroot, NULL); REASSIGN(curclass.classname, NULL); curclass.conversions = NULL; REASSIGN(curclass.display, NULL); REASSIGN(curclass.homedir, NULL); curclass.limit = DEFAULT_LIMIT; REASSIGN(curclass.limitfile, NULL); curclass.maxfilesize = DEFAULT_MAXFILESIZE; curclass.maxrateget = 0; curclass.maxrateput = 0; curclass.maxtimeout = DEFAULT_MAXTIMEOUT; REASSIGN(curclass.motd, ftpd_strdup(_NAME_FTPLOGINMESG)); REASSIGN(curclass.notify, NULL); curclass.portmin = 0; curclass.portmax = 0; curclass.rateget = 0; curclass.rateput = 0; curclass.timeout = DEFAULT_TIMEOUT; /* curclass.type is set elsewhere */ curclass.umask = DEFAULT_UMASK; curclass.mmapsize = 0; curclass.readsize = 0; curclass.writesize = 0; curclass.sendbufsize = 0; curclass.sendlowat = 0; CURCLASS_FLAGS_SET(checkportcmd); CURCLASS_FLAGS_CLR(denyquick); CURCLASS_FLAGS_CLR(hidesymlinks); CURCLASS_FLAGS_SET(modify); CURCLASS_FLAGS_SET(passive); CURCLASS_FLAGS_CLR(private); CURCLASS_FLAGS_CLR(sanenames); CURCLASS_FLAGS_SET(upload); } /* * Parse the configuration file, looking for the named class, and * define curclass to contain the appropriate settings. */ void parse_conf(const char *findclass) { FILE *f; char *buf, *p; size_t len; LLT llval; int none, match; char *endp, errbuf[100]; char *class, *word, *arg, *template; const char *infile; size_t line; struct ftpconv *conv, *cnext; init_curclass(); REASSIGN(curclass.classname, ftpd_strdup(findclass)); /* set more guest defaults */ if (strcasecmp(findclass, "guest") == 0) { CURCLASS_FLAGS_CLR(modify); curclass.umask = 0707; } infile = conffilename(_NAME_FTPDCONF); if ((f = fopen(infile, "r")) == NULL) return; line = 0; template = NULL; for (; (buf = fparseln(f, &len, &line, NULL, FPARSELN_UNESCCOMM | FPARSELN_UNESCCONT | FPARSELN_UNESCESC)) != NULL; free(buf)) { none = match = 0; p = buf; if (len < 1) continue; if (p[len - 1] == '\n') p[--len] = '\0'; if (EMPTYSTR(p)) continue; NEXTWORD(p, word); NEXTWORD(p, class); NEXTWORD(p, arg); if (EMPTYSTR(word) || EMPTYSTR(class)) continue; if (strcasecmp(class, "none") == 0) none = 1; if (! (strcasecmp(class, findclass) == 0 || (template != NULL && strcasecmp(class, template) == 0) || none || strcasecmp(class, "all") == 0) ) continue; #define CONF_FLAG(Field) \ do { \ if (none || \ (!EMPTYSTR(arg) && strcasecmp(arg, "off") == 0)) \ CURCLASS_FLAGS_CLR(Field); \ else \ CURCLASS_FLAGS_SET(Field); \ } while (0) #define CONF_STRING(Field) \ do { \ if (none || EMPTYSTR(arg)) \ arg = NULL; \ else \ arg = ftpd_strdup(arg); \ REASSIGN(curclass.Field, arg); \ } while (0) #define CONF_LL(Field,Arg,Min,Max) \ do { \ if (none || EMPTYSTR(Arg)) \ goto nextline; \ llval = strsuftollx(#Field, Arg, Min, Max, \ errbuf, sizeof(errbuf)); \ if (errbuf[0]) { \ syslog(LOG_WARNING, "%s line %d: %s", \ infile, (int)line, errbuf); \ goto nextline; \ } \ curclass.Field = llval; \ } while(0) if (0) { /* no-op */ } else if ((strcasecmp(word, "advertise") == 0) || (strcasecmp(word, "advertize") == 0)) { struct addrinfo hints, *res; int error; memset((char *)&curclass.advertise, 0, sizeof(curclass.advertise)); curclass.advertise.su_len = 0; if (none || EMPTYSTR(arg)) continue; res = NULL; memset(&hints, 0, sizeof(hints)); /* * only get addresses of the family * that we're listening on */ hints.ai_family = ctrl_addr.su_family; hints.ai_socktype = SOCK_STREAM; error = getaddrinfo(arg, "0", &hints, &res); if (error) { syslog(LOG_WARNING, "%s line %d: %s", infile, (int)line, gai_strerror(error)); advertiseparsefail: if (res) freeaddrinfo(res); continue; } if (res->ai_next) { syslog(LOG_WARNING, "%s line %d: multiple addresses returned for `%s'; please be more specific", infile, (int)line, arg); goto advertiseparsefail; } if (sizeof(curclass.advertise) < res->ai_addrlen || ( #ifdef INET6 res->ai_family != AF_INET6 && #endif res->ai_family != AF_INET)) { syslog(LOG_WARNING, "%s line %d: unsupported protocol %d for `%s'", infile, (int)line, res->ai_family, arg); goto advertiseparsefail; } memcpy(&curclass.advertise, res->ai_addr, res->ai_addrlen); curclass.advertise.su_len = res->ai_addrlen; freeaddrinfo(res); } else if (strcasecmp(word, "checkportcmd") == 0) { CONF_FLAG(checkportcmd); } else if (strcasecmp(word, "chroot") == 0) { CONF_STRING(chroot); } else if (strcasecmp(word, "classtype") == 0) { if (!none && !EMPTYSTR(arg)) { if (strcasecmp(arg, "GUEST") == 0) curclass.type = CLASS_GUEST; else if (strcasecmp(arg, "CHROOT") == 0) curclass.type = CLASS_CHROOT; else if (strcasecmp(arg, "REAL") == 0) curclass.type = CLASS_REAL; else { syslog(LOG_WARNING, "%s line %d: unknown class type `%s'", infile, (int)line, arg); continue; } } } else if (strcasecmp(word, "conversion") == 0) { char *suffix, *types, *disable, *convcmd; if (EMPTYSTR(arg)) { syslog(LOG_WARNING, "%s line %d: %s requires a suffix", infile, (int)line, word); continue; /* need a suffix */ } NEXTWORD(p, types); NEXTWORD(p, disable); convcmd = p; if (convcmd) convcmd += strspn(convcmd, " \t"); suffix = ftpd_strdup(arg); if (none || EMPTYSTR(types) || EMPTYSTR(disable) || EMPTYSTR(convcmd)) { types = NULL; disable = NULL; convcmd = NULL; } else { types = ftpd_strdup(types); disable = ftpd_strdup(disable); convcmd = ftpd_strdup(convcmd); } for (conv = curclass.conversions; conv != NULL; conv = conv->next) { if (strcmp(conv->suffix, suffix) == 0) break; } if (conv == NULL) { conv = (struct ftpconv *) calloc(1, sizeof(struct ftpconv)); if (conv == NULL) { syslog(LOG_WARNING, "can't malloc"); continue; } conv->next = NULL; for (cnext = curclass.conversions; cnext != NULL; cnext = cnext->next) if (cnext->next == NULL) break; if (cnext != NULL) cnext->next = conv; else curclass.conversions = conv; } REASSIGN(conv->suffix, suffix); REASSIGN(conv->types, types); REASSIGN(conv->disable, disable); REASSIGN(conv->command, convcmd); } else if (strcasecmp(word, "denyquick") == 0) { CONF_FLAG(denyquick); } else if (strcasecmp(word, "display") == 0) { CONF_STRING(display); } else if (strcasecmp(word, "hidesymlinks") == 0) { CONF_FLAG(hidesymlinks); } else if (strcasecmp(word, "homedir") == 0) { CONF_STRING(homedir); } else if (strcasecmp(word, "limit") == 0) { curclass.limit = DEFAULT_LIMIT; REASSIGN(curclass.limitfile, NULL); CONF_LL(limit, arg, -1, LLTMAX); REASSIGN(curclass.limitfile, EMPTYSTR(p) ? NULL : ftpd_strdup(p)); } else if (strcasecmp(word, "maxfilesize") == 0) { curclass.maxfilesize = DEFAULT_MAXFILESIZE; CONF_LL(maxfilesize, arg, -1, LLTMAX); } else if (strcasecmp(word, "maxtimeout") == 0) { curclass.maxtimeout = DEFAULT_MAXTIMEOUT; CONF_LL(maxtimeout, arg, MIN(30, curclass.timeout), LLTMAX); } else if (strcasecmp(word, "mmapsize") == 0) { curclass.mmapsize = 0; CONF_LL(mmapsize, arg, 0, SSIZE_MAX); } else if (strcasecmp(word, "readsize") == 0) { curclass.readsize = 0; CONF_LL(readsize, arg, 0, SSIZE_MAX); } else if (strcasecmp(word, "writesize") == 0) { curclass.writesize = 0; CONF_LL(writesize, arg, 0, SSIZE_MAX); } else if (strcasecmp(word, "recvbufsize") == 0) { curclass.recvbufsize = 0; CONF_LL(recvbufsize, arg, 0, INT_MAX); } else if (strcasecmp(word, "sendbufsize") == 0) { curclass.sendbufsize = 0; CONF_LL(sendbufsize, arg, 0, INT_MAX); } else if (strcasecmp(word, "sendlowat") == 0) { curclass.sendlowat = 0; CONF_LL(sendlowat, arg, 0, INT_MAX); } else if (strcasecmp(word, "modify") == 0) { CONF_FLAG(modify); } else if (strcasecmp(word, "motd") == 0) { CONF_STRING(motd); } else if (strcasecmp(word, "notify") == 0) { CONF_STRING(notify); } else if (strcasecmp(word, "passive") == 0) { CONF_FLAG(passive); } else if (strcasecmp(word, "portrange") == 0) { long minport, maxport; curclass.portmin = 0; curclass.portmax = 0; if (none || EMPTYSTR(arg)) continue; if (EMPTYSTR(p)) { syslog(LOG_WARNING, "%s line %d: missing maxport argument", infile, (int)line); continue; } minport = strsuftollx("minport", arg, IPPORT_RESERVED, IPPORT_ANONMAX, errbuf, sizeof(errbuf)); if (errbuf[0]) { syslog(LOG_WARNING, "%s line %d: %s", infile, (int)line, errbuf); continue; } maxport = strsuftollx("maxport", p, IPPORT_RESERVED, IPPORT_ANONMAX, errbuf, sizeof(errbuf)); if (errbuf[0]) { syslog(LOG_WARNING, "%s line %d: %s", infile, (int)line, errbuf); continue; } if (minport >= maxport) { syslog(LOG_WARNING, "%s line %d: minport %ld >= maxport %ld", infile, (int)line, minport, maxport); continue; } curclass.portmin = (int)minport; curclass.portmax = (int)maxport; } else if (strcasecmp(word, "private") == 0) { CONF_FLAG(private); } else if (strcasecmp(word, "rateget") == 0) { curclass.maxrateget = curclass.rateget = 0; CONF_LL(rateget, arg, 0, LLTMAX); curclass.maxrateget = curclass.rateget; } else if (strcasecmp(word, "rateput") == 0) { curclass.maxrateput = curclass.rateput = 0; CONF_LL(rateput, arg, 0, LLTMAX); curclass.maxrateput = curclass.rateput; } else if (strcasecmp(word, "sanenames") == 0) { CONF_FLAG(sanenames); } else if (strcasecmp(word, "timeout") == 0) { curclass.timeout = DEFAULT_TIMEOUT; CONF_LL(timeout, arg, 30, curclass.maxtimeout); } else if (strcasecmp(word, "template") == 0) { if (none) continue; REASSIGN(template, EMPTYSTR(arg) ? NULL : ftpd_strdup(arg)); } else if (strcasecmp(word, "umask") == 0) { unsigned long fumask; curclass.umask = DEFAULT_UMASK; if (none || EMPTYSTR(arg)) continue; errno = 0; endp = NULL; fumask = strtoul(arg, &endp, 8); if (errno || *arg == '\0' || *endp != '\0' || fumask > 0777) { syslog(LOG_WARNING, "%s line %d: invalid umask %s", infile, (int)line, arg); continue; } curclass.umask = (mode_t)fumask; } else if (strcasecmp(word, "upload") == 0) { CONF_FLAG(upload); if (! CURCLASS_FLAGS_ISSET(upload)) CURCLASS_FLAGS_CLR(modify); } else { syslog(LOG_WARNING, "%s line %d: unknown directive '%s'", infile, (int)line, word); continue; } nextline: ; } REASSIGN(template, NULL); fclose(f); } /* * Show file listed in curclass.display first time in, and list all the * files named in curclass.notify in the current directory. * Send back responses with the prefix `code' + "-". * If code == -1, flush the internal cache of directory names and return. */ void show_chdir_messages(int code) { static StringList *slist = NULL; struct stat st; struct tm *t; glob_t gl; time_t now, then; int age; char curwd[MAXPATHLEN]; char *cp, **rlist; if (code == -1) { if (slist != NULL) sl_free(slist, 1); slist = NULL; return; } if (quietmessages) return; /* Setup list for directory cache */ if (slist == NULL) slist = sl_init(); if (slist == NULL) { syslog(LOG_WARNING, "can't allocate memory for stringlist"); return; } /* Check if this directory has already been visited */ if (getcwd(curwd, sizeof(curwd) - 1) == NULL) { syslog(LOG_WARNING, "can't getcwd: %s", strerror(errno)); return; } if (sl_find(slist, curwd) != NULL) return; cp = ftpd_strdup(curwd); if (sl_add(slist, cp) == -1) syslog(LOG_WARNING, "can't add `%s' to stringlist", cp); /* First check for a display file */ (void)display_file(curclass.display, code); /* Now see if there are any notify files */ if (EMPTYSTR(curclass.notify)) return; memset(&gl, 0, sizeof(gl)); if (glob(curclass.notify, GLOB_BRACE|GLOB_LIMIT, NULL, &gl) != 0 || gl.gl_matchc == 0) { globfree(&gl); return; } time(&now); for (rlist = gl.gl_pathv; *rlist != NULL; rlist++) { if (stat(*rlist, &st) != 0) continue; if (!S_ISREG(st.st_mode)) continue; then = st.st_mtime; if (code != 0) { reply(-code, "%s", ""); code = 0; } reply(-code, "Please read the file %s", *rlist); t = localtime(&now); age = 365 * t->tm_year + t->tm_yday; t = localtime(&then); age -= 365 * t->tm_year + t->tm_yday; reply(-code, " it was last modified on %.24s - %d day%s ago", ctime(&then), age, PLURAL(age)); } globfree(&gl); } int display_file(const char *file, int code) { FILE *f; char *buf, *p; char curwd[MAXPATHLEN]; size_t len; off_t lastnum; time_t now; lastnum = 0; if (quietmessages) return (0); if (EMPTYSTR(file)) return(0); if ((f = fopen(file, "r")) == NULL) return (0); reply(-code, "%s", ""); for (; (buf = fparseln(f, &len, NULL, "\0\0\0", 0)) != NULL; free(buf)) { if (len > 0) if (buf[len - 1] == '\n') buf[--len] = '\0'; cprintf(stdout, " "); for (p = buf; *p; p++) { if (*p == '%') { p++; switch (*p) { case 'c': cprintf(stdout, "%s", curclass.classname ? curclass.classname : ""); break; case 'C': if (getcwd(curwd, sizeof(curwd)-1) == NULL){ syslog(LOG_WARNING, "can't getcwd: %s", strerror(errno)); continue; } cprintf(stdout, "%s", curwd); break; case 'E': if (! EMPTYSTR(emailaddr)) cprintf(stdout, "%s", emailaddr); break; case 'L': cprintf(stdout, "%s", hostname); break; case 'M': if (curclass.limit == -1) { cprintf(stdout, "unlimited"); lastnum = 0; } else { cprintf(stdout, LLF, (LLT)curclass.limit); lastnum = curclass.limit; } break; case 'N': cprintf(stdout, "%d", connections); lastnum = connections; break; case 'R': cprintf(stdout, "%s", remotehost); break; case 's': if (lastnum != 1) cprintf(stdout, "s"); break; case 'S': if (lastnum != 1) cprintf(stdout, "S"); break; case 'T': now = time(NULL); cprintf(stdout, "%.24s", ctime(&now)); break; case 'U': cprintf(stdout, "%s", pw ? pw->pw_name : ""); break; case '%': CPUTC('%', stdout); break; } } else CPUTC(*p, stdout); } cprintf(stdout, "\r\n"); } (void)fflush(stdout); (void)fclose(f); return (1); } /* * Parse src, expanding '%' escapes, into dst (which must be at least * MAXPATHLEN long). */ void format_path(char *dst, const char *src) { size_t len; const char *p; dst[0] = '\0'; len = 0; if (src == NULL) return; for (p = src; *p && len < MAXPATHLEN; p++) { if (*p == '%') { p++; switch (*p) { case 'c': len += strlcpy(dst + len, curclass.classname, MAXPATHLEN - len); break; case 'd': len += strlcpy(dst + len, pw->pw_dir, MAXPATHLEN - len); break; case 'u': len += strlcpy(dst + len, pw->pw_name, MAXPATHLEN - len); break; case '%': dst[len++] = '%'; break; } } else dst[len++] = *p; } if (len < MAXPATHLEN) dst[len] = '\0'; dst[MAXPATHLEN - 1] = '\0'; } /* * Find s2 at the end of s1. If found, return a string up to (but * not including) s2, otherwise returns NULL. */ static char * strend(const char *s1, char *s2) { static char buf[MAXPATHLEN]; char *start; size_t l1, l2; l1 = strlen(s1); l2 = strlen(s2); if (l2 >= l1 || l1 >= sizeof(buf)) return(NULL); strlcpy(buf, s1, sizeof(buf)); start = buf + (l1 - l2); if (strcmp(start, s2) == 0) { *start = '\0'; return(buf); } else return(NULL); } static int filetypematch(char *types, int mode) { for ( ; types[0] != '\0'; types++) switch (*types) { case 'd': if (S_ISDIR(mode)) return(1); break; case 'f': if (S_ISREG(mode)) return(1); break; } return(0); } /* * Look for a conversion. If we succeed, return a pointer to the * command to execute for the conversion. * * The command is stored in a static array so there's no memory * leak problems, and not too much to change in ftpd.c. This * routine doesn't need to be re-entrant unless we start using a * multi-threaded ftpd, and that's not likely for a while... */ const char ** do_conversion(const char *fname) { struct ftpconv *cp; struct stat st; int o_errno; char *base = NULL; char *cmd, *p, *lp; char **argv; StringList *sl; o_errno = errno; sl = NULL; cmd = NULL; for (cp = curclass.conversions; cp != NULL; cp = cp->next) { if (cp->suffix == NULL) { syslog(LOG_WARNING, "cp->suffix==NULL in conv list; SHOULDN'T HAPPEN!"); continue; } if ((base = strend(fname, cp->suffix)) == NULL) continue; if (cp->types == NULL || cp->disable == NULL || cp->command == NULL) continue; /* Is it enabled? */ if (strcmp(cp->disable, ".") != 0 && stat(cp->disable, &st) == 0) continue; /* Does the base exist? */ if (stat(base, &st) < 0) continue; /* Is the file type ok */ if (!filetypematch(cp->types, st.st_mode)) continue; break; /* "We have a winner!" */ } /* If we got through the list, no conversion */ if (cp == NULL) goto cleanup_do_conv; /* Split up command into an argv */ if ((sl = sl_init()) == NULL) goto cleanup_do_conv; cmd = ftpd_strdup(cp->command); p = cmd; while (p) { NEXTWORD(p, lp); if (strcmp(lp, "%s") == 0) lp = base; if (sl_add(sl, ftpd_strdup(lp)) == -1) goto cleanup_do_conv; } if (sl_add(sl, NULL) == -1) goto cleanup_do_conv; argv = sl->sl_str; free(cmd); free(sl); return (void *)(intptr_t)argv; cleanup_do_conv: if (sl) sl_free(sl, 1); free(cmd); errno = o_errno; return(NULL); } /* * Count the number of current connections, reading from * /var/run/ftpd.pids- * Does a kill -0 on each pid in that file, and only counts * processes that exist (or frees the slot if it doesn't). * Adds getpid() to the first free slot. Truncates the file * if possible. */ void count_users(void) { char fn[MAXPATHLEN]; int fd; size_t i, last, count; ssize_t scount; pid_t *pids, mypid; struct stat sb; struct flock fl; (void)strlcpy(fn, _PATH_CLASSPIDS, sizeof(fn)); (void)strlcat(fn, curclass.classname, sizeof(fn)); pids = NULL; connections = 1; fl.l_start = 0; fl.l_len = 0; fl.l_pid = 0; fl.l_type = F_WRLCK; fl.l_whence = SEEK_SET; if ((fd = open(fn, O_RDWR | O_CREAT, 0600)) == -1) return; if (fcntl(fd, F_SETLK, &fl) == -1) goto cleanup_count; if (fstat(fd, &sb) == -1) goto cleanup_count; if ((pids = calloc(sb.st_size + sizeof(pid_t), 1)) == NULL) goto cleanup_count; /* XXX: implement a better read loop */ scount = read(fd, pids, sb.st_size); if (scount == -1 || scount != sb.st_size || scount < 0) goto cleanup_count; count = (size_t)scount / sizeof(pid_t); mypid = getpid(); last = 0; for (i = 0; i < count; i++) { if (pids[i] == 0) continue; if (kill(pids[i], 0) == -1 && errno != EPERM) { if (mypid != 0) { pids[i] = mypid; mypid = 0; last = i; } } else { connections++; last = i; } } if (mypid != 0) { if (pids[last] != 0) last++; pids[last] = mypid; } count = (last + 1) * sizeof(pid_t); if (lseek(fd, 0, SEEK_SET) == -1) goto cleanup_count; /* XXX: implement a better write loop */ scount = write(fd, pids, count); if (scount == -1 || (size_t)scount != count) goto cleanup_count; (void)ftruncate(fd, count); cleanup_count: fl.l_type = F_UNLCK; (void)fcntl(fd, F_SETLK, &fl); close(fd); REASSIGN(pids, NULL); }