~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/transaction_services.cc

  • Committer: Olaf van der Spek
  • Date: 2011-04-08 13:16:30 UTC
  • mto: (2275.1.1 build)
  • mto: This revision was merged to the branch mainline in revision 2276.
  • Revision ID: olafvdspek@gmail.com-20110408131630-n74bfuxq2y1ytd1x
Session Times

Show diffs side-by-side

added added

removed removed

Lines of Context:
54
54
#include <drizzled/probes.h>
55
55
#include <drizzled/sql_parse.h>
56
56
#include <drizzled/session.h>
 
57
#include <drizzled/session/times.h>
57
58
#include <drizzled/sql_base.h>
58
59
#include <drizzled/replication_services.h>
59
60
#include <drizzled/transaction_services.h>
1024
1025
    trx->set_transaction_id(0);
1025
1026
  }
1026
1027
 
1027
 
  trx->set_start_timestamp(session.getCurrentTimestamp());
 
1028
  trx->set_start_timestamp(session.times.getCurrentTimestamp());
1028
1029
  
1029
1030
  /* segment info may get set elsewhere as needed */
1030
1031
  transaction.set_segment_id(1);
1035
1036
                                                     const Session& session)
1036
1037
{
1037
1038
  message::TransactionContext *trx= transaction.mutable_transaction_context();
1038
 
  trx->set_end_timestamp(session.getCurrentTimestamp());
 
1039
  trx->set_end_timestamp(session.times.getCurrentTimestamp());
1039
1040
}
1040
1041
 
1041
1042
void TransactionServices::cleanupTransactionMessage(message::Transaction *transaction,
1096
1097
                                               const Session& session)
1097
1098
{
1098
1099
  statement.set_type(type);
1099
 
  statement.set_start_timestamp(session.getCurrentTimestamp());
 
1100
  statement.set_start_timestamp(session.times.getCurrentTimestamp());
1100
1101
 
1101
1102
  if (session.variables.replicate_query)
1102
1103
    statement.set_sql(session.getQueryString()->c_str());
1105
1106
void TransactionServices::finalizeStatementMessage(message::Statement &statement,
1106
1107
                                                   Session& session)
1107
1108
{
1108
 
  statement.set_end_timestamp(session.getCurrentTimestamp());
 
1109
  statement.set_end_timestamp(session.times.getCurrentTimestamp());
1109
1110
  session.setStatementMessage(NULL);
1110
1111
}
1111
1112