Home
last modified time | relevance | path

Searched refs:rpc_name (Results 1 – 25 of 116) sorted by relevance

12345

/dports/devel/grpc/grpc-1.42.0/src/ruby/pb/test/
H A Dxds_client.rb162 watcher['rpcs_by_method'].each do |rpc_name, rpcs_by_peer|
266 rpc_name, remote_peer = r
267 results[rpc_name] = remote_peer
275 results.each do |rpc_name, remote_peer|
278 rpc_name = $RPC_MAP.invert()[rpc_name]
283 if not watcher['rpcs_by_method'].key?(rpc_name)
284 watcher['rpcs_by_method'][rpc_name] = Hash.new(0)
382 (rpc_name, metadata_key, metadata_value) = e.split(':')
383 rpc_name = $RPC_MAP[rpc_name]
385 if !metadata_to_send.key?(rpc_name)
[all …]
/dports/devel/grpc134/grpc-1.34.1/src/ruby/pb/test/
H A Dxds_client.rb101 watcher['rpcs_by_method'].each do |rpc_name, rpcs_by_peer|
102 rpcs_by_method[rpc_name] = LoadBalancerStatsResponse::RpcsByPeer.new(
176 results.each do |rpc_name, remote_peer|
181 if not watcher['rpcs_by_method'].key?(rpc_name)
182 watcher['rpcs_by_method'][rpc_name] = Hash.new(0)
186 watcher['rpcs_by_method'][rpc_name][remote_peer] += 1
273 (rpc_name, metadata_key, metadata_value) = e.split(':')
275 if !metadata_to_send.key?(rpc_name)
276 metadata_to_send[rpc_name] = {}
278 metadata_to_send[rpc_name][metadata_key] = metadata_value
/dports/www/firefox/firefox-99.0/third_party/rust/audioipc2-server/src/
H A Dlib.rs76 let rpc_name = "AudioIPC Server RPC"; in init_threads() localVariable
78 rpc_name.to_string(), in init_threads()
81 trace!("Starting {} thread", rpc_name); in init_threads()
87 trace!("Stopping {} thread", rpc_name); in init_threads()
91 debug!("Failed to start {} thread: {:?}", rpc_name, e); in init_threads()
/dports/devel/grpc/grpc-1.42.0/src/php/tests/interop/
H A Dxds_client.php179 foreach ($accumulated_method_stats as $rpc_name => $stats) {
184 $stats_per_method[$rpc_name] = $methodStats;
316 $rpc_name = $parts2[1];
324 $this->results[$rpc_name][$result_num] = "";
327 [$this->RPC_MAP[$rpc_name]] += 1;
330 [$this->RPC_MAP[$rpc_name]] += 1;
332 $this->add_rpc_result($rpc_name, $returncode);
/dports/devel/grpc130/grpc-1.30.2/src/python/grpcio_testing/grpc_testing/
H A D_common.py43 rpc_name = '/{}/{}'.format(service_descriptor.full_name,
45 rpc_names_to_descriptors[rpc_name] = method_descriptor
/dports/devel/grpc134/grpc-1.34.1/src/python/grpcio_testing/grpc_testing/
H A D_common.py43 rpc_name = '/{}/{}'.format(service_descriptor.full_name,
45 rpc_names_to_descriptors[rpc_name] = method_descriptor
/dports/devel/grpc/grpc-1.42.0/src/python/grpcio_testing/grpc_testing/
H A D_common.py43 rpc_name = '/{}/{}'.format(service_descriptor.full_name,
45 rpc_names_to_descriptors[rpc_name] = method_descriptor
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/python/grpcio_testing/grpc_testing/
H A D_common.py43 rpc_name = '/{}/{}'.format(service_descriptor.full_name,
45 rpc_names_to_descriptors[rpc_name] = method_descriptor
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/lib/gitlab/gitaly_client/
H A Drepository_service.rb367 def gitaly_fetch_stream_to_file(save_path, rpc_name, request_class, timeout) argument
372 rpc_name,
389 def gitaly_repo_stream_request(file_path, rpc_name, request_class, timeout) argument
405 rpc_name,
/dports/lang/rust/rustc-1.58.1-src/vendor/jsonrpc-derive/src/
H A Dto_client.rs101 let rpc_name = method.name(); in generate_client_methods() localVariable
137 self.inner.call_method(#rpc_name, #returns_str, args) in generate_client_methods()
169 let rpc_name = method.name(); in generate_client_methods() localVariable
177 self.inner.notify(#rpc_name, args_tuple) in generate_client_methods()
/dports/devel/google-cloud-cpp/google-cloud-cpp-1.21.0/google/cloud/spanner/internal/
H A Dmetadata_spanner_stub_test.cc63 std::string const& rpc_name, in ExpectSession() argument
66 [this, rpc_name](grpc::ClientContext& context, Request const&) { in ExpectSession()
68 IsContextMDValid(context, "google.spanner.v1.Spanner." + rpc_name, in ExpectSession()
/dports/devel/google-cloud-cpp117/google-cloud-cpp-1.17.0/google/cloud/spanner/internal/
H A Dmetadata_spanner_stub_test.cc63 std::string const& rpc_name, in ExpectSession() argument
66 [this, rpc_name](grpc::ClientContext& context, Request const&) { in ExpectSession()
68 IsContextMDValid(context, "google.spanner.v1.Spanner." + rpc_name, in ExpectSession()
/dports/security/softether-devel/v4.36-9754/src/Cedar/
H A DEtherLog.c111 #define DECLARE_RPC_EX(rpc_name, data_type, function, in_rpc, out_rpc, free_rpc) \ argument
112 else if (StrCmpi(name, rpc_name) == 0) \
125 #define DECLARE_RPC(rpc_name, data_type, function, in_rpc, out_rpc) \ argument
126 else if (StrCmpi(name, rpc_name) == 0) \
138 #define DECLARE_SC_EX(rpc_name, data_type, function, in_rpc, out_rpc, free_rpc) \ argument
151 ret = AdminCall(r, rpc_name, p); \
160 #define DECLARE_SC(rpc_name, data_type, function, in_rpc, out_rpc) \ argument
171 ret = AdminCall(r, rpc_name, p); \
/dports/security/softether/v4.38-9760/src/Cedar/
H A DEtherLog.c111 #define DECLARE_RPC_EX(rpc_name, data_type, function, in_rpc, out_rpc, free_rpc) \ argument
112 else if (StrCmpi(name, rpc_name) == 0) \
125 #define DECLARE_RPC(rpc_name, data_type, function, in_rpc, out_rpc) \ argument
126 else if (StrCmpi(name, rpc_name) == 0) \
138 #define DECLARE_SC_EX(rpc_name, data_type, function, in_rpc, out_rpc, free_rpc) \ argument
151 ret = AdminCall(r, rpc_name, p); \
160 #define DECLARE_SC(rpc_name, data_type, function, in_rpc, out_rpc) \ argument
171 ret = AdminCall(r, rpc_name, p); \
/dports/security/softether5/SoftEtherVPN-5.02.5180/src/Cedar/
H A DEtherLog.c31 #define DECLARE_RPC_EX(rpc_name, data_type, function, in_rpc, out_rpc, free_rpc) \ argument
32 else if (StrCmpi(name, rpc_name) == 0) \
45 #define DECLARE_RPC(rpc_name, data_type, function, in_rpc, out_rpc) \ argument
46 else if (StrCmpi(name, rpc_name) == 0) \
58 #define DECLARE_SC_EX(rpc_name, data_type, function, in_rpc, out_rpc, free_rpc) \ argument
71 ret = AdminCall(r, rpc_name, p); \
80 #define DECLARE_SC(rpc_name, data_type, function, in_rpc, out_rpc) \ argument
91 ret = AdminCall(r, rpc_name, p); \
/dports/devel/grpc130/grpc-1.30.2/src/ruby/lib/grpc/generic/
H A Drpc_server.rb541 rpc_name = GenericService.underscore(name.to_s).to_sym
543 handlers[route] = cls.new.method(rpc_name)
545 handlers[route] = service.method(rpc_name)
/dports/devel/grpc134/grpc-1.34.1/src/ruby/lib/grpc/generic/
H A Drpc_server.rb541 rpc_name = GenericService.underscore(name.to_s).to_sym
543 handlers[route] = cls.new.method(rpc_name)
545 handlers[route] = service.method(rpc_name)
/dports/devel/grpc/grpc-1.42.0/src/ruby/lib/grpc/generic/
H A Drpc_server.rb541 rpc_name = GenericService.underscore(name.to_s).to_sym
543 handlers[route] = cls.new.method(rpc_name)
545 handlers[route] = service.method(rpc_name)
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/ruby/lib/grpc/generic/
H A Drpc_server.rb542 rpc_name = GenericService.underscore(name.to_s).to_sym
544 handlers[route] = cls.new.method(rpc_name)
546 handlers[route] = service.method(rpc_name)
/dports/editors/helix/helix-0.5.0/helix-syntax/languages/tree-sitter-protobuf/queries/
H A Dhighlights.scm23 (rpc_name)
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/dbapi/driver/
H A Dinterfaces.hpp1205 virtual CDB_RPCCmd* RPC(const string& rpc_name) = 0;
1409 CDB_RPCCmd* RPC(const string& rpc_name, unsigned int /*unused*/) in RPC() argument
1411 return RPC(rpc_name); in RPC()
H A Dpublic.hpp94 virtual CDB_RPCCmd* RPC(const string& rpc_name);
359 CDB_RPCCmd* RPC(const string& rpc_name, unsigned int /*unused*/) in RPC() argument
361 return RPC(rpc_name); in RPC()
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/include/dbapi/driver/
H A Dinterfaces.hpp1205 virtual CDB_RPCCmd* RPC(const string& rpc_name) = 0;
1409 CDB_RPCCmd* RPC(const string& rpc_name, unsigned int /*unused*/) in RPC() argument
1411 return RPC(rpc_name); in RPC()
H A Dpublic.hpp94 virtual CDB_RPCCmd* RPC(const string& rpc_name);
359 CDB_RPCCmd* RPC(const string& rpc_name, unsigned int /*unused*/) in RPC() argument
361 return RPC(rpc_name); in RPC()
/dports/finance/py-python-bitcoinlib/python-bitcoinlib-0.11.0/bitcoin/tests/
H A Dfakebitcoinproxy.py110 def make_rpc_batch_request_entry(rpc_name, params): argument
118 "method": rpc_name,

12345