Add more PULSE instrumentation -> more deadlocks
This commit is contained in:
parent
73ac220d75
commit
f2fc5b91c2
6 changed files with 21 additions and 1 deletions
|
@ -118,6 +118,7 @@
|
||||||
-endif.
|
-endif.
|
||||||
-ifdef(PULSE).
|
-ifdef(PULSE).
|
||||||
-compile({parse_transform, pulse_instrument}).
|
-compile({parse_transform, pulse_instrument}).
|
||||||
|
-include_lib("pulse_otp/include/pulse_otp.hrl").
|
||||||
-endif.
|
-endif.
|
||||||
|
|
||||||
-include_lib("eunit/include/eunit.hrl").
|
-include_lib("eunit/include/eunit.hrl").
|
||||||
|
|
|
@ -45,6 +45,11 @@
|
||||||
-include("machi_pb.hrl").
|
-include("machi_pb.hrl").
|
||||||
-include("machi_projection.hrl").
|
-include("machi_projection.hrl").
|
||||||
|
|
||||||
|
-ifdef(PULSE).
|
||||||
|
-compile({parse_transform, pulse_instrument}).
|
||||||
|
-include_lib("pulse_otp/include/pulse_otp.hrl").
|
||||||
|
-endif.
|
||||||
|
|
||||||
-define(HARD_TIMEOUT, 2500).
|
-define(HARD_TIMEOUT, 2500).
|
||||||
|
|
||||||
-export([
|
-export([
|
||||||
|
|
|
@ -26,6 +26,11 @@
|
||||||
-include("machi_pb.hrl").
|
-include("machi_pb.hrl").
|
||||||
-include("machi_projection.hrl").
|
-include("machi_projection.hrl").
|
||||||
|
|
||||||
|
-ifdef(PULSE).
|
||||||
|
-compile({parse_transform, pulse_instrument}).
|
||||||
|
-include_lib("pulse_otp/include/pulse_otp.hrl").
|
||||||
|
-endif.
|
||||||
|
|
||||||
-export([from_pb_request/1,
|
-export([from_pb_request/1,
|
||||||
from_pb_response/1,
|
from_pb_response/1,
|
||||||
to_pb_request/2,
|
to_pb_request/2,
|
||||||
|
|
|
@ -42,6 +42,11 @@
|
||||||
|
|
||||||
-include("machi_projection.hrl").
|
-include("machi_projection.hrl").
|
||||||
|
|
||||||
|
-ifdef(PULSE).
|
||||||
|
-compile({parse_transform, pulse_instrument}).
|
||||||
|
-include_lib("pulse_otp/include/pulse_otp.hrl").
|
||||||
|
-endif.
|
||||||
|
|
||||||
%% API
|
%% API
|
||||||
-export([
|
-export([
|
||||||
start_link/3,
|
start_link/3,
|
||||||
|
|
|
@ -47,6 +47,10 @@
|
||||||
|
|
||||||
-ifdef(TEST).
|
-ifdef(TEST).
|
||||||
-include_lib("eunit/include/eunit.hrl").
|
-include_lib("eunit/include/eunit.hrl").
|
||||||
|
-ifdef(PULSE).
|
||||||
|
-compile({parse_transform, pulse_instrument}).
|
||||||
|
-include_lib("pulse_otp/include/pulse_otp.hrl").
|
||||||
|
-endif.
|
||||||
-endif. % TEST.
|
-endif. % TEST.
|
||||||
|
|
||||||
-export([start_link/1]).
|
-export([start_link/1]).
|
||||||
|
|
|
@ -469,8 +469,8 @@ shutdown_hard() ->
|
||||||
exec_ticks(Num, All_listE) ->
|
exec_ticks(Num, All_listE) ->
|
||||||
Parent = self(),
|
Parent = self(),
|
||||||
Pids = [spawn_link(fun() ->
|
Pids = [spawn_link(fun() ->
|
||||||
|
%% ?V("tick-~w,", [self()]),
|
||||||
[begin
|
[begin
|
||||||
erlang:yield(),
|
|
||||||
M_name = P#p_srvr.name,
|
M_name = P#p_srvr.name,
|
||||||
%% Max = 10,
|
%% Max = 10,
|
||||||
Max = 25,
|
Max = 25,
|
||||||
|
|
Loading…
Reference in a new issue