mirror of
https://github.com/soypat/lneto.git
synced 2026-08-25 00:49:04 +00:00
gofmt: ran gofmt because noticed weird diffs in last commit, seemed OK though
This commit is contained in:
+1
-1
@@ -369,4 +369,4 @@ func getSrcIPPort(ipCarrier []byte) (srcaddr []byte, port uint16, err error) {
|
|||||||
}
|
}
|
||||||
port = binary.BigEndian.Uint16(ipCarrier[off:]) // TCP and UDP share same port offsets.
|
port = binary.BigEndian.Uint16(ipCarrier[off:]) // TCP and UDP share same port offsets.
|
||||||
return srcaddr, port, nil
|
return srcaddr, port, nil
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -355,4 +355,4 @@ func TestServerRediscover(t *testing.T) {
|
|||||||
if cl.State() != StateBound {
|
if cl.State() != StateBound {
|
||||||
t.Errorf("second DORA: want StateBound, got %s", cl.State())
|
t.Errorf("second DORA: want StateBound, got %s", cl.State())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -259,8 +259,8 @@ func (d *dhcpInterceptor) buildARPReply(request []byte) {
|
|||||||
|
|
||||||
// ARP reply.
|
// ARP reply.
|
||||||
afrm, _ := arp.NewFrame(buf[sizeEthernet:])
|
afrm, _ := arp.NewFrame(buf[sizeEthernet:])
|
||||||
afrm.SetHardware(1, 6) // Ethernet, 6-byte addresses
|
afrm.SetHardware(1, 6) // Ethernet, 6-byte addresses
|
||||||
afrm.SetProtocol(ethernet.TypeIPv4, 4) // IPv4, 4-byte addresses
|
afrm.SetProtocol(ethernet.TypeIPv4, 4) // IPv4, 4-byte addresses
|
||||||
afrm.SetOperation(arp.OpReply)
|
afrm.SetOperation(arp.OpReply)
|
||||||
replySndrHW, replySndrIP := afrm.Sender4()
|
replySndrHW, replySndrIP := afrm.Sender4()
|
||||||
*replySndrHW = d.svMAC
|
*replySndrHW = d.svMAC
|
||||||
|
|||||||
+5
-5
@@ -11,11 +11,11 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
ErrRingBufferFull = lneto.ErrBufferFull
|
ErrRingBufferFull = lneto.ErrBufferFull
|
||||||
errRingNoData = errors.New("lneto/ring: empty write")
|
errRingNoData = errors.New("lneto/ring: empty write")
|
||||||
errInvalidDiscard = errors.New("lneto/ring: invalid discard amount")
|
errInvalidDiscard = errors.New("lneto/ring: invalid discard amount")
|
||||||
errDiscardExceeds = errors.New("lneto/ring: discard exceeds length")
|
errDiscardExceeds = errors.New("lneto/ring: discard exceeds length")
|
||||||
errOffsetOverflow = errors.New("lneto/ring: offset too large (32 bit overflow)")
|
errOffsetOverflow = errors.New("lneto/ring: offset too large (32 bit overflow)")
|
||||||
)
|
)
|
||||||
|
|
||||||
// Ring implements basic Ring buffer functionality.
|
// Ring implements basic Ring buffer functionality.
|
||||||
|
|||||||
@@ -118,7 +118,6 @@ func (i6frm Frame) ClearHeader() {
|
|||||||
// Validate API.
|
// Validate API.
|
||||||
//
|
//
|
||||||
|
|
||||||
|
|
||||||
// ValidateSize checks the frame's size fields and compares with the actual buffer
|
// ValidateSize checks the frame's size fields and compares with the actual buffer
|
||||||
// the frame. It returns a non-nil error on finding an inconsistency.
|
// the frame. It returns a non-nil error on finding an inconsistency.
|
||||||
func (i6frm Frame) ValidateSize(v *lneto.Validator) {
|
func (i6frm Frame) ValidateSize(v *lneto.Validator) {
|
||||||
|
|||||||
+8
-8
@@ -16,14 +16,14 @@ var (
|
|||||||
errDropSegment error = lneto.ErrPacketDrop
|
errDropSegment error = lneto.ErrPacketDrop
|
||||||
errWindowTooLarge = errors.New("invalid window size > 2**16")
|
errWindowTooLarge = errors.New("invalid window size > 2**16")
|
||||||
|
|
||||||
errBufferTooSmall error = lneto.ErrShortBuffer
|
errBufferTooSmall error = lneto.ErrShortBuffer
|
||||||
errNeedClosedTCBToOpen = errors.New("need closed TCB to call open")
|
errNeedClosedTCBToOpen = errors.New("need closed TCB to call open")
|
||||||
errInvalidState = errors.New("invalid state")
|
errInvalidState = errors.New("invalid state")
|
||||||
errConnNotExist = errors.New("connection does not exist")
|
errConnNotExist = errors.New("connection does not exist")
|
||||||
errConnectionClosing = errors.New("connection closing")
|
errConnectionClosing = errors.New("connection closing")
|
||||||
errExpectedSYN = errors.New("seqs:expected SYN")
|
errExpectedSYN = errors.New("seqs:expected SYN")
|
||||||
errBadSegack = errors.New("seqs:bad segack")
|
errBadSegack = errors.New("seqs:bad segack")
|
||||||
errFinwaitExpectedACK = errors.New("seqs:finwait1 expected ACK")
|
errFinwaitExpectedACK = errors.New("seqs:finwait1 expected ACK")
|
||||||
|
|
||||||
errWindowOverflow = newRejectErr("wnd > 2**16")
|
errWindowOverflow = newRejectErr("wnd > 2**16")
|
||||||
errSeqNotInWindow = newRejectErr("seq not in snd/rcv.wnd")
|
errSeqNotInWindow = newRejectErr("seq not in snd/rcv.wnd")
|
||||||
|
|||||||
@@ -177,7 +177,6 @@ func (tfrm Frame) String() string {
|
|||||||
// Validation API
|
// Validation API
|
||||||
//
|
//
|
||||||
|
|
||||||
|
|
||||||
// func (tfrm Frame) Validate(v *lneto.Validator) {
|
// func (tfrm Frame) Validate(v *lneto.Validator) {
|
||||||
// tfrm.ValidateSize(v)
|
// tfrm.ValidateSize(v)
|
||||||
// tfrm.ValidateExceptCRC(v)
|
// tfrm.ValidateExceptCRC(v)
|
||||||
|
|||||||
+2
-2
@@ -214,7 +214,7 @@ func TestWindowReject_ChallengeACK(t *testing.T) {
|
|||||||
t.Run("SeqNotInWindow", func(t *testing.T) {
|
t.Run("SeqNotInWindow", func(t *testing.T) {
|
||||||
tcb := setup()
|
tcb := setup()
|
||||||
retransmit := Segment{
|
retransmit := Segment{
|
||||||
SEQ: issB, // Before rcv.NXT (issB+512).
|
SEQ: issB, // Before rcv.NXT (issB+512).
|
||||||
ACK: issA,
|
ACK: issA,
|
||||||
Flags: FlagACK,
|
Flags: FlagACK,
|
||||||
WND: 64240,
|
WND: 64240,
|
||||||
@@ -237,7 +237,7 @@ func TestWindowReject_ChallengeACK(t *testing.T) {
|
|||||||
t.Run("LastNotInWindow", func(t *testing.T) {
|
t.Run("LastNotInWindow", func(t *testing.T) {
|
||||||
tcb := setup()
|
tcb := setup()
|
||||||
seg := Segment{
|
seg := Segment{
|
||||||
SEQ: issB + 512, // At rcv.NXT (in window).
|
SEQ: issB + 512, // At rcv.NXT (in window).
|
||||||
ACK: issA,
|
ACK: issA,
|
||||||
Flags: FlagACK,
|
Flags: FlagACK,
|
||||||
WND: 64240,
|
WND: 64240,
|
||||||
|
|||||||
Reference in New Issue
Block a user