Add fiber udp demo.

Author: zhengshuxin

lib_acl/samples/udp_server/main.c

@@ -12,7 +12,7 @@ static void run(const char *addr, int can_quit, int need_echo, int inter)
 {
 	char  buf[4096];
 	int   ret, i = 0;
-	ACL_VSTREAM *stream = acl_vstream_bind(addr, 0, 0);  /* °ó¶¨ UDP Ì×½Ó¿Ú */
+	ACL_VSTREAM *stream = acl_vstream_bind(addr, -1, 0);  /* °ó¶¨ UDP Ì×½Ó¿Ú */
 
 	if (stream == NULL) {
 		printf("acl_vstream_bind %s error %s\r\n",

lib_fiber/samples-c++1x/fiber_udpc/Makefile

@@ -0,0 +1,3 @@
+include ../Makefile_cpp.in
+CFLAGS += -std=c++11
+PROG = fiber_udpc

lib_fiber/samples-c++1x/fiber_udpc/main.cpp

@@ -0,0 +1,51 @@
+#include "stdafx.h"
+#include <vector>
+#include <thread>
+#include <iostream>
+
+int main() {
+	acl::fiber::stdout_open(true);
+
+	for (size_t i = 0; i < 5; i++) {
+		go[] {
+			const char* addr = "127.0.0.1:0";
+			acl::socket_stream ss;
+			if (!ss.bind_udp(addr, -1, acl::OPEN_FLAG_REUSEPORT)) {
+				printf("bind %s error %s\r\n", addr, acl::last_serror());
+				exit(1);
+			}
+
+			ss.set_rw_timeout(5, true);
+
+			int fd = ss.sock_handle();
+
+			const char* dest_addr = "127.0.0.1:8888";
+			const char* data = "hello world!";
+			char buf[1024];
+
+			for (size_t j = 0; j < 5; j++) {
+				int ret = ss.sendto(data, strlen(data), dest_addr, 0);
+				if (ret == -1) {
+					printf("sendto to %s error\r\n", dest_addr);
+					break;
+				}
+
+				ACL_SOCKADDR src_addr;
+				socklen_t addrlen = sizeof(src_addr);
+
+				ret = ::recvfrom(fd, buf, sizeof(buf) - 1, 0,
+					(struct sockaddr*) &src_addr, &addrlen);
+				if (ret == -1) {
+					printf("recvfrom error %s\r\n", acl::last_serror());
+					break;
+				}
+				buf[ret] = 0;
+				printf("recvfrom: %s\r\n", buf);
+			}
+		};
+	}
+
+	acl::fiber::schedule();
+	printf("All over!\r\n");
+	return 0;
+}

lib_fiber/samples-c++1x/fiber_udpc/stdafx.cpp

@@ -0,0 +1 @@
+#include "stdafx.h"

lib_fiber/samples-c++1x/fiber_udpc/stdafx.h

@@ -0,0 +1,19 @@
+// stdafx.h : 标准系统包含文件的包含文件，
+// 或是常用但不常更改的项目特定的包含文件
+//
+
+#pragma once
+
+
+// TODO: 在此处引用程序要求的附加头文件
+
+#include "lib_acl.h"
+#include "acl_cpp/lib_acl.hpp"
+#include "fiber/libfiber.hpp"
+
+#include "fiber/go_fiber.hpp"
+
+#ifdef	WIN32
+#define	snprintf _snprintf
+#endif
+