Home
last modified time | relevance | path

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

12

/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/autotest/client/site_tests/graphics_dEQP/
Dgenerate_controlfiles.py105 def get_controlfilename(test, shard=0): argument
123 def get_name(test, shard): argument
132 def get_testname(test, shard=0): argument
/external/tensorflow/tensorflow/contrib/factorization/python/ops/
Dgmm_ops.py282 def _define_full_covariance_probs(self, shard_id, shard): argument
304 def _define_diag_covariance_probs(self, shard_id, shard): argument
328 def _define_log_prob_operation(self, shard_id, shard): argument
370 def _define_partial_maximization_operation(self, shard_id, shard): argument
/external/tensorflow/tensorflow/contrib/kinesis/kernels/
Dkinesis_dataset_ops.cc153 std::string shard = ""; in MakeDataset() local
169 Dataset(OpKernelContext* ctx, const string& stream, const string& shard, in Dataset()
202 Node* shard = nullptr; in AsGraphDefInternal() local
292 Aws::String shard; in SetupStreamsLocked() 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/tensorflow/tensorflow/contrib/kinesis/python/ops/
Dkinesis_dataset_ops.py60 shard="", argument
/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.cc102 auto shard = [input_ptr, output_ptr](int64 start, int64 limit) { in operator ()() local
Dcompare_and_bitpack_op.cc148 auto shard = [&, thresh](int64 start, int64 limit) { in operator ()() local
Drange_sampler.cc236 int32 num_shards, int32 shard) in FixedUnigramSampler()
252 int32 num_shards, int32 shard) in FixedUnigramSampler()
Dlu_op.cc115 auto shard = [this, &input, &num_rows, &num_cols, &outputs, in Compute() local
Dcandidate_sampler_ops.cc173 int64 shard; in FixedUnigramCandidateSamplerOp() local
Dlinalg_ops_common.cc101 auto shard = [this, &inputs, &input_matrix_shapes, &outputs, in Compute() local
Ddepthwise_conv_op.cc187 auto shard = [&ctx, &args, &input, &filter_data, &output, data_format]( in operator ()() local
/external/autotest/frontend/afe/
Dfrontend_test_utils.py93 shard=None): argument
Drpc_utils.py949 def find_records_for_shard(shard, known_job_ids, known_host_ids): argument
968 def _persist_records_with_type_sent_from_shard( argument
1009 def persist_records_sent_from_shard(shard, jobs, hqes): argument
Dmodels.py518 shard = dbmodels.ForeignKey(Shard, blank=True, null=True) variable in Host
639 def assign_to_shard(cls, shard, known_ids): argument
1463 def sanity_check_update_from_shard(self, shard, updated_serialized): argument
1552 shard = dbmodels.ForeignKey(Shard, blank=True, null=True) variable in Job
1636 def assign_to_shard(cls, shard, known_ids): argument
1885 def sanity_check_update_from_shard(self, shard, updated_serialized, argument
/external/autotest/cli/
Dshard.py22 class shard(topic_common.atest): class
/external/tensorflow/tensorflow/python/ops/
Dcandidate_sampling_ops.py225 shard=0, argument
/external/boringssl/src/util/
Dall_tests.go59 shard, numShards int member
/external/tensorflow/tensorflow/contrib/factorization/kernels/
Dwals_solver_ops.cc215 auto work = [&](const Shard& shard) { in Compute()
/external/autotest/scheduler/shard/
Dshard_client.py231 def shard(self): member in ShardClient
/external/tensorflow/tensorflow/core/util/
Dtensor_slice_reader.cc129 for (size_t shard = 0; shard < fnames_.size(); ++shard) { in TensorSliceReader() local

12