masqmail-0.2

annotate src/libident/id_open.c @ 118:7f1f364c2a29

annotations at msg_calc_size()
author meillo@marmaro.de
date Thu, 01 Jul 2010 13:09:40 +0200
parents 08114f7dcc23
children
rev   line source
meillo@0 1 /*
meillo@0 2 ** id_open.c Establish/initiate a connection to an IDENT server
meillo@0 3 **
meillo@0 4 ** Author: Peter Eriksson <pen@lysator.liu.se>
meillo@0 5 ** Fixes: Pär Emanuelsson <pell@lysator.liu.se>
meillo@0 6 */
meillo@0 7
meillo@0 8 #ifdef NeXT3
meillo@0 9 # include <libc.h>
meillo@0 10 #endif
meillo@0 11
meillo@0 12 #include <stdio.h>
meillo@0 13 #include <errno.h>
meillo@0 14 #include <fcntl.h>
meillo@0 15
meillo@0 16 #ifdef HAVE_ANSIHEADERS
meillo@0 17 # include <stdlib.h>
meillo@0 18 # include <string.h>
meillo@0 19 # include <unistd.h>
meillo@0 20 # if !defined(__sgi) && !defined(VMS)
meillo@0 21 # define bzero(p,l) memset(p, 0, l)
meillo@0 22 # endif
meillo@0 23 #endif
meillo@0 24
meillo@0 25 #include <sys/types.h>
meillo@0 26 #include <sys/socket.h>
meillo@0 27 #include <sys/wait.h>
meillo@0 28 #include <sys/time.h>
meillo@0 29 #include <sys/file.h>
meillo@0 30
meillo@0 31 #define IN_LIBIDENT_SRC
meillo@0 32 #include "ident.h"
meillo@0 33
meillo@0 34 #include <arpa/inet.h>
meillo@0 35
meillo@0 36 #ifdef _AIX
meillo@0 37 # include <sys/select.h>
meillo@0 38 #endif
meillo@0 39
meillo@0 40
meillo@0 41 /*
meillo@10 42 ident_t *id_open __P3(struct in_addr *, laddr, struct in_addr *, faddr, struct timeval *, timeout)
meillo@0 43 */
meillo@0 44
meillo@10 45 ident_t*
meillo@10 46 id_open __P((__STRUCT_IN_ADDR_P laddr, __STRUCT_IN_ADDR_P faddr, __STRUCT_TIMEVAL_P timeout))
meillo@0 47 {
meillo@10 48 ident_t *id;
meillo@10 49 int res, tmperrno;
meillo@10 50 struct sockaddr_in sin_laddr, sin_faddr;
meillo@10 51 fd_set rs, ws, es;
meillo@0 52 #ifndef OLD_SETSOCKOPT
meillo@10 53 int on = 1;
meillo@10 54 struct linger linger;
meillo@0 55 #endif
meillo@10 56
meillo@10 57 if ((id = (ident_t *) malloc(sizeof(*id))) == 0)
meillo@10 58 return 0;
meillo@10 59
meillo@10 60 if ((id->fd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
meillo@10 61 free(id);
meillo@10 62 return 0;
meillo@10 63 }
meillo@10 64
meillo@10 65 if (timeout) {
meillo@10 66 if ((res = fcntl(id->fd, F_GETFL, 0)) < 0)
meillo@10 67 goto ERROR;
meillo@0 68
meillo@0 69 #ifndef VMS
meillo@10 70 if (fcntl(id->fd, F_SETFL, res | FNDELAY) < 0)
meillo@10 71 goto ERROR;
meillo@0 72 #endif
meillo@10 73 }
meillo@0 74
meillo@10 75 /* We silently ignore errors if we can't change LINGER */
meillo@0 76 #ifdef OLD_SETSOCKOPT
meillo@10 77 /* Old style setsockopt() */
meillo@10 78 (void) setsockopt(id->fd, SOL_SOCKET, SO_DONTLINGER);
meillo@10 79 (void) setsockopt(id->fd, SOL_SOCKET, SO_REUSEADDR);
meillo@0 80 #else
meillo@10 81 /* New style setsockopt() */
meillo@10 82 linger.l_onoff = 0;
meillo@10 83 linger.l_linger = 0;
meillo@10 84
meillo@10 85 (void) setsockopt(id->fd, SOL_SOCKET, SO_LINGER, (void *) &linger, sizeof(linger));
meillo@10 86 (void) setsockopt(id->fd, SOL_SOCKET, SO_REUSEADDR, (void *) &on, sizeof(on));
meillo@0 87 #endif
meillo@10 88
meillo@10 89 id->buf[0] = '\0';
meillo@10 90
meillo@10 91 bzero((char *) &sin_laddr, sizeof(sin_laddr));
meillo@10 92 sin_laddr.sin_family = AF_INET;
meillo@10 93 sin_laddr.sin_addr = *laddr;
meillo@10 94 sin_laddr.sin_port = 0;
meillo@10 95
meillo@10 96 if (bind(id->fd, (struct sockaddr *) &sin_laddr, sizeof(sin_laddr)) < 0) {
meillo@0 97 #ifdef DEBUG
meillo@10 98 perror("libident: bind");
meillo@0 99 #endif
meillo@10 100 goto ERROR;
meillo@10 101 }
meillo@0 102
meillo@10 103 bzero((char *) &sin_faddr, sizeof(sin_faddr));
meillo@10 104 sin_faddr.sin_family = AF_INET;
meillo@10 105 sin_faddr.sin_addr = *faddr;
meillo@10 106 sin_faddr.sin_port = htons(IDPORT);
meillo@10 107
meillo@10 108 errno = 0;
meillo@10 109 res = connect(id->fd, (struct sockaddr *) &sin_faddr, sizeof(sin_faddr));
meillo@10 110 if (res < 0 && errno != EINPROGRESS) {
meillo@0 111 #ifdef DEBUG
meillo@10 112 perror("libident: connect");
meillo@0 113 #endif
meillo@10 114 goto ERROR;
meillo@10 115 }
meillo@0 116
meillo@10 117 if (timeout) {
meillo@10 118 FD_ZERO(&rs);
meillo@10 119 FD_ZERO(&ws);
meillo@10 120 FD_ZERO(&es);
meillo@10 121
meillo@10 122 FD_SET(id->fd, &rs);
meillo@10 123 FD_SET(id->fd, &ws);
meillo@10 124 FD_SET(id->fd, &es);
meillo@0 125
meillo@0 126 #ifdef __hpux
meillo@10 127 if ((res = select(FD_SETSIZE, (int *) &rs, (int *) &ws, (int *) &es, timeout)) < 0)
meillo@0 128 #else
meillo@10 129 if ((res = select(FD_SETSIZE, &rs, &ws, &es, timeout)) < 0)
meillo@0 130 #endif
meillo@10 131 {
meillo@0 132 #ifdef DEBUG
meillo@10 133 perror("libident: select");
meillo@0 134 #endif
meillo@10 135 goto ERROR;
meillo@10 136 }
meillo@10 137
meillo@10 138 if (res == 0) {
meillo@10 139 errno = ETIMEDOUT;
meillo@10 140 goto ERROR;
meillo@10 141 }
meillo@10 142
meillo@10 143 if (FD_ISSET(id->fd, &es))
meillo@10 144 goto ERROR;
meillo@10 145
meillo@10 146 if (!FD_ISSET(id->fd, &rs) && !FD_ISSET(id->fd, &ws))
meillo@10 147 goto ERROR;
meillo@0 148 }
meillo@10 149
meillo@10 150 return id;
meillo@10 151
meillo@0 152 ERROR:
meillo@10 153 tmperrno = errno; /* Save, so close() won't erase it */
meillo@10 154 close(id->fd);
meillo@10 155 free(id);
meillo@10 156 errno = tmperrno;
meillo@10 157 return 0;
meillo@0 158 }