Home
last modified time | relevance | path

Searched refs:self (Results 1 – 25 of 26) sorted by relevance

12

/rocksdb-6.9/tools/
Dldb_test.py91 self.assertRunOKFull("%s %s" % (self.dbParam(self.DB_NAME), params),
263 self.assertTrue(self.loadDb(
272 self.assertTrue(self.loadDb(
280 self.assertTrue(self.dumpDb(
282 self.assertTrue(self.loadDb(
289 self.assertTrue(self.dumpDb(
291 self.assertTrue(self.loadDb(
306 self.assertTrue(self.loadDb(
319 self.assertTrue(self.dumpDb(
321 self.assertTrue(self.loadDb(
[all …]
/rocksdb-6.9/tools/block_cache_analyzer/
Dblock_cache_pysim.py147 return "k={},h={},v=[{}]".format(self.key, self.hash, self.value)
1067 self.A = np.zeros((len(self.policies), self.nfeatures, self.nfeatures))
1068 self.A_inv = np.zeros((len(self.policies), self.nfeatures, self.nfeatures))
1084 self.th_hat[a] = self.A_inv[a].dot(self.b[a])
1127 self.key, self.next_access_seq_no, self.value_size, self.is_removed
1257 self.key, self.next_access_seq_no, self.value_size, self.is_removed
1377 if self.t1 and ((key in self.b2) or (len(self.t1) > self.p)):
1408 self.p = min(self.c, self.p + max(len(self.b2) / len(self.b1), 1))
1417 self.p = max(0, self.p - max(len(self.b1) / len(self.b2), 1))
1425 while len(self.t1) + len(self.b1) >= self.c and self.b1:
[all …]
/rocksdb-6.9/tools/advisor/advisor/
Drule_parser.py15 def __init__(self, name): argument
16 self.name = name
23 def perform_checks(self): argument
58 if not self.conditions or len(self.conditions) < 1:
62 if not self.suggestions or len(self.suggestions) < 1:
194 def __repr__(self): argument
246 self.action = self.Action[value]
261 if self.action is self.Action.set and not self.suggested_values:
266 def __repr__(self): argument
272 ' option : ' + self.option + ' action : ' + self.action.name
[all …]
Ddb_stats_fetcher.py49 self.duration_sec = 60
224 self.keys_ts = {}
245 self.keys_ts = {}
264 self._get_string_in_quotes(self.entities),
266 self._get_string_in_quotes(self.start_time),
267 self._get_string_in_quotes(self.end_time)
276 '--stime=' + self._get_ods_cli_stime(self.start_time) + ' ' +
277 self._get_string_in_quotes(self.entities) + ' ' +
320 self._get_string_in_quotes(self.start_time),
321 self._get_string_in_quotes(self.end_time),
[all …]
Ddb_log_parser.py23 def __init__(self, type): argument
24 self.type = type
58 return self.time
63 def get_context(self): argument
64 return self.context
66 def get_message(self): argument
67 return self.message
70 self.message = self.message + '\n' + remaining_log.strip()
72 def get_timestamp(self): argument
80 def __repr__(self): argument
[all …]
Ddb_bench_runner.py48 self.benchmark = positional_args[1]
49 self.db_bench_args = None
54 self.ods_args = ods_args
66 self.THROUGHPUT: None, self.DB_PATH: None, self.PERF_CON: None
172 self.db_bench_binary, db_path
176 self._run_command(command)
180 self.db_bench_binary, self.benchmark, db_path
191 def _run_command(self, command): argument
206 self._run_command(command)
233 if self.ods_args:
[all …]
Ddb_timeseries_parser.py27 def __init__(self): argument
30 self.stats_freq_sec = None
33 def get_keys_from_conditions(self, conditions): argument
40 def fetch_timeseries(self, required_statistics): argument
53 if self.stats_freq_sec == 0:
56 if window_sec < self.stats_freq_sec:
57 window_sec = self.stats_freq_sec
99 if stat not in self.keys_ts[entity]:
122 self.fetch_timeseries(reqd_keys)
130 for entity in self.keys_ts:
[all …]
Ddb_options_parser.py126 self.options_dict = None
127 self.column_families = None
137 self.misc_options = {}
145 self.options_dict = {}
179 def get_misc_options(self): argument
182 return self.misc_options
184 def get_column_families(self): argument
185 return self.column_families
187 def get_all_options(self): argument
201 def get_options(self, reqd_options): argument
[all …]
Ddb_config_optimizer.py198 self.bench_runner = bench_runner
199 self.db_options = db_options
200 self.rule_parser = rule_parser
201 self.base_db_path = base_db
203 def run(self): argument
209 options = copy.deepcopy(self.db_options)
211 self.bench_runner.run_experiment(options, self.base_db_path)
214 self.rule_parser.load_rules_from_spec()
215 self.rule_parser.perform_section_checks()
220 self.rule_parser.print_rules(triggered_rules)
[all …]
Dbench_runner.py17 def run_experiment(self): argument
/rocksdb-6.9/build_tools/
Dgnu_parallel5374 return $self->{'failed'}{$self->sshlogin()};
5387 $self->{'failed'}{$self->sshlogin()}++;
5400 delete $self->{'failed'}{$self->sshlogin()};
6233 $self->{'tag'} = $self->{'commandline'}->
6416 $self->{'arg_queue'}->unget($self->pop());
6427 $self->{'arg_queue'}->unget($self->pop());
6450 $self->push($self->{'arg_queue'}->get());
7011 $self->set_seq($self->seq()+1);
7654 $self->{'delta_time'} = $self->{'pct'} * $self->remedian();
7760 link $self->{'idfile'}, $self->{'pidfile'};
[all …]
Dprecommit_checker.py25 self.f = open(self.filename, 'w+', 0)
27 def caption(self, str): argument
29 if self.f:
34 def error(self, str): argument
36 if self.f:
41 def log(self, str): argument
42 if self.f:
55 self.tests = tests
65 stdout=self.log.f, stderr=self.log.f)
138 def run_tests(self): argument
[all …]
Derror_filter.py22 def parse_error(self, line): argument
38 def __init__(self): argument
66 def __init__(self): argument
76 def __init__(self): argument
82 def __init__(self): argument
87 def __init__(self): argument
93 def __init__(self): argument
99 def __init__(self): argument
105 def __init__(self): argument
112 def __init__(self): argument
[all …]
/rocksdb-6.9/tools/advisor/test/
Dtest_rule_parser.py42 def setUp(self): argument
55 self.data_sources = {
67 self.assertFalse(
77 self.data_sources, self.column_families
99 def setUp(self): argument
112 self.data_sources = {
124 self.assertFalse(
130 self.db_rules.trigger_conditions(self.data_sources)
149 self.assertTrue(
162 def setUp(self): argument
[all …]
Dtest_db_bench_runner.py14 def setUp(self): argument
15 self.pos_args = [
21 self.bench_runner = DBBenchRunner(self.pos_args)
26 def test_setup(self): argument
27 self.assertEqual(self.bench_runner.db_bench_binary, self.pos_args[0])
28 self.assertEqual(self.bench_runner.benchmark, self.pos_args[1])
30 set(self.bench_runner.db_bench_args), set(self.pos_args[2:])
60 self.assertEqual(
97 self.pos_args[0] + ' --benchmarks=' + self.pos_args[1] +
104 def setUp(self): argument
[all …]
Dtest_db_options_parser.py14 def setUp(self): argument
23 self.db_options = DatabaseOptions(self.og_options, misc_options)
66 def test_is_misc_option(self): argument
68 self.assertFalse(
72 def test_set_up(self): argument
78 self.assertDictEqual(
81 self.assertListEqual(
85 def test_get_options(self): argument
147 self.assertDictEqual(
153 self.assertFalse(os.path.isfile(self.generated_options))
[all …]
Dtest_db_log_parser.py13 def setUp(self): argument
16 def test_get_column_family(self): argument
32 def test_get_methods(self): argument
44 self.assertEqual(
49 self.assertEqual(
53 def test_is_new_log(self): argument
56 self.assertTrue(Log.is_new_log(new_log))
61 def test_check_and_trigger_conditions(self): argument
80 self.assertSetEqual(
91 self.assertEqual(
[all …]
Dtest_db_stats_fetcher.py16 def setUp(self): argument
22 self.stats_dict = {NO_ENTITY: {}}
26 self.stats_dict[NO_ENTITY][stat_name] = {}
33 self.log_stats_parser.keys_ts = self.stats_dict
35 def test_check_and_trigger_conditions_bursty(self): argument
37 self.log_stats_parser.fetch_timeseries = MagicMock()
53 def test_check_and_trigger_conditions_eval_agg(self): argument
55 self.log_stats_parser.fetch_timeseries = MagicMock()
71 self.assertIsNone(cond1.get_trigger())
80 def test_check_and_trigger_conditions_eval(self): argument
[all …]
/rocksdb-6.9/buckifier/
Dtargets_builder.py29 self.path = path
32 self.total_lib = 0
33 self.total_bin = 0
34 self.total_test = 0
35 self.tests_cfg = ""
37 def __del__(self): argument
51 self.total_lib = self.total_lib + 1
58 self.total_bin = self.total_bin + 1
76 self.total_test = self.total_test + 1
78 def flush_tests(self): argument
[all …]
/rocksdb-6.9/java/src/main/java/org/rocksdb/
DAbstractMutableOptions.java63 protected abstract U self(); in self() method in AbstractMutableOptions.AbstractMutableOptionsBuilder
103 return self(); in setDouble()
122 return self(); in setLong()
141 return self(); in setInt()
160 return self(); in setBoolean()
179 return self(); in setIntArray()
198 return self(); in setEnum()
DMutableDBOptions.java127 protected MutableDBOptionsBuilder self() { in self() method in MutableDBOptions.MutableDBOptionsBuilder
DMutableColumnFamilyOptions.java174 protected MutableColumnFamilyOptionsBuilder self() { in self() method in MutableColumnFamilyOptions.MutableColumnFamilyOptionsBuilder
/rocksdb-6.9/docs/_sass/
D_search.scss7 align-self: center;
/rocksdb-6.9/java/
DRELEASE.md3 RocksDB can be built as a single self contained cross-platform JAR. The cross-platform jar can be u…
/rocksdb-6.9/db/
Dwrite_thread.h306 void ExitAsMemTableWriter(Writer* self, WriteGroup& write_group);

12