Home
last modified time | relevance | path

Searched refs:p (Results 1 – 25 of 86) sorted by relevance

1234

/rocksdb-6.9/util/
Dthread_local_test.cc120 p.tls2 = &tls2; in TEST_F()
175 p.mu->Lock(); in TEST_F()
180 while (p.started != p.total) { in TEST_F()
210 p.mu->Lock(); in TEST_F()
245 p.mu->Lock(); in TEST_F()
246 ++(*p.unref); in TEST_F()
257 while (p.started != p.total) { in TEST_F()
283 while (p.started != p.total) { in TEST_F()
323 while (p.started != p.total) { in TEST_F()
361 while (p.completed != p.total) { in TEST_F()
[all …]
Dcoding_test.cc23 const char* p = s.data(); in TEST() local
27 p += sizeof(uint16_t); in TEST()
37 const char* p = s.data(); in TEST() local
41 p += sizeof(uint32_t); in TEST()
54 const char* p = s.data(); in TEST() local
60 p += sizeof(uint64_t); in TEST()
64 p += sizeof(uint64_t); in TEST()
68 p += sizeof(uint64_t); in TEST()
108 p = GetVarint32Ptr(p, limit, &actual); in TEST()
143 p = GetVarint64Ptr(p, limit, &actual); in TEST()
[all …]
Dxxhash.cc115 static void XXH_free (void* p) { free(p); } in XXH_free() argument
385 #define XXH_get32bits(p) XXH_readLE32_align(p, align) argument
604 v1 = XXH32_round(v1, XXH_readLE32(p)); p+=4; in XXH32_update()
605 v2 = XXH32_round(v2, XXH_readLE32(p)); p+=4; in XXH32_update()
606 v3 = XXH32_round(v3, XXH_readLE32(p)); p+=4; in XXH32_update()
607 v4 = XXH32_round(v4, XXH_readLE32(p)); p+=4; in XXH32_update()
617 XXH_memcpy(state->mem32, p, (size_t)(bEnd-p)); in XXH32_update()
803 #define XXH_get64bits(p) XXH_readLE64_align(p, align) argument
1087 v1 = XXH64_round(v1, XXH_readLE64(p)); p+=8; in XXH64_update()
1088 v2 = XXH64_round(v2, XXH_readLE64(p)); p+=8; in XXH64_update()
[all …]
Dcoding.cc54 const char* GetVarint32PtrFallback(const char* p, const char* limit, in GetVarint32PtrFallback() argument
57 for (uint32_t shift = 0; shift <= 28 && p < limit; shift += 7) { in GetVarint32PtrFallback()
58 uint32_t byte = *(reinterpret_cast<const unsigned char*>(p)); in GetVarint32PtrFallback()
59 p++; in GetVarint32PtrFallback()
66 return reinterpret_cast<const char*>(p); in GetVarint32PtrFallback()
72 const char* GetVarint64Ptr(const char* p, const char* limit, uint64_t* value) { in GetVarint64Ptr() argument
74 for (uint32_t shift = 0; shift <= 63 && p < limit; shift += 7) { in GetVarint64Ptr()
75 uint64_t byte = *(reinterpret_cast<const unsigned char*>(p)); in GetVarint64Ptr()
76 p++; in GetVarint64Ptr()
83 return reinterpret_cast<const char*>(p); in GetVarint64Ptr()
Dcrc32c.cc331 *p += 4; in Slow_CRC32()
338 *p += 4; in Slow_CRC32()
347 Slow_CRC32(l, p); in Fast_CRC32()
350 *p += 8; in Fast_CRC32()
353 *p += 4; in Fast_CRC32()
355 *p += 4; in Fast_CRC32()
381 while (p != x) { in ExtendImpl()
387 CRC32(&l, &p); in ExtendImpl()
388 CRC32(&l, &p); in ExtendImpl()
392 CRC32(&l, &p); in ExtendImpl()
[all …]
Dcoding.h88 const char* ret = GetVarint64Ptr(p, limit, &u); in GetVarsignedint64Ptr()
154 inline const char* GetVarint32Ptr(const char* p, in GetVarint32Ptr() argument
157 if (p < limit) { in GetVarint32Ptr()
161 return p + 1; in GetVarint32Ptr()
370 const char* p = input->data(); in GetVarint32() local
371 const char* limit = p + input->size(); in GetVarint32()
382 const char* p = input->data(); in GetVarint64() local
383 const char* limit = p + input->size(); in GetVarint64()
394 const char* p = input->data(); in GetVarsignedint64() local
395 const char* limit = p + input->size(); in GetVarsignedint64()
[all …]
Dhash_map.h35 [key](const std::pair<K, V>& p) { return p.first == key; }); in Contains()
48 [key](const std::pair<K, V>& p) { return p.first == key; }); in Delete()
62 [key](const std::pair<K, V>& p) { return p.first == key; }); in Get()
Dcrc32c_ppc.c18 static unsigned int crc32_align(unsigned int crc, unsigned char const *p, in crc32_align() argument
20 while (len--) crc = crc_table[(crc ^ *p++) & 0xff] ^ (crc >> 8); in crc32_align()
26 unsigned int __crc32_vpmsum(unsigned int crc, unsigned char const *p,
Dcompression_context_cache.cc74 auto p = per_core_uncompr_.AccessElementAndIndex(); in GetZSTDUncompressData() local
75 int64_t idx = static_cast<int64_t>(p.second); in GetZSTDUncompressData()
76 return p.first->GetUncompressData(idx); in GetZSTDUncompressData()
/rocksdb-6.9/table/block_based/
Dblock.cc50 p += 3; in operator ()()
54 if ((p = GetVarint32Ptr(p, limit, value_length)) == nullptr) { in operator ()()
62 return p; in operator ()()
83 p += 3; in operator ()()
87 if ((p = GetVarint32Ptr(p, limit, value_length)) == nullptr) { in operator ()()
95 return p; in operator ()()
121 p += 2; in operator ()()
126 return p; in operator ()()
508 if (p >= limit) { in ParseNextDataKey()
575 if (p >= limit) { in ParseNextIndexKey()
[all …]
/rocksdb-6.9/port/win/
Dwin_jemalloc.cc45 void jemalloc_aligned_free(void* p) ROCKSDB_NOEXCEPT { je_free(p); } in jemalloc_aligned_free() argument
50 void* p = je_malloc(size); in operator new() local
51 if (!p) { in operator new()
54 return p; in operator new()
58 void* p = je_malloc(size); in operator new[]() local
59 if (!p) { in operator new[]()
62 return p; in operator new[]()
66 if (p) { in operator delete()
67 je_free(p); in operator delete()
72 if (p) { in operator delete[]()
[all …]
Dwin_logger.cc118 char* p = base; in Logv() local
126 p += snprintf(p, limit - p, "%04d/%02d/%02d-%02d:%02d:%02d.%06d %llx ", in Logv()
132 if (p < limit) { in Logv()
135 int done = vsnprintf(p, limit - p, format, backup_ap); in Logv()
137 p += done; in Logv()
145 if (p >= limit) { in Logv()
149 p = limit - 1; in Logv()
154 if (p == base || p[-1] != '\n') { in Logv()
155 *p++ = '\n'; in Logv()
158 assert(p <= limit); in Logv()
[all …]
/rocksdb-6.9/logging/
Dposix_logger.h103 char* p = base; in Logv() local
111 p += snprintf(p, limit - p, in Logv()
123 if (p < limit) { in Logv()
126 p += vsnprintf(p, limit - p, format, backup_ap); in Logv()
131 if (p >= limit) { in Logv()
135 p = limit - 1; in Logv()
140 if (p == base || p[-1] != '\n') { in Logv()
141 *p++ = '\n'; in Logv()
144 assert(p <= limit); in Logv()
145 const size_t write_size = p - base; in Logv()
Denv_logger.h99 char* p = base; in Logv() local
107 p += snprintf(p, limit - p, "%04d/%02d/%02d-%02d:%02d:%02d.%06d %llx ", in Logv()
113 if (p < limit) { in Logv()
116 p += vsnprintf(p, limit - p, format, backup_ap); in Logv()
121 if (p >= limit) { in Logv()
125 p = limit - 1; in Logv()
130 if (p == base || p[-1] != '\n') { in Logv()
131 *p++ = '\n'; in Logv()
134 assert(p <= limit); in Logv()
137 file_.Append(Slice(base, p - base)); in Logv()
Dlog_buffer.cc26 char* p = buffered_log->message; in AddLogToBuffer() local
33 if (p < limit) { in AddLogToBuffer()
36 auto n = vsnprintf(p, limit - p, format, backup_ap); in AddLogToBuffer()
42 p += n; in AddLogToBuffer()
44 p = limit; in AddLogToBuffer()
49 if (p > limit) { in AddLogToBuffer()
50 p = limit; in AddLogToBuffer()
54 *p = '\0'; in AddLogToBuffer()
/rocksdb-6.9/
Dappveyor.yml38 - msbuild Snappy.sln /p:Configuration=Debug /p:Platform=x64
39 - msbuild Snappy.sln /p:Configuration=Release /p:Platform=x64
46 - msbuild lz4.sln /p:Configuration=Debug /p:Platform=x64
47 - msbuild lz4.sln /p:Configuration=Release /p:Platform=x64
54 - msbuild zstd.sln /p:Configuration=Debug /p:Platform=x64
55 - msbuild zstd.sln /p:Configuration=Release /p:Platform=x64
/rocksdb-6.9/env/
Denv_hdfs.cc331 char* p = base; in Logv() local
339 p += snprintf(p, limit - p, in Logv()
351 if (p < limit) { in Logv()
354 p += vsnprintf(p, limit - p, format, backup_ap); in Logv()
359 if (p >= limit) { in Logv()
363 p = limit - 1; in Logv()
368 if (p == base || p[-1] != '\n') { in Logv()
369 *p++ = '\n'; in Logv()
372 assert(p <= limit); in Logv()
373 file_->Append(base, p-base); in Logv()
Dmock_env.cc357 char* p = base; in Logv() local
368 p += snprintf(p, limit - p, "%04d/%02d/%02d-%02d:%02d:%02d.%06d ", in Logv()
373 if (p < limit) { in Logv()
376 p += vsnprintf(p, limit - p, format, backup_ap); in Logv()
381 if (p >= limit) { in Logv()
385 p = limit - 1; in Logv()
390 if (p == base || p[-1] != '\n') { in Logv()
391 *p++ = '\n'; in Logv()
394 assert(p <= limit); in Logv()
395 const size_t write_size = p - base; in Logv()
/rocksdb-6.9/utilities/blob_db/
Dblob_dump_tool.cc257 for (size_t p = 0; p < sizeof(buf) - 1; p++) { in DumpSlice() local
258 if (buf[p] == 0) { in DumpSlice()
259 buf[p] = ' '; in DumpSlice()
268 std::string BlobDumpTool::GetString(std::pair<T, T> p) { in GetString() argument
269 if (p.first == 0 && p.second == 0) { in GetString()
272 return "(" + ToString(p.first) + ", " + ToString(p.second) + ")"; in GetString()
/rocksdb-6.9/memory/
Djemalloc_nodump_allocator.cc59 void JemallocNodumpAllocator::Deallocate(void* p) { in Deallocate() argument
63 size = malloc_usable_size(p); in Deallocate()
68 dallocx(p, tcache_flag); in Deallocate()
126 size_t JemallocNodumpAllocator::UsableSize(void* p, in UsableSize() argument
128 return malloc_usable_size(static_cast<void*>(p)); in UsableSize()
/rocksdb-6.9/db/
Dmemtable.cc491 char* p = EncodeVarint32(buf, internal_key_size); in Add() local
492 memcpy(p, key.data(), key_size); in Add()
493 Slice key_slice(p, key_size); in Add()
494 p += key_size; in Add()
496 EncodeFixed64(p, packed); in Add()
497 p += 8; in Add()
498 p = EncodeVarint32(p, val_size); in Add()
499 memcpy(p, value.data(), val_size); in Add()
977 char* p = in Update() local
980 memcpy(p, value.data(), value.size()); in Update()
[all …]
Ddbformat_test.cc139 const char p[] = "abcdefghijklmnopqrstuvwxyz"; in TEST_F() local
145 k.TrimAppend(0, p, 3); in TEST_F()
149 k.TrimAppend(1, p, 3); in TEST_F()
153 k.TrimAppend(0, p, 26); in TEST_F()
170 k.TrimAppend(27, p, 26); in TEST_F()
/rocksdb-6.9/monitoring/
Dstatistics.h95 void operator delete(void *p) { port::cacheline_aligned_free(p); } in ALIGN_AS()
96 void operator delete[](void *p) { port::cacheline_aligned_free(p); } in ALIGN_AS()
/rocksdb-6.9/utilities/memory/
Dmemory_test.cc122 for (int p = 0; p < opt.min_write_buffer_number_to_merge / 2; ++p) { in TEST_F() local
181 for (int p = 0; p < opt.min_write_buffer_number_to_merge / 2; ++p) { in TEST_F() local
/rocksdb-6.9/db/compaction/
Dcompaction_picker_level.cc411 uint32_t p = 0; in GetPathId() local
425 while (p < ioptions.cf_paths.size() - 1) { in GetPathId()
429 return p; in GetPathId()
451 p++; in GetPathId()
452 current_path_size = ioptions.cf_paths[p].target_size; in GetPathId()
454 return p; in GetPathId()

1234