sctp

package module

Go to main page

Versions in this module

v1

v1.8.16

Apr 16, 2024

v1.8.15

Apr 5, 2024

Changes in this version

+ var ErrTooManyReconfigRequests = errors.New("too many outstanding reconfig requests")

v1.8.14

Apr 3, 2024

v1.8.13

Mar 14, 2024

Changes in this version

type Config

+ Name string

+ RTOMax float64

v1.8.12

Feb 9, 2024

Changes in this version

+ var ErrZeroChecksumParamTooShort = errors.New("zero checksum parameter too short")

type Config

+ EnableZeroChecksum bool

v1.8.11

Feb 9, 2024

Changes in this version

+ var ErrInitUnknownParam = errors.New("INIT with unknown param")

v1.8.10

Feb 3, 2024

v1.8.9

Sep 4, 2023

v1.8.8

Aug 21, 2023

v1.8.7

Apr 29, 2023

Changes in this version

type Association

+ func (a *Association) CWND() uint32

+ func (a *Association) MTU() uint32

+ func (a *Association) RWND() uint32

+ func (a *Association) SRTT() float64

v1.8.6

Jan 13, 2023

Changes in this version

+ var ErrAssociationClosedBeforeConn = errors.New("association closed before connecting")

+ var ErrBuildAbortChunkFailed = errors.New("failed build Abort Chunk")

+ var ErrBuildErrorCaseHandle = errors.New("BuildErrorCause does not handle")

+ var ErrBuildErrorChunkFailed = errors.New("failed build Error Chunk")

+ var ErrChecksumMismatch = errors.New("checksum mismatch theirs")

+ var ErrChunk = errors.New("abort chunk, with following errors")

+ var ErrChunkHeaderNotEnoughSpace = errors.New("not enough data left in SCTP packet to satisfy requested length")

+ var ErrChunkHeaderPaddingNonZero = errors.New("chunk padding is non-zero at offset")

+ var ErrChunkHeaderTooSmall = errors.New("raw is too small for a SCTP chunk")

+ var ErrChunkMarshalParamAReconfigFailed = errors.New("unable to marshal parameter A for reconfig")

+ var ErrChunkMarshalParamBReconfigFailed = errors.New("unable to marshal parameter B for reconfig")

+ var ErrChunkNotLongEnoughForParams = errors.New("chunk Value isn't long enough for mandatory parameters exp")

+ var ErrChunkParseParamTypeFailed = errors.New("failed to parse param type")

+ var ErrChunkPayloadSmall = errors.New("packet is smaller than the header size")

+ var ErrChunkTooShort = errors.New("chunk too short")

+ var ErrChunkTypeInitAckFlagZero = errors.New("ChunkType of type INIT ACK flags must be all 0")

+ var ErrChunkTypeInitAckInitateTagZero = errors.New("ChunkType of type INIT ACK InitiateTag must not be 0")

+ var ErrChunkTypeInitFlagZero = errors.New("ChunkType of type INIT flags must be all 0")

+ var ErrChunkTypeInitInitateTagZero = errors.New("ChunkType of type INIT ACK InitiateTag must not be 0")

+ var ErrChunkTypeInitMarshalFailed = errors.New("failed marshaling INIT common data")

+ var ErrChunkTypeInitUnmarshalFailed = errors.New("failed to unmarshal INIT body")

+ var ErrChunkTypeNotAbort = errors.New("ChunkType is not of type ABORT")

+ var ErrChunkTypeNotCookieAck = errors.New("ChunkType is not of type COOKIEACK")

+ var ErrChunkTypeNotCookieEcho = errors.New("ChunkType is not of type COOKIEECHO")

+ var ErrChunkTypeNotCtError = errors.New("ChunkType is not of type ctError")

+ var ErrChunkTypeNotHeartbeat = errors.New("ChunkType is not of type HEARTBEAT")

+ var ErrChunkTypeNotInitAck = errors.New("ChunkType is not of type INIT ACK")

+ var ErrChunkTypeNotSack = errors.New("ChunkType is not of type SACK")

+ var ErrChunkTypeNotShutdown = errors.New("ChunkType is not of type SHUTDOWN")

+ var ErrChunkTypeNotShutdownAck = errors.New("ChunkType is not of type SHUTDOWN-ACK")

+ var ErrChunkTypeNotShutdownComplete = errors.New("ChunkType is not of type SHUTDOWN-COMPLETE")

+ var ErrChunkTypeNotTypeInit = errors.New("ChunkType is not of type INIT")

+ var ErrChunkTypeUnhandled = errors.New("unhandled chunk type")

+ var ErrChunkValueNotLongEnough = errors.New("chunk Value isn't long enough for mandatory parameters exp")

+ var ErrCookieEchoNotStoredToSend = errors.New("cookieEcho not stored to send")

+ var ErrHandleInitState = errors.New("todo: handle Init when in state")

+ var ErrHandshakeCookieEcho = errors.New("handshake failed (COOKIE ECHO)")

+ var ErrHandshakeInitAck = errors.New("handshake failed (INIT ACK)")

