/* Wenxian Li Hanoh Haim Cisco Systems, Inc. */ /* Copyright (c) 2015-2016 Cisco Systems, Inc. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ #include #include "utl_yaml.h" #include "bp_sim.h" #include "tuple_gen.h" static bool _enough_ips(uint32_t total_ip, double active_flows){ /* Socket utilization is lower than 20% */ if ( (active_flows/((double)total_ip*(double)MAX_PORT))>0.10 ) { return(false); } return (true); } void CServerPool::Create(IP_DIST_t dist_value, uint32_t min_ip, uint32_t max_ip, double active_flows ) { gen = new CIpPool(); gen->set_dist(dist_value); uint32_t total_ip = max_ip - min_ip +1; gen->m_ip_info.resize(total_ip); if ( _enough_ips(total_ip,active_flows) ) { for(int idx=0;idxm_ip_info[idx] = new CServerInfoL(); gen->m_ip_info[idx]->set_ip(min_ip+idx); } } else { for(int idx=0;idxm_ip_info[idx] = new CServerInfo(); gen->m_ip_info[idx]->set_ip(min_ip+idx); } } gen->CreateBase(); } void CClientPool::Create(IP_DIST_t dist_value, uint32_t min_ip, uint32_t max_ip, double active_flows, ClientCfgDB &client_info, uint16_t tcp_aging, uint16_t udp_aging) { assert(max_ip >= min_ip); set_dist(dist_value); uint32_t total_ip = max_ip - min_ip +1; bool is_long_range = _enough_ips(total_ip,active_flows); m_ip_info.resize(total_ip); /* if client info is empty - flat allocation o.w use configured clients */ if (client_info.is_empty()) { allocate_simple_clients(min_ip, total_ip, is_long_range); } else { allocate_configured_clients(min_ip, total_ip, is_long_range, client_info); } m_tcp_aging = tcp_aging; m_udp_aging = udp_aging; CreateBase(); } /** * simple allocation of a client - no configuration was provided * * @author imarom (27-Jun-16) * * @param ip * @param index * @param is_long_range */ void CClientPool::allocate_simple_clients(uint32_t min_ip, uint32_t total_ip, bool is_long_range) { /* simple creation of clients - no extended info */ for (uint32_t i = 0; i < total_ip; i++) { uint32_t ip = min_ip + i; if (is_long_range) { m_ip_info[i] = new CSimpleClientInfo(ip); } else { m_ip_info[i] = new CSimpleClientInfo(ip); } } } /** * simple allocation of a client - no configuration was provided * * @author imarom (27-Jun-16) * * @param ip * @param index * @param is_long_range */ void CClientPool::allocate_configured_clients(uint32_t min_ip, uint32_t total_ip, bool is_long_range, ClientCfgDB &client_info) { for (uint32_t i = 0; i < total_ip; i++) { uint32_t ip = min_ip + i; /* lookup for the right group of clients */ ClientCfgEntry *group = client_info.lookup(ip); if (!group) { std::stringstream ss; ss << "client configuration error: could not map IP '" << ip_to_str(ip) << "' to a group\n"; throw std::runtime_error(ss.str()); } ClientCfgBase info; group->assign(info); if (is_long_range) { m_ip_info[i] = new CConfiguredClientInfo(ip, info); } else { m_ip_info[i] = new CConfiguredClientInfo(ip, info); } } } bool CTupleGeneratorSmart::add_client_pool(IP_DIST_t client_dist, uint32_t min_client, uint32_t max_client, double active_flows, ClientCfgDB &client_info, uint16_t tcp_aging, uint16_t udp_aging) { assert(max_client>=min_client); CClientPool* pool = new CClientPool(); pool->Create(client_dist, min_client, max_client, active_flows, client_info, tcp_aging, udp_aging); m_client_pool.push_back(pool); return(true); } bool CTupleGeneratorSmart::add_server_pool(IP_DIST_t server_dist, uint32_t min_server, uint32_t max_server, double active_flows, bool is_bundling){ assert(max_server>=min_server); CServerPoolBase* pool; if (is_bundling) pool = new CServerPool(); else pool = new CServerPoolSimple(); // we currently only supports mac mapping file for client pool->Create(server_dist, min_server, max_server,active_flows); m_server_pool.push_back(pool); return(true); } bool CTupleGeneratorSmart::Create(uint32_t _id, uint32_t thread_id) { m_thread_id = thread_id; m_id = _id; m_was_init=true; return(true); } void CTupleGeneratorSmart::Delete(){ m_was_init=false; for (int idx=0;idxDelete(); delete m_client_pool[idx]; } m_client_pool.clear(); for (int idx=0;idxDelete(); delete m_server_pool[idx]; } m_server_pool.clear(); } void CTupleGenYamlInfo::dump(FILE *fd) {

# ===========================================================================
#       http://www.gnu.org/software/autoconf-archive/ax_prog_javah.html
# ===========================================================================
#
# SYNOPSIS
#
#   AX_PROG_JAVAH
#
# DESCRIPTION
#
#   AX_PROG_JAVAH tests the availability of the javah header generator and
#   looks for the jni.h header file. If available, JAVAH is set to the full
#   path of javah and CPPFLAGS is updated accordingly.
#
# LICENSE
#
#   Copyright (c) 2008 Luc Maisonobe <luc@spaceroots.org>
#
#   Copying and distribution of this file, with or without modification, are
#   permitted in any medium without royalty provided the copyright notice
#   and this notice are preserved. This file is offered as-is, without any
#   warranty.

#serial 8

AU_ALIAS([AC_PROG_JAVAH], [AX_PROG_JAVAH])
AC_DEFUN([AX_PROG_JAVAH],[
AC_REQUIRE([AC_CANONICAL_BUILD])dnl
AC_REQUIRE([AC_PROG_CPP])dnl
AC_PATH_PROG(JAVAH,javah)
AS_IF([test -n "$ac_cv_path_JAVAH"],
      [
        AC_TRY_CPP([#include <jni.h>],,[
        ac_save_CPPFLAGS="$CPPFLAGS"
		_ACJAVAH_FOLLOW_SYMLINKS("$ac_cv_path_JAVAH")
        ax_prog_javah_bin_dir=`AS_DIRNAME([$_ACJAVAH_FOLLOWED])`
        ac_dir="`AS_DIRNAME([$ax_prog_javah_bin_dir])`/include"
        AS_CASE([$build_os],
                [cygwin*],
                [ac_machdep=win32],
                [ac_machdep=`AS_ECHO($build_os) | sed 's,[[-0-9]].*,,'`])
        CPPFLAGS="$ac_save_CPPFLAGS -I$ac_dir -I$ac_dir/$ac_machdep"
        AC_TRY_CPP([#include <jni.h>],
                   ac_save_CPPFLAGS="$CPPFLAGS",
                   AC_MSG_WARN([unable to include <jni.h>]))
        CPPFLAGS="$ac_save_CPPFLAGS"])
      ])
])

AC_DEFUN([_ACJAVAH_FOLLOW_SYMLINKS],[
# find the include directory relative to the javac executable
_cur="$1"
while ls -ld "$_cur" 2>/dev/null | grep " -> " >/dev/null; do
        AC_MSG_CHECKING([symlink for $_cur])
        _slink=`ls -ld "$_cur" | sed 's/.* -> //'`
        case "$_slink" in
        /*) _cur="$_slink";;
        # 'X' avoids triggering unwanted echo options.
        *) _cur=`echo "X$_cur" | sed -e 's/^X//' -e 's:[[^/]]*$::'`"$_slink";;
        esac
        AC_MSG_RESULT([$_cur])
done
_ACJAVAH_FOLLOWED="$_cur"
])

_info.size();idx++) { CTupleGenPoolYaml pool; s_pool_info[idx] >> pool; if (fi.m_server_pool.size()>0) { copy_global_pool_para(pool, fi.m_server_pool[0]); } fi.m_server_pool.push_back(pool); } } else { printf("no server generator pool configured, using default pool\n"); } } bool CTupleGenYamlInfo::is_valid(uint32_t num_threads,bool is_plugins){ for (int i=0;i0); uint32_t dual_if_mask=(dual_port_id*poolinfo.getDualMask()); portion.m_ip_start = poolinfo.get_ip_start() + thread_id*chunks + dual_if_mask; portion.m_ip_end = portion.m_ip_start + chunks -1 ; }