diff options
| author | bernard.xiong <[email protected]> | 2010-04-01 12:58:29 +0000 |
|---|---|---|
| committer | bernard.xiong <[email protected]> | 2010-04-01 12:58:29 +0000 |
| commit | 6c83bee27f611040de051a17ed79dcc72ffa6838 (patch) | |
| tree | edcb9ac1d9e42b1e0c3fa344727842b324159af7 /examples/network/tcpsendpacket.c | |
| parent | 8f431e61bb136b67a873e03b83c3cec88efe7a8d (diff) | |
add TCP client send test.
git-svn-id: https://rt-thread.googlecode.com/svn/trunk@571 bbd45198-f89e-11dd-88c7-29a3b14d5316
Diffstat (limited to 'examples/network/tcpsendpacket.c')
| -rw-r--r-- | examples/network/tcpsendpacket.c | 63 |
1 files changed, 63 insertions, 0 deletions
diff --git a/examples/network/tcpsendpacket.c b/examples/network/tcpsendpacket.c new file mode 100644 index 0000000000..328b9df7c9 --- /dev/null +++ b/examples/network/tcpsendpacket.c @@ -0,0 +1,63 @@ +#include <rtthread.h>
+#include <lwip/netdb.h> /* Ϊ�˽�������������Ҫ����netdb.hͷ�ļ� */
+#include <lwip/sockets.h> /* ʹ��BSD socket����Ҫ����sockets.hͷ�ļ� */
+
+void tcp_senddata(const char* url, int port, int length)
+{
+ struct hostent *host;
+ int sock, err, result, timeout, index;
+ struct sockaddr_in server_addr;
+ rt_uint8_t *buffer_ptr;
+
+ /* ͨ��������ڲ���url���host��ַ��������������������������� */
+ host = gethostbyname(url);
+ /* ����һ��socket��������SOCKET_STREAM��TCP���� */
+ if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1)
+ {
+ /* ����socketʧ�� */
+ rt_kprintf("Socket error\n");
+ return;
+ }
+
+ /* �����ڴ� */
+ buffer_ptr = rt_malloc(length);
+ /* ���췢������ */
+ for (index = 0; index < length; index ++)
+ buffer_ptr[index] = index & 0xff;
+
+ timeout = 100;
+ /* ���÷��ͳ�ʱʱ��100ms */
+ lwip_setsockopt(sock, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout));
+ /* ��ʼ��Ԥ���ӵķ���˵�ַ */
+ 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));
+
+ /* ���ӵ������ */
+ err = connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr));
+ rt_kprintf("TCP thread connect error code: %d\n", err);
+
+ while(1)
+ {
+ /* �������ݵ�sock���� */
+ result = send(sock, buffer_ptr, length, MSG_DONTWAIT);
+ if(result == -1) //���ݷ��ʹ�����
+ {
+ rt_kprintf("TCP thread send error: %d\n", result);
+ lwip_close(sock); //�ر����ӣ����´�������
+ rt_thread_delay(10);
+ if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1)
+ rt_kprintf("TCP Socket error:%d\n",sock);
+ err = connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr));
+ rt_kprintf("TCP thread connect error code: %d\n", err);
+ }
+ }
+}
+
+#ifdef RT_USING_FINSH
+#include <finsh.h>
+/* ���tcpclient������finsh shell�� */
+FINSH_FUNCTION_EXPORT(tcp_senddata, send a packet through tcp connection);
+#endif
+
|