# HG changeset patch # User Michael Granger # Date 1558548027 25200 # Wed May 22 11:00:27 2019 -0700 # Node ID 62f6d793708f4646771a8d08320edc65053d99b0 # Parent 200c8be89458703633ac2c06189fc15670e1f286 Super to monitor event handler methods if possible diff --git a/lib/cztop/reactor/socket_monitoring.rb b/lib/cztop/reactor/socket_monitoring.rb --- a/lib/cztop/reactor/socket_monitoring.rb +++ b/lib/cztop/reactor/socket_monitoring.rb @@ -44,6 +44,7 @@ ### Tear down the monitor. def clean_up_socket_monitor( mon ) mon.terminate if mon + self.log.debug "Monitor is: %p" % [ mon ] end @@ -72,90 +73,105 @@ ### Monitor event callback for socket connection events def on_connected( fd, endpoint ) self.log.debug "Client socket on FD %d connected" % [ fd ] + super if defined?( super ) end ### Monitor event callback for socket connection-delayed events def on_connect_delayed( fd, endpoint ) self.log.debug "Client socket on FD %d connection delayed" % [ fd ] + super if defined?( super ) end ### Monitor event callback for socket retry events def on_connect_retried( fd, endpoint ) self.log.debug "Retrying connection for socket on FD %d" % [ fd ] + super if defined?( super ) end ### Monitor event callback for listening events def on_listening( fd, endpoint ) self.log.debug "Socket on FD %d is now listening for connections" % [ fd ] + super if defined?( super ) end ### Monitor event callback for bind failure events def on_bind_failed( fd, endpoint ) self.log.debug "Socket on FD %d could not be bound" % [ fd ] + super if defined?( super ) end ### Monitor event callback for socket accepted events def on_accepted( fd, endpoint ) self.log.debug "Client socket on FD %d accepted" % [ fd ] + super if defined?( super ) end ### Monitor event callback for socket accept failed events def on_accept_failed( fd, endpoint ) self.log.debug "Client socket on FD %d accept failed" % [ fd ] + super if defined?( super ) end ### Monitor event callback for socket closed events def on_closed( fd, endpoint ) self.log.debug "Client socket on FD %d closed" % [ fd ] + super if defined?( super ) end ### Monitor event callback for socket close failed events def on_close_failed( fd, endpoint ) self.log.debug "Close failed for socket on FD %d" % [ fd ] + super if defined?( super ) end ### Monitor event callback for socket disconnection events def on_disconnected( fd, endpoint ) self.log.debug "Client socket on FD %d disconnected" % [ fd ] + super if defined?( super ) end ### Monitor event callback for monitor stopped events. def on_monitor_stopped( fd, endpoint ) self.log.debug "Monitor for socket on FD %d stopped." % [ fd ] + super if defined?( super ) end ### Monitor event callback for successful auth events. def on_handshake_succeeded( fd, endpoint ) self.log.debug "Client socket on FD %d handshake succeeded" % [ fd ] + super if defined?( super ) end ### Monitor event callback for failed handshake events. def on_handshake_failed_no_detail( fd, endpoint ) self.log.debug "Client socket on FD %d handshake failed; no further details are known" % [ fd ] + super if defined?( super ) end ### Monitor event callback for failed handshake events. def on_handshake_failed_protocol( fd, endpoint ) self.log.debug "Client socket on FD %d handshake failed: protocol error" % [ fd ] + super if defined?( super ) end ### Monitor event callback for failed auth events. def on_handshake_failed_auth( fd, endpoint ) self.log.debug "Client socket on FD %d handshake failed: authentication failure" % [ fd ] + super if defined?( super ) end end # module CZTop::Reactor::SocketMonitoring