@@ -21,7 +21,7 @@ defmodule Rel.Listener do
21
21
alias ExSTUN.Message.Type
22
22
alias ExSTUN.Message.Attribute . { Username , XORMappedAddress }
23
23
24
- @ buf_size 1024 * 1024 * 1024
24
+ @ buf_size 2 * 1024
25
25
@ default_alloc_ports MapSet . new ( 49_152 .. 65_535 )
26
26
27
27
@ spec start_link ( term ( ) ) :: { :ok , pid ( ) }
@@ -42,15 +42,14 @@ defmodule Rel.Listener do
42
42
:ok = :socket . setopt ( socket , { :socket , :reuseport } , true )
43
43
:ok = :socket . setopt ( socket , { :socket , :rcvbuf } , @ buf_size )
44
44
:ok = :socket . setopt ( socket , { :socket , :sndbuf } , @ buf_size )
45
- :ok = :socket . setopt ( socket , { :otp , :rcvbuf } , @ buf_size )
46
45
:ok = :socket . bind ( socket , % { family: :inet , addr: ip , port: port } )
47
46
48
47
spawn ( Rel.Monitor , :start , [ self ( ) , socket ] )
49
48
50
49
recv_loop ( socket , id )
51
50
end
52
51
53
- defp recv_loop ( socket ) do
52
+ defp recv_loop ( socket , id ) do
54
53
case :socket . recvfrom ( socket ) do
55
54
{ :ok , { % { addr: client_addr , port: client_port } , packet } } ->
56
55
:telemetry . execute ( [ :listener , :client ] , % { inbound: byte_size ( packet ) } , % { listener_id: id } )
0 commit comments