wangyu- před 8 roky
rodič
revize
c688189035
3 změnil soubory, kde provedl 6 přidání a 4 odebrání
  1. 1 0
      delay_manager.h
  2. 2 1
      fd_manager.cpp
  3. 3 3
      main.cpp

+ 1 - 0
delay_manager.h

@@ -121,6 +121,7 @@ struct delay_manager_t
 	{
 		assert(0==1);
 	}
+	int set_capacity(int a){capacity=a;return 0;}
 	~delay_manager_t();
 	int get_timer_fd();
 	int check();

+ 2 - 1
fd_manager.cpp

@@ -49,7 +49,8 @@ u64_t fd_manager_t::create(int fd)
 fd_manager_t::fd_manager_t()
 {
 	counter=u32_t(-1);
-	counter+=10;
+	counter+=100;
+	reserve(10007);
 }
 fd_info_t & fd_manager_t::get_info(fd64_t fd64)
 {

+ 3 - 3
main.cpp

@@ -33,7 +33,7 @@ int disable_fec=0;
 int debug_force_flush_fec=0;
 
 int fec_data_num=20;
-int fec_redundant_num=10;
+int fec_redundant_num=8;
 int fec_mtu=1000;
 int fec_pending_num=30;
 int fec_pending_time=10000;
@@ -1354,10 +1354,10 @@ int main(int argc, char *argv[])
 	dup2(1, 2);		//redirect stderr to stdout
 	int i, j, k;
 	process_arg(argc,argv);
-	delay_manager.capacity=max_pending_packet;
+
+	delay_manager.set_capacity(max_pending_packet);
 	local_ip_uint32=inet_addr(local_ip);
 	remote_ip_uint32=inet_addr(remote_ip);
-	fd_manager.reserve(10007);
 
 	if(program_mode==client_mode)
 	{