isotp

Documentation

Index

• Constants
• Variables
• type Address
  • func NewAddress(rxid, txid int64) Address
• type AnyConn
• type IsotpConnection
  • func NewIsotpConnection(rx, tx int64, rxfn func() (Message, bool), txfn func(msg Message)) *IsotpConnection
  • func (ic *IsotpConnection) Empty_rxqueue()
  • func (ic *IsotpConnection) Empty_txqueue()
  • func (ic *IsotpConnection) Open()
  • func (ic *IsotpConnection) Send(payload []byte)
  • func (ic *IsotpConnection) Send_and_grant_flow_request(payload []byte, length int) []byte
  • func (ic *IsotpConnection) Send_and_no_wait_for_reply(payload []byte) []byte
  • func (ic *IsotpConnection) Send_and_wait_for_reply(payload []byte) []byte
  • func (ic *IsotpConnection) Wait_frame() []byte
• type Message
  • func NewMessage(id int64, payload []byte) Message
  • func (m Message) ToBytes() []byte
• type PDU
  • func NewPDU(msg Message, start_of_data int, data_length int) PDU
• type Timer
  • func NewTimer(timeout float32) *Timer
• type Transport
  • func NewTransport(a Address, rxfn func() (Message, bool), txfn func(m Message)) *Transport
  • func (t *Transport) Process()
  • func (t *Transport) Recv() []byte
  • func (t *Transport) Send(data []byte)

Constants

const CONSECUTIVE = "CONSECUTIVE"

const CONTINUE = "CONTINUE"

const Extended_11bits = 3

const Extended_29bits = 4

const FIRST = "FIRST"

const FLOW = "FLOW"

const Functional = 1

const IDLE = "IDLE"

const Mixed_11bits = 5

const Mixed_29bits = 6

const NormalFixed_29bits = 2

const Normal_11bits = 0

const Normal_29bits = 1

const OVERFLOW = "OVERFLOW"

const Physical = 0

const SINGLE = "SINGLE"

const TRANSMIT = "TRANSMIT"

const WAIT = "WAIT"

Variables

var RXID int64

var TXID int64

Types

type Address

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

func NewAddress

func NewAddress(rxid, txid int64) Address

type AnyConn

type AnyConn interface {
	Empty_rxqueue()
	Empty_txqueue()
	Send(payload []byte)
	Wait_frame() []byte
	Send_and_grant_flow_request(payload []byte, length int) []byte
	Send_and_wait_for_reply(payload []byte) []byte
	Send_and_no_wait_for_reply(payload []byte) []byte
}

type IsotpConnection

type IsotpConnection struct {
	Stack *Transport
	// contains filtered or unexported fields
}

func NewIsotpConnection

func NewIsotpConnection(rx, tx int64, rxfn func() (Message, bool),
	txfn func(msg Message)) *IsotpConnection

func (*IsotpConnection) Empty_rxqueue

func (ic *IsotpConnection) Empty_rxqueue()

func (*IsotpConnection) Empty_txqueue

func (ic *IsotpConnection) Empty_txqueue()

func (*IsotpConnection) Open

func (ic *IsotpConnection) Open()

func (*IsotpConnection) Send

func (ic *IsotpConnection) Send(payload []byte)

func (*IsotpConnection) Send_and_grant_flow_request

func (ic *IsotpConnection) Send_and_grant_flow_request(payload []byte, length int) []byte

func (*IsotpConnection) Send_and_no_wait_for_reply

func (ic *IsotpConnection) Send_and_no_wait_for_reply(payload []byte) []byte

func (*IsotpConnection) Send_and_wait_for_reply

func (ic *IsotpConnection) Send_and_wait_for_reply(payload []byte) []byte

func (*IsotpConnection) Wait_frame

func (ic *IsotpConnection) Wait_frame() []byte

type Message

type Message struct {
	Id      int64
	Payload []byte
	// contains filtered or unexported fields
}

func NewMessage

func NewMessage(id int64, payload []byte) Message

func (Message) ToBytes

func (m Message) ToBytes() []byte

type PDU

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

func NewPDU

func NewPDU(msg Message, start_of_data int, data_length int) PDU

type Timer

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

func NewTimer

func NewTimer(timeout float32) *Timer

type Transport

type Transport struct {
	Stmin     int
	Blocksize int
	// contains filtered or unexported fields
}

func NewTransport

func NewTransport(a Address, rxfn func() (Message, bool), txfn func(m Message)) *Transport

func (*Transport) Process

func (t *Transport) Process()

func (*Transport) Recv

func (t *Transport) Recv() []byte

func (*Transport) Send

func (t *Transport) Send(data []byte)