Merge pull request #6380 from guggero/websocket-proxy-race-fix

lnrpc: fix websocket proxy data race
This commit is contained in:
Oliver Gugger
2022-03-30 18:13:55 +02:00
committed by GitHub
2 changed files with 5 additions and 2 deletions

View File

@ -72,6 +72,9 @@ then watch it on chain. Taproot script spends are also supported through the
`lncli walletbalance` in existing wallets after upgrading to `lncli walletbalance` in existing wallets after upgrading to
Taproot](https://github.com/lightningnetwork/lnd/pull/6379). Taproot](https://github.com/lightningnetwork/lnd/pull/6379).
* [Fixed a data race in the websocket proxy
code](https://github.com/lightningnetwork/lnd/pull/6380).
## Misc ## Misc
* [An example systemd service file](https://github.com/lightningnetwork/lnd/pull/6033) * [An example systemd service file](https://github.com/lightningnetwork/lnd/pull/6033)

View File

@ -253,7 +253,7 @@ func (p *WebsocketProxy) upgradeToWebSocketProxy(w http.ResponseWriter,
payload = newPayload payload = newPayload
} }
_, err = requestForwarder.Write(payload) _, err := requestForwarder.Write(payload)
if err != nil { if err != nil {
p.logger.Errorf("WS: error writing message "+ p.logger.Errorf("WS: error writing message "+
"to upstream http server: %v", err) "to upstream http server: %v", err)
@ -338,7 +338,7 @@ func (p *WebsocketProxy) upgradeToWebSocketProxy(w http.ResponseWriter,
continue continue
} }
err = conn.WriteMessage( err := conn.WriteMessage(
websocket.TextMessage, responseForwarder.Bytes(), websocket.TextMessage, responseForwarder.Bytes(),
) )
if err != nil { if err != nil {