|
|
|
@ -370,7 +370,7 @@ struct AddOpImpl<FilterType, T, const NoInterceptor*, which> { |
|
|
|
|
|
|
|
|
|
// void $INTERCEPTOR_NAME($VALUE_TYPE&)
|
|
|
|
|
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, |
|
|
|
|
void (FilterType::Call::*)(typename T::element_type&), impl> { |
|
|
|
|
static void Add(FilterType* channel_data, size_t call_offset, Layout<T>& to) { |
|
|
|
@ -391,8 +391,8 @@ struct AddOpImpl<FilterType, T, |
|
|
|
|
|
|
|
|
|
// void $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*)
|
|
|
|
|
template <typename FilterType, typename T, |
|
|
|
|
void (FilterType::Call::* impl)(typename T::element_type&, |
|
|
|
|
FilterType*)> |
|
|
|
|
void (FilterType::Call::*impl)(typename T::element_type&, |
|
|
|
|
FilterType*)> |
|
|
|
|
struct AddOpImpl< |
|
|
|
|
FilterType, T, |
|
|
|
|
void (FilterType::Call::*)(typename T::element_type&, FilterType*), impl> { |
|
|
|
@ -415,7 +415,7 @@ struct AddOpImpl< |
|
|
|
|
|
|
|
|
|
// $VALUE_HANDLE $INTERCEPTOR_NAME($VALUE_HANDLE, FilterType*)
|
|
|
|
|
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> { |
|
|
|
|
static void Add(FilterType* channel_data, size_t call_offset, Layout<T>& to) { |
|
|
|
|
to.Add( |
|
|
|
@ -438,7 +438,7 @@ struct AddOpImpl<FilterType, T, T (FilterType::Call::*)(T, FilterType*), impl> { |
|
|
|
|
|
|
|
|
|
// absl::Status $INTERCEPTOR_NAME($VALUE_TYPE&)
|
|
|
|
|
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, |
|
|
|
|
absl::Status (FilterType::Call::*)(typename T::element_type&), |
|
|
|
|
impl> { |
|
|
|
@ -464,7 +464,7 @@ struct AddOpImpl<FilterType, T, |
|
|
|
|
|
|
|
|
|
// absl::Status $INTERCEPTOR_NAME(const $VALUE_TYPE&)
|
|
|
|
|
template <typename FilterType, typename T, |
|
|
|
|
absl::Status (FilterType::Call::* impl)( |
|
|
|
|
absl::Status (FilterType::Call::*impl)( |
|
|
|
|
const typename T::element_type&)> |
|
|
|
|
struct AddOpImpl< |
|
|
|
|
FilterType, T, |
|
|
|
@ -491,8 +491,8 @@ struct AddOpImpl< |
|
|
|
|
|
|
|
|
|
// absl::Status $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*)
|
|
|
|
|
template <typename FilterType, typename T, |
|
|
|
|
absl::Status (FilterType::Call::* impl)(typename T::element_type&, |
|
|
|
|
FilterType*)> |
|
|
|
|
absl::Status (FilterType::Call::*impl)(typename T::element_type&, |
|
|
|
|
FilterType*)> |
|
|
|
|
struct AddOpImpl<FilterType, T, |
|
|
|
|
absl::Status (FilterType::Call::*)(typename T::element_type&, |
|
|
|
|
FilterType*), |
|
|
|
@ -520,7 +520,7 @@ struct AddOpImpl<FilterType, T, |
|
|
|
|
|
|
|
|
|
// absl::Status $INTERCEPTOR_NAME(const $VALUE_TYPE&, FilterType*)
|
|
|
|
|
template <typename FilterType, typename T, |
|
|
|
|
absl::Status (FilterType::Call::* impl)( |
|
|
|
|
absl::Status (FilterType::Call::*impl)( |
|
|
|
|
const typename T::element_type&, FilterType*)> |
|
|
|
|
struct AddOpImpl<FilterType, T, |
|
|
|
|
absl::Status (FilterType::Call::*)( |
|
|
|
@ -549,7 +549,7 @@ struct AddOpImpl<FilterType, T, |
|
|
|
|
|
|
|
|
|
// absl::StatusOr<$VALUE_HANDLE> $INTERCEPTOR_NAME($VALUE_HANDLE, FilterType*)
|
|
|
|
|
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, |
|
|
|
|
absl::StatusOr<T> (FilterType::Call::*)(T, FilterType*), |
|
|
|
|
impl> { |
|
|
|
@ -576,7 +576,7 @@ struct AddOpImpl<FilterType, T, |
|
|
|
|
|
|
|
|
|
// ServerMetadataHandle $INTERCEPTOR_NAME($VALUE_TYPE&)
|
|
|
|
|
template <typename FilterType, typename T, |
|
|
|
|
ServerMetadataHandle (FilterType::Call::* impl)( |
|
|
|
|
ServerMetadataHandle (FilterType::Call::*impl)( |
|
|
|
|
typename T::element_type&)> |
|
|
|
|
struct AddOpImpl<FilterType, T, |
|
|
|
|
ServerMetadataHandle (FilterType::Call::*)( |
|
|
|
@ -604,7 +604,7 @@ struct AddOpImpl<FilterType, T, |
|
|
|
|
|
|
|
|
|
// ServerMetadataHandle $INTERCEPTOR_NAME(const $VALUE_TYPE&)
|
|
|
|
|
template <typename FilterType, typename T, |
|
|
|
|
ServerMetadataHandle (FilterType::Call::* impl)( |
|
|
|
|
ServerMetadataHandle (FilterType::Call::*impl)( |
|
|
|
|
const typename T::element_type&)> |
|
|
|
|
struct AddOpImpl<FilterType, T, |
|
|
|
|
ServerMetadataHandle (FilterType::Call::*)( |
|
|
|
@ -632,7 +632,7 @@ struct AddOpImpl<FilterType, T, |
|
|
|
|
|
|
|
|
|
// ServerMetadataHandle $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*)
|
|
|
|
|
template <typename FilterType, typename T, |
|
|
|
|
ServerMetadataHandle (FilterType::Call::* impl)( |
|
|
|
|
ServerMetadataHandle (FilterType::Call::*impl)( |
|
|
|
|
typename T::element_type&, FilterType*)> |
|
|
|
|
struct AddOpImpl<FilterType, T, |
|
|
|
|
ServerMetadataHandle (FilterType::Call::*)( |
|
|
|
@ -661,7 +661,7 @@ struct AddOpImpl<FilterType, T, |
|
|
|
|
|
|
|
|
|
// ServerMetadataHandle $INTERCEPTOR_NAME(const $VALUE_TYPE&, FilterType*)
|
|
|
|
|
template <typename FilterType, typename T, |
|
|
|
|
ServerMetadataHandle (FilterType::Call::* impl)( |
|
|
|
|
ServerMetadataHandle (FilterType::Call::*impl)( |
|
|
|
|
const typename T::element_type&, FilterType*)> |
|
|
|
|
struct AddOpImpl<FilterType, T, |
|
|
|
|
ServerMetadataHandle (FilterType::Call::*)( |
|
|
|
@ -690,7 +690,7 @@ struct AddOpImpl<FilterType, T, |
|
|
|
|
|
|
|
|
|
// PROMISE_RETURNING(absl::Status) $INTERCEPTOR_NAME($VALUE_TYPE&)
|
|
|
|
|
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< |
|
|
|
|
FilterType, T, R (FilterType::Call::*)(typename T::element_type&), impl, |
|
|
|
|
absl::enable_if_t<std::is_same<absl::Status, PromiseResult<R>>::value>> { |
|
|
|
@ -740,7 +740,7 @@ struct AddOpImpl< |
|
|
|
|
|
|
|
|
|
// PROMISE_RETURNING(absl::Status) $INTERCEPTOR_NAME($VALUE_TYPE&, FilterType*)
|
|
|
|
|
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< |
|
|
|
|
FilterType, T, |
|
|
|
|
R (FilterType::Call::*)(typename T::element_type&, FilterType*), impl, |
|
|
|
@ -795,7 +795,7 @@ struct AddOpImpl< |
|
|
|
|
// PROMISE_RETURNING(absl::StatusOr<$VALUE_HANDLE>)
|
|
|
|
|
// $INTERCEPTOR_NAME($VALUE_HANDLE, FilterType*)
|
|
|
|
|
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, |
|
|
|
|
absl::enable_if_t<std::is_same<absl::StatusOr<T>, |
|
|
|
|
PromiseResult<R>>::value>> { |
|
|
|
@ -1030,7 +1030,7 @@ struct StackData { |
|
|
|
|
|
|
|
|
|
template <typename FilterType> |
|
|
|
|
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); |
|
|
|
|
finalizers.push_back(Finalizer{ |
|
|
|
|
channel_data, |
|
|
|
@ -1044,8 +1044,8 @@ struct StackData { |
|
|
|
|
|
|
|
|
|
template <typename FilterType> |
|
|
|
|
void AddFinalizer(FilterType* channel_data, size_t call_offset, |
|
|
|
|
void (FilterType::Call::* p)(const grpc_call_final_info*, |
|
|
|
|
FilterType*)) { |
|
|
|
|
void (FilterType::Call::*p)(const grpc_call_final_info*, |
|
|
|
|
FilterType*)) { |
|
|
|
|
DCHECK(p == &FilterType::Call::OnFinalize); |
|
|
|
|
finalizers.push_back(Finalizer{ |
|
|
|
|
channel_data, |
|
|
|
@ -1297,9 +1297,9 @@ class CallFilters { |
|
|
|
|
|
|
|
|
|
private: |
|
|
|
|
template <typename Output, typename Input, |
|
|
|
|
Input(CallFilters::* input_location), |
|
|
|
|
filters_detail::Layout<Input>(filters_detail::StackData::* layout), |
|
|
|
|
void (CallState::* on_done)(), typename StackIterator> |
|
|
|
|
Input(CallFilters::*input_location), |
|
|
|
|
filters_detail::Layout<Input>(filters_detail::StackData::*layout), |
|
|
|
|
void (CallState::*on_done)(), typename StackIterator> |
|
|
|
|
class Executor { |
|
|
|
|
public: |
|
|
|
|
Executor(CallFilters* filters, StackIterator stack_begin, |
|
|
|
|