proxygen: TestAcceptor Class Reference

Inheritance diagram for TestAcceptor:

Public Member Functions
	TestAcceptor (const ServerSocketConfig &accConfig)

void	onNewConnection (folly::AsyncTransportWrapper::UniquePtr, const folly::SocketAddress *, const std::string &, SecureTransportType, const TransportInfo &) override

	TestAcceptor ()

void	onNewConnection (AsyncTransportWrapper::UniquePtr, const folly::SocketAddress *, const std::string &, SecureTransportType, const TransportInfo &) override

Public Member Functions inherited from wangle::Acceptor
	Acceptor (const ServerSocketConfig &accConfig)

	~Acceptor () override

virtual void	setSSLCacheProvider (const std::shared_ptr< SSLCacheProvider > &cacheProvider)

virtual void	init (folly::AsyncServerSocket serverSocket, folly::EventBase eventBase, SSLStats *stats=nullptr)

virtual void	resetSSLContextConfigs ()

void	addSSLContextConfig (const SSLContextConfig &sslCtxConfig)

SSLContextManager *	getSSLContextManager () const

virtual void	setTLSTicketSecrets (const std::vector< std::string > &oldSecrets, const std::vector< std::string > &currentSecrets, const std::vector< std::string > &newSecrets)

uint32_t	getNumConnections () const

virtual folly::EventBase *	getEventBase () const

virtual wangle::ConnectionManager *	getConnectionManager ()

void	addConnection (wangle::ManagedConnection *connection)

State	getState () const

std::chrono::milliseconds	getConnTimeout () const

const std::string &	getName () const

std::chrono::milliseconds	getSSLHandshakeTimeout () const

void	setGracefulShutdownTimeout (std::chrono::milliseconds gracefulShutdown)

std::chrono::milliseconds	getGracefulShutdownTimeout () const

virtual void	forceStop ()

bool	isSSL () const

const ServerSocketConfig &	getConfig () const

virtual void	onDoneAcceptingConnection (int fd, const folly::SocketAddress &clientAddr, std::chrono::steady_clock::time_point acceptTime) noexcept

void	processEstablishedConnection (int fd, const folly::SocketAddress &clientAddr, std::chrono::steady_clock::time_point acceptTime, TransportInfo &tinfo) noexcept

virtual void	startHandshakeManager (folly::AsyncSSLSocket::UniquePtr sslSock, Acceptor *acceptor, const folly::SocketAddress &clientAddr, std::chrono::steady_clock::time_point acceptTime, TransportInfo &tinfo) noexcept

void	drainAllConnections ()

virtual void	drainConnections (double pctToDrain)

void	dropAllConnections ()

virtual void	dropConnections (double pctToDrop)

virtual void	plaintextConnectionReady (folly::AsyncTransportWrapper::UniquePtr sock, const folly::SocketAddress &clientAddr, const std::string &nextProtocolName, SecureTransportType secureTransportType, TransportInfo &tinfo)

void	connectionReady (folly::AsyncTransportWrapper::UniquePtr sock, const folly::SocketAddress &clientAddr, const std::string &nextProtocolName, SecureTransportType secureTransportType, TransportInfo &tinfo)

virtual void	sslConnectionReady (folly::AsyncTransportWrapper::UniquePtr sock, const folly::SocketAddress &clientAddr, const std::string &nextProtocol, SecureTransportType secureTransportType, TransportInfo &tinfo)

virtual void	sslConnectionError (const folly::exception_wrapper &ex)

virtual void	updateSSLStats (const folly::AsyncTransportWrapper *, std::chrono::milliseconds, SSLErrorEnum) noexcept

Public Member Functions inherited from folly::AsyncServerSocket::AcceptCallback
virtual	~AcceptCallback ()=default

virtual void	acceptStarted () noexcept

Public Member Functions inherited from wangle::ConnectionManager::Callback
virtual	~Callback ()=default

Public Member Functions inherited from folly::AsyncUDPServerSocket::Callback
virtual void	onListenPaused () noexcept

virtual void	onListenResumed () noexcept

virtual	~Callback ()=default

Private Attributes
EventBase	base_

Additional Inherited Members
Public Types inherited from wangle::Acceptor
enum	State : uint32_t { State::kInit, State::kRunning, State::kDraining, State::kDone }

Static Public Member Functions inherited from wangle::Acceptor
static uint64_t	getTotalNumPendingSSLConns ()

Protected Member Functions inherited from wangle::Acceptor
virtual uint64_t	getConnectionCountForLoadShedding (void) const

virtual uint64_t	getActiveConnectionCountForLoadShedding () const

virtual uint64_t	getWorkerMaxConnections () const

virtual bool	canAccept (const folly::SocketAddress &)

void	onListenStarted () noexceptoverride

void	onListenStopped () noexceptoverride

void	onDataAvailable (std::shared_ptr< folly::AsyncUDPSocket >, const folly::SocketAddress &, std::unique_ptr< folly::IOBuf >, bool) noexceptoverride

