Searched refs:gwsreader (Results 1 – 3 of 3) sorted by relevance
/dports/sysutils/goaccess/goaccess-1.4.6/src/ |
H A D | gwsocket.c | 160 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 D | gwsocket.h | 64 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 D | goaccess.c | 93 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);
|