Client Memory Optimizations

packages/client/bin/cli.ts

@@ -236,6 +236,11 @@ const args: ClientOpts = yargs(hideBin(process.argv))
     describe: 'EIP-1459 ENR tree urls to query for peer discovery targets',
     array: true,
   })
+  .option('execution', {
+    describe: 'Start continuous VM execution (pre-Merge setting)',
+    boolean: true,
+    default: Config.EXECUTION,
+  })
   .option('numBlocksPerIteration', {
     describe: 'Number of blocks to execute in batch mode and logged to console',
     number: true,
@@ -738,6 +743,7 @@ async function run() {
     discDns: args.discDns,
     discV4: args.discV4,
     dnsAddr: args.dnsAddr,
+    execution: args.execution,
     numBlocksPerIteration: args.numBlocksPerIteration,
     accountCache: args.accountCache,
     storageCache: args.storageCache,

packages/client/lib/config.ts

@@ -189,6 +189,11 @@ export interface ConfigOptions {
    */
   dnsNetworks?: string[]
 
+  /**
+   * Start continuous VM execution (pre-Merge setting)
+   */
+  execution?: boolean
+
   /**
    * Number of blocks to execute in batch mode and logged to console
    */
@@ -310,6 +315,7 @@ export class Config {
   public static readonly MINPEERS_DEFAULT = 1
   public static readonly MAXPEERS_DEFAULT = 25
   public static readonly DNSADDR_DEFAULT = '8.8.8.8'
+  public static readonly EXECUTION = true
   public static readonly NUM_BLOCKS_PER_ITERATION = 100
   public static readonly ACCOUNT_CACHE = 400000
   public static readonly STORAGE_CACHE = 200000
@@ -345,6 +351,7 @@ export class Config {
   public readonly minPeers: number
   public readonly maxPeers: number
   public readonly dnsAddr: string
+  public readonly execution: boolean
   public readonly numBlocksPerIteration: number
   public readonly accountCache: number
   public readonly storageCache: number
@@ -402,6 +409,7 @@ export class Config {
     this.minPeers = options.minPeers ?? Config.MINPEERS_DEFAULT
     this.maxPeers = options.maxPeers ?? Config.MAXPEERS_DEFAULT
     this.dnsAddr = options.dnsAddr ?? Config.DNSADDR_DEFAULT
+    this.execution = options.execution ?? Config.EXECUTION
     this.numBlocksPerIteration = options.numBlocksPerIteration ?? Config.NUM_BLOCKS_PER_ITERATION
     this.accountCache = options.accountCache ?? Config.ACCOUNT_CACHE
     this.storageCache = options.storageCache ?? Config.STORAGE_CACHE

packages/client/lib/execution/execution.ts

@@ -56,15 +56,21 @@ export abstract class Execution {
    */
   async open(): Promise<void> {
     this.started = true
-    this.config.logger.info('Setup EVM execution.')
+    if (this.config.execution) {
+      this.config.logger.info('Setup EVM execution.')
+    } else {
+      this.config.logger.info('EVM execution skipped.')
+    }
   }
 
   /**
    * Stop execution. Returns a promise that resolves once stopped.
    */
   async stop(): Promise<boolean> {
     this.started = false
-    this.config.logger.info('Stopped execution.')
+    if (this.config.execution) {
+      this.config.logger.info('Stopped execution.')
+    }
     return true
   }
 }

packages/client/lib/execution/vmexecution.ts

@@ -137,8 +137,10 @@ export class VMExecution extends Execution {
       }
       const td = await this.vm.blockchain.getTotalDifficulty(headBlock.header.hash())
       this.config.execCommon.setHardforkByBlockNumber(number, td, timestamp)
-      this.hardfork = this.config.execCommon.hardfork()
-      this.config.logger.info(`Initializing VM execution hardfork=${this.hardfork}`)
+      if (this.config.execution) {
+        this.hardfork = this.config.execCommon.hardfork()
+        this.config.logger.info(`Initializing VM execution hardfork=${this.hardfork}`)
+      }
       if (number === BigInt(0)) {
         if (typeof this.vm.blockchain.genesisState !== 'function') {
           throw new Error('cannot get iterator head: blockchain has no genesisState function')

packages/client/lib/service/fullethereumservice.ts

@@ -162,7 +162,7 @@ export class FullEthereumService extends EthereumService {
     }
     await super.start()
     this.miner?.start()
-    if (!this.config.execCommon.gteHardfork(Hardfork.Paris)) {
+    if (!this.config.execCommon.gteHardfork(Hardfork.Paris) && this.config.execution) {
       void this.execution.run(true, true)
     }
     return true

packages/client/lib/sync/beaconsync.ts

@@ -69,7 +69,9 @@ export class BeaconSynchronizer extends Synchronizer {
     await this.skeleton.open()
 
     this.config.events.on(Event.SYNC_FETCHED_BLOCKS, this.processSkeletonBlocks)
-    this.config.events.on(Event.CHAIN_UPDATED, this.runExecution)
+    if (this.config.execution) {
+      this.config.events.on(Event.CHAIN_UPDATED, this.runExecution)
+    }
 
     const { height: number, td } = this.chain.blocks
     const hash = this.chain.blocks.latest!.hash()
@@ -331,7 +333,9 @@ export class BeaconSynchronizer extends Synchronizer {
   async close() {
     if (!this.opened) return
     this.config.events.removeListener(Event.SYNC_FETCHED_BLOCKS, this.processSkeletonBlocks)
-    this.config.events.removeListener(Event.CHAIN_UPDATED, this.runExecution)
+    if (this.config.execution) {
+      this.config.events.removeListener(Event.CHAIN_UPDATED, this.runExecution)
+    }
     await super.close()
   }
 }

packages/client/lib/sync/fullsync.ts

@@ -75,7 +75,9 @@ export class FullSynchronizer extends Synchronizer {
 
     this.config.events.on(Event.SYNC_FETCHED_BLOCKS, this.processBlocks)
     this.config.events.on(Event.SYNC_EXECUTION_VM_ERROR, this.stop)
-    this.config.events.on(Event.CHAIN_UPDATED, this.runExecution)
+    if (this.config.execution) {
+      this.config.events.on(Event.CHAIN_UPDATED, this.runExecution)
+    }
 
     await this.pool.open()
     const { height: number, td } = this.chain.blocks
@@ -404,7 +406,9 @@ export class FullSynchronizer extends Synchronizer {
   async stop(): Promise<boolean> {
     this.config.events.removeListener(Event.SYNC_FETCHED_BLOCKS, this.processBlocks)
     this.config.events.removeListener(Event.SYNC_EXECUTION_VM_ERROR, this.stop)
-    this.config.events.removeListener(Event.CHAIN_UPDATED, this.runExecution)
+    if (this.config.execution) {
+      this.config.events.removeListener(Event.CHAIN_UPDATED, this.runExecution)
+    }
     return super.stop()
   }
 

packages/client/lib/types.ts

@@ -143,6 +143,7 @@ export interface ClientOpts {
   minPeers?: number
   maxPeers?: number
   dnsAddr?: string
+  execution?: boolean
   numBlocksPerIteration?: number
   accountCache?: number
   storageCache?: number