Lib/network6.h

Go to the documentation of this file.

#ifndef  __JBXL_NETWORK_H_
#define  __JBXL_NETWORK_H_


#include "tools.h"
#include "jbxl_state.h"


#define _WINSOCK_DEPRECATED_NO_WARNINGS
#ifdef WIN32
    //#include <winsock2.h>    // included at tools.h
    #include <ws2tcpip.h>
    #include <fcntl.h>

    #ifndef socklen_t        
        #define socklen_t  int
    #endif
    extern WSADATA WsaData;

    #define _WINSOCK_DEPRECATED_NO_WARNINGS
    #pragma comment( lib, "ws2_32.lib" )

#else
    // Unix/Linux
    #include <sys/socket.h>

    #ifdef HAVE_UNISTD_H
        #ifndef _XOPEN_SOURCE
            #define _XOPEN_SOURCE
        #endif
        #include <unistd.h>
    #endif

    #ifdef HAVE_SYS_SOCKIO_H
        #include <sys/sockio.h>
    #endif

    #ifdef HAVE_NETINET_IN_H
        #include <netinet/in.h>
    #endif
    #ifdef HAVE_ARPA_INET_H
        #include <arpa/inet.h>
    #endif

    #include <netdb.h>

    #include <fcntl.h>
    #include <sys/ioctl.h>
    #include <net/if.h>
#endif


//#define  NET_MAX_IF_NUM       10      ///< 取り扱うネットワークインターフェイスの最大数



// for WinSock

int   init_network(void);
void  cleanup_network(void);


// Berkeley Socket

int   _udp_server_socket(int port, struct addrinfo** info, int family);                 
int   _udp_server_socket_setopt(int, int, const void*, int, struct addrinfo**, int f);  
int   _udp_client_socket(char* host, int, struct addrinfo**, int family);               
int   _udp_bind(int sock, int port, int family);                                        
int   _udp_bind_setopt(int sock, int port, int opt, const void*, int len, int family);  

/*
int  udp_server_socket(int port, struct addrinfo** info);           ///< udp のサーバソケットを作成する．IPv6 -> IPv4
int  udp_server_socket_ipv4(int port, struct addrinfo** info);      ///< IPv4 用udp のサーバソケットを作成する．
int  udp_server_socket_ipv6(int port, struct addrinfo** info);      ///< IPv6 用udp のサーバソケットを作成する．
*/
#define  udp_server_socket(p, a)                        _udp_server_socket((p), (a),  AF_UNSPEC)
#define  udp_server_socket_ipv4(p)                      _udp_server_socket((p), NULL, AF_INET)
#define  udp_server_socket_ipv6(p, a)                   _udp_server_socket((p), (a),  AF_INET6)

#define  udp_server_socket_setopt(p, o, v, l, a)        _udp_server_socket_setopt((p), (o), (v), (l), (a),  AF_UNSPEC)
#define  udp_server_socket_setopt_ipv4(p, o, v, l)      _udp_server_socket_setopt((p), (o), (v), (l), NULL, AF_INET)
#define  udp_server_socket_setopt_ipv6(p, o, v, l, a)   _udp_server_socket_setopt((p), (o), (v), (l), (a),  AF_INET6)

#define  udp_client_socket(h, p, a)                     _udp_client_socket((h), (p), (a), AF_UNSPEC)
#define  udp_client_socket_ipv4(h, p, a)                _udp_client_socket((h), (p), (a), AF_INET)
#define  udp_client_socket_ipv6(h, p, a)                _udp_client_socket((h), (p), (a), AF_INET6)

#define  udp_bind(s, p)                                 _udp_bind((s), (p), AF_UNSPEC)
#define  udp_bind_ipv4(s, p)                            _udp_bind((s), (p), AF_INET)
#define  udp_bind_ipv6(s, p)                            _udp_bind((s), (p), AF_INET6)

