mirror of
http://git.haproxy.org/git/haproxy.git/
synced 2024-12-18 01:14:38 +00:00
CLEANUP: assorted typo fixes in the code and comments
This is 8th iteration of typo fixes
This commit is contained in:
parent
39b2fda915
commit
856aabcda5
@ -310,7 +310,7 @@ static inline void fd_want_send(int fd)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* Set the fd as currently running on the current thread.
|
/* Set the fd as currently running on the current thread.
|
||||||
* Retuns 0 if all goes well, or -1 if we no longer own the fd, and should
|
* Returns 0 if all goes well, or -1 if we no longer own the fd, and should
|
||||||
* do nothing with it.
|
* do nothing with it.
|
||||||
*/
|
*/
|
||||||
static inline int fd_set_running(int fd)
|
static inline int fd_set_running(int fd)
|
||||||
|
@ -253,7 +253,7 @@ enum {
|
|||||||
CO_ER_SSL_TIMEOUT, /* timeout during SSL handshake */
|
CO_ER_SSL_TIMEOUT, /* timeout during SSL handshake */
|
||||||
CO_ER_SSL_TOO_MANY, /* too many SSL connections */
|
CO_ER_SSL_TOO_MANY, /* too many SSL connections */
|
||||||
CO_ER_SSL_NO_MEM, /* no more memory to allocate an SSL connection */
|
CO_ER_SSL_NO_MEM, /* no more memory to allocate an SSL connection */
|
||||||
CO_ER_SSL_RENEG, /* forbidden client renegociation */
|
CO_ER_SSL_RENEG, /* forbidden client renegotiation */
|
||||||
CO_ER_SSL_CA_FAIL, /* client cert verification failed in the CA chain */
|
CO_ER_SSL_CA_FAIL, /* client cert verification failed in the CA chain */
|
||||||
CO_ER_SSL_CRT_FAIL, /* client cert verification failed on the certificate */
|
CO_ER_SSL_CRT_FAIL, /* client cert verification failed on the certificate */
|
||||||
CO_ER_SSL_MISMATCH, /* Server presented an SSL certificate different from the configured one */
|
CO_ER_SSL_MISMATCH, /* Server presented an SSL certificate different from the configured one */
|
||||||
@ -345,7 +345,7 @@ enum mux_ctl_type {
|
|||||||
/* mux_ops describes the mux operations, which are to be performed at the
|
/* mux_ops describes the mux operations, which are to be performed at the
|
||||||
* connection level after data are exchanged with the transport layer in order
|
* connection level after data are exchanged with the transport layer in order
|
||||||
* to propagate them to streams. The <init> function will automatically be
|
* to propagate them to streams. The <init> function will automatically be
|
||||||
* called once the mux is instanciated by the connection's owner at the end
|
* called once the mux is instantiated by the connection's owner at the end
|
||||||
* of a transport handshake, when it is about to transfer data and the data
|
* of a transport handshake, when it is about to transfer data and the data
|
||||||
* layer is not ready yet.
|
* layer is not ready yet.
|
||||||
*/
|
*/
|
||||||
@ -370,7 +370,7 @@ struct mux_ops {
|
|||||||
void (*destroy)(void *ctx); /* Let the mux know one of its users left, so it may have to disappear */
|
void (*destroy)(void *ctx); /* Let the mux know one of its users left, so it may have to disappear */
|
||||||
void (*reset)(struct connection *conn); /* Reset the mux, because we're re-trying to connect */
|
void (*reset)(struct connection *conn); /* Reset the mux, because we're re-trying to connect */
|
||||||
const struct cs_info *(*get_cs_info)(struct conn_stream *cs); /* Return info on the specified conn_stream or NULL if not defined */
|
const struct cs_info *(*get_cs_info)(struct conn_stream *cs); /* Return info on the specified conn_stream or NULL if not defined */
|
||||||
int (*ctl)(struct connection *conn, enum mux_ctl_type mux_ctl, void *arg); /* Provides informations about the mux */
|
int (*ctl)(struct connection *conn, enum mux_ctl_type mux_ctl, void *arg); /* Provides information about the mux */
|
||||||
int (*takeover)(struct connection *conn); /* Attempts to migrate the connection to the current thread */
|
int (*takeover)(struct connection *conn); /* Attempts to migrate the connection to the current thread */
|
||||||
unsigned int flags; /* some flags characterizing the mux's capabilities (MX_FL_*) */
|
unsigned int flags; /* some flags characterizing the mux's capabilities (MX_FL_*) */
|
||||||
char name[8]; /* mux layer name, zero-terminated */
|
char name[8]; /* mux layer name, zero-terminated */
|
||||||
@ -426,14 +426,14 @@ struct conn_stream {
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
* This structure describes the info related to a conn_stream known by the mux
|
* This structure describes the info related to a conn_stream known by the mux
|
||||||
* only but usefull for the upper layer.
|
* only but useful for the upper layer.
|
||||||
* For now, only some dates and durations are reported. This structure will
|
* For now, only some dates and durations are reported. This structure will
|
||||||
* envolved. But for now, only the bare minimum is referenced.
|
* envolved. But for now, only the bare minimum is referenced.
|
||||||
*/
|
*/
|
||||||
struct cs_info {
|
struct cs_info {
|
||||||
struct timeval create_date; /* Creation date of the conn_stream in user date */
|
struct timeval create_date; /* Creation date of the conn_stream in user date */
|
||||||
struct timeval tv_create; /* Creation date of the conn_stream in internal date (monotonic) */
|
struct timeval tv_create; /* Creation date of the conn_stream in internal date (monotonic) */
|
||||||
long t_handshake; /* hanshake duration, -1 if never occurs */
|
long t_handshake; /* handshake duration, -1 if never occurs */
|
||||||
long t_idle; /* idle duration, -1 if never occurs */
|
long t_idle; /* idle duration, -1 if never occurs */
|
||||||
};
|
};
|
||||||
|
|
||||||
@ -452,7 +452,7 @@ struct connection {
|
|||||||
unsigned int flags; /* CO_FL_* */
|
unsigned int flags; /* CO_FL_* */
|
||||||
const struct protocol *ctrl; /* operations at the socket layer */
|
const struct protocol *ctrl; /* operations at the socket layer */
|
||||||
const struct xprt_ops *xprt; /* operations at the transport layer */
|
const struct xprt_ops *xprt; /* operations at the transport layer */
|
||||||
const struct mux_ops *mux; /* mux layer opreations. Must be set before xprt->init() */
|
const struct mux_ops *mux; /* mux layer operations. Must be set before xprt->init() */
|
||||||
void *xprt_ctx; /* general purpose pointer, initialized to NULL */
|
void *xprt_ctx; /* general purpose pointer, initialized to NULL */
|
||||||
void *ctx; /* highest level context (usually the mux), initialized to NULL */
|
void *ctx; /* highest level context (usually the mux), initialized to NULL */
|
||||||
void *owner; /* pointer to the owner session, or NULL */
|
void *owner; /* pointer to the owner session, or NULL */
|
||||||
|
@ -118,7 +118,7 @@ struct fdlist {
|
|||||||
|
|
||||||
/* info about one given fd */
|
/* info about one given fd */
|
||||||
struct fdtab {
|
struct fdtab {
|
||||||
unsigned long running_mask; /* mask of thread IDs currntly using the fd */
|
unsigned long running_mask; /* mask of thread IDs currently using the fd */
|
||||||
unsigned long thread_mask; /* mask of thread IDs authorized to process the fd */
|
unsigned long thread_mask; /* mask of thread IDs authorized to process the fd */
|
||||||
unsigned long update_mask; /* mask of thread IDs having an update for fd */
|
unsigned long update_mask; /* mask of thread IDs having an update for fd */
|
||||||
struct fdlist_entry update; /* Entry in the global update list */
|
struct fdlist_entry update; /* Entry in the global update list */
|
||||||
|
@ -190,7 +190,7 @@ struct bind_conf {
|
|||||||
struct listener {
|
struct listener {
|
||||||
enum obj_type obj_type; /* object type = OBJ_TYPE_LISTENER */
|
enum obj_type obj_type; /* object type = OBJ_TYPE_LISTENER */
|
||||||
enum li_state state; /* state: NEW, INIT, ASSIGNED, LISTEN, READY, FULL */
|
enum li_state state; /* state: NEW, INIT, ASSIGNED, LISTEN, READY, FULL */
|
||||||
short int nice; /* nice value to assign to the instanciated tasks */
|
short int nice; /* nice value to assign to the instantiated tasks */
|
||||||
int fd; /* the listen socket */
|
int fd; /* the listen socket */
|
||||||
int luid; /* listener universally unique ID, used for SNMP */
|
int luid; /* listener universally unique ID, used for SNMP */
|
||||||
int options; /* socket options : LI_O_* */
|
int options; /* socket options : LI_O_* */
|
||||||
|
@ -99,7 +99,7 @@ enum {
|
|||||||
SETCERT_ST_FIN,
|
SETCERT_ST_FIN,
|
||||||
};
|
};
|
||||||
|
|
||||||
/* This is used to preload the certifcate, private key
|
/* This is used to preload the certificate, private key
|
||||||
* and Cert Chain of a file passed in via the crt
|
* and Cert Chain of a file passed in via the crt
|
||||||
* argument
|
* argument
|
||||||
*
|
*
|
||||||
|
@ -105,7 +105,7 @@ struct strm_logs {
|
|||||||
int level; /* log level to force + 1 if > 0, -1 = no log */
|
int level; /* log level to force + 1 if > 0, -1 = no log */
|
||||||
struct timeval accept_date; /* date of the stream's accept() in user date */
|
struct timeval accept_date; /* date of the stream's accept() in user date */
|
||||||
struct timeval tv_accept; /* date of the stream's accept() in internal date (monotonic) */
|
struct timeval tv_accept; /* date of the stream's accept() in internal date (monotonic) */
|
||||||
long t_handshake; /* hanshake duration, -1 if never occurs */
|
long t_handshake; /* handshake duration, -1 if never occurs */
|
||||||
long t_idle; /* idle duration, -1 if never occurs */
|
long t_idle; /* idle duration, -1 if never occurs */
|
||||||
struct timeval tv_request; /* date the request arrives, {0,0} if never occurs */
|
struct timeval tv_request; /* date the request arrives, {0,0} if never occurs */
|
||||||
long t_queue; /* delay before the stream gets out of the connect queue, -1 if never occurs */
|
long t_queue; /* delay before the stream gets out of the connect queue, -1 if never occurs */
|
||||||
|
@ -88,7 +88,7 @@ update_up() {
|
|||||||
|
|
||||||
# backports commit "$1" with a signed-off by tag. In case of failure, aborts
|
# backports commit "$1" with a signed-off by tag. In case of failure, aborts
|
||||||
# the change and returns non-zero. Unneeded cherry-picks do return an error
|
# the change and returns non-zero. Unneeded cherry-picks do return an error
|
||||||
# because we don't want to accidently backport the latest commit instead of
|
# because we don't want to accidentally backport the latest commit instead of
|
||||||
# this one, and we don't know this one's ID.
|
# this one, and we don't know this one's ID.
|
||||||
backport_commit() {
|
backport_commit() {
|
||||||
local empty=1
|
local empty=1
|
||||||
|
@ -19,7 +19,7 @@ _help()
|
|||||||
--v, to run verbose
|
--v, to run verbose
|
||||||
run-regtests.sh --v, disables the default vtest 'quiet' parameter
|
run-regtests.sh --v, disables the default vtest 'quiet' parameter
|
||||||
|
|
||||||
--debug to show test logs on standard ouput (implies --v)
|
--debug to show test logs on standard output (implies --v)
|
||||||
run-regtests.sh --debug
|
run-regtests.sh --debug
|
||||||
|
|
||||||
--keep-logs to keep all log directories (by default kept if test fails)
|
--keep-logs to keep all log directories (by default kept if test fails)
|
||||||
|
54
src/hlua.c
54
src/hlua.c
@ -111,7 +111,7 @@
|
|||||||
* code and recompile the library. This system will probably not accepted
|
* code and recompile the library. This system will probably not accepted
|
||||||
* by maintainers of various distribs.
|
* by maintainers of various distribs.
|
||||||
*
|
*
|
||||||
* Our main excution point of the Lua is the function lua_resume(). A
|
* Our main execution point of the Lua is the function lua_resume(). A
|
||||||
* quick looking on the Lua sources displays a lua_lock() a the start
|
* quick looking on the Lua sources displays a lua_lock() a the start
|
||||||
* of function and a lua_unlock() at the end of the function. So I
|
* of function and a lua_unlock() at the end of the function. So I
|
||||||
* conclude that the Lua thread safe mode just perform a mutex around
|
* conclude that the Lua thread safe mode just perform a mutex around
|
||||||
@ -653,7 +653,7 @@ __LJMP int hlua_lua2arg_check(lua_State *L, int first, struct arg *argp,
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Check for exceed the number of requiered argument. */
|
/* Check for exceed the number of required argument. */
|
||||||
if ((mask & ARGT_MASK) == ARGT_STOP &&
|
if ((mask & ARGT_MASK) == ARGT_STOP &&
|
||||||
argp[idx].type != ARGT_STOP) {
|
argp[idx].type != ARGT_STOP) {
|
||||||
WILL_LJMP(luaL_argerror(L, first + idx, "Last argument expected"));
|
WILL_LJMP(luaL_argerror(L, first + idx, "Last argument expected"));
|
||||||
@ -883,18 +883,18 @@ __LJMP void hlua_yieldk(lua_State *L, int nresults, int ctx,
|
|||||||
* throws an error (longjmp).
|
* throws an error (longjmp).
|
||||||
*
|
*
|
||||||
* In some case (at least one), this function can be called from safe
|
* In some case (at least one), this function can be called from safe
|
||||||
* environement, so we must not initialise it. While the support of
|
* environment, so we must not initialise it. While the support of
|
||||||
* threads appear, the safe environment set a lock to ensure only one
|
* threads appear, the safe environment set a lock to ensure only one
|
||||||
* Lua execution at a time. If we initialize safe environment in another
|
* Lua execution at a time. If we initialize safe environment in another
|
||||||
* safe environmenet, we have a dead lock.
|
* safe environment, we have a dead lock.
|
||||||
*
|
*
|
||||||
* set "already_safe" true if the context is initialized form safe
|
* set "already_safe" true if the context is initialized form safe
|
||||||
* Lua fonction.
|
* Lua function.
|
||||||
*
|
*
|
||||||
* This function manipulates two Lua stacks: the main and the thread. Only
|
* This function manipulates two Lua stacks: the main and the thread. Only
|
||||||
* the main stack can fail. The thread is not manipulated. This function
|
* the main stack can fail. The thread is not manipulated. This function
|
||||||
* MUST NOT manipulate the created thread stack state, because it is not
|
* MUST NOT manipulate the created thread stack state, because it is not
|
||||||
* proctected against errors thrown by the thread stack.
|
* protected against errors thrown by the thread stack.
|
||||||
*/
|
*/
|
||||||
int hlua_ctx_init(struct hlua *lua, struct task *task, int already_safe)
|
int hlua_ctx_init(struct hlua *lua, struct task *task, int already_safe)
|
||||||
{
|
{
|
||||||
@ -1023,7 +1023,7 @@ void hlua_hook(lua_State *L, lua_Debug *ar)
|
|||||||
|
|
||||||
/* Lua cannot yield when its returning from a function,
|
/* Lua cannot yield when its returning from a function,
|
||||||
* so, we can fix the interrupt hook to 1 instruction,
|
* so, we can fix the interrupt hook to 1 instruction,
|
||||||
* expecting that the function is finnished.
|
* expecting that the function is finished.
|
||||||
*/
|
*/
|
||||||
if (lua_gethookmask(L) & LUA_MASKRET) {
|
if (lua_gethookmask(L) & LUA_MASKRET) {
|
||||||
lua_sethook(hlua->T, hlua_hook, LUA_MASKCOUNT, 1);
|
lua_sethook(hlua->T, hlua_hook, LUA_MASKCOUNT, 1);
|
||||||
@ -1418,7 +1418,7 @@ static int hlua_set_map(lua_State *L)
|
|||||||
* __pow "^"
|
* __pow "^"
|
||||||
* __concat ".."
|
* __concat ".."
|
||||||
*
|
*
|
||||||
* Special methods for redfining standar relations
|
* Special methods for redefining standard relations
|
||||||
* http://www.lua.org/pil/13.2.html
|
* http://www.lua.org/pil/13.2.html
|
||||||
*
|
*
|
||||||
* __eq "=="
|
* __eq "=="
|
||||||
@ -2540,7 +2540,7 @@ __LJMP static int hlua_socket_settimeout(struct lua_State *L)
|
|||||||
|
|
||||||
tmout = MS_TO_TICKS((int)dtmout);
|
tmout = MS_TO_TICKS((int)dtmout);
|
||||||
if (tmout == 0)
|
if (tmout == 0)
|
||||||
tmout++; /* very small timeouts are adjusted to a minium of 1ms */
|
tmout++; /* very small timeouts are adjusted to a minimum of 1ms */
|
||||||
|
|
||||||
/* Check if we run on the same thread than the xreator thread.
|
/* Check if we run on the same thread than the xreator thread.
|
||||||
* We cannot access to the socket if the thread is different.
|
* We cannot access to the socket if the thread is different.
|
||||||
@ -2598,7 +2598,7 @@ __LJMP static int hlua_socket_new(lua_State *L)
|
|||||||
memset(socket, 0, sizeof(*socket));
|
memset(socket, 0, sizeof(*socket));
|
||||||
socket->tid = tid;
|
socket->tid = tid;
|
||||||
|
|
||||||
/* Check if the various memory pools are intialized. */
|
/* Check if the various memory pools are initialized. */
|
||||||
if (!pool_head_stream || !pool_head_buffer) {
|
if (!pool_head_stream || !pool_head_buffer) {
|
||||||
hlua_pusherror(L, "socket: uninitialized pools.");
|
hlua_pusherror(L, "socket: uninitialized pools.");
|
||||||
goto out_fail_conf;
|
goto out_fail_conf;
|
||||||
@ -2884,7 +2884,7 @@ __LJMP static int hlua_channel_append_yield(lua_State *L, int status, lua_KConte
|
|||||||
if (max == 0 && co_data(chn) == 0) {
|
if (max == 0 && co_data(chn) == 0) {
|
||||||
/* There are no space available, and the output buffer is empty.
|
/* There are no space available, and the output buffer is empty.
|
||||||
* in this case, we cannot add more data, so we cannot yield,
|
* in this case, we cannot add more data, so we cannot yield,
|
||||||
* we return the amount of copyied data.
|
* we return the amount of copied data.
|
||||||
*/
|
*/
|
||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
@ -2971,7 +2971,7 @@ __LJMP static int hlua_channel_send_yield(lua_State *L, int status, lua_KContext
|
|||||||
|
|
||||||
/* If there is no space available, and the output buffer is empty.
|
/* If there is no space available, and the output buffer is empty.
|
||||||
* in this case, we cannot add more data, so we cannot yield,
|
* in this case, we cannot add more data, so we cannot yield,
|
||||||
* we return the amount of copyied data.
|
* we return the amount of copied data.
|
||||||
*/
|
*/
|
||||||
if (max == 0 && co_data(chn) == 0)
|
if (max == 0 && co_data(chn) == 0)
|
||||||
return 1;
|
return 1;
|
||||||
@ -3000,7 +3000,7 @@ __LJMP static int hlua_channel_send_yield(lua_State *L, int status, lua_KContext
|
|||||||
|
|
||||||
/* If there is no space available, and the output buffer is empty.
|
/* If there is no space available, and the output buffer is empty.
|
||||||
* in this case, we cannot add more data, so we cannot yield,
|
* in this case, we cannot add more data, so we cannot yield,
|
||||||
* we return the amount of copyied data.
|
* we return the amount of copied data.
|
||||||
*/
|
*/
|
||||||
max = b_room(&chn->buf);
|
max = b_room(&chn->buf);
|
||||||
if (max == 0 && co_data(chn) == 0)
|
if (max == 0 && co_data(chn) == 0)
|
||||||
@ -3021,7 +3021,7 @@ __LJMP static int hlua_channel_send_yield(lua_State *L, int status, lua_KContext
|
|||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Just a wraper of "_hlua_channel_send". This wrapper permits
|
/* Just a wrapper of "_hlua_channel_send". This wrapper permits
|
||||||
* yield the LUA process, and resume it without checking the
|
* yield the LUA process, and resume it without checking the
|
||||||
* input arguments.
|
* input arguments.
|
||||||
*/
|
*/
|
||||||
@ -3038,7 +3038,7 @@ __LJMP static int hlua_channel_send(lua_State *L)
|
|||||||
* forwarded. This function never fails.
|
* forwarded. This function never fails.
|
||||||
*
|
*
|
||||||
* The Lua function takes an amount of bytes to be forwarded in
|
* The Lua function takes an amount of bytes to be forwarded in
|
||||||
* imput. It returns the number of bytes forwarded.
|
* input. It returns the number of bytes forwarded.
|
||||||
*/
|
*/
|
||||||
__LJMP static int hlua_channel_forward_yield(lua_State *L, int status, lua_KContext ctx)
|
__LJMP static int hlua_channel_forward_yield(lua_State *L, int status, lua_KContext ctx)
|
||||||
{
|
{
|
||||||
@ -3686,7 +3686,7 @@ __LJMP static int hlua_applet_tcp_recv_yield(lua_State *L, int status, lua_KCont
|
|||||||
|
|
||||||
} else {
|
} else {
|
||||||
|
|
||||||
/* Copy the fisrt block caping to the length required. */
|
/* Copy the first block caping to the length required. */
|
||||||
if (len1 > len)
|
if (len1 > len)
|
||||||
len1 = len;
|
len1 = len;
|
||||||
luaL_addlstring(&appctx->b, blk1, len1);
|
luaL_addlstring(&appctx->b, blk1, len1);
|
||||||
@ -3781,7 +3781,7 @@ __LJMP static int hlua_applet_tcp_send_yield(lua_State *L, int status, lua_KCont
|
|||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Just a wraper of "hlua_applet_tcp_send_yield". This wrapper permits
|
/* Just a wrapper of "hlua_applet_tcp_send_yield". This wrapper permits
|
||||||
* yield the LUA process, and resume it without checking the
|
* yield the LUA process, and resume it without checking the
|
||||||
* input arguments.
|
* input arguments.
|
||||||
*/
|
*/
|
||||||
@ -4312,7 +4312,7 @@ __LJMP static int hlua_applet_http_send_yield(lua_State *L, int status, lua_KCon
|
|||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
/* Just a wraper of "hlua_applet_send_yield". This wrapper permits
|
/* Just a wrapper of "hlua_applet_send_yield". This wrapper permits
|
||||||
* yield the LUA process, and resume it without checking the
|
* yield the LUA process, and resume it without checking the
|
||||||
* input arguments.
|
* input arguments.
|
||||||
*/
|
*/
|
||||||
@ -4326,7 +4326,7 @@ __LJMP static int hlua_applet_http_send(lua_State *L)
|
|||||||
WILL_LJMP(lua_error(L));
|
WILL_LJMP(lua_error(L));
|
||||||
}
|
}
|
||||||
|
|
||||||
/* This interger is used for followinf the amount of data sent. */
|
/* This integer is used for followinf the amount of data sent. */
|
||||||
lua_pushinteger(L, 0);
|
lua_pushinteger(L, 0);
|
||||||
|
|
||||||
return MAY_LJMP(hlua_applet_http_send_yield(L, 0, 0));
|
return MAY_LJMP(hlua_applet_http_send_yield(L, 0, 0));
|
||||||
@ -4549,8 +4549,8 @@ __LJMP static int hlua_applet_http_send_response(lua_State *L)
|
|||||||
/* If we dont have a content-length set, and the HTTP version is 1.1
|
/* If we dont have a content-length set, and the HTTP version is 1.1
|
||||||
* and the status code implies the presence of a message body, we must
|
* and the status code implies the presence of a message body, we must
|
||||||
* announce a transfer encoding chunked. This is required by haproxy
|
* announce a transfer encoding chunked. This is required by haproxy
|
||||||
* for the keepalive compliance. If the applet annouces a transfer-encoding
|
* for the keepalive compliance. If the applet announces a transfer-encoding
|
||||||
* chunked itslef, don't do anything.
|
* chunked itself, don't do anything.
|
||||||
*/
|
*/
|
||||||
if ((flags & (HTX_SL_F_VER_11|HTX_SL_F_XFER_LEN)) == HTX_SL_F_VER_11 &&
|
if ((flags & (HTX_SL_F_VER_11|HTX_SL_F_XFER_LEN)) == HTX_SL_F_VER_11 &&
|
||||||
appctx->appctx->ctx.hlua_apphttp.status >= 200 &&
|
appctx->appctx->ctx.hlua_apphttp.status >= 200 &&
|
||||||
@ -5363,7 +5363,7 @@ __LJMP static int hlua_txn_set_priority_offset(lua_State *L)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* Forward the Reply object to the client. This function converts the reply in
|
/* Forward the Reply object to the client. This function converts the reply in
|
||||||
* HTX an push it to into the response channel. It is response to foward the
|
* HTX an push it to into the response channel. It is response to forward the
|
||||||
* message and terminate the transaction. It returns 1 on success and 0 on
|
* message and terminate the transaction. It returns 1 on success and 0 on
|
||||||
* error. The Reply must be on top of the stack.
|
* error. The Reply must be on top of the stack.
|
||||||
*/
|
*/
|
||||||
@ -6985,7 +6985,7 @@ void hlua_applet_http_fct(struct appctx *ctx)
|
|||||||
if (unlikely(si->state == SI_ST_DIS || si->state == SI_ST_CLO))
|
if (unlikely(si->state == SI_ST_DIS || si->state == SI_ST_CLO))
|
||||||
goto out;
|
goto out;
|
||||||
|
|
||||||
/* Check if the input buffer is avalaible. */
|
/* Check if the input buffer is available. */
|
||||||
if (!b_size(&res->buf)) {
|
if (!b_size(&res->buf)) {
|
||||||
si_rx_room_blk(si);
|
si_rx_room_blk(si);
|
||||||
goto out;
|
goto out;
|
||||||
@ -7147,7 +7147,7 @@ static void hlua_applet_http_release(struct appctx *ctx)
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* global {tcp|http}-request parser. Return ACT_RET_PRS_OK in
|
/* global {tcp|http}-request parser. Return ACT_RET_PRS_OK in
|
||||||
* succes case, else return ACT_RET_PRS_ERR.
|
* success case, else return ACT_RET_PRS_ERR.
|
||||||
*
|
*
|
||||||
* This function can fail with an abort() due to an Lua critical error.
|
* This function can fail with an abort() due to an Lua critical error.
|
||||||
* We are in the configuration parsing process of HAProxy, this abort() is
|
* We are in the configuration parsing process of HAProxy, this abort() is
|
||||||
@ -7202,9 +7202,9 @@ static enum act_parse_ret action_register_service_http(const char **args, int *c
|
|||||||
struct hlua_function *fcn = rule->kw->private;
|
struct hlua_function *fcn = rule->kw->private;
|
||||||
|
|
||||||
/* HTTP applets are forbidden in tcp-request rules.
|
/* HTTP applets are forbidden in tcp-request rules.
|
||||||
* HTTP applet request requires everything initilized by
|
* HTTP applet request requires everything initialized by
|
||||||
* "http_process_request" (analyzer flag AN_REQ_HTTP_INNER).
|
* "http_process_request" (analyzer flag AN_REQ_HTTP_INNER).
|
||||||
* The applet will be immediately initilized, but its before
|
* The applet will be immediately initialized, but its before
|
||||||
* the call of this analyzer.
|
* the call of this analyzer.
|
||||||
*/
|
*/
|
||||||
if (rule->from != ACT_F_HTTP_REQ) {
|
if (rule->from != ACT_F_HTTP_REQ) {
|
||||||
@ -7893,7 +7893,7 @@ int hlua_post_init()
|
|||||||
enum hlua_exec ret;
|
enum hlua_exec ret;
|
||||||
const char *error;
|
const char *error;
|
||||||
|
|
||||||
/* Call post initialisation function in safe environement. */
|
/* Call post initialisation function in safe environment. */
|
||||||
if (!SET_SAFE_LJMP(gL.T)) {
|
if (!SET_SAFE_LJMP(gL.T)) {
|
||||||
if (lua_type(gL.T, -1) == LUA_TSTRING)
|
if (lua_type(gL.T, -1) == LUA_TSTRING)
|
||||||
error = lua_tostring(gL.T, -1);
|
error = lua_tostring(gL.T, -1);
|
||||||
|
10
src/log.c
10
src/log.c
@ -613,7 +613,7 @@ int parse_logformat_string(const char *fmt, struct proxy *curproxy, struct list
|
|||||||
var = str;
|
var = str;
|
||||||
}
|
}
|
||||||
else if (*str == '%')
|
else if (*str == '%')
|
||||||
cformat = LF_TEXT; // convert this character to a litteral (useful for '%')
|
cformat = LF_TEXT; // convert this character to a literal (useful for '%')
|
||||||
else if (isdigit((unsigned char)*str) || *str == ' ' || *str == '\t') {
|
else if (isdigit((unsigned char)*str) || *str == ' ' || *str == '\t') {
|
||||||
/* single '%' followed by blank or digit, send them both */
|
/* single '%' followed by blank or digit, send them both */
|
||||||
cformat = LF_TEXT;
|
cformat = LF_TEXT;
|
||||||
@ -625,7 +625,7 @@ int parse_logformat_string(const char *fmt, struct proxy *curproxy, struct list
|
|||||||
|
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
cformat = LF_INIT; // handle other cases of litterals
|
cformat = LF_INIT; // handle other cases of literals
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case LF_STARG: // text immediately following '%{'
|
case LF_STARG: // text immediately following '%{'
|
||||||
@ -726,7 +726,7 @@ int parse_logformat_string(const char *fmt, struct proxy *curproxy, struct list
|
|||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Parse the first range of indexes from a string made of a list of comma seperated
|
* Parse the first range of indexes from a string made of a list of comma separated
|
||||||
* ranges of indexes. Note that an index may be considered as a particular range
|
* ranges of indexes. Note that an index may be considered as a particular range
|
||||||
* with a high limit to the low limit.
|
* with a high limit to the low limit.
|
||||||
*/
|
*/
|
||||||
@ -1364,7 +1364,7 @@ static inline char *lf_text(char *dst, const char *src, size_t size, const struc
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
* Write a IP address to the log string
|
* Write a IP address to the log string
|
||||||
* +X option write in hexadecimal notation, most signifant byte on the left
|
* +X option write in hexadecimal notation, most significant byte on the left
|
||||||
*/
|
*/
|
||||||
char *lf_ip(char *dst, const struct sockaddr *sockaddr, size_t size, const struct logformat_node *node)
|
char *lf_ip(char *dst, const struct sockaddr *sockaddr, size_t size, const struct logformat_node *node)
|
||||||
{
|
{
|
||||||
@ -1402,7 +1402,7 @@ char *lf_ip(char *dst, const struct sockaddr *sockaddr, size_t size, const struc
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
* Write a port to the log
|
* Write a port to the log
|
||||||
* +X option write in hexadecimal notation, most signifant byte on the left
|
* +X option write in hexadecimal notation, most significant byte on the left
|
||||||
*/
|
*/
|
||||||
char *lf_port(char *dst, const struct sockaddr *sockaddr, size_t size, const struct logformat_node *node)
|
char *lf_port(char *dst, const struct sockaddr *sockaddr, size_t size, const struct logformat_node *node)
|
||||||
{
|
{
|
||||||
|
@ -1142,7 +1142,7 @@ void len2mask6(int len, struct in6_addr *addr)
|
|||||||
/*
|
/*
|
||||||
* converts <str> to two struct in_addr* which must be pre-allocated.
|
* converts <str> to two struct in_addr* which must be pre-allocated.
|
||||||
* The format is "addr[/mask]", where "addr" cannot be empty, and mask
|
* The format is "addr[/mask]", where "addr" cannot be empty, and mask
|
||||||
* is optionnal and either in the dotted or CIDR notation.
|
* is optional and either in the dotted or CIDR notation.
|
||||||
* Note: "addr" can also be a hostname. Returns 1 if OK, 0 if error.
|
* Note: "addr" can also be a hostname. Returns 1 if OK, 0 if error.
|
||||||
*/
|
*/
|
||||||
int str2net(const char *str, int resolve, struct in_addr *addr, struct in_addr *mask)
|
int str2net(const char *str, int resolve, struct in_addr *addr, struct in_addr *mask)
|
||||||
@ -1193,7 +1193,7 @@ int str2net(const char *str, int resolve, struct in_addr *addr, struct in_addr *
|
|||||||
/*
|
/*
|
||||||
* converts <str> to two struct in6_addr* which must be pre-allocated.
|
* converts <str> to two struct in6_addr* which must be pre-allocated.
|
||||||
* The format is "addr[/mask]", where "addr" cannot be empty, and mask
|
* The format is "addr[/mask]", where "addr" cannot be empty, and mask
|
||||||
* is an optionnal number of bits (128 being the default).
|
* is an optional number of bits (128 being the default).
|
||||||
* Returns 1 if OK, 0 if error.
|
* Returns 1 if OK, 0 if error.
|
||||||
*/
|
*/
|
||||||
int str62net(const char *str, struct in6_addr *addr, unsigned char *mask)
|
int str62net(const char *str, struct in6_addr *addr, unsigned char *mask)
|
||||||
@ -1276,7 +1276,7 @@ int url2ipv4(const char *addr, struct in_addr *dst)
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
* Resolve destination server from URL. Convert <str> to a sockaddr_storage.
|
* Resolve destination server from URL. Convert <str> to a sockaddr_storage.
|
||||||
* <out> contain the code of the dectected scheme, the start and length of
|
* <out> contain the code of the detected scheme, the start and length of
|
||||||
* the hostname. Actually only http and https are supported. <out> can be NULL.
|
* the hostname. Actually only http and https are supported. <out> can be NULL.
|
||||||
* This function returns the consumed length. It is useful if you parse complete
|
* This function returns the consumed length. It is useful if you parse complete
|
||||||
* url like http://host:port/path, because the consumed length corresponds to
|
* url like http://host:port/path, because the consumed length corresponds to
|
||||||
@ -2187,9 +2187,9 @@ const char *parse_size_err(const char *text, unsigned *ret) {
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
* Parse binary string written in hexadecimal (source) and store the decoded
|
* Parse binary string written in hexadecimal (source) and store the decoded
|
||||||
* result into binstr and set binstrlen to the lengh of binstr. Memory for
|
* result into binstr and set binstrlen to the length of binstr. Memory for
|
||||||
* binstr is allocated by the function. In case of error, returns 0 with an
|
* binstr is allocated by the function. In case of error, returns 0 with an
|
||||||
* error message in err. In succes case, it returns the consumed length.
|
* error message in err. In success case, it returns the consumed length.
|
||||||
*/
|
*/
|
||||||
int parse_binary(const char *source, char **binstr, int *binstrlen, char **err)
|
int parse_binary(const char *source, char **binstr, int *binstrlen, char **err)
|
||||||
{
|
{
|
||||||
@ -2403,7 +2403,7 @@ int word_match(const char *sample, int slen, const char *word, int wlen)
|
|||||||
/* Converts any text-formatted IPv4 address to a host-order IPv4 address. It
|
/* Converts any text-formatted IPv4 address to a host-order IPv4 address. It
|
||||||
* is particularly fast because it avoids expensive operations such as
|
* is particularly fast because it avoids expensive operations such as
|
||||||
* multiplies, which are optimized away at the end. It requires a properly
|
* multiplies, which are optimized away at the end. It requires a properly
|
||||||
* formated address though (3 points).
|
* formatted address though (3 points).
|
||||||
*/
|
*/
|
||||||
unsigned int inetaddr_host(const char *text)
|
unsigned int inetaddr_host(const char *text)
|
||||||
{
|
{
|
||||||
@ -3765,7 +3765,7 @@ int append_prefixed_str(struct buffer *out, const char *in, const char *pfx, cha
|
|||||||
/* removes environment variable <name> from the environment as found in
|
/* removes environment variable <name> from the environment as found in
|
||||||
* environ. This is only provided as an alternative for systems without
|
* environ. This is only provided as an alternative for systems without
|
||||||
* unsetenv() (old Solaris and AIX versions). THIS IS NOT THREAD SAFE.
|
* unsetenv() (old Solaris and AIX versions). THIS IS NOT THREAD SAFE.
|
||||||
* The principle is to scan environ for each occurence of variable name
|
* The principle is to scan environ for each occurrence of variable name
|
||||||
* <name> and to replace the matching pointers with the last pointer of
|
* <name> and to replace the matching pointers with the last pointer of
|
||||||
* the array (since variables are not ordered).
|
* the array (since variables are not ordered).
|
||||||
* It always returns 0 (success).
|
* It always returns 0 (success).
|
||||||
|
@ -3276,7 +3276,7 @@ static void http_stats_io_handler(struct appctx *appctx)
|
|||||||
if (unlikely(si->state == SI_ST_DIS || si->state == SI_ST_CLO))
|
if (unlikely(si->state == SI_ST_DIS || si->state == SI_ST_CLO))
|
||||||
goto out;
|
goto out;
|
||||||
|
|
||||||
/* Check if the input buffer is avalaible. */
|
/* Check if the input buffer is available. */
|
||||||
if (!b_size(&res->buf)) {
|
if (!b_size(&res->buf)) {
|
||||||
si_rx_room_blk(si);
|
si_rx_room_blk(si);
|
||||||
goto out;
|
goto out;
|
||||||
@ -3397,7 +3397,7 @@ static int stats_dump_typed_info_fields(struct buffer *out,
|
|||||||
}
|
}
|
||||||
|
|
||||||
/* Fill <info> with HAProxy global info. <info> is preallocated
|
/* Fill <info> with HAProxy global info. <info> is preallocated
|
||||||
* array of length <len>. The length of the aray must be
|
* array of length <len>. The length of the array must be
|
||||||
* INF_TOTAL_FIELDS. If this length is less then this value, the
|
* INF_TOTAL_FIELDS. If this length is less then this value, the
|
||||||
* function returns 0, otherwise, it returns 1.
|
* function returns 0, otherwise, it returns 1.
|
||||||
*/
|
*/
|
||||||
|
@ -277,7 +277,7 @@ leave:
|
|||||||
|
|
||||||
/* Checks the next timer for the current thread by looking into its own timer
|
/* Checks the next timer for the current thread by looking into its own timer
|
||||||
* list and the global one. It may return TICK_ETERNITY if no timer is present.
|
* list and the global one. It may return TICK_ETERNITY if no timer is present.
|
||||||
* Note that the next timer might very well be slighly in the past.
|
* Note that the next timer might very well be slightly in the past.
|
||||||
*/
|
*/
|
||||||
int next_timer_expiry()
|
int next_timer_expiry()
|
||||||
{
|
{
|
||||||
|
Loading…
Reference in New Issue
Block a user