|
@@ -709,11 +709,11 @@ public class SFTPFileSystem extends FileSystem {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public void close() throws IOException {
|
|
public void close() throws IOException {
|
|
- if (closed.getAndSet(true)) {
|
|
|
|
- return;
|
|
|
|
- }
|
|
|
|
try {
|
|
try {
|
|
super.close();
|
|
super.close();
|
|
|
|
+ if (closed.getAndSet(true)) {
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
} finally {
|
|
} finally {
|
|
if (connectionPool != null) {
|
|
if (connectionPool != null) {
|
|
connectionPool.shutdown();
|
|
connectionPool.shutdown();
|