masqmail

view src/connect.c @ 401:885e3d886199

find changesets by author, revision, files, or words in the commit message
Various minor refactoring.
author markus schnalke <meillo@marmaro.de>
date Tue, 21 Feb 2012 16:11:00 +0100
parents 6500db550a03
children
line source
1 /*
2 ** MasqMail
3 ** Copyright (C) 1999 Oliver Kurth
4 **
5 ** This program is free software; you can redistribute it and/or modify
6 ** it under the terms of the GNU General Public License as published by
7 ** the Free Software Foundation; either version 2 of the License, or
8 ** (at your option) any later version.
9 **
10 ** This program is distributed in the hope that it will be useful,
11 ** but WITHOUT ANY WARRANTY; without even the implied warranty of
12 ** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 ** GNU General Public License for more details.
14 **
15 ** You should have received a copy of the GNU General Public License
16 ** along with this program; if not, write to the Free Software
17 ** Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
18 */
19 #include "masqmail.h"
20
21 static GList*
22 resolve_ip(gchar *ip)
23 {
24 struct in_addr ia;
25 mxip_addr mxip;
26
27 if (!inet_aton(ip, &ia)) {
28 /* No dots-and-numbers notation. */
29 return NULL;
30 }
31 mxip.name = g_strdup(ip);
32 mxip.pref = 0;
33 mxip.ip = (guint32) * (guint32 *) (&ia);
34 return g_list_append(NULL, g_memdup(&mxip, sizeof(mxip)));
35 }
36
37 mxip_addr*
38 connect_hostlist(int *psockfd, gchar *host, guint port, GList *addr_list)
39 {
40 GList *addr_node;
41 struct sockaddr_in saddr;
42 int saved_errno;
43
44 DEBUG(5) debugf("connect_hostlist entered\n");
45
46 for (addr_node = g_list_first(addr_list); addr_node;
47 addr_node = g_list_next(addr_node)) {
48 mxip_addr *addr = (mxip_addr *) (addr_node->data);
49 *psockfd = socket(PF_INET, SOCK_STREAM, 0);
50
51 memset(&saddr, 0, sizeof(saddr));
52 saddr.sin_family = AF_INET;
53 saddr.sin_port = htons(port);
54 /* clumsy, but makes compiler happy: */
55 saddr.sin_addr = *(struct in_addr *) (&(addr->ip));
56
57 DEBUG(5) debugf(" trying ip %s port %d\n",
58 inet_ntoa(saddr.sin_addr), port);
59
60 if (connect(*psockfd, (struct sockaddr *) &saddr,
61 sizeof(saddr))==0) {
62 DEBUG(5) debugf(" connected to %s\n",
63 inet_ntoa(saddr.sin_addr));
64 return addr;
65 }
66
67 saved_errno = errno;
68 close(*psockfd);
69 logwrite(LOG_WARNING, "connection to %s failed: %s\n",
70 inet_ntoa(saddr.sin_addr), strerror(errno));
71 errno = saved_errno;
72
73 if ((saved_errno != ECONNREFUSED) &&
74 (saved_errno != ETIMEDOUT) &&
75 (saved_errno != ENETUNREACH) &&
76 (saved_errno != EHOSTUNREACH)) {
77 return NULL;
78 }
79 }
80 return NULL;
81 }
82
83 /*
84 ** Given a list of resolver functions, this function
85 ** resolve the host and tries to connect to the addresses
86 ** returned. If a connection attemp is timed out or refused,
87 ** the next address is tried.
88 **
89 ** TODO: the resolver functions might return duplicate addresses,
90 ** if attempt failed for one it should not be tried again.
91 */
92 mxip_addr*
93 connect_resolvelist(int *psockfd, gchar *host, guint port,
94 GList *res_func_list)
95 {
96 GList *res_node;
97 GList *addr_list;
98
99 DEBUG(5) debugf("connect_resolvelist entered\n");
100
101 h_errno = 0;
102 if (isdigit(*host)) {
103 mxip_addr *addr;
104
105 if ((addr_list = resolve_ip(host))) {
106 addr = connect_hostlist(psockfd, host, port,
107 addr_list);
108 g_list_free(addr_list);
109 return addr;
110 }
111 /*
112 ** Probably a hostname that begins with a digit.
113 ** E.g. '3dwars.de'. Thus fall ...
114 */
115 }
116
117 if (!res_func_list) {
118 logwrite(LOG_ALERT, "res_funcs not set!\n");
119 exit(1);
120 }
121
122 foreach(res_func_list, res_node) {
123 resolve_func res_func;
124 DEBUG(6) debugf(" foreach() body\n");
125
126 res_func = (resolve_func) res_node->data;
127 if (!res_func) {
128 logwrite(LOG_ALERT, "Empty res_func!\n");
129 exit(1);
130 }
131
132 errno = 0;
133 if ((addr_list = res_func(NULL, host))) {
134
135 mxip_addr *addr;
136 if ((addr = connect_hostlist(psockfd, host, port,
137 addr_list))) {
138 return addr;
139 }
140 DEBUG(5) debugf("connect_hostlist failed: %s\n",
141 strerror(errno));
142 g_list_free(addr_list);
143 } else if (!g_list_next(res_node)) {
144 logwrite(LOG_ALERT, "could not resolve %s: %s\n",
145 host, hstrerror(h_errno));
146 }
147 }
148 return NULL;
149
150 }