streaming-docker/tools/multicastjoin.py

25 lines
570 B
Python
Executable File

#!/usr/bin/python
import socket, sys
from struct import *
import struct
import time
import sys
import logging
logging.basicConfig(level=logging.INFO)
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
sock.bind(('', 2068))
try:
mreq = struct.pack("=4sl", socket.inet_aton("226.2.2.2"), socket.INADDR_ANY)
sock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq)
except:
logging.exception(':(')
sys.stderr.write('******* Subscribe failed')
time.sleep(30)