X-Git-Url: http://plrg.eecs.uci.edu/git/?a=blobdiff_plain;f=folly%2Fwangle%2Fchannel%2FHandler.h;h=127ac97314648ec462fb092ab34109e8376eebaf;hb=98a8a89d7d118b3098c0fb1308f171745b530e4b;hp=d0b9edde3424eaabe7f7670ce6699bf76603b4a2;hpb=e845ef57f1f368944123e4a50bd4d1616a363efa;p=folly.git diff --git a/folly/wangle/channel/Handler.h b/folly/wangle/channel/Handler.h index d0b9edde..127ac973 100644 --- a/folly/wangle/channel/Handler.h +++ b/folly/wangle/channel/Handler.h @@ -71,8 +71,8 @@ class Handler : public HandlerBase> { ctx->fireTransportInactive(); } - virtual Future write(Context* ctx, Win msg) = 0; - virtual Future close(Context* ctx) { + virtual Future write(Context* ctx, Win msg) = 0; + virtual Future close(Context* ctx) { return ctx->fireClose(); } @@ -89,15 +89,15 @@ class Handler : public HandlerBase> { virtual void channelWritabilityChanged(HandlerContext* ctx) {} // outbound - virtual Future bind( + virtual Future bind( HandlerContext* ctx, SocketAddress localAddress) {} - virtual Future connect( + virtual Future connect( HandlerContext* ctx, SocketAddress remoteAddress, SocketAddress localAddress) {} - virtual Future disconnect(HandlerContext* ctx) {} - virtual Future deregister(HandlerContext* ctx) {} - virtual Future read(HandlerContext* ctx) {} + virtual Future disconnect(HandlerContext* ctx) {} + virtual Future deregister(HandlerContext* ctx) {} + virtual Future read(HandlerContext* ctx) {} virtual void flush(HandlerContext* ctx) {} */ }; @@ -141,8 +141,8 @@ class OutboundHandler : public HandlerBase> { typedef OutboundHandlerContext Context; virtual ~OutboundHandler() = default; - virtual Future write(Context* ctx, Win msg) = 0; - virtual Future close(Context* ctx) { + virtual Future write(Context* ctx, Win msg) = 0; + virtual Future close(Context* ctx) { return ctx->fireClose(); } }; @@ -156,7 +156,7 @@ class HandlerAdapter : public Handler { ctx->fireRead(std::forward(msg)); } - Future write(Context* ctx, W msg) override { + Future write(Context* ctx, W msg) override { return ctx->fireWrite(std::forward(msg)); } };