proxygen::ServiceWorker Class Reference

#include <ServiceWorker.h>

Public Types
using	AcceptorMap = std::map< AcceptorAddress, std::unique_ptr< wangle::Acceptor >>
using	NamedAddressMap = std::map< std::string, AcceptorAddress >

Public Member Functions
	ServiceWorker (Service *service, RequestWorker *worker)
virtual	~ServiceWorker ()
Service *	getService () const
void	addServiceAcceptor (const folly::SocketAddress &address, std::unique_ptr< wangle::Acceptor > acceptor)
void	addServiceAcceptor (const AcceptorAddress &accAddress, std::unique_ptr< wangle::Acceptor > acceptor)
void	drainServiceAcceptor (const folly::SocketAddress &address)
void	drainServiceAcceptor (const AcceptorAddress &accAddress)
RequestWorker *	getRequestWorker () const
const AcceptorMap &	getAcceptors ()
wangle::Acceptor *	getAcceptorByName (std::string name) const
const AcceptorMap &	getDrainingAcceptors ()
virtual void	flushStats ()
virtual void	clearAcceptors ()
virtual void	clearDrainingAcceptors ()
wangle::IConnectionCounter *	getConnectionCounter ()
virtual void	forceStop ()

Protected Attributes
wangle::SimpleConnectionCounter	connectionCounter_

Private Member Functions
	ServiceWorker (ServiceWorker const &)=delete
ServiceWorker &	operator= (ServiceWorker const &)=delete
void	addAcceptor (const AcceptorAddress &accAddress, std::unique_ptr< wangle::Acceptor > acceptor, AcceptorMap &acceptors)

Private Attributes
Service *	service_
RequestWorker *	worker_
AcceptorMap	acceptors_
NamedAddressMap	namedAddress_
AcceptorMap	drainingAcceptors_

Detailed Description

ServiceWorker contains all of the per-thread information for a Service.

ServiceWorker contains a pointer back to the single global Service. It contains a list of ProxyAcceptor objects for this worker thread, one per VIP.

ServiceWorker fits into the Proxygen object hierarchy as follows:

• Service: one instance (globally across the entire program)
• ServiceWorker: one instance per thread
• ServiceAcceptor: one instance per VIP per thread

Definition at line 37 of file ServiceWorker.h.

Member Typedef Documentation

using proxygen::ServiceWorker::AcceptorMap = std::map<AcceptorAddress, std::unique_ptr<wangle::Acceptor>>

Definition at line 40 of file ServiceWorker.h.

using proxygen::ServiceWorker::NamedAddressMap = std::map<std::string, AcceptorAddress>

Definition at line 42 of file ServiceWorker.h.

Constructor & Destructor Documentation

proxygen::ServiceWorker::ServiceWorker ( Service *  service, RequestWorker *  worker  )

inline

Definition at line 44 of file ServiceWorker.h.

      : service_(service), worker_(worker) {
  }

virtual proxygen::ServiceWorker::~ServiceWorker ( )

inlinevirtual

Definition at line 48 of file ServiceWorker.h.

                           {
  }

proxygen::ServiceWorker::ServiceWorker ( ServiceWorker const &  )

privatedelete

Member Function Documentation

void proxygen::ServiceWorker::addAcceptor ( const AcceptorAddress &  accAddress, std::unique_ptr< wangle::Acceptor >  acceptor, AcceptorMap &  acceptors  )

inlineprivate

Definition at line 140 of file ServiceWorker.h.

References folly::gen::move.

Referenced by addServiceAcceptor(), and drainServiceAcceptor().

                                           {
    CHECK(acceptors.find(accAddress) == acceptors.end());
    acceptors.insert(std::make_pair(accAddress, std::move(acceptor)));
  }

void proxygen::ServiceWorker::addServiceAcceptor ( const folly::SocketAddress &  address, std::unique_ptr< wangle::Acceptor >  acceptor  )

inline

Definition at line 55 of file ServiceWorker.h.

References folly::gen::move, and proxygen::AcceptorAddress::TCP.

                                                                  {
    addServiceAcceptor(
        AcceptorAddress(address, AcceptorAddress::AcceptorType::TCP),
        std::move(acceptor));
  }

void proxygen::ServiceWorker::addServiceAcceptor ( const AcceptorAddress &  accAddress, std::unique_ptr< wangle::Acceptor >  acceptor  )

inline

Definition at line 62 of file ServiceWorker.h.

References acceptors_, addAcceptor(), wangle::Acceptor::getName(), folly::gen::move, and namedAddress_.

                                                                  {
    namedAddress_.emplace(acceptor->getName(), accAddress);
    addAcceptor(accAddress, std::move(acceptor), acceptors_);
  }

virtual void proxygen::ServiceWorker::clearAcceptors ( )

inlinevirtual

Definition at line 115 of file ServiceWorker.h.

