/* * HTTP Info plugin for the olsr.org OLSR daemon * Copyright (c) 2004, Andreas Tønnesen(andreto@olsr.org) * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * * * Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in * the documentation and/or other materials provided with the * distribution. * * Neither the name of olsr.org, olsrd nor the names of its * contributors may be used to endorse or promote products derived * from this software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. * * Visit http://www.olsr.org for more information. * * If you find this software useful feel free to make a donation * to the project. For more information see the website or contact * the copyright holders. * * $Id: olsrd_httpinfo.c,v 1.80 2007/10/14 22:46:03 bernd67 Exp $ */ /* * Dynamic linked library for the olsr.org olsr daemon */ #include #include #include #include #include #include #ifdef WIN32 #include #else #include #endif #include "olsr.h" #include "olsr_cfg.h" #include "interfaces.h" #include "olsr_protocol.h" #include "net_olsr.h" #include "link_set.h" #include "socket_parser.h" #include "olsrd_httpinfo.h" #include "admin_interface.h" #include "html.h" #include "gfx.h" #ifdef OS #undef OS #endif #ifdef WIN32 #define close(x) closesocket(x) #define OS "Windows" #endif #ifdef linux #define OS "GNU/Linux" #endif #ifdef __FreeBSD__ #define OS "FreeBSD" #endif #ifndef OS #define OS "Undefined" #endif static char copyright_string[] __attribute__((unused)) = "olsr.org HTTPINFO plugin Copyright (c) 2004, Andreas Tønnesen(andreto@olsr.org) All rights reserved."; #define MAX_CLIENTS 3 #define MAX_HTTPREQ_SIZE (1024 * 10) #define DEFAULT_TCP_PORT 1978 #define HTML_BUFSIZE (1024 * 4000) #define FRAMEWIDTH 800 #define FILENREQ_MATCH(req, filename) \ !strcmp(req, filename) || \ (strlen(req) && !strcmp(&req[1], filename)) struct tab_entry { char *tab_label; char *filename; int(*build_body_cb)(char *, olsr_u32_t); olsr_bool display_tab; }; struct static_bin_file_entry { char *filename; unsigned char *data; unsigned int data_size; }; struct static_txt_file_entry { char *filename; const char **data; }; struct dynamic_file_entry { char *filename; int(*process_data_cb)(char *, olsr_u32_t, char *, olsr_u32_t); }; static int get_http_socket(int); static int build_tabs(char *, olsr_u32_t, int); static void parse_http_request(int); static int build_http_header(http_header_type, olsr_bool, olsr_u32_t, char *, olsr_u32_t); static int build_frame(char *, olsr_u32_t, char *, char *, int, int(*frame_body_cb)(char *, olsr_u32_t)); static int build_routes_body(char *, olsr_u32_t); static int build_config_body(char *, olsr_u32_t); static int build_neigh_body(char *, olsr_u32_t); static int build_topo_body(char *, olsr_u32_t); static int build_mid_body(char *, olsr_u32_t); static int build_nodes_body(char *, olsr_u32_t); static int build_all_body(char *, olsr_u32_t); static int build_about_body(char *, olsr_u32_t); static int build_cfgfile_body(char *, olsr_u32_t); static int check_allowed_ip(const struct allowed_net * const allowed_nets, const union olsr_ip_addr * const addr); static int build_ip_txt(char *buf, const olsr_u32_t bufsize, const olsr_bool want_link, const union olsr_ip_addr * const ipaddr, const int prefix_len); static int build_ipaddr_link(char *buf, const olsr_u32_t bufsize, const olsr_bool want_link, const union olsr_ip_addr * const ipaddr, const int prefix_len); static int section_title(char *buf, olsr_u32_t bufsize, const char *title); static ssize_t writen(int fd, const void *buf, size_t count); static struct timeval start_time; static struct http_stats stats; static int client_sockets[MAX_CLIENTS]; static int curr_clients; static int http_socket; #if 0 int netsprintf(char *str, const char* format, ...) __attribute__((format(printf, 2, 3))); static int netsprintf_direct = 0; static int netsprintf_error = 0; #define sprintf netsprintf #define NETDIRECT #endif static const struct tab_entry tab_entries[] = { {"Configuration", "config", build_config_body, OLSR_TRUE}, {"Routes", "routes", build_routes_body, OLSR_TRUE}, {"Links/Topology", "nodes", build_nodes_body, OLSR_TRUE}, {"All", "all", build_all_body, OLSR_TRUE}, #ifdef ADMIN_INTERFACE {"Admin", "admin", build_admin_body, OLSR_TRUE}, #endif {"About", "about", build_about_body, OLSR_TRUE}, {"FOO", "cfgfile", build_cfgfile_body, OLSR_FALSE}, {NULL, NULL, NULL, OLSR_FALSE} }; static const struct static_bin_file_entry static_bin_files[] = { {"favicon.ico", favicon_ico, 1406/*favicon_ico_len*/}, {"logo.gif", logo_gif, 2801/*logo_gif_len*/}, {"grayline.gif", grayline_gif, 43/*grayline_gif_len*/}, {NULL, NULL, 0} }; static const struct static_txt_file_entry static_txt_files[] = { {"httpinfo.css", httpinfo_css}, {NULL, NULL} }; static const struct dynamic_file_entry dynamic_files[] = { #ifdef ADMIN_INTERFACE {"set_values", process_set_values}, #endif {NULL, NULL} }; /** *Do initialization here * *This function is called by the my_init *function in uolsrd_plugin.c */ int olsrd_plugin_init(void) { /* Get start time */ gettimeofday(&start_time, NULL); curr_clients = 0; /* set up HTTP socket */ http_socket = get_http_socket(http_port != 0 ? http_port : DEFAULT_TCP_PORT); if(http_socket < 0) { fprintf(stderr, "(HTTPINFO) could not initialize HTTP socket\n"); exit(0); } /* Register socket */ add_olsr_socket(http_socket, &parse_http_request); return 1; } static int get_http_socket(int port) { struct sockaddr_in sin; olsr_u32_t yes = 1; int s; /* Init ipc socket */ if ((s = socket(AF_INET, SOCK_STREAM, 0)) == -1) { olsr_printf(1, "(HTTPINFO)socket %s\n", strerror(errno)); return -1; } if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char *)&yes, sizeof(yes)) < 0) { olsr_printf(1, "(HTTPINFO)SO_REUSEADDR failed %s\n", strerror(errno)); close(s); return -1; } /* Bind the socket */ /* complete the socket structure */ memset(&sin, 0, sizeof(sin)); sin.sin_family = AF_INET; sin.sin_addr.s_addr = INADDR_ANY; sin.sin_port = htons(port); /* bind the socket to the port number */ if (bind(s, (struct sockaddr *) &sin, sizeof(sin)) == -1) { olsr_printf(1, "(HTTPINFO) bind failed %s\n", strerror(errno)); close(s); return -1; } /* show that we are willing to listen */ if (listen(s, 1) == -1) { olsr_printf(1, "(HTTPINFO) listen failed %s\n", strerror(errno)); close(s); return -1; } return s; } /* Non reentrant - but we are not multithreaded anyway */ void parse_http_request(int fd) { struct sockaddr_in pin; socklen_t addrlen; char *addr; char req[MAX_HTTPREQ_SIZE]; static char body[HTML_BUFSIZE]; char req_type[11]; char filename[251]; char http_version[11]; int c = 0, r = 1, size = 0; if(curr_clients >= MAX_CLIENTS) return; curr_clients++; addrlen = sizeof(struct sockaddr_in); if ((client_sockets[curr_clients] = accept(fd, (struct sockaddr *) &pin, &addrlen)) == -1) { olsr_printf(1, "(HTTPINFO) accept: %s\n", strerror(errno)); goto close_connection; } if(!check_allowed_ip(allowed_nets, (union olsr_ip_addr *)&pin.sin_addr.s_addr)) { olsr_printf(1, "HTTP request from non-allowed host %s!\n", olsr_ip_to_string((union olsr_ip_addr *)&pin.sin_addr.s_addr)); close(client_sockets[curr_clients]); } addr = inet_ntoa(pin.sin_addr); memset(req, 0, MAX_HTTPREQ_SIZE); memset(body, 0, 1024*10); while((r = recv(client_sockets[curr_clients], &req[c], 1, 0)) > 0 && (c < (MAX_HTTPREQ_SIZE-1))) { c++; if((c > 3 && !strcmp(&req[c-4], "\r\n\r\n")) || (c > 1 && !strcmp(&req[c-2], "\n\n"))) break; } if(r < 0) { olsr_printf(1, "(HTTPINFO) Failed to recieve data from client!\n"); stats.err_hits++; goto close_connection; } /* Get the request */ if(sscanf(req, "%10s %250s %10s\n", req_type, filename, http_version) != 3) { /* Try without HTTP version */ if(sscanf(req, "%10s %250s\n", req_type, filename) != 2) { olsr_printf(1, "(HTTPINFO) Error parsing request %s!\n", req); stats.err_hits++; goto close_connection; } } olsr_printf(1, "Request: %s\nfile: %s\nVersion: %s\n\n", req_type, filename, http_version); if(!strcmp(req_type, "POST")) { #ifdef ADMIN_INTERFACE int i = 0; while(dynamic_files[i].filename) { printf("POST checking %s\n", dynamic_files[i].filename); if(FILENREQ_MATCH(filename, dynamic_files[i].filename)) { olsr_u32_t param_size; stats.ok_hits++; param_size = recv(client_sockets[curr_clients], req, MAX_HTTPREQ_SIZE-1, 0); req[param_size] = '\0'; printf("Dynamic read %d bytes\n", param_size); //memcpy(body, dynamic_files[i].data, static_bin_files[i].data_size); size += dynamic_files[i].process_data_cb(req, param_size, &body[size], sizeof(body)-size); c = build_http_header(HTTP_OK, OLSR_TRUE, size, req, MAX_HTTPREQ_SIZE); goto send_http_data; } i++; } #endif /* We only support GET */ strcpy(body, HTTP_400_MSG); stats.ill_hits++; c = build_http_header(HTTP_BAD_REQ, OLSR_TRUE, strlen(body), req, MAX_HTTPREQ_SIZE); } else if(!strcmp(req_type, "GET")) { int i = 0; int y = 0; while(static_bin_files[i].filename) { if(FILENREQ_MATCH(filename, static_bin_files[i].filename)) break; i++; } if(static_bin_files[i].filename) { stats.ok_hits++; memcpy(body, static_bin_files[i].data, static_bin_files[i].data_size); size = static_bin_files[i].data_size; c = build_http_header(HTTP_OK, OLSR_FALSE, size, req, MAX_HTTPREQ_SIZE); goto send_http_data; } i = 0; while(static_txt_files[i].filename) { if(FILENREQ_MATCH(filename, static_txt_files[i].filename)) break; i++; } if(static_txt_files[i].filename) { stats.ok_hits++; y = 0; while(static_txt_files[i].data[y]) { size += snprintf(&body[size], sizeof(body)-size, static_txt_files[i].data[y]); y++; } c = build_http_header(HTTP_OK, OLSR_FALSE, size, req, MAX_HTTPREQ_SIZE); goto send_http_data; } i = 0; if(strlen(filename) > 1) { while(tab_entries[i].filename) { if(FILENREQ_MATCH(filename, tab_entries[i].filename)) break; i++; } } if(tab_entries[i].filename) { #ifdef NETDIRECT c = build_http_header(HTTP_OK, OLSR_TRUE, size, req, MAX_HTTPREQ_SIZE); r = send(client_sockets[curr_clients], req, c, 0); if(r < 0) { olsr_printf(1, "(HTTPINFO) Failed sending data to client!\n"); goto close_connection; } netsprintf_error = 0; netsprintf_direct = 1; #endif size += snprintf(&body[size], sizeof(body)-size, "%s", http_ok_head); size += build_tabs(&body[size], sizeof(body)-size, i); size += build_frame(&body[size], sizeof(body)-size, "Current Routes", "routes", FRAMEWIDTH, tab_entries[i].build_body_cb); stats.ok_hits++; size += snprintf(&body[size], sizeof(body)-size, http_ok_tail); #ifdef NETDIRECT netsprintf_direct = 1; goto close_connection; #else c = build_http_header(HTTP_OK, OLSR_TRUE, size, req, MAX_HTTPREQ_SIZE); goto send_http_data; #endif } stats.ill_hits++; strcpy(body, HTTP_404_MSG); c = build_http_header(HTTP_BAD_FILE, OLSR_TRUE, strlen(body), req, MAX_HTTPREQ_SIZE); } else { /* We only support GET */ strcpy(body, HTTP_400_MSG); stats.ill_hits++; c = build_http_header(HTTP_BAD_REQ, OLSR_TRUE, strlen(body), req, MAX_HTTPREQ_SIZE); } send_http_data: r = writen(client_sockets[curr_clients], req, c); if(r < 0) { olsr_printf(1, "(HTTPINFO) Failed sending data to client!\n"); goto close_connection; } r = writen(client_sockets[curr_clients], body, size); if(r < 0) { olsr_printf(1, "(HTTPINFO) Failed sending data to client!\n"); goto close_connection; } close_connection: close(client_sockets[curr_clients]); curr_clients--; } int build_http_header(http_header_type type, olsr_bool is_html, olsr_u32_t msgsize, char *buf, olsr_u32_t bufsize) { time_t currtime; const char *h; int size; switch(type) { case(HTTP_BAD_REQ): h = HTTP_400; break; case(HTTP_BAD_FILE): h = HTTP_404; break; default: /* Defaults to OK */ h = HTTP_200; break; } size = snprintf(buf, bufsize, "%s", h); /* Date */ time(&currtime); size += strftime(&buf[size], bufsize-size, "Date: %a, %d %b %Y %H:%M:%S GMT\r\n", localtime(&currtime)); /* Server version */ size += snprintf(&buf[size], bufsize-size, "Server: %s %s %s\r\n", PLUGIN_NAME, PLUGIN_VERSION, HTTP_VERSION); /* connection-type */ size += snprintf(&buf[size], bufsize-size, "Connection: closed\r\n"); /* MIME type */ size += snprintf(&buf[size], bufsize-size, "Content-type: text/%s\r\n", is_html ? "html" : "plain"); /* Content length */ if(msgsize > 0) { size += snprintf(&buf[size], bufsize-size, "Content-length: %i\r\n", msgsize); } /* Cache-control * No caching dynamic pages */ size += snprintf(&buf[size], bufsize-size, "Cache-Control: no-cache\r\n"); if(!is_html) { size += snprintf(&buf[size], bufsize-size, "Accept-Ranges: bytes\r\n"); } /* End header */ size += snprintf(&buf[size], bufsize-size, "\r\n"); olsr_printf(1, "HEADER:\n%s", buf); return size; } static int build_tabs(char *buf, const olsr_u32_t bufsize, int active) { int size = 0, tabs = 0; size += snprintf(&buf[size], bufsize-size, html_tabs_prolog); for(tabs = 0; tab_entries[tabs].tab_label; tabs++) { if(!tab_entries[tabs].display_tab) continue; size += snprintf(&buf[size], bufsize-size, "
  • %s
    • \n", tab_entries[tabs].filename, tabs == active ? " class=\"active\"" : "", tab_entries[tabs].tab_label); } size += snprintf(&buf[size], bufsize-size, html_tabs_epilog); return size; } /* * destructor - called at unload */ void olsr_plugin_exit(void) { if(http_socket) close(http_socket); } static int section_title(char *buf, olsr_u32_t bufsize, const char *title) { return snprintf(buf, bufsize, "

    %s

    \n" "\n", title); } static int build_frame(char *buf, olsr_u32_t bufsize, char *title __attribute__((unused)), char *link __attribute__((unused)), int width __attribute__((unused)), int(*frame_body_cb)(char *, olsr_u32_t)) { int size = 0; size += snprintf(&buf[size], bufsize-size, "
    \n"); size += frame_body_cb(&buf[size], bufsize-size); size += snprintf(&buf[size], bufsize-size, "
    \n"); return size; } static int fmt_href(char *buf, const olsr_u32_t bufsize, const union olsr_ip_addr * const ipaddr) { return snprintf(buf, bufsize, "", olsr_ip_to_string(ipaddr), http_port); } static int build_ip_txt(char *buf, const olsr_u32_t bufsize, const olsr_bool print_link, const union olsr_ip_addr * const ipaddr, const int prefix_len) { int size = 0; if (print_link) { /* Print the link only if there is no prefix_len */ size += fmt_href(&buf[size], bufsize-size, ipaddr); } /* print ip address or ip prefix ? */ if (prefix_len == -1) { size += snprintf(&buf[size], bufsize-size, "%s", olsr_ip_to_string(ipaddr)); } else { size += snprintf(&buf[size], bufsize-size, "%s/%d", olsr_ip_to_string(ipaddr), prefix_len); } if (print_link) { /* Print the link only if there is no prefix_len */ size += snprintf(&buf[size], bufsize-size, ""); } return size; } static int build_ipaddr_link(char *buf, const olsr_u32_t bufsize, const olsr_bool want_link, const union olsr_ip_addr * const ipaddr, const int prefix_len) { int size = 0; const struct hostent * const hp = #ifndef WIN32 resolve_ip_addresses ? gethostbyaddr(ipaddr, olsr_cnf->ipsize, olsr_cnf->ip_version) : #endif NULL; const int print_link = want_link && (prefix_len == -1 || prefix_len == olsr_cnf->maxplen); size += snprintf(&buf[size], bufsize-size, ""); if (resolve_ip_addresses) { if (hp) { size += snprintf(&buf[size], bufsize-size, ""); } else { size += snprintf(&buf[size], bufsize-size, ""); size += build_ipaddr_with_link(&buf[size], bufsize-size, &rt->rt_dst.prefix, rt->rt_dst.prefix_len); size += build_ipaddr_with_link(&buf[size], bufsize-size, &rt->rt_best->rtp_nexthop.gateway, -1); size += snprintf(&buf[size], bufsize-size, "", rt->rt_best->rtp_metric.hops); size += snprintf(&buf[size], bufsize-size, "", rt->rt_best->rtp_metric.etx); size += snprintf(&buf[size], bufsize-size, "\n", if_ifwithindex_name(rt->rt_best->rtp_nexthop.iif_index)); return size; } static int build_routes_body(char *buf, olsr_u32_t bufsize) { int size = 0; struct rt_entry *rt; size += section_title(&buf[size], bufsize-size, "OLSR Routes in Kernel"); size += snprintf(&buf[size], bufsize-size, "DestinationGateway\n", resolve_ip_addresses ? " colspan=\"2\"" : ""); /* Walk the route table */ OLSR_FOR_ALL_RT_ENTRIES(rt) { size += build_route(&buf[size], bufsize-size, rt); } OLSR_FOR_ALL_RT_ENTRIES_END(rt); size += snprintf(&buf[size], bufsize-size, "
    "); size += build_ip_txt(&buf[size], bufsize-size, print_link, ipaddr, prefix_len); size += snprintf(&buf[size], bufsize-size, "("); if (print_link) { size += fmt_href(&buf[size], bufsize-size, ipaddr); } size += snprintf(&buf[size], bufsize-size, "%s", hp->h_name); if (print_link) { size += snprintf(&buf[size], bufsize-size, ""); } size += snprintf(&buf[size], bufsize-size, ")"); } } return size; } #define build_ipaddr_with_link(buf, bufsize, ipaddr, plen) \ build_ipaddr_link((buf), (bufsize), OLSR_TRUE, (ipaddr), (plen)) #define build_ipaddr_no_link(buf, bufsize, ipaddr, plen) \ build_ipaddr_link((buf), (bufsize), OLSR_FALSE, (ipaddr), (plen)) static int build_route(char *buf, olsr_u32_t bufsize, const struct rt_entry * rt) { int size = 0; size += snprintf(&buf[size], bufsize-size, "
    %d%.3f%s
    MetricETXInterface
    \n"); return size; } static int build_config_body(char *buf, olsr_u32_t bufsize) { int size = 0; struct olsr_if *ifs; struct plugin_entry *pentry; struct plugin_param *pparam; size += snprintf(&buf[size], bufsize-size, "Version: %s (built on %s on %s)\n
    ", olsrd_version, build_date, build_host); size += snprintf(&buf[size], bufsize-size, "OS: %s\n
    ", OS); { time_t currtime = time(NULL); int rc = strftime(&buf[size], bufsize-size, "System time: %a, %d %b %Y %H:%M:%S
    ", localtime(&currtime)); if (rc > 0) { size += rc; } } { struct timeval now, uptime; int hours, mins, days; gettimeofday(&now, NULL); timersub(&now, &start_time, &uptime); days = uptime.tv_sec/86400; uptime.tv_sec %= 86400; hours = uptime.tv_sec/3600; uptime.tv_sec %= 3600; mins = uptime.tv_sec/60; uptime.tv_sec %= 60; size += snprintf(&buf[size], bufsize-size, "Olsrd uptime: "); if (days) { size += snprintf(&buf[size], bufsize-size, "%d day(s) ", days); } size += snprintf(&buf[size], bufsize-size, "%02d hours %02d minutes %02d seconds
    \n", hours, mins, (int)uptime.tv_sec); } size += snprintf(&buf[size], bufsize-size, "HTTP stats(ok/dyn/error/illegal): %d/%d/%d/%d
    \n", stats.ok_hits, stats.dyn_hits, stats.err_hits, stats.ill_hits); size += snprintf(&buf[size], bufsize-size, "Click here to generate a configuration file for this node.\n"); size += snprintf(&buf[size], bufsize-size, "

    Variables

    \n"); size += snprintf(&buf[size], bufsize-size, "\n"); size += snprintf(&buf[size], bufsize-size, "\n", olsr_ip_to_string(&olsr_cnf->main_addr)); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->ip_version == AF_INET ? 4 : 6); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->debug_level); size += snprintf(&buf[size], bufsize-size, "\n\n"); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->pollrate); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->tc_redundancy); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->mpr_coverage); size += snprintf(&buf[size], bufsize-size, "\n\n"); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->lq_fish ? "Enabled" : "Disabled"); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->tos); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->rttable); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->willingness, olsr_cnf->willingness_auto ? "(auto)" : ""); size += snprintf(&buf[size], bufsize-size, "\n\n"); if (olsr_cnf->lq_level == 0) { size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->use_hysteresis ? "Enabled" : "Disabled"); if (olsr_cnf->use_hysteresis) { size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->hysteresis_param.scaling); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->hysteresis_param.thr_low, olsr_cnf->hysteresis_param.thr_high); } } size += snprintf(&buf[size], bufsize-size, "\n\n"); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->lq_level ? "Enabled" : "Disabled"); if (olsr_cnf->lq_level) { size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->lq_level); size += snprintf(&buf[size], bufsize-size, "\n", olsr_cnf->lq_wsize); } size += snprintf(&buf[size], bufsize-size, "
    Main address: %sIP version: %dDebug level: %d
    Pollrate: %0.2fTC redundancy: %dMPR coverage: %d
    Fisheye: %sTOS: 0x%04xRtTable: 0x%04xWillingness: %d %s
    Hysteresis: %sHyst scaling: %0.2fHyst lower/upper: %0.2f/%0.2f
    LQ extension: %sLQ level: %dLQ winsize: %d
    \n"); size += snprintf(&buf[size], bufsize-size, "

    Interfaces

    \n"); size += snprintf(&buf[size], bufsize-size, "\n"); for(ifs = olsr_cnf->interfaces; ifs; ifs = ifs->next) { struct interface *rifs = ifs->interf; size += snprintf(&buf[size], bufsize-size, "\n", ifs->name); if(!rifs) { size += snprintf(&buf[size], bufsize-size, "\n"); continue; } if(olsr_cnf->ip_version == AF_INET) { size += snprintf(&buf[size], bufsize-size, "\n", sockaddr_to_string(&rifs->int_addr)); size += snprintf(&buf[size], bufsize-size, "\n", sockaddr_to_string(&rifs->int_netmask)); size += snprintf(&buf[size], bufsize-size, "\n", sockaddr_to_string(&rifs->int_broadaddr)); size += snprintf(&buf[size], bufsize-size, "\n", rifs->int_mtu); size += snprintf(&buf[size], bufsize-size, "\n", rifs->is_wireless ? "Yes" : "No"); size += snprintf(&buf[size], bufsize-size, "\n"); } else { size += snprintf(&buf[size], bufsize-size, "\n", olsr_ip_to_string((union olsr_ip_addr *)&rifs->int6_addr.sin6_addr)); size += snprintf(&buf[size], bufsize-size, "\n", olsr_ip_to_string((union olsr_ip_addr *)&rifs->int6_multaddr.sin6_addr)); size += snprintf(&buf[size], bufsize-size, "\n"); size += snprintf(&buf[size], bufsize-size, "\n", rifs->int_mtu); size += snprintf(&buf[size], bufsize-size, "\n", rifs->is_wireless ? "Yes" : "No"); size += snprintf(&buf[size], bufsize-size, "\n"); } } size += snprintf(&buf[size], bufsize-size, "
    %s
    Status: DOWN
    IP: %sMASK: %sBCAST: %s
    MTU: %dWLAN: %sSTATUS: UP
    IP: %sMCAST: %s
    MTU: %dWLAN: %sSTATUS: UP
    \n"); if(olsr_cnf->allow_no_interfaces) size += snprintf(&buf[size], bufsize-size, "Olsrd is configured to run even if no interfaces are available
    \n"); else size += snprintf(&buf[size], bufsize-size, "Olsrd is configured to halt if no interfaces are available
    \n"); size += snprintf(&buf[size], bufsize-size, "

    Plugins

    \n"); size += snprintf(&buf[size], bufsize-size, "\n"); for(pentry = olsr_cnf->plugins; pentry; pentry = pentry->next) { size += snprintf(&buf[size], bufsize-size, "\n", pentry->name); size += snprintf(&buf[size], bufsize-size, "\n"); } size += snprintf(&buf[size], bufsize-size, "
    NameParameters
    %s
    \n"); size += section_title(&buf[size], bufsize-size, "Announced HNA entries"); if((olsr_cnf->ip_version == AF_INET) && (olsr_cnf->hna4_entries)) { struct hna4_entry *hna4; size += snprintf(&buf[size], bufsize-size, "NetworkNetmask\n"); for(hna4 = olsr_cnf->hna4_entries; hna4; hna4 = hna4->next) { size += snprintf(&buf[size], bufsize-size, "%s%s\n", olsr_ip_to_string(&hna4->net), olsr_ip_to_string(&hna4->netmask)); } } else if((olsr_cnf->ip_version == AF_INET6) && (olsr_cnf->hna6_entries)) { struct hna6_entry *hna6; size += snprintf(&buf[size], bufsize-size, "NetworkPrefix length\n"); for(hna6 = olsr_cnf->hna6_entries; hna6; hna6 = hna6->next) { size += snprintf(&buf[size], bufsize-size, "%s%d\n", olsr_ip_to_string(&hna6->net), hna6->prefix_len); } } size += snprintf(&buf[size], bufsize-size, "\n"); return size; } static int build_neigh_body(char *buf, olsr_u32_t bufsize) { struct neighbor_entry *neigh; struct neighbor_2_list_entry *list_2; struct link_entry *link = NULL; int size = 0, index, thop_cnt; size += section_title(&buf[size], bufsize-size, "Links"); size += snprintf(&buf[size], bufsize-size, "Local IPRemote IPHysteresis\n"); if (olsr_cnf->lq_level > 0) { size += snprintf(&buf[size], bufsize-size, "LinkQualitylosttotalNLQETX\n"); } size += snprintf(&buf[size], bufsize-size, "\n"); /* Link set */ link = link_set; while(link) { size += snprintf(&buf[size], bufsize-size, ""); size += build_ipaddr_with_link(&buf[size], bufsize, &link->local_iface_addr, -1); size += build_ipaddr_with_link(&buf[size], bufsize, &link->neighbor_iface_addr, -1); size += snprintf(&buf[size], bufsize-size, "%0.2f", link->L_link_quality); if (olsr_cnf->lq_level > 0) { size += snprintf(&buf[size], bufsize-size, "%0.2f" "%d" "%d" "%0.2f" "%0.2f\n", link->loss_link_quality, link->lost_packets, link->total_packets, link->neigh_link_quality, (link->loss_link_quality * link->neigh_link_quality) ? 1.0 / (link->loss_link_quality * link->neigh_link_quality) : 0.0); } size += snprintf(&buf[size], bufsize-size, "\n"); link = link->next; } size += snprintf(&buf[size], bufsize-size, "\n"); size += section_title(&buf[size], bufsize-size, "Neighbors"); size += snprintf(&buf[size], bufsize-size, "IP addressSYMMPRMPRSWillingness2 Hop Neighbors\n"); /* Neighbors */ for(index=0;indexnext) { size += snprintf(&buf[size], bufsize-size, ""); size += build_ipaddr_with_link(&buf[size], bufsize, &neigh->neighbor_main_addr, -1); size += snprintf(&buf[size], bufsize-size, "%s" "%s" "%s" "%d", (neigh->status == SYM) ? "YES" : "NO", neigh->is_mpr ? "YES" : "NO", olsr_lookup_mprs_set(&neigh->neighbor_main_addr) ? "YES" : "NO", neigh->willingness); size += snprintf(&buf[size], bufsize-size, " (%d)\n", thop_cnt); } } size += snprintf(&buf[size], bufsize-size, "\n"); return size; } static int build_topo_body(char *buf, olsr_u32_t bufsize) { int size = 0; struct tc_entry *tc; size += section_title(&buf[size], bufsize-size, "Topology Entries"); size += snprintf(&buf[size], bufsize-size, "Destination IPLast Hop IP"); if (olsr_cnf->lq_level > 0) { size += snprintf(&buf[size], bufsize-size, "LQILQETX"); } size += snprintf(&buf[size], bufsize-size, "\n"); OLSR_FOR_ALL_TC_ENTRIES(tc) { struct tc_edge_entry *tc_edge; OLSR_FOR_ALL_TC_EDGE_ENTRIES(tc, tc_edge) { size += snprintf(&buf[size], bufsize-size, ""); size += build_ipaddr_with_link(&buf[size], bufsize, &tc_edge->T_dest_addr, -1); size += build_ipaddr_with_link(&buf[size], bufsize, &tc->addr, -1); if (olsr_cnf->lq_level > 0) { const double d = tc_edge->link_quality * tc_edge->inverse_link_quality; size += snprintf(&buf[size], bufsize-size, "%0.2f" "%0.2f" "%0.2f\n", tc_edge->link_quality, tc_edge->inverse_link_quality, d ? 1.0 / d : 0.0); } size += snprintf(&buf[size], bufsize-size, "\n"); } OLSR_FOR_ALL_TC_EDGE_ENTRIES_END(tc, tc_edge); } OLSR_FOR_ALL_TC_ENTRIES_END(tc); size += snprintf(&buf[size], bufsize-size, "\n"); return size; } static int build_mid_body(char *buf, olsr_u32_t bufsize) { int size = 0; olsr_u8_t index; size += section_title(&buf[size], bufsize-size, "MID Entries"); size += snprintf(&buf[size], bufsize-size, "Main AddressAliases\n"); /* MID */ for(index = 0;index < HASHSIZE; index++) { struct mid_entry *entry = mid_set[index].next; while(entry != &mid_set[index]) { int mid_cnt; struct mid_address *alias; size += snprintf(&buf[size], bufsize-size, ""); size += build_ipaddr_with_link(&buf[size], bufsize, &entry->main_addr, -1); size += snprintf(&buf[size], bufsize-size, " (%d)\n", mid_cnt); entry = entry->next; } } size += snprintf(&buf[size], bufsize-size, "\n"); return size; } static int build_nodes_body(char *buf, olsr_u32_t bufsize) { int size = 0; size += build_neigh_body(&buf[size], bufsize-size); size += build_topo_body(&buf[size], bufsize-size); size += build_mid_body(&buf[size], bufsize-size); return size; } static int build_all_body(char *buf, olsr_u32_t bufsize) { int size = 0; size += build_config_body(&buf[size], bufsize-size); size += build_routes_body(&buf[size], bufsize-size); size += build_neigh_body(&buf[size], bufsize-size); size += build_topo_body(&buf[size], bufsize-size); size += build_mid_body(&buf[size], bufsize-size); return size; } static int build_about_body(char *buf, olsr_u32_t bufsize) { return snprintf(buf, bufsize, about_frame, build_date, build_host); } static int build_cfgfile_body(char *buf, olsr_u32_t bufsize) { int size = 0, i = 0; while(cfgfile_body[i] && strcmp(cfgfile_body[i], "")) { size += snprintf(&buf[size], bufsize-size, cfgfile_body[i]); i++; } #ifdef NETDIRECT { /* Hack to make netdirect stuff work with olsrd_write_cnf_buf */ char tmpBuf[10000]; size = olsrd_write_cnf_buf(olsr_cnf, tmpBuf, 10000); snprintf(&buf[size], bufsize-size, tmpBuf); } #else size += olsrd_write_cnf_buf(olsr_cnf, &buf[size], bufsize-size); #endif if(size < 0) { size = snprintf(buf, size, "ERROR GENERATING CONFIGFILE!\n"); } i++; while(cfgfile_body[i]) { size += snprintf(&buf[size], bufsize-size, cfgfile_body[i]); i++; } #if 0 printf("RETURNING %d\n", size); #endif return size; } static int check_allowed_ip(const struct allowed_net * const allowed_nets, const union olsr_ip_addr * const addr) { const struct allowed_net *alln; for (alln = allowed_nets; alln != NULL; alln = alln->next) { if((addr->v4 & alln->mask.v4) == (alln->net.v4 & alln->mask.v4)) { return 1; } } return 0; } #if 0 /* * In a bigger mesh, there are probs with the fixed * bufsize. Because the Content-Length header is * optional, the sprintf() is changed to a more * scalable solution here. */ int netsprintf(char *str, const char* format, ...) { va_list arg; int rv; va_start(arg, format); rv = vsprintf(str, format, arg); va_end(arg); if (0 != netsprintf_direct) { if (0 == netsprintf_error) { if (0 > send(client_sockets[curr_clients], str, rv, 0)) { olsr_printf(1, "(HTTPINFO) Failed sending data to client!\n"); netsprintf_error = 1; } } return 0; } return rv; } #endif static ssize_t writen(int fd, const void *buf, size_t count) { size_t bytes_left = count; const char *p = buf; while (bytes_left > 0) { const ssize_t written = write(fd, p, bytes_left); if (written == -1) { /* error */ if (errno == EINTR ) { continue; } return -1; } /* We wrote something */ bytes_left -= written; p += written; } return count; }