mirror of
https://github.com/refraction-networking/uquic.git
synced 2025-04-03 20:27:35 +03:00
95575f5fe7
uTLS is not yet bumped to the new version, so this commit breaks the dependencies relationship by getting rid of the local replace.
63 lines
1.9 KiB
Go
63 lines
1.9 KiB
Go
package quic
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/refraction-networking/uquic/internal/qerr"
|
|
)
|
|
|
|
type (
|
|
TransportError = qerr.TransportError
|
|
ApplicationError = qerr.ApplicationError
|
|
VersionNegotiationError = qerr.VersionNegotiationError
|
|
StatelessResetError = qerr.StatelessResetError
|
|
IdleTimeoutError = qerr.IdleTimeoutError
|
|
HandshakeTimeoutError = qerr.HandshakeTimeoutError
|
|
)
|
|
|
|
type (
|
|
TransportErrorCode = qerr.TransportErrorCode
|
|
ApplicationErrorCode = qerr.ApplicationErrorCode
|
|
StreamErrorCode = qerr.StreamErrorCode
|
|
)
|
|
|
|
const (
|
|
NoError = qerr.NoError
|
|
InternalError = qerr.InternalError
|
|
ConnectionRefused = qerr.ConnectionRefused
|
|
FlowControlError = qerr.FlowControlError
|
|
StreamLimitError = qerr.StreamLimitError
|
|
StreamStateError = qerr.StreamStateError
|
|
FinalSizeError = qerr.FinalSizeError
|
|
FrameEncodingError = qerr.FrameEncodingError
|
|
TransportParameterError = qerr.TransportParameterError
|
|
ConnectionIDLimitError = qerr.ConnectionIDLimitError
|
|
ProtocolViolation = qerr.ProtocolViolation
|
|
InvalidToken = qerr.InvalidToken
|
|
ApplicationErrorErrorCode = qerr.ApplicationErrorErrorCode
|
|
CryptoBufferExceeded = qerr.CryptoBufferExceeded
|
|
KeyUpdateError = qerr.KeyUpdateError
|
|
AEADLimitReached = qerr.AEADLimitReached
|
|
NoViablePathError = qerr.NoViablePathError
|
|
)
|
|
|
|
// A StreamError is used for Stream.CancelRead and Stream.CancelWrite.
|
|
// It is also returned from Stream.Read and Stream.Write if the peer canceled reading or writing.
|
|
type StreamError struct {
|
|
StreamID StreamID
|
|
ErrorCode StreamErrorCode
|
|
Remote bool
|
|
}
|
|
|
|
func (e *StreamError) Is(target error) bool {
|
|
_, ok := target.(*StreamError)
|
|
return ok
|
|
}
|
|
|
|
func (e *StreamError) Error() string {
|
|
pers := "local"
|
|
if e.Remote {
|
|
pers = "remote"
|
|
}
|
|
return fmt.Sprintf("stream %d canceled by %s with error code %d", e.StreamID, pers, e.ErrorCode)
|
|
}
|