RpcPipelineFactory Class Reference

Inheritance diagram for RpcPipelineFactory:

Public Member Functions
SerializePipeline::Ptr	newPipeline (std::shared_ptr< AsyncTransportWrapper > sock) override
SerializePipeline::Ptr	newPipeline (std::shared_ptr< AsyncTransportWrapper > sock) override
Public Member Functions inherited from wangle::PipelineFactory< SerializePipeline >
virtual SerializePipeline::Ptr	newPipeline (std::shared_ptr< folly::AsyncUDPSocket >, const folly::SocketAddress &)
virtual	~PipelineFactory ()=default

Private Attributes
ExecutorFilter< Bonk, Xtruct >	service_

Detailed Description

Definition at line 42 of file RpcClient.cpp.

Member Function Documentation

SerializePipeline::Ptr RpcPipelineFactory::newPipeline ( std::shared_ptr< AsyncTransportWrapper >  sock )

inlineoverridevirtual

Implements wangle::PipelineFactory< SerializePipeline >.

Definition at line 44 of file RpcClient.cpp.

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

                                                          {
    auto pipeline = SerializePipeline::create();
    pipeline->addBack(AsyncSocketHandler(sock));
    // ensure we can write from any thread
    pipeline->addBack(EventBaseHandler());
    pipeline->addBack(LengthFieldBasedFrameDecoder());
    pipeline->addBack(LengthFieldPrepender());
    pipeline->addBack(ClientSerializeHandler());
    pipeline->finalize();

    return pipeline;
  }

SerializePipeline::Ptr RpcPipelineFactory::newPipeline ( std::shared_ptr< AsyncTransportWrapper >  sock )

inlineoverridevirtual

Implements wangle::PipelineFactory< SerializePipeline >.

Definition at line 64 of file RpcServer.cpp.

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

                                                          {
    auto pipeline = SerializePipeline::create();
    pipeline->addBack(AsyncSocketHandler(sock));
    // ensure we can write from any thread
    pipeline->addBack(EventBaseHandler());
    pipeline->addBack(LengthFieldBasedFrameDecoder());
    pipeline->addBack(LengthFieldPrepender());
    pipeline->addBack(ServerSerializeHandler());
    // We could use a serial dispatcher instead easily
    // pipeline->addBack(SerialServerDispatcher<Bonk>(&service_));
    // Or a Pipelined Dispatcher
    // pipeline->addBack(PipelinedServerDispatcher<Bonk>(&service_));
    pipeline->addBack(MultiplexServerDispatcher<Bonk, Xtruct>(&service_));
    pipeline->finalize();

    return pipeline;
  }

Member Data Documentation

ExecutorFilter<Bonk, Xtruct> RpcPipelineFactory::service_

private

Initial value:

{
      std::make_shared<CPUThreadPoolExecutor>(10),
      std::make_shared<RpcService>()}

Definition at line 84 of file RpcServer.cpp.

---

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

• proxygen/wangle/wangle/example/rpc/RpcClient.cpp
• proxygen/wangle/wangle/example/rpc/RpcServer.cpp