Список говнокодов пользователя CHayT

Всего: 86

Куча / Говнокод #27640

0

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

-module(pqueue).

-export([ in/3
        , out/1
        , new/0
        , close/1
        ]).

-type prio() :: non_neg_integer().

-record(priority_queue,
        { tab :: ets:tid()
        }).

-define(size, {size, size}).
-define(seqno(PRIO), {seqno, PRIO}).

-opaque t() :: #priority_queue{}.

-export_type([ prio/0
             , t/0
             ]).

-spec new() -> t().
new() ->
  Tab = ets:new(pqueue_tab, [ordered_set]),
  ets:insert(Tab, {?size, 0}),
  #priority_queue{tab = Tab}.

-spec close(t()) -> ok.
close(#priority_queue{tab = Tab}) ->
  true = ets:delete(Tab),
  ok.

-spec in(term(), prio(), t()) -> ok.
in(Val, Prio, #priority_queue{tab = Tab}) when Prio >= 0 ->
  Key = {get_next_seqno(Tab, Prio), Prio},
  true = ets:insert_new(Tab, {Key, Val}),
  ets:update_counter(Tab, ?size, {2, 1}, {?size, 0}),
  ok.

-spec out(t()) -> {value, term()} | empty.
out(#priority_queue{tab = Tab}) ->
  case ets:first(Tab) of
    Key = {SeqNo, _Prio} when is_integer(SeqNo) ->
      Val = ets:lookup_element(Tab, Key, 2),
      ets:update_counter(Tab, ?size, {2, -1}),
      ets:delete(Tab, Key),
      {value, Val};
    _ ->
      empty
  end.

%% This function generates keys that go in sequence for each
%% individual priority level, but interleave for different priority
%% levels. Keys with lower priority are more sparse, so they are
%% consumed less often in the total sequence
get_next_seqno(Tab, Prio) ->
  Delta = Prio + 1,
  Key = ?seqno(Prio),
  ets:update_counter(Tab, Key, {2, Delta}, {Key, 0}).

Творение безумца или гения.

CHayT, 02 Сентября 2021

Комментарии (3)

bash / Говнокод #27560

+2

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

#!/bin/bash
set -euo pipefail

host() {
    echo "n${1}.local"
}

node() {
    echo "erl@$(host $1)"
}

build() {
    [ "${1}" -eq "1" ] && echo "build: ."
}

container() {
    cat <<EOF
  worker${1}:
    $(build $1)
    image: worker
    hostname: $(host $1)
    networks:
      backplane:
        aliases:
          - $(host $1)

    environment:
    - "NODE_NAME=$(node $1)"
    - ... прочая питушня
EOF
}

main() {
    cat <<EOF
version: '3.3'

networks:
  backplane:

services:
$(node 1)

$(node 2)

...
EOF
}

main > docker-compose.yml
docker-compose $@

Как тебе такое, Helm?

CHayT, 13 Августа 2021

Комментарии (35)

Куча / Говнокод #27547

+1

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21

Ltac destruct_mint_ H := 
   match type of H with
      (MInt_ _ ?z ?t) =>
      lazymatch goal with
        |- ?GOAL =>
        refine (match H in (MInt_ _ z0 t0) return (z = z0 -> t = t0 -> GOAL) with
                | mint_nil    _  =>
                  fun Heq_z Heq_tt_ =>
                    ltac:(destruct_mint_common Heq_tt_ Heq_z H)
                | mint_cons   _ te rest l      r   t H =>
                  fun Heq_z Heq_tt_ =>
                    ltac:(destruct_mint_common Heq_tt_ Heq_z H)
                | mint_cons_l _ te rest l r z t Hz H  =>
                  fun Heq_z Heq_tt_ =>
                    ltac:(destruct_mint_common Heq_tt_ Heq_z H)
                | mint_cons_r _ te te' rest l r z t Hz Hcomm H =>
                  fun Heq_z Heq_tt_ =>
                    ltac:(destruct_mint_common Heq_tt_ Heq_z H)
                end (eq_refl z) (eq_refl t))
      end
    end.

Наебавшись с inversion в механизированным доказательстве, закрыл я очи.

CHayT, 04 Августа 2021

Комментарии (23)

Куча / Говнокод #27522

+2

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21

...

       fun([N1, _N2], Trace) ->
               ?assert(
                  ?strict_causality( #{?snk_kind := "Adding table to a shard", shard := _Shard, live_change := true}
                                   , #{?snk_kind := "Shard schema change"}
                                   , ?of_node(N1, Trace)
                                   )),
               ?assert(
                  ?strict_causality( #{?snk_kind := "Shard schema change", shard := _Shard}
                                   , #{?snk_kind := "Restarting shard server", shard := _Shard}
                                   , ?of_node(N1, Trace)
                                   )),
               %% Schema change must cause restart of the replica process and bootstrap:
               {_, Rest} = ?split_trace_at(#{?snk_kind := "Shard schema change"}, Trace),
               ?assert(
                  ?strict_causality( #{?snk_kind := "Restarting shard server", shard := _Shard}
                                   , #{?snk_kind := state_change, to := bootstrap}
                                   , Rest
                                   ))
       end).

Немного galaxy-brain тестов

CHayT, 17 Июля 2021

Комментарии (19)

Куча / Говнокод #27475

+1

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69

dirty_boostrap_test() ->
    SourceTab = ets:new(source, [public, named_table]),
    ReplicaTab = ets:new(replica, [public, named_table]),
    %% Insert some initial data:
    ets:insert(source, {1, 1}),
    ets:insert(source, {2, 2}),
    ets:insert(source, {3, 3}),
    try
        register(testcase, self()),
        Replica = spawn_link(fun replica/0),
        register(replica, Replica),
        %% "importer" process emulates mnesia_tm:
        spawn_link(fun importer/0),
        %% "bootstrapper" process emulates bootstrapper server:
        spawn_link(fun bootstrapper/0),
        receive
            done ->
                SrcData = lists:sort(ets:tab2list(source)),
                RcvData = lists:sort(ets:tab2list(replica)),
                ?assertEqual(SrcData, RcvData)
        end
    after
        ets:delete(SourceTab),
        ets:delete(ReplicaTab)
    end.

importer() ->
    Ops = [ {write, 3, 3}
          , {write, 4, 4}
          , {write, 4, 5}
          , {delete, 2}
          ],
    lists:map(fun(OP) ->
                      import_op(source, OP),
                      %% Imitate mnesia event (note: here we send it
                      %% directly to the replica process bypassing
                      %% the agent):
                      replica ! {tlog, OP}
              end,
              Ops),
    replica ! last_trans.

replica() ->
    receive
        {bootstrap, K, V} ->
            ets:insert(replica, {K, V}),
            replica();
        bootstrap_done ->
            replay()
    end.

replay() ->
    receive
        {tlog, Op} ->
            import_op(replica, Op),
            replay();
        last_trans ->
            testcase ! done
    end.

import_op(Tab, {write, K, V}) ->
    ets:insert(Tab, {K, V});
import_op(Tab, {delete, K}) ->
    ets:delete(Tab, K).

bootstrapper() ->
    {Keys, _} = lists:unzip(ets:tab2list(source)),
    [replica ! {bootstrap, K, V} || K <- Keys, {_, V} <- ets:lookup(source, K)],
    replica ! bootstrap_done.

Follow-up к треду про то, как делать снепшоты.

CHayT, 20 Июня 2021

Комментарии (69)

Куча / Говнокод #27464

+1

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

insert(Alias, Tab, Val) ->
    ok.

delete(_Alias, _Tab, _Key) ->
    ok.

add_aliases(_) ->
    ok.

remove_aliases(_) ->
    ok.

check_definition(_Alias, _Tab, _Nodes, _Properties) ->
    ok.

close_table(_Alias, _Tab) ->
    ok.

create_table(_Alias, _Tab, _Properties) ->
    ok.

delete_table(_Alias, _Tab) ->
    ok.

first(_Alias, _Tab) ->
    '$end_of_table'.

fixtable(_Alias, _Tab, _Bool) ->
    ok.

last(_Alias, _Tab) ->
    '$end_of_table'.

index_is_consistent(_Alias, _IxTag, _Bool) ->
    ok.

init_backend() ->
    ok.

info(_Alias, Tab, memory) ->
    0;
info(Alias, Tab, size) ->
    0;
info(_Alias, _Info, _Item) ->
    nobody_here_but_us_chicken.

lookup(_Alias, _Tab, _Key) ->
    [].

is_index_consistent(_Alias, _IxTag) ->
    true.

load_table(_Alias, _Tab, _Reason, _CsList) ->
    ok.

match_delete(_Alias, _Tab, _Pattern) ->
    ok.

next(_Alias, _Tab, _Key) ->
    '$end_of_table'.

prev(_Alias, _Tab, _Key) ->
    '$end_of_table'.

real_suffixes() ->
    [].

repair_continuation(Continuation, _MatchSpec) ->
    Continuation.

select(_Continuation) ->
    '$end_of_table'.

select(_Alias, _Tab, _Pattern) ->
    '$end_of_table'.

select(_Alias, _Tab, _Pattern, _Limit) ->
    '$end_of_table'.


semantics(_Alias, storage) -> ram_copies;
semantics(_Alias, types  ) -> [set, ordered_set, bag];
semantics(_Alias, index_types) -> [];
semantics(_Alias, _) -> undefined.

slot(_Alias, _Tab, _Pos) ->
    '$end_of_table'.

sync_close_table(_Alias, _Tab) ->
    ok.

tmp_suffixes() ->
    [].

If /dev/null is fast in web scale I will use it. Is it web scale? Does /dev/null support sharding?

CHayT, 09 Июня 2021

Комментарии (127)

Куча / Говнокод #27400

+1

1
2
3
4
5
6
7
8

%% Generates a Normal-distributed random variable using Box-Muller method
%% from: https://github.com/basho/basho_stats/blob/develop/src/basho_stats_rv.erl
-spec rnd_normal(integer(), integer()) -> non_neg_integer().
rnd_normal(Mean, Sigma) ->
  Rv1 = random:uniform(),
  Rv2 = random:uniform(),
  Rho = math:sqrt(-2 * math:log(1-Rv2)),
  abs(trunc(Rho * math:cos(2 * math:pi() * Rv1) * Sigma + Mean)).

Это норма.

CHayT, 07 Мая 2021

Комментарии (21)

Куча / Говнокод #27377

+1

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18

%% This function is needed as a hack to guide dialyzer into inferring
%% the correct types.
-spec id(A) -> A.
id(A) ->
  A.

%% Где-то в header'е....

-define(deftarget(RECIPE), {RECIPE, fun my_module:id/1}).

%% A horrible, horrible hack to make Dialyzer infer right type of the promise return value
-define(want(TARGET),
        (fun() ->
             case TARGET of
               {_, ___IAmSorryYouHaveToSeeThisWorkaroundForDialyzer} ->
                 ___IAmSorryYouHaveToSeeThisWorkaroundForDialyzer(my_module:want(TARGET))
             end
         end)()).

Пути статический типизации в Erlang неисповедимы.

CHayT, 26 Апреля 2021

Комментарии (3)

Куча / Говнокод #27372

0

01
02
03
04
05
06
07
08
09
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49

-export([parse_transform/2, abstract/2]).

parse_transform(Forms, _Options) ->
  normal(Forms).

normal({call, _Line, {atom, _, '$$'}, [Outer]}) ->
  case Outer of
    {'fun', _, {clauses, Quoted}} ->
      %% Remove outer `fun' and only leave its clauses:
      ok;
    Quoted ->
      %% A plain term has been quoted, leave it as is:
      ok
  end,
  Result = abstract(Quoted),
  %% io:format("Quoted block ~p~n", [Result]),
  Result;
normal(L) when is_list(L) ->
  lists:map(fun normal/1, L);
normal(T) when is_tuple(T) ->
  list_to_tuple(lists:map(fun normal/1, tuple_to_list(T)));
normal(T) ->
  T.

-define(line, 0).

%% @doc Create AST of the AST
abstract({call, _Line, {atom, _, '$'}, [Splice]}) ->
  normal(Splice);
abstract(Orig = {var, Line, VarName}) ->
  case lists:suffix("__AST", atom_to_list(VarName)) of
    true ->
      Orig;
    false ->
      {tuple, ?line, [ {atom, ?line, var}
                     , {integer, ?line, Line}
                     , {atom, ?line, VarName}
                     ]}
  end;
abstract(T) when is_tuple(T) ->
  {tuple, ?line, lists:map(fun abstract/1, tuple_to_list(T))};
abstract([]) ->
  {nil, ?line};
abstract([Hd|Tail]) ->
  {cons, ?line, abstract(Hd), abstract(Tail)};
abstract(A) when is_atom(A) ->
  {atom, ?line, A};
abstract(I) when is_integer(I) ->
  {integer, ?line, I}.

Мета-метушня, убогое подобие лисповского квотирования.

CHayT, 23 Апреля 2021

Комментарии (7)

Куча / Говнокод #27315

+1

01
02
03
04
05
06
07
08
09
10
11
12
13
14

?check_trace(
       begin
           %% Inject some orderings to make sure the replicant
           %% receives transactions in all states.
           %%
           %% 1. Commit some transactions before the replicant start:
           ?force_ordering(#{?snk_kind := trans_gen_counter_update, value := 5}, #{?snk_kind := state_change, to := disconnected}),
           %% 2. Make sure the rest of transactions are produced after the agent starts:
           ?force_ordering(#{?snk_kind := subscribe_realtime_stream}, #{?snk_kind := trans_gen_counter_update, value := 10}),
           %% 3. Make sure transactions are sent during TLOG replay:
           ?force_ordering(#{?snk_kind := state_change, to := bootstrap}, #{?snk_kind := trans_gen_counter_update, value := 15}),
           %% 4. Make sure some transactions are produced while in normal mode
           ?force_ordering(#{?snk_kind := state_change, to := normal}, #{?snk_kind := trans_gen_counter_update, value := 25}),
...

Какой тест )))

CHayT, 24 Марта 2021

Комментарии (3)

Говнокод: по колено в коде.