Skip to content

Commit db56270

Browse files
committed
Call the actual accept logic directly for clarity and refactoring
1 parent 4d5cc58 commit db56270

File tree

4 files changed

+10
-18
lines changed

4 files changed

+10
-18
lines changed

lib/truffle/socket/socket.rb

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -406,11 +406,12 @@ def listen(backlog)
406406
end
407407

408408
def accept
409-
Truffle::Socket.accept(self, Socket)
409+
Truffle::Socket.accept_and_addrinfo(self, Socket, true)
410410
end
411411

412412
private def __accept_nonblock(exception)
413-
Truffle::Socket.accept_nonblock(self, Socket, exception)
413+
self.nonblock = true
414+
Truffle::Socket.accept_and_addrinfo(self, Socket, exception)
414415
end
415416

416417
def sysaccept

lib/truffle/socket/tcp_server.rb

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -63,13 +63,14 @@ def listen(backlog)
6363
end
6464

6565
def accept
66-
socket, _ = Truffle::Socket.accept(self, TCPSocket)
66+
socket, _ = Truffle::Socket.accept_and_addrinfo(self, TCPSocket, true)
6767

6868
socket
6969
end
7070

7171
private def __accept_nonblock(exception)
72-
socket, _ = Truffle::Socket.accept_nonblock(self, TCPSocket, exception)
72+
self.nonblock = true
73+
socket, _ = Truffle::Socket.accept_and_addrinfo(self, TCPSocket, exception)
7374

7475
socket
7576
end

lib/truffle/socket/truffle.rb

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ def self.sockaddr_class_for_socket(socket)
9393
end
9494
end
9595

96-
def self.internal_accept(source, new_class, exception)
96+
def self.accept_and_addrinfo(source, new_class, exception)
9797
raise IOError, 'socket has been closed' if source.closed?
9898

9999
sockaddr = sockaddr_class_for_socket(source).new
@@ -123,17 +123,6 @@ def self.internal_accept(source, new_class, exception)
123123
sockaddr.pointer.free
124124
end
125125
end
126-
private_class_method :internal_accept
127-
128-
def self.accept(source, new_class)
129-
internal_accept(source, new_class, true)
130-
end
131-
132-
def self.accept_nonblock(source, new_class, exception)
133-
source.nonblock = true
134-
135-
internal_accept(source, new_class, exception)
136-
end
137126

138127
def self.listen(source, backlog)
139128
backlog = Primitive.rb_to_int(backlog)

lib/truffle/socket/unix_server.rb

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,13 +51,14 @@ def listen(backlog)
5151
end
5252

5353
def accept
54-
socket, _ = Truffle::Socket.accept(self, UNIXSocket)
54+
socket, _ = Truffle::Socket.accept_and_addrinfo(self, UNIXSocket, true)
5555

5656
socket
5757
end
5858

5959
private def __accept_nonblock(exception)
60-
socket, _ = Truffle::Socket.accept_nonblock(self, UNIXSocket, exception)
60+
self.nonblock = true
61+
socket, _ = Truffle::Socket.accept_and_addrinfo(self, UNIXSocket, exception)
6162

6263
socket
6364
end

0 commit comments

Comments
 (0)