Home
last modified time | relevance | path

Searched refs:Append (Results 1 – 25 of 71) sorted by relevance

123

/rocksdb-6.9/utilities/merge_operators/string_append/
Dstringappend_test.cc136 slists.Append("k1", "v1"); in TEST_F()
137 slists.Append("k1", "v2"); in TEST_F()
138 slists.Append("k1", "v3"); in TEST_F()
140 slists.Append("k2", "a1"); in TEST_F()
141 slists.Append("k2", "a2"); in TEST_F()
142 slists.Append("k2", "a3"); in TEST_F()
270 slists.Append("a", "x"); in TEST_F()
271 slists.Append("b", "y"); in TEST_F()
272 slists.Append("a", "t"); in TEST_F()
273 slists.Append("a", "r"); in TEST_F()
[all …]
/rocksdb-6.9/table/block_based/
Dblock_based_table_reader.cc3043 out_file->Append( in DumpTable()
3048 out_file->Append("\n"); in DumpTable()
3051 out_file->Append( in DumpTable()
3095 out_file->Append( in DumpTable()
3104 out_file->Append( in DumpTable()
3132 out_file->Append( in DumpTable()
3148 out_file->Append( in DumpTable()
3166 out_file->Append( in DumpIndexBlock()
3216 out_file->Append("\n"); in DumpIndexBlock()
3308 out_file->Append(": "); in DumpKeyValue()
[all …]
/rocksdb-6.9/utilities/cassandra/
Dcassandra_functional_test.cc145 store.Append("k1", CreateTestRowValue({ in TEST_F()
150 store.Append("k1",CreateTestRowValue({ in TEST_F()
156 store.Append("k1", CreateTestRowValue({ in TEST_F()
180 store.Append("k1", CreateTestRowValue({ in TEST_F()
188 store.Append("k1",CreateTestRowValue({ in TEST_F()
213 store.Append("k1", CreateTestRowValue({ in TEST_F()
221 store.Append("k1",CreateTestRowValue({ in TEST_F()
244 store.Append("k1", CreateTestRowValue({ in TEST_F()
251 store.Append("k1",CreateTestRowValue({ in TEST_F()
266 store.Append("k1", CreateTestRowValue({ in TEST_F()
[all …]
/rocksdb-6.9/tools/dump/
Ddb_dump_tool.cc54 status = dumpfile->Append(magicslice); in Run()
61 status = dumpfile->Append(versionslice); in Run()
83 status = dumpfile->Append(infosizeslice); in Run()
88 status = dumpfile->Append(infoslice); in Run()
100 status = dumpfile->Append(keysizeslice); in Run()
105 status = dumpfile->Append(it->key()); in Run()
114 status = dumpfile->Append(valsizeslice); in Run()
119 status = dumpfile->Append(it->value()); in Run()
/rocksdb-6.9/utilities/blob_db/
Dblob_log_writer.cc48 Status s = dest_->Append(Slice(str)); in WriteHeader()
66 Status s = dest_->Append(Slice(str)); in AppendFooter()
117 Status s = dest_->Append(Slice(headerbuf)); in EmitPhysicalRecord()
119 s = dest_->Append(key); in EmitPhysicalRecord()
122 s = dest_->Append(val); in EmitPhysicalRecord()
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier_file.cc103 bool Append(std::vector<CacheWriteBuffer*>* bufs, size_t* woff,
128 return Append(bufs, woff, reinterpret_cast<const char*>(&hdr_), in Serialize()
130 Append(bufs, woff, reinterpret_cast<const char*>(key_.data()), in Serialize()
132 Append(bufs, woff, reinterpret_cast<const char*>(val_.data()), in Serialize()
136 bool CacheRecord::Append(std::vector<CacheWriteBuffer*>* bufs, size_t* woff, in Append() function in ROCKSDB_NAMESPACE::CacheRecord
147 buf->Append(p, size); in Append()
150 buf->Append(p, free); in Append()
317 bool WriteableCacheFile::Append(const Slice& key, const Slice& val, LBA* lba) { in Append() function in ROCKSDB_NAMESPACE::WriteableCacheFile
594 Status s = io.file_->Append(data); in DispatchIO()
Dblock_cache_tier_file.h107 virtual bool Append(const Slice& /*key*/, const Slice& /*val*/, in Append() function
207 bool Append(const Slice&, const Slice&, LBA* const) override;
/rocksdb-6.9/util/
Dfile_reader_writer_test.cc29 Status Append(const Slice& data) override { in TEST_F() function in ROCKSDB_NAMESPACE::TEST_F::FakeWF
87 writer->Append(Slice(large_buf.get(), num)); in TEST_F()
107 Status Append(const Slice& data) override { in TEST_F() function in ROCKSDB_NAMESPACE::TEST_F::FakeWF
171 writer->Append(Slice(random_string.c_str(), num)); in TEST_F()
193 Status Append(const Slice& /*data*/) override { in TEST_F() function in ROCKSDB_NAMESPACE::TEST_F::FakeWF
221 ASSERT_OK(writer->Append(std::string(2 * kMb, 'a'))); in TEST_F()
227 ASSERT_NOK(writer->Append(std::string(2 * kMb, 'b'))); in TEST_F()
253 write_holder->Append(Slice(str)); in ResetSourceStr()
/rocksdb-6.9/utilities/
Denv_mirror_test.cc69 ASSERT_OK(writable_file->Append("abc")); in TEST_F()
123 ASSERT_OK(writable_file->Append("hello ")); in TEST_F()
124 ASSERT_OK(writable_file->Append("world")); in TEST_F()
187 ASSERT_OK(writable_file->Append("foo")); in TEST_F()
188 ASSERT_OK(writable_file->Append(write_data)); in TEST_F()
Denv_librados_test.cc136 ASSERT_OK(writable_file->Append("abc")); in TEST_F()
182 ASSERT_OK(writable_file->Append("hello ")); in TEST_F()
183 ASSERT_OK(writable_file->Append("world")); in TEST_F()
256 ASSERT_OK(writable_file->Append("foo")); in TEST_F()
257 ASSERT_OK(writable_file->Append(write_data)); in TEST_F()
289 ASSERT_OK(writable_file->Append("foo")); in TEST_F()
292 ASSERT_OK(writable_file->Append("h")); in TEST_F()
324 ASSERT_OK(writable_file->Append(write_data)); in TEST_F()
835 ASSERT_OK(writable_file->Append("abc")); in TEST_F()
Denv_mirror.cc104 Status Append(const Slice& data) override { in Append() function in ROCKSDB_NAMESPACE::WritableFileMirror
105 Status as = a_->Append(data); in Append()
106 Status bs = b_->Append(data); in Append()
/rocksdb-6.9/table/cuckoo/
Dcuckoo_table_builder.cc304 io_status_ = file_->Append(Slice(unused_bucket)); in Finish()
307 io_status_ = file_->Append(GetKey(bucket.vector_idx)); in Finish()
310 io_status_ = file_->Append(GetValue(bucket.vector_idx)); in Finish()
368 io_status_ = file_->Append(property_block); in Finish()
381 io_status_ = file_->Append(meta_index_block); in Finish()
392 io_status_ = file_->Append(footer_encoding); in Finish()
/rocksdb-6.9/db/
Dlog_writer.cc73 s = dest_->Append(Slice("\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00", in AddRecord()
153 IOStatus s = dest_->Append(Slice(buf, header_size)); in EmitPhysicalRecord()
155 s = dest_->Append(Slice(ptr, n)); in EmitPhysicalRecord()
Dwrite_batch_test.cc170 TEST_F(WriteBatchTest, Append) { in TEST_F() argument
174 WriteBatchInternal::Append(&b1, &b2); in TEST_F()
179 WriteBatchInternal::Append(&b1, &b2); in TEST_F()
185 WriteBatchInternal::Append(&b1, &b2); in TEST_F()
191 WriteBatchInternal::Append(&b1, &b2); in TEST_F()
203 WriteBatchInternal::Append(&b1, &b2, /*wal only*/ true); in TEST_F()
Ddb_test_util.h222 Status Append(const Slice& data) override { in NewWritableFile()
233 return base_->Append(data); in NewWritableFile()
302 Status Append(const Slice& data) override { in NewWritableFile()
306 return base_->Append(data); in NewWritableFile()
336 Status Append(const Slice& data) override { in NewWritableFile()
349 s = base_->Append(data); in NewWritableFile()
/rocksdb-6.9/table/plain/
Dplain_table_builder.cc43 IOStatus io_s = file->Append(block_contents); in WriteBlock()
161 io_status_ = file_->Append(Slice(meta_bytes_buf, meta_bytes_buf_size)); in Add()
166 io_status_ = file_->Append(value); in Add()
284 io_status_ = file_->Append(footer_encoding); in Finish()
Dplain_table_key_coding.cc102 IOStatus io_s = file->Append(Slice(key_size_buf, len)); in AppendKey()
120 IOStatus io_s = file->Append(Slice(size_bytes, size_bytes_pos)); in AppendKey()
138 IOStatus io_s = file->Append(Slice(size_bytes, size_bytes_pos)); in AppendKey()
153 file->Append(Slice(key_to_write.data(), key_to_write.size() - 8)); in AppendKey()
161 IOStatus io_s = file->Append(key_to_write); in AppendKey()
/rocksdb-6.9/options/
Doptions_parser.cc59 writable->Append(option_file_header + "[" + in PersistRocksDBOptions()
65 writable->Append(" options_file_version=" + in PersistRocksDBOptions()
68 writable->Append("\n[" + opt_section_titles[kOptionSectionDBOptions] + in PersistRocksDBOptions()
76 writable->Append(options_file_content + "\n"); in PersistRocksDBOptions()
80 writable->Append("\n[" + opt_section_titles[kOptionSectionCFOptions] + in PersistRocksDBOptions()
88 writable->Append(options_file_content + "\n"); in PersistRocksDBOptions()
92 writable->Append("[" + opt_section_titles[kOptionSectionTableOptions] + in PersistRocksDBOptions()
100 writable->Append(options_file_content + "\n"); in PersistRocksDBOptions()
/rocksdb-6.9/env/
Denv_basic_test.cc160 ASSERT_OK(writable_file->Append("abc")); in TEST_P()
216 ASSERT_OK(writable_file->Append("hello ")); in TEST_P()
217 ASSERT_OK(writable_file->Append("world")); in TEST_P()
269 ASSERT_OK(writable_file->Append("foo")); in TEST_P()
270 ASSERT_OK(writable_file->Append(write_data)); in TEST_P()
Dmock_env_test.cc34 ASSERT_OK(writable_file->Append(kGood)); in TEST_F()
53 ASSERT_OK(writable_file->Append(kCorrupted)); in TEST_F()
Denv_test.cc157 same_file->Append("random_data"); in TEST_F()
218 ASSERT_OK(wfile->Append(expected_data)); in TEST_F()
984 ASSERT_OK(wfile->Append(data)); in TEST_P()
1133 ASSERT_OK(wfile->Append(slice)); in TEST_P()
1201 ASSERT_OK(wfile->Append(expected_data)); in TEST_F()
1302 ASSERT_OK(wfile->Append(slice)); in TEST_P()
1496 srcfile->Append(str); in TEST_P()
1505 srcfile->Append(buf); in TEST_P()
1515 srcfile->Append(buf); in TEST_P()
1547 file->Append(buf); in TEST_P()
[all …]
Denv_encryption.cc198 Status Append(const Slice& data) override { in Append() function in ROCKSDB_NAMESPACE::EncryptedWritableFile
217 status = file_->Append(dataToAppend); in Append()
484 status = underlying->Append(prefixSlice); in NewWritableFile()
531 status = underlying->Append(prefixSlice); in ReopenWritableFile()
573 status = underlying->Append(prefixSlice); in ReuseWritableFile()
/rocksdb-6.9/tools/
Dtrace_analyzer_tool.cc608 s = stat.second.a_key_size_f->Append(printout); in MakeStatistics()
689 s = stats.a_key_f->Append(printout); in MakeStatisticKeyStatsOrPrefix()
720 s = stats.a_prefix_cut_f->Append(pout); in MakeStatisticKeyStatsOrPrefix()
824 s = stat.second.a_qps_f->Append(printout); in MakeStatisticQPS()
836 s = stat.second.a_qps_f->Append(printout); in MakeStatisticQPS()
886 s = stat.second.a_key_num_f->Append(printout); in MakeStatisticQPS()
948 s = qps_f_->Append(printout); in MakeStatisticQPS()
979 s = cf_qps_f_->Append(printout); in MakeStatisticQPS()
1036 s = stat.time_series_f->Append(printout); in ReProcessing()
1093 s = stat.w_key_f->Append(printout); in ReProcessing()
[all …]
/rocksdb-6.9/file/
Dfile_util.cc62 s = dest_writer->Append(slice); in CopyFile()
85 s = dest_writer->Append(Slice(contents)); in CreateFile()
Dwritable_file_writer.cc24 IOStatus WritableFileWriter::Append(const Slice& data) { in Append() function in ROCKSDB_NAMESPACE::WritableFileWriter
72 size_t appended = buf_.Append(src, left); in Append()
323 s = writable_file_->Append(Slice(src, allowed), IOOptions(), nullptr); in WriteBuffered()

123