multiple client chat

parita pooj · parita pooj · commit f15ffb6738d7 · 2011-09-10T20:20:13.000+05:30
diff --git a/socket-programming/echo-client.py b/socket-programming/echo-client.py
@@ -6,20 +6,21 @@
 size = 1024 
 client= socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
 client.connect((host,port))
- 	
+print client.getsockname()	
 print '%'
-
+data=''
 while 1:
-	print client.getsockname()
-    	# read from keyboard
-    	data = raw_input("Data:")
-	print 'Sent:',data,'%'
-	data = client.recv(size)
+	# read from keyboard
+    	if data:
+                print 'Received:',data.'%'   
+        else:
+                data = raw_input("Data:")
+                if data:
+                        client.send(data)
+                        print 'Sent:',data,'%'
+                        data=''
+                else:
+                        data=client.recv(size)
+                 
     	
-	if data == '': 
-        	break 
-    	client.send(data) 
-    	data = client.recv(size)
-    	print 'Received:',data
-    	print '%' 
 client.close()
diff --git a/socket-programming/echo-server.py b/socket-programming/echo-server.py
@@ -8,27 +8,45 @@
 
 print "TCPServer Waiting for client on port 5000"
 
-data =''
+
+data ='initialised...'
 input_ = [server_socket]
 output = [server_socket]
 inputready,outputready,exceptready = select.select(input_,output,[])
+print len(inputready) , len(input_), len(outputready), len(output)
 while 1: 
-
-	print len(inputready) , len(input_), len(outputready), len(output)
-    	for s in inputready:
-
-		print s.getsockname()
-        	if s==server_socket:
-            		client, address = server_socket.accept()
-            		print "I got a connection from ", address
-            		input_.append(client)
-        	else:
-			data = s.recv(1024) 
-            		if data:
-                		s.send(data)
-                		print 'received:',data
-            		else:
-                		s.close() 
-                		input_.remove(s)
-				print "Mistake idhar hai kya ?"
-    	inputready,outputready,exceptready = select.select(input_,output,[])
+        for s in inputready:
+                if s==server_socket:
+                        client, address = server_socket.accept()
+                        print "I got a connection from ", address
+                        input_.append(client)
+            
+                else:
+                        if data:
+                                s.send(data)
+                        data=s.recv(1024)
+                        print "received:",data
+                        if data:
+                                print "out of inputready"
+                                break;
+                        else:
+                                input_.remove(s)
+                inputready,outputready,exceptready = select.select(input_,output,[])
+                print len(inputready) , len(input_), len(outputready), len(output)
+        inputready,outputready,exceptready = select.select(input_,output,[])
+        print len(inputready) , len(input_), len(outputready), len(output)
+        for s in outputready:
+                if s==server_socket:
+                        client, address = server_socket.accept()
+                        print "I got a connection from ", address
+                        output.append()
+                else:
+                        if data:
+                                s.send(data)
+                                output.remove(s)
+                        else:
+                                s.close()
+                inputready,outputready,exceptready = select.select(input_,output,[])
+                print len(inputready) , len(input_), len(outputready), len(output)
+   
+    
