Читаем О чём не пишут в книгах по Delphi полностью

 // зафиксировано подключение клиента, и функция accept не приведет

 // к блокированию нити.

 if FD_ISSET(MainSocket, SockSet) then

 begin

  ClientSockAddrLen := SizeOf(ClientSockAddr);

  // Принимаем подключившегося клиента. Для общения с ним создается

  // новый сокет, дескриптор которого помещается в ClientSocket.

  ClientSocket :=

   accept(MainSocket, @ClientSockAddr, @ClientSockAddrLen);

  if ClientSocket = INVALID_SOCKET then raise

   ESocketException.Create(

    'Ошибка при ожидании подключения клиента: ' + GetErrorString);

  // Создаем в динамической памяти новый экземпляр TConnection

  // и заполняем его данными, соответствующими подключившемуся клиенту

  New(NewConnection);

  NewConnection.ClientSocket := ClientSocket;

  NewConnection.ClientAddr :=

   Format('%u.%u.%u.%u:%u',

    Ord(ClientSockAddr.sin_addr.S_un_b.s_bl),

    Ord(ClientSockAddr.sin_addr.S_un_b.s_b2),

    Ord(ClientSockAddr.sin_addr.S_un_b.s_b3),

    Ord(ClientSockAddr.sin_addr.S_un_b.s_b4),

    ntohs(ClientSockAddr.sin_port));

  NewConnection.Deleted := False;

  // Добавляем соединение в список

  Connections.Add(NewConnection);

  WriteLn(OemString('Зафиксировано подключение с адреса ' +

   NewConnection.ClientAddr));

 end;

 // Теперь проверяем готовность всех сокетов подключившихся клиентов.

 // Так как множество SockSet не может содержать более чем FT_SETSIZE

 // элементов, а размер списка Connections мы нигде не ограничиваем,

 // приходится разбивать Connections на "куски" размером не более

 // FD_SETSIZE и обрабатывать этот список по частям.

 // Поэтому у нас появляется два цикла - внешний, который повторяется

 // столько раз, сколько у нас будет кусков, и внутренний, который

 // повторяется столько раз, сколько элементов в одном куске.

 for J := 0 to Ceil(Connections.Count, FD_SETSIZE) - 1 do

 begin

  FD_ZERO(SockSet);

  for I := FD_SETSIZE * J to Min(FD_SETSIZE * (J + 1) - 1, Connections.Count - 1) do

   FD_SET(PConnection(Connections[I])^.ClientSocket, SockSet);

  if select(0, @SockSet, nil, nil, @Timeout) = SOCKET_ERROR then

   raise ESocketException.Create(

    'Ошибка при проверке готовности сокетов: ' + GetErrorString);

  // Проверяем, какие сокеты функция select оставила в множестве,

  // и вызываем для них ProcessSocketMessage. В этом есть некоторый

  // риск, т.к. для того, чтобы select оставила сокет в множестве,

  // достаточно, чтобы он получил хотя бы один байт от клиента,

  // а не все сообщение. Поэтому может возникнуть такая ситуация,

  // когда сервер получил только часть сообщения, но уже пытается

  // прочитать сообщение целиком. Это приведет к блокированию нити,

Перейти на страницу:
Нет соединения с сервером, попробуйте зайти чуть позже