#define HTTP_MSG_CLOSED 35 // shutdown_w done, all bytes sent
#define HTTP_MSG_TUNNEL 36 // tunneled data after DONE
-/* various data sources for the responses */
-#define DATA_SRC_NONE 0
-#define DATA_SRC_STATS 1
-
/* data transmission states for the stats responses */
enum {
DATA_ST_INIT = 0,
void (*do_log)(struct session *s); /* the function to call in order to log (or NULL) */
void (*srv_error)(struct session *s, /* the function to call upon unrecoverable server errors (or NULL) */
struct stream_interface *si);
- short int data_source; /* where to get the data we generate ourselves */
short int data_state; /* where to get the data we generate ourselves */
union {
struct {
s->logs.srv_queue_size = 0; /* we will get this number soon */
s->data_state = DATA_ST_INIT;
- s->data_source = DATA_SRC_NONE;
s->req->flags |= BF_READ_DONTWAIT; /* we plan to read small requests */
if (si->applet.st0 == STAT_CLI_INIT) {
/* Stats output not initialized yet */
memset(&s->data_ctx.stats, 0, sizeof(s->data_ctx.stats));
- s->data_source = DATA_SRC_STATS;
si->applet.st0 = STAT_CLI_GETREQ;
}
else if (si->applet.st0 == STAT_CLI_END) {
s->logs.srv_queue_size = 0; /* we will get this number soon */
s->data_state = DATA_ST_INIT;
- s->data_source = DATA_SRC_NONE;
/* FIXME: the logs are horribly complicated now, because they are
* defined in <p>, <p>, and later <be> and <be>.
/* default error reporting function, may be changed by analysers */
s->srv_error = default_srv_error;
- s->data_source = DATA_SRC_NONE;
-
s->uniq_id = 0;
txn = &s->txn;
}
s->logs.tv_request = now;
- s->data_source = DATA_SRC_STATS;
s->data_state = DATA_ST_INIT;
s->task->nice = -32; /* small boost for HTTP statistics */
stream_int_register_handler(s->rep->prod, &http_stats_applet);