virtual folly::AsyncSocket::UniquePtr	makeNewAsyncSocket (folly::EventBase *base, int fd)

virtual folly::AsyncSSLSocket::UniquePtr	makeNewAsyncSSLSocket (const std::shared_ptr< folly::SSLContext > &ctx, folly::EventBase *base, int fd)

virtual void	onConnectionsDrained ()

void	connectionAccepted (int fd, const folly::SocketAddress &clientAddr) noexceptoverride

void	acceptError (const std::exception &ex) noexceptoverride

void	acceptStopped () noexceptoverride

void	onEmpty (const wangle::ConnectionManager &cm) override

void	onConnectionAdded (const ManagedConnection *) override

void	onConnectionRemoved (const ManagedConnection *) override

void	setLoadShedConfig (std::shared_ptr< const LoadShedConfiguration > loadShedConfig, const IConnectionCounter *counter)

virtual void	initDownstreamConnectionManager (folly::EventBase *eventBase)

virtual DefaultToFizzPeekingCallback *	getFizzPeeker ()

virtual std::shared_ptr< fizz::server::FizzServerContext >	createFizzContext ()

virtual std::shared_ptr< fizz::server::TicketCipher >	createFizzTicketCipher (folly::Optional< std::string >=folly::none)

void	updateFizzContext (fizz::server::FizzServerContext *)

Protected Attributes inherited from wangle::Acceptor
folly::EventBase *	base_ {nullptr}

const ServerSocketConfig	accConfig_

folly::AsyncSocket::OptionMap	socketOptions_

std::unique_ptr< SSLContextManager >	sslCtxManager_

SecurityProtocolContextManager	securityProtocolCtxManager_

TLSPlaintextPeekingCallback	tlsPlaintextPeekingCallback_

DefaultToSSLPeekingCallback	defaultPeekingCallback_

DefaultToFizzPeekingCallback	defaultFizzPeeker_

wangle::ConnectionManager::UniquePtr	downstreamConnectionManager_

std::shared_ptr< SSLCacheProvider >	cacheProvider_

wangle::TLSTicketKeySeeds	currentSecrets_

Detailed Description

Definition at line 31 of file AcceptorTest.cpp.

Constructor & Destructor Documentation

TestAcceptor::TestAcceptor ( const ServerSocketConfig & accConfig )

inlineexplicit

Definition at line 33 of file AcceptorTest.cpp.

34 : Acceptor(accConfig) {}

wangle::Acceptor::Acceptor

Acceptor(const ServerSocketConfig &accConfig)

Definition: Acceptor.cpp:54

TestAcceptor::TestAcceptor ( )

inline

Definition at line 70 of file BootstrapTest.cpp.

References wangle::Acceptor::init().

                  : Acceptor(ServerSocketConfig()) {
     Acceptor::init(nullptr, &base_);
   }

Member Function Documentation

void TestAcceptor::onNewConnection	(	folly::AsyncTransportWrapper::UniquePtr	,
		const folly::SocketAddress *	,
		const std::string &	,
		SecureTransportType	,
		const TransportInfo &
	)

inlineoverridevirtual

Invoked when a new connection is created. This is where application starts processing a new downstream connection.

NOTE: Application should add the new connection to downstreamConnectionManager so that it can be garbage collected after certain period of idleness.

Parameters

sock	the socket connected to the client
address	the address of the client
nextProtocolName	the name of the L6 or L7 protocol to be spoken on the connection, if known (e.g., from TLS NPN during secure connection setup), or an empty string if unknown
secureTransportType	the name of the secure transport type that was requested by the client.

Reimplemented from wangle::Acceptor.

Definition at line 36 of file AcceptorTest.cpp.

References folly::getEventBase(), and folly::EventBase::terminateLoopSoon().

                                                         {
     addConnection(new TestConnection);
 
     getEventBase()->terminateLoopSoon();
   }

void TestAcceptor::onNewConnection	(	AsyncTransportWrapper::UniquePtr	,
		const folly::SocketAddress *	,
		const std::string &	,
		SecureTransportType	,
		const TransportInfo &
	)

inlineoverridevirtual

Invoked when a new connection is created. This is where application starts processing a new downstream connection.

NOTE: Application should add the new connection to downstreamConnectionManager so that it can be garbage collected after certain period of idleness.

Parameters

sock	the socket connected to the client
address	the address of the client
nextProtocolName	the name of the L6 or L7 protocol to be spoken on the connection, if known (e.g., from TLS NPN during secure connection setup), or an empty string if unknown
secureTransportType	the name of the secure transport type that was requested by the client.

Reimplemented from wangle::Acceptor.

Definition at line 73 of file BootstrapTest.cpp.

77 {}

Member Data Documentation

EventBase TestAcceptor::base_

private

Definition at line 68 of file BootstrapTest.cpp.

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

proxygen/lib/services/test/AcceptorTest.cpp
proxygen/wangle/wangle/bootstrap/test/BootstrapTest.cpp

Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation