#include "network.h"

Include dependency graph for socket.c:

Functions
static	DEFINE_MUTEX (worker_socket_lock)

struct socket *	get_worker_socket (void)

struct socket *	set_worker_socket (struct socket *s)

int	close_worker_socket (void)

int	connect_worker_socket_to_server (struct sockaddr_in *addr)

Variables
static struct socket *	worker_socket = NULL

Function Documentation

◆ close_worker_socket()

int close_worker_socket ( void )

close_worker_socket - Closes the worker socket. Return: 0 on success, or an error code on failure.

Definition at line 43 of file socket.c.

                              {
    mutex_lock(&worker_socket_lock);
    if (worker_socket) {
        sock_release(worker_socket);
        worker_socket = NULL;
        DBG_MSG("close_worker_socket: socket released\n");
    }
    mutex_unlock(&worker_socket_lock);
    return SUCCESS;
}

◆ connect_worker_socket_to_server()

int connect_worker_socket_to_server ( struct sockaddr_in * addr )

connect_worker_socket_to_server - Connects the worker socket to the server.

Parameters

addr	The server address to connect to. Return: 0 on success, or a negative error code on failure.

Definition at line 59 of file socket.c.

                                                              {
    int ret;
    struct socket *s;
 
    ret = sock_create(AF_INET, SOCK_STREAM, IPPROTO_TCP, &s);
    if (ret < 0) {
        ERR_MSG("connect_worker_socket: failed to create socket (ret=%d)\n", ret);
        return ret;
    }
 
    ret = kernel_connect(s, (struct sockaddr *)addr, sizeof(*addr), 0);
    if (ret < 0) {
        ERR_MSG("connect_worker_socket: connection failed (ret=%d)\n", ret);
        sock_release(s);
        return ret;
    }
 
    set_worker_socket(s);
    DBG_MSG("connect_worker_socket: connection successful\n");
    return SUCCESS;
}

◆ DEFINE_MUTEX()

static DEFINE_MUTEX ( worker_socket_lock )

static

◆ get_worker_socket()

struct socket * get_worker_socket ( void )

Definition at line 17 of file socket.c.

                                       {
    struct socket *s;
    mutex_lock(&worker_socket_lock);
    s = worker_socket;
    mutex_unlock(&worker_socket_lock);
    return s;
}

◆ set_worker_socket()

struct socket * set_worker_socket ( struct socket * s )

set_worker_socket - Sets the worker socket.

Parameters

s	The socket to set as the worker socket. Return: Pointer to the newly set worker socket.

Definition at line 30 of file socket.c.

                                                   {
    mutex_lock(&worker_socket_lock);
    if (worker_socket)
        sock_release(worker_socket);
    worker_socket = s;
    mutex_unlock(&worker_socket_lock);
    return worker_socket;
}

Variable Documentation

◆ worker_socket

struct socket* worker_socket = NULL