|
|
@ -195,9 +195,9 @@ GetConnection(UserMapping *user, bool will_prep_stmt, PgFdwConnState **state) |
|
|
|
make_new_connection(entry, user); |
|
|
|
make_new_connection(entry, user); |
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
|
* We check the health of the cached connection here when starting a new |
|
|
|
* We check the health of the cached connection here when using it. In |
|
|
|
* remote transaction. If a broken connection is detected, we try to |
|
|
|
* cases where we're out of all transactions, if a broken connection is |
|
|
|
* reestablish a new connection later. |
|
|
|
* detected, we try to reestablish a new connection later. |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
PG_TRY(); |
|
|
|
PG_TRY(); |
|
|
|
{ |
|
|
|
{ |
|
|
@ -213,9 +213,7 @@ GetConnection(UserMapping *user, bool will_prep_stmt, PgFdwConnState **state) |
|
|
|
ErrorData *errdata = CopyErrorData(); |
|
|
|
ErrorData *errdata = CopyErrorData(); |
|
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
/*
|
|
|
|
* If connection failure is reported when starting a new remote |
|
|
|
* Determine whether to try to reestablish the connection. |
|
|
|
* transaction (not subtransaction), new connection will be |
|
|
|
|
|
|
|
* reestablished later. |
|
|
|
|
|
|
|
* |
|
|
|
* |
|
|
|
* After a broken connection is detected in libpq, any error other |
|
|
|
* After a broken connection is detected in libpq, any error other |
|
|
|
* than connection failure (e.g., out-of-memory) can be thrown |
|
|
|
* than connection failure (e.g., out-of-memory) can be thrown |
|
|
|