summaryrefslogtreecommitdiff
path: root/ft/txn.cc
diff options
context:
space:
mode:
Diffstat (limited to 'ft/txn.cc')
-rw-r--r--ft/txn.cc26
1 files changed, 13 insertions, 13 deletions
diff --git a/ft/txn.cc b/ft/txn.cc
index 5f72d70a1fd..a7687b7bc84 100644
--- a/ft/txn.cc
+++ b/ft/txn.cc
@@ -63,7 +63,7 @@ toku_txn_unlock(TOKUTXN txn)
toku_mutex_unlock(&txn->txn_lock);
}
-u_int64_t
+uint64_t
toku_txn_get_id(TOKUTXN txn)
{
return txn->txnid64;
@@ -159,9 +159,9 @@ toku_txn_create_txn (
.live_root_txn_list = nullptr,
.xids = xids,
.begin_was_logged = false,
- .checkpoint_needed_before_commit = FALSE,
- .do_fsync = FALSE,
- .force_fsync_on_commit = FALSE,
+ .checkpoint_needed_before_commit = false,
+ .do_fsync = false,
+ .force_fsync_on_commit = false,
.do_fsync_lsn = ZERO_LSN,
.xa_xid = {0},
.progress_poll_fun = NULL,
@@ -258,7 +258,7 @@ int toku_txn_commit_txn(TOKUTXN txn, int nosync,
void
toku_txn_require_checkpoint_on_commit(TOKUTXN txn) {
- txn->checkpoint_needed_before_commit = TRUE;
+ txn->checkpoint_needed_before_commit = true;
}
struct xcommit_info {
@@ -266,7 +266,7 @@ struct xcommit_info {
TOKUTXN txn;
};
-BOOL toku_txn_requires_checkpoint(TOKUTXN txn) {
+bool toku_txn_requires_checkpoint(TOKUTXN txn) {
return (!txn->parent && txn->checkpoint_needed_before_commit);
}
@@ -324,7 +324,7 @@ int toku_txn_abort_with_lsn(TOKUTXN txn, LSN oplsn,
txn->progress_poll_fun = poll;
txn->progress_poll_fun_extra = poll_extra;
int r;
- txn->do_fsync = FALSE;
+ txn->do_fsync = false;
if (!toku_txn_is_read_only(txn)) {
r = toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid64);
@@ -373,7 +373,7 @@ void toku_txn_get_prepared_xa_xid (TOKUTXN txn, TOKU_XA_XID *xid) {
copy_xid(xid, &txn->xa_xid);
}
-int toku_logger_recover_txn (TOKULOGGER logger, struct tokulogger_preplist preplist[/*count*/], long count, /*out*/ long *retp, u_int32_t flags) {
+int toku_logger_recover_txn (TOKULOGGER logger, struct tokulogger_preplist preplist[/*count*/], long count, /*out*/ long *retp, uint32_t flags) {
return toku_txn_manager_recover_txn(
logger->txn_manager,
preplist,
@@ -383,7 +383,7 @@ int toku_logger_recover_txn (TOKULOGGER logger, struct tokulogger_preplist prepl
);
}
-int toku_txn_maybe_fsync_log(TOKULOGGER logger, LSN do_fsync_lsn, BOOL do_fsync) {
+int toku_txn_maybe_fsync_log(TOKULOGGER logger, LSN do_fsync_lsn, bool do_fsync) {
int r = 0;
if (logger && do_fsync) {
r = toku_logger_fsync_if_lsn_not_fsynced(logger, do_fsync_lsn);
@@ -391,7 +391,7 @@ int toku_txn_maybe_fsync_log(TOKULOGGER logger, LSN do_fsync_lsn, BOOL do_fsync)
return r;
}
-void toku_txn_get_fsync_info(TOKUTXN ttxn, BOOL* do_fsync, LSN* do_fsync_lsn) {
+void toku_txn_get_fsync_info(TOKUTXN ttxn, bool* do_fsync, LSN* do_fsync_lsn) {
*do_fsync = ttxn->do_fsync;
*do_fsync_lsn = ttxn->do_fsync_lsn;
}
@@ -401,7 +401,7 @@ void toku_txn_close_txn(TOKUTXN txn) {
toku_txn_destroy_txn(txn);
}
-static int remove_txn (OMTVALUE hv, u_int32_t UU(idx), void *txnv)
+static int remove_txn (OMTVALUE hv, uint32_t UU(idx), void *txnv)
// Effect: This function is called on every open FT that a transaction used.
// This function removes the transaction from that FT.
{
@@ -454,7 +454,7 @@ XIDS toku_txn_get_xids (TOKUTXN txn) {
}
void toku_txn_force_fsync_on_commit(TOKUTXN txn) {
- txn->force_fsync_on_commit = TRUE;
+ txn->force_fsync_on_commit = true;
}
TXNID toku_get_oldest_in_live_root_txn_list(TOKUTXN txn) {
@@ -471,7 +471,7 @@ bool toku_is_txn_in_live_root_txn_list(const xid_omt_t &live_root_txn_list, TXNI
int r = live_root_txn_list.find_zero<TXNID, toku_find_xid_by_xid>(xid, &txnid, nullptr);
if (r==0) {
invariant(txnid == xid);
- retval = TRUE;
+ retval = true;
}
else {
invariant(r==DB_NOTFOUND);