← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/plugin/transaction_applier.cc

  • Committer: Jay Pipes
  • Date: 2009-10-07 23:59:47 UTC
  • mto: (1234.1.1 push) (1237.2.10 push)
  • mto: This revision was merged to the branch mainline in revision 1193.
  • Revision ID: jpipes@serialcoder-20091007235947-18simrecnzwv8t1q
Phase 2 new replication work:

* Removes old replication.proto file, old command_transform library
* Removes use of korr.h macro calls in favor of GPB's CodedOutputStream
  API.
* Updates transaction_log, default_replicator, and filtered_replicator module
  to use new Transaction message.
* Updates ReplicationServices to construct the new Transaction messages and
  associated Statement sub-messages
* Corrects transaction boundaries.  AUTOCOMMIT now works properly, and I have
  added a new test case to verify AUTOCOMMIT variable modification of the way
  in which Transaction messages are bundled up and sent across to replicators.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/plugin/transaction_applier.cc
20
20
#include "drizzled/global.h"
21
21
 
22
22
#include "drizzled/replication_services.h"
23
 
#include "drizzled/plugin/command_applier.h"
 
23
#include "drizzled/plugin/transaction_applier.h"
24
24
 
25
25
using namespace std;
26
 
using namespace drizzled;
27
 
 
28
 
bool plugin::CommandApplier::addPlugin(plugin::CommandApplier *applier)
 
26
 
 
27
namespace drizzled
 
28
{
 
29
 
 
30
bool plugin::TransactionApplier::addPlugin(plugin::TransactionApplier *applier)
29
31
{
30
32
  ReplicationServices &replication_services= ReplicationServices::singleton();
31
33
  /** @TODO ReplicationServices should indicate error in some way here */
33
35
  return false;
34
36
}
35
37
 
36
 
void plugin::CommandApplier::removePlugin(plugin::CommandApplier *applier)
 
38
void plugin::TransactionApplier::removePlugin(plugin::TransactionApplier *applier)
37
39
{
38
40
  ReplicationServices &replication_services= ReplicationServices::singleton();
39
41
  replication_services.detachApplier(applier);
40
42
}
41
43
 
 
44
}