Compare commits
2 Commits
872f2d7c59
...
a011b57ce2
Author | SHA1 | Date | |
---|---|---|---|
a011b57ce2 | |||
b1ee295345 |
2
liberty
2
liberty
@ -1 +1 @@
|
||||
Subproject commit 75fc6f1c374796f9e794297c3893089009b8772f
|
||||
Subproject commit aacf1b1d47824de2c924874e3d6cdad1d8b5ba2b
|
9
xP/xP.go
9
xP/xP.go
@ -75,12 +75,12 @@ func relayMakeReceiver(ctx context.Context, conn net.Conn) <-chan []byte {
|
||||
go func() {
|
||||
defer close(p)
|
||||
for {
|
||||
j := relayReadFrame(r)
|
||||
if j == nil {
|
||||
b := relayReadFrame(r)
|
||||
if b == nil {
|
||||
return
|
||||
}
|
||||
select {
|
||||
case p <- j:
|
||||
case p <- b:
|
||||
case <-ctx.Done():
|
||||
return
|
||||
}
|
||||
@ -145,8 +145,7 @@ func clientWriteError(ctx context.Context, ws *websocket.Conn, err error) bool {
|
||||
b, ok := (&RelayEventMessage{
|
||||
EventSeq: 0,
|
||||
Data: RelayEventData{
|
||||
Interface: RelayEventDataError{
|
||||
Event: RelayEventError,
|
||||
Variant: &RelayEventDataError{
|
||||
CommandSeq: 0,
|
||||
Error: err.Error(),
|
||||
},
|
||||
|
Loading…
x
Reference in New Issue
Block a user