Многопоточный чат на winsock

[btf]

Всем привет. Мне необходимо написать многопоточный чат. При написании, у меня возникла проблема. Я пишу по примеру из "Самоучитель игры на WinSock2". В книге приведен пример эхо-сервера, т.е. написать на его примере сервер для чата - не должно составить особой проблемы.
Сейчас я нахожусь на стадии написания сервера. Возникла проблема с многопоточностью. В книге все просто: клиент коннектится к серверу а далее вызывается функция CreateThread с одним из параметров SexToClient, где SexToClient - функция, обслуживающая клиента. Вот код данной функции:

DWORD WINAPI SexToClient(LPVOID client_socket)
{
SOCKET my_sock;
my_sock=((SOCKET *) client_socket)[0];
char buff[20*1024];
#define sHELLO "Hello, Sailor\r\n"
// отправляем клиенту приветствие
send(my_sock,sHELLO,sizeof(sHELLO),0);
// цикл эхо-сервера: прием строки от клиента и возвращение ее клиенту
while( (int bytes_recv=recv(my_sock,&buff[0],sizeof(buff),0)) &&
bytes_recv !=SOCKET_ERROR)
send(my_sock,&buff[0],bytes_recv,0);
// если мы здесь, то произошел выход из цикла по причине
// возращения функцией recv ошибки – соединение с клиентом разорвано
nclients; // уменьшаем счетчик активных клиентов
printf("disconnect\n"); PRINTNUSERS
// закрываем сокет
closesocket(my_sock);
return 0;
}

По этой функции у меня возникло несколько вопросов:
1) в строке "my_sock=((SOCKET *) client_socket)[0];" что значит [0]?
2) что значит DWORD WINAPI? Прошу не отправлять меня читать про WinApi. Я представляю что это такое, как и для чего используется. Просто прошу пояснить, что значат эти два слова перед описанием функции.
3) Ну и самый главный вопрос, который у меня возник. Как отправлять сообщение пользователя не ему самому, а всем пользователям сразу?
Я так понимаю, что надо как-то создать массив типа SOCKET, в котором будут хранится все сокеты, по которым подключены клиенты, и в цикле отправлять это сообщение всем, но как это сделать в потоке? Или может есть еще какие-нибудь варианты?

Подскажите, пожалуйста, ответы на эти вопросы.

[counter]

1) это массив элементов SOCKET (сишный синтаксис иногда пугает )
2) DWORD - возвращаемое значение функции
WINAPI = _stdcall - cоглашение вызова функций
http://ru.wikipedia.org/wiki/Соглаше...dcall.2Fwinapi
3) смотри 1)

[pproger]

2counter

это массив элементов SOCKET

был бы это массив, в SexToClient передавался бы его размер. а так человек просто разыменовал указатель по-индусски

SOCKET my_sock = *((SOCKET *) client_socket);

сишный синтаксис иногда пугает

дык не надо пугаться, надо его понять

[btf]

То есть, как я понял, я из этого потока могу получить доступ ко всем, подключенным к серверу, клиентам? И по сути, что бы отправить сообщение всем клиентам, достаточно использовать следующий код:

DWORD WINAPI SexToClient(LPVOID client_socket)
{
SOCKET my_sock;
my_sock=((SOCKET *) client_socket)[0];
char buff[20*1024];
#define sHELLO "Hello, Sailor\r\n"
// отправляем клиенту приветствие
send(my_sock,sHELLO,sizeof(sHELLO),0);
// цикл эхо-сервера: прием строки от клиента и возвращение ее клиенту
while( (int bytes_recv=recv(my_sock,&buff[0],sizeof(buff),0)) &&
bytes_recv !=SOCKET_ERROR)
for (int i=0; i<usersCount; i++) {
my_sock=((SOCKET*)client_socket)[i];
send(my_sock,&buff[0],bytes_recv,0);
}
// если мы здесь, то произошел выход из цикла по причине
// возращения функцией recv ошибки – соединение с клиентом разорвано
nclients; // уменьшаем счетчик активных клиентов
printf("disconnect\n"); PRINTNUSERS
// закрываем сокет
closesocket(my_sock);
return 0;
}

так?

По поводу пунктов 1 и 2 спасибо.

[veniside]

my_sock=((SOCKET*)client_socket)[i];

включив режим телепатии, можно сказать, что поток создаётся для одного сокета (клиента), так что [i], скорей-всего, не прокатит.

Если у вас клиентов мало (меньше 50), можно оставить код как есть, запускайте 50 потоков, только вместо эхо-цикла крутите пустой цикл, который будет ожидать данных для посылки клиенту (ну и принимать данные от клиента тоже полезно иногда).

Если клиентов много, система загнётся создавать на каждого юзвера отдельный поток. Надо думать, как одним потоком обрабатывать несколько клиентов.

И да, глобальный массив клиентов совсем не помешает, не забыть только обернуть его в критическую секцию, иначе в потоках будут чудеса происходить.

[Сыроежка]

Сообщение от pproger

2counter

был бы это массив, в SexToClient передавался бы его размер. а так человек просто разыменовал указатель по-индусски

SOCKET my_sock = *((SOCKET *) client_socket);

На самом деле это может быть и массивом, так как не обязательно передавать его размерность. Просто при передачи, так как это С код, массив преобразуется в указатель на его первый элемент. Автор кода может быть как раз и хотел этим показать, что это некий массив.

[pproger]

2Сыроежка

Просто при передачи, так как это С код, массив преобразуется в указатель на его первый элемент.

умоляю, освободи меня от своих нравоучений

На самом деле это может быть и массивом

от массива нет никакого толку, если не знаешь его размер

пс. на самом деле я не читал код дальше строки

my_sock=((SOCKET *) client_socket)[0];

сейчас вижу, что он обращается к этому указателю со смещением, отличным от нулевого. так или иначе, в таких случаях НУЖНО передавать размерность. сегодня ему хочется отправить сообщение всем клиентам, завтра - выборочным

[Пепел Феникса]

массив преобразуется в указатель на его первый элемент.

и давно сам массив преобразуется?

наверно уж имелось в виду что имя массива есть указатель на его первый элемент.

[btf]

veniside, для каждого подключившегося клиента создается отдельный поток. Максимально допустимое число клиентов меньше 50.
pproger, скорее всего

my_sock=((SOCKET *) client_socket)[0];

разывменование указателя. Только зачем тут используется индекс?

Только я все равно не понимаю, как реализовать передачу, полученной сервером, строки всем пользователям, а не только тому, от которого он получил.

Объясните пожалуйста.

P.S. если надо скинуть весь код - скажите, я скину.

[Сыроежка]

Сообщение от pproger

2Сыроежка

умоляю, освободи меня от своих нравоучений


от массива нет никакого толку, если не знаешь его размер

пс. на самом деле я не читал код дальше строки

my_sock=((SOCKET *) client_socket)[0];

сейчас вижу, что он обращается к этому указателю со смещением, отличным от нулевого. так или иначе, в таких случаях НУЖНО передавать размерность. сегодня ему хочется отправить сообщение всем клиентам, завтра - выборочным

Во-первых, информация о размере массива может содержаться в самом массиве. Во-вторых, может быть какая-нибудь глобальная переменная, содержащая размер массива. В-третьих, эттот масив может иметь фиксированную длину, которая объявлена где-нибудь в заголовочном файле как манифестная константа. Так что не надо тделать скоропалительных выводов!