~drizzle-trunk/drizzle/development

« back to all changes in this revision

Viewing changes to drizzled/transaction_services.h

  • Committer: Brian Aker
  • Date: 2010-04-06 06:50:19 UTC
  • mfrom: (1405.3.9 replication-api)
  • Revision ID: brian@gaz-20100406065019-n387mztxp1i75qel
Merge Jay

Show diffs side-by-side

added added

removed removed

Lines of Context:
63
63
    static TransactionServices transaction_services;
64
64
    return transaction_services;
65
65
  }
 
66
 
 
67
  /**
 
68
   * Returns true if the transaction manager should construct
 
69
   * Transaction and Statement messages, false otherwise.
 
70
   */
 
71
  bool shouldConstructMessages();
66
72
  /**
67
73
   * Method which returns the active Transaction message
68
74
   * for the supplied Session.  If one is not found, a new Transaction
189
195
   *
190
196
   * @param Pointer to the Session committing the transaction
191
197
   */
192
 
  void commitTransactionMessage(Session *in_session);
 
198
  int commitTransactionMessage(Session *in_session);
193
199
  /** 
194
200
   * Marks the current active transaction message as being rolled back and
195
201
   * pushes the transaction message out to replicators.
293
299
   */
294
300
  void rawStatement(Session *in_session, const std::string &query);
295
301
  /* transactions: interface to plugin::StorageEngine functions */
296
 
  int ha_commit_one_phase(Session *session, bool all);
297
 
  int ha_rollback_trans(Session *session, bool all);
 
302
  int commitPhaseOne(Session *session, bool all);
 
303
  int rollbackTransaction(Session *session, bool all);
298
304
 
299
305
  /* transactions: these functions never call plugin::StorageEngine functions directly */
300
 
  int ha_commit_trans(Session *session, bool all);
301
 
  int ha_autocommit_or_rollback(Session *session, int error);
 
306
  int commitTransaction(Session *session, bool all);
 
307
  int autocommitOrRollback(Session *session, int error);
302
308
 
303
309
  /* savepoints */
304
 
  int ha_rollback_to_savepoint(Session *session, NamedSavepoint &sv);
305
 
  int ha_savepoint(Session *session, NamedSavepoint &sv);
306
 
  int ha_release_savepoint(Session *session, NamedSavepoint &sv);
307
 
  bool mysql_xa_recover(Session *session);
 
310
  int rollbackToSavepoint(Session *session, NamedSavepoint &sv);
 
311
  int setSavepoint(Session *session, NamedSavepoint &sv);
 
312
  int releaseSavepoint(Session *session, NamedSavepoint &sv);
308
313
 
309
314
  /**
310
315
   * Marks a storage engine as participating in a statement