Modify to implement new half-close interfaces. (envoyproxy#34)

Signed-off-by: Greg Greenway <[email protected]>
jmarantz · Feb 2, 2018 · 39dc2dd · 39dc2dd
1 parent ab03265
commit 39dc2dd
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/echo2.cc b/echo2.cc
@@ -8,12 +8,12 @@
 namespace Envoy {
 namespace Filter {
 
-Network::FilterStatus Echo2::onData(Buffer::Instance& data) {
+Network::FilterStatus Echo2::onData(Buffer::Instance& data, bool) {
   ENVOY_CONN_LOG(trace, "echo: got {} bytes", read_callbacks_->connection(), data.length());
-  read_callbacks_->connection().write(data);
+  read_callbacks_->connection().write(data, false);
   ASSERT(0 == data.length());
   return Network::FilterStatus::StopIteration;
 }
 
-} // Filter
-} // Envoy
+} // namespace Filter
+} // namespace Envoy
diff --git a/echo2.h b/echo2.h
@@ -13,7 +13,7 @@ namespace Filter {
 class Echo2 : public Network::ReadFilter, Logger::Loggable<Logger::Id::filter> {
 public:
   // Network::ReadFilter
-  Network::FilterStatus onData(Buffer::Instance& data) override;
+  Network::FilterStatus onData(Buffer::Instance& data, bool end_stream) override;
   Network::FilterStatus onNewConnection() override { return Network::FilterStatus::Continue; }
   void initializeReadFilterCallbacks(Network::ReadFilterCallbacks& callbacks) override {
     read_callbacks_ = &callbacks;
@@ -23,5 +23,5 @@ class Echo2 : public Network::ReadFilter, Logger::Loggable<Logger::Id::filter> {
   Network::ReadFilterCallbacks* read_callbacks_{};
 };
 
-} // Filter
-} // Envoy
+} // namespace Filter
+} // namespace Envoy