tcp

Documentation

Index

• func PacketHandler(packet gopacket.Packet)
• func SetSendChannel(channel *pcap.Handle)
• type Connection
  • func NewConnection(channel *chan gopacket.Packet, request gopacket.Packet) *Connection
  • func (conn *Connection) Rewrite(data []byte, startSeq uint32)
  • func (conn *Connection) Update(rawPacket gopacket.Packet)
  • func (conn *Connection) WriteWindow(data []byte, startSeq uint32)
• type State
• type Timer
  • func NewTimer(max uint32) Timer
  • func (timer *Timer) Reset()
  • func (timer *Timer) Tick() bool

Functions

func PacketHandler

func PacketHandler(packet gopacket.Packet)

TCP包处理

func SetSendChannel

func SetSendChannel(channel *pcap.Handle)

Types

type Connection

type Connection struct {

	// 数据包channel
	Channel *chan gopacket.Packet
	// 连接状态
	State State
	// contains filtered or unexported fields
}

TCP Connection

func NewConnection

func NewConnection(channel *chan gopacket.Packet, request gopacket.Packet) *Connection

新建TCP连接

func (*Connection) Rewrite

func (conn *Connection) Rewrite(data []byte, startSeq uint32)

重发数据

func (*Connection) Update

func (conn *Connection) Update(rawPacket gopacket.Packet)

更新Connect数据

func (*Connection) WriteWindow

func (conn *Connection) WriteWindow(data []byte, startSeq uint32)

TCP写入数据接口 每次最多发送接收方窗口大小的数据

type State

type State uint8

TCP State

const (
	UNCONNECT   State = 0
	CONNECTED   State = 1
	WAITSYNACK  State = 3
	SENDDATA    State = 4
	RECEIVEDATA State = 5
	WAITACK     State = 6
	SENDFIN     State = 7
	RECEIVEFIN  State = 8
	WAITFINACK  State = 9
)

type Timer

type Timer struct {
	// contains filtered or unexported fields
}

计时器

func NewTimer

func NewTimer(max uint32) Timer

构造函数

func (*Timer) Reset

func (timer *Timer) Reset()

重置时间

func (*Timer) Tick

func (timer *Timer) Tick() bool

计时