TrueCloudLab/xk6-frostfs
42
1
Fork 20
Code Issues 33 Pull requests 2 Releases Activity Actions

native: Issue session token on the previous epoch #185

Merged
fyrchik merged 1 commit from fyrchik/xk6-frostfs:fix-native-epoch into master 2024-12-19 12:37:24 +00:00
Conversation 0 Commits 1 Files changed 1 +9 -4
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
internal/native/native.go
View file

@ -118,11 +118,16 @@ func (n *Native) Connect(endpoint, hexPrivateKey string, dialTimeout, streamTime
tok.SetAuthKey(&key) tok.SetAuthKey(&key)
tok.SetExp(exp) tok.SetExp(exp)
if prepareLocally && maxObjSize > 0 {
res, err := cli.NetworkInfo(n.vu.Context(), client.PrmNetworkInfo{}) res, err := cli.NetworkInfo(n.vu.Context(), client.PrmNetworkInfo{})
if err != nil { if err != nil {
return nil, err return nil, err
} }
prevEpoch := res.Info().CurrentEpoch() - 1
tok.SetNbf(prevEpoch)
tok.SetIat(prevEpoch)
if prepareLocally && maxObjSize > 0 {
if uint64(maxObjSize) > res.Info().MaxObjectSize() { if uint64(maxObjSize) > res.Info().MaxObjectSize() {
return nil, fmt.Errorf("max object size must be not greater than %d bytes", res.Info().MaxObjectSize()) return nil, fmt.Errorf("max object size must be not greater than %d bytes", res.Info().MaxObjectSize())
} }