projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'develop' into global-status-expiration
[akkoma]
/
benchmarks
/
load_testing
/
users.ex
diff --git
a/benchmarks/load_testing/users.ex
b/benchmarks/load_testing/users.ex
index b73ac8651017b63224afd483b0e8071cf62358d3..1a8c6e22f5b2a02ff7f0a4eeaaf1242305d786a7 100644
(file)
--- 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...")
def generate_users(max) do
IO.puts("Starting generating #{max} users...")
- {time,
_
} =
+ {time,
users
} =
:timer.tc(fn ->
Task.async_stream(
1..max,
:timer.tc(fn ->
Task.async_stream(
1..max,
@@
-41,10
+41,11
@@
defmodule Pleroma.LoadTesting.Users do
max_concurrency: @max_concurrency,
timeout: 30_000
)
max_concurrency: @max_concurrency,
timeout: 30_000
)
- |>
Stream.run
()
+ |>
Enum.to_list
()
end)
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
end
defp generate_user(i) do
@@
-104,7
+105,7
@@
defmodule Pleroma.LoadTesting.Users do
|> run_stream(main_user)
end)
|> run_stream(main_user)
end)
- IO.puts("Making friends t
ake
#{to_sec(time)} sec.\n")
+ IO.puts("Making friends t
ook
#{to_sec(time)} sec.\n")
end
def make_friends(%User{} = main_user, %User{} = user) do
end
def make_friends(%User{} = main_user, %User{} = user) do