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

feat(manager): max skew based on time instead of batches #1140

Merged
merged 57 commits into from
Nov 21, 2024
Merged
Changes from 1 commit
Commits
Show all changes
57 commits
Select commit Hold shift + click to select a range
2f66f5e
skew based on time
srene Oct 15, 2024
3e92814
test fix
srene Oct 15, 2024
8f7c678
new skey claculatuin
srene Oct 16, 2024
72f014a
fixing test + bds in mock
srene Oct 16, 2024
02f5ab7
lint fix
srene Oct 16, 2024
306f6e4
test adapted
srene Oct 16, 2024
a48066b
fix + test
srene Oct 16, 2024
58adc23
waiting for batch submission fix
srene Oct 17, 2024
d40e330
avoid waiting too much on startup
srene Oct 17, 2024
e169eda
fixing race conditions
srene Oct 17, 2024
0034ec8
lint fix
srene Oct 17, 2024
c7168c9
update last submitted block time
srene Oct 17, 2024
f37498b
test fix
srene Oct 18, 2024
80fcaf0
comment added
srene Oct 18, 2024
5667a91
test update
srene Oct 18, 2024
7e28f95
merge fix
srene Nov 4, 2024
349ee0e
fix after merge
srene Nov 4, 2024
d9dcfbd
store last settlement block time on store
srene Nov 4, 2024
10af08c
remove redundant call
srene Nov 4, 2024
0892543
move code to submit file
srene Nov 4, 2024
2bb1cf1
wip
srene Nov 5, 2024
d61d19a
skew fix
srene Nov 5, 2024
0169c1d
fix test
srene Nov 5, 2024
3544858
lint fix
srene Nov 5, 2024
d4d1037
var rename
srene Nov 5, 2024
723b243
test
srene Nov 5, 2024
d3cf946
test
srene Nov 5, 2024
c091f71
remove prints
srene Nov 6, 2024
cb3c54a
test update
srene Nov 6, 2024
e5b5a99
merge fix
srene Nov 8, 2024
b79248a
main merge
srene Nov 19, 2024
ad4bf06
fix after merge
srene Nov 19, 2024
7cf3883
addressing comments
srene Nov 19, 2024
a6b23de
rdk bump
srene Nov 19, 2024
247bc27
fix
srene Nov 19, 2024
8b04b99
lint fix
srene Nov 19, 2024
c8d0078
fix test
srene Nov 19, 2024
c190fe6
last block time fix
srene Nov 19, 2024
113fec4
lint fix
srene Nov 19, 2024
8b284c3
log removed
srene Nov 19, 2024
f227659
addressing comments
srene Nov 19, 2024
caf8f5c
move update block time
srene Nov 19, 2024
fac407c
param rename
srene Nov 19, 2024
3f87777
lint fix
srene Nov 19, 2024
fe1af66
wip
srene Nov 19, 2024
e703849
time to atomic int
srene Nov 19, 2024
373c2cb
fix race cond
srene Nov 19, 2024
764fc02
fix test
srene Nov 19, 2024
4405eb5
merge
srene Nov 19, 2024
3dd3e9a
merge fix
srene Nov 19, 2024
cf34896
merge fix
srene Nov 19, 2024
86bbc31
test fix
srene Nov 20, 2024
4e9dc27
improving logs
srene Nov 20, 2024
e28cec4
improving comments
srene Nov 20, 2024
87d785d
comments
srene Nov 21, 2024
e4de0e6
fix
srene Nov 21, 2024
e398d25
lint fix
srene Nov 21, 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
Prev Previous commit
Next Next commit
merge fix
  • Loading branch information
srene committed Nov 19, 2024
commit cf34896f64e362f9de5e4b608bc6616be5a39793
6 changes: 3 additions & 3 deletions block/submit_loop_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -130,8 +130,8 @@ func TestSubmitLoopFastProducerHaltingSubmitter(t *testing.T) {
testSubmitLoop(
t,
testArgs{
nParallel: 50,
testDuration: 2 * time.Second,
nParallel: 10,
testDuration: 4 * time.Second,
batchSkew: 100 * time.Millisecond,
skewMargin: 10 * time.Millisecond,
batchBytes: 100,
Expand All @@ -152,7 +152,7 @@ func TestSubmitLoopTimer(t *testing.T) {
testSubmitLoop(
t,
testArgs{
nParallel: 50,
nParallel: 10,
testDuration: 4 * time.Second,
batchSkew: 100 * time.Millisecond,
skewMargin: 10 * time.Millisecond,
Expand Down
Loading