Skip to content
This repository was archived by the owner on Apr 7, 2026. It is now read-only.

fix: close executor when closing pool #501

Merged
thiagotnunes merged 1 commit into from
Oct 9, 2020
Merged

fix: close executor when closing pool #501

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
40 changes: 24 additions & 16 deletions google-cloud-spanner/src/main/java/com/google/cloud/spanner/connection/SpannerPool.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -390,26 +390,34 @@ void checkAndCloseSpanners(CheckAndCloseSpannersMode mode) {
keysStillInUse.add(entry.getKey());
}
}
if (keysStillInUse.isEmpty() || mode == CheckAndCloseSpannersMode.WARN) {
if (!keysStillInUse.isEmpty()) {
try {
if (keysStillInUse.isEmpty() || mode == CheckAndCloseSpannersMode.WARN) {
if (!keysStillInUse.isEmpty()) {
logLeakedConnections(keysStillInUse);
logger.log(
Level.WARNING,
"There is/are "
+ keysStillInUse.size()
+ " connection(s) still open."
+ " Close all connections before stopping the application");
}
// Force close all Spanner instances by passing in a value that will always be less than
// the
// difference between the current time and the close time of a connection.
closeUnusedSpanners(Long.MIN_VALUE);
} else {
logLeakedConnections(keysStillInUse);
logger.log(
Level.WARNING,
throw SpannerExceptionFactory.newSpannerException(
ErrorCode.FAILED_PRECONDITION,
"There is/are "
+ keysStillInUse.size()
+ " connection(s) still open."
+ " Close all connections before stopping the application");
+ " connection(s) still open. Close all connections before calling closeSpanner()");
}
// Force close all Spanner instances by passing in a value that will always be less than the
// difference between the current time and the close time of a connection.
closeUnusedSpanners(Long.MIN_VALUE);
} else {
logLeakedConnections(keysStillInUse);
throw SpannerExceptionFactory.newSpannerException(
ErrorCode.FAILED_PRECONDITION,
"There is/are "
+ keysStillInUse.size()
+ " connection(s) still open. Close all connections before calling closeSpanner()");
} finally {

@olavloite olavloite Oct 7, 2020

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The only real change here is the addition of the finally block, but GitHub thinks there is a lot more changed because of the changed indentation and formatting.

if (closerService != null) {
closerService.shutdown();

@thiagotnunes thiagotnunes Oct 7, 2020

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Can this throw an exception?

@olavloite olavloite Oct 8, 2020

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Normally, no. It does not declare any checked exceptions, and it also does not wait until it has actually been shutdown, so the chance that anything goes wrong is relatively low.

The method can be invoked in two ways:

  • If a client application calls SpannerPool#closeSpannerPool() to explicitly close the pool. Any exception from closerService.shutdown() would in that case be propagated to the client application. Considering the fact that it would not be a checked exception, I would say that that is a reasonable thing to do, as it might indicate a problem somewhere, for example linked to the state of the client application at that moment.
  • It is called from the shutdown hook that closes the pool automatically when the application terminates. The shutdown hook catches and ignores any errors, as any errors at that moment are (probably) not something that a client application could do anything with. The alternative would be to bubble it up, which would cause the JVM (by default) to print the error to System.err.

@thiagotnunes thiagotnunes Oct 9, 2020

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Cool, that is fine, I was just worried that we could bubble up exceptions that we previously did not.

}
initialized = false;
}
}
}
Expand Down