diff options
Diffstat (limited to 'ext/pgsql/tests/29nb_async_connect.phpt')
| -rw-r--r-- | ext/pgsql/tests/29nb_async_connect.phpt | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/ext/pgsql/tests/29nb_async_connect.phpt b/ext/pgsql/tests/29nb_async_connect.phpt index a9b17ebc3a..d98b34da47 100644 --- a/ext/pgsql/tests/29nb_async_connect.phpt +++ b/ext/pgsql/tests/29nb_async_connect.phpt @@ -11,30 +11,30 @@ include('config.inc'); include('nonblocking.inc'); if (!$db = pg_connect($conn_str, PGSQL_CONNECT_ASYNC)) { - die("pg_connect() error"); + die("pg_connect() error"); } elseif (pg_connection_status($db) === PGSQL_CONNECTION_BAD) { - die("pg_connect() error"); + die("pg_connect() error"); } elseif ($db_socket = pg_socket($db)) { - stream_set_blocking($db_socket, FALSE); + stream_set_blocking($db_socket, FALSE); } else { - die("pg_socket() error"); + die("pg_socket() error"); } while (TRUE) { - switch ($status = pg_connect_poll($db)) { - case PGSQL_POLLING_READING: - nb_is_readable($db_socket); - break; - case PGSQL_POLLING_WRITING: - nb_is_writable($db_socket); - break; - case PGSQL_POLLING_FAILED: - die("async connection failed"); - case PGSQL_POLLING_OK: - break 2; - default: - die("unknown poll status"); - } + switch ($status = pg_connect_poll($db)) { + case PGSQL_POLLING_READING: + nb_is_readable($db_socket); + break; + case PGSQL_POLLING_WRITING: + nb_is_writable($db_socket); + break; + case PGSQL_POLLING_FAILED: + die("async connection failed"); + case PGSQL_POLLING_OK: + break 2; + default: + die("unknown poll status"); + } } assert(pg_connection_status($db) === PGSQL_CONNECTION_OK); echo "OK"; |