@@ 44,6 44,7 @@ module CZTop::Reactor::SocketMonitoring
### 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 @@ module CZTop::Reactor::SocketMonitoring
### 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