← Back to branch summary

~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/message/transaction_writer.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/message/transaction_writer.cc
22
22
 */
23
23
 
24
24
#include <drizzled/global.h>
 
25
#include <drizzled/hash/crc32.h>
25
26
#include <drizzled/gettext.h>
26
27
#include <sys/types.h>
27
28
#include <sys/stat.h>
274
275
  record1->add_key_value("1");
275
276
  record2->add_key_value("2");
276
277
 
277
 
 
278
278
  statement->set_end_timestamp(getNanoTimestamp());
279
279
}
280
280
 
288
288
 
289
289
  output->WriteLittleEndian64(static_cast<uint64_t>(length));
290
290
  output->WriteString(buffer);
 
291
  output->WriteLittleEndian32(drizzled::hash::crc32(buffer.c_str(), length)); /* checksum */
291
292
}
292
293
 
293
294
int main(int argc, char* argv[])