home *** CD-ROM | disk | FTP | other *** search
/ Chip 2001 January / Chip_2001-01_cd1.bin / tema / mysql / mysql-3.23.28g-win-source.exe / sql / slave.h < prev    next >
C/C++ Source or Header  |  2000-11-22  |  3KB  |  113 lines
  1. #ifndef SLAVE_H
  2. #define SLAVE_H
  3.  
  4. typedef struct st_master_info
  5. {
  6.   char log_file_name[FN_REFLEN];
  7.   ulonglong pos,pending;
  8.   FILE* file; // we keep the file open, so we need to remember the file pointer
  9.  
  10.   // the variables below are needed because we can change masters on the fly
  11.   char host[HOSTNAME_LENGTH+1];
  12.   char user[USERNAME_LENGTH+1];
  13.   char password[HASH_PASSWORD_LENGTH+1];
  14.   uint port;
  15.   uint connect_retry;
  16.   pthread_mutex_t lock;
  17.   bool inited;
  18.   
  19.   st_master_info():pending(0),inited(0)
  20.   {
  21.     host[0] = 0; user[0] = 0; password[0] = 0;
  22.     pthread_mutex_init(&lock, NULL);
  23.   }
  24.  
  25.   ~st_master_info()
  26.   {
  27.     pthread_mutex_destroy(&lock);
  28.   }
  29.   
  30.   inline void inc_pending(ulonglong val)
  31.   {
  32.     pending += val;
  33.   }
  34.   inline void inc_pos(ulonglong val)
  35.   {
  36.     pthread_mutex_lock(&lock);
  37.     pos += val + pending;
  38.     pending = 0;
  39.     pthread_mutex_unlock(&lock);
  40.   }
  41.   // thread safe read of position - not needed if we are in the slave thread,
  42.   // but required otherwise
  43.   inline void read_pos(ulonglong& var)
  44.   {
  45.     pthread_mutex_lock(&lock);
  46.     var = pos;
  47.     pthread_mutex_unlock(&lock);
  48.   }
  49. } MASTER_INFO;
  50.  
  51. typedef struct st_table_rule_ent
  52. {
  53.   char* db;
  54.   char* tbl_name;
  55.   uint key_len;
  56. } TABLE_RULE_ENT;
  57.  
  58. #define TABLE_RULE_HASH_SIZE   16
  59. #define TABLE_RULE_ARR_SIZE   16
  60.  
  61. int flush_master_info(MASTER_INFO* mi);
  62.  
  63. int mysql_table_dump(THD* thd, char* db, char* tbl_name, int fd = -1);
  64. // if fd is -1, dump to NET
  65. int fetch_nx_table(THD* thd, MASTER_INFO* mi);
  66. // retrieve non-exitent table from master
  67. // the caller must set thd->last_nx_table and thd->last_nx_db first
  68. int show_master_info(THD* thd);
  69. int show_binlog_info(THD* thd);
  70.  
  71. int tables_ok(THD* thd, TABLE_LIST* tables);
  72. // see if the query uses any tables that should not be replicated
  73.  
  74. int db_ok(const char* db, I_List<i_string> &do_list,
  75.       I_List<i_string> &ignore_list );
  76. // check to see if the database is ok to operate on with respect to the
  77. // do and ignore lists - used in replication
  78.  
  79. int add_table_rule(HASH* h, const char* table_spec);
  80. int add_wild_table_rule(DYNAMIC_ARRAY* a, const char* table_spec);
  81. void init_table_rule_hash(HASH* h, bool* h_inited);
  82. void init_table_rule_array(DYNAMIC_ARRAY* a, bool* a_inited);
  83.  
  84. int init_master_info(MASTER_INFO* mi);
  85. extern bool opt_log_slave_updates ;
  86. pthread_handler_decl(handle_slave,arg);
  87. extern bool volatile abort_loop, abort_slave;
  88. extern bool slave_running;
  89. extern pthread_t slave_real_id;
  90. extern MASTER_INFO glob_mi;
  91. extern HASH replicate_do_table, replicate_ignore_table;
  92. extern DYNAMIC_ARRAY  replicate_wild_do_table, replicate_wild_ignore_table;
  93. extern bool do_table_inited, ignore_table_inited,
  94.         wild_do_table_inited, wild_ignore_table_inited;
  95. extern bool table_rules_on;
  96.  
  97. #ifndef DBUG_OFF
  98. extern int disconnect_slave_event_count ;
  99. #endif
  100.  
  101. // the master variables are defaults read from my.cnf or command line
  102. extern uint master_port, master_connect_retry;
  103. extern my_string master_user, master_password, master_host,
  104.   master_info_file;
  105.  
  106. extern I_List<i_string> replicate_do_db, replicate_ignore_db;
  107. extern I_List<i_string_pair> replicate_rewrite_db;
  108. extern I_List<THD> threads;
  109.  
  110. #endif
  111.  
  112.  
  113.