ynerant
/
squinnondation
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/multicast' into multicast

This commit is contained in:
Yohann D'ANELLO 2021-01-09 21:31:52 +01:00
parent 7554bd0379 d23bb086dd
commit 83998e639b
Signed by: ynerant
GPG Key ID: 3A75C55819C8CF85
2 changed files with 0 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
for_testing_multicast/peer.py
View File

@ -1,28 +0,0 @@
from typing import Any, Tuple, Generator
from ipaddress import IPv6Address
import re
import socket
import time
import struct
# Initialise socket for IPv6 datagrams
sock = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
# Allows address to be reused
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
# Binds to all interfaces on the given port
sock.bind(('', 1212))
# Allow messages from this socket to loop back for development
#sock.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_MULTICAST_LOOP, True)
# Construct message for joining multicast group
#mreq = struct.pack("16s15s".encode('utf-8'), socket.inet_pton(socket.AF_INET6, "ff02::4242:4242"), (chr(0) * 16).encode('utf-8'))
mreq = struct.pack("16s15s", socket.inet_pton(socket.AF_INET6, "ff02::4242:4242"), bytes(socket.INADDR_ANY))
sock.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_JOIN_GROUP, mreq)
data, addr = sock.recvfrom(1024)
print(data)
print(addr[0], addr[1])

15
for_testing_multicast/sender.py
View File

@ -1,15 +0,0 @@
from typing import Any, Tuple, Generator
from ipaddress import IPv6Address
import re
import socket
import time
import struct
# Initialise socket for IPv6 datagrams
sock = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
sock.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, 2)
sock.sendto("hello world".encode('utf-8'), ("ff02::4242:4242", 1212))