Home
last modified time | relevance | path

Searched refs:shard (Results 1 – 25 of 292) sorted by relevance

12345678910>>...12

/external/grpc-grpc/src/core/lib/iomgr/
Dtimer_generic.cc250 static grpc_millis compute_min_deadline(timer_shard* shard) { in compute_min_deadline() argument
251 return grpc_timer_heap_is_empty(&shard->heap) in compute_min_deadline()
252 ? saturating_add(shard->queue_deadline_cap, 1) in compute_min_deadline()
253 : grpc_timer_heap_top(&shard->heap)->deadline; in compute_min_deadline()
276 timer_shard* shard = &g_shards[i]; in timer_list_init() local
277 gpr_mu_init(&shard->mu); in timer_list_init()
278 grpc_time_averaged_stats_init(&shard->stats, 1.0 / ADD_DEADLINE_SCALE, 0.1, in timer_list_init()
280 shard->queue_deadline_cap = g_shared_mutables.min_timer; in timer_list_init()
281 shard->shard_queue_index = i; in timer_list_init()
282 grpc_timer_heap_init(&shard->heap); in timer_list_init()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dtimer_generic.cc252 static grpc_millis compute_min_deadline(timer_shard* shard) { in compute_min_deadline() argument
253 return grpc_timer_heap_is_empty(&shard->heap) in compute_min_deadline()
254 ? saturating_add(shard->queue_deadline_cap, 1) in compute_min_deadline()
255 : grpc_timer_heap_top(&shard->heap)->deadline; in compute_min_deadline()
278 timer_shard* shard = &g_shards[i]; in timer_list_init() local
279 gpr_mu_init(&shard->mu); in timer_list_init()
280 grpc_time_averaged_stats_init(&shard->stats, 1.0 / ADD_DEADLINE_SCALE, 0.1, in timer_list_init()
282 shard->queue_deadline_cap = g_shared_mutables.min_timer; in timer_list_init()
283 shard->shard_queue_index = i; in timer_list_init()
284 grpc_timer_heap_init(&shard->heap); in timer_list_init()
[all …]
/external/grpc-grpc/src/core/lib/transport/
Dmetadata.cc58 #define REF_MD_LOCKED(shard, s) ref_md_locked((shard), (s), __FILE__, __LINE__) argument
62 #define REF_MD_LOCKED(shard, s) ref_md_locked((shard), (s)) argument
113 static void gc_mdtab(mdtab_shard* shard);
118 mdtab_shard* shard = &g_shards[i]; in grpc_mdctx_global_init() local
119 gpr_mu_init(&shard->mu); in grpc_mdctx_global_init()
120 shard->count = 0; in grpc_mdctx_global_init()
121 gpr_atm_no_barrier_store(&shard->free_estimate, 0); in grpc_mdctx_global_init()
122 shard->capacity = INITIAL_SHARD_CAPACITY; in grpc_mdctx_global_init()
123 shard->elems = static_cast<interned_metadata**>( in grpc_mdctx_global_init()
124 gpr_zalloc(sizeof(*shard->elems) * shard->capacity)); in grpc_mdctx_global_init()
[all …]
/external/grpc-grpc/src/core/lib/slice/
Dslice_intern.cc80 slice_shard* shard = &g_shards[SHARD_IDX(s->hash)]; in interned_slice_destroy() local
81 gpr_mu_lock(&shard->mu); in interned_slice_destroy()
85 for (prev_next = &shard->strs[TABLE_IDX(s->hash, shard->capacity)], in interned_slice_destroy()
90 shard->count--; in interned_slice_destroy()
92 gpr_mu_unlock(&shard->mu); in interned_slice_destroy()
129 static void grow_shard(slice_shard* shard) { in grow_shard() argument
132 size_t capacity = shard->capacity * 2; in grow_shard()
140 for (i = 0; i < shard->capacity; i++) { in grow_shard()
141 for (s = shard->strs[i]; s; s = next) { in grow_shard()
148 gpr_free(shard->strs); in grow_shard()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/slice/
Dslice_intern.cc71 slice_shard* shard = &g_shards[SHARD_IDX(this->hash)]; in ~InternedSliceRefcount() local
72 MutexLock lock(&shard->mu); in ~InternedSliceRefcount()
75 for (prev_next = &shard->strs[TABLE_IDX(this->hash, shard->capacity)], in ~InternedSliceRefcount()
80 shard->count--; in ~InternedSliceRefcount()
85 static void grow_shard(slice_shard* shard) { in grow_shard() argument
88 size_t capacity = shard->capacity * 2; in grow_shard()
96 for (i = 0; i < shard->capacity; i++) { in grow_shard()
97 for (s = shard->strs[i]; s; s = next) { in grow_shard()
104 gpr_free(shard->strs); in grow_shard()
105 shard->strs = strtab; in grow_shard()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dmetadata.cc232 static void gc_mdtab(mdtab_shard* shard);
237 mdtab_shard* shard = &g_shards[i]; in grpc_mdctx_global_init() local
238 gpr_mu_init(&shard->mu); in grpc_mdctx_global_init()
239 shard->count = 0; in grpc_mdctx_global_init()
240 gpr_atm_no_barrier_store(&shard->free_estimate, 0); in grpc_mdctx_global_init()
241 shard->capacity = INITIAL_SHARD_CAPACITY; in grpc_mdctx_global_init()
242 shard->elems = static_cast<InternedMetadata::BucketLink*>( in grpc_mdctx_global_init()
243 gpr_zalloc(sizeof(*shard->elems) * shard->capacity)); in grpc_mdctx_global_init()
249 mdtab_shard* shard = &g_shards[i]; in grpc_mdctx_global_shutdown() local
250 gpr_mu_destroy(&shard->mu); in grpc_mdctx_global_shutdown()
[all …]
/external/tensorflow/tensorflow/python/data/kernel_tests/
Dshard_test.py31 dataset = dataset_ops.Dataset.range(10).shard(5, 2)
38 dataset = dataset_ops.Dataset.zip((dataset_a, dataset_b)).shard(5, 2)
43 dataset = dataset_ops.Dataset.range(10).shard(5, 0)
49 dataset = dataset_ops.Dataset.range(10).shard(5, 7)
55 dataset = dataset_ops.Dataset.range(10).shard(5, -3)
61 dataset = dataset_ops.Dataset.range(10).shard(-3, 1)
67 dataset = dataset_ops.Dataset.range(10).shard(0, 1)
72 dataset = dataset_ops.Dataset.range(1).shard(5, 2)
77 dataset = dataset_ops.Dataset.range(10).shard(7, 5)
82 dataset = dataset_ops.Dataset.range(10).shard(5, 4)
[all …]
/external/autotest/client/site_tests/graphics_parallel_dEQP/
Dgenerate_controlfiles.py108 def get_controlfilename(test, shard=0): argument
109 return 'control.%s' % get_name(test, shard)
124 def get_name(test, shard): argument
127 name = '%s.%d' % (name, shard)
131 def get_testname(test, shard=0): argument
132 return 'graphics_parallel_dEQP.%s' % get_name(test, shard)
145 for shard in range(0, test.shards):
146 testname = get_testname(test, shard)
147 filename = get_controlfilename(test, shard)
153 shard=shard,
/external/cronet/build/config/fuchsia/test/
DREADME.md4 Fuchsia tests hermetically. Tests start from `minimum.shard.test-cml` and add
11 #### archivist.shard.test-cml
15 #### chromium_test_facet.shard.test-cml
22 #### fonts.shard.test-cml
23 For tests that test fonts by providing `fuchsia.fonts.Provider`. This shard
26 #### test_fonts.shard.test-cml
30 #### mark_vmo_executable.shard.test-cml
34 #### minimum.shard.test-cml
43 #### logger.shard.test-cml
46 #### sysmem.shard.test-cml
[all …]
Dweb_instance.shard.test-cml6 "//build/config/fuchsia/test/audio_output.shard.test-cml",
7 "//build/config/fuchsia/test/fonts.shard.test-cml",
8 "//build/config/fuchsia/test/mark_vmo_executable.shard.test-cml",
9 "//build/config/fuchsia/test/network.shard.test-cml",
10 "//build/config/fuchsia/test/platform_video_codecs.shard.test-cml",
11 "//build/config/fuchsia/test/test_ui_stack.shard.test-cml",
12 "vulkan/client.shard.cml",
/external/angle/build/config/fuchsia/test/
DREADME.md4 Fuchsia tests hermetically. Tests start from `minimum.shard.test-cml` and add
11 #### archivist.shard.test-cml
15 #### chromium_test_facet.shard.test-cml
22 #### fonts.shard.test-cml
24 This shard runs an isolated font provider with fonts bundled into the fonts
27 #### test_fonts.shard.test-cml
29 (beyond that provided by `fonts.shard.test-cml`). This shard requires fonts to
36 The user of this shard must provide a directory `/pkg/test_fonts`, which must
42 #### mark_vmo_executable.shard.test-cml
46 #### minimum.shard.test-cml
[all …]
Dweb_instance.shard.test-cml6 "//build/config/fuchsia/test/audio_output.shard.test-cml",
7 "//build/config/fuchsia/test/fonts.shard.test-cml",
8 "//build/config/fuchsia/test/mark_vmo_executable.shard.test-cml",
9 "//build/config/fuchsia/test/network.shard.test-cml",
10 "//build/config/fuchsia/test/platform_video_codecs.shard.test-cml",
11 "//build/config/fuchsia/test/test_ui_stack.shard.test-cml",
12 "vulkan/client.shard.cml",
/external/autotest/frontend/afe/
Dshard_heartbeat_unittest.py29 shard = self._create_shard(label)
34 assigned = models.Job.assign_to_shard(shard, [])
40 shard = self._create_shard(label)
45 assigned = models.Job.assign_to_shard(shard, [])
51 shard = self._create_shard(label)
54 assigned_jobs = models.Job.assign_to_shard(shard, [known_job.id])
61 shard = self._create_shard(label)
65 assigned = models.Job.assign_to_shard(shard, [])
72 shard = self._create_shard(label)
75 assigned = models.Job.assign_to_shard(shard, [])
[all …]
Drpc_interface.py433 if host.shard:
434 affected_shard_hostnames.add(host.shard.hostname)
1132 hosts = [h for h in hosts if h.shard is None]
1133 for shard, hostnames in shard_host_map.iteritems():
1145 rpc, [shard], **shard_filter)
1461 if not host.shard:
1468 shard_afe = frontend.AFE(server=host.shard.hostname)
1500 if not host_model.shard:
1503 shard_afe = frontend.AFE(server=host_model.shard.hostname)
1550 if not host.shard:
[all …]
Drpc_interface_unittest.py120 self.assertEqual(host2.shard, None)
134 self.assertEqual(host2.shard, None)
213 job2.shard = None
233 self.assertIsNone(job1.shard)
416 host2.shard = shard1
432 host2.shard = shard1
539 shard = models.Shard.objects.create(hostname='test_shard')
540 shard.labels.add(label)
544 shard=shard)
548 rpc_interface.remove_board_from_shard(shard.hostname, label.name)
[all …]
/external/libtextclassifier/native/utils/grammar/utils/
Dir.h144 bool case_sensitive = false, int shard = 0);
146 bool case_sensitive = false, int shard = 0) {
147 return Add(Lhs{lhs}, terminal, case_sensitive, shard);
151 Nonterm Add(const Lhs& lhs, Nonterm rhs, int shard = 0) {
152 return AddRule(lhs, rhs, &shards_[shard].unary_rules);
154 Nonterm Add(Nonterm lhs, Nonterm rhs, int shard = 0) {
155 return Add(Lhs{lhs}, rhs, shard);
159 Nonterm Add(const Lhs& lhs, Nonterm rhs_1, Nonterm rhs_2, int shard = 0) {
160 return AddRule(lhs, {rhs_1, rhs_2}, &shards_[shard].binary_rules);
162 Nonterm Add(Nonterm lhs, Nonterm rhs_1, Nonterm rhs_2, int shard = 0) {
[all …]
Drules.cc98 rule.rhs.front().terminal, rule.case_sensitive, rule.shard); in LowerRule()
108 rule.shard)); in LowerRule()
120 rhs_nonterms, rule.shard); in LowerRule()
208 const int8 max_whitespace_gap, const bool case_sensitive, const int shard, in ExpandOptionals() argument
224 r.shard = shard; in ExpandOptionals()
236 case_sensitive, shard, optional_element_indices, in ExpandOptionals()
242 case_sensitive, shard, optional_element_indices, in ExpandOptionals()
267 const std::vector<RhsElement>& rhs, int shard) { in ResolveFillers() argument
291 /*case_sensitive=*/false, shard); in ResolveFillers()
298 /*case_sensitive=*/false, shard); in ResolveFillers()
[all …]
Drules.h92 int shard = 0; member
119 bool case_sensitive = false, int shard = 0);
126 int shard = 0);
135 bool case_sensitive = false, int shard = 0);
140 bool case_sensitive = false, int shard = 0);
146 bool case_sensitive = false, int shard = 0);
149 bool case_sensitive = false, int shard = 0);
186 int shard, std::vector<int>::const_iterator optional_element_indices,
192 int shard = 0);
211 int shard = 0);
/external/bazelbuild-rules_android/src/common/golang/
Dshard_test.go15 package shard package
50 if shard := FNV(in, test.sc); shard != test.want[idx] {
51 t.Errorf("FNV applied for: %q got: %v wanted: %v", in, shard, test.want[idx])
92 if shard := shardFn(in, test.sc); shard != test.want[idx] {
93 t.Errorf("MakeSepFunc applied for: %q got: %v wanted: %v", in, shard, test.want[idx])
/external/tensorflow/tensorflow/core/kernels/
Drecord_yielder.cc136 Shard* shard = &shards[i]; in MainLoop() local
137 shard->index = i; in MainLoop()
139 shard->filenames.push_back(filenames[j]); in MainLoop()
141 thread_->Schedule([this, shard]() { ShardLoop(shard); }); in MainLoop()
198 void RecordYielder::ShardLoop(Shard* shard) { in ShardLoop() argument
201 for (const string& filename : shard->filenames) { in ShardLoop()
206 shard->status = errors::InvalidArgument("Can't open ", filename); in ShardLoop()
220 shard->status = errors::Aborted("stopped"); in ShardLoop()
226 shard->status = s; in ShardLoop()
235 shard->done.Notify(); in ShardLoop()
/external/compiler-rt/lib/sanitizer_common/tests/
Dsanitizer_thread_registry_test.cc163 uptr shard; // started from 1. member
170 uptr shard = (uptr)arg; in OnJoined() local
171 num_joined[shard]++; in OnJoined()
174 uptr shard = (uptr)arg; in OnStarted() local
175 num_started[shard]++; in OnStarted()
178 uptr shard = (uptr)arg; in OnCreated() local
179 num_created[shard]++; in OnCreated()
190 args->registry->CreateThread(0, false, 0, (void*)args->shard)); in RunThread()
192 args->registry->StartThread(tids[i], 0, (void*)args->shard); in RunThread()
196 args->registry->JoinThread(tids[i], (void*)args->shard); in RunThread()
[all …]
/external/perfetto/src/cloud_trace_processor/
Dworker_impl.cc63 TracePoolShard* shard = shards_.Find(args.pool_id()); in TracePoolShardSetTraces() local
64 if (!shard) { in TracePoolShardSetTraces()
85 shard->tps.emplace_back(std::move(tp)); in TracePoolShardSetTraces()
94 TracePoolShard* shard = shards_.Find(args.pool_id()); in TracePoolShardQuery() local
95 if (!shard) { in TracePoolShardQuery()
100 streams.reserve(shard->tps.size()); in TracePoolShardQuery()
101 for (std::unique_ptr<TraceProcessorWrapper>& tp : shard->tps) { in TracePoolShardQuery()
/external/bazelbuild-rules_android/src/tools/ak/bucketize/
Dpartitioner.go83 sharder shard.Func
99 func makePartitionSession(outputs map[res.Type][]io.Writer, sharder shard.Func, resourceOrder map[s…
232 shard := ps.sharder(fqn.String(), len(archs))
233 if shard > len(archs) || 0 > shard {
234 …f("%v: bad sharder f(%v, %d) -> %d must be [0,%d)", ps.sharder, fqn, len(archs), shard, len(archs))
236 return archs[shard], nil
286 shard := ps.sharder(fqn, len(ws))
287 if shard < 0 || shard >= len(ws) {
288 ….Errorf("%v: bad sharder f(%s, %d) -> %d must be [0,%d)", ps.sharder, fqn, len(ws), shard, len(ws))
290 if _, err := ws[shard].Write(p); err != nil {
Dpartitioner_test.go40 shardFn shard.Func
56 shardFn: shard.Func(func(fqn string, shardCount int) int {
60 shard, err := strconv.Atoi(ai)
64 return shard
82 shardFn: shard.FNV,
89 shardFn: shard.FNV,
126 for _, shard := range shards {
127 br := bytes.NewReader(shard.(*bytes.Buffer).Bytes())
279 t.Errorf("makePartitionSession(%v, %v, %d) got err: %v", tc.partitions, shard.FNV, 0, err)
311 for _, shard := range shards {
[all …]
/external/tensorflow/tensorflow/core/util/
Dtensor_slice_reader.cc130 for (size_t shard = 0; shard < fnames_.size(); ++shard) { in TensorSliceReader() local
131 fname_to_index_.insert(std::make_pair(fnames_[shard], shard)); in TensorSliceReader()
142 void TensorSliceReader::LoadShard(int shard) const { in LoadShard()
143 CHECK_LT(shard, sss_.size()); in LoadShard()
144 if (sss_[shard] || !status_.ok()) { in LoadShard()
149 const string fname = fnames_[shard]; in LoadShard()
158 sss_[shard].reset(table); in LoadShard()

12345678910>>...12