Home
last modified time | relevance | path

Searched refs:ptr (Results 1 – 25 of 43) sorted by relevance

12

/rocksdb-6.9/util/
Dcoding.h144 uint64_t lo = DecodeFixed32(ptr); in DecodeFixed64()
239 char* ptr = EncodeVarint32(buf, v); in PutVarint32() local
246 ptr = EncodeVarint32(ptr, v2); in PutVarint32Varint32()
254 ptr = EncodeVarint32(ptr, v2); in PutVarint32Varint32Varint32()
255 ptr = EncodeVarint32(ptr, v3); in PutVarint32Varint32Varint32()
263 *(ptr++) = (v & (B - 1)) | B; in EncodeVarint64()
272 char* ptr = EncodeVarint64(buf, v); in PutVarint64() local
286 ptr = EncodeVarint64(ptr, v2); in PutVarint64Varint64()
293 ptr = EncodeVarint64(ptr, v2); in PutVarint32Varint64()
301 ptr = EncodeVarint32(ptr, v2); in PutVarint32Varint32Varint64()
[all …]
Dthread_local.cc18 Entry() : ptr(nullptr) {} in Entry()
19 Entry(const Entry& e) : ptr(e.ptr.load(std::memory_order_relaxed)) {} in Entry()
20 std::atomic<void*> ptr; member
414 tls->entries[id].ptr.store(ptr, std::memory_order_release); in Reset()
424 return tls->entries[id].ptr.exchange(ptr, std::memory_order_acquire); in Swap()
444 void* ptr = in Scrape() local
446 if (ptr != nullptr) { in Scrape()
457 void* ptr = t->entries[id].ptr.load(); in Fold() local
459 func(ptr, res); in Fold()
509 void* ptr = t->entries[id].ptr.exchange(nullptr); in ReclaimId() local
[all …]
Dcoding.cc28 *(ptr++) = v; in EncodeVarint32()
30 *(ptr++) = v | B; in EncodeVarint32()
31 *(ptr++) = v >> 7; in EncodeVarint32()
33 *(ptr++) = v | B; in EncodeVarint32()
34 *(ptr++) = (v >> 7) | B; in EncodeVarint32()
35 *(ptr++) = v >> 14; in EncodeVarint32()
37 *(ptr++) = v | B; in EncodeVarint32()
38 *(ptr++) = (v >> 7) | B; in EncodeVarint32()
40 *(ptr++) = v >> 21; in EncodeVarint32()
42 *(ptr++) = v | B; in EncodeVarint32()
[all …]
Dthread_local_test.cc291 p.tls1.Reset(ptr); in TEST_F()
292 p.tls2->Reset(ptr); in TEST_F()
294 p.tls1.Reset(ptr); in TEST_F()
295 p.tls2->Reset(ptr); in TEST_F()
331 p.tls1.Reset(ptr); in TEST_F()
332 p.tls2->Reset(ptr); in TEST_F()
334 p.tls1.Reset(ptr); in TEST_F()
335 p.tls2->Reset(ptr); in TEST_F()
406 p.tls1.Reset(ptr); in TEST_F()
407 p.tls2->Reset(ptr); in TEST_F()
[all …]
Dxxhash.cc203 static xxh_u32 XXH_read32(const void* ptr) { return ((const unalign*)ptr)->u32; } in XXH_read32() argument
288 return XXH_CPU_LITTLE_ENDIAN ? XXH_read32(ptr) : XXH_swap32(XXH_read32(ptr)); in XXH_readLE32()
293 return XXH_CPU_LITTLE_ENDIAN ? XXH_swap32(XXH_read32(ptr)) : XXH_read32(ptr); in XXH_readBE32()
300 return XXH_readLE32(ptr); in XXH_readLE32_align()
302 return XXH_CPU_LITTLE_ENDIAN ? *(const xxh_u32*)ptr : XXH_swap32(*(const xxh_u32*)ptr); in XXH_readLE32_align()
713 static xxh_u64 XXH_read64(const void* ptr) { return ((const unalign64*)ptr)->u64; } in XXH_read64() argument
750 return XXH_CPU_LITTLE_ENDIAN ? XXH_read64(ptr) : XXH_swap64(XXH_read64(ptr)); in XXH_readLE64()
755 return XXH_CPU_LITTLE_ENDIAN ? XXH_swap64(XXH_read64(ptr)) : XXH_read64(ptr); in XXH_readBE64()
764 return XXH_CPU_LITTLE_ENDIAN ? *(const xxh_u64*)ptr : XXH_swap64(*(const xxh_u64*)ptr); in XXH_readLE64_align()
814 ptr+=4; \ in XXH64_finalize()
[all …]
Ddynamic_bloom.h100 AddHash(hash, [](std::atomic<uint64_t>* ptr, uint64_t mask) { in AddHash()
101 ptr->store(ptr->load(std::memory_order_relaxed) | mask, in AddHash()
107 AddHash(hash, [](std::atomic<uint64_t>* ptr, uint64_t mask) { in AddHashConcurrently()
113 if ((mask & ptr->load(std::memory_order_relaxed)) != mask) { in AddHashConcurrently()
114 ptr->fetch_or(mask, std::memory_order_relaxed); in AddHashConcurrently()
Dthread_local.h34 typedef void (*UnrefHandler)(void* ptr);
57 void Reset(void* ptr);
60 void* Swap(void* ptr);
66 bool CompareAndSwap(void* ptr, void*& expected);
Dxxh3p.h254 # define XXH_PREFETCH(ptr) (void)(ptr) /* disabled */ argument
258 # define XXH_PREFETCH(ptr) _mm_prefetch((const char*)(ptr), _MM_HINT_T0) argument
260 # define XXH_PREFETCH(ptr) __builtin_prefetch((ptr), 0 /* rw==read */, 3 /* locality */) argument
262 # define XXH_PREFETCH(ptr) (void)(ptr) /* disabled */ argument
Daligned_buffer.h89 static bool isAligned(const void* ptr, size_t alignment) { in isAligned() argument
90 return reinterpret_cast<uintptr_t>(ptr) % alignment == 0; in isAligned()
/rocksdb-6.9/db/
Dpinned_iterators_manager.h47 void PinPtr(void* ptr, ReleaseFunction release_func) { in PinPtr() argument
49 if (ptr == nullptr) { in PinPtr()
52 pinned_ptrs_.emplace_back(ptr, release_func); in PinPtr()
65 void* ptr = i->first; in ReleasePinnedData() local
67 release_func(ptr); in ReleasePinnedData()
75 static void ReleaseInternalIterator(void* ptr) { in ReleaseInternalIterator() argument
76 delete reinterpret_cast<InternalIterator*>(ptr); in ReleaseInternalIterator()
79 static void ReleaseArenaInternalIterator(void* ptr) { in ReleaseArenaInternalIterator() argument
80 reinterpret_cast<InternalIterator*>(ptr)->~InternalIterator(); in ReleaseArenaInternalIterator()
Dlog_writer.cc52 const char* ptr = slice.data(); in AddRecord() local
100 s = EmitPhysicalRecord(type, ptr, fragment_length); in AddRecord()
101 ptr += fragment_length; in AddRecord()
117 IOStatus Writer::EmitPhysicalRecord(RecordType t, const char* ptr, size_t n) { in EmitPhysicalRecord() argument
148 crc = crc32c::Extend(crc, ptr, n); in EmitPhysicalRecord()
155 s = dest_->Append(Slice(ptr, n)); in EmitPhysicalRecord()
Dcolumn_family.cc458 void SuperVersionUnrefHandle(void* ptr) { in SuperVersionUnrefHandle() argument
463 SuperVersion* sv = static_cast<SuperVersion*>(ptr); in SuperVersionUnrefHandle()
1165 void* ptr = local_sv_->Swap(SuperVersion::kSVInUse); in GetThreadLocalSuperVersion() local
1171 assert(ptr != SuperVersion::kSVInUse); in GetThreadLocalSuperVersion()
1172 SuperVersion* sv = static_cast<SuperVersion*>(ptr); in GetThreadLocalSuperVersion()
1267 for (auto ptr : sv_ptrs) { in ResetThreadLocalSuperVersions() local
1268 assert(ptr); in ResetThreadLocalSuperVersions()
1269 if (ptr == SuperVersion::kSVInUse) { in ResetThreadLocalSuperVersions()
1272 auto sv = static_cast<SuperVersion*>(ptr); in ResetThreadLocalSuperVersions()
Dc_test.c96 static void Free(char** ptr) { in Free() argument
97 if (*ptr) { in Free()
98 free(*ptr); in Free()
99 *ptr = NULL; in Free()
180 static void CheckPut(void* ptr, in CheckPut() argument
183 int* state = (int*) ptr; in CheckPut()
199 static void CheckDel(void* ptr, const char* k, size_t klen) { in CheckDel() argument
200 int* state = (int*) ptr; in CheckDel()
Dlog_writer.h107 IOStatus EmitPhysicalRecord(RecordType type, const char* ptr, size_t length);
/rocksdb-6.9/cache/
Dlru_cache.cc40 LRUHandle* old = *ptr; in Insert()
42 *ptr = h; in Insert()
55 LRUHandle** ptr = FindPointer(key, hash); in Remove() local
56 LRUHandle* result = *ptr; in Remove()
58 *ptr = result->next_hash; in Remove()
65 LRUHandle** ptr = &list_[hash & (length_ - 1)]; in FindPointer() local
66 while (*ptr != nullptr && ((*ptr)->hash != hash || key != (*ptr)->key())) { in FindPointer()
67 ptr = &(*ptr)->next_hash; in FindPointer()
69 return ptr; in FindPointer()
86 h->next_hash = *ptr; in Resize()
[all …]
/rocksdb-6.9/include/rocksdb/utilities/
Dobject_registry.h135 T* ptr = NewObject(target, result, &errmsg); in NewUniqueObject() local
136 if (ptr == nullptr) { in NewUniqueObject()
157 T* ptr = NewObject(target, &guard, &errmsg); in NewSharedObject() local
158 if (ptr == nullptr) { in NewSharedObject()
179 T* ptr = NewObject(target, &guard, &errmsg); in NewStaticObject() local
180 if (ptr == nullptr) { in NewStaticObject()
187 *result = ptr; in NewStaticObject()
/rocksdb-6.9/options/
Doptions_settable_test.cc59 for (char* ptr = start_ptr + offset; ptr < start_ptr + pair.first; ptr++) { in NumUnsetBytes() local
60 if (*ptr == kSpecialChar) { in NumUnsetBytes()
66 for (char* ptr = start_ptr + offset; ptr < start_ptr + total_size; ptr++) { in NumUnsetBytes() local
67 if (*ptr == kSpecialChar) { in NumUnsetBytes()
Doptions_helper.cc695 const auto* ptr = in SerializeSingleOptionHelper() local
697 *value = *ptr ? (*ptr)->Name() : kNullptrString; in SerializeSingleOptionHelper()
701 const auto* ptr = in SerializeSingleOptionHelper() local
704 *value = ptr->get() ? ptr->get()->Name() : kNullptrString; in SerializeSingleOptionHelper()
708 const auto* ptr = in SerializeSingleOptionHelper() local
711 *value = ptr->get() ? ptr->get()->Name() : kNullptrString; in SerializeSingleOptionHelper()
715 const auto* ptr = in SerializeSingleOptionHelper() local
717 *value = ptr->get() ? ptr->get()->Name() : kNullptrString; in SerializeSingleOptionHelper()
721 const auto* ptr = in SerializeSingleOptionHelper() local
723 *value = ptr->get() ? ptr->get()->Name() : kNullptrString; in SerializeSingleOptionHelper()
[all …]
/rocksdb-6.9/memory/
Dmemory_allocator.h16 void operator()(char* ptr) const { in operator()
18 allocator->Deallocate(reinterpret_cast<void*>(ptr)); in operator()
20 delete[] ptr; in operator()
Djemalloc_nodump_allocator.cc103 void JemallocNodumpAllocator::DestroyThreadSpecificCache(void* ptr) { in DestroyThreadSpecificCache() argument
104 assert(ptr != nullptr); in DestroyThreadSpecificCache()
105 unsigned* tcache_index = static_cast<unsigned*>(ptr); in DestroyThreadSpecificCache()
/rocksdb-6.9/env/
Dio_posix.cc200 return uintptr_t(ptr) % sector_size == 0; in IsSectorAligned()
267 char* ptr = scratch; in PositionedRead() local
269 r = pread(fd_, ptr, left, static_cast<off_t>(offset)); in PositionedRead()
276 ptr += r; in PositionedRead()
578 char* ptr = scratch; in Read() local
587 ptr += r; in Read()
921 if (ptr == MAP_FAILED) { in MapNewRegion()
926 base_ = reinterpret_cast<char*>(ptr); in MapNewRegion()
1402 char* ptr = scratch; in Read() local
1404 ssize_t done = pread(fd_, ptr, left, offset); in Read()
[all …]
Denv_test.cc56 void operator()(void* ptr) { in operator ()()
58 assert(ptr); in operator ()()
59 (*fn_)(ptr); in operator ()()
66 char* ptr = nullptr; in NewAligned() local
68 if (nullptr == (ptr = reinterpret_cast<char*>(_aligned_malloc(size, kPageSize)))) { in NewAligned()
71 std::unique_ptr<char, Deleter> uptr(ptr, Deleter(_aligned_free)); in NewAligned()
73 if (posix_memalign(reinterpret_cast<void**>(&ptr), kPageSize, size) != 0) { in NewAligned()
76 std::unique_ptr<char, Deleter> uptr(ptr, Deleter(free)); in NewAligned()
116 static void SetBool(void* ptr) { in SetBool() argument
117 reinterpret_cast<std::atomic<bool>*>(ptr)->store(true); in SetBool()
/rocksdb-6.9/table/plain/
Dplain_table_key_coding.cc44 char* ptr = EncodeVarint32(out_buffer + 1, key_size - kSizeInlineLimit); in EncodeSize() local
45 return ptr - out_buffer; in EncodeSize()
99 char* ptr = EncodeVarint32(key_size_buf, user_key_size); in AppendKey() local
100 assert(ptr <= key_size_buf + sizeof(key_size_buf)); in AppendKey()
101 auto len = ptr - key_size_buf; in AppendKey()
/rocksdb-6.9/port/win/
Dwin_thread.cc173 auto ptr = reinterpret_cast<std::shared_ptr<Data>*>(arg); in ThreadProc() local
174 std::unique_ptr<std::shared_ptr<Data>> data(ptr); in ThreadProc()
/rocksdb-6.9/db_stress_tool/
Ddb_stress_shared_state.h162 for (auto& ptr : key_locks_[i]) { in SharedState()
163 ptr.reset(new port::Mutex); in SharedState()

12