dtm_uml

meta_config_t

network_client_attr

product_user_t *p_user;char client_charset[10];unsigned char charset_num_c;GPtrArray *cache_cmds;GPtrArray *server_array;view_info *pvi;view_for_save *pvs;network_socket_transaction_state transaction_state;int is_handshake_send_partly;int is_auth_result_send_partly;vector* p_vec_last_query_servers;unsigned int last_query_num;unsigned int query_result_cnt;unsigned int unlock_table_result_cnt;bool last_query_is_multi_query;unsigned long log_id;start_transaction_time;char last_query_db[256];transaction id;unsigned long long dgtid;unsigned int sql_cnt;

dtm_config_action_register

string action_namedtm_config_action * action

process_info_t

pid_t pid;unsigned int process_num;process_type_t process_type; unsigned char graceful_shutdown;

network_server_attr

int is_sending_cache_cmds;int cache_cmd_index;int is_query_send_partly;int is_auth_send_partly;int has_set_sql;int has_call_sql;int has_changeuser_sql;int has_use_sql;int is_clean;int is_need_bind_client;packet_handshake handshake;guint64 cache_cmd;tsc_node_def_t *server_node;network_socket_xa_state transaction_state;network_socket *client;unsigned long long tid;bool is_send_old_passwd;string* last_send_query;byte_array *tmp_send_buf;vector *p_vec_self_buf;vector *p_vec_multi_query;struct timeval last_send_query_time;int last_query_num;int recv_query_num;

sql_parser_t

mem_pool_t *pool;char *sql_str;int sql_length;int err_no;sql_command_t *sql_cmd;char *sql_syntax_error_str;int sql_syntax_error_offset;int sql_syntax_error_offset1;int sql_gbk_change[GBK_5C_RECORDS];int sql_gbk_change_count;int sql_gbk_change_count_start;sql_item_charset_type_t sql_charset_name;char* sql_gbk;char* sql_gbk_format;char* sql_format_temp1;

dtm_shmtx_t

//以共享内存方式实现的同步#if (DTM_HAVE_ATOMIC_OPS)unsigned int *lock;#if (NGX_HAVE_POSIX_SEM)//共享内存需要自己实现自旋，避免占用CPU资源，通过信号量的方式来唤醒unsigned int *wait;//信号量标志unsigned int semaphore;//信号量结构体sem_t sem;#endifunsigned int enable;//以文件锁方式实现的进程同步#elseint fd;char *name;#endifunsigned spin;

view_for_save

int get_affected_sids(set& s)int reset(string xid)view_for_save(string xid)

basic_config_t

unsigned long long config_version; char product_name[MAX_PRODUCT_NAME_LEN]; char config_file_name[MAX_FILE_NAME_LEN]; int service_port; unsigned int max_threads; unsigned int backlog; char log_filename[MAX_FILE_NAME_LEN]; unsigned int log_level; unsigned int log_maxsize; #ifdef NEED_DGTID unsigned int binlog_maxsize; #endif time_t conf_modify_time; unsigned int force_lock_in_share_mode;

void init(); int to_string(FILE *f); bool operator == (const basic_config_t &basic_config) const

dtm_shm_t

unsigned char *addr;size_t size;

process_type_t

network_server

int process_num;process_type_t process_type;int pid;config_t *config;network_socket *service_socket;struct timeval cur_time;struct _dtm_poll *dtm_poll;network_socket_pool *client_socket_pool;network_socket_pool *server_socket_pool;sql_parser_t *global_sql_parser;char binary_path[MAX_FILE_NAME_LEN];char log_path[MAX_FILE_NAME_LEN];char conf_path[MAX_FILE_NAME_LEN];char install_path[MAX_FILE_NAME_LEN];char ip[21];char hostname[MAX_FILE_NAME_LEN];

config_t

basic_config_t basic_config;meta_config_t meta_config;GKeyFile *conf_file_;GKeyFile *userinfo_file_;

dtm_config_action_manager

time_t check_timedtm_config_action_register* cur_actionvector action_vector

dtm_poll

void *fd_mapping[CONFIG_MPL_EPOLL_MAX_SIZE];int cur_size;int max_fd;int epfd;struct epoll_event events[CONFIG_MPL_EPOLL_MAX_SIZE];size_t event_size;

tsc_node_def_t

char node_name[MAX_TABLET_SERVER_ID_LEN]; char host[MAX_HOSTNAME_PORT_LEN]; char password[MAX_PASSWORD_LEN]; char user[MAX_USERNAME_LEN];char charset[MAX_DEFAULT_CHARSET_LEN]; network_address addr; unsigned int ts_port;unsigned int ts_max_connections;unsigned int ts_reserved_master_connections; unsigned int ts_connect_timeout;unsigned int ts_time_reconnect_interval; time_t last_fail_time;unsigned int cur_connected; unsigned int ipkey; GHashTable *db_conn_pools;

int copy_proprities_from_node(tsc_node_def_t *other_node); int get_ip_for_network_database(); int to_string(FILE *f);int conn_pool_delete(network_socket *s);int conn_pool_add(network_socket *s);network_socket* conn_pool_get(const char *db_name);int db_conn_pools_free();

view_info

dtm_config_action

string _action_name

byte_array

unsigned char *data;int size;int offset;int capacity;

network_socket_pool

GQueue *sockets;network_server *srv;

packet_query

char cur_db[MAX_DB_NAME_LEN];guint64 command;unsigned char *args;int args_calloc_len;int args_len;struct timeval start_time;struct timeval start_process_time;struct timeval sql_parse_finish_time;struct timeval all_subreq_sent_time;struct timeval all_subreq_returned_time;struct timeval merge_result_time;struct timeval end_time;int type;packet_query_status status;int is_proxy_status;int status_type;int is_last_insert_id;int is_ddl_sql;int is_need_more_data;int no_xa_sql;int sql_cmd_type;GHashTable *field_as_mapping;

dtm_shmtx_sh_t

unsigned int lock;//一个lock变量unsigned int wait;//一个信号量变量

network_socket

int fd; byte_array *send_buf;int send_buf_offset;byte_array *self_buf;char ip[21];int port;int use_times;struct timeval start_time;struct timeval end_time;int query_times;struct timeval write_time;unsigned char header[4];int header_read_len;int header_offset;int row_data_offset;size_t packet_id;int packet_len;int packet_read_len;network_server *srv;struct _dtm_poll *dtm_poll;long served_client_times;char xa_id[MAX_XA_ID_LEN];network_socket_state state;packet_result result;char current_db[MAX_DB_NAME_LEN];time_t last_active_time;packet_query query;struct sockaddr_in addr;int is_in_pool;int commit_wait_build;int is_have_prepare_lock;int is_ok_packet;int is_err_packet;int is_session_auto_commit;int is_auto_commit;int bind_server;unsigned long long last_insert_id;char errmsg_buf[MAX_ERR_MSG_LEN];int sql_error_no;int is_client_socket;void *other_attr;bool wait_for_event;

product_user_t

char username[MAX_USERNAME_LEN];char password[MAX_PASSWORD_LEN];unsigned char password_is_null;unsigned int max_connections;unsigned int cur_connections;char webfoot_service_name[MAX_BNS_NAME_LEN];int enable_auth_ip;vector auth_ips;

int to_string(FILE *f);