Compare commits
2 Commits
872f2d7c59
...
a011b57ce2
| Author | SHA1 | Date | |
|---|---|---|---|
|
a011b57ce2
|
|||
|
b1ee295345
|
2
liberty
2
liberty
Submodule liberty updated: 75fc6f1c37...aacf1b1d47
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(),
|
||||
},
|
||||
|
||||
Reference in New Issue
Block a user