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

Merge pull request #1973 from ctiller/create-pull-request/patch-8771245

Browse Source 
Automated fix for refs/heads/transport-refs-4
pull/36598/head
Craig Tiller 11 months ago committed by GitHub
parent 8771245b9e 7fa201c8e5
commit e30d412391
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
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. 16
      src/core/lib/channel/promise_based_filter.h

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

@ -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> {
@ -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);
@ -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) {
@ -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(
@ -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);

Write Preview
Loading…
Cancel
Save