Lines Matching refs:rep_

481   rep_ = new Rep(ioptions, moptions, sanitized_table_options,  in BlockBasedTableBuilder()
488 if (rep_->filter_builder != nullptr) { in BlockBasedTableBuilder()
489 rep_->filter_builder->StartBlock(0); in BlockBasedTableBuilder()
494 &rep_->compressed_cache_key_prefix[0], in BlockBasedTableBuilder()
495 &rep_->compressed_cache_key_prefix_size); in BlockBasedTableBuilder()
501 assert(rep_->state == Rep::State::kClosed); in ~BlockBasedTableBuilder()
502 delete rep_; in ~BlockBasedTableBuilder()
506 Rep* r = rep_; in Add()
507 assert(rep_->state != Rep::State::kClosed); in Add()
586 Rep* r = rep_; in Flush()
587 assert(rep_->state != Rep::State::kClosed); in Flush()
608 Rep* r = rep_; in WriteBlock()
724 Rep* r = rep_; in WriteRawBlock()
795 Status BlockBasedTableBuilder::status() const { return rep_->status; } in status()
797 IOStatus BlockBasedTableBuilder::io_status() const { return rep_->io_status; } in io_status()
805 Rep* r = rep_; in InsertBlockInCache()
844 bool empty_filter_block = (rep_->filter_builder == nullptr || in WriteFilterBlock()
845 rep_->filter_builder->NumAdded() == 0); in WriteFilterBlock()
850 rep_->filter_builder->Finish(filter_block_handle, &s); in WriteFilterBlock()
852 rep_->props.filter_size += filter_content.size(); in WriteFilterBlock()
860 if (rep_->filter_builder->IsBlockBased()) { in WriteFilterBlock()
863 key = rep_->table_options.partition_filters in WriteFilterBlock()
867 key.append(rep_->table_options.filter_policy->Name()); in WriteFilterBlock()
875 auto index_builder_status = rep_->index_builder->Finish(&index_blocks); in WriteIndexBlock()
882 rep_->status = index_builder_status; in WriteIndexBlock()
895 if (rep_->table_options.enable_index_compression) { in WriteIndexBlock()
905 s = rep_->index_builder->Finish(&index_blocks, *index_block_handle); in WriteIndexBlock()
907 rep_->status = s; in WriteIndexBlock()
910 if (rep_->table_options.enable_index_compression) { in WriteIndexBlock()
925 rep_->props.column_family_id = rep_->column_family_id; in WritePropertiesBlock()
926 rep_->props.column_family_name = rep_->column_family_name; in WritePropertiesBlock()
927 rep_->props.filter_policy_name = in WritePropertiesBlock()
928 rep_->table_options.filter_policy != nullptr in WritePropertiesBlock()
929 ? rep_->table_options.filter_policy->Name() in WritePropertiesBlock()
931 rep_->props.index_size = in WritePropertiesBlock()
932 rep_->index_builder->IndexSize() + kBlockTrailerSize; in WritePropertiesBlock()
933 rep_->props.comparator_name = rep_->ioptions.user_comparator != nullptr in WritePropertiesBlock()
934 ? rep_->ioptions.user_comparator->Name() in WritePropertiesBlock()
936 rep_->props.merge_operator_name = in WritePropertiesBlock()
937 rep_->ioptions.merge_operator != nullptr in WritePropertiesBlock()
938 ? rep_->ioptions.merge_operator->Name() in WritePropertiesBlock()
940 rep_->props.compression_name = in WritePropertiesBlock()
941 CompressionTypeToString(rep_->compression_type); in WritePropertiesBlock()
942 rep_->props.compression_options = in WritePropertiesBlock()
943 CompressionOptionsToString(rep_->compression_opts); in WritePropertiesBlock()
944 rep_->props.prefix_extractor_name = in WritePropertiesBlock()
945 rep_->moptions.prefix_extractor != nullptr in WritePropertiesBlock()
946 ? rep_->moptions.prefix_extractor->Name() in WritePropertiesBlock()
951 i < rep_->ioptions.table_properties_collector_factories.size(); ++i) { in WritePropertiesBlock()
956 rep_->ioptions.table_properties_collector_factories[i]->Name(); in WritePropertiesBlock()
959 rep_->props.property_collectors_names = property_collectors_names; in WritePropertiesBlock()
960 if (rep_->table_options.index_type == in WritePropertiesBlock()
962 assert(rep_->p_index_builder_ != nullptr); in WritePropertiesBlock()
963 rep_->props.index_partitions = rep_->p_index_builder_->NumPartitions(); in WritePropertiesBlock()
964 rep_->props.top_level_index_size = in WritePropertiesBlock()
965 rep_->p_index_builder_->TopLevelIndexSize(rep_->offset); in WritePropertiesBlock()
967 rep_->props.index_key_is_user_key = in WritePropertiesBlock()
968 !rep_->index_builder->seperator_is_key_plus_seq(); in WritePropertiesBlock()
969 rep_->props.index_value_is_delta_encoded = in WritePropertiesBlock()
970 rep_->use_delta_encoding_for_index_values; in WritePropertiesBlock()
971 rep_->props.creation_time = rep_->creation_time; in WritePropertiesBlock()
972 rep_->props.oldest_key_time = rep_->oldest_key_time; in WritePropertiesBlock()
973 rep_->props.file_creation_time = rep_->file_creation_time; in WritePropertiesBlock()
976 property_block_builder.AddTableProperty(rep_->props); in WritePropertiesBlock()
979 NotifyCollectTableCollectorsOnFinish(rep_->table_properties_collectors, in WritePropertiesBlock()
980 rep_->ioptions.info_log, in WritePropertiesBlock()
1005 if (rep_->compression_dict != nullptr && in WriteCompressionDictBlock()
1006 rep_->compression_dict->GetRawDict().size()) { in WriteCompressionDictBlock()
1009 WriteRawBlock(rep_->compression_dict->GetRawDict(), kNoCompression, in WriteCompressionDictBlock()
1012 Slice compression_dict = rep_->compression_dict->GetRawDict(); in WriteCompressionDictBlock()
1027 if (ok() && !rep_->range_del_block.empty()) { in WriteRangeDelBlock()
1029 WriteRawBlock(rep_->range_del_block.Finish(), kNoCompression, in WriteRangeDelBlock()
1037 Rep* r = rep_; in WriteFooter()
1067 Rep* r = rep_; in EnterUnbuffered()
1133 Rep* r = rep_; in Finish()
1175 assert(rep_->state != Rep::State::kClosed); in Abandon()
1176 rep_->state = Rep::State::kClosed; in Abandon()
1180 return rep_->props.num_entries; in NumEntries()
1183 uint64_t BlockBasedTableBuilder::FileSize() const { return rep_->offset; } in FileSize()
1186 for (const auto& collector : rep_->table_properties_collectors) { in NeedCompact()
1195 TableProperties ret = rep_->props; in GetTableProperties()
1196 for (const auto& collector : rep_->table_properties_collectors) { in GetTableProperties()
1206 if (rep_->file != nullptr) { in GetFileChecksum()
1207 return rep_->file->GetFileChecksum(); in GetFileChecksum()
1214 if (rep_->file != nullptr) { in GetFileChecksumFuncName()
1215 return rep_->file->GetFileChecksumFuncName(); in GetFileChecksumFuncName()