Skip to content

Commit 4b33df7

Browse files
authored
Return StopAllIterationAndWatermark in fail_close cases. (#154)
in favor of #95, returns StopAllIterationAndWatermark to stop the further body processing in VM failure with fail_close cases. Signed-off-by: Takeshi Yoneda <takeshi@tetrate.io>
1 parent 38e6dbd commit 4b33df7

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/context.cc

+2-2
Original file line numberDiff line numberDiff line change
@@ -308,7 +308,7 @@ template <typename P> static uint32_t headerSize(const P &p) { return p ? p->siz
308308

309309
FilterHeadersStatus ContextBase::onRequestHeaders(uint32_t headers, bool end_of_stream) {
310310
CHECK_HTTP2(on_request_headers_abi_01_, on_request_headers_abi_02_, FilterHeadersStatus::Continue,
311-
FilterHeadersStatus::StopIteration);
311+
FilterHeadersStatus::StopAllIterationAndWatermark);
312312
DeferAfterCallActions actions(this);
313313
return convertVmCallResultToFilterHeadersStatus(
314314
wasm_->on_request_headers_abi_01_
@@ -343,7 +343,7 @@ FilterMetadataStatus ContextBase::onRequestMetadata(uint32_t elements) {
343343

344344
FilterHeadersStatus ContextBase::onResponseHeaders(uint32_t headers, bool end_of_stream) {
345345
CHECK_HTTP2(on_response_headers_abi_01_, on_response_headers_abi_02_,
346-
FilterHeadersStatus::Continue, FilterHeadersStatus::StopIteration);
346+
FilterHeadersStatus::Continue, FilterHeadersStatus::StopAllIterationAndWatermark);
347347
DeferAfterCallActions actions(this);
348348
return convertVmCallResultToFilterHeadersStatus(
349349
wasm_->on_response_headers_abi_01_

0 commit comments

Comments
 (0)