Home
last modified time | relevance | path

Searched refs:e (Results 1 – 25 of 68) sorted by relevance

123

/rocksdb-6.9/cache/
Dlru_cache.cc184 e->next->prev = e->prev; in LRU_Remove()
185 e->prev->next = e->next; in LRU_Remove()
186 e->prev = e->next = nullptr; in LRU_Remove()
204 e->prev->next = e; in LRU_Insert()
205 e->next->prev = e; in LRU_Insert()
214 e->prev->next = e; in LRU_Insert()
215 e->next->prev = e; in LRU_Insert()
280 e->Ref(); in Lookup()
291 e->Ref(); in Ref()
317 table_.Remove(e->key(), e->hash); in Release()
[all …]
/rocksdb-6.9/java/src/test/java/org/rocksdb/
DRocksDBExceptionTest.java21 } catch(final RocksDBException e) { in exception()
22 assertThat(e.getStatus()).isNull(); in exception()
33 } catch(final RocksDBException e) { in exceptionWithStatusCode()
34 assertThat(e.getStatus()).isNotNull(); in exceptionWithStatusCode()
48 } catch(final RocksDBException e) { in exceptionNoMsgWithStatusCode()
49 assertThat(e.getStatus()).isNotNull(); in exceptionNoMsgWithStatusCode()
63 } catch(final RocksDBException e) { in exceptionWithStatusCodeSubCode()
64 assertThat(e.getStatus()).isNotNull(); in exceptionWithStatusCodeSubCode()
66 assertThat(e.getStatus().getSubCode()) in exceptionWithStatusCodeSubCode()
79 } catch(final RocksDBException e) { in exceptionNoMsgWithStatusCodeSubCode()
[all …]
DOptimisticTransactionTest.java46 } catch(final RocksDBException e) { in getForUpdate_cf_conflict()
47 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.Busy); in getForUpdate_cf_conflict()
83 } catch(final RocksDBException e) { in getForUpdate_conflict()
84 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.Busy); in getForUpdate_conflict()
130 } catch(final RocksDBException e) { in multiGetForUpdate_cf_conflict()
131 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.Busy); in multiGetForUpdate_cf_conflict()
174 } catch(final RocksDBException e) { in multiGetForUpdate_conflict()
175 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.Busy); in multiGetForUpdate_conflict()
264 } catch(final RocksDBException e) { in name()
293 } catch(final RocksDBException e) { in startDb()
[all …]
DTransactionTest.java42 } catch(final RocksDBException e) { in getForUpdate_cf_conflict()
43 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.TimedOut); in getForUpdate_cf_conflict()
75 } catch(final RocksDBException e) { in getForUpdate_conflict()
76 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.TimedOut); in getForUpdate_conflict()
117 } catch(final RocksDBException e) { in multiGetForUpdate_cf_conflict()
118 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.TimedOut); in multiGetForUpdate_cf_conflict()
156 } catch(final RocksDBException e) { in multiGetForUpdate_conflict()
157 assertThat(e.getStatus().getCode()).isSameAs(Status.Code.TimedOut); in multiGetForUpdate_conflict()
252 } catch(final RocksDBException e) { in startDb()
256 throw e; in startDb()
DWriteBatchThreadedTest.java91 } catch (final ExecutionException e) { in threadedWrites()
96 throw e; in threadedWrites()
/rocksdb-6.9/db/
Ddb_iter_stress_test.cc53 if (key != e.key) return key < e.key; in operator <()
54 return std::tie(sequence, type) > std::tie(e.sequence, e.type); in operator <()
135 if (e.visible) { in MaybeMutate()
157 e.visible = true; in MaybeMutate()
201 [&](const Entry& e) { return cmp.Compare(e.ikey, target) < 0; }); in Seek() argument
213 [&](const Entry& e) { return cmp.Compare(e.ikey, target) <= 0; }); in SeekForPrev() argument
313 Entry& e = *it; in FindValueForCurrentKey() local
323 value = e.value; in FindValueForCurrentKey()
334 Entry& e = *it; in FindValueForCurrentKey() local
471 ParsedInternalKey internal_key(e.key, e.sequence, e.type); in TEST_F()
[all …]
/rocksdb-6.9/build_tools/
Drun_ci_db_test.ps1260 ForEach($e in $DiscoveredExe) { variable
261 $e = $e -replace '.exe$', '' variable
262 $bare_name = $e -replace '_je$', ''
265 Write-Warning "Test $e is excluded" variable
301 ForEach($e in $ListOfExe) { variable
303 $e = $e -replace '.exe$', '' variable
304 $bare_name = $e -replace '_je$', ''
307 Write-Warning "Test $e is excluded" variable
368 $exe_name = $e in RunJobs()
369 $Cases = $Suites[$e] in RunJobs()
[all …]
/rocksdb-6.9/java/rocksjni/
Denv.cc37 auto* e = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_RocksEnv_disposeInternal() local
38 assert(e != nullptr); in Java_org_rocksdb_RocksEnv_disposeInternal()
39 delete e; in Java_org_rocksdb_RocksEnv_disposeInternal()
174 auto* e = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_RocksMemEnv_disposeInternal() local
175 assert(e != nullptr); in Java_org_rocksdb_RocksMemEnv_disposeInternal()
176 delete e; in Java_org_rocksdb_RocksMemEnv_disposeInternal()
211 auto* e = reinterpret_cast<ROCKSDB_NAMESPACE::Env*>(jhandle); in Java_org_rocksdb_HdfsEnv_disposeInternal() local
212 assert(e != nullptr); in Java_org_rocksdb_HdfsEnv_disposeInternal()
213 delete e; in Java_org_rocksdb_HdfsEnv_disposeInternal()
235 assert(e != nullptr); in Java_org_rocksdb_TimedEnv_disposeInternal()
[all …]
/rocksdb-6.9/utilities/write_batch_with_index/
Dwrite_batch_with_index_test.cc50 Entry e; in PutCF() local
53 e.type = kPutRecord; in PutCF()
59 Entry e; in MergeCF() local
68 Entry e; in DeleteCF() local
70 e.value = ""; in DeleteCF()
91 data_map[e.key].push_back(&e); in TestValueAsSecondaryIndexHelper()
92 index_map[e.value].push_back(&e); in TestValueAsSecondaryIndexHelper()
99 batch->Put(&data, e.key, e.value); in TestValueAsSecondaryIndexHelper()
100 batch->Put(&index, e.value, e.key); in TestValueAsSecondaryIndexHelper()
102 batch->Merge(&data, e.key, e.value); in TestValueAsSecondaryIndexHelper()
[all …]
/rocksdb-6.9/java/samples/src/main/java/
DRocksDBSample.java39 } catch (final RocksDBException e) { in main()
40 System.out.format("Caught the expected exception -- %s\n", e); in main()
51 } catch (final IllegalArgumentException e) { in main()
120 } catch (final RocksDBException e) { in main()
121 System.out.format("[ERROR] caught the unexpected exception -- %s\n", e); in main()
228 } catch (final Exception e) { in main()
240 } catch (final Exception e) { in main()
298 } catch (final RocksDBException e) { in main()
299 System.err.println(e); in main()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DAbstractTraceWriter.java32 } catch (final RocksDBException e) { in writeProxy()
33 return statusToShort(e.getStatus()); in writeProxy()
48 } catch (final RocksDBException e) { in closeWriterProxy()
49 return statusToShort(e.getStatus()); in closeWriterProxy()
DColumnFamilyHandle.java82 } catch (RocksDBException e) { in equals()
83 throw new RuntimeException("Cannot compare column family handles", e); in equals()
91 } catch (RocksDBException e) { in hashCode()
92 throw new RuntimeException("Cannot calculate hash code of column family handle", e); in hashCode()
DStatisticsCollector.java100 catch (final InterruptedException e) { in collectStatistics()
104 catch (final Exception e) { in collectStatistics()
105 throw new RuntimeException("Error while calculating statistics", e); in collectStatistics()
/rocksdb-6.9/third-party/folly/folly/
DConstexprMath.h20 constexpr T constexpr_log2_(T a, T e) { in constexpr_log2_() argument
21 return e == T(1) ? a : constexpr_log2_(a + T(1), e / T(2)); in constexpr_log2_()
/rocksdb-6.9/tools/advisor/advisor/
Ddb_timeseries_parser.py181 except Exception as e:
183 'WARNING(TimeSeriesData) check_and_trigger: ' + str(e)
202 except Exception as e:
205 str(e)
Ddb_options_parser.py323 except Exception as e:
325 'WARNING(DatabaseOptions) check_and_trigger:' + str(e)
346 except Exception as e:
349 str(e)
Ddb_bench_runner.py168 except OSError as e:
169 print('Error: rmdir ' + e.filename + ' ' + e.strerror)
/rocksdb-6.9/file/
Drandom_access_file_reader.h79 [this](const std::shared_ptr<EventListener>& e) { in file_()
80 if (e->ShouldBeNotifiedOnFileIO()) { in file_()
81 listeners_.emplace_back(e); in file_()
Dwritable_file_writer.h108 [this](const std::shared_ptr<EventListener>& e) { in writable_file_()
109 if (e->ShouldBeNotifiedOnFileIO()) { in writable_file_()
110 listeners_.emplace_back(e); in writable_file_()
/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DEnvironmentTest.java239 } catch (final NoSuchFieldException | IllegalAccessException e) { in getEnvironmentClassField()
240 throw new RuntimeException(e); in getEnvironmentClassField()
255 } catch (final NoSuchFieldException | IllegalAccessException e) { in setEnvironmentClassField()
256 throw new RuntimeException(e); in setEnvironmentClassField()
/rocksdb-6.9/util/
Dthread_local.cc19 Entry(const Entry& e) : ptr(e.ptr.load(std::memory_order_relaxed)) {} in Entry()
294 for (auto& e : tls->entries) { in OnThreadExit() local
295 void* raw = e.ptr.load(); in OnThreadExit()
Dcrc32c.cc363 const uint8_t *e = p + size; in ExtendImpl() local
379 if (x <= e) { in ExtendImpl()
386 while ((e-p) >= 16) { in ExtendImpl()
391 while ((e-p) >= 8) { in ExtendImpl()
395 while (p != e) { in ExtendImpl()
/rocksdb-6.9/utilities/
Dobject_registry.cc40 for (const auto &e : iter.second) { in Dump() local
42 e->Name().c_str()); in Dump()
/rocksdb-6.9/docs/
DREADME.md15 1. Ensure that you are in the `/docs` directory in your local RocksDB clone (i.e., the same directo…
44 …- On first runs or for structural changes to the documentation (e.g., new sidebar menu item), do a…
66 …e.g., on a Mac, you can your IP address with something like `ifconfig | grep "inet " | grep -v 127…
/rocksdb-6.9/tools/rdb/
DREADME.md10 * static RocksDB library (i.e. librocksdb.a)
21 1. Make sure you have the static library (i.e. "librocksdb.a") in the root

123