/****************************************************************** * $Id: nanohttp-admin.c,v 1.12 2007/01/01 22:54:46 m0gg Exp $ * * CSOAP Project: A SOAP client/server library in C * Copyright (C) 2003 Ferhat Ayaz * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Library General Public * License as published by the Free Software Foundation; either * version 2 of the License, or (at your option) any later version. * * This library 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 * Library General Public License for more details. * * You should have received a copy of the GNU Library General Public * License along with this library; if not, write to the * Free Software Foundation, Inc., 59 Temple Place - Suite 330, * Boston, MA 02111-1307, USA. * * Email: ayaz@jprogrammer.net ******************************************************************/ #ifdef HAVE_CONFIG_H #include #endif #ifdef HAVE_SYS_TIME_H #include #endif #ifdef HAVE_STDIO_H #include #endif #ifdef HAVE_STRING_H #include #endif #ifdef HAVE_PTHREAD_H #include #endif #include "nanohttp-error.h" #include "nanohttp-common.h" #include "nanohttp-stream.h" #include "nanohttp-request.h" #include "nanohttp-server.h" #include "nanohttp-admin.h" static void _httpd_admin_send_title(httpd_conn_t *conn, const char *title) { httpd_send_header(conn, 200, HTTP_STATUS_200_REASON_PHRASE); http_output_stream_write_string(conn->out, "" ""); http_output_stream_write_string(conn->out, ""); http_output_stream_write_string(conn->out, "" "" "nhttpd "); http_output_stream_write_string(conn->out, title); http_output_stream_write_string(conn->out, "
"); return; } static inline void _httpd_admin_send_footer(httpd_conn_t *conn) { http_output_stream_write_string(conn->out, "" ""); return; } static void _httpd_admin_list_services(httpd_conn_t *conn) { char buffer[1024]; hservice_t *node; _httpd_admin_send_title(conn, "Available services"); http_output_stream_write_string(conn->out, "
    "); for (node = httpd_get_services(); node; node = node->next) { switch (node->status) { case NHTTPD_SERVICE_DOWN: sprintf(buffer, "
  • " "%s " "[Activate] " "[Statistics]" "
    • ", node->context, node->context, node->context, node->context); break; case NHTTPD_SERVICE_UP: default: sprintf(buffer, "
  • " "%s " "[Passivate] " "[Statistics] " "
    • ", node->context, node->context, node->context, node->context); break; } http_output_stream_write_string(conn->out, buffer); } http_output_stream_write_string(conn->out, "
"); _httpd_admin_send_footer(conn); return; } static void _httpd_admin_list_statistics(httpd_conn_t *conn, const char *service_name) { char buffer[1024]; hservice_t *service; sprintf(buffer, "Listing statistics for service %s", service_name); _httpd_admin_send_title(conn, buffer); if (!(service = httpd_find_service(service_name))) { http_output_stream_write_string(conn->out, "

" "Service not found!" "

"); _httpd_admin_send_footer(conn); return; } pthread_rwlock_rdlock(&(service->statistics->lock)); sprintf(buffer, "
    " "
  • Requests served: %lu
    • " "
  • Bytes read: %lu
    • " "
  • Bytes sent: %lu
    • " "
  • Time used: %li.%li sec
    • " "
      ", service->statistics->requests, service->statistics->bytes_received, service->statistics->bytes_transmitted, service->statistics->time.tv_sec, service->statistics->time.tv_usec); pthread_rwlock_unlock(&(service->statistics->lock)); http_output_stream_write_string(conn->out, buffer); _httpd_admin_send_footer(conn); return; } static void _httpd_admin_enable_service(httpd_conn_t *conn, const char *service_name) { hservice_t *service; char buffer[1024]; sprintf(buffer, "Activating service %s", service_name); _httpd_admin_send_title(conn, buffer); if (!(service = httpd_find_service(service_name))) { http_output_stream_write_string(conn->out, "

      " "Service not found!" "

      "); _httpd_admin_send_footer(conn); return; } httpd_enable_service(service); http_output_stream_write_string(conn->out, "

      " "Service is up" "

      "); _httpd_admin_send_footer(conn); return; } static void _httpd_admin_disable_service(httpd_conn_t *conn, const char *service_name) { hservice_t *service; char buffer[1024]; sprintf(buffer, "Passivating service %s", service_name); _httpd_admin_send_title(conn, buffer); if (!(service = httpd_find_service(service_name))) { http_output_stream_write_string(conn->out, "

      " "Service not found!" "

      "); _httpd_admin_send_footer(conn); return; } httpd_disable_service(service); http_output_stream_write_string(conn->out, "

      " "Service is down" "

      "); _httpd_admin_send_footer(conn); return; } static void _httpd_admin_handle_get(httpd_conn_t * conn, struct hrequest_t *req) { char *param; if ((param = hpairnode_get_ignore_case(req->query, NHTTPD_ADMIN_QUERY_SERVICES))) { _httpd_admin_list_services(conn); } else if ((param = hpairnode_get_ignore_case(req->query, NHTTPD_ADMIN_QUERY_STATISTICS))) { _httpd_admin_list_statistics(conn, param); } else if ((param = hpairnode_get_ignore_case(req->query, NHTTPD_ADMIN_QUERY_ACTIVATE_SERVICE))) { _httpd_admin_enable_service(conn, param); } else if ((param = hpairnode_get_ignore_case(req->query, NHTTPD_ADMIN_QUERY_PASSIVATE_SERVICE))) { _httpd_admin_disable_service(conn, param); } else { _httpd_admin_send_title(conn, "Welcome to the admin site"); http_output_stream_write_string(conn->out, ""); _httpd_admin_send_footer(conn); } return; } static void _httpd_admin_entry(httpd_conn_t * conn, struct hrequest_t *req) { if (req->method == HTTP_REQUEST_GET) { _httpd_admin_handle_get(conn, req); } else { httpd_send_header(conn, 501, HTTP_STATUS_501_REASON_PHRASE); http_output_stream_write_string(conn->out, "" "" "" "" "

      Sorry!

      " "
      " "
      POST Service is not implemented now. Use your browser.
      " "" ""); } return; } herror_t httpd_admin_init_args(int argc, char **argv) { int i; for (i=0; i