old_contents: import select
  import socket
  import sys
  import Queue
  
  # Create a TCP/IP socket
  server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  server.setblocking(0)
  
  # Bind the socket to the port
  server_address = ('localhost', 10000)
  print >>sys.stderr, 'starting up on %s port %s' % server_address
  server.bind(server_address)
  
  # Listen for incoming connections
  server.listen(5)
  
  # Keep up with the queues of outgoing messages
  message_queues = {}
  
  # Do not block forever (milliseconds)
  TIMEOUT = 1000
  
  # Commonly used flag setes
  READ_ONLY = select.POLLIN | select.POLLPRI | select.POLLHUP | select.POLLERR
  READ_WRITE = READ_ONLY | select.POLLOUT
  
new_contents: import select
  import socket
  import sys
  import Queue
  
  # Create a TCP/IP socket
  server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  server.setblocking(0)
  
  # Bind the socket to the port
  server_address = ('localhost', 10000)
  print >>sys.stderr, 'starting up on %s port %s' % server_address
  server.bind(server_address)
  
  # Listen for incoming connections
  server.listen(5)
  
  # Keep up with the queues of outgoing messages
  message_queues = {}
  
  # Do not block forever (milliseconds)
  TIMEOUT = 1000
  
  # Commonly used flag setes
  READ_ONLY = select.POLLIN | select.POLLPRI | select.POLLHUP | select.POLLERR
  READ_WRITE = READ_ONLY | select.POLLOUT
  
  # Set up the poller
  poller = select.poll()
  poller.register(server, READ_ONLY)
  
  # Map file descriptors to socket objects
  fd_to_socket = { server.fileno(): server,
                 }
  
  
    # Handle inputs
          if flag & (select.POLLIN | select.POLLPRI):
  
              if s is server:
                  # A "readable" server socket is ready to accept a connection
                  connection, client_address = s.accept()
                  print >>sys.stderr, 'new connection from', client_address
                  connection.setblocking(0)
                  fd_to_socket[ connection.fileno() ] = connection
                  poller.register(connection, READ_ONLY)
  
                  # Give the connection a queue for data we want to send
                  message_queues[connection] = Queue.Queue()
  
subject: Update sourcepolls.py