#define  udp_bind_setopt(s, p, o, v, l)                 _udp_bind_setopt((s), (p), (o), (v), (l), AF_UNSPEC)
#define  udp_bind_setopt_ipv4(s, p, o, v, l)            _udp_bind_setopt((s), (p), (o), (v), (l), AF_INET)
#define  udp_bind_setopt_ipv6(s, p, o, v, l)            _udp_bind_setopt((s), (p), (o), (v), (l), AF_INET6)

//
int   _tcp_server_socket(int port, int family);                                         
int   _tcp_server_socket_setopt(int port, int opt, const void*, int len, int famliy);   
int   _tcp_server_bind(int port, int family);                                           
int   _tcp_server_bind_setopt(int port, int opt, const void*, int len, int family);     

#define  tcp_server_socket(p)                       _tcp_server_socket((p), AF_UNSPEC)
#define  tcp_server_socket_ipv4(p)                  _tcp_server_socket((p), AF_INET)
#define  tcp_server_socket_ipv6(p)                  _tcp_server_socket((p), AF_INET6)

#define  tcp_server_socket_setop(p, o, v, l)        _tcp_server_socket_setopt((p), (o), (v), (l), AF_UNSPEC)
#define  tcp_server_socket_setop_ipv4(p, o, v, l)   _tcp_server_socket_setopt((p), (o), (v), (l), AF_INET)
#define  tcp_server_socket_setop_ipv6(p, o, v, l)   _tcp_server_socket_setopt((p), (o), (v), (l), AF_INET6)

#define  tcp_server_bind(p)                         _tcp_server_bind((p), AF_UNSPEC)
#define  tcp_server_bind_ipv4(p)                    _tcp_server_bind((p), AF_INET)
#define  tcp_server_bind_ipv6(p)                    _tcp_server_bind((p), AF_INET6)

#define  tcp_server_bind_setopt(p, o, v, l)         _tcp_server_bind_setopt((p), (o), (v), (l), AF_UNSPEC)
#define  tcp_server_bind_setopt_ipv4(p, o, v, l)    _tcp_server_bind_setopt((p), (o), (v), (l), AF_INET)
#define  tcp_server_bind_setopt_ipv6(p, o, v, l)    _tcp_server_bind_setopt((p), (o), (v), (l), AF_INET6)

int   _tcp_client_socket(char* hname, int port, int family);                            
int   _tcp_client_bind_socket(char* host, int sport, int cport, int family);            
int   _tcp_bind(int sock, int port, int family);                                        
int   _tcp_bind_setopt(int sock, int port, int opt, const void*, int len, int family);  
int   _tcp_connect(int sock, char* host, int port, int family);                         

#define  tcp_client_socket(h, p)                    _tcp_client_socket((h), (p), AF_UNSPEC)
#define  tcp_client_socket_ipv4(h, p)               _tcp_client_socket((h), (p), AF_INET)
#define  tcp_client_socket_ipv6(h, p)               _tcp_client_socket((h), (p), AF_INET6)

#define  tcp_client_bind_socket(h, s, c)            _tcp_client_bind_socket((h), (c), (s), AF_UNSPEC)
#define  tcp_client_bind_socket_ipv4(h, s, c)       _tcp_client_bind_socket((h), (c), (s), AF_INET)
#define  tcp_client_bind_socket_ipv6(h, s, c)       _tcp_client_bind_socket((h), (c), (s), AF_INET6)

#define  tcp_bind(s, p)                             _tcp_bind((s), (p), AD_UNSPEC)
#define  tcp_bind_ipv4(s, p)                        _tcp_bind((s), (p), AD_INET)
#define  tcp_bind_ipv6(s, p)                        _tcp_bind((s), (p), AD_INET6)

#define  tcp_bind_setopt(s, p, o, v, l)             _tcp_bind_setopt((s), (p), (o), (v), (l), AF_UNSPEC)
#define  tcp_bind_setopt_ipv4(s, p, o, v, l)        _tcp_bind_setopt((s), (p), (o), (v), (l), AF_INET)
#define  tcp_bind_setopt_ipv6(s, p, o, v, l)        _tcp_bind_setopt((s), (p), (o), (v), (l), AF_INET6)

