Home
last modified time | relevance | path

Searched refs:id (Results 1 – 25 of 69) sorted by relevance

123

/rocksdb-6.9/util/
Dthread_local.cc62 void ReclaimId(uint32_t id);
65 void* Get(uint32_t id) const;
293 uint32_t id = 0; in OnThreadExit() local
302 ++id; in OnThreadExit()
412 tls->entries.resize(id + 1); in Reset()
422 tls->entries.resize(id + 1); in Swap()
433 tls->entries.resize(id + 1); in CompareAndSwap()
471 handler_map_[id] = handler; in SetHandler()
491 return id; in GetId()
506 auto unref = GetHandler(id); in ReclaimId()
[all …]
Dtimer_queue.h83 uint64_t id = ++m_idcounter; in add() local
84 item.id = id; in add()
89 return id; in add()
97 size_t cancel(uint64_t id) { in cancel() argument
105 if (item.id == id && item.handler) { in cancel()
109 newItem.id = 0; // Means it is a canceled item in cancel()
131 if (item.id && item.handler) { in cancelAll()
133 item.id = 0; in cancelAll()
193 auto reschedule_pair = item.handler(item.id == 0); in checkWork()
216 uint64_t id; // id==0 means it was cancelled member
Dtimer_queue_test.cc60 auto id = q.add(2000, [tnow](bool aborted) mutable { in main() local
65 (void)id; in main()
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DWBWIRocksIterator.java70 final byte id; field in WBWIRocksIterator.WriteType
71 WriteType(final byte id) { in WriteType() argument
72 this.id = id; in WriteType()
75 public static WriteType fromId(final byte id) { in fromId() argument
77 if(id == wt.id) { in fromId()
81 throw new IllegalArgumentException("No WriteType with id=" + id); in fromId()
/rocksdb-6.9/port/
Dport_posix.cc234 void SetCpuPriority(ThreadId id, CpuPriority priority) { in SetCpuPriority() argument
240 sched_setscheduler(id, SCHED_OTHER, &param); in SetCpuPriority()
241 setpriority(PRIO_PROCESS, id, -20); in SetCpuPriority()
244 sched_setscheduler(id, SCHED_OTHER, &param); in SetCpuPriority()
245 setpriority(PRIO_PROCESS, id, 0); in SetCpuPriority()
248 sched_setscheduler(id, SCHED_OTHER, &param); in SetCpuPriority()
249 setpriority(PRIO_PROCESS, id, 19); in SetCpuPriority()
252 sched_setscheduler(id, SCHED_IDLE, &param); in SetCpuPriority()
258 (void)id; in SetCpuPriority()
/rocksdb-6.9/utilities/transactions/
Dtransaction_lock_mgr.cc39 txn_ids.push_back(id); in LockInfo()
269 for (auto id : lock_info.txn_ids) { in IsLockExpired() local
270 if (txn_id == id) { in IsLockExpired()
425 auto id = txn->GetID(); in DecrementWaitersImpl() local
426 assert(wait_txn_map_.Contains(id)); in DecrementWaitersImpl()
427 wait_txn_map_.Delete(id); in DecrementWaitersImpl()
441 auto id = txn->GetID(); in IncrementWaiters() local
445 assert(!wait_txn_map_.Contains(id)); in IncrementWaiters()
458 if (!rev_wait_txn_map_.Contains(id)) { in IncrementWaiters()
483 if (next == id) { in IncrementWaiters()
[all …]
Dwrite_unprepared_transaction_test.cc151 std::hash<std::thread::id>()(std::this_thread::get_id()))); in TEST_P()
174 std::function<void(uint32_t)> stress_thread = [&](int id) { in TEST_P() argument
175 size_t tid = std::hash<std::thread::id>()(std::this_thread::get_id()); in TEST_P()
185 std::set<std::string> owned_keys(keys.begin() + id * kNumKeys, in TEST_P()
186 keys.begin() + (id + 1) * kNumKeys); in TEST_P()
194 txn->SetName(ToString(id)); in TEST_P()
202 buf[0] = id; in TEST_P()
231 auto verify_key = [&owned_keys, &a, &id, &snapshot_num]( in TEST_P()
238 ASSERT_EQ(((int64_t*)value.c_str())[0], id); in TEST_P()
Dwrite_prepared_txn_db.cc255 auto id = h->GetID(); in UpdateCFComparatorMap() local
257 (*cf_map)[id] = comparator; in UpdateCFComparatorMap()
258 if (id != 0) { in UpdateCFComparatorMap()
259 (*handle_map)[id] = h; in UpdateCFComparatorMap()
263 (*handle_map)[id] = DefaultColumnFamily(); in UpdateCFComparatorMap()
278 auto id = h->GetID(); in UpdateCFComparatorMap() local
280 (*cf_map)[id] = comparator; in UpdateCFComparatorMap()
281 (*handle_map)[id] = h; in UpdateCFComparatorMap()
729 std::hash<std::thread::id> hasher; in AdvanceSeqByOne()
Dwrite_prepared_txn.h82 inline void SetId(uint64_t id) override { Transaction::SetId(id); } in SetId() argument
/rocksdb-6.9/table/
Dmock_table.cc68 uint32_t id = GetIDFromFile(file.get()); in NewTableReader() local
72 auto it = file_system_.files.find(id); in NewTableReader()
85 uint32_t id = GetAndWriteNextID(file); in NewTableBuilder() local
87 return new MockTableBuilder(id, &file_system_); in NewTableBuilder()
101 uint32_t id = GetAndWriteNextID(&file_writer); in CreateMockTable() local
102 file_system_.files.insert({id, std::move(file_contents)}); in CreateMockTable()
/rocksdb-6.9/port/win/
Dio_win.cc232 size_t WinMmapReadableFile::GetUniqueId(char* id, size_t max_size) const { in GetUniqueId() argument
233 return GetUniqueIdFromFile(hFile_, id, max_size); in GetUniqueId()
556 size_t WinMmapFile::GetUniqueId(char* id, size_t max_size) const { in GetUniqueId() argument
557 return GetUniqueIdFromFile(hFile_, id, max_size); in GetUniqueId()
723 size_t WinRandomAccessFile::GetUniqueId(char* id, size_t max_size) const { in GetUniqueId() argument
724 return GetUniqueIdFromFile(GetFileHandle(), id, max_size); in GetUniqueId()
984 size_t WinWritableFile::GetUniqueId(char* id, size_t max_size) const { in GetUniqueId() argument
985 return GetUniqueIdFromFile(GetFileHandle(), id, max_size); in GetUniqueId()
1056 size_t WinDirectory::GetUniqueId(char* id, size_t max_size) const { in GetUniqueId() argument
1057 return GetUniqueIdFromFile(handle_, id, max_size); in GetUniqueId()
Dio_win.h58 size_t GetUniqueIdFromFile(HANDLE hFile, char* id, size_t max_size);
146 virtual size_t GetUniqueId(char* id, size_t max_size) const override;
228 virtual size_t GetUniqueId(char* id, size_t max_size) const override;
271 virtual size_t GetUniqueId(char* id, size_t max_size) const override;
377 virtual size_t GetUniqueId(char* id, size_t max_size) const override;
440 size_t GetUniqueId(char* id, size_t max_size) const override;
/rocksdb-6.9/env/
Dio_posix.cc326 size_t PosixHelper::GetUniqueIdFromFile(int fd, char* id, size_t max_size) { in GetUniqueIdFromFile() argument
345 char* rid = id; in GetUniqueIdFromFile()
349 assert(rid >= id); in GetUniqueIdFromFile()
350 return static_cast<size_t>(rid - id); in GetUniqueIdFromFile()
355 size_t PosixHelper::GetUniqueIdFromFile(int fd, char* id, size_t max_size) { in GetUniqueIdFromFile() argument
366 char* rid = id; in GetUniqueIdFromFile()
370 assert(rid >= id); in GetUniqueIdFromFile()
371 return static_cast<size_t>(rid - id); in GetUniqueIdFromFile()
759 return PosixHelper::GetUniqueIdFromFile(fd_, id, max_size); in GetUniqueId()
1365 size_t PosixWritableFile::GetUniqueId(char* id, size_t max_size) const { in GetUniqueId() argument
[all …]
Dcomposite_env_wrapper.h90 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId() argument
91 return target_->GetUniqueId(id, max_size); in GetUniqueId()
179 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId() argument
180 return target_->GetUniqueId(id, max_size); in GetUniqueId()
266 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId() argument
267 return target_->GetUniqueId(id, max_size); in GetUniqueId()
686 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId() argument
687 return target_->GetUniqueId(id, max_size); in GetUniqueId()
768 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId() argument
769 return target_->GetUniqueId(id, max_size); in GetUniqueId()
[all …]
/rocksdb-6.9/file/
Dfilename.cc398 std::string id; in SetIdentityFile() local
400 id = env->GenerateUniqueId(); in SetIdentityFile()
402 id = db_id; in SetIdentityFile()
404 assert(!id.empty()); in SetIdentityFile()
407 Status s = WriteStringToFile(env, id, tmp, true); in SetIdentityFile()
Dreadahead_raf.cc92 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId() argument
93 return file_->GetUniqueId(id, max_size); in GetUniqueId()
/rocksdb-6.9/java/rocksjni/
Dcolumnfamilyhandle.cc38 const int32_t id = cfh->GetID(); in Java_org_rocksdb_ColumnFamilyHandle_getID() local
39 return static_cast<jint>(id); in Java_org_rocksdb_ColumnFamilyHandle_getID()
/rocksdb-6.9/db/
Dcolumn_family.cc486 uint32_t id, const std::string& name, Version* _dummy_versions, in ColumnFamilyData() argument
491 : id_(id), in ColumnFamilyData()
1439 ColumnFamilyData* ColumnFamilySet::GetColumnFamily(uint32_t id) const { in GetColumnFamily()
1440 auto cfd_iter = column_family_data_.find(id); in GetColumnFamily()
1476 const std::string& name, uint32_t id, Version* dummy_versions, in CreateColumnFamily() argument
1480 id, name, dummy_versions, table_cache_, write_buffer_manager_, options, in CreateColumnFamily()
1482 column_families_.insert({name, id}); in CreateColumnFamily()
1483 column_family_data_.insert({id, new_cfd}); in CreateColumnFamily()
1484 max_column_family_ = std::max(max_column_family_, id); in CreateColumnFamily()
1491 if (id == 0) { in CreateColumnFamily()
Ddb_test.cc2378 int id; member
2384 int id = t->id; in MTThreadBody() local
2388 Random rnd(1000 + id); in MTThreadBody()
2525 for (int id = 0; id < kNumThreads; id++) { in TEST_P() local
2532 for (int id = 0; id < kNumThreads; id++) { in TEST_P() local
2534 thread[id].id = id; in TEST_P()
2544 for (int id = 0; id < kNumThreads; id++) { in TEST_P() local
2569 int id; member
2575 int id = t->id; in GCThreadBody() local
2604 for (int id = 0; id < kGCNumThreads; id++) { in TEST_F() local
[all …]
Dcolumn_family.h512 ColumnFamilyData(uint32_t id, const std::string& name,
657 ColumnFamilyData* GetColumnFamily(uint32_t id) const;
668 ColumnFamilyData* CreateColumnFamily(const std::string& name, uint32_t id,
/rocksdb-6.9/utilities/
Denv_mirror.cc91 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId() argument
93 return a_->GetUniqueId(id, max_size); in GetUniqueId()
169 size_t GetUniqueId(char* id, size_t max_size) const override { in GetUniqueId() argument
171 return a_->GetUniqueId(id, max_size); in GetUniqueId()
Denv_librados.cc231 size_t GetUniqueId(char* id, size_t max_size) const { in GetUniqueId() argument
234 strncpy(id, _fid.c_str() + (_fid.size() - s), s); in GetUniqueId()
235 id[s - 1] = '\0'; in GetUniqueId()
481 size_t GetUniqueId(char* id, size_t max_size) const { in GetUniqueId() argument
484 strncpy(id, _fid.c_str() + (_fid.size() - s), s); in GetUniqueId()
485 id[s - 1] = '\0'; in GetUniqueId()
/rocksdb-6.9/test_util/
Dsync_point_impl.h34 std::unordered_map<std::string, std::thread::id> marked_thread_id_;
66 std::thread::id thread_id) { in DisabledByMarker()
/rocksdb-6.9/java/benchmark/src/main/java/org/rocksdb/benchmark/
DDbBenchmark.java67 Stats(int id) { in Stats() argument
68 id_ = id; in Stats()
111 void setId(int id) { id_ = id; } in setId() argument
281 abstract protected void getKey(byte[] key, long id, long range); in getKey() argument
302 @Override protected void getKey(byte[] key, long id, long range) { in getKey() argument
303 getFixedKey(key, id); in getKey()
322 @Override protected void getKey(byte[] key, long id, long range) { in getKey() argument
345 @Override protected void getKey(byte[] key, long id, long range) { in getKey() argument
/rocksdb-6.9/java/
DRELEASE.md42 <id>sonatype-nexus-staging</id>

123