Skip to content

Commit

Permalink
x
Browse files Browse the repository at this point in the history
  • Loading branch information
ctiller committed Jan 10, 2024
1 parent 5e8215d commit dd81e03
Show file tree
Hide file tree
Showing 6 changed files with 820 additions and 47 deletions.
1 change: 1 addition & 0 deletions BUILD
Original file line number Diff line number Diff line change
Expand Up @@ -1530,6 +1530,7 @@ grpc_cc_library(
"//src/core:arena_promise",
"//src/core:atomic_utils",
"//src/core:bitset",
"//src/core:call_final_info",
"//src/core:cancel_callback",
"//src/core:channel_args",
"//src/core:channel_args_endpoint_config",
Expand Down
14 changes: 14 additions & 0 deletions src/core/BUILD
Original file line number Diff line number Diff line change
Expand Up @@ -6624,6 +6624,20 @@ grpc_cc_library(
],
)

grpc_cc_library(
name = "call_final_info",
srcs = [
"lib/transport/call_final_info.cc",
],
hdrs = [
"lib/transport/call_final_info.h",
],
deps = [
"//:gpr",
"//:grpc_public_hdrs",
],
)

grpc_cc_library(
name = "parsed_metadata",
srcs = [
Expand Down
11 changes: 1 addition & 10 deletions src/core/lib/channel/channel_stack.h
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,7 @@
#include "src/core/lib/iomgr/polling_entity.h"
#include "src/core/lib/promise/arena_promise.h"
#include "src/core/lib/resource_quota/arena.h"
#include "src/core/lib/transport/call_final_info.h"
#include "src/core/lib/transport/transport.h"

struct grpc_channel_element_args {
Expand All @@ -90,16 +91,6 @@ struct grpc_call_element_args {
grpc_core::Arena* arena;
grpc_core::CallCombiner* call_combiner;
};
struct grpc_call_stats {
grpc_transport_stream_stats transport_stream_stats;
gpr_timespec latency; // From call creating to enqueing of received status
};
/// Information about the call upon completion.
struct grpc_call_final_info {
grpc_call_stats stats;
grpc_status_code final_status = GRPC_STATUS_OK;
const char* error_string = nullptr;
};

// Channel filters specify:
// 1. the amount of memory needed in the channel & call (via the sizeof_XXX
Expand Down
Loading

0 comments on commit dd81e03

Please sign in to comment.