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.

Sign up for GitHub

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

Jump to bottom

fix: fix race conditions from #14332 #14402

Merged
merged 11 commits into from
Dec 26, 2022
Merged

fix: fix race conditions from #14332 #14402

Show file tree
Hide file tree
Changes from 2 commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
6c2bc3f
fix: fix race conditions from #14332
julienrbrt Dec 23, 2022
6db824a
Merge branch 'main' into julien/export
julienrbrt Dec 23, 2022
9543a13
simplify
julienrbrt Dec 23, 2022
bbbd295
Merge branch 'main' into julien/export
julienrbrt Dec 23, 2022
e5b3fde
add tests
julienrbrt Dec 23, 2022
8371181
updates
julienrbrt Dec 23, 2022
0609840
Merge branch 'main' into julien/export
julienrbrt Dec 23, 2022
3f02ae7
Merge branch 'main' into julien/export
julienrbrt Dec 23, 2022
353903f
Merge branch 'main' into julien/export
julienrbrt Dec 24, 2022
ce1a6bd
Merge branch 'main' into julien/export
julienrbrt Dec 26, 2022
0f3a3d0
Merge branch 'main' into julien/export
alexanderbez Dec 26, 2022
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
11 changes: 4 additions & 7 deletions tests/Makefile
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -4,11 +4,8 @@ test-integration:
test-integration-cov:
go test ./integration/... -timeout 30m -coverpkg=../... -coverprofile=integration-profile.out -covermode=atomic

test-e2e: test-e2e-server
go test ./e2e/... -mod=readonly -timeout 30m -tags='e2e'
test-e2e:
go test ./e2e/... -mod=readonly -timeout 30m -race -tags='e2e'

test-e2e-cov: test-e2e-server
go test ./e2e/... -mod=readonly -timeout 30m -race -tags='e2e' -coverpkg=../... -coverprofile=e2e-profile.out -covermode=atomic

test-e2e-server:
go test ./e2e/server -mod=readonly -timeout 30m -tags='e2e' -coverpkg=../... -coverprofile=e2e-server-profile.out -covermode=atomic
test-e2e-cov:
go test ./e2e/... -mod=readonly -timeout 30m -race -tags='e2e' -coverpkg=../... -coverprofile=e2e-profile.out -covermode=atomic
4 changes: 2 additions & 2 deletions tests/e2e/server/export_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
//go:build !race
// +build !race
//go:build e2e
// +build e2e

package server_test

Expand Down
13 changes: 7 additions & 6 deletions types/module/module.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -395,22 +395,23 @@ func (m *Manager) ExportGenesisForModules(ctx sdk.Context, cdc codec.JSONCodec,
panic(err)
}

channels := make([]chan json.RawMessage, len(modulesToExport))
channels := make(map[string]chan json.RawMessage)
modulesWithGenesis := make([]string, 0, len(modulesToExport))
julienrbrt marked this conversation as resolved.
Show resolved Hide resolved

for i, moduleName := range modulesToExport {
for _, moduleName := range modulesToExport {
if module, ok := m.Modules[moduleName].(HasGenesis); ok {
channels[i] = make(chan json.RawMessage)
channels[moduleName] = make(chan json.RawMessage)
modulesWithGenesis = append(modulesWithGenesis, moduleName)

go func(module HasGenesis, ch chan json.RawMessage) {
ctx := ctx.WithGasMeter(sdk.NewInfiniteGasMeter()) // avoid race conditions
ch <- module.ExportGenesis(ctx, cdc)
}(module, channels[i])
}(module, channels[moduleName])
julienrbrt marked this conversation as resolved.
Show resolved Hide resolved
}
}

for i, moduleName := range modulesWithGenesis {
genesisData[moduleName] = <-channels[i]
for _, moduleName := range modulesWithGenesis {
genesisData[moduleName] = <-channels[moduleName]
}

return genesisData
Expand Down