moved code blocks, new option --manual-tun

main.cpp

@@ -104,25 +104,25 @@ int main(int argc, char *argv[])
 		}
 	}
 
-	g_fec_mode=0;
+	//g_fec_mode=0;
 
 	process_arg(argc,argv);
 
 	delay_manager.set_capacity(delay_capacity);
-	local_ip_uint32=inet_addr(local_ip);
-	remote_ip_uint32=inet_addr(remote_ip);
+	//local_ip_uint32=inet_addr(local_ip);
+	//remote_ip_uint32=inet_addr(remote_ip);
 	sub_net_uint32=inet_addr(sub_net);
 
 	if(strlen(tun_dev)==0)
 	{
-		sprintf(tun_dev,"tun%u",get_true_random_number()%1000);
+		sprintf(tun_dev,"tun%u",get_fake_random_number()%1000);
 	}
 	mylog(log_info,"using interface %s\n",tun_dev);
 	/*if(tun_mtu==0)
 	{
 		tun_mtu=g_fec_mtu;
 	}*/
-	if(client_or_server==client_mode)
+	if(program_mode==client_mode)
 	{
 		tun_dev_client_event_loop();
 	}

tun_dev.cpp

@@ -6,23 +6,10 @@
  */
 
 
-#include "common.h"
-#include "log.h"
-#include "misc.h"
-
-#include <netinet/tcp.h>   //Provides declarations for tcp header
-#include <netinet/udp.h>
-#include <netinet/ip.h>    //Provides declarations for ip header
-#include <netinet/if_ether.h>
-
-#include <linux/if.h>
-#include <linux/if_tun.h>
-
+#include "tun_dev.h"
 
 my_time_t last_keep_alive_time=0;
 
-int keep_alive_interval=3000;//3000ms
-
 int get_tun_fd(char * dev_name)
 {
 	int tun_fd=open("/dev/net/tun",O_RDWR);
@@ -46,8 +33,10 @@ int get_tun_fd(char * dev_name)
 	return tun_fd;
 }
 
-int set_if(char *if_name,u32_t local_ip,u32_t remote_ip,int mtu)
+int set_tun(char *if_name,u32_t local_ip,u32_t remote_ip,int mtu)
 {
+	if(manual_tun) return 0;
+
 	//printf("i m here1\n");
 	struct ifreq ifr;
 	struct sockaddr_in sai;
@@ -81,10 +70,6 @@ int set_if(char *if_name,u32_t local_ip,u32_t remote_ip,int mtu)
 	return 0;
 }
 
-const char header_normal=1;
-const char header_new_connect=2;
-const char header_reject=3;
-const char header_keep_alive=4;
 
 int put_header(char header,char * data,int &len)
 {
@@ -346,605 +331,4 @@ int do_keep_alive(dest_t & dest)
 	}
 	return 0;
 }
