| /external/perfetto/src/trace_processor/ |
| D | slice_tracker_unittest.cc | 46 std::vector<SliceInfo> ToSliceInfo(const TraceStorage::NestableSlices& slices) { in ToSliceInfo() argument
48 for (size_t i = 0; i < slices.slice_count(); i++) { in ToSliceInfo()
49 infos.emplace_back(SliceInfo{slices.start_ns()[i], slices.durations()[i]}); in ToSliceInfo()
62 auto slices = context.storage->nestable_slices(); in TEST() local
63 EXPECT_EQ(slices.slice_count(), 1); in TEST()
64 EXPECT_EQ(slices.start_ns()[0], 2); in TEST()
65 EXPECT_EQ(slices.durations()[0], 8); in TEST()
66 EXPECT_EQ(slices.cats()[0], 0); in TEST()
67 EXPECT_EQ(slices.names()[0], 1); in TEST()
68 EXPECT_EQ(slices.refs()[0], 42); in TEST()
[all …]
|
| D | slice_tracker.cc | 74 auto* slices = context_->storage->mutable_nestable_slices(); in StartSlice() local
81 int64_t parent_stack_id = depth == 0 ? 0 : slices->stack_ids()[stack->back()]; in StartSlice()
83 slices->AddSlice(timestamp, duration, utid, RefType::kRefUtid, cat, name, in StartSlice()
87 slices->set_stack_id(slice_idx, GetStackHash(*stack)); in StartSlice()
122 auto* slices = context_->storage->mutable_nestable_slices(); in End() local
127 if (cat && slices->cats()[slice_idx] != cat) in End()
129 if (name && slices->names()[slice_idx] != name) in End()
132 PERFETTO_DCHECK(slices->durations()[slice_idx] == kPendingDuration); in End()
133 slices->set_duration(slice_idx, timestamp - slices->start_ns()[slice_idx]); in End()
144 const auto& slices = context_->storage->nestable_slices(); in MaybeCloseStack() local
[all …]
|
| D | slice_table.cc | 32 const auto& slices = storage_->nestable_slices(); in CreateStorageSchema() local
35 .AddOrderedNumericColumn("ts", &slices.start_ns()) in CreateStorageSchema()
36 .AddNumericColumn("dur", &slices.durations()) in CreateStorageSchema()
37 .AddNumericColumn("ref", &slices.refs()) in CreateStorageSchema()
38 .AddStringColumn("ref_type", &slices.types(), &GetRefTypeStringMap()) in CreateStorageSchema()
39 .AddStringColumn("cat", &slices.cats(), &storage_->string_pool()) in CreateStorageSchema()
40 .AddStringColumn("name", &slices.names(), &storage_->string_pool()) in CreateStorageSchema()
41 .AddNumericColumn("depth", &slices.depths()) in CreateStorageSchema()
42 .AddNumericColumn("stack_id", &slices.stack_ids()) in CreateStorageSchema()
43 .AddNumericColumn("parent_stack_id", &slices.parent_stack_ids()) in CreateStorageSchema()
|
| D | sched_slice_table.cc | 30 const auto& slices = storage_->slices(); in CreateStorageSchema() local
32 .AddOrderedNumericColumn("ts", &slices.start_ns()) in CreateStorageSchema()
33 .AddNumericColumn("cpu", &slices.cpus()) in CreateStorageSchema()
34 .AddNumericColumn("dur", &slices.durations()) in CreateStorageSchema()
36 "ts_end", TsEndAccessor(&slices.start_ns(), &slices.durations())) in CreateStorageSchema()
37 .AddNumericColumn("utid", &slices.utids(), &slices.rows_for_utids()) in CreateStorageSchema()
38 .AddColumn<EndStateColumn>("end_state", &slices.end_state()) in CreateStorageSchema()
39 .AddNumericColumn("priority", &slices.priorities()) in CreateStorageSchema()
45 return static_cast<uint32_t>(storage_->slices().slice_count()); in RowCount()
|
| D | event_tracker_unittest.cc | 56 const auto& timestamps = context.storage->slices().start_ns(); in TEST_F()
72 ASSERT_EQ(context.storage->slices().utids().front(), 1); in TEST_F()
73 ASSERT_EQ(context.storage->slices().durations().front(), 1); in TEST_F()
84 const auto& timestamps = context.storage->slices().start_ns(); in TEST_F()
103 ASSERT_EQ(context.storage->slices().durations().at(0), 1u); in TEST_F()
104 ASSERT_EQ(context.storage->slices().durations().at(1), 11u - 1u); in TEST_F()
105 ASSERT_EQ(context.storage->slices().durations().at(2), 31u - 11u); in TEST_F()
106 ASSERT_EQ(context.storage->slices().utids().at(0), in TEST_F()
107 context.storage->slices().utids().at(2)); in TEST_F()
|
| /external/grpc-grpc/test/cpp/util/ |
| D | byte_buffer_test.cc | 55 std::vector<Slice> slices; in TEST_F() local
56 slices.emplace_back(kContent1); in TEST_F()
57 slices.emplace_back(kContent2); in TEST_F()
58 ByteBuffer buffer(&slices[0], 2); in TEST_F()
70 std::vector<Slice> slices; in TEST_F() local
71 slices.emplace_back(kContent1); in TEST_F()
72 slices.emplace_back(kContent2); in TEST_F()
73 ByteBuffer buffer(&slices[0], 2); in TEST_F()
92 std::vector<Slice> slices; in TEST_F() local
93 slices.push_back(Slice(hello, Slice::STEAL_REF)); in TEST_F()
[all …]
|
| D | cli_call.cc | 100 std::vector<grpc::Slice> slices; in Read() local
101 GPR_ASSERT(recv_buffer.Dump(&slices).ok()); in Read()
104 for (size_t i = 0; i < slices.size(); i++) { in Read()
105 response->append(reinterpret_cast<const char*>(slices[i].begin()), in Read()
106 slices[i].size()); in Read()
184 std::vector<grpc::Slice> slices; in ReadAndMaybeNotifyWrite() local
185 GPR_ASSERT(recv_buffer.Dump(&slices).ok()); in ReadAndMaybeNotifyWrite()
187 for (size_t i = 0; i < slices.size(); i++) { in ReadAndMaybeNotifyWrite()
188 response->append(reinterpret_cast<const char*>(slices[i].begin()), in ReadAndMaybeNotifyWrite()
189 slices[i].size()); in ReadAndMaybeNotifyWrite()
|
| /external/grpc-grpc/test/core/slice/ |
| D | slice_string_helpers_test.cc | 76 GPR_ASSERT(0 == grpc_slice_str_cmp(parts->slices[0], "one")); in test_strsplit()
77 GPR_ASSERT(0 == grpc_slice_str_cmp(parts->slices[1], "two")); in test_strsplit()
78 GPR_ASSERT(0 == grpc_slice_str_cmp(parts->slices[2], "three")); in test_strsplit()
79 GPR_ASSERT(0 == grpc_slice_str_cmp(parts->slices[3], "four")); in test_strsplit()
87 GPR_ASSERT(0 == grpc_slice_str_cmp(parts->slices[0], "one two three four")); in test_strsplit()
95 GPR_ASSERT(0 == grpc_slice_str_cmp(parts->slices[0], "foo")); in test_strsplit()
96 GPR_ASSERT(0 == grpc_slice_str_cmp(parts->slices[1], "")); in test_strsplit()
104 GPR_ASSERT(0 == grpc_slice_str_cmp(parts->slices[0], "")); in test_strsplit()
105 GPR_ASSERT(0 == grpc_slice_str_cmp(parts->slices[1], "foo")); in test_strsplit()
113 GPR_ASSERT(0 == grpc_slice_str_cmp(parts->slices[0], "")); in test_strsplit()
[all …]
|
| D | slice_buffer_test.cc | 61 grpc_slice slices[3]; in test_slice_buffer_move_first() local
68 slices[0] = grpc_slice_from_copied_string("aaa"); in test_slice_buffer_move_first()
69 slices[1] = grpc_slice_from_copied_string("bbbb"); in test_slice_buffer_move_first()
70 slices[2] = grpc_slice_from_copied_string("ccc"); in test_slice_buffer_move_first()
75 grpc_slice_ref(slices[idx]); in test_slice_buffer_move_first()
78 grpc_slice_buffer_add_indexed(&src, slices[idx]); in test_slice_buffer_move_first()
79 grpc_slice_buffer_add_indexed(&dst, slices[idx]); in test_slice_buffer_move_first()
|
| /external/grpc-grpc/test/core/http/ |
| D | parser_test.cc | 43 grpc_slice* slices; in test_request_succeeds() local
48 grpc_split_slices(split_mode, &input_slice, 1, &slices, &num_slices); in test_request_succeeds()
54 GPR_ASSERT(grpc_http_parser_parse(&parser, slices[i], nullptr) == in test_request_succeeds()
56 grpc_slice_unref(slices[i]); in test_request_succeeds()
91 gpr_free(slices); in test_request_succeeds()
101 grpc_slice* slices; in test_succeeds() local
106 grpc_split_slices(split_mode, &input_slice, 1, &slices, &num_slices); in test_succeeds()
112 GPR_ASSERT(grpc_http_parser_parse(&parser, slices[i], nullptr) == in test_succeeds()
114 grpc_slice_unref(slices[i]); in test_succeeds()
146 gpr_free(slices); in test_succeeds()
[all …]
|
| /external/grpc-grpc/test/core/surface/ |
| D | byte_buffer_reader_test.cc | 142 buffer = grpc_raw_compressed_byte_buffer_create(sliceb_out.slices, in read_compressed_slice()
191 buffer_from_reader->data.raw.slice_buffer.slices[0]), in test_byte_buffer_from_reader()
201 grpc_slice slices[2]; in test_readall() local
211 slices[0] = grpc_slice_malloc(512); in test_readall()
212 memcpy(GRPC_SLICE_START_PTR(slices[0]), lotsa_as, 512); in test_readall()
213 slices[1] = grpc_slice_malloc(1024); in test_readall()
214 memcpy(GRPC_SLICE_START_PTR(slices[1]), lotsa_bs, 1024); in test_readall()
216 buffer = grpc_raw_byte_buffer_create(slices, 2); in test_readall()
217 grpc_slice_unref(slices[0]); in test_readall()
218 grpc_slice_unref(slices[1]); in test_readall()
[all …]
|
| /external/perfetto/ui/src/tracks/chrome_slices/ |
| D | controller.ts | 115 const slices: Data = { constant
131 idx = slices.strings.length;
132 slices.strings.push(str);
140 slices.starts[row] = startSec;
141 slices.ends[row] = startSec + fromNs(+cols[1].longValues![row]);
142 slices.depths[row] = +cols[2].longValues![row];
143 slices.categories[row] = internString(cols[3].stringValues![row]);
144 slices.titles[row] = internString(cols[4].stringValues![row]);
147 slices.end = slices.ends[slices.ends.length - 1];
149 this.publish(slices);
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_util_test.cc | 25 std::vector<grpc::Slice> slices; in ToString() local
26 CHECK(buf.Dump(&slices).ok()); in ToString()
28 for (const grpc::Slice& s : slices) { in ToString()
37 std::vector<::grpc::Slice> slices; in MakeBuffer() local
41 slices.emplace_back(&str[pos], n); in MakeBuffer()
44 if (slices.empty()) { in MakeBuffer()
45 slices.emplace_back(); in MakeBuffer()
47 return ::grpc::ByteBuffer(&slices[0], slices.size()); in MakeBuffer()
93 int slices; in TEST() member
104 ::grpc::ByteBuffer src = MakeBuffer(proto.SerializeAsString(), c.slices); in TEST()
[all …]
|
| /external/grpc-grpc/test/core/util/ |
| D | slice_splitter.cc | 93 grpc_slice* slices; in grpc_split_slices_to_buffer() local
96 grpc_split_slices(mode, src_slices, src_slice_count, &slices, &nslices); in grpc_split_slices_to_buffer()
99 grpc_slice_buffer_add_indexed(dst, slices[i]); in grpc_split_slices_to_buffer()
101 gpr_free(slices); in grpc_split_slices_to_buffer()
106 grpc_split_slices_to_buffer(mode, src->slices, src->count, dst); in grpc_split_slice_buffer()
109 grpc_slice grpc_slice_merge(grpc_slice* slices, size_t nslices) { in grpc_slice_merge() argument
116 if (GRPC_SLICE_LENGTH(slices[i]) + length > capacity) { in grpc_slice_merge()
117 capacity = GPR_MAX(capacity * 2, GRPC_SLICE_LENGTH(slices[i]) + length); in grpc_slice_merge()
120 memcpy(out + length, GRPC_SLICE_START_PTR(slices[i]), in grpc_slice_merge()
121 GRPC_SLICE_LENGTH(slices[i])); in grpc_slice_merge()
[all …]
|
| D | passthru_endpoint.cc | 56 static void me_read(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_read() argument
64 grpc_slice_buffer_swap(&m->read_buffer, slices); in me_read()
68 m->on_read_out = slices; in me_read()
78 static void me_write(grpc_endpoint* ep, grpc_slice_buffer* slices, in me_write() argument
87 for (size_t i = 0; i < slices->count; i++) { in me_write()
88 grpc_slice_buffer_add(m->on_read_out, grpc_slice_copy(slices->slices[i])); in me_write()
93 for (size_t i = 0; i < slices->count; i++) { in me_write()
95 grpc_slice_copy(slices->slices[i])); in me_write()
|
| /external/perfetto/src/tracing/core/ |
| D | trace_packet_unittest.cc | 56 auto slice = tp.slices().begin(); in TEST()
57 ASSERT_NE(tp.slices().end(), slice); in TEST()
60 ASSERT_EQ(tp.slices().end(), ++slice); in TEST()
78 auto slice = tp.slices().begin(); in TEST()
79 ASSERT_NE(tp.slices().end(), slice); in TEST()
83 ASSERT_NE(tp.slices().end(), ++slice); in TEST()
87 ASSERT_NE(tp.slices().end(), ++slice); in TEST()
91 ASSERT_EQ(tp.slices().end(), ++slice); in TEST()
136 ASSERT_EQ(1u, tp.slices().size()); in TEST()
137 memcpy(&buf[preamble_size], tp.slices()[0].start, tp.slices()[0].size); in TEST()
[all …]
|
| /external/grpc-grpc/src/core/lib/slice/ |
| D | slice_buffer.cc | 37 size_t slice_offset = static_cast<size_t>(sb->slices - sb->base_slices); in maybe_embiggen()
41 if (sb->base_slices != sb->slices) { in maybe_embiggen()
43 memmove(sb->base_slices, sb->slices, sb->count * sizeof(grpc_slice)); in maybe_embiggen()
44 sb->slices = sb->base_slices; in maybe_embiggen()
58 sb->slices = sb->base_slices + slice_offset; in maybe_embiggen()
67 sb->base_slices = sb->slices = sb->inlined; in grpc_slice_buffer_init()
93 back = &sb->slices[sb->count - 1]; in grpc_slice_buffer_tiny_add()
104 back = &sb->slices[sb->count]; in grpc_slice_buffer_tiny_add()
114 sb->slices[out] = s; in grpc_slice_buffer_add_indexed()
128 grpc_slice* back = &sb->slices[n - 1]; in grpc_slice_buffer_add()
[all …]
|
| /external/tensorflow/tensorflow/python/autograph/operators/ |
| D | slices_test.py | 21 from tensorflow.python.autograph.operators import slices
33 l = slices.set_item(l, 0, [5, 6])
43 t = slices.get_item(
44 l, 1, slices.GetItemOpts(element_dtype=initial_list.dtype))
51 t = slices.get_item(initial_str, 1,
52 slices.GetItemOpts(element_dtype=initial_str.dtype))
58 t = slices.get_item(initial_list_str, 1,
59 slices.GetItemOpts(element_dtype=initial_str.dtype))
|
| /external/grpc-grpc/src/cpp/server/health/ |
| D | default_health_check_service.cc | 52 std::vector<Slice> slices; in Check() local
53 if (!request->Dump(&slices).ok()) { in Check()
60 if (slices.empty()) { in Check()
62 } else if (slices.size() == 1) { in Check()
63 request_bytes = const_cast<uint8_t*>(slices[0].begin()); in Check()
64 request_size = slices[0].size(); in Check()
69 for (size_t i = 0; i < slices.size(); i++) { in Check()
70 memcpy(copy_to, slices[i].begin(), slices[i].size()); in Check()
71 copy_to += slices[i].size(); in Check()
|
| /external/tensorflow/tensorflow/python/data/experimental/kernel_tests/serialization/ |
| D | dataset_constructor_serialization_test.py | 73 def _build_sparse_tensor_slice_dataset(self, slices): argument
75 [[i, j] for i in range(len(slices)) for j in range(len(slices[i]))],
77 values = np.array([val for s in slices for val in s], dtype=np.float64)
79 [len(slices), max(len(s) for s in slices) + 1], dtype=np.int64)
84 slices = [[1., 2., 3.], [1.], [1.], [1., 2.], [], [1., 2.], [], [], []]
88 lambda: self._build_sparse_tensor_slice_dataset(slices),
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | endpoint_tests.cc | 52 size_t count_slices(grpc_slice* slices, size_t nslices, int* current_data) { in count_slices() argument
58 buf = GRPC_SLICE_START_PTR(slices[i]); in count_slices()
59 for (j = 0; j < GRPC_SLICE_LENGTH(slices[i]); ++j) { in count_slices()
63 num_bytes += GRPC_SLICE_LENGTH(slices[i]); in count_slices()
80 grpc_slice* slices = in allocate_blocks() local
89 slices[i] = grpc_slice_malloc(slice_size > num_bytes_left ? num_bytes_left in allocate_blocks()
91 num_bytes_left -= GRPC_SLICE_LENGTH(slices[i]); in allocate_blocks()
92 buf = GRPC_SLICE_START_PTR(slices[i]); in allocate_blocks()
93 for (j = 0; j < GRPC_SLICE_LENGTH(slices[i]); ++j) { in allocate_blocks()
99 return slices; in allocate_blocks()
[all …]
|
| /external/perfetto/ui/src/tracks/cpu_slices/ |
| D | controller.ts | 127 const slices: SliceData = { constant
141 slices.starts[row] = startSec;
142 slices.ends[row] = startSec + fromNs(+cols[1].longValues![row]);
143 slices.utids[row] = +cols[2].longValues![row];
144 slices.ids[row] = +cols[3].longValues![row];
147 slices.end = slices.ends[slices.ends.length - 1];
149 return slices;
|
| /external/tensorflow/tensorflow/python/data/kernel_tests/ |
| D | from_sparse_tensor_slices_test.py | 44 slices = [[1., 2., 3.], [1.], [1.], [1., 2.], [], [1., 2.], [], [], []]
48 [[i, j] for i in range(len(slices)) for j in range(len(slices[i]))])
49 values = np.array([val for s in slices for val in s])
50 dense_shape = np.array([len(slices), max(len(s) for s in slices) + 1])
54 for i, s in enumerate(slices):
58 [[j] for j in range(len(slices[i]))]).reshape([-1, 1])
|
| /external/perfetto/ui/src/tracks/process_scheduling/ |
| D | controller.ts | 151 const slices: SliceData = { constant
166 slices.starts[row] = startSec;
167 slices.ends[row] = startSec + fromNs(+cols[1].longValues![row]);
168 slices.cpus[row] = +cols[2].longValues![row];
169 slices.utids[row] = +cols[3].longValues![row];
170 slices.end = Math.max(slices.ends[row], slices.end);
172 return slices;
|
| /external/tensorflow/tensorflow/tools/dockerfiles/ |
| D | assembler.py | 287 def build_name_from_slices(format_string, slices, args, is_dockerfile=False): argument
290 name_formatter.update({s['set_name']: s['add_to_name'] for s in slices})
293 for s in slices
340 def gather_tag_args(slices, cli_input_args, required_args): argument
344 for s in slices:
358 def gather_slice_list_items(slices, key): argument
360 return list(itertools.chain(*[s[key] for s in slices if key in s]))
363 def find_first_slice_value(slices, key): argument
365 for s in slices:
395 for slices in slice_combos:
[all …]
|