diff options
author | Hanoh Haim <hhaim@cisco.com> | 2017-02-16 12:58:18 +0200 |
---|---|---|
committer | Hanoh Haim <hhaim@cisco.com> | 2017-02-16 17:15:32 +0200 |
commit | c22bab89dd44db65a9359cf7a325002cee1925d6 (patch) | |
tree | 85cc0e5a481d09304c8500c364b1c59d3d26892b /src/tuple_gen.h | |
parent | c65f218096d53d736a43571e68020ad5010f6d21 (diff) |
support more than 255 client/server pools
Signed-off-by: Hanoh Haim <hhaim@cisco.com>
Diffstat (limited to 'src/tuple_gen.h')
-rwxr-xr-x | src/tuple_gen.h | 31 |
1 files changed, 18 insertions, 13 deletions
diff --git a/src/tuple_gen.h b/src/tuple_gen.h index 59f97587..55003d37 100755 --- a/src/tuple_gen.h +++ b/src/tuple_gen.h @@ -41,6 +41,9 @@ limitations under the License. #include <random> +typedef uint16_t pool_index_t; +#define CS_MAX_POOLS UINT16_MAX + class CTupleBase { public: @@ -649,17 +652,17 @@ public: } - void FreePort(uint8_t pool_idx, uint32_t id, uint16_t port) { + void FreePort(pool_index_t pool_idx, uint32_t id, uint16_t port) { get_client_pool(pool_idx)->FreePort(id, port); } - bool IsFreePortRequired(uint8_t pool_idx){ + bool IsFreePortRequired(pool_index_t pool_idx){ return(get_client_pool(pool_idx)->IsFreePortRequired()); } - uint16_t get_tcp_aging(uint8_t pool_idx) { + uint16_t get_tcp_aging(pool_index_t pool_idx) { return (get_client_pool(pool_idx)->get_tcp_aging()); } - uint16_t get_udp_aging(uint8_t pool_idx) { + uint16_t get_udp_aging(pool_index_t pool_idx) { return (get_client_pool(pool_idx)->get_udp_aging()); } @@ -698,16 +701,16 @@ public: double active_flows, bool is_bundling); - CClientPool* get_client_pool(uint8_t idx) { + CClientPool* get_client_pool(pool_index_t idx) { return m_client_pool[idx]; } - uint8_t get_client_pool_num() { + pool_index_t get_client_pool_num() { return m_client_pool.size(); } - uint8_t get_server_pool_num() { + pool_index_t get_server_pool_num() { return m_server_pool.size(); } - CServerPoolBase* get_server_pool(uint8_t idx) { + CServerPoolBase* get_server_pool(pool_index_t idx) { return m_server_pool[idx]; } private: @@ -762,7 +765,9 @@ public: public: - bool Create( CTupleGeneratorSmart * gen,uint8_t c_pool,uint8_t s_pool){ + bool Create( CTupleGeneratorSmart * gen, + pool_index_t c_pool, + pool_index_t s_pool){ m_gen=gen; m_is_single_server=false; m_server_ip=0; @@ -861,11 +866,11 @@ struct CTupleGenYamlInfo { public: bool is_valid(uint32_t num_threads,bool is_plugins); - uint8_t get_server_pool_id(std::string name){ + pool_index_t get_server_pool_id(std::string name){ if (name=="default") { return 0; } - for (uint8_t i=0;i<m_server_pool.size();i++) { + for (pool_index_t i=0;i<m_server_pool.size();i++) { if (m_server_pool[i].m_name==name) return i; } @@ -874,11 +879,11 @@ public: return 0; } - uint8_t get_client_pool_id(std::string name){ + pool_index_t get_client_pool_id(std::string name){ if (name=="default") { return 0; } - for (uint8_t i=0;i<m_client_pool.size();i++) { + for (pool_index_t i=0;i<m_client_pool.size();i++) { if (m_client_pool[i].m_name==name) return i; } |