Lines Matching refs:online_log
365 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()
636 index->online_log->table, v_no)->m_col.ord_part); in row_log_col_is_indexed()
663 ut_ad(rec_offs_size(offsets) <= sizeof index->online_log->tail.buf); in row_log_table_delete()
670 || index->online_log->error != DB_SUCCESS) { in row_log_table_delete()
674 dict_table_t* new_table = index->online_log->table; in row_log_table_delete()
679 ut_ad(index->online_log->min_trx); in row_log_table_delete()
682 if (index->online_log->same_pk) { in row_log_table_delete()
713 < index->online_log->min_trx; in row_log_table_delete()
717 < index->online_log->min_trx) { in row_log_table_delete()
727 index->online_log->min_trx)); in row_log_table_delete()
734 ut_ad(index->online_log->error != DB_SUCCESS); in row_log_table_delete()
754 if (byte* b = row_log_table_open(index->online_log, in row_log_table_delete()
849 < index->online_log->min_trx) { in row_log_table_low_redundant()
855 const bool is_instant = index->online_log->is_instant(index); in row_log_table_low_redundant()
868 if (insert || index->online_log->same_pk) { in row_log_table_low_redundant()
886 if (byte* b = row_log_table_open(index->online_log, in row_log_table_low_redundant()
913 if (n_fields <= index->online_log->n_core_fields) { in row_log_table_low_redundant()
951 row_log_t* log = index->online_log; in row_log_table_low()
1238 row_log_t* log = index->online_log; in row_log_table_get_pk()
1458 if (index->online_log->error != DB_SUCCESS) { in row_log_table_blob_free()
1462 page_no_map* blobs = index->online_log->blobs; in row_log_table_blob_free()
1465 index->online_log->blobs = blobs = UT_NEW_NOKEY(page_no_map()); in row_log_table_blob_free()
1469 const ulonglong log_pos = index->online_log->tail.total; in row_log_table_blob_free()
1504 if (index->online_log->error != DB_SUCCESS) { in row_log_table_blob_alloc()
1510 if (page_no_map* blobs = index->online_log->blobs) { in row_log_table_blob_alloc()
1515 p->second.blob_alloc(index->online_log->tail.total); in row_log_table_blob_alloc()
1717 const row_log_t*log = dup->index->online_log; in row_log_table_apply_insert_low()
1790 row_log_t*log = dup->index->online_log; in row_log_table_apply_insert()
2062 row_log_t* log = dup->index->online_log; in row_log_table_apply_update()
2430 row_log_t* log = dup->index->online_log; in row_log_table_apply_op()
2718 if (index == NULL || index->online_log == NULL) { in row_log_estimate_work()
2722 const row_log_t* l = index->online_log; in row_log_estimate_work()
2763 dict_table_t* new_table = index->online_log->table; in row_log_table_apply_ops()
2797 ut_ad(index->online_log->head.bytes == 0); in row_log_table_apply_ops()
2812 error = index->online_log->error; in row_log_table_apply_ops()
2818 if (UNIV_UNLIKELY(index->online_log->head.blocks in row_log_table_apply_ops()
2819 > index->online_log->tail.blocks)) { in row_log_table_apply_ops()
2828 if (index->online_log->head.blocks in row_log_table_apply_ops()
2829 == index->online_log->tail.blocks) { in row_log_table_apply_ops()
2830 if (index->online_log->head.blocks) { in row_log_table_apply_ops()
2833 if (index->online_log->fd > 0 in row_log_table_apply_ops()
2834 && ftruncate(index->online_log->fd, 0) == -1) { in row_log_table_apply_ops()
2843 index->online_log->head.blocks in row_log_table_apply_ops()
2844 = index->online_log->tail.blocks = 0; in row_log_table_apply_ops()
2847 next_mrec = index->online_log->tail.block; in row_log_table_apply_ops()
2848 next_mrec_end = next_mrec + index->online_log->tail.bytes; in row_log_table_apply_ops()
2854 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
2855 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2856 index->online_log->head.bytes = 0; in row_log_table_apply_ops()
2857 index->online_log->tail.bytes = 0; in row_log_table_apply_ops()
2864 ofs = (os_offset_t) index->online_log->head.blocks in row_log_table_apply_ops()
2875 if (!row_log_block_allocate(index->online_log->head)) { in row_log_table_apply_ops()
2881 byte* buf = index->online_log->head.block; in row_log_table_apply_ops()
2884 request, index->online_log->fd, in row_log_table_apply_ops()
2895 index->online_log->crypt_head, ofs)) { in row_log_table_apply_ops()
2901 memcpy(buf, index->online_log->crypt_head, in row_log_table_apply_ops()
2907 posix_fadvise(index->online_log->fd, in row_log_table_apply_ops()
2911 next_mrec = index->online_log->head.block; in row_log_table_apply_ops()
2918 error = index->online_log->error; in row_log_table_apply_ops()
2931 ut_ad(mrec == index->online_log->head.buf); in row_log_table_apply_ops()
2933 ut_ad(mrec_end < (&index->online_log->head.buf)[1]); in row_log_table_apply_ops()
2936 ulint((&index->online_log->head.buf)[1] - mrec_end)); in row_log_table_apply_ops()
2940 index->online_log->head.buf, in row_log_table_apply_ops()
2941 (&index->online_log->head.buf)[1], offsets); in row_log_table_apply_ops()
2953 index->online_log->head.bytes = ulint(mrec - mrec_end); in row_log_table_apply_ops()
2954 next_mrec += index->online_log->head.bytes; in row_log_table_apply_ops()
2963 ut_ad((mrec == NULL) == (index->online_log->head.bytes == 0)); in row_log_table_apply_ops()
2966 if (next_mrec_end == index->online_log->head.block in row_log_table_apply_ops()
2970 if (index->online_log->tail.bytes == 0) { in row_log_table_apply_ops()
2972 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2973 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
2974 ut_ad(index->online_log->head.bytes == 0); in row_log_table_apply_ops()
2976 ut_ad(next_mrec == index->online_log->head.block in row_log_table_apply_ops()
2977 + index->online_log->head.bytes); in row_log_table_apply_ops()
2978 ut_ad(index->online_log->tail.blocks in row_log_table_apply_ops()
2979 > index->online_log->head.blocks); in row_log_table_apply_ops()
2981 } else if (next_mrec_end == index->online_log->tail.block in row_log_table_apply_ops()
2982 + index->online_log->tail.bytes) { in row_log_table_apply_ops()
2983 ut_ad(next_mrec == index->online_log->tail.block in row_log_table_apply_ops()
2984 + index->online_log->head.bytes); in row_log_table_apply_ops()
2985 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
2986 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
2987 ut_ad(index->online_log->head.bytes in row_log_table_apply_ops()
2988 <= index->online_log->tail.bytes); in row_log_table_apply_ops()
3014 ut_ad(mrec >= index->online_log->head.block); in row_log_table_apply_ops()
3015 ut_ad(mrec_end == index->online_log->head.block in row_log_table_apply_ops()
3017 ut_ad(index->online_log->head.bytes in row_log_table_apply_ops()
3027 ut_ad(index->online_log->head.blocks == 0); in row_log_table_apply_ops()
3028 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
3029 ut_ad(mrec_end == index->online_log->tail.block in row_log_table_apply_ops()
3030 + index->online_log->tail.bytes); in row_log_table_apply_ops()
3031 ut_ad(mrec >= index->online_log->tail.block); in row_log_table_apply_ops()
3037 error = index->online_log->error; in row_log_table_apply_ops()
3064 index->online_log->head.bytes = 0; in row_log_table_apply_ops()
3065 index->online_log->head.blocks++; in row_log_table_apply_ops()
3069 index->online_log->head.bytes in row_log_table_apply_ops()
3075 ut_ad(index->online_log->tail.blocks == 0); in row_log_table_apply_ops()
3076 ut_ad(mrec_end == index->online_log->tail.block in row_log_table_apply_ops()
3077 + index->online_log->tail.bytes); in row_log_table_apply_ops()
3081 memcpy(index->online_log->head.buf, mrec, in row_log_table_apply_ops()
3083 mrec_end += ulint(index->online_log->head.buf - mrec); in row_log_table_apply_ops()
3084 mrec = index->online_log->head.buf; in row_log_table_apply_ops()
3098 row_log_block_free(index->online_log->head); in row_log_table_apply_ops()
3132 if (clust_index->online_log->n_rows == 0) { in row_log_table_apply()
3133 clust_index->online_log->n_rows = new_table->stat_n_rows; in row_log_table_apply()
3138 if (!clust_index->online_log) { in row_log_table_apply()
3149 clust_index->online_log->col_map, 0 in row_log_table_apply()
3155 || clust_index->online_log->head.total in row_log_table_apply()
3156 == clust_index->online_log->tail.total); in row_log_table_apply()
3258 index->online_log = log; in row_log_allocate()
3306 && mutex_own(&index->online_log->mutex)) in row_log_get_max_trx()
3309 return(index->online_log->max_trx); in row_log_get_max_trx()
3692 ut_ad(index->online_log); in row_log_apply_ops()
3707 ut_ad(index->online_log->head.bytes == 0); in row_log_apply_ops()
3715 error = index->online_log->error; in row_log_apply_ops()
3725 if (UNIV_UNLIKELY(index->online_log->head.blocks in row_log_apply_ops()
3726 > index->online_log->tail.blocks)) { in row_log_apply_ops()
3735 if (index->online_log->head.blocks in row_log_apply_ops()
3736 == index->online_log->tail.blocks) { in row_log_apply_ops()
3737 if (index->online_log->head.blocks) { in row_log_apply_ops()
3740 if (index->online_log->fd > 0 in row_log_apply_ops()
3741 && ftruncate(index->online_log->fd, 0) == -1) { in row_log_apply_ops()
3750 index->online_log->head.blocks in row_log_apply_ops()
3751 = index->online_log->tail.blocks = 0; in row_log_apply_ops()
3754 next_mrec = index->online_log->tail.block; in row_log_apply_ops()
3755 next_mrec_end = next_mrec + index->online_log->tail.bytes; in row_log_apply_ops()
3761 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3762 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3768 index->online_log->head.blocks) in row_log_apply_ops()
3778 if (!row_log_block_allocate(index->online_log->head)) { in row_log_apply_ops()
3783 byte* buf = index->online_log->head.block; in row_log_apply_ops()
3786 request, index->online_log->fd, in row_log_apply_ops()
3797 index->online_log->crypt_head, ofs)) { in row_log_apply_ops()
3803 memcpy(buf, index->online_log->crypt_head, srv_sort_buf_size); in row_log_apply_ops()
3808 posix_fadvise(index->online_log->fd, in row_log_apply_ops()
3812 next_mrec = index->online_log->head.block; in row_log_apply_ops()
3823 ut_ad(mrec == index->online_log->head.buf); in row_log_apply_ops()
3825 ut_ad(mrec_end < (&index->online_log->head.buf)[1]); in row_log_apply_ops()
3828 ulint((&index->online_log->head.buf)[1] - mrec_end)); in row_log_apply_ops()
3831 has_index_lock, index->online_log->head.buf, in row_log_apply_ops()
3832 (&index->online_log->head.buf)[1], offsets); in row_log_apply_ops()
3844 index->online_log->head.bytes = ulint(mrec - mrec_end); in row_log_apply_ops()
3845 next_mrec += index->online_log->head.bytes; in row_log_apply_ops()
3854 ut_ad((mrec == NULL) == (index->online_log->head.bytes == 0)); in row_log_apply_ops()
3857 if (next_mrec_end == index->online_log->head.block in row_log_apply_ops()
3861 if (index->online_log->tail.bytes == 0) { in row_log_apply_ops()
3863 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3864 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3865 ut_ad(index->online_log->head.bytes == 0); in row_log_apply_ops()
3867 ut_ad(next_mrec == index->online_log->head.block in row_log_apply_ops()
3868 + index->online_log->head.bytes); in row_log_apply_ops()
3869 ut_ad(index->online_log->tail.blocks in row_log_apply_ops()
3870 > index->online_log->head.blocks); in row_log_apply_ops()
3872 } else if (next_mrec_end == index->online_log->tail.block in row_log_apply_ops()
3873 + index->online_log->tail.bytes) { in row_log_apply_ops()
3874 ut_ad(next_mrec == index->online_log->tail.block in row_log_apply_ops()
3875 + index->online_log->head.bytes); in row_log_apply_ops()
3876 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3877 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3878 ut_ad(index->online_log->head.bytes in row_log_apply_ops()
3879 <= index->online_log->tail.bytes); in row_log_apply_ops()
3897 ut_ad(mrec >= index->online_log->head.block); in row_log_apply_ops()
3898 ut_ad(mrec_end == index->online_log->head.block in row_log_apply_ops()
3900 ut_ad(index->online_log->head.bytes in row_log_apply_ops()
3910 ut_ad(index->online_log->head.blocks == 0); in row_log_apply_ops()
3911 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3912 ut_ad(mrec_end == index->online_log->tail.block in row_log_apply_ops()
3913 + index->online_log->tail.bytes); in row_log_apply_ops()
3914 ut_ad(mrec >= index->online_log->tail.block); in row_log_apply_ops()
3937 index->online_log->head.bytes = 0; in row_log_apply_ops()
3938 index->online_log->head.blocks++; in row_log_apply_ops()
3942 index->online_log->head.bytes in row_log_apply_ops()
3948 ut_ad(index->online_log->tail.blocks == 0); in row_log_apply_ops()
3949 ut_ad(mrec_end == index->online_log->tail.block in row_log_apply_ops()
3950 + index->online_log->tail.bytes); in row_log_apply_ops()
3954 memcpy(index->online_log->head.buf, mrec, in row_log_apply_ops()
3956 mrec_end += ulint(index->online_log->head.buf - mrec); in row_log_apply_ops()
3957 mrec = index->online_log->head.buf; in row_log_apply_ops()
3973 if (((os_offset_t) index->online_log->tail.blocks + 1) in row_log_apply_ops()
3988 row_log_block_free(index->online_log->head); in row_log_apply_ops()
4043 log = index->online_log; in row_log_apply()
4044 index->online_log = NULL; in row_log_apply()
4054 ut_ad(index->online_log); in row_log_get_n_core_fields()
4055 return index->online_log->n_core_fields; in row_log_get_n_core_fields()