Lines Matching refs:target_
1170 explicit EnvWrapper(Env* t) : target_(t) {} in EnvWrapper()
1174 Env* target() const { return target_; } in target()
1178 return target_->RegisterDbPaths(paths); in RegisterDbPaths()
1182 return target_->UnregisterDbPaths(paths); in UnregisterDbPaths()
1188 return target_->NewSequentialFile(f, r, options); in NewSequentialFile()
1193 return target_->NewRandomAccessFile(f, r, options); in NewRandomAccessFile()
1197 return target_->NewWritableFile(f, r, options); in NewWritableFile()
1202 return target_->ReopenWritableFile(fname, result, options); in ReopenWritableFile()
1208 return target_->ReuseWritableFile(fname, old_fname, r, options); in ReuseWritableFile()
1213 return target_->NewRandomRWFile(fname, result, options); in NewRandomRWFile()
1218 return target_->NewMemoryMappedFileBuffer(fname, result); in NewMemoryMappedFileBuffer()
1222 return target_->NewDirectory(name, result); in NewDirectory()
1225 return target_->FileExists(f); in FileExists()
1229 return target_->GetChildren(dir, r); in GetChildren()
1233 return target_->GetChildrenFileAttributes(dir, result); in GetChildrenFileAttributes()
1236 return target_->DeleteFile(f); in DeleteFile()
1239 return target_->Truncate(fname, size); in Truncate()
1242 return target_->CreateDir(d); in CreateDir()
1245 return target_->CreateDirIfMissing(d); in CreateDirIfMissing()
1248 return target_->DeleteDir(d); in DeleteDir()
1251 return target_->GetFileSize(f, s); in GetFileSize()
1256 return target_->GetFileModificationTime(fname, file_mtime); in GetFileModificationTime()
1260 return target_->RenameFile(s, t); in RenameFile()
1264 return target_->LinkFile(s, t); in LinkFile()
1268 return target_->NumFileLinks(fname, count); in NumFileLinks()
1273 return target_->AreFilesSame(first, second, res); in AreFilesSame()
1277 return target_->LockFile(f, l); in LockFile()
1280 Status UnlockFile(FileLock* l) override { return target_->UnlockFile(l); } in UnlockFile()
1285 return target_->LoadLibrary(lib_name, search_path, result); in LoadLibrary()
1290 return target_->Schedule(f, a, pri, tag, u);
1294 return target_->UnSchedule(tag, pri); in UnSchedule()
1298 return target_->StartThread(f, a); in StartThread()
1300 void WaitForJoin() override { return target_->WaitForJoin(); } in WaitForJoin()
1302 return target_->GetThreadPoolQueueLen(pri);
1305 return target_->GetTestDirectory(path); in GetTestDirectory()
1309 return target_->NewLogger(fname, result); in NewLogger()
1311 uint64_t NowMicros() override { return target_->NowMicros(); } in NowMicros()
1312 uint64_t NowNanos() override { return target_->NowNanos(); } in NowNanos()
1313 uint64_t NowCPUNanos() override { return target_->NowCPUNanos(); } in NowCPUNanos()
1316 target_->SleepForMicroseconds(micros); in SleepForMicroseconds()
1319 return target_->GetHostName(name, len); in GetHostName()
1322 return target_->GetCurrentTime(unix_time); in GetCurrentTime()
1326 return target_->GetAbsolutePath(db_path, output_path); in GetAbsolutePath()
1329 return target_->SetBackgroundThreads(num, pri); in SetBackgroundThreads()
1332 return target_->GetBackgroundThreads(pri); in GetBackgroundThreads()
1336 return target_->SetAllowNonOwnerAccess(allow_non_owner_access); in SetAllowNonOwnerAccess()
1340 return target_->IncBackgroundThreadsIfNeeded(num, pri); in IncBackgroundThreadsIfNeeded()
1344 target_->LowerThreadPoolIOPriority(pool);
1348 target_->LowerThreadPoolCPUPriority(pool);
1352 return target_->TimeToString(time); in TimeToString()
1356 return target_->GetThreadList(thread_list); in GetThreadList()
1360 return target_->GetThreadStatusUpdater(); in GetThreadStatusUpdater()
1363 uint64_t GetThreadID() const override { return target_->GetThreadID(); } in GetThreadID()
1366 return target_->GenerateUniqueId(); in GenerateUniqueId()
1370 return target_->OptimizeForLogRead(env_options); in OptimizeForLogRead()
1374 return target_->OptimizeForManifestRead(env_options); in OptimizeForManifestRead()
1378 return target_->OptimizeForLogWrite(env_options, db_options); in OptimizeForLogWrite()
1382 return target_->OptimizeForManifestWrite(env_options); in OptimizeForManifestWrite()
1387 return target_->OptimizeForCompactionTableWrite(env_options, immutable_ops); in OptimizeForCompactionTableWrite()
1392 return target_->OptimizeForCompactionTableRead(env_options, db_options); in OptimizeForCompactionTableRead()
1395 return target_->GetFreeSpace(path, diskfree); in GetFreeSpace()
1398 target_->SanitizeEnvOptions(env_opts); in SanitizeEnvOptions()
1402 Env* target_;
1407 explicit SequentialFileWrapper(SequentialFile* target) : target_(target) {} in SequentialFileWrapper()
1410 return target_->Read(n, result, scratch); in Read()
1412 Status Skip(uint64_t n) override { return target_->Skip(n); } in Skip()
1413 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
1415 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
1418 return target_->InvalidateCache(offset, length); in InvalidateCache()
1422 return target_->PositionedRead(offset, n, result, scratch); in PositionedRead()
1426 SequentialFile* target_;
1432 : target_(target) {} in RandomAccessFileWrapper()
1436 return target_->Read(offset, n, result, scratch); in Read()
1439 return target_->MultiRead(reqs, num_reqs); in MultiRead()
1442 return target_->Prefetch(offset, n); in Prefetch()
1445 return target_->GetUniqueId(id, max_size); in GetUniqueId()
1447 void Hint(AccessPattern pattern) override { target_->Hint(pattern); } in Hint()
1448 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
1450 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
1453 return target_->InvalidateCache(offset, length); in InvalidateCache()
1457 RandomAccessFile* target_;
1462 explicit WritableFileWrapper(WritableFile* t) : target_(t) {} in WritableFileWrapper()
1464 Status Append(const Slice& data) override { return target_->Append(data); } in Append()
1466 return target_->PositionedAppend(data, offset); in PositionedAppend()
1468 Status Truncate(uint64_t size) override { return target_->Truncate(size); } in Truncate()
1469 Status Close() override { return target_->Close(); } in Close()
1470 Status Flush() override { return target_->Flush(); } in Flush()
1471 Status Sync() override { return target_->Sync(); } in Sync()
1472 Status Fsync() override { return target_->Fsync(); } in Fsync()
1473 bool IsSyncThreadSafe() const override { return target_->IsSyncThreadSafe(); } in IsSyncThreadSafe()
1475 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
1478 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
1482 target_->SetIOPriority(pri); in SetIOPriority()
1485 Env::IOPriority GetIOPriority() override { return target_->GetIOPriority(); } in GetIOPriority()
1488 target_->SetWriteLifeTimeHint(hint); in SetWriteLifeTimeHint()
1492 return target_->GetWriteLifeTimeHint(); in GetWriteLifeTimeHint()
1495 uint64_t GetFileSize() override { return target_->GetFileSize(); } in GetFileSize()
1498 target_->SetPreallocationBlockSize(size); in SetPreallocationBlockSize()
1503 target_->GetPreallocationStatus(block_size, last_allocated_block); in GetPreallocationStatus()
1507 return target_->GetUniqueId(id, max_size); in GetUniqueId()
1511 return target_->InvalidateCache(offset, length); in InvalidateCache()
1515 return target_->RangeSync(offset, nbytes); in RangeSync()
1519 target_->PrepareWrite(offset, len); in PrepareWrite()
1523 return target_->Allocate(offset, len); in Allocate()
1527 WritableFile* target_;
1532 explicit RandomRWFileWrapper(RandomRWFile* target) : target_(target) {} in RandomRWFileWrapper()
1534 bool use_direct_io() const override { return target_->use_direct_io(); } in use_direct_io()
1536 return target_->GetRequiredBufferAlignment(); in GetRequiredBufferAlignment()
1539 return target_->Write(offset, data); in Write()
1543 return target_->Read(offset, n, result, scratch); in Read()
1545 Status Flush() override { return target_->Flush(); } in Flush()
1546 Status Sync() override { return target_->Sync(); } in Sync()
1547 Status Fsync() override { return target_->Fsync(); } in Fsync()
1548 Status Close() override { return target_->Close(); } in Close()
1551 RandomRWFile* target_;
1556 explicit DirectoryWrapper(Directory* target) : target_(target) {} in DirectoryWrapper()
1558 Status Fsync() override { return target_->Fsync(); } in Fsync()
1560 return target_->GetUniqueId(id, max_size); in GetUniqueId()
1564 Directory* target_;
1569 explicit LoggerWrapper(Logger* target) : target_(target) {} in LoggerWrapper()
1571 Status Close() override { return target_->Close(); } in Close()
1573 return target_->LogHeader(format, ap); in LogHeader()
1576 return target_->Logv(format, ap); in Logv()
1580 return target_->Logv(log_level, format, ap); in Logv()
1582 size_t GetLogFileSize() const override { return target_->GetLogFileSize(); } in GetLogFileSize()
1583 void Flush() override { return target_->Flush(); } in Flush()
1585 return target_->GetInfoLogLevel(); in GetInfoLogLevel()
1588 return target_->SetInfoLogLevel(log_level); in SetInfoLogLevel()
1592 Logger* target_;