diff --git a/devices/abs/module_abs/multicast_absmodule.py b/devices/abs/module_abs/multicast_absmodule.py new file mode 100644 index 0000000..51aee44 --- /dev/null +++ b/devices/abs/module_abs/multicast_absmodule.py @@ -0,0 +1,55 @@ +""" +This script should run in the absmodule. +""" +import socket +import struct +import sys + +multicast_group = '224.3.29.71' +server_address = ('',10000) + +mod = ('192.168.1.63', 5500) #This IP should be modificated according to its absmodule +s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) +s.connect(mod) + +# 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 + #try: + s.sendto(message,mod) + 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(mod) + except: + print '\nProblem with creating socket repeater!!...\n' + s.close() + s = None + s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) + s.connect(mod) + 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 diff --git a/devices/abs/module_abs/multicast_server.py b/devices/abs/module_abs/multicast_server.py new file mode 100644 index 0000000..748dea7 --- /dev/null +++ b/devices/abs/module_abs/multicast_server.py @@ -0,0 +1,19 @@ +""" +This script should run in SIR. It creates a multicast server. +This server connects SIR client to a absmodule socket. SIR client socket sends SIR data to multicast server. This server sends the data to a +absmodule socket repeater that re-sends the configuration to Tcp Control Module (C server running in absmodule). +""" + +import socket +import struct +import sys + +#-------Socket Server---------- +sock_server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP) +sock_server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) +sock_server.bind(('',4242)) +mreq = struct.pack("=4sl", socket.inet_aton("224.3.29.71"),socket.INADDR_ANY) +sock_server.setsockopt(socket.IPPROTO_IP, socket.IP_ADD_MEMBERSHIP, mreq) + +while True: + print sock_server.recv(1024)