Home
last modified time | relevance | path

Searched defs:shard (Results 1 – 25 of 60) sorted by relevance

123

/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
118 mdtab_shard* shard = &g_shards[i]; in grpc_mdctx_global_init() local
130 mdtab_shard* shard = &g_shards[i]; in grpc_mdctx_global_shutdown() local
151 static void ref_md_locked(mdtab_shard* shard, in ref_md_locked()
170 static void gc_mdtab(mdtab_shard* shard) { in gc_mdtab()
202 static void grow_mdtab(mdtab_shard* shard) { in grow_mdtab()
230 static void rehash_mdtab(mdtab_shard* shard) { in rehash_mdtab()
279 mdtab_shard* shard = &g_shards[SHARD_IDX(hash)]; in grpc_mdelem_create() local
426 mdtab_shard* shard = &g_shards[SHARD_IDX(hash)]; in grpc_mdelem_unref() local
/external/grpc-grpc/src/core/lib/iomgr/
Dtimer_generic.cc250 static grpc_millis compute_min_deadline(timer_shard* shard) { in compute_min_deadline()
276 timer_shard* shard = &g_shards[i]; in timer_list_init() local
297 timer_shard* shard = &g_shards[i]; in timer_list_shutdown() local
338 static void note_deadline_change(timer_shard* shard) { in note_deadline_change()
356 timer_shard* shard = &g_shards[GPR_HASH_POINTER(timer, g_num_shards)]; in timer_init() local
464 timer_shard* shard = &g_shards[GPR_HASH_POINTER(timer, g_num_shards)]; in timer_cancel() local
492 static int refill_heap(timer_shard* shard, grpc_millis now) { in refill_heap()
529 static grpc_timer* pop_one(timer_shard* shard, grpc_millis now) { in pop_one()
560 static size_t pop_timers(timer_shard* shard, grpc_millis now, in pop_timers()
/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()
278 timer_shard* shard = &g_shards[i]; in timer_list_init() local
299 timer_shard* shard = &g_shards[i]; in timer_list_shutdown() local
340 static void note_deadline_change(timer_shard* shard) { in note_deadline_change()
358 timer_shard* shard = &g_shards[GPR_HASH_POINTER(timer, g_num_shards)]; in timer_init() local
467 timer_shard* shard = &g_shards[GPR_HASH_POINTER(timer, g_num_shards)]; in timer_cancel() local
496 static bool refill_heap(timer_shard* shard, grpc_millis now) { in refill_heap()
533 static grpc_timer* pop_one(timer_shard* shard, grpc_millis now) { in pop_one()
563 static size_t pop_timers(timer_shard* shard, grpc_millis now, in pop_timers()
/external/libtextclassifier/native/utils/grammar/utils/
Drules.cc208 const int8 max_whitespace_gap, const bool case_sensitive, const int shard, in ExpandOptionals()
267 const std::vector<RhsElement>& rhs, int shard) { in ResolveFillers()
315 const std::vector<RhsElement>& rhs, int shard) { in OptimizeRhs()
322 const int shard) { in Add()
344 const int shard) { in Add()
375 const bool case_sensitive, const int shard) { in AddWithExclusion()
385 const bool case_sensitive, const int shard) { in AddAssertion()
394 const bool case_sensitive, const int shard) { in AddValueMapping()
402 const bool case_sensitive, const int shard) { in AddValueMapping()
Dir.cc234 const bool case_sensitive, const int shard) { in Add()
247 const int shard) { in Add()
Drules.h92 int shard = 0; member
/external/autotest/client/site_tests/graphics_parallel_dEQP/
Dgenerate_controlfiles.py108 def get_controlfilename(test, shard=0): argument
124 def get_name(test, shard): argument
131 def get_testname(test, shard=0): argument
/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
85 static void grow_shard(slice_shard* shard) { in grow_shard()
204 static InternedSliceRefcount* InternNewStringLocked(slice_shard* shard, in InternNewStringLocked()
238 slice_shard* shard = &g_shards[SHARD_IDX(hash)]; in MatchInternedSliceLocked() local
261 slice_shard* shard = &g_shards[SHARD_IDX(hash)]; in FindOrCreateInternedSlice() local
316 slice_shard* shard = &g_shards[i]; in grpc_slice_intern_init() local
353 slice_shard* shard = &g_shards[i]; in grpc_slice_intern_shutdown() local
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dmetadata.cc237 mdtab_shard* shard = &g_shards[i]; in grpc_mdctx_global_init() local
249 mdtab_shard* shard = &g_shards[i]; in grpc_mdctx_global_shutdown() local
288 void InternedMetadata::RefWithShardLocked(mdtab_shard* shard) { in RefWithShardLocked()
306 static void gc_mdtab(mdtab_shard* shard) { in gc_mdtab()
318 static void grow_mdtab(mdtab_shard* shard) { in grow_mdtab()
345 static void rehash_mdtab(mdtab_shard* shard) { in rehash_mdtab()
448 mdtab_shard* shard = &g_shards[SHARD_IDX(hash)]; in md_create_must_intern() local
645 mdtab_shard* shard = &g_shards[SHARD_IDX(hash)]; in note_disposed_interned_metadata() local
/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
174 uptr shard = (uptr)arg; in OnStarted() local
178 uptr shard = (uptr)arg; in OnCreated() local
/external/grpc-grpc/src/core/lib/slice/
Dslice_intern.cc80 slice_shard* shard = &g_shards[SHARD_IDX(s->hash)]; in interned_slice_destroy() local
129 static void grow_shard(slice_shard* shard) { in grow_shard()
221 slice_shard* shard = &g_shards[SHARD_IDX(hash)]; in grpc_slice_intern() local
279 slice_shard* shard = &g_shards[i]; in grpc_slice_intern_init() local
311 slice_shard* shard = &g_shards[i]; in grpc_slice_intern_shutdown() local
/external/perfetto/src/cloud_trace_processor/
Dworker_impl.cc63 TracePoolShard* shard = shards_.Find(args.pool_id()); in TracePoolShardSetTraces() local
94 TracePoolShard* shard = shards_.Find(args.pool_id()); in TracePoolShardQuery() local
/external/bazelbuild-rules_android/src/common/golang/
Dshard_test.go15 package shard package
Dzipshard_test.go15 package shard package
Dshard.go16 package shard package
/external/tensorflow/tensorflow/core/kernels/
Drecord_yielder.cc136 Shard* shard = &shards[i]; in MainLoop() local
198 void RecordYielder::ShardLoop(Shard* shard) { in ShardLoop()
Dpopulation_count_op.cc106 auto shard = [input_ptr, output_ptr](int64_t start, int64_t limit) { in operator ()() local
Drange_sampler.cc240 int32_t num_shards, int32_t shard) in FixedUnigramSampler()
256 int32_t num_shards, int32_t shard) in FixedUnigramSampler()
/external/libtextclassifier/native/utils/grammar/parsing/
Dmatcher.cc269 for (const RulesSet_::Rules* shard : rules_shards_) { in AddTerminal() local
405 for (const RulesSet_::Rules* shard : rules_shards_) { in ProcessPendingSet() local
425 for (const RulesSet_::Rules* shard : rules_shards_) { in ProcessPendingSet() local
/external/autotest/frontend/afe/
Dmodels.py522 shard = dbmodels.ForeignKey(Shard, blank=True, null=True) variable in Host
643 def assign_to_shard(cls, shard, known_ids): argument
1474 def _check_update_from_shard(self, shard, updated_serialized): argument
1563 shard = dbmodels.ForeignKey(Shard, blank=True, null=True) variable in Job
1649 def assign_to_shard(cls, shard, known_ids): argument
1684 def _assign_jobs_to_shard(cls, job_ids, shard): argument
1694 def _get_new_jobs_for_shard(cls, shard, known_ids): argument
1711 def _get_jobs_without_hosts(cls, shard, known_ids): argument
1721 def _get_jobs_with_hosts(cls, shard, known_ids): argument
1928 def _check_update_from_shard(self, shard, updated_serialized, argument
Dfrontend_test_utils.py93 shard=None): argument
Drpc_utils.py950 def find_records_for_shard(shard, known_job_ids, known_host_ids): argument
969 def _persist_records_with_type_sent_from_shard( argument
1008 def persist_records_sent_from_shard(shard, jobs, hqes): argument
/external/tensorflow/tensorflow/python/ops/
Dcandidate_sampling_ops.py229 shard=0, argument
/external/tensorflow/tensorflow/core/kernels/linalg/
Dlu_op.cc115 auto shard = [this, &input, &num_rows, &num_cols, &outputs, in Compute() local
/external/tensorflow/tensorflow/python/checkpoint/
Dfunctional_saver.py122 def sharded_filename(filename_tensor, shard, num_shards): argument

123