Home
last modified time | relevance | path

Searched refs:scratch (Results 1 – 25 of 60) sorted by relevance

123

/rocksdb-6.9/db/
Dlog_reader.cc56 scratch->clear(); in ReadRecord()
79 scratch->clear(); in ReadRecord()
115 *record = Slice(*scratch); in ReadRecord()
137 scratch->clear(); in ReadRecord()
152 scratch->clear(); in ReadRecord()
162 scratch->clear(); in ReadRecord()
171 scratch->clear(); in ReadRecord()
182 scratch->clear(); in ReadRecord()
193 scratch->clear(); in ReadRecord()
402 assert(scratch != nullptr); in ReadRecord()
[all …]
Ddb_encryption_test.cc52 std::string scratch; in TEST_F() local
53 scratch.reserve(fileSize); in TEST_F()
55 status = seqFile->Read(fileSize, &data, (char*)scratch.data()); in TEST_F()
104 std::string scratch; in TEST_F() local
108 status = seqFile->Read(16, &data, (char*)scratch.data()); in TEST_F()
/rocksdb-6.9/file/
Dsequence_file_reader.cc25 Status SequentialFileReader::Read(size_t n, Slice* result, char* scratch) { in Read() argument
43 r = buf.Read(scratch, offset_advance, in Read()
46 *result = Slice(scratch, r); in Read()
49 s = file_->Read(n, IOOptions(), result, scratch, nullptr); in Read()
97 if (TryReadFromCache(n, &cached_len, scratch) && in Read()
100 *result = Slice(scratch, cached_len); in Read()
108 s = file_->Read(n, opts, result, scratch + cached_len, dbg); in Read()
111 *result = Slice(scratch, cached_len + result->size()); in Read()
121 TryReadFromCache(n, &remaining_len, scratch + cached_len); in Read()
122 *result = Slice(scratch, cached_len + remaining_len); in Read()
[all …]
Dreadahead_raf.cc39 char* scratch) const override { in Read()
42 return file_->Read(offset, n, result, scratch); in Read()
52 if (TryReadFromCache(offset, n, &cached_len, scratch) && in Read()
55 *result = Slice(scratch, cached_len); in Read()
68 scratch + cached_len); in Read()
69 *result = Slice(scratch, cached_len + remaining_len); in Read()
112 char* scratch) const { in TryReadFromCache()
121 memcpy(scratch, buffer_.BufferStart() + offset_in_buffer, *cached_len); in TryReadFromCache()
Drandom_access_file_reader_test.cc129 r0.scratch = nullptr; in TEST_F()
134 r1.scratch = nullptr; in TEST_F()
160 r0.scratch = nullptr; in TEST_F()
165 r1.scratch = nullptr; in TEST_F()
170 r2.scratch = nullptr; in TEST_F()
197 r0.scratch = nullptr; in TEST_F()
202 r1.scratch = nullptr; in TEST_F()
207 r2.scratch = nullptr; in TEST_F()
232 r0.scratch = nullptr; in TEST_F()
237 r1.scratch = nullptr; in TEST_F()
Drandom_access_file_reader.cc25 char* scratch, AlignedBuf* aligned_buf, in Read() argument
85 buf.Read(scratch, offset_advance, res_len); in Read()
87 scratch = buf.BufferStart(); in Read()
91 *result = Slice(scratch, res_len); in Read()
122 scratch + pos, nullptr); in Read()
166 req.scratch = nullptr; in Align()
229 char* scratch = buf.BufferStart(); in MultiRead() local
231 r.scratch = scratch; in MultiRead()
232 scratch += r.len; in MultiRead()
266 r.result = Slice(fs_r.scratch + offset, len); in MultiRead()
/rocksdb-6.9/utilities/
Denv_mirror_test.cc118 char scratch[100]; in TEST_F() local
129 ASSERT_OK(seq_file->Read(5, &result, scratch)); // Read "hello". in TEST_F()
132 ASSERT_OK(seq_file->Read(1000, &result, scratch)); // Read "world". in TEST_F()
137 ASSERT_OK(seq_file->Read(1000, &result, scratch)); in TEST_F()
142 ASSERT_OK(rand_file->Read(6, 5, &result, scratch)); // Read "world". in TEST_F()
146 ASSERT_OK(rand_file->Read(10, 100, &result, scratch)); // Read "d". in TEST_F()
150 ASSERT_TRUE(!rand_file->Read(1000, 5, &result, scratch).ok()); in TEST_F()
178 char* scratch = new char[kWriteSize * 2]; in TEST_F() local
194 ASSERT_OK(seq_file->Read(3, &result, scratch)); // Read "foo". in TEST_F()
200 ASSERT_OK(seq_file->Read(kWriteSize - read, &result, scratch)); in TEST_F()
[all …]
Denv_mirror.cc24 Status Read(size_t n, Slice* result, char* scratch) override { in Read() argument
26 Status as = a_->Read(n, &aslice, scratch); in Read()
35 assert(memcmp(bscratch, scratch + off, bslice.size()) == 0); in Read()
42 Status bs = b_->Read(n, result, scratch); in Read()
69 char* scratch) const override { in Read()
70 Status as = a_->Read(offset, n, result, scratch); in Read()
79 assert(memcmp(bscratch, scratch + off, bslice.size()) == 0); in Read()
85 Status bs = b_->Read(offset, n, result, scratch); in Read()
Denv_librados_test.cc177 char scratch[100]; in TEST_F() local
188 ASSERT_OK(seq_file->Read(5, &result, scratch)); // Read "hello". in TEST_F()
196 ASSERT_OK(seq_file->Read(1000, &result, scratch)); in TEST_F()
209 ASSERT_OK(rand_file->Read(1000, 5, &result, scratch)); in TEST_F()
246 char* scratch = new char[kWriteSize * 2]; in TEST_F() local
263 ASSERT_OK(seq_file->Read(3, &result, scratch)); // Read "foo". in TEST_F()
269 ASSERT_OK(seq_file->Read(kWriteSize - read, &result, scratch)); in TEST_F()
274 delete[] scratch; in TEST_F()
279 char* scratch = new char[kWriteSize * 2]; in TEST_F() local
299 ASSERT_OK(seq_file->Read(3, &result, scratch)); // Read "foo". in TEST_F()
[all …]
/rocksdb-6.9/env/
Denv_encryption.cc47 assert(scratch); in Read()
94 assert(scratch); in PositionedRead()
129 assert(scratch); in Read()
355 assert(scratch); in Read()
700 std::string scratch; in Encrypt() local
701 AllocateScratch(scratch); in Encrypt()
745 std::string scratch; in Decrypt() local
746 AllocateScratch(scratch); in Decrypt()
807 scratch.reserve(blockSize); in AllocateScratch()
820 auto status = cipher_.Encrypt(scratch); in EncryptBlock()
[all …]
Denv_basic_test.cc213 char scratch[100]; in TEST_P() local
223 ASSERT_OK(seq_file->Read(5, &result, scratch)); // Read "hello". in TEST_P()
226 ASSERT_OK(seq_file->Read(1000, &result, scratch)); // Read "world". in TEST_P()
231 ASSERT_OK(seq_file->Read(1000, &result, scratch)); in TEST_P()
236 ASSERT_OK(rand_file->Read(6, 5, &result, scratch)); // Read "world". in TEST_P()
240 ASSERT_OK(rand_file->Read(10, 100, &result, scratch)); // Read "d". in TEST_P()
244 ASSERT_TRUE(rand_file->Read(1000, 5, &result, scratch).ok()); in TEST_P()
260 char* scratch = new char[kWriteSize * 2]; in TEST_P() local
277 ASSERT_OK(seq_file->Read(3, &result, scratch)); // Read "foo". in TEST_P()
283 ASSERT_OK(seq_file->Read(kWriteSize - read, &result, scratch)); in TEST_P()
[all …]
Dmock_env_test.cc37 std::string scratch; in TEST_F() local
38 scratch.resize(kGood.size() + kCorrupted.size() + 16); in TEST_F()
42 ASSERT_OK(rand_file->Read(0, kGood.size(), &result, &(scratch[0]))); in TEST_F()
49 ASSERT_OK(rand_file->Read(0, kGood.size(), &result, &(scratch[0]))); in TEST_F()
57 &result, &(scratch[0]))); in TEST_F()
63 &result, &(scratch[0]))); in TEST_F()
Dio_posix.cc238 r = fread_unlocked(scratch, 1, n, file_); in Read()
240 *result = Slice(scratch, r); in Read()
267 char* ptr = scratch; in PositionedRead()
291 *result = Slice(scratch, (r < 0) ? 0 : n - left); in PositionedRead()
568 char* scratch, in Read() argument
578 char* ptr = scratch; in Read()
603 *result = Slice(scratch, (r < 0) ? 0 : n - left); in Read()
692 req->result = Slice(req->scratch, 0); in MultiRead()
719 req->result = Slice(req->scratch, 0); in MultiRead()
1402 char* ptr = scratch; in Read()
[all …]
Dcomposite_env_wrapper.h29 Status Read(size_t n, Slice* result, char* scratch) override { in Read() argument
32 return target_->Read(n, io_opts, result, scratch, &dbg); in Read()
43 char* scratch) override { in PositionedRead() argument
60 char* scratch) const override { in Read() argument
63 return target_->Read(offset, n, io_opts, result, scratch, &dbg); in Read()
75 fs_reqs[i].scratch = reqs[i].scratch; in MultiRead()
226 char* scratch) const override { in Read() argument
638 target_->PositionedRead(offset, n, result, scratch)); in PositionedRead()
653 Slice* result, char* scratch, in Read() argument
669 req.scratch = fs_reqs[i].scratch; in MultiRead()
[all …]
Dmock_env.cc103 Status Read(uint64_t offset, size_t n, Slice* result, char* scratch) const { in Read()
114 if (scratch) { in Read()
115 memcpy(scratch, &(data_[offset_]), n); in Read()
116 *result = Slice(scratch, n); in Read()
188 Status Read(size_t n, Slice* result, char* scratch) override { in Read() argument
189 Status s = file_->Read(pos_, n, result, scratch); in Read()
220 char* scratch) const override { in Read()
221 return file_->Read(offset, n, result, scratch); in Read()
239 char* scratch) const override { in Read()
240 return file_->Read(offset, n, result, scratch); in Read()
Denv_hdfs.cc85 virtual Status Read(size_t n, Slice* result, char* scratch) { in Read() argument
90 char* buffer = scratch; in Read()
115 *result = Slice(scratch, total_bytes_read); in Read()
123 char* scratch) const { in Read()
128 (void*)scratch, (tSize)n); in Read()
131 *result = Slice(scratch, (bytes_read < 0) ? 0 : bytes_read); in Read()
Dio_posix.h140 char* scratch, IODebugContext* dbg) override;
143 char* scratch, IODebugContext* dbg) override;
194 Slice* result, char* scratch,
286 Slice* result, char* scratch,
357 Slice* result, char* scratch,
/rocksdb-6.9/port/win/
Dio_win.cc214 char* scratch) const { in Read()
601 *result = Slice(scratch, r); in Read()
611 char* scratch) { in PositionedRead() argument
627 *result = Slice(scratch, bytes_read); in PositionedRead()
678 char* scratch) const { in ReadImpl()
685 !IsAligned(alignment_, scratch)) { in ReadImpl()
692 *result = Slice(scratch, 0); in ReadImpl()
698 *result = Slice(scratch, bytes_read); in ReadImpl()
715 char* scratch) const { in Read()
716 return ReadImpl(offset, n, result, scratch); in Read()
[all …]
Dio_win.h113 virtual Status Read(size_t n, Slice* result, char* scratch) override;
115 char* scratch) override;
142 char* scratch) const override;
246 char* scratch) const;
269 char* scratch) const override;
406 char* scratch) const override;
/rocksdb-6.9/db/compaction/
Dcompaction.cc403 InputLevelSummaryBuffer* scratch) const { in InputLevelSummary()
412 snprintf(scratch->buffer + len, sizeof(scratch->buffer) - len, " + "); in InputLevelSummary()
413 len = std::min(len, static_cast<int>(sizeof(scratch->buffer))); in InputLevelSummary()
417 len += snprintf(scratch->buffer + len, sizeof(scratch->buffer) - len, in InputLevelSummary()
420 len = std::min(len, static_cast<int>(sizeof(scratch->buffer))); in InputLevelSummary()
422 snprintf(scratch->buffer + len, sizeof(scratch->buffer) - len, in InputLevelSummary()
425 return scratch->buffer; in InputLevelSummary()
/rocksdb-6.9/utilities/persistent_cache/
Dblock_cache_tier_file.h161 bool Read(const LBA& lba, Slice* key, Slice* block, char* scratch) override;
168 bool ParseRec(const LBA& lba, Slice* key, Slice* val, char* scratch);
195 bool Read(const LBA& lba, Slice* key, Slice* block, char* scratch) override { in Read() argument
200 return RandomAccessCacheFile::Read(lba, key, block, scratch); in Read()
203 return ReadBuffer(lba, key, block, scratch); in Read()
216 bool ReadBuffer(const LBA& lba, Slice* key, Slice* block, char* scratch);
Dblock_cache_tier_file.cc228 char* scratch) { in Read() argument
238 Status s = freader_->Read(lba.off_, lba.size_, &result, scratch, nullptr); in Read()
245 assert(result.data() == scratch); in Read()
247 return ParseRec(lba, key, val, scratch); in Read()
251 char* scratch) { in ParseRec() argument
252 Slice data(scratch, lba.size_); in ParseRec()
451 char* scratch) { in ReadBuffer() argument
454 if (!ReadBuffer(lba, scratch)) { in ReadBuffer()
460 return ParseRec(lba, key, block, scratch); in ReadBuffer()
/rocksdb-6.9/include/rocksdb/
Denv_encryption.h47 char* scratch) = 0;
52 char* scratch) = 0;
123 char* scratch) override;
128 char* scratch) override;
Dfile_system.h547 char* scratch, IODebugContext* dbg) = 0;
596 char* scratch; member
624 Slice* result, char* scratch,
919 Slice* result, char* scratch,
1207 char* scratch, IODebugContext* dbg) override { in Read() argument
1208 return target_->Read(n, options, result, scratch, dbg); in Read()
1219 Slice* result, char* scratch, in PositionedRead() argument
1234 Slice* result, char* scratch, in Read() argument
1236 return target_->Read(offset, n, options, result, scratch, dbg); in Read()
1360 Slice* result, char* scratch, in Read() argument
[all …]
Denv.h626 char* scratch; member
653 char* scratch) const = 0;
932 char* scratch) const = 0;
1409 Status Read(size_t n, Slice* result, char* scratch) override { in Read() argument
1410 return target_->Read(n, result, scratch); in Read()
1421 char* scratch) override { in PositionedRead() argument
1422 return target_->PositionedRead(offset, n, result, scratch); in PositionedRead()
1435 char* scratch) const override { in Read() argument
1436 return target_->Read(offset, n, result, scratch); in Read()
1542 char* scratch) const override { in Read() argument
[all …]

123