mirror of https://github.com/ARMmbed/mbed-os.git
Added NET_13 TCP client echo loop host test to test automation suite
parent
65be1ee4a1
commit
c33b744fa5
|
@ -1,34 +1,69 @@
|
||||||
#include "mbed.h"
|
#include "mbed.h"
|
||||||
#include "EthernetInterface.h"
|
#include "EthernetInterface.h"
|
||||||
|
|
||||||
const char* ECHO_SERVER_ADDRESS = "10.2.200.57";
|
struct s_ip_address
|
||||||
const int ECHO_PORT = 7;
|
{
|
||||||
|
int ip_1;
|
||||||
|
int ip_2;
|
||||||
|
int ip_3;
|
||||||
|
int ip_4;
|
||||||
|
};
|
||||||
|
|
||||||
|
#define MAX_ECHO_LOOPS 100
|
||||||
|
|
||||||
int main() {
|
int main() {
|
||||||
|
char buffer[256] = {0};
|
||||||
|
char out_buffer[] = "Hello World\n";
|
||||||
|
char out_success[] = "{{success}}\n{{end}}\n";
|
||||||
|
char out_failure[] = "{{failure}}\n{{end}}\n";
|
||||||
|
s_ip_address ip_addr = {0, 0, 0, 0};
|
||||||
|
int port = 0;
|
||||||
|
|
||||||
|
printf("TCPCllient waiting for server IP and port...\r\n");
|
||||||
|
scanf("%d.%d.%d.%d:%d", &ip_addr.ip_1, &ip_addr.ip_2, &ip_addr.ip_3, &ip_addr.ip_4, &port);
|
||||||
|
printf("Address received:%d.%d.%d.%d:%d\r\n", ip_addr.ip_1, ip_addr.ip_2, ip_addr.ip_3, ip_addr.ip_4, port);
|
||||||
|
|
||||||
EthernetInterface eth;
|
EthernetInterface eth;
|
||||||
eth.init(); //Use DHCP
|
eth.init(); //Use DHCP
|
||||||
eth.connect();
|
eth.connect();
|
||||||
printf("IP Address is %s\n", eth.getIPAddress());
|
|
||||||
|
printf("TCPClient IP Address is %s\r\n", eth.getIPAddress());
|
||||||
|
sprintf(buffer, "%d.%d.%d.%d", ip_addr.ip_1, ip_addr.ip_2, ip_addr.ip_3, ip_addr.ip_4);
|
||||||
|
|
||||||
TCPSocketConnection socket;
|
TCPSocketConnection socket;
|
||||||
|
while (socket.connect(buffer, port) < 0) {
|
||||||
while (true) {
|
printf("TCPCllient unable to connect to %s:%d\r\n", buffer, port);
|
||||||
while (socket.connect(ECHO_SERVER_ADDRESS, ECHO_PORT) < 0) {
|
|
||||||
printf("Unable to connect to (%s) on port (%d)\n", ECHO_SERVER_ADDRESS, ECHO_PORT);
|
|
||||||
wait(1);
|
|
||||||
}
|
|
||||||
|
|
||||||
char hello[] = "Hello World\n";
|
|
||||||
socket.send_all(hello, sizeof(hello) - 1);
|
|
||||||
|
|
||||||
char buf[256];
|
|
||||||
int n = socket.receive(buf, 256);
|
|
||||||
buf[n] = '\0';
|
|
||||||
printf("%s", buf);
|
|
||||||
|
|
||||||
socket.close();
|
|
||||||
wait(1);
|
wait(1);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Test loop for multiple client conenctions
|
||||||
|
bool result = true;
|
||||||
|
int count_error = 0;
|
||||||
|
for (int i = 0; i < MAX_ECHO_LOOPS; i++) {
|
||||||
|
socket.send_all(out_buffer, sizeof(out_buffer) - 1);
|
||||||
|
|
||||||
|
int n = socket.receive(buffer, sizeof(buffer));
|
||||||
|
if (n > 0)
|
||||||
|
{
|
||||||
|
buffer[n] = '\0';
|
||||||
|
printf("%s", buffer);
|
||||||
|
bool echoed = strncmp(out_buffer, buffer, sizeof(out_buffer) - 1) == 0;
|
||||||
|
result = result && echoed;
|
||||||
|
if (echoed == false) {
|
||||||
|
count_error++; // Count error messages
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
printf("Loop messages passed: %d/%d\r\n", MAX_ECHO_LOOPS - count_error, MAX_ECHO_LOOPS);
|
||||||
|
|
||||||
|
if (result) {
|
||||||
|
socket.send_all(out_success, sizeof(out_success) - 1);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
socket.send_all(out_failure, sizeof(out_failure) - 1);
|
||||||
|
}
|
||||||
|
socket.close();
|
||||||
eth.disconnect();
|
eth.disconnect();
|
||||||
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
|
@ -660,6 +660,8 @@ TESTS = [
|
||||||
"id": "NET_13", "description": "TCP client echo loop",
|
"id": "NET_13", "description": "TCP client echo loop",
|
||||||
"source_dir": join(TEST_DIR, "net", "echo", "tcp_client_loop"),
|
"source_dir": join(TEST_DIR, "net", "echo", "tcp_client_loop"),
|
||||||
"dependencies": [MBED_LIBRARIES, RTOS_LIBRARIES, ETH_LIBRARY],
|
"dependencies": [MBED_LIBRARIES, RTOS_LIBRARIES, ETH_LIBRARY],
|
||||||
|
"automated": True,
|
||||||
|
"duration": 15,
|
||||||
"peripherals": ["ethernet"],
|
"peripherals": ["ethernet"],
|
||||||
},
|
},
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue