#! /usr/bin/python2.7 # # Send/receive UDP multicast packets. # Requires that your OS kernel supports IP multicast. # # Usage: # mcast -s (sender, IPv4) # mcast -s -6 (sender, IPv6) # mcast (receivers, IPv4) # mcast -6 (receivers, IPv6) MYPORT = 8123 MYGROUP_4 = '225.0.0.250' MYGROUP_6 = 'ff15:7079:7468:6f6e:6465:6d6f:6d63:6173' MYTTL = 1 # Increase to reach other networks import time import struct import socket import sys def main(): group = MYGROUP_6 if "-6" in sys.argv[1:] else MYGROUP_4 if "-s" in sys.argv[1:]: sender(group) else: receiver(group) def sender(group): addrinfo = socket.getaddrinfo(group, None)[0] s = socket.socket(addrinfo[0], socket.SOCK_DGRAM) # Set Time-to-live (optional) ttl_bin = struct.pack('@i', MYTTL) if addrinfo[0] == socket.AF_INET: # IPv4 s.setsockopt(socket.IPPROTO_IP, socket.IP_MULTICAST_TTL, ttl_bin) else: s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_MULTICAST_HOPS, ttl_bin) while True: data = repr(time.time()) s.sendto(data + '\0', (addrinfo[4][0], MYPORT)) time.sleep(1) def receiver(group): # Look up multicast group address in name server and find out IP version addrinfo = socket.getaddrinfo(group, None)[0] # Create a socket s = socket.socket(addrinfo[0], socket.SOCK_DGRAM) # Allow multiple copies of this program on one machine # (not strictly needed) s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # Bind it to the port s.bind(('', MYPORT)) group_bin = socket.inet_pton(addrinfo[0], addrinfo[4][0]) # Join group if addrinfo[0] == socket.AF_INET: # IPv4 mreq = group_bin + struct.pack('=I', socket.INADDR_ANY) s.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq) else: mreq = group_bin + struct.pack('@I', 0) s.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_JOIN_GROUP, mreq) # Loop, printing any data we receive while True: data, sender = s.recvfrom(1500) while data[-1:] == '\0': data = data[:-1] # Strip trailing \0's print (str(sender) + ' ' + repr(data)) if __name__ == '__main__': main()
Name | Type | Size | Permission | Actions |
---|---|---|---|---|
README | File | 628 B | 0644 |
|
broadcast.py | File | 283 B | 0644 |
|
broadcast.pyc | File | 547 B | 0644 |
|
broadcast.pyo | File | 547 B | 0644 |
|
echosvr.py | File | 738 B | 0755 |
|
echosvr.pyc | File | 827 B | 0644 |
|
echosvr.pyo | File | 827 B | 0644 |
|
finger.py | File | 1.23 KB | 0755 |
|
finger.pyc | File | 1.13 KB | 0644 |
|
finger.pyo | File | 1.13 KB | 0644 |
|
ftp.py | File | 3.84 KB | 0644 |
|
ftp.pyc | File | 2.88 KB | 0644 |
|
ftp.pyo | File | 2.88 KB | 0644 |
|
gopher.py | File | 9.55 KB | 0755 |
|
gopher.pyc | File | 10.08 KB | 0644 |
|
gopher.pyo | File | 10.08 KB | 0644 |
|
mcast.py | File | 2.16 KB | 0755 |
|
mcast.pyc | File | 2.12 KB | 0644 |
|
mcast.pyo | File | 2.12 KB | 0644 |
|
radio.py | File | 287 B | 0644 |
|
radio.pyc | File | 471 B | 0644 |
|
radio.pyo | File | 471 B | 0644 |
|
rpython.py | File | 713 B | 0755 |
|
rpython.pyc | File | 982 B | 0644 |
|
rpython.pyo | File | 982 B | 0644 |
|
rpythond.py | File | 1.18 KB | 0755 |
|
rpythond.pyc | File | 1.3 KB | 0644 |
|
rpythond.pyo | File | 1.3 KB | 0644 |
|
telnet.py | File | 2.94 KB | 0755 |
|
telnet.pyc | File | 2.1 KB | 0644 |
|
telnet.pyo | File | 2.1 KB | 0644 |
|
throughput.py | File | 2.04 KB | 0755 |
|
throughput.pyc | File | 2.42 KB | 0644 |
|
throughput.pyo | File | 2.42 KB | 0644 |
|
udpecho.py | File | 1.43 KB | 0755 |
|
udpecho.pyc | File | 1.98 KB | 0644 |
|
udpecho.pyo | File | 1.98 KB | 0644 |
|
unicast.py | File | 230 B | 0644 |
|
unicast.pyc | File | 456 B | 0644 |
|
unicast.pyo | File | 456 B | 0644 |
|
unixclient.py | File | 232 B | 0644 |
|
unixclient.pyc | File | 424 B | 0644 |
|
unixclient.pyo | File | 424 B | 0644 |
|
unixserver.py | File | 414 B | 0644 |
|
unixserver.pyc | File | 593 B | 0644 |
|
unixserver.pyo | File | 593 B | 0644 |
|