-
Notifications
You must be signed in to change notification settings - Fork 0
feat: Trusted Auctioneer: implement stream execute optimistic block #11
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
Merged
bharath-123
merged 75 commits into
bharath/add-mempool-clearing-event
from
bharath/implement-optimistic-execution
Jan 13, 2025
Merged
feat: Trusted Auctioneer: implement stream execute optimistic block #11
bharath-123
merged 75 commits into
bharath/add-mempool-clearing-event
from
bharath/implement-optimistic-execution
Jan 13, 2025
Conversation
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
67e8bb3 to
7428c4f
Compare
7428c4f to
14d50b2
Compare
14d50b2 to
9d5e8a9
Compare
b2656a4 to
3c385b6
Compare
c39ff65 to
f13364b
Compare
4c77ff2 to
b607990
Compare
f13364b to
0be6ac1
Compare
b607990 to
00ec806
Compare
0be6ac1 to
59f90a7
Compare
a78ff12 to
9868513
Compare
59f90a7 to
5d40100
Compare
9868513 to
96030a1
Compare
5d40100 to
40652a0
Compare
a3c4509 to
d7f0830
Compare
15d4ce4 to
e7abf02
Compare
822240a to
ffa4fcb
Compare
e7abf02 to
0158846
Compare
ffa4fcb to
5c33b09
Compare
0158846 to
fd3dd2c
Compare
27d7ce4 to
3013a91
Compare
fd3dd2c to
99acf19
Compare
ae9498d to
7471ef9
Compare
chore: Trusted Auctioneer: update the protos
feat: Trusted Auctioneer: Add initial set of metrics for auctioneer
feat: Trusted Auctioneer: Code cleanups
…-block feat: Trusted Auctioneer: Add API to query the current optimistic block
feat: Trusted Auctioneer: Support unmarshalling signed allocations and placing it at the TOB
feat: Trusted Auctioneer: Add a cmd line flag to run a Flame node in auctioneer mode
refactor: Trusted Auctioneer: Separate execution api service and optimistic execution api service
feat: Trusted Auctioneer: Implement bundle streaming
Merged
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This PR implements the
StreamExecuteOptimisticBlock.StreamExecuteOptimisticBlocklistens for optimistic block execution requests. On receiving aStreamExecuteOptimisticBlockRequest, we execute the block and wait for the mempool to be cleared. Once it's cleared, we return aStreamExecuteOptimisticBlockResponseback to the auctioneer.We also allow only 1 client to be connected to
StreamExecuteOptimisticBlock. We achieve this by maintaining an atomic boolean calledexecuteOptimisticBlockStreamConnectedwhere we perform aCompareAndSwapto update it from false to true everytime somebody connects to it.Changes made:
StreamExecuteOptimisticBlockgrpc methodmock_grpc_stream.gofile which contains a basicMockStreamimplementation used to mock grpc streams during unit testing.