URL: https://www.opennet.me/cgi-bin/openforum/vsluhboard.cgi
Форум: vsluhforumID9
Нить номер: 551
[ Назад ]

Исходное сообщение
"Как работает функция listen(int sock,int backlog) для socket-сервера?"

Отправлено TopTiT , 04-Мрт-02 03:32 
В общем я пытался в серверной программе ставить
....
listen(s,QUEUE_LEN)
while(1)
{
  new=accept(s,...)
   if (fork()==0)
    {
      //обработка запроса
    }
}

Этот код должен порождать отдельный процесс для обработки каждого нового сокета

И количество таких ПРОЦЕССОВ не должно быть больше чем QUEUE_LEN

.....не тут то было......

Мой сервак порождает отдельный процесс для любого количества запросов


ВОПРОС
  Я что потерялся?
    или этот параметр не то значит?
  Я подозреваю что это просто количество незавершенных запросов в очереди к серверу


Тогда решение должно быть таким
....
listen(s,QUEUE_LEN)
int ACCEPTED=0;
while(1)
{
  new=accept(s,...)
  ACCEPTED++;
  if (ACCEPTED > QUEUE_LEN)
   {
     //послать это клиента на #$%
      close(new)
   } else
   if (fork()==0)
    {
      //обработка запроса
    }
}


Оставьте свои КОММЕНТАРИИ....


Содержание

Сообщения в этом обсуждении
"RE: Как работает функция listen(int sock,int backlog) для socket-сервера?"
Отправлено romanSA , 04-Мрт-02 12:17 
Никакого влияния на число процессов в этом примере listen () не имеет.
listen (_nSocket_, _backlog_) просто резервирует буфер для клиентских соединений длиной _backlog_.
Когда клиентская программа пытается соединиться с сервером, то после "рукопожатия", соединение помещается в этот буфер.
Вызов accept () на самом деле извлекает соединение из буфера.
Если буфер переполняется, то клиенту идёт сообщение Connection refused.

Насчёт второго примера: а где ACCEPTED-- ?

И ещё, если тебе нужно, чтобы число обработчиков не превышало заданное, есть простой вариант:

listen(s,QUEUE_LEN);
int ACCEPTED=0;
while (1)
{
  if (ACCEPTED < QUEUE_LEN)
  {
    ACCEPTED++;
    if (fork()==0)
    {
      // бесконечный цикл обработки запросов в
      // дочернем процессе
      while (1)
      {
        // блокируем к.либо ресурс, например:
        flock (...);
    
        new=accept(s,...);
      
        // разблокируем ресурс:
        flock (...);

        //обработка запроса
        ...
        close (new);
      }
    }
  }

  pause ();

  if (/* дочерний процесс умер */)
  {
    ACCEPTED--;
  }
}

Как отслеживать смерть дочерних процессов?
man 2 signal
man 7 signal