| /external/chromium_org/content/browser/fileapi/ |
| fileapi_message_filter_unittest.cc | 209 scoped_refptr<Stream> stream = stream_registry->GetStream(kUrl); local
210 // Stream becomes available for read right after registration.
211 ASSERT_FALSE(stream.get() == NULL);
212 EXPECT_EQ(Stream::STREAM_EMPTY,
213 stream->ReadRawData(buffer.get(), kBufferSize, &bytes_read));
215 stream = NULL;
223 stream = stream_registry->GetStream(kUrl);
224 ASSERT_FALSE(stream.get() == NULL);
225 EXPECT_EQ(Stream::STREAM_EMPTY
265 scoped_refptr<Stream> stream = stream_registry->GetStream(kUrl); local
313 scoped_refptr<Stream> stream = stream_registry->GetStream(kUrl); local
[all...] |
| /external/chromium/net/http/ |
| http_stream.h | 7 // provides an abstraction for both a basic http stream as well as http
38 // Initialize stream. Must be called before calling SendRequest().
80 // Closes the stream.
81 // |not_reusable| indicates if the stream can be used for further requests.
82 // In the case of HTTP, where we re-use the byte-stream (e.g. the connection)
84 // underlying stream is never reused, it has no effect.
86 // into the stream implementation itself so that the caller
91 // Returns a new (not initialized) stream using the same underlying
92 // connection and invalidates the old stream - no further methods should be
93 // called on the old stream. The caller should ensure that the response bod
[all...] |
| /external/chromium/third_party/libjingle/source/talk/base/ |
| httpbase.h | 42 // HttpParser - Parses an HTTP stream provided via Process and end_of_input, and
104 // stream, and then call send() or recv() to initiate sending or receiving one
106 // moving data from the HTTP stream to the HttpData object and vice versa.
107 // However, it can also operate in stream mode, in which case the user of the
108 // stream interface drives I/O via calls to Read().
120 bool attach(StreamInterface* stream);
121 StreamInterface* stream() { return http_stream_; } function in class:talk_base::HttpBase
134 // Obtaining this stream puts HttpBase into stream mode until the stream
[all...] |
| /external/chromium_org/ppapi/examples/video_effects/ |
| video_effects.html | 36 <td>Local Media Stream</td>
37 <td>Local Media Stream After Effect</td>
38 <td>Remote Media Stream</td>
54 var attachMediaStream = function(element, stream) {
55 element.src = webkitURL.createObjectURL(stream);
80 function gotStream(stream){
81 trace("Received local stream");
82 // Call the polyfill wrapper to attach the media stream to this element.
83 attachMediaStream(vidlocal, stream);
84 localstream = stream;
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| httpbase.h | 42 // HttpParser - Parses an HTTP stream provided via Process and end_of_input, and
104 // stream, and then call send() or recv() to initiate sending or receiving one
106 // moving data from the HTTP stream to the HttpData object and vice versa.
107 // However, it can also operate in stream mode, in which case the user of the
108 // stream interface drives I/O via calls to Read().
120 bool attach(StreamInterface* stream);
121 StreamInterface* stream() { return http_stream_; } function in class:talk_base::HttpBase
134 // Obtaining this stream puts HttpBase into stream mode until the stream
[all...] |
| /external/chromium_org/third_party/skia/src/utils/ |
| SkParsePath.cpp | 190 static void write_scalar(SkWStream* stream, SkScalar value) {
203 stream->write(buffer, stop - buffer);
206 static void append_scalars(SkWStream* stream, char verb, const SkScalar data[],
208 stream->write(&verb, 1);
209 write_scalar(stream, data[0]);
211 stream->write(" ", 1);
212 write_scalar(stream, data[i]);
217 SkDynamicMemoryWStream stream; local
228 append_scalars(&stream, 'M', &pts[0].fX, 2);
231 append_scalars(&stream, 'L', &pts[1].fX, 2)
[all...] |
| /external/skia/src/utils/ |
| SkParsePath.cpp | 190 static void write_scalar(SkWStream* stream, SkScalar value) {
203 stream->write(buffer, stop - buffer);
206 static void append_scalars(SkWStream* stream, char verb, const SkScalar data[],
208 stream->write(&verb, 1);
209 write_scalar(stream, data[0]);
211 stream->write(" ", 1);
212 write_scalar(stream, data[i]);
217 SkDynamicMemoryWStream stream; local
228 append_scalars(&stream, 'M', &pts[0].fX, 2);
231 append_scalars(&stream, 'L', &pts[1].fX, 2)
[all...] |
| /external/smack/src/org/jivesoftware/smack/ |
| PacketWriter.java | 163 // Open the stream.
192 // Close the stream.
194 writer.write("</stream:stream>");
224 * Sends to the server a new stream element. This operation may be requested several times
231 StringBuilder stream = new StringBuilder(); local
232 stream.append("<stream:stream");
233 stream.append(" to=\"").append(connection.getServiceName()).append("\"")
[all...] |
| /libcore/luni/src/main/java/java/io/ |
| SequenceInputStream.java | 26 * the first stream until it ends, then the next stream is used, until the last
27 * stream returns end of file.
36 * The current input stream.
45 * the first stream to get bytes from.
47 * the second stream to get bytes from.
63 * Enumeration {@code e} as the stream sequence. The instances returned by
90 * Closes all streams in this sequence of input stream.
125 * stream first; if the end of this stream has been reached, it reads fro
[all...] |
| ByteArrayOutputStream.java | 24 * (internal) byte array. As bytes are written to this stream, the byte array
70 * Closes this stream. This releases system resources used for this stream.
73 * if an error occurs while attempting to close this stream.
78 * Although the spec claims "A closed stream cannot perform output
97 * Resets this stream to the beginning of the underlying byte array. All
99 * stream.
106 * Returns the total number of bytes written to this stream so far.
108 * @return the number of bytes written to this stream.
119 * @return this stream's current contents as a byte array
[all...] |
| /libcore/luni/src/main/java/java/util/jar/ |
| JarInputStream.java | 29 * The input stream from which the JAR file to be read may be fetched. It is
51 * Constructs a new {@code JarInputStream} from an input stream.
53 * @param stream
54 * the input stream containing the JAR file.
58 * If an error occurs reading entries from the input stream.
61 public JarInputStream(InputStream stream, boolean verify) throws IOException {
62 super(stream);
98 * Constructs a new {@code JarInputStream} from an input stream.
100 * @param stream
101 * the input stream containing the JAR file
[all...] |
| /libcore/luni/src/main/java/java/util/zip/ |
| DeflaterInputStream.java | 29 * underlying stream.
44 * uncompressed data, and this stream will be a source of compressed data.
55 * uncompressed data, and this stream will be a source of compressed data.
67 * uncompressed data, and this stream will be a source of compressed data.
88 * Closes the underlying input stream and discards any remaining uncompressed
99 * Reads a byte from the compressed input stream. The result will be a byte of compressed
100 * data corresponding to an uncompressed byte or bytes read from the underlying stream.
102 * @return the byte or -1 if the end of the stream has been reached.
110 * data corresponding to an uncompressed byte or bytes read from the underlying stream.
112 * stream has been reached
[all...] |
| /external/chromium_org/content/child/npapi/ |
| plugin_instance.cc | 91 PluginStreamUrl* stream = new PluginStreamUrl( local
94 AddStream(stream);
95 return stream;
98 void PluginInstance::AddStream(PluginStream* stream) {
99 open_streams_.push_back(make_scoped_refptr(stream));
102 void PluginInstance::RemoveStream(PluginStream* stream) {
109 if (stream_index->get() == stream) {
116 bool PluginInstance::IsValidStream(const NPStream* stream) {
120 if ((*stream_index)->stream() == stream)
386 PluginStringStream *stream = local
[all...] |
| /external/chromium_org/third_party/WebKit/Source/devtools/front_end/cm/ |
| javascript.js | 58 function chain(stream, state, f) {
60 return f(stream, state);
63 function nextUntilUnescaped(stream, end) {
65 while ((next = stream.next()) != null) {
81 function jsTokenBase(stream, state) {
82 var ch = stream.next();
84 return chain(stream, state, jsTokenString(ch));
87 else if (ch == "0" && stream.eat(/x/i)) {
88 stream.eatWhile(/[\da-f]/i);
91 else if (/\d/.test(ch) || ch == "-" && stream.eat(/\d/))
[all...] |
| /external/antlr/antlr-3.4/runtime/JavaScript/src/org/antlr/runtime/ |
| ANTLRStringStream.js | 2 * A stream of characters created from a JavaScript string that in turn gets
6 * @param {String} data the string from which this stream will be created.
10 * Location in the stream.
11 * Ranges from 0 to (stream length - 1).
41 * An Array of objects that tracks the stream state
43 * move through the input stream. Indexed from 1..markDepth.
65 * The number of characters in the stream.
77 * Reset the stream so that it's in the same state it was
89 * Consume the next character of data in the stream.
109 * you fell off either end of the stream
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/media/base/ |
| rtpdataengine.cc | 172 bool RtpDataMediaChannel::AddSendStream(const StreamParams& stream) {
173 if (!stream.has_ssrcs()) {
178 if (GetStreamBySsrc(send_streams_, stream.first_ssrc(), &found_stream)) {
179 LOG(LS_WARNING) << "Not adding data send stream '" << stream.id
180 << "' with ssrc=" << stream.first_ssrc()
181 << " because stream already exists.";
185 send_streams_.push_back(stream);
186 // TODO(pthatcher): This should be per-stream, not per-ssrc.
187 // And we should probably allow more than one per stream
[all...] |
| /external/libvpx/libvpx/nestegg/include/nestegg/ |
| nestegg.h | 72 #define NESTEGG_SEEK_SET 0 /**< Seek offset relative to beginning of stream. */
73 #define NESTEGG_SEEK_CUR 1 /**< Seek offset relative to current position in stream. */
74 #define NESTEGG_SEEK_END 2 /**< Seek offset relative to end of stream. */
82 typedef struct nestegg nestegg; /**< Opaque handle referencing the stream state. */
92 @retval 0 End of stream.
97 @param offset Offset within the stream to seek to.
107 @returns Current position within the stream.
138 read forward in the stream processing all elements until the first
151 /** Query the duration of the media stream in nanoseconds.
152 @param context Stream context initialized by #nestegg_init
[all...] |
| /bionic/libc/bionic/ |
| wchar.cpp | 41 int fwprintf(FILE* stream, const wchar_t* format, ...) {
44 int result = vfwprintf(stream, format, args);
69 int vfwprintf(FILE* /*stream*/, const wchar_t* /*format*/, va_list /*arg*/) {
79 int fwscanf(FILE* /*stream*/, const wchar_t* /*format*/, ... ) {
127 wint_t fgetwc(FILE* stream) {
128 return static_cast<wint_t>(fgetc(stream));
131 wchar_t* fgetws(wchar_t* ws, int n, FILE* stream) {
132 return reinterpret_cast<wchar_t*>(fgets(reinterpret_cast<char*>(ws), n, stream));
135 wint_t fputwc(wchar_t wc, FILE* stream) {
136 return static_cast<wint_t>(fputc(static_cast<char>(wc), stream));
[all...] |
| /external/chromium_org/third_party/freetype/src/sfnt/ |
| ttload.c | 111 /* Looks for a TrueType table by name, then seek a stream to it. */
118 /* stream :: The stream to seek when the table is found. */
129 FT_Stream stream,
160 /* - errors (except errors returned by stream handling) */
171 FT_Stream stream )
211 if ( table.Offset + table.Length > stream->size )
308 /* stream :: The input stream. */
317 /* The stream cursor must be at the beginning of the font directory. *
472 FT_Stream stream; local
[all...] |
| /external/freetype/src/sfnt/ |
| ttload.c | 110 /* Looks for a TrueType table by name, then seek a stream to it. */
117 /* stream :: The stream to seek when the table is found. */
128 FT_Stream stream,
159 /* - errors (except errors returned by stream handling) */
170 FT_Stream stream )
210 if ( table.Offset + table.Length > stream->size )
307 /* stream :: The input stream. */
316 /* The stream cursor must be at the beginning of the font directory. *
474 FT_Stream stream; local
[all...] |
| /external/chromium_org/v8/src/ |
| lithium.cc | 52 void LOperand::PrintTo(StringStream* stream) {
56 stream->Add("(0)");
60 stream->Add("v%d", unalloc->virtual_register());
62 stream->Add("(=%dS)", unalloc->fixed_slot_index());
72 stream->Add("(=%s)", register_name);
79 stream->Add("(=%s)", double_register_name);
83 stream->Add("(R)");
86 stream->Add("(WR)");
89 stream->Add("(1)");
92 stream->Add("(-)")
[all...] |
| /device/lge/mako/camera/QCamera/stack/mm-camera-test/src/ |
| mm_qcamera_preview.c | 221 CDBG_ERROR("%s:stream on preview err=%d\n", __func__, rc);
423 if (pme->stream[i].id == stream_id) {
424 CDBG("Allocate Memory for Stream %d",i);
509 if (pme->stream[i].id == stream_id) {
510 CDBG("Allocate Memory for Stream %d",i);
657 pme->stream[MM_CAMERA_PREVIEW].id = pme->cam->ops->add_stream(pme->cam->camera_handle,pme->ch_id,
661 if (!pme->stream[MM_CAMERA_PREVIEW].id) {
662 CDBG_ERROR("%s:Add stream preview error =%d\n", __func__, rc);
667 CDBG("%s :Add stream is successfull stream ID = %d",__func__,pme->stream[MM_CAMERA_PREVIEW].id)
691 int stream[2]; local
714 int stream[3]; local
778 int stream[3]; local
912 int stream[2]; local
939 int stream[2]; local
[all...] |
| /external/v8/src/ia32/ |
| lithium-ia32.cc | 94 void LInstruction::PrintTo(StringStream* stream) {
95 stream->Add("%s ", this->Mnemonic());
97 PrintOutputOperandTo(stream);
99 PrintDataTo(stream);
102 stream->Add(" ");
103 environment()->PrintTo(stream);
107 stream->Add(" ");
108 pointer_map()->PrintTo(stream);
113 void LInstruction::PrintDataTo(StringStream* stream) {
114 stream->Add("= ")
[all...] |
| /frameworks/av/services/camera/libcameraservice/device2/ |
| Camera2Device.cpp | 247 sp<StreamAdapter> stream = new StreamAdapter(mHal2Device); local
249 res = stream->connectToDevice(consumer, width, height, format, size);
251 ALOGE("%s: Camera %d: Unable to create stream (%d x %d, format %x):"
257 *id = stream->getId();
259 mStreams.push_back(stream);
278 ALOGE("%s: Camera %d: Output stream %d doesn't exist; can't create "
279 "reprocess stream from it!", __FUNCTION__, mId, outputId);
283 sp<ReprocessStreamAdapter> stream = new ReprocessStreamAdapter(mHal2Device); local
285 res = stream->connectToDevice((*streamI));
287 ALOGE("%s: Camera %d: Unable to create reprocessing stream from "
1240 StreamAdapter* stream = local
1267 StreamAdapter *stream = local
1302 StreamAdapter *stream = local
1474 ReprocessStreamAdapter* stream = local
1505 ReprocessStreamAdapter *stream = local
[all...] |
| /external/llvm/docs/tutorial/ |
| OCamlLangImpl2.rst | 114 The error handling routines make use of the builtin ``Stream.Failure``
115 and ``Stream.Error``s. ``Stream.Failure`` is raised when the parser is
117 ``Stream.Error`` is raised when the first token matches, but the rest do
167 1) It shows how we use the ``Stream.Error`` exception. When called, this
174 the ``??`` does not match, then ``Stream.Error "parse error"`` will be
195 | [< 'Token.Ident id; stream >] ->
197 | [< e=parse_expr; stream >] ->
201 end stream
214 parse_ident id stream
[all...] |
