При завершении потока кидает ошибку?

Question

[Sazoks]

Есть у меня клиент-серверная апликуха. Клиент набирает какие-то команды, они отправляются на сервер и далее обрабатываются этой функцией:

void Server::ClientThread(SOCKET ClientConn)
{
	int ID = -1, r;	
	char Func[32];
        std::map<std::string, void(Server::*)(SOCKET, int)>::iterator It;
	while ((r = recv(ClientConn, Func, sizeof(Func) - 1, NULL)) != -1 && r != 0)
              if ((It = Functions.find(Func)) != Functions.end())
                    (this->*It->second)(ClientConn, ID);
	std::cout << "Client disconnected\n";
	if (ID != -1) DeleteUser(ID);
}

Функция выше запускается в новом потоке при каждом новом подключении.
Недавно я обнаружил, что поток завершается с ошибкой! Из-за этого программа иногда ведет себя странно..
При выходе из этой функции, а значит, и при завершении потока, выскакивает ошибка "символы не загружены _здесь название файла_". Ну первое, что я сделал, загрузил символы (вроде логично), но теперь вместо этого выдает "Исходный код не доступен" и предлагает посмотреть дизассемблированный код. Ах да, вот эта функция выше, она НЕ статическая. В поток я передаю ее по указателю на метод вместе с this.
И еще, при выходе из потока в отладчике я попал в файл xthread.
Там есть следующая ф-ия:

static unsigned int __stdcall _Call_func(void *_Data)
		{	// entry point for new thread
		static_cast<_Pad *>(_Data)->_Go();
		return (0);
		}

Вот именно в строчке return (0) мне и выдает ошибку..
В общем-то и все.
Буду благодарен за любую помощь!

Comments

[Sazoks]

Dmitry, ну таким образом я вызываю методы из map
В map у меня идет пара строка : указатель на функцию. По введенному юзером слову в map ищется нужная ф-ия и вызывается

[Sazoks]

Dmitry, чивоо? Вы о чем?..
У меня в классе есть map, в этом методе я принимаю сообщение от клиента в буфер, так же в этом методе у меня есть итератор, в который я записываю адрес функции, которую ищу по ключу std::string!!!
Вы вообще читали вопрос? С этим все в порядке!
У меня поток с ошибкой непонятной (для меня) завершается....

[Евгений Шатунов]

Sazoks, покажи код создания твоего потока.

[Sazoks]

Евгений Шатунов,

void Server::Start()
{
	while (true)
	{
		if ((NewConn = accept(ServerSocket, reinterpret_cast<SOCKADDR*>(&ServerAddr), &SizeOfAddr)) == -1)
		{
			std::cout << "New connection: FAIL\n";
			continue;
		}
		std::cout << "Client connected\n";
		std::thread NewThread(&Server::ClientThread, this, NewConn);
		NewThread.detach();
	}
}

[Евгений Шатунов]

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

Иное дело, если бы у тебя был такой код:

std::thread NewThread{ [this]( SOCKET s ) { ClientThread( s ); }, NewConn };

то претензий к нему не было бы.

NewThread.detach();
Не надо так делать. Этот вопрос ты должен решить абсолютно иным способом. Это тоже возможная причина выкрутасов твоего кода.

[Sazoks]

Евгений Шатунов, спасибо, буду копать!
Про поток.. Это собирает потому, что ClientThread - это метод класса. А в любом методе класса по дефолту есть this в параметрах. Здесь я просто явно передал this и следом уже как положено обычный параметр.
А про .detach() не совсем понял( Что не так?

[Евгений Шатунов]

Sazoks, семантика thiscall-функций не оговорена стандартом. В общем случае ни кто не знает, как именно компилятор передает this в тело функции. Все усугубляется тем, что этот механизм сильно связан с аппаратными возможностями и ограничениями оборудования. Это может быть регистр eax, ecx, или стек. В первом случае, по счастливому совпадению, у тебя что-то получается и как-то работает. Но это не продлится долго, лишь до следующих компилятора или оси, где соглашение о вызовах может оказаться иным. Советую все таки сделать передачу управления через лямбду.

С detach все просто. Ты выкинул поток на мороз. Ты за ним приглядывать должен, должен грамотно потушить его при необходимости. Когда ты сделал detach, твой код расщепился на ветви исполнения, но управлять ими ты уже не волен. Это прямой путь к ошибкам. Сам же detach нужен для того, чтобы вывести низкоуровневый системный поток из под владения высокоуровневого объекта. Это часто нужно для передачи потока в какие-либо посреднические библиотеки, где далее будет обеспечен правильный контроль потока.

[Sazoks]

Евгений Шатунов, Про this понял, спасибо!
Но про detach.. Я думал об этом.. Мне по логике программы и не нужно следить за потоками. Все, что нужно, это создать его. Дальше юзер сам все решает. Этот поток заканчивается, когда юзер отключается. Т.е. при его отключение завершается метод ClientThread, запущенный в потоке, а значит и сам поток.
Возможно и правда ошибка в this, буду делать через лямбду.

[Sazoks]

Евгений Шатунов,
Сделал как вы и сказали, через лямбду...
Но результат тот же :(

Answer 1

[maaGames]

_Data == nullptr, поэтому падает
Отладчик показывает СЛЕДУЮЩУЮ строчку, после которой произошла ошибка. Т.е. ошибка перед return. А там варианта всего два, либо _Data== nullptr, либо в фукнции _Go() что-то пошло не так и это дальше ковыряйся в отладчике :)

Answer 2

[Армянское Радио]

Программа просто написана неверно. recv может вернуть любое количество байт, от 0 до 31. Массив у вас при этом не инициализирован, и будет ли в нем 0 - не ясно.

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

Более того, прочитав только кусок данных, recv при следующем чтении прочтет продолжение этих данных, то есть, вместо начала следующей команды вы получите середину предыдущей, и как итог - полную фигню.

Вам нужно переписать чтение команд и переделать протокол так, чтобы длина очередной команды передавалась в начале этой самой команды.

Comments

[Sazoks]

Да обработка-то нормально отрабатывает.
У меня ошибка вылетает, когда заканчивается цикл while и поток завершается.
Выхода из функции ClientThread я попадаю в файл xthread в функцию _Call_func, и вот уже здесь вылетает ошибка.
А если recv возвращает 0, значит соединение закрылось.

[Армянское Радио]

Sazoks, у вас программа читает неинициализированную память и творит UB, перепишите работу с recv как положено