diff options
| author | bernard.xiong <[email protected]> | 2010-03-01 09:39:28 +0000 |
|---|---|---|
| committer | bernard.xiong <[email protected]> | 2010-03-01 09:39:28 +0000 |
| commit | feec9197c41314931cd1978bb5e61e974e6deaba (patch) | |
| tree | 6b1b5abd87f66f26283a20f29250e6f97ba132ea /examples/network/tcpclient.c | |
| parent | 6ccd04543c7928151d9b4fb782470e7d8f3e1e14 (diff) | |
move TCP client/server and UDP client/server example to this directory.
git-svn-id: https://rt-thread.googlecode.com/svn/trunk@457 bbd45198-f89e-11dd-88c7-29a3b14d5316
Diffstat (limited to 'examples/network/tcpclient.c')
| -rw-r--r-- | examples/network/tcpclient.c | 81 |
1 files changed, 81 insertions, 0 deletions
diff --git a/examples/network/tcpclient.c b/examples/network/tcpclient.c new file mode 100644 index 0000000000..559a108d46 --- /dev/null +++ b/examples/network/tcpclient.c @@ -0,0 +1,81 @@ +#include <rtthread.h>
+#include <lwip/netdb.h>
+#include <lwip/sockets.h>
+
+static const char send_data[] = "This is TCP Client from RT-Thread.";
+void tcpclient(const char* url, int port)
+{
+ char *recv_data;
+ struct hostent *host;
+ int sock, bytes_received;
+ struct sockaddr_in server_addr;
+
+ host = gethostbyname(url);
+
+ recv_data = rt_malloc(1024);
+ if (recv_data == RT_NULL)
+ {
+ rt_kprintf("No memory\n");
+ return;
+ }
+
+ if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1)
+ {
+ rt_kprintf("Socket error\n");
+
+ /* release recv buffer */
+ rt_free(recv_data);
+ return;
+ }
+
+ server_addr.sin_family = AF_INET;
+ server_addr.sin_port = htons(port);
+ server_addr.sin_addr = *((struct in_addr *)host->h_addr);
+ rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));
+
+ if (connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1)
+ {
+ rt_kprintf("Connect error\n");
+
+ /* release recv buffer */
+ rt_free(recv_data);
+ return;
+ }
+
+ while(1)
+ {
+ bytes_received = recv(sock, recv_data, 1024, 0);
+ if (bytes_received < 0)
+ {
+ lwip_close(sock);
+
+ /* release recv buffer */
+ rt_free(recv_data);
+ break;
+ }
+
+ recv_data[bytes_received] = '\0';
+
+ if (strcmp(recv_data , "q") == 0 || strcmp(recv_data , "Q") == 0)
+ {
+ lwip_close(sock);
+
+ /* release recv buffer */
+ rt_free(recv_data);
+ break;
+ }
+ else
+ {
+ rt_kprintf("\nRecieved data = %s " , recv_data);
+ }
+
+ send(sock,send_data,strlen(send_data), 0);
+ }
+
+ return;
+}
+
+#ifdef RT_USING_FINSH
+#include <finsh.h>
+FINSH_FUNCTION_EXPORT(tcpclient, startup tcp client);
+#endif
|