Я создал TCP сокет соединение между клиентом и сервером.
Мне необходимо использовать потоки, потому что я получаю координаты x и y из другого процесса и рисую эти значения с помощью OpenGL.
Единственным способом, который я имел в виду, было создание потока для рисования OpenGL и использование основного потока для получения координат по сокету.
Моя серверная часть работала отлично перед добавлением #include <thread>
, поэтому я понятия не имею, в чем может быть проблема и почему я не могу использовать потоки при использовании сокетов.
После включения темы, после вызова recv()
Я получаю ошибку:
WSAENOTSOCK 10038
используя WSAGetLastError();
Я думаю, что этот код слишком длинный, чтобы я мог его опубликовать, поэтому я могу скопировать некоторые его части, которые необходимы.
РЕДАКТИРОВАТЬ: код создания сокета и ожидания соединения.
// Inicijaliziraj winsock
WSADATA wsData;
WORD ver = MAKEWORD(2, 2);
int wSocket = WSAStartup(ver, &wsData);
if (wSocket != 0) {
cerr << "Problem with initialization of Winsock, exiting!" << endl;
return;
}
// Create a socket
SOCKET listening = socket(AF_INET, SOCK_STREAM, 0);
if (listening == INVALID_SOCKET) {
cerr << "Unable to create a socket! Quitting" << endl;
return;
}
// Bind the ip address and port to a socket
sockaddr_in hint;
hint.sin_family = AF_INET;
hint.sin_port = htons(54000);
hint.sin_addr.S_un.S_addr = INADDR_ANY; // Could also use inet_pton
bind(listening, (sockaddr*)&hint, sizeof(hint));
// Tell winsock socket is for listening
listen(listening, SOMAXCONN);
// Wait for a connection
sockaddr_in client;
int clientSize = sizeof(client);
SOCKET clientSocket = accept(listening, (sockaddr*)&client, &clientSize);
/*
if (clientSocket == INVALID_SOCKET) {
cerr << "Unable to connect to client socket, Quitting!" << endl;
return;
}*/
char host[NI_MAXHOST]; // Client's remote name
char service[NI_MAXHOST]; // Service (PORT) the client is connected on
ZeroMemory(host, NI_MAXHOST); // Could use memset(host, 0, )
ZeroMemory(service, NI_MAXHOST);
if (getnameinfo((sockaddr*)&client, sizeof(client), host, NI_MAXHOST, service, NI_MAXSERV, 0) == 0)
{
cout << host << " connected on port " << service << endl;
}
else
{
inet_ntop(AF_INET, &client.sin_addr, host, NI_MAXHOST);
cout << host << " connected on port " << ntohs(client.sin_port) << endl;
}
// Close listening socket
closesocket(listening);
// While loop: accept and echo message back to client
char buf[4096];
//Opens new thread with canvas because otherwise while loop for recieving will block drawing
//std::thread t1(setDrawing, &iArgc, cppArgv);
while (true) {
ZeroMemory(buf, 4096);
// Wait for client to send data
int bytesRecieved = recv(clientSocket, buf, 4096, 0);
if (bytesRecieved == SOCKET_ERROR) {
int err = WSAGetLastError();
cerr << "Error in recv(). Quitting!" << endl;
break;
}
if (bytesRecieved == 0) {
cout << "Client disconnected " << endl;
break;
}
Моя серверная часть работала отлично перед добавлением
#include <thread>
, поэтому я понятия не имею, в чем может быть проблема и почему я не могу использовать потоки при использовании сокетов.
На что стоит обратить внимание, так это на то, что <thread>
заголовок C ++ STL Если ваш код имеет using namespace std;
утверждение, ваш код сокета может в конечном итоге вызвать STL std::bind()
функция вместо WinSock’s bind()
функция, которая в свою очередь вызовет listen()
потерпеть неудачу с WSAEINVAL
ошибка. Который вы не проверяете, так как вы не делаете никакой обработки ошибок на вашем bind()
или же listen()
звонки. Так что знайте об этом. избежать using namespace std;
заявления или вызвать WinSock’s bind()
как ::bind()
вместо. И ВСЕГДА выполняйте обработку ошибок при вызовах API.
Вы также прокомментировали свою обработку ошибок на accept()
, Если bind()
а также listen()
потерпеть неудачу, так будет accept()
, заставляя его вернуться INVALID_SOCKET
, Что может объяснить, почему вы получаете WSAENOTSOCK
ошибка на recv()
,
Других решений пока нет …