Unregister pgsql connection fds when they are deleted.

diff --git a/src/modules/extra/m_pgsql.cpp b/src/modules/extra/m_pgsql.cpp
index 916f164d189142f513cbb60c202f71ab2f790f75..c64017d6168b0a118b43ad8bc614d1787655a127 100644 (file)
--- a/src/modules/extra/m_pgsql.cpp
+++ b/src/modules/extra/m_pgsql.cpp
@@ -225,6 +225,7 @@ class SQLConn : public SQL::Provider, public EventHandler
                        q->OnError(err);
                        delete q;
                }
+               Close();
        }
 
        void OnEventHandlerRead() CXX11_OVERRIDE
@@ -506,7 +507,9 @@ restart:
        void Close()
        {
                status = DEAD;
-               SocketEngine::DelFd(this);
+
+               if (HasFd() && SocketEngine::HasFd(GetFd()))
+                       SocketEngine::DelFd(this);
 
                if(sql)
                {