BonkMultiplexClientDispatcher Class Reference

Inheritance diagram for BonkMultiplexClientDispatcher:

Public Member Functions
void	read (Context *, Xtruct in) override
Future< Xtruct >	operator() (Bonk arg) override
Future< Unit >	close () override
Future< Unit >	close (Context *ctx) override
Public Member Functions inherited from wangle::ClientDispatcherBase< SerializePipeline, Bonk, Xtruct >
	~ClientDispatcherBase () override
void	setPipeline (SerializePipeline *pipeline)
folly::Future< folly::Unit >	close () override
folly::Future< folly::Unit >	close (Context *ctx) override
Public Member Functions inherited from wangle::HandlerAdapter< Xtruct, Bonk >
void	read (Context *ctx, Xtructmsg) override
folly::Future< folly::Unit >	write (Context *ctx, Bonkmsg) override
Public Member Functions inherited from wangle::Handler< Xtruct, Xtruct, Bonk, Bonk >
	~Handler () override=default
virtual void	readEOF (Context *ctx)
virtual void	readException (Context *ctx, folly::exception_wrapper e)
virtual void	transportActive (Context *ctx)
virtual void	transportInactive (Context *ctx)
virtual folly::Future< folly::Unit >	writeException (Context *ctx, folly::exception_wrapper e)
Public Member Functions inherited from wangle::HandlerBase< HandlerContext< Xtruct, Bonk > >
virtual	~HandlerBase ()=default
virtual void	attachPipeline (HandlerContext< Xtruct, Bonk > *)
virtual void	detachPipeline (HandlerContext< Xtruct, Bonk > *)
HandlerContext< Xtruct, Bonk > *	getContext ()
Public Member Functions inherited from wangle::Service< Bonk, Xtruct >
virtual	~Service ()=default
virtual bool	isAvailable ()

Private Attributes
std::unordered_map< int32_t, Promise< Xtruct > >	requests_

Additional Inherited Members
Public Types inherited from wangle::ClientDispatcherBase< SerializePipeline, Bonk, Xtruct >
typedef HandlerAdapter< Xtruct, Bonk >::Context	Context
Public Types inherited from wangle::HandlerAdapter< Xtruct, Bonk >
typedef Handler< Xtruct, Xtruct, Bonk, Bonk >::Context	Context
Public Types inherited from wangle::Handler< Xtruct, Xtruct, Bonk, Bonk >
typedef Xtruct	rin
typedef Xtruct	rout
typedef Bonk	win
typedef Bonk	wout
typedef HandlerContext< Xtruct, Bonk >	Context
Static Public Attributes inherited from wangle::Handler< Xtruct, Xtruct, Bonk, Bonk >
static const HandlerDir	dir
Protected Attributes inherited from wangle::ClientDispatcherBase< SerializePipeline, Bonk, Xtruct >
SerializePipeline *	pipeline_

Detailed Description

Definition at line 60 of file RpcClient.cpp.

Member Function Documentation

Future<Unit> BonkMultiplexClientDispatcher::close ( )

inlineoverridevirtual

Reimplemented from wangle::Service< Bonk, Xtruct >.

Definition at line 84 of file RpcClient.cpp.

References folly::netops::close().

                                {
    printf("Channel closed\n");
    return ClientDispatcherBase::close();
  }

Future<Unit> BonkMultiplexClientDispatcher::close ( Context *  ctx )

inlineoverridevirtual

Reimplemented from wangle::Handler< Xtruct, Xtruct, Bonk, Bonk >.

Definition at line 89 of file RpcClient.cpp.

References folly::netops::close().

                                            {
    printf("Channel closed\n");
    return ClientDispatcherBase::close(ctx);
  }

Future<Xtruct> BonkMultiplexClientDispatcher::operator() ( Bonk  arg )

inlineoverridevirtual

Implements wangle::Service< Bonk, Xtruct >.

Definition at line 71 of file RpcClient.cpp.

References f.

                                               {
    auto& p = requests_[arg.type];
    auto f = p.getFuture();
    p.setInterruptHandler([arg, this](const folly::exception_wrapper&) {
      this->requests_.erase(arg.type);
    });
    this->pipeline_->write(arg);

    return f;
  }

void BonkMultiplexClientDispatcher::read ( Context *  , Xtruct  in  )

inlineoverridevirtual

Implements wangle::Handler< Xtruct, Xtruct, Bonk, Bonk >.

Definition at line 63 of file RpcClient.cpp.

References folly::gen::move.

                                          {
    auto search = requests_.find(in.i32_thing);
    CHECK(search != requests_.end());
    auto p = std::move(search->second);
    requests_.erase(in.i32_thing);
    p.setValue(in);
  }

Member Data Documentation

std::unordered_map<int32_t, Promise<Xtruct> > BonkMultiplexClientDispatcher::requests_

private

Definition at line 95 of file RpcClient.cpp.

---

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

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