More BSD enhancements (#970)
[asterisk/asterisk.git] / acl.c
diff --git a/acl.c b/acl.c
index ae81cc9..9e1edb4 100755 (executable)
--- a/acl.c
+++ b/acl.c
@@ -21,6 +21,7 @@
 #include <unistd.h>
 #include <asterisk/acl.h>
 #include <asterisk/logger.h>
+#include <asterisk/channel.h>
 #include <arpa/inet.h>
 #include <sys/socket.h>
 #include <netdb.h>
 #include <netinet/in_systm.h>
 #include <netinet/ip.h>
 #include <sys/ioctl.h>
+#if defined(__OpenBSD__) || defined(__NetBSD__) || defined(__FreeBSD__)
+#include <fcntl.h>
+#include <net/route.h>
+
+static ast_mutex_t routeseq_lock = AST_MUTEX_INITIALIZER;
+#endif
 
 #define AST_SENSE_DENY                 0
 #define AST_SENSE_ALLOW                        1
@@ -41,7 +48,7 @@ struct ast_ha {
 };
 
 /* Default IP - if not otherwise set, don't breathe garbage */
-static struct in_addr __ourip = { (in_addr_t)0x00000000 };
+static struct in_addr __ourip = { 0x00000000 };
 
 struct my_ifreq {
        char ifrn_name[IFNAMSIZ];       /* Interface name, e.g. "eth0", "ppp0", etc.  */
@@ -62,29 +69,43 @@ struct ast_ha *ast_append_ha(char *sense, char *stuff, struct ast_ha *path)
 {
        struct ast_ha *ha = malloc(sizeof(struct ast_ha));
        char *nm;
+       char tmp[256] = "";
        struct ast_ha *prev = NULL;
        struct ast_ha *ret;
+       int x,z;
+       unsigned int y;
        ret = path;
        while(path) {
                prev = path;
                path = path->next;
        }
        if (ha) {
-               char *stringp=NULL;
-               stringp=stuff;
-               strsep(&stringp, "/");
-               nm = strsep(&stringp, "/");
+               strncpy(tmp, stuff, sizeof(tmp) - 1);
+               nm = strchr(tmp, '/');
                if (!nm)
                        nm = "255.255.255.255";
-               if (!inet_aton(stuff, &ha->netaddr)) {
-                       ast_log(LOG_WARNING, "%s not a valid IP\n", stuff);
-                       free(ha);
-                       return NULL;
+               else {
+                       *nm = '\0';
+                       nm++;
                }
-               if (!inet_aton(nm, &ha->netmask)) {
+               if (!strchr(nm, '.')) {
+                       if ((sscanf(nm, "%i", &x) == 1) && (x >= 0) && (x <= 32)) {
+                               y = 0;
+                               for (z=0;z<x;z++) {
+                                       y >>= 1;
+                                       y |= 0x80000000;
+                               }
+                               ha->netmask.s_addr = htonl(y);
+                       }
+               } else if (!inet_aton(nm, &ha->netmask)) {
                        ast_log(LOG_WARNING, "%s not a valid netmask\n", nm);
                        free(ha);
-                       return NULL;
+                       return path;
+               }
+               if (!inet_aton(tmp, &ha->netaddr)) {
+                       ast_log(LOG_WARNING, "%s not a valid IP\n", tmp);
+                       free(ha);
+                       return path;
                }
                ha->netaddr.s_addr &= ha->netmask.s_addr;
                if (!strncasecmp(sense, "p", 1)) {
@@ -98,7 +119,7 @@ struct ast_ha *ast_append_ha(char *sense, char *stuff, struct ast_ha *path)
                else
                        ret = ha;
        }
-       return NULL;
+       return ret;
 }
 
 int ast_apply_ha(struct ast_ha *ha, struct sockaddr_in *sin)
@@ -158,6 +179,91 @@ int ast_lookup_iface(char *iface, struct in_addr *address) {
 
 int ast_ouraddrfor(struct in_addr *them, struct in_addr *us)
 {
+#if defined(__OpenBSD__) || defined(__NetBSD__) || defined(__FreeBSD__)
+       struct sockaddr_in *sin;
+       struct sockaddr *sa;
+       struct {
+               struct  rt_msghdr m_rtm;
+               char    m_space[512];
+       } m_rtmsg;
+       char *cp, *p = ast_strdupa(inet_ntoa(*them));
+       int i, l, s, seq, flags;
+       pid_t pid = getpid();
+       static int routeseq;    /* Protected by "routeseq_lock" mutex */
+
+       memset(us, 0, sizeof(struct in_addr));
+
+       memset(&m_rtmsg, 0, sizeof(m_rtmsg));
+       m_rtmsg.m_rtm.rtm_type = RTM_GET;
+       m_rtmsg.m_rtm.rtm_flags = RTF_UP | RTF_HOST;
+       m_rtmsg.m_rtm.rtm_version = RTM_VERSION;
+       ast_mutex_lock(&routeseq_lock);
+       seq = ++routeseq;
+       ast_mutex_unlock(&routeseq_lock);
+       m_rtmsg.m_rtm.rtm_seq = seq;
+       m_rtmsg.m_rtm.rtm_addrs = RTA_IFA | RTA_DST;
+       m_rtmsg.m_rtm.rtm_msglen = sizeof(struct rt_msghdr) + sizeof(struct sockaddr_in);
+       sin = (struct sockaddr_in *)m_rtmsg.m_space;
+       sin->sin_family = AF_INET;
+       sin->sin_len = sizeof(struct sockaddr_in);
+       sin->sin_addr = *them;
+
+       if ((s = socket(PF_ROUTE, SOCK_RAW, 0)) < 0) {
+               ast_log(LOG_ERROR, "Error opening routing socket\n");
+               return -1;
+       }
+       flags = fcntl(s, F_GETFL);
+       fcntl(s, F_SETFL, flags | O_NONBLOCK);
+       if (write(s, (char *)&m_rtmsg, m_rtmsg.m_rtm.rtm_msglen) < 0) {
+               ast_log(LOG_ERROR, "Error writing to routing socket: %s\n", strerror(errno));
+               close(s);
+               return -1;
+       }
+       do {
+               l = read(s, (char *)&m_rtmsg, sizeof(m_rtmsg));
+       } while (l > 0 && (m_rtmsg.m_rtm.rtm_seq != 1 || m_rtmsg.m_rtm.rtm_pid != pid));
+       if (l < 0) {
+               if (errno != EAGAIN)
+                       ast_log(LOG_ERROR, "Error reading from routing socket\n");
+               close(s);
+               return -1;
+       }
+       close(s);
+
+       if (m_rtmsg.m_rtm.rtm_version != RTM_VERSION) {
+               ast_log(LOG_ERROR, "Unsupported route socket protocol version\n");
+               return -1;
+       }
+
+       if (m_rtmsg.m_rtm.rtm_msglen != l)
+               ast_log(LOG_WARNING, "Message length mismatch, in packet %d, returned %d\n",
+                               m_rtmsg.m_rtm.rtm_msglen, l);
+
+       if (m_rtmsg.m_rtm.rtm_errno) {
+               ast_log(LOG_ERROR, "RTM_GET got %s (%d)\n",
+                               strerror(m_rtmsg.m_rtm.rtm_errno), m_rtmsg.m_rtm.rtm_errno);
+               return -1;
+       }
+
+       cp = (char *)m_rtmsg.m_space;
+       if (m_rtmsg.m_rtm.rtm_addrs)
+               for (i = 1; i; i <<= 1)
+                       if (m_rtmsg.m_rtm.rtm_addrs & i) {
+                               sa = (struct sockaddr *)cp;
+                               if (i == RTA_IFA && sa->sa_family == AF_INET) {
+                                       sin = (struct sockaddr_in *)sa;
+                                       *us = sin->sin_addr;
+                                       ast_log(LOG_DEBUG, "Found route to %s, output from our address %s.\n", p, inet_ntoa(*us));
+                                       return 0;
+                               }
+                               cp += sa->sa_len > 0 ?
+                                         (1 + ((sa->sa_len - 1) | (sizeof(long) - 1))) :
+                                         sizeof(long);
+                       }
+
+       ast_log(LOG_DEBUG, "No route found for address %s!\n", p);
+       return -1;
+#else
        FILE *PROC;
        unsigned int remote_ip;
        int res = 1;
@@ -221,6 +327,5 @@ int ast_ouraddrfor(struct in_addr *them, struct in_addr *us)
                return -1;
        }
        return 0;
+#endif
 }
-
-