Skip to content

Commit 171b00d

Browse files
committed
fix mensia backend
1 parent 3e512af commit 171b00d

4 files changed

Lines changed: 46 additions & 4 deletions

File tree

config/config.exs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
import Config
22

33
config :kvs,
4-
dba: :kvs_rocks,
5-
dba_st: :kvs_st,
6-
dba_seq: :kvs_rocks,
4+
dba: :kvs_mnesia,
5+
dba_st: :kvs_stream,
6+
dba_seq: :kvs_mnesia,
77
schema: [:kvs, :kvs_stream, BPE.Metainfo]
88

99
config :bpe,

config/config.mnesia.exs

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
import Config
2+
3+
config :kvs,
4+
dba: :kvs_mnesia,
5+
dba_st: :kvs_stream,
6+
dba_seq: :kvs_mnesia,
7+
schema: [:kvs, :kvs_stream, BPE.Metainfo]
8+
9+
config :bpe,
10+
logger_level: :debug,
11+
logger: [{:handler, :synrc, :logger_std_h,
12+
%{level: :debug,
13+
id: :synrc,
14+
module: :logger_std_h,
15+
config: %{type: :file, file: ~c"bpe.log"},
16+
formatter: {:logger_formatter,
17+
%{template: [:time, ~c" ", :pid, ~c" ", :msg, ~c"\n"],
18+
single_line: true,}}}}]

config/config.rocksdb.exs

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
import Config
2+
3+
config :kvs,
4+
dba: :kvs_rocks,
5+
dba_st: :kvs_st,
6+
dba_seq: :kvs_rocks,
7+
schema: [:kvs, :kvs_stream, BPE.Metainfo]
8+
9+
config :bpe,
10+
logger_level: :debug,
11+
logger: [{:handler, :synrc, :logger_std_h,
12+
%{level: :debug,
13+
id: :synrc,
14+
module: :logger_std_h,
15+
config: %{type: :file, file: ~c"bpe.log"},
16+
formatter: {:logger_formatter,
17+
%{template: [:time, ~c" ", :pid, ~c" ", :msg, ~c"\n"],
18+
single_line: true,}}}}]

lib/BPE.ex

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1041,7 +1041,13 @@ defmodule BPE do
10411041
end
10421042
end)
10431043

1044-
case :kvs.get(k, key({:step, writer(w, :count) - 1, id})) do
1044+
tab =
1045+
case :application.get_env(:kvs, :dba, :kvs_mnesia) do
1046+
:kvs_rocks -> k
1047+
:kvs_mnesia -> :hist
1048+
end
1049+
1050+
case :kvs.get(tab, key({:step, writer(w, :count) - 1, id})) do
10451051
{:error, _} -> []
10461052
{:ok, hist() = h} -> :kvs.append(hist(h, executors: new_executed), k)
10471053
end

0 commit comments

Comments
 (0)