| /external/lzma/C/ |
| 7zStream.c | 1 /* 7zStream.c -- 7z Stream functions
8 SRes SeqInStream_Read2(ISeqInStream *stream, void *buf, size_t size, SRes errorType)
13 RINOK(stream->Read(stream, buf, &processed));
22 SRes SeqInStream_Read(ISeqInStream *stream, void *buf, size_t size)
24 return SeqInStream_Read2(stream, buf, size, SZ_ERROR_INPUT_EOF);
27 SRes SeqInStream_ReadByte(ISeqInStream *stream, Byte *buf)
30 RINOK(stream->Read(stream, buf, &processed));
34 SRes LookInStream_SeekTo(ILookInStream *stream, UInt64 offset)
[all...] |
| /external/chromium_org/chrome/test/ext_auto/auto_provider/ |
| connection_handler.js | 6 // stream, finding and executing appropriate extension API method.
13 // Stream delegate callback.
14 onStreamError: function(stream) {
15 this.unregisterListeners_(stream);
18 // Stream delegate callback.
19 onStreamTerminated: function(stream) {
20 this.unregisterListeners_(stream);
23 // Pairs event |listenerMethod| with a given |stream|.
24 registerListener_: function(stream, eventName, eventObject,
26 if (!this.eventListener_[stream.socketId_]
[all...] |
| /external/chromium_org/chrome/browser/metrics/ |
| compression_utils.cc | 33 z_stream stream; local
35 stream.next_in = bit_cast<Bytef*>(source);
36 stream.avail_in = static_cast<uInt>(source_length);
37 stream.next_out = dest;
38 stream.avail_out = static_cast<uInt>(*dest_length);
39 if (static_cast<uLong>(stream.avail_out) != *dest_length)
42 stream.zalloc = static_cast<alloc_func>(0);
43 stream.zfree = static_cast<free_func>(0);
44 stream.opaque = static_cast<voidpf>(0);
48 int err = deflateInit2_(&stream,
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/media/base/ |
| rtpdump_unittest.cc | 78 talk_base::MemoryStream stream; local
79 RtpDumpWriter writer(&stream);
82 // Write a RTP packet to the stream, which is a valid RTP dump. Next, we will
85 stream.Rewind();
86 reader.reset(new RtpDumpReader(&stream));
90 stream.Rewind();
93 stream.WriteAll(new_line, strlen(new_line), NULL, NULL));
94 stream.Rewind();
95 reader.reset(new RtpDumpReader(&stream));
99 stream.Rewind()
119 talk_base::MemoryStream stream; local
157 talk_base::MemoryStream stream; local
179 talk_base::MemoryStream stream; local
208 talk_base::MemoryStream stream; local
234 talk_base::MemoryStream stream; local
245 talk_base::MemoryStream stream; local
256 talk_base::MemoryStream stream; local
278 talk_base::MemoryStream stream; local
[all...] |
| /external/chromium_org/third_party/skia/include/pdf/ |
| SkPDFDocument.h | 34 kFavorSpeedOverSize_Flags = 0x01, //!< Don't compress the stream, but
36 // the compressed stream.
46 /** Output the PDF to the passed stream. It is an error to call this (it
47 * will return false and not modify stream) if no pages have been added
51 * @param stream The writable output stream to send the PDF to.
53 SK_API bool emitPDF(SkWStream* stream);
89 /** Output the PDF header to the passed stream.
90 * @param stream The writable output stream to send the header to
[all...] |
| /external/chromium_org/third_party/zlib/ |
| uncompr.c | 30 z_stream stream; local
33 stream.next_in = (Bytef*)source;
34 stream.avail_in = (uInt)sourceLen;
36 if ((uLong)stream.avail_in != sourceLen) return Z_BUF_ERROR;
38 stream.next_out = dest;
39 stream.avail_out = (uInt)*destLen;
40 if ((uLong)stream.avail_out != *destLen) return Z_BUF_ERROR;
42 stream.zalloc = (alloc_func)0;
43 stream.zfree = (free_func)0;
45 err = inflateInit(&stream);
[all...] |
| /external/qemu/distrib/zlib-1.2.3/ |
| uncompr.c | 32 z_stream stream; local
35 stream.next_in = (Bytef*)source;
36 stream.avail_in = (uInt)sourceLen;
38 if ((uLong)stream.avail_in != sourceLen) return Z_BUF_ERROR;
40 stream.next_out = dest;
41 stream.avail_out = (uInt)*destLen;
42 if ((uLong)stream.avail_out != *destLen) return Z_BUF_ERROR;
44 stream.zalloc = (alloc_func)0;
45 stream.zfree = (free_func)0;
47 err = inflateInit(&stream);
[all...] |
| /external/skia/include/pdf/ |
| SkPDFDocument.h | 34 kFavorSpeedOverSize_Flags = 0x01, //!< Don't compress the stream, but
36 // the compressed stream.
46 /** Output the PDF to the passed stream. It is an error to call this (it
47 * will return false and not modify stream) if no pages have been added
51 * @param stream The writable output stream to send the PDF to.
53 SK_API bool emitPDF(SkWStream* stream);
89 /** Output the PDF header to the passed stream.
90 * @param stream The writable output stream to send the header to
[all...] |
| /external/zlib/src/ |
| uncompr.c | 30 z_stream stream; local
33 stream.next_in = (z_const Bytef *)source;
34 stream.avail_in = (uInt)sourceLen;
36 if ((uLong)stream.avail_in != sourceLen) return Z_BUF_ERROR;
38 stream.next_out = dest;
39 stream.avail_out = (uInt)*destLen;
40 if ((uLong)stream.avail_out != *destLen) return Z_BUF_ERROR;
42 stream.zalloc = (alloc_func)0;
43 stream.zfree = (free_func)0;
45 err = inflateInit(&stream);
[all...] |
| /external/guava/guava/src/com/google/common/collect/ |
| Serialization.java | 49 static int readCount(ObjectInputStream stream) throws IOException {
50 return stream.readInt();
54 * Stores the contents of a map in an output stream, as part of serialization.
61 static <K, V> void writeMap(Map<K, V> map, ObjectOutputStream stream)
63 stream.writeInt(map.size());
65 stream.writeObject(entry.getKey());
66 stream.writeObject(entry.getValue());
71 * Populates a map by reading an input stream, as part of deserialization.
74 static <K, V> void populateMap(Map<K, V> map, ObjectInputStream stream)
76 int size = stream.readInt()
[all...] |
| /external/srtp/googlepatches/ |
| google-9-rdbx-leak-plug.patch | 9 + * Uninitializes and Deallocates a stream.
12 +srtp_stream_uninit_and_dealloc(srtp_stream_t stream,
98 /* allocate ekt data associated with stream */
129 -srtp_stream_dealloc(srtp_t session, srtp_stream_ctx_t *stream) {
130 +srtp_stream_dealloc(srtp_stream_ctx_t *stream,
138 @@ -178,41 +174,29 @@ srtp_stream_dealloc(srtp_t session, srtp_stream_ctx_t *stream) {
143 - && stream->rtp_cipher == session->stream_template->rtp_cipher) {
146 + if (!stream_template || stream->rtp_cipher != stream_template->rtp_cipher) {
147 status = cipher_dealloc(stream->rtp_cipher);
154 - && stream->rtp_auth == session->stream_template->rtp_auth)
[all...] |
| /external/chromium_org/net/spdy/ |
| spdy_stream_unittest.cc | 151 base::WeakPtr<SpdyStream> stream = local
154 ASSERT_TRUE(stream.get() != NULL);
156 StreamDelegateSendImmediate delegate(stream, kPostBodyStringPiece);
157 stream->SetDelegate(&delegate);
159 EXPECT_FALSE(stream->HasUrlFromHeaders());
164 stream->SendRequestHeaders(headers.Pass(), MORE_DATA_TO_SEND));
165 EXPECT_TRUE(stream->HasUrlFromHeaders());
166 EXPECT_EQ(kStreamUrl, stream->GetUrlFromHeaders().spec());
193 // Conjure up a stream.
194 SpdyStream stream(SPDY_PUSH_STREAM
264 base::WeakPtr<SpdyStream> stream = local
348 base::WeakPtr<SpdyStream> stream = local
411 base::WeakPtr<SpdyStream> stream = local
471 base::WeakPtr<SpdyStream> stream = local
529 base::WeakPtr<SpdyStream> stream = local
604 base::WeakPtr<SpdyStream> stream = local
684 base::WeakPtr<SpdyStream> stream = local
754 base::WeakPtr<SpdyStream> stream = local
844 base::WeakPtr<SpdyStream> stream = local
936 base::WeakPtr<SpdyStream> stream = local
[all...] |
| spdy_write_queue.h | 35 // priority associated with the given stream, which may be NULL if
36 // the frame producer is not associated with a stream. If |stream|
42 const base::WeakPtr<SpdyStream>& stream);
45 // enqueued the earliest and its associated stream. Returns true and
46 // fills in |frame_type|, |frame_producer|, and |stream| if
50 base::WeakPtr<SpdyStream>* stream);
52 // Removes all pending writes for the given stream, which must be
54 void RemovePendingWritesForStream(const base::WeakPtr<SpdyStream>& stream);
57 // and streams with no stream id
70 base::WeakPtr<SpdyStream> stream; member in struct:net::SpdyWriteQueue::PendingWrite
[all...] |
| /external/chromium_org/content/browser/streams/ |
| stream.cc | 5 #include "content/browser/streams/stream.h"
23 Stream::Stream(StreamRegistry* registry,
42 writer_->RegisterCallback(base::Bind(&Stream::OnSpaceAvailable,
44 reader_->RegisterCallback(base::Bind(&Stream::OnDataAvailable,
50 Stream::~Stream() {
53 bool Stream::SetReadObserver(StreamReadObserver* observer) {
60 void Stream::RemoveReadObserver(StreamReadObserver* observer) {
65 void Stream::RemoveWriteObserver(StreamWriteObserver* observer)
[all...] |
| /external/lzma/CPP/7zip/Compress/ |
| RangeCoder.h | 23 COutBuffer Stream;
24 bool Create(UInt32 bufferSize) { return Stream.Create(bufferSize); }
26 void SetStream(ISequentialOutStream *stream) { Stream.SetStream(stream); }
29 Stream.Init();
43 HRESULT FlushStream() { return Stream.Flush(); }
45 void ReleaseStream() { Stream.ReleaseStream(); }
65 Stream.WriteByte((Byte)(temp + (Byte)(Low >> 32)));
106 UInt64 GetProcessedSize() { return Stream.GetProcessedSize() + _cacheSize + 4; }
[all...] |
| /frameworks/av/media/libstagefright/codecs/avc/enc/src/ |
| bitstream_io.cpp | 45 AVCEnc_Status BitstreamEncInit(AVCEncBitstream *stream, uint8 *buffer, int buf_size,
48 if (stream == NULL || buffer == NULL || buf_size <= 0)
53 stream->bitstreamBuffer = buffer;
55 stream->buf_size = buf_size;
57 stream->write_pos = 0;
59 stream->count_zeros = 0;
61 stream->current_word = 0;
63 stream->bit_left = WORD_SIZE;
65 stream->overrunBuffer = overrunBuffer;
67 stream->oBSize = oBSize
[all...] |
| /development/ndk/platforms/android-14/samples/native-media/ |
| README.txt | 1 This sample app requires an MPEG-2 Transport Stream file to be
8 Any actual stream must be created according to the MPEG-2 specification.
|
| /external/antlr/antlr-3.4/runtime/Python/tests/ |
| t029synpredgate.py | 12 stream = antlr3.StringStream('ac')
13 lexer = self.getLexer(stream)
|
| /external/lzma/CPP/7zip/Common/ |
| CWrappers.h | 20 ISequentialInStream *Stream;
22 CSeqInStreamWrap(ISequentialInStream *stream);
28 IInStream *Stream;
30 CSeekInStreamWrap(IInStream *stream);
36 ISequentialOutStream *Stream;
39 CSeqOutStreamWrap(ISequentialOutStream *stream);
51 ISequentialInStream *Stream;
84 ISequentialOutStream *Stream;
|
| StreamUtils.cpp | 9 HRESULT ReadStream(ISequentialInStream *stream, void *data, size_t *processedSize)
17 HRESULT res = stream->Read(data, curSize, &processedSizeLoc);
28 HRESULT ReadStream_FALSE(ISequentialInStream *stream, void *data, size_t size)
31 RINOK(ReadStream(stream, data, &processedSize));
35 HRESULT ReadStream_FAIL(ISequentialInStream *stream, void *data, size_t size)
38 RINOK(ReadStream(stream, data, &processedSize));
42 HRESULT WriteStream(ISequentialOutStream *stream, const void *data, size_t size)
48 HRESULT res = stream->Write(data, curSize, &processedSizeLoc);
|
| /external/robolectric/src/test/java/com/xtremelabs/robolectric/util/ |
| StringsTest.java | 13 InputStream stream = new ByteArrayInputStream("some random string".getBytes()); local
14 assertEquals("some random string", Strings.fromStream(stream));
|
| /external/chromium_org/content/test/plugin/ |
| plugin_execute_stream_javascript.h | 13 // This class tests executes the JavaScript given in the stream URL.
22 virtual NPError NewStream(NPMIMEType type, NPStream* stream,
24 virtual int32 WriteReady(NPStream *stream) OVERRIDE;
25 virtual int32 Write(NPStream *stream, int32 offset, int32 len,
27 virtual NPError DestroyStream(NPStream *stream, NPError reason) OVERRIDE;
|
| /external/chromium_org/native_client_sdk/src/examples/api/input_event/ |
| custom_events.cc | 52 std::ostringstream stream; local
53 stream << "Key event:"
57 return stream.str();
61 std::ostringstream stream; local
62 stream << "Mouse event:"
68 return stream.str();
72 std::ostringstream stream; local
73 stream << "Wheel event:"
79 return stream.str();
93 std::ostringstream stream; local
112 std::ostringstream stream; local
137 std::ostringstream stream; local
[all...] |
| /external/chromium_org/third_party/freetype/src/truetype/ |
| ttpload.h | 32 FT_Stream stream );
44 FT_Stream stream );
48 FT_Stream stream );
53 FT_Stream stream );
58 FT_Stream stream );
|
| /external/freetype/src/truetype/ |
| ttpload.h | 32 FT_Stream stream );
44 FT_Stream stream );
48 FT_Stream stream );
53 FT_Stream stream );
58 FT_Stream stream );
|
