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() {
|
go func() {
|
||||||
defer close(p)
|
defer close(p)
|
||||||
for {
|
for {
|
||||||
j := relayReadFrame(r)
|
b := relayReadFrame(r)
|
||||||
if j == nil {
|
if b == nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
select {
|
select {
|
||||||
case p <- j:
|
case p <- b:
|
||||||
case <-ctx.Done():
|
case <-ctx.Done():
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@ -145,8 +145,7 @@ func clientWriteError(ctx context.Context, ws *websocket.Conn, err error) bool {
|
|||||||
b, ok := (&RelayEventMessage{
|
b, ok := (&RelayEventMessage{
|
||||||
EventSeq: 0,
|
EventSeq: 0,
|
||||||
Data: RelayEventData{
|
Data: RelayEventData{
|
||||||
Interface: RelayEventDataError{
|
Variant: &RelayEventDataError{
|
||||||
Event: RelayEventError,
|
|
||||||
CommandSeq: 0,
|
CommandSeq: 0,
|
||||||
Error: err.Error(),
|
Error: err.Error(),
|
||||||
},
|
},
|
||||||
|
Loading…
x
Reference in New Issue
Block a user