QUIC support [DO NOT MERGE] by StefanBratanov · Pull Request #9484 · Consensys/teku

StefanBratanov · 2025-05-23T15:19:10Z

PR Description

Add QUIC support

Default QUIC ports to 9100 (IPv4) and 9190 (IPv6) when dual-stack.

Fixed Issue(s)

N/A

Documentation

I thought about documentation and added the doc-change-required label to this PR if updates are required.

Changelog

I thought about adding a changelog entry, and added one if I deemed necessary.

tbenr · 2025-05-23T16:27:59Z

I managed to run it on a 2 node interop and i get

2025-05-23 18:25:27.609 WARN  - Failed to initialize a channel. Closing: (77398ec10259844dd9c9426a9d40ada12d30e856)[id: 0x8d44b8eb, L:QuicConnectionAddress{connId=77398ec10259844dd9c9426a9d40ada12d30e856} ! R:QuicConnectionAddress{connId=}]
kotlin.UninitializedPropertyAccessException: lateinit property muxerSession has not been initialized
at io.libp2p.transport.implementation.ConnectionOverNetty.muxerSession(ConnectionOverNetty.kt:34) ~[jvm-libp2p-develop.jar:?]
at io.libp2p.pubsub.gossip.Gossip.handleConnection(Gossip.kt:53) ~[jvm-libp2p-develop.jar:?]
at io.libp2p.etc.BroadcastConnectionHandler.handleConnection(BroadcastConnectionHandler.kt:10) ~[jvm-libp2p-develop.jar:?]
at io.libp2p.etc.BroadcastConnectionHandler.handleConnection(BroadcastConnectionHandler.kt:10) ~[jvm-libp2p-develop.jar:?]
at io.libp2p.transport.quic.QuicTransport$serverTransportBuilder$2.initChannel(QuicTransport.kt:351) ~[jvm-libp2p-develop.jar:?]
at io.netty.channel.ChannelInitializer.initChannel(ChannelInitializer.java:129) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.ChannelInitializer.handlerAdded(ChannelInitializer.java:112) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannelHandlerContext.callHandlerAdded(AbstractChannelHandlerContext.java:1002) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline.callHandlerAdded0(DefaultChannelPipeline.java:558) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline.access$100(DefaultChannelPipeline.java:45) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline$PendingHandlerAddedTask.execute(DefaultChannelPipeline.java:1482) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline.callHandlerAddedForAllHandlers(DefaultChannelPipeline.java:1136) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline.invokeHandlerAddedIfNeeded(DefaultChannelPipeline.java:599) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannel$AbstractUnsafe$2.operationComplete(AbstractChannel.java:383) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannel$AbstractUnsafe$2.operationComplete(AbstractChannel.java:374) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:603) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:570) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:505) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:649) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:638) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.setSuccess(DefaultPromise.java:110) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPromise.setSuccess(DefaultChannelPromise.java:78) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPromise.setSuccess(DefaultChannelPromise.java:73) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannel.doRegister(AbstractChannel.java:968) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:408) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannel$AbstractUnsafe.register(AbstractChannel.java:346) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.SingleThreadEventLoop.register(SingleThreadEventLoop.java:119) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.SingleThreadEventLoop.register(SingleThreadEventLoop.java:113) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.incubator.codec.quic.QuicheQuicServerCodec.handleServer(QuicheQuicServerCodec.java:277) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.incubator.codec.quic.QuicheQuicServerCodec.quicPacketRead(QuicheQuicServerCodec.java:119) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.incubator.codec.quic.QuicheQuicCodec$QuicCodecHeaderProcessor.process(QuicheQuicCodec.java:362) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.incubator.codec.quic.QuicHeaderParser.parse(QuicHeaderParser.java:142) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.incubator.codec.quic.QuicheQuicCodec.handleQuicPacket(QuicheQuicCodec.java:200) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.incubator.codec.quic.QuicheQuicCodec.channelRead(QuicheQuicCodec.java:191) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1429) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:918) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.AbstractNioMessageChannel$NioMessageUnsafe.read(AbstractNioMessageChannel.java:100) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.handle(AbstractNioChannel.java:445) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.NioIoHandler$DefaultNioRegistration.handle(NioIoHandler.java:383) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.NioIoHandler.processSelectedKey(NioIoHandler.java:577) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.NioIoHandler.processSelectedKeysOptimized(NioIoHandler.java:552) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.NioIoHandler.processSelectedKeys(NioIoHandler.java:493) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.NioIoHandler.run(NioIoHandler.java:470) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:204) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:175) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1073) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at java.base/java.lang.Thread.run(Thread.java:1583) [?:?]