#define  tcp_connect(s, h, p)                       _tcp_connect((s), (h), (p), AF_UNSPEC)
#define  tcp_connect_ipv4(s, h, p)                  _tcp_connect((s), (h), (p), AF_INET)
#define  tcp_connect_ipv6(s, h, p)                  _tcp_connect((s), (h), (p), AF_INET6)

//
int   accept_intr(int, struct sockaddr*, socklen_t*);                           
int   socket_close(int sock);                                                   
int   set_nonblock_socket(int sock);
int   set_block_socket(int sock);


// Valid Sockets

int   get_valid_udp_socket(int min, int max, unsigned short* port);
int   get_valid_tcp_server_socket(int min, int max, unsigned short* port);
int   get_valid_tcp_client_socket(int min, int max, char* hostname, unsigned short sport, unsigned short* cport);


// Communication

int   udp_recv(int, char*, int, struct addrinfo*);
int   udp_send(int, char*, int, struct addrinfo*);
int   tcp_recv(int, char*, int);
int   tcp_send(int, char*, int);

int   udp_recv_wait(int sock, char* data, int size, struct addrinfo* sv_addr, int tm);
int   tcp_recv_wait(int sock, char* data, int sz, int tm);

int   tcp_send_mesgln(int, char*); 
int   tcp_recv_mstream(int sock, char* mesg, int sz, mstream* sb, int tm);

int   recv_wait(int sock, int tm);
int   recv_wait_twin(int sock1, int sock2, int tm);
int   send_wait(int sock, int tm);

#define  udp_send_mesg(s, m, a)         udp_send((s), (m), 0, (a))
#define  tcp_send_mesg(s, m)            tcp_send((s), (m), 0)


// IP address

struct sockaddr*  make_sockaddr_bynum(unsigned char* addr, int port, int family);    
struct sockaddr*  make_sockaddr_bystr(const char* addr, int port);                   

#define  make_sockaddr_bynum_ipv4(a, p) make_sockaddr_bynum((a), (p), AF_INET)
#define  make_sockaddr_bynum_ipv6(a, p) make_sockaddr_bynum((a), (p), AF_INET6)

char*  _get_hostname(const char* host, int family);                 

#define  get_hostname(h)                _get_hostname((h), AF_UNSPEC) 
#define  get_hostname_ipv4(h)           _get_hostname((h), AF_INET) 
#define  get_hostname_ipv6(h)           _get_hostname((h), AF_INET6) 

char*  get_hostname_bynum(unsigned char* bin, int family);          
char*  get_hostname_bystr(const char* str);                         

#define  get_hostname_bynum_ipv4(n)     get_hostname_bynum((n), AF_INET)
#define  get_hostname_bynum_ipv6(n)     get_hostname_bynum((n), AF_INET6)

char*  get_ipaddr_byname(const char* host, int family);             
unsigned char*  get_ipaddr_byname_num(const char* h, int family);   

#define  get_ipaddr_byname_ipv4(h)      get_ipaddr_byname((h), AF_INET)
#define  get_ipaddr_byname_ipv6(h)      get_ipaddr_byname((h), AF_INET6)
#define  get_ipaddr_byname_num_ipv4(h)  get_ipaddr_byname_num((h), AF_INET)
#define  get_ipaddr_byname_num_ipv6(h)  get_ipaddr_byname_num((h), AF_INET6)

char*  get_myipaddr(int family);                                    
unsigned char*  get_myipaddr_num(int family);                       

#define  get_myipaddr_ipv4()            get_myipaddr(AF_INET)
#define  get_myipaddr_ipv6()            get_myipaddr(AF_INET6)
#define  get_myipaddr_num_ipv4()        get_myipaddr_num(AF_INET)
#define  get_myipaddr_num_ipv6()        get_myipaddr_num(AF_INET6)

char*  _get_localip_bydest(const char* host, int family);           

