Lines Matching refs:s
355 Status s; in PrepareProcessing() local
357 s = NewFileTraceReader(env_, env_options_, trace_name_, &trace_reader_); in PrepareProcessing()
358 if (!s.ok()) { in PrepareProcessing()
359 return s; in PrepareProcessing()
367 s = env_->NewWritableFile(trace_sequence_name, &trace_sequence_f_, in PrepareProcessing()
369 if (!s.ok()) { in PrepareProcessing()
370 return s; in PrepareProcessing()
379 s = env_->NewWritableFile(qps_stats_name, &qps_f_, env_options_); in PrepareProcessing()
380 if (!s.ok()) { in PrepareProcessing()
381 return s; in PrepareProcessing()
386 s = env_->NewWritableFile(qps_stats_name, &cf_qps_f_, env_options_); in PrepareProcessing()
387 if (!s.ok()) { in PrepareProcessing()
388 return s; in PrepareProcessing()
396 Status s = ReadTraceRecord(header); in ReadTraceHeader() local
397 if (!s.ok()) { in ReadTraceHeader()
398 return s; in ReadTraceHeader()
407 return s; in ReadTraceHeader()
412 Status s = ReadTraceRecord(footer); in ReadTraceFooter() local
413 if (!s.ok()) { in ReadTraceFooter()
414 return s; in ReadTraceFooter()
419 return s; in ReadTraceFooter()
425 Status s = trace_reader_->Read(&encoded_trace); in ReadTraceRecord() local
426 if (!s.ok()) { in ReadTraceRecord()
427 return s; in ReadTraceRecord()
435 return s; in ReadTraceRecord()
442 Status s; in StartProcessing() local
444 s = ReadTraceHeader(&header); in StartProcessing()
445 if (!s.ok()) { in StartProcessing()
447 return s; in StartProcessing()
455 while (s.ok()) { in StartProcessing()
457 s = ReadTraceRecord(&trace); in StartProcessing()
458 if (!s.ok()) { in StartProcessing()
479 s = batch.Iterate(&write_handler); in StartProcessing()
480 if (!s.ok()) { in StartProcessing()
482 return s; in StartProcessing()
490 s = HandleGet(cf_id, key.ToString(), trace.ts, 1); in StartProcessing()
491 if (!s.ok()) { in StartProcessing()
493 return s; in StartProcessing()
500 s = HandleIter(cf_id, key.ToString(), trace.ts, trace.type); in StartProcessing()
501 if (!s.ok()) { in StartProcessing()
503 return s; in StartProcessing()
509 if (s.IsIncomplete()) { in StartProcessing()
514 return s; in StartProcessing()
523 Status s; in MakeStatistics() local
559 s = MakeStatisticCorrelation(stat.second, record.second); in MakeStatistics()
560 if (!s.ok()) { in MakeStatistics()
561 return s; in MakeStatistics()
568 s = MakeStatisticKeyStatsOrPrefix(stat.second); in MakeStatistics()
569 if (!s.ok()) { in MakeStatistics()
570 return s; in MakeStatistics()
584 s = stat.second.a_count_dist_f->Append(printout); in MakeStatistics()
585 if (!s.ok()) { in MakeStatistics()
587 return s; in MakeStatistics()
608 s = stat.second.a_key_size_f->Append(printout); in MakeStatistics()
609 if (!s.ok()) { in MakeStatistics()
611 return s; in MakeStatistics()
638 s = stat.second.a_value_size_f->Append(printout); in MakeStatistics()
639 if (!s.ok()) { in MakeStatistics()
641 return s; in MakeStatistics()
650 s = MakeStatisticQPS(); in MakeStatistics()
651 if (!s.ok()) { in MakeStatistics()
652 return s; in MakeStatistics()
663 Status s; in MakeStatisticKeyStatsOrPrefix() local
689 s = stats.a_key_f->Append(printout); in MakeStatisticKeyStatsOrPrefix()
690 if (!s.ok()) { in MakeStatisticKeyStatsOrPrefix()
692 return s; in MakeStatisticKeyStatsOrPrefix()
720 s = stats.a_prefix_cut_f->Append(pout); in MakeStatisticKeyStatsOrPrefix()
721 if (!s.ok()) { in MakeStatisticKeyStatsOrPrefix()
723 return s; in MakeStatisticKeyStatsOrPrefix()
793 Status s; in MakeStatisticQPS() local
824 s = stat.second.a_qps_f->Append(printout); in MakeStatisticQPS()
825 if (!s.ok()) { in MakeStatisticQPS()
827 return s; in MakeStatisticQPS()
836 s = stat.second.a_qps_f->Append(printout); in MakeStatisticQPS()
837 if (!s.ok()) { in MakeStatisticQPS()
839 return s; in MakeStatisticQPS()
886 s = stat.second.a_key_num_f->Append(printout); in MakeStatisticQPS()
887 if (!s.ok()) { in MakeStatisticQPS()
890 return s; in MakeStatisticQPS()
905 s = stat.second.a_top_qps_prefix_f->Append(printout); in MakeStatisticQPS()
906 if (!s.ok()) { in MakeStatisticQPS()
908 return s; in MakeStatisticQPS()
924 s = stat.second.a_top_qps_prefix_f->Append(pout); in MakeStatisticQPS()
925 if (!s.ok()) { in MakeStatisticQPS()
927 return s; in MakeStatisticQPS()
948 s = qps_f_->Append(printout); in MakeStatisticQPS()
949 if (!s.ok()) { in MakeStatisticQPS()
950 return s; in MakeStatisticQPS()
979 s = cf_qps_f_->Append(printout); in MakeStatisticQPS()
980 if (!s.ok()) { in MakeStatisticQPS()
981 return s; in MakeStatisticQPS()
1005 Status s; in ReProcessing() local
1036 s = stat.time_series_f->Append(printout); in ReProcessing()
1037 if (!s.ok()) { in ReProcessing()
1039 return s; in ReProcessing()
1056 s = env_->NewSequentialFile(whole_key_path, &wkey_input_f, env_options_); in ReProcessing()
1057 if (!s.ok()) { in ReProcessing()
1071 ReadOneLine(&iss, &sf_reader, &get_key, &has_data, &s); in ReProcessing()
1073 if (!s.ok()) { in ReProcessing()
1075 return s; in ReProcessing()
1093 s = stat.w_key_f->Append(printout); in ReProcessing()
1094 if (!s.ok()) { in ReProcessing()
1096 return s; in ReProcessing()
1114 s = stat.w_prefix_cut_f->Append(printout); in ReProcessing()
1115 if (!s.ok()) { in ReProcessing()
1118 return s; in ReProcessing()
1184 Status s; in KeyStatsInsertion() local
1230 s = OpenStatsOutputFiles(ta_[type].type_name, ta_[type].stats[cf_id]); in KeyStatsInsertion()
1232 s = StatsUnitCorrelationUpdate(unit, type, ts, key); in KeyStatsInsertion()
1266 s = StatsUnitCorrelationUpdate(found_key->second, type, ts, key); in KeyStatsInsertion()
1376 Status s; in OpenStatsOutputFiles() local
1378 s = CreateOutputFile(type, new_stats.cf_name, "accessed_key_stats.txt", in OpenStatsOutputFiles()
1380 s = CreateOutputFile(type, new_stats.cf_name, in OpenStatsOutputFiles()
1384 s = CreateOutputFile(type, new_stats.cf_name, "whole_key_stats.txt", in OpenStatsOutputFiles()
1390 s = CreateOutputFile(type, new_stats.cf_name, in OpenStatsOutputFiles()
1396 s = CreateOutputFile(type, new_stats.cf_name, "accessed_key_prefix_cut.txt", in OpenStatsOutputFiles()
1399 s = CreateOutputFile(type, new_stats.cf_name, "whole_key_prefix_cut.txt", in OpenStatsOutputFiles()
1404 s = CreateOutputFile(type, new_stats.cf_name, in OpenStatsOutputFiles()
1411 s = CreateOutputFile(type, new_stats.cf_name, "time_series.txt", in OpenStatsOutputFiles()
1416 s = CreateOutputFile(type, new_stats.cf_name, in OpenStatsOutputFiles()
1422 s = CreateOutputFile(type, new_stats.cf_name, in OpenStatsOutputFiles()
1428 s = CreateOutputFile(type, new_stats.cf_name, "qps_stats.txt", in OpenStatsOutputFiles()
1443 Status s; in CreateOutputFile() local
1444 s = env_->NewWritableFile(path, f_ptr, env_options_); in CreateOutputFile()
1445 if (!s.ok()) { in CreateOutputFile()
1510 Status s; in HandleGet() local
1513 s = WriteTraceSequence(TraceOperationType::kGet, column_family_id, key, in HandleGet()
1515 if (!s.ok()) { in HandleGet()
1535 s = KeyStatsInsertion(TraceOperationType::kGet, column_family_id, key, in HandleGet()
1537 if (!s.ok()) { in HandleGet()
1540 return s; in HandleGet()
1546 Status s; in HandlePut() local
1549 s = WriteTraceSequence(TraceOperationType::kPut, column_family_id, in HandlePut()
1551 if (!s.ok()) { in HandlePut()
1568 s = KeyStatsInsertion(TraceOperationType::kPut, column_family_id, in HandlePut()
1570 if (!s.ok()) { in HandlePut()
1573 return s; in HandlePut()
1579 Status s; in HandleDelete() local
1582 s = WriteTraceSequence(TraceOperationType::kDelete, column_family_id, in HandleDelete()
1584 if (!s.ok()) { in HandleDelete()
1601 s = KeyStatsInsertion(TraceOperationType::kDelete, column_family_id, in HandleDelete()
1603 if (!s.ok()) { in HandleDelete()
1606 return s; in HandleDelete()
1612 Status s; in HandleSingleDelete() local
1615 s = WriteTraceSequence(TraceOperationType::kSingleDelete, column_family_id, in HandleSingleDelete()
1617 if (!s.ok()) { in HandleSingleDelete()
1634 s = KeyStatsInsertion(TraceOperationType::kSingleDelete, column_family_id, in HandleSingleDelete()
1636 if (!s.ok()) { in HandleSingleDelete()
1639 return s; in HandleSingleDelete()
1646 Status s; in HandleDeleteRange() local
1649 s = WriteTraceSequence(TraceOperationType::kRangeDelete, column_family_id, in HandleDeleteRange()
1651 if (!s.ok()) { in HandleDeleteRange()
1668 s = KeyStatsInsertion(TraceOperationType::kRangeDelete, column_family_id, in HandleDeleteRange()
1670 s = KeyStatsInsertion(TraceOperationType::kRangeDelete, column_family_id, in HandleDeleteRange()
1672 if (!s.ok()) { in HandleDeleteRange()
1675 return s; in HandleDeleteRange()
1681 Status s; in HandleMerge() local
1684 s = WriteTraceSequence(TraceOperationType::kMerge, column_family_id, in HandleMerge()
1686 if (!s.ok()) { in HandleMerge()
1703 s = KeyStatsInsertion(TraceOperationType::kMerge, column_family_id, in HandleMerge()
1705 if (!s.ok()) { in HandleMerge()
1708 return s; in HandleMerge()
1715 Status s; in HandleIter() local
1723 return s; in HandleIter()
1726 return s; in HandleIter()
1730 s = WriteTraceSequence(type, column_family_id, key, value_size, ts); in HandleIter()
1731 if (!s.ok()) { in HandleIter()
1748 s = KeyStatsInsertion(type, column_family_id, key, value_size, ts); in HandleIter()
1749 if (!s.ok()) { in HandleIter()
1752 return s; in HandleIter()
1959 ROCKSDB_NAMESPACE::Status s = analyzer->PrepareProcessing(); in trace_analyzer_tool() local
1960 if (!s.ok()) { in trace_analyzer_tool()
1961 fprintf(stderr, "%s\n", s.getState()); in trace_analyzer_tool()
1966 s = analyzer->StartProcessing(); in trace_analyzer_tool()
1967 if (!s.ok() && !FLAGS_try_process_corrupted_trace) { in trace_analyzer_tool()
1968 fprintf(stderr, "%s\n", s.getState()); in trace_analyzer_tool()
1973 s = analyzer->MakeStatistics(); in trace_analyzer_tool()
1974 if (!s.ok()) { in trace_analyzer_tool()
1975 fprintf(stderr, "%s\n", s.getState()); in trace_analyzer_tool()
1981 s = analyzer->ReProcessing(); in trace_analyzer_tool()
1982 if (!s.ok()) { in trace_analyzer_tool()
1983 fprintf(stderr, "%s\n", s.getState()); in trace_analyzer_tool()
1989 s = analyzer->EndProcessing(); in trace_analyzer_tool()
1990 if (!s.ok()) { in trace_analyzer_tool()
1991 fprintf(stderr, "%s\n", s.getState()); in trace_analyzer_tool()