← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/sql_table.cc

This patch does a few things:

* Renames the TransactionServices component in the kernel
  to ReplicationServices.
* Renames the transaction.proto to replication proto and
  updates the various programs referencing drizzled/message/transaction.pb.h
* Adds a public method to the kernel's ReplicationServices component:
  getLastAppliedTimestamp() which returns the timestamp of the last Command message
  which was successfully sent to a registered Applier plugin (the Command was "applied")
* Updates ReplicationServices::push() method to update an atomic timestamp
  when a Command is successfully applied by a replicator to an applier.

The ReplicationServices::getLastAppliedTimestamp() is critical to the upcoming
Publisher plugin, as it allows the publisher to ask the kernel when the last Command
message was applied.

Show diffs side-by-side

added added

removed removed

Lines of Context:
drizzled/sql_table.cc
31
31
#include <drizzled/unireg.h>
32
32
#include <drizzled/item/int.h>
33
33
#include <drizzled/item/empty_string.h>
34
 
#include <drizzled/transaction_services.h>
 
34
#include <drizzled/replication_services.h>
35
35
 
36
36
#include <algorithm>
37
37
 
38
38
using namespace std;
39
 
extern drizzled::TransactionServices transaction_services;
 
39
extern drizzled::ReplicationServices replication_services;
40
40
 
41
41
static const char hexchars[]= "0123456789abcdef";
42
42
bool is_primary_key(KEY *key_info)
343
343
void write_bin_log(Session *session, bool,
344
344
                   char const *query, size_t query_length)
345
345
{
346
 
  transaction_services.rawStatement(session, query, query_length);
 
346
  replication_services.rawStatement(session, query, query_length);
347
347
}
348
348
 
349
349