tbenr · 2025-05-23T16:29:47Z

I also had to add

in our build

implementation "io.netty.incubator:netty-incubator-codec-native-quic::osx-aarch_64"

native libs are not explicitly set as implementation dependencies in the libp2p project

StefanBratanov · 2025-05-28T14:30:38Z

I managed to run it on a 2 node interop and i get

2025-05-23 18:25:27.609 WARN  - Failed to initialize a channel. Closing: (77398ec10259844dd9c9426a9d40ada12d30e856)[id: 0x8d44b8eb, L:QuicConnectionAddress{connId=77398ec10259844dd9c9426a9d40ada12d30e856} ! R:QuicConnectionAddress{connId=}]
kotlin.UninitializedPropertyAccessException: lateinit property muxerSession has not been initialized
at io.libp2p.transport.implementation.ConnectionOverNetty.muxerSession(ConnectionOverNetty.kt:34) ~[jvm-libp2p-develop.jar:?]
at io.libp2p.pubsub.gossip.Gossip.handleConnection(Gossip.kt:53) ~[jvm-libp2p-develop.jar:?]
at io.libp2p.etc.BroadcastConnectionHandler.handleConnection(BroadcastConnectionHandler.kt:10) ~[jvm-libp2p-develop.jar:?]
at io.libp2p.etc.BroadcastConnectionHandler.handleConnection(BroadcastConnectionHandler.kt:10) ~[jvm-libp2p-develop.jar:?]
at io.libp2p.transport.quic.QuicTransport$serverTransportBuilder$2.initChannel(QuicTransport.kt:351) ~[jvm-libp2p-develop.jar:?]
at io.netty.channel.ChannelInitializer.initChannel(ChannelInitializer.java:129) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.ChannelInitializer.handlerAdded(ChannelInitializer.java:112) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannelHandlerContext.callHandlerAdded(AbstractChannelHandlerContext.java:1002) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline.callHandlerAdded0(DefaultChannelPipeline.java:558) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline.access$100(DefaultChannelPipeline.java:45) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline$PendingHandlerAddedTask.execute(DefaultChannelPipeline.java:1482) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline.callHandlerAddedForAllHandlers(DefaultChannelPipeline.java:1136) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline.invokeHandlerAddedIfNeeded(DefaultChannelPipeline.java:599) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannel$AbstractUnsafe$2.operationComplete(AbstractChannel.java:383) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannel$AbstractUnsafe$2.operationComplete(AbstractChannel.java:374) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:603) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:570) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:505) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:649) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:638) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.DefaultPromise.setSuccess(DefaultPromise.java:110) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPromise.setSuccess(DefaultChannelPromise.java:78) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPromise.setSuccess(DefaultChannelPromise.java:73) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannel.doRegister(AbstractChannel.java:968) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannel$AbstractUnsafe.register0(AbstractChannel.java:408) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.AbstractChannel$AbstractUnsafe.register(AbstractChannel.java:346) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.SingleThreadEventLoop.register(SingleThreadEventLoop.java:119) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.SingleThreadEventLoop.register(SingleThreadEventLoop.java:113) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.incubator.codec.quic.QuicheQuicServerCodec.handleServer(QuicheQuicServerCodec.java:277) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.incubator.codec.quic.QuicheQuicServerCodec.quicPacketRead(QuicheQuicServerCodec.java:119) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.incubator.codec.quic.QuicheQuicCodec$QuicCodecHeaderProcessor.process(QuicheQuicCodec.java:362) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.incubator.codec.quic.QuicHeaderParser.parse(QuicHeaderParser.java:142) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.incubator.codec.quic.QuicheQuicCodec.handleQuicPacket(QuicheQuicCodec.java:200) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.incubator.codec.quic.QuicheQuicCodec.channelRead(QuicheQuicCodec.java:191) ~[netty-incubator-codec-classes-quic-0.0.71.Final.jar:0.0.71.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1429) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:918) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.AbstractNioMessageChannel$NioMessageUnsafe.read(AbstractNioMessageChannel.java:100) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.handle(AbstractNioChannel.java:445) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.NioIoHandler$DefaultNioRegistration.handle(NioIoHandler.java:383) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.NioIoHandler.processSelectedKey(NioIoHandler.java:577) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.NioIoHandler.processSelectedKeysOptimized(NioIoHandler.java:552) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.NioIoHandler.processSelectedKeys(NioIoHandler.java:493) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.nio.NioIoHandler.run(NioIoHandler.java:470) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.SingleThreadIoEventLoop.runIo(SingleThreadIoEventLoop.java:204) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:175) ~[netty-transport-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1073) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[netty-common-4.2.0.Final.jar:4.2.0.Final]
at java.base/java.lang.Thread.run(Thread.java:1583) [?:?]

