summaryrefslogtreecommitdiff
path: root/storage/xtradb/read/read0read.c
diff options
context:
space:
mode:
Diffstat (limited to 'storage/xtradb/read/read0read.c')
-rw-r--r--storage/xtradb/read/read0read.c55
1 files changed, 25 insertions, 30 deletions
diff --git a/storage/xtradb/read/read0read.c b/storage/xtradb/read/read0read.c
index 85adae4ddff..f049dd21e8d 100644
--- a/storage/xtradb/read/read0read.c
+++ b/storage/xtradb/read/read0read.c
@@ -168,8 +168,7 @@ read_view_t*
read_view_oldest_copy_or_open_new(
/*==============================*/
trx_id_t cr_trx_id, /*!< in: trx_id of creating
- transaction, or ut_dulint_zero
- used in purge */
+ transaction, or 0 used in purge */
mem_heap_t* heap) /*!< in: memory heap from which
allocated */
{
@@ -191,7 +190,7 @@ read_view_oldest_copy_or_open_new(
n = old_view->n_trx_ids;
- if (!ut_dulint_is_zero(old_view->creator_trx_id)) {
+ if (old_view->creator_trx_id) {
n++;
} else {
needs_insert = FALSE;
@@ -206,9 +205,8 @@ read_view_oldest_copy_or_open_new(
while (i < n) {
if (needs_insert
&& (i >= old_view->n_trx_ids
- || ut_dulint_cmp(old_view->creator_trx_id,
- read_view_get_nth_trx_id(old_view, i))
- > 0)) {
+ || old_view->creator_trx_id
+ > read_view_get_nth_trx_id(old_view, i))) {
read_view_set_nth_trx_id(view_copy, i,
old_view->creator_trx_id);
@@ -252,8 +250,7 @@ read_view_t*
read_view_open_now(
/*===============*/
trx_id_t cr_trx_id, /*!< in: trx_id of creating
- transaction, or ut_dulint_zero
- used in purge */
+ transaction, or 0 used in purge */
mem_heap_t* heap) /*!< in: memory heap from which
allocated */
{
@@ -267,7 +264,7 @@ read_view_open_now(
view->creator_trx_id = cr_trx_id;
view->type = VIEW_NORMAL;
- view->undo_no = ut_dulint_zero;
+ view->undo_no = 0;
/* No future transactions should be visible in the view */
@@ -280,7 +277,7 @@ read_view_open_now(
/* No active transaction should be visible, except cr_trx */
while (trx) {
- if (ut_dulint_cmp(trx->id, cr_trx_id) != 0
+ if (trx->id != cr_trx_id
&& (trx->conc_state == TRX_ACTIVE
|| trx->conc_state == TRX_PREPARED)) {
@@ -292,9 +289,9 @@ read_view_open_now(
trx_sys->max_trx_id can still be active, if it is
in the middle of its commit! Note that when a
transaction starts, we initialize trx->no to
- ut_dulint_max. */
+ IB_ULONGLONG_MAX. */
- if (ut_dulint_cmp(view->low_limit_no, trx->no) > 0) {
+ if (view->low_limit_no > trx->no) {
view->low_limit_no = trx->no;
}
@@ -360,38 +357,36 @@ UNIV_INTERN
void
read_view_print(
/*============*/
+ FILE* file,
const read_view_t* view) /*!< in: read view */
{
ulint n_ids;
ulint i;
if (view->type == VIEW_HIGH_GRANULARITY) {
- fprintf(stderr,
- "High-granularity read view undo_n:o %lu %lu\n",
- (ulong) ut_dulint_get_high(view->undo_no),
- (ulong) ut_dulint_get_low(view->undo_no));
+ fprintf(file,
+ "High-granularity read view undo_n:o %llu\n",
+ (ullint) view->undo_no);
} else {
- fprintf(stderr, "Normal read view\n");
+ fprintf(file, "Normal read view\n");
}
- fprintf(stderr, "Read view low limit trx n:o %lu %lu\n",
- (ulong) ut_dulint_get_high(view->low_limit_no),
- (ulong) ut_dulint_get_low(view->low_limit_no));
+ fprintf(file, "Read view low limit trx n:o " TRX_ID_FMT "\n",
+ (ullint) view->low_limit_no);
- fprintf(stderr, "Read view up limit trx id " TRX_ID_FMT "\n",
- TRX_ID_PREP_PRINTF(view->up_limit_id));
+ fprintf(file, "Read view up limit trx id " TRX_ID_FMT "\n",
+ (ullint) view->up_limit_id);
- fprintf(stderr, "Read view low limit trx id " TRX_ID_FMT "\n",
- TRX_ID_PREP_PRINTF(view->low_limit_id));
+ fprintf(file, "Read view low limit trx id " TRX_ID_FMT "\n",
+ (ullint) view->low_limit_id);
- fprintf(stderr, "Read view individually stored trx ids:\n");
+ fprintf(file, "Read view individually stored trx ids:\n");
n_ids = view->n_trx_ids;
for (i = 0; i < n_ids; i++) {
- fprintf(stderr, "Read view trx id " TRX_ID_FMT "\n",
- TRX_ID_PREP_PRINTF(
- read_view_get_nth_trx_id(view, i)));
+ fprintf(file, "Read view trx id " TRX_ID_FMT "\n",
+ (ullint) read_view_get_nth_trx_id(view, i));
}
}
@@ -460,9 +455,9 @@ read_cursor_view_create_for_mysql(
trx_sys->max_trx_id can still be active, if it is
in the middle of its commit! Note that when a
transaction starts, we initialize trx->no to
- ut_dulint_max. */
+ IB_ULONGLONG_MAX. */
- if (ut_dulint_cmp(view->low_limit_no, trx->no) > 0) {
+ if (view->low_limit_no > trx->no) {
view->low_limit_no = trx->no;
}