message_decompress_filter.cc File Reference

#include <grpc/support/port_platform.h>
#include "src/core/ext/filters/http/message_compress/message_decompress_filter.h"
#include <stdint.h>
#include <string.h>
#include <new>
#include "absl/strings/str_cat.h"
#include "absl/strings/str_format.h"
#include "absl/types/optional.h"
#include <grpc/impl/codegen/compression_types.h>
#include <grpc/status.h>
#include <grpc/support/log.h>
#include "src/core/ext/filters/message_size/message_size_filter.h"
#include "src/core/lib/channel/channel_args.h"
#include "src/core/lib/compression/message_compress.h"
#include "src/core/lib/gprpp/debug_location.h"
#include "src/core/lib/iomgr/call_combiner.h"
#include "src/core/lib/iomgr/closure.h"
#include "src/core/lib/iomgr/error.h"
#include "src/core/lib/profiling/timers.h"
#include "src/core/lib/slice/slice_buffer.h"
#include "src/core/lib/transport/metadata_batch.h"
#include "src/core/lib/transport/transport.h"

Include dependency graph for message_decompress_filter.cc:

Go to the source code of this file.

Namespaces
	grpc_core

Variables
const grpc_channel_filter	grpc_core::MessageDecompressFilter

Variable Documentation

algorithm_

grpc_compression_algorithm algorithm_ = GRPC_COMPRESS_NONE

private

Definition at line 120 of file message_decompress_filter.cc.

call_combiner_

CallCombiner* call_combiner_

private

Definition at line 110 of file message_decompress_filter.cc.

error_

grpc_error_handle error_ = GRPC_ERROR_NONE

private

Definition at line 112 of file message_decompress_filter.cc.

max_recv_message_length_

int max_recv_message_length_

private

Definition at line 119 of file message_decompress_filter.cc.

max_recv_size_

int max_recv_size_

private

Definition at line 65 of file message_decompress_filter.cc.

message_size_service_config_parser_index_

const size_t message_size_service_config_parser_index_

private

Definition at line 66 of file message_decompress_filter.cc.

on_recv_initial_metadata_ready_

grpc_closure on_recv_initial_metadata_ready_

private

Definition at line 114 of file message_decompress_filter.cc.

on_recv_message_ready_

grpc_closure on_recv_message_ready_

private

Definition at line 123 of file message_decompress_filter.cc.

on_recv_trailing_metadata_ready_

grpc_closure on_recv_trailing_metadata_ready_

private

Definition at line 127 of file message_decompress_filter.cc.

on_recv_trailing_metadata_ready_error_

grpc_error_handle on_recv_trailing_metadata_ready_error_ = GRPC_ERROR_NONE

private

Definition at line 129 of file message_decompress_filter.cc.

original_recv_initial_metadata_ready_

grpc_closure* original_recv_initial_metadata_ready_ = nullptr

private

Definition at line 115 of file message_decompress_filter.cc.

original_recv_message_ready_

grpc_closure* original_recv_message_ready_ = nullptr

private

Definition at line 124 of file message_decompress_filter.cc.

original_recv_trailing_metadata_ready_

grpc_closure* original_recv_trailing_metadata_ready_ = nullptr

private

Definition at line 128 of file message_decompress_filter.cc.

recv_initial_metadata_

grpc_metadata_batch* recv_initial_metadata_ = nullptr

private

Definition at line 116 of file message_decompress_filter.cc.

recv_message_

absl::optional<SliceBuffer>* recv_message_ = nullptr

private

Definition at line 121 of file message_decompress_filter.cc.

recv_message_flags_

uint32_t* recv_message_flags_ = nullptr

private

Definition at line 122 of file message_decompress_filter.cc.

seen_recv_message_ready_

bool seen_recv_message_ready_ = false

private

Definition at line 118 of file message_decompress_filter.cc.

seen_recv_trailing_metadata_ready_

bool seen_recv_trailing_metadata_ready_ = false

private

Definition at line 126 of file message_decompress_filter.cc.