wangle::ObservingPipelineFactory< T, R, P > Class Template Reference

#include <ObservingHandler.h>

Inheritance diagram for wangle::ObservingPipelineFactory< T, R, P >:

Public Member Functions
	ObservingPipelineFactory (std::shared_ptr< ServerPool< R, P >> serverPool, std::shared_ptr< BroadcastPipelineFactory< T, R >> broadcastPipelineFactory)
ObservingPipeline< T >::Ptr	newPipeline (std::shared_ptr< folly::AsyncTransportWrapper > socket, const R &routingData, RoutingDataHandler< R > *, std::shared_ptr< TransportInfo > transportInfo) override
virtual BroadcastPool< T, R, P > *	broadcastPool (std::shared_ptr< BaseClientBootstrapFactory<>> clientFactory=nullptr)
Public Member Functions inherited from wangle::RoutingDataPipelineFactory< ObservingPipeline< T >, R >
virtual	~RoutingDataPipelineFactory ()

Protected Attributes
std::shared_ptr< ServerPool< R, P > >	serverPool_
std::shared_ptr< BroadcastPipelineFactory< T, R > >	broadcastPipelineFactory_
folly::ThreadLocalPtr< BroadcastPool< T, R, P > >	broadcastPool_

Detailed Description

template<typename T, typename R, typename P = DefaultPipeline>
class wangle::ObservingPipelineFactory< T, R, P >

Definition at line 74 of file ObservingHandler.h.

Constructor & Destructor Documentation

template<typename T, typename R, typename P = DefaultPipeline>

wangle::ObservingPipelineFactory< T, R, P >::ObservingPipelineFactory ( std::shared_ptr< ServerPool< R, P >>  serverPool, std::shared_ptr< BroadcastPipelineFactory< T, R >>  broadcastPipelineFactory  )

inline

Definition at line 77 of file ObservingHandler.h.

      : serverPool_(serverPool),
        broadcastPipelineFactory_(broadcastPipelineFactory) {}

Member Function Documentation

template<typename T, typename R, typename P = DefaultPipeline>

virtual BroadcastPool<T, R, P>* wangle::ObservingPipelineFactory< T, R, P >::broadcastPool ( std::shared_ptr< BaseClientBootstrapFactory<>>  clientFactory = nullptr )

inlinevirtual

Definition at line 100 of file ObservingHandler.h.

Referenced by TEST_F().

                                                                           {
    if (!broadcastPool_) {
      if (clientFactory) {
        broadcastPool_.reset(new BroadcastPool<T, R, P>(
            serverPool_, broadcastPipelineFactory_, clientFactory));
      } else {
        broadcastPool_.reset(
            new BroadcastPool<T, R, P>(serverPool_, broadcastPipelineFactory_));
      }
    }
    return broadcastPool_.get();
  }

template<typename T, typename R, typename P = DefaultPipeline>

ObservingPipeline<T>::Ptr wangle::ObservingPipelineFactory< T, R, P >::newPipeline ( std::shared_ptr< folly::AsyncTransportWrapper >  socket, const R &  routingData, RoutingDataHandler< R > *  , std::shared_ptr< TransportInfo >  transportInfo  )

inlineoverridevirtual

Implements wangle::RoutingDataPipelineFactory< ObservingPipeline< T >, R >.

Definition at line 83 of file ObservingHandler.h.

                                                           {
    auto pipeline = ObservingPipeline<T>::create();
    pipeline->addBack(AsyncSocketHandler(socket));
    auto handler = std::make_shared<ObservingHandler<T, R, P>>(
        routingData, broadcastPool());
    pipeline->addBack(handler);
    pipeline->finalize();

    pipeline->setTransportInfo(transportInfo);

    return pipeline;
  }

Member Data Documentation

template<typename T, typename R, typename P = DefaultPipeline>

std::shared_ptr<BroadcastPipelineFactory<T, R> > wangle::ObservingPipelineFactory< T, R, P >::broadcastPipelineFactory_

protected

Definition at line 116 of file ObservingHandler.h.

template<typename T, typename R, typename P = DefaultPipeline>

folly::ThreadLocalPtr<BroadcastPool<T, R, P> > wangle::ObservingPipelineFactory< T, R, P >::broadcastPool_

protected

Definition at line 117 of file ObservingHandler.h.

template<typename T, typename R, typename P = DefaultPipeline>

std::shared_ptr<ServerPool<R, P> > wangle::ObservingPipelineFactory< T, R, P >::serverPool_

protected

Definition at line 115 of file ObservingHandler.h.

---

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

• proxygen/wangle/wangle/channel/broadcast/ObservingHandler.h