Compare commits
No commits in common. "a011b57ce24c8c78c1ccbc3137d2a0d5e814c1ba" and "872f2d7c59645e5ce0ddfb703a46bed50f16705b" have entirely different histories.
a011b57ce2
...
872f2d7c59
2
liberty
2
liberty
@ -1 +1 @@
|
||||
Subproject commit aacf1b1d47824de2c924874e3d6cdad1d8b5ba2b
|
||||
Subproject commit 75fc6f1c374796f9e794297c3893089009b8772f
|
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 {
|
||||
b := relayReadFrame(r)
|
||||
if b == nil {
|
||||
j := relayReadFrame(r)
|
||||
if j == nil {
|
||||
return
|
||||
}
|
||||
select {
|
||||
case p <- b:
|
||||
case p <- j:
|
||||
case <-ctx.Done():
|
||||
return
|
||||
}
|
||||
@ -145,7 +145,8 @@ func clientWriteError(ctx context.Context, ws *websocket.Conn, err error) bool {
|
||||
b, ok := (&RelayEventMessage{
|
||||
EventSeq: 0,
|
||||
Data: RelayEventData{
|
||||
Variant: &RelayEventDataError{
|
||||
Interface: RelayEventDataError{
|
||||
Event: RelayEventError,
|
||||
CommandSeq: 0,
|
||||
Error: err.Error(),
|
||||
},
|
||||
|
Loading…
x
Reference in New Issue
Block a user