Lines Matching refs:online_log
366 log = index->online_log; in row_log_online_op()
489 return(index->online_log->error); in row_log_table_get_error()
543 row_log_t* log = index->online_log; in row_log_table_close_func()
635 index->online_log->table, v_no)->m_col.ord_part); in row_log_col_is_indexed()
662 ut_ad(rec_offs_size(offsets) <= sizeof index->online_log->tail.buf); in row_log_table_delete()
669 || index->online_log->error != DB_SUCCESS) { in row_log_table_delete()
673 dict_table_t* new_table = index->online_log->table; in row_log_table_delete()
678 ut_ad(index->online_log->min_trx); in row_log_table_delete()
681 if (index->online_log->same_pk) { in row_log_table_delete()
712 < index->online_log->min_trx; in row_log_table_delete()
716 < index->online_log->min_trx) { in row_log_table_delete()
726 index->online_log->min_trx)); in row_log_table_delete()
733 ut_ad(index->online_log->error != DB_SUCCESS); in row_log_table_delete()
753 if (byte* b = row_log_table_open(index->online_log, in row_log_table_delete()
848 < index->online_log->min_trx) { in row_log_table_low_redundant()
854 const bool is_instant = index->online_log->is_instant(index); in row_log_table_low_redundant()
867 if (insert || index->online_log->same_pk) { in row_log_table_low_redundant()
885 if (byte* b = row_log_table_open(index->online_log, in row_log_table_low_redundant()
912 if (n_fields <= index->online_log->n_core_fields) { in row_log_table_low_redundant()
950 row_log_t* log = index->online_log; in row_log_table_low()
1237 row_log_t* log = index->online_log; in row_log_table_get_pk()
1457 if (index->online_log->error != DB_SUCCESS) { in row_log_table_blob_free()
1461 page_no_map* blobs = index->online_log->blobs; in row_log_table_blob_free()
1464 index->online_log->blobs = blobs = UT_NEW_NOKEY(page_no_map()); in row_log_table_blob_free()
1468 const ulonglong log_pos = index->online_log->tail.total; in row_log_table_blob_free()
1503 if (index->online_log->error != DB_SUCCESS) { in row_log_table_blob_alloc()
1509 if (page_no_map* blobs = index->online_log->blobs) { in row_log_table_blob_alloc()
1514 p->second.blob_alloc(index->online_log->tail.total); in row_log_table_blob_alloc()
1716 const row_log_t*log = dup->index->online_log; in row_log_table_apply_insert_low()
1789 row_log_t*log = dup->index->online_log; in row_log_table_apply_insert()
2061 row_log_t* log = dup->index->online_log; in row_log_table_apply_update()
2428 row_log_t* log = dup->index->online_log; in row_log_table_apply_op()
2716 if (index == NULL || index->online_log == NULL) { in row_log_estimate_work()
2720 const row_log_t* l = index->online_log; in row_log_estimate_work()
2761 dict_table_t* new_table = index->online_log->table; in row_log_table_apply_ops()
2795 ut_ad(index->online_log->head.bytes == 0); in row_log_table_apply_ops()
2810 error = index->online_log->error; in row_log_table_apply_ops()
2816 if (UNIV_UNLIKELY(index->online_log->head.blocks in row_log_table_apply_ops()
2817 > index->online_log->tail.blocks)) { in row_log_table_apply_ops()
2826 if (index->online_log->head.blocks in row_log_table_apply_ops()
2827 == index->online_log->tail.blocks) { in row_log_table_apply_ops()
2828 if (index->online_log->head.blocks) { in row_log_table_apply_ops()
2831 if (index->online_log->fd > 0 in row_log_table_apply_ops()
2832 && ftruncate(index->online_log->fd, 0) == -1) { in row_log_table_apply_ops()
2841 index->online_log->head.blocks in row_log_table_apply_ops()
2842 = index->online_log->tail.blocks = 0; in row_log_table_apply_ops()
2845 next_mrec = index->online_log->tail.block; in row_log_table_apply_ops()
2846 next_mrec_end = next_mrec + index->online_log->tail.bytes; in row_log_table_apply_ops()
2852 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
2853 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2854 index->online_log->head.bytes = 0; in row_log_table_apply_ops()
2855 index->online_log->tail.bytes = 0; in row_log_table_apply_ops()
2862 ofs = (os_offset_t) index->online_log->head.blocks in row_log_table_apply_ops()
2873 if (!row_log_block_allocate(index->online_log->head)) { in row_log_table_apply_ops()
2878 byte* buf = index->online_log->head.block; in row_log_table_apply_ops()
2881 IORequestRead, index->online_log->fd, in row_log_table_apply_ops()
2892 index->online_log->crypt_head, ofs)) { in row_log_table_apply_ops()
2898 memcpy(buf, index->online_log->crypt_head, in row_log_table_apply_ops()
2904 posix_fadvise(index->online_log->fd, in row_log_table_apply_ops()
2908 next_mrec = index->online_log->head.block; in row_log_table_apply_ops()
2915 error = index->online_log->error; in row_log_table_apply_ops()
2928 ut_ad(mrec == index->online_log->head.buf); in row_log_table_apply_ops()
2930 ut_ad(mrec_end < (&index->online_log->head.buf)[1]); in row_log_table_apply_ops()
2933 ulint((&index->online_log->head.buf)[1] - mrec_end)); in row_log_table_apply_ops()
2937 index->online_log->head.buf, in row_log_table_apply_ops()
2938 (&index->online_log->head.buf)[1], offsets); in row_log_table_apply_ops()
2950 index->online_log->head.bytes = ulint(mrec - mrec_end); in row_log_table_apply_ops()
2951 next_mrec += index->online_log->head.bytes; in row_log_table_apply_ops()
2960 ut_ad((mrec == NULL) == (index->online_log->head.bytes == 0)); in row_log_table_apply_ops()
2963 if (next_mrec_end == index->online_log->head.block in row_log_table_apply_ops()
2967 if (index->online_log->tail.bytes == 0) { in row_log_table_apply_ops()
2969 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2970 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
2971 ut_ad(index->online_log->head.bytes == 0); in row_log_table_apply_ops()
2973 ut_ad(next_mrec == index->online_log->head.block in row_log_table_apply_ops()
2974 + index->online_log->head.bytes); in row_log_table_apply_ops()
2975 ut_ad(index->online_log->tail.blocks in row_log_table_apply_ops()
2976 > index->online_log->head.blocks); in row_log_table_apply_ops()
2978 } else if (next_mrec_end == index->online_log->tail.block in row_log_table_apply_ops()
2979 + index->online_log->tail.bytes) { in row_log_table_apply_ops()
2980 ut_ad(next_mrec == index->online_log->tail.block in row_log_table_apply_ops()
2981 + index->online_log->head.bytes); in row_log_table_apply_ops()
2982 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2983 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
2984 ut_ad(index->online_log->head.bytes in row_log_table_apply_ops()
2985 <= index->online_log->tail.bytes); in row_log_table_apply_ops()
3011 ut_ad(mrec >= index->online_log->head.block); in row_log_table_apply_ops()
3012 ut_ad(mrec_end == index->online_log->head.block in row_log_table_apply_ops()
3014 ut_ad(index->online_log->head.bytes in row_log_table_apply_ops()
3024 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
3025 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
3026 ut_ad(mrec_end == index->online_log->tail.block in row_log_table_apply_ops()
3027 + index->online_log->tail.bytes); in row_log_table_apply_ops()
3028 ut_ad(mrec >= index->online_log->tail.block); in row_log_table_apply_ops()
3034 error = index->online_log->error; in row_log_table_apply_ops()
3061 index->online_log->head.bytes = 0; in row_log_table_apply_ops()
3062 index->online_log->head.blocks++; in row_log_table_apply_ops()
3066 index->online_log->head.bytes in row_log_table_apply_ops()
3072 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
3073 ut_ad(mrec_end == index->online_log->tail.block in row_log_table_apply_ops()
3074 + index->online_log->tail.bytes); in row_log_table_apply_ops()
3078 memcpy(index->online_log->head.buf, mrec, in row_log_table_apply_ops()
3080 mrec_end += ulint(index->online_log->head.buf - mrec); in row_log_table_apply_ops()
3081 mrec = index->online_log->head.buf; in row_log_table_apply_ops()
3095 row_log_block_free(index->online_log->head); in row_log_table_apply_ops()
3129 if (clust_index->online_log->n_rows == 0) { in row_log_table_apply()
3130 clust_index->online_log->n_rows = new_table->stat_n_rows; in row_log_table_apply()
3135 if (!clust_index->online_log) { in row_log_table_apply()
3146 clust_index->online_log->col_map, 0 in row_log_table_apply()
3152 || clust_index->online_log->head.total in row_log_table_apply()
3153 == clust_index->online_log->tail.total); in row_log_table_apply()
3257 index->online_log = log; in row_log_allocate()
3305 && mutex_own(&index->online_log->mutex)) in row_log_get_max_trx()
3308 return(index->online_log->max_trx); in row_log_get_max_trx()
3691 ut_ad(index->online_log); in row_log_apply_ops()
3706 ut_ad(index->online_log->head.bytes == 0); in row_log_apply_ops()
3714 error = index->online_log->error; in row_log_apply_ops()
3724 if (UNIV_UNLIKELY(index->online_log->head.blocks in row_log_apply_ops()
3725 > index->online_log->tail.blocks)) { in row_log_apply_ops()
3734 if (index->online_log->head.blocks in row_log_apply_ops()
3735 == index->online_log->tail.blocks) { in row_log_apply_ops()
3736 if (index->online_log->head.blocks) { in row_log_apply_ops()
3739 if (index->online_log->fd > 0 in row_log_apply_ops()
3740 && ftruncate(index->online_log->fd, 0) == -1) { in row_log_apply_ops()
3749 index->online_log->head.blocks in row_log_apply_ops()
3750 = index->online_log->tail.blocks = 0; in row_log_apply_ops()
3753 next_mrec = index->online_log->tail.block; in row_log_apply_ops()
3754 next_mrec_end = next_mrec + index->online_log->tail.bytes; in row_log_apply_ops()
3760 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3761 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3767 index->online_log->head.blocks) in row_log_apply_ops()
3775 if (!row_log_block_allocate(index->online_log->head)) { in row_log_apply_ops()
3780 byte* buf = index->online_log->head.block; in row_log_apply_ops()
3783 IORequestRead, index->online_log->fd, in row_log_apply_ops()
3794 index->online_log->crypt_head, ofs)) { in row_log_apply_ops()
3800 memcpy(buf, index->online_log->crypt_head, srv_sort_buf_size); in row_log_apply_ops()
3805 posix_fadvise(index->online_log->fd, in row_log_apply_ops()
3809 next_mrec = index->online_log->head.block; in row_log_apply_ops()
3820 ut_ad(mrec == index->online_log->head.buf); in row_log_apply_ops()
3822 ut_ad(mrec_end < (&index->online_log->head.buf)[1]); in row_log_apply_ops()
3825 ulint((&index->online_log->head.buf)[1] - mrec_end)); in row_log_apply_ops()
3828 has_index_lock, index->online_log->head.buf, in row_log_apply_ops()
3829 (&index->online_log->head.buf)[1], offsets); in row_log_apply_ops()
3841 index->online_log->head.bytes = ulint(mrec - mrec_end); in row_log_apply_ops()
3842 next_mrec += index->online_log->head.bytes; in row_log_apply_ops()
3851 ut_ad((mrec == NULL) == (index->online_log->head.bytes == 0)); in row_log_apply_ops()
3854 if (next_mrec_end == index->online_log->head.block in row_log_apply_ops()
3858 if (index->online_log->tail.bytes == 0) { in row_log_apply_ops()
3860 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3861 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3862 ut_ad(index->online_log->head.bytes == 0); in row_log_apply_ops()
3864 ut_ad(next_mrec == index->online_log->head.block in row_log_apply_ops()
3865 + index->online_log->head.bytes); in row_log_apply_ops()
3866 ut_ad(index->online_log->tail.blocks in row_log_apply_ops()
3867 > index->online_log->head.blocks); in row_log_apply_ops()
3869 } else if (next_mrec_end == index->online_log->tail.block in row_log_apply_ops()
3870 + index->online_log->tail.bytes) { in row_log_apply_ops()
3871 ut_ad(next_mrec == index->online_log->tail.block in row_log_apply_ops()
3872 + index->online_log->head.bytes); in row_log_apply_ops()
3873 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3874 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3875 ut_ad(index->online_log->head.bytes in row_log_apply_ops()
3876 <= index->online_log->tail.bytes); in row_log_apply_ops()
3894 ut_ad(mrec >= index->online_log->head.block); in row_log_apply_ops()
3895 ut_ad(mrec_end == index->online_log->head.block in row_log_apply_ops()
3897 ut_ad(index->online_log->head.bytes in row_log_apply_ops()
3907 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3908 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3909 ut_ad(mrec_end == index->online_log->tail.block in row_log_apply_ops()
3910 + index->online_log->tail.bytes); in row_log_apply_ops()
3911 ut_ad(mrec >= index->online_log->tail.block); in row_log_apply_ops()
3934 index->online_log->head.bytes = 0; in row_log_apply_ops()
3935 index->online_log->head.blocks++; in row_log_apply_ops()
3939 index->online_log->head.bytes in row_log_apply_ops()
3945 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3946 ut_ad(mrec_end == index->online_log->tail.block in row_log_apply_ops()
3947 + index->online_log->tail.bytes); in row_log_apply_ops()
3951 memcpy(index->online_log->head.buf, mrec, in row_log_apply_ops()
3953 mrec_end += ulint(index->online_log->head.buf - mrec); in row_log_apply_ops()
3954 mrec = index->online_log->head.buf; in row_log_apply_ops()
3970 if (((os_offset_t) index->online_log->tail.blocks + 1) in row_log_apply_ops()
3985 row_log_block_free(index->online_log->head); in row_log_apply_ops()
4040 log = index->online_log; in row_log_apply()
4041 index->online_log = NULL; in row_log_apply()
4051 ut_ad(index->online_log); in row_log_get_n_core_fields()
4052 return index->online_log->n_core_fields; in row_log_get_n_core_fields()