I get the same when testing. @Nashatyrev any idea? In QuicServer#serverTransportBuilder, I can see the muxer not set? Any idea what is the best way to fix

Nashatyrev · 2025-05-29T09:16:00Z

What I see in QuicTransport is that ConnectionOverNetty.setMuxerSession() is called in the dial() method only but I don't get where it is called when a server side handler is created 🤔

Nashatyrev · 2025-05-29T09:31:19Z

Quic tests are working because on the server side Connection.muxerSession is not invoked.
The QuicTransport implementation is quite new and is not well test covered, so I would be cautious adding it to Teku

StefanBratanov · 2025-05-29T11:00:05Z

Quic tests are working because on the server side Connection.muxerSession is not invoked. The QuicTransport implementation is quite new and is not well test covered, so I would be cautious adding it to Teku

Yeah, we are just experimenting. So I suppose the muxer should also be set on the server side.

github-actions · 2025-09-11T12:32:32Z

All contributors have signed the CLA ✍️ ✅
_{Posted by the CLA Assistant Lite bot.}

Nashatyrev · 2025-09-11T16:40:40Z

I have read the CLA Document and I hereby sign the CLA

…disconnect() isn't propagated and converted to close() as the netty QuickStreamChannel declares it doesn't support disconnect() (#2)

rolfyone added the DO NOT MERGE Not ready to merge label May 23, 2025

StefanBratanov mentioned this pull request Sep 8, 2025

Move QUIC implementation to prototype 🍋 libp2p/jvm-libp2p#423

Merged

github-actions bot added a commit that referenced this pull request Sep 11, 2025

@Nashatyrev has signed the CLA in #9484

51b18f1

StefanBratanov force-pushed the quic branch from 245c81d to f147a94 Compare October 9, 2025 07:04

StefanBratanov force-pushed the quic branch from eee9a03 to 2a54e71 Compare October 29, 2025 07:26

StefanBratanov force-pushed the quic branch from 2a54e71 to c8f4e1a Compare November 11, 2025 09:02

StefanBratanov and others added 9 commits November 24, 2025 12:04

QUIC support

ba02c05

fix assemble

229b8eb

small change

46e8599

add better defaults

9d7689a

fix build

491f426

small fixes

abe381e

QUIC: need to close a stream for writing via libp2p Stream instance. …

8c8e346

…disconnect() isn't propagated and converted to close() as the netty QuickStreamChannel declares it doesn't support disconnect() (#2)

fix conflicts

2f019fb

spotless

a397d47

StefanBratanov force-pushed the quic branch from c8f4e1a to a397d47 Compare November 24, 2025 04:04

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

QUIC support [DO NOT MERGE]#9484

QUIC support [DO NOT MERGE]#9484
StefanBratanov wants to merge 9 commits intoConsensys:masterfrom
StefanBratanov:quic

StefanBratanov commented May 23, 2025 •

edited

Loading

Uh oh!

tbenr commented May 23, 2025 •

edited

Loading

Uh oh!

tbenr commented May 23, 2025

Uh oh!

StefanBratanov commented May 28, 2025

Uh oh!

Nashatyrev commented May 29, 2025

Uh oh!

Nashatyrev commented May 29, 2025

Uh oh!

StefanBratanov commented May 29, 2025

Uh oh!

github-actions bot commented Sep 11, 2025 •

edited

Loading

Uh oh!

Nashatyrev commented Sep 11, 2025

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

4 participants

Conversation

StefanBratanov commented May 23, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

PR Description

Fixed Issue(s)

Documentation

Changelog

Uh oh!

tbenr commented May 23, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

tbenr commented May 23, 2025

Uh oh!

StefanBratanov commented May 28, 2025

Uh oh!

Nashatyrev commented May 29, 2025

Uh oh!

Nashatyrev commented May 29, 2025

Uh oh!

StefanBratanov commented May 29, 2025

Uh oh!

github-actions bot commented Sep 11, 2025 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

Nashatyrev commented Sep 11, 2025

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

4 participants

StefanBratanov commented May 23, 2025 •

edited

Loading

tbenr commented May 23, 2025 •

edited

Loading

github-actions bot commented Sep 11, 2025 •

edited

Loading