#include "mbed.h"
#include "EthernetInterface.h"

void server_thread(void const* arg) {
    TCPSocketServer server;
    
    server.set_blocking (true);
    server.bind(11000);    
    server.listen(1);

    while (true) {
        TCPSocketConnection client;

        int ret = server.accept(client);
        
        if (ret == 0) {
            char buffer[1024];
            while (true) {
                int n = client.receive(buffer, sizeof(buffer));
                
                if (n < 0)
                    break;
            }
        }

        client.close();
    }
}

DigitalOut heartbeatLed(LED_GREEN);

int main(void) {
    EthernetInterface eth;
    eth.init();
    eth.connect();    
    
    Thread server(&server_thread);
    
    while(true){
      Thread::wait(1000);
      // Heartbeat.
      // The board systematically crashes after a low number of sends from a client,
      // e.g. ~10 times 1000 bytes, ~2-3 times 10000 bytes, etc.
      heartbeatLed = !heartbeatLed;
    }
}

Imports System.Net
Imports System.Net.Sockets
Imports System.Text

Public Class SynchronousSocketClient

    Public Shared Sub Main()
        Dim ipAddress As New IPAddress(New Byte() {192, 168, 100, 140})
        Dim remoteEP As New IPEndPoint(ipAddress, 11000)
        Dim sender As New Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp)

        ' Connect the socket to the remote endpoint.
        sender.Connect(remoteEP)
        sender.ReceiveTimeout = 1000 'In ms.

        ' 1000 chars.
        Dim msg As Byte() = Encoding.ASCII.GetBytes(StrDup(100, "1234567890"))

        ' Send the data through the socket.

        Dim sw As New Stopwatch()
        sw.Start()

        Dim bytesSent As Integer = sender.Send(msg)

        sw.Stop()

        Dim ms As Long = sw.ElapsedMilliseconds
        Console.WriteLine("Elapsed: " + ms.ToString + " ms.")

        ' Release the socket.
        sender.Shutdown(SocketShutdown.Both)
        sender.Close()

        Console.ReadKey()
    End Sub

End Class