diff --git a/Network IPv4 Broadcast.go b/Network IPv4 Broadcast.go index bddc631..bc48d54 100644 --- a/Network IPv4 Broadcast.go +++ b/Network IPv4 Broadcast.go @@ -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} } } diff --git a/Network IPv6 Multicast.go b/Network IPv6 Multicast.go index 1fd650e..eeae8e9 100644 --- a/Network IPv6 Multicast.go +++ b/Network IPv6 Multicast.go @@ -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} } } diff --git a/Network Init.go b/Network Init.go index 0904cb5..84d20c0 100644 --- a/Network Init.go +++ b/Network Init.go @@ -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 ( diff --git a/Network.go b/Network.go index dec146d..1a3278d 100644 --- a/Network.go +++ b/Network.go @@ -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} } }