mirror of
https://github.com/PeernetOfficial/core.git
synced 2026-07-16 18:37:51 +01:00
Minor change: New networkWire.unicast field which might be handy in the future.
This commit is contained in:
@@ -79,7 +79,7 @@ func (network *Network) BroadcastIPv4Listen() {
|
||||
}
|
||||
|
||||
// send the packet to a channel which is processed by multiple workers.
|
||||
rawPacketsIncoming <- networkWire{network: network, sender: sender.(*net.UDPAddr), raw: buffer[:length], receiverPublicKey: ipv4BroadcastPublicKey}
|
||||
rawPacketsIncoming <- networkWire{network: network, sender: sender.(*net.UDPAddr), raw: buffer[:length], receiverPublicKey: ipv4BroadcastPublicKey, unicast: false}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -125,7 +125,7 @@ func (network *Network) MulticastIPv6Listen() {
|
||||
}
|
||||
|
||||
// send the packet to a channel which is processed by multiple workers.
|
||||
rawPacketsIncoming <- networkWire{network: network, sender: sender.(*net.UDPAddr), raw: buffer[:length], receiverPublicKey: ipv6MulticastPublicKey}
|
||||
rawPacketsIncoming <- networkWire{network: network, sender: sender.(*net.UDPAddr), raw: buffer[:length], receiverPublicKey: ipv6MulticastPublicKey, unicast: false}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -27,6 +27,7 @@ type networkWire struct {
|
||||
sender *net.UDPAddr // sender of the packet
|
||||
receiverPublicKey *btcec.PublicKey // public key associated with the receiver
|
||||
raw []byte // buffer
|
||||
unicast bool // True if the message was sent via unicast. False if sent via IPv4 broadcast or IPv6 multicast.
|
||||
}
|
||||
|
||||
var (
|
||||
|
||||
@@ -106,7 +106,7 @@ func (network *Network) Listen() {
|
||||
}
|
||||
|
||||
// send the packet to a channel which is processed by multiple workers.
|
||||
rawPacketsIncoming <- networkWire{network: network, sender: sender, raw: buffer[:length], receiverPublicKey: peerPublicKey}
|
||||
rawPacketsIncoming <- networkWire{network: network, sender: sender, raw: buffer[:length], receiverPublicKey: peerPublicKey, unicast: true}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user