From 7031bbae437b805a9b21afacbea1fbd414f5cbfd Mon Sep 17 00:00:00 2001 From: Greyson Parrelli Date: Fri, 14 Jul 2023 13:10:08 -0400 Subject: [PATCH] Close the SVR2 socket when we're done. --- .../org/whispersystems/signalservice/api/svr/Svr2Socket.kt | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/libsignal/service/src/main/java/org/whispersystems/signalservice/api/svr/Svr2Socket.kt b/libsignal/service/src/main/java/org/whispersystems/signalservice/api/svr/Svr2Socket.kt index df297fb104..6ae409e0a1 100644 --- a/libsignal/service/src/main/java/org/whispersystems/signalservice/api/svr/Svr2Socket.kt +++ b/libsignal/service/src/main/java/org/whispersystems/signalservice/api/svr/Svr2Socket.kt @@ -117,6 +117,8 @@ internal class Svr2Socket( Stage.WAITING_FOR_RESPONSE -> { Log.d(TAG, "[onMessage] Received response for our request.") emitSuccess(Svr2Response.ADAPTER.decode(client.establishedRecv(bytes.toByteArray()))) + Log.d(TAG, "[onMessage] Success! Closing.") + webSocket.close(1000, "OK") } Stage.CLOSED -> { @@ -134,7 +136,7 @@ internal class Svr2Socket( emitError(e) } catch (e: AttestationDataException) { Log.w(TAG, e) - webSocket.close(1000, "OK") + webSocket.close(1007, "OK") emitError(IOException(e)) } catch (e: SgxCommunicationFailureException) { Log.w(TAG, e)