blob: a3986760fccc6bd6a85a48890b6f764e3d2229c1 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
defmodule Octonetcat.Accepter do
@moduledoc """
Simple Socket/Connection Accepter
"""
require Logger
@listen_port Application.get_env(:octonetcat, :listen_port) || 9999
def accept do
{:ok, socket} = :gen_tcp.listen(
@listen_port,
[:binary, packet: :line, active: false, reuseaddr: true])
loop_accepter(socket)
end
defp loop_accepter(socket) do
{:ok, client} = :gen_tcp.accept(socket)
Logger.info("Accepted connection")
Logger.info("Passing to Echo Server")
{:ok, pid} = Task.Supervisor.start_child(
Octonetcat.TaskSupervisor,
Octonetcat.Echo,
:serve,
[client])
:ok = :gen_tcp.controlling_process(client, pid)
loop_accepter(socket)
end
end
|
