Chiebot-Mirror
/
grpc
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Automated change: Fix sanity tests

Browse Source
pull/36598/head
ctiller 11 months ago committed by github-actions[bot]
parent 8771245b9e
commit 7fa201c8e5
2 changed files with 68 additions and 72 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 92
      src/core/lib/channel/promise_based_filter.h
  2. 48
      src/core/lib/transport/call_filters.h

92
src/core/lib/channel/promise_based_filter.h
Unescape View File

@ -351,7 +351,7 @@ auto MapResult(const NoInterceptor*, Promise x, void*) {
} }
template <typename Promise, typename Derived> template <typename Promise, typename Derived>
auto MapResult(absl::Status (Derived::Call::* fn)(ServerMetadata&), Promise x, auto MapResult(absl::Status (Derived::Call::*fn)(ServerMetadata&), Promise x,
FilterCallData<Derived>* call_data) { FilterCallData<Derived>* call_data) {
DCHECK(fn == &Derived::Call::OnServerTrailingMetadata); DCHECK(fn == &Derived::Call::OnServerTrailingMetadata);
return Map(std::move(x), [call_data](ServerMetadataHandle md) { return Map(std::move(x), [call_data](ServerMetadataHandle md) {
@ -362,7 +362,7 @@ auto MapResult(absl::Status (Derived::Call::* fn)(ServerMetadata&), Promise x,
} }
template <typename Promise, typename Derived> template <typename Promise, typename Derived>
auto MapResult(void (Derived::Call::* fn)(ServerMetadata&), Promise x, auto MapResult(void (Derived::Call::*fn)(ServerMetadata&), Promise x,
FilterCallData<Derived>* call_data) { FilterCallData<Derived>* call_data) {
DCHECK(fn == &Derived::Call::OnServerTrailingMetadata); DCHECK(fn == &Derived::Call::OnServerTrailingMetadata);
return Map(std::move(x), [call_data](ServerMetadataHandle md) { return Map(std::move(x), [call_data](ServerMetadataHandle md) {
@ -372,7 +372,7 @@ auto MapResult(void (Derived::Call::* fn)(ServerMetadata&), Promise x,
} }
template <typename Promise, typename Derived> template <typename Promise, typename Derived>
auto MapResult(void (Derived::Call::* fn)(ServerMetadata&, Derived*), Promise x, auto MapResult(void (Derived::Call::*fn)(ServerMetadata&, Derived*), Promise x,
FilterCallData<Derived>* call_data) { FilterCallData<Derived>* call_data) {
DCHECK(fn == &Derived::Call::OnServerTrailingMetadata); DCHECK(fn == &Derived::Call::OnServerTrailingMetadata);
return Map(std::move(x), [call_data](ServerMetadataHandle md) { return Map(std::move(x), [call_data](ServerMetadataHandle md) {
@ -494,7 +494,7 @@ auto RunCall(Interceptor interceptor, CallArgs call_args,
template <typename Derived> template <typename Derived>
inline auto InterceptClientToServerMessageHandler( inline auto InterceptClientToServerMessageHandler(
void (Derived::Call::* fn)(const Message&), void (Derived::Call::*fn)(const Message&),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnClientToServerMessage); DCHECK(fn == &Derived::Call::OnClientToServerMessage);
return [call_data](MessageHandle msg) -> absl::optional<MessageHandle> { return [call_data](MessageHandle msg) -> absl::optional<MessageHandle> {
@ -505,7 +505,7 @@ inline auto InterceptClientToServerMessageHandler(
template <typename Derived> template <typename Derived>
inline auto InterceptClientToServerMessageHandler( inline auto InterceptClientToServerMessageHandler(
ServerMetadataHandle (Derived::Call::* fn)(const Message&), ServerMetadataHandle (Derived::Call::*fn)(const Message&),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnClientToServerMessage); DCHECK(fn == &Derived::Call::OnClientToServerMessage);
return [call_data](MessageHandle msg) -> absl::optional<MessageHandle> { return [call_data](MessageHandle msg) -> absl::optional<MessageHandle> {
@ -519,7 +519,7 @@ inline auto InterceptClientToServerMessageHandler(
template <typename Derived> template <typename Derived>
inline auto InterceptClientToServerMessageHandler( inline auto InterceptClientToServerMessageHandler(
ServerMetadataHandle (Derived::Call::* fn)(const Message&, Derived*), ServerMetadataHandle (Derived::Call::*fn)(const Message&, Derived*),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnClientToServerMessage); DCHECK(fn == &Derived::Call::OnClientToServerMessage);
return [call_data](MessageHandle msg) -> absl::optional<MessageHandle> { return [call_data](MessageHandle msg) -> absl::optional<MessageHandle> {
@ -534,7 +534,7 @@ inline auto InterceptClientToServerMessageHandler(
template <typename Derived> template <typename Derived>
inline auto InterceptClientToServerMessageHandler( inline auto InterceptClientToServerMessageHandler(
MessageHandle (Derived::Call::* fn)(MessageHandle, Derived*), MessageHandle (Derived::Call::*fn)(MessageHandle, Derived*),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnClientToServerMessage); DCHECK(fn == &Derived::Call::OnClientToServerMessage);
return [call_data](MessageHandle msg) -> absl::optional<MessageHandle> { return [call_data](MessageHandle msg) -> absl::optional<MessageHandle> {
@ -545,8 +545,7 @@ inline auto InterceptClientToServerMessageHandler(
template <typename Derived> template <typename Derived>
inline auto InterceptClientToServerMessageHandler( inline auto InterceptClientToServerMessageHandler(
absl::StatusOr<MessageHandle> (Derived::Call::* fn)(MessageHandle, absl::StatusOr<MessageHandle> (Derived::Call::*fn)(MessageHandle, Derived*),
Derived*),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnClientToServerMessage); DCHECK(fn == &Derived::Call::OnClientToServerMessage);
return [call_data](MessageHandle msg) -> absl::optional<MessageHandle> { return [call_data](MessageHandle msg) -> absl::optional<MessageHandle> {
@ -570,7 +569,7 @@ inline void InterceptClientToServerMessage(HookFunction hook,
template <typename Derived, typename HookFunction> template <typename Derived, typename HookFunction>
inline void InterceptClientToServerMessage(HookFunction hook, inline void InterceptClientToServerMessage(HookFunction hook,
void (Derived::Call::* half_close)(), void (Derived::Call::*half_close)(),
FilterCallData<Derived>* call_data, FilterCallData<Derived>* call_data,
const CallArgs& call_args) { const CallArgs& call_args) {
call_args.client_to_server_messages->InterceptAndMapWithHalfClose( call_args.client_to_server_messages->InterceptAndMapWithHalfClose(
@ -586,7 +585,7 @@ inline void InterceptClientToServerMessage(const NoInterceptor*,
template <typename Derived> template <typename Derived>
inline auto InterceptClientToServerMessageHandler( inline auto InterceptClientToServerMessageHandler(
ServerMetadataHandle (Derived::Call::* fn)(const Message&), ServerMetadataHandle (Derived::Call::*fn)(const Message&),
typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) { typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientToServerMessage); DCHECK(fn == &Derived::Call::OnClientToServerMessage);
return return
@ -600,7 +599,7 @@ inline auto InterceptClientToServerMessageHandler(
template <typename Derived> template <typename Derived>
inline auto InterceptClientToServerMessageHandler( inline auto InterceptClientToServerMessageHandler(
void (Derived::Call::* fn)(const Message&), typename Derived::Call* call, void (Derived::Call::*fn)(const Message&), typename Derived::Call* call,
Derived*, PipeBasedCallSpine* call_spine) { Derived*, PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientToServerMessage); DCHECK(fn == &Derived::Call::OnClientToServerMessage);
return [call](MessageHandle msg) -> absl::optional<MessageHandle> { return [call](MessageHandle msg) -> absl::optional<MessageHandle> {
@ -611,7 +610,7 @@ inline auto InterceptClientToServerMessageHandler(
template <typename Derived> template <typename Derived>
inline auto InterceptClientToServerMessageHandler( inline auto InterceptClientToServerMessageHandler(
ServerMetadataHandle (Derived::Call::* fn)(const Message&, Derived*), ServerMetadataHandle (Derived::Call::*fn)(const Message&, Derived*),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientToServerMessage); DCHECK(fn == &Derived::Call::OnClientToServerMessage);
@ -626,7 +625,7 @@ inline auto InterceptClientToServerMessageHandler(
template <typename Derived> template <typename Derived>
inline auto InterceptClientToServerMessageHandler( inline auto InterceptClientToServerMessageHandler(
MessageHandle (Derived::Call::* fn)(MessageHandle, Derived*), MessageHandle (Derived::Call::*fn)(MessageHandle, Derived*),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientToServerMessage); DCHECK(fn == &Derived::Call::OnClientToServerMessage);
@ -637,8 +636,7 @@ inline auto InterceptClientToServerMessageHandler(
template <typename Derived> template <typename Derived>
inline auto InterceptClientToServerMessageHandler( inline auto InterceptClientToServerMessageHandler(
absl::StatusOr<MessageHandle> (Derived::Call::* fn)(MessageHandle, absl::StatusOr<MessageHandle> (Derived::Call::*fn)(MessageHandle, Derived*),
Derived*),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientToServerMessage); DCHECK(fn == &Derived::Call::OnClientToServerMessage);
@ -665,7 +663,7 @@ inline void InterceptClientToServerMessage(HookFunction fn,
template <typename Derived, typename HookFunction> template <typename Derived, typename HookFunction>
inline void InterceptClientToServerMessage(HookFunction fn, inline void InterceptClientToServerMessage(HookFunction fn,
void (Derived::Call::* half_close)(), void (Derived::Call::*half_close)(),
typename Derived::Call* call, typename Derived::Call* call,
Derived* channel, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
@ -687,8 +685,8 @@ inline void InterceptClientInitialMetadata(const NoInterceptor*, void*, void*,
template <typename Derived> template <typename Derived>
inline void InterceptClientInitialMetadata( inline void InterceptClientInitialMetadata(
void (Derived::Call::* fn)(ClientMetadata& md), void (Derived::Call::*fn)(ClientMetadata& md), typename Derived::Call* call,
typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) { Derived*, PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientInitialMetadata); DCHECK(fn == &Derived::Call::OnClientInitialMetadata);
call_spine->client_initial_metadata().receiver.InterceptAndMap( call_spine->client_initial_metadata().receiver.InterceptAndMap(
[call](ClientMetadataHandle md) { [call](ClientMetadataHandle md) {
@ -699,7 +697,7 @@ inline void InterceptClientInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptClientInitialMetadata( inline void InterceptClientInitialMetadata(
void (Derived::Call::* fn)(ClientMetadata& md, Derived* channel), void (Derived::Call::*fn)(ClientMetadata& md, Derived* channel),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientInitialMetadata); DCHECK(fn == &Derived::Call::OnClientInitialMetadata);
@ -712,7 +710,7 @@ inline void InterceptClientInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptClientInitialMetadata( inline void InterceptClientInitialMetadata(
ServerMetadataHandle (Derived::Call::* fn)(ClientMetadata& md), ServerMetadataHandle (Derived::Call::*fn)(ClientMetadata& md),
typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) { typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientInitialMetadata); DCHECK(fn == &Derived::Call::OnClientInitialMetadata);
call_spine->client_initial_metadata().receiver.InterceptAndMap( call_spine->client_initial_metadata().receiver.InterceptAndMap(
@ -727,8 +725,8 @@ inline void InterceptClientInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptClientInitialMetadata( inline void InterceptClientInitialMetadata(
ServerMetadataHandle (Derived::Call::* fn)(ClientMetadata& md, ServerMetadataHandle (Derived::Call::*fn)(ClientMetadata& md,
Derived* channel), Derived* channel),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientInitialMetadata); DCHECK(fn == &Derived::Call::OnClientInitialMetadata);
@ -744,7 +742,7 @@ inline void InterceptClientInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptClientInitialMetadata( inline void InterceptClientInitialMetadata(
absl::Status (Derived::Call::* fn)(ClientMetadata& md), absl::Status (Derived::Call::*fn)(ClientMetadata& md),
typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) { typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientInitialMetadata); DCHECK(fn == &Derived::Call::OnClientInitialMetadata);
call_spine->client_initial_metadata().receiver.InterceptAndMap( call_spine->client_initial_metadata().receiver.InterceptAndMap(
@ -760,7 +758,7 @@ inline void InterceptClientInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptClientInitialMetadata( inline void InterceptClientInitialMetadata(
absl::Status (Derived::Call::* fn)(ClientMetadata& md, Derived* channel), absl::Status (Derived::Call::*fn)(ClientMetadata& md, Derived* channel),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnClientInitialMetadata); DCHECK(fn == &Derived::Call::OnClientInitialMetadata);
@ -780,7 +778,7 @@ inline void InterceptClientInitialMetadata(
template <typename Promise, typename Derived> template <typename Promise, typename Derived>
absl::void_t<decltype(StatusCast<ServerMetadataHandle>( absl::void_t<decltype(StatusCast<ServerMetadataHandle>(
std::declval<PromiseResult<Promise>>))> std::declval<PromiseResult<Promise>>))>
InterceptClientInitialMetadata(Promise (Derived::Call::* promise_factory)( InterceptClientInitialMetadata(Promise (Derived::Call::*promise_factory)(
ClientMetadata& md, Derived* channel), ClientMetadata& md, Derived* channel),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
@ -806,7 +804,7 @@ inline void InterceptServerInitialMetadata(const NoInterceptor*, void*,
template <typename Derived> template <typename Derived>
inline void InterceptServerInitialMetadata( inline void InterceptServerInitialMetadata(
void (Derived::Call::* fn)(ServerMetadata&), void (Derived::Call::*fn)(ServerMetadata&),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnServerInitialMetadata); DCHECK(fn == &Derived::Call::OnServerInitialMetadata);
call_args.server_initial_metadata->InterceptAndMap( call_args.server_initial_metadata->InterceptAndMap(
@ -818,7 +816,7 @@ inline void InterceptServerInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptServerInitialMetadata( inline void InterceptServerInitialMetadata(
absl::Status (Derived::Call::* fn)(ServerMetadata&), absl::Status (Derived::Call::*fn)(ServerMetadata&),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnServerInitialMetadata); DCHECK(fn == &Derived::Call::OnServerInitialMetadata);
call_args.server_initial_metadata->InterceptAndMap( call_args.server_initial_metadata->InterceptAndMap(
@ -835,7 +833,7 @@ inline void InterceptServerInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptServerInitialMetadata( inline void InterceptServerInitialMetadata(
void (Derived::Call::* fn)(ServerMetadata&, Derived*), void (Derived::Call::*fn)(ServerMetadata&, Derived*),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnServerInitialMetadata); DCHECK(fn == &Derived::Call::OnServerInitialMetadata);
call_args.server_initial_metadata->InterceptAndMap( call_args.server_initial_metadata->InterceptAndMap(
@ -847,7 +845,7 @@ inline void InterceptServerInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptServerInitialMetadata( inline void InterceptServerInitialMetadata(
absl::Status (Derived::Call::* fn)(ServerMetadata&, Derived*), absl::Status (Derived::Call::*fn)(ServerMetadata&, Derived*),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnServerInitialMetadata); DCHECK(fn == &Derived::Call::OnServerInitialMetadata);
call_args.server_initial_metadata->InterceptAndMap( call_args.server_initial_metadata->InterceptAndMap(
@ -868,7 +866,7 @@ inline void InterceptServerInitialMetadata(const NoInterceptor*, void*, void*,
template <typename Derived> template <typename Derived>
inline void InterceptServerInitialMetadata( inline void InterceptServerInitialMetadata(
void (Derived::Call::* fn)(ServerMetadata&), typename Derived::Call* call, void (Derived::Call::*fn)(ServerMetadata&), typename Derived::Call* call,
Derived*, PipeBasedCallSpine* call_spine) { Derived*, PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnServerInitialMetadata); DCHECK(fn == &Derived::Call::OnServerInitialMetadata);
call_spine->server_initial_metadata().sender.InterceptAndMap( call_spine->server_initial_metadata().sender.InterceptAndMap(
@ -880,7 +878,7 @@ inline void InterceptServerInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptServerInitialMetadata( inline void InterceptServerInitialMetadata(
absl::Status (Derived::Call::* fn)(ServerMetadata&), absl::Status (Derived::Call::*fn)(ServerMetadata&),
typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) { typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnServerInitialMetadata); DCHECK(fn == &Derived::Call::OnServerInitialMetadata);
call_spine->server_initial_metadata().sender.InterceptAndMap( call_spine->server_initial_metadata().sender.InterceptAndMap(
@ -896,7 +894,7 @@ inline void InterceptServerInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptServerInitialMetadata( inline void InterceptServerInitialMetadata(
void (Derived::Call::* fn)(ServerMetadata&, Derived*), void (Derived::Call::*fn)(ServerMetadata&, Derived*),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnServerInitialMetadata); DCHECK(fn == &Derived::Call::OnServerInitialMetadata);
@ -909,7 +907,7 @@ inline void InterceptServerInitialMetadata(
template <typename Derived> template <typename Derived>
inline void InterceptServerInitialMetadata( inline void InterceptServerInitialMetadata(
absl::Status (Derived::Call::* fn)(ServerMetadata&, Derived*), absl::Status (Derived::Call::*fn)(ServerMetadata&, Derived*),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnServerInitialMetadata); DCHECK(fn == &Derived::Call::OnServerInitialMetadata);
@ -929,7 +927,7 @@ inline void InterceptServerToClientMessage(const NoInterceptor*, void*,
template <typename Derived> template <typename Derived>
inline void InterceptServerToClientMessage( inline void InterceptServerToClientMessage(
void (Derived::Call::* fn)(const Message&), void (Derived::Call::*fn)(const Message&),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnServerToClientMessage); DCHECK(fn == &Derived::Call::OnServerToClientMessage);
call_args.server_to_client_messages->InterceptAndMap( call_args.server_to_client_messages->InterceptAndMap(
@ -941,7 +939,7 @@ inline void InterceptServerToClientMessage(
template <typename Derived> template <typename Derived>
inline void InterceptServerToClientMessage( inline void InterceptServerToClientMessage(
ServerMetadataHandle (Derived::Call::* fn)(const Message&), ServerMetadataHandle (Derived::Call::*fn)(const Message&),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnServerToClientMessage); DCHECK(fn == &Derived::Call::OnServerToClientMessage);
call_args.server_to_client_messages->InterceptAndMap( call_args.server_to_client_messages->InterceptAndMap(
@ -956,7 +954,7 @@ inline void InterceptServerToClientMessage(
template <typename Derived> template <typename Derived>
inline void InterceptServerToClientMessage( inline void InterceptServerToClientMessage(
ServerMetadataHandle (Derived::Call::* fn)(const Message&, Derived*), ServerMetadataHandle (Derived::Call::*fn)(const Message&, Derived*),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnServerToClientMessage); DCHECK(fn == &Derived::Call::OnServerToClientMessage);
call_args.server_to_client_messages->InterceptAndMap( call_args.server_to_client_messages->InterceptAndMap(
@ -972,7 +970,7 @@ inline void InterceptServerToClientMessage(
template <typename Derived> template <typename Derived>
inline void InterceptServerToClientMessage( inline void InterceptServerToClientMessage(
MessageHandle (Derived::Call::* fn)(MessageHandle, Derived*), MessageHandle (Derived::Call::*fn)(MessageHandle, Derived*),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnServerToClientMessage); DCHECK(fn == &Derived::Call::OnServerToClientMessage);
call_args.server_to_client_messages->InterceptAndMap( call_args.server_to_client_messages->InterceptAndMap(
@ -984,8 +982,7 @@ inline void InterceptServerToClientMessage(
template <typename Derived> template <typename Derived>
inline void InterceptServerToClientMessage( inline void InterceptServerToClientMessage(
absl::StatusOr<MessageHandle> (Derived::Call::* fn)(MessageHandle, absl::StatusOr<MessageHandle> (Derived::Call::*fn)(MessageHandle, Derived*),
Derived*),
FilterCallData<Derived>* call_data, const CallArgs& call_args) { FilterCallData<Derived>* call_data, const CallArgs& call_args) {
DCHECK(fn == &Derived::Call::OnServerToClientMessage); DCHECK(fn == &Derived::Call::OnServerToClientMessage);
call_args.server_to_client_messages->InterceptAndMap( call_args.server_to_client_messages->InterceptAndMap(
@ -1004,7 +1001,7 @@ inline void InterceptServerToClientMessage(const NoInterceptor*, void*, void*,
template <typename Derived> template <typename Derived>
inline void InterceptServerToClientMessage( inline void InterceptServerToClientMessage(
void (Derived::Call::* fn)(const Message&), typename Derived::Call* call, void (Derived::Call::*fn)(const Message&), typename Derived::Call* call,
Derived*, PipeBasedCallSpine* call_spine) { Derived*, PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnServerToClientMessage); DCHECK(fn == &Derived::Call::OnServerToClientMessage);
call_spine->server_to_client_messages().sender.InterceptAndMap( call_spine->server_to_client_messages().sender.InterceptAndMap(
@ -1016,7 +1013,7 @@ inline void InterceptServerToClientMessage(
template <typename Derived> template <typename Derived>
inline void InterceptServerToClientMessage( inline void InterceptServerToClientMessage(
ServerMetadataHandle (Derived::Call::* fn)(const Message&), ServerMetadataHandle (Derived::Call::*fn)(const Message&),
typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) { typename Derived::Call* call, Derived*, PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnServerToClientMessage); DCHECK(fn == &Derived::Call::OnServerToClientMessage);
call_spine->server_to_client_messages().sender.InterceptAndMap( call_spine->server_to_client_messages().sender.InterceptAndMap(
@ -1030,7 +1027,7 @@ inline void InterceptServerToClientMessage(
template <typename Derived> template <typename Derived>
inline void InterceptServerToClientMessage( inline void InterceptServerToClientMessage(
ServerMetadataHandle (Derived::Call::* fn)(const Message&, Derived*), ServerMetadataHandle (Derived::Call::*fn)(const Message&, Derived*),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnServerToClientMessage); DCHECK(fn == &Derived::Call::OnServerToClientMessage);
@ -1046,7 +1043,7 @@ inline void InterceptServerToClientMessage(
template <typename Derived> template <typename Derived>
inline void InterceptServerToClientMessage( inline void InterceptServerToClientMessage(
MessageHandle (Derived::Call::* fn)(MessageHandle, Derived*), MessageHandle (Derived::Call::*fn)(MessageHandle, Derived*),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnServerToClientMessage); DCHECK(fn == &Derived::Call::OnServerToClientMessage);
@ -1058,8 +1055,7 @@ inline void InterceptServerToClientMessage(
template <typename Derived> template <typename Derived>
inline void InterceptServerToClientMessage( inline void InterceptServerToClientMessage(
absl::StatusOr<MessageHandle> (Derived::Call::* fn)(MessageHandle, absl::StatusOr<MessageHandle> (Derived::Call::*fn)(MessageHandle, Derived*),
Derived*),
typename Derived::Call* call, Derived* channel, typename Derived::Call* call, Derived* channel,
PipeBasedCallSpine* call_spine) { PipeBasedCallSpine* call_spine) {
DCHECK(fn == &Derived::Call::OnServerToClientMessage); DCHECK(fn == &Derived::Call::OnServerToClientMessage);
@ -1103,7 +1099,7 @@ inline void InterceptServerTrailingMetadata(
inline void InterceptFinalize(const NoInterceptor*, void*, void*) {} inline void InterceptFinalize(const NoInterceptor*, void*, void*) {}
template <class Call> template <class Call>
inline void InterceptFinalize(void (Call::* fn)(const grpc_call_final_info*), inline void InterceptFinalize(void (Call::*fn)(const grpc_call_final_info*),
void*, Call* call) { void*, Call* call) {
DCHECK(fn == &Call::OnFinalize); DCHECK(fn == &Call::OnFinalize);
GetContext<CallFinalization>()->Add( GetContext<CallFinalization>()->Add(
@ -1114,7 +1110,7 @@ inline void InterceptFinalize(void (Call::* fn)(const grpc_call_final_info*),
template <class Derived> template <class Derived>
inline void InterceptFinalize( inline void InterceptFinalize(
void (Derived::Call::* fn)(const grpc_call_final_info*, Derived*), void (Derived::Call::*fn)(const grpc_call_final_info*, Derived*),
Derived* channel, typename Derived::Call* call) { Derived* channel, typename Derived::Call* call) {
DCHECK(fn == &Derived::Call::OnFinalize); DCHECK(fn == &Derived::Call::OnFinalize);
GetContext<CallFinalization>()->Add( GetContext<CallFinalization>()->Add(

48
src/core/lib/transport/call_filters.h
Unescape View File

@ -313,7 +313,7 @@ struct AddOpImpl<FilterType, T, const NoInterceptor*, which> {
// void $INTERCEPTOR_NAME($VALUE_TYPE&) // void $INTERCEPTOR_NAME($VALUE_TYPE&)
template <typename FilterType, typename T, template <typename FilterType, typename T,
void (FilterType::Call::* impl)(typename T::element_type&)> void (FilterType::Call::*impl)(typename T::element_type&)>
struct AddOpImpl<FilterType, T, struct AddOpImpl<FilterType, T,
void (FilterType::Call::*)(typename T::element_type&), impl> { void (FilterType::Call::*)(typename T::element_type&), impl> {
static void Add(FilterType* channel_data, size_t call_offset, static void Add(FilterType* channel_data, size_t call_offset,
@ -350,8 +350,8 @@ struct AddOpImpl<FilterType, T,
// void $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*) // void $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*)
template <typename FilterType, typename T, template <typename FilterType, typename T,
void (FilterType::Call::* impl)(typename T::element_type&, void (FilterType::Call::*impl)(typename T::element_type&,
FilterType*)> FilterType*)>
struct AddOpImpl< struct AddOpImpl<
FilterType, T, FilterType, T,
void (FilterType::Call::*)(typename T::element_type&, FilterType*), impl> { void (FilterType::Call::*)(typename T::element_type&, FilterType*), impl> {
@ -391,7 +391,7 @@ struct AddOpImpl<
// $VALUE_HANDLE $INTERCEPTOR_NAME($VALUE_HANDLE, FilterType*) // $VALUE_HANDLE $INTERCEPTOR_NAME($VALUE_HANDLE, FilterType*)
template <typename FilterType, typename T, template <typename FilterType, typename T,
T (FilterType::Call::* impl)(T, FilterType*)> T (FilterType::Call::*impl)(T, FilterType*)>
struct AddOpImpl<FilterType, T, T (FilterType::Call::*)(T, FilterType*), impl> { struct AddOpImpl<FilterType, T, T (FilterType::Call::*)(T, FilterType*), impl> {
static void Add(FilterType* channel_data, size_t call_offset, static void Add(FilterType* channel_data, size_t call_offset,
Layout<FallibleOperator<T>>& to) { Layout<FallibleOperator<T>>& to) {
@ -433,7 +433,7 @@ struct AddOpImpl<FilterType, T, T (FilterType::Call::*)(T, FilterType*), impl> {
// absl::Status $INTERCEPTOR_NAME($VALUE_TYPE&) // absl::Status $INTERCEPTOR_NAME($VALUE_TYPE&)
template <typename FilterType, typename T, template <typename FilterType, typename T,
absl::Status (FilterType::Call::* impl)(typename T::element_type&)> absl::Status (FilterType::Call::*impl)(typename T::element_type&)>
struct AddOpImpl<FilterType, T, struct AddOpImpl<FilterType, T,
absl::Status (FilterType::Call::*)(typename T::element_type&), absl::Status (FilterType::Call::*)(typename T::element_type&),
impl> { impl> {
@ -478,7 +478,7 @@ struct AddOpImpl<FilterType, T,
// absl::Status $INTERCEPTOR_NAME(const $VALUE_TYPE&) // absl::Status $INTERCEPTOR_NAME(const $VALUE_TYPE&)
template <typename FilterType, typename T, template <typename FilterType, typename T,
absl::Status (FilterType::Call::* impl)( absl::Status (FilterType::Call::*impl)(
const typename T::element_type&)> const typename T::element_type&)>
struct AddOpImpl< struct AddOpImpl<
FilterType, T, FilterType, T,
@ -506,8 +506,8 @@ struct AddOpImpl<
// absl::Status $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*) // absl::Status $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*)
template <typename FilterType, typename T, template <typename FilterType, typename T,
absl::Status (FilterType::Call::* impl)(typename T::element_type&, absl::Status (FilterType::Call::*impl)(typename T::element_type&,
FilterType*)> FilterType*)>
struct AddOpImpl<FilterType, T, struct AddOpImpl<FilterType, T,
absl::Status (FilterType::Call::*)(typename T::element_type&, absl::Status (FilterType::Call::*)(typename T::element_type&,
FilterType*), FilterType*),
@ -536,7 +536,7 @@ struct AddOpImpl<FilterType, T,
// absl::Status $INTERCEPTOR_NAME(const $VALUE_TYPE&, FilterType*) // absl::Status $INTERCEPTOR_NAME(const $VALUE_TYPE&, FilterType*)
template <typename FilterType, typename T, template <typename FilterType, typename T,
absl::Status (FilterType::Call::* impl)( absl::Status (FilterType::Call::*impl)(
const typename T::element_type&, FilterType*)> const typename T::element_type&, FilterType*)>
struct AddOpImpl<FilterType, T, struct AddOpImpl<FilterType, T,
absl::Status (FilterType::Call::*)( absl::Status (FilterType::Call::*)(
@ -566,7 +566,7 @@ struct AddOpImpl<FilterType, T,
// absl::StatusOr<$VALUE_HANDLE> $INTERCEPTOR_NAME($VALUE_HANDLE, FilterType*) // absl::StatusOr<$VALUE_HANDLE> $INTERCEPTOR_NAME($VALUE_HANDLE, FilterType*)
template <typename FilterType, typename T, template <typename FilterType, typename T,
absl::StatusOr<T> (FilterType::Call::* impl)(T, FilterType*)> absl::StatusOr<T> (FilterType::Call::*impl)(T, FilterType*)>
struct AddOpImpl<FilterType, T, struct AddOpImpl<FilterType, T,
absl::StatusOr<T> (FilterType::Call::*)(T, FilterType*), absl::StatusOr<T> (FilterType::Call::*)(T, FilterType*),
impl> { impl> {
@ -594,7 +594,7 @@ struct AddOpImpl<FilterType, T,
// ServerMetadataHandle $INTERCEPTOR_NAME($VALUE_TYPE&) // ServerMetadataHandle $INTERCEPTOR_NAME($VALUE_TYPE&)
template <typename FilterType, typename T, template <typename FilterType, typename T,
ServerMetadataHandle (FilterType::Call::* impl)( ServerMetadataHandle (FilterType::Call::*impl)(
typename T::element_type&)> typename T::element_type&)>
struct AddOpImpl<FilterType, T, struct AddOpImpl<FilterType, T,
ServerMetadataHandle (FilterType::Call::*)( ServerMetadataHandle (FilterType::Call::*)(
@ -623,7 +623,7 @@ struct AddOpImpl<FilterType, T,
// ServerMetadataHandle $INTERCEPTOR_NAME(const $VALUE_TYPE&) // ServerMetadataHandle $INTERCEPTOR_NAME(const $VALUE_TYPE&)
template <typename FilterType, typename T, template <typename FilterType, typename T,
ServerMetadataHandle (FilterType::Call::* impl)( ServerMetadataHandle (FilterType::Call::*impl)(
const typename T::element_type&)> const typename T::element_type&)>
struct AddOpImpl<FilterType, T, struct AddOpImpl<FilterType, T,
ServerMetadataHandle (FilterType::Call::*)( ServerMetadataHandle (FilterType::Call::*)(
@ -652,7 +652,7 @@ struct AddOpImpl<FilterType, T,
// ServerMetadataHandle $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*) // ServerMetadataHandle $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*)
template <typename FilterType, typename T, template <typename FilterType, typename T,
ServerMetadataHandle (FilterType::Call::* impl)( ServerMetadataHandle (FilterType::Call::*impl)(
typename T::element_type&, FilterType*)> typename T::element_type&, FilterType*)>
struct AddOpImpl<FilterType, T, struct AddOpImpl<FilterType, T,
ServerMetadataHandle (FilterType::Call::*)( ServerMetadataHandle (FilterType::Call::*)(
@ -682,7 +682,7 @@ struct AddOpImpl<FilterType, T,
// ServerMetadataHandle $INTERCEPTOR_NAME(const $VALUE_TYPE&, FilterType*) // ServerMetadataHandle $INTERCEPTOR_NAME(const $VALUE_TYPE&, FilterType*)
template <typename FilterType, typename T, template <typename FilterType, typename T,
ServerMetadataHandle (FilterType::Call::* impl)( ServerMetadataHandle (FilterType::Call::*impl)(
const typename T::element_type&, FilterType*)> const typename T::element_type&, FilterType*)>
struct AddOpImpl<FilterType, T, struct AddOpImpl<FilterType, T,
ServerMetadataHandle (FilterType::Call::*)( ServerMetadataHandle (FilterType::Call::*)(
@ -712,7 +712,7 @@ struct AddOpImpl<FilterType, T,
// PROMISE_RETURNING(absl::Status) $INTERCEPTOR_NAME($VALUE_TYPE&) // PROMISE_RETURNING(absl::Status) $INTERCEPTOR_NAME($VALUE_TYPE&)
template <typename FilterType, typename T, typename R, template <typename FilterType, typename T, typename R,
R (FilterType::Call::* impl)(typename T::element_type&)> R (FilterType::Call::*impl)(typename T::element_type&)>
struct AddOpImpl< struct AddOpImpl<
FilterType, T, R (FilterType::Call::*)(typename T::element_type&), impl, FilterType, T, R (FilterType::Call::*)(typename T::element_type&), impl,
absl::enable_if_t<std::is_same<absl::Status, PromiseResult<R>>::value>> { absl::enable_if_t<std::is_same<absl::Status, PromiseResult<R>>::value>> {
@ -763,7 +763,7 @@ struct AddOpImpl<
// PROMISE_RETURNING(absl::Status) $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*) // PROMISE_RETURNING(absl::Status) $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*)
template <typename FilterType, typename T, typename R, template <typename FilterType, typename T, typename R,
R (FilterType::Call::* impl)(typename T::element_type&, FilterType*)> R (FilterType::Call::*impl)(typename T::element_type&, FilterType*)>
struct AddOpImpl< struct AddOpImpl<
FilterType, T, FilterType, T,
R (FilterType::Call::*)(typename T::element_type&, FilterType*), impl, R (FilterType::Call::*)(typename T::element_type&, FilterType*), impl,
@ -819,7 +819,7 @@ struct AddOpImpl<
// PROMISE_RETURNING(absl::StatusOr<$VALUE_HANDLE>) // PROMISE_RETURNING(absl::StatusOr<$VALUE_HANDLE>)
// $INTERCEPTOR_NAME($VALUE_HANDLE, FilterType*) // $INTERCEPTOR_NAME($VALUE_HANDLE, FilterType*)
template <typename FilterType, typename T, typename R, template <typename FilterType, typename T, typename R,
R (FilterType::Call::* impl)(T, FilterType*)> R (FilterType::Call::*impl)(T, FilterType*)>
struct AddOpImpl<FilterType, T, R (FilterType::Call::*)(T, FilterType*), impl, struct AddOpImpl<FilterType, T, R (FilterType::Call::*)(T, FilterType*), impl,
absl::enable_if_t<std::is_same<absl::StatusOr<T>, absl::enable_if_t<std::is_same<absl::StatusOr<T>,
PromiseResult<R>>::value>> { PromiseResult<R>>::value>> {
@ -1043,7 +1043,7 @@ struct StackData {
template <typename FilterType> template <typename FilterType>
void AddFinalizer(FilterType* channel_data, size_t call_offset, void AddFinalizer(FilterType* channel_data, size_t call_offset,
void (FilterType::Call::* p)(const grpc_call_final_info*)) { void (FilterType::Call::*p)(const grpc_call_final_info*)) {
DCHECK(p == &FilterType::Call::OnFinalize); DCHECK(p == &FilterType::Call::OnFinalize);
finalizers.push_back(Finalizer{ finalizers.push_back(Finalizer{
channel_data, channel_data,
@ -1057,8 +1057,8 @@ struct StackData {
template <typename FilterType> template <typename FilterType>
void AddFinalizer(FilterType* channel_data, size_t call_offset, void AddFinalizer(FilterType* channel_data, size_t call_offset,
void (FilterType::Call::* p)(const grpc_call_final_info*, void (FilterType::Call::*p)(const grpc_call_final_info*,
FilterType*)) { FilterType*)) {
DCHECK(p == &FilterType::Call::OnFinalize); DCHECK(p == &FilterType::Call::OnFinalize);
finalizers.push_back(Finalizer{ finalizers.push_back(Finalizer{
channel_data, channel_data,
@ -1479,10 +1479,10 @@ class CallFilters {
std::string DebugString() const; std::string DebugString() const;
private: private:
template <filters_detail::PipeState(CallFilters::* state_ptr), template <filters_detail::PipeState(CallFilters::*state_ptr),
void*(CallFilters::* push_ptr), typename T, void*(CallFilters::*push_ptr), typename T,
filters_detail::Layout<filters_detail::FallibleOperator<T>>( filters_detail::Layout<filters_detail::FallibleOperator<T>>(
filters_detail::StackData::* layout_ptr)> filters_detail::StackData::*layout_ptr)>
class PipePromise { class PipePromise {
public: public:
class Push { class Push {
@ -1649,7 +1649,7 @@ class CallFilters {
}; };
template <std::vector<filters_detail::HalfCloseOperator>( template <std::vector<filters_detail::HalfCloseOperator>(
filters_detail::StackData::* half_close_layout_ptr)> filters_detail::StackData::*half_close_layout_ptr)>
class PullMessage { class PullMessage {
public: public:
explicit PullMessage(CallFilters* filters) : filters_(filters) {} explicit PullMessage(CallFilters* filters) : filters_(filters) {}

Write Preview
Loading…
Cancel
Save