"""
This script should run in the absmodule.
"""
import socket
import struct
import sys

multicast_group = '224.3.29.71'
server_address = ('',10000)

absmod = ('10.10.20.53', 5500) #This IP should be modificated according to its absmodule
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect(absmod)

# Create the socket
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# Bind to the server address
sock.bind(server_address)

#Tell the operating system to add the socket to the multicast group
#on all interfaces.
group = socket.inet_aton(multicast_group)
mreq  = struct.pack('4sL', group, socket.INADDR_ANY)
sock.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq)
#Receive/respond loop

while True:

    print >>sys.stderr, '\nwaiting to receive message'
    data, address = sock.recvfrom(1024)
    if data != '':
        message = data
        
        s.sendto(message,absmod)
        rx_text = s.recv(1024)
        s.close()
        s = None
        print >>sys.stderr, 'Respond from TCP server: %s' % rx_text
        try:
            s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            s.connect(absmod)
        except:
            print '\nProblem with creating socket repeater!!...\n'
            s.close()
            s = None
            s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            s.connect(absmod)
            break

    print >>sys.stderr, 'received %s bytes from %s' % (len(data), address)
    print >>sys.stderr, data

    #print >>sys.stderr, 'sending acknowledgement to', address
    #sock.sendto('ack', address)break