Thomas Mørch
c62aca4125
Removed Wire and SAMD_AnalogCorrection libraries from HW section, as we didn't change anything in those, so let's keep it to the standard ones Modified SPI library, initializing extra SPI ports, also HW mux changes in the setup of individual SPI ports to match the GW setup Added MyHWSAMD files so they are included in the core headers (MyConfig.h / MySensors.h)
93 lines
1.8 KiB
C++
93 lines
1.8 KiB
C++
#include "utility/w5100.h"
|
|
#include "utility/socket.h"
|
|
extern "C" {
|
|
#include "string.h"
|
|
}
|
|
|
|
#include "Ethernet.h"
|
|
#include "EthernetClient.h"
|
|
#include "EthernetServer.h"
|
|
|
|
EthernetServer::EthernetServer(uint16_t port)
|
|
{
|
|
_port = port;
|
|
}
|
|
|
|
void EthernetServer::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;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
void EthernetServer::accept()
|
|
{
|
|
int listening = 0;
|
|
|
|
for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
|
|
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()) {
|
|
client.stop();
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!listening) {
|
|
begin();
|
|
}
|
|
}
|
|
|
|
EthernetClient EthernetServer::available()
|
|
{
|
|
accept();
|
|
|
|
for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
|
|
EthernetClient client(sock);
|
|
if (EthernetClass::_server_port[sock] == _port) {
|
|
uint8_t s = client.status();
|
|
if (s == SnSR::ESTABLISHED || s == SnSR::CLOSE_WAIT) {
|
|
if (client.available()) {
|
|
// XXX: don't always pick the lowest numbered socket.
|
|
return client;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
return EthernetClient(MAX_SOCK_NUM);
|
|
}
|
|
|
|
size_t EthernetServer::write(uint8_t b)
|
|
{
|
|
return write(&b, 1);
|
|
}
|
|
|
|
size_t EthernetServer::write(const uint8_t *buffer, size_t size)
|
|
{
|
|
size_t n = 0;
|
|
|
|
accept();
|
|
|
|
for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
|
|
EthernetClient client(sock);
|
|
|
|
if (EthernetClass::_server_port[sock] == _port &&
|
|
client.status() == SnSR::ESTABLISHED) {
|
|
n += client.write(buffer, size);
|
|
}
|
|
}
|
|
|
|
return n;
|
|
}
|