References acceptors_, drainingAcceptors_, and namedAddress_.

                                {
    acceptors_.clear();
    namedAddress_.clear();
    drainingAcceptors_.clear();
  }

virtual void proxygen::ServiceWorker::clearDrainingAcceptors ( )

inlinevirtual

Definition at line 121 of file ServiceWorker.h.

References drainingAcceptors_.

                                        {
    drainingAcceptors_.clear();
  }

void proxygen::ServiceWorker::drainServiceAcceptor ( const folly::SocketAddress &  address )

inline

Definition at line 68 of file ServiceWorker.h.

References proxygen::AcceptorAddress::TCP.

                                                               {
    drainServiceAcceptor(
        AcceptorAddress(address, AcceptorAddress::AcceptorType::TCP));
  }

void proxygen::ServiceWorker::drainServiceAcceptor ( const AcceptorAddress &  accAddress )

inline

Definition at line 73 of file ServiceWorker.h.

References acceptors_, addAcceptor(), drainingAcceptors_, folly::gen::move, name, and namedAddress_.

                                                               {
    // Move the old acceptor to drainingAcceptors_ if present
    const auto& it = acceptors_.find(accAddress);
    if (it != acceptors_.end()) {
      auto name = it->second->getName();
      addAcceptor(accAddress, std::move(it->second), drainingAcceptors_);
      acceptors_.erase(it);
      namedAddress_.erase(name);
    }
  }

virtual void proxygen::ServiceWorker::flushStats ( )

inlinevirtual

Definition at line 111 of file ServiceWorker.h.

                            {
  }

virtual void proxygen::ServiceWorker::forceStop ( )

inlinevirtual

Definition at line 129 of file ServiceWorker.h.

                           {
  }

wangle::Acceptor* proxygen::ServiceWorker::getAcceptorByName ( std::string  name ) const

inline

Find an acceptor by name running in the same request worker.

Definition at line 95 of file ServiceWorker.h.

References acceptors_, and namedAddress_.

                                                          {
    auto it = namedAddress_.find(name);
    if (it != namedAddress_.end()) {
      auto it2 = acceptors_.find(it->second);
      if (it2 != acceptors_.end()) {
        return it2->second.get();
      }
    }
    return nullptr;
  }

const AcceptorMap& proxygen::ServiceWorker::getAcceptors ( )

inline

Definition at line 88 of file ServiceWorker.h.

References acceptors_.

                                    {
    return acceptors_;
  }

wangle::IConnectionCounter* proxygen::ServiceWorker::getConnectionCounter ( )

inline

Definition at line 125 of file ServiceWorker.h.

References connectionCounter_.

                                                   {
    return &connectionCounter_;
  }

const AcceptorMap& proxygen::ServiceWorker::getDrainingAcceptors ( )

inline

Definition at line 106 of file ServiceWorker.h.

References drainingAcceptors_.

                                            {
    return drainingAcceptors_;
  }

RequestWorker* proxygen::ServiceWorker::getRequestWorker ( ) const

inline

Definition at line 84 of file ServiceWorker.h.

References worker_.

                                          {
    return worker_;
  }

Service* proxygen::ServiceWorker::getService ( ) const

inline

Definition at line 51 of file ServiceWorker.h.

References service_.

                              {
    return service_;
  }

ServiceWorker& proxygen::ServiceWorker::operator= ( ServiceWorker const &  )

privatedelete

Member Data Documentation

AcceptorMap proxygen::ServiceWorker::acceptors_

private

A list of the Acceptor objects specific to this worker thread, one Acceptor per VIP.

Definition at line 162 of file ServiceWorker.h.

Referenced by addServiceAcceptor(), clearAcceptors(), drainServiceAcceptor(), getAcceptorByName(), and getAcceptors().

wangle::SimpleConnectionCounter proxygen::ServiceWorker::connectionCounter_

protected

Definition at line 133 of file ServiceWorker.h.

Referenced by getConnectionCounter().

AcceptorMap proxygen::ServiceWorker::drainingAcceptors_

private

A list of Acceptors that are being drained and will be deleted soon.

Definition at line 173 of file ServiceWorker.h.

Referenced by clearAcceptors(), clearDrainingAcceptors(), drainServiceAcceptor(), and getDrainingAcceptors().

NamedAddressMap proxygen::ServiceWorker::namedAddress_

private

A list of the addresses indexed by name, used to look up an acceptor by name

Definition at line 168 of file ServiceWorker.h.

Referenced by addServiceAcceptor(), clearAcceptors(), drainServiceAcceptor(), and getAcceptorByName().

Service* proxygen::ServiceWorker::service_

private

The global Service object.

Definition at line 150 of file ServiceWorker.h.

Referenced by getService().

RequestWorker* proxygen::ServiceWorker::worker_

private

The RequestWorker that is actually responsible for running the EventBase loop in this thread.

Definition at line 156 of file ServiceWorker.h.

Referenced by getRequestWorker().

---

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

• proxygen/lib/services/ServiceWorker.h