|
56 | 56 | SyncManager*[A, B] = ref object
|
57 | 57 | pool: PeerPool[A, B]
|
58 | 58 | DENEB_FORK_EPOCH: Epoch
|
| 59 | + FULU_FORK_EPOCH: Epoch |
59 | 60 | MIN_EPOCHS_FOR_BLOB_SIDECARS_REQUESTS: uint64
|
60 | 61 | MAX_BLOBS_PER_BLOCK_ELECTRA: uint64
|
61 | 62 | responseTimeout: chronos.Duration
|
@@ -142,6 +143,7 @@ proc initQueue[A, B](man: SyncManager[A, B]) =
|
142 | 143 | proc newSyncManager*[A, B](
|
143 | 144 | pool: PeerPool[A, B],
|
144 | 145 | denebEpoch: Epoch,
|
| 146 | + fuluEpoch: Epoch, |
145 | 147 | minEpochsForBlobSidecarsRequests: uint64,
|
146 | 148 | maxBlobsPerBlockElectra: uint64,
|
147 | 149 | direction: SyncQueueKind,
|
@@ -171,6 +173,7 @@ proc newSyncManager*[A, B](
|
171 | 173 | var res = SyncManager[A, B](
|
172 | 174 | pool: pool,
|
173 | 175 | DENEB_FORK_EPOCH: denebEpoch,
|
| 176 | + FULU_FORK_EPOCH: fuluEpoch, |
174 | 177 | MIN_EPOCHS_FOR_BLOB_SIDECARS_REQUESTS: minEpochsForBlobSidecarsRequests,
|
175 | 178 | MAX_BLOBS_PER_BLOCK_ELECTRA: maxBlobsPerBlockElectra,
|
176 | 179 | getLocalHeadSlot: getLocalHeadSlotCb,
|
@@ -212,7 +215,7 @@ proc shouldGetBlobs[A, B](man: SyncManager[A, B], s: Slot): bool =
|
212 | 215 | let
|
213 | 216 | wallEpoch = man.getLocalWallSlot().epoch
|
214 | 217 | epoch = s.epoch()
|
215 |
| - (epoch >= man.DENEB_FORK_EPOCH) and |
| 218 | + (epoch >= man.DENEB_FORK_EPOCH) and (epoch < man.FULU_FORK_EPOCH) and |
216 | 219 | (wallEpoch < man.MIN_EPOCHS_FOR_BLOB_SIDECARS_REQUESTS or
|
217 | 220 | epoch >= wallEpoch - man.MIN_EPOCHS_FOR_BLOB_SIDECARS_REQUESTS)
|
218 | 221 |
|
|
0 commit comments