CustomPipelineFactory Class Reference

Inheritance diagram for CustomPipelineFactory:

Public Member Functions
	CustomPipelineFactory ()
TestObsPipeline::Ptr	newPipeline (std::shared_ptr< folly::AsyncTransportWrapper > socket, const TestRoutingData &routingData, RoutingDataHandler< TestRoutingData > *, std::shared_ptr< TransportInfo >) override
BytesPipeline::Ptr	newPipeline (std::shared_ptr< AsyncTransportWrapper > sock) override
Public Member Functions inherited from wangle::PipelineFactory< BytesPipeline >
virtual BytesPipeline::Ptr	newPipeline (std::shared_ptr< folly::AsyncUDPSocket >, const folly::SocketAddress &)
virtual	~PipelineFactory ()=default
Public Member Functions inherited from wangle::ObservingPipelineFactory< std::shared_ptr< folly::IOBuf >, TestRoutingData >
	ObservingPipelineFactory (std::shared_ptr< ServerPool< TestRoutingData, DefaultPipeline >> serverPool, std::shared_ptr< BroadcastPipelineFactory< std::shared_ptr< folly::IOBuf >, TestRoutingData >> broadcastPipelineFactory)
ObservingPipeline< std::shared_ptr< folly::IOBuf > >::Ptr	newPipeline (std::shared_ptr< folly::AsyncTransportWrapper > socket, const TestRoutingData &routingData, RoutingDataHandler< TestRoutingData > *, std::shared_ptr< TransportInfo > transportInfo) override
virtual BroadcastPool< std::shared_ptr< folly::IOBuf >, TestRoutingData, DefaultPipeline > *	broadcastPool (std::shared_ptr< BaseClientBootstrapFactory<>> clientFactory=nullptr)
Public Member Functions inherited from wangle::RoutingDataPipelineFactory< ObservingPipeline< std::shared_ptr< folly::IOBuf > >, TestRoutingData >
virtual	~RoutingDataPipelineFactory ()

Public Attributes
TestRoutingData	routingData_
std::atomic< int >	routingPipelines_ {0}
Public Attributes inherited from TestPipelineFactory
std::atomic< int >	pipelines {0}
std::atomic< int >	pipelines_ {0}

Additional Inherited Members
Protected Attributes inherited from wangle::ObservingPipelineFactory< std::shared_ptr< folly::IOBuf >, TestRoutingData >
std::shared_ptr< ServerPool< TestRoutingData, DefaultPipeline > >	serverPool_
std::shared_ptr< BroadcastPipelineFactory< std::shared_ptr< folly::IOBuf >, TestRoutingData > >	broadcastPipelineFactory_
folly::ThreadLocalPtr< BroadcastPool< std::shared_ptr< folly::IOBuf >, TestRoutingData, DefaultPipeline > >	broadcastPool_

Detailed Description

Definition at line 57 of file ObservingClientPipelineTest.cpp.

Constructor & Destructor Documentation

CustomPipelineFactory::CustomPipelineFactory ( )

inline

Definition at line 62 of file ObservingClientPipelineTest.cpp.

  : ObservingPipelineFactory<std::shared_ptr<folly::IOBuf>, TestRoutingData>(
      nullptr, nullptr) {
  }

Member Function Documentation

TestObsPipeline::Ptr CustomPipelineFactory::newPipeline ( std::shared_ptr< folly::AsyncTransportWrapper >  socket, const TestRoutingData &  routingData, RoutingDataHandler< TestRoutingData > *  , std::shared_ptr< TransportInfo >    )

inlineoverridevirtual

Implements wangle::RoutingDataPipelineFactory< ObservingPipeline< std::shared_ptr< folly::IOBuf > >, TestRoutingData >.

Definition at line 67 of file ObservingClientPipelineTest.cpp.

References wangle::Pipeline< R, W >::create().

                                               {
    routingData_ = routingData;
    auto pipeline = TestObsPipeline::create();
    pipeline->addBack(AsyncSocketHandler(socket));
    pipeline->finalize();
    routingPipelines_++;
    return pipeline;
  }

BytesPipeline::Ptr CustomPipelineFactory::newPipeline ( std::shared_ptr< AsyncTransportWrapper >  sock )

inlineoverridevirtual

Reimplemented from TestPipelineFactory.

Definition at line 80 of file ObservingClientPipelineTest.cpp.

References ADD_FAILURE, and TestPipelineFactory::newPipeline().

                                                          {
    // Should not be called.
    ADD_FAILURE() << "Should not be called, "
                  << "this function is typically called from "
                  << "makePipeline that has been overridden in this "
                  << "test to call a different version of newPipeline.";
    return TestPipelineFactory::newPipeline(sock);
  }

Member Data Documentation

TestRoutingData CustomPipelineFactory::routingData_

Definition at line 90 of file ObservingClientPipelineTest.cpp.

std::atomic<int> CustomPipelineFactory::routingPipelines_ {0}

Definition at line 91 of file ObservingClientPipelineTest.cpp.

---

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

• proxygen/wangle/wangle/channel/broadcast/test/ObservingClientPipelineTest.cpp