File tree Expand file tree Collapse file tree 1 file changed +10
-2
lines changed Expand file tree Collapse file tree 1 file changed +10
-2
lines changed Original file line number Diff line number Diff line change @@ -1068,13 +1068,21 @@ static PHP_METHOD(PDO, pgsqlGetNotify)
1068
1068
1069
1069
H = (pdo_pgsql_db_handle * )dbh -> driver_data ;
1070
1070
1071
- PQconsumeInput (H -> server );
1071
+ if (!PQconsumeInput (H -> server )) {
1072
+ pdo_pgsql_error (dbh , PGRES_FATAL_ERROR , NULL );
1073
+ PDO_HANDLE_DBH_ERR ();
1074
+ RETURN_FALSE ;
1075
+ }
1072
1076
pgsql_notify = PQnotifies (H -> server );
1073
1077
1074
1078
if (ms_timeout && !pgsql_notify ) {
1075
1079
php_pollfd_for_ms (PQsocket (H -> server ), PHP_POLLREADABLE , (int )ms_timeout );
1076
1080
1077
- PQconsumeInput (H -> server );
1081
+ if (!PQconsumeInput (H -> server )) {
1082
+ pdo_pgsql_error (dbh , PGRES_FATAL_ERROR , NULL );
1083
+ PDO_HANDLE_DBH_ERR ();
1084
+ RETURN_FALSE ;
1085
+ }
1078
1086
pgsql_notify = PQnotifies (H -> server );
1079
1087
}
1080
1088
You can’t perform that action at this time.
0 commit comments