net_load_tests::open_close_test_helper Class Reference

#include <net_load_tests.h>

Public Member Functions
	open_close_test_helper (test_tcp_server &tcp_server, size_t open_request_target, size_t max_opened_connection_count)
bool	handle_new_connection (const boost::uuids::uuid &connection_id, bool ignore_close_fails=false)
void	close_remaining_connections ()
bool	close_next_connection (bool ignore_close_fails)
size_t	opened_connection_count () const

Detailed Description

Definition at line 137 of file net_load_tests.h.

Constructor & Destructor Documentation

open_close_test_helper()

net_load_tests::open_close_test_helper::open_close_test_helper ( test_tcp_server & tcp_server, size_t open_request_target, size_t max_opened_connection_count )

inline

Definition at line 140 of file net_load_tests.h.

      : m_tcp_server(tcp_server)
      , m_max_opened_connection_count(max_opened_connection_count)
      , m_opened_connection_count(0)
      , m_next_opened_conn_idx(0)
      , m_next_closed_conn_idx(0)
      , m_connections(open_request_target)
    {
      for (auto& conn_id : m_connections)
        conn_id = boost::uuids::nil_uuid();
    }

Member Function Documentation

close_next_connection()

bool net_load_tests::open_close_test_helper::close_next_connection ( bool ignore_close_fails )

inline

Definition at line 176 of file net_load_tests.h.

    {
      size_t idx = m_next_closed_conn_idx.fetch_add(1, std::memory_order_relaxed);
      if (m_next_opened_conn_idx.load(std::memory_order_relaxed) <= idx)
      {
        LOG_PRINT_L0("Not enough opened connections");
        return false;
      }
      if (m_connections[idx].is_nil())
      {
        LOG_PRINT_L0("Connection isn't opened");
        return false;
      }
      if (!m_tcp_server.get_config_object().close(m_connections[idx]))
      {
        LOG_PRINT_L0("Close connection error: " << m_connections[idx]);
        if (!ignore_close_fails)
        {
          return false;
        }
      }
 
      m_connections[idx] = boost::uuids::nil_uuid();
      m_opened_connection_count.fetch_sub(1, std::memory_order_relaxed);
      return true;
    }

Here is the caller graph for this function:

close_remaining_connections()

void net_load_tests::open_close_test_helper::close_remaining_connections ( )

inline

Definition at line 171 of file net_load_tests.h.

    {
      while (close_next_connection(false));
    }

Here is the call graph for this function:

handle_new_connection()

bool net_load_tests::open_close_test_helper::handle_new_connection ( const boost::uuids::uuid & connection_id, bool ignore_close_fails = false )

inline

Definition at line 152 of file net_load_tests.h.

    {
      size_t idx = m_next_opened_conn_idx.fetch_add(1, std::memory_order_relaxed);
      if (idx >= m_connections.size())
      {
        LOG_PRINT_L0("ERROR: connections overflow");
        exit(1);
      }
      m_connections[idx] = connection_id;
 
      size_t prev_connection_count = m_opened_connection_count.fetch_add(1, std::memory_order_relaxed);
      if (m_max_opened_connection_count <= prev_connection_count)
      {
        return close_next_connection(ignore_close_fails);
      }
 
      return true;
    }

Here is the call graph for this function:

opened_connection_count()

size_t net_load_tests::open_close_test_helper::opened_connection_count ( ) const

inline

Definition at line 203 of file net_load_tests.h.

{ return m_opened_connection_count.load(std::memory_order_relaxed); }

---

The documentation for this class was generated from the following file:

• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/tests/net_load_tests/net_load_tests.h