projects
/
folly.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Future<Unit> wangle fixup
[folly.git]
/
folly
/
wangle
/
channel
/
Handler.h
diff --git
a/folly/wangle/channel/Handler.h
b/folly/wangle/channel/Handler.h
index cdad11e53f65124e8c91db43239b695dc04412cf..127ac97314648ec462fb092ab34109e8376eebaf 100644
(file)
--- a/
folly/wangle/channel/Handler.h
+++ b/
folly/wangle/channel/Handler.h
@@
-26,13
+26,10
@@
namespace folly { namespace wangle {
template <class Context>
class HandlerBase {
public:
template <class Context>
class HandlerBase {
public:
- virtual ~HandlerBase()
{}
+ virtual ~HandlerBase()
= default;
virtual void attachPipeline(Context* ctx) {}
virtual void attachPipeline(Context* ctx) {}
- virtual void attachTransport(Context* ctx) {}
-
virtual void detachPipeline(Context* ctx) {}
virtual void detachPipeline(Context* ctx) {}
- virtual void detachTransport(Context* ctx) {}
Context* getContext() {
if (attachCount_ != 1) {
Context* getContext() {
if (attachCount_ != 1) {
@@
-58,7
+55,7
@@
class Handler : public HandlerBase<HandlerContext<Rout, Wout>> {
typedef Win win;
typedef Wout wout;
typedef HandlerContext<Rout, Wout> Context;
typedef Win win;
typedef Wout wout;
typedef HandlerContext<Rout, Wout> Context;
- virtual ~Handler()
{}
+ virtual ~Handler()
= default;
virtual void read(Context* ctx, Rin msg) = 0;
virtual void readEOF(Context* ctx) {
virtual void read(Context* ctx, Rin msg) = 0;
virtual void readEOF(Context* ctx) {
@@
-67,9
+64,15
@@
class Handler : public HandlerBase<HandlerContext<Rout, Wout>> {
virtual void readException(Context* ctx, exception_wrapper e) {
ctx->fireReadException(std::move(e));
}
virtual void readException(Context* ctx, exception_wrapper e) {
ctx->fireReadException(std::move(e));
}
+ virtual void transportActive(Context* ctx) {
+ ctx->fireTransportActive();
+ }
+ virtual void transportInactive(Context* ctx) {
+ ctx->fireTransportInactive();
+ }
- virtual Future<
void
> write(Context* ctx, Win msg) = 0;
- virtual Future<
void
> close(Context* ctx) {
+ virtual Future<
Unit
> write(Context* ctx, Win msg) = 0;
+ virtual Future<
Unit
> close(Context* ctx) {
return ctx->fireClose();
}
return ctx->fireClose();
}
@@
-81,22
+84,20
@@
class Handler : public HandlerBase<HandlerContext<Rout, Wout>> {
exception_wrapper e) {}
virtual void channelRegistered(HandlerContext* ctx) {}
virtual void channelUnregistered(HandlerContext* ctx) {}
exception_wrapper e) {}
virtual void channelRegistered(HandlerContext* ctx) {}
virtual void channelUnregistered(HandlerContext* ctx) {}
- virtual void channelActive(HandlerContext* ctx) {}
- virtual void channelInactive(HandlerContext* ctx) {}
virtual void channelReadComplete(HandlerContext* ctx) {}
virtual void userEventTriggered(HandlerContext* ctx, void* evt) {}
virtual void channelWritabilityChanged(HandlerContext* ctx) {}
// outbound
virtual void channelReadComplete(HandlerContext* ctx) {}
virtual void userEventTriggered(HandlerContext* ctx, void* evt) {}
virtual void channelWritabilityChanged(HandlerContext* ctx) {}
// outbound
- virtual Future<
void
> bind(
+ virtual Future<
Unit
> bind(
HandlerContext* ctx,
SocketAddress localAddress) {}
HandlerContext* ctx,
SocketAddress localAddress) {}
- virtual Future<
void
> connect(
+ virtual Future<
Unit
> connect(
HandlerContext* ctx,
SocketAddress remoteAddress, SocketAddress localAddress) {}
HandlerContext* ctx,
SocketAddress remoteAddress, SocketAddress localAddress) {}
- virtual Future<
void
> disconnect(HandlerContext* ctx) {}
- virtual Future<
void
> deregister(HandlerContext* ctx) {}
- virtual Future<
void
> read(HandlerContext* ctx) {}
+ virtual Future<
Unit
> disconnect(HandlerContext* ctx) {}
+ virtual Future<
Unit
> deregister(HandlerContext* ctx) {}
+ virtual Future<
Unit
> read(HandlerContext* ctx) {}
virtual void flush(HandlerContext* ctx) {}
*/
};
virtual void flush(HandlerContext* ctx) {}
*/
};
@@
-108,10
+109,10
@@
class InboundHandler : public HandlerBase<InboundHandlerContext<Rout>> {
typedef Rin rin;
typedef Rout rout;
typedef Rin rin;
typedef Rout rout;
- typedef
Nothing
win;
- typedef
Nothing
wout;
+ typedef
Unit
win;
+ typedef
Unit
wout;
typedef InboundHandlerContext<Rout> Context;
typedef InboundHandlerContext<Rout> Context;
- virtual ~InboundHandler()
{}
+ virtual ~InboundHandler()
= default;
virtual void read(Context* ctx, Rin msg) = 0;
virtual void readEOF(Context* ctx) {
virtual void read(Context* ctx, Rin msg) = 0;
virtual void readEOF(Context* ctx) {
@@
-120,6
+121,12
@@
class InboundHandler : public HandlerBase<InboundHandlerContext<Rout>> {
virtual void readException(Context* ctx, exception_wrapper e) {
ctx->fireReadException(std::move(e));
}
virtual void readException(Context* ctx, exception_wrapper e) {
ctx->fireReadException(std::move(e));
}
+ virtual void transportActive(Context* ctx) {
+ ctx->fireTransportActive();
+ }
+ virtual void transportInactive(Context* ctx) {
+ ctx->fireTransportInactive();
+ }
};
template <class Win, class Wout = Win>
};
template <class Win, class Wout = Win>
@@
-127,15
+134,15
@@
class OutboundHandler : public HandlerBase<OutboundHandlerContext<Wout>> {
public:
static const HandlerDir dir = HandlerDir::OUT;
public:
static const HandlerDir dir = HandlerDir::OUT;
- typedef
Nothing
rin;
- typedef
Nothing
rout;
+ typedef
Unit
rin;
+ typedef
Unit
rout;
typedef Win win;
typedef Wout wout;
typedef OutboundHandlerContext<Wout> Context;
typedef Win win;
typedef Wout wout;
typedef OutboundHandlerContext<Wout> Context;
- virtual ~OutboundHandler()
{}
+ virtual ~OutboundHandler()
= default;
- virtual Future<
void
> write(Context* ctx, Win msg) = 0;
- virtual Future<
void
> close(Context* ctx) {
+ virtual Future<
Unit
> write(Context* ctx, Win msg) = 0;
+ virtual Future<
Unit
> close(Context* ctx) {
return ctx->fireClose();
}
};
return ctx->fireClose();
}
};
@@
-149,7
+156,7
@@
class HandlerAdapter : public Handler<R, R, W, W> {
ctx->fireRead(std::forward<R>(msg));
}
ctx->fireRead(std::forward<R>(msg));
}
- Future<
void
> write(Context* ctx, W msg) override {
+ Future<
Unit
> write(Context* ctx, W msg) override {
return ctx->fireWrite(std::forward<W>(msg));
}
};
return ctx->fireWrite(std::forward<W>(msg));
}
};