WizFi250 Tcp Udp Example
Dependencies: WizFi250Interface mbed
Fork of WizFi250TcpUdpExample by
src/main.cpp@0:279f250818f6, 2014-06-03 (annotated)
- Committer:
- kaizen
- Date:
- Tue Jun 03 01:00:04 2014 +0000
- Revision:
- 0:279f250818f6
- Child:
- 1:c0b6bfde0ea9
WizFi250 Library TCP UDP Example
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
kaizen | 0:279f250818f6 | 1 | /* |
kaizen | 0:279f250818f6 | 2 | /* Copyright (C) 2014 Wiznet, MIT License |
kaizen | 0:279f250818f6 | 3 | * |
kaizen | 0:279f250818f6 | 4 | * Permission is hereby granted, free of charge, to any person obtaining a copy of this software |
kaizen | 0:279f250818f6 | 5 | * and associated documentation files (the "Software"), to deal in the Software without restriction, |
kaizen | 0:279f250818f6 | 6 | * including without limitation the rights to use, copy, modify, merge, publish, distribute, |
kaizen | 0:279f250818f6 | 7 | * sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is |
kaizen | 0:279f250818f6 | 8 | * furnished to do so, subject to the following conditions: |
kaizen | 0:279f250818f6 | 9 | * |
kaizen | 0:279f250818f6 | 10 | * The above copyright notice and this permission notice shall be included in all copies or |
kaizen | 0:279f250818f6 | 11 | * substantial portions of the Software. |
kaizen | 0:279f250818f6 | 12 | * |
kaizen | 0:279f250818f6 | 13 | * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING |
kaizen | 0:279f250818f6 | 14 | * BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND |
kaizen | 0:279f250818f6 | 15 | * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, |
kaizen | 0:279f250818f6 | 16 | * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, |
kaizen | 0:279f250818f6 | 17 | * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. |
kaizen | 0:279f250818f6 | 18 | */ |
kaizen | 0:279f250818f6 | 19 | |
kaizen | 0:279f250818f6 | 20 | #include <stdio.h> |
kaizen | 0:279f250818f6 | 21 | #include "mbed.h" |
kaizen | 0:279f250818f6 | 22 | #include "WizFi250Interface.h" |
kaizen | 0:279f250818f6 | 23 | |
kaizen | 0:279f250818f6 | 24 | #define TARGET_FRDM_KL25Z |
kaizen | 0:279f250818f6 | 25 | #define SECURE WizFi250::SEC_AUTO |
kaizen | 0:279f250818f6 | 26 | #define SSID "WiznetKaizen" |
kaizen | 0:279f250818f6 | 27 | #define PASS "12345678" |
kaizen | 0:279f250818f6 | 28 | |
kaizen | 0:279f250818f6 | 29 | #define ECHO_SERVER_ADDRESS "192.168.15.14" |
kaizen | 0:279f250818f6 | 30 | #define ECHO_SERVER_PORT 5000 |
kaizen | 0:279f250818f6 | 31 | |
kaizen | 0:279f250818f6 | 32 | #define FEED_HOST "api.xively.com" |
kaizen | 0:279f250818f6 | 33 | #define FEED_ID "EUHFMSwZj8pDdE6jKZgooDt3vlDivDy6srpKgbfE0rgdnZ3D" |
kaizen | 0:279f250818f6 | 34 | #define API_KEY "827175846" |
kaizen | 0:279f250818f6 | 35 | |
kaizen | 0:279f250818f6 | 36 | void testUdpEchoClient(); |
kaizen | 0:279f250818f6 | 37 | void testUdpEchoServer(); |
kaizen | 0:279f250818f6 | 38 | void testTcpEchoClient(); |
kaizen | 0:279f250818f6 | 39 | void testTcpEchoServer(); |
kaizen | 0:279f250818f6 | 40 | |
kaizen | 0:279f250818f6 | 41 | int main() |
kaizen | 0:279f250818f6 | 42 | { |
kaizen | 0:279f250818f6 | 43 | int i; |
kaizen | 0:279f250818f6 | 44 | char input; |
kaizen | 0:279f250818f6 | 45 | |
kaizen | 0:279f250818f6 | 46 | WizFi250Interface wizfi250(PTE0,PTE1,PTD5,PTD0,PTD4,NC,115200); |
kaizen | 0:279f250818f6 | 47 | wizfi250.init(); |
kaizen | 0:279f250818f6 | 48 | if ( wizfi250.connect(SECURE, SSID, PASS)) return -1; |
kaizen | 0:279f250818f6 | 49 | printf("IP Address is %s\r\n", wizfi250.getIPAddress()); |
kaizen | 0:279f250818f6 | 50 | |
kaizen | 0:279f250818f6 | 51 | |
kaizen | 0:279f250818f6 | 52 | while(1) |
kaizen | 0:279f250818f6 | 53 | { |
kaizen | 0:279f250818f6 | 54 | printf("\r\nInput Test Mode ( 1:)\r\n"); |
kaizen | 0:279f250818f6 | 55 | scanf("%c",&input); |
kaizen | 0:279f250818f6 | 56 | |
kaizen | 0:279f250818f6 | 57 | if(input == 'q') |
kaizen | 0:279f250818f6 | 58 | break; |
kaizen | 0:279f250818f6 | 59 | |
kaizen | 0:279f250818f6 | 60 | switch(input) |
kaizen | 0:279f250818f6 | 61 | { |
kaizen | 0:279f250818f6 | 62 | case '1': |
kaizen | 0:279f250818f6 | 63 | testTcpEchoServer(); |
kaizen | 0:279f250818f6 | 64 | break; |
kaizen | 0:279f250818f6 | 65 | case '2': |
kaizen | 0:279f250818f6 | 66 | testTcpEchoClient(); |
kaizen | 0:279f250818f6 | 67 | break; |
kaizen | 0:279f250818f6 | 68 | case '3': |
kaizen | 0:279f250818f6 | 69 | testUdpEchoClient(); |
kaizen | 0:279f250818f6 | 70 | break; |
kaizen | 0:279f250818f6 | 71 | case '4': |
kaizen | 0:279f250818f6 | 72 | testUdpEchoServer(); |
kaizen | 0:279f250818f6 | 73 | break; |
kaizen | 0:279f250818f6 | 74 | } |
kaizen | 0:279f250818f6 | 75 | } |
kaizen | 0:279f250818f6 | 76 | |
kaizen | 0:279f250818f6 | 77 | printf("End the test program\r\n"); |
kaizen | 0:279f250818f6 | 78 | } |
kaizen | 0:279f250818f6 | 79 | |
kaizen | 0:279f250818f6 | 80 | |
kaizen | 0:279f250818f6 | 81 | void testTcpEchoServer() |
kaizen | 0:279f250818f6 | 82 | { |
kaizen | 0:279f250818f6 | 83 | char buffer[1024]; |
kaizen | 0:279f250818f6 | 84 | int n = 0; |
kaizen | 0:279f250818f6 | 85 | |
kaizen | 0:279f250818f6 | 86 | TCPSocketServer server; |
kaizen | 0:279f250818f6 | 87 | server.bind(ECHO_SERVER_PORT); |
kaizen | 0:279f250818f6 | 88 | server.listen(); |
kaizen | 0:279f250818f6 | 89 | |
kaizen | 0:279f250818f6 | 90 | printf("\nWait for new connection...\r\n"); |
kaizen | 0:279f250818f6 | 91 | TCPSocketConnection client; |
kaizen | 0:279f250818f6 | 92 | server.accept(client); |
kaizen | 0:279f250818f6 | 93 | client.set_blocking(false, 1500); |
kaizen | 0:279f250818f6 | 94 | |
kaizen | 0:279f250818f6 | 95 | printf("Connection from: %s\r\n", client.get_address()); |
kaizen | 0:279f250818f6 | 96 | while (true) |
kaizen | 0:279f250818f6 | 97 | { |
kaizen | 0:279f250818f6 | 98 | if( client.is_connected() == false ) |
kaizen | 0:279f250818f6 | 99 | { |
kaizen | 0:279f250818f6 | 100 | client.close(); |
kaizen | 0:279f250818f6 | 101 | break; |
kaizen | 0:279f250818f6 | 102 | } |
kaizen | 0:279f250818f6 | 103 | |
kaizen | 0:279f250818f6 | 104 | n = client.receive_all(buffer, sizeof(buffer)); |
kaizen | 0:279f250818f6 | 105 | if ( n > 0 ) |
kaizen | 0:279f250818f6 | 106 | { |
kaizen | 0:279f250818f6 | 107 | buffer[n] = '\0'; |
kaizen | 0:279f250818f6 | 108 | printf("length : %d\r\n", n); |
kaizen | 0:279f250818f6 | 109 | |
kaizen | 0:279f250818f6 | 110 | client.send_all(buffer, n); |
kaizen | 0:279f250818f6 | 111 | } |
kaizen | 0:279f250818f6 | 112 | } |
kaizen | 0:279f250818f6 | 113 | } |
kaizen | 0:279f250818f6 | 114 | |
kaizen | 0:279f250818f6 | 115 | void testUdpEchoClient() |
kaizen | 0:279f250818f6 | 116 | { |
kaizen | 0:279f250818f6 | 117 | int i; |
kaizen | 0:279f250818f6 | 118 | UDPSocket sock; |
kaizen | 0:279f250818f6 | 119 | sock.init(); |
kaizen | 0:279f250818f6 | 120 | |
kaizen | 0:279f250818f6 | 121 | Endpoint echo_server; |
kaizen | 0:279f250818f6 | 122 | echo_server.set_address(ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT); |
kaizen | 0:279f250818f6 | 123 | |
kaizen | 0:279f250818f6 | 124 | |
kaizen | 0:279f250818f6 | 125 | for(i=0;i<10;i++) |
kaizen | 0:279f250818f6 | 126 | { |
kaizen | 0:279f250818f6 | 127 | char out_buffer[] = "Hello World\n"; |
kaizen | 0:279f250818f6 | 128 | sock.sendTo(echo_server, out_buffer, sizeof(out_buffer)); |
kaizen | 0:279f250818f6 | 129 | |
kaizen | 0:279f250818f6 | 130 | char in_buffer[256]; |
kaizen | 0:279f250818f6 | 131 | int n = sock.receiveFrom(echo_server, in_buffer, sizeof(in_buffer)); |
kaizen | 0:279f250818f6 | 132 | in_buffer[n] = '\0'; |
kaizen | 0:279f250818f6 | 133 | |
kaizen | 0:279f250818f6 | 134 | if( n > 0 ) |
kaizen | 0:279f250818f6 | 135 | printf("%s\r\n", in_buffer); |
kaizen | 0:279f250818f6 | 136 | } |
kaizen | 0:279f250818f6 | 137 | |
kaizen | 0:279f250818f6 | 138 | sock.close(); |
kaizen | 0:279f250818f6 | 139 | } |
kaizen | 0:279f250818f6 | 140 | |
kaizen | 0:279f250818f6 | 141 | |
kaizen | 0:279f250818f6 | 142 | void testUdpEchoServer() |
kaizen | 0:279f250818f6 | 143 | { |
kaizen | 0:279f250818f6 | 144 | UDPSocket server; |
kaizen | 0:279f250818f6 | 145 | server.set_blocking(false); |
kaizen | 0:279f250818f6 | 146 | server.bind(ECHO_SERVER_PORT); |
kaizen | 0:279f250818f6 | 147 | |
kaizen | 0:279f250818f6 | 148 | Endpoint client; |
kaizen | 0:279f250818f6 | 149 | char buffer[256]; |
kaizen | 0:279f250818f6 | 150 | while(true) |
kaizen | 0:279f250818f6 | 151 | { |
kaizen | 0:279f250818f6 | 152 | int n = server.receiveFrom(client, buffer, sizeof(buffer)); |
kaizen | 0:279f250818f6 | 153 | if(n > 0) |
kaizen | 0:279f250818f6 | 154 | { |
kaizen | 0:279f250818f6 | 155 | //INFO("Received packet from: %s\n", client.get_address()); |
kaizen | 0:279f250818f6 | 156 | buffer[n] = '\0'; |
kaizen | 0:279f250818f6 | 157 | printf("%s\r\n", buffer); |
kaizen | 0:279f250818f6 | 158 | server.sendTo(client, buffer, n); |
kaizen | 0:279f250818f6 | 159 | break; |
kaizen | 0:279f250818f6 | 160 | } |
kaizen | 0:279f250818f6 | 161 | } |
kaizen | 0:279f250818f6 | 162 | } |
kaizen | 0:279f250818f6 | 163 | |
kaizen | 0:279f250818f6 | 164 | |
kaizen | 0:279f250818f6 | 165 | void testTcpEchoClient() |
kaizen | 0:279f250818f6 | 166 | { |
kaizen | 0:279f250818f6 | 167 | char buffer[512]; |
kaizen | 0:279f250818f6 | 168 | TCPSocketConnection socket; |
kaizen | 0:279f250818f6 | 169 | |
kaizen | 0:279f250818f6 | 170 | while (socket.connect(ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT) < 0) |
kaizen | 0:279f250818f6 | 171 | { |
kaizen | 0:279f250818f6 | 172 | printf("Unable to connect to (%s) on port (%d)\r\n", ECHO_SERVER_ADDRESS, ECHO_SERVER_PORT); |
kaizen | 0:279f250818f6 | 173 | wait(1); |
kaizen | 0:279f250818f6 | 174 | } |
kaizen | 0:279f250818f6 | 175 | |
kaizen | 0:279f250818f6 | 176 | while(true) |
kaizen | 0:279f250818f6 | 177 | { |
kaizen | 0:279f250818f6 | 178 | int n = socket.receive(buffer, sizeof(buffer)); |
kaizen | 0:279f250818f6 | 179 | if(n > 0) |
kaizen | 0:279f250818f6 | 180 | { |
kaizen | 0:279f250818f6 | 181 | buffer[n] = '\0'; |
kaizen | 0:279f250818f6 | 182 | printf("%s\r\n",buffer); |
kaizen | 0:279f250818f6 | 183 | socket.send(buffer, strlen(buffer)); |
kaizen | 0:279f250818f6 | 184 | //socket.send_all(buffer, sizeof(buffer)-1); |
kaizen | 0:279f250818f6 | 185 | break; |
kaizen | 0:279f250818f6 | 186 | } |
kaizen | 0:279f250818f6 | 187 | } |
kaizen | 0:279f250818f6 | 188 | |
kaizen | 0:279f250818f6 | 189 | socket.close(); |
kaizen | 0:279f250818f6 | 190 | } |