fg_rpc_server.h File Reference

RPCServer related functions and structs used by the Flowgrind daemon. More...

#include "config.h"
#include <stdlib.h>
#include <stdint.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netdb.h>
#include <netinet/tcp.h>
#include <xmlrpc-c/base.h>
#include <xmlrpc-c/server.h>
#include <xmlrpc-c/server_abyss.h>
#include <xmlrpc-c/util.h>

Go to the source code of this file.

Data Structures
struct	fg_rpc_server
	Information about the daemons XMLrpc server. More...

Functions
void	init_rpc_server (struct fg_rpc_server *server, char *rpc_bind_addr, unsigned port)
	Initializes the xmlrpc server. More...
void	run_rpc_server (struct fg_rpc_server *server)
	Enters the xmlrpc server mainloop. More...

Detailed Description

RPCServer related functions and structs used by the Flowgrind daemon.

Definition in file fg_rpc_server.h.

Function Documentation

init_rpc_server()

void init_rpc_server	(	struct fg_rpc_server *	server,
		char *	rpc_bind_addr,
		unsigned	port
	)

Initializes the xmlrpc server.

This function initializes the xmlrpc environment, registers exported methods and binds to the control port.

Definition at line 835 of file fg_rpc_server.c.

{
        xmlrpc_registry * registryP;
        xmlrpc_env *env = &(server->env);
        memset(&(server->parms), 0, sizeof(server->parms));
 
        xmlrpc_env_init(env);
        registryP = xmlrpc_registry_new(env);
 
        xmlrpc_registry_add_method(env, registryP, NULL, "add_flow_destination", &add_flow_destination, NULL);
        xmlrpc_registry_add_method(env, registryP, NULL, "add_flow_source", &add_flow_source, NULL);
        xmlrpc_registry_add_method(env, registryP, NULL, "start_flows", &start_flows, NULL);
        xmlrpc_registry_add_method(env, registryP, NULL, "get_reports", &method_get_reports, NULL);
        xmlrpc_registry_add_method(env, registryP, NULL, "stop_flow", &method_stop_flow, NULL);
        xmlrpc_registry_add_method(env, registryP, NULL, "get_version", &method_get_version, NULL);
        xmlrpc_registry_add_method(env, registryP, NULL, "get_status", &method_get_status, NULL);
        xmlrpc_registry_add_method(env, registryP, NULL, "get_uuid", &method_get_uuid, NULL);
 
        /* In the modern form of the Abyss API, we supply parameters in memory
           like a normal API.  We select the modern form by setting
           config_file_name to NULL:
        */
        server->parms.config_file_name  = NULL;
        server->parms.registryP         = registryP;
        server->parms.socket_bound      = 1;
        server->parms.log_file_name     = NULL; /*"/tmp/xmlrpc_log";*/
 
        /* Increase HTTP keep-alive duration. Using defaults the amount of
         * sockets in TIME_WAIT state would become too high.
         */
        server->parms.keepalive_timeout = 60;
        server->parms.keepalive_max_conn = 1000;
 
        /* Disable introspection */
        server->parms.dont_advertise = 1;
 
        logging(LOG_NOTICE, "running XML-RPC server on port %u", port);
        printf("Running XML-RPC server...\n");
 
        server->parms.socket_handle = bind_rpc_server(rpc_bind_addr, port);
}

run_rpc_server()

void run_rpc_server

(

struct fg_rpc_server *

server

)

Enters the xmlrpc server mainloop.

Definition at line 878 of file fg_rpc_server.c.

{
        xmlrpc_env *env = &(server->env);
        xmlrpc_server_abyss(env, &(server->parms), XMLRPC_APSIZE(socket_handle));
 
        if (env->fault_occurred)
                logging(LOG_ALERT, "XML-RPC Fault: %s (%d)", env->fault_string,
                        env->fault_code);
        /* xmlrpc_server_abyss() never returns */
}