mirror of
https://github.com/arduino/Arduino.git
synced 2024-12-10 21:24:12 +01:00
80 lines
1.5 KiB
C++
80 lines
1.5 KiB
C++
|
extern "C" {
|
||
|
#include "types.h"
|
||
|
#include "w5100.h"
|
||
|
#include "socket.h"
|
||
|
}
|
||
|
|
||
|
#include "Ethernet.h"
|
||
|
#include "Client.h"
|
||
|
#include "Server.h"
|
||
|
|
||
|
Server::Server(uint16_t port)
|
||
|
{
|
||
|
_port = port;
|
||
|
}
|
||
|
|
||
|
void Server::begin()
|
||
|
{
|
||
|
for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
|
||
|
Client client(sock);
|
||
|
if (client.status() == SOCK_CLOSED) {
|
||
|
socket(sock, Sn_MR_TCP, _port, 0);
|
||
|
listen(sock);
|
||
|
EthernetClass::_server_port[sock] = _port;
|
||
|
break;
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
void Server::accept()
|
||
|
{
|
||
|
int listening = 0;
|
||
|
|
||
|
for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
|
||
|
Client client(sock);
|
||
|
|
||
|
if (EthernetClass::_server_port[sock] == _port) {
|
||
|
if (client.status() == SOCK_LISTEN) {
|
||
|
listening = 1;
|
||
|
} else if (client.status() == SOCK_CLOSE_WAIT && !client.available()) {
|
||
|
client.stop();
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
if (!listening) {
|
||
|
begin();
|
||
|
}
|
||
|
}
|
||
|
|
||
|
Client Server::available()
|
||
|
{
|
||
|
accept();
|
||
|
|
||
|
for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
|
||
|
Client client(sock);
|
||
|
if (EthernetClass::_server_port[sock] == _port &&
|
||
|
client.status() == SOCK_ESTABLISHED) {
|
||
|
if (client.available()) {
|
||
|
// XXX: don't always pick the lowest numbered socket.
|
||
|
return client;
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
return Client(255);
|
||
|
}
|
||
|
|
||
|
void Server::write(uint8_t b)
|
||
|
{
|
||
|
accept();
|
||
|
|
||
|
for (int sock = 0; sock < MAX_SOCK_NUM; sock++) {
|
||
|
Client client(sock);
|
||
|
|
||
|
if (EthernetClass::_server_port[sock] == _port &&
|
||
|
client.status() == SOCK_ESTABLISHED) {
|
||
|
client.write(b);
|
||
|
}
|
||
|
}
|
||
|
}
|