|
From: Christine C. <chr...@us...> - 2008-09-04 12:37:25
|
Update of /cvsroot/linux-decnet/dnprogs/nml In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv17902 Added Files: Makefile main.c nml.c Log Message: Make a start on NML --- NEW FILE: Makefile --- # Makefile for NML include ../Makefile.common PROG1=dnetnml MANPAGES8=dnetnml.8 PROG1OBJS=main.o nml.o CDEFS+=-DPROTOTYPES CFLAGS+=-I ../dnroute/netlink/include all: $(PROG1) .c.o: $(CC) $(CFLAGS) $(SYSCONF_PREFIX) -c -o $@ $< $(PROG1): $(PROG1OBJS) $(DEPLIBDNET) $(DEPLIBDAEMON) $(UULIB) $(CC) $(CFLAGS) -o $@ $(PROG1OBJS) $(LIBDNET) $(LIBUU) $(LIBDAEMON) -L ../dnroute/netlink -lnetlink install: install -d $(prefix)/bin install -d $(manprefix)/man/man5 install -d $(manprefix)/man/man8 install -m 0755 $(STRIPBIN) $(PROG1) $(prefix)/sbin install -m 0644 $(MANPAGES8) $(manprefix)/man/man8 dep depend: $(CC) $(CFLAGS) -MM *.c >.depend 2>/dev/null clean: rm -f $(PROG1) *.o *.bak .depend make -C $(UUDIR) clean ifeq (.depend,$(wildcard .depend)) include .depend endif --- NEW FILE: main.c --- /****************************************************************************** (c) 2008 Christine Caulfield chr...@go... This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. ****************************************************************************** */ #include <stdio.h> #include <stdlib.h> #include <syslog.h> #include <signal.h> #include <string.h> #include <syslog.h> #include <errno.h> #include <unistd.h> #include <regex.h> #include <pwd.h> #include <sys/socket.h> #include <netdnet/dn.h> #include <netdnet/dnetdb.h> #include <sys/ioctl.h> #include <sys/types.h> #include <sys/wait.h> extern int process_request(int sock, int verbosity); // Global variables. int verbosity = 0; void usage(char *prog, FILE *f) { fprintf(f,"\n%s options:\n", prog); fprintf(f," -v Verbose messages\n"); fprintf(f," -h Show this help text\n"); fprintf(f," -d Show debug logging\n"); fprintf(f," -V Show version number\n\n"); } int main(int argc, char *argv[]) { pid_t pid; char opt; struct sockaddr_dn sockaddr; struct optdata_dn optdata; int insock; int debug; int len = sizeof(sockaddr); int check_user=1; // Deal with command-line arguments. Do these before the check for root // so we can check the version number and get help without being root. opterr = 0; optind = 0; while ((opt=getopt(argc,argv,"?vVdhu:Ufl:")) != EOF) { switch(opt) { case 'h': usage(argv[0], stdout); exit(0); case '?': usage(argv[0], stderr); exit(0); case 'v': verbosity++; break; case 'd': debug++; break; case 'V': printf("\nnml from dnprogs version %s\n\n", VERSION); exit(1); break; } } // Initialise logging init_daemon_logging("nml", debug?'e':'s'); // Wait for something to happen (or check to see if it already has) insock = dnet_daemon(DNOBJECT_NICE, NULL, verbosity, !debug); if (insock > -1) { dnet_accept(insock, 0, NULL, 0); process_request(insock, verbosity); } return 0; } --- NEW FILE: nml.c --- /****************************************************************************** (c) 2008 Christine Caulfield chr...@go... This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. ****************************************************************************** */ #include <stdio.h> #include <stdlib.h> #include <syslog.h> #include <string.h> #include <unistd.h> #include <syslog.h> #include <errno.h> #include <unistd.h> #include <sys/ioctl.h> #include <sys/types.h> #include <sys/socket.h> #include <net/if.h> #include <netinet/in.h> #include <netdnet/dn.h> #include <netdnet/dnetdb.h> #include "libnetlink.h" /* Sigh - people keep removing features ... */ #ifndef NDA_RTA #define NDA_RTA(r) ((struct rtattr*)(((char*)(r)) + NLMSG_ALIGN(sizeof(struct ndmsg)))) #endif static struct rtnl_handle talk_rth; static struct rtnl_handle listen_rth; static int first_time = 1; static char *if_index_to_name(int ifindex) { struct ifreq ifr; static char buf[64]; int sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP); ifr.ifr_ifindex = ifindex; if (ioctl(sock, SIOCGIFNAME, &ifr) == 0) { strcpy(buf, ifr.ifr_name); } else { sprintf(buf, "if%d", ifindex); } close(sock); return buf; } static int send_node(int sock, struct nodeent *n, int exec, char *device) { char buf[256]; int ptr = 0; buf[ptr++] = 1; // Here is your data miss buf[ptr++] = 0; buf[ptr++] = 0; // Status buf[ptr++] = 0; // Node information buf[ptr++] = n->n_addr[0]; buf[ptr++] = n->n_addr[1]; buf[ptr++] = strlen(n->n_name) | (exec?0x80:0); memcpy(&buf[ptr], n->n_name, strlen(n->n_name)); ptr += strlen(n->n_name); /* device */ if (device) { buf[ptr++] = '6'; // TODO get real value! buf[ptr++] = 3; // CIRCUIT buf[ptr++] = 64; buf[ptr++] = strlen(device); strcpy(&buf[ptr], device); ptr += strlen(device); } return write(sock, buf, ptr); } static int send_exec(int sock) { struct dn_naddr *exec_addr; struct nodeent *exec_node; unsigned int exec_area; unsigned int nodeaddr; char *dev; /* Get and send the exec information */ exec_addr = getnodeadd(); exec_area = exec_addr->a_addr[1]>>2; nodeaddr = exec_addr->a_addr[0] | exec_addr->a_addr[1]<<8; exec_node = getnodebyaddr((char*)exec_addr->a_addr, 2, AF_DECnet); dev = getexecdev(); return send_node(sock, exec_node, 1, dev); } /* Called for each neighbour node in the list */ static int got_neigh(struct sockaddr_nl *who, struct nlmsghdr *n, void *arg) { struct ndmsg *r = NLMSG_DATA(n); struct rtattr * tb[NDA_MAX+1]; int sock = (int)arg; dnetlog(LOG_DEBUG, "got_neigh\n"); memset(tb, 0, sizeof(tb)); parse_rtattr(tb, NDA_MAX, NDA_RTA(r), n->nlmsg_len - NLMSG_LENGTH(sizeof(*r))); if (tb[NDA_DST]) { unsigned char *addr = RTA_DATA(tb[NDA_DST]); unsigned short faddr = addr[0] | (addr[1]<<8); struct nodeinfo *n, *n1; int interface = r->ndm_ifindex; int node = faddr & 0x3ff; int area = faddr >> 10; struct nodeent *ne = getnodebyaddr((char *)&faddr, 2, AF_DECnet); struct nodeent tne; if (ne) { send_node(sock, ne, 0, if_index_to_name(interface)); } else { tne.n_name=""; tne.n_addr[0] = addr[0]; tne.n_addr[1] = addr[1]; send_node(sock, &tne, 0, if_index_to_name(interface)); } } return 0; } static int send_neighbour_nodes(int sock) { if (first_time) { if (rtnl_open(&talk_rth, 0) < 0) return -1; if (rtnl_open(&listen_rth, 0) < 0) return -1; first_time = 0; } send_exec(sock); /* Get the list of adjacent nodes */ if (rtnl_wilddump_request(&listen_rth, AF_DECnet, RTM_GETNEIGH) < 0) { syslog(LOG_ERR, "Cannot send dump request: %m"); return -1; } /* Calls got_neigh() for each adjacent node */ if (rtnl_dump_filter(&listen_rth, got_neigh, (void *)sock, NULL, NULL) < 0) { syslog(LOG_ERR, "Dump terminated: %m\n"); return -1; } dnetlog(LOG_DEBUG, "end of send_neighbour_nodes\n"); return 0; } static int send_perm_nodes(int sock) { void *nodelist; char *nodename; send_exec(sock); /* Now iterate the permanent database */ nodelist = dnet_getnode(); nodename = dnet_nextnode(nodelist); while (nodename) { struct nodeent *n = getnodebyname(nodename); send_node(sock, n, 0); nodename = dnet_nextnode(nodelist); } dnet_endnode(nodelist); return 0; } static int read_information(int sock, unsigned char *buf, int length) { unsigned char option = buf[1]; unsigned char entity = buf[2]; char response = 2; // Tell remote end we are sending the data. write(sock, &response, 1); // Parameter entries from [3] onwards. // option & 0x80: 1=perm DB, 0=volatile DB // option & 0x78: type 0=summary, 1=status, 2=char, 3=counters, 4=events // option & 0x07: entity type // entity: 0=node, 1=line, 2=logging, 3=circuit, 4=module 5=area fprintf(stderr, "CC: option=%d. entity=%d\n", option, entity); // Send the permanent node information ... switch (option) { case 0: // nodes if (entity == 0xff) send_perm_nodes(sock); if (entity == 0xfc) send_neighbour_nodes(sock); break; default: break; } // End of data. response = -128; write(sock, &response, 1); return 0; } static void unsupported(int sock) { char buf[256]; buf[0] = -1; buf[1] = 0; buf[2] = 0; // TODO This text should be of the defined type... strcpy(&buf[3], "Unrecognised command"); write(sock, buf, strlen(&buf[3])+4); } int process_request(int sock, int verbosity) { unsigned char buf[4096]; int status; do { status = read(sock, buf, sizeof(buf)); if (status == -1 || status == 0) break; if (verbosity > 1) { int i; dnetlog(LOG_DEBUG, "Received message %d bytes: \n", status); for (i=0; i<status; i++) dnetlog(LOG_DEBUG, "%02x ", buf[i]); dnetlog(LOG_DEBUG, "\n"); } switch (buf[0]) { case 15:// Request down-line load unsupported(sock); break; case 16:// Request up-line dump unsupported(sock); break; case 17:// Trigger bootstrap unsupported(sock); break; case 18:// Test unsupported(sock); break; case 19:// Change parameter unsupported(sock); break; case 20:// Read information read_information(sock, buf, status); break; case 21:// Zero counters unsupported(sock); break; case 22:// System-specific function unsupported(sock); break; default: unsupported(sock); // Send error } } while (status > 0); return 0; } |
