Profile target

.gitignore

@@ -1,4 +1,5 @@
 .eunit
 doc/README.md
 erl_crash.dump
+fprofx.*
 _build

Makefile

@@ -1,31 +1,42 @@
-REBAR=./rebar3
+CACHEGRIND=qcachegrind
+REBAR3=./rebar3
 
 all: compile
 
 clean:
 	@echo "Running rebar3 clean..."
-	@$(REBAR) clean -a
+	@$(REBAR3) clean -a
 
 compile:
 	@echo "Running rebar3 compile..."
-	@$(REBAR) as compile compile
+	@$(REBAR3) as compile compile
 
 dialyzer:
 	@echo "Running rebar3 dialyze..."
-	@$(REBAR) dialyzer
+	@$(REBAR3) dialyzer
 
 edoc:
 	@echo "Running rebar3 edoc..."
-	@$(REBAR) as edoc edoc
+	@$(REBAR3) as edoc edoc
 
 eunit:
 	@echo "Running rebar3 eunit..."
-	@$(REBAR) do eunit -cv, cover -v
+	@$(REBAR3) do eunit -cv, cover -v
+
+profile:
+	@echo "Profiling..."
+	@$(REBAR3) as test compile
+	@erl -noshell \
+	     -pa _build/test/lib/*/ebin \
+		 -eval 'anchor_profile:fprofx()' \
+		 -eval 'init:stop()'
+	@_build/test/lib/fprofx/erlgrindx -p fprofx.analysis
+	@$(CACHEGRIND) fprofx.cgrind
 
 test: dialyzer eunit xref
 
 xref:
 	@echo "Running rebar3 xref..."
-	@$(REBAR) xref
+	@$(REBAR3) xref
 
-.PHONY: edoc test xref
+.PHONY: clean compile dialyzer edoc eunit profile xref

rebar.config

@@ -28,6 +28,9 @@
     {deps, [
       {edown, {git, "https://github.com/uwiger/edown.git", {tag, "0.7"}}}
     ]}
+  ]},
+  {test, [
+    {src_dirs, ["src", "test"]}
   ]}
 ]}.
 

test/anchor_profile.erl

@@ -0,0 +1,50 @@
+-module(anchor_profile).
+
+-export([
+    fprofx/0
+]).
+
+-define(N, 1000).
+-define(P, 20).
+
+%% public
+-spec fprofx() -> ok.
+
+fprofx() ->
+    Filenames = filelib:wildcard("_build/default/lib/*/ebin/*.beam"),
+    Rootnames = [filename:rootname(Filename, ".beam") ||
+        Filename <- Filenames],
+    lists:foreach(fun code:load_abs/1, Rootnames),
+
+    fprofx:start(),
+    {ok, Tracer} = fprofx:profile(start),
+    fprofx:trace([start, {procs, new}, {tracer, Tracer}]),
+
+    anchor_app:start(),
+    anchor:set(<<"key">>, <<"value">>),
+
+    Self = self(),
+    [spawn(fun () ->
+        [anchor:get(<<"key">>) || _ <- lists:seq(1, ?N)],
+        Self ! exit
+    end) || _ <- lists:seq(1, ?P)],
+    wait(),
+
+    fprofx:trace(stop),
+    fprofx:analyse([totals, {dest, ""}]),
+    fprofx:stop(),
+
+    anchor_app:stop(),
+    ok.
+
+%% private
+wait() ->
+    wait(?P).
+
+wait(0) ->
+    ok;
+wait(X) ->
+    receive
+        exit ->
+            wait(X - 1)
+    end.