Home
last modified time | relevance | path

Searched refs:ctx_ (Results 1 – 25 of 100) sorted by relevance

1234

/external/grpc-grpc/src/cpp/common/
Dsecure_auth_context.cc27 : ctx_(ctx), take_ownership_(take_ownership) {} in SecureAuthContext()
30 if (take_ownership_) grpc_auth_context_release(ctx_); in ~SecureAuthContext()
34 if (!ctx_) { in GetPeerIdentity()
37 grpc_auth_property_iterator iter = grpc_auth_context_peer_identity(ctx_); in GetPeerIdentity()
48 if (!ctx_) { in GetPeerIdentityPropertyName()
51 const char* name = grpc_auth_context_peer_identity_property_name(ctx_); in GetPeerIdentityPropertyName()
57 if (!ctx_) { in FindPropertyValues()
61 grpc_auth_context_find_properties_by_name(ctx_, name.c_str()); in FindPropertyValues()
71 if (ctx_) { in begin()
73 grpc_auth_context_property_iterator(ctx_); in begin()
[all …]
Dauth_property_iterator.cc26 : property_(nullptr), ctx_(nullptr), index_(0), name_(nullptr) {} in AuthPropertyIterator()
31 ctx_(iter->ctx), in AuthPropertyIterator()
38 grpc_auth_property_iterator iter = {ctx_, index_, name_}; in operator ++()
40 ctx_ = iter.ctx; in operator ++()
/external/grpc-grpc/include/grpcpp/impl/codegen/
Dasync_unary_call.h204 : call_(nullptr, nullptr, nullptr), ctx_(ctx) {} in ServerAsyncResponseWriter()
214 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
217 meta_buf_.SendInitialMetadata(ctx_->initial_metadata_, in SendInitialMetadata()
218 ctx_->initial_metadata_flags()); in SendInitialMetadata()
219 if (ctx_->compression_level_set()) { in SendInitialMetadata()
220 meta_buf_.set_compression_level(ctx_->compression_level()); in SendInitialMetadata()
222 ctx_->sent_initial_metadata_ = true; in SendInitialMetadata()
243 if (!ctx_->sent_initial_metadata_) { in Finish()
244 finish_buf_.SendInitialMetadata(ctx_->initial_metadata_, in Finish()
245 ctx_->initial_metadata_flags()); in Finish()
[all …]
Dsync_stream.h583 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
586 ops.SendInitialMetadata(ctx_->initial_metadata_, in SendInitialMetadata()
587 ctx_->initial_metadata_flags()); in SendInitialMetadata()
588 if (ctx_->compression_level_set()) { in SendInitialMetadata()
589 ops.set_compression_level(ctx_->compression_level()); in SendInitialMetadata()
591 ctx_->sent_initial_metadata_ = true; in SendInitialMetadata()
610 ServerContext* const ctx_; variable
616 : call_(call), ctx_(ctx) {} in ServerReader()
635 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
638 ops.SendInitialMetadata(ctx_->initial_metadata_, in SendInitialMetadata()
[all …]
Dasync_stream.h702 : call_(nullptr, nullptr, nullptr), ctx_(ctx) {} in ServerAsyncReader()
710 GPR_CODEGEN_ASSERT(!ctx_->sent_initial_metadata_); in SendInitialMetadata()
713 meta_ops_.SendInitialMetadata(ctx_->initial_metadata_, in SendInitialMetadata()
714 ctx_->initial_metadata_flags()); in SendInitialMetadata()
715 if (ctx_->compression_level_set()) { in SendInitialMetadata()
716 meta_ops_.set_compression_level(ctx_->compression_level()); in SendInitialMetadata()
718 ctx_->sent_initial_metadata_ = true; in SendInitialMetadata()
741 if (!ctx_->sent_initial_metadata_) { in Finish()
742 finish_ops_.SendInitialMetadata(ctx_->initial_metadata_, in Finish()
743 ctx_->initial_metadata_flags()); in Finish()
[all …]
/external/compiler-rt/lib/sanitizer_common/tests/
Dsanitizer_suppressions_test.cc67 : ctx_(kTestSuppressionTypes, ARRAY_SIZE(kTestSuppressionTypes)) {} in SuppressionContextTest()
70 SuppressionContext ctx_; member in __sanitizer::SuppressionContextTest
74 EXPECT_EQ(count, ctx_.SuppressionCount()); in CheckSuppressions()
76 const Suppression *s = ctx_.SuppressionAt(i); in CheckSuppressions()
84 ctx_.Parse("race:foo\n" in TEST_F()
94 ctx_.Parse( in TEST_F()
105 ctx_.Parse( in TEST_F()
115 ctx_.Parse( in TEST_F()
126 ctx_.Parse( in TEST_F()
129 EXPECT_TRUE(ctx_.HasSuppressionType("race")); in TEST_F()
[all …]
/external/tensorflow/tensorflow/core/kernels/
Dfunctional_ops.cc155 ctx_(ctx), in State()
160 lib_(CHECK_NOTNULL(ctx_->function_library())) { in State()
161 SetRunOptions(ctx_, &opts_, true /* always_collect_stats */); in State()
162 for (int i = 1; i < ctx_->num_inputs(); ++i) { in State()
163 args_.push_back(ctx_->input(i)); in State()
174 return absl::StrCat("IfOp #parent_step_id=", ctx_->step_id(), in Start()
184 s = SetOutputs(kernel_, ctx_, rets_); in Start()
186 ctx_->SetStatus(s); in Start()
195 OpKernelContext* const ctx_; member in tensorflow::__anon351ad7530111::IfOp::State
251 ctx_(ctx), in State()
[all …]
/external/boringssl/src/ssl/test/
Dfuzzer.h311 bssl::UniquePtr<SSL> ssl_handoff(SSL_new(ctx_.get())); in TestOneInput()
312 bssl::UniquePtr<SSL> ssl_handback(SSL_new(ctx_.get())); in TestOneInput()
379 ctx_.reset(SSL_CTX_new(protocol_ == kDTLS ? DTLS_method() : TLS_method())); in Init()
383 if (!ctx_ || !privkey || !pkey || in Init()
385 !SSL_CTX_use_PrivateKey(ctx_.get(), pkey.get())) { in Init()
392 !SSL_CTX_use_certificate(ctx_.get(), cert.get()) || in Init()
393 !SSL_CTX_set_ocsp_response(ctx_.get(), kOCSPResponse, in Init()
395 !SSL_CTX_set_signed_cert_timestamp_list(ctx_.get(), kSCT, in Init()
402 ctx_.get(), in Init()
405 SSL_CTX_enable_signed_cert_timestamps(ctx_.get()); in Init()
[all …]
/external/libchrome/crypto/
Dsecure_hash.cc27 SHA256_Init(&ctx_); in SecureHashSHA256()
31 memcpy(&ctx_, &other.ctx_, sizeof(ctx_)); in SecureHashSHA256()
35 OPENSSL_cleanse(&ctx_, sizeof(ctx_)); in ~SecureHashSHA256()
39 SHA256_Update(&ctx_, static_cast<const unsigned char*>(input), len); in Update()
45 SHA256_Final(result.safe_buffer(), &ctx_); in Finish()
55 SHA256_CTX ctx_; member in crypto::__anon022e31ee0111::SecureHashSHA256
/external/boringssl/src/crypto/test/
Dabi_test.cc258 explicit UnwindCursor(const CONTEXT &ctx) : ctx_(ctx) { in UnwindCursor()
259 starting_ip_ = ctx_.Rip; in UnwindCursor()
272 RtlLookupFunctionEntry(ctx_.Rip, &image_base, nullptr); in Step()
279 memcpy(&ctx_.Rip, reinterpret_cast<const void *>(ctx_.Rsp), in Step()
280 sizeof(ctx_.Rip)); in Step()
281 ctx_.Rsp += 8; in Step()
288 RtlVirtualUnwind(UNW_FLAG_NHANDLER, image_base, ctx_.Rip, entry, &ctx_, in Step()
290 return ctx_.Rip != 0; in Step()
294 UnwindStatusOr<crypto_word_t> GetIP() { return ctx_.Rip; } in GetIP()
297 UnwindStatusOr<crypto_word_t> GetSP() { return ctx_.Rsp; } in GetSP()
[all …]
/external/grpc-grpc/test/cpp/common/
Dauth_property_iterator_test.cc43 ctx_ = grpc_auth_context_create(nullptr); in SetUp()
44 grpc_auth_context_add_cstring_property(ctx_, "name", "chapi"); in SetUp()
45 grpc_auth_context_add_cstring_property(ctx_, "name", "chapo"); in SetUp()
46 grpc_auth_context_add_cstring_property(ctx_, "foo", "bar"); in SetUp()
48 grpc_auth_context_set_peer_identity_property_name(ctx_, "name")); in SetUp()
50 void TearDown() override { grpc_auth_context_release(ctx_); } in TearDown()
51 grpc_auth_context* ctx_; member in grpc::__anon310f54fb0111::AuthPropertyIteratorTest
62 grpc_auth_context_property_iterator(ctx_); in TEST_F()
/external/deqp-deps/SPIRV-Tools/source/opt/
Dpropagator.cpp24 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 …]
/external/swiftshader/third_party/SPIRV-Tools/source/opt/
Dpropagator.cpp24 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 …]
/external/angle/third_party/spirv-tools/src/source/opt/
Dpropagator.cpp24 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 …]
/external/perfetto/src/trace_processor/importers/ninja/
Dninja_log_parser.cc31 NinjaLogParser::NinjaLogParser(TraceProcessorContext* ctx) : ctx_(ctx) {} in NinjaLogParser()
89 ctx_->storage->IncrementStats(stats::ninja_parse_errors); in Parse()
101 StringId name_id = ctx_->storage->InternString("Build"); in Parse()
102 ctx_->process_tracker->SetProcessNameIfUnset( in Parse()
103 ctx_->process_tracker->GetOrCreateProcess(cur_build_id_), name_id); in Parse()
171 StringId name_id = ctx_->storage->InternString(name); in NotifyEndOfFile()
172 auto utid = ctx_->process_tracker->UpdateThread(worker_id, job.build_id); in NotifyEndOfFile()
173 ctx_->process_tracker->SetThreadNameIfUnset(utid, name_id); in NotifyEndOfFile()
174 TrackId track_id = ctx_->track_tracker->InternThreadTrack(utid); in NotifyEndOfFile()
182 StringId name_id = ctx_->storage->InternString(base::StringView(job.names)); in NotifyEndOfFile()
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Dremote_copy_node.cc78 ctx_(ctx), in RemoteCopyNode()
88 ctx_->Ref(); in RemoteCopyNode()
93 ctx_->Unref(); in ~RemoteCopyNode()
116 EagerOperation op(ctx_); in StartSend()
145 request.set_context_id(ctx_->GetContextId()); in StartSend()
147 status = ctx_->RemoteMgr()->SerializeRemoteTensorHandle( in StartSend()
149 src_->DeviceOrHostCPU(*ctx_)->name()); in StartSend()
156 remote_op->set_id(ctx_->RemoteMgr()->NextOpId()); in StartSend()
160 status = ctx_->GetClient(send_device_, &eager_client); in StartSend()
196 uint64 context_id = ctx_->GetContextId(); in RunRemoteRecv()
[all …]
Dremote_mgr_test.cc55 ctx_ = new tensorflow::EagerContext( in RemoteMgrTest()
63 ~RemoteMgrTest() override { ctx_->Unref(); } in ~RemoteMgrTest()
68 EagerContext* ctx_; member in tensorflow::eager::__anondf09ac640111::RemoteMgrTest
72 RemoteMgr remote_mgr(false, ctx_); in TEST_F()
77 TensorHandle::CreateLocalHandle(t, local_device_, ctx_, &handle)); in TEST_F()
81 op_id, output_num, t.shape(), /*remote_task=*/"", context_id_, ctx_); in TEST_F()
94 RemoteMgr remote_mgr(false, ctx_); in TEST_F()
103 /*resource_device=*/nullptr, ctx_, &handle)); in TEST_F()
/external/grpc-grpc/include/grpcpp/test/
Dserver_context_test_spouse.h32 explicit ServerContextTestSpouse(ServerContext* ctx) : ctx_(ctx) {} in ServerContextTestSpouse()
39 ctx_->client_metadata_.map()->clear(); in AddClientMetadata()
42 ctx_->client_metadata_.map()->insert( in AddClientMetadata()
50 return ctx_->initial_metadata_; in GetInitialMetadata()
54 return ctx_->trailing_metadata_; in GetTrailingMetadata()
58 ServerContext* ctx_; // not owned
/external/deqp-deps/SPIRV-Tools/test/opt/
Dpropagator_test.cpp37 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::__anon171c7acf0111::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()
/external/angle/third_party/spirv-tools/src/test/opt/
Dpropagator_test.cpp37 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::__anon26a359c30111::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()
/external/swiftshader/third_party/SPIRV-Tools/test/opt/
Dpropagator_test.cpp37 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::__anon6eb660890111::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()
/external/webrtc/webrtc/base/
Dopenssldigest.cc21 EVP_MD_CTX_init(&ctx_); in OpenSSLDigest()
23 EVP_DigestInit_ex(&ctx_, md_, NULL); in OpenSSLDigest()
30 EVP_MD_CTX_cleanup(&ctx_); in ~OpenSSLDigest()
44 EVP_DigestUpdate(&ctx_, buf, len); in Update()
52 EVP_DigestFinal_ex(&ctx_, static_cast<unsigned char*>(buf), &md_len); in Finish()
53 EVP_DigestInit_ex(&ctx_, md_, NULL); // prepare for future Update()s in Finish()
/external/python/cpython3/Python/
Dast_opt.c392 static int astfold_mod(mod_ty node_, PyArena *ctx_, int optimize_);
393 static int astfold_stmt(stmt_ty node_, PyArena *ctx_, int optimize_);
394 static int astfold_expr(expr_ty node_, PyArena *ctx_, int optimize_);
395 static int astfold_arguments(arguments_ty node_, PyArena *ctx_, int optimize_);
396 static int astfold_comprehension(comprehension_ty node_, PyArena *ctx_, int optimize_);
397 static int astfold_keyword(keyword_ty node_, PyArena *ctx_, int optimize_);
398 static int astfold_slice(slice_ty node_, PyArena *ctx_, int optimize_);
399 static int astfold_arg(arg_ty node_, PyArena *ctx_, int optimize_);
400 static int astfold_withitem(withitem_ty node_, PyArena *ctx_, int optimize_);
401 static int astfold_excepthandler(excepthandler_ty node_, PyArena *ctx_, int optimize_);
[all …]
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_call.h164 : handle_request_function_(handle_request_function), responder_(&ctx_) {} in Call()
182 if (ctx_.IsCancelled()) { in RequestCancelled()
220 (grpc_service->*enqueue_function)(&call->ctx_, &call->request, in EnqueueRequest()
241 grpc_service->RequestAsyncUnary(method_id, &call->ctx_, &call->request, in EnqueueRequestForMethod()
251 return ctx_.client_metadata(); in client_metadata()
260 ctx_.AsyncNotifyWhenDone(&cancelled_tag_); in RegisterCancellationHandler()
264 ::grpc::ServerContext ctx_;
425 stream_(&ctx_), in ServerBidirectionalStreamingCall()
485 (grpc_service->*enqueue_function)(&call->ctx_, &call->stream_, cq, cq, in EnqueueRequest()
497 ::grpc::ServerContext ctx_;
/external/tensorflow/tensorflow/core/grappler/optimizers/
Dgraph_optimizer_stage.h121 : optimizer_name_(optimizer_name), stage_name_(stage_name), ctx_(ctx) {} in GraphOptimizerStage()
187 return ::tensorflow::grappler::GetInputNode(ctx_, input, node); in GetInputNode()
194 return ::tensorflow::grappler::GetTensorProperties(ctx_, tensor, in GetTensorProperties()
199 return ::tensorflow::grappler::AddCopyNode(ctx_, name, node_to_copy); in AddCopyNode()
202 return ::tensorflow::grappler::AddEmptyNode(ctx_, name); in AddEmptyNode()
206 const GraphOptimizerContext& ctx() const { return ctx_; } in ctx()
211 while (ctx_.node_map->NodeExists(node_name)) { in UniqueNodeName()
221 const GraphOptimizerContext ctx_; variable

1234