Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import socket
- import binascii
- import struct
- def create_ipv4_sockets():
- mcast_address = "226.1.1.1"
- src_address = "0.0.0.0"
- port = 50000
- group = (mcast_address, port)
- # Open a multicast receive socket and join the group
- rxsock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
- rxsock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
- rxsock.bind((src_address,50000) )
- print(socket.INADDR_ANY)
- print(socket.inet_aton(src_address))
- req = struct.pack("=4s4s", socket.inet_aton(mcast_address), socket.inet_aton(src_address))
- rxsock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, req)
- return rxsock
- s = create_ipv4_sockets()
- while (1):
- print("essai de reception")
- buf = s.recvfrom(256)
- print("buf :" +str(buf))
Advertisement
Add Comment
Please, Sign In to add comment