P2P Transfer class TCPListener and the TCPClient classes

P2P Transfer class TCPListener and the TCPClient classes P2PTransferclassTCPListenerandtheTCPClientclasses P2P Transfer class TCPListener and the TCPClient classes [C#] Robert Wagner /PreviewSnippet.aspx?SnippetID=6515de74-dc7c-4a00-985b-a92162e7c2cc SurroundsWith

 0)
   {
    port = ol.Port;
   }
   else
   {
    // The default in case nothing else is set
    port = 8081;
   } 
   this.tcpl = new MyTcpListener(port);   
  }
 
  public void TransferShutdown()
  {
   tcpl.StopMe();
  }
  public void ListenForPeers() 
  {           
   try
   {  
    
    Encoding ASCII = Encoding.ASCII;     
        
tcpl.Start(); 

    while (true)
    {  
     // Accept will block until someone connects     
     Socket s = tcpl.AcceptSocket();      
     NetworkStream DataStream = new NetworkStream(s);
     String filename;
     Byte[] Buffer = new Byte[256];
     DataStream.Read(Buffer, 0, 256);
     filename = Encoding.ASCII.GetString(Buffer);
     StringBuilder sbFileName = new StringBuilder(filename);
     StringBuilder sbFileName2 = sbFileName.Replace("\", "\\");
     FileStream fs = new FileStream(sbFileName2.ToString(), FileMode.Open, FileAccess.Read);     
     BinaryReader reader = new BinaryReader(fs);
     byte[] bytes = new byte[1024];
     int read;
     while((read = reader.Read(bytes, 0, bytes.Length)) != 0) 
     {
      DataStream.Write(bytes, 0, read);
     }
     reader.Close(); 
     DataStream.Flush();
     DataStream.Close();
    }
   }
   catch(SocketException ex)
   {    
    MessageBox.Show(ex.ToString());
   }
  }
  public void DownloadToClient(String server, string remotefilename, string localfilename) 
  {
   try
   {
    TcpClient tcpc = new TcpClient();                
    Byte[] read = new Byte[1024];                    
    OptionsLoader ol = new OptionsLoader(); 
    int port = 0;
    if (ol.Port > 0)
    {
     port = ol.Port;
    }
    else
    {
     // The default in case nothing else is set
     port = 8081;
    } 

    // Try to connect to the server 
    IPHostEntry IPHost = Dns.Resolve(server); 
    string []aliases = IPHost.Aliases; 
    IPAddress[] addr = IPHost.AddressList; 
    IPEndPoint ep = new IPEndPoint(addr[0], port);
    tcpc.Connect(ep);
    
    // Get the stream
    Stream s = tcpc.GetStream();    
    Byte[] b = Encoding.ASCII.GetBytes(remotefilename.ToCharArray());
    s.Write( b, 0,  b.Length );
    int bytes;
    FileStream fs = new FileStream(localfilename, FileMode.OpenOrCreate);
    BinaryWriter w = new BinaryWriter(fs);
    // Read the stream and convert it to ASII   
    while( (bytes = s.Read(read, 0, read.Length)) != 0) 
    {    
     w.Write(read, 0, bytes);
     read = new Byte[1024];    
    }               
    tcpc.Close();
    w.Close();
    fs.Close();
   }
   catch(Exception ex)
   {
    throw new Exception(ex.ToString());     
   }
  } 
 }
}]]>