| /external/pigweed/pw_transfer/ |
| D | transfer_test.cc | 116 ctx_(transfer_thread_, 64), in ReadTransfer()
118 ctx_.service().RegisterHandler(handler_); in ReadTransfer()
123 ctx_.call(); // Open the read stream in ReadTransfer()
134 PW_RAW_TEST_METHOD_CONTEXT(TransferService, Read) ctx_;
141 rpc::test::WaitForPackets(ctx_.output(), 2, [this] { in TEST_F()
142 ctx_.SendClientStream( in TEST_F()
154 ASSERT_EQ(ctx_.total_responses(), 2u); in TEST_F()
155 Chunk c0 = DecodeChunk(ctx_.responses()[0]); in TEST_F()
156 Chunk c1 = DecodeChunk(ctx_.responses()[1]); in TEST_F()
171 ctx_.SendClientStream( in TEST_F()
[all …]
|
| /external/cronet/crypto/ |
| D | secure_hash.cc | 26 SHA256_Init(&ctx_); in SecureHashSHA256()
30 memcpy(&ctx_, &other.ctx_, sizeof(ctx_)); in SecureHashSHA256()
34 OPENSSL_cleanse(&ctx_, sizeof(ctx_)); in ~SecureHashSHA256()
38 SHA256_Update(&ctx_, static_cast<const unsigned char*>(input), len); in Update()
44 SHA256_Final(result.safe_buffer(), &ctx_); in Finish()
54 SHA256_CTX ctx_; member in crypto::__anon945b8a3e0111::SecureHashSHA256
63 SHA512_Init(&ctx_); in SecureHashSHA512()
67 memcpy(&ctx_, &other.ctx_, sizeof(ctx_)); in SecureHashSHA512()
70 ~SecureHashSHA512() override { OPENSSL_cleanse(&ctx_, sizeof(ctx_)); } in ~SecureHashSHA512()
73 SHA512_Update(&ctx_, static_cast<const unsigned char*>(input), len); in Update()
[all …]
|
| /external/perfetto/src/base/threading/ |
| D | stream_unittest.cc | 53 PollContext ctx_{&interested_, &ready_}; member in perfetto::base::__anonebbc91730111::StreamUnittest
63 auto res = stream.PollNext(&ctx_); in TEST_F()
77 ASSERT_TRUE(stream.PollNext(&ctx_).IsPending()); in TEST_F()
78 ASSERT_EQ(stream.PollNext(&ctx_).item(), 1); in TEST_F()
79 ASSERT_TRUE(stream.PollNext(&ctx_).IsDone()); in TEST_F()
96 ASSERT_TRUE(stream.PollNext(&ctx_).IsPending()); in TEST_F()
97 ASSERT_EQ(stream.PollNext(&ctx_).item(), "1"); in TEST_F()
98 ASSERT_TRUE(stream.PollNext(&ctx_).IsPending()); in TEST_F()
99 ASSERT_EQ(stream.PollNext(&ctx_).item(), "2"); in TEST_F()
100 ASSERT_TRUE(stream.PollNext(&ctx_).IsDone()); in TEST_F()
[all …]
|
| /external/rust/crates/grpcio-sys/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_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 | 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 …]
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-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_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 | 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 …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | remote_mgr_test.cc | 57 ctx_ = new tensorflow::EagerContext( in RemoteMgrTest()
63 ~RemoteMgrTest() override { ctx_->Unref(); } in ~RemoteMgrTest()
67 EagerContext* ctx_; member in tensorflow::eager::__anon7914da5e0111::RemoteMgrTest
71 RemoteMgr remote_mgr(false, ctx_); in TEST_F()
76 std::move(t), local_device_, local_device_, ctx_); in TEST_F()
80 output_num, "", ctx_)); in TEST_F()
82 handle->SetRemoteShape(shape, remote_device_, ctx_->GetContextViewId())); in TEST_F()
94 RemoteMgr remote_mgr(false, ctx_); in TEST_F()
99 op_id, output_num, DT_FLOAT, remote_device_, /*is_ready=*/true, ctx_); in TEST_F()
111 RemoteMgr remote_mgr(false, ctx_); in TEST_F()
[all …]
|
| /external/grpc-grpc/src/cpp/common/ |
| D | secure_auth_context.cc | 27 : 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 …]
|
| /external/rust/crates/grpcio-sys/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 …]
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | async_unary_call.h | 204 : 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 …]
|
| D | sync_stream.h | 583 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 …]
|
| D | async_stream.h | 702 : 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/ |
| D | sanitizer_suppressions_test.cc | 67 : 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/rust/crates/grpcio-sys/grpc/src/core/lib/security/credentials/external/ |
| D | aws_external_account_credentials.cc | 133 ctx_ = ctx; in RetrieveSubjectToken()
172 grpc_http_response_destroy(&ctx_->response); in RetrieveRegion()
173 ctx_->response = {}; in RetrieveRegion()
174 GRPC_CLOSURE_INIT(&ctx_->closure, OnRetrieveRegion, this, nullptr); in RetrieveRegion()
175 grpc_httpcli_get(ctx_->httpcli_context, ctx_->pollent, resource_quota, in RetrieveRegion()
176 &request, ctx_->deadline, &ctx_->closure, &ctx_->response); in RetrieveRegion()
195 absl::string_view response_body(ctx_->response.body, in OnRetrieveRegionInternal()
196 ctx_->response.body_length); in OnRetrieveRegionInternal()
222 grpc_http_response_destroy(&ctx_->response); in RetrieveRoleName()
223 ctx_->response = {}; in RetrieveRoleName()
[all …]
|
| D | external_account_credentials.cc | 213 GPR_ASSERT(ctx_ == nullptr); in fetch_oauth2()
214 ctx_ = new HTTPRequestContext(httpcli_context, pollent, deadline); in fetch_oauth2()
220 RetrieveSubjectToken(ctx_, options_, cb); in fetch_oauth2()
294 grpc_http_response_destroy(&ctx_->response); in ExchangeToken()
295 ctx_->response = {}; in ExchangeToken()
296 GRPC_CLOSURE_INIT(&ctx_->closure, OnExchangeToken, this, nullptr); in ExchangeToken()
297 grpc_httpcli_post(ctx_->httpcli_context, ctx_->pollent, resource_quota, in ExchangeToken()
298 &request, body.c_str(), body.size(), ctx_->deadline, in ExchangeToken()
299 &ctx_->closure, &ctx_->response); in ExchangeToken()
317 metadata_req_->response = ctx_->response; in OnExchangeTokenInternal()
[all …]
|
| /external/webrtc/net/dcsctp/socket/ |
| D | heartbeat_handler.cc | 92 ctx_(context), in HeartbeatHandler()
120 interval_timer_->set_duration(interval_duration_ + ctx_->current_rto()); in RestartTimer()
134 ctx_->Send(ctx_->PacketBuilder().Add( in HandleHeartbeatRequest()
142 ctx_->callbacks().OnError( in HandleHeartbeatAck()
150 ctx_->callbacks().OnError(ErrorKind::kParseFailed, in HandleHeartbeatAck()
156 TimeMs now = ctx_->callbacks().TimeMillis(); in HandleHeartbeatAck()
158 ctx_->ObserveRTT(now - info->created_at()); in HandleHeartbeatAck()
164 ctx_->ClearTxErrorCounter(); in HandleHeartbeatAck()
168 if (ctx_->is_connection_established()) { in OnIntervalTimerExpiry()
169 HeartbeatInfo info(ctx_->callbacks().TimeMillis()); in OnIntervalTimerExpiry()
[all …]
|
| /external/cronet/third_party/boringssl/src/ssl/test/ |
| D | fuzzer.h | 319 bssl::UniquePtr<SSL> ssl_handoff(SSL_new(ctx_.get())); in TestOneInput()
320 bssl::UniquePtr<SSL> ssl_handback(SSL_new(ctx_.get())); in TestOneInput()
387 ctx_.reset(SSL_CTX_new(protocol_ == kDTLS ? DTLS_method() : TLS_method())); in Init()
391 if (!ctx_ || !privkey || !pkey || in Init()
393 !SSL_CTX_use_PrivateKey(ctx_.get(), pkey.get())) { in Init()
400 !SSL_CTX_use_certificate(ctx_.get(), cert.get()) || in Init()
401 !SSL_CTX_set_ocsp_response(ctx_.get(), kOCSPResponse, in Init()
403 !SSL_CTX_set_signed_cert_timestamp_list(ctx_.get(), kSCT, in Init()
410 ctx_.get(), in Init()
413 SSL_CTX_enable_signed_cert_timestamps(ctx_.get()); in Init()
[all …]
|
| /external/rust/crates/quiche/deps/boringssl/src/ssl/test/ |
| D | fuzzer.h | 329 bssl::UniquePtr<SSL> ssl_handoff(SSL_new(ctx_.get())); in TestOneInput()
330 bssl::UniquePtr<SSL> ssl_handback(SSL_new(ctx_.get())); in TestOneInput()
397 ctx_.reset(SSL_CTX_new(protocol_ == kDTLS ? DTLS_method() : TLS_method())); in Init()
401 if (!ctx_ || !privkey || !pkey || in Init()
403 !SSL_CTX_use_PrivateKey(ctx_.get(), pkey.get())) { in Init()
410 !SSL_CTX_use_certificate(ctx_.get(), cert.get()) || in Init()
411 !SSL_CTX_set_ocsp_response(ctx_.get(), kOCSPResponse, in Init()
413 !SSL_CTX_set_signed_cert_timestamp_list(ctx_.get(), kSCT, in Init()
420 ctx_.get(), in Init()
423 SSL_CTX_enable_signed_cert_timestamps(ctx_.get()); in Init()
[all …]
|
| /external/boringssl/src/ssl/test/ |
| D | fuzzer.h | 319 bssl::UniquePtr<SSL> ssl_handoff(SSL_new(ctx_.get())); in TestOneInput()
320 bssl::UniquePtr<SSL> ssl_handback(SSL_new(ctx_.get())); in TestOneInput()
387 ctx_.reset(SSL_CTX_new(protocol_ == kDTLS ? DTLS_method() : TLS_method())); in Init()
391 if (!ctx_ || !privkey || !pkey || in Init()
393 !SSL_CTX_use_PrivateKey(ctx_.get(), pkey.get())) { in Init()
400 !SSL_CTX_use_certificate(ctx_.get(), cert.get()) || in Init()
401 !SSL_CTX_set_ocsp_response(ctx_.get(), kOCSPResponse, in Init()
403 !SSL_CTX_set_signed_cert_timestamp_list(ctx_.get(), kSCT, in Init()
410 ctx_.get(), in Init()
413 SSL_CTX_enable_signed_cert_timestamps(ctx_.get()); in Init()
[all …]
|
| /external/libchrome/crypto/ |
| D | secure_hash.cc | 27 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::__anon592e9de80111::SecureHashSHA256
|