libspamc.c File Reference

#include "config.h"
#include "libspamc.h"
#include "utils.h"
#include <stdlib.h>
#include <assert.h>
#include <stdio.h>
#include <string.h>
#include <syslog.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/un.h>
#include <netinet/tcp.h>
#include <arpa/inet.h>

Go to the source code of this file.

Classes
struct	libspamc_private_message
Defines
#define	closesocket(x)   close(x)
#define	SHUT_RD   0
#define	SHUT_WR   1
#define	SHUT_RDWR   2
#define	h_errno   errno
#define	spamc_get_errno()   errno
#define	INADDR_NONE   ((in_addr_t) 0xffffffff)
#define	EX__MAX   200
#define	SPAMC_MAXHOST   256
#define	SPAMC_MAXSERV   256
#define	CRNLCRNL   "\r\n\r\n"
#define	CRNLCRNL_LEN   4
#define	NLNL   "\n\n"
#define	NLNL_LEN   2
#define	LOG_BUFSIZ   1023
Functions
static int	_translate_connect_errno (int err)
static int	_opensocket (int flags, int type, int *psock)
static int	_try_to_connect_unix (struct transport *tp, int *sockptr)
static int	_try_to_connect_tcp (const struct transport *tp, int *sockptr)
static void	_clear_message (struct message *m)
static void	_use_msg_for_out (struct message *m)
static int	_message_read_raw (int fd, struct message *m)
static int	_message_read_bsmtp (int fd, struct message *m)
int	message_read (int fd, int flags, struct message *m)
long	message_write (int fd, struct message *m)
void	message_dump (int in_fd, int out_fd, struct message *m)
static int	_spamc_read_full_line (struct message *m, int flags, SSL *ssl, int sock, char *buf, size_t *lenp, size_t bufsiz)
static float	_locale_safe_string_to_float (char *buf, int siz)
static int	_handle_spamd_header (struct message *m, int flags, char *buf, int len, unsigned int *didtellflags)
static int	_zlib_compress (char *m_msg, int m_msg_len, unsigned char **zlib_buf, int *zlib_bufsiz, int flags)
int	_append_original_body (struct message *m, int flags)
int	message_filter (struct transport *tp, const char *username, int flags, struct message *m)
int	message_process (struct transport *trans, char *username, int max_size, int in_fd, int out_fd, const int flags)
int	message_tell (struct transport *tp, const char *username, int flags, struct message *m, int msg_class, unsigned int tellflags, unsigned int *didtellflags)
void	message_cleanup (struct message *m)
int	process_message (struct transport *tp, char *username, int max_size, int in_fd, int out_fd, const int my_check_only, const int my_safe_fallback)
void	transport_init (struct transport *tp)
static void	_randomize_hosts (struct transport *tp)
int	transport_setup (struct transport *tp, int flags)
void	libspamc_log (int flags, int level, char *msg,...)
Variables
char *	optarg
static const int	EXPANSION_ALLOWANCE = 16384
static const char *	PROTOCOL_VERSION = "SPAMC/1.4"
int	libspamc_timeout = 0

---

Define Documentation

#define closesocket (  x   )     close(x)

Definition at line 49 of file libspamc.c. Referenced by _opensocket(), _try_to_connect_tcp(), _try_to_connect_unix(), message_filter(), and message_tell().

#define CRNLCRNL   "\r\n\r\n"

Referenced by _append_original_body().

#define CRNLCRNL_LEN   4

Referenced by _append_original_body().

#define EX__MAX   200

Definition at line 107 of file libspamc.c.

#define h_errno   errno

Definition at line 85 of file libspamc.c. Referenced by transport_setup().

#define INADDR_NONE   ((in_addr_t) 0xffffffff)

Definition at line 99 of file libspamc.c.

#define LOG_BUFSIZ   1023

Definition at line 2028 of file libspamc.c. Referenced by libspamc_log().

#define NLNL   "\n\n"

Referenced by _append_original_body().

#define NLNL_LEN   2

Referenced by _append_original_body().

#define SHUT_RD   0

Definition at line 75 of file libspamc.c. Referenced by message_filter(), and message_tell().

#define SHUT_RDWR   2

Definition at line 81 of file libspamc.c.

#define SHUT_WR   1

Definition at line 78 of file libspamc.c. Referenced by message_filter(), and message_tell().

#define spamc_get_errno (   )     errno