-int tun_dev_client_event_loop()
-{
-	char data[buf_len];
-	int len;
-	int i,j,k,ret;
-	int epoll_fd,tun_fd;
-
-	int remote_fd;
-	fd64_t remote_fd64;
-
-	tun_fd=get_tun_fd(tun_dev);
-	assert(tun_fd>0);
-
-	assert(new_connected_socket2(remote_fd,remote_addr)==0);
-	remote_fd64=fd_manager.create(remote_fd);
-
-	assert(set_if(tun_dev,htonl((ntohl(sub_net_uint32)&0xFFFFFF00)|2),htonl((ntohl(sub_net_uint32)&0xFFFFFF00 )|1),tun_mtu)==0);
-
-	epoll_fd = epoll_create1(0);
-	assert(epoll_fd>0);
-
-	const int max_events = 4096;
-	struct epoll_event ev, events[max_events];
-	if (epoll_fd < 0) {
-		mylog(log_fatal,"epoll return %d\n", epoll_fd);
-		myexit(-1);
-	}
-
-	ev.events = EPOLLIN;
-	ev.data.u64 = remote_fd64;
-	ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, remote_fd, &ev);
-	if (ret!=0) {
-		mylog(log_fatal,"add  remote_fd64 error\n");
-		myexit(-1);
-	}
-
-	ev.events = EPOLLIN;
-	ev.data.u64 = tun_fd;
-	ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, tun_fd, &ev);
-	if (ret!=0) {
-		mylog(log_fatal,"add  tun_fd error\n");
-		myexit(-1);
-	}
-
-
-	ev.events = EPOLLIN;
-	ev.data.u64 = delay_manager.get_timer_fd();
-
-	mylog(log_debug,"delay_manager.get_timer_fd()=%d\n",delay_manager.get_timer_fd());
-	ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, delay_manager.get_timer_fd(), &ev);
-	if (ret!= 0) {
-		mylog(log_fatal,"add delay_manager.get_timer_fd() error\n");
-		myexit(-1);
-	}
-
-
-    conn_info_t *conn_info_p=new conn_info_t;
-    conn_info_t &conn_info=*conn_info_p;  //huge size of conn_info,do not allocate on stack
-
-	u64_t tmp_timer_fd64=conn_info.fec_encode_manager.get_timer_fd64();
-	ev.events = EPOLLIN;
-	ev.data.u64 = tmp_timer_fd64;
-
-	mylog(log_debug,"conn_info.fec_encode_manager.get_timer_fd64()=%llu\n",conn_info.fec_encode_manager.get_timer_fd64());
-	ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fd_manager.to_fd(tmp_timer_fd64), &ev);
-	if (ret!= 0) {
-		mylog(log_fatal,"add fec_encode_manager.get_timer_fd64() error\n");
-		myexit(-1);
-	}
-
-	conn_info.timer.add_fd_to_epoll(epoll_fd);
-	conn_info.timer.set_timer_repeat_us(timer_interval*1000);
-
-
-
-
-
-	int fifo_fd=-1;
-
-	if(fifo_file[0]!=0)
-	{
-		fifo_fd=create_fifo(fifo_file);
-		ev.events = EPOLLIN;
-		ev.data.u64 = fifo_fd;
-
-		ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fifo_fd, &ev);
-		if (ret!= 0) {
-			mylog(log_fatal,"add fifo_fd to epoll error %s\n",strerror(errno));
-			myexit(-1);
-		}
-		mylog(log_info,"fifo_file=%s\n",fifo_file);
-	}
-
-
-	dest_t udp_dest;
-	udp_dest.cook=1;
-	udp_dest.type=type_fd64;
-	udp_dest.inner.fd64=remote_fd64;
-
-	dest_t tun_dest;
-	tun_dest.type=type_write_fd;
-	tun_dest.inner.fd=tun_fd;
-
-	int got_feed_back=0;
-
-	while(1)////////////////////////
-	{
-
-		if(about_to_exit) myexit(0);
-
-		int nfds = epoll_wait(epoll_fd, events, max_events, 180 * 1000);
-		if (nfds < 0) {  //allow zero
-			if(errno==EINTR  )
-			{
-				mylog(log_info,"epoll interrupted by signal,continue\n");
-				//myexit(0);
-			}
-			else
-			{
-				mylog(log_fatal,"epoll_wait return %d,%s\n", nfds,strerror(errno));
-				myexit(-1);
-			}
-		}
-		int idx;
-		for (idx = 0; idx < nfds; ++idx)
-		{
-			if(events[idx].data.u64==(u64_t)conn_info.timer.get_timer_fd())
-			{
-				uint64_t value;
-				read(conn_info.timer.get_timer_fd(), &value, 8);
-				mylog(log_trace,"events[idx].data.u64==(u64_t)conn_info.timer.get_timer_fd()\n");
-				conn_info.stat.report_as_client();
-				if(got_feed_back) do_keep_alive(udp_dest);
-			}
-
-			else if(events[idx].data.u64==conn_info.fec_encode_manager.get_timer_fd64())
-			{
-				fd64_t fd64=events[idx].data.u64;
-				mylog(log_trace,"events[idx].data.u64 == conn_info.fec_encode_manager.get_timer_fd64()\n");
-
-				uint64_t value;
-				if(!fd_manager.exist(fd64))   //fd64 has been closed
-				{
-					mylog(log_trace,"!fd_manager.exist(fd64)");
-					continue;
-				}
-				if((ret=read(fd_manager.to_fd(fd64), &value, 8))!=8)
-				{
-					mylog(log_trace,"(ret=read(fd_manager.to_fd(fd64), &value, 8))!=8,ret=%d\n",ret);
-					continue;
-				}
-				if(value==0)
-				{
-					mylog(log_debug,"value==0\n");
-					continue;
-				}
-				assert(value==1);
-
-				char header=(got_feed_back==0?header_new_connect:header_normal);
-				from_normal_to_fec2(conn_info,udp_dest,0,0,header);
-			}
-			else if(events[idx].data.u64==(u64_t)tun_fd)
-			{
-				len=read(tun_fd,data,max_data_len+1);
-
-				if(len==max_data_len+1)
-				{
-					mylog(log_warn,"huge packet, data_len > %d,dropped\n",max_data_len);
-					continue;
-				}
-
-				if(len<0)
-				{
-					mylog(log_warn,"read from tun_fd return %d,errno=%s\n",len,strerror(errno));
-					continue;
-				}
-
-				do_mssfix(data,len);
-
-				mylog(log_trace,"Received packet from tun,len: %d\n",len);
-
-				char header=(got_feed_back==0?header_new_connect:header_normal);
-				from_normal_to_fec2(conn_info,udp_dest,data,len,header);
-
-			}
-			else if(events[idx].data.u64==(u64_t)remote_fd64)
-			{
-				fd64_t fd64=events[idx].data.u64;
-				int fd=fd_manager.to_fd(fd64);
-
-				len=recv(fd,data,max_data_len+1,0);
-
-				if(len==max_data_len+1)
-				{
-					mylog(log_warn,"huge packet, data_len > %d,dropped\n",max_data_len);
-					continue;
-				}
-
-				if(len<0)
-				{
-					mylog(log_warn,"recv return %d,errno=%s\n",len,strerror(errno));
-					continue;
-				}
-
-				if(de_cook(data,len)<0)
-				{
-					mylog(log_warn,"de_cook(data,len)failed \n");
-					continue;
-
-				}
-
-				char header=0;
-				if(get_header(header,data,len)!=0)
-				{
-					mylog(log_warn,"get_header failed\n");
-					continue;
-				}
-
-				if(header==header_keep_alive)
-				{
-					mylog(log_trace,"got keep_alive packet\n");
-					continue;
-				}
-
-				if(header==header_reject)
-				{
-					if(keep_reconnect==0)
-					{
-						mylog(log_fatal,"server restarted or switched to handle another client,exited\n");
-						myexit(-1);
-					}
-					else
-					{
-						if(got_feed_back==1)
-							mylog(log_warn,"server restarted or switched to handle another client,but keep-reconnect enabled,trying to reconnect\n");
-						got_feed_back=0;
-					}
-					continue;
-				}
-				else if(header==header_normal)
-				{
-					if(got_feed_back==0)
-						mylog(log_info,"connection accepted by server\n");
-					got_feed_back=1;
-				}
-				else
-				{
-					mylog(log_warn,"invalid header %d %d\n",int(header),len);
-					continue;
-				}
-
-				mylog(log_trace,"Received packet from udp,len: %d\n",len);
-
-				from_fec_to_normal2(conn_info,tun_dest,data,len);
-
-			}
-		    else if (events[idx].data.u64 == (u64_t)delay_manager.get_timer_fd())
-		    {
-				uint64_t value;
-				read(delay_manager.get_timer_fd(), &value, 8);
-				mylog(log_trace,"events[idx].data.u64 == (u64_t)delay_manager.get_timer_fd()\n");
-
-			}
-			else if (events[idx].data.u64 == (u64_t)fifo_fd)
-			{
-				char buf[buf_len];
-				int len=read (fifo_fd, buf, sizeof (buf));
-				if(len<0)
-				{
-					mylog(log_warn,"fifo read failed len=%d,errno=%s\n",len,strerror(errno));
-					continue;
-				}
-				buf[len]=0;
-				handle_command(buf);
-			}
-			else
-			{
-				assert(0==1);
-			}
-		}
-		delay_manager.check();
-	}
-
-
-	return 0;
-}
-
-int tun_dev_server_event_loop()
-{
-	char data[buf_len];
-	int len;
-	int i,j,k,ret;
-	int epoll_fd,tun_fd;
-	int local_listen_fd;
-
-	tun_fd=get_tun_fd(tun_dev);
-	assert(tun_fd>0);
-
-	assert(new_listen_socket2(local_listen_fd,local_addr)==0);
-	assert(set_if(tun_dev,htonl((ntohl(sub_net_uint32)&0xFFFFFF00)|1),htonl((ntohl(sub_net_uint32)&0xFFFFFF00 )|2),tun_mtu)==0);
-
-	epoll_fd = epoll_create1(0);
-	assert(epoll_fd>0);
-
-	const int max_events = 4096;
-	struct epoll_event ev, events[max_events];
-	if (epoll_fd < 0) {
-		mylog(log_fatal,"epoll return %d\n", epoll_fd);
-		myexit(-1);
-	}
-
-	ev.events = EPOLLIN;
-	ev.data.u64 = local_listen_fd;
-	ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, local_listen_fd, &ev);
-	if (ret!=0) {
-		mylog(log_fatal,"add  udp_listen_fd error\n");
-		myexit(-1);
-	}
-
-	ev.events = EPOLLIN;
-	ev.data.u64 = tun_fd;
-	ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, tun_fd, &ev);
-	if (ret!=0) {
-		mylog(log_fatal,"add  tun_fd error\n");
-		myexit(-1);
-	}
-
-	ev.events = EPOLLIN;
-	ev.data.u64 = delay_manager.get_timer_fd();
-
-	mylog(log_debug,"delay_manager.get_timer_fd()=%d\n",delay_manager.get_timer_fd());
-	ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, delay_manager.get_timer_fd(), &ev);
-	if (ret!= 0) {
-		mylog(log_fatal,"add delay_manager.get_timer_fd() error\n");
-		myexit(-1);
-	}
-
-
-    conn_info_t *conn_info_p=new conn_info_t;
-    conn_info_t &conn_info=*conn_info_p;  //huge size of conn_info,do not allocate on stack
-
-	u64_t tmp_timer_fd64=conn_info.fec_encode_manager.get_timer_fd64();
-	ev.events = EPOLLIN;
-	ev.data.u64 = tmp_timer_fd64;
-
-	mylog(log_debug,"conn_info.fec_encode_manager.get_timer_fd64()=%llu\n",conn_info.fec_encode_manager.get_timer_fd64());
-	ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fd_manager.to_fd(tmp_timer_fd64), &ev);
-	if (ret!= 0) {
-		mylog(log_fatal,"add fec_encode_manager.get_timer_fd64() error\n");
-		myexit(-1);
-	}
-
-	conn_info.timer.add_fd_to_epoll(epoll_fd);
-	conn_info.timer.set_timer_repeat_us(timer_interval*1000);
-
-
-
-
-	int fifo_fd=-1;
-
-	if(fifo_file[0]!=0)
-	{
-		fifo_fd=create_fifo(fifo_file);
-		ev.events = EPOLLIN;
-		ev.data.u64 = fifo_fd;
-
-		ret = epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fifo_fd, &ev);
-		if (ret!= 0) {
-			mylog(log_fatal,"add fifo_fd to epoll error %s\n",strerror(errno));
-			myexit(-1);
-		}
-		mylog(log_info,"fifo_file=%s\n",fifo_file);
-	}
-
-	dest_t udp_dest;
-	udp_dest.cook=1;
-	udp_dest.type=type_fd_addr;
-
-	udp_dest.inner.fd_addr.fd=local_listen_fd;
-	udp_dest.inner.fd_addr.addr.clear();
-
-	dest_t tun_dest;
-	tun_dest.type=type_write_fd;
-	tun_dest.inner.fd=tun_fd;
-
-	while(1)////////////////////////
-	{
-
-		if(about_to_exit) myexit(0);
-
-		int nfds = epoll_wait(epoll_fd, events, max_events, 180 * 1000);
-		if (nfds < 0) {  //allow zero
-			if(errno==EINTR  )
-			{
-				mylog(log_info,"epoll interrupted by signal,continue\n");
-				//myexit(0);
-			}
-			else
-			{
-				mylog(log_fatal,"epoll_wait return %d,%s\n", nfds,strerror(errno));
-				myexit(-1);
-			}
-		}
-		int idx;
-		for (idx = 0; idx < nfds; ++idx)
-		{
-			if(events[idx].data.u64==(u64_t)conn_info.timer.get_timer_fd())
-			{
-				uint64_t value;
-				read(conn_info.timer.get_timer_fd(), &value, 8);
-
-				if(udp_dest.inner.fd_addr.addr.is_vaild()==0)
-				{
-					continue;
-				}
-				conn_info.stat.report_as_server(udp_dest.inner.fd_addr.addr);
-				do_keep_alive(udp_dest);
-			}
-			else if(events[idx].data.u64==conn_info.fec_encode_manager.get_timer_fd64())
-			{
-				assert(udp_dest.inner.fd_addr.addr.is_vaild()!=0);
-				mylog(log_trace,"events[idx].data.u64 == conn_info.fec_encode_manager.get_timer_fd64()\n");
-				uint64_t fd64=events[idx].data.u64;
-				//mylog(log_info,"timer!!!\n");
-				uint64_t value;
-				if(!fd_manager.exist(fd64))   //fd64 has been closed
-				{
-					mylog(log_trace,"!fd_manager.exist(fd64)");
-					continue;
-				}
-				if((ret=read(fd_manager.to_fd(fd64), &value, 8))!=8)
-				{
-					mylog(log_trace,"(ret=read(fd_manager.to_fd(fd64), &value, 8))!=8,ret=%d\n",ret);
-					continue;
-				}
-				if(value==0)
-				{
-					mylog(log_debug,"value==0\n");
-					continue;
-				}
-				assert(value==1);
-
-				from_normal_to_fec2(conn_info,udp_dest,0,0,header_normal);
-			}
-			else if(events[idx].data.u64==(u64_t)local_listen_fd)
-			{
-				//struct sockaddr_in udp_new_addr_in={0};
-				//socklen_t udp_new_addr_len = sizeof(sockaddr_in);
-				address_t::storage_t udp_new_addr_in={0};
-				socklen_t udp_new_addr_len = sizeof(address_t::storage_t);
-
-				if ((len = recvfrom(local_listen_fd, data, max_data_len+1, 0,
-						(struct sockaddr *) &udp_new_addr_in, &udp_new_addr_len)) < 0) {
-					mylog(log_error,"recv_from error,this shouldnt happen,err=%s,but we can try to continue\n",strerror(errno));
-					continue;
-					//myexit(1);
-				};
-
-				address_t new_addr;
-				new_addr.from_sockaddr((struct sockaddr *) &udp_new_addr_in,udp_new_addr_len);
-
-				if(len==max_data_len+1)
-				{
-					mylog(log_warn,"huge packet, data_len > %d,dropped\n",max_data_len);
-					continue;
-				}
-
-				if(de_cook(data,len)<0)
-				{
-					mylog(log_warn,"de_cook(data,len)failed \n");
-					continue;
-
-				}
-
-				char header=0;
-				if(get_header(header,data,len)!=0)
-				{
-					mylog(log_warn,"get_header failed\n");
-					continue;
-				}
-
-				if(udp_dest.inner.fd_addr.addr==new_addr)
-				{
-					if(header==header_keep_alive)
-					{
-						mylog(log_trace,"got keep_alive packet\n");
-						continue;
-					}
-
-					if(header!=header_new_connect&& header!=header_normal)
-					{
-						mylog(log_warn,"invalid header\n");
-						continue;
-					}
-				}
-				else
-				{
-					if(header==header_keep_alive)
-					{
-						mylog(log_debug,"got keep_alive packet from unexpected client\n");
-						continue;
-					}
-
-					if(header==header_new_connect)
-					{
-						mylog(log_info,"new connection from %s\n", new_addr.get_str());
-						udp_dest.inner.fd_addr.addr=new_addr;
-						//udp_dest.inner.fd_ip_port.ip_port.ip=udp_new_addr_in.sin_addr.s_addr;
-						//udp_dest.inner.fd_ip_port.ip_port.port=ntohs(udp_new_addr_in.sin_port);
-						conn_info.fec_decode_manager.clear();
-						conn_info.fec_encode_manager.clear_data();
-						memset(&conn_info.stat,0,sizeof(conn_info.stat));
-
-					}
-					else if(header==header_normal)
-					{
-						mylog(log_debug,"rejected connection from %s\n", new_addr.get_str());
-
-
-						len=1;
-						data[0]=header_reject;
-						do_cook(data,len);
-
-
-						dest_t tmp_dest;
-						tmp_dest.type=type_fd_addr;
-
-						tmp_dest.inner.fd_addr.fd=local_listen_fd;
-						tmp_dest.inner.fd_addr.addr=new_addr;
-
-						delay_manager.add(0,tmp_dest,data,len);;
-						continue;
-					}
-					else
-					{
-						mylog(log_warn,"invalid header\n");
-					}
-				}
-
-				mylog(log_trace,"Received packet from %s,len: %d\n", new_addr.get_str(),len);
-
-				from_fec_to_normal2(conn_info,tun_dest,data,len);
-
-			}
-			else if(events[idx].data.u64==(u64_t)tun_fd)
-			{
-				len=read(tun_fd,data,max_data_len+1);
-
-				if(len==max_data_len+1)
-				{
-					mylog(log_warn,"huge packet, data_len > %d,dropped\n",max_data_len);
-					continue;
-				}
-
-				if(len<0)
-				{
-					mylog(log_warn,"read from tun_fd return %d,errno=%s\n",len,strerror(errno));
-					continue;
-				}
-
-				do_mssfix(data,len);
-
-				mylog(log_trace,"Received packet from tun,len: %d\n",len);
-
-				if(udp_dest.inner.fd_addr.addr.is_vaild()==0)
-				{
-					mylog(log_debug,"received packet from tun,but there is no client yet,dropped packet\n");
-					continue;
-				}
 
-				from_normal_to_fec2(conn_info,udp_dest,data,len,header_normal);
-
-			}
-		    else if (events[idx].data.u64 == (u64_t)delay_manager.get_timer_fd())
-		    {
-				uint64_t value;
-				read(delay_manager.get_timer_fd(), &value, 8);
-				mylog(log_trace,"events[idx].data.u64 == (u64_t)delay_manager.get_timer_fd()\n");
-			}
-			else if (events[idx].data.u64 == (u64_t)fifo_fd)
-			{
-				char buf[buf_len];
-				int len=read (fifo_fd, buf, sizeof (buf));
-				if(len<0)
-				{
-					mylog(log_warn,"fifo read failed len=%d,errno=%s\n",len,strerror(errno));
-					continue;
-				}
-				buf[len]=0;
-				handle_command(buf);
-			}
-			else
-			{
-				assert(0==1);
-			}
-		}
-		delay_manager.check();
-	}
-
-
-	return 0;
-}

