net_util.h

Go to the documentation of this file.

 
#ifndef NET_UTIL_H
#define NET_UTIL_H
 
#ifdef PLATFORM_ARDUINO
#error To be implemented. No support for federation on Arduino yet.
#else
#include <sys/socket.h>
#include <regex.h>
#endif
 
#include <sys/types.h>
#include <stdbool.h>
 
#include "low_level_platform.h"
#include "tag.h"
 
#define NUM_SOCKET_RETRIES 10
#define DELAY_BETWEEN_SOCKET_RETRIES MSEC(100)
 
#define HOST_LITTLE_ENDIAN 1
#define HOST_BIG_ENDIAN 2
 
int host_is_big_endian(void);
 
#ifdef FEDERATED
 
extern lf_mutex_t socket_mutex;
 
int create_real_time_tcp_socket_errexit();
 
int read_from_socket(int socket, size_t num_bytes, unsigned char* buffer);
 
int read_from_socket_close_on_error(int* socket, size_t num_bytes, unsigned char* buffer);
 
void read_from_socket_fail_on_error(int* socket, size_t num_bytes, unsigned char* buffer, lf_mutex_t* mutex,
                                    char* format, ...);
 
ssize_t peek_from_socket(int socket, unsigned char* result);
 
int write_to_socket(int socket, size_t num_bytes, unsigned char* buffer);
 
int write_to_socket_close_on_error(int* socket, size_t num_bytes, unsigned char* buffer);
 
void write_to_socket_fail_on_error(int* socket, size_t num_bytes, unsigned char* buffer, lf_mutex_t* mutex,
                                   char* format, ...);
 
#endif // FEDERATED
 
void encode_int64(int64_t data, unsigned char* buffer);
 
void encode_int32(int32_t data, unsigned char* buffer);
 
void encode_uint32(uint32_t data, unsigned char* buffer);
 
void encode_uint16(uint16_t data, unsigned char* buffer);
 
int32_t swap_bytes_if_big_endian_int32(int32_t src);
 
int64_t swap_bytes_if_big_endian_int64(int64_t src);
 
uint16_t swap_bytes_if_big_endian_uint16(uint16_t src);
 
int32_t extract_int32(unsigned char* bytes);
 
int64_t extract_int64(unsigned char* bytes);
 
uint16_t extract_uint16(unsigned char* bytes);
 
#ifdef FEDERATED
 
void extract_header(unsigned char* buffer, uint16_t* port_id, uint16_t* federate_id, size_t* length);
 
void extract_timed_header(unsigned char* buffer, uint16_t* port_id, uint16_t* federate_id, size_t* length, tag_t* tag);
 
tag_t extract_tag(unsigned char* buffer);
 
void encode_tag(unsigned char* buffer, tag_t tag);
 
typedef struct rti_addr_info_t {
  char rti_host_str[256];
  char rti_port_str[6];
  char rti_user_str[256];
  bool has_host;
  bool has_port;
  bool has_user;
} rti_addr_info_t;
 
bool match_regex(const char* str, char* regex);
 
bool validate_port(char* port);
 
bool validate_host(const char* host);
 
bool validate_user(const char* user);
 
bool extract_match_group(const char* rti_addr, char* dest, regmatch_t group, size_t max_len, size_t min_len,
                         const char* err_msg);
 
bool extract_match_groups(const char* rti_addr, char** rti_addr_strs, bool** rti_addr_flags, regmatch_t* group_array,
                          int* gids, size_t* max_lens, size_t* min_lens, const char** err_msgs);
 
void extract_rti_addr_info(const char* rti_addr, rti_addr_info_t* rti_addr_info);
 
#endif // FEDERATED
 
#endif /* NET_UTIL_H */