Public Member Functions
	jresponderbuf (std::shared_ptr< jlogger > &logger, std::shared_ptr< jring< ringflow >> &flowring, std::shared_ptr< jring< ringin >> &inputring, std::shared_ptr< jring< ringout >> &outputring, std::shared_ptr< ProtocolPP::jbuffer< uint8_t, 256 >> &memory, uint64_t seed, bool use_crypto, uint32_t threads=1, const char units="us", const char readlatency="80..120", const char computelatency="2000..5000", const char writelatency="50..100")

virtual	~jresponderbuf ()=default
	standard deconstructor

void	dequeue (std::string flow)
	enqueue flows to responder

void	enqueue (std::string &flow)

void	run ()
	run the responder

void	teardown ()
	teardown the responder

	jresponderbuf (jresponderbuf &rhs)=delete

	jresponderbuf (const jresponderbuf &rhs)=delete

Constructor & Destructor Documentation

◆ jresponderbuf()

InterfacePP::jresponderbuf::jresponderbuf	(	std::shared_ptr< jlogger > &	logger,
		std::shared_ptr< jring< ringflow >> &	flowring,
		std::shared_ptr< jring< ringin >> &	inputring,
		std::shared_ptr< jring< ringout >> &	outputring,
		std::shared_ptr< ProtocolPP::jbuffer< uint8_t, 256 >> &	memory,
		uint64_t	seed,
		bool	use_crypto,
		uint32_t	threads = `1`,
		const char *	units = `"us"`,
		const char *	readlatency = `"80..120"`,
		const char *	computelatency = `"2000..5000"`,
		const char *	writelatency = `"50..100"`
	)

constructor for responder to test wasp interface

Parameters

logger	- object to print output
flowring	- software ring for the flows
inputring	- software ring for the input packets
outputring	- software ring for the output packets
memory	- shared buffer memory for responder and producer
seed	- seed for the random number generator
use_crypto	- use cryptographic quality random numbers
threads	- number of threads (execution units) per responder
units	- units of time for latencies
readlatency	- latency for read transactions
computelatency	- latency for compute transactions
writelatency	- latency for write transactions

void InterfacePP::jresponderbuf::enqueue ( std::string & flow )

dequeue flows from responder

Parameters

flow	- flow to dequeue

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