Lines Matching refs:s
54 Status s = CreateLoggerFromOptions(dbname, result, &result.info_log); in SanitizeOptions() local
55 if (!s.ok()) { in SanitizeOptions()
181 Status s; in SanitizeOptionsByTable() local
183 s = cf.options.table_factory->SanitizeOptions(db_opts, cf.options); in SanitizeOptionsByTable()
184 if (!s.ok()) { in SanitizeOptionsByTable()
185 return s; in SanitizeOptionsByTable()
195 Status s; in ValidateOptions() local
197 s = ColumnFamilyData::ValidateOptions(db_options, cfd.options); in ValidateOptions()
198 if (!s.ok()) { in ValidateOptions()
199 return s; in ValidateOptions()
202 s = ValidateOptions(db_options); in ValidateOptions()
203 return s; in ValidateOptions()
258 Status s = SetIdentityFile(env_, dbname_); in NewDB() local
259 if (!s.ok()) { in NewDB()
260 return s; in NewDB()
276 s = NewWritableFile(fs_.get(), manifest, &file, file_options); in NewDB()
277 if (!s.ok()) { in NewDB()
278 return s; in NewDB()
288 s = log.AddRecord(record); in NewDB()
289 if (s.ok()) { in NewDB()
290 s = SyncManifest(env_, &immutable_db_options_, log.file()); in NewDB()
293 if (s.ok()) { in NewDB()
295 s = SetCurrentFile(fs_.get(), dbname_, 1, directories_.GetDbDir()); in NewDB()
299 return s; in NewDB()
360 Status s = directories_.SetDirectories(fs_.get(), dbname_, in Recover() local
363 if (!s.ok()) { in Recover()
364 return s; in Recover()
367 s = env_->LockFile(LockFileName(dbname_), &db_lock_); in Recover()
368 if (!s.ok()) { in Recover()
369 return s; in Recover()
373 s = env_->FileExists(current_fname); in Recover()
374 if (s.IsNotFound()) { in Recover()
376 s = NewDB(); in Recover()
378 if (!s.ok()) { in Recover()
379 return s; in Recover()
385 } else if (s.ok()) { in Recover()
392 assert(s.IsIOError()); in Recover()
393 return s; in Recover()
401 s = fs_->NewRandomAccessFile(current_fname, customized_fs, &idfile, in Recover()
403 if (!s.ok()) { in Recover()
404 std::string error_str = s.ToString(); in Recover()
407 s = fs_->NewRandomAccessFile(current_fname, customized_fs, &idfile, in Recover()
409 if (s.ok()) { in Recover()
420 Status s; in Recover() local
423 s = versions_->Recover(column_families, read_only, &db_id_); in Recover()
425 s = versions_->TryRecover(column_families, read_only, &db_id_, in Recover()
427 if (s.ok()) { in Recover()
428 s = CleanupFilesAfterRecovery(); in Recover()
431 if (!s.ok()) { in Recover()
432 return s; in Recover()
438 s = fs_->FileExists(IdentityFileName(dbname_), IOOptions(), nullptr); in Recover()
442 if (s.IsNotFound()) { in Recover()
443 s = SetIdentityFile(env_, dbname_); in Recover()
444 if (!s.ok()) { in Recover()
445 return s; in Recover()
447 } else if (!s.ok()) { in Recover()
448 assert(s.IsIOError()); in Recover()
449 return s; in Recover()
451 s = GetDbIdentityFromIdentityFile(&db_id_); in Recover()
452 if (immutable_db_options_.write_dbid_to_manifest && s.ok()) { in Recover()
458 s = versions_->LogAndApply(versions_->GetColumnFamilySet()->GetDefault(), in Recover()
463 s = SetIdentityFile(env_, dbname_, db_id_); in Recover()
466 if (immutable_db_options_.paranoid_checks && s.ok()) { in Recover()
467 s = CheckConsistency(); in Recover()
469 if (s.ok() && !read_only) { in Recover()
472 s = cfd->AddDirectories(&created_dirs); in Recover()
473 if (!s.ok()) { in Recover()
474 return s; in Recover()
479 if (s.ok() && immutable_db_options_.persist_stats_to_disk) { in Recover()
480 s = InitPersistStatsColumnFamily(); in Recover()
483 if (s.ok()) { in Recover()
511 s = env_->GetChildren(immutable_db_options_.wal_dir, &filenames); in Recover()
513 if (s.IsNotFound()) { in Recover()
516 } else if (!s.ok()) { in Recover()
517 return s; in Recover()
545 s = env_->GetFileSize(fname, &bytes); in Recover()
546 if (s.ok()) { in Recover()
561 s = RecoverLogFiles(logs, &next_sequence, read_only, in Recover()
566 if (!s.ok()) { in Recover()
582 if (s.ok()) { in Recover()
583 s = env_->GetChildren(GetName(), &file_names); in Recover()
585 if (s.ok()) { in Recover()
598 return s; in Recover()
603 Status s; in PersistentStatsProcessFormatVersion() local
642 s = CreateColumnFamily(cfo, kPersistentStatsColumnFamilyName, &handle); in PersistentStatsProcessFormatVersion()
648 if (s.ok() && should_persist_format_version) { in PersistentStatsProcessFormatVersion()
660 s = Write(wo, &batch); in PersistentStatsProcessFormatVersion()
663 return s; in PersistentStatsProcessFormatVersion()
674 Status s; in InitPersistStatsColumnFamily() local
686 s = CreateColumnFamily(cfo, kPersistentStatsColumnFamilyName, &handle); in InitPersistStatsColumnFamily()
690 return s; in InitPersistStatsColumnFamily()
702 void Corruption(size_t bytes, const Status& s) override { in RecoverLogFiles()
705 fname, static_cast<int>(bytes), s.ToString().c_str()); in RecoverLogFiles()
707 *this->status = s; in RecoverLogFiles()
1141 Status s; in RestoreAliveLogFiles() local
1155 s = env_->GetFileSize(fname, &log.size); in RestoreAliveLogFiles()
1156 if (!s.ok()) { in RestoreAliveLogFiles()
1189 return s; in RestoreAliveLogFiles()
1204 Status s; in WriteLevel0TableForRecovery() local
1243 s = BuildTable( in WriteLevel0TableForRecovery()
1260 meta.fd.GetFileSize(), s.ToString().c_str()); in WriteLevel0TableForRecovery()
1269 if (s.ok() && meta.fd.GetFileSize() > 0) { in WriteLevel0TableForRecovery()
1286 return s; in WriteLevel0TableForRecovery()
1300 Status s = DB::Open(db_options, dbname, column_families, &handles, dbptr); in Open() local
1301 if (s.ok()) { in Open()
1314 return s; in Open()
1328 Status s; in CreateWAL() local
1346 s = fs_->ReuseWritableFile(log_fname, old_log_fname, opt_file_options, in CreateWAL()
1349 s = NewWritableFile(fs_.get(), log_fname, &lfile, opt_file_options); in CreateWAL()
1352 if (s.ok()) { in CreateWAL()
1364 return s; in CreateWAL()
1371 Status s = SanitizeOptionsByTable(db_options, column_families); in Open() local
1372 if (!s.ok()) { in Open()
1373 return s; in Open()
1376 s = ValidateOptions(db_options, column_families); in Open()
1377 if (!s.ok()) { in Open()
1378 return s; in Open()
1391 s = impl->env_->CreateDirIfMissing(impl->immutable_db_options_.wal_dir); in Open()
1392 if (s.ok()) { in Open()
1403 s = impl->env_->CreateDirIfMissing(path); in Open()
1404 if (!s.ok()) { in Open()
1415 if (s.ok()) { in Open()
1416 s = impl->CreateArchivalDirectory(); in Open()
1418 if (!s.ok()) { in Open()
1420 return s; in Open()
1428 s = impl->Recover(column_families, false, false, false, &recovered_seq); in Open()
1429 if (s.ok()) { in Open()
1434 s = impl->CreateWAL(new_log_number, 0 /*recycle_log_number*/, in Open()
1436 if (s.ok()) { in Open()
1443 if (s.ok()) { in Open()
1457 s = impl->CreateColumnFamily(cf.options, cf.name, &handle); in Open()
1459 if (s.ok()) { in Open()
1465 s = Status::InvalidArgument("Column family not found: ", cf.name); in Open()
1471 if (s.ok()) { in Open()
1488 s = impl->directories_.GetDbDir()->Fsync(IOOptions(), nullptr); in Open()
1490 if (s.ok()) { in Open()
1506 s = impl->WriteToWAL(empty_batch, log_writer, &log_used, &log_size); in Open()
1507 if (s.ok()) { in Open()
1509 s = impl->FlushWAL(false); in Open()
1510 if (s.ok()) { in Open()
1511 s = log_writer->file()->Sync(impl->immutable_db_options_.use_fsync); in Open()
1517 if (s.ok() && impl->immutable_db_options_.persist_stats_to_disk) { in Open()
1519 s = impl->PersistentStatsProcessFormatVersion(); in Open()
1522 if (s.ok()) { in Open()
1529 s = Status::InvalidArgument( in Open()
1541 s = Status::InvalidArgument( in Open()
1546 if (!s.ok()) { in Open()
1553 if (s.ok()) { in Open()
1568 if (s.ok() && sfm) { in Open()
1633 if (s.ok()) { in Open()
1641 s = Status::IOError( in Open()
1646 if (s.ok()) { in Open()
1649 if (!s.ok()) { in Open()
1657 return s; in Open()