velimir

{ok, Tracer} = dbg:tracer(port, dbg:trace_port(file, {"/tmp/trace", wrap, atom_to_list(node()), 50000000, 12})).

dbg:p(<0.3628.0>, ['receive', 'send', set_on_link]).


dbg:stop_clear().

%% dbg:ctp().
%% dbg:ctpe('receive').
%% dbg:ctpe('send').

velimir

RC = fun
         Receiver({Max, Max}, Fd, SchedFlag) ->
            io:format("count reached the max~n", []),
            stop;
         Receiver({Counter, Max}, Fd, SchedFlag) ->
                receive
                    stop ->
                        io:format("stop tracing~n", []),
                        ok;
                    {trace, _, call, {erlang, port_command, [Port, _Payload, _Opts]}} ->

velimir

velimir

diff --git a/src/emqx_auth_ldap.erl b/src/emqx_auth_ldap.erl
index 1476a87..5333b35 100644
--- a/src/emqx_auth_ldap.erl
+++ b/src/emqx_auth_ldap.erl
@@ -37,7 +37,7 @@ register_metrics() ->
 
 check(ClientInfo = #{username := Username, password := Password}, AuthResult,
       State = #{password_attr := PasswdAttr}) ->
-    CheckResult = case lookup_user(Username, State) of
+    CheckResult = case lookup_user(Username, Password, State) of

velimir

rabbitmqctl eval '{ok, Q} = rabbit_amqqueue:lookup(rabbit_misc:r(<<"/">>, queue, <<"rmq-two-test-queue">>)), rabbit_amqqueue:delete_crashed_internal(Q, <<"rmq-internal">>).'

velimir

levels = {}
prev_level = 1

local function visit_section(level)
   if level < prev_level then
      for i = level + 1, #levels do
         levels[i] = nil
      end
   end
   prev_level = level

velimir

Mandatory flags

TLDR:

• alternate-exchange - what exchanges to try to use if no routes are found
• mandatory - message MUST hit the queue (not necessarily flushed to disk)
• publish.confirm - if message hits a queue, notify me when queue accepted it (flushed to disk if it’s needed)

velimir

Usage

  usage: rmq-pwd.py [-h]
                    [--algorithm {sha1,sha3_256,sha512,shake_128,blake2s,sha3_384,shake_256,sha3_512,sha224,md5,blake2b,sha384,sha256,sha3_224}]
                    [--salt SALT]
                    secret

  Calculate salted password for RMQ

positional arguments:

velimir

trace_receiver() ->
    receive
        stop ->
            ?LOG_INFO(?LC, "stop tracing", []),
            ok;
        Msg ->
            ?LOG_INFO(?LC, "message received", []),
            ?LOG_INFO(?LC, "~p", [Msg]),
            trace_receiver()
    end.

velimir

-module(io_test).

-export([main/0]).

main() ->
    CTProvider = providers:create([{name, ct},
                                   {module, rebar_prv_common_test},
                                   {deps, []},
                                   {bare, true},
                                   {example, "rebar3 ct"},