https://opennet.me/openforum/vsluhforumID9/8433.html Hello, big bro..<br>Есть проблема..<br>Делаю сервер с 3 портами, работающими каждый независимо друг от друга...<br>Использую неблокируюшие сокеты + select. Возникает следующая проблема - после добавления слушающих сокетов в множество селект прекрасно разбирает входящие соединения и разруливает их, нок примеру если мне необходимо принимать данные от нескольких клиентов (одновременно), после вызова accept только первый клиент посылает данные (на примере эхо-сервера и телнета проверил), а остальные хоть и подключаются, но при вводе строк не получают ответа.. Как только первый клиент отрубается, начинают работать остальные... Как поправить, где пропустил чего?<br>--<br>функция принимает 3 порта, функция makeServerSocket принимает порт и возвращает дискриптор слушающего сокета (в ней выполняются последовательно socket, bind, listen).<br>В этой функции также включен nonblocking mode через fcntl.<br>Спс :)<br>P.S. всякие kqueue, epoll и пр. не предлагать плиз взамен этому. Ибо геморрно и разбираться надо :( fork тоже не катит, как https://opennet.me/openforum/vsluhforumID9/8433.html#11 Thu, 17 Sep 2009 09:51:26 GMT &gt;Выложи плиз :), интересно стало. <br><br>Держи, не жалко. Думаю, разберешься что куда...<br>Это не итоговая версия - здесь много сообщений для отслеживания ошибок..<br><br>int startServer(int emulator_port, int controller_port, int system_port) <br>{<br>int emu_sock=0, contr_sock=0, sys_sock=0;<br>int emu_fd, contr_fd, sys_fd;<br>int epfd=0;<br>struct sockaddr_in my_addr,emu_addr,contr_addr,sys_addr;<br>int res=0,res1=0,res2=0;<br>int i=0;<br>int new_fd,kdpfd,ret;<br>static struct epoll_event ev;<br>static struct epoll_event events[EPOLL_QUEUE_LEN]; /*When no size, error - Bad address*/<br>int len=sizeof(struct sockaddr_in);<br>int curfds,nfds;<br>int n;<br><br>if((emu_sock=makeServerSocket(emulator_port))==-1)<br>{<br>perror("error emulator listen");<br>return -1;<br>}<br>if((contr_sock=makeServerSocket(controller_port))==-1)<br>{<br>perror("error controller listen");<br>return -1;<br>}<br>if((sys_sock=makeServerSocket(system_port))==-1)<br>{<br>perror("error system listen");<br>return -1;<br>}<br>if((epfd=epoll_create(EPOLL_QUEUE_LEN))==-1) https://opennet.me/openforum/vsluhforumID9/8433.html#10 Thu, 17 Sep 2009 09:10:55 GMT &gt;Фуф, вроде справился, правда код вырос в 2 раза, но основную цель <br>&gt;выполняет - есть 3 открытых порта, к к-ым может прицепиться множество <br>&gt;народу на каждый, и будут они работать все вместе.. <br>&gt;И вообщем ушел я от селектов... <br>&gt;Сделал на epoll, вроде он побыстрее будет судя по диаграммкам С10К... <br>&gt;Кого заинтересует - могу выложить код, не жалко.. Сам долго гуглил на <br>&gt;более-менее нормальные примеры epoll. <br><br>Выложи плиз :), интересно стало.<br><br><br> https://opennet.me/openforum/vsluhforumID9/8433.html#9 Wed, 16 Sep 2009 16:46:00 GMT Фуф, вроде справился, правда код вырос в 2 раза, но основную цель выполняет - есть 3 открытых порта, к к-ым может прицепиться множество народу на каждый, и будут они работать все вместе..<br>И вообщем ушел я от селектов...<br>Сделал на epoll, вроде он побыстрее будет судя по диаграммкам С10К...<br>Кого заинтересует - могу выложить код, не жалко.. Сам долго гуглил на более-менее нормальные примеры epoll.<br> https://opennet.me/openforum/vsluhforumID9/8433.html#8 Wed, 16 Sep 2009 07:51:51 GMT &gt;Потоки нужны, ибо планируется обеспечить взаимодействие между клиентами на разных портах, через процессы это вроде тяжело реализовать... <br><br>Потоки нужны, если обработка тяжёлая и хочется заюзать несколько процов. Количество потоков определяется количеством процов. А клиентов всех засовывать в select (poll/epoll...) и обрабатывать асинхронно, это никак не помешает никаким взаимодействиям.<br> https://opennet.me/openforum/vsluhforumID9/8433.html#7 Wed, 16 Sep 2009 03:14:50 GMT &gt;&gt;[оверквотинг удален]<br>&gt;Потоки нужны, ибо планируется обеспечить взаимодействие между клиентами на разных портах,<br>&gt; через процессы это вроде тяжело реализовать... <br><br>Через процессы можно использовать IPC, но у меня опыта в IPC нету, поэтому тоже кажеться что сложно :-)<br><br>&gt;P.S. Может есть у кого примеры серверов с несколькими работающими портами и <br>&gt;вызовами типа select\poll\epoll...? <br><br>Примеров у меня нету, но могу посоветовать использовать какую-нибудь библиотеку, котороя умеет делать мультплексирование и прочие низкоуровневые штуки.<br>для C++ можно посмотреть ACE Framework (http://www.cs.wustl.edu/~schmidt/ACE.html) или POCO C++ (http://pocoproject.org/), обе библиотеки имеют примеры.<br>для C можно использовать glib (http://library.gnome.org/devel/glib/2.20/), я думаю что найдётся много OpenSource прокетов где можно посмотреть примеры использования glib, например pidgin использует glib<br><br><br><br><br> https://opennet.me/openforum/vsluhforumID9/8433.html#6 Wed, 16 Sep 2009 02:44:59 GMT &gt;[оверквотинг удален]<br>&gt;&gt;отдельный поток и там уже вызывать функцию accept(), правильно я понимаю? <br>&gt;<br>&gt;Это один из вариантов. Есть как минимум ещё два стандартных пути: <br>&gt;<br>&gt; - вместо потоков для обработки данных каждого соединения использовать дочерние <br>&gt;процессы <br>&gt;<br>&gt; - использовать более совершенные по сравнению с select() механизмы (ну <br>&gt;хотя бы вызов poll()) и обеспечить переключение контекста в одном-единственном потоке, <br>&gt;с ожиданием активности клиентов и их готовности к приёму данных <br><br>Потоки нужны, ибо планируется обеспечить взаимодействие между клиентами на разных портах, через процессы это вроде тяжело реализовать...<br><br>P.S. Может есть у кого примеры серверов с несколькими работающими портами и вызовами типа select\poll\epoll...?<br> https://opennet.me/openforum/vsluhforumID9/8433.html#5 Tue, 15 Sep 2009 21:01:14 GMT Прочитал сам свое сообщение, по-моему вышло не совсем понятно. Короче, цикл должен быть один, вокруг select(), и без вложеных циклов. Когда select() сработает, нужно проверять готовность всех сокетов на чтение/запись/ошибку (из FD_SET'ов которые были поданы как 2-й, 3-й и 4-и параметер select()'у. Для каждого активного сокета, должен быть свой, отдельный, буффер с данными, и запомнена текущая позиция в каждом буфере, которая нужна чтобы точно знать сколько мы уже прочитали из сокета (если мы сейчас читаем из этого сокета) или записали (если мы сейчас пишем в этот сокет). Нужен также некий протокол который определяет когда все ожидаемые данные прочитаны из конкретного сокета (напр. NewLine или фиксированная длинна, или, как в HTTP, длинна данных передается в начале самих данных). Сразу после accept(), сокет находится в режиме чтения, когда (по протоколу) все данные прочитаны, сокет переводится в режим записи. Вот, такое вот дополнение к моему сообщению, может, так яснее.<br><br>А так как реализовано автором, несмо https://opennet.me/openforum/vsluhforumID9/8433.html#4 Tue, 15 Sep 2009 20:24:29 GMT &gt;[оверквотинг удален]<br>&gt;&gt;отдельный поток и там уже вызывать функцию accept(), правильно я понимаю? <br>&gt;<br>&gt;Это один из вариантов. Есть как минимум ещё два стандартных пути: <br>&gt;<br>&gt; - вместо потоков для обработки данных каждого соединения использовать дочерние <br>&gt;процессы <br>&gt;<br>&gt; - использовать более совершенные по сравнению с select() механизмы (ну <br>&gt;хотя бы вызов poll()) и обеспечить переключение контекста в одном-единственном потоке, <br>&gt;с ожиданием активности клиентов и их готовности к приёму данных <br><br>И есть "самый" стандартный вариант :), который, очевидно и был нужен автору: не нужно цикла do-while вокруг recv()+send(), а вместо этого, нужно:<br><br>а) создавать для каждого сокета свой буффер и запоминать сколько уже данных записано в каждый буффер (текущая позиция в буфере, начальное значение 0), <br>б) для каждого сокета готового к чтению, прочитать (recv()) (без цикла - один раз!) столько, сколько сокет отдаст, в буффер этого сокета начиная с текущей позиции, и потом увеличить текущую позицию на количество https://opennet.me/openforum/vsluhforumID9/8433.html#3 Tue, 15 Sep 2009 17:12:50 GMT &gt; Значит после того, как FD_ISSET просигналил о появлении соединения, нужно создавать <br>&gt;отдельный поток и там уже вызывать функцию accept(), правильно я понимаю? <br><br>Это один из вариантов. Есть как минимум ещё два стандартных пути:<br><br> - вместо потоков для обработки данных каждого соединения использовать дочерние процессы<br><br> - использовать более совершенные по сравнению с select() механизмы (ну хотя бы вызов poll()) и обеспечить переключение контекста в одном-единственном потоке, с ожиданием активности клиентов и их готовности к приёму данных<br>