Update readme.md

This commit is contained in:
Kusakabe Si 2021-12-12 18:40:21 +00:00
parent 2a27f7b463
commit 0258ed4ef0
3 changed files with 49 additions and 3 deletions

View File

@ -7,6 +7,7 @@ package device
import ( import (
"bytes" "bytes"
"encoding/base64"
"encoding/binary" "encoding/binary"
"errors" "errors"
"fmt" "fmt"
@ -470,7 +471,12 @@ func (peer *Peer) RoutineSequentialReceiver() {
src_nodeID = EgHeader.GetSrc() src_nodeID = EgHeader.GetSrc()
dst_nodeID = EgHeader.GetDst() dst_nodeID = EgHeader.GetDst()
packet_type = elem.Type packet_type = elem.Type
if !packet_type.IsValid_EgType() {
if device.LogLevel.LogTransit {
fmt.Printf("Transit: Invalid packet usage:%v ttl:%v, content %v PL:%v S:%v D:%v From:%v IP:%v\n", elem.Type.ToString(), elem.TTL, base64.StdEncoding.EncodeToString([]byte(elem.packet)), len(elem.packet), src_nodeID.ToString(), dst_nodeID.ToString(), peer.ID.ToString(), peer.endpoint.DstToString())
}
goto skip
}
if device.IsSuperNode { if device.IsSuperNode {
if packet_type.IsControl_Edge2Super() { if packet_type.IsControl_Edge2Super() {
should_process = true should_process = true
@ -574,6 +580,10 @@ func (peer *Peer) RoutineSequentialReceiver() {
fmt.Printf("Transit: Transfer From:%v Me:%v To:%v S:%v D:%v\n", peer.ID, device.ID, peer_out.ID, src_nodeID.ToString(), dst_nodeID.ToString()) fmt.Printf("Transit: Transfer From:%v Me:%v To:%v S:%v D:%v\n", peer.ID, device.ID, peer_out.ID, src_nodeID.ToString(), dst_nodeID.ToString())
} }
go device.SendPacket(peer_out, elem.Type, l2ttl, elem.packet, MessageTransportOffsetContent) go device.SendPacket(peer_out, elem.Type, l2ttl, elem.packet, MessageTransportOffsetContent)
} else {
if device.LogLevel.LogTransit {
fmt.Printf("Transit: No route to %v,usage:%v ttl:%v, content %v PL:%v S:%v D:%v From:%v IP:%v\n", dst_nodeID.ToString(), elem.Type.ToString(), elem.TTL, base64.StdEncoding.EncodeToString([]byte(elem.packet)), len(elem.packet), src_nodeID.ToString(), dst_nodeID.ToString(), peer.ID.ToString(), peer.endpoint.DstToString())
}
} }
} }
} }

View File

@ -9,7 +9,7 @@ The SuperNode runs [Floyd-Warshall Algorithm](https://en.wikipedia.org/wiki/Floy
## Quick start ## Quick start
首先按需求修改`gensuper.yaml` Edit the file `gensuper.yaml` based on your requirement first.
```yaml ```yaml
Config output dir: /tmp/eg_gen Config output dir: /tmp/eg_gen

View File

@ -32,6 +32,42 @@ const (
BroadcastPeer BroadcastPeer
) )
func (v Usage) IsValid_EgType() bool {
if v >= NormalPacket && v <= BroadcastPeer {
return true
}
return false
}
func (v Usage) ToString() string {
switch v {
case MessageInitiationType:
return "MessageInitiationType"
case MessageResponseType:
return "MessageResponseType"
case MessageCookieReplyType:
return "MessageCookieReplyType"
case MessageTransportType:
return "MessageTransportType"
case NormalPacket:
return "NormalPacket"
case Register:
return "Register"
case ServerUpdate:
return "ServerUpdate"
case PingPacket:
return "PingPacket"
case PongPacket:
return "PongPacket"
case QueryPeer:
return "QueryPeer"
case BroadcastPeer:
return "BroadcastPeer"
default:
return "Unknown:" + string(uint8(v))
}
}
func (v Usage) IsNormal() bool { func (v Usage) IsNormal() bool {
return v == NormalPacket return v == NormalPacket
} }