Rename #before_close to #shutdown

Author: ysbaddaden

src/crystal/event_loop/file_descriptor.cr

@@ -46,14 +46,13 @@ abstract class Crystal::EventLoop
     # file descriptor.
     abstract def reopened(file_descriptor : Crystal::System::FileDescriptor) : Nil
 
-    # Hook to react on the file descriptor after the IO object has been marked
-    # closed but before calling `#close` to actually close the system fd or
-    # handle.
+    # Internal shutdown of the file descriptor. Called after the
+    # IO::FileDescriptor has been marked closed but before calling `#close` to
+    # actually close the system fd or handle.
     #
-    # On UNIX targets the event loop must resume pending waiters and let them
-    # fail because the IO object is closed.
-    def before_close(file_descriptor : Crystal::System::FileDescriptor) : Nil
-    end
+    # Implementations shall resume all pending waiters and let them fail because
+    # the IO has been closed.
+    abstract def shutdown(file_descriptor : Crystal::System::FileDescriptor) : Nil
 
     # Closes the system fd or handle.
     abstract def close(file_descriptor : Crystal::System::FileDescriptor) : Nil

src/crystal/event_loop/iocp.cr

@@ -307,6 +307,9 @@ class Crystal::EventLoop::IOCP < Crystal::EventLoop
     raise NotImplementedError.new("Crystal::System::IOCP#reopened(FileDescriptor)")
   end
 
+  def shutdown(file_descriptor : Crystal::System::FileDescriptor) : Nil
+  end
+
   def close(file_descriptor : Crystal::System::FileDescriptor) : Nil
     LibC.CancelIoEx(file_descriptor.windows_handle, nil) unless file_descriptor.system_blocking?
     file_descriptor.file_descriptor_close
@@ -445,6 +448,9 @@ class Crystal::EventLoop::IOCP < Crystal::EventLoop
     end
   end
 
+  def shutdown(socket : ::Socket) : Nil
+  end
+
   def close(socket : ::Socket) : Nil
     raise NotImplementedError.new("Crystal::System::IOCP#close(Socket)")
   end

src/crystal/event_loop/libevent.cr

@@ -178,7 +178,7 @@ class Crystal::EventLoop::LibEvent < Crystal::EventLoop
     file_descriptor.evented_close
   end
 
-  def before_close(file_descriptor : Crystal::System::FileDescriptor) : Nil
+  def shutdown(file_descriptor : Crystal::System::FileDescriptor) : Nil
     # perform cleanup before LibC.close. Using a file descriptor after it has
     # been closed is never defined and can always lead to undefined results
     file_descriptor.evented_close
@@ -302,7 +302,7 @@ class Crystal::EventLoop::LibEvent < Crystal::EventLoop
     end
   end
 
-  def before_close(socket : ::Socket) : Nil
+  def shutdown(socket : ::Socket) : Nil
     # perform cleanup before LibC.close. Using a file descriptor after it has
     # been closed is never defined and can always lead to undefined results
     socket.evented_close

src/crystal/event_loop/polling.cr

@@ -232,7 +232,7 @@ abstract class Crystal::EventLoop::Polling < Crystal::EventLoop
     resume_all(file_descriptor)
   end
 
-  def before_close(file_descriptor : System::FileDescriptor) : Nil
+  def shutdown(file_descriptor : System::FileDescriptor) : Nil
     # perform cleanup before LibC.close. Using a file descriptor after it has
     # been closed is never defined and can always lead to undefined results
     resume_all(file_descriptor)
@@ -366,7 +366,7 @@ abstract class Crystal::EventLoop::Polling < Crystal::EventLoop
     end
   end
 
-  def before_close(socket : ::Socket) : Nil
+  def shutdown(socket : ::Socket) : Nil
     # perform cleanup before LibC.close. Using a file descriptor after it has
     # been closed is never defined and can always lead to undefined results
     resume_all(socket)

src/crystal/event_loop/socket.cr

@@ -74,13 +74,13 @@ abstract class Crystal::EventLoop
     # and the source address.
     abstract def receive_from(socket : ::Socket, slice : Bytes) : Tuple(Int32, ::Socket::Address)
 
-    # Hook to react on the socket after the IO object has been marked closed but
-    # before calling `#close` to actually close the system socket fd or handle.
+    # Internal shutdown of the socket. Called after the Socket has been marked
+    # closed but before calling `#close` to actually close the system socket fd
+    # or handle.
     #
-    # On UNIX targets the event loop must resume pending waiters and let them
-    # fail because the IO object is closed.
-    def before_close(socket : ::Socket) : Nil
-    end
+    # Implementations shall resume all pending waiters and let them fail because
+    # the IO has been closed. They don't have to call the `shutdown` syscall.
+    abstract def shutdown(socket : ::Socket) : Nil
 
     # Closes the system socket fd or handle.
     abstract def close(socket : ::Socket) : Nil

src/crystal/event_loop/wasi.cr

@@ -80,10 +80,13 @@ class Crystal::EventLoop::Wasi < Crystal::EventLoop
     raise NotImplementedError.new("Crystal::EventLoop#reopened(FileDescriptor)")
   end
 
-  def before_close(file_descriptor : Crystal::System::FileDescriptor) : Nil
+  def shutdown(file_descriptor : Crystal::System::FileDescriptor) : Nil
     file_descriptor.evented_close
   end
 
+  def shutdown(file_descriptor : Crystal::System::FileDescriptor) : Nil
+  end
+
   def close(file_descriptor : Crystal::System::FileDescriptor) : Nil
     file_descriptor.file_descriptor_close
   end
@@ -136,10 +139,13 @@ class Crystal::EventLoop::Wasi < Crystal::EventLoop
     raise NotImplementedError.new "Crystal::Wasi::EventLoop#accept"
   end
 
-  def before_close(socket : ::Socket) : Nil
+  def shutdown(socket : ::Socket) : Nil
     socket.evented_close
   end
 
+  def shutdown(socket : ::Socket) : Nil
+  end
+
   def close(socket : ::Socket) : Nil
     socket.socket_close
   end

src/crystal/system/unix/file_descriptor.cr

@@ -134,7 +134,7 @@ module Crystal::System::FileDescriptor
   end
 
   private def system_close
-    event_loop.before_close(self)
+    event_loop.shutdown(self)
     event_loop.close(self)
   end
 

src/crystal/system/unix/socket.cr

@@ -224,7 +224,7 @@ module Crystal::System::Socket
   end
 
   private def system_close
-    event_loop.before_close(self)
+    event_loop.shutdown(self)
     event_loop.close(self)
   end
 

src/crystal/system/wasi/socket.cr

@@ -152,7 +152,7 @@ module Crystal::System::Socket
   end
 
   private def system_close
-    event_loop.before_close(self)
+    event_loop.shutdown(self)
     event_loop.close(self)
   end
 

src/crystal/system/win32/file_descriptor.cr

@@ -216,7 +216,7 @@ module Crystal::System::FileDescriptor
   end
 
   private def system_close
-    event_loop.before_close(self)
+    event_loop.shutdown(self)
     event_loop.close(self)
   end