| /third_party/curl/tests/server/ |
| H A D | sws.c | 96 #define RCMD_STREAM 2 /* told to stream */
178 /* 'stream' means to send a never-ending stream of data */
179 #define CMD_STREAM "stream"
263 FILE *stream; in parse_servercmd() local
266 stream = test2fopen(req->testno, logdir); in parse_servercmd()
270 if(!stream) { in parse_servercmd()
284 error = getpart(&orgcmd, &cmdsize, "reply", "servercmd", stream); in parse_servercmd()
285 fclose(stream); in parse_servercmd()
306 logmsg("instructed to stream"); in parse_servercmd()
1014 FILE *stream; send_doc() local
[all...] |
| /third_party/alsa-lib/src/pcm/ |
| H A D | pcm_rate.c | 366 if (pcm->stream == SND_PCM_STREAM_PLAYBACK) { in snd_pcm_rate_hw_params()
643 if (pcm->stream != SND_PCM_STREAM_PLAYBACK) in snd_pcm_rate_sync_hwptr0()
705 if (pcm->stream == SND_PCM_STREAM_PLAYBACK) { in snd_pcm_rate_delay()
1034 if (pcm->stream == SND_PCM_STREAM_PLAYBACK) { in snd_pcm_rate_mmap_commit()
1079 if (pcm->stream == SND_PCM_STREAM_CAPTURE) in snd_pcm_rate_avail_update()
1116 if (pcm->stream == SND_PCM_STREAM_PLAYBACK) { in snd_pcm_rate_poll_revents()
1129 if (pcm->stream == SND_PCM_STREAM_PLAYBACK) { in snd_pcm_rate_drain()
1201 if (pcm->stream == SND_PCM_STREAM_CAPTURE) in snd_pcm_rate_start()
1230 if (pcm->stream == SND_PCM_STREAM_PLAYBACK) { in snd_pcm_rate_status()
1238 if (pcm->stream in snd_pcm_rate_status()
1674 _snd_pcm_rate_open(snd_pcm_t **pcmp, const char *name, snd_config_t *root, snd_config_t *conf, snd_pcm_stream_t stream, int mode) _snd_pcm_rate_open() argument
[all...] |
| /third_party/node/deps/uv/src/win/ |
| H A D | pipe.c | 31 #include "stream-inl.h"
589 assert(handle->stream.conn.write_reqs_pending == 0); in uv__pipe_shutdown()
1113 handle->stream.serv.connection_cb = cb; in uv__pipe_listen()
1134 handle->stream.serv.connection_cb = cb; in uv__pipe_listen()
1548 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data()
1554 if (handle->stream.conn.write_reqs_pending == 0) { in uv__pipe_write_data()
1596 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data()
1629 handle->stream.conn.write_reqs_pending++; in uv__pipe_write_data()
2064 handle->stream.conn.write_reqs_pending--; in uv__process_pipe_write_req()
2068 assert(handle->stream in uv__process_pipe_write_req()
[all...] |
| H A D | tty.c | 40 #include "stream-inl.h"
2196 handle->stream.conn.write_reqs_pending++;
2218 if (handle->stream.conn.write_reqs_pending > 0)
2241 handle->stream.conn.write_reqs_pending--;
2242 if (handle->stream.conn.write_reqs_pending == 0)
2246 handle->stream.conn.shutdown_req);
2272 void uv__process_tty_shutdown_req(uv_loop_t* loop, uv_tty_t* stream, uv_shutdown_t* req) { argument
2273 assert(stream->stream.conn.write_reqs_pending == 0);
2276 stream
[all...] |
| /third_party/glslang/gtests/ |
| H A D | VkRelaxed.FromFile.cpp | 276 std::ostringstream stream; in TEST_P() local
277 outputResultToStream(&stream, result, controls); in TEST_P()
285 checkEqAndUpdateIfRequested(expectedOutput, stream.str(), expectedOutputFname, in TEST_P()
|
| /third_party/gn/src/base/ |
| H A D | logging.cc | 189 // writes the common header info to the stream
275 stream() << ": " << SystemErrorCodeToString(err_); in ~Win32ErrorLogMessage()
285 stream() << ": " << SystemErrorCodeToString(err_); in ~ErrnoLogMessage()
323 LogMessage(file, line, LOG_ERROR).stream() << "NOTREACHED() hit."; in LogErrorNotReached()
|
| /third_party/ffmpeg/tests/fate/ |
| H A D | cover-art.mak | 40 fate-cover-art-aiff-id3v2-remux: CMD = transcode flac $(TARGET_SAMPLES)/cover_art/cover_art.flac aiff "-map 0 -map 0:v -map 0:v -map 0:v -c:a pcm_s16be -c:v:0 copy -filter:v:1 scale -c:v:1 png -filter:v:2 scale -c:v:2 bmp -c:v:3 copy -write_id3v2 1 -metadata:g unknown_key=unknown_value -metadata compilation=foo -metadata:s:v:0 title=first -metadata:s:v:1 title=second -metadata:s:v:1 comment=Illustration -metadata:s:v:2 title=third -metadata:s:v:2 comment=Conductor -metadata:s:v:3 title=fourth -metadata:s:v:3 comment=Composer" "-map 0 -c copy -t 0.1" "-show_entries format_tags:stream_tags:stream_disposition=attached_pic:stream=index,codec_name"
47 fate-cover-art-mp3-id3v2-remux: CMD = transcode mp3 $(TARGET_SAMPLES)/exif/embedded_small.mp3 mp3 "-map 0 -map 0:v -map 0:v -c:a copy -filter:v:0 scale -filter:v:2 scale -c:v:0 bmp -c:v:1 copy -c:v:2 png -metadata:s:v:0 comment=Band/Orchestra" "-map 0 -c copy -t 0.1" "-show_entries stream_tags:stream_disposition=attached_pic:stream=index,codec_name"
58 fate-cover-art-flac-remux: CMD = transcode mov $(TARGET_SAMPLES)/lossless-audio/inside.m4a flac "-map 0 -map 1:v -map 1:v -af channelmap=channel_layout=FL+FC,aresample -c:a flac -multi_dim_quant 1 -c:v:0 copy -metadata:s:v:0 comment=Illustration -metadata:s:v:0 title=OpenMusic -filter:v:1 scale -c:v:1 png -metadata:s:v:1 title=landscape -c:v:2 copy -filter:v:3 scale -metadata:s:v:2 title=portrait -c:v:3 bmp -metadata:s:v:3 comment=Conductor -c:v:4 copy -t 0.4" "-map 0 -map 0:a -c:a:0 copy -c:v copy" "-show_entries format_tags:stream_tags:stream_disposition=attached_pic:stream=index,codec_name" "-f ogg -i $(TARGET_SAMPLES)/cover_art/ogg_vorbiscomment_cover.opus"
|
| /third_party/lzma/CPP/7zip/UI/Common/ |
| H A D | OpenArchive.h | 124 IInStream *stream;
member
138 stream(NULL),
in COpenOptions()
230 UString Path; // Path from root (including alt stream name, if alt stream)
274 // parts.Back() can contain alt stream name "nams:AltName"
282 // 1) if we use additional cache stream
310 Int64 Offset; // it's offset of start of archive inside stream that is open by Archive Handler
323 UInt64 ArcStreamOffset; // offset of stream that is open by Archive Handler
380 HRESULT CreateNewTailStream(CMyComPtr<IInStream> &stream);
|
| /third_party/node/lib/internal/ |
| H A D | encoding.js | 430 this[kUTF8FastPath] &&= !(options?.stream);
446 flags |= options.stream ? 0 : CONVERTER_FLAGS_FLUSH;
528 if (options !== null && options.stream) {
541 // If the very first result in the stream is a BOM, and we are not
|
| /third_party/node/lib/internal/readline/ |
| H A D | utils.js | 86 function* emitKeys(stream) {
371 stream.emit('keypress', escaped ? undefined : s, key);
374 stream.emit('keypress', s, key);
|
| /third_party/node/src/ |
| H A D | node_report_utils.cc | 254 writer->json_keyvalue("writeQueueSize", handle->stream.write_queue_size); in WalkHandle()
256 static_cast<bool>(uv_is_readable(&handle->stream))); in WalkHandle()
258 static_cast<bool>(uv_is_writable(&handle->stream))); in WalkHandle()
|
| /third_party/mesa3d/src/intel/tools/ |
| H A D | aubinator.c | 202 FILE *stream; member
250 return file->cursor < file->end || (file->stream && !feof(file->stream)); in aub_file_more_stuff()
|
| /third_party/ltp/testcases/network/stress/ns-tools/ |
| H A D | ns-tcpserver.c | 97 FILE *stream = stdout; /* stream where the usage is output */ in usage() local
100 stream = stderr; in usage()
102 fprintf(stream, "%s [OPTION]\n" in usage()
|
| H A D | ns-igmp_querier.c | 91 FILE *stream = stdout; /* stream where the usage is output */ in usage() local
94 stream = stderr; in usage()
96 fprintf(stream, "%s [OPTION]\n" in usage()
|
| H A D | ns-mcast_join.c | 97 FILE *stream = stdout; /* stream where the usage is output */ in usage() local
100 stream = stderr; in usage()
102 fprintf(stream, "%s [OPTION]\n" in usage()
|
| /third_party/mesa3d/src/gallium/tools/trace/ |
| H A D | model.py | 73 stream = StringIO()
74 formatter = format.Formatter(stream)
77 return stream.getvalue()
|
| /third_party/node/deps/uv/src/unix/ |
| H A D | internal.h | 230 /* stream */
231 void uv__stream_init(uv_loop_t* loop, uv_stream_t* stream,
234 void uv__stream_destroy(uv_stream_t* stream);
236 int uv__stream_try_select(uv_stream_t* stream, int* fd);
|
| /third_party/libphonenumber/metadata/src/main/java/com/google/i18n/phonenumbers/metadata/finitestatematcher/compiler/ |
| H A D | MatcherCompiler.java | 128 return dfa.successors(source).stream().sorted(ordering).collect(toImmutableSet()); in sortedOutputs()
146 return sortedOutputs(source).stream().collect(toImmutableMap(Function.identity(), getMask)); in getOutMap()
262 return getOutStates().stream().map(seqStart::get).collect(toImmutableSet()); in unorderedOutSequences()
|
| /third_party/libphonenumber/migrator/migrator-servlet/src/main/java/com/google/phonenumbers/ |
| H A D | ServletMain.java | 233 req.setAttribute("invalidUntouchedNumbers", report.getUntouchedEntries().stream() in handleFileMigration()
250 return entryList.stream().map(MigrationEntry::getOriginalNumber).collect(ImmutableList.toImmutableList()); in getMigrationEntryOutputList()
259 return resultList.stream().map(MigrationResult::toString).collect(ImmutableList.toImmutableList()); in getMigrationResultOutputList()
|
| /third_party/pulseaudio/src/pulse/ |
| H A D | internal.h | 26 #include <pulse/stream.h>
31 #include <pulse/ext-stream-restore.h>
256 pa_stream *stream; member
|
| /third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/d3d/ |
| H A D | HLSLCompiler.cpp | 224 std::ostringstream stream; in compileToBinary() local
225 stream << "#line 2 \"" << sourcePath << "\"\n\n" << hlsl; in compileToBinary()
226 std::string sourceText = stream.str(); in compileToBinary()
|
| /third_party/skia/third_party/externals/angle2/src/compiler/translator/ |
| H A D | Common.h | 233 // Initialize a new stream which must be imbued with the classic locale
237 T stream; in InitializeStream() local
238 stream.imbue(std::locale::classic()); in InitializeStream()
239 return stream; in InitializeStream()
|
| /third_party/skia/third_party/externals/spirv-tools/utils/vscode/src/lsp/protocol/ |
| H A D | log.go | 30 stream jsonrpc2.Stream
34 // LoggingStream returns a stream that does LSP protocol logging too
40 data, count, err := s.stream.Read(ctx)
49 count, err := s.stream.Write(ctx, data)
|
| /third_party/skia/third_party/externals/swiftshader/third_party/SPIRV-Tools/utils/vscode/src/lsp/protocol/ |
| H A D | log.go | 30 stream jsonrpc2.Stream
34 // LoggingStream returns a stream that does LSP protocol logging too
40 data, count, err := s.stream.Read(ctx)
49 count, err := s.stream.Write(ctx, data)
|
| /third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/java/com/google/sample/oboe/manualtest/ |
| H A D | AutoGlitchActivity.java | 33 private static final int SETUP_TIME_SECONDS = 4; // Time for the stream to settle.
187 // Give previous stream time to close and release resources. Avoid race conditions. in testConfiguration()
196 AudioStreamBase stream = mAudioOutTester.getCurrentAudioStream(); in testConfiguration()
197 int sizeFrames = stream.getBufferCapacityInFrames() / 2; in testConfiguration()
198 stream.setBufferSizeInFrames(sizeFrames); in testConfiguration()
|