Skip to content

Commit 9bedc0d

Browse files
committed
Merge branch '2.0' into 2.1
2 parents 64079de + 1f65ad4 commit 9bedc0d

2 files changed

Lines changed: 1 addition & 4 deletions

File tree

changelog/README.md

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
Merged from 2.0 branch:
1313

1414
- [bug] JAVA-994: Don't call on(Up|Down|Add|Remove) methods if Cluster is closed/closing.
15-
- [bug] JAVA-995: Defunct connection even if initializing.
1615

1716

1817
### 2.1.9
@@ -353,8 +352,6 @@ Merged from 2.0 branch: everything up to 2.0.3 (included), and the following.
353352
### 2.0.13 (in progress)
354353

355354
- [bug] JAVA-994: Don't call on(Up|Down|Add|Remove) methods if Cluster is closed/closing.
356-
- [bug] JAVA-995: Defunct connection even if initializing.
357-
358355

359356
### 2.0.12
360357

driver-core/src/main/java/com/datastax/driver/core/Connection.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1063,7 +1063,7 @@ private class ChannelCloseListener implements ChannelFutureListener {
10631063
public void operationComplete(ChannelFuture future) throws Exception {
10641064
// If we've closed the channel client side then we don't really want to defunct the connection, but
10651065
// if there is remaining thread waiting on us, we still want to wake them up
1066-
if (isClosed()) {
1066+
if (!isInitialized || isClosed()) {
10671067
dispatcher.errorOutAllHandler(new TransportException(address, "Channel has been closed"));
10681068
// we still want to force so that the future completes
10691069
Connection.this.closeAsync().force();

0 commit comments

Comments
 (0)