SSLCacheTest.cpp File Reference

#include <folly/io/async/EventBase.h>
#include <gflags/gflags.h>
#include <iostream>
#include <thread>
#include <folly/io/async/AsyncSSLSocket.h>
#include <folly/io/async/AsyncSocket.h>
#include <vector>

Go to the source code of this file.

Classes
class	ClientRunner
class	SSLCacheClient

Functions
	DEFINE_int32 (clients, 1,"Number of simulated SSL clients")
	DEFINE_int32 (threads, 1,"Number of threads to spread clients across")
	DEFINE_int32 (requests, 2,"Total number of requests per client")
	DEFINE_int32 (port, 9423,"Server port")
	DEFINE_bool (sticky, false,"A given client sends all reqs to one ""(random) server")
	DEFINE_bool (global, false,"All clients in a thread use the same SSL session")
	DEFINE_bool (handshakes, false,"Force 100% handshakes")
int	main (int argc, char *argv[])

Variables
string	f_servers [10]
int	f_num_servers = 0
int	tnum = 0

Function Documentation

DEFINE_bool	(	sticky	,
		false	,
		"A given client sends all reqs to one ""(random) server"
	)

DEFINE_bool	(	global	,
		false	,
		"All clients in a thread use the same SSL session"
	)

DEFINE_bool	(	handshakes	,
		false	,
		"Force 100% handshakes"
	)

DEFINE_int32	(	clients	,
		1	,
		"Number of simulated SSL clients"
	)

DEFINE_int32	(	threads	,
		1	,
		"Number of threads to spread clients across"
	)

DEFINE_int32	(	requests	,
		2	,
		"Total number of requests per client"
	)

DEFINE_int32	(	port	,
		9423	,
		"Server port"
	)

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 94 of file SSLCacheTest.cpp.

References f_num_servers, f_servers, ClientRunner::hits, i, ClientRunner::miss, ClientRunner::reqs, ClientRunner::run(), string, folly::pushmi::detail::t, threads, and folly::detail::distributed_mutex::time().

{
  gflags::SetUsageMessage(std::string("\n\n"
"usage: sslcachetest [options] -c <clients> -t <threads> servers\n"
));
  gflags::ParseCommandLineFlags(&argc, &argv, true);
  int reqs = 0;
  int hits = 0;
  int miss = 0;
  struct timeval start;
  struct timeval end;
  struct timeval result;

  srand((unsigned int)time(nullptr));

  for (int i = 1; i < argc; i++) {
    f_servers[f_num_servers++] = argv[i];
  }
  if (f_num_servers == 0) {
    cout << "require at least one server\n";
    return 1;
  }

  gettimeofday(&start, nullptr);
  if (FLAGS_threads == 1) {
    ClientRunner r;
    r.run();
    gettimeofday(&end, nullptr);
    reqs = r.reqs;
    hits = r.hits;
    miss = r.miss;
  }
  else {
    std::vector<ClientRunner> clients;
    std::vector<std::thread> threads;
    for (int t = 0; t < FLAGS_threads; t++) {
      threads.emplace_back([&] {
          clients[t].run();
        });
    }
    for (auto& thr: threads) {
      thr.join();
    }
    gettimeofday(&end, nullptr);

    for (const auto& client: clients) {
      reqs += client.reqs;
      hits += client.hits;
      miss += client.miss;
    }
  }

  timersub(&end, &start, &result);

  cout << "Requests: " << reqs << endl;
  cout << "Handshakes: " << miss << endl;
  cout << "Resumes: " << hits << endl;
  cout << "Runtime(ms): " << result.tv_sec << "." << result.tv_usec / 1000 <<
    endl;

  cout << "ops/sec: " << (reqs * 1.0) /
    ((double)result.tv_sec * 1.0 + (double)result.tv_usec / 1000000.0) << endl;

  return 0;
}

Variable Documentation

int f_num_servers = 0

Definition at line 37 of file SSLCacheTest.cpp.

Referenced by main(), and SSLCacheClient::start().

string f_servers[10]

Definition at line 36 of file SSLCacheTest.cpp.

Referenced by main(), and SSLCacheClient::start().

int tnum = 0

Definition at line 38 of file SSLCacheTest.cpp.