mirror of
https://github.com/CalcProgrammer1/OpenRGB.git
synced 2026-01-02 12:17:51 -05:00
b94f701db8
It was coming from `recv_select()` `nd accept_select()` The timeout for select() is only when waiting for the file descriptor to be ready for reading/writing so when the FD is ready AND there is nothing to read, it will not return and instead keep executing the while loop with no timeout. Fix this by adding a 100ms timeout when there is nothing to read.
614 lines
18 KiB
C++
614 lines
18 KiB
C++
/*-----------------------------------------*\
|
|
| NetworkServer.cpp |
|
|
| |
|
|
| Server code for OpenRGB SDK |
|
|
| |
|
|
| Adam Honse (CalcProgrammer1) 5/9/2020 |
|
|
\*-----------------------------------------*/
|
|
|
|
#include "NetworkServer.h"
|
|
#include <cstring>
|
|
|
|
#ifndef WIN32
|
|
#include <sys/ioctl.h>
|
|
#include <netinet/tcp.h>
|
|
#include <sys/types.h>
|
|
#include <arpa/inet.h>
|
|
#else
|
|
#include <ws2tcpip.h>
|
|
#endif
|
|
#include <memory.h>
|
|
#include <errno.h>
|
|
#include <stdlib.h>
|
|
#include <iostream>
|
|
|
|
const char yes = 1;
|
|
|
|
#ifdef WIN32
|
|
#include <Windows.h>
|
|
#else
|
|
#include <unistd.h>
|
|
#endif
|
|
|
|
using namespace std::chrono_literals;
|
|
|
|
|
|
NetworkServer::NetworkServer(std::vector<RGBController *>& control) : controllers(control)
|
|
{
|
|
port_num = OPENRGB_SDK_PORT;
|
|
server_online = false;
|
|
}
|
|
|
|
void NetworkServer::ClientInfoChanged()
|
|
{
|
|
ClientInfoChangeMutex.lock();
|
|
|
|
/*-------------------------------------------------*\
|
|
| Client info has changed, call the callbacks |
|
|
\*-------------------------------------------------*/
|
|
for(unsigned int callback_idx = 0; callback_idx < ClientInfoChangeCallbacks.size(); callback_idx++)
|
|
{
|
|
ClientInfoChangeCallbacks[callback_idx](ClientInfoChangeCallbackArgs[callback_idx]);
|
|
}
|
|
|
|
ClientInfoChangeMutex.unlock();
|
|
}
|
|
|
|
unsigned short NetworkServer::GetPort()
|
|
{
|
|
return port_num;
|
|
}
|
|
|
|
bool NetworkServer::GetOnline()
|
|
{
|
|
return server_online;
|
|
}
|
|
|
|
unsigned int NetworkServer::GetNumClients()
|
|
{
|
|
return ServerClients.size();
|
|
}
|
|
|
|
const char * NetworkServer::GetClientString(unsigned int client_num)
|
|
{
|
|
if(client_num < ServerClients.size())
|
|
{
|
|
return ServerClients[client_num]->client_string.c_str();
|
|
}
|
|
else
|
|
{
|
|
return "";
|
|
}
|
|
}
|
|
|
|
const char * NetworkServer::GetClientIP(unsigned int client_num)
|
|
{
|
|
if(client_num < ServerClients.size())
|
|
{
|
|
return ServerClients[client_num]->client_ip;
|
|
}
|
|
else
|
|
{
|
|
return "";
|
|
}
|
|
}
|
|
|
|
void NetworkServer::RegisterClientInfoChangeCallback(NetServerCallback new_callback, void * new_callback_arg)
|
|
{
|
|
ClientInfoChangeCallbacks.push_back(new_callback);
|
|
ClientInfoChangeCallbackArgs.push_back(new_callback_arg);
|
|
}
|
|
|
|
void NetworkServer::SetPort(unsigned short new_port)
|
|
{
|
|
if(server_online == false)
|
|
{
|
|
port_num = new_port;
|
|
}
|
|
}
|
|
|
|
void NetworkServer::StartServer()
|
|
{
|
|
//Start a TCP server and launch threads
|
|
char port_str[6];
|
|
snprintf(port_str, 6, "%d", port_num);
|
|
|
|
sockaddr_in myAddress;
|
|
|
|
/*-------------------------------------------------*\
|
|
| Windows requires WSAStartup before using sockets |
|
|
\*-------------------------------------------------*/
|
|
#ifdef WIN32
|
|
if (WSAStartup(MAKEWORD(2, 2), &wsa) != NO_ERROR)
|
|
{
|
|
WSACleanup();
|
|
return;
|
|
}
|
|
#endif
|
|
|
|
/*-------------------------------------------------*\
|
|
| Create the server socket |
|
|
\*-------------------------------------------------*/
|
|
server_sock = socket(AF_INET, SOCK_STREAM, 0);
|
|
if (server_sock == INVALID_SOCKET)
|
|
{
|
|
printf("Error: network socket could not be created\n");
|
|
WSACleanup();
|
|
return;
|
|
}
|
|
|
|
/*-------------------------------------------------*\
|
|
| Fill in server address info with port value |
|
|
\*-------------------------------------------------*/
|
|
myAddress.sin_family = AF_INET;
|
|
myAddress.sin_addr.s_addr = inet_addr("0.0.0.0");
|
|
myAddress.sin_port = htons(atoi(port_str));
|
|
|
|
/*-------------------------------------------------*\
|
|
| Bind the server socket |
|
|
\*-------------------------------------------------*/
|
|
if (bind(server_sock, (sockaddr*)&myAddress, sizeof(myAddress)) == SOCKET_ERROR)
|
|
{
|
|
printf("Error: Could not bind network socket \nIs port %hu already being used?\n", GetPort());
|
|
WSACleanup();
|
|
return;
|
|
}
|
|
|
|
/*-------------------------------------------------*\
|
|
| Set socket options - no delay |
|
|
\*-------------------------------------------------*/
|
|
setsockopt(server_sock, IPPROTO_TCP, TCP_NODELAY, &yes, sizeof(yes));
|
|
|
|
server_online = true;
|
|
|
|
/*-------------------------------------------------*\
|
|
| Start the connection thread |
|
|
\*-------------------------------------------------*/
|
|
ConnectionThread = new std::thread(&NetworkServer::ConnectionThreadFunction, this);
|
|
}
|
|
|
|
void NetworkServer::StopServer()
|
|
{
|
|
server_online = false;
|
|
|
|
for(unsigned int client_idx = 0; client_idx < ServerClients.size(); client_idx++)
|
|
{
|
|
shutdown(ServerClients[client_idx]->client_sock, SD_RECEIVE);
|
|
closesocket(ServerClients[client_idx]->client_sock);
|
|
ServerClients[client_idx]->client_listen_thread->join();
|
|
}
|
|
|
|
shutdown(server_sock, SD_RECEIVE);
|
|
closesocket(server_sock);
|
|
|
|
ConnectionThread->join();
|
|
|
|
for(unsigned int client_idx = 0; client_idx < ServerClients.size(); client_idx++)
|
|
{
|
|
delete ServerClients[client_idx];
|
|
}
|
|
|
|
ServerClients.clear();
|
|
|
|
/*-------------------------------------------------*\
|
|
| Client info has changed, call the callbacks |
|
|
\*-------------------------------------------------*/
|
|
ClientInfoChanged();
|
|
}
|
|
|
|
void NetworkServer::ConnectionThreadFunction()
|
|
{
|
|
//This thread handles client connections
|
|
|
|
printf("Network connection thread started on port %hu\n", GetPort());
|
|
while(server_online == true)
|
|
{
|
|
/*-------------------------------------------------*\
|
|
| Create new socket for client connection |
|
|
\*-------------------------------------------------*/
|
|
NetworkClientInfo * client_info = new NetworkClientInfo();
|
|
|
|
/*-------------------------------------------------*\
|
|
| Listen for incoming client connection on the |
|
|
| server socket. This call blocks until a |
|
|
| connection is established |
|
|
\*-------------------------------------------------*/
|
|
if(listen(server_sock, 10) < 0)
|
|
{
|
|
printf("Connection thread closed\r\n");
|
|
server_online = false;
|
|
|
|
return;
|
|
}
|
|
|
|
/*-------------------------------------------------*\
|
|
| Accept the client connection |
|
|
\*-------------------------------------------------*/
|
|
struct sockaddr_in client_addr;
|
|
socklen_t client_addr_len = sizeof(client_addr);
|
|
client_info->client_sock = accept_select(server_sock, (struct sockaddr *)&client_addr, &client_addr_len);
|
|
|
|
if(client_info->client_sock < 0)
|
|
{
|
|
printf("Connection thread closed\r\n");
|
|
server_online = false;
|
|
|
|
return;
|
|
}
|
|
|
|
/*-------------------------------------------------*\
|
|
| Get the new client socket and store it in the |
|
|
| clients vector |
|
|
\*-------------------------------------------------*/
|
|
u_long arg = 0;
|
|
ioctlsocket(client_info->client_sock, FIONBIO, &arg);
|
|
setsockopt(client_info->client_sock, IPPROTO_TCP, TCP_NODELAY, &yes, sizeof(yes));
|
|
|
|
inet_ntop(AF_INET, &client_addr.sin_addr, client_info->client_ip, INET_ADDRSTRLEN);
|
|
|
|
client_info->client_string = "Client";
|
|
|
|
//Start a listener thread for the new client socket
|
|
client_info->client_listen_thread = new std::thread(&NetworkServer::ListenThreadFunction, this, client_info);
|
|
|
|
ServerClients.push_back(client_info);
|
|
|
|
/*-------------------------------------------------*\
|
|
| Client info has changed, call the callbacks |
|
|
\*-------------------------------------------------*/
|
|
ClientInfoChanged();
|
|
}
|
|
|
|
printf("Connection thread closed\r\n");
|
|
server_online = false;
|
|
}
|
|
|
|
int NetworkServer::accept_select(int sockfd, struct sockaddr *addr, socklen_t *addrlen)
|
|
{
|
|
fd_set set;
|
|
struct timeval timeout;
|
|
timeout.tv_sec = 5;
|
|
timeout.tv_usec = 0;
|
|
|
|
while(1)
|
|
{
|
|
FD_ZERO(&set); /* clear the set */
|
|
FD_SET(sockfd, &set); /* add our file descriptor to the set */
|
|
|
|
int rv = select(sockfd + 1, &set, NULL, NULL, &timeout);
|
|
|
|
if(rv == SOCKET_ERROR || server_online == false)
|
|
{
|
|
return -1;
|
|
}
|
|
else if(rv == 0)
|
|
{
|
|
std::this_thread::sleep_for(100ms);
|
|
continue;
|
|
}
|
|
else
|
|
{
|
|
// socket has something to read
|
|
return(accept(sockfd, addr, addrlen));
|
|
}
|
|
}
|
|
}
|
|
|
|
int NetworkServer::recv_select(SOCKET s, char *buf, int len, int flags)
|
|
{
|
|
fd_set set;
|
|
struct timeval timeout;
|
|
timeout.tv_sec = 5;
|
|
timeout.tv_usec = 0;
|
|
|
|
while(1)
|
|
{
|
|
FD_ZERO(&set); /* clear the set */
|
|
FD_SET(s, &set); /* add our file descriptor to the set */
|
|
|
|
int rv = select(s + 1, &set, NULL, NULL, &timeout);
|
|
|
|
if(rv == SOCKET_ERROR || server_online == false)
|
|
{
|
|
return 0;
|
|
}
|
|
else if(rv == 0)
|
|
{
|
|
std::this_thread::sleep_for(100ms);
|
|
continue;
|
|
}
|
|
else
|
|
{
|
|
// socket has something to read
|
|
return(recv(s, buf, len, flags));
|
|
}
|
|
}
|
|
}
|
|
|
|
void NetworkServer::ListenThreadFunction(NetworkClientInfo * client_info)
|
|
{
|
|
SOCKET client_sock = client_info->client_sock;
|
|
|
|
printf("Network server started\n");
|
|
//This thread handles messages received from clients
|
|
while(server_online == true)
|
|
{
|
|
NetPacketHeader header;
|
|
int bytes_read = 0;
|
|
char * data = NULL;
|
|
|
|
//Read first byte of magic
|
|
bytes_read = recv_select(client_sock, &header.pkt_magic[0], 1, 0);
|
|
|
|
if(bytes_read <= 0)
|
|
{
|
|
goto listen_done;
|
|
}
|
|
|
|
//Test first character of magic - 'O'
|
|
if(header.pkt_magic[0] != 'O')
|
|
{
|
|
continue;
|
|
}
|
|
|
|
//Read second byte of magic
|
|
bytes_read = recv_select(client_sock, &header.pkt_magic[1], 1, 0);
|
|
|
|
if(bytes_read <= 0)
|
|
{
|
|
goto listen_done;
|
|
}
|
|
|
|
//Test second character of magic - 'R'
|
|
if(header.pkt_magic[1] != 'R')
|
|
{
|
|
continue;
|
|
}
|
|
|
|
//Read third byte of magic
|
|
bytes_read = recv_select(client_sock, &header.pkt_magic[2], 1, 0);
|
|
|
|
if(bytes_read <= 0)
|
|
{
|
|
goto listen_done;
|
|
}
|
|
|
|
//Test third character of magic - 'G'
|
|
if(header.pkt_magic[2] != 'G')
|
|
{
|
|
continue;
|
|
}
|
|
|
|
//Read fourth byte of magic
|
|
bytes_read = recv_select(client_sock, &header.pkt_magic[3], 1, 0);
|
|
|
|
if(bytes_read <= 0)
|
|
{
|
|
goto listen_done;
|
|
}
|
|
|
|
//Test fourth character of magic - 'B'
|
|
if(header.pkt_magic[3] != 'B')
|
|
{
|
|
continue;
|
|
}
|
|
|
|
//If we get to this point, the magic is correct. Read the rest of the header
|
|
bytes_read = 0;
|
|
do
|
|
{
|
|
int tmp_bytes_read = 0;
|
|
|
|
tmp_bytes_read = recv_select(client_sock, (char *)&header.pkt_dev_idx + bytes_read, sizeof(header) - sizeof(header.pkt_magic) - bytes_read, 0);
|
|
|
|
bytes_read += tmp_bytes_read;
|
|
|
|
if(tmp_bytes_read <= 0)
|
|
{
|
|
goto listen_done;
|
|
}
|
|
|
|
} while(bytes_read != sizeof(header) - sizeof(header.pkt_magic));
|
|
|
|
//printf( "Server: Received header, now receiving data of size %d\r\n", header.pkt_size);
|
|
|
|
//Header received, now receive the data
|
|
if(header.pkt_size > 0)
|
|
{
|
|
bytes_read = 0;
|
|
|
|
data = new char[header.pkt_size];
|
|
|
|
do
|
|
{
|
|
int tmp_bytes_read = 0;
|
|
|
|
tmp_bytes_read = recv_select(client_sock, &data[bytes_read], header.pkt_size - bytes_read, 0);
|
|
|
|
if(tmp_bytes_read <= 0)
|
|
{
|
|
goto listen_done;
|
|
}
|
|
bytes_read += tmp_bytes_read;
|
|
|
|
} while (bytes_read < header.pkt_size);
|
|
}
|
|
|
|
//printf( "Server: Received header and data\r\n" );
|
|
//printf( "Server: Packet ID: %d \r\n", header.pkt_id);
|
|
|
|
//Entire request received, select functionality based on request ID
|
|
switch(header.pkt_id)
|
|
{
|
|
case NET_PACKET_ID_REQUEST_CONTROLLER_COUNT:
|
|
//printf( "NET_PACKET_ID_REQUEST_CONTROLLER_COUNT\r\n" );
|
|
SendReply_ControllerCount(client_sock);
|
|
break;
|
|
|
|
case NET_PACKET_ID_REQUEST_CONTROLLER_DATA:
|
|
//printf( "NET_PACKET_ID_REQUEST_CONTROLLER_DATA\r\n" );
|
|
SendReply_ControllerData(client_sock, header.pkt_dev_idx);
|
|
break;
|
|
|
|
case NET_PACKET_ID_SET_CLIENT_NAME:
|
|
printf( "NET_PACKET_ID_SET_CLIENT_NAME\r\n" );
|
|
ProcessRequest_ClientString(client_sock, header.pkt_size, data);
|
|
break;
|
|
|
|
case NET_PACKET_ID_RGBCONTROLLER_RESIZEZONE:
|
|
//printf( "NET_PACKET_ID_RGBCONTROLLER_RESIZEZONE\r\n" );
|
|
|
|
if((header.pkt_dev_idx < controllers.size()) && (header.pkt_size == (2 * sizeof(int))))
|
|
{
|
|
int zone;
|
|
int new_size;
|
|
|
|
memcpy(&zone, data, sizeof(int));
|
|
memcpy(&new_size, data + sizeof(int), sizeof(int));
|
|
|
|
controllers[header.pkt_dev_idx]->ResizeZone(zone, new_size);
|
|
}
|
|
break;
|
|
|
|
case NET_PACKET_ID_RGBCONTROLLER_UPDATELEDS:
|
|
//printf( "NET_PACKET_ID_RGBCONTROLLER_UPDATELEDS\r\n" );
|
|
|
|
if(header.pkt_dev_idx < controllers.size())
|
|
{
|
|
controllers[header.pkt_dev_idx]->SetColorDescription((unsigned char *)data);
|
|
controllers[header.pkt_dev_idx]->UpdateLEDs();
|
|
}
|
|
break;
|
|
|
|
case NET_PACKET_ID_RGBCONTROLLER_UPDATEZONELEDS:
|
|
//printf( "NET_PACKET_ID_RGBCONTROLLER_UPDATEZONELEDS\r\n" );
|
|
|
|
if(header.pkt_dev_idx < controllers.size())
|
|
{
|
|
int zone;
|
|
|
|
memcpy(&zone, &data[sizeof(unsigned int)], sizeof(int));
|
|
|
|
controllers[header.pkt_dev_idx]->SetZoneColorDescription((unsigned char *)data);
|
|
controllers[header.pkt_dev_idx]->UpdateZoneLEDs(zone);
|
|
}
|
|
break;
|
|
|
|
case NET_PACKET_ID_RGBCONTROLLER_UPDATESINGLELED:
|
|
//printf( "NET_PACKET_ID_RGBCONTROLLER_UPDATESINGLELED\r\n" );
|
|
|
|
if(header.pkt_dev_idx < controllers.size())
|
|
{
|
|
int led;
|
|
|
|
memcpy(&led, data, sizeof(int));
|
|
|
|
controllers[header.pkt_dev_idx]->SetSingleLEDColorDescription((unsigned char *)data);
|
|
controllers[header.pkt_dev_idx]->UpdateSingleLED(led);
|
|
}
|
|
break;
|
|
|
|
case NET_PACKET_ID_RGBCONTROLLER_SETCUSTOMMODE:
|
|
//printf( "NET_PACKET_ID_RGBCONTROLLER_SETCUSTOMMODE\r\n" );
|
|
|
|
if(header.pkt_dev_idx < controllers.size())
|
|
{
|
|
controllers[header.pkt_dev_idx]->SetCustomMode();
|
|
}
|
|
break;
|
|
|
|
case NET_PACKET_ID_RGBCONTROLLER_UPDATEMODE:
|
|
//printf( "NET_PACKET_ID_RGBCONTROLLER_UPDATEMODE\r\n" );
|
|
|
|
if(header.pkt_dev_idx < controllers.size())
|
|
{
|
|
controllers[header.pkt_dev_idx]->SetModeDescription((unsigned char *)data);
|
|
controllers[header.pkt_dev_idx]->UpdateMode();
|
|
}
|
|
break;
|
|
}
|
|
|
|
delete[] data;
|
|
}
|
|
|
|
listen_done:
|
|
printf("Server connection closed\r\n");
|
|
shutdown(client_info->client_sock, SD_RECEIVE);
|
|
closesocket(client_info->client_sock);
|
|
|
|
for(unsigned int this_idx = 0; this_idx < ServerClients.size(); this_idx++)
|
|
{
|
|
if(ServerClients[this_idx] == client_info)
|
|
{
|
|
ServerClients.erase(ServerClients.begin() + this_idx);
|
|
break;
|
|
}
|
|
}
|
|
|
|
/*-------------------------------------------------*\
|
|
| Client info has changed, call the callbacks |
|
|
\*-------------------------------------------------*/
|
|
ClientInfoChanged();
|
|
}
|
|
|
|
void NetworkServer::ProcessRequest_ClientString(SOCKET client_sock, unsigned int data_size, char * data)
|
|
{
|
|
for(unsigned int this_idx = 0; this_idx < ServerClients.size(); this_idx++)
|
|
{
|
|
if(ServerClients[this_idx]->client_sock == client_sock)
|
|
{
|
|
ServerClients[this_idx]->client_string = data;
|
|
break;
|
|
}
|
|
}
|
|
|
|
/*-------------------------------------------------*\
|
|
| Client info has changed, call the callbacks |
|
|
\*-------------------------------------------------*/
|
|
ClientInfoChanged();
|
|
}
|
|
|
|
void NetworkServer::SendReply_ControllerCount(SOCKET client_sock)
|
|
{
|
|
NetPacketHeader reply_hdr;
|
|
unsigned int reply_data;
|
|
|
|
reply_hdr.pkt_magic[0] = 'O';
|
|
reply_hdr.pkt_magic[1] = 'R';
|
|
reply_hdr.pkt_magic[2] = 'G';
|
|
reply_hdr.pkt_magic[3] = 'B';
|
|
|
|
reply_hdr.pkt_dev_idx = 0;
|
|
reply_hdr.pkt_id = NET_PACKET_ID_REQUEST_CONTROLLER_COUNT;
|
|
reply_hdr.pkt_size = sizeof(unsigned int);
|
|
|
|
reply_data = controllers.size();
|
|
|
|
send(client_sock, (const char *)&reply_hdr, sizeof(NetPacketHeader), 0);
|
|
send(client_sock, (const char *)&reply_data, sizeof(unsigned int), 0);
|
|
}
|
|
|
|
void NetworkServer::SendReply_ControllerData(SOCKET client_sock, unsigned int dev_idx)
|
|
{
|
|
if(dev_idx < controllers.size())
|
|
{
|
|
NetPacketHeader reply_hdr;
|
|
unsigned char *reply_data = controllers[dev_idx]->GetDeviceDescription();
|
|
unsigned int reply_size;
|
|
|
|
memcpy(&reply_size, reply_data, sizeof(reply_size));
|
|
|
|
reply_hdr.pkt_magic[0] = 'O';
|
|
reply_hdr.pkt_magic[1] = 'R';
|
|
reply_hdr.pkt_magic[2] = 'G';
|
|
reply_hdr.pkt_magic[3] = 'B';
|
|
|
|
reply_hdr.pkt_dev_idx = dev_idx;
|
|
reply_hdr.pkt_id = NET_PACKET_ID_REQUEST_CONTROLLER_DATA;
|
|
reply_hdr.pkt_size = reply_size;
|
|
|
|
send(client_sock, (const char *)&reply_hdr, sizeof(NetPacketHeader), 0);
|
|
send(client_sock, (const char *)reply_data, reply_size, 0);
|
|
}
|
|
}
|