You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
204 lines
5.9 KiB
204 lines
5.9 KiB
5 months ago
|
/*
|
||
|
* include/haproxy/hlua-t.h
|
||
|
* Lua core types definitions
|
||
|
*
|
||
|
* Copyright (C) 2015-2016 Thierry Fournier <tfournier@arpalert.org>
|
||
|
*
|
||
|
* This library 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, version 2.1
|
||
|
* exclusively.
|
||
|
*
|
||
|
* 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
|
||
|
* 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 Street, Fifth Floor, Boston, MA 02110-1301 USA
|
||
|
*/
|
||
|
|
||
|
#ifndef _HAPROXY_HLUA_T_H
|
||
|
#define _HAPROXY_HLUA_T_H
|
||
|
|
||
|
#ifdef USE_LUA
|
||
|
|
||
|
#include <lua.h>
|
||
|
#include <lauxlib.h>
|
||
|
|
||
|
#include <import/ebpttree.h>
|
||
|
|
||
|
#include <haproxy/proxy-t.h>
|
||
|
#include <haproxy/regex-t.h>
|
||
|
#include <haproxy/server-t.h>
|
||
|
#include <haproxy/stick_table-t.h>
|
||
|
#include <haproxy/xref-t.h>
|
||
|
|
||
|
#define CLASS_CORE "Core"
|
||
|
#define CLASS_TXN "TXN"
|
||
|
#define CLASS_FETCHES "Fetches"
|
||
|
#define CLASS_CONVERTERS "Converters"
|
||
|
#define CLASS_SOCKET "Socket"
|
||
|
#define CLASS_CHANNEL "Channel"
|
||
|
#define CLASS_HTTP "HTTP"
|
||
|
#define CLASS_MAP "Map"
|
||
|
#define CLASS_APPLET_TCP "AppletTCP"
|
||
|
#define CLASS_APPLET_HTTP "AppletHTTP"
|
||
|
#define CLASS_PROXY "Proxy"
|
||
|
#define CLASS_SERVER "Server"
|
||
|
#define CLASS_LISTENER "Listener"
|
||
|
#define CLASS_REGEX "Regex"
|
||
|
#define CLASS_STKTABLE "StickTable"
|
||
|
|
||
|
struct stream;
|
||
|
|
||
|
#define HLUA_RUN 0x00000001
|
||
|
#define HLUA_CTRLYIELD 0x00000002
|
||
|
#define HLUA_WAKERESWR 0x00000004
|
||
|
#define HLUA_WAKEREQWR 0x00000008
|
||
|
#define HLUA_EXIT 0x00000010
|
||
|
|
||
|
#define HLUA_F_AS_STRING 0x01
|
||
|
#define HLUA_F_MAY_USE_HTTP 0x02
|
||
|
|
||
|
#define HLUA_TXN_NOTERM 0x00000001
|
||
|
|
||
|
#define HLUA_CONCAT_BLOCSZ 2048
|
||
|
|
||
|
enum hlua_exec {
|
||
|
HLUA_E_OK = 0,
|
||
|
HLUA_E_AGAIN, /* LUA yield, must resume the stack execution later, when
|
||
|
the associatedtask is waked. */
|
||
|
HLUA_E_ETMOUT, /* Execution timeout */
|
||
|
HLUA_E_NOMEM, /* Out of memory error */
|
||
|
HLUA_E_YIELD, /* LUA code try to yield, and this is not allowed */
|
||
|
HLUA_E_ERRMSG, /* LUA stack execution failed with a string error message
|
||
|
in the top of stack. */
|
||
|
HLUA_E_ERR, /* LUA stack execution failed without error message. */
|
||
|
};
|
||
|
|
||
|
struct hlua {
|
||
|
lua_State *T; /* The LUA stack. */
|
||
|
int state_id; /* contains the lua state id. 0 is common state, 1 to n are per-thread states.*/
|
||
|
int Tref; /* The reference of the stack in coroutine case.
|
||
|
-1 for the main lua stack. */
|
||
|
int Mref; /* The reference of the memory context in coroutine case.
|
||
|
-1 if the memory context is not used. */
|
||
|
int nargs; /* The number of arguments in the stack at the start of execution. */
|
||
|
unsigned int flags; /* The current execution flags. */
|
||
|
int wake_time; /* The lua wants to be waked at this time, or before. */
|
||
|
unsigned int max_time; /* The max amount of execution time for an Lua process, in ms. */
|
||
|
unsigned int start_time; /* The ms time when the Lua starts the last execution. */
|
||
|
unsigned int run_time; /* Lua total execution time in ms. */
|
||
|
struct task *task; /* The task associated with the lua stack execution.
|
||
|
We must wake this task to continue the task execution */
|
||
|
struct list com; /* The list head of the signals attached to this task. */
|
||
|
struct ebpt_node node;
|
||
|
int gc_count; /* number of items which need a GC */
|
||
|
};
|
||
|
|
||
|
/* This is a part of the list containing references to functions
|
||
|
* called at the initialisation time.
|
||
|
*/
|
||
|
struct hlua_init_function {
|
||
|
struct list l;
|
||
|
int function_ref;
|
||
|
};
|
||
|
|
||
|
/* This struct contains the lua data used to bind
|
||
|
* Lua function on HAProxy hook like sample-fetches
|
||
|
* or actions.
|
||
|
*/
|
||
|
struct hlua_function {
|
||
|
struct list l;
|
||
|
char *name;
|
||
|
int function_ref[MAX_THREADS + 1];
|
||
|
int nargs;
|
||
|
};
|
||
|
|
||
|
/* This struct is used with the structs:
|
||
|
* - http_req_rule
|
||
|
* - http_res_rule
|
||
|
* - tcp_rule
|
||
|
* It contains the lua execution configuration.
|
||
|
*/
|
||
|
struct hlua_rule {
|
||
|
struct hlua_function *fcn;
|
||
|
char **args;
|
||
|
};
|
||
|
|
||
|
/* This struct contains the pointer provided on the most
|
||
|
* of internal HAProxy calls during the processing of
|
||
|
* rules, converters and sample-fetches. This struct is
|
||
|
* associated with the lua object called "TXN".
|
||
|
*/
|
||
|
struct hlua_txn {
|
||
|
struct stream *s;
|
||
|
struct proxy *p;
|
||
|
int dir; /* SMP_OPT_DIR_{REQ,RES} */
|
||
|
int flags;
|
||
|
};
|
||
|
|
||
|
/* This struct contains the applet context. */
|
||
|
struct hlua_appctx {
|
||
|
struct appctx *appctx;
|
||
|
luaL_Buffer b; /* buffer used to prepare strings. */
|
||
|
struct hlua_txn htxn;
|
||
|
};
|
||
|
|
||
|
/* This struct is used with sample fetches and sample converters. */
|
||
|
struct hlua_smp {
|
||
|
struct stream *s;
|
||
|
struct proxy *p;
|
||
|
unsigned int flags; /* LUA_F_OPT_* */
|
||
|
int dir; /* SMP_OPT_DIR_{REQ,RES} */
|
||
|
};
|
||
|
|
||
|
/* This struct contains data used with sleep functions. */
|
||
|
struct hlua_sleep {
|
||
|
struct task *task; /* task associated with sleep. */
|
||
|
struct list com; /* list of signal to wake at the end of sleep. */
|
||
|
unsigned int wakeup_ms; /* hour to wakeup. */
|
||
|
};
|
||
|
|
||
|
/* This struct is used to create coprocess doing TCP or
|
||
|
* SSL I/O. It uses a fake stream.
|
||
|
*/
|
||
|
struct hlua_socket {
|
||
|
struct xref xref; /* cross reference with the stream used for socket I/O. */
|
||
|
luaL_Buffer b; /* buffer used to prepare strings. */
|
||
|
unsigned long tid; /* Store the thread id which creates the socket. */
|
||
|
};
|
||
|
|
||
|
struct hlua_concat {
|
||
|
int size;
|
||
|
int len;
|
||
|
};
|
||
|
|
||
|
struct hlua_addr {
|
||
|
union {
|
||
|
struct {
|
||
|
struct in_addr ip;
|
||
|
struct in_addr mask;
|
||
|
} v4;
|
||
|
struct {
|
||
|
struct in6_addr ip;
|
||
|
struct in6_addr mask;
|
||
|
} v6;
|
||
|
} addr;
|
||
|
int type;
|
||
|
};
|
||
|
|
||
|
#else /* USE_LUA */
|
||
|
/************************ For use when Lua is disabled ********************/
|
||
|
|
||
|
/* Empty struct for compilation compatibility */
|
||
|
struct hlua { };
|
||
|
struct hlua_socket { };
|
||
|
struct hlua_rule { };
|
||
|
|
||
|
#endif /* USE_LUA */
|
||
|
|
||
|
#endif /* _HAPROXY_HLUA_T_H */
|