Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 1495) sorted by relevance

12345678910>>...60

/packages/modules/Bluetooth/system/gd/packet/parser/
Denum_gen.cc25 void EnumGen::GenDefinition(std::ostream& stream) { in GenDefinition() argument
26 stream << "enum class "; in GenDefinition()
27 stream << e_.name_; in GenDefinition()
28 stream << " : " << util::GetTypeForSize(e_.size_); in GenDefinition()
29 stream << " {"; in GenDefinition()
31 stream << pair.second << " = 0x" << std::hex << pair.first << std::dec << ","; in GenDefinition()
33 stream << "};\n"; in GenDefinition()
36 void EnumGen::GenDefinitionPybind11(std::ostream& stream) { in GenDefinitionPybind11() argument
37 stream << "py::enum_<" << e_.name_ << ">(m, \"" << e_.name_ << "\")"; in GenDefinitionPybind11()
39 stream << ".value(\"" << pair.second << "\", " << e_.name_ << "::" << pair.second << ")"; in GenDefinitionPybind11()
[all …]
/packages/modules/Connectivity/tests/cts/net/src/android/net/rtp/cts/
DAudioStreamTest.java29 AudioStream stream = new AudioStream(address); in testRtpStream() local
30 assertEquals(stream.getLocalAddress(), address); in testRtpStream()
31 assertEquals(stream.getLocalPort() % 2, 0); in testRtpStream()
33 assertNull(stream.getRemoteAddress()); in testRtpStream()
34 assertEquals(stream.getRemotePort(), -1); in testRtpStream()
35 stream.associate(address, 1000); in testRtpStream()
36 assertEquals(stream.getRemoteAddress(), address); in testRtpStream()
37 assertEquals(stream.getRemotePort(), 1000); in testRtpStream()
39 assertFalse(stream.isBusy()); in testRtpStream()
40 stream.release(); in testRtpStream()
[all …]
/packages/services/Car/tests/obd2_test/src/com/android/car/obd2/test/
DIntegerArrayStreamTest.java30 IntegerArrayStream stream = new IntegerArrayStream(DATA_SET); in testPeekConsume() local
31 assertEquals(1, stream.peek()); in testPeekConsume()
32 assertEquals(1, stream.consume()); in testPeekConsume()
33 assertEquals(2, stream.peek()); in testPeekConsume()
34 assertEquals(2, stream.consume()); in testPeekConsume()
39 IntegerArrayStream stream = new IntegerArrayStream(DATA_SET); in testResidualLength() local
40 assertEquals(DATA_SET.length, stream.residualLength()); in testResidualLength()
41 stream.consume(); in testResidualLength()
42 assertEquals(DATA_SET.length - 1, stream.residualLength()); in testResidualLength()
47 IntegerArrayStream stream = new IntegerArrayStream(DATA_SET); in testHasAtLeast() local
[all …]
/packages/services/Telephony/testapps/TestRcsApp/aosp_test_rcsclient/src/com/android/libraries/rcs/simpleclient/protocol/msrp/
DMsrpParser.java42 public static MsrpChunk parse(final InputStream stream) throws IOException { in parse() argument
46 int i = stream.read(); in parse()
50 skipWithDelimiter(stream, CHAR_SP); in parse()
59 i = stream.read(); in parse()
75 for (i = stream.read(); (i != CHAR_LF) && (i != -1); i = stream.read()) { in parse()
99 i = stream.read(); in parse()
117 readHeaders(stream, transaction, value); in parse()
124 i = stream.read(); in parse()
132 readChunk(stream, transaction); in parse()
139 final InputStream stream, final MsrpChunk.Builder transaction, in readHeaders() argument
[all …]
/packages/modules/Bluetooth/system/test/mock/
Dmock_frameworks_libaudio.cc32 AAudioStream* stream) { in AAudioStream_getAllowedCapturePolicy() argument
36 aaudio_content_type_t AAudioStream_getContentType(AAudioStream* stream) { in AAudioStream_getContentType() argument
40 aaudio_direction_t AAudioStream_getDirection(AAudioStream* stream) { in AAudioStream_getDirection() argument
44 aaudio_format_t AAudioStream_getFormat(AAudioStream* stream) { in AAudioStream_getFormat() argument
48 aaudio_input_preset_t AAudioStream_getInputPreset(AAudioStream* stream) { in AAudioStream_getInputPreset() argument
53 AAudioStream* stream) { in AAudioStream_getPerformanceMode() argument
70 aaudio_result_t AAudioStream_close(AAudioStream* stream) { in AAudioStream_close() argument
74 aaudio_result_t AAudioStream_getTimestamp(AAudioStream* stream, in AAudioStream_getTimestamp() argument
81 aaudio_result_t AAudioStream_read(AAudioStream* stream, void* buffer, in AAudioStream_read() argument
87 aaudio_result_t AAudioStream_release(AAudioStream* stream) { in AAudioStream_release() argument
[all …]
/packages/modules/Wifi/service/tests/wifitests/src/com/android/server/wifi/hotspot2/anqp/
DANQPParserTest.java55 ByteArrayOutputStream stream = new ByteArrayOutputStream(); in getVenueNamePayload() local
56 stream.write(new byte[VenueNameElement.VENUE_INFO_LENGTH]); in getVenueNamePayload()
57 stream.write(getI18NameListPayload(language, text)); in getVenueNamePayload()
58 return stream.toByteArray(); in getVenueNamePayload()
69 ByteArrayOutputStream stream = new ByteArrayOutputStream(); in getDomainNamePayload() local
72 stream.write((byte) nameBytes.length); in getDomainNamePayload()
73 stream.write(nameBytes); in getDomainNamePayload()
75 return stream.toByteArray(); in getDomainNamePayload()
88 ByteArrayOutputStream stream = new ByteArrayOutputStream(); in getRoamingConsortiumPayload() local
90 stream.write((byte) oisLength[i]); in getRoamingConsortiumPayload()
[all …]
DNAIRealmDataTestUtil.java87 ByteArrayOutputStream stream = new ByteArrayOutputStream(); in formatNAIRealmData() local
89 stream.write((byte) realmData.length); in formatNAIRealmData()
90 stream.write((byte) realmData.length >> 8); in formatNAIRealmData()
91 stream.write(realmData); in formatNAIRealmData()
92 return stream.toByteArray(); in formatNAIRealmData()
110 ByteArrayOutputStream stream = new ByteArrayOutputStream(); in getNAIRealmData() local
112 stream.write((byte) (utfEncoding ? NAIRealmData.NAI_ENCODING_UTF8_MASK : 0)); in getNAIRealmData()
113 stream.write((byte) realmStrData.length); in getNAIRealmData()
114 stream.write(realmStrData); in getNAIRealmData()
115 stream.write((byte) 1); // EAP Method count in getNAIRealmData()
[all …]
DVenueUrlElementTest.java58 private void appendVenue(ByteArrayOutputStream stream, int venueNumber, String url) in appendVenue() argument
62 stream.write((byte) length); in appendVenue()
63 stream.write((byte) venueNumber); in appendVenue()
64 stream.write(venueBytes); in appendVenue()
73 ByteArrayOutputStream stream = new ByteArrayOutputStream(); in getTestData() local
76 appendVenue(stream, entry.getKey(), entry.getValue().toString()); in getTestData()
78 return stream.toByteArray(); in getTestData()
87 ByteArrayOutputStream stream = new ByteArrayOutputStream(); in getTestData() local
88 appendVenue(stream, venueNumber, url); in getTestData()
89 return stream.toByteArray(); in getTestData()
[all …]
/packages/apps/TvSettings/Settings/src/com/android/tv/settings/system/development/audio/
DWavWriter.java47 DataOutputStream stream = new DataOutputStream( in writeToFile() local
49 writeFileHeader(stream, data.length); in writeToFile()
50 stream.write(data, 0, data.length); in writeToFile()
51 stream.close(); in writeToFile()
64 private static void writeFileHeader(DataOutputStream stream, int numBytes) throws IOException { in writeFileHeader() argument
66 stream.writeBytes("RIFF"); in writeFileHeader()
68 stream.write(toLittleEndianBytes(HEADER_SIZE + numBytes - 8)); in writeFileHeader()
70 stream.writeBytes("WAVE"); in writeFileHeader()
72 stream.writeBytes("fmt "); in writeFileHeader()
74 stream.write(toLittleEndianBytes(16), 0, 4); in writeFileHeader()
[all …]
/packages/apps/TvSettings/SettingsAPI/java/com/android/tv/settings/library/system/development/audio/
DWavWriter.java47 DataOutputStream stream = new DataOutputStream( in writeToFile() local
49 writeFileHeader(stream, data.length); in writeToFile()
50 stream.write(data, 0, data.length); in writeToFile()
51 stream.close(); in writeToFile()
64 private static void writeFileHeader(DataOutputStream stream, int numBytes) throws IOException { in writeFileHeader() argument
66 stream.writeBytes("RIFF"); in writeFileHeader()
68 stream.write(toLittleEndianBytes(HEADER_SIZE + numBytes - 8)); in writeFileHeader()
70 stream.writeBytes("WAVE"); in writeFileHeader()
72 stream.writeBytes("fmt "); in writeFileHeader()
74 stream.write(toLittleEndianBytes(16), 0, 4); in writeFileHeader()
[all …]
/packages/modules/Bluetooth/system/audio_bluetooth_hw/
Dstream_apis.cc200 static uint32_t out_get_sample_rate(const struct audio_stream* stream) { in out_get_sample_rate() argument
201 const auto* out = reinterpret_cast<const BluetoothStreamOut*>(stream); in out_get_sample_rate()
214 static int out_set_sample_rate(struct audio_stream* stream, uint32_t rate) { in out_set_sample_rate() argument
215 auto* out = reinterpret_cast<BluetoothStreamOut*>(stream); in out_set_sample_rate()
221 static size_t out_get_buffer_size(const struct audio_stream* stream) { in out_get_buffer_size() argument
222 const auto* out = reinterpret_cast<const BluetoothStreamOut*>(stream); in out_get_buffer_size()
231 const struct audio_stream* stream) { in out_get_channels() argument
232 const auto* out = reinterpret_cast<const BluetoothStreamOut*>(stream); in out_get_channels()
246 static audio_format_t out_get_format(const struct audio_stream* stream) { in out_get_format() argument
247 const auto* out = reinterpret_cast<const BluetoothStreamOut*>(stream); in out_get_format()
[all …]
/packages/modules/Bluetooth/system/audio_a2dp_hw/src/
Daudio_a2dp_hw.cc132 struct audio_stream_out stream; member
139 struct audio_stream_in stream; member
162 static size_t out_get_buffer_size(const struct audio_stream* stream);
163 static uint32_t out_get_latency(const struct audio_stream_out* stream);
926 static ssize_t out_write(struct audio_stream_out* stream, const void* buffer, in out_write() argument
928 struct a2dp_stream_out* out = (struct a2dp_stream_out*)stream; in out_write()
954 const size_t frames = bytes / audio_stream_out_frame_size(stream); in out_write()
982 const size_t frames = bytes / audio_stream_out_frame_size(stream); in out_write()
996 static uint32_t out_get_sample_rate(const struct audio_stream* stream) { in out_get_sample_rate() argument
997 struct a2dp_stream_out* out = (struct a2dp_stream_out*)stream; in out_get_sample_rate()
[all …]
/packages/modules/Bluetooth/system/audio_hearing_aid_hw/src/
Daudio_hearing_aid_hw.cc141 struct audio_stream_out stream; member
148 struct audio_stream_in stream; member
175 static size_t out_get_buffer_size(const struct audio_stream* stream);
903 static ssize_t out_write(struct audio_stream_out* stream, const void* buffer, in out_write() argument
905 struct ha_stream_out* out = (struct ha_stream_out*)stream; in out_write()
931 const size_t frames = bytes / audio_stream_out_frame_size(stream); in out_write()
959 const size_t frames = bytes / audio_stream_out_frame_size(stream); in out_write()
973 static uint32_t out_get_sample_rate(const struct audio_stream* stream) { in out_get_sample_rate() argument
974 struct ha_stream_out* out = (struct ha_stream_out*)stream; in out_get_sample_rate()
981 static int out_set_sample_rate(struct audio_stream* stream, uint32_t rate) { in out_set_sample_rate() argument
[all …]
/packages/modules/Bluetooth/system/btif/src/
Dbtif_avrcp_audio_track.cc40 AAudioStream* stream; member
60 void ErrorCallback(AAudioStream* stream, void* userdata, aaudio_result_t error);
64 AAudioStream* stream; in BtifAvrcpAudioErrorHandle() local
74 result = AAudioStreamBuilder_openStream(builder, &stream); in BtifAvrcpAudioErrorHandle()
80 trackHolder->stream = stream; in BtifAvrcpAudioErrorHandle()
82 if (trackHolder != NULL && trackHolder->stream != NULL) { in BtifAvrcpAudioErrorHandle()
84 AAudioStream_requestStart(trackHolder->stream); in BtifAvrcpAudioErrorHandle()
89 void ErrorCallback(AAudioStream* stream, in ErrorCallback() argument
103 AAudioStream* stream; in BtifAvrcpAudioTrackCreate() local
112 result = AAudioStreamBuilder_openStream(builder, &stream); in BtifAvrcpAudioTrackCreate()
[all …]
/packages/apps/SecureElement/src/com/android/se/security/gpac/
DBerTlv.java168 public static void encodeLength(int length, ByteArrayOutputStream stream) { in encodeLength() argument
171 stream.write(0x83); in encodeLength()
172 stream.write(((length & 0x00FF0000) >> 16)); in encodeLength()
173 stream.write(((length & 0x0000FF00) >> 8)); in encodeLength()
174 stream.write((length & 0x000000FF)); in encodeLength()
176 stream.write(0x82); in encodeLength()
177 stream.write(((length & 0x0000FF00) >> 8)); in encodeLength()
178 stream.write((length & 0x000000FF)); in encodeLength()
180 stream.write(0x81); in encodeLength()
181 stream.write((length & 0x000000FF)); in encodeLength()
[all …]
/packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/avrcpcontroller/bip/
DBipImagePropertiesTest.java130 InputStream stream = toUtf8Stream(xmlString); in testParsePropertiesSimple() local
131 BipImageProperties properties = new BipImageProperties(stream); in testParsePropertiesSimple()
165 InputStream stream = toUtf8Stream(xmlString); in testParsePropertiesRich() local
166 BipImageProperties properties = new BipImageProperties(stream); in testParsePropertiesRich()
191 InputStream stream = toUtf8Stream(xmlString); in testParseNoHandle() local
192 BipImageProperties properties = new BipImageProperties(stream); in testParseNoHandle()
218 InputStream stream = toUtf8Stream(xmlString); in testParseNoVersion() local
219 BipImageProperties properties = new BipImageProperties(stream); in testParseNoVersion()
244 InputStream stream = toUtf8Stream(xmlString); in testParseNoFriendlyName() local
245 BipImageProperties properties = new BipImageProperties(stream); in testParseNoFriendlyName()
[all …]
/packages/apps/Settings/src/com/android/settings/notification/
DAudioHelper.java63 public int getLastAudibleStreamVolume(int stream) { in getLastAudibleStreamVolume() argument
64 return mAudioManager.getLastAudibleStreamVolume(stream); in getLastAudibleStreamVolume()
67 public int getStreamVolume(int stream) { in getStreamVolume() argument
68 return mAudioManager.getStreamVolume(stream); in getStreamVolume()
71 public boolean setStreamVolume(int stream, int volume) { in setStreamVolume() argument
72 mAudioManager.setStreamVolume(stream, volume, 0); in setStreamVolume()
76 public int getMaxVolume(int stream) { in getMaxVolume() argument
77 return mAudioManager.getStreamMaxVolume(stream); in getMaxVolume()
80 public int getMinVolume(int stream) { in getMinVolume() argument
83 minVolume = mAudioManager.getStreamMinVolume(stream); in getMinVolume()
[all …]
/packages/modules/Bluetooth/system/hci/src/
Dpacket_fragmenter.cc100 uint8_t* stream = packet->data + packet->offset; in fragment_and_dispatch() local
105 STREAM_TO_UINT16(handle, stream); in fragment_and_dispatch()
113 stream = packet->data + packet->offset; in fragment_and_dispatch()
114 UINT16_TO_STREAM(stream, HCI_ISO_SET_COMPLETE_FLAG(handle)); in fragment_and_dispatch()
118 stream = packet->data + packet->offset; in fragment_and_dispatch()
119 STREAM_SKIP_UINT16(stream); in fragment_and_dispatch()
120 UINT16_TO_STREAM(stream, max_data_size); in fragment_and_dispatch()
130 stream = packet->data + packet->offset; in fragment_and_dispatch()
132 UINT16_TO_STREAM(stream, in fragment_and_dispatch()
135 UINT16_TO_STREAM(stream, in fragment_and_dispatch()
[all …]
/packages/apps/KeyChain/src/com/android/keychain/
DKeyChainStateStorage.java52 FileInputStream stream = null; in loadCredentialManagementApp() local
54 stream = file.openRead(); in loadCredentialManagementApp()
56 parser.setInput(stream, StandardCharsets.UTF_8.name()); in loadCredentialManagementApp()
69 if (stream != null) { in loadCredentialManagementApp()
70 stream.close(); in loadCredentialManagementApp()
81 FileOutputStream stream; in saveCredentialManagementApp() local
83 stream = file.startWrite(); in saveCredentialManagementApp()
90 out.setOutput(stream, StandardCharsets.UTF_8.name()); in saveCredentialManagementApp()
99 file.finishWrite(stream); in saveCredentialManagementApp()
100 stream.close(); in saveCredentialManagementApp()
[all …]
/packages/modules/Bluetooth/android/app/tests/unit/src/com/android/bluetooth/mapclient/
DEventReportTest.java56 ByteArrayInputStream stream = new ByteArrayInputStream(xml.toString().getBytes()); in fromStream() local
58 EventReport report = EventReport.fromStream(new DataInputStream(stream)); in fromStream()
74 ByteArrayInputStream stream = new ByteArrayInputStream(xml.toString().getBytes()); in fromStream_withInvalidXml_doesNotCrash_andReturnNull() local
76 EventReport report = EventReport.fromStream(new DataInputStream(stream)); in fromStream_withInvalidXml_doesNotCrash_andReturnNull()
99 ByteArrayInputStream stream = new ByteArrayInputStream(xml.toString().getBytes()); in fromStreamWithDateTime() local
101 EventReport report = EventReport.fromStream(new DataInputStream(stream)); in fromStreamWithDateTime()
116 InputStream stream = mock(InputStream.class); in fromStream_withIOException_doesNotCrash_andReturnNull() local
117 doThrow(new IOException()).when(stream).read(any()); in fromStream_withIOException_doesNotCrash_andReturnNull()
119 EventReport report = EventReport.fromStream(new DataInputStream(stream)); in fromStream_withIOException_doesNotCrash_andReturnNull()
130 ByteArrayInputStream stream = new ByteArrayInputStream(xml.toString().getBytes()); in fromStream_withIllegalArgumentException_doesNotCrash_andReturnNull() local
[all …]
/packages/services/Telephony/src/com/android/services/telephony/rcs/validator/
DOutgoingTransportStateValidator.java34 import java.util.stream.Collectors;
35 import java.util.stream.Stream;
84 mAllowedTags = allowedFeatureTags.stream().map(String::trim).map(String::toLowerCase) in open()
86 mDeniedTags = deniedFeatureTags.stream().map(String::trim).map(String::toLowerCase) in open()
99 mRestrictedFeatureTags = restrictedFeatureTags.stream().map(String::trim) in restrictFeatureTags()
139 return Stream.concat(mSipSessionTracker.getEarlyDialogs().stream(), in getAllowedCallIds()
140 mSipSessionTracker.getConfirmedDialogs().stream()).map(SipDialog::getCallId) in getAllowedCallIds()
169 boolean startsDialog = Arrays.stream(SipSessionTracker.SIP_REQUEST_DIALOG_START_METHODS) in verifyOpenMessage()
188 featureTags = featureTags.stream().map(String::toLowerCase).map(String::trim) in validateMessageFeatureTag()
190 long acceptedFeatureTagCount = featureTags.stream() in validateMessageFeatureTag()
[all …]
/packages/modules/Uwb/service/java/com/android/server/uwb/util/
DFileUtils.java38 FileInputStream stream = null; in readFromAtomicFile() local
40 stream = file.openRead(); in readFromAtomicFile()
42 int avail = stream.available(); in readFromAtomicFile()
45 int amt = stream.read(data, pos, data.length - pos); in readFromAtomicFile()
50 avail = stream.available(); in readFromAtomicFile()
58 if (stream != null) stream.close(); in readFromAtomicFile()
/packages/modules/Connectivity/bpf_progs/
Doffload.c129 const struct stream_bool stream,
191 if (!stream.down && (src32 == dst32) && (ip6->saddr.s6_addr32[1] == ip6->daddr.s6_addr32[1]))
204 if (is_ethernet) __builtin_memcpy(stream.down ? kd.dstMac : ku.dstMac, eth->h_dest, ETH_ALEN);
206 Tether6Value* v = stream.down ? bpf_tether_downstream6_map_lookup_elem(&kd)
212 uint32_t stat_and_limit_k = stream.down ? skb->ifindex : v->oif;
257 __sync_fetch_and_add(stream.down ? &stat_v->rxErrors : &stat_v->txErrors, 1);
269 __sync_fetch_and_add(stream.down ? &stat_v->rxErrors : &stat_v->txErrors, 1);
289 __sync_fetch_and_add(stream.down ? &stat_v->rxPackets : &stat_v->txPackets, packets);
290 __sync_fetch_and_add(stream.down ? &stat_v->rxBytes : &stat_v->txBytes, L3_bytes);
365 const struct stream_bool stream, const struct updatetime_bool updatetime, in do_forward4_bottom() argument
[all …]
Doffload@mainline.c129 const struct stream_bool stream,
191 if (!stream.down && (src32 == dst32) && (ip6->saddr.s6_addr32[1] == ip6->daddr.s6_addr32[1]))
204 if (is_ethernet) __builtin_memcpy(stream.down ? kd.dstMac : ku.dstMac, eth->h_dest, ETH_ALEN);
206 Tether6Value* v = stream.down ? bpf_tether_downstream6_map_lookup_elem(&kd)
212 uint32_t stat_and_limit_k = stream.down ? skb->ifindex : v->oif;
257 __sync_fetch_and_add(stream.down ? &stat_v->rxErrors : &stat_v->txErrors, 1);
269 __sync_fetch_and_add(stream.down ? &stat_v->rxErrors : &stat_v->txErrors, 1);
289 __sync_fetch_and_add(stream.down ? &stat_v->rxPackets : &stat_v->txPackets, packets);
290 __sync_fetch_and_add(stream.down ? &stat_v->rxBytes : &stat_v->txBytes, L3_bytes);
365 const struct stream_bool stream, const struct updatetime_bool updatetime, in do_forward4_bottom() argument
[all …]
/packages/modules/Bluetooth/system/bta/gatt/
Dbta_gattc_utils.cc802 std::stringstream stream; in bta_gatt_client_dump() local
805 stream << " ->conn_track (GATT_MAX_PHY_CHANNEL=" << GATT_MAX_PHY_CHANNEL in bta_gatt_client_dump()
811 stream << " address: " in bta_gatt_client_dump()
813 stream << "\n"; in bta_gatt_client_dump()
816 stream << " -- used: " << entry_count << "\n"; in bta_gatt_client_dump()
819 stream << " ->bg_track (BTA_GATTC_KNOWN_SR_MAX=" << BTA_GATTC_KNOWN_SR_MAX in bta_gatt_client_dump()
827 stream << " address: " << ADDRESS_TO_LOGGABLE_STR(p_bg_track->remote_bda) in bta_gatt_client_dump()
829 stream << "\n"; in bta_gatt_client_dump()
832 stream << " -- used: " << entry_count << "\n"; in bta_gatt_client_dump()
834 stream << " ->cl_rcb (BTA_GATTC_CL_MAX=" << BTA_GATTC_CL_MAX << ")\n"; in bta_gatt_client_dump()
[all …]

12345678910>>...60