← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/sql_repl.cc

  • Committer: Brian Aker
  • Date: 2008-10-06 03:55:31 UTC
  • mto: This revision was merged to the branch mainline in revision 479.
  • Revision ID: brian@gir.tangent.org-20081006035531-ade3cc3kfwutd35g
uint cleanup.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/sql_repl.cc
52
52
  header[EVENT_TYPE_OFFSET] = ROTATE_EVENT;
53
53
 
54
54
  char* p = log_file_name+dirname_length(log_file_name);
55
 
  uint ident_len = (uint) strlen(p);
 
55
  uint32_t ident_len = (uint32_t) strlen(p);
56
56
  uint32_t event_len = ident_len + LOG_EVENT_HEADER_LEN + ROTATE_HEADER_LEN;
57
57
  int4store(header + SERVER_ID_OFFSET, server_id);
58
58
  int4store(header + EVENT_LEN_OFFSET, event_len);
222
222
 
223
223
bool purge_error_message(THD* thd, int res)
224
224
{
225
 
  uint errmsg= 0;
 
225
  uint32_t errmsg= 0;
226
226
 
227
227
  switch (res)  {
228
228
  case 0: break;
351
351
 
352
352
  char* p= coord->file_name + dirname_length(coord->file_name);
353
353
 
354
 
  uint ident_len = strlen(p);
 
354
  uint32_t ident_len = strlen(p);
355
355
  uint32_t event_len = ident_len + LOG_EVENT_HEADER_LEN;
356
356
  int4store(header + SERVER_ID_OFFSET, server_id);
357
357
  int4store(header + EVENT_LEN_OFFSET, event_len);
376
376
*/
377
377
 
378
378
void mysql_binlog_send(THD* thd, char* log_ident, my_off_t pos,
379
 
                       ushort flags)
 
379
                       uint16_t flags)
380
380
{
381
381
  LOG_INFO linfo;
382
382
  char *log_file_name = linfo.log_file_name;
1019
1019
  struct stat stat_area;
1020
1020
  char fname[FN_REFLEN];
1021
1021
  int thread_mask= 0, error= 0;
1022
 
  uint sql_errno=0;
 
1022
  uint32_t sql_errno=0;
1023
1023
  const char* errmsg=0;
1024
1024
 
1025
1025
  lock_slave_threads(mi);
1348
1348
                   const char* log_file_name2, uint64_t log_pos2)
1349
1349
{
1350
1350
  int res;
1351
 
  uint log_file_name1_len=  strlen(log_file_name1);
1352
 
  uint log_file_name2_len=  strlen(log_file_name2);
 
1351
  uint32_t log_file_name1_len=  strlen(log_file_name1);
 
1352
  uint32_t log_file_name2_len=  strlen(log_file_name2);
1353
1353
 
1354
1354
  //  We assume that both log names match up to '.'
1355
1355
  if (log_file_name1_len == log_file_name2_len)
1555
1555
  File file;
1556
1556
  char fname[FN_REFLEN];
1557
1557
  List<Item> field_list;
1558
 
  uint length;
 
1558
  uint32_t length;
1559
1559
  int cur_dir_len;
1560
1560
  Protocol *protocol= thd->protocol;
1561
1561
 
1632
1632
int log_loaded_block(IO_CACHE* file)
1633
1633
{
1634
1634
  LOAD_FILE_INFO *lf_info;
1635
 
  uint block_len;
 
1635
  uint32_t block_len;
1636
1636
  /* buffer contains position where we started last read */
1637
1637
  uchar* buffer= (uchar*) my_b_get_buffer_start(file);
1638
 
  uint max_event_size= current_thd->variables.max_allowed_packet;
 
1638
  uint32_t max_event_size= current_thd->variables.max_allowed_packet;
1639
1639
  lf_info= (LOAD_FILE_INFO*) file->arg;
1640
1640
  if (lf_info->thd->current_stmt_binlog_row_based)
1641
1641
    return(0);