mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-08-08 16:17:09 +02:00
Code Issues Projects Releases Wiki Activity
d93e6ec4cc
haproxy/contrib/debug/flags.c
Willy Tarreau 19bc201c9f MEDIUM: connection: remove the intermediary polling state from the connection 
Historically we used to require that the connections held the desired
polling states for the data layer and the socket layer. Then with muxes
these were more or less merged into the transport layer, and now it
happens that with all transport layers having their own state, the
"transport layer state" as we have it in the connection (XPRT_RD_ENA,
XPRT_WR_ENA) is only an exact copy of the undelying file descriptor
state, but with a delay. All of this is causing some difficulties at
many places in the code because there are still some locations which
use the conn_want_* API to remain clean and only rely on connection,
and count on a later collection call to conn_cond_update_polling(),
while others need an immediate action and directly use the FD updates.

Since our updates are now much cheaper, most of them being only an
atomic test-and-set operation, and since our I/O callbacks are deferred,
there's no benefit anymore in trying to "cache" the transient state
change in the connection flags hoping to cancel them before they
become an FD event. Better make such calls transparent indirections
to the FD layer instead and get rid of the deferred operations which
needlessly complicate the logic inside.

This removes flags CO_FL_XPRT_{RD,WR}_ENA and CO_FL_WILL_UPDATE.
A number of functions related to polling updates were either greatly
simplified or removed.

Two places were using CO_FL_XPRT_WR_ENA as a hint to know if more data
were expected to be sent after a PROXY protocol or SOCKSv4 header. These
ones were simply replaced with a check on the subscription which is
where we ought to get the autoritative information from.

Now the __conn_xprt_want_* and their conn_xprt_want_* counterparts
are the same. conn_stop_polling() and conn_xprt_stop_both() are the
same as well. conn_cond_update_polling() only causes errors to stop
polling. It also becomes way more obvious that muxes should not at
all employ conn_xprt_{want|stop}_{recv,send}(), and that the call
to __conn_xprt_stop_recv() in case a mux failed to allocate a buffer
is inappropriate, it ought to unsubscribe from reads instead. All of
this definitely requires a serious cleanup.
2020-02-21 11:21:12 +01:00

474 lines
13 KiB
C
Raw Blame History

