File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed
web/client-api/src/main/java/io/deephaven/web/client/api Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change 3939import io .deephaven .javascript .proto .dhinternal .io .deephaven_core .proto .partitionedtable_pb_service .PartitionedTableServiceClient ;
4040import io .deephaven .javascript .proto .dhinternal .io .deephaven_core .proto .session_pb .ExportRequest ;
4141import io .deephaven .javascript .proto .dhinternal .io .deephaven_core .proto .session_pb .ExportResponse ;
42+ import io .deephaven .javascript .proto .dhinternal .io .deephaven_core .proto .session_pb .HandshakeRequest ;
4243import io .deephaven .javascript .proto .dhinternal .io .deephaven_core .proto .session_pb .PublishRequest ;
4344import io .deephaven .javascript .proto .dhinternal .io .deephaven_core .proto .session_pb .ReleaseRequest ;
4445import io .deephaven .javascript .proto .dhinternal .io .deephaven_core .proto .session_pb .TerminationNotificationRequest ;
@@ -618,6 +619,14 @@ public void forceClose() {
618619 DomGlobal .clearTimeout (scheduledAuthUpdate );
619620 scheduledAuthUpdate = null ;
620621 }
622+
623+ // Allow this to be disabled in case races are possible that break this.
624+ // Flag is temporary, as long as we're sure there are no ill effects from the feature.
625+ ConfigValue disableCloseOnDisconnect = getServerConfigValue ("web.disableCloseSessionOnDisconnect" );
626+ if (disableCloseOnDisconnect == null || !disableCloseOnDisconnect .hasStringValue ()) {
627+ sessionServiceClient .closeSession (new HandshakeRequest (), metadata ());
628+ }
629+ metadata ().delete (FLIGHT_AUTH_HEADER_NAME );
621630 }
622631
623632 public void setSessionTimeoutMs (double sessionTimeoutMs ) {
You can’t perform that action at this time.
0 commit comments