summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rwxr-xr-xsrc/tuple_gen.cpp39
1 files changed, 22 insertions, 17 deletions
diff --git a/src/tuple_gen.cpp b/src/tuple_gen.cpp
index 309f6ebd..b9b156d0 100755
--- a/src/tuple_gen.cpp
+++ b/src/tuple_gen.cpp
@@ -235,51 +235,56 @@ void operator >> (const YAML::Node& node, CTupleGenPoolYaml & fi) {
}else if (tmp == "normal") {
fi.m_dist=cdNORMAL_DIST;
} else {
- printf("\ndist,seq\n");
fi.m_dist=cdSEQ_DIST;
}
utl_yaml_read_ip_addr(node,"ip_start",fi.m_ip_start);
utl_yaml_read_ip_addr(node,"ip_end",fi.m_ip_end);
+ fi.m_number_of_clients_per_gb = 0;
+
+ fi.m_min_clients = 0;
+ fi.m_is_bundling = false;
+ fi.m_tcp_aging_sec = 0;
+ fi.m_udp_aging_sec = 0;
+ fi.m_dual_interface_mask = 0;
try {
utl_yaml_read_uint32(node,"clients_per_gb",fi.m_number_of_clients_per_gb);
} catch ( const std::exception& e ) {
- fi.m_number_of_clients_per_gb = 0;
- }
+ ;}
try {
utl_yaml_read_uint32(node,"min_clients",fi.m_min_clients);
} catch ( const std::exception& e ) {
- fi.m_min_clients = 0;
- }
+ ;}
try {
utl_yaml_read_ip_addr(node,"dual_port_mask",fi.m_dual_interface_mask);
} catch ( const std::exception& e ) {
- fi.m_dual_interface_mask = 0;
- }
+ ;}
try {
utl_yaml_read_uint16(node,"tcp_aging",fi.m_tcp_aging_sec);
} catch ( const std::exception& e ) {
- fi.m_tcp_aging_sec = 0;
- }
+ ;}
try {
utl_yaml_read_uint16(node,"udp_aging",fi.m_udp_aging_sec);
} catch ( const std::exception& e ) {
- fi.m_udp_aging_sec = 0;
- }
+ ;}
try {
node["track_ports"] >> fi.m_is_bundling;
} catch ( const std::exception& e ) {
- fi.m_is_bundling = false;
- }
+ ;}
}
void copy_global_pool_para(CTupleGenPoolYaml & src, CTupleGenPoolYaml & dst) {
+ printf("src.m_number_of_clients_per_gb:%d\n",src.m_number_of_clients_per_gb);
if (src.m_number_of_clients_per_gb == 0)
src.m_number_of_clients_per_gb = dst.m_number_of_clients_per_gb;
+ printf("src.m_min_clients:%d\n",src.m_min_clients);
if (src.m_min_clients == 0)
src.m_min_clients = dst.m_min_clients;
+ printf("src.m_dual_interface_mask:%d\n",src.m_dual_interface_mask);
if (src.m_dual_interface_mask == 0)
src.m_dual_interface_mask = dst.m_dual_interface_mask;
+ printf("src.m_tcp_aging_sec:%d\n",src.m_tcp_aging_sec);
if (src.m_tcp_aging_sec == 0)
src.m_tcp_aging_sec = dst.m_tcp_aging_sec;
+ printf("src.m_udp_aging_sec:%d\n",src.m_udp_aging_sec);
if (src.m_udp_aging_sec == 0)
src.m_udp_aging_sec = dst.m_udp_aging_sec;
}
@@ -320,13 +325,13 @@ void operator >> (const YAML::Node& node, CTupleGenYamlInfo & fi) {
CTupleGenPoolYaml pool;
try {
c_pool_info[idx] >> pool;
+ if (fi.m_client_pool.size()>0) {
+ copy_global_pool_para(pool, fi.m_client_pool[0]);
+ }
+ fi.m_client_pool.push_back(pool);
} catch ( const std::exception& e ) {
printf("client pool in YAML is wrong\n");
}
- if (fi.m_client_pool.size()>0) {
- copy_global_pool_para(pool, fi.m_client_pool[0]);
- }
- fi.m_client_pool.push_back(pool);
}
}catch ( const std::exception& e ) {
printf("no client generator pool configured, using default pool\n");