diff options
author | Alexander Strizhakov <alex.strizhakov@gmail.com> | 2020-03-30 11:59:14 +0300 |
---|---|---|
committer | Alexander Strizhakov <alex.strizhakov@gmail.com> | 2020-03-30 11:59:14 +0300 |
commit | 96e279655763fedcb701e59c500023a70568c4c6 (patch) | |
tree | 50019e4058459ee99992b85f4aa5132eb64372d3 /benchmarks/load_testing/users.ex | |
parent | 56503c385e8412a1189748bcf3fdfd4090be9f56 (diff) | |
download | pleroma-96e279655763fedcb701e59c500023a70568c4c6.tar.gz pleroma-96e279655763fedcb701e59c500023a70568c4c6.zip |
use in timelines benchmark new user generator
Diffstat (limited to 'benchmarks/load_testing/users.ex')
-rw-r--r-- | benchmarks/load_testing/users.ex | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/benchmarks/load_testing/users.ex b/benchmarks/load_testing/users.ex index b73ac8651..1a8c6e22f 100644 --- a/benchmarks/load_testing/users.ex +++ b/benchmarks/load_testing/users.ex @@ -33,7 +33,7 @@ defmodule Pleroma.LoadTesting.Users do def generate_users(max) do IO.puts("Starting generating #{max} users...") - {time, _} = + {time, users} = :timer.tc(fn -> Task.async_stream( 1..max, @@ -41,10 +41,11 @@ defmodule Pleroma.LoadTesting.Users do max_concurrency: @max_concurrency, timeout: 30_000 ) - |> Stream.run() + |> Enum.to_list() end) - IO.puts("Generating users take #{to_sec(time)} sec.\n") + IO.puts("Generating users took #{to_sec(time)} sec.\n") + users end defp generate_user(i) do @@ -104,7 +105,7 @@ defmodule Pleroma.LoadTesting.Users do |> run_stream(main_user) end) - IO.puts("Making friends take #{to_sec(time)} sec.\n") + IO.puts("Making friends took #{to_sec(time)} sec.\n") end def make_friends(%User{} = main_user, %User{} = user) do |