Spaces:
Sleeping
Sleeping
hiett
commited on
Commit
•
7edc4a0
1
Parent(s):
fa07385
Remove old logs
Browse files
lib/srh/http/command_handler.ex
CHANGED
@@ -131,7 +131,6 @@ defmodule Srh.Http.CommandHandler do
|
|
131 |
result
|
132 |
|
133 |
{:error, %{reason: :closed} = error} ->
|
134 |
-
IO.puts("Transaction error: #{inspect(error)}")
|
135 |
# Ensure that this pool is killed, but still pass the error up the chain for the response
|
136 |
Client.destroy_workers(client_pid)
|
137 |
decode_error(error, srh_id)
|
@@ -175,8 +174,6 @@ defmodule Srh.Http.CommandHandler do
|
|
175 |
when is_number(max_connections) do
|
176 |
case GenRegistry.lookup_or_start(Client, srh_id, [max_connections, connection_info]) do
|
177 |
{:ok, pid} ->
|
178 |
-
IO.puts("SRH: Found client #{inspect(pid)}")
|
179 |
-
|
180 |
# Run the command
|
181 |
case Client.find_worker(pid)
|
182 |
|> ClientWorker.redis_command(command_array) do
|
|
|
131 |
result
|
132 |
|
133 |
{:error, %{reason: :closed} = error} ->
|
|
|
134 |
# Ensure that this pool is killed, but still pass the error up the chain for the response
|
135 |
Client.destroy_workers(client_pid)
|
136 |
decode_error(error, srh_id)
|
|
|
174 |
when is_number(max_connections) do
|
175 |
case GenRegistry.lookup_or_start(Client, srh_id, [max_connections, connection_info]) do
|
176 |
{:ok, pid} ->
|
|
|
|
|
177 |
# Run the command
|
178 |
case Client.find_worker(pid)
|
179 |
|> ClientWorker.redis_command(command_array) do
|
lib/srh/redis/client_registry.ex
CHANGED
@@ -33,8 +33,6 @@ defmodule Srh.Redis.ClientRegistry do
|
|
33 |
end
|
34 |
|
35 |
def destroy_workers(registry) do
|
36 |
-
# TODO: remove before shipping
|
37 |
-
IO.puts("DEBUG: Destroying workers")
|
38 |
GenServer.cast(registry, {:destroy_workers})
|
39 |
end
|
40 |
|
|
|
33 |
end
|
34 |
|
35 |
def destroy_workers(registry) do
|
|
|
|
|
36 |
GenServer.cast(registry, {:destroy_workers})
|
37 |
end
|
38 |
|
lib/srh/redis/client_worker.ex
CHANGED
@@ -18,7 +18,6 @@ defmodule Srh.Redis.ClientWorker do
|
|
18 |
end
|
19 |
|
20 |
def redis_command(worker, command_array) do
|
21 |
-
IO.puts("redis_command (for pid #{inspect(worker)}): #{inspect(command_array)}")
|
22 |
GenServer.call(worker, {:redis_command, command_array})
|
23 |
end
|
24 |
|
|
|
18 |
end
|
19 |
|
20 |
def redis_command(worker, command_array) do
|
|
|
21 |
GenServer.call(worker, {:redis_command, command_array})
|
22 |
end
|
23 |
|