This commit is contained in:
Bolke de Bruin 2022-08-06 11:51:14 +02:00
parent 6917beb0d2
commit b83f876687

View file

@ -165,10 +165,10 @@ func (s *Server) Process(ctx context.Context) error {
log.Printf("Channel closed while in wrong state %d != %d", s.State, SERVER_STATE_OPENED)
return errors.New("wrong state")
}
log.Printf("Channel closed")
s.Session.TransportIn.Close()
s.Session.TransportOut.Close()
s.State = SERVER_STATE_CLOSED
log.Printf("Channel closed")
return nil
default:
log.Printf("Unknown packet (size %d): %x", sz, pkt)