Conversation
pool: switch ON blobpool+no reannotx
* chainconfig: use cancun fork for BSC; feat: fill WithdrawalsHash when BSC enable cancun fork; * rawdb: support to CRUD blobs; freezer: support to freeze block blobs; * freezer: support to freeze block blobs; * blockchain: add blob cache & blob query helper; * blockchain: add blob cache & blob query helper; * freezer: refactor addition table logic, add uts; * blobexpiry: add more extra expiry time, and logs; * ci: fix UT fails; * fix: fix some PR review comments; * parlia: implement IsDataAvailable function; * blob: refactor blob transfer logic; * blob: support config blob extra reserve;
eth/protocols/eth/handlers.go
Outdated
| var packet BlockPacket | ||
|
|
||
| // First, try to decode as NewBlockPacket | ||
| nbp := new(NewBlockPacket) |
There was a problem hiding this comment.
Maybe we could add some UTs to check the decode is ok for the old msg and the new msg.
eth/protocols/eth/protocol.go
Outdated
| TD *big.Int | ||
| } | ||
|
|
||
| type NewBlockWithBlobPacket struct { |
There was a problem hiding this comment.
Is it possible that we don't add this new type, but to extend the NewBlockPacket, like:
type NewBlockPacket struct {
Block *types.Block
TD *big.Int
Sidecars types.BlobTxSidecars `rlp:"optional"`
}
Sidecars will be empty when broadcast block only. And Sidecars would contain payload if broadcast block with blobs
There was a problem hiding this comment.
Removed it in this commit: 851ae4a
Please check.
eth/protocols/eth/handlers.go
Outdated
| if body.Withdrawals != nil { | ||
| withdrawalHashes[i] = types.DeriveSha(types.Withdrawals(body.Withdrawals), hasher) | ||
| } | ||
| if body.Sidecars != nil { |
There was a problem hiding this comment.
I think the sidecarsHashes is useless, it cannot give help any validation. It can be removed. I think just modify DeliverBodies, and add blobs for fetchResult in reconstruct.
The importBlockResults in Downloader also need modify to append blobs.
for i, result := range results {
blocks[i] = types.NewBlockWithHeader(result.Header).WithBody(result.Transactions, result.Uncles).WithWithdrawals(result.Withdrawals).WithBlobs(result.Blobs)
}|
|
||
| if hash := types.CalcUncleHash(ann.Block.Uncles()); hash != ann.Block.UncleHash() { | ||
| log.Warn("Propagated block has invalid uncles", "have", hash, "exp", ann.Block.UncleHash()) | ||
| return nil // TODO(karalabe): return error eventually, but wait a few releases |
There was a problem hiding this comment.
func handleBlockHeaders need some changes?
There was a problem hiding this comment.
Header doesn't carry sidecar specific things. What change should be made?
There was a problem hiding this comment.
sorry, I mean handleBlockBodies
eth/protocols/eth/broadcast.go
Outdated
|
|
||
| // blockPropagation is a block propagation event, waiting for its turn in the | ||
| // broadcast queue. | ||
| type blockAndBlobPropagation struct { |
There was a problem hiding this comment.
Is possible to reuse blockPropagation?
such things like
type blockPropagation struct {
block *types.Block
td *big.Int
sidecars types.BlobTxSidecars `rlp:"optional"`
}
There was a problem hiding this comment.
same question, we can also remove AsyncSendNewBlockAndBlob(...) if we reuse blockPropagation
There was a problem hiding this comment.
Removed AsyncSendNewBlockAndBlob() in this commit: 10cfa61
eth/protocols/eth/protocol.go
Outdated
| TD *big.Int | ||
| Block *types.Block | ||
| TD *big.Int | ||
| Sidecars *types.BlobTxSidecars `rlp:"optional"` |
There was a problem hiding this comment.
not use pointer, but array?
Sidecars []*BlobTxSidecar
* ci: temp enable blobtx branch ci run; * Switch ON blobpool & ensure Cancun hardfork can occur (#2223) * feat: support blob storage & miscs; (#2229) * chainconfig: use cancun fork for BSC; * feat: fill WithdrawalsHash when BSC enable cancun fork; * rawdb: support to CRUD blobs; * freezer: support to freeze block blobs; * blockchain: add blob cache & blob query helper; * freezer: refactor addition table logic, add uts; * blobexpiry: add more extra expiry time, and logs; * parlia: implement IsDataAvailable function; * blob: refactor blob transfer logic; * blob: support config blob extra reserve; * blockchian: support to import block with blob & blobGasFee; (#2260) * blob: implement min&max gas price logic; * blockchian: support import side chain; * blobpool: reject the banned address; * blockchain: add chasing head for DA check; * params: update blob related config; * blockchain: opt data available checking performance; * params: modify blob related params; * gasprice: support BEP-336 blob gas price calculate; * blobTx: mining + brodcasting (#2253) * blobtx mining pass (#2282) * Sidecar fetching changes for 4844 (#2283) * ci: temp enable blobtx branch ci run; * Switch ON blobpool & ensure Cancun hardfork can occur (#2223) * feat: support blob storage & miscs; (#2229) * chainconfig: use cancun fork for BSC; feat: fill WithdrawalsHash when BSC enable cancun fork; * rawdb: support to CRUD blobs; * freezer: support to freeze block blobs; * blockchain: add blob cache & blob query helper; * freezer: refactor addition table logic, add uts; * blobexpiry: add more extra expiry time, and logs; * parlia: implement IsDataAvailable function; * blob: refactor blob transfer logic; * blob: support config blob extra reserve; * blockchian: support to import block with blob & blobGasFee; (#2260) * blob: implement min&max gas price logic; * blockchian: support import side chain; * blobpool: reject the banned address; * blockchain: add chasing head for DA check; * params: update blob related config; * blockchain: opt data available checking performance; * params: modify blob related params; * gasprice: support BEP-336 blob gas price calculate; * fix failed check for WithdrawalsHash (#2276) * eth: include sidecars in fitering of body * core: refactor sidecars name * eth: sidecars type refactor * core: remove extra from bad merge * eth: fix handlenewblock test after merge * Implement eth_getBlobSidecars && eth_getBlobSidecarByTxHash (#2286) * execution: add blob gas fee reward to system; * syncing: support blob syncing & DA checking; * naming: rename blobs to sidecars; * fix the semantics of WithXXX (#2293) * config: reduce sidecar cache to 1024 and rename (#2297) * fix: Withdrawals turn into empty from nil when BlockBody has Sidecars (#2301) * internal/api_test: add test case for eth_getBlobSidecars && eth_getBlobSidecarByTxHash (#2300) * consensus/misc: rollback CalcBlobFee (#2306) * flags: add new flags to override blobs' params; * freezer: fix blob ancient save error; * blobsidecar: add new sidecar struct with metadata; (#2315) * core/rawdb: optimize write block with sidecars (#2318) * core: more check for validity of sidecars * mev: add TxIndex for mev bid (#2325) * remove useless Config() (#2326) * fix WithSidecars (#2327) * fix: fix mined block sidecar issue; (#2328) * fix WithSidecars (#2329) --------- Co-authored-by: GalaIO <GalaIO@users.noreply.github.com> Co-authored-by: buddho <galaxystroller@gmail.com> Co-authored-by: Satyajit Das <emailtovamos@gmail.com> Co-authored-by: Eric <45141191+zlacfzy@users.noreply.github.com> Co-authored-by: zzzckck <152148891+zzzckck@users.noreply.github.com>
Description
add a description of your changes here...
Rationale
tell us why we need these changes...
Example
add an example CLI or API response...
Changes
Notable changes: