12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502 |
- /* Copyright 2003 Roger Dingledine
- * Copyright 2004-2005 Roger Dingledine, Nick Mathewson */
- /* See LICENSE for licensing information */
- /* $Id$ */
- const char util_c_id[] = "$Id$";
- /**
- * \file util.c
- * \brief Common functions for strings, IO, network, data structures,
- * process control.
- **/
- /* This is required on rh7 to make strptime not complain.
- */
- #define _GNU_SOURCE
- #include "orconfig.h"
- #include "util.h"
- #include "log.h"
- #include "crypto.h"
- #include "torint.h"
- #ifdef MS_WINDOWS
- #include <io.h>
- #include <direct.h>
- #endif
- #ifdef HAVE_CTYPE_H
- #include <ctype.h>
- #endif
- #include <stdlib.h>
- #include <stdio.h>
- #include <string.h>
- #include <assert.h>
- #ifdef HAVE_NETINET_IN_H
- #include <netinet/in.h>
- #endif
- #ifdef HAVE_ARPA_INET_H
- #include <arpa/inet.h>
- #endif
- #ifdef HAVE_ERRNO_H
- #include <errno.h>
- #endif
- #ifdef HAVE_LIMITS_H
- #include <limits.h>
- #endif
- #ifdef HAVE_SYS_LIMITS_H
- #include <sys/limits.h>
- #endif
- #ifdef HAVE_MACHINE_LIMITS_H
- #ifndef __FreeBSD__
- /* FreeBSD has a bug where it complains that this file is obsolete,
- and I should migrate to using sys/limits. It complains even when
- I include both. */
- #include <machine/limits.h>
- #endif
- #endif
- #ifdef HAVE_SYS_TYPES_H
- #include <sys/types.h> /* Must be included before sys/stat.h for Ultrix */
- #endif
- #ifdef HAVE_SYS_SOCKET_H
- #include <sys/socket.h>
- #endif
- #ifdef HAVE_SYS_TIME_H
- #include <sys/time.h>
- #endif
- #ifdef HAVE_UNISTD_H
- #include <unistd.h>
- #endif
- #ifdef HAVE_SYS_STAT_H
- #include <sys/stat.h>
- #endif
- #ifdef HAVE_SYS_FCNTL_H
- #include <sys/fcntl.h>
- #endif
- #ifdef HAVE_FCNTL_H
- #include <fcntl.h>
- #endif
- #ifndef O_BINARY
- #define O_BINARY 0
- #endif
- #ifndef O_TEXT
- #define O_TEXT 0
- #endif
- /* =====
- * Memory management
- * ===== */
- #ifdef USE_DMALLOC
- #include <dmalloc.h>
- #else
- #define dmalloc_strdup(file, line, string, xalloc_b) strdup(string)
- #define dmalloc_malloc(file, line, size, func_id, alignment, xalloc_b) malloc(size)
- #define DMALLOC_FUNC_MALLOC 0
- #define dmalloc_realloc(file, line, old_pnt, new_size, func_id, xalloc_b) realloc((old_pnt), (new_size))
- #define DMALLOC_FUNC_REALLOC 0
- #endif
- /** Allocate a chunk of <b>size</b> bytes of memory, and return a pointer to
- * result. On error, log and terminate the process. (Same as malloc(size),
- * but never returns NULL.)
- *
- * <b>file</b> and <b>line</b> are used if dmalloc is enabled, and
- * ignored otherwise.
- */
- void *_tor_malloc(const char *file, const int line, size_t size) {
- void *result;
- /* Some libcs don't do the right thing on size==0. Override them. */
- if (size==0) {
- size=1;
- }
- result = dmalloc_malloc(file, line, size, DMALLOC_FUNC_MALLOC, 0, 0);
- if (!result) {
- log_fn(LOG_ERR, "Out of memory. Dying.");
- /* XXX if these functions die within a worker process, they won't
- * call spawn_exit */
- exit(1);
- }
- // memset(result,'X',size); /* deadbeef to encourage bugs */
- return result;
- }
- /* Allocate a chunk of <b>size</b> bytes of memory, fill the memory with
- * zero bytes, and return a pointer to the result. Log and terminate
- * the process on error. (Same as calloc(size,1), but never returns NULL.)
- */
- void *_tor_malloc_zero(const char *file, const int line, size_t size) {
- void *result = _tor_malloc(file, line, size);
- memset(result, 0, size);
- return result;
- }
- /** Change the size of the memory block pointed to by <b>ptr</b> to <b>size</b>
- * bytes long; return the new memory block. On error, log and
- * terminate. (Like realloc(ptr,size), but never returns NULL.)
- */
- void *_tor_realloc(const char *file, const int line, void *ptr, size_t size) {
- void *result;
- result = dmalloc_realloc(file, line, ptr, size, DMALLOC_FUNC_REALLOC, 0);
- if (!result) {
- log_fn(LOG_ERR, "Out of memory. Dying.");
- exit(1);
- }
- return result;
- }
- /** Return a newly allocated copy of the NUL-terminated string s. On
- * error, log and terminate. (Like strdup(s), but never returns
- * NULL.)
- */
- char *_tor_strdup(const char *file, const int line, const char *s) {
- char *dup;
- tor_assert(s);
- dup = dmalloc_strdup(file, line, s, 0);
- if (!dup) {
- log_fn(LOG_ERR,"Out of memory. Dying.");
- exit(1);
- }
- return dup;
- }
- /** Allocate and return a new string containing the first <b>n</b>
- * characters of <b>s</b>. If <b>s</b> is longer than <b>n</b>
- * characters, only the first <b>n</b> are copied. The result is
- * always NUL-terminated. (Like strndup(s,n), but never returns
- * NULL.)
- */
- char *_tor_strndup(const char *file, const int line, const char *s, size_t n) {
- char *dup;
- tor_assert(s);
- dup = _tor_malloc(file, line, n+1);
- /* Performance note: Ordinarily we prefer strlcpy to strncpy. But
- * this function gets called a whole lot, and platform strncpy is
- * much faster than strlcpy when strlen(s) is much longer than n.
- */
- strncpy(dup, s, n);
- dup[n]='\0';
- return dup;
- }
- /* =====
- * String manipulation
- * ===== */
- /** Remove from the string <b>s</b> every character which appears in
- * <b>strip</b>. Return the number of characters removed. */
- int tor_strstrip(char *s, const char *strip)
- {
- char *read = s;
- while (*read) {
- if (strchr(strip, *read)) {
- ++read;
- } else {
- *s++ = *read++;
- }
- }
- *s = '\0';
- return read-s;
- }
- /** Set the <b>dest_len</b>-byte buffer <b>buf</b> to contain the
- * string <b>s</b>, with the string <b>insert</b> inserted after every
- * <b>n</b> characters. Return 0 on success, -1 on failure.
- *
- * If <b>rule</b> is ALWAYS_TERMINATE, then always end the string with
- * <b>insert</b>, even if its length is not a multiple of <b>n</b>. If
- * <b>rule</b> is NEVER_TERMINATE, then never end the string with
- * <b>insert</b>, even if its length <i>is</i> a multiple of <b>n</b>.
- * If <b>rule</b> is TERMINATE_IF_EVEN, then end the string with <b>insert</b>
- * exactly when its length <i>is</i> a multiple of <b>n</b>.
- */
- int tor_strpartition(char *dest, size_t dest_len,
- const char *s, const char *insert, size_t n,
- part_finish_rule_t rule)
- {
- char *destp;
- size_t len_in, len_out, len_ins;
- int is_even, remaining;
- tor_assert(s);
- tor_assert(insert);
- tor_assert(n > 0);
- tor_assert(n < SIZE_T_CEILING);
- tor_assert(dest_len < SIZE_T_CEILING);
- len_in = strlen(s);
- len_ins = strlen(insert);
- tor_assert(len_in < SIZE_T_CEILING);
- tor_assert(len_in/n < SIZE_T_CEILING/len_ins); /* avoid overflow */
- len_out = len_in + (len_in/n)*len_ins;
- is_even = (len_in%n) == 0;
- switch (rule)
- {
- case ALWAYS_TERMINATE:
- if (!is_even) len_out += len_ins;
- break;
- case NEVER_TERMINATE:
- if (is_even && len_in) len_out -= len_ins;
- break;
- case TERMINATE_IF_EVEN:
- break;
- }
- if (dest_len < len_out+1)
- return -1;
- destp = dest;
- remaining = len_in;
- while (remaining) {
- strncpy(destp, s, n);
- remaining -= n;
- if (remaining < 0) {
- if (rule == ALWAYS_TERMINATE)
- strcpy(destp+n+remaining,insert);
- break;
- } else if (remaining == 0 && rule == NEVER_TERMINATE) {
- *(destp+n) = '\0';
- break;
- }
- strcpy(destp+n, insert);
- s += n;
- destp += n+len_ins;
- }
- tor_assert(len_out == strlen(dest));
- return 0;
- }
- /** Return a pointer to a NUL-terminated hexadecimal string encoding
- * the first <b>fromlen</b> bytes of <b>from</b>. (fromlen must be \<= 32.) The
- * result does not need to be deallocated, but repeated calls to
- * hex_str will trash old results.
- */
- const char *hex_str(const char *from, size_t fromlen)
- {
- static char buf[65];
- if (fromlen>(sizeof(buf)-1)/2)
- fromlen = (sizeof(buf)-1)/2;
- base16_encode(buf,sizeof(buf),from,fromlen);
- return buf;
- }
- /** Convert all alphabetic characters in the nul-terminated string <b>s</b> to
- * lowercase. */
- void tor_strlower(char *s)
- {
- while (*s) {
- *s = tolower(*s);
- ++s;
- }
- }
- /* Compares the first strlen(s2) characters of s1 with s2. Returns as for
- * strcmp.
- */
- int strcmpstart(const char *s1, const char *s2)
- {
- size_t n = strlen(s2);
- return strncmp(s1, s2, n);
- }
- /* Compares the first strlen(s2) characters of s1 with s2. Returns as for
- * strcasecmp.
- */
- int strcasecmpstart(const char *s1, const char *s2)
- {
- size_t n = strlen(s2);
- return strncasecmp(s1, s2, n);
- }
- /* Compares the last strlen(s2) characters of s1 with s2. Returns as for
- * strcmp.
- */
- int strcmpend(const char *s1, const char *s2)
- {
- size_t n1 = strlen(s1), n2 = strlen(s2);
- if (n2>n1)
- return strcmp(s1,s2);
- else
- return strncmp(s1+(n1-n2), s2, n2);
- }
- /* Compares the last strlen(s2) characters of s1 with s2. Returns as for
- * strcasecmp.
- */
- int strcasecmpend(const char *s1, const char *s2)
- {
- size_t n1 = strlen(s1), n2 = strlen(s2);
- if (n2>n1) /* then they can't be the same; figure out which is bigger */
- return strcasecmp(s1,s2);
- else
- return strncasecmp(s1+(n1-n2), s2, n2);
- }
- /** Return a pointer to the first char of s that is not whitespace and
- * not a comment, or to the terminating NUL if no such character exists.
- */
- const char *eat_whitespace(const char *s) {
- tor_assert(s);
- while (TOR_ISSPACE(*s) || *s == '#') {
- while (TOR_ISSPACE(*s))
- s++;
- if (*s == '#') { /* read to a \n or \0 */
- while (*s && *s != '\n')
- s++;
- if (!*s)
- return s;
- }
- }
- return s;
- }
- /** Return a pointer to the first char of s that is not a space or a tab,
- * or to the terminating NUL if no such character exists. */
- const char *eat_whitespace_no_nl(const char *s) {
- while (*s == ' ' || *s == '\t')
- ++s;
- return s;
- }
- /** Return a pointer to the first char of s that is whitespace or <b>#</b>,
- * or to the terminating NUL if no such character exists.
- */
- const char *find_whitespace(const char *s) {
- tor_assert(s);
- while (*s && !TOR_ISSPACE(*s) && *s != '#')
- s++;
- return s;
- }
- #define CHECK_STRTOX_RESULT() \
- /* Was at least one character converted? */ \
- if (endptr == s) \
- goto err; \
- /* Were there unexpected unconverted characters? */ \
- if (!next && *endptr) \
- goto err; \
- /* Is r within limits? */ \
- if (r < min || r > max) \
- goto err; \
- if (ok) *ok = 1; \
- if (next) *next = endptr; \
- return r; \
- err: \
- if (ok) *ok = 0; \
- if (next) *next = endptr; \
- return 0;
- /** Extract a long from the start of s, in the given numeric base. If
- * there is unconverted data and next is provided, set *next to the
- * first unconverted character. An error has occurred if no characters
- * are converted; or if there are unconverted characters and next is NULL; or
- * if the parsed value is not between min and max. When no error occurs,
- * return the parsed value and set *ok (if provided) to 1. When an error
- * occurs, return 0 and set *ok (if provided) to 0.
- */
- long
- tor_parse_long(const char *s, int base, long min, long max,
- int *ok, char **next)
- {
- char *endptr;
- long r;
- r = strtol(s, &endptr, base);
- CHECK_STRTOX_RESULT();
- }
- unsigned long
- tor_parse_ulong(const char *s, int base, unsigned long min,
- unsigned long max, int *ok, char **next)
- {
- char *endptr;
- unsigned long r;
- r = strtoul(s, &endptr, base);
- CHECK_STRTOX_RESULT();
- }
- /** Only base 10 is guaranteed to work for now. */
- uint64_t
- tor_parse_uint64(const char *s, int base, uint64_t min,
- uint64_t max, int *ok, char **next)
- {
- char *endptr;
- uint64_t r;
- #ifdef HAVE_STRTOULL
- r = (uint64_t)strtoull(s, &endptr, base);
- #elif defined(MS_WINDOWS)
- #if _MSC_VER < 1300
- tor_assert(base <= 10);
- r = (uint64_t)_atoi64(s);
- endptr = (char*)s;
- while (TOR_ISSPACE(*endptr)) endptr++;
- while (TOR_ISDIGIT(*endptr)) endptr++;
- #else
- r = (uint64_t)_strtoui64(s, &endptr, base);
- #endif
- #elif SIZEOF_LONG == 8
- r = (uint64_t)strtoul(s, &endptr, base);
- #else
- #error "I don't know how to parse 64-bit numbers."
- #endif
- CHECK_STRTOX_RESULT();
- }
- void base16_encode(char *dest, size_t destlen, const char *src, size_t srclen)
- {
- const char *end;
- char *cp;
- tor_assert(destlen >= srclen*2+1);
- tor_assert(destlen < SIZE_T_CEILING);
- cp = dest;
- end = src+srclen;
- while (src<end) {
- sprintf(cp,"%02X",*(const uint8_t*)src);
- ++src;
- cp += 2;
- }
- *cp = '\0';
- }
- static const char HEX_DIGITS[] = "0123456789ABCDEFabcdef";
- static INLINE int hex_decode_digit(char c)
- {
- const char *cp;
- int n;
- cp = strchr(HEX_DIGITS, c);
- if (!cp)
- return -1;
- n = cp-HEX_DIGITS;
- if (n<=15)
- return n; /* digit or uppercase */
- else
- return n-6; /* lowercase */
- }
- int base16_decode(char *dest, size_t destlen, const char *src, size_t srclen)
- {
- const char *end;
- int v1,v2;
- if ((srclen % 2) != 0)
- return -1;
- if (destlen < srclen/2 || destlen > SIZE_T_CEILING)
- return -1;
- end = src+srclen;
- while (src<end) {
- v1 = hex_decode_digit(*src);
- v2 = hex_decode_digit(*(src+1));
- if (v1<0||v2<0)
- return -1;
- *(uint8_t*)dest = (v1<<4)|v2;
- ++dest;
- src+=2;
- }
- return 0;
- }
- /* =====
- * Time
- * ===== */
- /** Return the number of microseconds elapsed between *start and *end.
- */
- long
- tv_udiff(struct timeval *start, struct timeval *end)
- {
- long udiff;
- long secdiff = end->tv_sec - start->tv_sec;
- if (labs(secdiff+1) > LONG_MAX/1000000) {
- log_fn(LOG_WARN, "comparing times too far apart.");
- return LONG_MAX;
- }
- udiff = secdiff*1000000L + (end->tv_usec - start->tv_usec);
- return udiff;
- }
- /** Return -1 if *a \< *b, 0 if *a==*b, and 1 if *a \> *b.
- */
- int tv_cmp(struct timeval *a, struct timeval *b) {
- if (a->tv_sec > b->tv_sec)
- return 1;
- if (a->tv_sec < b->tv_sec)
- return -1;
- if (a->tv_usec > b->tv_usec)
- return 1;
- if (a->tv_usec < b->tv_usec)
- return -1;
- return 0;
- }
- /** Increment *a by the number of seconds and microseconds in *b.
- */
- void tv_add(struct timeval *a, struct timeval *b) {
- a->tv_usec += b->tv_usec;
- a->tv_sec += b->tv_sec + (a->tv_usec / 1000000);
- a->tv_usec %= 1000000;
- }
- /** Increment *a by <b>ms</b> milliseconds.
- */
- void tv_addms(struct timeval *a, long ms) {
- a->tv_usec += (ms * 1000) % 1000000;
- a->tv_sec += ((ms * 1000) / 1000000) + (a->tv_usec / 1000000);
- a->tv_usec %= 1000000;
- }
- #define IS_LEAPYEAR(y) (!(y % 4) && ((y % 100) || !(y % 400)))
- static int n_leapdays(int y1, int y2) {
- --y1;
- --y2;
- return (y2/4 - y1/4) - (y2/100 - y1/100) + (y2/400 - y1/400);
- }
- /** Number of days per month in non-leap year; used by tor_timegm. */
- static const int days_per_month[] =
- { 31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31};
- /** Return a time_t given a struct tm. The result is given in GMT, and
- * does not account for leap seconds.
- */
- time_t
- tor_timegm(struct tm *tm) {
- /* This is a pretty ironclad timegm implementation, snarfed from Python2.2.
- * It's way more brute-force than fiddling with tzset().
- */
- time_t ret;
- unsigned long year, days, hours, minutes;
- int i;
- year = tm->tm_year + 1900;
- tor_assert(year >= 1970);
- tor_assert(tm->tm_mon >= 0);
- tor_assert(tm->tm_mon <= 11);
- days = 365 * (year-1970) + n_leapdays(1970,year);
- for (i = 0; i < tm->tm_mon; ++i)
- days += days_per_month[i];
- if (tm->tm_mon > 1 && IS_LEAPYEAR(year))
- ++days;
- days += tm->tm_mday - 1;
- hours = days*24 + tm->tm_hour;
- minutes = hours*60 + tm->tm_min;
- ret = minutes*60 + tm->tm_sec;
- return ret;
- }
- /* strftime is locale-specific, so we need to replace those parts */
- static const char *WEEKDAY_NAMES[] =
- { "Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat" };
- static const char *MONTH_NAMES[] =
- { "Jan", "Feb", "Mar", "Apr", "May", "Jun",
- "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" };
- void format_rfc1123_time(char *buf, time_t t) {
- struct tm tm;
- tor_gmtime_r(&t, &tm);
- strftime(buf, RFC1123_TIME_LEN+1, "___, %d ___ %Y %H:%M:%S GMT", &tm);
- tor_assert(tm.tm_wday >= 0);
- tor_assert(tm.tm_wday <= 6);
- memcpy(buf, WEEKDAY_NAMES[tm.tm_wday], 3);
- tor_assert(tm.tm_wday >= 0);
- tor_assert(tm.tm_mon <= 11);
- memcpy(buf+8, MONTH_NAMES[tm.tm_mon], 3);
- }
- int parse_rfc1123_time(const char *buf, time_t *t) {
- struct tm tm;
- char month[4];
- char weekday[4];
- int i, m;
- if (strlen(buf) != RFC1123_TIME_LEN)
- return -1;
- memset(&tm, 0, sizeof(tm));
- if (sscanf(buf, "%3s, %d %3s %d %d:%d:%d GMT", weekday,
- &tm.tm_mday, month, &tm.tm_year, &tm.tm_hour,
- &tm.tm_min, &tm.tm_sec) < 7) {
- log_fn(LOG_WARN, "Got invalid RFC1123 time \"%s\"", buf);
- return -1;
- }
- m = -1;
- for (i = 0; i < 12; ++i) {
- if (!strcmp(month, MONTH_NAMES[i])) {
- m = i;
- break;
- }
- }
- if (m<0) {
- log_fn(LOG_WARN, "Got invalid RFC1123 time \"%s\"", buf);
- return -1;
- }
- tm.tm_mon = m;
- tm.tm_year -= 1900;
- *t = tor_timegm(&tm);
- return 0;
- }
- void format_local_iso_time(char *buf, time_t t) {
- struct tm tm;
- strftime(buf, ISO_TIME_LEN+1, "%Y-%m-%d %H:%M:%S", tor_localtime_r(&t, &tm));
- }
- void format_iso_time(char *buf, time_t t) {
- struct tm tm;
- strftime(buf, ISO_TIME_LEN+1, "%Y-%m-%d %H:%M:%S", tor_gmtime_r(&t, &tm));
- }
- int parse_iso_time(const char *cp, time_t *t) {
- struct tm st_tm;
- #ifdef HAVE_STRPTIME
- if (!strptime(cp, "%Y-%m-%d %H:%M:%S", &st_tm)) {
- log_fn(LOG_WARN, "Published time was unparseable"); return -1;
- }
- #else
- unsigned int year=0, month=0, day=0, hour=100, minute=100, second=100;
- if (sscanf(cp, "%u-%u-%u %u:%u:%u", &year, &month,
- &day, &hour, &minute, &second) < 6) {
- log_fn(LOG_WARN, "Published time was unparseable"); return -1;
- }
- if (year < 1970 || month < 1 || month > 12 || day < 1 || day > 31 ||
- hour > 23 || minute > 59 || second > 61) {
- log_fn(LOG_WARN, "Published time was nonsensical"); return -1;
- }
- st_tm.tm_year = year-1900;
- st_tm.tm_mon = month-1;
- st_tm.tm_mday = day;
- st_tm.tm_hour = hour;
- st_tm.tm_min = minute;
- st_tm.tm_sec = second;
- #endif
- *t = tor_timegm(&st_tm);
- return 0;
- }
- /* =====
- * File helpers
- * ===== */
- /** Write <b>count</b> bytes from <b>buf</b> to <b>fd</b>. <b>isSocket</b>
- * must be 1 if fd was returned by socket() or accept(), and 0 if fd
- * was returned by open(). Return the number of bytes written, or -1
- * on error. Only use if fd is a blocking fd. */
- int
- write_all(int fd, const char *buf, size_t count, int isSocket) {
- size_t written = 0;
- int result;
- while (written != count) {
- if (isSocket)
- result = send(fd, buf+written, count-written, 0);
- else
- result = write(fd, buf+written, count-written);
- if (result<0)
- return -1;
- written += result;
- }
- return count;
- }
- /** Read from <b>fd</b> to <b>buf</b>, until we get <b>count</b> bytes
- * or reach the end of the file. <b>isSocket</b> must be 1 if fd
- * was returned by socket() or accept(), and 0 if fd was returned by
- * open(). Return the number of bytes read, or -1 on error. Only use
- * if fd is a blocking fd. */
- int
- read_all(int fd, char *buf, size_t count, int isSocket) {
- size_t numread = 0;
- int result;
- if (count > SIZE_T_CEILING)
- return -1;
- while (numread != count) {
- if (isSocket)
- result = recv(fd, buf+numread, count-numread, 0);
- else
- result = read(fd, buf+numread, count-numread);
- if (result<0)
- return -1;
- else if (result == 0)
- break;
- numread += result;
- }
- return numread;
- }
- /*
- * Filesystem operations.
- */
- /** Clean up <b>name</b> so that we can use it in a call to "stat". On Unix,
- * we do nothing. On Windows, we remove a trailing slash, unless the path is
- * the root of a disk. */
- static void
- clean_name_for_stat(char *name)
- {
- #ifdef MS_WINDOWS
- size_t len = strlen(name);
- if (!len)
- return;
- if (name[len-1]=='\\' || name[len-1]=='/') {
- if (len == 1 || (len==3 && name[1]==':'))
- return;
- name[len-1]='\0';
- }
- #endif
- }
- /** Return FN_ERROR if filename can't be read, FN_NOENT if it doesn't
- * exist, FN_FILE if it is a regular file, or FN_DIR if it's a
- * directory. */
- file_status_t file_status(const char *fname)
- {
- struct stat st;
- char *f;
- int r;
- f = tor_strdup(fname);
- clean_name_for_stat(f);
- r = stat(f, &st);
- tor_free(f);
- if (r) {
- if (errno == ENOENT) {
- return FN_NOENT;
- }
- return FN_ERROR;
- }
- if (st.st_mode & S_IFDIR)
- return FN_DIR;
- else if (st.st_mode & S_IFREG)
- return FN_FILE;
- else
- return FN_ERROR;
- }
- /** Check whether dirname exists and is private. If yes return 0. If
- * it does not exist, and check==CPD_CREATE is set, try to create it
- * and return 0 on success. If it does not exist, and
- * check==CPD_CHECK, and we think we can create it, return 0. Else
- * return -1. */
- int check_private_dir(const char *dirname, cpd_check_t check)
- {
- int r;
- struct stat st;
- char *f;
- tor_assert(dirname);
- f = tor_strdup(dirname);
- clean_name_for_stat(f);
- r = stat(f, &st);
- tor_free(f);
- if (r) {
- if (errno != ENOENT) {
- log(LOG_WARN, "Directory %s cannot be read: %s", dirname,
- strerror(errno));
- return -1;
- }
- if (check == CPD_NONE) {
- log(LOG_WARN, "Directory %s does not exist.", dirname);
- return -1;
- } else if (check == CPD_CREATE) {
- log(LOG_INFO, "Creating directory %s", dirname);
- #ifdef MS_WINDOWS
- r = mkdir(dirname);
- #else
- r = mkdir(dirname, 0700);
- #endif
- if (r) {
- log(LOG_WARN, "Error creating directory %s: %s", dirname,
- strerror(errno));
- return -1;
- }
- }
- /* XXXX In the case where check==CPD_CHECK, we should look at the
- * parent directory a little harder. */
- return 0;
- }
- if (!(st.st_mode & S_IFDIR)) {
- log(LOG_WARN, "%s is not a directory", dirname);
- return -1;
- }
- #ifndef MS_WINDOWS
- if (st.st_uid != getuid()) {
- log(LOG_WARN, "%s is not owned by this UID (%d). You must fix this to proceed.", dirname, (int)getuid());
- return -1;
- }
- if (st.st_mode & 0077) {
- log(LOG_WARN, "Fixing permissions on directory %s", dirname);
- if (chmod(dirname, 0700)) {
- log(LOG_WARN, "Could not chmod directory %s: %s", dirname,
- strerror(errno));
- return -1;
- } else {
- return 0;
- }
- }
- #endif
- return 0;
- }
- /** Create a file named <b>fname</b> with the contents <b>str</b>. Overwrite the
- * previous <b>fname</b> if possible. Return 0 on success, -1 on failure.
- *
- * This function replaces the old file atomically, if possible.
- */
- int
- write_str_to_file(const char *fname, const char *str, int bin)
- {
- #ifdef MS_WINDOWS
- if (!bin && strchr(str, '\r')) {
- log_fn(LOG_WARN,
- "How odd. Writing a string that does contain CR already.");
- }
- #endif
- return write_bytes_to_file(fname, str, strlen(str), bin);
- }
- /** As write_str_to_file, but does not assume a NUL-terminated *
- * string. Instead, we write <b>len</b> bytes, starting at <b>str</b>. */
- int write_bytes_to_file(const char *fname, const char *str, size_t len,
- int bin)
- {
- size_t tempname_len;
- char *tempname;
- int fd;
- int result;
- tempname_len = strlen(fname)+16;
- tor_assert(tempname_len > strlen(fname)); /*check for overflow*/
- tempname = tor_malloc(tempname_len);
- if (tor_snprintf(tempname, tempname_len, "%s.tmp", fname)<0) {
- log(LOG_WARN, "Failed to generate filename");
- goto err;
- }
- if ((fd = open(tempname, O_WRONLY|O_CREAT|O_TRUNC|(bin?O_BINARY:O_TEXT), 0600))
- < 0) {
- log(LOG_WARN, "Couldn't open %s for writing: %s", tempname,
- strerror(errno));
- goto err;
- }
- result = write_all(fd, str, len, 0);
- if (result < 0 || (size_t)result != len) {
- log(LOG_WARN, "Error writing to %s: %s", tempname, strerror(errno));
- close(fd);
- goto err;
- }
- if (close(fd)) {
- log(LOG_WARN,"Error flushing to %s: %s", tempname, strerror(errno));
- goto err;
- }
- if (replace_file(tempname, fname)) {
- log(LOG_WARN, "Error replacing %s: %s", fname, strerror(errno));
- goto err;
- }
- tor_free(tempname);
- return 0;
- err:
- tor_free(tempname);
- return -1;
- }
- /** Read the contents of <b>filename</b> into a newly allocated
- * string; return the string on success or NULL on failure.
- */
- /*
- * This function <em>may</em> return an erroneous result if the file
- * is modified while it is running, but must not crash or overflow.
- * Right now, the error case occurs when the file length grows between
- * the call to stat and the call to read_all: the resulting string will
- * be truncated.
- */
- char *read_file_to_str(const char *filename, int bin) {
- int fd; /* router file */
- struct stat statbuf;
- char *string, *f;
- int r;
- tor_assert(filename);
- f = tor_strdup(filename);
- clean_name_for_stat(f);
- r = stat(f, &statbuf);
- tor_free(f);
- if (r < 0) {
- log_fn(LOG_INFO,"Could not stat %s.",filename);
- return NULL;
- }
- fd = open(filename,O_RDONLY|(bin?O_BINARY:O_TEXT),0);
- if (fd<0) {
- log_fn(LOG_WARN,"Could not open %s.",filename);
- return NULL;
- }
- string = tor_malloc(statbuf.st_size+1);
- r = read_all(fd,string,statbuf.st_size,0);
- if (r<0) {
- log_fn(LOG_WARN,"Error reading from file '%s': %s", filename,
- strerror(errno));
- tor_free(string);
- close(fd);
- return NULL;
- }
- string[r] = '\0'; /* NUL-terminate the result. */
- if (bin && r != statbuf.st_size) {
- /* If we're in binary mode, then we'd better have an exact match for
- * size. Otherwise, win32 encoding may throw us off, and that's okay. */
- log_fn(LOG_WARN,"Could read only %d of %ld bytes of file '%s'.",
- r, (long)statbuf.st_size,filename);
- tor_free(string);
- close(fd);
- return NULL;
- }
- #ifdef MS_WINDOWS
- if (!bin && strchr(string, '\r')) {
- log_fn(LOG_DEBUG, "We didn't convert CRLF to LF as well as we hoped when reading %s. Coping.",
- filename);
- tor_strstrip(string, "\r");
- }
- #endif
- close(fd);
- return string;
- }
- /** Given a string containing part of a configuration file or similar format,
- * advance past comments and whitespace and try to parse a single line. If we
- * parse a line successfully, set *<b>key_out</b> to the key portion and
- * *<b>value_out</b> to the value portion of the line, and return a pointer to
- * the start of the next line. If we run out of data, return a pointer to the
- * end of the string. If we encounter an error, return NULL.
- *
- * NOTE: We modify <b>line</b> as we parse it, by inserting NULs to terminate
- * the key and value.
- */
- char *
- parse_line_from_str(char *line, char **key_out, char **value_out)
- {
- char *key, *val, *cp;
- tor_assert(key_out);
- tor_assert(value_out);
- *key_out = *value_out = key = val = NULL;
- /* Skip until the first keyword. */
- while (1) {
- while (TOR_ISSPACE(*line))
- ++line;
- if (*line == '#') {
- while (*line && *line != '\n')
- ++line;
- } else {
- break;
- }
- }
- if (!*line) { /* End of string? */
- *key_out = *value_out = NULL;
- return line;
- }
- /* Skip until the next space. */
- key = line;
- while (*line && !TOR_ISSPACE(*line) && *line != '#')
- ++line;
- /* Skip until the value */
- while (*line == ' ' || *line == '\t')
- *line++ = '\0';
- val = line;
- /* Find the end of the line. */
- while (*line && *line != '\n' && *line != '#')
- ++line;
- if (*line == '\n')
- cp = line++;
- else {
- cp = line-1;
- }
- while (cp>=val && TOR_ISSPACE(*cp))
- *cp-- = '\0';
- if (*line == '#') {
- do {
- *line++ = '\0';
- } while (*line && *line != '\n');
- if (*line == '\n')
- ++line;
- }
- *key_out = key;
- *value_out = val;
- return line;
- }
- /** Expand any homedir prefix on 'filename'; return a newly allocated
- * string. */
- char *expand_filename(const char *filename)
- {
- tor_assert(filename);
- if (*filename == '~') {
- size_t len;
- char *home, *result;
- const char *rest;
- if (filename[1] == '/' || filename[1] == '\0') {
- home = getenv("HOME");
- if (!home) {
- log_fn(LOG_WARN, "Couldn't find $HOME environment variable while expanding %s", filename);
- return NULL;
- }
- home = tor_strdup(home);
- rest = strlen(filename)>=2?(filename+2):NULL;
- } else {
- #ifdef HAVE_PWD_H
- char *username, *slash;
- slash = strchr(filename, '/');
- if (slash)
- username = tor_strndup(filename+1,slash-filename-1);
- else
- username = tor_strdup(filename+1);
- if (!(home = get_user_homedir(username))) {
- log_fn(LOG_WARN,"Couldn't get homedir for %s",username);
- tor_free(username);
- return NULL;
- }
- tor_free(username);
- rest = slash ? (slash+1) : NULL;
- #else
- log_fn(LOG_WARN, "Couldn't expend homedir on system without pwd.h");
- return tor_strdup(filename);
- #endif
- }
- tor_assert(home);
- /* Remove trailing slash. */
- if (strlen(home)>1 && !strcmpend(home,"/")) {
- home[strlen(home)-1] = '\0';
- }
- /* Plus one for /, plus one for NUL.
- * Round up to 16 in case we can't do math. */
- len = strlen(home)+strlen(rest)+16;
- result = tor_malloc(len);
- tor_snprintf(result,len,"%s/%s",home,rest?rest:"");
- tor_free(home);
- return result;
- } else {
- return tor_strdup(filename);
- }
- }
- /* =====
- * Net helpers
- * ===== */
- /** Return true iff <b>ip</b> (in host order) is an IP reserved to localhost,
- * or reserved for local networks by RFC 1918.
- */
- int is_internal_IP(uint32_t ip) {
- if (((ip & 0xff000000) == 0x0a000000) || /* 10/8 */
- ((ip & 0xff000000) == 0x00000000) || /* 0/8 */
- ((ip & 0xff000000) == 0x7f000000) || /* 127/8 */
- ((ip & 0xffff0000) == 0xa9fe0000) || /* 169.254/16 */
- ((ip & 0xfff00000) == 0xac100000) || /* 172.16/12 */
- ((ip & 0xffff0000) == 0xc0a80000)) /* 192.168/16 */
- return 1;
- return 0;
- }
- /** Return true iff <b>ip</b> (in host order) is judged to be on the
- * same network as us. For now, check if it's an internal IP.
- *
- * XXX Also check if it's on the same class C network as our public IP.
- */
- int is_local_IP(uint32_t ip) {
- return is_internal_IP(ip);
- }
- /** Parse a string of the form "host[:port]" from <b>addrport</b>. If
- * <b>address</b> is provided, set *<b>address</b> to a copy of the
- * host portion of the string. If <b>addr</b> is provided, try to
- * resolve the host portion of the string and store it into
- * *<b>addr</b> (in host byte order). If <b>port</b> is provided,
- * store the port number into *<b>port</b>, or 0 if no port is given.
- * Return 0 on success, -1 on failure.
- */
- int
- parse_addr_port(const char *addrport, char **address, uint32_t *addr,
- uint16_t *port)
- {
- const char *colon;
- char *_address = NULL;
- int _port;
- int ok = 1;
- tor_assert(addrport);
- tor_assert(port);
- colon = strchr(addrport, ':');
- if (colon) {
- _address = tor_strndup(addrport, colon-addrport);
- _port = (int) tor_parse_long(colon+1,10,1,65535,NULL,NULL);
- if (!_port) {
- log_fn(LOG_WARN, "Port '%s' out of range", colon+1);
- ok = 0;
- }
- } else {
- _address = tor_strdup(addrport);
- _port = 0;
- }
- if (addr) {
- /* There's an addr pointer, so we need to resolve the hostname. */
- if (tor_lookup_hostname(_address,addr)) {
- log_fn(LOG_WARN, "Couldn't look up '%s'", _address);
- ok = 0;
- *addr = 0;
- }
- *addr = ntohl(*addr);
- }
- if (address && ok) {
- *address = _address;
- } else {
- if (address)
- *address = NULL;
- tor_free(_address);
- }
- if (port)
- *port = ok ? ((uint16_t) _port) : 0;
- return ok ? 0 : -1;
- }
- /** Parse a string <b>s</b> in the format of
- * (IP(/mask|/mask-bits)?|*):(*|port(-maxport)?), setting the various
- * *out pointers as appropriate. Return 0 on success, -1 on failure.
- */
- int
- parse_addr_and_port_range(const char *s, uint32_t *addr_out,
- uint32_t *mask_out, uint16_t *port_min_out,
- uint16_t *port_max_out)
- {
- char *address;
- char *mask, *port, *endptr;
- struct in_addr in;
- int bits;
- tor_assert(s);
- tor_assert(addr_out);
- tor_assert(mask_out);
- tor_assert(port_min_out);
- tor_assert(port_max_out);
- address = tor_strdup(s);
- /* Break 'address' into separate strings.
- */
- mask = strchr(address,'/');
- port = strchr(mask?mask:address,':');
- if (mask)
- *mask++ = '\0';
- if (port)
- *port++ = '\0';
- /* Now "address" is the IP|'*' part...
- * "mask" is the Mask|Maskbits part...
- * and "port" is the *|port|min-max part.
- */
- if (strcmp(address,"*")==0) {
- *addr_out = 0;
- } else if (tor_inet_aton(address, &in) != 0) {
- *addr_out = ntohl(in.s_addr);
- } else {
- log_fn(LOG_WARN, "Malformed IP %s in address pattern; rejecting.",address);
- goto err;
- }
- if (!mask) {
- if (strcmp(address,"*")==0)
- *mask_out = 0;
- else
- *mask_out = 0xFFFFFFFFu;
- } else {
- endptr = NULL;
- bits = (int) strtol(mask, &endptr, 10);
- if (!*endptr) {
- /* strtol handled the whole mask. */
- if (bits < 0 || bits > 32) {
- log_fn(LOG_WARN, "Bad number of mask bits on address range; rejecting.");
- goto err;
- }
- *mask_out = ~((1<<(32-bits))-1);
- } else if (tor_inet_aton(mask, &in) != 0) {
- *mask_out = ntohl(in.s_addr);
- } else {
- log_fn(LOG_WARN, "Malformed mask %s on address range; rejecting.",
- mask);
- goto err;
- }
- }
- if (!port || strcmp(port, "*") == 0) {
- *port_min_out = 1;
- *port_max_out = 65535;
- } else {
- endptr = NULL;
- *port_min_out = (uint16_t) tor_parse_long(port, 10, 1, 65535,
- NULL, &endptr);
- if (*endptr == '-') {
- port = endptr+1;
- endptr = NULL;
- *port_max_out = (uint16_t) tor_parse_long(port, 10, 1, 65535, NULL,
- &endptr);
- if (*endptr || !*port_max_out) {
- log_fn(LOG_WARN, "Malformed port %s on address range rejecting.",
- port);
- }
- } else if (*endptr || !*port_min_out) {
- log_fn(LOG_WARN, "Malformed port %s on address range; rejecting.",
- port);
- goto err;
- } else {
- *port_max_out = *port_min_out;
- }
- if (*port_min_out > *port_max_out) {
- log_fn(LOG_WARN,"Insane port range on address policy; rejecting.");
- goto err;
- }
- }
- tor_free(address);
- return 0;
- err:
- tor_free(address);
- return -1;
- }
- /** Given an IPv4 address <b>in</b> (in network order, as usual),
- * write it as a string into the <b>buf_len</b>-byte buffer in
- * <b>buf</b>.
- */
- int
- tor_inet_ntoa(struct in_addr *in, char *buf, size_t buf_len)
- {
- uint32_t a = ntohl(in->s_addr);
- return tor_snprintf(buf, buf_len, "%d.%d.%d.%d",
- (int)(uint8_t)((a>>24)&0xff),
- (int)(uint8_t)((a>>16)&0xff),
- (int)(uint8_t)((a>>8 )&0xff),
- (int)(uint8_t)((a )&0xff));
- }
- /* Return true iff <b>name</b> looks like it might be a hostname or IP
- * address of some kind. */
- int
- is_plausible_address(const char *name)
- {
- const char *cp;
- tor_assert(name);
- /* We could check better here. */
- for (cp=name; *cp; cp++) {
- if (*cp != '.' && *cp != '-' && !TOR_ISALNUM(*cp))
- return 0;
- }
- return 1;
- }
- /**
- * Set *<b>addr</b> to the host-order IPv4 address (if any) of whatever
- * interface connects to the internet. This address should only be used in
- * checking whether our address has changed. Return 0 on success, -1 on
- * failure.
- */
- int
- get_interface_address(uint32_t *addr)
- {
- int sock=-1, r=-1;
- struct sockaddr_in target_addr, my_addr;
- socklen_t my_addr_len = sizeof(my_addr);
- tor_assert(addr);
- *addr = 0;
- sock = socket(PF_INET,SOCK_DGRAM,IPPROTO_UDP);
- if (sock < 0) {
- int e = tor_socket_errno(-1);
- log_fn(LOG_WARN, "unable to create socket: %s", tor_socket_strerror(e));
- goto err;
- }
- memset(&target_addr, 0, sizeof(target_addr));
- target_addr.sin_family = AF_INET;
- /* discard port */
- target_addr.sin_port = 9;
- /* 18.0.0.1 (Don't worry: no packets are sent. We just need a real address
- * on the internet.) */
- target_addr.sin_addr.s_addr = htonl(0x12000001);
- if (connect(sock,(struct sockaddr *)&target_addr,sizeof(target_addr))<0) {
- int e = tor_socket_errno(sock);
- log_fn(LOG_WARN, "connnect() failed: %s", tor_socket_strerror(e));
- goto err;
- }
- /* XXXX Can this be right on IPv6 clients? */
- if (getsockname(sock, &my_addr, &my_addr_len)) {
- int e = tor_socket_errno(sock);
- log_fn(LOG_WARN, "getsockname() failed: %s", tor_socket_strerror(e));
- goto err;
- }
- *addr = ntohl(my_addr.sin_addr.s_addr);
- r=0;
- err:
- if (sock >= 0)
- tor_close_socket(sock);
- return r;
- }
- /* =====
- * Process helpers
- * ===== */
- #ifndef MS_WINDOWS
- /* Based on code contributed by christian grothoff */
- static int start_daemon_called = 0;
- static int finish_daemon_called = 0;
- static int daemon_filedes[2];
- /** Start putting the process into daemon mode: fork and drop all resources
- * except standard fds. The parent process never returns, but stays around
- * until finish_daemon is called. (Note: it's safe to call this more
- * than once: calls after the first are ignored.)
- */
- void start_daemon(void)
- {
- pid_t pid;
- if (start_daemon_called)
- return;
- start_daemon_called = 1;
- pipe(daemon_filedes);
- pid = fork();
- if (pid < 0) {
- log_fn(LOG_ERR,"fork failed. Exiting.");
- exit(1);
- }
- if (pid) { /* Parent */
- int ok;
- char c;
- close(daemon_filedes[1]); /* we only read */
- ok = -1;
- while (0 < read(daemon_filedes[0], &c, sizeof(char))) {
- if (c == '.')
- ok = 1;
- }
- fflush(stdout);
- if (ok == 1)
- exit(0);
- else
- exit(1); /* child reported error */
- } else { /* Child */
- close(daemon_filedes[0]); /* we only write */
- pid = setsid(); /* Detach from controlling terminal */
- /*
- * Fork one more time, so the parent (the session group leader) can exit.
- * This means that we, as a non-session group leader, can never regain a
- * controlling terminal. This part is recommended by Stevens's
- * _Advanced Programming in the Unix Environment_.
- */
- if (fork() != 0) {
- exit(0);
- }
- return;
- }
- }
- /** Finish putting the process into daemon mode: drop standard fds, and tell
- * the parent process to exit. (Note: it's safe to call this more than once:
- * calls after the first are ignored. Calls start_daemon first if it hasn't
- * been called already.)
- */
- void finish_daemon(const char *desired_cwd)
- {
- int nullfd;
- char c = '.';
- if (finish_daemon_called)
- return;
- if (!start_daemon_called)
- start_daemon();
- finish_daemon_called = 1;
- if (!desired_cwd)
- desired_cwd = "/";
- /* Don't hold the wrong FS mounted */
- if (chdir(desired_cwd) < 0) {
- log_fn(LOG_ERR,"chdir to %s failed. Exiting.",desired_cwd);
- exit(1);
- }
- nullfd = open("/dev/null",
- O_CREAT | O_RDWR | O_APPEND);
- if (nullfd < 0) {
- log_fn(LOG_ERR,"/dev/null can't be opened. Exiting.");
- exit(1);
- }
- /* close fds linking to invoking terminal, but
- * close usual incoming fds, but redirect them somewhere
- * useful so the fds don't get reallocated elsewhere.
- */
- if (dup2(nullfd,0) < 0 ||
- dup2(nullfd,1) < 0 ||
- dup2(nullfd,2) < 0) {
- log_fn(LOG_ERR,"dup2 failed. Exiting.");
- exit(1);
- }
- if (nullfd > 2)
- close(nullfd);
- write(daemon_filedes[1], &c, sizeof(char)); /* signal success */
- close(daemon_filedes[1]);
- }
- #else
- /* defined(MS_WINDOWS) */
- void start_daemon(void) {}
- void finish_daemon(const char *cp) {}
- #endif
- /** Write the current process ID, followed by NL, into <b>filename</b>.
- */
- void write_pidfile(char *filename) {
- #ifndef MS_WINDOWS
- FILE *pidfile;
- if ((pidfile = fopen(filename, "w")) == NULL) {
- log_fn(LOG_WARN, "Unable to open %s for writing: %s", filename,
- strerror(errno));
- } else {
- fprintf(pidfile, "%d\n", (int)getpid());
- fclose(pidfile);
- }
- #endif
- }
|