← 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-08 07:48:37 UTC
  • Revision ID: brian@tangent.org-20081008074837-fl4pbrupvvtolezn
Wrote out master.info (more of it). Add to this more private'izing of
Master_Info object.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/sql_repl.cc
1037
1037
    goto err;
1038
1038
 
1039
1039
  /* Clear master's log coordinates */
1040
 
  mi->init_master_log_pos();
 
1040
  mi->reset();
1041
1041
  /*
1042
1042
     Reset errors (the idea is that we forget about the
1043
1043
     old master).
1155
1155
  */
1156
1156
 
1157
1157
  if ((lex_mi->host || lex_mi->port) && !lex_mi->log_file_name && !lex_mi->pos)
1158
 
  {
1159
 
    mi->master_log_name[0] = 0;
1160
 
    mi->master_log_pos= BIN_LOG_HEADER_SIZE;
1161
 
  }
 
1158
    mi->reset();
1162
1159
 
1163
1160
  if (lex_mi->log_file_name)
1164
1161
    mi->setLogName(lex_mi->log_file_name);
1165
1162
  if (lex_mi->pos)
1166
1163
  {
1167
 
    mi->master_log_pos= lex_mi->pos;
 
1164
    mi->setLogPosition(lex_mi->pos);
1168
1165
  }
1169
1166
 
1170
1167
  if (lex_mi->host)
1219
1216
       of replication is not 100% clear, so we guard against problems using
1220
1217
       cmax().
1221
1218
      */
1222
 
     mi->master_log_pos = ((BIN_LOG_HEADER_SIZE > mi->rli.group_master_log_pos)
1223
 
                           ? BIN_LOG_HEADER_SIZE
1224
 
                           : mi->rli.group_master_log_pos);
 
1219
     mi->setLogPosition(((BIN_LOG_HEADER_SIZE > mi->rli.group_master_log_pos)
 
1220
                         ? BIN_LOG_HEADER_SIZE
 
1221
                         : mi->rli.group_master_log_pos));
1225
1222
     mi->setLogName(mi->rli.group_master_log_name.c_str());
1226
1223
  }
1227
1224
  /*
1228
1225
    Relay log's IO_CACHE may not be inited, if rli->inited==0 (server was never
1229
1226
    a slave before).
1230
1227
  */
1231
 
  if (mi->flush_master_info(0))
 
1228
  if (mi->flush())
1232
1229
  {
1233
1230
    my_error(ER_RELAY_LOG_INIT, MYF(0), "Failed to flush master info file");
1234
1231
    unlock_slave_threads(mi);
1273
1270
    ''/0: we have lost all copies of the original good coordinates.
1274
1271
    That's why we always save good coords in rli.
1275
1272
  */
1276
 
  mi->rli.group_master_log_pos= mi->master_log_pos;
1277
 
  mi->rli.group_master_log_name.assign(mi->master_log_name);
 
1273
  mi->rli.group_master_log_pos= mi->getLogPosition();
 
1274
  mi->rli.group_master_log_name.assign(mi->getLogName());
1278
1275
 
1279
1276
  if (mi->rli.group_master_log_name.size() == 0) // uninitialized case
1280
1277
    mi->rli.group_master_log_pos= 0;