← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/log_event.cc

  • Committer: Brian Aker
  • Date: 2008-08-05 04:10:42 UTC
  • mfrom: (261.2.8 codestyle)
  • mto: This revision was merged to the branch mainline in revision 263.
  • Revision ID: brian@tangent.org-20080805041042-1l4893r3bwy2lxz2
Merge from Monty

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/log_event.cc
133
133
  char buff[MAX_SLAVE_ERRMSG], *slider;
134
134
  const char *buff_end= buff + sizeof(buff);
135
135
  uint len;
136
 
  List_iterator_fast<MYSQL_ERROR> it(thd->warn_list);
137
 
  MYSQL_ERROR *err;
 
136
  List_iterator_fast<DRIZZLE_ERROR> it(thd->warn_list);
 
137
  DRIZZLE_ERROR *err;
138
138
  buff[0]= 0;
139
139
 
140
140
  for (err= it++, slider= buff; err && slider < buff_end - 1;
1931
1931
  */
1932
1932
 
1933
1933
  /* A 2nd variable part; this is common to all versions */ 
1934
 
  memcpy((char*) start, end, data_len);          // Copy db and query
 
1934
  memcpy(start, end, data_len);          // Copy db and query
1935
1935
  start[data_len]= '\0';              // End query with \0 (For safetly)
1936
1936
  db= (char *)start;
1937
1937
  query= (char *)(start + db_len + 1);
2046
2046
 
2047
2047
  if (likely(charset_inited) &&
2048
2048
      (unlikely(!print_event_info->charset_inited ||
2049
 
                memcmp((uchar*) print_event_info->charset, (uchar*) charset, 6))))
 
2049
                memcmp(print_event_info->charset, charset, 6))))
2050
2050
  {
2051
2051
    CHARSET_INFO *cs_info= get_charset(uint2korr(charset), MYF(MY_WME));
2052
2052
    if (cs_info)
2069
2069
  }
2070
2070
  if (time_zone_len)
2071
2071
  {
2072
 
    if (memcmp((uchar*) print_event_info->time_zone_str,
2073
 
               (uchar*) time_zone_str, time_zone_len+1))
 
2072
    if (memcmp(print_event_info->time_zone_str, time_zone_str, time_zone_len+1))
2074
2073
    {
2075
2074
      my_b_printf(file,"SET @@session.time_zone='%s'%s\n",
2076
2075
                  time_zone_str, print_event_info->delimiter);
2889
2888
  */
2890
2889
  uchar buff[FORMAT_DESCRIPTION_HEADER_LEN];
2891
2890
  int2store(buff + ST_BINLOG_VER_OFFSET,binlog_version);
2892
 
  memcpy((char*) buff + ST_SERVER_VER_OFFSET,server_version,ST_SERVER_VER_LEN);
 
2891
  memcpy(buff + ST_SERVER_VER_OFFSET,server_version,ST_SERVER_VER_LEN);
2893
2892
  if (!dont_set_created)
2894
2893
    created= when= get_time();
2895
2894
  int4store(buff + ST_CREATED_OFFSET,created);
2896
2895
  buff[ST_COMMON_HEADER_LEN_OFFSET]= LOG_EVENT_HEADER_LEN;
2897
 
  memcpy((char*) buff+ST_COMMON_HEADER_LEN_OFFSET+1, (uchar*) post_header_len,
 
2896
  memcpy(buff+ST_COMMON_HEADER_LEN_OFFSET+1, post_header_len,
2898
2897
         LOG_EVENT_TYPES);
2899
2898
  return (write_header(file, sizeof(buff)) ||
2900
2899
          my_b_safe_write(file, buff, sizeof(buff)));
3577
3576
      "data truncated" warning but which is absorbed and never gets to the
3578
3577
      error log); still we init it to avoid a Valgrind message.
3579
3578
    */
3580
 
    mysql_reset_errors(thd, 0);
 
3579
    drizzle_reset_errors(thd, 0);
3581
3580
 
3582
3581
    TABLE_LIST tables;
3583
 
    memset((char*) &tables, 0, sizeof(tables));
 
3582
    memset(&tables, 0, sizeof(tables));
3584
3583
    tables.db= thd->strmake(thd->db, thd->db_length);
3585
3584
    tables.alias = tables.table_name = (char*) table_name;
3586
3585
    tables.lock_type = TL_WRITE;
4237
4236
  :Log_event(buf, description_event)
4238
4237
{
4239
4238
  buf+= description_event->common_header_len;
4240
 
  memcpy((char*) &xid, buf, sizeof(xid));
 
4239
  memcpy(&xid, buf, sizeof(xid));
4241
4240
}
4242
4241
 
4243
4242
 
5082
5081
  IO_CACHE file;
5083
5082
  int error = 1;
5084
5083
 
5085
 
  memset((char*)&file, 0, sizeof(file));
 
5084
  memset(&file, 0, sizeof(file));
5086
5085
  fname_buf= strmov(proc_info, "Making temp file ");
5087
5086
  ext= slave_load_file_stem(fname_buf, file_id, server_id, ".info");
5088
5087
  thd_proc_info(thd, proc_info);