/dports/devel/grpc/grpc-1.42.0/src/ruby/pb/test/ |
H A D | xds_client.rb | 162 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 D | xds_client.rb | 101 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 D | lib.rs | 76 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 D | xds_client.php | 179 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.py | 43 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.py | 43 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.py | 43 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.py | 43 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 D | repository_service.rb | 367 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 D | to_client.rs | 101 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 D | metadata_spanner_stub_test.cc | 63 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 D | metadata_spanner_stub_test.cc | 63 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 D | EtherLog.c | 111 #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 D | EtherLog.c | 111 #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 D | EtherLog.c | 31 #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 D | rpc_server.rb | 541 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 D | rpc_server.rb | 541 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 D | rpc_server.rb | 541 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 D | rpc_server.rb | 542 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 D | highlights.scm | 23 (rpc_name)
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/include/dbapi/driver/ |
H A D | interfaces.hpp | 1205 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 D | public.hpp | 94 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 D | interfaces.hpp | 1205 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 D | public.hpp | 94 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 D | fakebitcoinproxy.py | 110 def make_rpc_batch_request_entry(rpc_name, params): argument 118 "method": rpc_name,
|