# -*- coding: utf-8 -*-

 import socket, threading

 con = threading.Condition()

 HOST = raw_input("input the server's ip adrress: ") # Symbolic name meaning all available interfaces

 PORT = 8888 # Arbitrary non-privileged port

 data = ''

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

 print 'Socket created'

 s.bind((HOST, PORT))

 s.listen(10)

 print 'Socket now listening'

 #Function for handling connections. This will be used to create threads

 def clientThreadIn(conn, nick):

     global data

 #infinite loop so that function do not terminate and thread do not end.

     while True:

     #Receiving from client

         try:

             temp = conn.recv(1024)

             if not temp:

                 conn.close()

                 return

             NotifyAll(temp)

             print data

         except:

             NotifyAll(nick + " leaves the room!")

             print data

             return

     #came out of loop

 def NotifyAll(sss):

     global data

     if con.acquire():

         data = sss

         con.notifyAll()

         con.release()

 def ClientThreadOut(conn, nick):

     global data

     while True:

         if con.acquire():

             con.wait()          #notifyAll effect there

             if data:

                 try:

                     conn.send(data)

                     con.release()

                 except:

                     con.release()

                     return

 while 1:

     #wait to accept a connection - blocking call

     conn, addr = s.accept()

     print 'Connected with ' + addr[0] + ':' + str(addr[1])

     nick = conn.recv(1024)

     #send only takes string

     #start new thread takes 1st argument as a function name to be run, second is the tuple of arguments to the function.

     NotifyAll('Welcome ' + nick + ' to the room!')

     print data

     print str((threading.activeCount() + 1) / 2) + ' person(s)!'

     conn.send(data)

     threading.Thread(target = clientThreadIn , args = (conn, nick)).start()

     threading.Thread(target = ClientThreadOut , args = (conn, nick)).start()

 s.close()

 # -*- coding: utf-8 -*-

 import socket, threading

 inString = ''

 outString = ''

 nick = ''

 def DealOut(s):

     global nick, outString

     while True:

         outString = raw_input()

         outString = nick + ': ' + outString

         s.send(outString)

 def DealIn(s):

     global inString

     while True:

         try:

             inString = s.recv(1024)

             if not inString:

                 break

             if outString != inString:

                 print inString

         except:

             break

 nick = raw_input("input your nickname: ")

 ip = raw_input("input the server's ip adrress: ")

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

 sock.connect((ip, 8888))

 sock.send(nick)

 thin = threading.Thread(target = DealIn, args = (sock,))

 thin.start()

 thout = threading.Thread(target = DealOut, args = (sock,))

 thout.start()