Upstream/waveterm
1
0
Fork 0
mirror of https://github.com/wavetermdev/waveterm.git synced 2025-01-30 23:01:30 +01:00
Code Issues Packages Projects Releases Wiki Activity

create new contexts for goroutine calls

Browse Source
This commit is contained in:
sawka 2023-12-18 14:41:53 -08:00
parent 80f7162691
commit 7a37fdb942
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
wavesrv/pkg/cmdrunner/cmdrunner.go
View File

@ -3974,7 +3974,9 @@ func setNoTelemetry(ctx context.Context, clientData *sstore.ClientData, noTeleme
}
log.Printf("client no-telemetry setting updated to %v\n", noTelemetryVal)
go func() {
err := pcloud.SendNoTelemetryUpdate(ctx, clientOpts.NoTelemetry)
cloudCtx, cancelFn := context.WithTimeout(context.Background(), 10*time.Second)
defer cancelFn()
err := pcloud.SendNoTelemetryUpdate(cloudCtx, clientOpts.NoTelemetry)
if err != nil {
log.Printf("[error] sending no-telemetry update: %v\n", err)
log.Printf("note that telemetry update has still taken effect locally, and will be respected by the client\n")
@ -3996,7 +3998,9 @@ func TelemetryOnCommand(ctx context.Context, pk *scpacket.FeCommandPacketType) (
return nil, err
}
go func() {
err := pcloud.SendTelemetry(ctx, false)
cloudCtx, cancelFn := context.WithTimeout(context.Background(), 10*time.Second)
defer cancelFn()
err := pcloud.SendTelemetry(cloudCtx, false)
if err != nil {
// ignore error, but log
log.Printf("[error] sending telemetry update (in /telemetry:on): %v\n", err)