wangle::CloseOnReleaseFilter< Req, Resp > Class Template Reference

#include <CloseOnReleaseFilter.h>

Inheritance diagram for wangle::CloseOnReleaseFilter< Req, Resp >:

Public Member Functions
	CloseOnReleaseFilter (std::shared_ptr< Service< Req, Resp >> service)
folly::Future< Resp >	operator() (Req req) override
folly::Future< folly::Unit >	close () override
Public Member Functions inherited from wangle::ServiceFilter< Req, Resp >
	ServiceFilter (std::shared_ptr< Service< Req, Resp >> service)
	~ServiceFilter () override=default
folly::Future< folly::Unit >	close () override
bool	isAvailable () override
Public Member Functions inherited from wangle::Service< Req, Resp >
virtual	~Service ()=default

Private Attributes
std::atomic< bool >	released {false}

Additional Inherited Members
Protected Attributes inherited from wangle::ServiceFilter< Req, Resp >
std::shared_ptr< Service< Req, Resp > >	service_

Detailed Description

template<typename Req, typename Resp = Req>
class wangle::CloseOnReleaseFilter< Req, Resp >

A service that rejects all requests after its 'close' method has been invoked.

Definition at line 28 of file CloseOnReleaseFilter.h.

Constructor & Destructor Documentation

template<typename Req , typename Resp = Req>

wangle::CloseOnReleaseFilter< Req, Resp >::CloseOnReleaseFilter ( std::shared_ptr< Service< Req, Resp >>  service )

inlineexplicit

Definition at line 30 of file CloseOnReleaseFilter.h.

      : ServiceFilter<Req, Resp>(service) {}

Member Function Documentation

template<typename Req , typename Resp = Req>

folly::Future<folly::Unit> wangle::CloseOnReleaseFilter< Req, Resp >::close ( )

inlineoverridevirtual

Reimplemented from wangle::Service< Req, Resp >.

Definition at line 42 of file CloseOnReleaseFilter.h.

References folly::makeFuture(), wangle::CloseOnReleaseFilter< Req, Resp >::released, and wangle::ServiceFilter< Req, Resp >::service_.

                                          {
    if (!released.exchange(true)) {
      return this->service_->close();
    } else {
      return folly::makeFuture();
    }
  }

template<typename Req , typename Resp = Req>

folly::Future<Resp> wangle::CloseOnReleaseFilter< Req, Resp >::operator() ( Req  req )

inlineoverridevirtual

Implements wangle::Service< Req, Resp >.

Definition at line 33 of file CloseOnReleaseFilter.h.

References folly::gen::move, wangle::CloseOnReleaseFilter< Req, Resp >::released, and wangle::ServiceFilter< Req, Resp >::service_.

                                                 {
    if (!released ){
      return (*this->service_)(std::move(req));
    } else {
      return folly::makeFuture<Resp>(
        folly::make_exception_wrapper<std::runtime_error>("Service Closed"));
    }
  }

Member Data Documentation

template<typename Req , typename Resp = Req>

std::atomic<bool> wangle::CloseOnReleaseFilter< Req, Resp >::released {false}

private

Definition at line 50 of file CloseOnReleaseFilter.h.

Referenced by wangle::CloseOnReleaseFilter< Req, Resp >::close(), and wangle::CloseOnReleaseFilter< Req, Resp >::operator()().

---

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

• proxygen/wangle/wangle/service/CloseOnReleaseFilter.h