| /rocksdb-6.9/trace_replay/ |
| D | block_cache_tracer_test.cc | 59 assert(writer); in WriteBlockAccess()
164 BlockCacheTracer writer; in TEST_F() local
189 BlockCacheTracer writer; in TEST_F() local
215 BlockCacheTracer writer; in TEST_F() local
228 BlockCacheTracer writer; in TEST_F() local
232 writer.EndTrace(); in TEST_F()
255 BlockCacheTracer writer; in TEST_F() local
262 ASSERT_EQ(0, writer.NextGetId()); in TEST_F()
263 ASSERT_EQ(0, writer.NextGetId()); in TEST_F()
267 writer.EndTrace(); in TEST_F()
[all …]
|
| /rocksdb-6.9/db/db_impl/ |
| D | db_impl_write.cc | 272 for (auto* writer : write_group) { in WriteImpl() local
361 writer->sequence, disable_memtable, writer->log_used, index++, in WriteImpl()
369 assert(writer->batch_cnt); in WriteImpl()
709 for (auto* writer : write_group) { in WriteImplWALOnly() local
766 for (auto* writer : write_group) { in WriteImplWALOnly() local
767 if (writer->CallbackFailed()) { in WriteImplWALOnly()
770 writer->sequence = curr_seq; in WriteImplWALOnly()
773 curr_seq += writer->batch_cnt; in WriteImplWALOnly()
775 if (!writer->disable_memtable) { in WriteImplWALOnly()
802 if (!writer->CallbackFailed() && writer->pre_release_callback) { in WriteImplWALOnly()
[all …]
|
| D | db_impl_debug.cc | 27 void* writer = TEST_BeginWrite(); in TEST_SwitchWAL() local
29 TEST_EndWrite(writer); in TEST_SwitchWAL()
36 log::Writer* cur_log_writer = logs_.back().writer; in TEST_WALBufferIsEmpty()
112 void* writer = TEST_BeginWrite(); in TEST_SwitchMemtable() local
121 TEST_EndWrite(writer); in TEST_SwitchMemtable()
189 auto writer = reinterpret_cast<WriteThread::Writer*>(w); in TEST_EndWrite() local
190 write_thread_.ExitUnbatched(writer); in TEST_EndWrite()
191 delete writer; in TEST_EndWrite()
|
| D | db_impl.h | 1215 : number(_number), writer(_writer) {} in LogWriterNumber()
1218 auto* w = writer; in ReleaseWriter()
1219 writer = nullptr; in ReleaseWriter()
1223 Status s = writer->WriteBuffer(); in ClearWriter()
1224 delete writer; in ClearWriter() local
1225 writer = nullptr; in ClearWriter()
1232 log::Writer* writer; // own member
|
| /rocksdb-6.9/java/src/test/java/org/rocksdb/test/ |
| D | RocksJunitRunner.java | 39 private final PrintStream writer; field in RocksJunitRunner.RocksJunitListener
66 public RocksJunitListener(final PrintStream writer) { in RocksJunitListener() argument
67 super(writer); in RocksJunitListener()
68 this.writer = writer; in RocksJunitListener()
73 writer.format("Starting RocksJava Tests...%n"); in testRunStarted()
86 writer.format("%nRunning: %s%n", description.getClassName()); in testStarted()
96 writer.format("Tests run: %d, Failures: %d, Errors: %d, Ignored: %d, Time elapsed: %s sec%n", in printTestsSummary()
137 writer.format("\t%s OK%n",currentMethodName); in testFinished()
139 writer.format(" [%s] %s%n", currentStatus.name(), currentMethodName); in testFinished()
|
| /rocksdb-6.9/db/ |
| D | write_thread.h | 87 Writer* writer; member
91 : writer(w), last_writer(last) {} in Iterator()
93 Writer* operator*() const { return writer; }
96 assert(writer != nullptr);
97 if (writer == last_writer) {
98 writer = nullptr;
100 writer = writer->link_newer;
106 return writer != other.writer;
|
| D | write_callback_test.cc | 211 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F() local
214 ASSERT_TRUE(writer->state == in TEST_F()
217 ASSERT_TRUE(writer->state == in TEST_F()
225 ASSERT_TRUE(writer->callback->Callback(nullptr).ok() == in TEST_F()
228 ASSERT_TRUE(writer->callback->Callback(nullptr).ok() == in TEST_F()
242 auto* writer = reinterpret_cast<WriteThread::Writer*>(arg); in TEST_F() local
246 ASSERT_TRUE(writer->state == in TEST_F()
249 ASSERT_TRUE(writer->state == in TEST_F()
252 writer->state == in TEST_F()
|
| D | c_test.c | 657 rocksdb_sstfilewriter_t* writer = in main() local
661 rocksdb_sstfilewriter_open(writer, sstfilename, &err); in main()
663 rocksdb_sstfilewriter_put(writer, "sstk1", 5, "v1", 2, &err); in main()
665 rocksdb_sstfilewriter_put(writer, "sstk2", 5, "v2", 2, &err); in main()
667 rocksdb_sstfilewriter_put(writer, "sstk3", 5, "v3", 2, &err); in main()
669 rocksdb_sstfilewriter_finish(writer, &err); in main()
682 rocksdb_sstfilewriter_open(writer, sstfilename, &err); in main()
684 rocksdb_sstfilewriter_put(writer, "sstk2", 5, "v4", 2, &err); in main()
688 rocksdb_sstfilewriter_put(writer, "sstk3", 5, "v6", 2, &err); in main()
690 rocksdb_sstfilewriter_finish(writer, &err); in main()
[all …]
|
| D | table_properties_collector_test.cc | 264 std::unique_ptr<WritableFileWriter> writer; in TestCustomizedTablePropertiesCollector() local
276 &int_tbl_prop_collector_factories, &writer, &builder); in TestCustomizedTablePropertiesCollector()
284 writer->Flush(); in TestCustomizedTablePropertiesCollector()
288 static_cast<LegacyWritableFileWrapper*>(writer->writable_file()); in TestCustomizedTablePropertiesCollector()
|
| D | c.cc | 3409 rocksdb_sstfilewriter_t* writer = new rocksdb_sstfilewriter_t; in rocksdb_sstfilewriter_create() local
3410 writer->rep = new SstFileWriter(env->rep, io_options->rep); in rocksdb_sstfilewriter_create()
3411 return writer; in rocksdb_sstfilewriter_create()
3418 writer->rep = new SstFileWriter(env->rep, io_options->rep); in rocksdb_sstfilewriter_create_with_comparator()
3419 return writer; in rocksdb_sstfilewriter_create_with_comparator()
3424 SaveError(errptr, writer->rep->Open(std::string(name))); in rocksdb_sstfilewriter_open()
3449 SaveError(errptr, writer->rep->Delete(Slice(key, keylen))); in rocksdb_sstfilewriter_delete()
3454 SaveError(errptr, writer->rep->Finish(nullptr)); in rocksdb_sstfilewriter_finish()
3459 *file_size = writer->rep->FileSize(); in rocksdb_sstfilewriter_file_size()
3463 delete writer->rep; in rocksdb_sstfilewriter_destroy()
[all …]
|
| D | forward_iterator_bench.cc | 78 Writer* writer; member
218 if ((*shard_states_)[i].writer == this) { in run()
366 shard_states[i].writer = &writers[writer_dist(rng)]; in main()
|
| D | wal_manager_test.cc | 138 log::Writer writer(std::move(file_writer), 1, in TEST_F() local
143 writer.AddRecord(WriteBatchInternal::Contents(&batch)); in TEST_F()
|
| D | write_batch.cc | 2001 WriteThread::Writer* writer, SequenceNumber sequence, in InsertInto() argument
2010 assert(writer->ShouldWriteToMemtable()); in InsertInto()
2016 SetSequence(writer->batch, sequence); in InsertInto()
2017 inserter.set_log_number_ref(writer->log_ref); in InsertInto()
2018 Status s = writer->batch->Iterate(&inserter); in InsertInto()
|
| D | write_batch_internal.h | 183 static Status InsertInto(WriteThread::Writer* writer, SequenceNumber sequence,
|
| /rocksdb-6.9/util/ |
| D | file_reader_writer_test.cc | 79 std::unique_ptr<WritableFileWriter> writer( in TEST_F() local
87 writer->Append(Slice(large_buf.get(), num)); in TEST_F()
91 writer->Flush(); in TEST_F()
94 writer->Close(); in TEST_F()
162 std::unique_ptr<WritableFileWriter> writer( in TEST_F() local
171 writer->Append(Slice(random_string.c_str(), num)); in TEST_F()
176 writer->Flush(); in TEST_F()
179 writer->Flush(); in TEST_F()
180 writer->Close(); in TEST_F()
217 std::unique_ptr<WritableFileWriter> writer( in TEST_F() local
[all …]
|
| D | log_write_bench.cc | 41 std::unique_ptr<WritableFileWriter> writer; in RunBenchmark() local
42 writer.reset(new WritableFileWriter(std::move(file), file_name, env_options, in RunBenchmark()
54 writer->Append(record); in RunBenchmark()
55 writer->Flush(); in RunBenchmark()
57 writer->Sync(false); in RunBenchmark()
|
| D | rate_limiter_test.cc | 75 auto writer = [](void* p) { in TEST_F() local
105 env->StartThread(writer, &arg); in TEST_F()
141 auto writer = [](void* p) { in TEST_F() local
165 env->StartThread(writer, &arg); in TEST_F()
|
| /rocksdb-6.9/table/ |
| D | sst_file_reader_test.cc | 60 SstFileWriter writer(soptions_, options_); in CreateFile() local
61 ASSERT_OK(writer.Open(file_name)); in CreateFile()
63 ASSERT_OK(writer.Put(keys[i], keys[i])); in CreateFile()
64 ASSERT_OK(writer.Merge(keys[i + 1], EncodeAsUint64(i + 1))); in CreateFile()
65 ASSERT_OK(writer.Delete(keys[i + 2])); in CreateFile()
67 ASSERT_OK(writer.Finish()); in CreateFile()
|
| /rocksdb-6.9/tools/block_cache_analyzer/ |
| D | block_cache_trace_analyzer_test.cc | 95 void WriteBlockAccess(BlockCacheTraceWriter* writer, uint32_t from_key_id, in WriteBlockAccess() argument
97 assert(writer); in WriteBlockAccess()
124 ASSERT_OK(writer->WriteBlockAccess( in WriteBlockAccess()
228 BlockCacheTraceWriter writer(env_, trace_opt, std::move(trace_writer)); in TEST_F() local
229 ASSERT_OK(writer.WriteHeader()); in TEST_F()
230 WriteBlockAccess(&writer, 0, TraceType::kBlockTraceDataBlock, 50); in TEST_F()
615 BlockCacheTraceWriter writer(env_, trace_opt, std::move(trace_writer)); in TEST_F() local
616 ASSERT_OK(writer.WriteHeader()); in TEST_F()
620 WriteBlockAccess(&writer, 10, TraceType::kBlockTraceDataBlock, 10); in TEST_F()
621 WriteBlockAccess(&writer, 20, TraceType::kBlockTraceFilterBlock, 10); in TEST_F()
[all …]
|
| /rocksdb-6.9/java/rocksjni/ |
| D | sst_file_writerjni.cc | 157 auto *writer = in Java_org_rocksdb_SstFileWriter_putDirect() local
159 auto put = [&env, &writer](ROCKSDB_NAMESPACE::Slice &key, in Java_org_rocksdb_SstFileWriter_putDirect()
161 ROCKSDB_NAMESPACE::Status s = writer->Put(key, value); in Java_org_rocksdb_SstFileWriter_putDirect()
178 auto *writer = in Java_org_rocksdb_SstFileWriter_fileSize() local
180 return static_cast<jlong>(writer->FileSize()); in Java_org_rocksdb_SstFileWriter_fileSize()
|
| /rocksdb-6.9/utilities/blob_db/ |
| D | blob_db_impl.cc | 769 std::shared_ptr<Writer>* writer) { in CheckOrCreateWriterLocked() argument
770 assert(writer != nullptr); in CheckOrCreateWriterLocked()
771 *writer = blob_file->GetWriter(); in CheckOrCreateWriterLocked()
772 if (*writer != nullptr) { in CheckOrCreateWriterLocked()
777 *writer = blob_file->GetWriter(); in CheckOrCreateWriterLocked()
785 std::shared_ptr<Writer>* writer) { in CreateBlobFileAndWriter() argument
788 assert(writer); in CreateBlobFileAndWriter()
802 assert(*writer); in CreateBlobFileAndWriter()
841 std::shared_ptr<Writer> writer; in SelectBlobFile() local
887 std::shared_ptr<Writer> writer; in SelectBlobFileTTL() local
[all …]
|
| D | blob_db_impl.h | 266 std::shared_ptr<Writer>* writer);
374 std::shared_ptr<Writer>* writer);
|
| /rocksdb-6.9/utilities/persistent_cache/ |
| D | block_cache_tier_file.h | 181 Writer* writer, const std::string& dir, in WriteableCacheFile() argument
186 writer_(writer), in WriteableCacheFile()
|
| /rocksdb-6.9/include/rocksdb/ |
| D | c.h | 1369 rocksdb_sstfilewriter_t* writer, const char* name, char** errptr);
1371 rocksdb_sstfilewriter_t* writer, const char* key, size_t keylen,
1374 rocksdb_sstfilewriter_t* writer, const char* key, size_t keylen,
1377 rocksdb_sstfilewriter_t* writer, const char* key, size_t keylen,
1380 rocksdb_sstfilewriter_t* writer, const char* key, size_t keylen,
1383 rocksdb_sstfilewriter_t* writer, char** errptr);
1385 rocksdb_sstfilewriter_t* writer, uint64_t* file_size);
1387 rocksdb_sstfilewriter_t* writer);
|
| /rocksdb-6.9/test_util/ |
| D | testutil.h | 383 const WritableFileWriter* writer) { in GetStringSinkFromLegacyWriter() argument
385 static_cast<LegacyWritableFileWrapper*>(writer->writable_file()); in GetStringSinkFromLegacyWriter()
|