proxygen
Public Member Functions | List of all members
wangle::RoutingDataPipelineFactory< Pipeline, R > Class Template Referenceabstract

#include <AcceptRoutingHandler.h>

Public Member Functions

virtual ~RoutingDataPipelineFactory ()
 
virtual Pipeline::Ptr newPipeline (std::shared_ptr< folly::AsyncTransportWrapper > socket, const R &routingData, RoutingDataHandler< R > *routingHandler, std::shared_ptr< TransportInfo > transportInfo)=0
 

Detailed Description

template<typename Pipeline, typename R>
class wangle::RoutingDataPipelineFactory< Pipeline, R >

An AcceptPipeline with the ability to hash connections to a specific worker thread. Hashing can be based on data passed in by the client.

For each connection, AcceptRoutingHandler creates and maintains a routing pipeline internally. The routing pipeline should take care of reading from the socket, parsing the data based on which to hash the connection and invoking RoutingDataHandler::Callback::onRoutingData to notify the AcceptRoutingHandler. AcceptRoutingHandler then pauses reads from the socket, moves the connection over to the hashed worker thread, and resumes reading from the socket on the child pipeline.

Definition at line 39 of file AcceptRoutingHandler.h.

Constructor & Destructor Documentation

template<typename Pipeline, typename R>
virtual wangle::RoutingDataPipelineFactory< Pipeline, R >::~RoutingDataPipelineFactory ( )
inlinevirtual

Definition at line 116 of file AcceptRoutingHandler.h.

116 {}

Member Function Documentation

template<typename Pipeline, typename R>
virtual Pipeline::Ptr wangle::RoutingDataPipelineFactory< Pipeline, R >::newPipeline ( std::shared_ptr< folly::AsyncTransportWrapper >  socket,
const R &  routingData,
RoutingDataHandler< R > *  routingHandler,
std::shared_ptr< TransportInfo >  transportInfo 
)
pure virtual

Implemented in SimpleObservingPipelineFactory, wangle::MockObservingPipelineFactory, wangle::MockDownstreamPipelineFactory, ServerPipelineFactory, wangle::ObservingPipelineFactory< T, R, P >, wangle::ObservingPipelineFactory< std::shared_ptr< folly::IOBuf >, TestRoutingData >, wangle::ObservingPipelineFactory< int, std::string >, wangle::ObservingPipelineFactory< std::string, std::string >, and CustomPipelineFactory.

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