Tcp server реализация

                   
     byte buffer = new byte[50000]; 
     while (ns.DataAvailable == true)
     {
          int available_bytes = clients[(int)num].Available;
          ns.Read(buffer, offset, available_bytes);
          offset += available_bytes;
      }

     
  while (ns.DataAvailable == true && буфер_принят полностью)
     {
          ...
      }

             ... прием коннекта
                    this.clients[_countClient] = _server.AcceptTcpClient();
                    Thread readThread = new Thread(ReceiveRun);
                    readThread.Start(_countClient);
 
 
 
           // Вход после приема коннекта
 
        void ReceiveRun(object num) // бесконечный цикл приема пакетов
        {
 
            ns = clients[(int)num].GetStream();
 
            while (true)        // цикл приема пакетов в данном соединении (до ошибки или другой причины)
            {
                pkt_len = 0;  // Длина пакета. Ее можно определить после того как будет принято не менее 7 байт
                offset = 0;    // указатель куда принимать очередную порцию данных с начала буфера
                try
                {
                    while (true)
                    {
                        if ((pkt_len != 0) && (offset >= pkt_len))  // выходим , если принят весь пакет
                            break;
                        if (!ns.DataAvailable)                      // ждем
                            continue;
 
                        int available_bytes = clients[(int)num].Available; // есть очередная порция данных - принимаем
                        ns.Read(buffer, offset, available_bytes); 
                        offset += available_bytes;                          //сдвигаемся в буфере на длину принятой порции
                        if ((offset >= 7) && (pkt_len==0)){            //если уже принято 7 байтов - читаем общую длину пакета
                            pkt_len = get_fullpktlen(buffer); 
                        }
                    }
                    ... ОБРАБОТКА ПАКЕТА И НА ОЖИДАНИЕ СЛЕДУЮЩЕГО
                catch
                {
                    continue;// не знаю надо ли что-нибудь здесь делать, кроме как в лог записать параметры сбоя
                }
         }

        void ReceiveRun(object num) // бесконечный цикл приема пакетов
        {
            var ns = clients[(int)num].GetStream();
 
            using (var br = new BinaryReader(ns))
            while (true)
            {
                var packetSize = br.ReadInt32();//read 4 bytes of packet size
                var packet = br.ReadBytes(packetSize);//read packet
                //обработка пакета ...
            }
        }

        const int MAXNUMCLIENTS = 20;                           // Количество принимаемых подключений к серверу    
        TcpClient[] clients = new TcpClient[MAXNUMCLIENTS];   
 
        void AcceptClients()
        {
 
            while (true)
            {
                try
                {
                    this.clients[_countClient] = _server.AcceptTcpClient();
                    Thread readThread = new Thread(ReceiveRun);
                    readThread.Start(_countClient);
                    _countClient++;
                    Invoke(new UpdateClientsDisplayDelegate(UpdateClientsDisplay));  // обновим в осн потоке гл формы
                }
                catch
                {
                    ErrorSound(); // Перехватим возможные исключения
                }
                if (_countClient == MAXNUMCLIENTS || _stopNetwork == true) 
                {
                    break;
                }
 
            }
        }

        void ReceiveRun(object num) // бесконечный цикл приема пакетов
        {
            var ns = clients[(int)num].GetStream();
 
            using (var br = new BinaryReader(ns))
            while (true)
            {
                byte[] header= (byte[])br.ReadBytes(7);//read 7 bytes to get  packet size
                packetSize = BitConverter.ToInt32(header, 6);
                var packet = br.ReadBytes(packetSize);//read packet
                //обработка пакета ...
            }
        }