← Back to branch summary

~jaypipes/drizzle/new-test-runner

« back to all changes in this revision

Viewing changes to drizzled/replication/rli.h

  • Committer: Jay Pipes
  • Date: 2008-12-11 17:52:34 UTC
  • mfrom: (482.16.152 testable)
  • Revision ID: jpipes@serialcoder-20081211175234-uqsfvmgxejvmellq
merge with trunk

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/replication/rli.h
134
134
    a different log under our feet
135
135
  */
136
136
  uint32_t cur_log_old_open_count;
137
 
  
 
137
 
138
138
  /*
139
139
    Let's call a group (of events) :
140
140
      - a transaction
163
163
  bool is_fake; /* Mark that this is a fake relay log info structure */
164
164
#endif
165
165
 
166
 
  /* 
 
166
  /*
167
167
     Original log name and position of the group we're currently executing
168
168
     (whose coordinates are group_relay_log_name/pos in the relay log)
169
169
     in the master's binlog. These concern the *group*, because in the master's
212
212
  volatile bool abort_slave;
213
213
  volatile uint32_t slave_running;
214
214
 
215
 
  /* 
 
215
  /*
216
216
     Condition and its parameters from START SLAVE UNTIL clause.
217
 
     
218
 
     UNTIL condition is tested with is_until_satisfied() method that is 
 
217
 
 
218
     UNTIL condition is tested with is_until_satisfied() method that is
219
219
     called by exec_relay_log_event(). is_until_satisfied() caches the result
220
220
     of the comparison of log names because log names don't change very often;
221
221
     this cache is invalidated by parts of code which change log names with
222
222
     notify_*_log_name_updated() methods. (They need to be called only if SQL
223
223
     thread is running).
224
224
   */
225
 
  
 
225
 
226
226
  enum {UNTIL_NONE= 0, UNTIL_MASTER_POS, UNTIL_RELAY_POS} until_condition;
227
227
  char until_log_name[FN_REFLEN];
228
228
  uint64_t until_log_pos;
229
229
  /* extension extracted from log_name and converted to int32_t */
230
 
  uint32_t until_log_name_extension;   
231
 
  /* 
 
230
  uint32_t until_log_name_extension;
 
231
  /*
232
232
     Cached result of comparison of until_log_name and current log name
233
 
     -2 means unitialised, -1,0,1 are comarison results 
 
233
     -2 means unitialised, -1,0,1 are comarison results
234
234
  */
235
 
  enum 
236
 
  { 
 
235
  enum
 
236
  {
237
237
    UNTIL_LOG_NAMES_CMP_UNKNOWN= -2, UNTIL_LOG_NAMES_CMP_LESS= -1,
238
238
    UNTIL_LOG_NAMES_CMP_EQUAL= 0, UNTIL_LOG_NAMES_CMP_GREATER= 1
239
239
  } until_log_names_cmp_result;
262
262
  ~Relay_log_info();
263
263
 
264
264
  /*
265
 
    Invalidate cached until_log_name and group_relay_log_name comparison 
 
265
    Invalidate cached until_log_name and group_relay_log_name comparison
266
266
    result. Should be called after any update of group_realy_log_name if
267
267
    there chances that sql_thread is running.
268
268
  */
273
273
  }
274
274
 
275
275
  /*
276
 
    The same as previous but for group_master_log_name. 
 
276
    The same as previous but for group_master_log_name.
277
277
  */
278
278
  inline void notify_group_master_log_name_update()
279
279
  {
280
280
    if (until_condition==UNTIL_MASTER_POS)
281
281
      until_log_names_cmp_result= UNTIL_LOG_NAMES_CMP_UNKNOWN;
282
282
  }
283
 
  
 
283
 
284
284
  inline void inc_event_relay_log_pos()
285
285
  {
286
286
    event_relay_log_pos= future_event_relay_log_pos;
289
289
  void inc_group_relay_log_pos(uint64_t log_pos,
290
290
                               bool skip_lock=0);
291
291
 
292
 
  int32_t wait_for_pos(Session* session, String* log_name, int64_t log_pos, 
 
292
  int32_t wait_for_pos(Session* session, String* log_name, int64_t log_pos,
293
293
                   int64_t timeout);
294
294
  void close_temporary_tables();
295
295