static void php_pqconn_wakeup(php_persistent_handle_factory_t *f, void **handle)
{
PGresult *res = PQexec(*handle, "");
- php_pq_clear_res(res);
+ php_pqres_clear(res);
if (CONNECTION_OK != PQstatus(*handle)) {
PQreset(*handle);
PGresult *res = unlisten(obj->intern->conn, key->key->val, key->key->len);
if (res) {
- php_pq_clear_res(res);
+ php_pqres_clear(res);
}
return ZEND_HASH_APPLY_REMOVE;
}
/* clean up async results */
while ((res = PQgetResult(*handle))) {
- php_pq_clear_res(res);
+ php_pqres_clear(res);
}
/* clean up transaction & session */
}
if (res) {
- php_pq_clear_res(res);
+ php_pqres_clear(res);
}
if (evdata) {
if (res) {
php_pqres_success(res);
- php_pq_clear_res(res);
+ php_pqres_clear(res);
}
}
}
obj->intern->poller = PQconsumeInput;
php_pqconn_add_listener(obj, channel_str, channel_len, &listener);
}
- php_pq_clear_res(res);
+ php_pqres_clear(res);
}
php_pqconn_notify_listeners(obj);
throw_exce(EX_RUNTIME, "Failed to notify listeners (%s)", PHP_PQerrorMessage(obj->intern->conn));
} else {
php_pqres_success(res);
- php_pq_clear_res(res);
+ php_pqres_clear(res);
}
php_pqconn_notify_listeners(obj);
} else if (SUCCESS == php_pqres_success(res)) {
php_pq_object_to_zval_no_addref(PQresultInstanceData(res, php_pqconn_event), return_value);
} else {
- php_pq_clear_res(res);
+ php_pqres_clear(res);
}
php_pqconn_notify_listeners(obj);
if (SUCCESS == php_pqres_success(res)) {
php_pq_object_to_zval_no_addref(PQresultInstanceData(res, php_pqconn_event), return_value);
} else {
- php_pq_clear_res(res);
+ php_pqres_clear(res);
}
php_pqconn_notify_listeners(obj);
throw_exce(EX_RUNTIME, "Failed to prepare statement (%s)", PHP_PQerrorMessage(obj->intern->conn));
} else {
rv = php_pqres_success(res);
- php_pq_clear_res(res);
+ php_pqres_clear(res);
php_pqconn_notify_listeners(obj);
}
throw_exce(EX_RUNTIME, "Failed to declare cursor (%s)", PHP_PQerrorMessage(obj->intern->conn));
} else {
rv = php_pqres_success(res);
- php_pq_clear_res(res);
+ php_pqres_clear(res);
php_pqconn_notify_listeners(obj);
}
throw_exce(EX_RUNTIME, "Failed to start transaction (%s)", PHP_PQerrorMessage(conn_obj->intern->conn));
} else {
rv = php_pqres_success(res);
- php_pq_clear_res(res);
+ php_pqres_clear(res);
php_pqconn_notify_listeners(conn_obj);
}