summaryrefslogtreecommitdiff
path: root/examples/network/tcpsendpacket.c
diff options
context:
space:
mode:
authoraozima <[email protected]>2018-02-06 18:59:24 +0800
committeraozima <[email protected]>2018-02-06 18:59:24 +0800
commite20fb2f5b2130093191f818d307bb9cc30b0bc28 (patch)
treedaa94054ad5ee826b6f19e12230fdc63feeae6f8 /examples/network/tcpsendpacket.c
parentff811a93ff0a834ae3080c435ee216e5b92cd759 (diff)
[examples] update:
1. cleanup for posix dfs_net. 2. fixed recv buf overwrite. 3. format code.
Diffstat (limited to 'examples/network/tcpsendpacket.c')
-rw-r--r--examples/network/tcpsendpacket.c17
1 files changed, 9 insertions, 8 deletions
diff --git a/examples/network/tcpsendpacket.c b/examples/network/tcpsendpacket.c
index e7c514806e..75134c19a2 100644
--- a/examples/network/tcpsendpacket.c
+++ b/examples/network/tcpsendpacket.c
@@ -1,8 +1,9 @@
#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)
+#include <netdb.h> /* Ϊ�˽�������������Ҫ����netdb.hͷ�ļ� */
+#include <sys/socket.h> /* ʹ��BSD socket����Ҫ����socket.hͷ�ļ� */
+
+void tcp_senddata(const char *url, int port, int length)
{
struct hostent *host;
int sock, err, result, timeout, index;
@@ -27,7 +28,7 @@ void tcp_senddata(const char* url, int port, int length)
timeout = 100;
/* ���÷��ͳ�ʱʱ��100ms */
- lwip_setsockopt(sock, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout));
+ setsockopt(sock, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout));
/* ��ʼ��Ԥ���ӵķ���˵�ַ */
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(port);
@@ -38,20 +39,20 @@ void tcp_senddata(const char* url, int port, int length)
err = connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr));
rt_kprintf("TCP thread connect error code: %d\n", err);
- while(1)
+ while (1)
{
/* �������ݵ�sock���� */
result = send(sock, buffer_ptr, length, MSG_DONTWAIT);
- if(result < 0) //���ݷ��ʹ�����
+ if (result < 0) //���ݷ��ʹ�����
{
rt_kprintf("TCP thread send error: %d\n", result);
- lwip_close(sock);
+ closesocket(sock);
/* �ر����ӣ����´������� */
rt_thread_delay(10);
if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1)
- rt_kprintf("TCP Socket error:%d\n",sock);
+ 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);