Виндавс7 слишком умный.
Получатель на UDP-порту 127.0.0.1:12345. Отправитель открывает случайный порт 127.0.0.1:0 и шлет на получателя.
Так все работает. Но если получателя нет, например не успел стартануть, то отправитель получает ошибку на recvfrom()
1.
2.
3.
int r = recvfrom(sock, (char*)msg->raw_ptr(), UDP_MAX_SIZE, 0, (SOCKADDR*) &msg->addr, &addr_size);
if(r <= 0) { // Ошибка сокета, остановка приема
debug_log("%s: recv error %d", name_get(), WSAGetLastError());
WSAGetLastError() показывает 10054
https://docs.microsoft.com/en-us/windows/win32/winsock/windows-sockets-error-codes-2 WSAECONNRESET 10054
Connection reset by peer.
An existing connection was forcibly closed by the remote host. This normally results if the peer application on the remote host is suddenly stopped, the host is rebooted, the host or remote network interface is disabled, or the remote host uses a hard close (see setsockopt for more information on the SO_LINGER option on the remote socket). This error may also result if a connection was broken due to keep-alive activity detecting a failure while one or more operations are in progress. Operations that were in progress fail with WSAENETRESET. Subsequent operations fail with WSAECONNRESET.
Принцип работы: отправитель открывает порт и запускает отдельный поток для ожидания входящих, в том потоке recvfrom(). Затем происходит отправка нескольких пакетов и recvfrom() прекращает ожидание с ошибкой.
Нафига такая фича? Это же UDP, сейчас нет получателя, через секунду появился, а у меня поток приема уже завершился и больше ответов не ожидает.
Может кто знает как эту "продвинутость" отключить?
Код открытия порта
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
bool open(int port = 0) {
close();
int err = udp_init();
if(err != NO_ERROR) {
release_log("%s: udp_init() error %d", name_get(), err);
return false;
}
sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
if (sock == INVALID_SOCKET) {
release_log("%s: socket() error %d", name_get(), err);
return false;
}
// Буферы приема и отправки
int size = UDP_BUF_SIZE;
err = setsockopt(sock, SOL_SOCKET, SO_SNDBUF, (char*)&size, sizeof(size));
if (err != 0) {
release_log("%s: setsockopt(SO_SNDBUF) error %d", name_get(), err);
close();
return false;
}
size *= 5;
err = setsockopt(sock, SOL_SOCKET, SO_RCVBUF, (char*)&size, sizeof(size));
if (err != 0) {
release_log("%s: setsockopt(SO_RCVBUF) error %d", name_get(), err);
close();
return false;
}
// Установка запрета фрагментации пакетов
int yes = IP_PMTUDISC_DO;
err = setsockopt(sock, IPPROTO_IP, IP_DONTFRAGMENT, (char*)&yes, sizeof(yes));
if (err != 0) {
release_log("%s: setsockopt(IP_DONTFRAGMENT) error %d", name_get(), err);
close();
return false;
}
sockaddr_in addr_in;
addr_in.sin_family = AF_INET;
addr_in.sin_port = htons((uint16_t) port);
#ifdef _DEBUG
addr_in.sin_addr.s_addr = htonl(INADDR_LOOPBACK);
#else
addr_in.sin_addr.s_addr = htonl(INADDR_ANY);
#endif
err = bind(sock, (SOCKADDR*)&addr_in, (socklen_t)sizeof(sockaddr_in));
if (err != 0) {
release_log("%s: bind() error %d", name_get(), err);
close();
return false;
}
th_recv = std::thread(recv_thread, this); // Поток с recvfrom()
return true;
}
PS sendto() никаких ошибок не выдает.
