socket.h

Go to the documentation of this file.

#ifndef SOCKET_H
#define SOCKET_H
 
#include <errno.h>
#include <stddef.h>
#include <stdint.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/time.h>
 
#include "bounded_queue.h"

typedef struct listener_t {
    int sockfd; /* UDP Port */
    bounded_queue_t *bounded_q; /* Work queue associated with queue */
    size_t max_line; /* The max lines work queue can handel*/
    pthread_t thread; /* Listening and populating thread */
    int started; /* Operation flag */
    volatile int done; /* Atomic flag, for listener's thread, avoid compiler reordering for read/write on thread operations.*/
} listener_t;

listener_t *listener_create(int port, bounded_queue_t *bounded_q, size_t max_line);

int listener_start(listener_t *listener);

void listener_stop(listener_t *listener);

void listener_destroy(listener_t *listener);
#endif