This commit is contained in:
黄思敏 2022-08-29 11:21:23 +08:00
parent f4b1dc1a4e
commit 7a28fca8ff

View File

@ -210,7 +210,7 @@ func (nc *NetCard) runRead() {
// log.Printf("Payload: % x\n", rframe.Payload()) // log.Printf("Payload: % x\n", rframe.Payload())
log.Printf("Ethertype: % x %v realAddr %s\n", rframe.Ethertype(), waterutil.IsIPv4(rframe), realAddr) log.Printf("Ethertype: % x %v realAddr %s\n", rframe.Ethertype(), waterutil.IsIPv4(rframe), realAddr)
log.Printf("Dst: %s Src %s\n", waterutil.IPv4Destination(rframe), waterutil.IPv4Source(rframe)) log.Printf("Src %s Dst: %s\n", waterutil.IPv4Source(rframe), waterutil.IPv4Destination(rframe))
var buffer *ExchangeBuffer var buffer *ExchangeBuffer
if buffer, ok = bytesMap[realAddr]; !ok { if buffer, ok = bytesMap[realAddr]; !ok {
@ -223,11 +223,6 @@ func (nc *NetCard) runRead() {
for dst, buffer := range bytesMap { for dst, buffer := range bytesMap {
for _, buf := range buffer.BytesArray {
ifce.Write(buf)
}
continue
var cli *RPCClient var cli *RPCClient
if cli, ok = nc.clientMap[dst]; !ok { if cli, ok = nc.clientMap[dst]; !ok {