utils.c File Reference

#include <unistd.h>
#include <sys/uio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <errno.h>
#include <signal.h>
#include <stdio.h>
#include "utils.h"

Go to the source code of this file.

Typedefs
typedef void	sigfunc (int)
Functions
sigfunc *	sig_catch (int sig, void(*f)(int))
static void	catch_alrm (int x)
int	timeout_connect (int sockfd, const struct sockaddr *serv_addr, size_t addrlen)
int	fd_timeout_read (int fd, char fdflag, void *buf, size_t nbytes)
int	ssl_timeout_read (SSL *ssl, void *buf, int nbytes)
int	full_read (int fd, char fdflag, void *vbuf, int min, int len)
int	full_read_ssl (SSL *ssl, unsigned char *buf, int min, int len)
int	full_write (int fd, char fdflag, const void *vbuf, int len)

---

Typedef Documentation

typedef void sigfunc(int)

Definition at line 53 of file utils.c.

---

Function Documentation

static void catch_alrm (  int  x  )  [static]

Definition at line 65 of file utils.c. References UNUSED_VARIABLE. Referenced by fd_timeout_read(), ssl_timeout_read(), and timeout_connect(). { UNUSED_VARIABLE(x); }

int fd_timeout_read (  int  fd, char  fdflag, void *  buf, size_t  nbytes )

Definition at line 98 of file utils.c. References catch_alrm(), libspamc_timeout, and sig_catch(). Referenced by _spamc_read_full_line(), and full_read(). { int nred; int origerr; #ifndef _WIN32 sigfunc *sig; sig = sig_catch(SIGALRM, catch_alrm); if (libspamc_timeout > 0) { alarm(libspamc_timeout); } #endif do { if (fdflag) { nred = (int)read(fd, buf, nbytes); origerr = errno; } else { nred = (int)recv(fd, buf, nbytes, 0); #ifndef _WIN32 origerr = errno; #else origerr = WSAGetLastError(); #endif } } while (nred < 0 && origerr == EWOULDBLOCK); #ifndef _WIN32 if (nred < 0 && origerr == EINTR) errno = ETIMEDOUT; if (libspamc_timeout > 0) { alarm(0); } /* restore old signal handler */ sig_catch(SIGALRM, sig); #endif return nred; }

int full_read (  int  fd, char  fdflag, void *  vbuf, int  min, int  len )

Definition at line 184 of file utils.c. References fd_timeout_read(). Referenced by _message_read_bsmtp(), _message_read_raw(), message_dump(), and message_filter(). { unsigned char *buf = (unsigned char *) vbuf; int total; int thistime; for (total = 0; total < min;) { thistime = fd_timeout_read(fd, fdflag, buf + total, len - total); if (thistime < 0) { if (total >= min) { /* error, but we read *some*. return what we've read * so far and next read (if there is one) will return -1. */ return total; } else { return -1; } } else if (thistime == 0) { /* EOF, but we didn't read the minimum. return what we've read * so far and next read (if there is one) will return 0. */ return total; } total += thistime; } return total; }

int full_read_ssl (  SSL *  ssl, unsigned char *  buf, int  min, int  len )

Definition at line 213 of file utils.c. References ssl_timeout_read(). Referenced by message_filter(). { int total; int thistime; for (total = 0; total < min;) { thistime = ssl_timeout_read(ssl, buf + total, len - total); if (thistime < 0) { if (total >= min) { /* error, but we read *some*. return what we've read * so far and next read (if there is one) will return -1. */ return total; } else { return -1; } } else if (thistime == 0) { /* EOF, but we didn't read the minimum. return what we've read * so far and next read (if there is one) will return 0. */ return total; } total += thistime; } return total; }

int full_write (  int  fd, char  fdflag, const void *  vbuf, int  len )

Definition at line 241 of file utils.c. Referenced by main(), message_dump(), message_filter(), message_process(), message_tell(), and message_write(). { const char *buf = (const char *) vbuf; int total; int thistime; int origerr; for (total = 0; total < len;) { if (fdflag) { thistime = write(fd, buf + total, len - total); origerr = errno; } else { thistime = send(fd, buf + total, len - total, 0); #ifndef _WIN32 origerr = errno; #else origerr = WSAGetLastError(); #endif } if (thistime < 0) { if (EINTR == origerr || EWOULDBLOCK == origerr) continue; return thistime; /* always an error for writes */ } total += thistime; } return total; }

sigfunc* sig_catch (  int  sig, void(*)(int)  f )

Definition at line 55 of file utils.c. Referenced by fd_timeout_read(), ssl_timeout_read(), and timeout_connect(). { struct sigaction act, oact; act.sa_handler = f; act.sa_flags = 0; sigemptyset(&act.sa_mask); sigaction(sig, &act, &oact); return oact.sa_handler; }

int ssl_timeout_read (  SSL *  ssl, void *  buf, int  nbytes )

Definition at line 141 of file utils.c. References catch_alrm(), libspamc_timeout, sig_catch(), and UNUSED_VARIABLE. Referenced by _spamc_read_full_line(), and full_read_ssl(). { int nred; #ifndef _WIN32 sigfunc *sig; sig = sig_catch(SIGALRM, catch_alrm); if (libspamc_timeout > 0) { alarm(libspamc_timeout); } #endif do { #ifdef SPAMC_SSL nred = SSL_read(ssl, buf, nbytes); #else UNUSED_VARIABLE(ssl); UNUSED_VARIABLE(buf); UNUSED_VARIABLE(nbytes); nred = 0; /* never used */ #endif } while (nred < 0 && errno == EWOULDBLOCK); #ifndef _WIN32 if (nred < 0 && errno == EINTR) errno = ETIMEDOUT; if (libspamc_timeout > 0) { alarm(0); } /* restore old signal handler */ sig_catch(SIGALRM, sig); #endif return nred; }

int timeout_connect (  int  sockfd, const struct sockaddr *  serv_addr, size_t  addrlen )

Definition at line 71 of file utils.c. References catch_alrm(), libspamc_timeout, and sig_catch(). Referenced by _try_to_connect_tcp(), and _try_to_connect_unix(). { int ret; #ifndef _WIN32 sigfunc* sig; sig = sig_catch(SIGALRM, catch_alrm); if (libspamc_timeout > 0) { alarm(libspamc_timeout); } #endif ret = connect(sockfd, serv_addr, addrlen); #ifndef _WIN32 if (libspamc_timeout > 0) { alarm(0); } /* restore old signal handler */ sig_catch(SIGALRM, sig); #endif return ret; }

---

© sourcejam.com 2005-2008