socket.c File Reference

#include "headers/socket.h"

Functions
static void *	listener_loop (void *arg)
	Looping function for socket thread.
listener_t *	listener_create (int port, bounded_queue_t *bounded_q, size_t max_line)
	Allocate a listener bound to the given UDP port.
int	listener_start (listener_t *listener)
	Spawn the receive thread.
void	listener_stop (listener_t *listener)
	Signal the receive thread to exit and join it. Does NOT shut down the queue — caller decides when to call bq_shutdown.
void	listener_destroy (listener_t *listener)
	Free the listener and close its socket.

Function Documentation

listener_create()

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

Allocate a listener bound to the given UDP port.

Parameters

port	UDP port to bind on.
bounded_q	Queue raw lines are pushed onto. Listener does NOT take ownership — caller manages lifetime.
max_line	The max buffer length per line.

Returns

Listener handle on success, NULL on socket/bind/alloc failure.

listener_destroy()

void listener_destroy

(

listener_t *

listener

)

Free the listener and close its socket.

Parameters

listener

Listener to destroy.

listener_loop()

void * listener_loop ( void * arg )

static

Looping function for socket thread.

Parameters

arg	The listener_t of the connection

listener_start()

int listener_start

(

listener_t *

listener

)

Spawn the receive thread.

Parameters

listener

Listener to start.

Returns

0 on success, -1 if pthread_create failed, -2 already started.

listener_stop()

void listener_stop

(

listener_t *

listener

)

Signal the receive thread to exit and join it. Does NOT shut down the queue — caller decides when to call bq_shutdown.

Parameters

listener

Listener to stop.