/external/grpc-grpc/include/grpcpp/impl/codegen/ |
D | method_handler_impl.h | 68 return func_(service_, param.server_context, &req, &rsp); in RunHandler() 72 GPR_CODEGEN_ASSERT(!param.server_context->sent_initial_metadata_); in RunHandler() 76 ops.SendInitialMetadata(param.server_context->initial_metadata_, in RunHandler() 77 param.server_context->initial_metadata_flags()); in RunHandler() 78 if (param.server_context->compression_level_set()) { in RunHandler() 79 ops.set_compression_level(param.server_context->compression_level()); in RunHandler() 84 ops.ServerSendStatus(param.server_context->trailing_metadata_, status); in RunHandler() 110 ServerReader<RequestType> reader(param.call, param.server_context); in RunHandler() 113 return func_(service_, param.server_context, &reader, &rsp); in RunHandler() 119 if (!param.server_context->sent_initial_metadata_) { in RunHandler() [all …]
|
D | rpc_service_method.h | 44 : call(c), server_context(context) { in HandlerParameter() 49 ServerContext* server_context; member
|
D | client_context.h | 180 const ServerContext& server_context,
|
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
D | method_handler.h | 59 GPR_CODEGEN_ASSERT(!param.server_context->sent_initial_metadata_); in UnaryRunHandlerHelper() 64 ops.SendInitialMetadata(¶m.server_context->initial_metadata_, in UnaryRunHandlerHelper() 65 param.server_context->initial_metadata_flags()); in UnaryRunHandlerHelper() 66 if (param.server_context->compression_level_set()) { in UnaryRunHandlerHelper() 67 ops.set_compression_level(param.server_context->compression_level()); in UnaryRunHandlerHelper() 72 ops.ServerSendStatus(¶m.server_context->trailing_metadata_, status); in UnaryRunHandlerHelper() 113 static_cast<::grpc::ServerContext*>(param.server_context), in RunHandler() 152 param.call, static_cast<::grpc::ServerContext*>(param.server_context)); in RunHandler() 157 static_cast<::grpc::ServerContext*>(param.server_context), in RunHandler() 165 if (!param.server_context->sent_initial_metadata_) { in RunHandler() [all …]
|
D | server_callback_handlers.h | 55 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 57 param.server_context->BeginCompletionOp( in RunHandler() 64 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 268 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 273 param.server_context->BeginCompletionOp( in RunHandler() 283 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 454 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 460 param.server_context->BeginCompletionOp( in RunHandler() 470 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 675 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() [all …]
|
D | rpc_service_method.h | 56 server_context(context), in HandlerParameter() 63 ::grpc::ServerContextBase* const server_context;
|
D | client_context.h | 208 const grpc::ServerContext& server_context, 211 const grpc::CallbackServerContext& server_context, 492 const grpc::ServerContextBase& server_context,
|
D | server_interceptor.h | 79 ServerContextBase* server_context() { return ctx_; } in server_context() function
|
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
D | method_handler.h | 59 GPR_CODEGEN_ASSERT(!param.server_context->sent_initial_metadata_); in UnaryRunHandlerHelper() 64 ops.SendInitialMetadata(¶m.server_context->initial_metadata_, in UnaryRunHandlerHelper() 65 param.server_context->initial_metadata_flags()); in UnaryRunHandlerHelper() 66 if (param.server_context->compression_level_set()) { in UnaryRunHandlerHelper() 67 ops.set_compression_level(param.server_context->compression_level()); in UnaryRunHandlerHelper() 72 ops.ServerSendStatus(¶m.server_context->trailing_metadata_, status); in UnaryRunHandlerHelper() 113 static_cast<::grpc::ServerContext*>(param.server_context), in RunHandler() 152 param.call, static_cast<::grpc::ServerContext*>(param.server_context)); in RunHandler() 157 static_cast<::grpc::ServerContext*>(param.server_context), in RunHandler() 165 if (!param.server_context->sent_initial_metadata_) { in RunHandler() [all …]
|
D | server_callback_handlers.h | 55 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 57 param.server_context->BeginCompletionOp( in RunHandler() 64 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 268 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 273 param.server_context->BeginCompletionOp( in RunHandler() 283 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 454 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 460 param.server_context->BeginCompletionOp( in RunHandler() 470 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() 675 static_cast<::grpc::CallbackServerContext*>(param.server_context), in RunHandler() [all …]
|
D | rpc_service_method.h | 56 server_context(context), in HandlerParameter() 63 ::grpc::ServerContextBase* const server_context;
|
D | client_context.h | 208 const grpc::ServerContext& server_context, 211 const grpc::CallbackServerContext& server_context, 492 const grpc::ServerContextBase& server_context,
|
D | server_interceptor.h | 79 ServerContextBase* server_context() { return ctx_; } in server_context() function
|
/external/python/cpython3/Lib/test/ |
D | test_ssl.py | 320 server_context = ssl.SSLContext(ssl.PROTOCOL_TLS_SERVER) 321 server_context.load_cert_chain(server_cert) 322 server_context.load_verify_locations(SIGNING_CA) 324 return client_context, server_context, hostname 2686 def server_params_test(client_context, server_context, indata=b"FOO\n", argument 2694 server = ThreadedEchoServer(context=server_context, 2760 server_context = ssl.SSLContext(server_protocol) 2761 server_context.options |= server_options 2767 and hasattr(server_context, 'minimum_version') 2769 and server_context.minimum_version > min_version): [all …]
|
/external/rust/crates/grpcio-sys/grpc/src/cpp/client/ |
D | client_context.cc | 100 const grpc::ServerContext& server_context, PropagationOptions options) { in FromServerContext() argument 101 return FromInternalServerContext(server_context, options); in FromServerContext() 105 const grpc::CallbackServerContext& server_context, in FromCallbackServerContext() argument 107 return FromInternalServerContext(server_context, options); in FromCallbackServerContext()
|
/external/python/pyopenssl/tests/ |
D | test_ssl.py | 1025 server_context = Context(TLSv1_2_METHOD) 1026 server_context.set_keylog_callback(keylog) 1027 server_context.use_certificate( 1030 server_context.use_privatekey( 1036 self._handshake_test(server_context, client_context) 1866 server_context = Context(SSLv23_METHOD) 1867 server_context.set_alpn_select_callback(select) 1870 server_context.use_privatekey( 1873 server_context.use_certificate( 1878 server = Connection(server_context, None) [all …]
|
/external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
D | eager_service_impl.cc | 337 ServerContext* server_context = nullptr; in UpdateContext() local 338 TF_RETURN_IF_ERROR(GetServerContext(request->context_id(), &server_context)); in UpdateContext() 339 core::ScopedUnref context_unref(server_context); in UpdateContext() 341 tensorflow::EagerContext* ctx = server_context->Context(); in UpdateContext() 421 ServerContext* server_context = in CreateMasterContext() local 424 contexts_.emplace(context_id, server_context); in CreateMasterContext() 749 uint64 context_id, ServerContext** server_context) { in GetServerContext() argument 753 *server_context = nullptr; in GetServerContext() 760 *server_context = iter->second; in GetServerContext() 761 (*server_context)->Ref(); in GetServerContext() [all …]
|
/external/python/cpython2/Lib/test/ |
D | test_ssl.py | 1969 def server_params_test(client_context, server_context, indata=b"FOO\n", argument 1976 server = ThreadedEchoServer(context=server_context, 2039 server_context = ssl.SSLContext(server_protocol) 2040 server_context.options |= server_options 2048 for ctx in (client_context, server_context): 2053 stats = server_params_test(client_context, server_context, 2132 server_context = ssl.SSLContext(ssl.PROTOCOL_TLSv1) 2133 server_context.load_cert_chain(SIGNED_CERTFILE) 2142 server = ThreadedEchoServer(context=server_context, chatty=True) 2152 server = ThreadedEchoServer(context=server_context, chatty=True) [all …]
|
/external/python/cpython3/Lib/test/test_asyncio/ |
D | utils.py | 74 server_context = ssl.SSLContext(ssl.PROTOCOL_TLS_SERVER) 75 server_context.load_cert_chain(ONLYCERT, ONLYKEY) 76 server_context.check_hostname = False 77 server_context.verify_mode = ssl.CERT_NONE 78 return server_context
|
D | test_sslproto.py | 221 server_context = test_utils.simple_server_sslcontext() 230 sock.start_tls(server_context, server_side=True) 286 server_context = test_utils.simple_server_sslcontext() 292 sock.start_tls(server_context, server_side=True) 349 server_context = test_utils.simple_server_sslcontext() 359 sock.start_tls(server_context, server_side=True) 502 server_context = test_utils.simple_server_sslcontext() 553 tr, proto, server_context,
|
/external/grpc-grpc/test/cpp/end2end/ |
D | exception_test.cc | 42 Status Echo(ServerContext* server_context, const EchoRequest* request, in Echo() argument
|
D | channelz_service_test.cc | 65 Status Echo(ServerContext* server_context, const EchoRequest* request, in Echo() argument 68 ClientContext::FromServerContext(*server_context); in Echo()
|
/external/grpc-grpc/test/core/tsi/alts/fake_handshaker/ |
D | fake_handshaker_server.cc | 62 ServerContext* server_context, in DoHandshake() argument
|
/external/pigweed/pw_rpc/ |
D | BUILD | 56 "public/pw_rpc/server_context.h",
|
D | BUILD.gn | 53 "public/pw_rpc/server_context.h",
|