Lines Matching refs:online_log
307 log = index->online_log; in row_log_online_op()
412 return(index->online_log->error); in row_log_table_get_error()
548 ut_ad(rec_offs_size(offsets) <= sizeof index->online_log->tail.buf); in row_log_table_delete()
556 || index->online_log->error != DB_SUCCESS) { in row_log_table_delete()
560 dict_table_t* new_table = index->online_log->table; in row_log_table_delete()
567 if (index->online_log->same_pk) { in row_log_table_delete()
607 ut_ad(index->online_log->error != DB_SUCCESS); in row_log_table_delete()
648 if (byte* b = row_log_table_open(index->online_log, in row_log_table_delete()
674 index->online_log->col_map) { in row_log_table_delete()
691 index->online_log, b, mrec_size, avail_size); in row_log_table_delete()
771 if (insert || index->online_log->same_pk) { in row_log_table_low_redundant()
789 if (byte* b = row_log_table_open(index->online_log, in row_log_table_low_redundant()
815 index->online_log, b, mrec_size, avail_size); in row_log_table_low_redundant()
843 index->online_log->table); in row_log_table_low()
849 ut_ad(rec_offs_size(offsets) <= sizeof index->online_log->tail.buf); in row_log_table_low()
860 || index->online_log->error != DB_SUCCESS) { in row_log_table_low()
880 if (insert || index->online_log->same_pk) { in row_log_table_low()
898 if (byte* b = row_log_table_open(index->online_log, in row_log_table_low()
925 index->online_log, b, mrec_size, avail_size); in row_log_table_low()
1053 row_log_t* log = index->online_log; in row_log_table_get_pk()
1259 if (index->online_log->error != DB_SUCCESS) { in row_log_table_blob_free()
1263 page_no_map* blobs = index->online_log->blobs; in row_log_table_blob_free()
1266 index->online_log->blobs = blobs = new page_no_map(); in row_log_table_blob_free()
1270 const ulonglong log_pos = index->online_log->tail.total; in row_log_table_blob_free()
1304 if (index->online_log->error != DB_SUCCESS) { in row_log_table_blob_alloc()
1310 if (page_no_map* blobs = index->online_log->blobs) { in row_log_table_blob_alloc()
1315 p->second.blob_alloc(index->online_log->tail.total); in row_log_table_blob_alloc()
1493 const row_log_t*log = dup->index->online_log; in row_log_table_apply_insert_low()
1573 const row_log_t*log = dup->index->online_log; in row_log_table_apply_insert()
1852 const row_log_t*log = dup->index->online_log; in row_log_table_apply_update()
2216 row_log_t* log = dup->index->online_log; in row_log_table_apply_op()
2341 if (dup->index->online_log->same_pk) { in row_log_table_apply_op()
2505 dict_table_t* new_table = index->online_log->table; in row_log_table_apply_ops()
2544 ut_ad(index->online_log->head.bytes == 0); in row_log_table_apply_ops()
2557 error = index->online_log->error; in row_log_table_apply_ops()
2563 if (UNIV_UNLIKELY(index->online_log->head.blocks in row_log_table_apply_ops()
2564 > index->online_log->tail.blocks)) { in row_log_table_apply_ops()
2573 if (index->online_log->head.blocks in row_log_table_apply_ops()
2574 == index->online_log->tail.blocks) { in row_log_table_apply_ops()
2575 if (index->online_log->head.blocks) { in row_log_table_apply_ops()
2578 if (index->online_log->fd != -1 in row_log_table_apply_ops()
2579 && ftruncate(index->online_log->fd, 0) == -1) { in row_log_table_apply_ops()
2583 index->online_log->head.blocks in row_log_table_apply_ops()
2584 = index->online_log->tail.blocks = 0; in row_log_table_apply_ops()
2587 next_mrec = index->online_log->tail.block; in row_log_table_apply_ops()
2588 next_mrec_end = next_mrec + index->online_log->tail.bytes; in row_log_table_apply_ops()
2594 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
2595 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2596 index->online_log->head.bytes = 0; in row_log_table_apply_ops()
2597 index->online_log->tail.bytes = 0; in row_log_table_apply_ops()
2605 ofs = (os_offset_t) index->online_log->head.blocks in row_log_table_apply_ops()
2616 if (!row_log_block_allocate(index->online_log->head)) { in row_log_table_apply_ops()
2622 index->online_log->fd, in row_log_table_apply_ops()
2623 index->online_log->head.block, ofs, in row_log_table_apply_ops()
2633 posix_fadvise(index->online_log->fd, in row_log_table_apply_ops()
2640 fallocate(index->online_log->fd, in row_log_table_apply_ops()
2645 next_mrec = index->online_log->head.block; in row_log_table_apply_ops()
2652 error = index->online_log->error; in row_log_table_apply_ops()
2665 ut_ad(mrec == index->online_log->head.buf); in row_log_table_apply_ops()
2667 ut_ad(mrec_end < (&index->online_log->head.buf)[1]); in row_log_table_apply_ops()
2670 (&index->online_log->head.buf)[1] - mrec_end); in row_log_table_apply_ops()
2674 index->online_log->head.buf, in row_log_table_apply_ops()
2675 (&index->online_log->head.buf)[1], offsets); in row_log_table_apply_ops()
2687 index->online_log->head.bytes = mrec - mrec_end; in row_log_table_apply_ops()
2688 next_mrec += index->online_log->head.bytes; in row_log_table_apply_ops()
2697 ut_ad((mrec == NULL) == (index->online_log->head.bytes == 0)); in row_log_table_apply_ops()
2700 if (next_mrec_end == index->online_log->head.block in row_log_table_apply_ops()
2704 if (index->online_log->tail.bytes == 0) { in row_log_table_apply_ops()
2706 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2707 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
2708 ut_ad(index->online_log->head.bytes == 0); in row_log_table_apply_ops()
2710 ut_ad(next_mrec == index->online_log->head.block in row_log_table_apply_ops()
2711 + index->online_log->head.bytes); in row_log_table_apply_ops()
2712 ut_ad(index->online_log->tail.blocks in row_log_table_apply_ops()
2713 > index->online_log->head.blocks); in row_log_table_apply_ops()
2715 } else if (next_mrec_end == index->online_log->tail.block in row_log_table_apply_ops()
2716 + index->online_log->tail.bytes) { in row_log_table_apply_ops()
2717 ut_ad(next_mrec == index->online_log->tail.block in row_log_table_apply_ops()
2718 + index->online_log->head.bytes); in row_log_table_apply_ops()
2719 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2720 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
2721 ut_ad(index->online_log->head.bytes in row_log_table_apply_ops()
2722 <= index->online_log->tail.bytes); in row_log_table_apply_ops()
2748 ut_ad(mrec >= index->online_log->head.block); in row_log_table_apply_ops()
2749 ut_ad(mrec_end == index->online_log->head.block in row_log_table_apply_ops()
2751 ut_ad(index->online_log->head.bytes in row_log_table_apply_ops()
2761 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
2762 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2763 ut_ad(mrec_end == index->online_log->tail.block in row_log_table_apply_ops()
2764 + index->online_log->tail.bytes); in row_log_table_apply_ops()
2765 ut_ad(mrec >= index->online_log->tail.block); in row_log_table_apply_ops()
2771 error = index->online_log->error; in row_log_table_apply_ops()
2798 index->online_log->head.bytes = 0; in row_log_table_apply_ops()
2799 index->online_log->head.blocks++; in row_log_table_apply_ops()
2803 index->online_log->head.bytes += next_mrec - mrec; in row_log_table_apply_ops()
2808 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2809 ut_ad(mrec_end == index->online_log->tail.block in row_log_table_apply_ops()
2810 + index->online_log->tail.bytes); in row_log_table_apply_ops()
2814 memcpy(index->online_log->head.buf, mrec, in row_log_table_apply_ops()
2816 mrec_end += index->online_log->head.buf - mrec; in row_log_table_apply_ops()
2817 mrec = index->online_log->head.buf; in row_log_table_apply_ops()
2831 row_log_block_free(index->online_log->head); in row_log_table_apply_ops()
2861 if (!clust_index->online_log) { in row_log_table_apply()
2872 clust_index->online_log->col_map, 0 in row_log_table_apply()
2878 || clust_index->online_log->head.total in row_log_table_apply()
2879 == clust_index->online_log->tail.total); in row_log_table_apply()
2940 index->online_log = log; in row_log_allocate()
2982 && mutex_own(&index->online_log->mutex)) in row_log_get_max_trx()
2985 return(index->online_log->max_trx); in row_log_get_max_trx()
3369 ut_ad(index->online_log); in row_log_apply_ops()
3385 ut_ad(index->online_log->head.bytes == 0); in row_log_apply_ops()
3391 error = index->online_log->error; in row_log_apply_ops()
3401 if (UNIV_UNLIKELY(index->online_log->head.blocks in row_log_apply_ops()
3402 > index->online_log->tail.blocks)) { in row_log_apply_ops()
3411 if (index->online_log->head.blocks in row_log_apply_ops()
3412 == index->online_log->tail.blocks) { in row_log_apply_ops()
3413 if (index->online_log->head.blocks) { in row_log_apply_ops()
3416 if (index->online_log->fd != -1 in row_log_apply_ops()
3417 && ftruncate(index->online_log->fd, 0) == -1) { in row_log_apply_ops()
3421 index->online_log->head.blocks in row_log_apply_ops()
3422 = index->online_log->tail.blocks = 0; in row_log_apply_ops()
3425 next_mrec = index->online_log->tail.block; in row_log_apply_ops()
3426 next_mrec_end = next_mrec + index->online_log->tail.bytes; in row_log_apply_ops()
3432 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3433 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3441 ofs = (os_offset_t) index->online_log->head.blocks in row_log_apply_ops()
3450 if (!row_log_block_allocate(index->online_log->head)) { in row_log_apply_ops()
3456 index->online_log->fd, in row_log_apply_ops()
3457 index->online_log->head.block, ofs, in row_log_apply_ops()
3468 posix_fadvise(index->online_log->fd, in row_log_apply_ops()
3475 fallocate(index->online_log->fd, in row_log_apply_ops()
3480 next_mrec = index->online_log->head.block; in row_log_apply_ops()
3491 ut_ad(mrec == index->online_log->head.buf); in row_log_apply_ops()
3493 ut_ad(mrec_end < (&index->online_log->head.buf)[1]); in row_log_apply_ops()
3496 (&index->online_log->head.buf)[1] - mrec_end); in row_log_apply_ops()
3499 has_index_lock, index->online_log->head.buf, in row_log_apply_ops()
3500 (&index->online_log->head.buf)[1], offsets); in row_log_apply_ops()
3512 index->online_log->head.bytes = mrec - mrec_end; in row_log_apply_ops()
3513 next_mrec += index->online_log->head.bytes; in row_log_apply_ops()
3522 ut_ad((mrec == NULL) == (index->online_log->head.bytes == 0)); in row_log_apply_ops()
3525 if (next_mrec_end == index->online_log->head.block in row_log_apply_ops()
3529 if (index->online_log->tail.bytes == 0) { in row_log_apply_ops()
3531 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3532 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3533 ut_ad(index->online_log->head.bytes == 0); in row_log_apply_ops()
3535 ut_ad(next_mrec == index->online_log->head.block in row_log_apply_ops()
3536 + index->online_log->head.bytes); in row_log_apply_ops()
3537 ut_ad(index->online_log->tail.blocks in row_log_apply_ops()
3538 > index->online_log->head.blocks); in row_log_apply_ops()
3540 } else if (next_mrec_end == index->online_log->tail.block in row_log_apply_ops()
3541 + index->online_log->tail.bytes) { in row_log_apply_ops()
3542 ut_ad(next_mrec == index->online_log->tail.block in row_log_apply_ops()
3543 + index->online_log->head.bytes); in row_log_apply_ops()
3544 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3545 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3546 ut_ad(index->online_log->head.bytes in row_log_apply_ops()
3547 <= index->online_log->tail.bytes); in row_log_apply_ops()
3565 ut_ad(mrec >= index->online_log->head.block); in row_log_apply_ops()
3566 ut_ad(mrec_end == index->online_log->head.block in row_log_apply_ops()
3568 ut_ad(index->online_log->head.bytes in row_log_apply_ops()
3578 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3579 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3580 ut_ad(mrec_end == index->online_log->tail.block in row_log_apply_ops()
3581 + index->online_log->tail.bytes); in row_log_apply_ops()
3582 ut_ad(mrec >= index->online_log->tail.block); in row_log_apply_ops()
3605 index->online_log->head.bytes = 0; in row_log_apply_ops()
3606 index->online_log->head.blocks++; in row_log_apply_ops()
3610 index->online_log->head.bytes += next_mrec - mrec; in row_log_apply_ops()
3615 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3616 ut_ad(mrec_end == index->online_log->tail.block in row_log_apply_ops()
3617 + index->online_log->tail.bytes); in row_log_apply_ops()
3621 memcpy(index->online_log->head.buf, mrec, in row_log_apply_ops()
3623 mrec_end += index->online_log->head.buf - mrec; in row_log_apply_ops()
3624 mrec = index->online_log->head.buf; in row_log_apply_ops()
3640 if (((os_offset_t) index->online_log->tail.blocks + 1) in row_log_apply_ops()
3655 row_log_block_free(index->online_log->head); in row_log_apply_ops()
3705 log = index->online_log; in row_log_apply()
3706 index->online_log = NULL; in row_log_apply()