Home
last modified time | relevance | path

Searched refs:gwsreader (Results 1 – 3 of 3) sorted by relevance

/dports/sysutils/goaccess/goaccess-1.4.6/src/
H A Dgwsocket.c160 read_fifo (GWSReader * gwsreader, void (*f) (int)) { in read_fifo() argument
161 WSPacket **pa = &gwsreader->packet; in read_fifo()
167 {.fd = gwsreader->fd,.events = POLLIN,}, in read_fifo()
189 if ((bytes = ws_read_fifo (fd, gwsreader->hdr, &gwsreader->hlen, readh, need)) < 0) in read_fifo()
196 ptr = gwsreader->hdr; in read_fifo()
216 clear_fifo_packet (gwsreader); in read_fifo()
301 if (!gwsreader || !gwswriter) in stop_ws_server()
306 pthread_mutex_lock (&gwsreader->mutex); in stop_ws_server()
309 pthread_mutex_unlock (&gwsreader->mutex); in stop_ws_server()
317 reader = gwsreader->thread; in stop_ws_server()
[all …]
H A Dgwsocket.h64 int read_fifo (GWSReader * gwsreader, void (*f) (int));
66 int setup_ws_server (GWSWriter * gwswriter, GWSReader * gwsreader);
69 void stop_ws_server (GWSWriter * gwswriter, GWSReader * gwsreader);
H A Dgoaccess.c93 static GWSReader *gwsreader; variable
202 free (gwsreader); in house_keeping()
1325 stop_ws_server (gwswriter, gwsreader);
1428 gwsreader = new_gwsreader ();
1436 if ((gwsreader->fd = open_fifoout ()) == -1) {
1443 setup_ws_server (gwswriter, gwsreader);