Multi-Hackers / SocketModem

A library for talking to Multi-Tech's Cellular SocketModem Devices.

Dependents:   M2X_dev axeda_wrapper_dev MTS_M2x_Example1 MTS_Cellular_Connect_Example ... more

tests/test_TCP_Socket_Echo.h@68:c490e4a51778, 2013-12-24 (annotated)

Committer:
sgodinez
Date:
Tue Dec 24 01:15:44 2013 +0000
Revision:
68:c490e4a51778
Parent:
55:56d9a9d98079
Child:
71:82205735732b
Moved timeout functionality to MTSBufferedIO calls. Improved sendCmd.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
sgodinez 41:81d035fb0b6a 1 #ifndef _TEST_TCP_SOCKET_ECHO_H_
sgodinez 41:81d035fb0b6a 2 #define _TEST_TCP_SOCKET_ECHO_H_
sgodinez 41:81d035fb0b6a 3
sgodinez 41:81d035fb0b6a 4
sgodinez 41:81d035fb0b6a 5 //Setup a netcat server with command: ncat -l 5798 -k -c 'xargs -n1 --null echo'
sgodinez 68:c490e4a51778 6 bool testTcpSocketEchoLoop();
sgodinez 41:81d035fb0b6a 7
sgodinez 41:81d035fb0b6a 8 void testTcpSocketEcho() {
sgodinez 44:86fa8f50a1df 9 using namespace mts;
sgodinez 44:86fa8f50a1df 10
sgodinez 41:81d035fb0b6a 11 Cellular::Code code;
sgodinez 41:81d035fb0b6a 12 const int TEST_PORT = 5798;
sgodinez 41:81d035fb0b6a 13 const std::string TEST_SERVER("204.26.122.96");
sgodinez 41:81d035fb0b6a 14
sgodinez 41:81d035fb0b6a 15 printf("TCP SOCKET TESTING\r\n");
sgodinez 41:81d035fb0b6a 16 printf("Setting APN\r\n");
sgodinez 41:81d035fb0b6a 17 code = Cellular::getInstance()->setApn("b2b.tmobile.com");
sgodinez 44:86fa8f50a1df 18 if(code == Cellular::CELL_OK) {
sgodinez 41:81d035fb0b6a 19 printf("Success!\r\n");
sgodinez 41:81d035fb0b6a 20 } else {
sgodinez 41:81d035fb0b6a 21 printf("Error during APN setup [%d]\r\n", (int)code);
sgodinez 41:81d035fb0b6a 22 }
sgodinez 41:81d035fb0b6a 23
sgodinez 41:81d035fb0b6a 24 printf("Setting Socket Closeable\r\n");
sgodinez 41:81d035fb0b6a 25 code = Cellular::getInstance()->setSocketCloseable();
sgodinez 44:86fa8f50a1df 26 if(code == Cellular::CELL_OK) {
sgodinez 41:81d035fb0b6a 27 printf("Success!\r\n");
sgodinez 41:81d035fb0b6a 28 } else {
sgodinez 41:81d035fb0b6a 29 printf("Error setting socket closeable [%d]\r\n", (int)code);
sgodinez 41:81d035fb0b6a 30 }
sgodinez 41:81d035fb0b6a 31
sgodinez 53:27c9622de0f9 32 printf("Setting Local Port\r\n");
sgodinez 53:27c9622de0f9 33 if(Cellular::getInstance()->bind(5000)) {
sgodinez 53:27c9622de0f9 34 printf("Success!\r\n");
sgodinez 53:27c9622de0f9 35 } else {
sgodinez 53:27c9622de0f9 36 printf("Error setting local port [%d]\r\n", (int)code);
sgodinez 53:27c9622de0f9 37 }
sgodinez 53:27c9622de0f9 38
sgodinez 53:27c9622de0f9 39 printf("Setting Primary DNS\r\n");
sgodinez 53:27c9622de0f9 40 code = Cellular::getInstance()->setDns("8.8.8.8");
sgodinez 53:27c9622de0f9 41 if(code == Cellular::CELL_OK) {
sgodinez 53:27c9622de0f9 42 printf("Success!\r\n");
sgodinez 53:27c9622de0f9 43 } else {
sgodinez 53:27c9622de0f9 44 printf("Error setting primary DNS [%d]\r\n", (int)code);
sgodinez 53:27c9622de0f9 45 }
sgodinez 53:27c9622de0f9 46
sgodinez 41:81d035fb0b6a 47 printf("Establishing PPP Connection\r\n");
sgodinez 41:81d035fb0b6a 48 if(Cellular::getInstance()->connect()) {
sgodinez 41:81d035fb0b6a 49 printf("Success!\r\n");
sgodinez 41:81d035fb0b6a 50 } else {
sgodinez 55:56d9a9d98079 51 printf("Error during PPP connection. Aborting.\r\n");
sgodinez 55:56d9a9d98079 52 return;
sgodinez 41:81d035fb0b6a 53 }
sgodinez 41:81d035fb0b6a 54
sgodinez 41:81d035fb0b6a 55 printf("Opening a TCP Socket\r\n");
sgodinez 41:81d035fb0b6a 56 if(Cellular::getInstance()->open(TEST_SERVER, TEST_PORT, IPStack::TCP)) {
sgodinez 41:81d035fb0b6a 57 printf("Success!\r\n");
sgodinez 41:81d035fb0b6a 58 } else {
sgodinez 55:56d9a9d98079 59 printf("Error during TCP socket open [%s:%d]. Aborting.\r\n", TEST_SERVER.c_str(), TEST_PORT);
sgodinez 55:56d9a9d98079 60 return;
sgodinez 41:81d035fb0b6a 61 }
sgodinez 41:81d035fb0b6a 62
sgodinez 68:c490e4a51778 63 int count = 0;
sgodinez 68:c490e4a51778 64 while(testTcpSocketEchoLoop()) {
sgodinez 68:c490e4a51778 65 count++;
sgodinez 68:c490e4a51778 66 printf("Successful Echos: [%d]\r\n", count);
sgodinez 68:c490e4a51778 67 }
sgodinez 68:c490e4a51778 68
sgodinez 68:c490e4a51778 69 printf("Closing socket\r\n");
sgodinez 68:c490e4a51778 70 Cellular::getInstance()->close();
sgodinez 68:c490e4a51778 71
sgodinez 68:c490e4a51778 72
sgodinez 68:c490e4a51778 73 //printf("Disconnecting\r\n");
sgodinez 68:c490e4a51778 74 // Cellular::getInstance()->disconnect();
sgodinez 68:c490e4a51778 75 }
sgodinez 68:c490e4a51778 76
sgodinez 68:c490e4a51778 77 bool testTcpSocketEchoLoop() {
sgodinez 68:c490e4a51778 78 const char buffer[] = "*ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz1234567890*";
sgodinez 68:c490e4a51778 79 const int size = sizeof(buffer);
sgodinez 68:c490e4a51778 80 char echoData[size];
sgodinez 68:c490e4a51778 81
sgodinez 41:81d035fb0b6a 82 printf("Sending buffer\r\n");
sgodinez 41:81d035fb0b6a 83 int bytesWritten = Cellular::getInstance()->write(buffer, size, 10000);
sgodinez 41:81d035fb0b6a 84 if(bytesWritten == size) {
sgodinez 41:81d035fb0b6a 85 printf("Successfully sent buffer\r\n");
sgodinez 41:81d035fb0b6a 86 } else {
sgodinez 55:56d9a9d98079 87 printf("Failed to send buffer. Closing socket and aborting.\r\n");
sgodinez 55:56d9a9d98079 88 Cellular::getInstance()->close();
sgodinez 68:c490e4a51778 89 return false;
sgodinez 41:81d035fb0b6a 90 }
sgodinez 41:81d035fb0b6a 91
sgodinez 41:81d035fb0b6a 92 printf("Receiving echo (timeout = 15 seconds)\r\n");
sgodinez 41:81d035fb0b6a 93 Timer tmr;
sgodinez 41:81d035fb0b6a 94 int bytesRead = 0;
sgodinez 41:81d035fb0b6a 95 tmr.start();
sgodinez 41:81d035fb0b6a 96 do {
sgodinez 55:56d9a9d98079 97 int status = Cellular::getInstance()->read(&echoData[bytesRead], size - bytesRead, 1000);
sgodinez 55:56d9a9d98079 98 if(status != -1) {
sgodinez 55:56d9a9d98079 99 bytesRead += status;
sgodinez 55:56d9a9d98079 100 } else {
sgodinez 55:56d9a9d98079 101 printf("Error reading from socket. Closing socket and aborting.\r\n");
sgodinez 55:56d9a9d98079 102 Cellular::getInstance()->close();
sgodinez 68:c490e4a51778 103 return false;
sgodinez 55:56d9a9d98079 104 }
sgodinez 41:81d035fb0b6a 105 printf("Total bytes read %d\r\n", bytesRead);
sgodinez 41:81d035fb0b6a 106 } while (tmr.read_ms() <= 15000 && bytesRead < size);
sgodinez 41:81d035fb0b6a 107
sgodinez 55:56d9a9d98079 108
sgodinez 41:81d035fb0b6a 109 //Safely Cap at Max Size
sgodinez 41:81d035fb0b6a 110 echoData[size - 1] = '\0';
sgodinez 41:81d035fb0b6a 111 printf("Comparing Buffers\r\n");
sgodinez 68:c490e4a51778 112 printf("SENT [%d]: [%s]\r\n", size, buffer);
sgodinez 68:c490e4a51778 113 printf("RECV [%d]: [%s]\r\n", bytesRead, echoData);
sgodinez 41:81d035fb0b6a 114
sgodinez 41:81d035fb0b6a 115 for(int i = 0; i < size - 1; i++) {
sgodinez 41:81d035fb0b6a 116 if(buffer[i] != echoData[i]) {
sgodinez 41:81d035fb0b6a 117 printf("Buffers do not match at index %d\r\n", i);
sgodinez 68:c490e4a51778 118 return false;
sgodinez 41:81d035fb0b6a 119 }
sgodinez 68:c490e4a51778 120 }
sgodinez 68:c490e4a51778 121 return true;
sgodinez 41:81d035fb0b6a 122 }
sgodinez 41:81d035fb0b6a 123
sgodinez 41:81d035fb0b6a 124 #endif