+ var ErrHeartbeatAckMarshalParam = errors.New("unable to marshal parameter for Heartbeat Ack")

+ var ErrHeartbeatAckNotHeartbeatInfo = errors.New("heartbeat Ack must have one param, and it should be a HeartbeatInfo")

+ var ErrHeartbeatAckParams = errors.New("heartbeat Ack must have one param")

+ var ErrHeartbeatChunkUnmarshal = errors.New("failed unmarshalling param in Heartbeat Chunk")

+ var ErrHeartbeatNotLongEnoughInfo = errors.New("heartbeat is not long enough to contain Heartbeat Info")

+ var ErrHeartbeatParam = errors.New("heartbeat should only have HEARTBEAT param")

+ var ErrInflightQueueTSNPop = errors.New("unable to be popped from inflight queue TSN")

+ var ErrInitAckAdvertisedReceiver1500 = errors.New("INIT ACK Advertised Receiver Window Credit (a_rwnd) must be >= 1500")

+ var ErrInitAckInboundStreamRequestZero = errors.New("INIT ACK inbound stream request must be > 0")

+ var ErrInitAckMarshalParam = errors.New("unable to marshal parameter for INIT/INITACK")

+ var ErrInitAckNoCookie = errors.New("no cookie in InitAck")

+ var ErrInitAckOutboundStreamRequestZero = errors.New("INIT ACK outbound stream request must be > 0")

+ var ErrInitAckUnmarshalFailed = errors.New("failed to unmarshal INIT body")

+ var ErrInitAdvertisedReceiver1500 = errors.New("INIT ACK Advertised Receiver Window Credit (a_rwnd) must be >= 1500")

+ var ErrInitChunkBundled = errors.New("init chunk must not be bundled with any other chunk")

+ var ErrInitChunkParseParamTypeFailed = errors.New("failed to parse param type")

+ var ErrInitChunkUnmarshalParam = errors.New("failed unmarshalling param in Init Chunk")

+ var ErrInitChunkVerifyTagNotZero = errors.New(...)

+ var ErrInitCommonDataMarshalFailed = errors.New("failed marshaling INIT common data")

+ var ErrInitInboundStreamRequestZero = errors.New("INIT ACK inbound stream request must be > 0")

+ var ErrInitNotStoredToSend = errors.New("the init not stored to send")

+ var ErrInitOutboundStreamRequestZero = errors.New("INIT ACK outbound stream request must be > 0")

+ var ErrInvalidAlgorithmType = errors.New("invalid algorithm type")

+ var ErrInvalidChunkSize = errors.New("invalid chunk size")

+ var ErrMarshalStreamFailed = errors.New("failed to marshal stream")

+ var ErrOutboundPacketTooLarge = errors.New("outbound packet larger than maximum message size")

+ var ErrPacketRawTooSmall = errors.New("raw is smaller than the minimum length for a SCTP packet")

+ var ErrParamHeaderParseFailed = errors.New("failed to parse param type")

+ var ErrParamHeaderSelfReportedLengthLonger = errors.New("param self reported length is longer than header length")

+ var ErrParamHeaderSelfReportedLengthShorter = errors.New("param self reported length is shorter than header length")

+ var ErrParamHeaderTooShort = errors.New("param header too short")

+ var ErrParamPacketTooShort = errors.New("packet to short")

+ var ErrParamTypeUnhandled = errors.New("unhandled ParamType")

+ var ErrParamterType = errors.New("unexpected parameter type")

+ var ErrParseParamTypeFailed = errors.New("failed to parse param type")

+ var ErrParseSCTPChunkNotEnoughData = errors.New("unable to parse SCTP chunk, not enough data for complete header")

+ var ErrPayloadDataStateNotExist = errors.New("sending payload data in non-established state")

+ var ErrProtocolViolationUnmarshal = errors.New("unable to unmarshal Protocol Violation error")

+ var ErrReadDeadlineExceeded = fmt.Errorf("read deadline exceeded: %w", os.ErrDeadlineExceeded)

+ var ErrReconfigRespParamTooShort = errors.New("reconfig response parameter too short")

+ var ErrResetPacketInStateNotExist = errors.New("sending reset packet in non-established state")

+ var ErrSCTPPacketDestinationPortZero = errors.New("sctp packet must not have a destination port of 0")

+ var ErrSCTPPacketSourcePortZero = errors.New("sctp packet must not have a source port of 0")

+ var ErrSSNResetRequestParamTooShort = errors.New("outgoing SSN reset request parameter too short")

+ var ErrSackSizeNotLargeEnoughInfo = errors.New("SACK Chunk size is not large enough to contain header")

+ var ErrSackSizeNotMatchPredicted = errors.New("SACK Chunk size does not match predicted amount from header values")

+ var ErrShutdownNonEstablished = errors.New("shutdown called in non-established state")

+ var ErrSilentlyDiscard = errors.New("silently discard")

+ var ErrStreamClosed = errors.New("stream closed")

