| /leveldb-1.20/db/ |
| H A D | write_batch_test.cc | 19 std::string state; in PrintContents() local
28 state.append("Put("); in PrintContents()
29 state.append(ikey.user_key.ToString()); in PrintContents()
30 state.append(", "); in PrintContents()
32 state.append(")"); in PrintContents()
36 state.append("Delete("); in PrintContents()
38 state.append(")"); in PrintContents()
42 state.append("@"); in PrintContents()
47 state.append("ParseError()"); in PrintContents()
49 state.append("CountMismatch()"); in PrintContents()
[all …]
|
| H A D | skiplist_test.cc | 337 TestState* state = reinterpret_cast<TestState*>(arg); in ConcurrentReader() local
338 Random rnd(state->seed_); in ConcurrentReader()
340 state->Change(TestState::RUNNING); in ConcurrentReader()
341 while (!state->quit_flag_.Acquire_Load()) { in ConcurrentReader()
342 state->t_.ReadStep(&rnd); in ConcurrentReader()
345 state->Change(TestState::DONE); in ConcurrentReader()
357 TestState state(seed + 1); in RunConcurrent() local
359 state.Wait(TestState::RUNNING); in RunConcurrent()
361 state.t_.WriteStep(&rnd); in RunConcurrent()
363 state.quit_flag_.Release_Store(&state); // Any non-NULL arg will do in RunConcurrent()
[all …]
|
| H A D | fault_injection_test.cc | 109 TestWritableFile(const FileState& state,
162 : state_(state), in TestWritableFile()
232 FileState state(fname); in NewWritableFile() local
233 state.pos_ = 0; in NewWritableFile()
250 FileState state(fname); in NewAppendableFile() local
251 state.pos_ = 0; in NewAppendableFile()
257 state = db_file_state_[fname]; in NewAppendableFile()
271 const FileState& state = it->second; in DropUnsyncedFileData() local
272 if (!state.IsFullySynced()) { in DropUnsyncedFileData()
273 s = state.DropUnsyncedData(); in DropUnsyncedFileData()
[all …]
|
| H A D | c_test.c | 92 int* state = (int*) ptr; in CheckPut() local
93 CheckCondition(*state < 2); in CheckPut()
94 switch (*state) { in CheckPut()
104 (*state)++; in CheckPut()
109 int* state = (int*) ptr; in CheckDel() local
110 CheckCondition(*state == 2); in CheckDel()
112 (*state)++; in CheckDel()
|
| H A D | version_set.cc | 262 SaverState state; member
272 s->state = kCorrupt; in SaveValue()
276 if (s->state == kFound) { in SaveValue()
404 saver.state = kNotFound; in Get()
413 switch (saver.state) { in Get()
456 state->matches++; in RecordReadSample()
457 if (state->matches == 1) { in RecordReadSample()
463 return state->matches < 2; in RecordReadSample()
467 State state; in RecordReadSample() local
468 state.matches = 0; in RecordReadSample()
[all …]
|
| H A D | c.cc | 364 void* state, in leveldb_writebatch_iterate() argument
380 handler.state_ = state; in leveldb_writebatch_iterate()
454 void* state, in leveldb_comparator_create() argument
462 result->state_ = state; in leveldb_comparator_create()
474 void* state, in leveldb_filterpolicy_create() argument
487 result->state_ = state; in leveldb_filterpolicy_create()
|
| H A D | db_impl.cc | 1057 IterState* state = reinterpret_cast<IterState*>(arg1); in CleanupIteratorState() local
1058 state->mu->Lock(); in CleanupIteratorState()
1059 state->mem->Unref(); in CleanupIteratorState()
1060 if (state->imm != NULL) state->imm->Unref(); in CleanupIteratorState()
1061 state->version->Unref(); in CleanupIteratorState()
1062 state->mu->Unlock(); in CleanupIteratorState()
1063 delete state; in CleanupIteratorState()
|
| H A D | db_test.cc | 1773 MTState* state; member
1780 DB* db = t->state->test->db_; in MTThreadBody()
1786 while (t->state->stop.Acquire_Load() == NULL) { in MTThreadBody()
1787 t->state->counter[id].Release_Store(reinterpret_cast<void*>(counter)); in MTThreadBody()
1813 t->state->counter[w].Acquire_Load())); in MTThreadBody()
1818 t->state->thread_done[id].Release_Store(t); in MTThreadBody()
1838 thread[id].state = &mt; in TEST()
|
| /leveldb-1.20/util/ |
| H A D | env_test.cc | 84 State state; in TEST() local
85 state.val = 0; in TEST()
86 state.num_running = 3; in TEST()
88 env_->StartThread(&ThreadBody, &state); in TEST()
91 state.mu.Lock(); in TEST()
92 int num = state.num_running; in TEST()
93 state.mu.Unlock(); in TEST()
99 ASSERT_EQ(state.val, 3); in TEST()
|
| H A D | status.cc | 11 const char* Status::CopyState(const char* state) { in CopyState() argument
13 memcpy(&size, state, sizeof(size)); in CopyState()
15 memcpy(result, state, size + 5); in CopyState()
|
| H A D | env_posix.cc | 659 StartThreadState* state = reinterpret_cast<StartThreadState*>(arg); in StartThreadWrapper() local
660 state->user_function(state->arg); in StartThreadWrapper()
661 delete state; in StartThreadWrapper()
667 StartThreadState* state = new StartThreadState; in StartThread() local
668 state->user_function = function; in StartThread()
669 state->arg = arg; in StartThread()
671 pthread_create(&t, NULL, &StartThreadWrapper, state)); in StartThread()
|
| /leveldb-1.20/include/leveldb/ |
| H A D | c.h | 175 void* state,
212 void* state,
224 void* state,
|
| /leveldb-1.20/doc/bench/ |
| H A D | db_bench_tree_db.cc | 424 void Write(bool sync, Order order, DBState state, in Write() argument
427 if (state == FRESH) { in Write()
|
| H A D | db_bench_sqlite3.cc | 478 void Write(bool write_sync, Order order, DBState state, in Write() argument
481 if (state == FRESH) { in Write()
|
| /leveldb-1.20/doc/ |
| H A D | index.md | 180 Snapshots provide consistent read-only views over the entire state of the
182 read should operate on a particular version of the DB state. If
184 of the current state.
193 ... read using iter to view the state when the snapshot was created ...
200 state that was being maintained just to support reading as of that snapshot.
|
| H A D | impl.md | 50 serving state (as files are added or removed) are appended to this log.
94 The old files are discarded and the new files are added to the serving state.
|