| /system/hwservicemanager/ |
| D | test_lazy.cpp | 36 stream.push_back(clients); in onClients()
40 std::vector<bool> stream; member in RecordingClientCallback
94 ASSERT_THAT(cb->stream, ElementsAre()); in TEST_F()
109 ASSERT_THAT(cb->stream, ElementsAre()); in TEST_F()
122 ASSERT_THAT(cb->stream, ElementsAre(true)); in TEST_F()
128 ASSERT_THAT(cb->stream, ElementsAre(true)); in TEST_F()
131 ASSERT_THAT(cb->stream, ElementsAre(true, false)); // reported only after two intervals in TEST_F()
144 ASSERT_THAT(cb->stream, ElementsAre(true)); in TEST_F()
147 ASSERT_THAT(cb->stream, ElementsAre(true)); in TEST_F()
150 ASSERT_THAT(cb->stream, ElementsAre(true, false)); // reported only after two intervals in TEST_F()
[all …]
|
| /system/core/debuggerd/common/include/ |
| D | dump_type.h | 31 inline std::ostream& operator<<(std::ostream& stream, const DebuggerdDumpType& rhs) {
34 stream << "kDebuggerdNativeBacktrace";
37 stream << "kDebuggerdTombstone";
40 stream << "kDebuggerdJavaBacktrace";
43 stream << "kDebuggerdAnyIntercept";
46 stream << "kDebuggerdTombstoneProto";
49 stream << "[unknown]";
52 return stream;
|
| /system/media/audio_utils/ |
| D | tinysndfile.c | 33 FILE *stream; member
67 FILE *stream = fopen(path, "rb"); in sf_open_read() local
68 if (stream == NULL) { in sf_open_read()
78 handle->stream = stream; in sf_open_read()
84 actual = fread(wav, sizeof(char), sizeof(wav), stream); in sf_open_read()
116 actual = fread(chunk, sizeof(char), sizeof(chunk), stream); in sf_open_read()
145 actual = fread(fmt, sizeof(char), 2, stream); in sf_open_read()
174 actual = fread(&fmt[2], sizeof(char), minSize - 2, stream); in sf_open_read()
182 fseek(stream, (long) (chunkSize - minSize), SEEK_CUR); in sf_open_read()
245 dataTell = ftell(stream); in sf_open_read()
[all …]
|
| /system/libziparchive/ |
| D | zip_archive_stream_entry.cc | 148 static inline int zlib_inflateInit2(z_stream* stream, int window_bits) { in zlib_inflateInit2() argument
149 return inflateInit2(stream, window_bits); in zlib_inflateInit2()
298 ZipArchiveStreamEntry* stream = nullptr; in Create() local
300 stream = new ZipArchiveStreamEntryCompressed(handle); in Create()
302 stream = new ZipArchiveStreamEntryUncompressed(handle); in Create()
304 if (stream && !stream->Init(entry)) { in Create()
305 delete stream; in Create()
306 stream = nullptr; in Create()
309 return stream; in Create()
314 ZipArchiveStreamEntry* stream = nullptr; in CreateRaw() local
[all …]
|
| /system/chre/platform/slpi/see/ |
| D | see_helper.cc | 57 #define LOG_NANOPB_ERROR(stream) \ argument
58 LOGE("Nanopb error: %s:%d", PB_GET_ERROR(stream), __LINE__)
144 bool copyPayload(pb_ostream_t *stream, const pb_field_t *field, in copyPayload() argument
149 if (!pb_encode_tag_for_field(stream, field)) { in copyPayload()
150 LOG_NANOPB_ERROR(stream); in copyPayload()
151 } else if (!pb_encode_string(stream, in copyPayload()
154 LOG_NANOPB_ERROR(stream); in copyPayload()
188 pb_ostream_t stream = pb_ostream_from_buffer(msg->get(), *msgLen); in encodeSnsStdAttrReq() local
190 success = pb_encode(&stream, sns_std_attr_req_fields, &req); in encodeSnsStdAttrReq()
192 LOG_NANOPB_ERROR(&stream); in encodeSnsStdAttrReq()
[all …]
|
| /system/chre/apps/test/common/chre_cross_validator_sensor/src/ |
| D | chre_cross_validator_sensor_manager.cc | 42 bool decodeSensorName(pb_istream_t *stream, const pb_field_s *field, in decodeSensorName() argument
48 if (stream->bytes_left > kMaxSensorNameSize - 1) return false; in decodeSensorName()
50 size_t bytesToCopy = stream->bytes_left; in decodeSensorName()
51 if (!pb_read(stream, name, stream->bytes_left)) return false; in decodeSensorName()
132 bool Manager::encodeThreeAxisSensorDatapointValues(pb_ostream_t *stream, in encodeThreeAxisSensorDatapointValues() argument
140 stream, in encodeThreeAxisSensorDatapointValues()
146 if (!pb_encode_fixed32(stream, &sensorThreeAxisDataSample->values[i])) { in encodeThreeAxisSensorDatapointValues()
163 bool Manager::encodeFloatSensorDatapointValue(pb_ostream_t *stream, in encodeFloatSensorDatapointValue() argument
169 stream, in encodeFloatSensorDatapointValue()
174 if (!pb_encode_fixed32(stream, &sensorFloatDataSample->value)) { in encodeFloatSensorDatapointValue()
[all …]
|
| /system/chre/apps/nearby/location/lbs/contexthub/nanoapps/nearby/ |
| D | app_manager.cc | 221 pb_istream_t stream = pb_istream_from_buffer(message, message_size); in HandleHostConfigRequest() local
222 if (!pb_decode(&stream, nearby_BleConfig_fields, &config)) { in HandleHostConfigRequest()
288 auto stream = pb_ostream_from_buffer(static_cast<pb_byte_t *>(msg_buf), in SendFilterResultsToHost() local
291 if (!EncodeFilterResults(filter_results, &stream, &msg_size)) { in SendFilterResultsToHost()
293 PB_GET_ERROR(&stream)); in SendFilterResultsToHost()
318 auto stream = pb_ostream_from_buffer(static_cast<pb_byte_t *>(msg_buf), in SendFilterResultToHost() local
321 if (!EncodeFilterResult(filter_result, &stream, &msg_size)) { in SendFilterResultToHost()
323 PB_GET_ERROR(&stream)); in SendFilterResultToHost()
347 static bool EncodeFilterResultCallback(pb_ostream_t *stream, in EncodeFilterResultCallback() argument
356 stream, in EncodeFilterResultCallback()
[all …]
|
| /system/chre/apps/test/common/chre_cross_validator_sensor/inc/ |
| D | chre_cross_validator_sensor_manager.h | 129 static bool encodeThreeAxisSensorDatapointValues(pb_ostream_t *stream,
141 static bool encodeThreeAxisSensorDatapoints(pb_ostream_t *stream,
153 static bool encodeFloatSensorDatapoints(pb_ostream_t *stream,
165 static bool encodeProximitySensorDatapoints(pb_ostream_t *stream,
177 static bool encodeStepCounterSensorDatapoints(pb_ostream_t *stream,
189 static bool encodeFloatSensorDatapointValue(pb_ostream_t *stream,
203 static bool encodeProximitySensorDatapointValue(pb_ostream_t *stream,
216 static bool encodeStepCounterSensorDatapointValue(pb_ostream_t *stream,
|
| /system/chre/apps/test/common/shared/src/ |
| D | send_message.cc | 35 bool encodeErrorMessage(pb_ostream_t *stream, const pb_field_t * /*field*/, in encodeErrorMessage() argument
40 stream, &chre_test_common_TestResult_fields in encodeErrorMessage()
42 pb_encode_string(stream, reinterpret_cast<const pb_byte_t *>(str), in encodeErrorMessage()
106 pb_ostream_t stream = pb_ostream_from_buffer(bytes, size); in sendMessageToHost() local
107 if (!pb_encode(&stream, fields, message)) { in sendMessageToHost()
108 LOGE("Failed to encode message error %s", PB_GET_ERROR(&stream)); in sendMessageToHost()
|
| /system/chre/apps/rpc_world/rpc/ |
| D | rpc_world.proto | 9 // Request a stream of ticks.
10 rpc Timer(TimerRequest) returns (stream TimerResponse) {}
13 rpc Add(stream NumberMessage) returns (NumberMessage) {}
22 // Number of ticks that the server should stream.
|
| /system/nvram/messages/ |
| D | nvram_messages.cpp | 178 BlobOutputStreamBuffer stream(blob); in Encode() local
179 return nvram::proto::Encode(msg, &stream) && stream.Truncate(); in Encode()
184 ArrayOutputStreamBuffer stream(buffer, *size); in Encode() local
185 if (!nvram::proto::Encode(msg, &stream)) { in Encode()
188 *size = stream.bytes_written(); in Encode()
194 InputStreamBuffer stream(data, size); in Decode() local
195 return nvram::proto::Decode(msg, &stream) && stream.Done(); in Decode()
|
| /system/core/healthd/ |
| D | charger_test.cpp | 78 std::ofstream stream(path); in createFile() local
79 if (!stream.is_open()) { in createFile()
83 stream << content << std::endl; in createFile()
84 stream.close(); in createFile()
89 std::ifstream stream(path); in openToString() local
90 if (!stream.is_open()) { in openToString()
94 return std::string(std::istreambuf_iterator<char>(stream), std::istreambuf_iterator<char>()); in openToString()
|
| /system/core/fs_mgr/liblp/ |
| D | super_layout_builder.cpp | 219 std::ostream& operator<<(std::ostream& stream, const SuperImageExtent& extent) { in operator <<() argument
220 stream << "extent:" << extent.offset << ":" << extent.size << ":"; in operator <<()
223 stream << "data"; in operator <<()
226 stream << "partition:" << extent.image_name << ":" << extent.image_offset; in operator <<()
229 stream << "zero"; in operator <<()
232 stream << "dontcare"; in operator <<()
235 stream << "invalid"; in operator <<()
237 return stream; in operator <<()
|
| /system/libhidl/base/ |
| D | Status.cpp | 102 std::ostream& operator<< (std::ostream& stream, const Status& s) { in operator <<() argument
104 stream << "No error"; in operator <<()
106 stream << "Status(" << exceptionToString(s.exceptionCode()) << "): '"; in operator <<()
108 stream << statusToString(s.transactionError()) << ": "; in operator <<()
110 stream << s.exceptionMessage() << "'"; in operator <<()
112 return stream; in operator <<()
|
| /system/apex/tests/testdata/ |
| D | init.rc | 10 …socket pdx/system/vr/display/client stream 0666 system graphics u:object_r:pdx_display_client_…
11 …socket pdx/system/vr/display/manager stream 0666 system graphics u:object_r:pdx_display_manager…
12 …socket pdx/system/vr/display/vsync stream 0666 system graphics u:object_r:pdx_display_vsync_e…
|
| /system/gsid/tests/ |
| D | DsuGsiIntegrationTest.java | 83 InputStream stream = null; in setUp() local
89 stream = new FileInputStream(gsiImageFile); in setUp()
91 stream = new FileInputStream(mSystemImagePath); in setUp()
93 stream = new BufferedInputStream(stream); in setUp()
101 StreamUtil.copyStreams(stream, out); in setUp()
105 StreamUtil.close(stream); in setUp()
|
| /system/nvram/core/ |
| D | persistence.cpp | 47 BlobOutputStreamBuffer stream(blob); in EncodeObject() local
48 ProtoWriter writer(&stream); in EncodeObject()
51 !stream.Truncate()) { in EncodeObject()
68 InputStreamBuffer stream(blob.data(), blob.size()); in DecodeObject() local
69 ProtoReader reader(&stream); in DecodeObject()
|
| /system/chre/apps/test/common/chre_cross_validator_wifi/src/ |
| D | chre_cross_validator_wifi_manager.cc | 69 pb_istream_t stream = pb_istream_from_buffer( in handleMessageFromHost() local
74 if (!pb_decode(&stream, in handleMessageFromHost()
132 pb_istream_t stream = in handleDataMessage() local
136 WifiScanResult scanResult(&stream); in handleDataMessage()
261 bool Manager::encodeErrorMessage(pb_ostream_t *stream, in encodeErrorMessage() argument
267 stream, &chre_test_common_TestResult_fields in encodeErrorMessage()
269 pb_encode_string(stream, reinterpret_cast<const pb_byte_t *>(str), in encodeErrorMessage()
|
| D | wifi_scan_result.cc | 60 bool WifiScanResult::decodeString(pb_istream_t *stream, in decodeString() argument
63 return pb_read(stream, strPtr, stream->bytes_left); in decodeString()
|
| /system/timezone/input_tools/android/telephonylookup_generator/src/main/java/com/android/libcore/timezone/telephonylookup/ |
| D | TelephonyLookupXmlFile.java | 28 import javax.xml.stream.XMLOutputFactory;
29 import javax.xml.stream.XMLStreamException;
30 import javax.xml.stream.XMLStreamWriter;
35 import javax.xml.transform.stream.StreamResult;
36 import javax.xml.transform.stream.StreamSource;
|
| /system/core/debuggerd/test_permissive_mte/src/com/android/tests/debuggerd/ |
| D | PermissiveMteTest.java | 68 if (!tombstoneProto.getCommandLineList().stream().anyMatch(x -> x.contains(mUUID))) { in tearDown()
90 if (!tombstoneProto.getCommandLineList().stream().anyMatch(x -> x.contains(mUUID))) { in testCrash()
93 if (!tombstoneProto.getCommandLineList().stream().anyMatch(x -> x.contains("testCrash"))) { in testCrash()
118 if (!tombstoneProto.getCommandLineList().stream().anyMatch(x -> x.contains(mUUID))) { in testCrashProperty()
121 if (!tombstoneProto.getCommandLineList().stream().anyMatch(x -> x.contains("testCrash"))) { in testCrashProperty()
|
| /system/timezone/input_tools/android/tzlookup_generator/src/main/java/com/android/libcore/timezone/tzlookup/ |
| D | CountryZonesFileSupport.java | 26 import java.util.stream.Collectors;
50 return countries.stream() in extractIsoCodes()
56 return timeZones.stream() in extractIds()
|
| /system/timezone/input_tools/android/tzlookup_generator/src/main/java/com/android/libcore/timezone/tzlookup/zonetree/ |
| D | UniqueZonesVisualizer.java | 29 import java.util.stream.Collectors;
31 import static java.util.stream.Collectors.toSet;
57 countryCodes = countryZones.getCountriesList().stream() in main()
75 this.countryMap = countryZones.getCountriesList().stream() in UniqueZonesVisualizer()
|
| /system/timezone/input_tools/android/tzids/src/main/java/com/android/timezone/tzids/ |
| D | TimeZoneIds.java | 19 import static java.util.stream.Collectors.toMap;
166 .stream() in createCountryIdMap()
171 .stream() in createCountryIdMap()
184 .stream() in createCountryIdMap()
190 .stream() in createCountryIdMap()
|
| /system/tools/hidl/hashing/ |
| D | Hash.cpp | 55 std::ifstream stream(path); in sha256File() local
57 fileStream << stream.rdbuf(); in sha256File()
113 std::ifstream stream(path); in readHashFile() local
114 if (!stream) { in readHashFile()
122 while (std::getline(stream, line)) { in readHashFile()
|