mirror of https://github.com/grpc/grpc.git
Lizan Zhou
6 years ago
commit
91e15f65dc
62 changed files with 1217 additions and 554 deletions
@ -0,0 +1,39 @@ |
||||
/*
|
||||
* Copyright 2015 gRPC authors. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
* you may not use this file except in compliance with the License. |
||||
* You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
|
||||
/*
|
||||
* WARNING: Auto-generated code. |
||||
* |
||||
* To make changes to this file, change |
||||
* tools/codegen/core/gen_static_metadata.py, and then re-run it. |
||||
* |
||||
* This file contains the mapping from the index of each metadata element in the |
||||
* grpc static metadata table to the index of that element in the hpack static |
||||
* metadata table. If the element is not contained in the static hpack table, |
||||
* then the returned index is 0. |
||||
*/ |
||||
|
||||
#include <grpc/support/port_platform.h> |
||||
|
||||
#include "src/core/ext/transport/chttp2/transport/hpack_mapping.h" |
||||
|
||||
const uint8_t grpc_hpack_static_mdelem_indices[GRPC_STATIC_MDELEM_COUNT] = { |
||||
0, 0, 0, 0, 0, 0, 0, 0, 3, 8, 13, 6, 7, 0, 1, 2, 0, 4, |
||||
5, 9, 10, 11, 12, 14, 15, 0, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, |
||||
0, 0, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, |
||||
42, 43, 44, 0, 0, 45, 46, 47, 48, 49, 50, 51, 52, 53, 54, 55, 56, 57, |
||||
58, 59, 60, 61, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, |
||||
}; |
||||
@ -0,0 +1,38 @@ |
||||
/*
|
||||
* Copyright 2015 gRPC authors. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
* you may not use this file except in compliance with the License. |
||||
* You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
*/ |
||||
|
||||
/*
|
||||
* WARNING: Auto-generated code. |
||||
* |
||||
* To make changes to this file, change |
||||
* tools/codegen/core/gen_static_metadata.py, and then re-run it. |
||||
* |
||||
* This file contains the mapping from the index of each metadata element in the |
||||
* grpc static metadata table to the index of that element in the hpack static |
||||
* metadata table. If the element is not contained in the static hpack table, |
||||
* then the returned index is 0. |
||||
*/ |
||||
|
||||
#ifndef GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_HPACK_MAPPING_H |
||||
#define GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_HPACK_MAPPING_H |
||||
|
||||
#include <grpc/support/port_platform.h> |
||||
|
||||
#include "src/core/lib/transport/static_metadata.h" |
||||
|
||||
extern const uint8_t grpc_hpack_static_mdelem_indices[GRPC_STATIC_MDELEM_COUNT]; |
||||
|
||||
#endif /* GRPC_CORE_EXT_TRANSPORT_CHTTP2_TRANSPORT_HPACK_MAPPING_H */ |
||||
@ -1,149 +0,0 @@ |
||||
/*
|
||||
* |
||||
* Copyright 2018 gRPC authors. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
* you may not use this file except in compliance with the License. |
||||
* You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
* |
||||
*/ |
||||
|
||||
#include <functional> |
||||
|
||||
#include <grpcpp/impl/codegen/callback_common.h> |
||||
#include <grpcpp/impl/codegen/status.h> |
||||
|
||||
#include "src/core/lib/gprpp/memory.h" |
||||
#include "src/core/lib/surface/completion_queue.h" |
||||
|
||||
namespace grpc { |
||||
namespace internal { |
||||
namespace { |
||||
|
||||
template <class Func, class Arg> |
||||
void CatchingCallback(Func&& func, Arg&& arg) { |
||||
#if GRPC_ALLOW_EXCEPTIONS |
||||
try { |
||||
func(arg); |
||||
} catch (...) { |
||||
// nothing to return or change here, just don't crash the library
|
||||
} |
||||
#else // GRPC_ALLOW_EXCEPTIONS
|
||||
func(arg); |
||||
#endif // GRPC_ALLOW_EXCEPTIONS
|
||||
} |
||||
|
||||
class CallbackWithSuccessImpl : public grpc_core::CQCallbackInterface { |
||||
public: |
||||
static void operator delete(void* ptr, std::size_t size) { |
||||
assert(size == sizeof(CallbackWithSuccessImpl)); |
||||
} |
||||
|
||||
// This operator should never be called as the memory should be freed as part
|
||||
// of the arena destruction. It only exists to provide a matching operator
|
||||
// delete to the operator new so that some compilers will not complain (see
|
||||
// https://github.com/grpc/grpc/issues/11301) Note at the time of adding this
|
||||
// there are no tests catching the compiler warning.
|
||||
static void operator delete(void*, void*) { assert(0); } |
||||
|
||||
CallbackWithSuccessImpl(grpc_call* call, CallbackWithSuccessTag* parent, |
||||
std::function<void(bool)> f) |
||||
: call_(call), parent_(parent), func_(std::move(f)) { |
||||
grpc_call_ref(call); |
||||
} |
||||
|
||||
void Run(bool ok) override { |
||||
void* ignored = parent_->ops(); |
||||
bool new_ok = ok; |
||||
GPR_ASSERT(parent_->ops()->FinalizeResult(&ignored, &new_ok)); |
||||
GPR_ASSERT(ignored == parent_->ops()); |
||||
|
||||
// Last use of func_ or ok, so ok to move them out for rvalue call above
|
||||
CatchingCallback(std::move(func_), std::move(ok)); |
||||
|
||||
func_ = nullptr; // reset to clear this out for sure
|
||||
grpc_call_unref(call_); |
||||
} |
||||
|
||||
private: |
||||
grpc_call* call_; |
||||
CallbackWithSuccessTag* parent_; |
||||
std::function<void(bool)> func_; |
||||
}; |
||||
|
||||
class CallbackWithStatusImpl : public grpc_core::CQCallbackInterface { |
||||
public: |
||||
static void operator delete(void* ptr, std::size_t size) { |
||||
assert(size == sizeof(CallbackWithStatusImpl)); |
||||
} |
||||
|
||||
// This operator should never be called as the memory should be freed as part
|
||||
// of the arena destruction. It only exists to provide a matching operator
|
||||
// delete to the operator new so that some compilers will not complain (see
|
||||
// https://github.com/grpc/grpc/issues/11301) Note at the time of adding this
|
||||
// there are no tests catching the compiler warning.
|
||||
static void operator delete(void*, void*) { assert(0); } |
||||
|
||||
CallbackWithStatusImpl(grpc_call* call, CallbackWithStatusTag* parent, |
||||
std::function<void(Status)> f) |
||||
: call_(call), parent_(parent), func_(std::move(f)), status_() { |
||||
grpc_call_ref(call); |
||||
} |
||||
|
||||
void Run(bool ok) override { |
||||
void* ignored = parent_->ops(); |
||||
|
||||
GPR_ASSERT(parent_->ops()->FinalizeResult(&ignored, &ok)); |
||||
GPR_ASSERT(ignored == parent_->ops()); |
||||
|
||||
// Last use of func_ or status_, so ok to move them out
|
||||
CatchingCallback(std::move(func_), std::move(status_)); |
||||
|
||||
func_ = nullptr; // reset to clear this out for sure
|
||||
grpc_call_unref(call_); |
||||
} |
||||
Status* status_ptr() { return &status_; } |
||||
|
||||
private: |
||||
grpc_call* call_; |
||||
CallbackWithStatusTag* parent_; |
||||
std::function<void(Status)> func_; |
||||
Status status_; |
||||
}; |
||||
|
||||
} // namespace
|
||||
|
||||
CallbackWithSuccessTag::CallbackWithSuccessTag(grpc_call* call, |
||||
std::function<void(bool)> f, |
||||
CompletionQueueTag* ops) |
||||
: impl_(new (grpc_call_arena_alloc(call, sizeof(CallbackWithSuccessImpl))) |
||||
CallbackWithSuccessImpl(call, this, std::move(f))), |
||||
ops_(ops) {} |
||||
|
||||
void CallbackWithSuccessTag::force_run(bool ok) { impl_->Run(ok); } |
||||
|
||||
CallbackWithStatusTag::CallbackWithStatusTag(grpc_call* call, |
||||
std::function<void(Status)> f, |
||||
CompletionQueueTag* ops) |
||||
: ops_(ops) { |
||||
auto* impl = new (grpc_call_arena_alloc(call, sizeof(CallbackWithStatusImpl))) |
||||
CallbackWithStatusImpl(call, this, std::move(f)); |
||||
impl_ = impl; |
||||
status_ = impl->status_ptr(); |
||||
} |
||||
|
||||
void CallbackWithStatusTag::force_run(Status s) { |
||||
*status_ = std::move(s); |
||||
impl_->Run(true); |
||||
} |
||||
|
||||
} // namespace internal
|
||||
} // namespace grpc
|
||||
Loading…
Reference in new issue