Update fleetspeak/src/server/spanner/broadcaststore.go

daschwanden · coperni · web-flow · commit 2fd7fe211cac · 2025-03-03T10:12:18.000+01:00
Co-authored-by: coperni &lt;5769938+coperni@users.noreply.github.com&gt;
diff --git a/fleetspeak/src/server/spanner/broadcaststore.go b/fleetspeak/src/server/spanner/broadcaststore.go
@@ -284,7 +284,5 @@ func (d *Datastore) tryCleanupAllocation(ctx context.Context, txn *spanner.ReadW
 	broadcastCols := []string{"BroadcastID", "Allocated", "Sent"}
 	ms := []*spanner.Mutation{spanner.Update(d.broadcasts, broadcastCols, []interface{}{bid.Bytes(), int64(newAllocated), bSent + baSent})}
 	ms = append(ms, spanner.Delete(d.broadcastAllocations, spanner.Key{bid.Bytes(), aid.Bytes()}))
-	txn.BufferWrite(ms)
-
-	return nil
+	return txn.BufferWrite(ms)
 }

Original file line number	Diff line number	Diff line change
`@@ -284,7 +284,5 @@ func (d Datastore) tryCleanupAllocation(ctx context.Context, txn spanner.ReadW`
`284`	`284`	`broadcastCols := []string{"BroadcastID", "Allocated", "Sent"}`
`285`	`285`	`ms := []*spanner.Mutation{spanner.Update(d.broadcasts, broadcastCols, []interface{}{bid.Bytes(), int64(newAllocated), bSent + baSent})}`
`286`	`286`	`ms = append(ms, spanner.Delete(d.broadcastAllocations, spanner.Key{bid.Bytes(), aid.Bytes()}))`
`287`		`- txn.BufferWrite(ms)`
`288`		`-`
`289`		`- return nil`
	`287`	`+ return txn.BufferWrite(ms)`
`290`	`288`	`}`