tun_dev.h

@@ -5,9 +5,44 @@
  *      Author: root
  */
 
+
 #ifndef TUN_DEV_H_
 #define TUN_DEV_H_
 
+#include "common.h"
+#include "log.h"
+#include "misc.h"
+
+#include <netinet/tcp.h>   //Provides declarations for tcp header
+#include <netinet/udp.h>
+#include <netinet/ip.h>    //Provides declarations for ip header
+#include <netinet/if_ether.h>
+
+#include <linux/if.h>
+#include <linux/if_tun.h>
+
+extern my_time_t last_keep_alive_time;
+
+const int keep_alive_interval=3000;//3000ms
+
+const char header_normal=1;
+const char header_new_connect=2;
+const char header_reject=3;
+const char header_keep_alive=4;
+
+int set_tun(char *if_name,u32_t local_ip,u32_t remote_ip,int mtu);
+
+int get_tun_fd(char * dev_name);
+
+int put_header(char header,char * data,int &len);
+
+int get_header(char &header,char * data,int &len);
+int from_normal_to_fec2(conn_info_t & conn_info,dest_t &dest,char * data,int len,char header);
+
+int from_fec_to_normal2(conn_info_t & conn_info,dest_t &dest,char * data,int len);
+int do_mssfix(char * s,int len);
+int do_keep_alive(dest_t & dest);
+
 
 int tun_dev_client_event_loop();