Skip to content

Commit b89cc99

Browse files
committed
decRef() explainers
1 parent 3928276 commit b89cc99

5 files changed

Lines changed: 5 additions & 5 deletions

File tree

src/main/java/software/amazon/awssdk/crt/CrtResource.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -300,7 +300,7 @@ public boolean isNull() {
300300

301301
@Override
302302
public void close() {
303-
decRef("close() called.");
303+
decRef("close() called");
304304
}
305305

306306
/**

src/main/java/software/amazon/awssdk/crt/eventstream/ClientConnectionContinuationHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ public CompletableFuture<Void> getContinuationClosedFuture() {
6767
@Override
6868
public void close() {
6969
if (continuation != null) {
70-
continuation.decRef();
70+
continuation.decRef("close() called");
7171
continuation = null;
7272
}
7373
}

src/main/java/software/amazon/awssdk/crt/eventstream/ClientConnectionHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ public void close() {
9393
if (clientConnection.isOpen()) {
9494
clientConnection.closeConnection(0);
9595
}
96-
clientConnection.decRef();
96+
clientConnection.decRef("close() called");
9797
clientConnection = null;
9898
}
9999
}

src/main/java/software/amazon/awssdk/crt/eventstream/ServerConnectionContinuationHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ public CompletableFuture<Void> getContinuationClosedFuture() {
6868
@Override
6969
public void close() {
7070
if (continuation != null) {
71-
continuation.decRef();
71+
continuation.decRef("close() called");
7272
continuation = null;
7373
}
7474
}

src/main/java/software/amazon/awssdk/crt/eventstream/ServerConnectionHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ public void close() {
7676
if (connection.isConnectionOpen()) {
7777
connection.closeConnection(0);
7878
}
79-
connection.decRef();
79+
connection.decRef("close() called");
8080
connection = null;
8181
}
8282
}

0 commit comments

Comments
 (0)