#include <stdio.h>
#include <stdlib.h>
#include <types/channel.h>
#include <types/connection.h>
#include <types/http_ana.h>
#include <types/stream.h>
#include <types/stream_interface.h>
#include <types/task.h>
// 1 bit per flag, no hole permitted here
#define SHOW_AS_ANA 0x00000001
#define SHOW_AS_CHN 0x00000002
#define SHOW_AS_CONN 0x00000004
#define SHOW_AS_CS 0x00000008
#define SHOW_AS_SI 0x00000010
#define SHOW_AS_SIET 0x00000020
#define SHOW_AS_STRM 0x00000040
#define SHOW_AS_TASK 0x00000080
#define SHOW_AS_TXN 0x00000100
// command line names, must be in exact same order as the SHOW_AS_* flags above
// so that show_as_words[i] matches flag 1U<<i.
const char *show_as_words[] = { "ana", "chn", "conn", "cs", "si", "siet", "strm", "task", "txn", };
#define SHOW_FLAG(f,n) \
do { \
if (!((f) & (n))) break; \
(f) &= ~(n); \
printf(#n"%s", (f) ? " | " : ""); \
} while (0)
unsigned int get_show_as(const char *word)
{
int w = 0;
while (1) {
if (w == sizeof(show_as_words) / sizeof(*show_as_words))
return 0;
if (strcmp(word, show_as_words[w]) == 0)
return 1U << w;
w++;
}
}
void show_chn_ana(unsigned int f)
{
printf("chn->ana = ");
if (!f) {
printf("0\n");
return;
}
SHOW_FLAG(f, AN_REQ_FLT_START_FE);
SHOW_FLAG(f, AN_REQ_INSPECT_FE);
SHOW_FLAG(f, AN_REQ_WAIT_HTTP);
SHOW_FLAG(f, AN_REQ_HTTP_BODY);
SHOW_FLAG(f, AN_REQ_HTTP_PROCESS_FE);
SHOW_FLAG(f, AN_REQ_SWITCHING_RULES);
SHOW_FLAG(f, AN_REQ_FLT_START_BE);
SHOW_FLAG(f, AN_REQ_INSPECT_BE);
SHOW_FLAG(f, AN_REQ_HTTP_PROCESS_BE);
SHOW_FLAG(f, AN_REQ_HTTP_TARPIT);
SHOW_FLAG(f, AN_REQ_SRV_RULES);
SHOW_FLAG(f, AN_REQ_HTTP_INNER);
SHOW_FLAG(f, AN_REQ_PRST_RDP_COOKIE);
SHOW_FLAG(f, AN_REQ_STICKING_RULES);
SHOW_FLAG(f, AN_REQ_FLT_HTTP_HDRS);
SHOW_FLAG(f, AN_REQ_HTTP_XFER_BODY);
SHOW_FLAG(f, AN_REQ_FLT_XFER_DATA);
SHOW_FLAG(f, AN_REQ_FLT_END);
SHOW_FLAG(f, AN_RES_FLT_START_FE);
SHOW_FLAG(f, AN_RES_FLT_START_BE);
SHOW_FLAG(f, AN_RES_INSPECT);
SHOW_FLAG(f, AN_RES_WAIT_HTTP);
SHOW_FLAG(f, AN_RES_STORE_RULES);
SHOW_FLAG(f, AN_RES_HTTP_PROCESS_FE);
SHOW_FLAG(f, AN_RES_HTTP_PROCESS_BE);
SHOW_FLAG(f, AN_RES_FLT_HTTP_HDRS);
SHOW_FLAG(f, AN_RES_HTTP_XFER_BODY);
SHOW_FLAG(f, AN_RES_FLT_XFER_DATA);
SHOW_FLAG(f, AN_RES_FLT_END);
if (f) {
printf("EXTRA(0x%08x)", f);
}
putchar('\n');
}
void show_chn_flags(unsigned int f)
{
printf("chn->flags = ");
if (!f) {
printf("0\n");
return;
}
SHOW_FLAG(f, CF_ISRESP);
SHOW_FLAG(f, CF_EOI);
SHOW_FLAG(f, CF_FLT_ANALYZE);
SHOW_FLAG(f, CF_WAKE_ONCE);
SHOW_FLAG(f, CF_NEVER_WAIT);
SHOW_FLAG(f, CF_SEND_DONTWAIT);
SHOW_FLAG(f, CF_EXPECT_MORE);
SHOW_FLAG(f, CF_DONT_READ);
SHOW_FLAG(f, CF_AUTO_CONNECT);
SHOW_FLAG(f, CF_READ_DONTWAIT);
SHOW_FLAG(f, CF_KERN_SPLICING);
SHOW_FLAG(f, CF_READ_ATTACHED);
SHOW_FLAG(f, CF_ANA_TIMEOUT);
SHOW_FLAG(f, CF_WROTE_DATA);
SHOW_FLAG(f, CF_STREAMER_FAST);
SHOW_FLAG(f, CF_STREAMER);
SHOW_FLAG(f, CF_AUTO_CLOSE);
SHOW_FLAG(f, CF_SHUTW_NOW);
SHOW_FLAG(f, CF_SHUTW);
SHOW_FLAG(f, CF_WAKE_WRITE);
SHOW_FLAG(f, CF_WRITE_ERROR);
SHOW_FLAG(f, CF_WRITE_TIMEOUT);
SHOW_FLAG(f, CF_WRITE_PARTIAL);
SHOW_FLAG(f, CF_WRITE_NULL);
SHOW_FLAG(f, CF_READ_NOEXP);
SHOW_FLAG(f, CF_SHUTR_NOW);
SHOW_FLAG(f, CF_SHUTR);
SHOW_FLAG(f, CF_READ_ERROR);
SHOW_FLAG(f, CF_READ_TIMEOUT);
SHOW_FLAG(f, CF_READ_PARTIAL);
SHOW_FLAG(f, CF_READ_NULL);
if (f) {
printf("EXTRA(0x%08x)", f);
}
putchar('\n');
}
void show_conn_flags(unsigned int f)
{
printf("conn->flags = ");
if (!f) {
printf("0\n");
return;
}
SHOW_FLAG(f, CO_FL_XPRT_TRACKED);
SHOW_FLAG(f, CO_FL_RCVD_PROXY);
SHOW_FLAG(f, CO_FL_PRIVATE);
SHOW_FLAG(f, CO_FL_ACCEPT_CIP);
SHOW_FLAG(f, CO_FL_ACCEPT_PROXY);
SHOW_FLAG(f, CO_FL_SSL_WAIT_HS);
SHOW_FLAG(f, CO_FL_SEND_PROXY);
SHOW_FLAG(f, CO_FL_WAIT_L6_CONN);
SHOW_FLAG(f, CO_FL_WAIT_L4_CONN);
SHOW_FLAG(f, CO_FL_ERROR);
SHOW_FLAG(f, CO_FL_SOCK_WR_SH);
SHOW_FLAG(f, CO_FL_SOCK_RD_SH);
SHOW_FLAG(f, CO_FL_SOCKS4_RECV);
SHOW_FLAG(f, CO_FL_SOCKS4_SEND);
SHOW_FLAG(f, CO_FL_EARLY_DATA);
SHOW_FLAG(f, CO_FL_EARLY_SSL_HS);
SHOW_FLAG(f, CO_FL_ADDR_TO_SET);
SHOW_FLAG(f, CO_FL_ADDR_FROM_SET);
SHOW_FLAG(f, CO_FL_WAIT_ROOM);
SHOW_FLAG(f, CO_FL_XPRT_READY);
SHOW_FLAG(f, CO_FL_CTRL_READY);
if (f) {
printf("EXTRA(0x%08x)", f);
}
putchar('\n');
}
void show_cs_flags(unsigned int f)
{
printf("cs->flags = ");
if (!f) {
printf("0\n");
return;
}
SHOW_FLAG(f, CS_FL_READ_PARTIAL);
SHOW_FLAG(f, CS_FL_NOT_FIRST);
SHOW_FLAG(f, CS_FL_KILL_CONN);
SHOW_FLAG(f, CS_FL_WAIT_FOR_HS);
SHOW_FLAG(f, CS_FL_EOI);
SHOW_FLAG(f, CS_FL_EOS);
SHOW_FLAG(f, CS_FL_ERR_PENDING);
SHOW_FLAG(f, CS_FL_WANT_ROOM);
SHOW_FLAG(f, CS_FL_RCV_MORE);
SHOW_FLAG(f, CS_FL_ERROR);
SHOW_FLAG(f, CS_FL_SHWS);
SHOW_FLAG(f, CS_FL_SHWN);
SHOW_FLAG(f, CS_FL_SHRR);
SHOW_FLAG(f, CS_FL_SHRD);
if (f) {
printf("EXTRA(0x%08x)", f);
}
putchar('\n');
}
void show_si_et(unsigned int f)
{
printf("si->et = ");
if (!f) {
printf("SI_ET_NONE\n");
return;
}
SHOW_FLAG(f, SI_ET_QUEUE_TO);
SHOW_FLAG(f, SI_ET_QUEUE_ERR);
SHOW_FLAG(f, SI_ET_QUEUE_ABRT);
SHOW_FLAG(f, SI_ET_CONN_TO);
SHOW_FLAG(f, SI_ET_CONN_ERR);
SHOW_FLAG(f, SI_ET_CONN_ABRT);
SHOW_FLAG(f, SI_ET_CONN_RES);
SHOW_FLAG(f, SI_ET_CONN_OTHER);
SHOW_FLAG(f, SI_ET_DATA_TO);
SHOW_FLAG(f, SI_ET_DATA_ERR);
SHOW_FLAG(f, SI_ET_DATA_ABRT);
if (f) {
printf("EXTRA(0x%08x)", f);
}
putchar('\n');
}
void show_si_flags(unsigned int f)
{
printf("si->flags = ");
if (!f) {
printf("SI_FL_NONE\n");
return;
}
SHOW_FLAG(f, SI_FL_EXP);
SHOW_FLAG(f, SI_FL_ERR);
SHOW_FLAG(f, SI_FL_RXBLK_ROOM);
SHOW_FLAG(f, SI_FL_WAIT_DATA);
SHOW_FLAG(f, SI_FL_ISBACK);
SHOW_FLAG(f, SI_FL_DONT_WAKE);
SHOW_FLAG(f, SI_FL_INDEP_STR);
SHOW_FLAG(f, SI_FL_NOLINGER);
SHOW_FLAG(f, SI_FL_NOHALF);
SHOW_FLAG(f, SI_FL_SRC_ADDR);
SHOW_FLAG(f, SI_FL_WANT_GET);
SHOW_FLAG(f, SI_FL_CLEAN_ABRT);
SHOW_FLAG(f, SI_FL_RXBLK_CHAN);
SHOW_FLAG(f, SI_FL_RXBLK_BUFF);
SHOW_FLAG(f, SI_FL_RXBLK_ROOM);
SHOW_FLAG(f, SI_FL_RXBLK_SHUT);
SHOW_FLAG(f, SI_FL_RX_WAIT_EP);
if (f) {
printf("EXTRA(0x%08x)", f);
}
putchar('\n');
}
void show_task_state(unsigned int f)
{
printf("task->state = ");
if (!f) {
printf("TASK_SLEEPING\n");
return;
}
SHOW_FLAG(f, TASK_WOKEN_OTHER);
SHOW_FLAG(f, TASK_WOKEN_RES);
SHOW_FLAG(f, TASK_WOKEN_MSG);
SHOW_FLAG(f, TASK_WOKEN_SIGNAL);
SHOW_FLAG(f, TASK_WOKEN_IO);
SHOW_FLAG(f, TASK_WOKEN_TIMER);
SHOW_FLAG(f, TASK_WOKEN_INIT);
SHOW_FLAG(f, TASK_RUNNING);
if (f) {
printf("EXTRA(0x%08x)", f);
}
putchar('\n');
}
void show_txn_flags(unsigned int f)
{
printf("txn->flags = ");
if (!f) {
printf("0\n");
return;
}
SHOW_FLAG(f, TX_NOT_FIRST);
SHOW_FLAG(f, TX_USE_PX_CONN);
SHOW_FLAG(f, TX_WAIT_NEXT_RQ);
SHOW_FLAG(f, TX_CON_WANT_TUN);
SHOW_FLAG(f, TX_CACHE_COOK);
SHOW_FLAG(f, TX_CACHEABLE);
SHOW_FLAG(f, TX_SCK_PRESENT);
//printf("%s", f ? "" : " | ");
switch (f & TX_SCK_MASK) {
case TX_SCK_NONE: f &= ~TX_SCK_MASK ; /*printf("TX_SCK_NONE%s", f ? " | " : "");*/ break;
case TX_SCK_FOUND: f &= ~TX_SCK_MASK ; printf("TX_SCK_FOUND%s", f ? " | " : ""); break;
case TX_SCK_DELETED: f &= ~TX_SCK_MASK ; printf("TX_SCK_DELETED%s", f ? " | " : ""); break;
case TX_SCK_INSERTED: f &= ~TX_SCK_MASK ; printf("TX_SCK_INSERTED%s", f ? " | " : ""); break;
case TX_SCK_REPLACED: f &= ~TX_SCK_MASK ; printf("TX_SCK_REPLACED%s", f ? " | " : ""); break;
case TX_SCK_UPDATED: f &= ~TX_SCK_MASK ; printf("TX_SCK_UPDATED%s", f ? " | " : ""); break;
default: printf("TX_SCK_MASK(%02x)", f); f &= ~TX_SCK_MASK ; printf("%s", f ? " | " : ""); break;
}
//printf("%s", f ? "" : " | ");
switch (f & TX_CK_MASK) {
case TX_CK_NONE: f &= ~TX_CK_MASK ; /*printf("TX_CK_NONE%s", f ? " | " : "");*/ break;
case TX_CK_INVALID: f &= ~TX_CK_MASK ; printf("TX_CK_INVALID%s", f ? " | " : ""); break;
case TX_CK_DOWN: f &= ~TX_CK_MASK ; printf("TX_CK_DOWN%s", f ? " | " : ""); break;
case TX_CK_VALID: f &= ~TX_CK_MASK ; printf("TX_CK_VALID%s", f ? " | " : ""); break;
case TX_CK_EXPIRED: f &= ~TX_CK_MASK ; printf("TX_CK_EXPIRED%s", f ? " | " : ""); break;
case TX_CK_OLD: f &= ~TX_CK_MASK ; printf("TX_CK_OLD%s", f ? " | " : ""); break;
case TX_CK_UNUSED: f &= ~TX_CK_MASK ; printf("TX_CK_UNUSED%s", f ? " | " : ""); break;
default: printf("TX_CK_MASK(%02x)", f); f &= ~TX_CK_MASK ; printf("%s", f ? " | " : ""); break;
}
SHOW_FLAG(f, TX_CLTARPIT);
SHOW_FLAG(f, TX_SVALLOW);
SHOW_FLAG(f, TX_SVDENY);
SHOW_FLAG(f, TX_CLALLOW);
SHOW_FLAG(f, TX_CLDENY);
if (f) {
printf("EXTRA(0x%08x)", f);
}
putchar('\n');
}
void show_strm_flags(unsigned int f)
{
printf("strm->flags = ");
if (!f) {
printf("0\n");
return;
}
SHOW_FLAG(f, SF_SRV_REUSED);
SHOW_FLAG(f, SF_IGNORE_PRST);
//printf("%s", f ? "" : " | ");
switch (f & SF_FINST_MASK) {
case SF_FINST_R: f &= ~SF_FINST_MASK ; printf("SF_FINST_R%s", f ? " | " : ""); break;
case SF_FINST_C: f &= ~SF_FINST_MASK ; printf("SF_FINST_C%s", f ? " | " : ""); break;
case SF_FINST_H: f &= ~SF_FINST_MASK ; printf("SF_FINST_H%s", f ? " | " : ""); break;
case SF_FINST_D: f &= ~SF_FINST_MASK ; printf("SF_FINST_D%s", f ? " | " : ""); break;
case SF_FINST_L: f &= ~SF_FINST_MASK ; printf("SF_FINST_L%s", f ? " | " : ""); break;
case SF_FINST_Q: f &= ~SF_FINST_MASK ; printf("SF_FINST_Q%s", f ? " | " : ""); break;
case SF_FINST_T: f &= ~SF_FINST_MASK ; printf("SF_FINST_T%s", f ? " | " : ""); break;
}
switch (f & SF_ERR_MASK) {
case SF_ERR_LOCAL: f &= ~SF_ERR_MASK ; printf("SF_ERR_LOCAL%s", f ? " | " : ""); break;
case SF_ERR_CLITO: f &= ~SF_ERR_MASK ; printf("SF_ERR_CLITO%s", f ? " | " : ""); break;
case SF_ERR_CLICL: f &= ~SF_ERR_MASK ; printf("SF_ERR_CLICL%s", f ? " | " : ""); break;
case SF_ERR_SRVTO: f &= ~SF_ERR_MASK ; printf("SF_ERR_SRVTO%s", f ? " | " : ""); break;
case SF_ERR_SRVCL: f &= ~SF_ERR_MASK ; printf("SF_ERR_SRVCL%s", f ? " | " : ""); break;
case SF_ERR_PRXCOND: f &= ~SF_ERR_MASK ; printf("SF_ERR_PRXCOND%s", f ? " | " : ""); break;
case SF_ERR_RESOURCE: f &= ~SF_ERR_MASK ; printf("SF_ERR_RESOURCE%s", f ? " | " : ""); break;
case SF_ERR_INTERNAL: f &= ~SF_ERR_MASK ; printf("SF_ERR_INTERNAL%s", f ? " | " : ""); break;
case SF_ERR_DOWN: f &= ~SF_ERR_MASK ; printf("SF_ERR_DOWN%s", f ? " | " : ""); break;
case SF_ERR_KILLED: f &= ~SF_ERR_MASK ; printf("SF_ERR_KILLED%s", f ? " | " : ""); break;
case SF_ERR_UP: f &= ~SF_ERR_MASK ; printf("SF_ERR_UP%s", f ? " | " : ""); break;
case SF_ERR_CHK_PORT: f &= ~SF_ERR_MASK ; printf("SF_ERR_CHK_PORT%s", f ? " | " : ""); break;
}
SHOW_FLAG(f, SF_HTX);
SHOW_FLAG(f, SF_REDIRECTABLE);
SHOW_FLAG(f, SF_IGNORE);
SHOW_FLAG(f, SF_REDISP);
SHOW_FLAG(f, SF_CURR_SESS);
SHOW_FLAG(f, SF_MONITOR);
SHOW_FLAG(f, SF_FORCE_PRST);
SHOW_FLAG(f, SF_BE_ASSIGNED);
SHOW_FLAG(f, SF_ADDR_SET);
SHOW_FLAG(f, SF_ASSIGNED);
SHOW_FLAG(f, SF_DIRECT);
if (f) {
printf("EXTRA(0x%08x)", f);
}
putchar('\n');
}
void usage_exit(const char *name)
{
fprintf(stderr, "Usage: %s [ana|chn|conn|cs|si|sierr|strm|task|txn]* { [+-][0x]value* | - }\n", name);
exit(1);
}
int main(int argc, char **argv)
{
unsigned int flags;
unsigned int show_as = 0;
unsigned int f;
const char *name = argv[0];
char line[20];
char *value;
int multi = 0;
int use_stdin = 0;
char *err;
while (argc > 0) {
argv++; argc--;
if (argc < 1)
usage_exit(name);
f = get_show_as(argv[0]);
if (!f)
break;
show_as |= f;
}
if (!show_as)
show_as = ~0U;
if (argc > 1)
multi = 1;
if (strcmp(argv[0], "-") == 0)
use_stdin = 1;
while (argc > 0) {
if (use_stdin) {
value = fgets(line, sizeof(line), stdin);
if (!value)
break;
/* skip common leading delimitors that slip from copy-paste */
while (*value == ' ' || *value == '\t' || *value == ':' || *value == '=')
value++;
/* stop at the end of the number and trim any C suffix like "UL" */
err = value;
while (*err == '-' || *err == '+' ||
(isalnum(*err) && toupper(*err) != 'U' && toupper(*err) != 'L'))
err++;
if (err)
*err = 0;
} else {
value = argv[0];
argv++; argc--;
}
flags = strtoul(value, &err, 0);
if (!*value || *err) {
fprintf(stderr, "Unparsable value: <%s>\n", value);
usage_exit(name);
}
if (multi || use_stdin)
printf("### 0x%08x:\n", flags);
if (show_as & SHOW_AS_ANA) show_chn_ana(flags);
if (show_as & SHOW_AS_CHN) show_chn_flags(flags);
if (show_as & SHOW_AS_CONN) show_conn_flags(flags);
if (show_as & SHOW_AS_CS) show_cs_flags(flags);
if (show_as & SHOW_AS_SI) show_si_flags(flags);
if (show_as & SHOW_AS_SIET) show_si_et(flags);
if (show_as & SHOW_AS_STRM) show_strm_flags(flags);
if (show_as & SHOW_AS_TASK) show_task_state(flags);
if (show_as & SHOW_AS_TXN) show_txn_flags(flags);
}
return 0;
}
Reference in New Issue View Git Blame Copy Permalink