X-Git-Url: http://git.kpe.io/?a=blobdiff_plain;f=logger.lisp;h=a6aea52c6495a8fe80c97a334686fff044793d8c;hb=2ca1ab4fda6c7a17b6a8f9ccb903f3ecdf35eefe;hp=065effa485c76bd7be8931ae2f7fa2b2bb336d36;hpb=097d28989cb7d3e3c824212e1ddeeb8d6a2a3f39;p=irc-logger.git diff --git a/logger.lisp b/logger.lisp index 065effa..a6aea52 100644 --- a/logger.lisp +++ b/logger.lisp @@ -381,9 +381,9 @@ (defun add-private-log-entry (logger fmt &rest args) (apply #'add-log-entry - (if (get-private-log-stream logger) + (if (and logger (get-private-log-stream logger)) (get-private-log-stream logger) - *standard-output*) + *standard-output*) fmt args)) (defun privmsg-hook (msg) @@ -399,7 +399,7 @@ (let ((end (- (length (trailing-argument msg)) 1))) ;; end has been as low as 7 (when (< end 8) - (warn "End is less than 8: `$A'." msg)) + (warn "End is less than 8: `~A'." msg)) (output-event msg :action (first (arguments msg)) (subseq (trailing-argument msg) (min 8 end) (- (length (trailing-argument msg)) 1))))) @@ -645,7 +645,8 @@ (add-private-log-entry nil "Calling create-logger [add-logger].~%") (let ((logger (do ((new-logger - (mp:with-timeout (*timeout* nil) + (#-sbcl mp:with-timeout #-sbcl (*timeout* nil) + #+sbcl sb-ext:with-timeout #+sbcl *timeout* (create-logger nick server :channels channels :output output :logging-stream logging-stream :password password :realname realname :username username @@ -653,7 +654,8 @@ :unknown-log unknown-log :formats formats :async async)) - (mp:with-timeout (*timeout* nil) + (#-sbcl mp:with-timeout #-sbcl (*timeout* nil) + #+sbcl sb-ext:with-timeout #+sbcl *timeout* (create-logger nick server :channels channels :output output :logging-stream logging-stream :password password :realname realname :username username @@ -802,23 +804,35 @@ *recon-channel-names* (channel-names logger)) (ignore-errors (remove-logger logger))) - (let ((new-logger - (ignore-errors - (add-logger *recon-nick* *recon-server* - :channels *recon-channel-names* - :output *recon-user-output* - :password *recon-password* - :realname *recon-realname* - :username *recon-username* - :logging-stream *recon-logging-stream* - :private-log *recon-private-log* - :unknown-log *recon-unknown-log* - :async *recon-async* - :formats *recon-formats*)))) - (when new-logger - (sleep 5) - (when (is-connected new-logger) - (log-reconnection new-logger))))) + (do ((new-logger nil)) + (new-logger) + (setq new-logger + (ignore-errors + (add-logger *recon-nick* *recon-server* + :channels *recon-channel-names* + :output *recon-user-output* + :password *recon-password* + :realname *recon-realname* + :username *recon-username* + :logging-stream *recon-logging-stream* + :private-log *recon-private-log* + :unknown-log *recon-unknown-log* + :async *recon-async* + :formats *recon-formats*))) + (cond + (new-logger + (sleep 240) + (cond + ((is-connected new-logger) + (log-reconnection new-logger)) + (t + (log-daemon-message new-logger "Newly added logger is not connected. Removing connection and will re-attempt.") + (ignore-errors (remove-logger new-logger)) + (sleep 60) + (setq new-logger nil)))) + (t + (log-daemon-message nil "Got NIL for new logger. Waiting and retrying.") + (sleep 20))))) ) ;; end closure (defun daemon-monitor ()