# Server code ------------------------------
from multiprocessing.connection import Listener
import time

address = ''
port = 6000
authkey = 'test'

keep_running = True
while keep_running:
  print 'Waiting for client'
  listener = Listener((address, port), authkey=authkey) 
  remote_conn = listener.accept()
  print 'Got client ' + listener.last_accepted[0] + ':%d' %(listener.last_accepted[1])

  try:
    while True:
      if remote_conn.poll():
        msg = remote_conn.recv()
        print 'msg: ' + msg
        if msg=='quit':
          keep_running = False
          break
      else:
        time.sleep(0.01)
  except EOFError:
    print 'Lost connection to client'
    listener.close()

## Client code ----------------------------------
from multiprocessing.connection import Client

address = ('', 6000)
conn = Client(address, authkey='test')
    
keep_running = True
while keep_running:
  msg=raw_input('Enter string ')
  conn.send(msg)
  if msg=='quit':
    keep_running = False