DashyFox/Ethernet_W5500
1
0
Fork 0
mirror of https://github.com/Show-maket/EthernetMaket.git synced 2025-05-03 14:50:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #1 from Show-maket/vanilla-server

Browse Source 
vanilla
This commit is contained in:
DashyFox 2024-12-09 15:52:23 +03:00 committed by GitHub
commit 71176f9274
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 88 additions and 74 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

152
src/EthernetOverride/Server.cpp
View File

@ -12,85 +12,99 @@ void EthernetMaketServer::resetServerHandler()
serverHandler = [](EthernetMaketClient &sclient) {};
}
EthernetMaketClient EthernetMaketServer::available(int sock)
{
accept(sock);
EthernetClient client(sock);
if (EthernetClass::_server_port[sock] == _port &&
(client.status() == SnSR::ESTABLISHED ||
client.status() == SnSR::CLOSE_WAIT))
{
if (client.available())
{
return std::move(EthernetMaketClient(client));
}
}
return std::move(EthernetMaketClient(MAX_SOCK_NUM));
}
// EthernetMaketClient EthernetMaketServer::available(int sock)
// {
// accept(sock);
// EthernetClient client(sock);
// if (EthernetClass::_server_port[sock] == _port &&
// (client.status() == SnSR::ESTABLISHED ||
// client.status() == SnSR::CLOSE_WAIT))
// {
// if (client.available())
// {
// return std::move(EthernetMaketClient(client));
// }
// }
// return std::move(EthernetMaketClient(MAX_SOCK_NUM));
// }
void EthernetMaketServer::accept(int sock)
{
int listening = 0;
EthernetClient client(sock);
// void EthernetMaketServer::accept(int sock)
// {
// int listening = 0;
// EthernetClient client(sock);
if (EthernetClass::_server_port[sock] == _port)
{
if (client.status() == SnSR::LISTEN)
{
listening = 1;
}
else if (client.status() == SnSR::CLOSE_WAIT && !client.available())
{
Serial.println("HARD STOP");
client.stop();
}
}
// if (EthernetClass::_server_port[sock] == _port)
// {
// if (client.status() == SnSR::LISTEN)
// {
// listening = 1;
// }
// else if (client.status() == SnSR::CLOSE_WAIT && !client.available())
// {
// Serial.println("HARD STOP");
// client.stop();
// }
// }
if (!listening)
{
// begin();
begin(sock); // added
}
}
// if (!listening)
// {
// // begin();
// begin(sock); // added
// }
// }
void EthernetMaketServer::begin(int sock)
{
EthernetClient client(sock);
if (client.status() == SnSR::CLOSED)
{
socket(sock, SnMR::TCP, _port, 0);
listen(sock);
EthernetClass::_server_port[sock] = _port;
serverSocket = sock;
return;
}
// Serial.println(F("EthernetMaketServer::begin() FAIL"));
}
void EthernetMaketServer::begin()
{
for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
EthernetClient client(sock);
if (client.status() == SnSR::CLOSED) {
socket(sock, SnMR::TCP, _port, 0);
listen(sock);
EthernetClass::_server_port[sock] = _port;
serverSocket = sock;
break;
}
}
// Serial.println(F("EthernetMaketServer::begin() FAIL"));
}
// void EthernetMaketServer::begin(int sock)
// {
// EthernetClient client(sock);
// if (client.status() == SnSR::CLOSED)
// {
// socket(sock, SnMR::TCP, _port, 0);
// listen(sock);
// EthernetClass::_server_port[sock] = _port;
// serverSocket = sock;
// return;
// }
// // Serial.println(F("EthernetMaketServer::begin() FAIL"));
// }
// void EthernetMaketServer::begin()
// {
// for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
// EthernetClient client(sock);
// if (client.status() == SnSR::CLOSED) {
// socket(sock, SnMR::TCP, _port, 0);
// listen(sock);
// EthernetClass::_server_port[sock] = _port;
// serverSocket = sock;
// break;
// }
// }
// // Serial.println(F("EthernetMaketServer::begin() FAIL"));
// }
uint8_t buf[256];
void EthernetMaketServer::tick()
{
// for (int sock = 0; sock < MAX_SOCK_NUM; sock++)
{
sclient = available(serverSocket);
if (sclient.connected() && sclient.available() > 0)
EthernetClient sclient = available(/* serverSocket */);
size_t dataSize;
if (sclient.connected() && (dataSize = sclient.available()) > 0)
{
sclient.activityUpdate();
serverHandler(sclient);
Serial.println("Receive!");
memset(buf,0x00,sizeof(buf));
sclient.read(buf, sizeof(buf));
Serial.print("Received data: ");
for (int i = 0; i < dataSize; i++)
{
Serial.print(buf[i], HEX);
Serial.print(" ");
}
Serial.println("\n");
// sclient.activityUpdate();
//* serverHandler(sclient);
}

10
src/EthernetOverride/Server.h
View File

@ -8,8 +8,8 @@ class EthernetMaketClient;
class EthernetMaketServer : public EthernetServer
{
private:
EthernetClient available();
void accept(int sock);
// EthernetClient available();
// void accept(int sock);
std::function<void(EthernetMaketClient&)> serverHandler = [](EthernetMaketClient &sclient) {};
SOCKET serverSocket = MAX_SOCK_NUM;
@ -18,12 +18,12 @@ private:
public:
using EthernetServer::EthernetServer;
EthernetMaketClient available(int sock);
// EthernetMaketClient available(int sock);
void setServerHandler(std::function<void(EthernetMaketClient)> handler);
void resetServerHandler();
void begin() override;
void begin(int sock);
// void begin() override;
// void begin(int sock);
void tick();
};