File tree Expand file tree Collapse file tree
crates/openshell-server/src Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -336,7 +336,7 @@ struct PendingRelay {
336336 sandbox_id : String ,
337337 relay_open : RelayOpen ,
338338 created_at : Instant ,
339- /// Last session whose outbound queue received this RelayOpen.
339+ /// Last session whose outbound queue received this ` RelayOpen` .
340340 delivered_session_id : Option < String > ,
341341}
342342
@@ -820,12 +820,10 @@ impl SupervisorSessionRegistry {
820820 . map_err ( |_| Status :: unavailable ( "supervisor session disconnected" ) ) ?;
821821 let sent = {
822822 let sessions = self . sessions . lock ( ) . unwrap ( ) ;
823- if ! sessions
823+ if sessions
824824 . get ( sandbox_id)
825825 . is_some_and ( |session| session. session_id == session_id)
826826 {
827- false
828- } else {
829827 let mut pending = self . pending_relays . lock ( ) . unwrap ( ) ;
830828 if pending. len ( ) >= MAX_PENDING_RELAYS {
831829 return Err ( Status :: resource_exhausted ( format ! (
@@ -857,6 +855,8 @@ impl SupervisorSessionRegistry {
857855 payload : Some ( gateway_message:: Payload :: RelayOpen ( relay_open. clone ( ) ) ) ,
858856 } ) ;
859857 true
858+ } else {
859+ false
860860 }
861861 } ;
862862 if sent {
@@ -962,9 +962,9 @@ impl SupervisorSessionRegistry {
962962 break ;
963963 } ;
964964 let sessions = self . sessions . lock ( ) . unwrap ( ) ;
965- if ! sessions
965+ if sessions
966966 . get ( sandbox_id)
967- . is_some_and ( |session| session. session_id = = session_id)
967+ . is_none_or ( |session| session. session_id ! = session_id)
968968 {
969969 break ;
970970 }
You can’t perform that action at this time.
0 commit comments