← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/replicator.cc

  • Committer: Monty Taylor
  • Date: 2008-12-07 18:57:39 UTC
  • mfrom: (665.1.4 codestyle)
  • mto: This revision was merged to the branch mainline in revision 670.
  • Revision ID: monty@inaugust.com-20081207185739-zb0z4vz3s11f2l7t
Merged from Eric.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/replicator.cc
74
74
static bool replicator_session_iterate (Session *session, plugin_ref plugin, void *)
75
75
{
76
76
  replicator_t *repl= plugin_data(plugin, replicator_t *);
77
 
  void *session_data;
 
77
  void *session_data= NULL;
78
78
 
79
79
  /* call this loaded replicator plugin's replicator_func1 function pointer */
80
80
  if (repl && repl->session_init)
102
102
{
103
103
  bool foreach_rv;
104
104
 
105
 
  /* 
 
105
  /*
106
106
    call replicator_session_iterate
107
 
    once for each loaded replicator plugin 
 
107
    once for each loaded replicator plugin
108
108
  */
109
109
  foreach_rv= plugin_foreach(session, replicator_session_iterate,
110
110
                             DRIZZLE_REPLICATOR_PLUGIN, NULL);
209
209
  return replicator_do_row(session, &param);
210
210
}
211
211
 
212
 
bool replicator_update_row(Session *session, Table *table, 
213
 
                           const unsigned char *before, 
 
212
bool replicator_update_row(Session *session, Table *table,
 
213
                           const unsigned char *before,
214
214
                           const unsigned char *after)
215
215
{
216
216
  replicator_row_parms_st param;
235
235
  return replicator_do_row(session, &param);
236
236
}
237
237
 
238
 
/* 
 
238
/*
239
239
  Here be Dragons!
240
240
 
241
 
  Ok, not so much dragons, but this is where we handle either commits or rollbacks of 
242
 
  statements. 
 
241
  Ok, not so much dragons, but this is where we handle either commits or rollbacks of
 
242
  statements.
243
243
*/
244
244
typedef struct replicator_row_end_st
245
245
{
273
273
{
274
274
  bool foreach_rv;
275
275
  replicator_row_end_st params;
276
 
  
 
276
 
277
277
  params.autocommit= autocommit;
278
278
  params.commit= commit;
279
279