@@ -343,38 +343,6 @@ func (d *DAConfig) IsFiberEnabled() bool {
343343 return d .Fiber .Enabled
344344}
345345
346- // ApplyFiberDefaults flips the DA client to Fiber-friendly defaults
347- // when the Fiber profile is enabled — adaptive batching, a 1 s
348- // DA.BlockTime so inclusion-tracking keeps pace with Fibre's
349- // settlement, and a bounded pending-cache window so a Fibre stall
350- // can't grow memory unbounded. Caller-provided non-zero values for
351- // the tunables (BatchSizeThreshold, BatchMinItems) are preserved.
352- //
353- // Intended to be invoked once at runner startup, after parsing the
354- // usual config but before constructing the DA client.
355- func (c * Config ) ApplyFiberDefaults () {
356- if ! c .DA .IsFiberEnabled () {
357- return
358- }
359-
360- c .DA .BatchingStrategy = "adaptive"
361- if c .DA .BatchSizeThreshold <= 0 || c .DA .BatchSizeThreshold > 1 {
362- c .DA .BatchSizeThreshold = 0.5
363- }
364- c .DA .BatchMaxDelay = DurationWrapper {Duration : 8 * time .Second }
365- if c .DA .BatchMinItems == 0 {
366- c .DA .BatchMinItems = 1
367- }
368-
369- c .DA .BlockTime = DurationWrapper {Duration : 1 * time .Second }
370- // Tighter pending cap (was 50). At 50, a Fibre upload stall lets the
371- // submitter accumulate 50 × ~32 MiB blob copies + their per-validator
372- // retry buffers; under load that exceeded c6in.8xlarge's 64 GiB and
373- // OOM-killed evnode at 63.8 GiB. 10 keeps the in-flight footprint
374- // bounded while still letting healthy uploads pipeline.
375- c .Node .MaxPendingHeadersAndData = 10
376- }
377-
378346// GetNamespace returns the namespace for header submissions.
379347func (d * DAConfig ) GetNamespace () string {
380348 return d .Namespace
0 commit comments