RepoMirrors
/
haproxy
mirror of http://git.haproxy.org/git/haproxy.git/
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

MINOR: spoa_example: Count the number of frames processed by each worker 

This is done for debug purpose. This way, it is easy to know if the load is
equally distributed between workers.
This commit is contained in:
Christopher Faulet 2018-01-23 14:46:51 +01:00 committed by Willy Tarreau
parent b077cdc012
commit 0b89f72e88
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
contrib/spoa_example/spoa.c
View File

@ -150,6 +150,7 @@ struct worker {
struct list clients;
struct list frames;
unsigned int nbframes;
};
@ -1287,7 +1288,7 @@ worker_monitor_cb(evutil_socket_t fd, short events, void *arg)
{
struct worker *worker = arg;
LOG(worker, "%u clients connected", worker->nbclients);
LOG(worker, "%u clients connected (%u frames)", worker->nbclients, worker->nbframes);
}
static void
@ -1330,7 +1331,7 @@ process_frame_cb(evutil_socket_t fd, short events, void *arg)
goto stop_processing;
if (spoe_decode_data(&p, end, &data, &type) == -1)
goto skip_message;
frame->worker->nbframes++;
if (type == SPOE_DATA_T_IPV4)
check_ipv4_reputation(frame, &data.ipv4);
if (type == SPOE_DATA_T_IPV6)
@ -1819,6 +1820,7 @@ main(int argc, char **argv)
w->id = i+1;
w->nbclients = 0;
w->nbframes = 0;
LIST_INIT(&w->engines);
LIST_INIT(&w->clients);
LIST_INIT(&w->frames);