Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Chaining WM #1388

Merged
merged 34 commits into from
Apr 10, 2024
Merged
Changes from 1 commit
Commits
Show all changes
34 commits
Select commit Hold shift + click to select a range
3e2b5e8
wm chain setup
Hitenjain14 Feb 15, 2024
0f4a46d
Merge branch 'staging' of https://github.com/0chain/blobber into feat…
Hitenjain14 Feb 15, 2024
cdfa217
Merge branch 'sprint-1.13' of https://github.com/0chain/blobber into …
Hitenjain14 Feb 15, 2024
b9f4d18
fix lint
Hitenjain14 Feb 15, 2024
1d5d87e
add sql migration
Hitenjain14 Feb 15, 2024
b51a8c5
fix migration
Hitenjain14 Feb 15, 2024
7d50fa5
add chain data in refpath
Hitenjain14 Feb 15, 2024
72d2603
add save logs
Hitenjain14 Feb 15, 2024
8435fea
add query param chain data
Hitenjain14 Feb 15, 2024
8dc720c
unlock wm on commit
Hitenjain14 Feb 15, 2024
b4b7a56
export chain length
Hitenjain14 Feb 15, 2024
42e0ced
fix uncommitted markers
Hitenjain14 Feb 15, 2024
9189ecf
fix sequence
Hitenjain14 Feb 15, 2024
b2772c7
change chainhash verify
Hitenjain14 Feb 16, 2024
1491cb1
Revert "change chainhash verify"
Hitenjain14 Feb 16, 2024
157ee28
fix chain size
Hitenjain14 Feb 16, 2024
87b1921
calculate chain hash
Hitenjain14 Feb 17, 2024
be1740c
fix wm update
Hitenjain14 Feb 17, 2024
92ae4a2
add chain hash logs
Hitenjain14 Feb 18, 2024
734ff94
add chain lenght logs
Hitenjain14 Feb 18, 2024
861f741
add commit log
Hitenjain14 Feb 19, 2024
6a4a4c8
Revert "fix wm update"
Hitenjain14 Feb 19, 2024
fc1c11f
revert commit marker logs
Hitenjain14 Feb 19, 2024
f88bf2a
move chain values to config
Hitenjain14 Feb 19, 2024
09eddac
add support for old wm in validators
Hitenjain14 Feb 23, 2024
b1dd3a3
Merge branch 'sprint-1.13' of https://github.com/0chain/blobber into …
Hitenjain14 Feb 23, 2024
35b95bf
Merge branch 'sprint-1.13' into feat/wm-chain
Hitenjain14 Feb 26, 2024
44090b9
Merge branch 'sprint-1.13' into feat/wm-chain
Hitenjain14 Mar 4, 2024
4753b4e
fix lint nil check
Hitenjain14 Mar 8, 2024
e307c23
add wm version
Hitenjain14 Apr 6, 2024
da2e84a
Merge remote-tracking branch 'origin' into feat/wm-chain
Hitenjain14 Apr 6, 2024
9bae8c6
Merge branch 'sprint-1.14' of https://github.com/0chain/blobber into …
Hitenjain14 Apr 6, 2024
ab9404c
Merge branch 'sprint-1.14' into feat/wm-chain
Hitenjain14 Apr 8, 2024
66ea139
change base go version
Hitenjain14 Apr 8, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions code/go/0chain.net/blobbercore/writemarker/protocol.go
Original file line number Diff line number Diff line change
@@ -150,6 +150,8 @@ func (wme *WriteMarkerEntity) redeemMarker(ctx context.Context, startSeq int64)
return err
}

Logger.Info("redeem_marker_chain", zap.String("allocation_id", wme.WM.AllocationID), zap.Int("chain_data_length", len(sn.ChainData)), zap.Int("chain_length", wme.WM.ChainLength))

commitedMarker, err := GetLatestCommittedWriteMarker(ctx, wme.WM.AllocationID)
if err != nil {
return err
@@ -175,6 +177,8 @@ func (wme *WriteMarkerEntity) redeemMarker(ctx context.Context, startSeq int64)
}
return common.NewError("chain_hash_mismatch", "Chain hash does not match")
}
} else {
Logger.Info("no_committed_marker", zap.String("allocation_id", wme.WM.AllocationID))
}

if sn.AllocationRoot == sn.PrevAllocationRoot {