+++ /dev/null
-/*
- * @file protomod_urla.c
- * @brief protocol module of HTTP.
- * @brief this module provide session persistence by URL key.
- *
- * L7VSD: Linux Virtual Server for Layer7 Load Balancing
- * Copyright (C) 2008 NTT COMWARE Corporation.
- *
- * This program is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License as published by the Free Software Foundation; either
- * version 2.1 of the License, or (at your option) 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
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this library; if not, write to the Free Software
- * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA
- *
- **********************************************************************/
-
-#define __STDC_LIMIT_MACROS
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <time.h>
-#include <getopt.h>
-#include "l7vs_service.h"
-#include "l7vs_conn.h"
-#include "l7vs_dest.h"
-#include "l7vs_module.h"
-#include "module_http.h"
-#include <fnmatch.h>
-
-#include <iostream>
-#ifdef USE_BOOST_XPRESSIVE
- #include <boost/xpressive/xpressive.hpp>
-#else
- #include <boost/regex.hpp>
-#endif
-
-#define SERVICE_ARG_MAXSIZE (512)
-#define KEY_NAME_MAXSIZE (128)
-#define URLA_SERVICE_NUMBER (128)
-#define X_FORWARDED_FOR_LENGTH (48)
-
-struct l7vs_urla_service {
- handle_t service_handle;
- char key_name[KEY_NAME_MAXSIZE];
- int forwarded_for;
-#ifdef USE_BOOST_XPRESSIVE
- boost::xpressive::sregex key_name_regex;
-#else
- boost::regex key_name_regex;
-#endif
- int reschedule;
-};
-
-struct l7vs_urla_service_arg {
- char key_name[KEY_NAME_MAXSIZE];
- int forwarded_for;
- int reschedule;
-};
-
-static void fini(void);
-static int create(void*, handle_t);
-static void* create_sa(struct l7vs_service_arg*);
-static int compare(handle_t, handle_t);
-static int match_cldata(struct l7vs_service*, struct l7vs_conn*,
- char*, size_t*, struct l7vs_dest**, int*);
-static int analyze_rsdata(struct l7vs_service*, struct l7vs_conn*,
- char*, size_t*);
-static int destroy(handle_t);
-static void destroy_sa(void**);
-static int service_arg(struct l7vs_service_arg_multi*, handle_t);
-static int parse(void*, int, char**);
-
-static struct l7vs_urla_service *l7vs_protomod_urla_search_service(handle_t);
-static struct l7vs_urla_service *l7vs_protomod_urla_create_service();
-static struct l7vs_urla_service *l7vs_protomod_urla_create_temp_service();
-
-static void l7vs_urla_service_c_str(char*, struct l7vs_urla_service*);
-static void l7vs_urla_service_arg_c_str(char*, struct l7vs_urla_service_arg*);
-
-struct l7vs_urla_service *urla_service_list[URLA_SERVICE_NUMBER];
-
-static struct l7vs_protomod urla_protomod = {
- NULL, /* handle */
- "urla", /* modname */
- 0, /* refcnt */
- 0, /* fast schedule */
- create, /* create function */
- compare, /* compare function */
- match_cldata, /* match_cldata function */
- analyze_rsdata, /* analyze_rsdata function */
- destroy, /* destroy function */
- fini, /* fini function */
- create_sa, /* create_sa function */
- service_arg, /* service_arg function */
- parse, /* parse function */
- destroy_sa, /* destroy_sa function */
- NULL, /* initialize function */
- NULL, /* finalize function */
- NULL, /* get_log_level function */
- NULL, /* put_log_debug function */
- NULL, /* put_log_info function */
- NULL, /* put_log_warn function */
- NULL, /* put_log_error function */
- NULL /* put_log_fatal function */
-};
-
-/*!
- * Protocol module initialize function. This function run when dlopen and dlsym at first time.
- * @param[in] handle dlopen's handle
- * @return l7vs_protomod struct
- */
-extern "C" struct l7vs_protomod *
-init(void *handle)
-{
- struct l7vs_protomod* return_value = NULL;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,135,
- "in_function: struct l7vs_protomod* init(void* handle): handle=%p", handle);
- }
- /*------ DEBUG LOG END ------*/
-
- /* check null */
- if (handle == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,117, "Arg(handle) is NULL pointer.");
- goto init_out;
- }
-
- /* initialize urla service list */
- memset(urla_service_list, 0, sizeof(struct l7vs_urla_service *) * URLA_SERVICE_NUMBER);
- /* set dlopen's handle */
- urla_protomod.handle = handle;
-
- return_value = &urla_protomod;
-
-init_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char protomod_str[DEBUG_STR_LEN] = {0};
- l7vs_protomod_c_str(protomod_str, &urla_protomod);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,136,
- "out_function: struct l7vs_protomod* init(void* handle): return=&(%s)", protomod_str);
- }
- /*------ DEBUG LOG END ------*/
- return return_value;
-}
-
-/*!
- * Protocol module finalize function. free all urla service list just in case.
- * @param void
- * @return void
- */
-static void
-fini(void)
-{
- /* urla service list counter */
- int service_number = 0;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,137, "in_function: void fini(void)");
- }
- /*------ DEBUG LOG END ------*/
-
- /* check all urla service list */
- for (service_number = 0; service_number < URLA_SERVICE_NUMBER; ++service_number) {
- /* if pointer that does not point NULL exists ... */
- if (urla_service_list[service_number] != NULL) {
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_SYSTEM_MEMORY)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_SYSTEM_MEMORY,34, "free: %p",
- urla_service_list[service_number]);
- }
- /*------ DEBUG LOG END ------*/
-
- /* free and points NULL */
- free(urla_service_list[service_number]);
- urla_service_list[service_number] = NULL;
- }
- }
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,138, "out_function: void fini(void)");
- }
- /*------ DEBUG LOG END ------*/
-}
-
-/*!
- * Create urla service struct.
- * @param urla_arg urla service argument struct
- * @param service_handle a unique service ID
- * @retval 0 successfully create urla service.
- * @retval -1 some errors occur.
- */
-static int
-create(void *urla_arg, handle_t service_handle)
-{
- struct l7vs_urla_service *urla_service;
- struct l7vs_urla_service_arg *urla_service_arg;
- int return_value = 0;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char urla_arg_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_arg_c_str(urla_arg_str, (struct l7vs_urla_service_arg*) urla_arg);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,139,
- "in_function: int create(void* urla_arg, handle_t service_handle):urla_arg=&(%s), "
- "service_handle=%d", urla_arg_str, service_handle);
- }
- /*------ DEBUG LOG END ------*/
-
- /* check null */
- if (urla_arg == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,118, "Arg(urla_arg) is NULL pointer.");
- return_value = -1;
- goto create_out;
- }
-
- if (service_handle != TEMP_SERVICEHANDLE) {
- /* search empty urla service list and create urla service */
- urla_service = l7vs_protomod_urla_create_service();
- } else {
- /* create temporary urla service */
- urla_service = l7vs_protomod_urla_create_temp_service();
- }
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char urla_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_c_str(urla_str, urla_service);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,140, "pointer assign: urla_service=&(%s)",
- urla_str);
- }
- /*------ DEBUG LOG END ------*/
-
- if (urla_service == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,119, "Could not make urla service.");
- return_value = -1;
- goto create_out;
- }
-
- urla_service_arg = (struct l7vs_urla_service_arg *) urla_arg;
-
- /* set service handle, key name and reschedule flag */
- urla_service->service_handle = service_handle;
- urla_service->forwarded_for = urla_service_arg->forwarded_for;
- if ( strnlen(urla_service_arg->key_name, KEY_NAME_MAXSIZE) ) {
- try {
-#ifdef USE_BOOST_XPRESSIVE
- urla_service->key_name_regex = boost::xpressive::sregex::compile(urla_service_arg->key_name);
-#else
- urla_service->key_name_regex.assign(urla_service_arg->key_name);
-#endif
- }
- catch (...) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,284, "Regex pattern error of key_name");
- return_value = -1;
- goto create_out;
- }
- }
- urla_service->reschedule = urla_service_arg->reschedule;
-
-create_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,141,
- "out_function: int create(void* urla_arg, handle_t service_handle):return_value=%d",
- return_value);
- }
- /*------ DEBUG LOG END ------*/
-
- return return_value;
-}
-
-/*!
- * Create urla service argument struct.
- * @param[out] srv_arg service argument struct
- * @return urla service argument struct
- */
-static void *
-create_sa(struct l7vs_service_arg *srv_arg)
-{
- struct l7vs_urla_service_arg *urla_service_arg;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char service_arg_str[DEBUG_STR_LEN] = {0};
- l7vs_service_arg_c_str(service_arg_str, srv_arg);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,142,
- "in_function: void* create_sa(struct l7vs_service_arg* srv_arg):srv_arg=&(%s)",
- service_arg_str);
- }
- /*------ DEBUG LOG END ------*/
-
- /* check null */
- if (srv_arg == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,120, "Arg(srv_arg) is NULL pointer.");
- urla_service_arg = NULL;
- goto create_sa_out;
- }
-
- /* create urla service argument struct */
- urla_service_arg = (struct l7vs_urla_service_arg *) calloc(1, sizeof(struct l7vs_urla_service_arg));
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_SYSTEM_MEMORY)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_SYSTEM_MEMORY,35, "calloc: addr=%p, size=%ld",
- urla_service_arg, (unsigned long int) sizeof(struct l7vs_urla_service_arg));
- }
- /*------ DEBUG LOG END ------*/
-
- if (urla_service_arg == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_SYSTEM_MEMORY,27, "Could not allocate memory.");
- goto create_sa_out;
- }
-
- /* set urla service argument size and protomod name "urla" */
- srv_arg->len = sizeof(struct l7vs_urla_service_arg);
- strcpy(srv_arg->protomod, urla_protomod.modname);
-
-create_sa_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char urla_service_arg_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_arg_c_str(urla_service_arg_str, urla_service_arg);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,143,
- "out_function: void* create_sa(struct l7vs_service_arg* srv_arg):return_value=&(%s)",
- urla_service_arg_str);
- }
- /*------ DEBUG LOG END ------*/
-
- return (void*) urla_service_arg;
-}
-
-/*!
- * Compare two service.
- * @param[in] srv_handle1 one of a unique service ID
- * @param[in] srv_handle2 one of a unique service ID
- * @retval 0 they matched perfectly.
- * @retval -1 they are different.
- */
-static int
-compare(handle_t srv_handle1, handle_t srv_handle2)
-{
- struct l7vs_urla_service *urla_srv1, *urla_srv2;
- int return_value = 0;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,144,
- "in_function: int compare(handle_t srv_handle1, handle_t srv_handle2):"
- "srv_handle1=%u, srv_handle2=%u", srv_handle1, srv_handle2);
- }
- /*------ DEBUG LOG END ------*/
-
- /* search service that has such a service ID(1) */
- urla_srv1 = l7vs_protomod_urla_search_service(srv_handle1);
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char urla_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_c_str(urla_str, urla_srv1);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,145, "pointer assign: urla_srv1=&(%s)",
- urla_str);
- }
- /*------ DEBUG LOG END ------*/
-
- if (urla_srv1 == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,121,
- "Could not find such service handle's urla service.");
- return_value = -1;
- goto compare_out;
- }
-
- /* search service that has such a service ID(2) */
- urla_srv2 = l7vs_protomod_urla_search_service(srv_handle2);
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char urla_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_c_str(urla_str, urla_srv2);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,146, "pointer assign: urla_srv2=&(%s)",
- urla_str);
- }
- /*------ DEBUG LOG END ------*/
-
- if (urla_srv2 == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,122,
- "Could not find such service handle's urla service.");
- return_value = -1;
- goto compare_out;
- }
-
- /* compare two key name */
- if (strncmp(urla_srv1->key_name, urla_srv2->key_name, KEY_NAME_MAXSIZE) != 0) {
- return_value = -1;
- goto compare_out;
- }
-
-compare_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,147,
- "out_function: int compare(handle_t srv_handle1, handle_t srv_handle2):return_value=%d",
- return_value);
- }
- /*------ DEBUG LOG END ------*/
-
- return return_value;
-}
-
-/*!
- * Check the client packet and determine a real server.
- * @param[in] srv service struct include service handle, protocol module and schedule module.
- * @param[in] conn connection data.
- * @param[in] request packet data from client
- * @param[in] len length of packet data
- * @param[out] dest destination (real server) list
- * @param[out] tcps TCP Splicer flag
- * @retval 0 successfully check packet data
- * @retval -1 some errors occur.
- */
-static int
-match_cldata(struct l7vs_service *srv, struct l7vs_conn *conn,
- char *request, size_t *len, struct l7vs_dest **dest, int *tcps)
-{
- struct l7vs_urla_service *urla_service;
- int ret;
- int i;
- size_t key_name_len;
- char *location, pattern[PATTERN_MATCH_MAXSIZE + 2];
- int offset_length;
- char *x_forwarded_value;
- char *next_line = NULL;
- char x_forwarded_for_header[X_FORWARDED_FOR_LENGTH];
- char backup_char;
- int return_value = 0;
-
- std::string packet_data;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char srv_str[DEBUG_STR_LEN] = {0};
- char conn_str[DEBUG_STR_LEN] = {0};
- char dest_str[DEBUG_STR_LEN] = {0};
- char len_str[DEBUG_STR_LEN] = {0};
- char tcps_str[DEBUG_STR_LEN] = {0};
- l7vs_service_c_str(srv_str, srv);
- l7vs_conn_c_str(conn_str, conn);
- if (dest != NULL) {
- l7vs_dest_c_str(dest_str, *dest);
- }
- else {
- strncpy(dest_str, "NULL", DEBUG_STR_LEN);
- }
- if (len != NULL) {
- snprintf(len_str, DEBUG_STR_LEN, "%lu", (unsigned long int) *len);
- }
- else {
- strncpy(len_str, "NULL", DEBUG_STR_LEN);
- }
- if (tcps != NULL) {
- snprintf(tcps_str, DEBUG_STR_LEN, "%d", *tcps);
- }
- else {
- strncpy(tcps_str, "NULL", DEBUG_STR_LEN);
- }
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,148,
- "in_function: int match_cldata(struct l7vs_service* srv, struct l7vs_conn* conn, "
- "char* request, size_t* len, struct l7vs_dest** dest, int* tcps):srv=&(%s), conn=&(%s), "
- "request=\"%s\", len=&(%s), dest=&(&(%s)), tcps=&(%s)",
- srv_str, conn_str, request, len_str, dest_str, tcps_str);
- }
- /*------ DEBUG LOG END ------*/
-
- /* check null */
- if (srv == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,123, "Arg(srv) is NULL pointer.");
- return_value = -1;
- goto match_cldata_out;
- }
- if (srv->pm == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,124, "Arg(srv->pm) is NULL pointer.");
- return_value = -1;
- goto match_cldata_out;
- }
- if (request == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,125, "Arg(request) is NULL pointer.");
- return_value = -1;
- goto match_cldata_out;
- }
- if (len == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,126, "Arg(len) is NULL pointer.");
- return_value = -1;
- goto match_cldata_out;
- }
- if (dest == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,127, "Arg(dest) is NULL pointer.");
- return_value = -1;
- goto match_cldata_out;
- }
- if (tcps == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,128, "Arg(tcps) is NULL pointer.");
- return_value = -1;
- goto match_cldata_out;
- }
-
- /* search service that has such a service ID */
- urla_service = l7vs_protomod_urla_search_service(srv->handle);
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char urla_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_c_str(urla_str, urla_service);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,149, "pointer assign: urla_service=&(%s)",
- urla_str);
- }
- /*------ DEBUG LOG END ------*/
-
- if (urla_service == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,129, "Could not find such service handle's urla service.");
- return_value = -1;
- goto match_cldata_out;
- }
-
- /* initialize protocol module ... clear destination list */
- ret = srv->pm->initialize(srv, conn, request, *len, dest);
- if (ret != 0) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,130, "Could not initialize protomod.");
- return_value = -1;
- goto match_cldata_out;
- }
-
- /* check key_name length */
- if (urla_service->key_name[0] == '\0') {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,131, "key name is NULL pointer");
- return_value = -1;
- goto match_cldata_out;
- }
-
- /* check the size of request data */
- key_name_len = strnlen(urla_service->key_name, KEY_NAME_MAXSIZE);
- if (*len < (15 + key_name_len) ) {
- PUT_LOG_INFO(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,6, "Request data is too short.");
- return_value = 1;
- goto match_cldata_out;
- }
-
- /* check the HTTP method in HTTP request header */
- uri_len = *len;
- uri = http_check_request_method(request, &uri_len);
- if (uri == NULL) {
- PUT_LOG_INFO(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,7, "Client message is not HTTP request.");
- return_value = 1;
- goto match_cldata_out;
- }
-
- /* check key name */
- packet_data = std::string(uri, uri_len);
-#ifdef USE_BOOST_XPRESSIVE
- if ( !boost::xpressive::regex_search(packet_data, urla_service->key_name_regex) ) {
-#else
- if ( !boost::regex_search(packet_data, urla_service->key_name_regex) ) {
-#endif
- return_value = -1;
- goto match_cldata_out;
- }
- }
-
- /* add X-Forwarded-For field */
- if (urla_service->forwarded_for) {
- x_forwarded_value = http_search_header_field(request, "X-Forwarded-For");
-
- /* already exists X-Forwarded-For field */
- if (x_forwarded_value) {
- next_line = http_skip_header_line(x_forwarded_value);
- /* backtrack to look up insert point */
- if (next_line) {
- next_line--; // *next_line == '\n'
- if (*(next_line - 1) == '\r') {
- next_line--;
- }
- /* append client IP address */
- snprintf(x_forwarded_for_header, X_FORWARDED_FOR_LENGTH, ", %s", inet_ntoa(conn->caddr.sin_addr));
- }
- }
-
- /* not exists X-Forwarded-For field */
- if (!next_line) {
- /* construct new X-Forwarded-For header item */
- snprintf(x_forwarded_for_header, X_FORWARDED_FOR_LENGTH, "X-Forwarded-For: %s\r\n", inet_ntoa(conn->caddr.sin_addr));
-
- next_line = http_skip_header_line(request);
- }
-
- /* when insert point exist */
- if (next_line != NULL) {
- offset_length = (int) (next_line - request);
-
- /* insert X-Forwarded-For header field */
- http_insert_field(request, offset_length, x_forwarded_for_header, *len);
-
- /* add header length */
- *len += strlen(x_forwarded_for_header);
- }
- }
-
- *tcps = 0;
-
- /* finalize */
- ret = srv->pm->finalize(srv, conn, request, *len, dest, urla_service->reschedule);
- if (ret != 0) {
- PUT_LOG_INFO(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,12, "Could not finalize protomod. (Realserver decision failure)");
- return_value = -1;
- goto match_cldata_out;
- }
-
-match_cldata_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,150,
- "out_function: int match_cldata(struct l7vs_service* srv, struct l7vs_conn* conn, "
- "char* request, size_t* len, struct l7vs_dest** dest, int* tcps):return_value=%d",
- return_value);
- }
- /*------ DEBUG LOG END ------*/
-
- return return_value;
-}
-
-/*!
- * Check the real server packet and insert a Set-Cookie field.
- * @param[in] srv service struct include service handle, protocol module and schedule module.
- * @param[in] conn connection data.
- * @param[in] response packet data from real server
- * @param[in] len length of packet data. it will be lengthened.
- * @retval 0 successfully check packet data.
- * @retval -1 some errors occur.
- */
-static int
-analyze_rsdata(struct l7vs_service *srv, struct l7vs_conn *conn,
- char *response, size_t *len)
-{
- int return_value = 0;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char srv_str[DEBUG_STR_LEN] = {0};
- char conn_str[DEBUG_STR_LEN] = {0};
- char len_str[DEBUG_STR_LEN] = {0};
- l7vs_service_c_str(srv_str, srv);
- l7vs_conn_c_str(conn_str, conn);
- if (len != NULL) {
- snprintf(len_str, DEBUG_STR_LEN, "%lu", (unsigned long int) *len);
- }
- else {
- strncpy(len_str, "NULL", DEBUG_STR_LEN);
- }
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,151,
- "in_function: int analyze_rsdata(struct l7vs_service* srv, struct l7vs_conn* conn, "
- "char* response, size_t* len):srv=&(%s), conn=&(%s), response=\"%s\", len=&(%s)",
- srv_str, conn_str, response, len_str);
- }
- /*------ DEBUG LOG END ------*/
-
- /* check null */
- if (srv == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,133, "Arg(srv) is NULL pointer.");
- return_value = -1;
- goto analyze_rsdata_out;
- }
- if (conn == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,134, "Arg(conn) is NULL pointer.");
- return_value = -1;
- goto analyze_rsdata_out;
- }
- if (conn->dest == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,135, "Arg(conn->dest) is NULL pointer.");
- return_value = -1;
- goto analyze_rsdata_out;
- }
- if (response == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,136, "Arg(response) is NULL pointer.");
- return_value = -1;
- goto analyze_rsdata_out;
- }
- if (len == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,137, "Arg(len) is NULL pointer.");
- return_value = -1;
- goto analyze_rsdata_out;
- }
-
- /* sorry flag check */
- if (conn->sorry_conn_flag == 1) {
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,152, "Response from sorry server.");
- }
- /*------ DEBUG LOG END ------*/
- goto analyze_rsdata_out;
- }
-
- /* search Location header field */
- location = http_search_header_field(request, "Location");
- if (location != NULL) {
- }
-
-analyze_rsdata_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,153,
- "out_function: int analyze_rsdata(struct l7vs_service* srv, struct l7vs_conn* conn, "
- "char* response, size_t* len):return_value=%d", return_value);
- }
- /*------ DEBUG LOG END ------*/
-
- return return_value;
-}
-
-/*!
- * Destroy urla service
- * @param[in] srv_handle a unique service ID
- * @retval 0 successfully check packet data.
- * @retval -1 some errors occur.
- */
-static int
-destroy(handle_t srv_handle)
-{
- /* urla service list counter */
- int service_number = 0;
- int free_flag = 0;
- int return_value = 0;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,154,
- "in_function: int destroy(handle_t srv_handle):srv_handle=%u",
- srv_handle);
- }
- /*------ DEBUG LOG END ------*/
-
- /* check all urla service list */
- for (service_number = 0; service_number < URLA_SERVICE_NUMBER; ++service_number) {
- /* found urla service that has srv_handle */
- if (urla_service_list[service_number] != NULL &&
- urla_service_list[service_number]->service_handle == srv_handle) {
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_SYSTEM_MEMORY)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_SYSTEM_MEMORY,36, "free: %p",
- urla_service_list[service_number]);
- }
- /*------ DEBUG LOG END ------*/
-
- /* free and NULL */
- free(urla_service_list[service_number]);
- urla_service_list[service_number] = NULL;
-
- free_flag = 1;
- break;
- }
- }
-
- /* urla service was not found */
- if (free_flag == 0) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,138, "Could not find such service handle's urla service.");
- return_value = -1;
- goto destroy_out;
- }
-
-destroy_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,155,
- "out_function: int destroy(handle_t srv_handle):return_value=%d",
- srv_handle);
- }
- /*------ DEBUG LOG END ------*/
-
- return return_value;
-}
-
-/*!
- * Destroy urla service argument
- * @param[in] urla_arg urla service argument
- * @return void
- */
-static void
-destroy_sa(void **urla_arg)
-{
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char urla_arg_str[DEBUG_STR_LEN] = {0};
- if (urla_arg != NULL) {
- l7vs_urla_service_arg_c_str(urla_arg_str, (struct l7vs_urla_service_arg*) *urla_arg);
- }
- else {
- strncpy(urla_arg_str, "NULL", DEBUG_STR_LEN);
- }
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,156,
- "in_function: void destroy_sa(void** urla_arg):urla_arg=&(&(%s))",
- urla_arg_str);
- }
- /*------ DEBUG LOG END ------*/
-
- /* check null */
- if (urla_arg == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,139, "Arg(urla_arg) is NULL pointer.");
- }
- else if (*urla_arg == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,140, "Arg(*urla_arg) is NULL pointer.");
- }
- else {
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_SYSTEM_MEMORY)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_SYSTEM_MEMORY,37, "free: %p",
- *urla_arg);
- }
- /*------ DEBUG LOG END ------*/
-
- /* free and NULL */
- free((struct l7vs_urla_service_arg*) *urla_arg);
- *urla_arg = NULL;
- }
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,157,
- "out_function: void destroy_sa(void** urla_arg)");
- }
- /*------ DEBUG LOG END ------*/
-}
-
-/*!
- * Create strings for service list of l7vsadm
- * @param srv_arg service argument struct
- * @param srv_handle a unique service ID
- * @retval 0 successfully create strings
- * @retval -1 some errors occur.
- */
-static int
-service_arg(struct l7vs_service_arg_multi *srv_arg_mt, handle_t srv_handle)
-{
- struct l7vs_urla_service *urla_service;
- struct l7vs_urla_service_arg c_sarg;
- char urla_argument[SERVICE_ARG_MAXSIZE];
- int return_value = 0;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char srv_arg_mt_str[DEBUG_STR_LEN] = {0};
- l7vs_service_arg_multi_c_str(srv_arg_mt_str, srv_arg_mt);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,158,
- "in_function: int service_arg(struct l7vs_service_arg_multi* srv_arg_mt, "
- "handle_t srv_handle):srv_arg_mt=&(%s), srv_handle=%u",
- srv_arg_mt_str, srv_handle);
- }
- /*------ DEBUG LOG END ------*/
-
- /* check null */
- if (srv_arg_mt == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,141, "Arg(srv_arg_mt) is NULL pointer.");
- return_value = -1;
- goto service_arg_out;
- }
-
- /* search service that has such a service ID */
- urla_service = l7vs_protomod_urla_search_service(srv_handle);
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char urla_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_c_str(urla_str, urla_service);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,159, "pointer assign: urla_service=&(%s)",
- urla_str);
- }
- /*------ DEBUG LOG END ------*/
-
- if (urla_service == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,142, "Could not find such service handle's urla service.");
- return_value = -1;
- goto service_arg_out;
- }
-
- /* initialize argument strings */
- memset(urla_argument, 0, SERVICE_ARG_MAXSIZE);
-
- /* set urla args to service argument struct */
- srv_arg_mt->srv_arg.reschedule = urla_service->reschedule;
-
- /* create long argument (l7vsadm option -L/-l) */
- if ( strnlen(urla_service->pattern_match, PATTERN_MATCH_MAXSIZE) ) {
- snprintf(urla_argument, SERVICE_ARG_MAXSIZE, "--pattern-match %s", urla_service->pattern_match);
- }
- if ( strnlen(urla_service->uri_pattern_match, REGEX_PATTERN_MATCH_MAXSIZE) ) {
- snprintf(urla_argument + strlen(urla_argument), SERVICE_ARG_MAXSIZE - strlen(urla_argument),
- " --uri-pattern-match %s", urla_service->uri_pattern_match);
- }
- if ( strnlen(urla_service->host_pattern_match, REGEX_PATTERN_MATCH_MAXSIZE) ) {
- snprintf(urla_argument + strlen(urla_argument), SERVICE_ARG_MAXSIZE - strlen(urla_argument),
- " --host-pattern-match %s", urla_service->host_pattern_match);
- }
- strncpy(srv_arg_mt->srv_arg.protomod_key_string, urla_argument, 256);
-
- /* create verbose argument (l7vsadm option -V/-v) */
- if (urla_service->forwarded_for) {
- snprintf(urla_argument + strlen(urla_argument), SERVICE_ARG_MAXSIZE - strlen(urla_argument),
- " --forwarded-for");
- }
- strncpy(srv_arg_mt->srv_arg.protomod_opt_string, urla_argument, 512);
-
- strncpy(c_sarg.pattern_match, urla_service->pattern_match, PATTERN_MATCH_MAXSIZE);
- strncpy(c_sarg.uri_pattern_match, urla_service->uri_pattern_match, REGEX_PATTERN_MATCH_MAXSIZE);
- strncpy(c_sarg.host_pattern_match, urla_service->host_pattern_match, REGEX_PATTERN_MATCH_MAXSIZE);
- c_sarg.reschedule = urla_service->reschedule;
-
- memcpy(srv_arg_mt->protomod_arg, &c_sarg, sizeof(struct l7vs_urla_service_arg));
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char urla_arg_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_arg_c_str(urla_arg_str, &c_sarg);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,160,
- "pointer assign: srv_arg_mt->protomod_arg=&(%s)", urla_arg_str);
- }
- /*------ DEBUG LOG END ------*/
-
-service_arg_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,161,
- "out_function: int service_arg(struct l7vs_service_arg_multi* srv_arg_mt, "
- "handle_t srv_handle):return_value=%d", return_value);
- }
- /*------ DEBUG LOG END ------*/
-
- return return_value;
-}
-
-/*!
- * Parse l7vsadm options to urla argument
- * @param[out] urla_arg urla service argument struct
- * @param[int] argc number of l7vsadm argument
- * @param[int] argv l7vsadm argument list
- * @retval 0 successfully parse argument
- * @retval -1 some errors occur.
- */
-static int
-parse(void *urla_arg, int argc, char *argv[])
-{
- struct l7vs_urla_service_arg *urla_service_arg;
- static struct option opt[] = {
- {"pattern-match", required_argument, NULL, 'P'},
- {"uri-pattern-match", required_argument, NULL, 'U'},
- {"host-pattern-match", required_argument, NULL, 'H'},
- {"forwarded-for", no_argument, NULL, 'F'},
- {NULL, 0, NULL, 0 }
- };
- int c;
- int key_name_flag = 0;
- int forwarded_for_flag = 0;
- int return_value = 0;
-#ifndef USE_BOOST_XPRESSIVE
- boost::regex regex;
-#endif
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- int i;
- char argv_str[DEBUG_STR_LEN] = {0};
- char urla_arg_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_arg_c_str(urla_arg_str, (struct l7vs_urla_service_arg*) urla_arg);
- argv_str[0] = '\0';
- if (argv == NULL)
- snprintf(argv_str, DEBUG_STR_LEN, "NULL");
- else {
- for (i = 0; i < argc; i++) {
- snprintf(argv_str, DEBUG_STR_LEN, "%sargv[%d]=\"%s\", ", argv_str, i, argv[i]);
- }
- i = strnlen(argv_str, DEBUG_STR_LEN);
- if (i > 1)
- argv_str[i - 2] = '\0';
- }
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,162,
- "in_function: int parse(void* urla_arg, int argc, char* argv[]):urla_arg=&(%s), "
- "argc=%d, %s", urla_arg_str, argc, argv_str);
- }
- /*------ DEBUG LOG END ------*/
-
- /* check null */
- if (urla_arg == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,143, "Arg(urla_arg) is NULL pointer.");
- return_value = -1;
- goto parse_out;
- }
- if (argv == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,144, "Arg(argv) is NULL pointer.");
- return_value = -1;
- goto parse_out;
- }
-
- urla_service_arg = (struct l7vs_urla_service_arg *) urla_arg;
- optind = 0;
-
- /* check all argument */
- while ((c = getopt_long(argc, argv, "K:U:H:F", opt, NULL)) != -1) {
- switch (c) {
- /* --key-name / -K */
- case 'K':
- /* check maximum length */
- if (strnlen(optarg, KEY_NAME_MAXSIZE) >= KEY_NAME_MAXSIZE) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,145,
- "-K/--key-name option value '%s' too long", optarg);
- return_value = -1;
- goto parse_out;
- }
- /* check minimum length */
- if (strnlen(optarg, KEY_NAME_MAXSIZE) <= 0 ) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,146,
- "-K/--key-name option value '%s' invalid", optarg);
- return_value = -1;
- goto parse_out;
- }
- strncpy(urla_service_arg->key-name, optarg, KEY_NAME_MAXSIZE);
- key_name_flag++;
- break;
-
- /* --forwarded-for / -F */
- case 'F':
- /* x-forwarded-for on */
- urla_service_arg->forwarded_for = 1;
- forwarded_for_flag++;
- break;
-
- /* else error */
- default:
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,147, "Option error.");
- return_value = -1;
- goto parse_out;
- }
- }
-
- /* set default no forwarded_for */
- if (forwarded_for_flag == 0) {
- urla_service_arg->forwarded_for = 0;
- }
-
- /* set default no reschedule */
- urla_service_arg->reschedule = 0;
-
- /* no key-name value */
- if (key_name_flag == 0) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,148,
- "You have to '--key-name' option.");
- return_value = -1;
- goto parse_out;
- }
-
- /* same option */
- if (key_name_flag > 1) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,149,
- "Cannot set multiple option '--key-name/-K'.");
- return_value = -1;
- goto parse_out;
- }
-
- /* compile regex */
- if (key_name_flag) {
- try {
-#ifdef USE_BOOST_XPRESSIVE
- boost::xpressive::sregex::compile(urla_service_arg->key_name);
-#else
- regex.assign(urla_service_arg->key_name);
-#endif
- }
- catch (...) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,292,
- "Regex pattern error of option '--key-name/-K'.");
- return_value = -1;
- goto parse_out;
- }
- }
-
-parse_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,163,
- "out_function: int parse(void* urla_arg, int argc, char* argv[]):return_value=%d",
- return_value);
- }
- /*------ DEBUG LOG END ------*/
-
- return return_value;
-}
-
-/*!
- * Search urla service from urla service list using service handle
- * @param[in] service_handle a unique service ID
- * @return urla service struct when service was found. NULL when service was not found.
- */
-static struct l7vs_urla_service *
-l7vs_protomod_urla_search_service(handle_t service_handle)
-{
- /* urla service list counter */
- int service_number = 0;
- struct l7vs_urla_service* return_value = NULL;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,164,
- "in_function: struct l7vs_urla_service* l7vs_protomod_urla_search_service(handle_t service_handle):"
- "service_handle=%d", service_handle);
- }
- /*------ DEBUG LOG END ------*/
-
- /* check all urla service list */
- for (service_number = 0; service_number < URLA_SERVICE_NUMBER; ++service_number) {
- /* found the service has same service handle */
- if (urla_service_list[service_number] != NULL &&
- urla_service_list[service_number]->service_handle == service_handle) {
- return_value = urla_service_list[service_number];
- break;
- }
- }
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char ssl_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_c_str(ssl_str, return_value);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,165,
- "out_function: struct l7vs_urla_service* l7vs_protomod_urla_search_service(handle_t service_handle):"
- "return_value=&(%s)", ssl_str);
- }
- /*------ DEBUG LOG END ------*/
-
- return return_value;
-}
-
-/*!
- * Create urla service.
- * @param void
- * @return urla service struct when create a service. NULL when cannot create service.
- */
-static struct l7vs_urla_service *
-l7vs_protomod_urla_create_service()
-{
- struct l7vs_urla_service* return_value = NULL;
- int service_number = 0;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,166,
- "in_function: struct l7vs_urla_service* l7vs_protomod_urla_create_service()");
- }
- /*------ DEBUG LOG END ------*/
-
- /* check all urla service list */
- for (service_number = 0; service_number < URLA_SERVICE_NUMBER - 1; ++service_number) {
- /* if pointer that does not point NULL exists ... */
- if (urla_service_list[service_number] == NULL) {
- /* create a service at empty pointer */
- urla_service_list[service_number] = (struct l7vs_urla_service *) calloc(1, sizeof(struct l7vs_urla_service));
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_SYSTEM_MEMORY)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_SYSTEM_MEMORY,38, "calloc: addr=%p, size=%ld",
- urla_service_list[service_number], (unsigned long int) sizeof(struct l7vs_urla_service));
- }
- /*------ DEBUG LOG END ------*/
-
- if (urla_service_list[service_number] == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_SYSTEM_MEMORY,28, "Could not allocate memory.");
- goto create_service_out;
- }
- return_value = urla_service_list[service_number];
- goto create_service_out;
- }
- }
-
- /* all service list is full */
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,150, "urla service list is full.");
-
-create_service_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char ssl_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_c_str(ssl_str, return_value);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,167,
- "out_function: struct l7vs_urla_service* l7vs_protomod_urla_create_service():"
- "return_value=&(%s)", ssl_str);
- }
- /*------ DEBUG LOG END ------*/
-
- return return_value;
-}
-
-/*!
- * Create temporary urla service.
- * @param void
- * @return urla service struct when create a service. NULL when cannot create service.
- */
-static struct l7vs_urla_service *
-l7vs_protomod_urla_create_temp_service()
-{
- struct l7vs_urla_service* return_value = NULL;
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,168,
- "in_function: struct l7vs_urla_service* l7vs_protomod_urla_create_temp_service()");
- }
- /*------ DEBUG LOG END ------*/
-
- /* if pointer that does not point NULL exists ... */
- if (urla_service_list[URLA_SERVICE_NUMBER - 1] != NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,151, "Temporary urla service is being used by other process.");
- goto create_temp_service_out;
- }
-
- /* create temp service */
- urla_service_list[URLA_SERVICE_NUMBER - 1] = (struct l7vs_urla_service *) calloc(1, sizeof(struct l7vs_urla_service));
-
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_SYSTEM_MEMORY)) {
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_SYSTEM_MEMORY,39, "calloc: addr=%p, size=%ld",
- urla_service_list[URLA_SERVICE_NUMBER - 1], (unsigned long int) sizeof(struct l7vs_urla_service));
- }
- /*------ DEBUG LOG END ------*/
-
- if (urla_service_list[URLA_SERVICE_NUMBER - 1] == NULL) {
- PUT_LOG_ERROR(urla_protomod, LOG_CAT_L7VSD_SYSTEM_MEMORY,29, "Could not allocate memory");
- goto create_temp_service_out;
- }
-
- return_value = urla_service_list[URLA_SERVICE_NUMBER - 1];
-
-create_temp_service_out:
- /*-------- DEBUG LOG --------*/
- if (urla_protomod.get_log_level != NULL &&
- LOG_LV_DEBUG == urla_protomod.get_log_level(LOG_CAT_L7VSD_PROTOCOL)) {
- char ssl_str[DEBUG_STR_LEN] = {0};
- l7vs_urla_service_c_str(ssl_str, return_value);
- PUT_LOG_DEBUG(urla_protomod, LOG_CAT_L7VSD_PROTOCOL,169,
- "out_function: struct l7vs_urla_service* l7vs_protomod_urla_create_service():"
- "return_value=&(%s)", ssl_str);
- }
- /*------ DEBUG LOG END ------*/
-
- return return_value;
-}
-
-/*!
- * Serialize struct l7vs_urla_service for debug log.
- * @param[out] buf serialized string
- * @param[in] urla l7vs_urla_service struct
- */
-static void l7vs_urla_service_c_str(char* buf, struct l7vs_urla_service* urla) {
- if (urla == NULL) {
- snprintf(buf, DEBUG_STR_LEN, "NULL");
- }
- else {
- snprintf(buf, DEBUG_STR_LEN, "service_handle=%d, pattern_match=\"%s\", uri_pattern_match=\"%s\", host_pattern_match=\"%s\", "
- "forwarded_for=%d, reschedule=%d", urla->service_handle, urla->pattern_match, urla->uri_pattern_match, urla->host_pattern_match,
- urla->forwarded_for, urla->reschedule);
- }
-}
-
-/*!
- * Serialize struct l7vs_urla_service_arg for debug log.
- * @param[out] buf serialized string
- * @param[in] urla_arg l7vs_urla_service_arg struct
- */
-void l7vs_urla_service_arg_c_str(char* buf, struct l7vs_urla_service_arg* urla_arg) {
- if (urla_arg == NULL) {
- snprintf(buf, DEBUG_STR_LEN, "NULL");
- }
- else {
- snprintf(buf, DEBUG_STR_LEN, "pattern_match=\"%s\", uri_pattern_match=\"%s\", host_pattern_match=\"%s\", forwarded_for=%d, reschedule=%d",
- urla_arg->pattern_match, urla_arg->uri_pattern_match, urla_arg->host_pattern_match, urla_arg->forwarded_for, urla_arg->reschedule);
- }
-}
OSDN Git Service
