Skip to content

Commit f8b04b6

Browse files
committed
add descriptions to decRef and close
1 parent 105d04e commit f8b04b6

7 files changed

Lines changed: 7 additions & 7 deletions

File tree

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
}

src/main/java/software/amazon/awssdk/crt/io/ClientBootstrap.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ private void onShutdownComplete() {
9090
public static void closeStaticDefault() {
9191
synchronized (ClientBootstrap.class) {
9292
if (staticDefaultClientBootstrap != null) {
93-
staticDefaultClientBootstrap.close();
93+
staticDefaultClientBootstrap.close("closeStaticDefault");
9494
}
9595
staticDefaultClientBootstrap = null;
9696
}

src/main/java/software/amazon/awssdk/crt/io/EventLoopGroup.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ public static void setStaticDefaultNumThreads(int numThreads) {
9595
public static void closeStaticDefault() {
9696
synchronized (EventLoopGroup.class) {
9797
if (staticDefaultEventLoopGroup != null) {
98-
staticDefaultEventLoopGroup.close();
98+
staticDefaultEventLoopGroup.close("closeStaticDefault");
9999
}
100100
staticDefaultEventLoopGroup = null;
101101
}

src/main/java/software/amazon/awssdk/crt/io/HostResolver.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ public static void setStaticDefaultMaxEntries(int maxEntries) {
7373
public static void closeStaticDefault() {
7474
synchronized (HostResolver.class) {
7575
if (staticDefaultResolver != null) {
76-
staticDefaultResolver.close();
76+
staticDefaultResolver.close("closeStaticDefault");
7777
}
7878
staticDefaultResolver = null;
7979
}

0 commit comments

Comments
 (0)