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"
 
#ifdef FEDERATED
#include "socket_common.h"
#endif
 
#define HOST_LITTLE_ENDIAN 1
#define HOST_BIG_ENDIAN 2

int host_is_big_endian(void);

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 */