udp2raw/common.h

134 lines
3.5 KiB
C
Raw Normal View History

2017-07-29 12:32:26 +00:00
/*
* common.h
*
* Created on: Jul 29, 2017
* Author: wangyu
*/
#ifndef COMMON_H_
#define COMMON_H_
2017-08-03 19:29:53 +00:00
//#define __STDC_FORMAT_MACROS 1
#include <inttypes.h>
2017-07-29 12:32:26 +00:00
#include<stdio.h>
#include<string.h>
#include<stdlib.h>
#include<getopt.h>
2017-07-30 08:57:24 +00:00
#include<unistd.h>
2017-07-29 12:32:26 +00:00
#include<errno.h>
#include <sys/epoll.h>
#include <sys/wait.h>
#include <sys/socket.h> //for socket ofcourse
#include <sys/types.h>
#include <stdlib.h> //for exit(0);
#include <errno.h> //For errno - the error number
#include <netinet/tcp.h> //Provides declarations for tcp header
#include <netinet/udp.h>
#include <netinet/ip.h> //Provides declarations for ip header
#include <netinet/if_ether.h>
#include <arpa/inet.h>
#include <fcntl.h>
#include <byteswap.h>
#include <arpa/inet.h>
#include <linux/if_ether.h>
#include <linux/filter.h>
#include <sys/time.h>
#include <time.h>
#include <sys/timerfd.h>
#include <sys/ioctl.h>
#include <netinet/in.h>
#include <net/if.h>
#include <arpa/inet.h>
#include <stdarg.h>
#include <assert.h>
2017-07-29 12:32:26 +00:00
2017-07-30 08:57:24 +00:00
#include<unordered_map>
2017-07-29 12:32:26 +00:00
using namespace std;
2017-07-31 05:26:07 +00:00
const int max_data_len=1600;
2017-07-29 12:32:26 +00:00
const int buf_len=max_data_len+200;
2017-07-29 21:53:30 +00:00
const uint32_t max_handshake_conn_num=10000;
const uint32_t max_ready_conn_num=1000;
const uint32_t anti_replay_window_size=1000;
const int max_conv_num=10000;
2017-07-29 12:32:26 +00:00
2017-07-30 10:09:51 +00:00
const uint32_t client_handshake_timeout=5000;
const uint32_t client_retry_interval=1000;
2017-07-29 21:53:30 +00:00
const uint32_t server_handshake_timeout=10000;// this should be much longer than clients. client retry initially ,server retry passtively
const int conv_clear_ratio=10; //conv grabage collecter check 1/10 of all conv one time
const int conn_clear_ratio=10;
2017-07-30 05:39:18 +00:00
const int conv_clear_min=5;
const int conn_clear_min=1;
2017-07-29 12:32:26 +00:00
2017-08-02 10:57:27 +00:00
const uint32_t conv_clear_interval=1000;
const uint32_t conn_clear_interval=1000;
2017-07-30 15:18:37 +00:00
const int max_fail_time=100000;
2017-07-29 12:32:26 +00:00
2017-07-29 12:58:38 +00:00
const uint32_t heartbeat_interval=1000;
2017-07-29 12:32:26 +00:00
2017-07-30 10:09:51 +00:00
const uint32_t timer_interval=400;//this should be smaller than heartbeat_interval and retry interval;
2017-07-29 12:32:26 +00:00
//const uint32_t conv_timeout=120000; //120 second
const uint32_t conv_timeout=30000; //for test
2017-07-29 12:32:26 +00:00
2017-07-29 21:53:30 +00:00
const uint32_t client_conn_timeout=10000;
2017-07-29 12:32:26 +00:00
//const uint32_t server_conn_timeout=conv_timeout+60000;//this should be 60s+ longer than conv_timeout,so that conv_manager can destruct convs gradually,to avoid latency glicth
const uint32_t server_conn_timeout=conv_timeout+10000;//for test
2017-07-29 12:32:26 +00:00
2017-07-30 09:07:17 +00:00
enum raw_mode_t{mode_faketcp=0,mode_udp,mode_icmp,mode_end};
2017-07-29 12:32:26 +00:00
extern raw_mode_t raw_mode;
enum program_mode_t {unset_mode=0,client_mode,server_mode};
extern program_mode_t program_mode;
2017-07-30 08:57:24 +00:00
extern unordered_map<int, const char*> raw_mode_tostring ;
2017-07-29 12:32:26 +00:00
extern int socket_buf_size;
typedef uint32_t id_t;
typedef uint64_t iv_t;
2017-08-01 12:03:29 +00:00
typedef uint64_t padding_t;
2017-07-29 12:32:26 +00:00
typedef uint64_t anti_replay_seq_t;
uint64_t get_current_time();
uint64_t pack_u64(uint32_t a,uint32_t b);
uint32_t get_u64_h(uint64_t a);
uint32_t get_u64_l(uint64_t a);
char * my_ntoa(uint32_t ip);
void myexit(int a);
void init_random_number_fd();
uint64_t get_true_random_number_64();
2017-07-29 13:22:13 +00:00
uint32_t get_true_random_number();
2017-07-29 12:32:26 +00:00
uint32_t get_true_random_number_nz();
uint64_t ntoh64(uint64_t a);
uint64_t hton64(uint64_t a);
2017-08-04 04:46:46 +00:00
bool larger_than_u16(uint16_t a,uint16_t b);
bool larger_than_u32(uint32_t a,uint32_t b);
2017-07-29 12:32:26 +00:00
void setnonblocking(int sock);
int set_buf_size(int fd);
unsigned short csum(const unsigned short *ptr,int nbytes);
void INThandler(int sig);
int numbers_to_char(id_t id1,id_t id2,id_t id3,char * &data,int &len);
int char_to_numbers(const char * data,int len,id_t &id1,id_t &id2,id_t &id3);
void myexit(int a);
2017-07-29 12:32:26 +00:00
#endif /* COMMON_H_ */