infobin/event_header.h at master · fateswing/infobin · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
/*************************************************************************
  > File Name: event_header.h
  > Author: gaopeng QQ:22389860 all right reserved
  > Mail: gaopp_200217@163.com
  > Created Time: Thu 02 Mar 2017 08:07:22 PM CST
 ************************************************************************/

#define BIN_LOG_HEADER_SIZE 4U
#define LOG_EVENT_HEADER_LEN 19U    /* the fixed header length */
#define O_MEM  1
#define CRC_LEN 4
#define MAX_MEM_COUNT 134217728


#define OFFSET_0  0
//event header

#ifdef __MYSQL_SOURCE
#define EVENT_TYPE_OFFSET    4
#define SERVER_ID_OFFSET     5
#define EVENT_LEN_OFFSET     9
#define LOG_POS_OFFSET       13
#define FLAGS_OFFSET         17
#endif

#define EVENT_TIMESTAMP 4
#define EVENT_TYPE_OFFSET 5
#define SERVER_ID_OFFSET 9
#define EVENT_LEN_OFFSET 13
#define LOG_POS_OFFSET 17
#define FLAGS_OFFSET 19
//FED
#define FORMAT_V 21


//FED event fixed data
#define FED_BINLOG_FORMAT 2
#define FED_MYSQL_FORMAT 52
#define FED_USED 56
#define FED_EVENT_HEADER 57

//DML event fixed data
#define DML_TABLE_ID 6


//MAP event fixed data
#define MAP_TABLE_ID 6
#define MAP_UNSUED 8
//MAP event variable data
#define MAP_DB_LENGTH 1
#define MAP_TABLE_LENGTH 1

//GTID event fixed data
#define GTID_FLAGS 1
#define GTID_SID   17
#define GTID_GNO   25
#define GTID_FLAG  26
#define GTID_LAST  34
#define GTID_SEQ   42
//QUER event fixed data
#define QUERY_T_ID 4
#define QUERY_EXE_T 8
#define QUERY_DEFAULT_DB_LEN 9
#define QUERY_ERR_CODE 11
#define QUERY_META_BLOCK_LEN 13


//EVENT CODE
#define  WRITE_ROWS_EVENT 30
#define  UPDATE_ROWS_EVENT 31
#define  DELETE_ROWS_EVENT 32
#define  TABLE_MAP_EVENT 19
#define  GTID_LOG_EVENT 33


#define BINLOG_VERSION    4
#define BINLOG_HEADER_LENGTH 19
#define BINLOG_MAICO 1852400382

#define ERR_POST __FILE__,__LINE__

typedef struct map_tab
{
	uint64_t table_id;
	uint8_t db_name[512];
	uint8_t tab_name[512];
} MAP_TAB;

typedef struct query_event
{
	uint32_t exe_time;
	uint8_t db_name[512];
	uint8_t* statment;
} QUERY_EVENT;

typedef struct node_p
{
	struct node_p* next;
	void* data;
} NODE_P;


typedef struct head_p
{
	NODE_P* head;
	NODE_P* end;
} HEAD_P;

typedef struct op_str
{
	char db_name[512];
	char tab_name[512];
	uint64_t   ino;
	uint64_t   inoc;
	uint64_t   upo;
	uint64_t   upoc;
	uint64_t   deo;
	uint64_t   deoc;
	uint64_t   cnt;
	uint64_t   cntc;
} OP_STR;


extern HEAD_P MTR_POS_H ;//MAX TRX SIZE HEAD
extern HEAD_P TIM_POS_H ;//TIME PIECE HEAD

extern uint64_t POS_T;
extern uint64_t POS_E;
extern uint64_t TRX_TOTAL;
extern uint64_t EVE_TOTAL;
extern uint64_t MAX_EVE;
extern uint64_t MAX_EVE_P;
extern uint64_t PI_SIZE;
extern uint32_t POS_TIME;
extern uint32_t END_TIME;
extern uint32_t BEG_TIME;
extern uint64_t MAX_FILE_Z;
extern uint64_t MAX_FILE_Z;

extern uint32_t QUR_T  ;
extern uint32_t QUR_X ;

extern uint32_t QUR_POS ;
extern uint32_t QUR_POS_END ;

extern uint32_t EXE_T;


int init_chain(uint64_t a,uint64_t b,HEAD_P* head);
int print_total(HEAD_P* head_pi,HEAD_P* head_trx,HEAD_P* head_mt ,HEAD_P* tab_mt,uint64_t mi,uint32_t mt);
int init_chain2(uint64_t a,uint64_t b,uint64_t c,uint64_t d,uint64_t e,HEAD_P* head);
int add_chain_op(const char* db_name,const char* table_name,uint64_t ino,uint64_t upo,uint64_t deo, uint64_t inoc,uint64_t upoc,uint64_t deoc, HEAD_P* head);