fix missing return

diff --git a/src/php_pq.c b/src/php_pq.c
index eb9bac1e5a344182a6d64acb5d18eec25413b383..20182c277fb7996ef0e34b35a4e0c0321be0bdea 100644 (file)
--- a/src/php_pq.c
+++ b/src/php_pq.c
@@ -977,6 +977,7 @@ static PHP_METHOD(pqconn, poll) {
                                if (obj->poller == PQconsumeInput) {
                                        RETVAL_LONG(obj->poller(obj->conn) * PGRES_POLLING_OK);
                                        php_pqconn_notify_listeners(getThis(), obj TSRMLS_CC);
+                                       return;
                                } else {
                                        RETURN_LONG(obj->poller(obj->conn));
                                }