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
New Record Stream Facility #6469
Conversation
82f74f9
to
bdb3981
Compare
BTW, over at a different PR dealing with stream files I ask a question about the "simple checksum" that involves the magic number |
96e86df
to
909dfdf
Compare
9c479c7
to
cbc000c
Compare
c5fd9ce
to
5c473a7
Compare
c2aaf9c
to
da67924
Compare
I have no idea of that odd checksum. Seems not very useful, would love to remove it. |
dbb03e2
to
de71ede
Compare
hedera-node/hedera-app-spi/src/main/java/com/hedera/node/app/spi/info/NodeInfo.java
Outdated
Show resolved
Hide resolved
...ra-app-spi/src/main/java/com/hedera/node/app/spi/records/SingleTransactionRecordBuilder.java
Outdated
Show resolved
Hide resolved
hedera-node/hedera-app/src/main/java/com/hedera/node/app/info/MonoNodeInfo.java
Outdated
Show resolved
Hide resolved
hedera-node/hedera-app/src/main/java/com/hedera/node/app/records/BlockRecordManager.java
Outdated
Show resolved
Hide resolved
hedera-node/hedera-app/src/main/java/com/hedera/node/app/records/files/RecordFileFormat.java
Outdated
Show resolved
Hide resolved
hedera-node/hedera-app/src/main/java/com/hedera/node/app/records/files/RecordFileWriter.java
Outdated
Show resolved
Hide resolved
hedera-node/hedera-app/src/main/java/com/hedera/node/app/records/files/RecordFileWriter.java
Outdated
Show resolved
Hide resolved
hedera-node/hedera-app/src/test/java/com/hedera/node/app/records/files/RecordStreamV6Test.java
Outdated
Show resolved
Hide resolved
hedera-node/hedera-app/src/main/java/com/hedera/node/app/records/BlockRecordManagerImpl.java
Outdated
Show resolved
Hide resolved
e37b8e2
to
08b8a68
Compare
Codecov ReportPatch coverage:
Additional details and impacted files@@ Coverage Diff @@
## develop #6469 +/- ##
==============================================
+ Coverage 68.81% 89.74% +20.93%
+ Complexity 25010 19911 -5099
==============================================
Files 2302 1574 -728
Lines 146837 59045 -87792
Branches 8921 6241 -2680
==============================================
- Hits 101039 52990 -48049
+ Misses 43926 4712 -39214
+ Partials 1872 1343 -529
☔ View full report in Codecov by Sentry. |
...-app-spi/src/testFixtures/java/com/hedera/node/app/spi/fixtures/state/MapWritableStates.java
Show resolved
Hide resolved
...c/testFixtures/java/com/hedera/node/app/spi/fixtures/state/ObjectReadableSingletonState.java
Outdated
Show resolved
Hide resolved
...c/testFixtures/java/com/hedera/node/app/spi/fixtures/state/ObjectWritableSingletonState.java
Outdated
Show resolved
Hide resolved
...ra-node/hedera-app/src/main/java/com/hedera/node/app/records/BlockRecordInjectionModule.java
Outdated
Show resolved
Hide resolved
hedera-node/hedera-app/src/main/java/com/hedera/node/app/records/BlockRecordManager.java
Outdated
Show resolved
Hide resolved
hedera-node/hedera-app/src/main/java/com/hedera/node/app/records/BlockRecordManager.java
Show resolved
Hide resolved
Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Fixed JavaDoc Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Fixed one test Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Applied Spotless Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Updated UtilPrngHandler to use BlockRecordInfo Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Updated UtilPrngHandler to use BlockRecordInfo Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Fixes to most review comments Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Lots more testing and fixing, happy now Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Much better testing Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Spotless cleanup Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Progress and tests pass :-) Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Fix after rebase and moved to using Google Jimfs file system for faster tests Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Added test record data Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Fixing things adding tests Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Lots of progress Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Think I have the structure right and state Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Refactored connection to workflow Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Refactored for V7 and fixed HandleWorkflow relationship with BlockRecordManager Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Removed need for Pbj Helper as PBJ 0.6.0 has needed API Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Clean up First working version of Record file writing. Make everything compile after rebase. Progress on BlockRecordManager. Added StreamFileProducer. Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com>
Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com>
Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com>
Signed-off-by: Richard Bair <rbair23@users.noreply.github.com>
Signed-off-by: Richard Bair <rbair23@users.noreply.github.com>
72c9eb0
to
102e405
Compare
Do we want to update the |
hedera-node/hedera-app/src/main/java/com/hedera/node/app/info/NetworkInfoImpl.java
Show resolved
Hide resolved
hedera-node/hedera-app/src/main/java/com/hedera/node/app/records/BlockRecordStreamConfig.java
Outdated
Show resolved
Hide resolved
...a-node/hedera-app/src/main/java/com/hedera/node/app/records/impl/BlockRecordManagerImpl.java
Outdated
Show resolved
Hide resolved
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.
We should discuss in more detail how the state changes have to be committed. I think the BlockRecordManagerImpl
has to be responsible to commit its own state, but I am not sure.
...a-node/hedera-app/src/main/java/com/hedera/node/app/records/impl/BlockRecordManagerImpl.java
Outdated
Show resolved
Hide resolved
...a-node/hedera-app/src/main/java/com/hedera/node/app/records/impl/BlockRecordManagerImpl.java
Show resolved
Hide resolved
...a-node/hedera-app/src/main/java/com/hedera/node/app/records/impl/BlockRecordManagerImpl.java
Show resolved
Hide resolved
...a-node/hedera-app/src/main/java/com/hedera/node/app/records/impl/BlockRecordManagerImpl.java
Outdated
Show resolved
Hide resolved
...a-node/hedera-app/src/main/java/com/hedera/node/app/records/impl/BlockRecordManagerImpl.java
Show resolved
Hide resolved
...p/src/main/java/com/hedera/node/app/records/impl/producers/StreamFileProducerConcurrent.java
Show resolved
Hide resolved
...p/src/main/java/com/hedera/node/app/records/impl/producers/StreamFileProducerConcurrent.java
Show resolved
Hide resolved
...c/main/java/com/hedera/node/app/records/impl/producers/StreamFileProducerSingleThreaded.java
Show resolved
Hide resolved
...src/main/java/com/hedera/node/app/records/impl/producers/formats/v6/BlockRecordFormatV6.java
Show resolved
Hide resolved
...src/main/java/com/hedera/node/app/records/impl/producers/formats/v6/BlockRecordFormatV6.java
Outdated
Show resolved
Hide resolved
…ate HederaTestConfigBuilder to include all configs without classpath scanning. Signed-off-by: Richard Bair <rbair23@users.noreply.github.com>
Signed-off-by: Richard Bair <rbair23@users.noreply.github.com>
SonarCloud Quality Gate failed. 0 Bugs 78.9% Coverage Catch issues before they fail your Quality Gate with our IDE extension SonarLint |
...src/main/java/com/hedera/node/app/records/impl/producers/formats/v6/BlockRecordWriterV6.java
Show resolved
Hide resolved
...p/src/main/java/com/hedera/node/app/records/impl/producers/formats/v6/SignatureWriterV6.java
Show resolved
Hide resolved
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.
LGTM on files owned by me.
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.
LGTM (except for committing state, can be handled in separate PR)
...p/src/main/java/com/hedera/node/app/records/impl/producers/StreamFileProducerConcurrent.java
Show resolved
Hide resolved
...p/src/main/java/com/hedera/node/app/records/impl/producers/StreamFileProducerConcurrent.java
Show resolved
Hide resolved
hedera-node/hedera-config/src/main/java/com/hedera/node/config/data/HederaConfig.java
Show resolved
Hide resolved
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.
LGTM other than one comment
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.
Filtering on files owned by me, LGTM!
Signed-off-by: jasperpotts <jasperpotts@users.noreply.github.com> Signed-off-by: Richard Bair <rbair23@users.noreply.github.com> Co-authored-by: jasperpotts <jasperpotts@users.noreply.github.com> Co-authored-by: Richard Bair <rbair23@users.noreply.github.com>
Creating new record stream writing Facility, Issue #4742