Home
last modified time | relevance | path

Searched refs:buf (Results 1 – 25 of 103) sorted by relevance

12345

/rocksdb-6.9/util/
Dcoding.h211 dst->append(buf, sizeof(buf)); in PutFixed16()
222 dst->append(buf, sizeof(buf)); in PutFixed32()
233 dst->append(buf, sizeof(buf)); in PutFixed64()
240 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint32()
247 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint32Varint32()
256 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint32Varint32Varint32()
273 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint64()
280 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarsignedint64()
287 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint64Varint64()
294 dst->append(buf, static_cast<size_t>(ptr - buf)); in PutVarint32Varint64()
[all …]
Dcrc32c_test.cc70 char buf[32]; in TEST() local
72 memset(buf, 0, sizeof(buf)); in TEST()
73 ASSERT_EQ(0x8a9136aaU, Value(buf, sizeof(buf))); in TEST()
75 memset(buf, 0xff, sizeof(buf)); in TEST()
76 ASSERT_EQ(0x62a8ab43U, Value(buf, sizeof(buf))); in TEST()
79 buf[i] = static_cast<char>(i); in TEST()
81 ASSERT_EQ(0x46dd794eU, Value(buf, sizeof(buf))); in TEST()
84 buf[i] = static_cast<char>(31 - i); in TEST()
86 ASSERT_EQ(0x113fdb5cU, Value(buf, sizeof(buf))); in TEST()
145 inline uint64_t fnv64_buf(const void* buf, in fnv64_buf() argument
[all …]
Dstring_util.cc83 char buf[30]; in AppendNumberTo() local
84 snprintf(buf, sizeof(buf), "%" PRIu64, num); in AppendNumberTo()
85 str->append(buf); in AppendNumberTo()
94 char buf[10]; in AppendEscapedStringTo() local
95 snprintf(buf, sizeof(buf), "\\x%02x", in AppendEscapedStringTo()
109 char buf[19]; in NumberToHumanString() local
112 snprintf(buf, sizeof(buf), "%" PRIi64, num); in NumberToHumanString()
114 snprintf(buf, sizeof(buf), "%" PRIi64 "K", num / 1000); in NumberToHumanString()
116 snprintf(buf, sizeof(buf), "%" PRIi64 "M", num / 1000000); in NumberToHumanString()
118 snprintf(buf, sizeof(buf), "%" PRIi64 "G", num / 1000000000); in NumberToHumanString()
[all …]
Dfile_checksum_helper.h41 char buf[sizeof(v)]; in Uint32ToString() local
42 buf[0] = v & 0xff; in Uint32ToString()
43 buf[1] = (v >> 8) & 0xff; in Uint32ToString()
44 buf[2] = (v >> 16) & 0xff; in Uint32ToString()
45 buf[3] = (v >> 24) & 0xff; in Uint32ToString()
46 s.append(buf, sizeof(v)); in Uint32ToString()
74 const char* buf = s.c_str(); in StringToUint32() local
75 v |= static_cast<uint32_t>(buf[0]); in StringToUint32()
76 v |= (static_cast<uint32_t>(buf[1]) << 8); in StringToUint32()
77 v |= (static_cast<uint32_t>(buf[2]) << 16); in StringToUint32()
[all …]
Dcrc32c.cc546 #define CRCtriplet(crc, buf, offset) \ argument
547 crc##0 = _mm_crc32_u64(crc##0, *(buf##0 + offset)); \
548 crc##1 = _mm_crc32_u64(crc##1, *(buf##1 + offset)); \
549 crc##2 = _mm_crc32_u64(crc##2, *(buf##2 + offset));
551 #define CRCduplet(crc, buf, offset) \ argument
552 crc##0 = _mm_crc32_u64(crc##0, *(buf##0 + offset)); \
553 crc##1 = _mm_crc32_u64(crc##1, *(buf##1 + offset));
555 #define CRCsinglet(crc, buf, offset) \ argument
556 crc = _mm_crc32_u64(crc, *(uint64_t*)(buf + offset));
688 const unsigned char* next = (const unsigned char*)buf; in crc32c_3way()
[all …]
Dslice_test.cc34 std::string buf; in TEST_F() local
35 PinnableSlice v1(&buf); in TEST_F()
39 ASSERT_EQ(buf.data(), v2.data()); in TEST_F()
40 ASSERT_EQ(&buf, v2.GetSelf()); in TEST_F()
44 ASSERT_EQ(buf.data(), v3.data()); in TEST_F()
45 ASSERT_EQ(&buf, v3.GetSelf()); in TEST_F()
/rocksdb-6.9/java/src/test/java/org/rocksdb/util/
DJNIComparatorTest.java83 buf.putInt(i); in storeWithJavaComparator()
84 buf.flip(); in storeWithJavaComparator()
86 db.put(buf.array(), buf.array()); in storeWithJavaComparator()
88 buf.clear(); in storeWithJavaComparator()
103 buf.putInt(i); in storeWithCppComparator()
104 buf.flip(); in storeWithCppComparator()
106 db.put(buf.array(), buf.array()); in storeWithCppComparator()
108 buf.clear(); in storeWithCppComparator()
129 buf.flip(); in readAllWithJavaComparator()
134 buf.clear(); in readAllWithJavaComparator()
[all …]
/rocksdb-6.9/db/
Dinternal_stats.cc565 snprintf(buf, sizeof(buf), in HandleLevelStats()
963 snprintf(buf, sizeof(buf), in DumpDBStats()
992 snprintf(buf, sizeof(buf), in DumpDBStats()
1002 snprintf(buf, sizeof(buf), in DumpDBStats()
1024 buf, sizeof(buf), in DumpDBStats()
1043 buf, sizeof(buf), in DumpDBStats()
1277 buf, sizeof(buf), in DumpCFStatsNoFileHistogram()
1298 snprintf(buf, sizeof(buf), in DumpCFStatsNoFileHistogram()
1306 snprintf(buf, sizeof(buf), in DumpCFStatsNoFileHistogram()
1313 snprintf(buf, sizeof(buf), in DumpCFStatsNoFileHistogram()
[all …]
Dlog_writer.cc121 char buf[kRecyclableHeaderSize]; in EmitPhysicalRecord() local
124 buf[4] = static_cast<char>(n & 0xff); in EmitPhysicalRecord()
125 buf[5] = static_cast<char>(n >> 8); in EmitPhysicalRecord()
126 buf[6] = static_cast<char>(t); in EmitPhysicalRecord()
143 EncodeFixed32(buf + 7, static_cast<uint32_t>(log_number_)); in EmitPhysicalRecord()
144 crc = crc32c::Extend(crc, buf + 7, 4); in EmitPhysicalRecord()
150 EncodeFixed32(buf, crc); in EmitPhysicalRecord()
153 IOStatus s = dest_->Append(Slice(buf, header_size)); in EmitPhysicalRecord()
Ddb_tailing_iter_test.cc54 char buf[32]; in TEST_F() local
55 snprintf(buf, sizeof(buf), "%016d", i); in TEST_F()
57 Slice key(buf, 16); in TEST_F()
277 char buf[32]; in TEST_F() local
278 snprintf(buf, sizeof(buf), "1%015d", i); in TEST_F()
280 Slice key(buf, 16); in TEST_F()
363 char buf[100]; in TEST_F() local
364 snprintf(buf, sizeof(buf), "%05d", 2*i); in TEST_F()
365 std::string key(buf); in TEST_F()
/rocksdb-6.9/tools/
Dldb_cmd_test.cc90 char buf[16]; in TEST_F() local
91 snprintf(buf, sizeof(buf), "%08d", i); in TEST_F()
92 ASSERT_OK(db->Put(wopts, buf, buf)); in TEST_F()
274 snprintf(buf, sizeof(buf), "%08d", i); in TEST_F()
282 snprintf(buf, sizeof(buf), "%08d", i); in TEST_F()
290 snprintf(buf, sizeof(buf), "%08d", i); in TEST_F()
298 snprintf(buf, sizeof(buf), "%08d", i); in TEST_F()
361 snprintf(buf, sizeof(buf), "%08d", i); in TEST_F()
369 snprintf(buf, sizeof(buf), "%08d", i); in TEST_F()
377 snprintf(buf, sizeof(buf), "%08d", i); in TEST_F()
[all …]
Dsst_dump_test.cc29 char buf[100]; in MakeKey() local
30 snprintf(buf, sizeof(buf), "k_%04d", i); in MakeKey()
31 InternalKey key(std::string(buf), 0, ValueType::kTypeValue); in MakeKey()
36 char buf[100]; in MakeValue() local
37 snprintf(buf, sizeof(buf), "v_%04d", i); in MakeValue()
38 InternalKey key(std::string(buf), 0, ValueType::kTypeValue); in MakeValue()
/rocksdb-6.9/file/
Drandom_access_file_reader.cc44 AlignedBuffer buf; in Read() local
45 buf.Alignment(alignment); in Read()
46 buf.AllocateNewBuffer(read_size); in Read()
51 buf.Capacity() - buf.CurrentSize(), buf.Alignment(), in Read()
54 assert(buf.CurrentSize() == 0); in Read()
76 buf.Size(buf.CurrentSize() + tmp.size()); in Read()
87 scratch = buf.BufferStart(); in Read()
226 AlignedBuffer buf; in MultiRead() local
227 buf.Alignment(alignment); in MultiRead()
228 buf.AllocateNewBuffer(total_len); in MultiRead()
[all …]
Dfilename.cc61 char buf[100]; in MakeFileName() local
62 snprintf(buf, sizeof(buf), "%06llu.%s", in MakeFileName()
64 return buf; in MakeFileName()
156 char buf[100]; in DescriptorFileName() local
157 snprintf(buf, sizeof(buf), "/MANIFEST-%06llu", in DescriptorFileName()
179 snprintf(buf, sizeof(buf), kInfoLogPrefix); in InfoLogPrefix()
182 size_t len = GetInfoLogPrefix(db_absolute_path, buf, sizeof(buf)); in InfoLogPrefix()
200 char buf[50]; in OldInfoLogFileName() local
208 return log_dir + "/" + info_log_prefix.buf + ".old." + buf; in OldInfoLogFileName()
227 char buf[100]; in MetaDatabaseName() local
[all …]
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier_file_buffer.h32 void Append(const char* buf, const size_t size) { in Append() argument
34 memcpy(buf_.get() + pos_, buf, size); in Append()
71 assert(buf); in CacheWriteBufferAllocator()
72 if (buf) { in CacheWriteBufferAllocator()
73 bufs_.push_back(buf); in CacheWriteBufferAllocator()
82 for (auto* buf : bufs_) { in ~CacheWriteBufferAllocator()
83 delete buf; in ~CacheWriteBufferAllocator() local
97 return buf; in Allocate()
101 assert(buf); in Deallocate()
103 buf->Reset(); in Deallocate()
[all …]
Dblock_cache_tier_file.cc147 buf->Append(p, size); in Append()
150 buf->Append(p, free); in Append()
153 assert(!buf->Free()); in Append()
154 assert(buf->Used() == buf->Capacity()); in Append()
157 if (!buf->Free()) { in Append()
374 if (!buf) { in ExpandBuffer()
380 free += buf->Free(); in ExpandBuffer()
381 bufs_.push_back(buf); in ExpandBuffer()
412 assert(!buf->Free() || in DispatchBuffer()
416 buf->FillTrailingZeros(); in DispatchBuffer()
[all …]
/rocksdb-6.9/java/rocksjni/
Dslice.cc41 char* buf = new char[len + 1]; in Java_org_rocksdb_AbstractSlice_createNewSliceFromString() local
42 memcpy(buf, str, len); in Java_org_rocksdb_AbstractSlice_createNewSliceFromString()
43 buf[len] = 0; in Java_org_rocksdb_AbstractSlice_createNewSliceFromString()
139 jbyte* buf = new jbyte[len]; in Java_org_rocksdb_Slice_createNewSlice0() local
166 char* buf = new char[len]; in Java_org_rocksdb_Slice_createNewSlice1() local
167 memcpy(buf, ptrData, len - 1); in Java_org_rocksdb_Slice_createNewSlice1()
168 buf[len - 1] = '\0'; in Java_org_rocksdb_Slice_createNewSlice1()
215 delete[] buf; in Java_org_rocksdb_Slice_clear0()
241 delete[] buf; in Java_org_rocksdb_Slice_disposeInternalBuf()
330 delete[] buf; in Java_org_rocksdb_DirectSlice_clear0()
[all …]
Dcomparatorjnicallback.cc82 void* buf = _env->GetDirectBufferAddress(tlb->jbuf); in ComparatorJniCallback() local
83 delete[] static_cast<char*>(buf); in ComparatorJniCallback()
174 void* buf = env->GetDirectBufferAddress(m_jcompare_buf_a); in ~ComparatorJniCallback() local
175 delete[] static_cast<char*>(buf); in ~ComparatorJniCallback()
183 delete[] static_cast<char*>(buf); in ~ComparatorJniCallback()
191 delete[] static_cast<char*>(buf); in ~ComparatorJniCallback()
199 delete[] static_cast<char*>(buf); in ~ComparatorJniCallback()
207 delete[] static_cast<char*>(buf); in ~ComparatorJniCallback()
595 void* buf = env->GetDirectBufferAddress(jreuse_buffer); in ReuseBuffer() local
596 if (buf == nullptr) { in ReuseBuffer()
[all …]
/rocksdb-6.9/examples/
Dmulti_processes_example.cc79 char buf[sizeof(k)]; in Key() local
80 buf[0] = k & 0xff; in Key()
81 buf[1] = (k >> 8) & 0xff; in Key()
82 buf[2] = (k >> 16) & 0xff; in Key()
83 buf[3] = (k >> 24) & 0xff; in Key()
84 buf[4] = (k >> 32) & 0xff; in Key()
85 buf[5] = (k >> 40) & 0xff; in Key()
86 buf[6] = (k >> 48) & 0xff; in Key()
87 buf[7] = (k >> 56) & 0xff; in Key()
88 ret.append(buf, sizeof(k)); in Key()
[all …]
/rocksdb-6.9/monitoring/
Dhistogram.cc185 char buf[1650]; in ToString() local
186 snprintf(buf, sizeof(buf), in ToString()
189 r.append(buf); in ToString()
190 snprintf(buf, sizeof(buf), in ToString()
193 r.append(buf); in ToString()
194 snprintf(buf, sizeof(buf), in ToString()
199 r.append(buf); in ToString()
208 snprintf(buf, sizeof(buf), in ToString()
216 r.append(buf); in ToString()
/rocksdb-6.9/env/
Denv_encryption.cc199 AlignedBuffer buf; in Append() local
210 buf.Size(data.size()); in Append()
211 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in Append()
215 dataToAppend = Slice(buf.BufferStart(), buf.CurrentSize()); in Append()
225 AlignedBuffer buf; in PositionedAppend() local
234 buf.Size(data.size()); in PositionedAppend()
235 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in PositionedAppend()
239 dataToAppend = Slice(buf.BufferStart(), buf.CurrentSize()); in PositionedAppend()
330 AlignedBuffer buf; in Write() local
340 status = stream_->Encrypt(offset, buf.BufferStart(), buf.CurrentSize()); in Write()
[all …]
/rocksdb-6.9/utilities/blob_db/
Dblob_dump_tool.cc248 char buf[100]; in DumpSlice() local
250 memset(buf, 0, sizeof(buf)); in DumpSlice()
253 snprintf(buf + j * 3 + 15, 2, "%x", c >> 4); in DumpSlice()
254 snprintf(buf + j * 3 + 16, 2, "%x", c & 0xf); in DumpSlice()
255 snprintf(buf + j + 65, 2, "%c", (0x20 <= c && c <= 0x7e) ? c : '.'); in DumpSlice()
257 for (size_t p = 0; p < sizeof(buf) - 1; p++) { in DumpSlice()
258 if (buf[p] == 0) { in DumpSlice()
259 buf[p] = ' '; in DumpSlice()
262 fprintf(stdout, "%s\n", i == 0 ? buf + 15 : buf); in DumpSlice()
Dblob_log_writer.cc85 std::string buf; in AddRecord() local
86 ConstructBlobHeader(&buf, key, val, expiration); in AddRecord()
88 Status s = EmitPhysicalRecord(buf, key, val, key_offset, blob_offset); in AddRecord()
97 std::string buf; in AddRecord() local
98 ConstructBlobHeader(&buf, key, val, 0); in AddRecord()
100 Status s = EmitPhysicalRecord(buf, key, val, key_offset, blob_offset); in AddRecord()
104 void Writer::ConstructBlobHeader(std::string* buf, const Slice& key, in ConstructBlobHeader() argument
110 record.EncodeHeaderTo(buf); in ConstructBlobHeader()
/rocksdb-6.9/memtable/
Dinlineskiplist_test.cc67 char* buf = list->AllocateKey(sizeof(Key)); in Insert() local
68 memcpy(buf, &key, sizeof(Key)); in Insert()
69 list->Insert(buf); in Insert()
74 char* buf = list->AllocateKey(sizeof(Key)); in InsertWithHint() local
75 memcpy(buf, &key, sizeof(Key)); in InsertWithHint()
138 memcpy(buf, &key, sizeof(Key)); in TEST_F()
139 list.Insert(buf); in TEST_F()
409 memcpy(buf, &new_key, sizeof(Key)); in WriteStep()
410 list_.Insert(buf); in WriteStep()
419 memcpy(buf, &new_key, sizeof(Key)); in ConcurrentWriteStep()
[all …]
/rocksdb-6.9/table/
Dmock_table.cc108 char buf[4]; in GetAndWriteNextID() local
109 EncodeFixed32(buf, next_id); in GetAndWriteNextID()
110 file->Append(Slice(buf, 4)); in GetAndWriteNextID()
115 char buf[4]; in GetIDFromFile() local
117 file->Read(0, 4, &result, buf, nullptr); in GetIDFromFile()
119 return DecodeFixed32(buf); in GetIDFromFile()

12345