| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | server_callback_handlers.h | 133 if (!ctx_->sent_initial_metadata_) { in Finish()
134 finish_ops_.SendInitialMetadata(&ctx_->initial_metadata_, in Finish()
135 ctx_->initial_metadata_flags()); in Finish()
136 if (ctx_->compression_level_set()) { in Finish()
137 finish_ops_.set_compression_level(ctx_->compression_level()); in Finish()
139 ctx_->sent_initial_metadata_ = true; in Finish()
143 finish_ops_.ServerSendStatus(&ctx_->trailing_metadata_, in Finish()
146 finish_ops_.ServerSendStatus(&ctx_->trailing_metadata_, s); in Finish()
153 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
169 meta_ops_.SendInitialMetadata(&ctx_->initial_metadata_, in SendInitialMetadata()
[all …]
|
| D | async_unary_call_impl.h | 201 : call_(nullptr, nullptr, nullptr), ctx_(ctx) {} in ServerAsyncResponseWriter()
211 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
214 meta_buf_.SendInitialMetadata(&ctx_->initial_metadata_, in SendInitialMetadata()
215 ctx_->initial_metadata_flags()); in SendInitialMetadata()
216 if (ctx_->compression_level_set()) { in SendInitialMetadata()
217 meta_buf_.set_compression_level(ctx_->compression_level()); in SendInitialMetadata()
219 ctx_->sent_initial_metadata_ = true; in SendInitialMetadata()
241 if (!ctx_->sent_initial_metadata_) { in Finish()
242 finish_buf_.SendInitialMetadata(&ctx_->initial_metadata_, in Finish()
243 ctx_->initial_metadata_flags()); in Finish()
[all …]
|
| D | async_stream.h | 700 : call_(nullptr, nullptr, nullptr), ctx_(ctx) {} in ServerAsyncReader()
708 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
711 meta_ops_.SendInitialMetadata(&ctx_->initial_metadata_, in SendInitialMetadata()
712 ctx_->initial_metadata_flags()); in SendInitialMetadata()
713 if (ctx_->compression_level_set()) { in SendInitialMetadata()
714 meta_ops_.set_compression_level(ctx_->compression_level()); in SendInitialMetadata()
716 ctx_->sent_initial_metadata_ = true; in SendInitialMetadata()
739 if (!ctx_->sent_initial_metadata_) { in Finish()
740 finish_ops_.SendInitialMetadata(&ctx_->initial_metadata_, in Finish()
741 ctx_->initial_metadata_flags()); in Finish()
[all …]
|
| D | async_stream_impl.h | 703 : call_(nullptr, nullptr, nullptr), ctx_(ctx) {} in ServerAsyncReader()
711 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
714 meta_ops_.SendInitialMetadata(&ctx_->initial_metadata_, in SendInitialMetadata()
715 ctx_->initial_metadata_flags()); in SendInitialMetadata()
716 if (ctx_->compression_level_set()) { in SendInitialMetadata()
717 meta_ops_.set_compression_level(ctx_->compression_level()); in SendInitialMetadata()
719 ctx_->sent_initial_metadata_ = true; in SendInitialMetadata()
742 if (!ctx_->sent_initial_metadata_) { in Finish()
743 finish_ops_.SendInitialMetadata(&ctx_->initial_metadata_, in Finish()
744 ctx_->initial_metadata_flags()); in Finish()
[all …]
|
| D | sync_stream_impl.h | 587 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
591 ops.SendInitialMetadata(&ctx_->initial_metadata_, in SendInitialMetadata()
592 ctx_->initial_metadata_flags()); in SendInitialMetadata()
593 if (ctx_->compression_level_set()) { in SendInitialMetadata()
594 ops.set_compression_level(ctx_->compression_level()); in SendInitialMetadata()
596 ctx_->sent_initial_metadata_ = true; in SendInitialMetadata()
616 ServerContext* const ctx_; variable
622 : call_(call), ctx_(ctx) {} in ServerReader()
641 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
645 ops.SendInitialMetadata(&ctx_->initial_metadata_, in SendInitialMetadata()
[all …]
|
| D | sync_stream.h | 586 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
590 ops.SendInitialMetadata(&ctx_->initial_metadata_, in SendInitialMetadata()
591 ctx_->initial_metadata_flags()); in SendInitialMetadata()
592 if (ctx_->compression_level_set()) { in SendInitialMetadata()
593 ops.set_compression_level(ctx_->compression_level()); in SendInitialMetadata()
595 ctx_->sent_initial_metadata_ = true; in SendInitialMetadata()
615 ServerContext* const ctx_; variable
621 : call_(call), ctx_(ctx) {} in ServerReader()
640 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
644 ops.SendInitialMetadata(&ctx_->initial_metadata_, in SendInitialMetadata()
[all …]
|
| D | async_unary_call.h | 298 : call_(nullptr, nullptr, nullptr), ctx_(ctx) {} in ServerAsyncResponseWriter()
308 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
311 meta_buf_.SendInitialMetadata(&ctx_->initial_metadata_, in SendInitialMetadata()
312 ctx_->initial_metadata_flags()); in SendInitialMetadata()
313 if (ctx_->compression_level_set()) { in SendInitialMetadata()
314 meta_buf_.set_compression_level(ctx_->compression_level()); in SendInitialMetadata()
316 ctx_->sent_initial_metadata_ = true; in SendInitialMetadata()
338 if (!ctx_->sent_initial_metadata_) { in Finish()
339 finish_buf_.SendInitialMetadata(&ctx_->initial_metadata_, in Finish()
340 ctx_->initial_metadata_flags()); in Finish()
[all …]
|
| /third_party/grpc/src/cpp/common/ |
| D | secure_auth_context.cc | 26 if (ctx_ == nullptr) { in GetPeerIdentity()
30 grpc_auth_context_peer_identity(ctx_.get()); in GetPeerIdentity()
41 if (ctx_ == nullptr) { in GetPeerIdentityPropertyName()
44 const char* name = grpc_auth_context_peer_identity_property_name(ctx_.get()); in GetPeerIdentityPropertyName()
50 if (ctx_ == nullptr) { in FindPropertyValues()
54 grpc_auth_context_find_properties_by_name(ctx_.get(), name.c_str()); in FindPropertyValues()
64 if (ctx_ != nullptr) { in begin()
66 grpc_auth_context_property_iterator(ctx_.get()); in begin()
81 if (ctx_ == nullptr) return; in AddProperty()
82 grpc_auth_context_add_property(ctx_.get(), key.c_str(), value.data(), in AddProperty()
[all …]
|
| /third_party/grpc/src/core/lib/security/credentials/external/ |
| D | aws_external_account_credentials.cc | 132 ctx_ = ctx; in RetrieveSubjectToken()
168 grpc_http_response_destroy(&ctx_->response); in RetrieveRegion()
169 ctx_->response = {}; in RetrieveRegion()
170 GRPC_CLOSURE_INIT(&ctx_->closure, OnRetrieveRegion, this, nullptr); in RetrieveRegion()
171 grpc_httpcli_get(ctx_->httpcli_context, ctx_->pollent, resource_quota, in RetrieveRegion()
172 &request, ctx_->deadline, &ctx_->closure, &ctx_->response); in RetrieveRegion()
191 absl::string_view response_body(ctx_->response.body, in OnRetrieveRegionInternal()
192 ctx_->response.body_length); in OnRetrieveRegionInternal()
218 grpc_http_response_destroy(&ctx_->response); in RetrieveRoleName()
219 ctx_->response = {}; in RetrieveRoleName()
[all …]
|
| D | external_account_credentials.cc | 212 GPR_ASSERT(ctx_ == nullptr); in fetch_oauth2()
213 ctx_ = new HTTPRequestContext(httpcli_context, pollent, deadline); in fetch_oauth2()
219 RetrieveSubjectToken(ctx_, options_, cb); in fetch_oauth2()
293 grpc_http_response_destroy(&ctx_->response); in ExchangeToken()
294 ctx_->response = {}; in ExchangeToken()
295 GRPC_CLOSURE_INIT(&ctx_->closure, OnExchangeToken, this, nullptr); in ExchangeToken()
296 grpc_httpcli_post(ctx_->httpcli_context, ctx_->pollent, resource_quota, in ExchangeToken()
297 &request, body.c_str(), body.size(), ctx_->deadline, in ExchangeToken()
298 &ctx_->closure, &ctx_->response); in ExchangeToken()
314 metadata_req_->response = ctx_->response; in OnExchangeTokenInternal()
[all …]
|
| D | url_external_account_credentials.cc | 124 ctx_ = ctx; in RetrieveSubjectToken()
145 grpc_http_response_destroy(&ctx_->response); in RetrieveSubjectToken()
146 ctx_->response = {}; in RetrieveSubjectToken()
147 GRPC_CLOSURE_INIT(&ctx_->closure, OnRetrieveSubjectToken, this, nullptr); in RetrieveSubjectToken()
148 grpc_httpcli_get(ctx_->httpcli_context, ctx_->pollent, resource_quota, in RetrieveSubjectToken()
149 &request, ctx_->deadline, &ctx_->closure, &ctx_->response); in RetrieveSubjectToken()
167 absl::string_view response_body(ctx_->response.body, in OnRetrieveSubjectTokenInternal()
168 ctx_->response.body_length); in OnRetrieveSubjectTokenInternal()
201 ctx_ = nullptr; in FinishRetrieveSubjectToken()
|
| /third_party/grpc/test/cpp/qps/ |
| D | client_callback.cc | 109 std::vector<std::unique_ptr<CallbackClientRpcContext>> ctx_; member in grpc::testing::CallbackClient
148 ctx_.emplace_back( in CallbackUnaryClient()
173 if (ctx_[vector_idx]->alarm_ == nullptr) { in ScheduleRpc()
174 ctx_[vector_idx]->alarm_.reset(new Alarm); in ScheduleRpc()
176 ctx_[vector_idx]->alarm_->experimental().Set( in ScheduleRpc()
188 ctx_[vector_idx]->stub_->experimental_async()->UnaryCall( in IssueUnaryCallbackRpc()
189 (&ctx_[vector_idx]->context_), &request_, &ctx_[vector_idx]->response_, in IssueUnaryCallbackRpc()
204 ctx_[vector_idx].reset( in IssueUnaryCallbackRpc()
205 new CallbackClientRpcContext(ctx_[vector_idx]->stub_)); in IssueUnaryCallbackRpc()
220 ctx_.emplace_back( in CallbackStreamingClient()
[all …]
|
| /third_party/grpc/test/cpp/end2end/ |
| D | test_service_impl.cc | 135 : service_(service), ctx_(ctx), req_(request), resp_(response) { in Echo()
140 async_cancel_check_ = std::thread([this] { (void)ctx_->IsCancelled(); }); in Echo()
177 EXPECT_TRUE(ctx_->IsCancelled()); in Echo()
186 EXPECT_EQ(ctx_->IsCancelled(), on_cancel_invoked_); in Echo()
204 EXPECT_TRUE(ctx_->IsCancelled()); in Echo()
219 kServerTryCancelRequest, ctx_->client_metadata(), DO_NOT_CANCEL); in Echo()
225 EXPECT_FALSE(ctx_->IsCancelled()); in Echo()
226 ctx_->TryCancel(); in Echo()
232 internal::MaybeEchoDeadline(ctx_, req_, resp_); in Echo()
252 EXPECT_FALSE(ctx_->IsCancelled()); in Echo()
[all …]
|
| /third_party/boost/libs/coroutine/src/detail/ |
| D | coroutine_context.cpp | 36 ctx_( 0) in coroutine_context()
41 ctx_( context::detail::make_fcontext( palloc_.sp, palloc_.size, fn) ) in coroutine_context()
46 ctx_( other.ctx_) in coroutine_context()
55 ctx_ = other.ctx_; in operator =()
68 context::detail::transfer_t t = context::detail::jump_fcontext( other.ctx_, & data); in jump()
70 ret->from->ctx_ = t.fctx; in jump()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/source/opt/ |
| D | propagator.cpp | 24 if (dest_bb == ctx_->cfg()->pseudo_exit_block()) { in AddControlEdge()
50 if (!BlockHasBeenSimulated(ctx_->get_instr_block(use_instr))) { in AddSSAEdges()
61 BasicBlock* phi_bb = ctx_->get_instr_block(phi); in IsPhiArgExecutable()
65 BasicBlock* in_bb = ctx_->get_instr_block(in_label_instr); in IsPhiArgExecutable()
110 BasicBlock* block = ctx_->get_instr_block(instr); in Simulate()
126 AddControlEdge(Edge(ctx_->get_instr_block(instr), dest_bb)); in Simulate()
176 if (block == ctx_->cfg()->pseudo_exit_block()) { in Simulate()
213 bb_succs_[ctx_->cfg()->pseudo_entry_block()].push_back( in Initialize()
214 Edge(ctx_->cfg()->pseudo_entry_block(), fn->entry().get())); in Initialize()
220 ctx_->get_instr_block(get_def_use_mgr()->GetDef(label_id)); in Initialize()
[all …]
|
| /third_party/skia/third_party/externals/spirv-tools/source/opt/ |
| D | propagator.cpp | 24 if (dest_bb == ctx_->cfg()->pseudo_exit_block()) { in AddControlEdge()
50 if (!BlockHasBeenSimulated(ctx_->get_instr_block(use_instr))) { in AddSSAEdges()
61 BasicBlock* phi_bb = ctx_->get_instr_block(phi); in IsPhiArgExecutable()
65 BasicBlock* in_bb = ctx_->get_instr_block(in_label_instr); in IsPhiArgExecutable()
110 BasicBlock* block = ctx_->get_instr_block(instr); in Simulate()
126 AddControlEdge(Edge(ctx_->get_instr_block(instr), dest_bb)); in Simulate()
176 if (block == ctx_->cfg()->pseudo_exit_block()) { in Simulate()
213 bb_succs_[ctx_->cfg()->pseudo_entry_block()].push_back( in Initialize()
214 Edge(ctx_->cfg()->pseudo_entry_block(), fn->entry().get())); in Initialize()
220 ctx_->get_instr_block(get_def_use_mgr()->GetDef(label_id)); in Initialize()
[all …]
|
| /third_party/spirv-tools/source/opt/ |
| D | propagator.cpp | 24 if (dest_bb == ctx_->cfg()->pseudo_exit_block()) { in AddControlEdge()
50 if (!BlockHasBeenSimulated(ctx_->get_instr_block(use_instr))) { in AddSSAEdges()
61 BasicBlock* phi_bb = ctx_->get_instr_block(phi); in IsPhiArgExecutable()
65 BasicBlock* in_bb = ctx_->get_instr_block(in_label_instr); in IsPhiArgExecutable()
110 BasicBlock* block = ctx_->get_instr_block(instr); in Simulate()
126 AddControlEdge(Edge(ctx_->get_instr_block(instr), dest_bb)); in Simulate()
176 if (block == ctx_->cfg()->pseudo_exit_block()) { in Simulate()
213 bb_succs_[ctx_->cfg()->pseudo_entry_block()].push_back( in Initialize()
214 Edge(ctx_->cfg()->pseudo_entry_block(), fn->entry().get())); in Initialize()
220 ctx_->get_instr_block(get_def_use_mgr()->GetDef(label_id)); in Initialize()
[all …]
|
| /third_party/grpc/test/cpp/common/ |
| D | auth_property_iterator_test.cc | 43 ctx_ = grpc_core::MakeRefCounted<grpc_auth_context>(nullptr); in SetUp()
44 grpc_auth_context_add_cstring_property(ctx_.get(), "name", "chapi"); in SetUp()
45 grpc_auth_context_add_cstring_property(ctx_.get(), "name", "chapo"); in SetUp()
46 grpc_auth_context_add_cstring_property(ctx_.get(), "foo", "bar"); in SetUp()
47 EXPECT_EQ(1, grpc_auth_context_set_peer_identity_property_name(ctx_.get(), in SetUp()
50 grpc_core::RefCountedPtr<grpc_auth_context> ctx_; member in grpc::__anon0f7e2be80111::AuthPropertyIteratorTest
61 grpc_auth_context_property_iterator(ctx_.get()); in TEST_F()
|
| /third_party/mindspore/mindspore/lite/micro/coder/generator/ |
| D | generator.cc | 52 ctx_ = std::move(ctx); in Generator()
71 for (const auto &block : ctx_->code_blocks()) { in CodeNetRunFunc()
82 CodeCMakeNetLibrary(ofs, ctx_, config_); in CodeSourceCMakeFile()
129 CodeSessionCompileGraph(ofs, ctx_, config_); in CodeSessionImplement()
142 CodeWeightFileHeader(hofs, ctx_); in CodeWeightFile()
152 cofs << "unsigned char * " << ctx_->buffer_name() << " = 0; \n"; in CodeWeightFile()
156 SaveDataToNet(ctx_->saved_weights(), net_file); in CodeWeightFile()
157 CodeModelParamsForNet(hofs, cofs, ctx_); in CodeWeightFile()
158 CodeWeightInitFunc(cofs, ctx_); in CodeWeightFile()
160 CodeModelParamsState(hofs, ctx_->saved_weights()); in CodeWeightFile()
[all …]
|
| /third_party/openssl/test/ossl_shim/include/openssl/ |
| D | base.h | 52 StackAllocated() { init(&ctx_); } in StackAllocated()
53 ~StackAllocated() { cleanup(&ctx_); } in ~StackAllocated()
58 T *get() { return &ctx_; } in get()
59 const T *get() const { return &ctx_; } in get()
62 cleanup(&ctx_); in Reset()
63 init(&ctx_); in Reset()
67 T ctx_;
|
| /third_party/grpc/include/grpcpp/test/ |
| D | server_context_test_spouse.h | 32 explicit ServerContextTestSpouse(ServerContext* ctx) : ctx_(ctx) {} in ServerContextTestSpouse()
39 ctx_->client_metadata_.map()->clear(); in AddClientMetadata()
41 ctx_->client_metadata_.map()->insert( in AddClientMetadata()
49 return ctx_->initial_metadata_; in GetInitialMetadata()
53 return ctx_->trailing_metadata_; in GetTrailingMetadata()
57 ServerContext* ctx_; // not owned
|
| D | default_reactor_test_peer.h | 41 : ctx_(ctx) { in DefaultReactorTestPeer()
46 &ctx_->default_reactor_); in reactor()
48 bool test_status_set() const { return ctx_->test_status_set(); } in test_status_set()
49 Status test_status() const { return ctx_->test_status(); } in test_status()
52 experimental::CallbackServerContext* const ctx_; // not owned
|
| /third_party/mindspore/mindspore/lite/micro/coder/generator/train/ |
| D | train_generator.cc | 29 for (const auto &block : ctx_->train_blocks()) { in CodeGradientFunc()
63 CodeInputImplement(ofs, ctx_); in CodeNetCFile()
64 CodeInitResourceImplement(ofs, ctx_); in CodeNetCFile()
65 CodeFreeResourceImplement(ofs, ctx_); in CodeNetCFile()
66 CodeFeaturesImplement(ofs, ctx_); in CodeNetCFile()
69 CodeTrainImplement(ofs, ctx_); in CodeNetCFile()
|
| /third_party/spirv-tools/test/opt/ |
| D | propagator_test.cpp | 37 ctx_.reset(nullptr); in TearDown()
43 ctx_ = BuildModule(SPV_ENV_UNIVERSAL_1_1, nullptr, input); in Assemble()
44 ASSERT_NE(nullptr, ctx_) << "Assembling failed for shader:\n" in Assemble()
49 SSAPropagator propagator(ctx_.get(), visit_fn); in Propagate()
51 for (auto& fn : *ctx_->module()) { in Propagate()
65 std::unique_ptr<IRContext> ctx_; member in spvtools::opt::__anon2b591c230111::PropagatorTest
113 Instruction* rhs_def = ctx_->get_def_use_mgr()->GetDef(rhs_id); in TEST_F()
180 Instruction* rhs_def = ctx_->get_def_use_mgr()->GetDef(rhs_id); in TEST_F()
|
| /third_party/skia/third_party/externals/spirv-tools/test/opt/ |
| D | propagator_test.cpp | 37 ctx_.reset(nullptr); in TearDown()
43 ctx_ = BuildModule(SPV_ENV_UNIVERSAL_1_1, nullptr, input); in Assemble()
44 ASSERT_NE(nullptr, ctx_) << "Assembling failed for shader:\n" in Assemble()
49 SSAPropagator propagator(ctx_.get(), visit_fn); in Propagate()
51 for (auto& fn : *ctx_->module()) { in Propagate()
65 std::unique_ptr<IRContext> ctx_; member in spvtools::opt::__anon2a375db80111::PropagatorTest
113 Instruction* rhs_def = ctx_->get_def_use_mgr()->GetDef(rhs_id); in TEST_F()
180 Instruction* rhs_def = ctx_->get_def_use_mgr()->GetDef(rhs_id); in TEST_F()
|