Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

fix: In logical decoding the if the backend was requesting a reply we… #1467

Merged
merged 7 commits into from Aug 28, 2019

ignore concurrent requests to processCopyResults

  • Loading branch information...
davecramer committed Aug 27, 2019
commit 52a09ec65e1798dd29cf1b47b8cf510137cf0f40
@@ -1081,8 +1081,12 @@ synchronized void readFromCopy(CopyOperationImpl op, boolean block) throws SQLEx
CopyOperationImpl processCopyResults(CopyOperationImpl op, boolean block)
throws SQLException, IOException {

/*
* This is a hack as we should not end up here, but sometimes do with large copy operations.
*/
if ( processingCopyResults.compareAndSet(false,true) == false ) {
throw new PSQLException("Debug should not be here", PSQLState.UNKNOWN_STATE);
LOGGER.log(Level.INFO, "Ignoring request to process copy results, already processing");
return null;
}

boolean endReceiving = false;
ProTip! Use n and p to navigate between commits in a pull request.
You can’t perform that action at this time.