Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Refactor YamuxHandler #326

Merged
merged 13 commits into from
Oct 9, 2023
Merged

Refactor YamuxHandler #326

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
bdeb23d
Refactor YamuxHandler:
Nashatyrev Sep 15, 2023
62fff83
Test should not close the session stream (id == 0)
Nashatyrev Sep 15, 2023
5eda133
Relax the test: allow throwing exception on non-existing stream, chec…
Nashatyrev Sep 15, 2023
31093e7
Merge remote-tracking branch 'origin/develop' into refactor/yamux-han…
Nashatyrev Sep 15, 2023
3049d40
Extract writeFrame() method
Nashatyrev Sep 15, 2023
626fa2d
Spotless
Nashatyrev Sep 15, 2023
c0667a7
Fix the warning
Nashatyrev Sep 15, 2023
7eb0e68
Fix exception text
Nashatyrev Sep 15, 2023
e81b321
Minor methods refactor
Nashatyrev Sep 15, 2023
36820df
Group class properties
Nashatyrev Sep 15, 2023
071db58
Adjust exception message. Fix the test
Nashatyrev Sep 15, 2023
7ffd525
Merge branch 'develop' into refactor/yamux-handler
Nashatyrev Oct 6, 2023
76fb96a
Fix the merge issue
Nashatyrev Oct 9, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 15 additions & 0 deletions libp2p/src/main/kotlin/io/libp2p/mux/MuxerException.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,15 @@
package io.libp2p.mux

import io.libp2p.core.Libp2pException
import io.libp2p.etc.util.netty.mux.MuxId

open class MuxerException(message: String, ex: Exception?) : Libp2pException(message, ex)

open class ReadMuxerException(message: String, ex: Exception?) : MuxerException(message, ex)
open class WriteMuxerException(message: String, ex: Exception?) : MuxerException(message, ex)

class UnknownStreamIdMuxerException(muxId: MuxId) : ReadMuxerException("Stream with id $muxId not found", null)

class InvalidFrameMuxerException(message: String) : ReadMuxerException(message, null)

class WriteBufferOverflowMuxerException(message: String) : WriteMuxerException(message, null)
Loading