+ var ErrTSNRequestNotExist = errors.New("requested non-existent TSN")

+ var ErrUnexpectedChuckPoppedOrdered = errors.New("unexpected chunk popped (ordered)")

+ var ErrUnexpectedChuckPoppedUnordered = errors.New("unexpected chunk popped (unordered)")

+ var ErrUnexpectedQState = errors.New("unexpected q state (should've been selected)")

+ var ErrUnimplemented = errors.New("unimplemented")

+ var ErrUnmarshalUnknownChunkType = errors.New("failed to unmarshal, contains unknown chunk type")

v1.8.5

Dec 12, 2022

v1.8.4

Dec 1, 2022

Changes in this version

type Stream

+ func (s *Stream) SetReadDeadline(deadline time.Time) error

+ func (s *Stream) SetState(newState StreamState)

v1.8.3

Oct 15, 2022

Changes in this version

type Association

+ func (a *Association) Abort(reason string)

type Stream

+ func (s *Stream) State() StreamState

+ type StreamState int

+ const StreamStateClosed

+ const StreamStateClosing

+ const StreamStateOpen

+ func (ss StreamState) String() string

v1.8.2

Dec 15, 2021

v1.8.1

Dec 15, 2021

v1.8.0

Nov 9, 2021

Changes in this version

type PayloadProtocolIdentifier

+ const PayloadTypeUnknown

v1.7.12

Mar 23, 2021

Changes in this version

type Association

+ func (a *Association) Shutdown(ctx context.Context) error

v1.7.11

Sep 29, 2020

v1.7.10

Sep 12, 2020

Changes in this version

type Association

+ func (a *Association) MaxMessageSize() uint32

+ func (a *Association) SetMaxMessageSize(maxMsgSize uint32)

type Config

+ MaxMessageSize uint32

v1.7.9

Aug 12, 2020

v1.7.8

Jul 15, 2020

v1.7.7

Jul 13, 2020

v1.7.6

Feb 28, 2020

v1.7.5

Feb 24, 2020

v1.7.4

Feb 1, 2020

v1.7.3

Nov 3, 2019

v1.7.2

Oct 23, 2019

v1.7.1

Oct 21, 2019

v1.7.0

Oct 7, 2019

Changes in this version

type Config

+ MaxReceiveBufferSize uint32

v1.6.13

Sep 30, 2019

v1.6.12

Sep 29, 2019

v1.6.11

Sep 28, 2019

v1.6.10

Sep 8, 2019

v1.6.9

Aug 23, 2019

v1.6.8

Aug 22, 2019

Changes in this version

type Association

+ func (a *Association) BytesReceived() uint64

+ func (a *Association) BytesSent() uint64

v1.6.7

Aug 18, 2019

v1.6.6

Aug 12, 2019

v1.6.5

Aug 8, 2019

v1.6.4

Jul 4, 2019

v1.6.3

May 8, 2019

v1.6.2

May 7, 2019

v1.6.1

Apr 29, 2019

v1.6.0

Apr 25, 2019

v1.5.0

Apr 6, 2019

Changes in this version

+ type Config struct

+ LoggerFactory logging.LoggerFactory

+ NetConn net.Conn

type Stream

+ func (s *Stream) BufferedAmount() uint64

+ func (s *Stream) BufferedAmountLowThreshold() uint64

+ func (s *Stream) OnBufferedAmountLow(f func())

+ func (s *Stream) SetBufferedAmountLowThreshold(th uint64)

v1.4.4

Apr 4, 2019

Changes in this version

+ const ReliabilityTypeReliable

+ const ReliabilityTypeRexmit

+ const ReliabilityTypeTimed

+ type Association struct

+ func Client(netConn net.Conn) (*Association, error)

+ func Server(netConn net.Conn) (*Association, error)

+ func (a *Association) AcceptStream() (*Stream, error)

+ func (a *Association) Close() error

+ func (a *Association) OpenStream(streamIdentifier uint16, defaultPayloadType PayloadProtocolIdentifier) (*Stream, error)

+ type PayloadProtocolIdentifier uint32

+ const PayloadTypeWebRTCBinary

+ const PayloadTypeWebRTCBinaryEmpty

+ const PayloadTypeWebRTCDCEP

+ const PayloadTypeWebRTCString

+ const PayloadTypeWebRTCStringEmpty

+ func (p PayloadProtocolIdentifier) String() string

+ type Stream struct

+ func (s *Stream) Close() error

+ func (s *Stream) Read(p []byte) (int, error)

+ func (s *Stream) ReadSCTP(p []byte) (int, PayloadProtocolIdentifier, error)

+ func (s *Stream) SetDefaultPayloadType(defaultPayloadType PayloadProtocolIdentifier)

+ func (s *Stream) SetReliabilityParams(unordered bool, relType byte, relVal uint32)

+ func (s *Stream) StreamIdentifier() uint16

+ func (s *Stream) Write(p []byte) (n int, err error)

+ func (s *Stream) WriteSCTP(p []byte, ppi PayloadProtocolIdentifier) (n int, err error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL