/external/gemmlowp/meta/generators/ |
D | gemm_NxMxK_neon.py | 20 def GenerateCommonTempsCountersAndConsts(emitter, rows): argument 21 emitter.EmitDeclare('const std::int32_t', 'row_chunks', 'm / 3') 22 emitter.EmitDeclare('const std::int32_t', 'col_chunks', 'n / 3') 23 emitter.EmitDeclare('const std::int32_t', 'padded_k', '((k + 7) / 8) * 8') 24 emitter.EmitDeclare('const std::int32_t', 'chunk_size', 'k * 3') 25 emitter.EmitDeclare('const std::int32_t', 'zipped_chunk_size', 27 emitter.EmitDeclare('const std::int32_t', 'zipped_rhs_size', 29 emitter.EmitDeclare('const std::uint8_t*', 'lhs_chunk', 'lhs') 30 emitter.EmitDeclare('const std::uint8_t*', 'rhs_chunk', 'rhs') 31 emitter.EmitDeclare('std::uint8_t*', 'zipped_lhs', 'scratch') [all …]
|
D | quantized_mul_kernels_common.py | 19 def _ReadParams(emitter, registers, input_address, elements, min_register): argument 25 emitter.EmitVLoadAE(registers_count * 4, 32, registers, input_address, 64) 29 def _Duplicate(emitter, registers, rows, values): argument 38 emitter.EmitVDup('32', duplicated[i], 39 emitter.Lane(32, values[i / 4], i % 4)) 44 def _DuplicateGeneralRegister(emitter, registers, value, min_register): argument 46 emitter.EmitVDup('32', register, value) 53 def Prepare(self, emitter, registers, kernel_m, kernel_n, lhs, rhs): argument 55 emitter.EmitNewline() 56 emitter.EmitComment('StaticQuantization::Prepare') [all …]
|
D | gemv_1xMxK_neon.py | 21 def GenerateCommonTempsCountersAndConsts(emitter): argument 23 emitter.EmitDeclare('const std::int32_t', 'col_chunks', 'n / 8') 24 emitter.EmitDeclare('const std::int32_t', 'padded_k', '((k + 7) / 8) * 8') 25 emitter.EmitDeclare('const std::int32_t', 'chunk_size', 'k * 4') 26 emitter.EmitDeclare('const std::int32_t', 'zipped_chunk_size', 28 emitter.EmitDeclare('const std::uint8_t*', 'rhs_chunk', 'rhs') 29 emitter.EmitDeclare('std::uint8_t*', 'zipped_lhs', 'scratch') 30 emitter.EmitDeclare('std::int32_t*', 'zipped_lhs_offsets', 32 emitter.EmitDeclare('std::uint8_t*', 'zipped_rhs_1', 34 emitter.EmitDeclare('std::uint8_t*', 'zipped_rhs_2', [all …]
|
D | zip_Nx8_neon.py | 27 def GenerateZipLanes(emitter, registers, zip_lanes, input_address, stride): argument 50 emitter.EmitAdd(address_register, last_address_register, stride) 64 def GenerateClearAggregators(emitter, lanes): argument 66 emitter.EmitVMov('i16', lane.aggregator, emitter.ImmediateConstant(0)) 69 def GenerateLoadAggregateStore(emitter, lanes, output_address, alignment): argument 71 emitter.EmitNewline() 72 emitter.EmitComment('Load Aggregate Store.') 75 emitter.EmitVLoad( 77 emitter.DereferenceIncrement(lane.input_address, alignment)) 81 emitter.EmitVAddw('u8', lane.aggregator, lane.aggregator, lane.load) [all …]
|
D | mul_Nx8_Mx8_neon.py | 48 def GenerateAndClearAggregators(emitter, registers, aggregator_count): argument 50 emitter.EmitComment('Clear aggregators.') 56 emitter.EmitVMov('i32', aggregator, emitter.ImmediateConstant(0)) 58 emitter.EmitVMov('i32', aggregator, aggregators[i - 3]) 59 emitter.EmitNewline() 63 def GenerateNxMLoadMultiplyAggregate(emitter, registers, left_lanes, argument 66 emitter.EmitComment('General NxM lanes loop.') 67 emitter.EmitNumericalLabel(1) 68 emitter.EmitNewline() 69 emitter.EmitComment('Subtract counter.') [all …]
|
D | mul_1x8_Mx8_neon.py | 14 def GenerateLoadMultiplyAggregate(emitter, registers, lanes_count, aggregators, argument 17 emitter.EmitComment('General 1xM lanes loop.') 18 emitter.EmitNumericalLabel(1) 19 emitter.EmitNewline() 20 emitter.EmitComment('Subtract counter.') 21 emitter.EmitSubs(count, count, emitter.ImmediateConstant(8)) 22 emitter.EmitNewline() 27 emitter.EmitVLoad('1.8', left_load, emitter.DereferenceIncrement(lhs, 64)) 28 emitter.EmitVLoadA('1.8', right_load, emitter.DereferenceIncrement(rhs_1, 64)) 30 emitter.EmitPldOffset(lhs, emitter.ImmediateConstant(64)) [all …]
|
D | transform_kernels_common.py | 19 def _DuplicateGeneralRegister(size, emitter, registers, value, min_register): argument 21 emitter.EmitVDup(size, register, value) 25 def _DuplicateGeneralMemoryRegister(size, emitter, registers, value, argument 29 emitter.EmitLdr(general, value) 30 emitter.EmitVDup(size, register, general) 44 def Prepare(self, emitter, registers, unused_kernel_size): argument 45 emitter.EmitNewline() 46 emitter.EmitComment('MinMax::Prepare') 48 self.min = _DuplicateGeneralRegister(8, emitter, registers, 52 self.max = _DuplicateGeneralRegister(8, emitter, registers, [all …]
|
D | qnt_Nx8_neon.py | 35 def LoadAndDuplicateOffsets(emitter, registers, lanes, offsets): argument 40 emitter.EmitVLoadA('1.32', [emitter.AllLanes(registers.Low(register)), 41 emitter.AllLanes(registers.High(register))], 42 emitter.DereferenceIncrement(offsets, 32)) 49 def GenerateQntLanes(emitter, registers, qnt_lanes, source, stride, destination, argument 52 offset_registers = LoadAndDuplicateOffsets(emitter, registers, qnt_lanes, 73 emitter.EmitAdd(input_register, last_input_register, stride) 74 emitter.EmitAdd(output_register, last_output_register, destination_stride) 80 def DuplicateRegister(emitter, registers, value): argument 82 emitter.EmitVDup('32', register, value) [all …]
|
D | meta_neon.py | 30 def GenerateInternalFunctions(emitter): argument 33 emitter.EmitNewline() 37 emitter.EmitNewline() 41 emitter.EmitNewline() 45 emitter.EmitNewline() 49 emitter.EmitNewline() 53 emitter.EmitNewline() 57 emitter.EmitNewline() 59 qnt_Nx8_neon.GenerateFunctions(neon_emitter.NeonEmitter(), emitter) 60 emitter.EmitNewline() [all …]
|
D | streams_common.py | 37 def _GenerateInputs(emitter, registers, lanes_count, input_address, stride): argument 47 emitter.EmitAdd(address_register, last_address_register, stride) 52 def _GenerateClear(emitter, clear_type, block): argument 54 emitter.EmitVMov(clear_type, row, emitter.ImmediateConstant(0)) 57 def _GenerateLoadAggregateStore(emitter, registers, lanes_count, elements_count, argument 60 emitter.EmitNewline() 61 emitter.EmitComment('Load Aggregate Store: %dx%d.' % (lanes_count, 67 _GenerateClear(emitter, 'i8', block) 70 emitter.EmitVLoadE(8, elements_count, row, input_address, None) 73 emitter.EmitVAddw('u8', aggregator, aggregator, row) [all …]
|
D | common.py | 70 def __init__(self, emitter, name): argument 72 self.emitter = emitter 77 self.emitter.EmitMemberFunctionBegin( 81 GenerateDebugLog(self.emitter, 84 self.emitter.EmitFunctionEnd() 90 def __init__(self, emitter, kernel_name, output_stream_name): argument 93 self.emitter = emitter 102 self.emitter.EmitMemberFunctionBegin( 109 GenerateDebugLog(self.emitter, '%s::Multiply()' % 113 self.emitter.EmitFunctionEnd() [all …]
|
/external/jemalloc_new/include/jemalloc/internal/ |
D | emitter.h | 86 emitter_init(emitter_t *emitter, emitter_output_t emitter_output, in emitter_init() argument 88 emitter->output = emitter_output; in emitter_init() 89 emitter->write_cb = write_cb; in emitter_init() 90 emitter->cbopaque = cbopaque; in emitter_init() 91 emitter->item_at_depth = false; in emitter_init() 92 emitter->nesting_depth = 0; in emitter_init() 98 emitter_printf(emitter_t *emitter, const char *format, ...) { in emitter_printf() argument 102 malloc_vcprintf(emitter->write_cb, emitter->cbopaque, format, ap); in emitter_printf() 109 emitter_table_printf(emitter_t *emitter, const char *format, ...) { in emitter_table_printf() argument 110 if (emitter->output == emitter_output_table) { in emitter_table_printf() [all …]
|
/external/jemalloc_new/test/unit/ |
D | emitter.c | 70 emitter_t emitter; in assert_emit_output() local 78 emitter_init(&emitter, emitter_output_json, &forwarding_cb, in assert_emit_output() 80 (*emit_fn)(&emitter); in assert_emit_output() 87 emitter_init(&emitter, emitter_output_table, &forwarding_cb, in assert_emit_output() 89 (*emit_fn)(&emitter); in assert_emit_output() 94 emit_dict(emitter_t *emitter) { in emit_dict() argument 100 emitter_begin(emitter); in emit_dict() 101 emitter_dict_begin(emitter, "foo", "This is the foo table:"); in emit_dict() 102 emitter_kv(emitter, "abc", "ABC", emitter_type_bool, &b_false); in emit_dict() 103 emitter_kv(emitter, "def", "DEF", emitter_type_bool, &b_true); in emit_dict() [all …]
|
/external/oss-fuzz/projects/libyaml/ |
D | libyaml_deconstructor_fuzzer.c | 39 yaml_emitter_t emitter; in LLVMFuzzerTestOneInput() local 49 if (!yaml_emitter_initialize(&emitter)) { in LLVMFuzzerTestOneInput() 60 yaml_emitter_set_output(&emitter, yaml_write_handler, &out); in LLVMFuzzerTestOneInput() 62 yaml_emitter_set_canonical(&emitter, is_canonical); in LLVMFuzzerTestOneInput() 63 yaml_emitter_set_unicode(&emitter, is_unicode); in LLVMFuzzerTestOneInput() 69 if (!yaml_emitter_emit(&emitter, &output_event)) in LLVMFuzzerTestOneInput() 76 if (!yaml_emitter_emit(&emitter, &output_event)) in LLVMFuzzerTestOneInput() 85 if (!yaml_emitter_emit(&emitter, &output_event)) in LLVMFuzzerTestOneInput() 106 if (!yaml_emitter_emit(&emitter, &output_event)) in LLVMFuzzerTestOneInput() 120 if (!yaml_emitter_emit(&emitter, &output_event)) in LLVMFuzzerTestOneInput() [all …]
|
D | libyaml_reformatter_alt_fuzzer.c | 39 yaml_emitter_t emitter; in LLVMFuzzerTestOneInput() local 47 if (!yaml_emitter_initialize(&emitter)) in LLVMFuzzerTestOneInput() 56 yaml_emitter_set_output(&emitter, yaml_write_handler, &out); in LLVMFuzzerTestOneInput() 58 yaml_emitter_set_canonical(&emitter, is_canonical); in LLVMFuzzerTestOneInput() 59 yaml_emitter_set_unicode(&emitter, is_unicode); in LLVMFuzzerTestOneInput() 75 if (!yaml_emitter_dump(&emitter, &document)) in LLVMFuzzerTestOneInput() 80 yaml_emitter_delete(&emitter); in LLVMFuzzerTestOneInput()
|
D | libyaml_reformatter_fuzzer.c | 39 yaml_emitter_t emitter; in LLVMFuzzerTestOneInput() local 47 if (!yaml_emitter_initialize(&emitter)) in LLVMFuzzerTestOneInput() 56 yaml_emitter_set_output(&emitter, yaml_write_handler, &out); in LLVMFuzzerTestOneInput() 58 yaml_emitter_set_canonical(&emitter, is_canonical); in LLVMFuzzerTestOneInput() 59 yaml_emitter_set_unicode(&emitter, is_unicode); in LLVMFuzzerTestOneInput() 75 if (!yaml_emitter_emit(&emitter, &event)) in LLVMFuzzerTestOneInput() 80 yaml_emitter_delete(&emitter); in LLVMFuzzerTestOneInput()
|
D | libyaml_dumper_fuzzer.c | 209 yaml_emitter_t emitter; in LLVMFuzzerTestOneInput() local 226 if (!yaml_emitter_initialize(&emitter)) in LLVMFuzzerTestOneInput() 229 yaml_emitter_set_canonical(&emitter, is_canonical); in LLVMFuzzerTestOneInput() 230 yaml_emitter_set_unicode(&emitter, is_unicode); in LLVMFuzzerTestOneInput() 233 yaml_emitter_set_output(&emitter, yaml_write_handler, &out); in LLVMFuzzerTestOneInput() 234 yaml_emitter_open(&emitter); in LLVMFuzzerTestOneInput() 255 if (!(yaml_emitter_dump(&emitter, &document) || in LLVMFuzzerTestOneInput() 256 (yaml_emitter_flush(&emitter) && 0))) { in LLVMFuzzerTestOneInput() 268 yaml_emitter_close(&emitter); in LLVMFuzzerTestOneInput() 269 yaml_emitter_delete(&emitter); in LLVMFuzzerTestOneInput()
|
/external/jemalloc_new/src/ |
D | stats.c | 193 mutex_stats_emit(emitter_t *emitter, emitter_row_t *row, in mutex_stats_emit() argument 197 emitter_table_row(emitter, row); in mutex_stats_emit() 210 emitter_json_kv(emitter, #counter, EMITTER_TYPE_##type, \ in mutex_stats_emit() 219 stats_arena_bins_print(emitter_t *emitter, bool mutex, unsigned i) { in stats_arena_bins_print() argument 288 emitter_table_printf(emitter, "bins:"); in stats_arena_bins_print() 289 emitter_table_row(emitter, &header_row); in stats_arena_bins_print() 290 emitter_json_arr_begin(emitter, "bins"); in stats_arena_bins_print() 306 emitter_table_printf(emitter, in stats_arena_bins_print() 336 emitter_json_arr_obj_begin(emitter); in stats_arena_bins_print() 337 emitter_json_kv(emitter, "nmalloc", emitter_type_uint64, in stats_arena_bins_print() [all …]
|
/external/dtc/ |
D | yamltree.c | 24 #define yaml_emitter_emit_or_die(emitter, event) ( \ argument 26 if (!yaml_emitter_emit(emitter, event)) \ 28 yaml_error_name[(emitter)->error], \ 29 (emitter)->problem, __func__, __LINE__); \ 32 static void yaml_propval_int(yaml_emitter_t *emitter, struct marker *markers, char *data, int len, … in yaml_propval_int() argument 50 yaml_emitter_emit_or_die(emitter, &event); in yaml_propval_int() 88 yaml_emitter_emit_or_die(emitter, &event); in yaml_propval_int() 92 yaml_emitter_emit_or_die(emitter, &event); in yaml_propval_int() 95 static void yaml_propval_string(yaml_emitter_t *emitter, char *str, int len) in yaml_propval_string() argument 109 yaml_emitter_emit_or_die(emitter, &event); in yaml_propval_string() [all …]
|
/external/linux-kselftest/tools/testing/selftests/filesystems/epoll/ |
D | epoll_wakeup_test.c | 457 pthread_t emitter; in TEST() local 473 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST() 481 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST() 482 pthread_kill(emitter, SIGUSR1); in TEST() 483 pthread_join(emitter, NULL); in TEST() 500 pthread_t emitter; in TEST() local 516 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST() 524 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST() 525 pthread_kill(emitter, SIGUSR1); in TEST() 526 pthread_join(emitter, NULL); in TEST() [all …]
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
D | StateFlowStressTest.kt | 33 val emitter = (value % nEmitters).toInt() in <lambda>() constant 36 … val ok = if (index++ == 0) current >= c[emitter] else current > c[emitter] in <lambda>() 39 … "was ${c[emitter]} in collector #$collector from emitter #$emitter" in <lambda>() 41 c[emitter] = current in <lambda>() 50 repeat(nEmitters) { emitter -> in <lambda>() method 54 state.value = current * nEmitters + emitter in <lambda>() 55 emitted[emitter] = current in <lambda>() 71 c.withIndex().all { (emitter, current) -> current > emitted[emitter] / 2 } in <lambda>() method
|
/external/snakeyaml/src/main/java/org/yaml/snakeyaml/serializer/ |
D | Serializer.java | 28 import org.yaml.snakeyaml.emitter.Emitable; 52 private final Emitable emitter; field in Serializer 64 public Serializer(Emitable emitter, Resolver resolver, DumperOptions opts, Tag rootTag) { in Serializer() argument 65 this.emitter = emitter; in Serializer() 82 this.emitter.emit(new StreamStartEvent(null, null)); in open() 95 this.emitter.emit(new StreamEndEvent(null, null)); in close() 106 this.emitter.emit(new DocumentStartEvent(null, null, this.explicitStart, this.useVersion, in serialize() 113 this.emitter.emit(new DocumentEndEvent(null, null, this.explicitEnd)); in serialize() 158 this.emitter.emit(new AliasEvent(tAlias, null, null)); in serializeNode() 170 this.emitter.emit(event); in serializeNode() [all …]
|
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
D | RxConvert.kt | 108 …context: CoroutineContext = EmptyCoroutineContext) : Observable<T> = Observable.create { emitter -> in asObservable() method 115 collect { value -> emitter.onNext(value) } in asObservable() 116 emitter.onComplete() in asObservable() 120 if (!emitter.tryOnError(e)) { in asObservable() 124 emitter.onComplete() in asObservable() 128 emitter.setCancellable(RxCancellable(job)) in asObservable()
|
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
D | RxConvert.kt | 108 …context: CoroutineContext = EmptyCoroutineContext) : Observable<T> = Observable.create { emitter -> in asObservable() method 115 collect { value -> emitter.onNext(value) } in asObservable() 116 emitter.onComplete() in asObservable() 120 if (!emitter.tryOnError(e)) { in asObservable() 124 emitter.onComplete() in asObservable() 128 emitter.setCancellable(RxCancellable(job)) in asObservable()
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
D | SharedFlow.kt | 418 val emitter = synchronized(this) lock@{ in emitSuspend() constant 434 emitter?.let { cont.disposeOnCancellation(it) } in emitSuspend() 439 private fun cancelEmitter(emitter: Emitter) = synchronized(this) { in <lambda>() 440 if (emitter.index < head) return // already skipped past this index in <lambda>() 442 if (buffer.getBufferAt(emitter.index) !== emitter) return // already resumed in <lambda>() 443 buffer.setBufferAt(emitter.index, NO_VALUE) in <lambda>() 488 val emitter = buffer.getBufferAt(curEmitterIndex) in updateCollectorIndexLocked() constant 489 if (emitter !== NO_VALUE) { in updateCollectorIndexLocked() 490 emitter as Emitter // must have Emitter class in updateCollectorIndexLocked() 491 resumes[resumeCount++] = emitter.cont in updateCollectorIndexLocked() [all …]
|