comm

type Fault struct {
	Type      string
	Happening bool
	Durtaion  int
}

type Flow struct {
	Name string   `json:"name"` // subsys name
	ID   int      `json:"id"`   // subsys id
	Dst  []string `json:"dst"`
	Freq string   `json:"freq"`
}

type Link struct {
	PacketLossRate float64 // percentage
	Bandwidth      float64 // in Mbps
	Speed          float64 // m/s
	Distance       float64 // in meter

	// for mars-earth
	HardcodedDelay float64
	Failed         bool
	// contains filtered or unexported fields
}

type Log struct {
	Type       int               `json:"type"` // -1: heartbeat, 0: log, 1: statistics
	Msg        string            `json:"msg"`
	Statistics map[string][2]int `json:"stats_comm"`
	PktTx      PktTx             `json:"pkt_tx"`
}

type Node interface {
	Name() string
	OutPort() *Port // return an idle outcoming port for connecting
	InPort() *Port  // return an idle incoming port for connecting
	Start()
}

type Packet struct {
	// protocol use
	Src          uint8  `json:"src"`
	Dst          uint8  `json:"dst"`
	MessageType  uint8  `json:"message_type"`
	Priority     uint8  `json:"priority"`
	Version      uint8  `json:"version"`
	Reserved     uint8  `json:"reserved"`
	PhysicalTime uint32 `json:"physical_time"`
	SimulinkTime uint32 `json:"simulink_time"`
	Sequence     uint16 `json:"sequence"`
	Length       uint16 `json:"length"`
	Payload      []byte `json:"-"`

	// internal use
	IsSim       bool
	RawBytes    []byte
	Delay       float64
	Path        []string
	UID         int   // for animation
	Seq         int32 // for 802.1CB-FRER
	RxTimestamp int64
	TxTimestamp int64
	DupID       int
}

type PktTx struct {
	Node     string `json:"node"`
	UID      int    `json:"uid"`
	Finished bool   `json:"finished"`
}

type Port struct {
	ID       int
	Owner    string
	Neighbor string
	Channel  chan *Packet
	Failed   bool
}

type Priority struct {
	Name     string      `json:"name"`
	Priority json.Number `json:"priority"`
}

type RoutingEntry struct {
	NextHop  string
	HopCount int
}

type StatsDelay struct {
	Source string       `json:"source"`
	Data   [][2]float64 `json:"data"`
}

type Subsys struct {
	Priority int // will overwrite priority in packets

	RoutingTable map[string][]RoutingEntry

	SeqRecoverHistory      map[int32]bool // for frer
	SeqRecoverHistoryMutex sync.Mutex
	// contains filtered or unexported fields
}

type Switch struct {
	GCL [PORT_NUM_SWITCH][]TimeWindow // portid:schedule

	Neighbors []string

	Faults map[string]Fault

	SeqRecoverHistory      map[int32]bool
	SeqRecoverHistoryMutex sync.Mutex
	RoutingTable           map[string][]RoutingEntry
	// contains filtered or unexported fields
}

type TimeWindow struct {
	Queue int `json:"queue"`
}

type TopoGraph struct {
	Nodes []*TopologyGraphNode
}

type TopologyData struct {
	Tag   string         `json:"tag"`
	Nodes []TopologyNode `json:"nodes"`
	Edges [][2]string    `json:"edges"`
}

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

type TopologyNode struct {
	Name     string `json:"name"`
	Position [2]int `json:"value"`
}