Keith Ruenheck / MTS-Socket

increased chunk size

Dependencies:   HTTPClient-SSL

Fork of MTS-Socket by MultiTech

Test/TestUDPSocket.h@49:139d2c3e2765, 2016-02-04 (annotated)

Committer:
kruenhec
Date:
Thu Feb 04 17:43:02 2016 +0000
Revision:
49:139d2c3e2765
Parent:
35:c85bea9cb713 
Added hardware reset of modem, including the option from debugMenu=>SystemSetup

Who changed what in which revision?

UserRevisionLine numberNew contents of line
mfiore 9:b2e3862705fc 1 #ifndef TESTUDPSOCKET_H
mfiore 9:b2e3862705fc 2 #define TESTUDPSOCKET_H
mfiore 9:b2e3862705fc 3
mfiore 9:b2e3862705fc 4 #include "mtsas.h"
mfiore 9:b2e3862705fc 5
mfiore 9:b2e3862705fc 6 using namespace mts;
mfiore 9:b2e3862705fc 7
mfiore 9:b2e3862705fc 8 class TestUDPSocket : public TestCollection
mfiore 9:b2e3862705fc 9 {
mfiore 9:b2e3862705fc 10 public:
mfiore 9:b2e3862705fc 11 TestUDPSocket();
mfiore 9:b2e3862705fc 12 virtual void run();
mfiore 9:b2e3862705fc 13
mfiore 9:b2e3862705fc 14 private:
mfiore 9:b2e3862705fc 15 MTSSerialFlowControl* io;
mfiore 9:b2e3862705fc 16 Cellular* radio;
mfiore 9:b2e3862705fc 17 UDPSocket* sock;
mfiore 9:b2e3862705fc 18 };
mfiore 9:b2e3862705fc 19
Vanger 14:7643ed024fe8 20 //Must set test server and test port before running socket test
mfiore 9:b2e3862705fc 21 const char UDP_TEST_SERVER[] = "";
mfiore 9:b2e3862705fc 22 const int UDP_TEST_PORT = -1;
mfiore 9:b2e3862705fc 23
Vanger 14:7643ed024fe8 24 //Test pattern can be changed to any alphanumeric pattern wanted
mfiore 9:b2e3862705fc 25 const char TEST_PATTERN[] = "abcdefghijklmnopqrstuvwzyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890!@#$%^&*()[]{}|\r\n"
mfiore 9:b2e3862705fc 26 "abcdefghijklmnopqrstuvwzyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890!@#$%^&*()[]{}/\r\n"
mfiore 9:b2e3862705fc 27 "abcdefghijklmnopqrstuvwzyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890!@#$%^&*()[]{}-\r\n"
mfiore 9:b2e3862705fc 28 "abcdefghijklmnopqrstuvwzyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890!@#$%^&*()[]{}\\\r\n"
mfiore 9:b2e3862705fc 29 "abcdefghijklmnopqrstuvwzyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890!@#$%^&*()[]{}|\r\n"
mfiore 9:b2e3862705fc 30 "abcdefghijklmnopqrstuvwzyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890!@#$%^&*()[]{}/\r\n"
mfiore 9:b2e3862705fc 31 "abcdefghijklmnopqrstuvwzyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890!@#$%^&*()[]{}-\r\n"
mfiore 9:b2e3862705fc 32 "abcdefghijklmnopqrstuvwzyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890!@#$%^&*()[]{}\\\r\n"
mfiore 9:b2e3862705fc 33 "abcdefghijklmnopqrstuvwzyzABCDEFGHIJKLMNOPQRSTUVWXYZ1234567890!@#$%^&*()[]{}*\r\n";
mfiore 9:b2e3862705fc 34
mfiore 9:b2e3862705fc 35 TestUDPSocket::TestUDPSocket() : TestCollection("TestUDPSocket") {}
mfiore 9:b2e3862705fc 36
mfiore 9:b2e3862705fc 37 void TestUDPSocket::run() {
mfiore 10:42220b7df921 38
mfiore 9:b2e3862705fc 39 Endpoint remote;
mfiore 9:b2e3862705fc 40 remote.set_address(UDP_TEST_SERVER, UDP_TEST_PORT);
mfiore 9:b2e3862705fc 41
mfiore 9:b2e3862705fc 42 MTSLog::setLogLevel(MTSLog::TRACE_LEVEL);
mfiore 9:b2e3862705fc 43 Test::start("Setup");
mfiore 9:b2e3862705fc 44 io = new MTSSerialFlowControl(D8, D2, D3, D6);
mfiore 9:b2e3862705fc 45 io->baud(115200);
mfiore 9:b2e3862705fc 46 radio = CellularFactory::create(io);
mfiore 9:b2e3862705fc 47 if (! radio) {
mfiore 9:b2e3862705fc 48 Test::assertTrue(false);
mfiore 9:b2e3862705fc 49 }
mfiore 9:b2e3862705fc 50 radio->configureSignals(D4, D7, RESET);
mfiore 9:b2e3862705fc 51 Transport::setTransport(radio);
mfiore 9:b2e3862705fc 52
mfiore 9:b2e3862705fc 53 for (int i = 0; i < 10; i++) {
mfiore 9:b2e3862705fc 54 if (i >= 10) {
mfiore 9:b2e3862705fc 55 Test::assertTrue(false);
mfiore 9:b2e3862705fc 56 }
mfiore 12:9efe3cc3cb6c 57 if (radio->setApn(APN) == MTS_SUCCESS) {
mfiore 9:b2e3862705fc 58 break;
mfiore 9:b2e3862705fc 59 } else {
mfiore 9:b2e3862705fc 60 wait(1);
mfiore 9:b2e3862705fc 61 }
mfiore 9:b2e3862705fc 62 }
Vanger 14:7643ed024fe8 63
mfiore 9:b2e3862705fc 64 for (int i = 0; i < 3; i++) {
mfiore 9:b2e3862705fc 65 if (i >= 3) {
mfiore 9:b2e3862705fc 66 Test::assertTrue(false);
mfiore 9:b2e3862705fc 67 }
mfiore 9:b2e3862705fc 68 if (radio->connect()) {
mfiore 9:b2e3862705fc 69 break;
mfiore 9:b2e3862705fc 70 } else {
mfiore 9:b2e3862705fc 71 wait(1);
mfiore 9:b2e3862705fc 72 }
mfiore 9:b2e3862705fc 73 }
mfiore 9:b2e3862705fc 74
mfiore 9:b2e3862705fc 75 for (int i = 0; i < 5; i++) {
mfiore 9:b2e3862705fc 76 if (i >= 5) {
mfiore 9:b2e3862705fc 77 Test::assertTrue(false);
mfiore 9:b2e3862705fc 78 }
mfiore 9:b2e3862705fc 79 if (radio->ping()) {
mfiore 9:b2e3862705fc 80 break;
mfiore 9:b2e3862705fc 81 } else {
mfiore 9:b2e3862705fc 82 wait(1);
mfiore 9:b2e3862705fc 83 }
mfiore 9:b2e3862705fc 84 }
mfiore 9:b2e3862705fc 85
mfiore 9:b2e3862705fc 86 sock = new UDPSocket();
Vanger 14:7643ed024fe8 87 sock->set_blocking(false, 20000);
mfiore 9:b2e3862705fc 88 Test::end();
mfiore 9:b2e3862705fc 89
Vanger 14:7643ed024fe8 90 /** set up an UDP echo server using netcat
mfiore 9:b2e3862705fc 91 * nc -e /bin/cat -l -u -p TEST_PORT
Vanger 14:7643ed024fe8 92 * this should echo back anything you send to it.
Vanger 14:7643ed024fe8 93 * Note: Listen port might close after each UDP packet
Vanger 14:7643ed024fe8 94 * if testing UIP-type radios.
mfiore 9:b2e3862705fc 95 */
mfiore 9:b2e3862705fc 96
mfiore 9:b2e3862705fc 97 int bufsize = 1024;
mfiore 9:b2e3862705fc 98 char buf[bufsize];
mfiore 9:b2e3862705fc 99 int size = 0;
mfiore 9:b2e3862705fc 100
mfiore 9:b2e3862705fc 101 for (int i = 0; i < 10; i++) {
mfiore 9:b2e3862705fc 102 Test::start("Test UDP");
mfiore 9:b2e3862705fc 103 logInfo("sending to remote");
mfiore 9:b2e3862705fc 104 size = sock->sendTo(remote, (char*) TEST_PATTERN, sizeof(TEST_PATTERN));
mfiore 9:b2e3862705fc 105 if (size != sizeof(TEST_PATTERN)) {
mfiore 9:b2e3862705fc 106 logError("failed to send - only sent %d bytes", size);
mfiore 9:b2e3862705fc 107 Test::assertTrue(false);
mfiore 9:b2e3862705fc 108 }
mfiore 9:b2e3862705fc 109 logInfo("receiving from remote");
mfiore 9:b2e3862705fc 110 size = sock->receiveFrom(remote, buf, bufsize);
mfiore 9:b2e3862705fc 111 if (size != sizeof(TEST_PATTERN)) {
mfiore 9:b2e3862705fc 112 logError("failed to receive - only received %d bytes", size);
mfiore 9:b2e3862705fc 113 Test::assertTrue(false);
mfiore 9:b2e3862705fc 114 } else {
mfiore 9:b2e3862705fc 115 for (int j = 0; j < sizeof(TEST_PATTERN); j++) {
mfiore 9:b2e3862705fc 116 if (buf[j] != TEST_PATTERN[j]) {
mfiore 9:b2e3862705fc 117 logError("patterns don't match at %d, pattern [%#02X] received [%#02X]", j, TEST_PATTERN[j], buf[j]);
mfiore 9:b2e3862705fc 118 Test::assertTrue(false);
mfiore 9:b2e3862705fc 119 }
mfiore 9:b2e3862705fc 120 }
mfiore 9:b2e3862705fc 121 }
mfiore 9:b2e3862705fc 122 Test::end();
mfiore 9:b2e3862705fc 123 }
Vanger 14:7643ed024fe8 124 sock->close();
Vanger 14:7643ed024fe8 125 radio->disconnect();
mfiore 9:b2e3862705fc 126 }
mfiore 9:b2e3862705fc 127
mfiore 9:b2e3862705fc 128 #endif