socket_msu.c File Reference

#include "socket_msu.h"
#include "local_msu.h"
#include "epollops.h"
#include "logging.h"
#include "msu_message.h"
#include "runtime_dfg.h"
#include "communication.h"
#include "msu_calls.h"
#include "rt_stats.h"
#include <sys/epoll.h>
#include <stdlib.h>
#include <netinet/ip.h>

Go to the source code of this file.

Classes
struct	sock_msu_state
struct	key_seed
struct	sock_init

Macros
#define	MAX_FDS   65536
#define	SOCKET_HANDLER_TIMEOUT   500
#define	SOCKET_HANDLER_BATCH_SIZE   1000
#define	MONITOR_NUM_FDS
#define	DEFAULT_PORT   8080
#define	DEFAULT_TARGET   501
#define	INIT_SYNTAX   "<port>, <target_msu_type>"

Functions
int	msu_monitor_fd (int fd, uint32_t events, struct local_msu *destination, struct msu_msg_hdr *hdr)
int	msu_remove_fd_monitor (int fd)
static int	process_connection (int fd, void *v_state)
static int	set_default_target (int fd, void *v_state)
static int	socket_handler_main_loop (struct local_msu *self)
static int	socket_msu_receive (struct local_msu *self, struct msu_msg *msg)
static void	socket_msu_destroy (struct local_msu *self)
static int	parse_init_payload (char *to_parse, struct sock_init *parsed)
static int	socket_msu_init (struct local_msu *self, struct msu_init_data *init_data)

Variables
struct local_msu *	instance
struct msu_msg_hdr	blank_hdr = {}
struct msu_msg_key	self_key
struct msu_type	SOCKET_MSU_TYPE

Macro Definition Documentation

#define DEFAULT_PORT   8080

Definition at line 216 of file socket_msu.c.

#define DEFAULT_TARGET   501

Definition at line 217 of file socket_msu.c.

#define INIT_SYNTAX   "<port>, <target_msu_type>"

Definition at line 218 of file socket_msu.c.

#define MAX_FDS   65536

Definition at line 34 of file socket_msu.c.

#define MONITOR_NUM_FDS

Definition at line 56 of file socket_msu.c.

#define SOCKET_HANDLER_BATCH_SIZE   1000

Definition at line 49 of file socket_msu.c.

#define SOCKET_HANDLER_TIMEOUT   500

Definition at line 48 of file socket_msu.c.

Function Documentation

int msu_monitor_fd	(	int	fd,
		uint32_t	events,
		struct local_msu *	destination,
		struct msu_msg_hdr *	hdr
	)

Definition at line 58 of file socket_msu.c.

int msu_remove_fd_monitor

(

int

fd

)

Definition at line 87 of file socket_msu.c.

static int parse_init_payload ( char *  to_parse, struct sock_init *  parsed  )

static

Definition at line 225 of file socket_msu.c.

static int process_connection ( int  fd, void *  v_state  )

static

Definition at line 113 of file socket_msu.c.

static int set_default_target ( int  fd, void *  v_state  )

static

Definition at line 168 of file socket_msu.c.

static int socket_handler_main_loop ( struct local_msu *  self )

static

Definition at line 177 of file socket_msu.c.

static void socket_msu_destroy ( struct local_msu *  self )

static

Definition at line 199 of file socket_msu.c.

static int socket_msu_init ( struct local_msu *  self, struct msu_init_data *  init_data  )

static

Definition at line 255 of file socket_msu.c.

static int socket_msu_receive ( struct local_msu *  self, struct msu_msg *  msg  )

static

Definition at line 189 of file socket_msu.c.

Variable Documentation

struct msu_msg_hdr blank_hdr = {}

Definition at line 85 of file socket_msu.c.

struct local_msu* instance

Definition at line 36 of file socket_msu.c.

struct msu_msg_key self_key

Initial value:

= {
    .key = {0},
    .key_len = 0,
    .id = 0
}

Definition at line 107 of file socket_msu.c.

struct msu_type SOCKET_MSU_TYPE

Initial value:

= {
    .name = "socket_msu",
    .id =  10 ,
    .init = socket_msu_init,
    .destroy = socket_msu_destroy,
    .receive = socket_msu_receive
}

Definition at line 304 of file socket_msu.c.