mirror of
https://github.com/status-im/status-go.git
synced 2025-01-14 16:56:44 +00:00
93 lines
2.4 KiB
Go
93 lines
2.4 KiB
Go
package sctp // nolint:dupl
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
)
|
|
|
|
/*
|
|
Abort represents an SCTP Chunk of type ABORT
|
|
|
|
The ABORT chunk is sent to the peer of an association to close the
|
|
association. The ABORT chunk may contain Cause Parameters to inform
|
|
the receiver about the reason of the abort. DATA chunks MUST NOT be
|
|
bundled with ABORT. Control chunks (except for INIT, INIT ACK, and
|
|
SHUTDOWN COMPLETE) MAY be bundled with an ABORT, but they MUST be
|
|
placed before the ABORT in the SCTP packet or they will be ignored by
|
|
the receiver.
|
|
|
|
0 1 2 3
|
|
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
|
|
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|
|
| Type = 6 |Reserved |T| Length |
|
|
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|
|
| |
|
|
| zero or more Error Causes |
|
|
| |
|
|
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|
|
*/
|
|
type chunkAbort struct {
|
|
chunkHeader
|
|
errorCauses []errorCause
|
|
}
|
|
|
|
var (
|
|
errChunkTypeNotAbort = errors.New("ChunkType is not of type ABORT")
|
|
errBuildAbortChunkFailed = errors.New("failed build Abort Chunk")
|
|
)
|
|
|
|
func (a *chunkAbort) unmarshal(raw []byte) error {
|
|
if err := a.chunkHeader.unmarshal(raw); err != nil {
|
|
return err
|
|
}
|
|
|
|
if a.typ != ctAbort {
|
|
return fmt.Errorf("%w: actually is %s", errChunkTypeNotAbort, a.typ.String())
|
|
}
|
|
|
|
offset := chunkHeaderSize
|
|
for {
|
|
if len(raw)-offset < 4 {
|
|
break
|
|
}
|
|
|
|
e, err := buildErrorCause(raw[offset:])
|
|
if err != nil {
|
|
return fmt.Errorf("%w: %v", errBuildAbortChunkFailed, err)
|
|
}
|
|
|
|
offset += int(e.length())
|
|
a.errorCauses = append(a.errorCauses, e)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (a *chunkAbort) marshal() ([]byte, error) {
|
|
a.chunkHeader.typ = ctAbort
|
|
a.flags = 0x00
|
|
a.raw = []byte{}
|
|
for _, ec := range a.errorCauses {
|
|
raw, err := ec.marshal()
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
a.raw = append(a.raw, raw...)
|
|
}
|
|
return a.chunkHeader.marshal()
|
|
}
|
|
|
|
func (a *chunkAbort) check() (abort bool, err error) {
|
|
return false, nil
|
|
}
|
|
|
|
// String makes chunkAbort printable
|
|
func (a *chunkAbort) String() string {
|
|
res := a.chunkHeader.String()
|
|
|
|
for _, cause := range a.errorCauses {
|
|
res += fmt.Sprintf("\n - %s", cause)
|
|
}
|
|
|
|
return res
|
|
}
|