Skip to content

Commit

Permalink
envoy: update upstream for onComplete callback
Browse files Browse the repository at this point in the history
Signed-off-by: Mike Schore <mike.schore@gmail.com>
  • Loading branch information
goaway committed Aug 9, 2019
1 parent da4d4d6 commit bc7f073
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 5 deletions.
2 changes: 1 addition & 1 deletion envoy
Submodule envoy updated 441 files
4 changes: 4 additions & 0 deletions library/common/http/dispatcher.cc
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,10 @@ void Dispatcher::DirectStreamCallbacks::onTrailers(HeaderMapPtr&& trailers) {
observer_.on_trailers(Utility::transformHeaders(*trailers), observer_.context);
}

void Dispatcher::DirectStreamCallbacks::onComplete() {
// TODO: implement me
}

void Dispatcher::DirectStreamCallbacks::onReset() {
http_dispatcher_.removeStream(stream_);
observer_.on_error({ENVOY_STREAM_RESET, envoy_nodata}, observer_.context);
Expand Down
9 changes: 5 additions & 4 deletions library/common/http/dispatcher.h
Original file line number Diff line number Diff line change
Expand Up @@ -59,10 +59,11 @@ class Dispatcher : public Logger::Loggable<Logger::Id::http> {
Dispatcher& http_dispatcher);

// AsyncClient::StreamCallbacks
void onHeaders(HeaderMapPtr&& headers, bool end_stream);
void onData(Buffer::Instance& data, bool end_stream);
void onTrailers(HeaderMapPtr&& trailers);
void onReset();
void onHeaders(HeaderMapPtr&& headers, bool end_stream) override;
void onData(Buffer::Instance& data, bool end_stream) override;
void onTrailers(HeaderMapPtr&& trailers) override;
void onComplete() override;
void onReset() override;

private:
const envoy_stream_t stream_;
Expand Down

0 comments on commit bc7f073

Please sign in to comment.