Home
last modified time | relevance | path

Searched refs:server_context (Results 1 – 25 of 40) sorted by relevance

12

/external/grpc-grpc/include/grpcpp/impl/codegen/
Dmethod_handler_impl.h68 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 …]
Drpc_service_method.h44 : call(c), server_context(context) { in HandlerParameter()
49 ServerContext* server_context; member
Dclient_context.h180 const ServerContext& server_context,
/external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/
Dmethod_handler.h59 GPR_CODEGEN_ASSERT(!param.server_context->sent_initial_metadata_); in UnaryRunHandlerHelper()
64 ops.SendInitialMetadata(&param.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(&param.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 …]
Dserver_callback_handlers.h55 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 …]
Drpc_service_method.h56 server_context(context), in HandlerParameter()
63 ::grpc::ServerContextBase* const server_context;
Dclient_context.h208 const grpc::ServerContext& server_context,
211 const grpc::CallbackServerContext& server_context,
492 const grpc::ServerContextBase& server_context,
Dserver_interceptor.h79 ServerContextBase* server_context() { return ctx_; } in server_context() function
/external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/
Dmethod_handler.h59 GPR_CODEGEN_ASSERT(!param.server_context->sent_initial_metadata_); in UnaryRunHandlerHelper()
64 ops.SendInitialMetadata(&param.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(&param.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 …]
Dserver_callback_handlers.h55 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 …]
Drpc_service_method.h56 server_context(context), in HandlerParameter()
63 ::grpc::ServerContextBase* const server_context;
Dclient_context.h208 const grpc::ServerContext& server_context,
211 const grpc::CallbackServerContext& server_context,
492 const grpc::ServerContextBase& server_context,
Dserver_interceptor.h79 ServerContextBase* server_context() { return ctx_; } in server_context() function
/external/python/cpython3/Lib/test/
Dtest_ssl.py320 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/
Dclient_context.cc100 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/
Dtest_ssl.py1025 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/
Deager_service_impl.cc337 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/
Dtest_ssl.py1969 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/
Dutils.py74 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
Dtest_sslproto.py221 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/
Dexception_test.cc42 Status Echo(ServerContext* server_context, const EchoRequest* request, in Echo() argument
Dchannelz_service_test.cc65 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/
Dfake_handshaker_server.cc62 ServerContext* server_context, in DoHandshake() argument
/external/pigweed/pw_rpc/
DBUILD56 "public/pw_rpc/server_context.h",
DBUILD.gn53 "public/pw_rpc/server_context.h",

12