| /examples/network/ |
| A D | tcp_server.py | 14 def tcp_link(sock,addr): argument
16 sock.send('Welcome to RT-Thread!')
18 data=sock.recv(1024)
23 sock.send('Hello,%s!'%data)
24 sock.close()
30 sock,addr=s.accept() variable
33 t=threading.Thread(target=tcp_link(sock,addr))
|
| A D | tcpsendpacket.c | 18 int sock, err, result, timeout, index; in tcp_senddata() local
25 if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1) in tcp_senddata()
47 setsockopt(sock, SOL_SOCKET, SO_SNDTIMEO, &timeout, sizeof(timeout)); in tcp_senddata()
55 err = connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)); in tcp_senddata()
61 result = send(sock, buffer_ptr, length, MSG_DONTWAIT); in tcp_senddata()
65 closesocket(sock); in tcp_senddata()
70 if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1) in tcp_senddata()
71 rt_kprintf("TCP Socket error:%d\n", sock); in tcp_senddata()
73 err = connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)); in tcp_senddata()
|
| A D | udpserver.c | 44 int sock; in udpserv() local
62 if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1) in udpserv()
75 if (bind(sock, (struct sockaddr *)&server_addr, in udpserv()
94 FD_SET(sock, &readset); in udpserv()
97 if (select(sock + 1, &readset, RT_NULL, RT_NULL, &timeout) == 0) in udpserv()
101 bytes_read = recvfrom(sock, recv_data, BUFSZ - 1, 0, in udpserv()
134 if (sock >= 0) in udpserv()
136 closesocket(sock); in udpserv()
137 sock = -1; in udpserv()
|
| A D | tcpclient.c | 50 int sock = -1; in tcpclient() local
74 if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1) in tcpclient()
89 if (connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1) in tcpclient()
106 FD_SET(sock, &readset); in tcpclient()
109 if (select(sock + 1, &readset, RT_NULL, RT_NULL, &timeout) == 0) in tcpclient()
113 bytes_received = recv(sock, recv_data, BUFSZ - 1, 0); in tcpclient()
150 ret = send(sock, send_data, rt_strlen(send_data), 0); in tcpclient()
177 if (sock >= 0) in tcpclient()
179 closesocket(sock); in tcpclient()
180 sock = -1; in tcpclient()
|
| A D | tcpserver.c | 48 int sock, connected, bytes_received; in tcpserv() local
63 if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1) in tcpserv()
76 if (bind(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1) in tcpserv()
83 if (listen(sock, 10) == -1) in tcpserv()
100 FD_SET(sock, &readset); in tcpserv()
105 if (select(sock + 1, &readset, RT_NULL, RT_NULL, &timeout) == 0) in tcpserv()
109 connected = accept(sock, (struct sockaddr *)&client_addr, &sin_size); in tcpserv()
215 if (sock >= 0) in tcpserv()
217 closesocket(sock); in tcpserv()
218 sock = -1; in tcpserv()
|
| A D | udpclient.c | 38 int sock; in udpclient() local
51 if ((sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1) in udpclient()
72 sendto(sock, send_data, rt_strlen(send_data), 0, in udpclient()
88 if (sock >= 0) in udpclient()
90 closesocket(sock); in udpclient()
91 sock = -1; in udpclient()
|
| A D | chargen.c | 127 int sock; in chargen_thread() local
131 sock = accept(listenfd, &cliaddr, &clilen); in chargen_thread()
132 if (sock >= 0) in chargen_thread()
133 closesocket(sock); in chargen_thread()
|
| /examples/test/ |
| A D | net_test.c | 80 int sock; in udpecho_socket_entry() local
95 if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1) in udpecho_socket_entry()
108 if (bind(sock,(struct sockaddr *)&server_addr, in udpecho_socket_entry()
120 bytes_read = recvfrom(sock, recv_data, UDP_SOCKET_BUFFER_SIZE, 0, in udpecho_socket_entry()
124 sendto(sock, recv_data, bytes_read, 0, in udpecho_socket_entry()
208 int sock = -1, connected, bytes_received; in tcpecho_socket_entry() local
219 if ((sock = socket(AF_INET, SOCK_STREAM, 0)) == -1) in tcpecho_socket_entry()
232 if (bind(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1) in tcpecho_socket_entry()
239 if (listen(sock, 5) == -1) in tcpecho_socket_entry()
249 connected = accept(sock, (struct sockaddr *)&client_addr, &sin_size); in tcpecho_socket_entry()
[all …]
|