/external/autotest/cli/ |
D | host_unittest.py | 124 rpcs=[('get_hosts', {}, 154 rpcs=[('get_hosts', {}, 185 rpcs=[('get_hosts', {'hostname__in': ['host1']}, 209 rpcs=[('get_hosts', {'hostname__in': ['host2', 'host1']}, 245 rpcs=[('get_hosts', {'hostname__in': ['host2', 'host1']}, 269 rpcs=[('get_hosts', {'hostname__in': ['host2', 'host1']}, 280 rpcs=[('get_hosts', {'labels__name__in': ['label3']}, 313 rpcs=[('get_hosts', {'multiple_labels': ['label2', 346 rpcs=[('get_hosts', {'multiple_labels': ['label2', 368 rpcs=[('get_hosts', [all …]
|
D | acl_unittest.py | 82 rpcs=[('get_acl_groups', {}, True, 93 rpcs=[('get_acl_groups', {'name__in': ['acl0']}, True, 104 rpcs=[('get_acl_groups', {'users__login': 'user0'}, True, 115 rpcs=[('get_acl_groups', {'hosts__hostname': 'host0'}, 128 rpcs=[('get_acl_groups', {'hosts__hostname': 'host0'}, 182 rpcs=[('add_acl_group', 193 rpcs=[('add_acl_group', 208 rpcs=[('delete_acl_group', {'id': 'acl0'}, True, None)], 215 rpcs=[('delete_acl_group', {'id': 'acl0'}, 227 rpcs=[('delete_acl_group', [all …]
|
D | label_unittest.py | 49 rpcs=[('get_labels', {}, True, self.values)], 56 rpcs=[('get_labels', {}, True, self.values)], 63 rpcs=[('get_labels', {}, True, self.values)], 70 rpcs=[('get_labels', {}, True, self.values)], 78 rpcs=[('get_labels', {}, True, self.values)], 87 rpcs=[('add_label', 100 rpcs=[('add_label', 119 rpcs=[('delete_label', {'id': 'label0'}, True, None), 128 rpcs=[('label_add_hosts', {'id': 'label0', 138 rpcs=[('label_remove_hosts', {'id': 'label0',
|
D | shard_unittest.py | 22 rpcs=[('get_shards', {}, True, self.values)], 31 rpcs=[('add_shard', 40 rpcs=[('add_shard', 53 rpcs=[('add_board_to_shard', 62 rpcs=[('add_board_to_shard', 74 rpcs=[('add_board_to_shard', 88 rpcs=[('delete_shard', {'hostname': 'shard0'}, True, None),
|
D | test_unittest.py | 56 rpcs=[('get_tests', {'experimental': False}, 65 rpcs=[('get_tests', {}, 74 rpcs=[('get_tests', {'experimental': True}, 90 rpcs=[('get_tests', {'name__in': ['test3'], 102 rpcs=[('get_tests', {'name__in': ['test1', 'test3'], 114 rpcs=[('get_tests', {'name__in': ['test1', 'test3'], 124 rpcs=[('get_tests', {'experimental': False}, 134 rpcs=[('get_tests', {'experimental': False}, 143 rpcs=[('get_tests', {'experimental': False},
|
D | job_unittest.py | 113 rpcs=[('get_jobs_summary', {'owner': 'user0', 123 rpcs=[('get_jobs_summary', {'owner': 'Cringer', 133 rpcs=[('get_jobs_summary', {'running': None}, 142 rpcs=[('get_jobs_summary', {'id__in': ['5964'], 162 rpcs=[('get_jobs_summary', {'id__in': ['5964'], 183 rpcs=[('get_jobs_summary', {'name__startswith': 'myt', 203 rpcs=[('get_jobs_summary', {'running': None}, 225 rpcs=[('get_jobs_summary', {'id__in': ['180']}, True, 257 rpcs=[('get_jobs_summary', {'id__in': ['6761']}, True, 296 rpcs=[('get_jobs_summary', {'id__in': ['6761']}, True, [all …]
|
D | user_unittest.py | 65 rpcs=[('get_users', {}, 82 rpcs=[('get_users', {'login__in': ['user0']}, 93 rpcs=[('get_users', {'aclgroup__name__in': ['acl0']}, 104 rpcs=[('get_users', {'access_level__in': ['2']}, 115 rpcs=[('get_users', {}, 133 rpcs=[('get_users', {'login__in': ['user0', 'user1']}, 147 rpcs=[('get_users', {'aclgroup__name__in': ['acl0']}, 158 rpcs=[('get_users', {'access_level__in': ['2']},
|
D | cli_mock.py | 133 def mock_rpcs(self, rpcs): argument 139 for (op, dargs, success, expected) in rpcs: 148 def run_cmd(self, argv, rpcs=[], exit_code=None, argument 170 self.mock_rpcs(rpcs)
|
/external/grpc-grpc/src/python/grpcio_tests/tests/testing/ |
D | _client_test.py | 136 rpcs = [] 141 rpcs.append(rpc) 143 for rpc in rpcs: 145 for rpc in rpcs: 148 for rpc in rpcs: 150 for rpc in rpcs: 153 for rpc in rpcs: 155 for rpc in rpcs: 187 rpcs = tuple( 191 for rpc in rpcs: [all …]
|
/external/grpc-grpc/src/cpp/server/load_reporter/ |
D | load_reporter.h | 173 uint64_t rpcs; member 179 const std::chrono::system_clock::time_point& end_time, uint64_t rpcs, in LoadBalancingFeedbackRecord() 182 rpcs(rpcs), in LoadBalancingFeedbackRecord() 206 void AppendNewFeedbackRecord(uint64_t rpcs, uint64_t errors);
|
D | load_reporter.cc | 268 uint64_t rpcs = 0; in GenerateLoadBalancingFeedback() local 273 rpcs += p->rpcs; in GenerateLoadBalancingFeedback() 284 static_cast<float>(rpcs / duration_seconds.count())); in GenerateLoadBalancingFeedback() 366 void LoadReporter::AppendNewFeedbackRecord(uint64_t rpcs, uint64_t errors) { in AppendNewFeedbackRecord() argument 375 feedback_records_.emplace_back(std::chrono::system_clock::now(), rpcs, errors, in AppendNewFeedbackRecord()
|
/external/sl4a/Docs/ |
D | generate_api_from_javadoc.py | 85 self.rpcs = list() 130 for rpc in facade.rpcs: 145 facade.rpcs.append(rpc_function) 146 facade.rpcs.sort(key=lambda rpc: rpc.name)
|
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
D | NettyClientTransportTest.java | 239 final List<Rpc> rpcs = new ArrayList<>(transports.size()); in creatingMultipleTlsTransportsShouldSucceed() local 241 rpcs.add(new Rpc(transport).halfClose()); in creatingMultipleTlsTransportsShouldSucceed() 245 for (Rpc rpc : rpcs) { in creatingMultipleTlsTransportsShouldSucceed() 376 Rpc[] rpcs = new Rpc[] { new Rpc(transport), new Rpc(transport), new Rpc(transport) }; in bufferedStreamsShouldBeClosedWhenConnectionTerminates() local 379 rpcs[0].waitForResponse(); in bufferedStreamsShouldBeClosedWhenConnectionTerminates() 385 for (int i = 1; i < rpcs.length; i++) { in bufferedStreamsShouldBeClosedWhenConnectionTerminates() 387 rpcs[i].waitForClose(); in bufferedStreamsShouldBeClosedWhenConnectionTerminates()
|
/external/grpc-grpc/src/ruby/end2end/ |
D | README.md | 9 well as an address to listen on for control rpcs. Depending on the test, the
|
/external/grpc-grpc/doc/ |
D | health-checking.md | 4 Health checks are used to probe whether the server is able to handle rpcs. The
|
D | connection-backoff-interop-test-description.md | 74 * The port to listen on for control rpcs. For example, "8080"
|
D | unit_testing.md | 38 …ctations on the pure-virtual methods we can test client-side logic without having to make any rpcs.
|
/external/grpc-grpc/examples/cpp/helloworld/ |
D | README.md | 251 To handle multiple rpcs, the async server creates an object `CallData` to
|