SimpleServerPool Class Reference

Inheritance diagram for SimpleServerPool:

Public Member Functions
Future< DefaultPipeline * >	connect (BaseClientBootstrap< DefaultPipeline > *client, const std::string &) noexceptoverride
Public Member Functions inherited from wangle::ServerPool< std::string >
virtual	~ServerPool ()

Detailed Description

Implementation of a broadcast ServerPool that establishes connection to an upstream server.

Definition at line 133 of file BroadcastProxy.cpp.

Member Function Documentation

Future<DefaultPipeline*> SimpleServerPool::connect ( BaseClientBootstrap< DefaultPipeline > *  client, const std::string &  routingData  )

inlineoverridevirtualnoexcept

Kick off an upstream connect request given the BaseClientBootstrap when a broadcast is not available locally.

Implements wangle::ServerPool< std::string >.

Definition at line 135 of file BroadcastProxy.cpp.

References wangle::BaseClientBootstrap< P >::connect(), folly::INFO, and folly::SocketAddress::setFromLocalPort().

                                            {
    SocketAddress address;
    address.setFromLocalPort(FLAGS_upstream_port);

    LOG(INFO) << "Connecting to upstream server " << address
              << " for subscribing to broadcast";
    return client->connect(address);
  }

---

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

• proxygen/wangle/wangle/example/broadcast/BroadcastProxy.cpp