-
Notifications
You must be signed in to change notification settings - Fork 307
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
Assert DB is open before createStreamKeyRaw #9014
Conversation
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
storage/src/main/java/tech/pegasys/teku/storage/server/rocksdb/RocksDbInstance.java
Fixed
Show fixed
Hide fixed
storage/src/main/java/tech/pegasys/teku/storage/server/rocksdb/RocksDbInstance.java
Fixed
Show fixed
Hide fixed
883f7b2
to
b12d493
Compare
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
Signed-off-by: Gabriel Fukushima <[email protected]>
@@ -160,6 +165,7 @@ public Stream<ColumnEntry<Bytes, Bytes>> streamRaw(final KvStoreColumn<?, ?> col | |||
@Override | |||
@MustBeClosed | |||
public Stream<Bytes> streamKeysRaw(final KvStoreColumn<?, ?> column) { | |||
assertOpen(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this is checked in createStreamRaw, we can let it go through here i think...
@@ -60,6 +64,7 @@ public class RocksDbInstance implements KvStoreAccessor { | |||
|
|||
@Override | |||
public <T> Optional<T> get(final KvStoreVariable<T> variable) { | |||
assertOpen(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this one shouldnt be needed? it's asserted in getRaw
...
services/chainstorage/src/main/java/tech/pegasys/teku/services/chainstorage/StorageService.java
Show resolved
Hide resolved
closing this as a few improvements here were merged on other PRs |
PR Description
This PR adds a validation before create a stream to avoid the SIGSEGV we were getting on shutdown using RocksDB.
Fixed Issue(s)
Fixes #8939
Documentation
doc-change-required
label to this PR if updates are required.Changelog