2 Copyright (c) 2009 Frank Lahm <franklahm@gmail.com>
4 This program is free software; you can redistribute it and/or modify
5 it under the terms of the GNU General Public License as published by
6 the Free Software Foundation; either version 2 of the License, or
7 (at your option) any later version.
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 GNU General Public License for more details.
17 * Netatalk utility functions
22 #endif /* HAVE_CONFIG_H */
26 #include <sys/types.h>
27 #include <sys/socket.h>
28 #include <arpa/inet.h>
29 #include <netinet/in.h>
36 #include <atalk/logger.h>
38 static char ipv4mapprefix[] = {0,0,0,0,0,0,0,0,0,0,0xff,0xff};
41 * @brief set or unset non-blocking IO on a fd
43 * @param fd (r) File descriptor
44 * @param cmd (r) 0: disable non-blocking IO, ie block\n
45 * <>0: enable non-blocking IO
47 * @returns 0 on success, -1 on failure
49 int setnonblock(int fd, int cmd)
54 if ((fdflags = ofdflags = fcntl(fd, F_GETFL, 0)) == -1)
58 fdflags |= O_NONBLOCK;
60 fdflags &= ~O_NONBLOCK;
62 if (fdflags != ofdflags)
63 if (fcntl(fd, F_SETFL, fdflags) == -1)
70 * non-blocking drop-in replacement for read with timeout using select
72 * @param socket (r) socket, if in blocking mode, pass "setnonblocking" arg as 1
73 * @param data (rw) buffer for the read data
74 * @param lenght (r) how many bytes to read
75 * @param setnonblocking (r) when non-zero this func will enable and disable non blocking
76 * io mode for the socket
77 * @param timeout (r) number of seconds to try reading
79 * @returns number of bytes actually read or -1 on fatal error
81 ssize_t readt(int socket, void *data, const size_t length, int setnonblocking, int timeout)
85 struct timeval now, end, tv;
90 if (setnonblock(socket, 1) != 0)
94 /* Calculate end time */
95 (void)gettimeofday(&now, NULL);
97 end.tv_sec += timeout;
99 while (stored < length) {
100 len = read(socket, (char *) data + stored, length - stored);
107 FD_SET(socket, &rfds);
111 while ((ret = select(socket + 1, &rfds, NULL, NULL, &tv)) < 1) {
114 LOG(log_warning, logtype_afpd, "select timeout %d s", timeout);
118 if (errno == EINTR) {
119 (void)gettimeofday(&now, NULL);
120 if (now.tv_sec >= end.tv_sec && now.tv_usec >= end.tv_usec) {
121 LOG(log_warning, logtype_afpd, "select timeout %d s", timeout);
124 if (now.tv_usec > end.tv_usec) {
125 tv.tv_usec = 1000000 + end.tv_usec - now.tv_usec;
126 tv.tv_sec = end.tv_sec - now.tv_sec - 1;
128 tv.tv_usec = end.tv_usec - now.tv_usec;
129 tv.tv_sec = end.tv_sec - now.tv_sec;
132 FD_SET(socket, &rfds);
135 LOG(log_error, logtype_afpd, "select: %s", strerror(errno));
139 } /* while (select) */
141 } /* switch (errno) */
142 LOG(log_error, logtype_afpd, "read: %s", strerror(errno));
150 } /* while (stored < length) */
153 if (setnonblocking) {
154 if (setnonblock(socket, 0) != 0)
158 if (len == -1 && stored == 0)
159 /* last read or select got an error and we haven't got yet anything => return -1*/
165 * @brief convert an IPv4 or IPv6 address to a static string using inet_ntop
167 * IPv6 mapped IPv4 addresses are returned as IPv4 addreses eg
168 * ::ffff:10.0.0.0 is returned as "10.0.0.0".
170 * @param sa (r) pointer to an struct sockaddr
172 * @returns pointer to a static string cotaining the converted address as string.\n
173 * On error pointers to "0.0.0.0" or "::0" are returned.
175 const char *getip_string(const struct sockaddr *sa)
177 static char ip4[INET_ADDRSTRLEN];
178 static char ip6[INET6_ADDRSTRLEN];
180 switch (sa->sa_family) {
183 const struct sockaddr_in *sai4 = (const struct sockaddr_in *)sa;
184 if ((inet_ntop(AF_INET, &(sai4->sin_addr), ip4, INET_ADDRSTRLEN)) == NULL)
189 const struct sockaddr_in6 *sai6 = (const struct sockaddr_in6 *)sa;
190 if ((inet_ntop(AF_INET6, &(sai6->sin6_addr), ip6, INET6_ADDRSTRLEN)) == NULL)
193 /* Deal with IPv6 mapped IPv4 addresses*/
194 if ((memcmp(sai6->sin6_addr.s6_addr, ipv4mapprefix, sizeof(ipv4mapprefix))) == 0)
195 return (strrchr(ip6, ':') + 1);
199 return "getip_string ERROR";
202 /* We never get here */
206 * @brief return port number from struct sockaddr
208 * @param sa (r) pointer to an struct sockaddr
210 * @returns port as unsigned int
212 unsigned int getip_port(const struct sockaddr *sa)
214 if (sa->sa_family == AF_INET) { /* IPv4 */
215 const struct sockaddr_in *sai4 = (const struct sockaddr_in *)sa;
216 return ntohs(sai4->sin_port);
218 const struct sockaddr_in6 *sai6 = (const struct sockaddr_in6 *)sa;
219 return ntohs(sai6->sin6_port);
222 /* We never get here */
226 * @brief apply netmask to IP (v4 or v6)
228 * Modifies IP address in sa->sin[6]_addr-s[6]_addr. The caller is responsible
229 * for passing a value for mask that is sensible to the passed address,
230 * eg 0 <= mask <= 32 for IPv4 or 0<= mask <= 128 for IPv6. mask > 32 for
231 * IPv4 is treated as mask = 32, mask > 128 is set to 128 for IPv6.
233 * @param ai (rw) pointer to an struct sockaddr
234 * @parma mask (r) number of maskbits
236 void apply_ip_mask(struct sockaddr *sa, uint32_t mask)
239 switch (sa->sa_family) {
244 struct sockaddr_in *si = (struct sockaddr_in *)sa;
245 uint32_t nmask = mask ? ~((1 << (32 - mask)) - 1) : 0;
246 si->sin_addr.s_addr &= htonl(nmask);
253 int i, maskbytes, maskbits;
254 struct sockaddr_in6 *si6 = (struct sockaddr_in6 *)sa;
256 /* Deal with IPv6 mapped IPv4 addresses*/
257 if ((memcmp(si6->sin6_addr.s6_addr, ipv4mapprefix, sizeof(ipv4mapprefix))) == 0) {
263 maskbytes = (128 - mask) / 8; /* maskbytes really are those that will be 0'ed */
266 for (i = maskbytes - 1; i >= 0; i--)
267 si6->sin6_addr.s6_addr[15 - i] = 0;
269 si6->sin6_addr.s6_addr[15 - maskbytes] &= ~((1 << (8 - maskbits)) - 1);
278 * @brief compare IP addresses for equality
280 * @param sa1 (r) pointer to an struct sockaddr
281 * @param sa2 (r) pointer to an struct sockaddr
283 * @returns Addresses are converted to strings and compared with strcmp and
284 * the result of strcmp is returned.
286 * @note IPv6 mapped IPv4 addresses are treated as IPv4 addresses.
288 int compare_ip(const struct sockaddr *sa1, const struct sockaddr *sa2)
294 ip1 = strdup(getip_string(sa1));
295 ip2 = getip_string(sa2);
297 ret = strcmp(ip1, ip2);