mirror of
https://github.com/iv-org/invidious.git
synced 2025-12-03 20:38:29 -06:00
Merge 11ae5721a7986968249bb2fb27484f7dd6b391c7 into 35d1d499bc42a9b141b3dc92c4a5827b5f21a3ff
This commit is contained in:
commit
78d6cb5d97
@ -3,9 +3,10 @@
|
|||||||
# IPv6 addresses.
|
# IPv6 addresses.
|
||||||
#
|
#
|
||||||
class TCPSocket
|
class TCPSocket
|
||||||
def initialize(host, port, dns_timeout = nil, connect_timeout = nil, blocking = false, family = Socket::Family::UNSPEC)
|
def initialize(host : String, port, dns_timeout = nil, connect_timeout = nil, blocking = false, family = Socket::Family::UNSPEC)
|
||||||
Addrinfo.tcp(host, port, timeout: dns_timeout, family: family) do |addrinfo|
|
Addrinfo.tcp(host, port, timeout: dns_timeout, family: family) do |addrinfo|
|
||||||
super(addrinfo.family, addrinfo.type, addrinfo.protocol, blocking)
|
super(family: addrinfo.family, type: addrinfo.type, protocol: addrinfo.protocol)
|
||||||
|
Socket.set_blocking(self.fd, blocking)
|
||||||
connect(addrinfo, timeout: connect_timeout) do |error|
|
connect(addrinfo, timeout: connect_timeout) do |error|
|
||||||
close
|
close
|
||||||
error
|
error
|
||||||
|
|||||||
@ -316,7 +316,7 @@ module Invidious::SigHelper
|
|||||||
{% end %}
|
{% end %}
|
||||||
|
|
||||||
@socket.sync = false
|
@socket.sync = false
|
||||||
@socket.blocking = false
|
Socket.set_blocking(@socket.fd, false)
|
||||||
end
|
end
|
||||||
|
|
||||||
def closed? : Bool
|
def closed? : Bool
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user