Receiving data correctly
This commit is contained in:
		
							parent
							
								
									9a02c05f84
								
							
						
					
					
						commit
						1ca571002e
					
				
					 1 changed files with 9 additions and 15 deletions
				
			
		| 
						 | 
					@ -91,28 +91,22 @@ namespace CLRScript
 | 
				
			||||||
        {
 | 
					        {
 | 
				
			||||||
            while(true){
 | 
					            while(true){
 | 
				
			||||||
                Debug("Accepting");
 | 
					                Debug("Accepting");
 | 
				
			||||||
                //Socket sockClient = sockServer.Accept();
 | 
					                sockServer.BeginAccept(new AsyncCallback(RequestHandler), null);
 | 
				
			||||||
                sockServer.BeginAccept(new AsyncCallback(RequestHandler), sockServer);
 | 
					                //Wait for EndAccept?
 | 
				
			||||||
 | 
					                Thread.Sleep(1000);
 | 
				
			||||||
            }
 | 
					            }
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        void RequestHandler(IAsyncResult state)
 | 
					        void RequestHandler(IAsyncResult state)
 | 
				
			||||||
        {
 | 
					        {
 | 
				
			||||||
            Debug("Connection received");
 | 
					            Socket sockClient = sockServer.EndAccept(state);
 | 
				
			||||||
            //Socket listener = (Socket)state.AsyncState;
 | 
					 | 
				
			||||||
            //Socket handler = listener.EndAccept(state);
 | 
					 | 
				
			||||||
            //Socket sockClient = sockServer.EndAccept(state);
 | 
					 | 
				
			||||||
            //Debug("Connection Accepted");
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
            //byte[] rawLength = new byte[4];
 | 
					            byte[] rawData = new byte[1024];
 | 
				
			||||||
            //sockClient.Receive(rawLength);
 | 
					            sockClient.Receive(rawData, rawData.Length, 0);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
            //int length = rawLength[0]<<8 + rawLength[1];
 | 
					            string data = Encoding.UTF8.GetString(rawData);
 | 
				
			||||||
            //byte[] rawData = new byte[length];
 | 
					            Debug("Queued "+data);
 | 
				
			||||||
            //sockClient.Receive(rawData);
 | 
					            sockBufferIn.Enqueue(data);
 | 
				
			||||||
            //string data = Encoding.UTF8.GetString(rawData);
 | 
					 | 
				
			||||||
            //Debug("got data: "+data);
 | 
					 | 
				
			||||||
            //sockBufferIn.Enqueue(data);
 | 
					 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        Socket sockServer;
 | 
					        Socket sockServer;
 | 
				
			||||||
| 
						 | 
					
 | 
				
			||||||
		Loading…
	
	Add table
		
		Reference in a new issue