diff --git a/relp_handler.go b/relp_handler.go index 6d101f6..b88de07 100644 --- a/relp_handler.go +++ b/relp_handler.go @@ -81,8 +81,14 @@ func (r *RELPHandler) connectToRELPServer() (net.Conn, error) { } conn, err := net.Dial("tcp", net.JoinHostPort(host, port)) if err != nil { + if relpDebug { + log.Printf("Failed to connect to RELP server at %s: %v", net.JoinHostPort(host, port), err) + } return nil, err } + if relpDebug { + log.Printf("Successfully connected to RELP server at %s", net.JoinHostPort(host, port)) + } return conn, nil } @@ -90,8 +96,14 @@ func (r *RELPHandler) Startup() error { var err error r.conn, err = r.connectToRELPServer() if err != nil { + if relpDebug { + log.Printf("Failed to establish TCP connection: %v", err) + } return fmt.Errorf("Failed to establish TCP connection: %v", err) } + if relpDebug { + log.Printf("Successfully connected to RELP server at %s", r.relpServerURL) + } go r.receiveEventsFromChannel() go r.processFailedEvents() go r.watchDirectoryForFailedEventFiles() @@ -172,6 +184,9 @@ func (r *RELPHandler) watchDirectoryForFailedEventFiles() { return default: if r.isConnected() { + if relpDebug { + log.Printf("Reconnected to RELP server at %s", r.relpServerURL) + } files, err := ioutil.ReadDir(cacheDir) if err != nil { log.Printf("Error reading cache directory: %v", err)