if (obj->poller == PQconsumeInput) {
RETVAL_LONG(obj->poller(obj->conn) * PGRES_POLLING_OK);
php_pqconn_notify_listeners(getThis(), obj TSRMLS_CC);
if (obj->poller == PQconsumeInput) {
RETVAL_LONG(obj->poller(obj->conn) * PGRES_POLLING_OK);
php_pqconn_notify_listeners(getThis(), obj TSRMLS_CC);