TheArchive/tailscale
1
0
Fork 0
mirror of https://github.com/tailscale/tailscale.git synced 2025-04-21 06:01:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

tka: allow checkpoint AUMs to change TKA state

Browse Source 
Updates https://github.com/tailscale/corp/issues/8568
Signed-off-by: Tom DNetto <tom@tailscale.com>
This commit is contained in:
Tom DNetto 2023-07-19 09:33:12 -07:00 committed by Tom
parent 24f0e91169
commit 2c782d742c
1 changed files with 1 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tka/tka.go
View File

@ -9,7 +9,6 @@ import (
"errors" "errors"
"fmt" "fmt"
"os" "os"
"reflect"
"sort" "sort"
"github.com/fxamacker/cbor/v2" "github.com/fxamacker/cbor/v2"
@ -182,17 +181,6 @@ func advanceByPrimary(state State, candidates []AUM) (next *AUM, out State, err
aum := pickNextAUM(state, candidates) aum := pickNextAUM(state, candidates)
// TODO(tom): Remove this before GA, this is just a correctness check during implementation.
// Post-GA, we want clients to not error if they dont recognize additional fields in State.
if aum.MessageKind == AUMCheckpoint {
dupe := state
dupe.LastAUMHash = nil
// aum.State is non-nil (see aum.StaticValidate).
if !reflect.DeepEqual(dupe, *aum.State) {
return nil, State{}, errors.New("checkpoint includes changes not represented in earlier AUMs")
}
}
if state, err = state.applyVerifiedAUM(aum); err != nil { if state, err = state.applyVerifiedAUM(aum); err != nil {
return nil, State{}, fmt.Errorf("advancing state: %v", err) return nil, State{}, fmt.Errorf("advancing state: %v", err)
} }
@ -334,8 +322,7 @@ func computeStateAt(storage Chonk, maxIter int, wantHash AUMHash) (State, error)
// as we've already iterated through them above so they must exist, // as we've already iterated through them above so they must exist,
// but we check anyway to be super duper sure. // but we check anyway to be super duper sure.
if err == nil && *state.LastAUMHash != wantHash { if err == nil && *state.LastAUMHash != wantHash {
// TODO(tom): Error instead of panic before GA. return State{}, errors.New("unexpected fastForward outcome")
panic("unexpected fastForward outcome")
} }
return state, err return state, err
} }