Definition at line 91 of file libspamc.c. Referenced by _opensocket(), and _try_to_connect_tcp().

#define SPAMC_MAXHOST   256

Definition at line 120 of file libspamc.c. Referenced by _try_to_connect_tcp().

#define SPAMC_MAXSERV   256

Definition at line 126 of file libspamc.c. Referenced by _try_to_connect_tcp().

---

Function Documentation

int _append_original_body (  struct message *  m, int  flags )

Definition at line 1096 of file libspamc.c. References libspamc_private_message::alloced_size, CRNLCRNL, CRNLCRNL_LEN, EX_OK, EX_SOFTWARE, libspamc_log(), LOG_ERR, NLNL, NLNL_LEN, message::out, message::out_len, message::priv, message::raw, and message::raw_len. Referenced by message_filter(). { char *cp, *cpend, *bodystart; int bodylen, outspaceleft, towrite; /* at this stage, m->out now contains the rewritten headers. * find and append the raw message's body, up to m->priv->alloced_size * bytes. */ #define CRNLCRNL "\r\n\r\n" #define CRNLCRNL_LEN 4 #define NLNL "\n\n" #define NLNL_LEN 2 cpend = m->raw + m->raw_len; bodystart = NULL; for (cp = m->raw; cp < cpend; cp++) { if (*cp == '\r' && cpend - cp >= CRNLCRNL_LEN && !strncmp(cp, CRNLCRNL, CRNLCRNL_LEN)) { bodystart = cp + CRNLCRNL_LEN; break; } else if (*cp == '\n' && cpend - cp >= NLNL_LEN && !strncmp(cp, NLNL, NLNL_LEN)) { bodystart = cp + NLNL_LEN; break; } } if (bodystart == NULL) { libspamc_log(flags, LOG_ERR, "failed to find end-of-headers"); return EX_SOFTWARE; } bodylen = cpend - bodystart; outspaceleft = (m->priv->alloced_size-1) - m->out_len; towrite = (bodylen < outspaceleft ? bodylen : outspaceleft); /* copy in the body; careful not to overflow */ strncpy (m->out + m->out_len, bodystart, towrite); m->out_len += towrite; return EX_OK; }

static void _clear_message (  struct message *  m  )  [static]

Definition at line 606 of file libspamc.c. References message::content_length, EX_TOOBIG, message::is_spam, MESSAGE_NONE, message::msg, message::msg_len, message::out, message::out_len, message::outbuf, message::post, message::post_len, message::pre, message::pre_len, message::raw, message::raw_len, message::score, message::threshold, and message::type. Referenced by _message_read_bsmtp(), _message_read_raw(), message_cleanup(), and message_read(). { m->type = MESSAGE_NONE; m->raw = NULL; m->raw_len = 0; m->pre = NULL; m->pre_len = 0; m->msg = NULL; m->msg_len = 0; m->post = NULL; m->post_len = 0; m->is_spam = EX_TOOBIG; m->score = 0.0; m->threshold = 0.0; m->outbuf = NULL; m->out = NULL; m->out_len = 0; m->content_length = -1; }

static int _handle_spamd_header (  struct message *  m, int  flags, char *  buf, int  len, unsigned int *  didtellflags )  [static]

Definition at line 965 of file libspamc.c. References _locale_safe_string_to_float(), message::content_length, EX_ISSPAM, EX_NOTSPAM, EX_OK, EX_PROTOCOL, message::is_spam, libspamc_log(), LOG_ERR, message::out, message::out_len, message::score, SPAMC_CHECK_ONLY, SPAMC_REMOVE_LOCAL, SPAMC_REMOVE_REMOTE, SPAMC_REPORT, SPAMC_REPORT_IFSPAM, SPAMC_SET_LOCAL, SPAMC_SET_REMOTE, message::threshold, and UNUSED_VARIABLE. Referenced by message_filter(), and message_tell(). { char is_spam[6]; char s_str[21], t_str[21]; char didset_ret[15]; char didremove_ret[15]; UNUSED_VARIABLE(len); /* Feb 12 2003 jm: actually, I think sccanf is working fine here ;) * let's stick with it for this parser. * May 7 2003 jm: using %f is bad where LC_NUMERIC is "," in the locale. * work around using our own locale-independent float-parser code. */ if (sscanf(buf, "Spam: %5s ; %20s / %20s", is_spam, s_str, t_str) == 3) { m->score = _locale_safe_string_to_float(s_str, 20); m->threshold = _locale_safe_string_to_float(t_str, 20); /* set bounds on these to ensure no buffer overflow in the sprintf */ if (m->score > 1e10) m->score = 1e10; else if (m->score < -1e10) m->score = -1e10; if (m->threshold > 1e10) m->threshold = 1e10; else if (m->threshold < -1e10) m->threshold = -1e10; /* Format is "Spam: x; y / x" */ m->is_spam = strcasecmp("true", is_spam) == 0 ? EX_ISSPAM : EX_NOTSPAM; if (flags & SPAMC_CHECK_ONLY) { m->out_len = sprintf(m->out, "%.1f/%.1f\n", m->score, m->threshold); } else if ((flags & SPAMC_REPORT_IFSPAM && m->is_spam == EX_ISSPAM) || (flags & SPAMC_REPORT)) { m->out_len = sprintf(m->out, "%.1f/%.1f\n", m->score, m->threshold); } return EX_OK; } else if (sscanf(buf, "Content-length: %d", &m->content_length) == 1) { if (m->content_length < 0) { libspamc_log(flags, LOG_ERR, "spamd responded with bad Content-length '%s'", buf); return EX_PROTOCOL; } return EX_OK; } else if (sscanf(buf, "DidSet: %14s", didset_ret) == 1) { if (strstr(didset_ret, "local")) { *didtellflags |= SPAMC_SET_LOCAL; } if (strstr(didset_ret, "remote")) { *didtellflags |= SPAMC_SET_REMOTE; } } else if (sscanf(buf, "DidRemove: %14s", didremove_ret) == 1) { if (strstr(didremove_ret, "local")) { *didtellflags |= SPAMC_REMOVE_LOCAL; } if (strstr(didremove_ret, "remote")) { *didtellflags |= SPAMC_REMOVE_REMOTE; } } return EX_OK; }

static float _locale_safe_string_to_float (  char *  buf, int  siz )  [static]

Definition at line 904 of file libspamc.c. Referenced by _handle_spamd_header(), message_filter(), and message_tell(). { int is_neg; char *cp, *dot; int divider; float ret, postdot; buf[siz - 1] = '\0'; /* ensure termination */ /* ok, let's illustrate using "100.033" as an example... */ is_neg = 0; if (*buf == '-') { is_neg = 1; } ret = (float) (strtol(buf, &dot, 10)); if (dot == NULL) { return 0.0; } if (dot != NULL && *dot != '.') { return ret; } /* ex: ret == 100.0 */ cp = (dot + 1); postdot = (float) (strtol(cp, NULL, 10)); /* note: don't compare floats == 0.0, it's unsafe. use a range */ if (postdot >= -0.00001 && postdot <= 0.00001) { return ret; } /* ex: postdot == 33.0, cp="033" */ /* now count the number of decimal places and figure out what power of 10 to use */ divider = 1; while (*cp != '\0') { divider *= 10; cp++; } /* ex: * cp="033", divider=1 * cp="33", divider=10 * cp="3", divider=100 * cp="", divider=1000 */ if (is_neg) { ret -= (postdot / ((float) divider)); } else { ret += (postdot / ((float) divider)); } /* ex: ret == 100.033, tada! ... hopefully */ return ret; }

static int _message_read_bsmtp (  int  fd, struct message *  m )  [static]

Definition at line 663 of file libspamc.c. References _clear_message(), EX_DATAERR, EX_IOERR, EX_OK, EX_OSERR, EX_SOFTWARE, EX_TOOBIG, full_read(), message::max_len, MESSAGE_BSMTP, MESSAGE_ERROR, message::msg, message::msg_len, message::out, message::out_len, message::post, message::post_len, message::pre, message::pre_len, message::raw, message::raw_len, and message::type. Referenced by message_read(). { unsigned int i, j, p_len; char prev; char* p; _clear_message(m); if ((m->raw = malloc(m->max_len + 1)) == NULL) return EX_OSERR; /* Find the DATA line */ m->raw_len = full_read(fd, 1, m->raw, m->max_len + 1, m->max_len + 1); if (m->raw_len <= 0) { free(m->raw); m->raw = NULL; m->raw_len = 0; return EX_IOERR; } m->type = MESSAGE_ERROR; if (m->raw_len > (int) m->max_len) return EX_TOOBIG; p = m->pre = m->raw; /* Search for \nDATA\n which marks start of actual message */ while ((p_len = (m->raw_len - (p - m->raw))) > 8) { /* leave room for at least \nDATA\n.\n */ char* q = memchr(p, '\n', p_len - 8); /* find next \n then see if start of \nDATA\n */ if (q == NULL) break; q++; if (((q[0]|0x20) == 'd') && /* case-insensitive ASCII comparison */ ((q[1]|0x20) == 'a') && ((q[2]|0x20) == 't') && ((q[3]|0x20) == 'a')) { q+=4; if (q[0] == '\r') ++q; if (*(q++) == '\n') { /* leave q at start of message if we found it */ m->msg = q; m->pre_len = q - m->raw; m->msg_len = m->raw_len - m->pre_len; break; } } p = q; /* the above code ensures no other '\n' comes before q */ } if (m->msg == NULL) return EX_DATAERR; /* ensure this is >= 0 */ if (m->msg_len < 0) { return EX_SOFTWARE; } /* Find the end-of-DATA line */ prev = '\n'; for (i = j = 0; i < (unsigned int) m->msg_len; i++) { if (prev == '\n' && m->msg[i] == '.') { /* Dot at the beginning of a line */ if (((int) (i+1) == m->msg_len) || ((int) (i+1) < m->msg_len && m->msg[i + 1] == '\n') || ((int) (i+2) < m->msg_len && m->msg[i + 1] == '\r' && m->msg[i + 2] == '\n')) { /* Lone dot! That's all, folks */ m->post = m->msg + i; m->post_len = m->msg_len - i; m->msg_len = j; break; } else if ((int) (i+1) < m->msg_len && m->msg[i + 1] == '.') { /* Escaping dot, eliminate. */ prev = '.'; continue; } /* Else an ordinary dot, drop down to ordinary char handler */ } prev = m->msg[i]; m->msg[j++] = m->msg[i]; } /* if bad format with no end "\n.\n", error out */ if (m->post == NULL) return EX_DATAERR; m->type = MESSAGE_BSMTP; m->out = m->msg; m->out_len = m->msg_len; return EX_OK; }

static int _message_read_raw (  int  fd, struct message *  m )  [static]

Definition at line 635 of file libspamc.c. References _clear_message(), EX_IOERR, EX_OK, EX_OSERR, EX_TOOBIG, libspamc_private_message::flags, full_read(), libspamc_log(), LOG_ERR, message::max_len, MESSAGE_ERROR, MESSAGE_RAW, message::msg, message::msg_len, message::out, message::out_len, message::priv, message::raw, message::raw_len, and message::type. Referenced by message_read(). { _clear_message(m); if ((m->raw = malloc(m->max_len + 1)) == NULL) return EX_OSERR; m->raw_len = full_read(fd, 1, m->raw, m->max_len + 1, m->max_len + 1); if (m->raw_len <= 0) { free(m->raw); m->raw = NULL; m->raw_len = 0; return EX_IOERR; } m->type = MESSAGE_ERROR; if (m->raw_len > (int) m->max_len) { libspamc_log(m->priv->flags, LOG_ERR, "skipped message, greater than max message size (%d bytes)", m->max_len); return EX_TOOBIG; } m->type = MESSAGE_RAW; m->msg = m->raw; m->msg_len = m->raw_len; m->out = m->msg; m->out_len = m->msg_len; return EX_OK; }

static int _opensocket (  int  flags, int  type, int *  psock )  [static]

Definition at line 205 of file libspamc.c. References closesocket, EX_NOPERM, EX_OSERR, EX_SOFTWARE, libspamc_log(), libspamc_timeout, LOG_ERR, and spamc_get_errno. Referenced by _try_to_connect_tcp(), and _try_to_connect_unix(). { int proto = 0; #endif const char *typename; int origerr; #ifdef _WIN32 int socktout; #endif assert(psock != 0); /*---------------------------------------------------------------- * Create a few induction variables that are implied by the socket * type given by the user. The typename is strictly used for debug * reporting. */ #ifdef SPAMC_HAS_ADDRINFO switch(res->ai_family) { case PF_UNIX: typename = "PF_UNIX"; break; case PF_INET: typename = "PF_INET"; break; case PF_INET6: typename = "PF_INET6"; break; default: typename = "Unknown"; break; } #else if (type == PF_UNIX) { typename = "PF_UNIX"; } else { typename = "PF_INET"; proto = IPPROTO_TCP; } #endif #ifdef DO_CONNECT_DEBUG_SYSLOGS libspamc_log(flags, CONNECT_DEBUG_LEVEL, "dbg: create socket(%s)", typename); #endif #ifdef SPAMC_HAS_ADDRINFO if ((*psock = socket(res->ai_family, res->ai_socktype, res->ai_protocol)) #else if ((*psock = socket(type, SOCK_STREAM, proto)) #endif #ifndef _WIN32 < 0 #else == INVALID_SOCKET #endif ) { /*-------------------------------------------------------- * At this point we had a failure creating the socket, and * this is pretty much fatal. Translate the error reason * into something the user can understand. */ origerr = spamc_get_errno(); #ifndef _WIN32 libspamc_log(flags, LOG_ERR, "socket(%s) to spamd failed: %s", typename, strerror(origerr)); #else libspamc_log(flags, LOG_ERR, "socket(%s) to spamd failed: %d", typename, origerr); #endif switch (origerr) { case EPROTONOSUPPORT: case EINVAL: return EX_SOFTWARE; case EACCES: return EX_NOPERM; case ENFILE: case EMFILE: case ENOBUFS: case ENOMEM: return EX_OSERR; default: return EX_SOFTWARE; } } #ifdef _WIN32 /* bug 4344: makes timeout functional on Win32 */ socktout = libspamc_timeout * 1000; if (type == PF_INET && setsockopt(*psock, SOL_SOCKET, SO_RCVTIMEO, (char *)&socktout, sizeof(socktout)) != 0) { origerr = spamc_get_errno(); switch (origerr) { case EBADF: case ENOTSOCK: case ENOPROTOOPT: case EFAULT: libspamc_log(flags, LOG_ERR, "setsockopt(SO_RCVTIMEO) failed: %d", origerr); closesocket(*psock); return EX_SOFTWARE; default: break; /* ignored */ } } #endif /*---------------------------------------------------------------- * Do a bit of setup on the TCP socket if required. Notes above * suggest this is probably not set */ #ifdef USE_TCP_NODELAY { int one = 1; if (type == PF_INET && setsockopt(*psock, 0, TCP_NODELAY, &one, sizeof one) != 0) { origerr = spamc_get_errno(); switch (origerr) { case EBADF: case ENOTSOCK: case ENOPROTOOPT: case EFAULT: libspamc_log(flags, LOG_ERR, #ifndef _WIN32 "setsockopt(TCP_NODELAY) failed: %s", strerror(origerr)); #else "setsockopt(TCP_NODELAY) failed: %d", origerr); #endif closesocket(*psock); return EX_SOFTWARE; default: break; /* ignored */ } } } #endif /* USE_TCP_NODELAY */ return EX_OK; /* all is well */ }

static void _randomize_hosts (  struct transport *  tp  )  [static]

Definition at line 1749 of file libspamc.c. References transport::hosts, and transport::nhosts. Referenced by transport_setup(). { #ifdef SPAMC_HAS_ADDRINFO struct addrinfo *tmp; #else struct in_addr tmp; #endif int i; int rnum; assert(tp != 0); if (tp->nhosts <= 1) return; rnum = rand() % tp->nhosts; while (rnum-- > 0) { tmp = tp->hosts[0]; /* TODO: free using freeaddrinfo() */ for (i = 1; i < tp->nhosts; i++) tp->hosts[i - 1] = tp->hosts[i]; tp->hosts[i - 1] = tmp; } }

static int _spamc_read_full_line (  struct message *  m, int  flags, SSL *  ssl, int  sock, char *  buf, size_t *  lenp, size_t  bufsiz )  [static]

Definition at line 858 of file libspamc.c. References EX_IOERR, EX_OK, EX_TOOBIG, fd_timeout_read(), libspamc_log(), LOG_ERR, SPAMC_USE_SSL, ssl_timeout_read(), and UNUSED_VARIABLE. Referenced by message_filter(), and message_tell(). { int failureval; int bytesread = 0; size_t len; UNUSED_VARIABLE(m); *lenp = 0; /* Now, read from spamd */ for (len = 0; len < bufsiz - 1; len++) { if (flags & SPAMC_USE_SSL) { bytesread = ssl_timeout_read(ssl, buf + len, 1); } else { bytesread = fd_timeout_read(sock, 0, buf + len, 1); } if (bytesread <= 0) { failureval = EX_IOERR; goto failure; } if (buf[len] == '\n') { buf[len] = '\0'; if (len > 0 && buf[len - 1] == '\r') { len--; buf[len] = '\0'; } *lenp = len; return EX_OK; } } libspamc_log(flags, LOG_ERR, "spamd responded with line of %d bytes, dying", len); failureval = EX_TOOBIG; failure: return failureval; }

static int _translate_connect_errno (  int  err  )  [static]

Definition at line 165 of file libspamc.c. References EX_NOPERM, EX_SOFTWARE, and EX_UNAVAILABLE. Referenced by _try_to_connect_tcp(), and _try_to_connect_unix(). { switch (err) { case EBADF: case EFAULT: case ENOTSOCK: case EISCONN: case EADDRINUSE: case EINPROGRESS: case EALREADY: case EAFNOSUPPORT: return EX_SOFTWARE; case ECONNREFUSED: case ETIMEDOUT: case ENETUNREACH: return EX_UNAVAILABLE; case EACCES: return EX_NOPERM; default: return EX_SOFTWARE; } }

static int _try_to_connect_tcp (  const struct transport *  tp, int *  sockptr )  [static]

Definition at line 435 of file libspamc.c. References _opensocket(), _translate_connect_errno(), closesocket, transport::connect_retries, EX_OK, transport::flags, transport::hosts, libspamc_log(), LOG_DEBUG, LOG_ERR, transport::nhosts, transport::port, transport::retry_sleep, spamc_get_errno, SPAMC_MAXHOST, SPAMC_MAXSERV, and timeout_connect(). Referenced by message_filter(), and message_tell(). { int numloops; int origerr = 0; int ret; #ifdef SPAMC_HAS_ADDRINFO struct addrinfo *res = NULL; #else int res = PF_INET; #endif char host[SPAMC_MAXHOST-1]; /* hostname, for logging */ char port[SPAMC_MAXSERV-1]; /* port, for logging */ int connect_retries, retry_sleep; assert(tp != 0); assert(sockptr != 0); assert(tp->nhosts > 0); /* default values */ retry_sleep = tp->retry_sleep; connect_retries = tp->connect_retries; if (connect_retries == 0) { connect_retries = 3; } if (retry_sleep < 0) { retry_sleep = 1; } for (numloops = 0; numloops < connect_retries; numloops++) { const int hostix = numloops % tp->nhosts; int status, mysock; /*-------------------------------------------------------- * We always start by creating the socket, as we get only * one attempt to connect() on each one. If this fails, * we're done. */ #ifdef SPAMC_HAS_ADDRINFO res = tp->hosts[hostix]; while(res) { char *family = NULL; switch(res->ai_family) { case AF_INET: family = "AF_INET"; break; case AF_INET6: family = "AF_INET6"; break; default: family = "Unknown"; break; } if ((ret = _opensocket(tp->flags, res, &mysock)) != EX_OK) { res = res->ai_next; continue; } getnameinfo(res->ai_addr, res->ai_addrlen, host, sizeof(host), port, sizeof(port), NI_NUMERICHOST|NI_NUMERICSERV); #ifdef DO_CONNECT_DEBUG_SYSLOGS libspamc_log(tp->flags, CONNECT_DEBUG_LEVEL, "dbg: connect(%s) to spamd (host %s, port %s) (try #%d of %d)", family, host, port, numloops + 1, connect_retries); #endif /* this is special-cased so that we have an address we can * safely use as an "always fail" test case */ if (!strcmp(host, "255.255.255.255")) { libspamc_log(tp->flags, LOG_ERR, "connect to spamd on %s failed, broadcast addr", host); status = -1; } else { status = timeout_connect(mysock, res->ai_addr, res->ai_addrlen); } #else struct sockaddr_in addrbuf; const char *ipaddr; const char* family="AF_INET"; if ((ret = _opensocket(tp->flags, PF_INET, &mysock)) != EX_OK) return ret; memset(&addrbuf, 0, sizeof(addrbuf)); addrbuf.sin_family = AF_INET; addrbuf.sin_port = htons(tp->port); addrbuf.sin_addr = tp->hosts[hostix]; ipaddr = inet_ntoa(addrbuf.sin_addr); /* make a copy in host, for logging (bug 5577) */ strncpy (host, ipaddr, sizeof(host) - 1); #ifdef DO_CONNECT_DEBUG_SYSLOGS libspamc_log(tp->flags, LOG_DEBUG, "dbg: connect(AF_INET) to spamd at %s (try #%d of %d)", ipaddr, numloops + 1, connect_retries); #endif /* this is special-cased so that we have an address we can * safely use as an "always fail" test case */ if (!strcmp(ipaddr, "255.255.255.255")) { libspamc_log(tp->flags, LOG_ERR, "connect to spamd on %s failed, broadcast addr", ipaddr); status = -1; } else { status = timeout_connect(mysock, (struct sockaddr *) &addrbuf, sizeof(addrbuf)); } #endif if (status != 0) { origerr = spamc_get_errno(); closesocket(mysock); #ifndef _WIN32 libspamc_log(tp->flags, LOG_ERR, "connect to spamd on %s failed, retrying (#%d of %d): %s", host, numloops+1, connect_retries, strerror(origerr)); #else libspamc_log(tp->flags, LOG_ERR, "connect to spamd on %s failed, retrying (#%d of %d): %d", host, numloops+1, connect_retries, origerr); #endif } else { #ifdef DO_CONNECT_DEBUG_SYSLOGS libspamc_log(tp->flags, CONNECT_DEBUG_LEVEL, "dbg: connect(%s) to spamd done",family); #endif *sockptr = mysock; return EX_OK; } #ifdef SPAMC_HAS_ADDRINFO res = res->ai_next; } #endif sleep(retry_sleep); } /* for(numloops...) */ #ifdef SPAMC_HAS_ADDRINFO for(numloops=0;numloops<tp->nhosts;numloops++) { freeaddrinfo(tp->hosts[numloops]); } #endif libspamc_log(tp->flags, LOG_ERR, "connection attempt to spamd aborted after %d retries", connect_retries); return _translate_connect_errno(origerr); }

static int _try_to_connect_unix (  struct transport *  tp, int *  sockptr )  [static]

Definition at line 361 of file libspamc.c. References _opensocket(), _translate_connect_errno(), closesocket, EX_OK, EX_OSERR, transport::flags, libspamc_log(), LOG_ERR, transport::socketpath, and timeout_connect(). Referenced by message_filter(), and message_tell(). { #ifndef _WIN32 int mysock, status, origerr; struct sockaddr_un addrbuf; #ifdef SPAMC_HAS_ADDRINFO struct addrinfo hints, *res; #else int res = PF_UNIX; #endif int ret; assert(tp != 0); assert(sockptr != 0); assert(tp->socketpath != 0); #ifdef SPAMC_HAS_ADDRINFO memset(&hints, 0, sizeof(hints)); hints.ai_family = PF_UNIX; hints.ai_socktype = SOCK_STREAM; hints.ai_protocol = 0; res = &hints; #endif /*---------------------------------------------------------------- * If the socket itself can't be created, this is a fatal error. */ if ((ret = _opensocket(tp->flags, res, &mysock)) != EX_OK) return ret; /* set up the UNIX domain socket */ memset(&addrbuf, 0, sizeof addrbuf); addrbuf.sun_family = AF_UNIX; strncpy(addrbuf.sun_path, tp->socketpath, sizeof addrbuf.sun_path - 1); addrbuf.sun_path[sizeof addrbuf.sun_path - 1] = '\0'; #ifdef DO_CONNECT_DEBUG_SYSLOGS libspamc_log(tp->flags, CONNECT_DEBUG_LEVEL, "dbg: connect(AF_UNIX) to spamd at %s", addrbuf.sun_path); #endif status = timeout_connect(mysock, (struct sockaddr *) &addrbuf, sizeof(addrbuf)); origerr = errno; if (status >= 0) { #ifdef DO_CONNECT_DEBUG_SYSLOGS libspamc_log(tp->flags, CONNECT_DEBUG_LEVEL, "dbg: connect(AF_UNIX) ok"); #endif *sockptr = mysock; return EX_OK; } libspamc_log(tp->flags, LOG_ERR, "connect(AF_UNIX) to spamd %s failed: %s", addrbuf.sun_path, strerror(origerr)); closesocket(mysock); return _translate_connect_errno(origerr); #else (void) tp; /* not used. suppress compiler warning */ (void) sockptr; /* not used. suppress compiler warning */ return EX_OSERR; #endif }