radarsys_met Files · devices/abs/module_abs/multicast_absmodule.py

Experiment detail view update

Fiorella Quino - - Load All Authors

File last commit:

r231:ff117d7a8fbd


                r365:24b24259841b

Download file

             multicast_absmodule.py
        
                    55 lines
            
             | 1.6 KiB
            
                | text/x-python
            
             |
                PythonLexer
            
             / devices / abs / module_abs / multicast_absmodule.py
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        Fiorella Quino
    
Multicast scripts...

              r193
            
      """

      This script should run in the absmodule.

      """

      import socket

      import struct

      import sys

      multicast_group = '224.3.29.71'

      server_address = ('',10000)

        Fiorella Quino
    
sockets and restful...

              r223
            
      absmod = ('10.10.20.53', 5500) #This IP should be modificated according to its absmodule

        Fiorella Quino
    
Multicast scripts...

              r193
            
      s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

        Fiorella Quino
    
sockets and restful...

              r223
            
      s.connect(absmod)

        Fiorella Quino
    
Multicast scripts...

              r193
            
      # 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

        Fiorella Quino
    
Prueba de repositorio...

              r231
            
        Fiorella Quino
    
sockets and restful...

              r223
            
              s.sendto(message,absmod)

        Fiorella Quino
    
Multicast scripts...

              r193
            
              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)

        Fiorella Quino
    
sockets and restful...

              r223
            
                  s.connect(absmod)

        Fiorella Quino
    
Multicast scripts...

              r193
            
              except:

                  print '\nProblem with creating socket repeater!!...\n'

                  s.close()

                  s = None

                  s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

        Fiorella Quino
    
sockets and restful...

              r223
            
                  s.connect(absmod)

        Fiorella Quino
    
Multicast scripts...

              r193
            
                  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

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages

Fiorella Quino Multicast scripts...	r193	"""
		This script should run in the absmodule.
		"""
		import socket
		import struct
		import sys

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

Fiorella Quino sockets and restful...	r223	absmod = ('10.10.20.53', 5500) #This IP should be modificated according to its absmodule
Fiorella Quino Multicast scripts...	r193	s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
Fiorella Quino sockets and restful...	r223	s.connect(absmod)
Fiorella Quino Multicast scripts...	r193
		# 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
Fiorella Quino Prueba de repositorio...	r231
Fiorella Quino sockets and restful...	r223	s.sendto(message,absmod)
Fiorella Quino Multicast scripts...	r193	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)
Fiorella Quino sockets and restful...	r223	s.connect(absmod)
Fiorella Quino Multicast scripts...	r193	except:
		print '\nProblem with creating socket repeater!!...\n'
		s.close()
		s = None
		s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
Fiorella Quino sockets and restful...	r223	s.connect(absmod)
Fiorella Quino Multicast scripts...	r193	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