1511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall/* 2511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * pcap-sita.c: Packet capture interface additions for SITA ACN devices 3511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * 4511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * Copyright (c) 2007 Fulko Hew, SITA INC Canada, Inc <fulko.hew@sita.aero> 5511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * 6511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * License: BSD 7511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * 8511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * Redistribution and use in source and binary forms, with or without 9511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * modification, are permitted provided that the following conditions 10511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * are met: 11511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * 12511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * 1. Redistributions of source code must retain the above copyright 13511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * notice, this list of conditions and the following disclaimer. 14511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * 2. Redistributions in binary form must reproduce the above copyright 15511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * notice, this list of conditions and the following disclaimer in 16511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * the documentation and/or other materials provided with the 17511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * distribution. 18511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * 3. The names of the authors may not be used to endorse or promote 19511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * products derived from this software without specific prior 20511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * written permission. 21511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * 22511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR 23511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED 24511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE. 25511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall */ 26511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 27511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* $Id: pcap-sita.c */ 28511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 29511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#ifdef HAVE_CONFIG_H 30511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include "config.h" 31511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#endif 32511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 33511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include <stdio.h> 34511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include <string.h> 35511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include <stdlib.h> 36511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include <unistd.h> 37511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include <fcntl.h> 38511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include <errno.h> 39511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include <sys/time.h> 40511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include <sys/socket.h> 41511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include <netinet/in.h> 42511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include <arpa/inet.h> 43511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include "pcap-int.h" 44511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 45511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#include "pcap-sita.h" 46511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 47511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* non-configureable manifests follow */ 48511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 49511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#define IOP_SNIFFER_PORT 49152 /* TCP port on the IOP used for 'distributed pcap' usage */ 50511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#define MAX_LINE_SIZE 255 /* max size of a buffer/line in /etc/hosts we allow */ 51511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#define MAX_CHASSIS 8 /* number of chassis in an ACN site */ 52511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#define MAX_GEOSLOT 8 /* max number of access units in an ACN site */ 53511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 54511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#define FIND 0 55511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall#define LIVE 1 56511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 57511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgralltypedef struct iface { 58511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall struct iface *next; /* a pointer to the next interface */ 59511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *name; /* this interface's name */ 60511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *IOPname; /* this interface's name on an IOP */ 61511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall uint32_t iftype; /* the type of interface (DLT values) */ 62511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} iface_t; 63511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 64511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgralltypedef struct unit { 65511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *ip; /* this unit's IP address (as extracted from /etc/hosts) */ 66511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int fd; /* the connection to this unit (if it exists) */ 67511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int find_fd; /* a big kludge to avoid my programming limitations since I could have this unit open for findalldevs purposes */ 68511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int first_time; /* 0 = just opened via acn_open_live(), ie. the first time, NZ = nth time */ 69511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall struct sockaddr_in *serv_addr; /* the address control block for comms to this unit */ 70511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis; 71511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int geoslot; 72511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface_t *iface; /* a pointer to a linked list of interface structures */ 73511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *imsg; /* a pointer to an inbound message */ 74511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int len; /* the current size of the inbound message */ 75511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} unit_t; 76511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 77511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic unit_t units[MAX_CHASSIS+1][MAX_GEOSLOT+1]; /* we use indexes of 1 through 8, but we reserve/waste index 0 */ 78511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic fd_set readfds; /* a place to store the file descriptors for the connections to the IOPs */ 79511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int max_fs; 80511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 81511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallpcap_if_t *acn_if_list; /* pcap's list of available interfaces */ 82511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 83511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void dump_interface_list(void) { 84511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_if_t *iff; 85511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_addr_t *addr; 86511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int longest_name_len = 0; 87511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *n, *d, *f; 88511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int if_number = 0; 89511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 90511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iff = acn_if_list; 91511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (iff) { 92511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (iff->name && (strlen(iff->name) > longest_name_len)) longest_name_len = strlen(iff->name); 93511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iff = iff->next; 94511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 95511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iff = acn_if_list; 96511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("Interface List:\n"); 97511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (iff) { 98511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall n = (iff->name) ? iff->name : ""; 99511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall d = (iff->description) ? iff->description : ""; 100511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall f = (iff->flags == PCAP_IF_LOOPBACK) ? "L" : ""; 101511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("%3d: %*s %s '%s'\n", if_number++, longest_name_len, n, f, d); 102511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall addr = iff->addresses; 103511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (addr) { 104511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("%*s ", (5 + longest_name_len), ""); /* add some indentation */ 105511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("%15s ", (addr->addr) ? inet_ntoa(((struct sockaddr_in *)addr->addr)->sin_addr) : ""); 106511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("%15s ", (addr->netmask) ? inet_ntoa(((struct sockaddr_in *)addr->netmask)->sin_addr) : ""); 107511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("%15s ", (addr->broadaddr) ? inet_ntoa(((struct sockaddr_in *)addr->broadaddr)->sin_addr) : ""); 108511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("%15s ", (addr->dstaddr) ? inet_ntoa(((struct sockaddr_in *)addr->dstaddr)->sin_addr) : ""); 109511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("\n"); 110511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall addr = addr->next; 111511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 112511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iff = iff->next; 113511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 114511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 115511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 116511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void dump(unsigned char *ptr, int i, int indent) { 117511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "%*s", indent, " "); 118511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (; i > 0; i--) { 119511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "%2.2x ", *ptr++); 120511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 121511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "\n"); 122511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 123511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 124511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void dump_interface_list_p(void) { 125511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_if_t *iff; 126511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_addr_t *addr; 127511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int if_number = 0; 128511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 129511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iff = acn_if_list; 130511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("Interface Pointer @ %p is %p:\n", &acn_if_list, iff); 131511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (iff) { 132511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("%3d: %p %p next: %p\n", if_number++, iff->name, iff->description, iff->next); 133511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall dump((unsigned char *)iff, sizeof(pcap_if_t), 5); 134511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall addr = iff->addresses; 135511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (addr) { 136511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf(" %p %p %p %p, next: %p\n", addr->addr, addr->netmask, addr->broadaddr, addr->dstaddr, addr->next); 137511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall dump((unsigned char *)addr, sizeof(pcap_addr_t), 10); 138511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall addr = addr->next; 139511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 140511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iff = iff->next; 141511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 142511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 143511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 144511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void dump_unit_table(void) { 145511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 146511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface_t *p; 147511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 148511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("%c:%c %s %s\n", 'C', 'S', "fd", "IP Address"); 149511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (chassis = 0; chassis <= MAX_CHASSIS; chassis++) { 150511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (geoslot = 0; geoslot <= MAX_GEOSLOT; geoslot++) { 151511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (units[chassis][geoslot].ip != NULL) 152511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("%d:%d %2d %s\n", chassis, geoslot, units[chassis][geoslot].fd, units[chassis][geoslot].ip); 153511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p = units[chassis][geoslot].iface; 154511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (p) { 155511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *n = (p->name) ? p->name : ""; 156511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *i = (p->IOPname) ? p->IOPname : ""; 157511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p = p->next; 158511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf(" %12s -> %12s\n", i, n); 159511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 160511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 161511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 162511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 163511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 164511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int find_unit_by_fd(int fd, int *chassis, int *geoslot, unit_t **unit_ptr) { 165511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int c, s; 166511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 167511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (c = 0; c <= MAX_CHASSIS; c++) { 168511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (s = 0; s <= MAX_GEOSLOT; s++) { 169511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (units[c][s].fd == fd || units[c][s].find_fd == fd) { 170511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (chassis) *chassis = c; 171511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (geoslot) *geoslot = s; 172511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (unit_ptr) *unit_ptr = &units[c][s]; 173511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 1; 174511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 175511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 176511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 177511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 178511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 179511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 180511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int read_client_nbytes(int fd, int count, unsigned char *buf) { 181511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unit_t *u; 182511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 183511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int len; 184511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 185511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall find_unit_by_fd(fd, &chassis, &geoslot, &u); 186511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (count) { 187511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((len = recv(fd, buf, count, 0)) <= 0) return -1; /* read in whatever data was sent to us */ 188511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall count -= len; 189511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall buf += len; 190511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } /* till we have everything we are looking for */ 191511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 192511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 193511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 194511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void empty_unit_iface(unit_t *u) { 195511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface_t *p, *cur; 196511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 197511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall cur = u->iface; 198511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (cur) { /* loop over all the interface entries */ 199511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (cur->name) free(cur->name); /* throwing away the contents if they exist */ 200511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (cur->IOPname) free(cur->IOPname); 201511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p = cur->next; 202511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall free(cur); /* then throw away the structure itself */ 203511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall cur = p; 204511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 205511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->iface = 0; /* and finally remember that there are no remaining structure */ 206511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 207511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 208511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void empty_unit(int chassis, int geoslot) { 209511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unit_t *u = &units[chassis][geoslot]; 210511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 211511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall empty_unit_iface(u); 212511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (u->imsg) { /* then if an inbound message buffer exists */ 213511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->imsg = (char *)realloc(u->imsg, 1); /* and re-allocate the old large buffer into a new small one */ 214511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (u->imsg == NULL) { /* oops, realloc call failed */ 215511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "Warning...call to realloc() failed, value of errno is %d\n", errno); 216511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 217511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 218511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 219511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 220511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void empty_unit_table(void) { 221511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 222511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 223511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (chassis = 0; chassis <= MAX_CHASSIS; chassis++) { 224511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (geoslot = 0; geoslot <= MAX_GEOSLOT; geoslot++) { 225511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (units[chassis][geoslot].ip != NULL) { 226511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall free(units[chassis][geoslot].ip); /* get rid of the malloc'ed space that holds the IP address */ 227511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall units[chassis][geoslot].ip = 0; /* then set the pointer to NULL */ 228511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 229511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall empty_unit(chassis, geoslot); 230511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 231511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 232511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 233511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 234511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic char *find_nth_interface_name(int n) { 235511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 236511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface_t *p; 237511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *last_name = 0; 238511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 239511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (n < 0) n = 0; /* ensure we are working with a valid number */ 240511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (chassis = 0; chassis <= MAX_CHASSIS; chassis++) { /* scan the table... */ 241511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (geoslot = 0; geoslot <= MAX_GEOSLOT; geoslot++) { 242511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (units[chassis][geoslot].ip != NULL) { 243511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p = units[chassis][geoslot].iface; 244511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (p) { /* and all interfaces... */ 245511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (p->IOPname) last_name = p->name; /* remembering the last name found */ 246511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (n-- == 0) return last_name; /* and if we hit the instance requested */ 247511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p = p->next; 248511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 249511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 250511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 251511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 252511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* if we couldn't fine the selected entry */ 253511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (last_name) return last_name; /* ... but we did have at least one entry... return the last entry found */ 254511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return ""; /* ... but if there wasn't any entry... return an empty string instead */ 255511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 256511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 257511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallint acn_parse_hosts_file(char *errbuf) { /* returns: -1 = error, 0 = OK */ 258511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall FILE *fp; 259511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char buf[MAX_LINE_SIZE]; 260511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *ptr, *ptr2; 261511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int pos; 262511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 263511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unit_t *u; 264511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 265511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall empty_unit_table(); 266511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((fp = fopen("/etc/hosts", "r")) == NULL) { /* try to open the hosts file and if it fails */ 267511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "Cannot open '/etc/hosts' for reading."); /* return the nohostsfile error response */ 268511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 269511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 270511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (fgets(buf, MAX_LINE_SIZE-1, fp)) { /* while looping over the file */ 271511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 272511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pos = strcspn(buf, "#\n\r"); /* find the first comment character or EOL */ 273511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall *(buf + pos) = '\0'; /* and clobber it and anything that follows it */ 274511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 275511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pos = strspn(buf, " \t"); /* then find the first non-white space */ 276511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (pos == strlen(buf)) /* if there is nothing but white space on the line */ 277511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall continue; /* ignore that empty line */ 278511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr = buf + pos; /* and skip over any of that leading whitespace */ 279511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 280511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((ptr2 = strstr(ptr, "_I_")) == NULL) /* skip any lines that don't have names that look like they belong to IOPs */ 281511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall continue; 282511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (*(ptr2 + 4) != '_') /* and skip other lines that have names that don't look like ACN components */ 283511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall continue; 284511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall *(ptr + strcspn(ptr, " \t")) = '\0'; /* null terminate the IP address so its a standalone string */ 285511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 286511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall chassis = *(ptr2 + 3) - '0'; /* extract the chassis number */ 287511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall geoslot = *(ptr2 + 5) - '0'; /* and geo-slot number */ 288511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (chassis < 1 || chassis > MAX_CHASSIS || 289511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall geoslot < 1 || geoslot > MAX_GEOSLOT) { /* if the chassis and/or slot numbers appear to be bad... */ 290511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "Invalid ACN name in '/etc/hosts'."); /* warn the user */ 291511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall continue; /* and ignore the entry */ 292511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 293511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((ptr2 = (char *)malloc(strlen(ptr) + 1)) == NULL) { 294511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "malloc: %s", pcap_strerror(errno)); 295511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall continue; 296511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 297511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall strcpy(ptr2, ptr); /* copy the IP address into our malloc'ed memory */ 298511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u = &units[chassis][geoslot]; 299511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->ip = ptr2; /* and remember the whole shebang */ 300511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->chassis = chassis; 301511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->geoslot = geoslot; 302511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 303511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fclose(fp); 304511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (*errbuf) return -1; 305511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall else return 0; 306511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 307511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 308511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int open_with_IOP(unit_t *u, int flag) { 309511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int sockfd; 310511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *ip; 311511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 312511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (u->serv_addr == NULL) { 313511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->serv_addr = malloc(sizeof(struct sockaddr_in)); 314511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 315511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* since we called malloc(), lets check to see if we actually got the memory */ 316511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (u->serv_addr == NULL) { /* oops, we didn't get the memory requested */ 317511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "malloc() request for u->serv_addr failed, value of errno is: %d\n", errno); 318511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 319511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 320511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 321511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 322511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ip = u->ip; 323511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* bzero() is deprecated, replaced with memset() */ 324511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memset((char *)u->serv_addr, 0, sizeof(struct sockaddr_in)); 325511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->serv_addr->sin_family = AF_INET; 326511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->serv_addr->sin_addr.s_addr = inet_addr(ip); 327511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->serv_addr->sin_port = htons(IOP_SNIFFER_PORT); 328511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 329511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { 330511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "pcap can't open a socket for connecting to IOP at %s\n", ip); 331511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 332511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 333511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (connect(sockfd, (struct sockaddr *)u->serv_addr, sizeof(struct sockaddr_in)) < 0) { 334511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "pcap can't connect to IOP at %s\n", ip); 335511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 336511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 337511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (flag == LIVE) u->fd = sockfd; 338511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall else u->find_fd = sockfd; 339511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->first_time = 0; 340511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return sockfd; /* return the non-zero file descriptor as a 'success' indicator */ 341511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 342511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 343511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void close_with_IOP(int chassis, int geoslot, int flag) { 344511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int *id; 345511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 346511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (flag == LIVE) id = &units[chassis][geoslot].fd; 347511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall else id = &units[chassis][geoslot].find_fd; 348511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 349511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (*id) { /* this was the last time, so... if we are connected... */ 350511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall close(*id); /* disconnect us */ 351511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall *id = 0; /* and forget that the descriptor exists because we are not open */ 352511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 353511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 354511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 355511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void pcap_cleanup_acn(pcap_t *handle) { 356511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 357511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unit_t *u; 358511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 359511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (find_unit_by_fd(handle->fd, &chassis, &geoslot, &u) == 0) 360511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return; 361511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall close_with_IOP(chassis, geoslot, LIVE); 362511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (u) 363511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->first_time = 0; 364511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_cleanup_live_common(handle); 365511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 366511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 367511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void send_to_fd(int fd, int len, unsigned char *str) { 368511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int nwritten; 369511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 370511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 371511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (len > 0) { 372511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((nwritten = write(fd, str, len)) <= 0) { 373511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall find_unit_by_fd(fd, &chassis, &geoslot, NULL); 374511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (units[chassis][geoslot].fd == fd) close_with_IOP(chassis, geoslot, LIVE); 375511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall else if (units[chassis][geoslot].find_fd == fd) close_with_IOP(chassis, geoslot, FIND); 376511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall empty_unit(chassis, geoslot); 377511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return; 378511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 379511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall len -= nwritten; 380511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall str += nwritten; 381511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 382511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 383511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 384511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void acn_freealldevs(void) { 385511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 386511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_if_t *iff, *next_iff; 387511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_addr_t *addr, *next_addr; 388511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 389511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (iff = acn_if_list; iff != NULL; iff = next_iff) { 390511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall next_iff = iff->next; 391511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (addr = iff->addresses; addr != NULL; addr = next_addr) { 392511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall next_addr = addr->next; 393511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (addr->addr) free(addr->addr); 394511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (addr->netmask) free(addr->netmask); 395511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (addr->broadaddr) free(addr->broadaddr); 396511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (addr->dstaddr) free(addr->dstaddr); 397511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall free(addr); 398511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 399511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (iff->name) free(iff->name); 400511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (iff->description) free(iff->description); 401511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall free(iff); 402511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 403511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 404511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 405511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void nonUnified_IOP_port_name(char *buf, size_t bufsize, const char *proto, unit_t *u) { 406511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 407511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(buf, bufsize, "%s_%d_%d", proto, u->chassis, u->geoslot); 408511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 409511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 410511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void unified_IOP_port_name(char *buf, size_t bufsize, const char *proto, unit_t *u, int IOPportnum) { 411511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int portnum; 412511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 413511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall portnum = ((u->chassis - 1) * 64) + ((u->geoslot - 1) * 8) + IOPportnum + 1; 414511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(buf, bufsize, "%s_%d", proto, portnum); 415511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 416511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 417511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic char *translate_IOP_to_pcap_name(unit_t *u, char *IOPname, bpf_u_int32 iftype) { 418511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface_t *iface_ptr, *iface; 419511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *name; 420511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char buf[32]; 421511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *proto; 422511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *port; 423511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int IOPportnum = 0; 424511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 425511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface = malloc(sizeof(iface_t)); /* get memory for a structure */ 426511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (iface == NULL) { /* oops, we didn't get the memory requested */ 427511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "Error...couldn't allocate memory for interface structure...value of errno is: %d\n", errno); 428511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return NULL; 429511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 430511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memset((char *)iface, 0, sizeof(iface_t)); /* bzero is deprecated(), replaced with memset() */ 431511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 432511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface->iftype = iftype; /* remember the interface type of this interface */ 433511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 434511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall name = malloc(strlen(IOPname) + 1); /* get memory for the IOP's name */ 435511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (name == NULL) { /* oops, we didn't get the memory requested */ 436511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "Error...couldn't allocate memory for IOPname...value of errno is: %d\n", errno); 437511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return NULL; 438511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 439511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 440511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall strcpy(name, IOPname); /* and copy it in */ 441511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface->IOPname = name; /* and stick it into the structure */ 442511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 443511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (strncmp(IOPname, "lo", 2) == 0) { 444511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall IOPportnum = atoi(&IOPname[2]); 445511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall switch (iftype) { 446511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall case DLT_EN10MB: 447511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall nonUnified_IOP_port_name(buf, sizeof buf, "lo", u); 448511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall break; 449511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall default: 450511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unified_IOP_port_name(buf, sizeof buf, "???", u, IOPportnum); 451511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall break; 452511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 453511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else if (strncmp(IOPname, "eth", 3) == 0) { 454511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall IOPportnum = atoi(&IOPname[3]); 455511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall switch (iftype) { 456511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall case DLT_EN10MB: 457511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall nonUnified_IOP_port_name(buf, sizeof buf, "eth", u); 458511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall break; 459511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall default: 460511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unified_IOP_port_name(buf, sizeof buf, "???", u, IOPportnum); 461511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall break; 462511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 463511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else if (strncmp(IOPname, "wan", 3) == 0) { 464511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall IOPportnum = atoi(&IOPname[3]); 465511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall switch (iftype) { 466511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall case DLT_SITA: 467511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unified_IOP_port_name(buf, sizeof buf, "wan", u, IOPportnum); 468511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall break; 469511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall default: 470511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unified_IOP_port_name(buf, sizeof buf, "???", u, IOPportnum); 471511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall break; 472511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 473511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else { 474511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "Error... invalid IOP name %s\n", IOPname); 475511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return NULL; 476511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 477511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 478511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall name = malloc(strlen(buf) + 1); /* get memory for that name */ 479511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (name == NULL) { /* oops, we didn't get the memory requested */ 480511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fprintf(stderr, "Error...couldn't allocate memory for IOP port name...value of errno is: %d\n", errno); 481511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return NULL; 482511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 483511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 484511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall strcpy(name, buf); /* and copy it in */ 485511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface->name = name; /* and stick it into the structure */ 486511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 487511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (u->iface == 0) { /* if this is the first name */ 488511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->iface = iface; /* stick this entry at the head of the list */ 489511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else { 490511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface_ptr = u->iface; 491511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (iface_ptr->next) { /* othewise scan the list */ 492511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface_ptr = iface_ptr->next; /* till we're at the last entry */ 493511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 494511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface_ptr->next = iface; /* then tack this entry on the end of the list */ 495511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 496511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return iface->name; 497511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 498511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 499511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int if_sort(char *s1, char *s2) { 500511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *s1_p2, *s2_p2; 501511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char str1[MAX_LINE_SIZE], str2[MAX_LINE_SIZE]; 502511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int s1_p1_len, s2_p1_len; 503511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int retval; 504511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 505511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((s1_p2 = strchr(s1, '_'))) { /* if an underscore is found... */ 506511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s1_p1_len = s1_p2 - s1; /* the prefix length is the difference in pointers */ 507511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s1_p2++; /* the suffix actually starts _after_ the underscore */ 508511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else { /* otherwise... */ 509511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s1_p1_len = strlen(s1); /* the prefix length is the length of the string itself */ 510511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s1_p2 = 0; /* and there is no suffix */ 511511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 512511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((s2_p2 = strchr(s2, '_'))) { /* now do the same for the second string */ 513511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s2_p1_len = s2_p2 - s2; 514511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s2_p2++; 515511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else { 516511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s2_p1_len = strlen(s2); 517511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s2_p2 = 0; 518511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 519511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall strncpy(str1, s1, (s1_p1_len > sizeof(str1)) ? s1_p1_len : sizeof(str1)); *(str1 + s1_p1_len) = 0; 520511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall strncpy(str2, s2, (s2_p1_len > sizeof(str2)) ? s2_p1_len : sizeof(str2)); *(str2 + s2_p1_len) = 0; 521511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall retval = strcmp(str1, str2); 522511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (retval != 0) return retval; /* if they are not identical, then we can quit now and return the indication */ 523511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return strcmp(s1_p2, s2_p2); /* otherwise we return the result of comparing the 2nd half of the string */ 524511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 525511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 526511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void sort_if_table(void) { 527511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_if_t *p1, *p2, *prev, *temp; 528511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int has_swapped; 529511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 530511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (!acn_if_list) return; /* nothing to do if the list is empty */ 531511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 532511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (1) { 533511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p1 = acn_if_list; /* start at the head of the list */ 534511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall prev = 0; 535511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall has_swapped = 0; 536511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while ((p2 = p1->next)) { 537511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (if_sort(p1->name, p2->name) > 0) { 538511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (prev) { /* we are swapping things that are _not_ at the head of the list */ 539511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall temp = p2->next; 540511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall prev->next = p2; 541511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p2->next = p1; 542511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p1->next = temp; 543511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else { /* special treatment if we are swapping with the head of the list */ 544511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall temp = p2->next; 545511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall acn_if_list= p2; 546511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p2->next = p1; 547511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p1->next = temp; 548511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 549511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p1 = p2; 550511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall prev = p1; 551511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall has_swapped = 1; 552511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 553511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall prev = p1; 554511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p1 = p1->next; 555511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 556511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (has_swapped == 0) 557511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return; 558511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 559511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return; 560511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 561511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 562511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int process_client_data (char *errbuf) { /* returns: -1 = error, 0 = OK */ 563511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 564511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unit_t *u; 565511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_if_t *iff, *prev_iff; 566511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_addr_t *addr, *prev_addr; 567511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *ptr; 568511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int address_count; 569511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall struct sockaddr_in *s; 570511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char *newname; 571511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall bpf_u_int32 interfaceType; 572511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unsigned char flags; 573511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 574511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall prev_iff = 0; 575511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (chassis = 0; chassis <= MAX_CHASSIS; chassis++) { 576511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (geoslot = 0; geoslot <= MAX_GEOSLOT; geoslot++) { /* now loop over all the devices */ 577511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u = &units[chassis][geoslot]; 578511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall empty_unit_iface(u); 579511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr = u->imsg; /* point to the start of the msg for this IOP */ 580511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (ptr < (u->imsg + u->len)) { 581511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((iff = malloc(sizeof(pcap_if_t))) == NULL) { 582511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "malloc: %s", pcap_strerror(errno)); 583511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 584511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 585511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memset((char *)iff, 0, sizeof(pcap_if_t)); /* bzero() is deprecated, replaced with memset() */ 586511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (acn_if_list == 0) acn_if_list = iff; /* remember the head of the list */ 587511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (prev_iff) prev_iff->next = iff; /* insert a forward link */ 588511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 589511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (*ptr) { /* if there is a count for the name */ 590511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((iff->name = malloc(*ptr + 1)) == NULL) { /* get that amount of space */ 591511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "malloc: %s", pcap_strerror(errno)); 592511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 593511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 594511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memcpy(iff->name, (ptr + 1), *ptr); /* copy the name into the malloc'ed space */ 595511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall *(iff->name + *ptr) = 0; /* and null terminate the string */ 596511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr += *ptr; /* now move the pointer forwards by the length of the count plus the length of the string */ 597511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 598511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr++; 599511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 600511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (*ptr) { /* if there is a count for the description */ 601511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((iff->description = malloc(*ptr + 1)) == NULL) { /* get that amount of space */ 602511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "malloc: %s", pcap_strerror(errno)); 603511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 604511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 605511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memcpy(iff->description, (ptr + 1), *ptr); /* copy the name into the malloc'ed space */ 606511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall *(iff->description + *ptr) = 0; /* and null terminate the string */ 607511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr += *ptr; /* now move the pointer forwards by the length of the count plus the length of the string */ 608511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 609511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr++; 610511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 611511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall interfaceType = ntohl(*(bpf_u_int32 *)ptr); 612511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr += 4; /* skip over the interface type */ 613511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 614511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall flags = *ptr++; 615511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (flags) iff->flags = PCAP_IF_LOOPBACK; /* if this is a loopback style interface, lets mark it as such */ 616511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 617511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall address_count = *ptr++; 618511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 619511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall prev_addr = 0; 620511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (address_count--) { 621511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((addr = malloc(sizeof(pcap_addr_t))) == NULL) { 622511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "malloc: %s", pcap_strerror(errno)); 623511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 624511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 625511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall+ memset((char *)addr, 0, sizeof(pcap_addr_t)); /* bzero() is deprecated, replaced with memset() */ 626511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (iff->addresses == 0) iff->addresses = addr; 627511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (prev_addr) prev_addr->next = addr; /* insert a forward link */ 628511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (*ptr) { /* if there is a count for the address */ 629511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((s = malloc(sizeof(struct sockaddr_in))) == NULL) { /* get that amount of space */ 630511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "malloc: %s", pcap_strerror(errno)); 631511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 632511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 633511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memset((char *)s, 0, sizeof(struct sockaddr_in)); /* bzero() is deprecated, replaced with memset() */ 634511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall addr->addr = (struct sockaddr *)s; 635511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s->sin_family = AF_INET; 636511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s->sin_addr.s_addr = *(bpf_u_int32 *)(ptr + 1); /* copy the address in */ 637511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr += *ptr; /* now move the pointer forwards according to the specified length of the address */ 638511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 639511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr++; /* then forwards one more for the 'length of the address' field */ 640511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (*ptr) { /* process any netmask */ 641511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((s = malloc(sizeof(struct sockaddr_in))) == NULL) { 642511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "malloc: %s", pcap_strerror(errno)); 643511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 644511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 645511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* bzero() is deprecated, replaced with memset() */ 646511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memset((char *)s, 0, sizeof(struct sockaddr_in)); 647511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 648511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall addr->netmask = (struct sockaddr *)s; 649511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s->sin_family = AF_INET; 650511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s->sin_addr.s_addr = *(bpf_u_int32*)(ptr + 1); 651511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr += *ptr; 652511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 653511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr++; 654511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (*ptr) { /* process any broadcast address */ 655511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((s = malloc(sizeof(struct sockaddr_in))) == NULL) { 656511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "malloc: %s", pcap_strerror(errno)); 657511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 658511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 659511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* bzero() is deprecated, replaced with memset() */ 660511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memset((char *)s, 0, sizeof(struct sockaddr_in)); 661511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 662511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall addr->broadaddr = (struct sockaddr *)s; 663511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s->sin_family = AF_INET; 664511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s->sin_addr.s_addr = *(bpf_u_int32*)(ptr + 1); 665511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr += *ptr; 666511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 667511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr++; 668511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (*ptr) { /* process any destination address */ 669511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((s = malloc(sizeof(struct sockaddr_in))) == NULL) { 670511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "malloc: %s", pcap_strerror(errno)); 671511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 672511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 673511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* bzero() is deprecated, replaced with memset() */ 674511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memset((char *)s, 0, sizeof(struct sockaddr_in)); 675511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 676511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall addr->dstaddr = (struct sockaddr *)s; 677511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s->sin_family = AF_INET; 678511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall s->sin_addr.s_addr = *(bpf_u_int32*)(ptr + 1); 679511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr += *ptr; 680511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 681511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ptr++; 682511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall prev_addr = addr; 683511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 684511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall prev_iff = iff; 685511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 686511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall newname = translate_IOP_to_pcap_name(u, iff->name, interfaceType); /* add a translation entry and get a point to the mangled name */ 687511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((iff->name = realloc(iff->name, strlen(newname) + 1)) == NULL) { /* we now re-write the name stored in the interface list */ 688511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(errbuf, PCAP_ERRBUF_SIZE, "realloc: %s", pcap_strerror(errno)); 689511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 690511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 691511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall strcpy(iff->name, newname); /* to this new name */ 692511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 693511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 694511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 695511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 696511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 697511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 698511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int read_client_data (int fd) { 699511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unsigned char buf[256]; 700511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 701511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unit_t *u; 702511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int len; 703511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 704511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall find_unit_by_fd(fd, &chassis, &geoslot, &u); 705511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 706511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((len = recv(fd, buf, sizeof(buf), 0)) <= 0) return 0; /* read in whatever data was sent to us */ 707511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 708511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((u->imsg = realloc(u->imsg, (u->len + len))) == NULL) /* extend the buffer for the new data */ 709511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 710511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memcpy((u->imsg + u->len), buf, len); /* append the new data */ 711511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->len += len; 712511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 1; 713511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 714511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 715511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void wait_for_all_answers(void) { 716511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int retval; 717511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall struct timeval tv; 718511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int fd; 719511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 720511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 721511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall tv.tv_sec = 2; 722511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall tv.tv_usec = 0; 723511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 724511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (1) { 725511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int flag = 0; 726511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fd_set working_set; 727511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 728511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (fd = 0; fd <= max_fs; fd++) { /* scan the list of descriptors we may be listening to */ 729511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (FD_ISSET(fd, &readfds)) flag = 1; /* and see if there are any still set */ 730511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 731511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (flag == 0) return; /* we are done, when they are all gone */ 732511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 733511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memcpy(&working_set, &readfds, sizeof(readfds)); /* otherwise, we still have to listen for more stuff, till we timeout */ 734511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall retval = select(max_fs + 1, &working_set, NULL, NULL, &tv); 735511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (retval == -1) { /* an error occured !!!!! */ 736511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return; 737511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else if (retval == 0) { /* timeout occured, so process what we've got sofar and return */ 738511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall printf("timeout\n"); 739511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return; 740511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else { 741511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (fd = 0; fd <= max_fs; fd++) { /* scan the list of things to do, and do them */ 742511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (FD_ISSET(fd, &working_set)) { 743511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (read_client_data(fd) == 0) { /* if the socket has closed */ 744511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall FD_CLR(fd, &readfds); /* and descriptors we listen to for errors */ 745511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall find_unit_by_fd(fd, &chassis, &geoslot, NULL); 746511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall close_with_IOP(chassis, geoslot, FIND); /* and close out connection to him */ 747511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 748511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 749511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 750511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 751511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 752511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 753511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 754511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic char *get_error_response(int fd, char *errbuf) { /* return a pointer on error, NULL on no error */ 755511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall char byte; 756511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int len = 0; 757511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 758511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (1) { 759511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall recv(fd, &byte, 1, 0); /* read another byte in */ 760511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (errbuf && (len++ < PCAP_ERRBUF_SIZE)) { /* and if there is still room in the buffer */ 761511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall *errbuf++ = byte; /* stick it in */ 762511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall *errbuf = '\0'; /* ensure the string is null terminated just in case we might exceed the buffer's size */ 763511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 764511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (byte == '\0') { 765511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (len > 1) { return errbuf; } 766511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall else { return NULL; } 767511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 768511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 769511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 770511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 771511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallint acn_findalldevs(char *errbuf) { /* returns: -1 = error, 0 = OK */ 772511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 773511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unit_t *u; 774511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 775511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall FD_ZERO(&readfds); 776511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall max_fs = 0; 777511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (chassis = 0; chassis <= MAX_CHASSIS; chassis++) { 778511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (geoslot = 0; geoslot <= MAX_GEOSLOT; geoslot++) { 779511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u = &units[chassis][geoslot]; 780511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (u->ip && (open_with_IOP(u, FIND))) { /* connect to the remote IOP */ 781511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(u->find_fd, 1, (unsigned char *)"\0"); 782511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (get_error_response(u->find_fd, errbuf)) 783511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall close_with_IOP(chassis, geoslot, FIND); 784511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall else { 785511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (u->find_fd > max_fs) 786511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall max_fs = u->find_fd; /* remember the highest number currently in use */ 787511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall FD_SET(u->find_fd, &readfds); /* we are going to want to read this guy's response to */ 788511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->len = 0; 789511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(u->find_fd, 1, (unsigned char *)"Q"); /* this interface query request */ 790511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 791511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 792511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 793511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 794511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall wait_for_all_answers(); 795511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (process_client_data(errbuf)) 796511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 797511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall sort_if_table(); 798511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 799511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 800511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 801511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int pcap_stats_acn(pcap_t *handle, struct pcap_stat *ps) { 802511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unsigned char buf[12]; 803511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 804511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(handle->fd, 1, (unsigned char *)"S"); /* send the get_stats command to the IOP */ 805511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 806511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (read_client_nbytes(handle->fd, sizeof(buf), buf) == -1) return -1; /* try reading the required bytes */ 807511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 808511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ps->ps_recv = ntohl(*(uint32_t *)&buf[0]); /* break the buffer into its three 32 bit components */ 809511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ps->ps_drop = ntohl(*(uint32_t *)&buf[4]); 810511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall ps->ps_ifdrop = ntohl(*(uint32_t *)&buf[8]); 811511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 812511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 813511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 814511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 815511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int acn_open_live(const char *name, char *errbuf, int *linktype) { /* returns 0 on error, else returns the file descriptor */ 816511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int chassis, geoslot; 817511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unit_t *u; 818511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall iface_t *p; 819511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_if_t *alldevsp; 820511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 821511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_findalldevs_interfaces(&alldevsp, errbuf); 822511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (chassis = 0; chassis <= MAX_CHASSIS; chassis++) { /* scan the table... */ 823511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall for (geoslot = 0; geoslot <= MAX_GEOSLOT; geoslot++) { 824511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u = &units[chassis][geoslot]; 825511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (u->ip != NULL) { 826511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p = u->iface; 827511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (p) { /* and all interfaces... */ 828511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (p->IOPname && p->name && (strcmp(p->name, name) == 0)) { /* and if we found the interface we want... */ 829511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall *linktype = p->iftype; 830511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall open_with_IOP(u, LIVE); /* start a connection with that IOP */ 831511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(u->fd, strlen(p->IOPname)+1, (unsigned char *)p->IOPname); /* send the IOP's interface name, and a terminating null */ 832511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (get_error_response(u->fd, errbuf)) { 833511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 834511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 835511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return u->fd; /* and return that open descriptor */ 836511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 837511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p = p->next; 838511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 839511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 840511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 841511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 842511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; /* if the interface wasn't found, return an error */ 843511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 844511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 845511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic void acn_start_monitor(int fd, int snaplen, int timeout, int promiscuous, int direction) { 846511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unsigned char buf[8]; 847511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unit_t *u; 848511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 849511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall //printf("acn_start_monitor()\n"); // fulko 850511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall find_unit_by_fd(fd, NULL, NULL, &u); 851511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (u->first_time == 0) { 852511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall buf[0] = 'M'; 853511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall *(uint32_t *)&buf[1] = htonl(snaplen); 854511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall buf[5] = timeout; 855511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall buf[6] = promiscuous; 856511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall buf[7] = direction; 857511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall //printf("acn_start_monitor() first time\n"); // fulko 858511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(fd, 8, buf); /* send the start monitor command with its parameters to the IOP */ 859511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u->first_time = 1; 860511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 861511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall //printf("acn_start_monitor() complete\n"); // fulko 862511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 863511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 864511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int pcap_inject_acn(pcap_t *p, const void *buf _U_, size_t size _U_) { 865511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall strlcpy(p->errbuf, "Sending packets isn't supported on ACN adapters", 866511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall PCAP_ERRBUF_SIZE); 867511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return (-1); 868511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 869511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 870511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int pcap_setfilter_acn(pcap_t *handle, struct bpf_program *bpf) { 871511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int fd = handle->fd; 872511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int count; 873511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall struct bpf_insn *p; 874511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall uint16_t shortInt; 875511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall uint32_t longInt; 876511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 877511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(fd, 1, (unsigned char *)"F"); /* BPF filter follows command */ 878511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall count = bpf->bf_len; 879511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall longInt = htonl(count); 880511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(fd, 4, (unsigned char *)&longInt); /* send the instruction sequence count */ 881511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p = bpf->bf_insns; 882511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (count--) { /* followed by the list of instructions */ 883511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall shortInt = htons(p->code); 884511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall longInt = htonl(p->k); 885511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(fd, 2, (unsigned char *)&shortInt); 886511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(fd, 1, (unsigned char *)&p->jt); 887511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(fd, 1, (unsigned char *)&p->jf); 888511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall send_to_fd(fd, 4, (unsigned char *)&longInt); 889511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p++; 890511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 891511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (get_error_response(fd, NULL)) 892511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 893511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 894511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 895511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 896511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int pcap_setdirection_acn(pcap_t *handle, pcap_direction_t d) { 897511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(handle->errbuf, sizeof(handle->errbuf), 898511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall "Setting direction is not supported on ACN adapters"); 899511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 900511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 901511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 902511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int acn_read_n_bytes_with_timeout(pcap_t *handle, int count) { 903511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall struct timeval tv; 904511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int retval, fd; 905511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fd_set r_fds; 906511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fd_set w_fds; 907511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall u_char *bp; 908511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int len = 0; 909511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int offset = 0; 910511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 911511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall tv.tv_sec = 5; 912511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall tv.tv_usec = 0; 913511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 914511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fd = handle->fd; 915511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall FD_ZERO(&r_fds); 916511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall FD_SET(fd, &r_fds); 917511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall memcpy(&w_fds, &r_fds, sizeof(r_fds)); 918511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall bp = handle->bp; 919511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall while (count) { 920511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall retval = select(fd + 1, &w_fds, NULL, NULL, &tv); 921511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (retval == -1) { /* an error occured !!!!! */ 922511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall// fprintf(stderr, "error during packet data read\n"); 923511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; /* but we need to return a good indication to prevent unneccessary popups */ 924511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else if (retval == 0) { /* timeout occured, so process what we've got sofar and return */ 925511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall// fprintf(stderr, "timeout during packet data read\n"); 926511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 927511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } else { 928511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if ((len = recv(fd, (bp + offset), count, 0)) <= 0) { 929511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall// fprintf(stderr, "premature exit during packet data rx\n"); 930511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return -1; 931511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 932511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall count -= len; 933511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall offset += len; 934511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 935511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 936511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 937511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 938511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 939511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int pcap_read_acn(pcap_t *handle, int max_packets, pcap_handler callback, u_char *user) { 940511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall #define HEADER_SIZE (4 * 4) 941511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall unsigned char packet_header[HEADER_SIZE]; 942511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall struct pcap_pkthdr pcap_header; 943511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 944511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall //printf("pcap_read_acn()\n"); // fulko 945511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall acn_start_monitor(handle->fd, handle->snapshot, handle->opt.timeout, handle->opt.promisc, handle->direction); /* maybe tell him to start monitoring */ 946511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall //printf("pcap_read_acn() after start monitor\n"); // fulko 947511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 948511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->bp = packet_header; 949511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (acn_read_n_bytes_with_timeout(handle, HEADER_SIZE) == -1) return 0; /* try to read a packet header in so we can get the sizeof the packet data */ 950511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 951511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_header.ts.tv_sec = ntohl(*(uint32_t *)&packet_header[0]); /* tv_sec */ 952511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_header.ts.tv_usec = ntohl(*(uint32_t *)&packet_header[4]); /* tv_usec */ 953511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_header.caplen = ntohl(*(uint32_t *)&packet_header[8]); /* caplen */ 954511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_header.len = ntohl(*(uint32_t *)&packet_header[12]); /* len */ 955511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 956511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->bp = handle->buffer + handle->offset; /* start off the receive pointer at the right spot */ 957511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (acn_read_n_bytes_with_timeout(handle, pcap_header.caplen) == -1) return 0; /* then try to read in the rest of the data */ 958511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 959511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall callback(user, &pcap_header, handle->bp); /* call the user supplied callback function */ 960511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 1; 961511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 962511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 963511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallstatic int pcap_activate_sita(pcap_t *handle) { 964511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall int fd; 965511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 966511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (handle->opt.rfmon) { 967511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* 968511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * No monitor mode on SITA devices (they're not Wi-Fi 969511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * devices). 970511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall */ 971511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return PCAP_ERROR_RFMON_NOTSUP; 972511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 973511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 974511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* Initialize some components of the pcap structure. */ 975511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 976511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->inject_op = pcap_inject_acn; 977511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->setfilter_op = pcap_setfilter_acn; 978511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->setdirection_op = pcap_setdirection_acn; 979511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->set_datalink_op = NULL; /* can't change data link type */ 980511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->getnonblock_op = pcap_getnonblock_fd; 981511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->setnonblock_op = pcap_setnonblock_fd; 982511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->cleanup_op = pcap_cleanup_acn; 983511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->read_op = pcap_read_acn; 984511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->stats_op = pcap_stats_acn; 985511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 986511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall fd = acn_open_live(handle->opt.source, handle->errbuf, 987511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall &handle->linktype); 988511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (fd == -1) 989511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return PCAP_ERROR; 990511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->fd = fd; 991511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->bufsize = handle->snapshot; 992511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 993511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* Allocate the buffer */ 994511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 995511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->buffer = malloc(handle->bufsize + handle->offset); 996511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (!handle->buffer) { 997511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall snprintf(handle->errbuf, PCAP_ERRBUF_SIZE, 998511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall "malloc: %s", pcap_strerror(errno)); 999511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_cleanup_acn(handle); 1000511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return PCAP_ERROR; 1001511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall } 1002511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 1003511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall /* 1004511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * "handle->fd" is a socket, so "select()" and "poll()" 1005511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall * should work on it. 1006511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall */ 1007511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall handle->selectable_fd = handle->fd; 1008511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 1009511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return 0; 1010511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 1011511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 1012511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrallpcap_t *pcap_create_interface(const char *device, char *ebuf) { 1013511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall pcap_t *p; 1014511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 1015511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p = pcap_create_common(device, ebuf, 0); 1016511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall if (p == NULL) 1017511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return (NULL); 1018511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall 1019511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall p->activate_op = pcap_activate_sita; 1020511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall return (p); 1021511eca30a483e912c274e1d8ba3a0f8f081e2227JP Abgrall} 1022