/dports/devel/grpc130/grpc-1.30.2/src/core/lib/slice/ |
H A D | slice_intern.cc | 44 using grpc_core::InternedSliceRefcount; 64 namespace grpc_core { namespace 117 grpc_core::g_hash_seed); in grpc_slice_default_hash_impl() 140 const grpc_core::StaticMetadataSlice* static_slice_table = in grpc_slice_maybe_static_intern() 157 return grpc_core::ManagedMemorySlice(&slice); in grpc_slice_intern() 166 static const grpc_core::StaticMetadataSlice* MatchStaticSlice( in MatchStaticSlice() 307 grpc_core::g_hash_seed = seed; in grpc_test_only_set_slice_hash_seed() 308 grpc_core::g_forced_hash_seed = true; in grpc_test_only_set_slice_hash_seed() 312 if (!grpc_core::g_forced_hash_seed) { in grpc_slice_intern_init() 313 grpc_core::g_hash_seed = in grpc_slice_intern_init() [all …]
|
/dports/devel/grpc134/grpc-1.34.1/src/core/lib/slice/ |
H A D | slice_intern.cc | 44 using grpc_core::InternedSliceRefcount; 64 namespace grpc_core { namespace 117 grpc_core::g_hash_seed); in grpc_slice_default_hash_impl() 140 const grpc_core::StaticMetadataSlice* static_slice_table = in grpc_slice_maybe_static_intern() 157 return grpc_core::ManagedMemorySlice(&slice); in grpc_slice_intern() 166 static const grpc_core::StaticMetadataSlice* MatchStaticSlice( in MatchStaticSlice() 307 grpc_core::g_hash_seed = seed; in grpc_test_only_set_slice_hash_seed() 308 grpc_core::g_forced_hash_seed = true; in grpc_test_only_set_slice_hash_seed() 312 if (!grpc_core::g_forced_hash_seed) { in grpc_slice_intern_init() 313 grpc_core::g_hash_seed = in grpc_slice_intern_init() [all …]
|
/dports/devel/grpc/grpc-1.42.0/test/core/gprpp/ |
H A D | examine_stack_test.cc | 56 grpc_core::SetCurrentStackTraceProvider(nullptr); in TEST() 57 EXPECT_EQ(grpc_core::GetCurrentStackTraceProvider(), nullptr); in TEST() 58 EXPECT_EQ(grpc_core::GetCurrentStackTrace(), absl::nullopt); in TEST() 62 grpc_core::SetCurrentStackTraceProvider(&SimpleCurrentStackTraceProvider); in TEST() 63 EXPECT_NE(grpc_core::GetCurrentStackTraceProvider(), nullptr); in TEST() 64 EXPECT_EQ(grpc_core::GetCurrentStackTrace(), "stacktrace"); in TEST() 68 grpc_core::SetCurrentStackTraceProvider(&AbseilCurrentStackTraceProvider); in TEST() 69 EXPECT_NE(grpc_core::GetCurrentStackTraceProvider(), nullptr); in TEST() 71 grpc_core::GetCurrentStackTrace(); in TEST()
|
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/transport/chttp2/transport/ |
H A D | internal.h | 49 namespace grpc_core { 210 namespace grpc_core { 295 grpc_core::RefCount refs; 299 grpc_core::MemoryOwner memory_owner; 303 grpc_core::Combiner* combiner; 399 grpc_core::HPackParser hpack_parser; 410 grpc_core::PolymorphicManualConstructor< 492 grpc_core::ContextList* cl = nullptr; 493 grpc_core::RefCountedPtr<grpc_core::channelz::SocketNode> channelz_socket; 550 grpc_core::OrphanablePtr<grpc_core::ByteStream> fetching_send_message; [all …]
|
/dports/devel/grpc130/grpc-1.30.2/src/core/lib/security/credentials/tls/ |
H A D | tls_credentials.cc | 61 grpc_core::RefCountedPtr<grpc_tls_credentials_options> options) in TlsCredentials() 67 grpc_core::RefCountedPtr<grpc_channel_security_connector> 69 grpc_core::RefCountedPtr<grpc_call_credentials> call_creds, in create_security_connector() 86 grpc_core::RefCountedPtr<grpc_channel_security_connector> sc = in create_security_connector() 87 grpc_core::TlsChannelSecurityConnector::CreateTlsChannelSecurityConnector( in create_security_connector() 100 grpc_core::RefCountedPtr<grpc_tls_credentials_options> options) in TlsServerCredentials() 106 grpc_core::RefCountedPtr<grpc_server_security_connector> 108 return grpc_core::TlsServerSecurityConnector:: in create_security_connector() 118 grpc_core::RefCountedPtr<grpc_tls_credentials_options>(options)); in grpc_tls_credentials_create() 127 grpc_core::RefCountedPtr<grpc_tls_credentials_options>(options)); in grpc_tls_server_credentials_create()
|
/dports/devel/grpc130/grpc-1.30.2/src/cpp/thread_manager/ |
H A D | thread_manager.cc | 33 thd_ = grpc_core::Thread( in WorkerThread() 66 grpc_core::MutexLock lock(&mu_); in ~ThreadManager() 76 grpc_core::MutexLock lock(&mu_); in Wait() 83 grpc_core::MutexLock lock(&mu_); in Shutdown() 88 grpc_core::MutexLock lock(&mu_); in IsShutdown() 93 grpc_core::MutexLock list_lock(&list_mu_); in GetMaxActiveThreadsSoFar() 99 grpc_core::MutexLock list_lock(&list_mu_); in MarkAsCompleted() 104 grpc_core::MutexLock lock(&mu_); in MarkAsCompleted() 120 grpc_core::MutexLock lock(&list_mu_); in CleanupCompletedThreads() 136 grpc_core::MutexLock lock(&mu_); in Initialize() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/security/credentials/ |
H A D | credentials.h | 98 : grpc_core::RefCounted<grpc_channel_credentials> { 107 virtual grpc_core::RefCountedPtr<grpc_channel_security_connector> 109 grpc_core::RefCountedPtr<grpc_call_credentials> call_creds, in create_security_connector() 120 virtual grpc_core::RefCountedPtr<grpc_channel_credentials> 176 : public grpc_core::RefCounted<grpc_call_credentials> { 216 : public grpc_core::RefCounted<grpc_server_credentials> { 222 virtual grpc_core::RefCountedPtr<grpc_server_security_connector> 258 grpc_core::RefCountedPtr<grpc_call_credentials> creds) in grpc_credentials_metadata_request() 264 grpc_core::RefCountedPtr<grpc_call_credentials> creds; 270 grpc_core::RefCountedPtr<grpc_call_credentials> creds) { in grpc_credentials_metadata_request_create() [all …]
|
/dports/devel/grpc130/grpc-1.30.2/src/core/lib/surface/ |
H A D | lame_client.cc | 38 namespace grpc_core { namespace 158 grpc_core::lame_start_transport_stream_op_batch, 159 grpc_core::lame_start_transport_op, 160 sizeof(grpc_core::CallData), 161 grpc_core::lame_init_call_elem, 163 grpc_core::lame_destroy_call_elem, 164 sizeof(grpc_core::ChannelData), 165 grpc_core::lame_init_channel_elem, 166 grpc_core::lame_destroy_channel_elem, 167 grpc_core::lame_get_channel_info, [all …]
|
/dports/devel/grpc134/grpc-1.34.1/src/core/lib/surface/ |
H A D | lame_client.cc | 38 namespace grpc_core { namespace 158 grpc_core::lame_start_transport_stream_op_batch, 159 grpc_core::lame_start_transport_op, 160 sizeof(grpc_core::CallData), 161 grpc_core::lame_init_call_elem, 163 grpc_core::lame_destroy_call_elem, 164 sizeof(grpc_core::ChannelData), 165 grpc_core::lame_init_channel_elem, 166 grpc_core::lame_destroy_channel_elem, 167 grpc_core::lame_get_channel_info, [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/security/security_connector/alts/ |
H A D | alts_security_connector.h | 41 grpc_core::RefCountedPtr<grpc_channel_security_connector> 43 grpc_core::RefCountedPtr<grpc_channel_credentials> channel_creds, 44 grpc_core::RefCountedPtr<grpc_call_credentials> request_metadata_creds, 56 grpc_core::RefCountedPtr<grpc_server_security_connector> 58 grpc_core::RefCountedPtr<grpc_server_credentials> server_creds); 60 namespace grpc_core { 64 grpc_core::RefCountedPtr<grpc_auth_context>
|
/dports/devel/grpc/grpc-1.42.0/test/cpp/common/ |
H A D | timer_test.cc | 72 grpc_core::ExecCtx exec_ctx; in TEST_F() 84 grpc_core::ExecCtx exec_ctx; in TEST_F() 87 grpc_timer_init(&timer, grpc_core::ExecCtx::Get()->Now() + 500, in TEST_F() 107 grpc_core::ExecCtx exec_ctx; in TEST_F() 134 grpc_core::ExecCtx exec_ctx; in TEST_F() 168 grpc_core::ExecCtx exec_ctx; in TEST_F() 170 grpc_timer_init(&timer, grpc_core::ExecCtx::Get()->Now() + 10000, in TEST_F() 179 grpc_core::ExecCtx exec_ctx; in TEST_F() 184 grpc_timer_init(&timers[i], grpc_core::ExecCtx::Get()->Now() + 100, in TEST_F() 201 grpc_core::ExecCtx exec_ctx; in TEST_F() [all …]
|
/dports/devel/grpc/grpc-1.42.0/src/core/lib/surface/ |
H A D | lame_client.cc | 41 namespace grpc_core { namespace 158 grpc_core::lame_start_transport_stream_op_batch, 159 grpc_core::lame_start_transport_op, 160 sizeof(grpc_core::CallData), 161 grpc_core::lame_init_call_elem, 163 grpc_core::lame_destroy_call_elem, 164 sizeof(grpc_core::ChannelData), 165 grpc_core::lame_init_channel_elem, 166 grpc_core::lame_destroy_channel_elem, 167 grpc_core::lame_get_channel_info, [all …]
|
/dports/devel/grpc130/grpc-1.30.2/test/cpp/common/ |
H A D | timer_test.cc | 70 grpc_core::ExecCtx exec_ctx; in TEST_F() 82 grpc_core::ExecCtx exec_ctx; in TEST_F() 85 grpc_timer_init(&timer, grpc_core::ExecCtx::Get()->Now() + 500, in TEST_F() 105 grpc_core::ExecCtx exec_ctx; in TEST_F() 132 grpc_core::ExecCtx exec_ctx; in TEST_F() 166 grpc_core::ExecCtx exec_ctx; in TEST_F() 168 grpc_timer_init(&timer, grpc_core::ExecCtx::Get()->Now() + 10000, in TEST_F() 177 grpc_core::ExecCtx exec_ctx; in TEST_F() 182 grpc_timer_init(&timers[i], grpc_core::ExecCtx::Get()->Now() + 100, in TEST_F() 199 grpc_core::ExecCtx exec_ctx; in TEST_F() [all …]
|
/dports/devel/grpc/grpc-1.42.0/test/core/event_engine/test_suite/ |
H A D | timer_test.cc | 38 grpc_core::Mutex mu_; 39 grpc_core::CondVar cv_; 45 grpc_core::MutexLock lock(&mu_); in TEST_F() 47 grpc_core::MutexLock lock(&mu_); in TEST_F() 65 grpc_core::MutexLock lock(&mu_); in TEST_F() 71 grpc_core::MutexLock lock(&mu_); in TEST_F() 80 grpc_core::MutexLock lock(&mu_); in TEST_F() 106 grpc_core::MutexLock lock(&mu_); in TEST_F() 108 grpc_core::MutexLock lock(&mu_); in TEST_F() 131 grpc_core::MutexLock lock(&mu_); in ScheduleCheckCB() [all …]
|
/dports/devel/grpc/grpc-1.42.0/test/core/security/ |
H A D | aws_request_signer_test.cc | 70 grpc_core::AwsRequestSigner signer( in TEST() 88 grpc_core::AwsRequestSigner signer( in TEST() 105 grpc_core::AwsRequestSigner signer( in TEST() 122 grpc_core::AwsRequestSigner signer( in TEST() 154 grpc_core::AwsRequestSigner signer( in TEST() 169 grpc_core::AwsRequestSigner signer( in TEST() 184 grpc_core::AwsRequestSigner signer( in TEST() 199 grpc_core::AwsRequestSigner signer( in TEST() 214 grpc_core::AwsRequestSigner signer( in TEST() 231 grpc_core::AwsRequestSigner signer( in TEST() [all …]
|
/dports/devel/grpc134/grpc-1.34.1/test/core/security/ |
H A D | aws_request_signer_test.cc | 69 grpc_core::AwsRequestSigner signer( in TEST() 87 grpc_core::AwsRequestSigner signer( in TEST() 104 grpc_core::AwsRequestSigner signer( in TEST() 121 grpc_core::AwsRequestSigner signer( in TEST() 153 grpc_core::AwsRequestSigner signer( in TEST() 168 grpc_core::AwsRequestSigner signer( in TEST() 183 grpc_core::AwsRequestSigner signer( in TEST() 198 grpc_core::AwsRequestSigner signer( in TEST() 213 grpc_core::AwsRequestSigner signer( in TEST() 230 grpc_core::AwsRequestSigner signer( in TEST() [all …]
|
/dports/devel/grpc134/grpc-1.34.1/test/cpp/common/ |
H A D | timer_test.cc | 70 grpc_core::ExecCtx exec_ctx; in TEST_F() 82 grpc_core::ExecCtx exec_ctx; in TEST_F() 85 grpc_timer_init(&timer, grpc_core::ExecCtx::Get()->Now() + 500, in TEST_F() 105 grpc_core::ExecCtx exec_ctx; in TEST_F() 132 grpc_core::ExecCtx exec_ctx; in TEST_F() 166 grpc_core::ExecCtx exec_ctx; in TEST_F() 168 grpc_timer_init(&timer, grpc_core::ExecCtx::Get()->Now() + 10000, in TEST_F() 177 grpc_core::ExecCtx exec_ctx; in TEST_F() 182 grpc_timer_init(&timers[i], grpc_core::ExecCtx::Get()->Now() + 100, in TEST_F() 199 grpc_core::ExecCtx exec_ctx; in TEST_F() [all …]
|
/dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/surface/ |
H A D | lame_client.cc | 41 namespace grpc_core { namespace 158 grpc_core::lame_start_transport_stream_op_batch, 159 grpc_core::lame_start_transport_op, 160 sizeof(grpc_core::CallData), 161 grpc_core::lame_init_call_elem, 163 grpc_core::lame_destroy_call_elem, 164 sizeof(grpc_core::ChannelData), 165 grpc_core::lame_init_channel_elem, 166 grpc_core::lame_destroy_channel_elem, 167 grpc_core::lame_get_channel_info, [all …]
|
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/lib/surface/ |
H A D | lame_client.cc | 42 namespace grpc_core { namespace 159 grpc_core::lame_start_transport_stream_op_batch, 160 grpc_core::lame_start_transport_op, 161 sizeof(grpc_core::CallData), 162 grpc_core::lame_init_call_elem, 164 grpc_core::lame_destroy_call_elem, 165 sizeof(grpc_core::ChannelData), 166 grpc_core::lame_init_channel_elem, 167 grpc_core::lame_destroy_channel_elem, 168 grpc_core::lame_get_channel_info, [all …]
|
/dports/devel/grpc/grpc-1.42.0/src/core/lib/security/security_connector/alts/ |
H A D | alts_security_connector.h | 42 grpc_core::RefCountedPtr<grpc_channel_security_connector> 44 grpc_core::RefCountedPtr<grpc_channel_credentials> channel_creds, 45 grpc_core::RefCountedPtr<grpc_call_credentials> request_metadata_creds, 57 grpc_core::RefCountedPtr<grpc_server_security_connector> 59 grpc_core::RefCountedPtr<grpc_server_credentials> server_creds); 65 namespace grpc_core { 69 grpc_core::RefCountedPtr<grpc_auth_context>
|
/dports/devel/grpc130/grpc-1.30.2/src/core/lib/security/security_connector/alts/ |
H A D | alts_security_connector.h | 42 grpc_core::RefCountedPtr<grpc_channel_security_connector> 44 grpc_core::RefCountedPtr<grpc_channel_credentials> channel_creds, 45 grpc_core::RefCountedPtr<grpc_call_credentials> request_metadata_creds, 57 grpc_core::RefCountedPtr<grpc_server_security_connector> 59 grpc_core::RefCountedPtr<grpc_server_credentials> server_creds); 65 namespace grpc_core { 69 grpc_core::RefCountedPtr<grpc_auth_context>
|
/dports/devel/grpc134/grpc-1.34.1/src/core/lib/security/security_connector/alts/ |
H A D | alts_security_connector.h | 42 grpc_core::RefCountedPtr<grpc_channel_security_connector> 44 grpc_core::RefCountedPtr<grpc_channel_credentials> channel_creds, 45 grpc_core::RefCountedPtr<grpc_call_credentials> request_metadata_creds, 57 grpc_core::RefCountedPtr<grpc_server_security_connector> 59 grpc_core::RefCountedPtr<grpc_server_credentials> server_creds); 65 namespace grpc_core { 69 grpc_core::RefCountedPtr<grpc_auth_context>
|
/dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/security/security_connector/alts/ |
H A D | alts_security_connector.h | 42 grpc_core::RefCountedPtr<grpc_channel_security_connector> 44 grpc_core::RefCountedPtr<grpc_channel_credentials> channel_creds, 45 grpc_core::RefCountedPtr<grpc_call_credentials> request_metadata_creds, 57 grpc_core::RefCountedPtr<grpc_server_security_connector> 59 grpc_core::RefCountedPtr<grpc_server_credentials> server_creds); 65 namespace grpc_core { 69 grpc_core::RefCountedPtr<grpc_auth_context>
|
/dports/devel/grpc134/grpc-1.34.1/src/core/lib/iomgr/ |
H A D | pollset_custom.cc | 58 grpc_core::ExecCtx::Run(DEBUG_LOCATION, closure, GRPC_ERROR_NONE); in pollset_shutdown() 71 grpc_millis now = grpc_core::ExecCtx::Get()->Now(); in pollset_work() 78 grpc_core::ExecCtx* curr = grpc_core::ExecCtx::Get(); in pollset_work() 79 grpc_core::ExecCtx::Set(nullptr); in pollset_work() 81 grpc_core::ExecCtx::Set(curr); in pollset_work() 82 grpc_core::ExecCtx::Get()->InvalidateNow(); in pollset_work() 83 if (grpc_core::ExecCtx::Get()->HasWork()) { in pollset_work() 84 grpc_core::ExecCtx::Get()->Flush(); in pollset_work()
|
/dports/devel/grpc130/grpc-1.30.2/src/core/lib/iomgr/ |
H A D | pollset_custom.cc | 58 grpc_core::ExecCtx::Run(DEBUG_LOCATION, closure, GRPC_ERROR_NONE); in pollset_shutdown() 71 grpc_millis now = grpc_core::ExecCtx::Get()->Now(); in pollset_work() 78 grpc_core::ExecCtx* curr = grpc_core::ExecCtx::Get(); in pollset_work() 79 grpc_core::ExecCtx::Set(nullptr); in pollset_work() 81 grpc_core::ExecCtx::Set(curr); in pollset_work() 82 grpc_core::ExecCtx::Get()->InvalidateNow(); in pollset_work() 83 if (grpc_core::ExecCtx::Get()->HasWork()) { in pollset_work() 84 grpc_core::ExecCtx::Get()->Flush(); in pollset_work()
|