#define  get_localip_bydest(h)          _get_localip_bydest((h), AF_UNSPEC)
#define  get_localip_bydest_ipv4(h)     _get_localip_bydest((h), AF_INET)
#define  get_localip_bydest_ipv6(h)     _get_localip_bydest((h), AF_INET6)

#define  get_localip()                  _get_localip_bydest("www.google.co.jp", AF_UNSPEC)
#define  get_localip_ipv4()             _get_localip_bydest("www.google.co.jp", AF_INET)
#define  get_localip_ipv6()             _get_localip_bydest("www.google.co.jp", AF_INET6)

unsigned char*  get_mynetaddr_num(int family);                      
char*  get_mynetaddr(int family);                                   

#define  get_mynetaddr_num_ipv4()       get_mynetaddr_num(AF_INET)
#define  get_mynetaddr_num_ipv6()       get_mynetaddr_num(AF_INET6)
#define  get_mynetaddr_ipv4()           get_mynetaddr(AF_INET)
#define  get_mynetaddr_ipv6()           get_mynetaddr(AF_INET6)


// Tools

unsigned char*  to_address_num(char*, int md, int mk, int family);  
char*  to_address_char(unsigned char* addr, int mask, int family);  

#define  to_address_num8_ipv4(a, m)     to_address_num((a), (m), 1, AF_INET)    
#define  to_address_num4_ipv4(a, m)     to_address_num((a), (m), 0, AF_INET)    
#define  to_address_char8_ipv4(a)       to_address_char((a), 1, AF_INET)        
#define  to_address_char4_ipv4(a)       to_address_char((a), 0, AF_INET)        

#define  to_address_num32_ipv6(a, m)    to_address_num((a), (m), 1, AF_INET6)   
#define  to_address_num16_ipv6(a, m)    to_address_num((a), (m), 0, AF_INET6)   
#define  to_address_char32_ipv6(a)      to_address_char((a), 1, AF_INET6)       
#define  to_address_char16_ipv6(a)      to_address_char((a), 0, AF_INET6)       

int   is_same_sockaddr(struct sockaddr* addr1, struct sockaddr* addr2);
int   is_same_network(char* addr1, char* addr2, char* mask);
int   is_same_network_num(unsigned char* addr1, unsigned char* addr2, unsigned char* mask, int family);

#define  is_same_network_num_ipv4(a1, a2, m)  is_same_network_num((a1), (a2), (m), AF_INET) 
#define  is_same_network_num_ipv6(a1, a2, m)  is_same_network_num((a1), (a2), (m), AF_INET6) 

void  udp_hole_punching(int sock, struct addrinfo* addr, int num);  



// for IPv4 only 

int   udp_client_socket_sockaddr_in(char*, int, struct sockaddr_in*);   

int   udp_recv_sockaddr_in(int, char*, int, struct sockaddr_in*);       
int   udp_send_sockaddr_in(int, char*, int, struct sockaddr_in*);       
int   udp_recv_wait_sockaddr_in(int sock, char* data, int size, struct sockaddr_in* sv_addr, int tm);   

#define  udp_send_mesg_sockaddr_in(s, m, a)  udp_send_sockaddr_in((s), (m), 0, (a))

struct sockaddr_in  get_sockaddr_in(char* hostname, unsigned short cport);
struct sockaddr_in  get_sockaddr_in_bynum(char* ipnum, unsigned short cport);
struct sockaddr_in  get_local_sockaddr_in(unsigned short cport);

//int    is_same_sockaddr_ipv4(struct sockaddr_in addr1, struct sockaddr_in addr2);
#define  is_same_sockaddr_in(a, b)  is_same_sockaddr((struct sockaddr*)&(a), (struct sockaddr*)&(b))    

unsigned char*  get_ipaddr_num_ipv4(struct in_addr);        
char*  get_ipaddr_ipv4(struct in_addr);                     

void   udp_hole_punching_sockaddr_in(int sock, struct sockaddr_in addr, int nm);    


#endif // __JBXL_NETWORK_H_

---