Found 41328 results in 4188 files, showing top 50 files (show more).
github.com/llvm-mirror/llvm:tools/llvm-pdbutil/llvm-pdbutil.cpp: [ master, ]
731:     Stream("stream", cl::Required,
641: cl::opt<bool> StreamMetadata(
645: cl::opt<bool> StreamDirectory(
649: cl::opt<bool> PdbStream("pdb-stream",
656: cl::opt<bool> DbiStream("dbi-stream",
660: cl::opt<bool> TpiStream("tpi-stream",
664: cl::opt<bool> IpiStream("ipi-stream",
668: cl::opt<bool> PublicsStream("publics-stream",
1356: static void exportStream() {
387:     DumpStreamData("stream-data", cl::CommaSeparated, cl::ZeroOrMore,
454: cl::opt<bool> DumpStreams("streams",
457: cl::opt<bool> DumpStreamBlocks(
591: cl::opt<bool> DumpNamedStreams("named-streams",
368: cl::OptionCategory DbiBytes("Dbi Stream Options");
369: cl::OptionCategory PdbBytes("PDB Stream Options");
650:                         cl::desc("Dump the PDB Stream (Stream 1)"),
657:                         cl::desc("Dump the DBI Stream Headers (Stream 2)"),
661:                         cl::desc("Dump the TPI Stream (Stream 3)"),
665:                         cl::desc("Dump the IPI Stream (Stream 5)"),
669:                             cl::desc("Dump the Publics Stream"),
1064:   auto &Stream = outs();
1066:                             ? Stream.has_colors()
1068:   LinePrinter Printer(2, UseColor, Stream);
1368:     if (to_integer(opts::exportstream::Stream, Index)) {
1381:     Index = ExitOnErr(IS.getNamedStreamIndex(opts::exportstream::Stream));
1382:     outs() << "Dumping contents of stream '" << opts::exportstream::Stream
53: #include "llvm/DebugInfo/PDB/Native/InfoStream.h"
61: #include "llvm/DebugInfo/PDB/Native/TpiStream.h"
75: #include "llvm/Support/BinaryByteStream.h"
713:                clEnumValN(InputFileType::PDBStream, "pdb-stream",
715:                clEnumValN(InputFileType::DBIStream, "dbi-stream",
719:                clEnumValN(InputFileType::ModuleStream, "mod-stream",
773:     ExitOnErr(Builder.getMsfBuilder().addStream(0));
783:   pdb::yaml::PdbInfoStream DefaultInfoStream;
784:   pdb::yaml::PdbDbiStream DefaultDbiStream;
785:   pdb::yaml::PdbTpiStream DefaultTpiStream;
786:   pdb::yaml::PdbTpiStream DefaultIpiStream;
788:   const auto &Info = YamlObj.PdbStream.getValueOr(DefaultInfoStream);
798:   const auto &Dbi = YamlObj.DbiStream.getValueOr(DefaultDbiStream);
814:       const auto &ModiStream = *MI.Modi;
815:       for (auto Symbol : ModiStream.Symbols) {
833:   const auto &Tpi = YamlObj.TpiStream.getValueOr(DefaultTpiStream);
841:   const auto &Ipi = YamlObj.IpiStream.getValueOr(DefaultIpiStream);
1304:     if (File.hasPDBTpiStream()) {
1305:       auto &Tpi = ExitOnErr(File.getPDBTpiStream());
1309:     if (File.hasPDBIpiStream()) {
1310:       auto &Ipi = ExitOnErr(File.getPDBIpiStream());
1322:     ExitOnErr(Builder.getMsfBuilder().addStream(0));
1360:   std::unique_ptr<MappedBlockStream> SourceStream;
1380:     InfoStream &IS = cantFail(File.getPDBInfoStream());
1386:   SourceStream = File.createIndexedStream(Index);
1388:       FileOutputBuffer::create(OutFileName, SourceStream->getLength()));
1389:   FileBufferByteStream DestStream(std::move(OutFile), llvm::support::little);
1390:   BinaryStreamWriter Writer(DestStream);
1391:   ExitOnErr(Writer.writeStreamRef(*SourceStream));
1392:   ExitOnErr(DestStream.commit());
1479:       opts::pdb2yaml::StreamMetadata = true;
1480:       opts::pdb2yaml::StreamDirectory = true;
1481:       opts::pdb2yaml::PdbStream = true;
1483:       opts::pdb2yaml::DbiStream = true;
1484:       opts::pdb2yaml::TpiStream = true;
1485:       opts::pdb2yaml::IpiStream = true;
1486:       opts::pdb2yaml::PublicsStream = true;
1499:       opts::pdb2yaml::DbiStream = true;
1566:     exportStream();
45: #include "llvm/DebugInfo/CodeView/TypeStreamMerger.h"
52: #include "llvm/DebugInfo/PDB/Native/DbiStreamBuilder.h"
54: #include "llvm/DebugInfo/PDB/Native/InfoStreamBuilder.h"
62: #include "llvm/DebugInfo/PDB/Native/TpiStreamBuilder.h"
772:   for (uint32_t I = 0; I < kSpecialStreamCount; ++I)
1321:   for (uint32_t I = 0; I < kSpecialStreamCount; ++I)
1369:       if (Index >= File.getNumStreams()) {
1463:       opts::dump::DumpStreams = true;
1464:       opts::dump::DumpStreamBlocks = true;
github.com/tensorflow/fold:tensorflow/tensorflow/stream_executor/stream.cc: [ master, ]
236: Stream::Stream(StreamExecutor *parent)
245: Stream::Stream(StreamExecutor *parent,
255: Stream::~Stream() {
1793: Stream *Stream::GetOrCreateSubStream() {
1810: void Stream::ReturnSubStream(Stream *sub_stream) {
195: // there are on Stream and how many parameters they each have.
196: string CallStr(const char *function_name, Stream *stream,
202:   string str = port::StrCat("Called Stream::", function_name, "(");
265: Stream &Stream::Init() {
284: Stream &Stream::InitTimer(Timer *timer) {
295: Stream &Stream::InitWithTimer(Timer *timer) {
301: Stream &Stream::ThenRecordEvent(Event *event) {
314: Stream &Stream::ThenBatchNormalizationForward(
342: Stream &Stream::ThenBatchNormalizationBackward(
364: Stream &Stream::ThenBatchNormalizationForward(
392: Stream &Stream::ThenBatchNormalizationBackward(
415: Stream &Stream::ThenFusedConvolveWithScratch(
448: Stream &Stream::ThenFusedConvolveWithScratch(
482: Stream &Stream::ThenFusedConvolveWithScratch(
515: Stream &Stream::ThenConvolveWithScratch(
542: Stream &Stream::ThenConvolveWithScratch(
569: Stream &Stream::ThenFusedConvolveWithAlgorithm(
607: Stream &Stream::ThenFusedConvolveWithAlgorithm(
646: Stream &Stream::ThenFusedConvolveWithAlgorithm(
684: Stream &Stream::ThenConvolveWithAlgorithm(
715: Stream &Stream::ThenConvolveWithAlgorithm(
746: Stream &Stream::ThenFusedConvolve(
764: Stream &Stream::ThenConvolve(
778: Stream &Stream::ThenConvolveQuantized(
808: Stream &Stream::ThenConvolveQuantized(
838: Stream &Stream::ThenSeparableConvolve(
865: Stream &Stream::ThenConvolveBackwardDataWithScratch(
893: Stream &Stream::ThenConvolveBackwardDataWithAlgorithm(
926: Stream &Stream::ThenConvolveBackwardDataWithAlgorithm(
959: Stream &Stream::ThenConvolveBackwardDataWithScratch(
987: Stream &Stream::ThenConvolveBackwardData(
1001: Stream &Stream::ThenConvolveBackwardFilterWithScratch(
1029: Stream &Stream::ThenConvolveBackwardFilterWithAlgorithm(
1062: Stream &Stream::ThenConvolveBackwardFilterWithScratch(
1090: Stream &Stream::ThenConvolveBackwardFilterWithAlgorithm(
1123: Stream &Stream::ThenConvolveBackwardFilter(
1138: Stream &Stream::ThenConvolveBackwardBiasImpl(
1158: Stream &Stream::ThenConvolveBackwardBias(
1167: Stream &Stream::ThenConvolveBackwardBias(
1176: Stream &Stream::ThenConvolveBackwardBias(
1185: Stream &Stream::ThenMatMul(const DeviceMemory<float> &input_data,
1204: Stream &Stream::ThenMatMulQuantized(
1226: Stream &Stream::ThenMatMulQuantized(
1248: Stream &Stream::ThenBiasAdd(const DeviceMemory<float> &input_data,
1266: Stream &Stream::ThenPoolForward(
1290: Stream &Stream::ThenPoolForward(
1311: Stream &Stream::ThenPoolForward(
1332: Stream &Stream::ThenPoolBackward(
1359: Stream &Stream::ThenPoolBackward(
1383: Stream &Stream::ThenPoolBackward(
1407: Stream &Stream::ThenNormalize(
1423: Stream &Stream::ThenNormalizeWithDimensions(
1441: Stream &Stream::ThenNormalizeBackwardWithDimensions(
1463: Stream &Stream::ThenActivate(dnn::ActivationMode activation_mode,
1471: Stream &Stream::ThenActivateWithOptions(dnn::ActivationMode activation_mode,
1490: Stream &Stream::ThenDepthConcatenate(
1520: Stream &Stream::ThenSpaceConcatenate(
1567: Stream &Stream::ThenReshape(const dnn::BatchDescriptor &input_dimensions,
1585: Stream &Stream::ThenDepthToSpace(
1606: Stream &Stream::ThenSpaceToDepth(
1627: Stream &Stream::ThenElementwiseOperate(
1648: Stream &Stream::ThenElementwiseOperateScaledQuantized(
1671: Stream &Stream::ThenXYPad(const dnn::BatchDescriptor &dimensions,
1690: Stream &Stream::ThenXYSlice(const dnn::BatchDescriptor &dimensions,
1711: Stream &Stream::ThenXYBroadcast(const dnn::BatchDescriptor &dimensions,
1729: Stream &Stream::ThenMemcpyD2HQuantized(
1746: Stream &Stream::ThenMemcpyH2DQuantized(
1763: Stream &Stream::ThenCopyHostBuffer2Device(
1778: Stream &Stream::ThenCopyDevice2HostBuffer(
1801:   sub_streams_.emplace_back(std::unique_ptr<Stream>{new Stream{parent_}},
1803:   Stream *sub_stream = sub_streams_.back().first.get();
1821: Stream &Stream::ThenStartTimer(Timer *t) {
1832: Stream &Stream::ThenStopTimer(Timer *t) {
1843: Stream &Stream::ThenWaitFor(Stream *other) {
1856: Stream &Stream::ThenWaitFor(Event *event) {
1878:   // arguments except the first one of Stream* type.
1879:   Stream &operator()(Stream *stream,
1880:                      bool (blas::BlasSupport::*blas_func)(Stream *, Args...),
1887:   Stream &Run(Stream *stream,
1888:               bool (blas::BlasSupport::*blas_func)(Stream *, Args...),
1893: Stream &ThenBlasImpl<Args...>::Run(
1894:     Stream *stream, bool (blas::BlasSupport::*blas_func)(Stream *, Args...),
1913: Stream &Stream::ThenBlasAsum(uint64 elem_count, const DeviceMemory<float> &x,
1923: Stream &Stream::ThenBlasAsum(uint64 elem_count, const DeviceMemory<double> &x,
1933: Stream &Stream::ThenBlasAsum(uint64 elem_count,
1944: Stream &Stream::ThenBlasAsum(uint64 elem_count,
1955: Stream &Stream::ThenBlasAxpy(uint64 elem_count, float alpha,
1967: Stream &Stream::ThenBlasAxpy(uint64 elem_count, double alpha,
1979: Stream &Stream::ThenBlasAxpy(uint64 elem_count, std::complex<float> alpha,
1993: Stream &Stream::ThenBlasAxpy(uint64 elem_count, std::complex<double> alpha,
2007: Stream &Stream::ThenBlasCopy(uint64 elem_count, const DeviceMemory<float> &x,
2017: Stream &Stream::ThenBlasCopy(uint64 elem_count, const DeviceMemory<double> &x,
2027: Stream &Stream::ThenBlasCopy(uint64 elem_count,
2039: Stream &Stream::ThenBlasCopy(uint64 elem_count,
2051: Stream &Stream::ThenBlasDot(uint64 elem_count, const DeviceMemory<float> &x,
2063: Stream &Stream::ThenBlasDot(uint64 elem_count, const DeviceMemory<double> &x,
2075: Stream &Stream::ThenBlasDotc(uint64 elem_count,
2091: Stream &Stream::ThenBlasDotc(uint64 elem_count,
2107: Stream &Stream::ThenBlasDotu(uint64 elem_count,
2123: Stream &Stream::ThenBlasDotu(uint64 elem_count,
2139: Stream &Stream::ThenBlasNrm2(uint64 elem_count, const DeviceMemory<float> &x,
2149: Stream &Stream::ThenBlasNrm2(uint64 elem_count, const DeviceMemory<double> &x,
2159: Stream &Stream::ThenBlasNrm2(uint64 elem_count,
2170: Stream &Stream::ThenBlasNrm2(uint64 elem_count,
2181: Stream &Stream::ThenBlasRot(uint64 elem_count, DeviceMemory<float> *x, int incx,
2193: Stream &Stream::ThenBlasRot(uint64 elem_count, DeviceMemory<double> *x,
2205: Stream &Stream::ThenBlasRot(uint64 elem_count,
2218: Stream &Stream::ThenBlasRot(uint64 elem_count,
2231: Stream &Stream::ThenBlasRotg(DeviceMemory<float> *a, DeviceMemory<float> *b,
2240: Stream &Stream::ThenBlasRotg(DeviceMemory<double> *a, DeviceMemory<double> *b,
2249: Stream &Stream::ThenBlasRotg(DeviceMemory<std::complex<float>> *a,
2261: Stream &Stream::ThenBlasRotg(DeviceMemory<std::complex<double>> *a,
2273: Stream &Stream::ThenBlasRotm(uint64 elem_count, DeviceMemory<float> *x,
2285: Stream &Stream::ThenBlasRotm(uint64 elem_count, DeviceMemory<double> *x,
2297: Stream &Stream::ThenBlasRotmg(DeviceMemory<float> *d1, DeviceMemory<float> *d2,
2309: Stream &Stream::ThenBlasRotmg(DeviceMemory<double> *d1,
2322: Stream &Stream::ThenBlasScal(uint64 elem_count, float alpha,
2330: Stream &Stream::ThenBlasScal(uint64 elem_count, double alpha,
2338: Stream &Stream::ThenBlasScal(uint64 elem_count, float alpha,
2346: Stream &Stream::ThenBlasScal(uint64 elem_count, double alpha,
2354: Stream &Stream::ThenBlasScal(uint64 elem_count, std::complex<float> alpha,
2363: Stream &Stream::ThenBlasScal(uint64 elem_count, std::complex<double> alpha,
2372: Stream &Stream::ThenBlasSwap(uint64 elem_count, DeviceMemory<float> *x,
2382: Stream &Stream::ThenBlasSwap(uint64 elem_count, DeviceMemory<double> *x,
2392: Stream &Stream::ThenBlasSwap(uint64 elem_count,
2403: Stream &Stream::ThenBlasSwap(uint64 elem_count,
2414: Stream &Stream::ThenBlasIamax(uint64 elem_count, const DeviceMemory<float> &x,
2424: Stream &Stream::ThenBlasIamax(uint64 elem_count, const DeviceMemory<double> &x,
2434: Stream &Stream::ThenBlasIamax(uint64 elem_count,
2445: Stream &Stream::ThenBlasIamax(uint64 elem_count,
2456: Stream &Stream::ThenBlasIamin(uint64 elem_count, const DeviceMemory<float> &x,
2466: Stream &Stream::ThenBlasIamin(uint64 elem_count, const DeviceMemory<double> &x,
2476: Stream &Stream::ThenBlasIamin(uint64 elem_count,
2487: Stream &Stream::ThenBlasIamin(uint64 elem_count,
2498: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2514: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2530: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2550: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2570: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2585: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2600: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2620: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2640: Stream &Stream::ThenBlasGer(uint64 m, uint64 n, float alpha,
2654: Stream &Stream::ThenBlasGer(uint64 m, uint64 n, double alpha,
2668: Stream &Stream::ThenBlasGerc(uint64 m, uint64 n, std::complex<float> alpha,
2685: Stream &Stream::ThenBlasGerc(uint64 m, uint64 n, std::complex<double> alpha,
2702: Stream &Stream::ThenBlasGeru(uint64 m, uint64 n, std::complex<float> alpha,
2719: Stream &Stream::ThenBlasGeru(uint64 m, uint64 n, std::complex<double> alpha,
2736: Stream &Stream::ThenBlasHbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2755: Stream &Stream::ThenBlasHbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2774: Stream &Stream::ThenBlasHemv(blas::UpperLower uplo, uint64 n,
2793: Stream &Stream::ThenBlasHemv(blas::UpperLower uplo, uint64 n,
2812: Stream &Stream::ThenBlasHer(blas::UpperLower uplo, uint64 n, float alpha,
2826: Stream &Stream::ThenBlasHer(blas::UpperLower uplo, uint64 n, double alpha,
2840: Stream &Stream::ThenBlasHer2(blas::UpperLower uplo, uint64 n,
2858: Stream &Stream::ThenBlasHer2(blas::UpperLower uplo, uint64 n,
2876: Stream &Stream::ThenBlasHpmv(blas::UpperLower uplo, uint64 n,
2894: Stream &Stream::ThenBlasHpmv(blas::UpperLower uplo, uint64 n,
2912: Stream &Stream::ThenBlasHpr(blas::UpperLower uplo, uint64 n, float alpha,
2924: Stream &Stream::ThenBlasHpr(blas::UpperLower uplo, uint64 n, double alpha,
2936: Stream &Stream::ThenBlasHpr2(blas::UpperLower uplo, uint64 n,
2953: Stream &Stream::ThenBlasHpr2(blas::UpperLower uplo, uint64 n,
2970: Stream &Stream::ThenBlasSbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2984: Stream &Stream::ThenBlasSbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2998: Stream &Stream::ThenBlasSpmv(blas::UpperLower uplo, uint64 n, float alpha,
3012: Stream &Stream::ThenBlasSpmv(blas::UpperLower uplo, uint64 n, double alpha,
3026: Stream &Stream::ThenBlasSpr(blas::UpperLower uplo, uint64 n, float alpha,
3037: Stream &Stream::ThenBlasSpr(blas::UpperLower uplo, uint64 n, double alpha,
3048: Stream &Stream::ThenBlasSpr2(blas::UpperLower uplo, uint64 n, float alpha,
3062: Stream &Stream::ThenBlasSpr2(blas::UpperLower uplo, uint64 n, double alpha,
3076: Stream &Stream::ThenBlasSymv(blas::UpperLower uplo, uint64 n, float alpha,
3090: Stream &Stream::ThenBlasSymv(blas::UpperLower uplo, uint64 n, double alpha,
3104: Stream &Stream::ThenBlasSyr(blas::UpperLower uplo, uint64 n, float alpha,
3116: Stream &Stream::ThenBlasSyr(blas::UpperLower uplo, uint64 n, double alpha,
3128: Stream &Stream::ThenBlasSyr2(blas::UpperLower uplo, uint64 n, float alpha,
3142: Stream &Stream::ThenBlasSyr2(blas::UpperLower uplo, uint64 n, double alpha,
3156: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
3170: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
3184: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
3199: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
3214: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
3228: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
3242: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
3257: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
3272: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
3285: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
3298: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
3312: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
3326: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3339: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3352: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3366: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3380: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3394: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3408: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3423: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3438: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3452: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3466: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3481: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3496: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3514: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3530: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3546: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3567: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3595:   Stream &operator()(Stream *stream,
3597:                          Stream *, Args..., blas::ProfileResult *),
3606: Stream &Stream::ThenBlasGemvWithProfiling(
3623: Stream &Stream::ThenBlasGemvWithProfiling(
3641: Stream &Stream::ThenBlasGemvWithProfiling(
3661: Stream &Stream::ThenBlasGemvWithProfiling(
3681: Stream &Stream::ThenBlasGemmWithProfiling(
3701: Stream &Stream::ThenBlasGemmWithProfiling(
3720: Stream &Stream::ThenBlasGemmWithProfiling(
3740: Stream &Stream::ThenBlasGemmWithProfiling(
3762: Stream &Stream::ThenBlasGemmWithProfiling(
3784: Stream &Stream::ThenBlasGemmWithAlgorithm(
3808: Stream &Stream::ThenBlasGemmWithAlgorithm(
3829: Stream &Stream::ThenBlasGemmWithAlgorithm(
3850: Stream &Stream::ThenBlasGemmWithAlgorithm(
3872: Stream &Stream::ThenBlasGemmWithAlgorithm(
3897: Stream &Stream::ThenBlasGemmWithAlgorithm(
3922: Stream &Stream::ThenBlasHemm(blas::Side side, blas::UpperLower uplo, uint64 m,
3942: Stream &Stream::ThenBlasHemm(blas::Side side, blas::UpperLower uplo, uint64 m,
3962: Stream &Stream::ThenBlasHerk(blas::UpperLower uplo, blas::Transpose trans,
3977: Stream &Stream::ThenBlasHerk(blas::UpperLower uplo, blas::Transpose trans,
3992: Stream &Stream::ThenBlasHer2k(blas::UpperLower uplo, blas::Transpose trans,
4011: Stream &Stream::ThenBlasHer2k(blas::UpperLower uplo, blas::Transpose trans,
4030: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
4046: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
4062: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
4082: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
4102: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
4116: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
4130: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
4146: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
4162: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
4178: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
4194: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
4214: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
4234: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
4249: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
4264: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
4281: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
4298: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
4313: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
4328: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
4345: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
4362: Stream &Stream::ThenBlasGemmBatched(
4373: Stream &Stream::ThenBlasGemmBatchedWithScratch(
4394: Stream &Stream::ThenBlasGemmBatched(
4405: Stream &Stream::ThenBlasGemmBatchedWithScratch(
4426: Stream &Stream::ThenBlasGemmBatched(
4439: Stream &Stream::ThenBlasGemmBatchedWithScratch(
4465: Stream &Stream::ThenBlasGemmBatched(
4478: Stream &Stream::ThenBlasGemmBatchedWithScratch(
4504: Stream &Stream::ThenSetRngSeed(const uint8 *seed, uint64 seed_bytes) {
4522: Stream &Stream::ThenPopulateRandUniform(DeviceMemory<float> *values) {
4537: Stream &Stream::ThenPopulateRandGaussian(float mean, float sd,
4553: Stream &Stream::ThenPopulateRandGaussian(double mean, double sd,
4569: Stream &Stream::ThenPopulateRandUniform(DeviceMemory<double> *values) {
4584: Stream &Stream::ThenPopulateRandUniform(
4600: Stream &Stream::ThenPopulateRandUniform(
4617: Stream &Stream::ThenMemcpy(void *host_dst, const DeviceMemoryBase &gpu_src,
4630: Stream &Stream::ThenMemcpy(DeviceMemoryBase *gpu_dst, const void *host_src,
4643: Stream &Stream::ThenMemcpy(DeviceMemoryBase *gpu_dst,
4656: Stream &Stream::ThenMemZero(DeviceMemoryBase *location, uint64 size) {
4668: Stream &Stream::ThenMemset32(DeviceMemoryBase *location, uint32 pattern,
4682: Stream &Stream::ThenRnnForward(
4714: Stream &Stream::ThenRnnForward(
4747: Stream &Stream::ThenRnnBackward(
4788: Stream &Stream::ThenRnnBackward(
4830: Stream &Stream::ThenTransformTensor(const dnn::BatchDescriptor &input_desc,
4851: Stream &Stream::ThenDoHostCallbackForTest(std::function<void()> callback) {
4857: Stream &Stream::ThenDoHostCallback(std::function<void()> callback) {
4869: Stream &Stream::ThenFft(fft::Plan *plan,
4886: Stream &Stream::ThenFft(fft::Plan *plan,
4903: Stream &Stream::ThenFft(fft::Plan *plan, const DeviceMemory<float> &input,
4919: Stream &Stream::ThenFft(fft::Plan *plan, const DeviceMemory<double> &input,
4935: Stream &Stream::ThenFft(fft::Plan *plan,
4952: Stream &Stream::ThenFft(fft::Plan *plan,
4971: Stream &Stream::ThenEnqueueOnBackgroundThread(
4983: bool Stream::BlockHostUntilDone() {
246:                internal::StreamInterface *implementation)
261:     parent_->DeallocateStream(this);
273:   if (parent_->AllocateStream(this)) {
801:           << "attempting to perform DNN operation using StreamExecutor "
831:           << "attempting to perform DNN operation using StreamExecutor "
1283:           << "attempting to perform DNN operation using StreamExecutor "
1352:           << "attempting to perform DNN operation using StreamExecutor "
1902:           << "attempting to perform BLAS operation using StreamExecutor "
4530:       LOG(INFO) << "attempting to perform RNG operation using StreamExecutor "
4546:       LOG(INFO) << "attempting to perform RNG operation using StreamExecutor "
4562:       LOG(INFO) << "attempting to perform RNG operation using StreamExecutor "
4577:       LOG(INFO) << "attempting to perform RNG operation using StreamExecutor "
4593:       LOG(INFO) << "attempting to perform RNG operation using StreamExecutor "
4610:                 << " attempting to perform RNG operation using StreamExecutor "
4879:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4896:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4912:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4928:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4945:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4962:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4972:     std::function<void(StreamExecutor *)> task) {
4975:   StreamExecutor *stream_executor = this->parent_;
238:       implementation_(parent->implementation()->GetStreamImplementation()),
1848:     CheckError(parent_->CreateStreamDependency(this, other));
github.com/kubernetes/client-go:rest/request.go: [ master, ]
71: 	Stream(context.Context) (io.ReadCloser, error)
830: func (r *Request) Stream(ctx context.Context) (io.ReadCloser, error) {
770: func (r *Request) newStreamWatcher(resp *http.Response) (watch.Interface, error) {
826: // Stream formats and executes the request, and offers streaming of the response.
1086: 			klog.V(2).Infof("Stream error %#v when reading response body, may be caused by closed connection.", err)
776: 	objectDecoder, streamingSerializer, framer, err := r.c.content.Negotiator.StreamDecoder(mediaType, params)
1078: 		case http2.StreamError:
737: 			return r.newStreamWatcher(resp)
786: 	return watch.NewStreamWatcher(
github.com/google/highwayhash:highwayhash/vector256.h: [ master, ]
671: HH_INLINE void Stream(const V256<T>& v, T* const HH_RESTRICT to) {
674: HH_INLINE void Stream(const V256<float>& v, float* const HH_RESTRICT to) {
677: HH_INLINE void Stream(const V256<double>& v, double* const HH_RESTRICT to) {
github.com/tensorflow/deepmath:tensorflow/tensorflow/stream_executor/stream.cc: [ master, ]
249: Stream::Stream(StreamExecutor *parent)
258: Stream::Stream(StreamExecutor *parent,
268: Stream::~Stream() {
1738: Stream *Stream::GetOrCreateSubStream() {
1785: void Stream::ReturnSubStream(Stream *sub_stream) {
5277: string Stream::DebugStreamPointers() const {
207: // there are on Stream and how many parameters they each have.
208: string CallStr(const char *function_name, Stream *stream,
215:                             " Called Stream::", function_name, "(");
284: port::Status Stream::RefreshStatus() {
290: Stream &Stream::Init() {
309: Stream &Stream::InitTimer(Timer *timer) {
320: Stream &Stream::InitWithTimer(Timer *timer) {
326: Stream &Stream::ThenRecordEvent(Event *event) {
339: Stream &Stream::ThenBatchNormalizationForward(
367: Stream &Stream::ThenBatchNormalizationBackward(
389: Stream &Stream::ThenBatchNormalizationForward(
417: Stream &Stream::ThenBatchNormalizationBackward(
440: Stream &Stream::ThenFusedConvolveWithAlgorithm(
478: Stream &Stream::ThenFusedConvolveWithAlgorithm(
516: Stream &Stream::ThenFusedConvolveWithAlgorithm(
555: Stream &Stream::ThenFusedConvolveWithAlgorithm(
593: Stream &Stream::ThenConvolveWithAlgorithm(
635: Stream &Stream::ThenConvolveWithAlgorithm(
677: Stream &Stream::ThenConvolveWithAlgorithm(
719: Stream &Stream::ThenConvolve(
734: Stream &Stream::ThenConvolveQuantized(
764: Stream &Stream::ThenConvolveQuantized(
794: Stream &Stream::ThenSeparableConvolve(
821: Stream &Stream::ThenConvolveBackwardDataWithAlgorithm(
866: Stream &Stream::ThenConvolveBackwardDataWithAlgorithm(
911: Stream &Stream::ThenConvolveBackwardDataWithAlgorithm(
956: Stream &Stream::ThenConvolveBackwardFilterWithAlgorithm(
1001: Stream &Stream::ThenConvolveBackwardFilterWithAlgorithm(
1046: Stream &Stream::ThenConvolveBackwardFilterWithAlgorithm(
1092: Stream &Stream::ThenConvolveBackwardBiasImpl(
1112: Stream &Stream::ThenConvolveBackwardBias(
1121: Stream &Stream::ThenConvolveBackwardBias(
1130: Stream &Stream::ThenConvolveBackwardBias(
1139: Stream &Stream::ThenMatMul(const DeviceMemory<float> &input_data,
1158: Stream &Stream::ThenMatMulQuantized(
1180: Stream &Stream::ThenMatMulQuantized(
1202: Stream &Stream::ThenBiasAdd(const DeviceMemory<float> &input_data,
1220: Stream &Stream::ThenPoolForward(
1245: Stream &Stream::ThenPoolForward(
1267: Stream &Stream::ThenPoolForward(
1290: Stream &Stream::ThenPoolForward(
1312: Stream &Stream::ThenPoolBackward(
1342: Stream &Stream::ThenPoolBackward(
1369: Stream &Stream::ThenPoolBackward(
1396: Stream &Stream::ThenNormalizeWithDimensions(
1414: Stream &Stream::ThenNormalizeBackwardWithDimensions(
1438: Stream &Stream::ThenActivate(dnn::ActivationMode activation_mode,
1446: Stream &Stream::ThenActivateWithOptions(dnn::ActivationMode activation_mode,
1465: Stream &Stream::ThenDepthConcatenate(
1495: Stream &Stream::ThenSpaceConcatenate(
1542: Stream &Stream::ThenReshape(const dnn::BatchDescriptor &input_dimensions,
1560: Stream &Stream::ThenDepthToSpace(
1581: Stream &Stream::ThenSpaceToDepth(
1602: Stream &Stream::ThenElementwiseOperate(
1623: Stream &Stream::ThenElementwiseOperateScaledQuantized(
1646: Stream &Stream::ThenXYPad(const dnn::BatchDescriptor &dimensions,
1665: Stream &Stream::ThenXYSlice(const dnn::BatchDescriptor &dimensions,
1686: Stream &Stream::ThenXYBroadcast(const dnn::BatchDescriptor &dimensions,
1704: Stream &Stream::ThenMemcpyD2HQuantized(
1721: Stream &Stream::ThenMemcpyH2DQuantized(
1744:     std::pair<std::unique_ptr<Stream>, bool> &pair = sub_streams_[index];
1747:       Stream *sub_stream = pair.first.get();
1772:   sub_streams_.emplace_back(std::unique_ptr<Stream>{new Stream{parent_}},
1774:   Stream *sub_stream = sub_streams_.back().first.get();
1790:     std::pair<std::unique_ptr<Stream>, bool> &pair = sub_streams_[index];
1820: Stream &Stream::ThenStartTimer(Timer *t) {
1832: Stream &Stream::ThenStopTimer(Timer *t) {
1844: Stream &Stream::ThenWaitFor(Stream *other) {
1858: Stream &Stream::ThenWaitFor(Event *event) {
1880:   // arguments except the first one of Stream* type.
1881:   Stream &operator()(Stream *stream,
1882:                      bool (blas::BlasSupport::*blas_func)(Stream *, Args...),
1889:   Stream &Run(Stream *stream,
1890:               bool (blas::BlasSupport::*blas_func)(Stream *, Args...),
1895: Stream &ThenBlasImpl<Args...>::Run(
1896:     Stream *stream, bool (blas::BlasSupport::*blas_func)(Stream *, Args...),
1915: Stream &Stream::ThenBlasAsum(uint64 elem_count, const DeviceMemory<float> &x,
1925: Stream &Stream::ThenBlasAsum(uint64 elem_count, const DeviceMemory<double> &x,
1935: Stream &Stream::ThenBlasAsum(uint64 elem_count,
1946: Stream &Stream::ThenBlasAsum(uint64 elem_count,
1957: Stream &Stream::ThenBlasAxpy(uint64 elem_count, float alpha,
1969: Stream &Stream::ThenBlasAxpy(uint64 elem_count, double alpha,
1981: Stream &Stream::ThenBlasAxpy(uint64 elem_count, std::complex<float> alpha,
1995: Stream &Stream::ThenBlasAxpy(uint64 elem_count, std::complex<double> alpha,
2009: Stream &Stream::ThenBlasCopy(uint64 elem_count, const DeviceMemory<float> &x,
2019: Stream &Stream::ThenBlasCopy(uint64 elem_count, const DeviceMemory<double> &x,
2029: Stream &Stream::ThenBlasCopy(uint64 elem_count,
2041: Stream &Stream::ThenBlasCopy(uint64 elem_count,
2053: Stream &Stream::ThenBlasDot(uint64 elem_count, const DeviceMemory<float> &x,
2065: Stream &Stream::ThenBlasDot(uint64 elem_count, const DeviceMemory<double> &x,
2077: Stream &Stream::ThenBlasDotc(uint64 elem_count,
2093: Stream &Stream::ThenBlasDotc(uint64 elem_count,
2109: Stream &Stream::ThenBlasDotu(uint64 elem_count,
2125: Stream &Stream::ThenBlasDotu(uint64 elem_count,
2141: Stream &Stream::ThenBlasNrm2(uint64 elem_count, const DeviceMemory<float> &x,
2151: Stream &Stream::ThenBlasNrm2(uint64 elem_count, const DeviceMemory<double> &x,
2161: Stream &Stream::ThenBlasNrm2(uint64 elem_count,
2172: Stream &Stream::ThenBlasNrm2(uint64 elem_count,
2183: Stream &Stream::ThenBlasRot(uint64 elem_count, DeviceMemory<float> *x, int incx,
2195: Stream &Stream::ThenBlasRot(uint64 elem_count, DeviceMemory<double> *x,
2207: Stream &Stream::ThenBlasRot(uint64 elem_count,
2220: Stream &Stream::ThenBlasRot(uint64 elem_count,
2233: Stream &Stream::ThenBlasRotg(DeviceMemory<float> *a, DeviceMemory<float> *b,
2242: Stream &Stream::ThenBlasRotg(DeviceMemory<double> *a, DeviceMemory<double> *b,
2251: Stream &Stream::ThenBlasRotg(DeviceMemory<std::complex<float>> *a,
2263: Stream &Stream::ThenBlasRotg(DeviceMemory<std::complex<double>> *a,
2275: Stream &Stream::ThenBlasRotm(uint64 elem_count, DeviceMemory<float> *x,
2287: Stream &Stream::ThenBlasRotm(uint64 elem_count, DeviceMemory<double> *x,
2299: Stream &Stream::ThenBlasRotmg(DeviceMemory<float> *d1, DeviceMemory<float> *d2,
2311: Stream &Stream::ThenBlasRotmg(DeviceMemory<double> *d1,
2324: Stream &Stream::ThenBlasScal(uint64 elem_count, float alpha,
2332: Stream &Stream::ThenBlasScal(uint64 elem_count, double alpha,
2340: Stream &Stream::ThenBlasScal(uint64 elem_count, float alpha,
2348: Stream &Stream::ThenBlasScal(uint64 elem_count, double alpha,
2356: Stream &Stream::ThenBlasScal(uint64 elem_count, std::complex<float> alpha,
2365: Stream &Stream::ThenBlasScal(uint64 elem_count, std::complex<double> alpha,
2374: Stream &Stream::ThenBlasSwap(uint64 elem_count, DeviceMemory<float> *x,
2384: Stream &Stream::ThenBlasSwap(uint64 elem_count, DeviceMemory<double> *x,
2394: Stream &Stream::ThenBlasSwap(uint64 elem_count,
2405: Stream &Stream::ThenBlasSwap(uint64 elem_count,
2416: Stream &Stream::ThenBlasIamax(uint64 elem_count, const DeviceMemory<float> &x,
2426: Stream &Stream::ThenBlasIamax(uint64 elem_count, const DeviceMemory<double> &x,
2436: Stream &Stream::ThenBlasIamax(uint64 elem_count,
2447: Stream &Stream::ThenBlasIamax(uint64 elem_count,
2458: Stream &Stream::ThenBlasIamin(uint64 elem_count, const DeviceMemory<float> &x,
2468: Stream &Stream::ThenBlasIamin(uint64 elem_count, const DeviceMemory<double> &x,
2478: Stream &Stream::ThenBlasIamin(uint64 elem_count,
2489: Stream &Stream::ThenBlasIamin(uint64 elem_count,
2500: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2516: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2532: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2552: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2572: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2587: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2602: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2622: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2642: Stream &Stream::ThenBlasGer(uint64 m, uint64 n, float alpha,
2656: Stream &Stream::ThenBlasGer(uint64 m, uint64 n, double alpha,
2670: Stream &Stream::ThenBlasGerc(uint64 m, uint64 n, std::complex<float> alpha,
2687: Stream &Stream::ThenBlasGerc(uint64 m, uint64 n, std::complex<double> alpha,
2704: Stream &Stream::ThenBlasGeru(uint64 m, uint64 n, std::complex<float> alpha,
2721: Stream &Stream::ThenBlasGeru(uint64 m, uint64 n, std::complex<double> alpha,
2738: Stream &Stream::ThenBlasHbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2757: Stream &Stream::ThenBlasHbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2776: Stream &Stream::ThenBlasHemv(blas::UpperLower uplo, uint64 n,
2795: Stream &Stream::ThenBlasHemv(blas::UpperLower uplo, uint64 n,
2814: Stream &Stream::ThenBlasHer(blas::UpperLower uplo, uint64 n, float alpha,
2828: Stream &Stream::ThenBlasHer(blas::UpperLower uplo, uint64 n, double alpha,
2842: Stream &Stream::ThenBlasHer2(blas::UpperLower uplo, uint64 n,
2860: Stream &Stream::ThenBlasHer2(blas::UpperLower uplo, uint64 n,
2878: Stream &Stream::ThenBlasHpmv(blas::UpperLower uplo, uint64 n,
2896: Stream &Stream::ThenBlasHpmv(blas::UpperLower uplo, uint64 n,
2914: Stream &Stream::ThenBlasHpr(blas::UpperLower uplo, uint64 n, float alpha,
2926: Stream &Stream::ThenBlasHpr(blas::UpperLower uplo, uint64 n, double alpha,
2938: Stream &Stream::ThenBlasHpr2(blas::UpperLower uplo, uint64 n,
2955: Stream &Stream::ThenBlasHpr2(blas::UpperLower uplo, uint64 n,
2972: Stream &Stream::ThenBlasSbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2986: Stream &Stream::ThenBlasSbmv(blas::UpperLower uplo, uint64 n, uint64 k,
3000: Stream &Stream::ThenBlasSpmv(blas::UpperLower uplo, uint64 n, float alpha,
3014: Stream &Stream::ThenBlasSpmv(blas::UpperLower uplo, uint64 n, double alpha,
3028: Stream &Stream::ThenBlasSpr(blas::UpperLower uplo, uint64 n, float alpha,
3039: Stream &Stream::ThenBlasSpr(blas::UpperLower uplo, uint64 n, double alpha,
3050: Stream &Stream::ThenBlasSpr2(blas::UpperLower uplo, uint64 n, float alpha,
3064: Stream &Stream::ThenBlasSpr2(blas::UpperLower uplo, uint64 n, double alpha,
3078: Stream &Stream::ThenBlasSymv(blas::UpperLower uplo, uint64 n, float alpha,
3092: Stream &Stream::ThenBlasSymv(blas::UpperLower uplo, uint64 n, double alpha,
3106: Stream &Stream::ThenBlasSyr(blas::UpperLower uplo, uint64 n, float alpha,
3118: Stream &Stream::ThenBlasSyr(blas::UpperLower uplo, uint64 n, double alpha,
3130: Stream &Stream::ThenBlasSyr2(blas::UpperLower uplo, uint64 n, float alpha,
3144: Stream &Stream::ThenBlasSyr2(blas::UpperLower uplo, uint64 n, double alpha,
3158: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
3172: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
3186: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
3201: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
3216: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
3230: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
3244: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
3259: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
3274: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
3287: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
3300: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
3314: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
3328: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3341: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3354: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3368: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3382: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3396: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3410: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3425: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3440: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3454: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3468: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3483: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3498: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3516: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3532: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3548: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3569: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3597:   Stream &operator()(Stream *stream,
3599:                          Stream *, Args..., blas::ProfileResult *),
3608: Stream &Stream::ThenBlasGemvWithProfiling(
3625: Stream &Stream::ThenBlasGemvWithProfiling(
3643: Stream &Stream::ThenBlasGemvWithProfiling(
3663: Stream &Stream::ThenBlasGemvWithProfiling(
3683: Stream &Stream::ThenBlasGemmWithProfiling(
3703: Stream &Stream::ThenBlasGemmWithProfiling(
3722: Stream &Stream::ThenBlasGemmWithProfiling(
3742: Stream &Stream::ThenBlasGemmWithProfiling(
3764: Stream &Stream::ThenBlasGemmWithProfiling(
3786: Stream &Stream::ThenBlasGemmWithAlgorithm(
3811: Stream &Stream::ThenBlasGemmWithAlgorithm(
3834: Stream &Stream::ThenBlasGemmWithAlgorithm(
3857: Stream &Stream::ThenBlasGemmWithAlgorithm(
3881: Stream &Stream::ThenBlasGemmWithAlgorithm(
3909: Stream &Stream::ThenBlasGemmWithAlgorithm(
3937: Stream &Stream::ThenBlasHemm(blas::Side side, blas::UpperLower uplo, uint64 m,
3957: Stream &Stream::ThenBlasHemm(blas::Side side, blas::UpperLower uplo, uint64 m,
3977: Stream &Stream::ThenBlasHerk(blas::UpperLower uplo, blas::Transpose trans,
3992: Stream &Stream::ThenBlasHerk(blas::UpperLower uplo, blas::Transpose trans,
4007: Stream &Stream::ThenBlasHer2k(blas::UpperLower uplo, blas::Transpose trans,
4026: Stream &Stream::ThenBlasHer2k(blas::UpperLower uplo, blas::Transpose trans,
4045: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
4061: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
4077: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
4097: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
4117: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
4131: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
4145: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
4161: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
4177: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
4193: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
4209: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
4229: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
4249: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
4264: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
4279: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
4296: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
4313: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
4328: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
4343: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
4360: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
4377: Stream &Stream::ThenBlasGemmBatched(
4389: Stream &Stream::ThenBlasGemmBatchedWithScratch(
4411: Stream &Stream::ThenBlasGemmBatched(
4422: Stream &Stream::ThenBlasGemmBatchedWithScratch(
4443: Stream &Stream::ThenBlasGemmBatched(
4454: Stream &Stream::ThenBlasGemmBatchedWithScratch(
4475: Stream &Stream::ThenBlasGemmBatched(
4488: Stream &Stream::ThenBlasGemmBatchedWithScratch(
4514: Stream &Stream::ThenBlasGemmBatched(
4527: Stream &Stream::ThenBlasGemmBatchedWithScratch(
4553: Stream &Stream::ThenBlasGemmStridedBatched(
4574: Stream &Stream::ThenBlasGemmStridedBatched(
4595: Stream &Stream::ThenBlasGemmStridedBatched(
4616: Stream &Stream::ThenBlasGemmStridedBatched(
4639: Stream &Stream::ThenBlasGemmStridedBatched(
4662: Stream &Stream::ThenSetRngSeed(const uint8 *seed, uint64 seed_bytes) {
4680: Stream &Stream::ThenPopulateRandUniform(DeviceMemory<float> *values) {
4696: Stream &Stream::ThenPopulateRandGaussian(float mean, float sd,
4713: Stream &Stream::ThenPopulateRandGaussian(double mean, double sd,
4730: Stream &Stream::ThenPopulateRandUniform(DeviceMemory<double> *values) {
4746: Stream &Stream::ThenPopulateRandUniform(
4763: Stream &Stream::ThenPopulateRandUniform(
4780: Stream &Stream::ThenMemcpy(void *host_dst, const DeviceMemoryBase &gpu_src,
4793: Stream &Stream::ThenMemcpy(DeviceMemoryBase *gpu_dst, const void *host_src,
4806: Stream &Stream::ThenMemcpy(DeviceMemoryBase *gpu_dst,
4819: Stream &Stream::ThenMemZero(DeviceMemoryBase *location, uint64 size) {
4831: Stream &Stream::ThenMemset32(DeviceMemoryBase *location, uint32 pattern,
4845: Stream &Stream::ThenRnnForward(
4882: Stream &Stream::ThenRnnForward(
4918: Stream &Stream::ThenRnnForward(
4955: Stream &Stream::ThenRnnBackward(
5002: Stream &Stream::ThenRnnBackward(
5048: Stream &Stream::ThenRnnBackward(
5095: Stream &Stream::ThenTransformTensor(const dnn::BatchDescriptor &input_desc,
5116: Stream &Stream::ThenDoHostCallback(std::function<void()> callback) {
5127: Stream &Stream::ThenDoHostCallbackWithStatus(
5139: Stream &Stream::ThenFft(fft::Plan *plan,
5157: Stream &Stream::ThenFft(fft::Plan *plan,
5175: Stream &Stream::ThenFft(fft::Plan *plan, const DeviceMemory<float> &input,
5192: Stream &Stream::ThenFft(fft::Plan *plan, const DeviceMemory<double> &input,
5209: Stream &Stream::ThenFft(fft::Plan *plan,
5227: Stream &Stream::ThenFft(fft::Plan *plan,
5247: Stream &Stream::ThenEnqueueOnBackgroundThread(
5259: port::Status Stream::BlockHostUntilDone() {
5283: void Stream::CheckStatus(port::Status status) {
259:                internal::StreamInterface *implementation)
280:     parent_->DeallocateStream(this);
298:   if (parent_->AllocateStream(this)) {
757:           << "attempting to perform DNN operation using StreamExecutor "
787:           << "attempting to perform DNN operation using StreamExecutor "
1238:           << "attempting to perform DNN operation using StreamExecutor "
1335:           << "attempting to perform DNN operation using StreamExecutor "
1755:       // The stream is reusable and not ok. Streams have a monotonic state
1801:       // The returned stream is not ok. Streams have a monotonic state
1904:           << "attempting to perform BLAS operation using StreamExecutor "
4689:                 << " attempting to perform RNG operation using StreamExecutor"
4706:                 << " attempting to perform RNG operation using StreamExecutor"
4723:                 << " attempting to perform RNG operation using StreamExecutor"
4739:                 << " attempting to perform RNG operation using StreamExecutor"
4756:                 << " attempting to perform RNG operation using StreamExecutor"
4773:                 << " attempting to perform RNG operation using StreamExecutor"
5150:                 << " attempting to perform FFT operation using StreamExecutor"
5168:                 << " attempting to perform FFT operation using StreamExecutor"
5185:                 << " attempting to perform FFT operation using StreamExecutor"
5202:                 << " attempting to perform FFT operation using StreamExecutor"
5220:                 << " attempting to perform FFT operation using StreamExecutor"
5238:                 << " attempting to perform FFT operation using StreamExecutor"
5248:     std::function<void(StreamExecutor *)> task) {
5251:   StreamExecutor *stream_executor = this->parent_;
214:   string str = absl::StrCat(stream->DebugStreamPointers(),
251:       implementation_(parent->implementation()->GetStreamImplementation()),
1749:         VLOG(1) << DebugStreamPointers() << " reusing sub_stream "
1750:                 << sub_stream->DebugStreamPointers();
1763:       VLOG(1) << DebugStreamPointers() << " dropped !ok sub_stream "
1764:               << sub_stream->DebugStreamPointers();
1779:   VLOG(1) << DebugStreamPointers() << " created new sub_stream "
1780:           << sub_stream->DebugStreamPointers();
1797:       VLOG(1) << DebugStreamPointers() << " returned ok sub_stream "
1798:               << sub_stream->DebugStreamPointers();
1804:       VLOG(1) << DebugStreamPointers() << " returned !ok sub_stream "
1805:               << sub_stream->DebugStreamPointers();
1815:   LOG(FATAL) << DebugStreamPointers()
1817:              << sub_stream->DebugStreamPointers();
1826:     LOG(INFO) << DebugStreamPointers()
1838:     LOG(INFO) << DebugStreamPointers()
1849:     CheckError(parent_->CreateStreamDependency(this, other));
1852:     LOG(INFO) << DebugStreamPointers() << " did not wait for "
1853:               << other->DebugStreamPointers();
1870:     LOG(INFO) << DebugStreamPointers() << " did not wait for an event.";
4670:       LOG(INFO) << DebugStreamPointers() << " unable to initialize RNG";
4673:     LOG(INFO) << DebugStreamPointers()
4688:       LOG(INFO) << DebugStreamPointers()
4705:       LOG(INFO) << DebugStreamPointers()
4722:       LOG(INFO) << DebugStreamPointers()
4738:       LOG(INFO) << DebugStreamPointers()
4755:       LOG(INFO) << DebugStreamPointers()
4772:       LOG(INFO) << DebugStreamPointers()
4787:     LOG(INFO) << DebugStreamPointers()
4800:     LOG(INFO) << DebugStreamPointers()
4813:     LOG(INFO) << DebugStreamPointers()
4825:     LOG(INFO) << DebugStreamPointers()
4838:     LOG(INFO) << DebugStreamPointers()
5120:     LOG(INFO) << DebugStreamPointers()
5132:     LOG(INFO) << DebugStreamPointers()
5149:       LOG(INFO) << DebugStreamPointers()
5167:       LOG(INFO) << DebugStreamPointers()
5184:       LOG(INFO) << DebugStreamPointers()
5201:       LOG(INFO) << DebugStreamPointers()
5219:       LOG(INFO) << DebugStreamPointers()
5237:       LOG(INFO) << DebugStreamPointers()
5266:     LOG(INFO) << DebugStreamPointers() << " " << status;
github.com/tensorflow/deepmath:fold/tensorflow/tensorflow/stream_executor/stream.cc: [ master, ]
219: Stream::Stream(StreamExecutor *parent)
228: Stream::Stream(StreamExecutor *parent,
238: Stream::~Stream() {
1442: Stream *Stream::GetOrCreateSubStream() {
1459: void Stream::ReturnSubStream(Stream *sub_stream) {
178: // there are on Stream and how many parameters they each have.
179: string CallStr(const char *function_name, Stream *stream,
185:   string str = port::StrCat("Called Stream::", function_name, "(");
248: Stream &Stream::Init() {
267: Stream &Stream::InitTimer(Timer *timer) {
278: Stream &Stream::InitWithTimer(Timer *timer) {
284: Stream &Stream::ThenRecordEvent(Event *event) {
297: Stream &Stream::ThenBatchNormalizationForward(
325: Stream &Stream::ThenBatchNormalizationBackward(
347: Stream &Stream::ThenConvolveWithScratch(
375: Stream &Stream::ThenConvolveWithScratch(
402: Stream &Stream::ThenConvolveWithAlgorithm(
433: Stream &Stream::ThenConvolveWithAlgorithm(
464: Stream &Stream::ThenConvolve(
478: Stream &Stream::ThenConvolveQuantized(
508: Stream &Stream::ThenConvolveQuantized(
538: Stream &Stream::ThenSeparableConvolve(
565: Stream &Stream::ThenConvolveBackwardDataWithScratch(
593: Stream &Stream::ThenConvolveBackwardDataWithAlgorithm(
626: Stream &Stream::ThenConvolveBackwardDataWithAlgorithm(
659: Stream &Stream::ThenConvolveBackwardDataWithScratch(
687: Stream &Stream::ThenConvolveBackwardData(
701: Stream &Stream::ThenConvolveBackwardFilterWithScratch(
729: Stream &Stream::ThenConvolveBackwardFilterWithAlgorithm(
762: Stream &Stream::ThenConvolveBackwardFilterWithScratch(
790: Stream &Stream::ThenConvolveBackwardFilterWithAlgorithm(
823: Stream &Stream::ThenConvolveBackwardFilter(
838: Stream &Stream::ThenConvolveBackwardBiasImpl(
858: Stream &Stream::ThenConvolveBackwardBias(
867: Stream &Stream::ThenConvolveBackwardBias(
876: Stream &Stream::ThenConvolveBackwardBias(
885: Stream &Stream::ThenMatMul(const DeviceMemory<float> &input_data,
904: Stream &Stream::ThenMatMulQuantized(
926: Stream &Stream::ThenMatMulQuantized(
948: Stream &Stream::ThenBiasAdd(const DeviceMemory<float> &input_data,
966: Stream &Stream::ThenPoolForward(
987: Stream &Stream::ThenPoolForward(
1008: Stream &Stream::ThenPoolBackward(
1032: Stream &Stream::ThenPoolBackward(
1056: Stream &Stream::ThenNormalize(
1072: Stream &Stream::ThenNormalizeWithDimensions(
1090: Stream &Stream::ThenNormalizeBackwardWithDimensions(
1112: Stream &Stream::ThenActivate(dnn::ActivationMode activation_mode,
1120: Stream &Stream::ThenActivateWithOptions(dnn::ActivationMode activation_mode,
1139: Stream &Stream::ThenDepthConcatenate(
1169: Stream &Stream::ThenSpaceConcatenate(
1216: Stream &Stream::ThenReshape(const dnn::BatchDescriptor &input_dimensions,
1234: Stream &Stream::ThenDepthToSpace(
1255: Stream &Stream::ThenSpaceToDepth(
1276: Stream &Stream::ThenElementwiseOperate(
1297: Stream &Stream::ThenElementwiseOperateScaledQuantized(
1320: Stream &Stream::ThenXYPad(const dnn::BatchDescriptor &dimensions,
1339: Stream &Stream::ThenXYSlice(const dnn::BatchDescriptor &dimensions,
1360: Stream &Stream::ThenXYBroadcast(const dnn::BatchDescriptor &dimensions,
1378: Stream &Stream::ThenMemcpyD2HQuantized(
1395: Stream &Stream::ThenMemcpyH2DQuantized(
1412: Stream &Stream::ThenCopyHostBuffer2Device(
1427: Stream &Stream::ThenCopyDevice2HostBuffer(
1450:   sub_streams_.emplace_back(std::unique_ptr<Stream>{new Stream{parent_}},
1452:   Stream *sub_stream = sub_streams_.back().first.get();
1470: Stream &Stream::ThenStartTimer(Timer *t) {
1481: Stream &Stream::ThenStopTimer(Timer *t) {
1492: Stream &Stream::ThenWaitFor(Stream *other) {
1505: Stream &Stream::ThenWaitFor(Event *event) {
1527:   // arguments except the first one of Stream* type.
1528:   Stream &operator()(Stream *stream,
1529:                      bool (blas::BlasSupport::*blas_func)(Stream *, Args...),
1536:   Stream &Run(Stream *stream,
1537:               bool (blas::BlasSupport::*blas_func)(Stream *, Args...),
1542: Stream &ThenBlasImpl<Args...>::Run(
1543:     Stream *stream, bool (blas::BlasSupport::*blas_func)(Stream *, Args...),
1562: Stream &Stream::ThenBlasAsum(uint64 elem_count, const DeviceMemory<float> &x,
1572: Stream &Stream::ThenBlasAsum(uint64 elem_count, const DeviceMemory<double> &x,
1582: Stream &Stream::ThenBlasAsum(uint64 elem_count,
1593: Stream &Stream::ThenBlasAsum(uint64 elem_count,
1604: Stream &Stream::ThenBlasAxpy(uint64 elem_count, float alpha,
1616: Stream &Stream::ThenBlasAxpy(uint64 elem_count, double alpha,
1628: Stream &Stream::ThenBlasAxpy(uint64 elem_count, std::complex<float> alpha,
1642: Stream &Stream::ThenBlasAxpy(uint64 elem_count, std::complex<double> alpha,
1656: Stream &Stream::ThenBlasCopy(uint64 elem_count, const DeviceMemory<float> &x,
1666: Stream &Stream::ThenBlasCopy(uint64 elem_count, const DeviceMemory<double> &x,
1676: Stream &Stream::ThenBlasCopy(uint64 elem_count,
1688: Stream &Stream::ThenBlasCopy(uint64 elem_count,
1700: Stream &Stream::ThenBlasDot(uint64 elem_count, const DeviceMemory<float> &x,
1712: Stream &Stream::ThenBlasDot(uint64 elem_count, const DeviceMemory<double> &x,
1724: Stream &Stream::ThenBlasDotc(uint64 elem_count,
1740: Stream &Stream::ThenBlasDotc(uint64 elem_count,
1756: Stream &Stream::ThenBlasDotu(uint64 elem_count,
1772: Stream &Stream::ThenBlasDotu(uint64 elem_count,
1788: Stream &Stream::ThenBlasNrm2(uint64 elem_count, const DeviceMemory<float> &x,
1798: Stream &Stream::ThenBlasNrm2(uint64 elem_count, const DeviceMemory<double> &x,
1808: Stream &Stream::ThenBlasNrm2(uint64 elem_count,
1819: Stream &Stream::ThenBlasNrm2(uint64 elem_count,
1830: Stream &Stream::ThenBlasRot(uint64 elem_count, DeviceMemory<float> *x, int incx,
1842: Stream &Stream::ThenBlasRot(uint64 elem_count, DeviceMemory<double> *x,
1854: Stream &Stream::ThenBlasRot(uint64 elem_count,
1867: Stream &Stream::ThenBlasRot(uint64 elem_count,
1880: Stream &Stream::ThenBlasRotg(DeviceMemory<float> *a, DeviceMemory<float> *b,
1889: Stream &Stream::ThenBlasRotg(DeviceMemory<double> *a, DeviceMemory<double> *b,
1898: Stream &Stream::ThenBlasRotg(DeviceMemory<std::complex<float>> *a,
1910: Stream &Stream::ThenBlasRotg(DeviceMemory<std::complex<double>> *a,
1922: Stream &Stream::ThenBlasRotm(uint64 elem_count, DeviceMemory<float> *x,
1934: Stream &Stream::ThenBlasRotm(uint64 elem_count, DeviceMemory<double> *x,
1946: Stream &Stream::ThenBlasRotmg(DeviceMemory<float> *d1, DeviceMemory<float> *d2,
1958: Stream &Stream::ThenBlasRotmg(DeviceMemory<double> *d1,
1971: Stream &Stream::ThenBlasScal(uint64 elem_count, float alpha,
1979: Stream &Stream::ThenBlasScal(uint64 elem_count, double alpha,
1987: Stream &Stream::ThenBlasScal(uint64 elem_count, float alpha,
1995: Stream &Stream::ThenBlasScal(uint64 elem_count, double alpha,
2003: Stream &Stream::ThenBlasScal(uint64 elem_count, std::complex<float> alpha,
2012: Stream &Stream::ThenBlasScal(uint64 elem_count, std::complex<double> alpha,
2021: Stream &Stream::ThenBlasSwap(uint64 elem_count, DeviceMemory<float> *x,
2031: Stream &Stream::ThenBlasSwap(uint64 elem_count, DeviceMemory<double> *x,
2041: Stream &Stream::ThenBlasSwap(uint64 elem_count,
2052: Stream &Stream::ThenBlasSwap(uint64 elem_count,
2063: Stream &Stream::ThenBlasIamax(uint64 elem_count, const DeviceMemory<float> &x,
2073: Stream &Stream::ThenBlasIamax(uint64 elem_count, const DeviceMemory<double> &x,
2083: Stream &Stream::ThenBlasIamax(uint64 elem_count,
2094: Stream &Stream::ThenBlasIamax(uint64 elem_count,
2105: Stream &Stream::ThenBlasIamin(uint64 elem_count, const DeviceMemory<float> &x,
2115: Stream &Stream::ThenBlasIamin(uint64 elem_count, const DeviceMemory<double> &x,
2125: Stream &Stream::ThenBlasIamin(uint64 elem_count,
2136: Stream &Stream::ThenBlasIamin(uint64 elem_count,
2147: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2163: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2179: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2199: Stream &Stream::ThenBlasGbmv(blas::Transpose trans, uint64 m, uint64 n,
2219: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2234: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2249: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2269: Stream &Stream::ThenBlasGemv(blas::Transpose trans, uint64 m, uint64 n,
2289: Stream &Stream::ThenBlasGer(uint64 m, uint64 n, float alpha,
2303: Stream &Stream::ThenBlasGer(uint64 m, uint64 n, double alpha,
2317: Stream &Stream::ThenBlasGerc(uint64 m, uint64 n, std::complex<float> alpha,
2334: Stream &Stream::ThenBlasGerc(uint64 m, uint64 n, std::complex<double> alpha,
2351: Stream &Stream::ThenBlasGeru(uint64 m, uint64 n, std::complex<float> alpha,
2368: Stream &Stream::ThenBlasGeru(uint64 m, uint64 n, std::complex<double> alpha,
2385: Stream &Stream::ThenBlasHbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2404: Stream &Stream::ThenBlasHbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2423: Stream &Stream::ThenBlasHemv(blas::UpperLower uplo, uint64 n,
2442: Stream &Stream::ThenBlasHemv(blas::UpperLower uplo, uint64 n,
2461: Stream &Stream::ThenBlasHer(blas::UpperLower uplo, uint64 n, float alpha,
2475: Stream &Stream::ThenBlasHer(blas::UpperLower uplo, uint64 n, double alpha,
2489: Stream &Stream::ThenBlasHer2(blas::UpperLower uplo, uint64 n,
2507: Stream &Stream::ThenBlasHer2(blas::UpperLower uplo, uint64 n,
2525: Stream &Stream::ThenBlasHpmv(blas::UpperLower uplo, uint64 n,
2543: Stream &Stream::ThenBlasHpmv(blas::UpperLower uplo, uint64 n,
2561: Stream &Stream::ThenBlasHpr(blas::UpperLower uplo, uint64 n, float alpha,
2573: Stream &Stream::ThenBlasHpr(blas::UpperLower uplo, uint64 n, double alpha,
2585: Stream &Stream::ThenBlasHpr2(blas::UpperLower uplo, uint64 n,
2602: Stream &Stream::ThenBlasHpr2(blas::UpperLower uplo, uint64 n,
2619: Stream &Stream::ThenBlasSbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2633: Stream &Stream::ThenBlasSbmv(blas::UpperLower uplo, uint64 n, uint64 k,
2647: Stream &Stream::ThenBlasSpmv(blas::UpperLower uplo, uint64 n, float alpha,
2661: Stream &Stream::ThenBlasSpmv(blas::UpperLower uplo, uint64 n, double alpha,
2675: Stream &Stream::ThenBlasSpr(blas::UpperLower uplo, uint64 n, float alpha,
2686: Stream &Stream::ThenBlasSpr(blas::UpperLower uplo, uint64 n, double alpha,
2697: Stream &Stream::ThenBlasSpr2(blas::UpperLower uplo, uint64 n, float alpha,
2711: Stream &Stream::ThenBlasSpr2(blas::UpperLower uplo, uint64 n, double alpha,
2725: Stream &Stream::ThenBlasSymv(blas::UpperLower uplo, uint64 n, float alpha,
2739: Stream &Stream::ThenBlasSymv(blas::UpperLower uplo, uint64 n, double alpha,
2753: Stream &Stream::ThenBlasSyr(blas::UpperLower uplo, uint64 n, float alpha,
2765: Stream &Stream::ThenBlasSyr(blas::UpperLower uplo, uint64 n, double alpha,
2777: Stream &Stream::ThenBlasSyr2(blas::UpperLower uplo, uint64 n, float alpha,
2791: Stream &Stream::ThenBlasSyr2(blas::UpperLower uplo, uint64 n, double alpha,
2805: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
2819: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
2833: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
2848: Stream &Stream::ThenBlasTbmv(blas::UpperLower uplo, blas::Transpose trans,
2863: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
2877: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
2891: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
2906: Stream &Stream::ThenBlasTbsv(blas::UpperLower uplo, blas::Transpose trans,
2921: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
2934: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
2947: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
2961: Stream &Stream::ThenBlasTpmv(blas::UpperLower uplo, blas::Transpose trans,
2975: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
2988: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3001: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3015: Stream &Stream::ThenBlasTpsv(blas::UpperLower uplo, blas::Transpose trans,
3029: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3043: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3057: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3072: Stream &Stream::ThenBlasTrmv(blas::UpperLower uplo, blas::Transpose trans,
3087: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3101: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3115: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3130: Stream &Stream::ThenBlasTrsv(blas::UpperLower uplo, blas::Transpose trans,
3145: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3163: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3179: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3195: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3216: Stream &Stream::ThenBlasGemm(blas::Transpose transa, blas::Transpose transb,
3244:   Stream &operator()(Stream *stream,
3246:                          Stream *, Args..., blas::ProfileResult *),
3255: Stream &Stream::ThenBlasGemmWithAlgorithm(
3279: Stream &Stream::ThenBlasGemmWithAlgorithm(
3300: Stream &Stream::ThenBlasGemmWithAlgorithm(
3322: Stream &Stream::ThenBlasGemmWithAlgorithm(
3347: Stream &Stream::ThenBlasGemmWithAlgorithm(
3372: Stream &Stream::ThenBlasHemm(blas::Side side, blas::UpperLower uplo, uint64 m,
3392: Stream &Stream::ThenBlasHemm(blas::Side side, blas::UpperLower uplo, uint64 m,
3412: Stream &Stream::ThenBlasHerk(blas::UpperLower uplo, blas::Transpose trans,
3427: Stream &Stream::ThenBlasHerk(blas::UpperLower uplo, blas::Transpose trans,
3442: Stream &Stream::ThenBlasHer2k(blas::UpperLower uplo, blas::Transpose trans,
3461: Stream &Stream::ThenBlasHer2k(blas::UpperLower uplo, blas::Transpose trans,
3480: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
3496: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
3512: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
3532: Stream &Stream::ThenBlasSymm(blas::Side side, blas::UpperLower uplo, uint64 m,
3552: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
3566: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
3580: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
3596: Stream &Stream::ThenBlasSyrk(blas::UpperLower uplo, blas::Transpose trans,
3612: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
3628: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
3644: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
3664: Stream &Stream::ThenBlasSyr2k(blas::UpperLower uplo, blas::Transpose trans,
3684: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
3699: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
3714: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
3731: Stream &Stream::ThenBlasTrmm(blas::Side side, blas::UpperLower uplo,
3748: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
3763: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
3778: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
3795: Stream &Stream::ThenBlasTrsm(blas::Side side, blas::UpperLower uplo,
3812: Stream &Stream::ThenBlasGemmBatched(
3823: Stream &Stream::ThenBlasGemmBatchedWithScratch(
3844: Stream &Stream::ThenBlasGemmBatched(
3855: Stream &Stream::ThenBlasGemmBatchedWithScratch(
3876: Stream &Stream::ThenBlasGemmBatched(
3889: Stream &Stream::ThenBlasGemmBatchedWithScratch(
3915: Stream &Stream::ThenBlasGemmBatched(
3928: Stream &Stream::ThenBlasGemmBatchedWithScratch(
3954: Stream &Stream::ThenSetRngSeed(const uint8 *seed, uint64 seed_bytes) {
3972: Stream &Stream::ThenPopulateRandUniform(DeviceMemory<float> *values) {
3987: Stream &Stream::ThenPopulateRandGaussian(float mean, float sd,
4003: Stream &Stream::ThenPopulateRandGaussian(double mean, double sd,
4019: Stream &Stream::ThenPopulateRandUniform(DeviceMemory<double> *values) {
4034: Stream &Stream::ThenPopulateRandUniform(
4050: Stream &Stream::ThenPopulateRandUniform(
4067: Stream &Stream::ThenMemcpy(void *host_dst, const DeviceMemoryBase &gpu_src,
4080: Stream &Stream::ThenMemcpy(DeviceMemoryBase *gpu_dst, const void *host_src,
4093: Stream &Stream::ThenMemcpy(DeviceMemoryBase *gpu_dst,
4106: Stream &Stream::ThenMemZero(DeviceMemoryBase *location, uint64 size) {
4118: Stream &Stream::ThenMemset32(DeviceMemoryBase *location, const uint32 &pattern,
4132: Stream &Stream::ThenRnnForward(
4164: Stream &Stream::ThenRnnBackward(
4205: Stream &Stream::ThenDoHostCallbackForTest(std::function<void()> callback) {
4211: Stream &Stream::ThenDoHostCallback(std::function<void()> callback) {
4223: Stream &Stream::ThenFft(fft::Plan *plan,
4240: Stream &Stream::ThenFft(fft::Plan *plan,
4257: Stream &Stream::ThenFft(fft::Plan *plan, const DeviceMemory<float> &input,
4273: Stream &Stream::ThenFft(fft::Plan *plan, const DeviceMemory<double> &input,
4289: Stream &Stream::ThenFft(fft::Plan *plan,
4306: Stream &Stream::ThenFft(fft::Plan *plan,
4325: Stream &Stream::ThenEnqueueOnBackgroundThread(
4337: bool Stream::BlockHostUntilDone() {
229:                internal::StreamInterface *implementation)
244:     parent_->DeallocateStream(this);
256:   if (parent_->AllocateStream(this)) {
501:           << "attempting to perform DNN operation using StreamExecutor "
531:           << "attempting to perform DNN operation using StreamExecutor "
1551:           << "attempting to perform BLAS operation using StreamExecutor "
3980:       LOG(INFO) << "attempting to perform RNG operation using StreamExecutor "
3996:       LOG(INFO) << "attempting to perform RNG operation using StreamExecutor "
4012:       LOG(INFO) << "attempting to perform RNG operation using StreamExecutor "
4027:       LOG(INFO) << "attempting to perform RNG operation using StreamExecutor "
4043:       LOG(INFO) << "attempting to perform RNG operation using StreamExecutor "
4060:                 << " attempting to perform RNG operation using StreamExecutor "
4233:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4250:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4266:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4282:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4299:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4316:       LOG(INFO) << "attempting to perform FFT operation using StreamExecutor "
4326:     std::function<void(StreamExecutor *)> task) {
4329:   StreamExecutor *stream_executor = this->parent_;
221:       implementation_(parent->implementation()->GetStreamImplementation()),
1497:     CheckError(parent_->CreateStreamDependency(this, other));
github.com/firebase/firebase-android-sdk:firebase-crashlytics-ndk/src/third_party/crashpad/third_party/cpp-httplib/cpp-httplib/httplib.h: [ master, ]
161: class Stream {
163:     virtual ~Stream() {}
173: class SocketStream : public Stream {
308: class SSLSocketStream : public Stream {
1388: inline SocketStream::SocketStream(socket_t sock): sock_(sock)
1392: inline SocketStream::~SocketStream()
2221: inline SSLSocketStream::SSLSocketStream(socket_t sock, SSL* ssl)
2226: inline SSLSocketStream::~SSLSocketStream()
221:     bool process_request(Stream& strm, bool last_connection, bool& connection_close);
237:     void write_response(Stream& strm, bool last_connection, const Request& req, Response& res);
292:     bool process_request(Stream& strm, Request& req, Response& res, bool& connection_close);
301:     bool read_response_line(Stream& strm, Response& res);
302:     void write_request(Stream& strm, Request& req);
386:     stream_line_reader(Stream& strm, char* fixed_buffer, size_t fixed_buffer_size)
442:     Stream& strm_;
761: inline bool read_headers(Stream& strm, Headers& headers)
788: inline bool read_content_with_length(Stream& strm, std::string& out, size_t len, Progress progress)
808: inline bool read_content_without_length(Stream& strm, std::string& out)
824: inline bool read_content_chunked(Stream& strm, std::string& out)
870: bool read_content(Stream& strm, T& x, Progress progress = Progress())
890: inline void write_headers(Stream& strm, const T& info)
1358: inline void Stream::write_format(const char* fmt, const Args& ...args)
1539: inline void Server::write_response(Stream& strm, bool last_connection, const Request& req, Response& res)
1750: inline bool Server::process_request(Stream& strm, bool last_connection, bool& connection_close)
1837:         [this](Stream& strm, bool last_connection, bool& connection_close) {
1881: inline bool Client::read_response_line(Stream& strm, Response& res)
1917: inline void Client::write_request(Stream& strm, Request& req)
1964: inline bool Client::process_request(Stream& strm, Request& req, Response& res, bool& connection_close)
2001:         [&](Stream& strm, bool /*last_connection*/, bool& connection_close) {
2292:         [this](Stream& strm, bool last_connection, bool& connection_close) {
2325:         [&](Stream& strm, bool /*last_connection*/, bool& connection_close) {
175:     SocketStream(socket_t sock);
176:     virtual ~SocketStream();
310:     SSLSocketStream(socket_t sock, SSL* ssl);
311:     virtual ~SSLSocketStream();
510:             SocketStream strm(sock);
522:         SocketStream strm(sock);
1396: inline int SocketStream::read(char* ptr, size_t size)
1401: inline int SocketStream::write(const char* ptr, size_t size)
1406: inline int SocketStream::write(const char* ptr)
1411: inline std::string SocketStream::get_remote_addr() {
2179:             SSLSocketStream strm(sock, ssl);
2191:         SSLSocketStream strm(sock, ssl);
2230: inline int SSLSocketStream::read(char* ptr, size_t size)
2235: inline int SSLSocketStream::write(const char* ptr, size_t size)
2240: inline int SSLSocketStream::write(const char* ptr)
2245: inline std::string SSLSocketStream::get_remote_addr() {
github.com/googledatalab/datalab:third_party/externs/ts/node/node.d.ts: [ master, ]
1131:     export interface Stream extends events.EventEmitter {
99:     export interface ReadableStream extends EventEmitter {
112:     export interface WritableStream extends EventEmitter {
123:     export interface ReadWriteStream extends ReadableStream, WritableStream {}
830:     export interface ReadStream extends stream.Readable {}
831:     export interface WriteStream extends stream.Writable {}
937:     export function createReadStream(path: string, options?: {
1027:     export interface ClearTextStream extends stream.Duplex {
1301:     export interface WriteStream extends net.Socket {
105:         pipe<T extends WritableStream>(destination: T, options?: { end?: boolean; }): T;
106:         unpipe<T extends WritableStream>(destination?: T): void;
109:         wrap(oldStream: ReadableStream): ReadableStream;
126:         stdout: WritableStream;
127:         stderr: WritableStream;
128:         stdin: ReadableStream;
561:         input?: NodeJS.ReadableStream;
562:         output?: NodeJS.WritableStream;
587:         input: NodeJS.ReadableStream;
588:         output: NodeJS.WritableStream;
930:     export function createReadStream(path: string, options?: {
936:     }): ReadStream;
943:     }): ReadStream;
944:     export function createWriteStream(path: string, options?: {
948:     }): WriteStream;
1049:     export function createServer(options: TlsOptions, secureConnectionListener?: (cleartextStream: ClearTextStream) =>void ): Server;
1050:     export function connect(options: TlsOptions, secureConnectionListener?: () =>void ): ClearTextStream;
1051: ...(32 bytes skipped)...: number, host?: string, options?: ConnectionOptions, secureConnectListener?: () =>void ): ClearTextStream;
1052: ...(17 bytes skipped)...on connect(port: number, options?: ConnectionOptions, secureConnectListener?: () =>void ): ClearTextStream;
1132:         pipe<T extends NodeJS.WritableStream>(destination: T, options?: { end?: boolean; }): T;
1141:     export class Readable extends events.EventEmitter implements NodeJS.ReadableStream {
1149:         pipe<T extends NodeJS.WritableStream>(destination: T, options?: { end?: boolean; }): T;
1150:         unpipe<T extends NodeJS.WritableStream>(destination?: T): void;
1153:         wrap(oldStream: NodeJS.ReadableStream): NodeJS.ReadableStream;
1162:     export class Writable extends events.EventEmitter implements NodeJS.WritableStream {
1181:     export class Duplex extends Readable implements NodeJS.ReadWriteStream {
1198:     export class Transform extends events.EventEmitter implements NodeJS.ReadWriteStream {
1209:         pipe<T extends NodeJS.WritableStream>(destination: T, options?: { end?: boolean; }): T;
1210:         unpipe<T extends NodeJS.WritableStream>(destination?: T): void;
1213:         wrap(oldStream: NodeJS.ReadableStream): NodeJS.ReadableStream;
1297:     export interface ReadStream extends net.Socket {
github.com/google/mediapipe:mediapipe/framework/api2/builder.h: [ master, ]
269: using Stream = Source<T>;
255: //   Stream<Image> Resize(Stream<Image> image, const Size& size, Graph& graph) {
266: //   Stream<Image> input_image = graph.In("INPUT_IMAGE").Cast<Image>();
267: //   Stream<Image> resized_image = Resize(input_image, {64, 64}, graph);
github.com/apache/rocketmq-externals:rocketmq-knative/source/vendor/github.com/aliyun/aliyun-tablestore-go-sdk/tablestore/otsprotocol/table_store.pb.go: [ master, ]
2188: type Stream struct {
316: type StreamStatus int32
319: 	StreamStatus_STREAM_ENABLING StreamStatus = 1
320: 	StreamStatus_STREAM_ACTIVE   StreamStatus = 2
323: var StreamStatus_name = map[int32]string{
327: var StreamStatus_value = map[string]int32{
790: type StreamSpecification struct {
791: 	EnableStream     *bool  `protobuf:"varint,1,req,name=enable_stream" json:"enable_stream,omitempty"`
801: func (m *StreamSpecification) GetEnableStream() bool {
815: type StreamDetails struct {
816: 	EnableStream     *bool   `protobuf:"varint,1,req,name=enable_stream" json:"enable_stream,omitempty"`
817: 	StreamId         *string `protobuf:"bytes,2,opt,name=stream_id" json:"stream_id,omitempty"`
828: func (m *StreamDetails) GetEnableStream() bool {
871: 	StreamSpec         *StreamSpecification `protobuf:"bytes,5,opt,name=stream_spec" json:"stream_spec,omitempty"`
937: 	StreamSpec         *StreamSpecification `protobuf:"bytes,4,opt,name=stream_spec" json:"stream_spec,omitempty"`
977: 	StreamDetails             *StreamDetails             `protobuf:"bytes,3,opt,name=stream_details" json:"stream_details,omitempty"`
1030: 	StreamDetails             *StreamDetails             `protobuf:"bytes,5,opt,name=stream_details" json:"stream_details,omitempty"`
2189: 	StreamId         *string `protobuf:"bytes,1,req,name=stream_id" json:"stream_id,omitempty"`
2222: 	Streams          []*Stream `protobuf:"bytes,1,rep,name=streams" json:"streams,omitempty"`
2238: type StreamShard struct {
2272: 	StreamId              *string `protobuf:"bytes,1,req,name=stream_id" json:"stream_id,omitempty"`
2305: 	StreamId         *string        `protobuf:"bytes,1,req,name=stream_id" json:"stream_id,omitempty"`
2309: 	StreamStatus     *StreamStatus  `protobuf:"varint,5,req,name=stream_status,enum=otsprotocol.StreamStatus" json:"stream_status,omitempty"`
2370: 	StreamId         *string `protobuf:"bytes,1,req,name=stream_id" json:"stream_id,omitempty"`
2461: 	StreamRecords     []*GetStreamRecordResponse_StreamRecord `protobuf:"bytes,1,rep,name=stream_records" json:"stream_records,omitempty"`
2485: type GetStreamRecordResponse_StreamRecord struct {
835: func (m *StreamDetails) GetStreamId() string {
909: func (m *CreateTableRequest) GetStreamSpec() *StreamSpecification {
967: func (m *UpdateTableRequest) GetStreamSpec() *StreamSpecification {
1000: func (m *UpdateTableResponse) GetStreamDetails() *StreamDetails {
1069: func (m *DescribeTableResponse) GetStreamDetails() *StreamDetails {
2171: type ListStreamRequest struct {
2200: func (m *Stream) GetStreamId() string {
2221: type ListStreamResponse struct {
2231: func (m *ListStreamResponse) GetStreams() []*Stream {
2271: type DescribeStreamRequest struct {
2283: func (m *DescribeStreamRequest) GetStreamId() string {
2304: type DescribeStreamResponse struct {
2320: func (m *DescribeStreamResponse) GetStreamId() string {
2348: func (m *DescribeStreamResponse) GetStreamStatus() StreamStatus {
2382: func (m *GetShardIteratorRequest) GetStreamId() string {
2435: type GetStreamRecordRequest struct {
2460: type GetStreamRecordResponse struct {
2471: func (m *GetStreamRecordResponse) GetStreamRecords() []*GetStreamRecordResponse_StreamRecord {
2195: func (m *Stream) Reset()                    { *m = Stream{} }
2196: func (m *Stream) String() string            { return proto.CompactTextString(m) }
2197: func (*Stream) ProtoMessage()               {}
2198: func (*Stream) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{50} }
2207: func (m *Stream) GetTableName() string {
2214: func (m *Stream) GetCreationTime() int64 {
2993: 	proto.RegisterType((*Stream)(nil), "otsprotocol.Stream")
332: func (x StreamStatus) Enum() *StreamStatus {
333: 	p := new(StreamStatus)
337: func (x StreamStatus) String() string {
338: 	return proto.EnumName(StreamStatus_name, int32(x))
340: func (x *StreamStatus) UnmarshalJSON(data []byte) error {
341: 	value, err := proto.UnmarshalJSONEnum(StreamStatus_value, data, "StreamStatus")
345: 	*x = StreamStatus(value)
348: func (StreamStatus) EnumDescriptor() ([]byte, []int) { return fileDescriptor2, []int{8} }
796: func (m *StreamSpecification) Reset()                    { *m = StreamSpecification{} }
797: func (m *StreamSpecification) String() string            { return proto.CompactTextString(m) }
798: func (*StreamSpecification) ProtoMessage()               {}
799: func (*StreamSpecification) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{10} }
802: 	if m != nil && m.EnableStream != nil {
803: 		return *m.EnableStream
808: func (m *StreamSpecification) GetExpirationTime() int32 {
823: func (m *StreamDetails) Reset()                    { *m = StreamDetails{} }
824: func (m *StreamDetails) String() string            { return proto.CompactTextString(m) }
825: func (*StreamDetails) ProtoMessage()               {}
826: func (*StreamDetails) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{11} }
829: 	if m != nil && m.EnableStream != nil {
830: 		return *m.EnableStream
836: 	if m != nil && m.StreamId != nil {
837: 		return *m.StreamId
842: func (m *StreamDetails) GetExpirationTime() int32 {
849: func (m *StreamDetails) GetLastEnableTime() int64 {
911: 		return m.StreamSpec
969: 		return m.StreamSpec
1002: 		return m.StreamDetails
1071: 		return m.StreamDetails
2201: 	if m != nil && m.StreamId != nil {
2202: 		return *m.StreamId
2233: 		return m.Streams
2245: func (m *StreamShard) Reset()                    { *m = StreamShard{} }
2246: func (m *StreamShard) String() string            { return proto.CompactTextString(m) }
2247: func (*StreamShard) ProtoMessage()               {}
2248: func (*StreamShard) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{52} }
2250: func (m *StreamShard) GetShardId() string {
2257: func (m *StreamShard) GetParentId() string {
2264: func (m *StreamShard) GetParentSiblingId() string {
2284: 	if m != nil && m.StreamId != nil {
2285: 		return *m.StreamId
2310: 	Shards           []*StreamShard `protobuf:"bytes,6,rep,name=shards" json:"shards,omitempty"`
2321: 	if m != nil && m.StreamId != nil {
2322: 		return *m.StreamId
2349: 	if m != nil && m.StreamStatus != nil {
2350: 		return *m.StreamStatus
2352: 	return StreamStatus_STREAM_ENABLING
2355: func (m *DescribeStreamResponse) GetShards() []*StreamShard {
2383: 	if m != nil && m.StreamId != nil {
2384: 		return *m.StreamId
2473: 		return m.StreamRecords
2491: func (m *GetStreamRecordResponse_StreamRecord) Reset()         { *m = GetStreamRecordResponse_StreamRecord{} }
2492: func (m *GetStreamRecordResponse_StreamRecord) String() string { return proto.CompactTextString(m) }
2493: func (*GetStreamRecordResponse_StreamRecord) ProtoMessage()    {}
2494: func (*GetStreamRecordResponse_StreamRecord) Descriptor() ([]byte, []int) {
2498: func (m *GetStreamRecordResponse_StreamRecord) GetActionType() ActionType {
2505: func (m *GetStreamRecordResponse_StreamRecord) GetRecord() []byte {
2953: 	proto.RegisterType((*StreamSpecification)(nil), "otsprotocol.StreamSpecification")
2954: 	proto.RegisterType((*StreamDetails)(nil), "otsprotocol.StreamDetails")
2995: 	proto.RegisterType((*StreamShard)(nil), "otsprotocol.StreamShard")
3002: 	proto.RegisterType((*GetStreamRecordResponse_StreamRecord)(nil), "otsprotocol.GetStreamRecordResponse.StreamRecord")
3030: 	proto.RegisterEnum("otsprotocol.StreamStatus", StreamStatus_name, StreamStatus_value)
2176: func (m *ListStreamRequest) Reset()                    { *m = ListStreamRequest{} }
2177: func (m *ListStreamRequest) String() string            { return proto.CompactTextString(m) }
2178: func (*ListStreamRequest) ProtoMessage()               {}
2179: func (*ListStreamRequest) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{49} }
2181: func (m *ListStreamRequest) GetTableName() string {
2226: func (m *ListStreamResponse) Reset()                    { *m = ListStreamResponse{} }
2227: func (m *ListStreamResponse) String() string            { return proto.CompactTextString(m) }
2228: func (*ListStreamResponse) ProtoMessage()               {}
2229: func (*ListStreamResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{51} }
2278: func (m *DescribeStreamRequest) Reset()                    { *m = DescribeStreamRequest{} }
2279: func (m *DescribeStreamRequest) String() string            { return proto.CompactTextString(m) }
2280: func (*DescribeStreamRequest) ProtoMessage()               {}
2281: func (*DescribeStreamRequest) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{53} }
2290: func (m *DescribeStreamRequest) GetInclusiveStartShardId() string {
2297: func (m *DescribeStreamRequest) GetShardLimit() int32 {
2315: func (m *DescribeStreamResponse) Reset()                    { *m = DescribeStreamResponse{} }
2316: func (m *DescribeStreamResponse) String() string            { return proto.CompactTextString(m) }
2317: func (*DescribeStreamResponse) ProtoMessage()               {}
2318: func (*DescribeStreamResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{54} }
2327: func (m *DescribeStreamResponse) GetExpirationTime() int32 {
2334: func (m *DescribeStreamResponse) GetTableName() string {
2341: func (m *DescribeStreamResponse) GetCreationTime() int64 {
2362: func (m *DescribeStreamResponse) GetNextShardId() string {
2441: func (m *GetStreamRecordRequest) Reset()                    { *m = GetStreamRecordRequest{} }
2442: func (m *GetStreamRecordRequest) String() string            { return proto.CompactTextString(m) }
2443: func (*GetStreamRecordRequest) ProtoMessage()               {}
2444: func (*GetStreamRecordRequest) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{57} }
2446: func (m *GetStreamRecordRequest) GetShardIterator() string {
2453: func (m *GetStreamRecordRequest) GetLimit() int32 {
2466: func (m *GetStreamRecordResponse) Reset()                    { *m = GetStreamRecordResponse{} }
2467: func (m *GetStreamRecordResponse) String() string            { return proto.CompactTextString(m) }
2468: func (*GetStreamRecordResponse) ProtoMessage()               {}
2469: func (*GetStreamRecordResponse) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{58} }
2478: func (m *GetStreamRecordResponse) GetNextShardIterator() string {
2992: 	proto.RegisterType((*ListStreamRequest)(nil), "otsprotocol.ListStreamRequest")
2994: 	proto.RegisterType((*ListStreamResponse)(nil), "otsprotocol.ListStreamResponse")
2996: 	proto.RegisterType((*DescribeStreamRequest)(nil), "otsprotocol.DescribeStreamRequest")
2997: 	proto.RegisterType((*DescribeStreamResponse)(nil), "otsprotocol.DescribeStreamResponse")
3000: 	proto.RegisterType((*GetStreamRecordRequest)(nil), "otsprotocol.GetStreamRecordRequest")
3001: 	proto.RegisterType((*GetStreamRecordResponse)(nil), "otsprotocol.GetStreamRecordResponse")
github.com/google/highwayhash:highwayhash/vector128.h: [ master, ]
709: HH_INLINE void Stream(const V128<T>& v, T* const HH_RESTRICT to) {
712: HH_INLINE void Stream(const V128<float>& v, float* const HH_RESTRICT to) {
715: HH_INLINE void Stream(const V128<double>& v, double* const HH_RESTRICT to) {
github.com/sourcegraph/thyme:data.go: [ master, ]
45: type Stream struct {
44: // Stream represents all the sampling data gathered by Thyme.
51: func (s Stream) Print() string {
github.com/google/zetasql:java/com/google/zetasql/PreparedExpression.java: [ master, ]
338:   public final class Stream implements AutoCloseable {
350:     private Stream() {
322:   public Stream stream() {
325:     return new Stream();
485:         setException(new RuntimeException("Stream closed"));
331:    * <p>Streaming evaluation requests are buffered until there is either no outstanding work or an
364:               stub.evaluateStream(new ResponseObserver());
489:       public void beforeStart(final ClientCallStreamObserver<EvaluateRequestBatch> requestStream) {
490:         requestStream.setOnReadyHandler(this::onReady);
40: import io.grpc.stub.ClientCallStreamObserver;
348:     private final ClientCallStreamObserver<EvaluateRequestBatch> requestObserver;
363:           (ClientCallStreamObserver<EvaluateRequestBatch>)
github.com/apache/cordova-weinre:weinre.server/node_modules/express/node_modules/connect/node_modules/formidable/lib/incoming_form.js: [ master, ]
13:     Stream = require('stream').Stream,
452: IncomingForm.prototype._initOctetStream = function() {
328:     part = new Stream();
256:     this._initOctetStream();
293:       file._writeStream.destroy();
github.com/apache/cordova-weinre:weinre.server/node_modules/nopt/lib/nopt.js: [ master, ]
9:   , Stream = require("stream").Stream
21:   , Stream  : { type: Stream,  validate: validateStream  }
169: function validateStream (data, k, val) {
170:   if (!(val instanceof Stream)) return false
github.com/kubernetes/client-go:tools/remotecommand/remotecommand.go: [ master, ]
49: 	Stream(options StreamOptions) error
114: func (e *streamExecutor) Stream(options StreamOptions) error {
37: type StreamOptions struct {
56: 	StreamWithContext(ctx context.Context, options StreamOptions) error
60: 	CreateStream(headers http.Header) (httpstream.Stream, error)
119: func (e *streamExecutor) newConnectionAndStream(ctx context.Context, options StreamOptions) (httpstream.Connection, streamProtocolHandler, error) {
156: func (e *streamExecutor) StreamWithContext(ctx context.Context, options StreamOptions) error {
112: // Stream opens a protocol streamer to the server and streams until a client closes
34: // StreamOptions holds information pertaining to the current streaming session:
47: 	// Deprecated: use StreamWithContext instead to avoid possible resource leaks.
51: 	// StreamWithContext initiates the transport of the standard shell streams. It will
92: 		remotecommand.StreamProtocolV4Name,
93: 		remotecommand.StreamProtocolV3Name,
94: 		remotecommand.StreamProtocolV2Name,
95: 		remotecommand.StreamProtocolV1Name,
115: 	return e.StreamWithContext(context.Background(), options)
118: // newConnectionAndStream creates a new SPDY connection and a stream protocol handler upon it.
138: 	case remotecommand.StreamProtocolV4Name:
140: 	case remotecommand.StreamProtocolV3Name:
142: 	case remotecommand.StreamProtocolV2Name:
145: ...(13 bytes skipped)...nfof("The server did not negotiate a streaming protocol version. Falling back to %s", remotecommand.StreamProtocolV1Name)
147: 	case remotecommand.StreamProtocolV1Name:
154: // StreamWithContext opens a protocol streamer to the server and streams until a client closes
157: 	conn, streamer, err := e.newConnectionAndStream(ctx, options)
139: 		streamer = newStreamProtocolV4(options)
141: 		streamer = newStreamProtocolV3(options)
143: 		streamer = newStreamProtocolV2(options)
148: 		streamer = newStreamProtocolV1(options)
github.com/material-motion/material-motion-swift:CHANGELOG.md: [ develop, ]
711: ### Stream changes
379: let delayedStream = stream.delay(by: .seconds(1))
385: let stringStream = stream.toStream()
675: | From: | `public init(threshold: CGFloat, system: @escaping SpringToStream<T>)` |
676: | To: | `public init(threshold: CGFloat = 1, system: @escaping SpringToStream<T> = coreAnimation)` |
702: ...(76 bytes skipped)... T, direction: ReactiveProperty<TransitionDirection>, threshold: CGFloat, system: @escaping SpringToStream<T>)` |
703: ...(84 bytes skipped)...ion: ReactiveProperty<TransitionDirection>, threshold: CGFloat = default, system: @escaping SpringToStream<T> = default)` |
777: * [Remove superfluous Equatable conformity in coreAnimationSpringToStream.](https://github.com/material-motion/material-motion-swift/commit/b0b84ffe236c56f48a90ae7086d407109...(25 bytes skipped)...
848: * [Remove asStream conversions.](https://github.com/material-motion/material-motion-swift/commit/3b26f8aac0109038d382c...(37 bytes skipped)...
853: * [Remove excessive .asStream invocations by adding a property-to-property runtime.add method.](https://github.com/material-motio...(89 bytes skipped)...
895: * [Remove excessive asStream cast from operators.](https://github.com/material-motion/material-motion-swift/commit/140b9877abe02...(45 bytes skipped)...
965: * [Rename TweenSource to TweenToStream.](https://github.com/material-motion/material-motion-swift/commit/e726b55624e933fe1e363335e517d2ea2...(25 bytes skipped)...
967: * [Store the container view in ReactiveUIGestureRecognizer and expose a simpler velocityOnReleaseStream API.](https://github.com/material-motion/material-motion-swift/commit/3039394fbfe118f7784a517439590...(29 bytes skipped)...
968: * [Rename GestureSource to GestureToStream.](https://github.com/material-motion/material-motion-swift/commit/5954e4a38eef7af6c2750c86bc7ae6b47...(25 bytes skipped)...
969: * [Rename ScrollSource to ScrollViewToStream.](https://github.com/material-motion/material-motion-swift/commit/2c274b4be937c747b55273ac5ada82ca2...(25 bytes skipped)...
970: * [Rename SpringSource to SpringToStream.](https://github.com/material-motion/material-motion-swift/commit/2f51c7b96516eae7547748ce22a22fda1...(25 bytes skipped)...
github.com/llvm-mirror/clang:www/analyzer/alpha_checks.html: [ master, ]
955: <tr><td><a id="alpha.unix.Stream"><div class="namedescr expandable"><span class="name">
927: <tr><td><a id="alpha.unix.SimpleStream"><div class="namedescr expandable"><span class="name">
956: alpha.unix.Stream</span><span class="lang">
928: alpha.unix.SimpleStream</span><span class="lang">
github.com/apache/isis:antora/components/refguide-index/modules/commons/pages/index/collections/Can.adoc: [ master, ]
341: [#ofStream_Stream]
430: [#pickByIndex_IntStream]
342: === ofStream(Stream)
431: === pickByIndex(IntStream)
33:   Can<T> ofStream(Stream<T> stream)     // <.>
145: <.> xref:#ofStream_Stream[ofStream(Stream)]
55:   Can<T> pickByIndex(IntStream intStream)     // <.>
220: <.> xref:#pickByIndex_IntStream[pickByIndex(IntStream)]
223: ...(95 bytes skipped)...om this xref:refguide:commons:index/collections/Can.adoc[Can] , picked by index using the given _IntStream_ (in the order of picking).
433: ...(95 bytes skipped)...om this xref:refguide:commons:index/collections/Can.adoc[Can] , picked by index using the given _IntStream_ (in the order of picking).
github.com/google/ion:third_party/zlib/src/contrib/ada/zlib.adb: [ master, ]
23:    type Z_Stream is new Thin.Z_Stream;
445:    function Stream_End (Filter : in Filter_Type) return Boolean is
49:    subtype Footer_Array is Stream_Element_Array (1 .. 8);
51:    Simple_GZip_Header : constant Stream_Element_Array (1 .. 10)
85:    procedure Raise_Error (Stream : in Z_Stream);
91:    procedure Check_Error (Stream : in Z_Stream; Code : in Thin.Int);
94:       (Z_Stream, Z_Stream_Access);
97:      (Z_Stream_Access, Thin.Z_Streamp);
101:       In_Data   : in     Ada.Streams.Stream_Element_Array;
102:       In_Last   :    out Ada.Streams.Stream_Element_Offset;
103:       Out_Data  :    out Ada.Streams.Stream_Element_Array;
104:       Out_Last  :    out Ada.Streams.Stream_Element_Offset;
110:       In_Data   : in     Ada.Streams.Stream_Element_Array;
111:       In_Last   :    out Ada.Streams.Stream_Element_Offset;
112:       Out_Data  :    out Ada.Streams.Stream_Element_Array;
113:       Out_Last  :    out Ada.Streams.Stream_Element_Offset;
121:    procedure Check_Error (Stream : in Z_Stream; Code : in Thin.Int) is
127:               & ": " & Last_Error_Message (Stream));
169:       Data : in Ada.Streams.Stream_Element_Array)
181:       Data : in     Ada.Streams.Stream_Element_Array) is
223:       Filter.Strm        := new Z_Stream;
225:       Filter.Stream_End  := False;
246:       Out_Data  :    out Ada.Streams.Stream_Element_Array;
247:       Out_Last  :    out Ada.Streams.Stream_Element_Offset;
250:       No_Data : Stream_Element_Array := (1 .. 0 => 0);
251:       Last    : Stream_Element_Offset;
265:       In_Buffer  : Stream_Element_Array
266:                      (1 .. Stream_Element_Offset (In_Buffer_Size));
267:       Out_Buffer : Stream_Element_Array
268:                      (1 .. Stream_Element_Offset (Out_Buffer_Size));
269:       Last       : Stream_Element_Offset;
270:       In_Last    : Stream_Element_Offset;
271:       In_First   : Stream_Element_Offset;
272:       Out_Last   : Stream_Element_Offset;
292:             exit Main when Stream_End (Filter);
357:       Filter.Strm        := new Z_Stream;
359:       Filter.Stream_End  := False;
387:    procedure Raise_Error (Stream : in Z_Stream) is
389:       Raise_Error (Last_Error_Message (Stream));
398:       Item   :    out Ada.Streams.Stream_Element_Array;
399:       Last   :    out Ada.Streams.Stream_Element_Offset;
402:       In_Last    : Stream_Element_Offset;
403:       Item_First : Ada.Streams.Stream_Element_Offset := Item'First;
433:          exit when Stream_End (Filter)
442:    -- Stream_End --
448:          return Filter.Stream_End
451:          return Filter.Stream_End;
453:    end Stream_End;
479:       In_Data   : in     Ada.Streams.Stream_Element_Array;
480:       In_Last   :    out Ada.Streams.Stream_Element_Offset;
481:       Out_Data  :    out Ada.Streams.Stream_Element_Array;
482:       Out_Last  :    out Ada.Streams.Stream_Element_Offset;
510:       In_Data   : in     Ada.Streams.Stream_Element_Array;
511:       In_Last   :    out Ada.Streams.Stream_Element_Offset;
512:       Out_Data  :    out Ada.Streams.Stream_Element_Array;
513:       Out_Last  :    out Ada.Streams.Stream_Element_Offset;
536:          Filter.Stream_End := True;
542:          - Stream_Element_Offset (Avail_In (Filter.Strm.all));
544:          - Stream_Element_Offset (Avail_Out (Filter.Strm.all));
553:       In_Data   : in     Ada.Streams.Stream_Element_Array;
554:       In_Last   :    out Ada.Streams.Stream_Element_Offset;
555:       Out_Data  :    out Ada.Streams.Stream_Element_Array;
556:       Out_Last  :    out Ada.Streams.Stream_Element_Offset;
559:       Out_First : Stream_Element_Offset;
561:       procedure Add_Data (Data : in Stream_Element_Array);
566:         (Item : in out Stream_Element_Array;
574:       procedure Add_Data (Data : in Stream_Element_Array) is
575:          Data_First : Stream_Element_Offset renames Filter.Offset;
576:          Data_Last  : Stream_Element_Offset;
577:          Data_Len   : Stream_Element_Offset; --  -1
578:          Out_Len    : Stream_Element_Offset; --  -1
608:         (Item : in out Stream_Element_Array;
614:             Item (J) := Stream_Element (D and 16#FF#);
622:       if not Filter.Stream_End then
636:       if Filter.Stream_End and then Out_Last <= Out_Data'Last then
670:       Item   : in     Ada.Streams.Stream_Element_Array;
673:       Buffer   : Stream_Element_Array (1 .. Buffer_Size);
674:       In_Last  : Stream_Element_Offset;
675:       Out_Last : Stream_Element_Offset;
676:       In_First : Stream_Element_Offset := Item'First;
695:          exit when In_Last = Item'Last or Stream_End (Filter);
37:      function (Strm : in Thin.Z_Streamp; Flush : in Thin.Int) return Thin.Int;
41:       function (Ctrm : in Thin.Z_Streamp) return Thin.Int;
github.com/apache/skywalking:oap-server/server-storage-plugin/storage-banyandb-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/banyandb/MetadataRegistry.java: [ master, ]
639:         private final String timestampColumn4Stream;
86:     public Stream registerStreamModel(Model model, BanyanDBStorageConfig config, ConfigService configService) {
60: import org.apache.skywalking.banyandb.v1.client.metadata.Stream;
108:         String timestampColumn4Stream = model.getBanyanDBModelExtension().getTimestampColumn();
109:         if (StringUtil.isBlank(timestampColumn4Stream)) {
113:         schemaBuilder.timestampColumn4Stream(timestampColumn4Stream);
119:         final Stream.Builder builder = Stream.create(schemaMetadata.getGroup(), schemaMetadata.name());
297:      * Parse tags' metadata for {@link Stream}
512:                         return Optional.ofNullable(client.findStream(this.group, this.name()));
550:                     resourceExist = client.existStream(this.group, this.name());
github.com/apache/hawq:tools/tpch/tpchdriver.c: [ master, ]
1850: Run_Query_Stream ()
1901: Print_Stream_Summary ()
2325: 	Run_Query_Stream ();
2346: 	fprintf (stdout, " Stream %d finished on %s\n", snum, ctime (&StartTime.time));
2347: 	fprintf (fdetail, "\n Stream %d finished on %s\n", snum, ctime (&StartTime.time));
2349: 	Print_Stream_Summary ();
github.com/tensorflow/haskell:third_party/tensorflow/tensorflow/c/experimental/stream_executor/stream_executor.h: [ master, ]
93: typedef struct SP_Stream_st* SP_Stream;
235: typedef struct SP_StreamExecutor {
415: } SP_StreamExecutor;
420: typedef struct SE_CreateStreamExecutorParams {
425: } SE_CreateStreamExecutorParams;
282:   // Creates SP_Stream. This call should also allocate stream
285:   void (*create_stream)(const SP_Device* device, SP_Stream* stream,
288:   // Destroys SP_Stream and deallocates any underlying resources.
289:   void (*destroy_stream)(const SP_Device* device, SP_Stream stream);
293:   void (*create_stream_dependency)(const SP_Device* device, SP_Stream dependent,
294:                                    SP_Stream other, TF_Status* status);
297:   void (*get_stream_status)(const SP_Device* device, SP_Stream stream,
313:   void (*record_event)(const SP_Device* device, SP_Stream stream,
317:   void (*wait_for_event)(const SP_Device* const device, SP_Stream stream,
331:   void (*start_timer)(const SP_Device* device, SP_Stream stream, SP_Timer timer,
335:   void (*stop_timer)(const SP_Device* device, SP_Stream stream, SP_Timer timer,
341:   void (*memcpy_dtoh)(const SP_Device* device, SP_Stream stream, void* host_dst,
347:   void (*memcpy_htod)(const SP_Device* device, SP_Stream stream,
353:   void (*memcpy_dtod)(const SP_Device* device, SP_Stream stream,
389:   void (*block_host_until_done)(const SP_Device* device, SP_Stream stream,
397:   void (*mem_zero)(const SP_Device* device, SP_Stream stream,
402:   void (*memset)(const SP_Device* device, SP_Stream stream,
407:   void (*memset32)(const SP_Device* device, SP_Stream stream,
413:   TF_Bool (*host_callback)(const SP_Device* device, SP_Stream stream,
24: // C API for StreamExecutor. The API is under active development and eventually
392:   // Synchronizes all activity occurring in the StreamExecutor's context (most
418:   TF_OFFSET_OF_END(SP_StreamExecutor, host_callback)
424:   SP_StreamExecutor* stream_executor;  // output, to be filled by plugin
489:   // Callbacks for creating/destroying SP_StreamExecutor.
493:   // Clean up fields inside SP_StreamExecutor that were allocated
496:                                   SP_StreamExecutor* stream_executor);
513:   // StreamExecutor C API version.
428:   TF_OFFSET_OF_END(SE_CreateStreamExecutorParams, stream_executor)
491:                                  SE_CreateStreamExecutorParams* params,
github.com/googlecreativelab/anypixel:firmware/controller/ThirdParty/SPL/inc/stm32f4xx_sdio.h: [ master, ]
348: #define SDIO_TransferMode_Stream            ((uint32_t)0x00000004)
349: #define IS_SDIO_TRANSFER_MODE(MODE) (((MODE) == SDIO_TransferMode_Stream) || \
github.com/madler/zlib:contrib/ada/zlib.adb: [ master, ] Duplicate result
github.com/google/bloaty:third_party/zlib/contrib/ada/zlib.adb: [ master, ] Duplicate result
github.com/apache/metron:site/current-book/use-cases/typosquat_detection/index.html: [ master, ]
162: <h2><a name="Reading_Summaries_In-Stream"></a>Reading Summaries In-Stream</h2>
github.com/deepmind/pysc2:pysc2/env/converted_env.py: [ master, ]
190: class _Stream(dm_env.Environment):
216: class _StreamedEnvironment:
307:       _Stream(p, environment)
193:   def __init__(self, player: int, environment: '_StreamedEnvironment'):
305:   environment = _StreamedEnvironment(converted_environment)
github.com/angular/angular-cli:packages/angular_devkit/core/src/experimental/jobs/README.md: [ master, ]
220: ### Raw Input Stream
240: ### Raw Output Stream
7: The whole API is serializable, allowing you to use a Node Stream or message channel to
github.com/google/WebFundamentals:src/content/id/fundamentals/performance/http2/index.md: [ master, ]
207: ## Stream, pesan, dan bingkai
213: * *Stream*: Alur dua arah byte dalam koneksi yang terbentuk,
231: ![Stream, pesan, dan bingkai HTTP/2](images/streams_messages_frames01.svg)
309: Stream yang memiliki induk yang sama (dengan kata lain, stream bersaudara) harus dialokasikan
322: 1. Stream A atau B tidak menentukan dependensi induk dan disebut bergantung
326: 1. Stream D bergantung pada root stream; C bergantung pada D. Dengan demikian, D harus
329: 1. Stream D harus menerima alokasi penuh resource sebelum C; C harus menerima
332: 1. Stream D harus menerima alokasi penuh resource sebelum E dan C; E dan C
github.com/kubernetes/test-infra:kettle/OVERVIEW.md: [ master, ]
42: # Stream Results
18: - [stream.py](#Stream-Results): Wait for pub-sub events for completed builds and upload as results surface.
43: After all historical data has been uploaded, Kettle enters a Streaming phase. It subscribes to pub-sub results from `kubernetes-jenkins/gcs-changes/kettle` (or the spe...(105 bytes skipped)...
github.com/google/go-github:github/repos_releases_test.go: [ master, ]
427: func TestRepositoriesService_DownloadReleaseAsset_Stream(t *testing.T) {
github.com/googleapis/google-api-php-client:tests/Google/Task/RunnerTest.php: [ master, ]
31: use GuzzleHttp\Stream\Stream as Guzzle5Stream;
684:       $stream = Guzzle5Stream::factory($current['body']);
github.com/kohsuke/args4j:args4j/test/org/kohsuke/args4j/Args4JTestBase.java: [ master, ]
104:     private class Stream2String extends OutputStream {
89:         Stream2String s2s = new Stream2String();
4: import java.io.OutputStream;
84:      * @see CmdLineParser#printUsage(OutputStream)
101:      * Utility class for capturing an OutputStream into a String.
github.com/apache/kafka:streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java: [ trunk, ]
146: public class StreamsConfig extends AbstractConfig {
1335:     public StreamsConfig(final Map<?, ?> props) {
1339:     protected StreamsConfig(final Map<?, ?> props,
231:      * Prefix used to add arbitrary tags to a Kafka Stream's instance as key-value pairs.
589: ...(11 bytes skipped)...                                                   "Note that one warmup replica corresponds to one Stream Task. Furthermore, note that each warmup replica can only be promoted to an active task " +
43: import org.apache.kafka.streams.errors.StreamsException;
44: import org.apache.kafka.streams.internals.StreamsConfigUtils;
48: import org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor;
73:  * Can also be used to configure the Kafka Streams internal {@link KafkaConsumer}, {@link KafkaProducer} and {@link Admin}.
88:  * streamsProperties.put(StreamsConfig.consumerPrefix(ConsumerConfig.METADATA_MAX_AGE_CONFIG), 60000);
90:  * streamsProperties.put(StreamsConfig.producerPrefix(ProducerConfig.METADATA_MAX_AGE_CONFIG), 60000);
92:  * StreamsConfig streamsConfig = new StreamsConfig(streamsProperties);
101:  * streamsProperties.put(StreamsConfig.consumerPrefix("my.custom.config"), "foo");
103:  * streamsProperties.put(StreamsConfig.producerPrefix("my.custom.config"), "bar");
110:  * StreamsConfig streamsConfig = new StreamsConfig(streamsProperties);
121:  * Kafka Streams requires at least the following properties to be set:
127:  * By default, Kafka Streams does not allow users to overwrite the following properties (Streams setting shown in parentheses):
129:  *   <li>{@link ConsumerConfig#GROUP_ID_CONFIG "group.id"} (&lt;application.id&gt;) - Streams client will always use the application ID a consumer group ID</li>
130:  *   <li>{@link ConsumerConfig#ENABLE_AUTO_COMMIT_CONFIG "enable.auto.commit"} (false) - Streams client will always disable/turn off auto committing</li>
131: ...(8 bytes skipped)...>{@link ConsumerConfig#PARTITION_ASSIGNMENT_STRATEGY_CONFIG "partition.assignment.strategy"} (<code>StreamsPartitionAssignor</code>) - Streams client will always use its own partition assignor</li>
135: ...(24 bytes skipped)..."exactly_once"} (deprecated), or {@link #EXACTLY_ONCE_BETA "exactly_once_beta"} (deprecated), Kafka Streams does not
136:  * allow users to overwrite the following properties (Streams setting shown in parentheses):
148:     private static final Logger log = LoggerFactory.getLogger(StreamsConfig.class);
249:         + "Streams if it should optimize the topology and what optimizations to apply. "
411:      * If you enable this feature Kafka Streams will use more resources (like broker connections)
424:      * If you enable this feature Kafka Streams will use fewer resources (like broker connections)
491:         " with pattern <code>&lt;client.id&gt;-StreamThread-&lt;threadSequenceNumber$gt;-&lt;consumer|producer|restore-consumer&gt;</code>.";
580:         + " Streams will process them in timestamp order."
591: ...(38 bytes skipped)...                        "that the maximum rate at which active tasks can be migrated from one Kafka Streams Instance to another instance can be determined by " +
631: ...(43 bytes skipped)...UTOSCALING_ENABLED_DOC = "Enable autoscaling the partitions of internal topics which are managed by Streams."
638: ...(20 bytes skipped)...inal String PARTITION_AUTOSCALING_TIMEOUT_MS_DOC = "The maximum amount of time in milliseconds that Streams will attempt to retry autoscaling of internal topic partitions.";
669: ...(39 bytes skipped)...ARE_ASSIGNMENT_TAGS_DOC = "List of client tag keys used to distribute standby replicas across Kafka Streams instances." +
670:                                                                  " When configured, Kafka Streams will make a best-effort to distribute" +
694:      * This config is ignored by Kafka Streams. Note, that the internal clients (producer, admin) are still impacted by this config.
1165:         // This is settable in the main Streams config, but it's a private API for now
1168:         // These are not settable in the main Streams config; they are set by the StreamThread to pass internal
1172:         // This is settable in the main Streams config, but it's a private API for testing
1331:      * Create a new {@code StreamsConfig} using the given properties.
1333:      * @param props properties that specify Kafka Streams and internal consumer/producer configuration
1342:         eosEnabled = StreamsConfigUtils.eosEnabled(this);
1344:         final String processingModeConfig = getString(StreamsConfig.PROCESSING_GUARANTEE_CONFIG);
1386:         if (StreamsConfigUtils.eosEnabled(this) && !originals().containsKey(COMMIT_INTERVAL_MS_CONFIG)) {
1436:         if (StreamsConfigUtils.processingMode(this) == StreamsConfigUtils.ProcessingMode.EXACTLY_ONCE_V2) {
1442:         // bootstrap.servers should be from StreamsConfig
1450:         // Streams does not allow users to configure certain consumer/producer configurations, for example,
1454:         // Streams will be used instead.
1456: ...(44 bytes skipped)...ssage = "Unexpected user-specified %s config: %s found. %sUser setting (%s) will be ignored and the Streams default setting (%s) will be used ";
1540:         // this is a hack to work around StreamsConfig constructor inside StreamsPartitionAssignor to avoid casting
1562:         consumerProps.put(ConsumerConfig.PARTITION_ASSIGNMENT_STRATEGY_CONFIG, StreamsPartitionAssignor.class.getName());
1681:         if (StreamsConfigUtils.processingMode(this) == StreamsConfigUtils.ProcessingMode.EXACTLY_ONCE_ALPHA) {
1734:      * Get a map of custom configs by removing from the originals all the Streams, Consumer, Producer, and AdminClient configs.
1782:         return getConfiguredInstance(StreamsConfig.DEFAULT_CLIENT_SUPPLIER_CONFIG,
1796:             throw new ConfigException("Please specify a key serde or set one through StreamsConfig#DEFAULT_KEY_SERDE_CLASS_CONFIG");
1803:             throw new StreamsException(
1818:             throw new ConfigException("Please specify a value serde or set one through StreamsConfig#DEFAULT_VALUE_SERDE_CLASS_CONFIG");
1825:             throw new StreamsException(
72:  * Configuration for a {@link KafkaStreams} instance.
142:  * @see KafkaStreams#KafkaStreams(org.apache.kafka.streams.Topology, Properties)
461: ...(91 bytes skipped)...er-defined endpoint that can be used for state store discovery and interactive queries on this KafkaStreams instance.";
547: ...(15 bytes skipped)...org.apache.kafka.common.serialization.Serde</code> interface. Note that setting this config in KafkaStreams application would result " +
github.com/apache/druid:indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java: [ master, ]
763:   private final Map<PartitionIdType, SequenceOffsetType> previousSequencesFromStream = new HashMap<>();
2464:   private boolean updatePartitionDataFromStream()
2633:   protected Map<PartitionIdType, SequenceOffsetType> getLatestSequencesFromStream()
3801:   protected abstract void updatePartitionLagFromStream();
146: public abstract class SeekableStreamSupervisor<PartitionIdType, SequenceOffsetType, RecordType extends ByteEntity>
767:   public SeekableStreamSupervisor(
3370:   private void checkIfStreamInactiveAndTurnSupervisorIdle()
3682:   private SequenceOffsetType getOffsetFromStreamForPartition(PartitionIdType partition, boolean useEarliestOffset)
129: import java.util.stream.Stream;
3777:     final List<ListenableFuture<Void>> futures = Stream.concat(
3827:             Stream.concat(
75: import org.apache.druid.indexing.seekablestream.common.StreamException;
76: import org.apache.druid.indexing.seekablestream.common.StreamPartition;
1475:       if (!updatePartitionDataFromStream() && !stateManager.isAtLeastOneSuccessfulRun()) {
1613:       if (resetMetadata.getSeekableStreamSequenceNumbers().getStream().equals(ioConfig.getStream())) {
1692:             resetMetadata.getSeekableStreamSequenceNumbers().getStream(),
1693:             ioConfig.getStream()
2160:                                           ioConfig.getStream().equals(
2161:                                               latestDataSourceMetadata.getSeekableStreamSequenceNumbers().getStream()
2461:     return recordSupplier.getPartitionIds(ioConfig.getStream()).size();
2470:       partitionIdsFromSupplier = recordSupplier.getPartitionIds(ioConfig.getStream());
2474:       log.warn("Could not fetch partitions for topic/stream [%s]: %s", ioConfig.getStream(), e.getMessage());
2483:       String errMsg = StringUtils.format("No partitions found for stream [%s]", ioConfig.getStream());
2484:       stateManager.recordThrowableEvent(new StreamException(new ISE(errMsg)));
2489: ...(0 bytes skipped)...    log.debug("Found [%d] partitions for stream [%s]", partitionIdsFromSupplier.size(), ioConfig.getStream());
2534:           ioConfig.getStream()
2536:       stateManager.recordThrowableEvent(new StreamException(new ISE(errMsg)));
2583:             ioConfig.getStream(),
2596:             ioConfig.getStream(),
2642:       final Set<StreamPartition<PartitionIdType>> partitions = partitionIds.stream()
2643:                                                                            .map(partitionId -> new StreamPartition<>(
2644:                                                                                ioConfig.getStream(),
3376:     Map<PartitionIdType, SequenceOffsetType> latestSequencesFromStream = getLatestSequencesFromStream();
3382:         && previousSequencesFromStream.equals(latestSequencesFromStream)
3392:     previousSequencesFromStream.clear();
3393:     previousSequencesFromStream.putAll(latestSequencesFromStream);
3610:                 createDataSourceMetaDataForReset(ioConfig.getStream(), ImmutableMap.of(partition, sequence))
3612:             throw new StreamException(
3621:             throw new StreamException(
3662:         if (!ioConfig.getStream().equals(partitions.getStream())) {
3665:               partitions.getStream(),
3666:               ioConfig.getStream()
3686:       StreamPartition<PartitionIdType> topicPartition = new StreamPartition<>(ioConfig.getStream(), partition);
3766:         updatePartitionLagFromStream();
3899:         spec.getIoConfig().getStream().equals(seekableMetadata.getSeekableStreamSequenceNumbers().getStream()),
3901:         spec.getIoConfig().getStream(),
3902:         seekableMetadata.getSeekableStreamSequenceNumbers().getStream()
4125:     StreamPartition<PartitionIdType> streamPartition = StreamPartition.of(ioConfig.getStream(), partition);
4229:                                 .setDimension(DruidMetrics.STREAM, getIoConfig().getStream())
4241:                               .setDimension(DruidMetrics.STREAM, getIoConfig().getStream())
4248:                               .setDimension(DruidMetrics.STREAM, getIoConfig().getStream())
4255:                               .setDimension(DruidMetrics.STREAM, getIoConfig().getStream())
64: import org.apache.druid.indexing.seekablestream.SeekableStreamDataSourceMetadata;
65: import org.apache.druid.indexing.seekablestream.SeekableStreamIndexTask;
66: import org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskClient;
67: import org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskClientFactory;
68: import org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskIOConfig;
69: import org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskRunner;
70: import org.apache.druid.indexing.seekablestream.SeekableStreamIndexTaskTuningConfig;
71: import org.apache.druid.indexing.seekablestream.SeekableStreamSequenceNumbers;
72: import org.apache.druid.indexing.seekablestream.SeekableStreamStartSequenceNumbers;
135:  * Supervisor responsible for managing the SeekableStreamIndexTasks (Kafka/Kinesis) for a single dataSource. At a high level, the class accepts a
136:  * {@link SeekableStreamSupervisorSpec} which includes the stream name (topic / stream) and configuration as well as an inge...(21 bytes skipped)...
159:   private static final EmittingLogger log = new EmittingLogger(SeekableStreamSupervisor.class);
184:    * A TaskGroup is the main data structure used by SeekableStreamSupervisor to organize and monitor stream partitions and
489:    * Finally, change the taskCount in SeekableStreamSupervisorIOConfig and sync it to MetadataStorage.
490:    * After the taskCount is changed in SeekableStreamSupervisorIOConfig, next RunNotice will create scaled number of ingest tasks without resubmitting th...(13 bytes skipped)...
616:     private final SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> checkpointMetadata;
621:         SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> checkpointMetadata
644:           if (checkpoint.equals(checkpointMetadata.getSeekableStreamSequenceNumbers()
720:   protected final SeekableStreamSupervisorStateManager stateManager;
729:   private final SeekableStreamIndexTaskClient<PartitionIdType, SequenceOffsetType> taskClient;
730:   private final SeekableStreamSupervisorSpec spec;
731:   private final SeekableStreamSupervisorIOConfig ioConfig;
733:   private final SeekableStreamSupervisorTuningConfig tuningConfig;
734:   private final SeekableStreamIndexTaskTuningConfig taskTuningConfig;
772:       final SeekableStreamIndexTaskClientFactory<PartitionIdType, SequenceOffsetType> taskClientFactory,
774:       final SeekableStreamSupervisorSpec spec,
797:     this.stateManager = new SeekableStreamSupervisorStateManager(
904:               "First initialization attempt failed for SeekableStreamSupervisor[%s], starting retries...",
1060:                     log.makeAlert(e, "SeekableStreamSupervisor[%s] failed to handle notice", dataSource)
1068:                 log.info("SeekableStreamSupervisor[%s] interrupted, exiting", dataSource);
1083:             "Started SeekableStreamSupervisor[%s], first run in [%s], with spec: [%s]",
1095:         log.makeAlert(e, "Exception starting SeekableStreamSupervisor[%s]", dataSource)
1132:   private SupervisorReport<? extends SeekableStreamSupervisorReportPayload<PartitionIdType, SequenceOffsetType>> generateReport(
1138:     final SeekableStreamSupervisorReportPayload<PartitionIdType, SequenceOffsetType> payload = createReportPayload(
1143:     SupervisorReport<SeekableStreamSupervisorReportPayload<PartitionIdType, SequenceOffsetType>> report = new SupervisorReport<>(
1401:     SeekableStreamIndexTaskTuningConfig ss = spec.getSpec().getTuningConfig().convertToTaskTuningConfig();
1402:     SeekableStreamSupervisorIOConfig oo = spec.getSpec().getIOConfig();
1474:       stateManager.maybeSetState(SeekableStreamSupervisorStateManager.SeekableStreamState.CONNECTING_TO_STREAM);
1479:       stateManager.maybeSetState(SeekableStreamSupervisorStateManager.SeekableStreamState.DISCOVERING_INITIAL_TASKS);
1490:       checkIfStreamInactiveAndTurnSupervisorIdle();
1509:           stateManager.maybeSetState(SeekableStreamSupervisorStateManager.SeekableStreamState.CREATING_TASKS);
1610:       final SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> resetMetadata =
1611:           (SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType>) dataSourceMetadata;
1624:         final SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> currentMetadata =
1625:             (SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType>) metadata;
1631:             .getSeekableStreamSequenceNumbers()
1637:                                                                         .getSeekableStreamSequenceNumbers()
1671:           resetMetadata.getSeekableStreamSequenceNumbers()
1767:       final SeekableStreamIndexTask<PartitionIdType, SequenceOffsetType, RecordType> seekableStreamIndexTask = (SeekableStreamIndexTask<PartitionIdType, SequenceOffsetType, RecordType>) task;
1775:         Set<PartitionIdType> taskPartitions = seekableStreamIndexTask.getIOConfig()
1802:       Iterator<PartitionIdType> it = seekableStreamIndexTask.getIOConfig()
1819:                   new Function<Pair<SeekableStreamIndexTaskRunner.Status, Map<PartitionIdType, SequenceOffsetType>>, Boolean>()
1822:                     public Boolean apply(Pair<SeekableStreamIndexTaskRunner.Status, Map<PartitionIdType, SequenceOffsetType>> pair)
1824:                       final SeekableStreamIndexTaskRunner.Status status = pair.lhs;
1829:                         if (status == SeekableStreamIndexTaskRunner.Status.PUBLISHING) {
1830:                           seekableStreamIndexTask.getIOConfig()
1839:                                                          seekableStreamIndexTask.getIOConfig()
1882:                           for (PartitionIdType partition : seekableStreamIndexTask.getIOConfig()
1916:                                           seekableStreamIndexTask.getIOConfig()
1921:                                       seekableStreamIndexTask.getIOConfig().getMinimumMessageTime(),
1922:                                       seekableStreamIndexTask.getIOConfig().getMaximumMessageTime(),
1923:                                       seekableStreamIndexTask.getIOConfig()
1926:                                       seekableStreamIndexTask.getIOConfig().getBaseSequenceName()
1986:    * Left-hand side: Status of the task from {@link SeekableStreamIndexTaskClient#getStatusAsync}.
1988:    * Right-hand side: If status is {@link SeekableStreamIndexTaskRunner.Status#PUBLISHING}, end offsets from
1989:    * {@link SeekableStreamIndexTaskClient#getEndOffsetsAsync}. Otherwise, null.
1993:   private ListenableFuture<Pair<SeekableStreamIndexTaskRunner.Status, Map<PartitionIdType, SequenceOffsetType>>> getStatusAndPossiblyEndOffsets(
2000:           if (status == SeekableStreamIndexTaskRunner.Status.PUBLISHING) {
2156:     final SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> latestDataSourceMetadata = (SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType>) rawDataSourceMetadata;
2159:                                           latestDataSourceMetadata.getSeekableStreamSequenceNumbers() != null &&
2165:       latestOffsetsFromDb = latestDataSourceMetadata.getSeekableStreamSequenceNumbers().getPartitionSequenceNumberMap();
2319:               SeekableStreamIndexTask<PartitionIdType, SequenceOffsetType, RecordType> task =
2320:                   (SeekableStreamIndexTask<PartitionIdType, SequenceOffsetType, RecordType>) taskOptional.get();
2377:     SeekableStreamIndexTask<PartitionIdType, SequenceOffsetType, RecordType> task =
2378:         (SeekableStreamIndexTask<PartitionIdType, SequenceOffsetType, RecordType>) genericTask;
2420:       SeekableStreamIndexTaskTuningConfig tuningConfig
2696:       SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> currentMetadata =
2697:           (SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType>)
2700:       SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> cleanedMetadata =
2776:   protected SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> createDataSourceMetadataWithExpiredPartition...(2 bytes skipped)...
2777:       SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> currentMetadata,
2797:       SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> oldMetadata,
2798:       SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> cleanedMetadata
2801:     Map<PartitionIdType, SequenceOffsetType> oldPartitionSeqNos = oldMetadata.getSeekableStreamSequenceNumbers()
2804:     Map<PartitionIdType, SequenceOffsetType> cleanedPartitionSeqNos = cleanedMetadata.getSeekableStreamSequenceNumbers()
3596:    * {@link SeekableStreamSupervisorIOConfig#useEarliestSequenceNumber}.
3643:       sequence = getOffsetFromStreamForPartition(partition, useEarliestSequenceNumber);
3656:     if (dataSourceMetadata instanceof SeekableStreamDataSourceMetadata
3659:       SeekableStreamSequenceNumbers<PartitionIdType, SequenceOffsetType> partitions = ((SeekableStreamDataSourceMetadata) dataSourceMetadata)
3660:           .getSeekableStreamSequenceNumbers();
3717:     SeekableStreamIndexTaskIOConfig newIoConfig = createTaskIoConfig(
3728:     List<SeekableStreamIndexTask<PartitionIdType, SequenceOffsetType, RecordType>> taskList = createIndexTasks(
3738:     for (SeekableStreamIndexTask indexTask : taskList) {
3884:   public SeekableStreamSupervisorIOConfig getIoConfig()
3895:     final SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> seekableMetadata =
3896:         (SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType>) checkpointMetadata;
3905:         seekableMetadata.getSeekableStreamSequenceNumbers() instanceof SeekableStreamStartSequenceNumbers,
3906:         "checkpointMetadata must be SeekableStreamStartSequenceNumbers"
3973:   protected abstract SeekableStreamIndexTaskIOConfig createTaskIoConfig(
3981:       SeekableStreamSupervisorIOConfig ioConfig
3991:   protected abstract List<SeekableStreamIndexTask<PartitionIdType, SequenceOffsetType, RecordType>> createIndexTasks(
3996:       SeekableStreamIndexTaskIOConfig taskIoConfig,
3997:       SeekableStreamIndexTaskTuningConfig taskTuningConfig,
4035:   protected abstract SeekableStreamDataSourceMetadata<PartitionIdType, SequenceOffsetType> createDataSourceMetaDataForReset(
4057:     SeekableStreamSupervisorIOConfig ioConfig = spec.getIoConfig();
4058:     SeekableStreamSupervisorTuningConfig tuningConfig = spec.getTuningConfig();
4110:   protected abstract SeekableStreamSupervisorReportPayload<PartitionIdType, SequenceOffsetType> createReportPayload(
github.com/apache/flink:flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java: [ master, ]
150: public class StreamExecutionEnvironment implements AutoCloseable {
238:     public StreamExecutionEnvironment() {
250:     public StreamExecutionEnvironment(final Configuration configuration) {
261:     public StreamExecutionEnvironment(
274:     public StreamExecutionEnvironment(
1594:     public DataStream<String> readFileStream(
1680:     public DataStreamSource<String> socketTextStream(
1704:     public DataStreamSource<String> socketTextStream(
1724:     public DataStreamSource<String> socketTextStream(String hostname, int port, char delimiter) {
1740:     public DataStreamSource<String> socketTextStream(String hostname, int port, String delimiter) {
1755:     public DataStreamSource<String> socketTextStream(String hostname, int port) {
933:     public void setStreamTimeCharacteristic(TimeCharacteristic characteristic) {
950:     public TimeCharacteristic getStreamTimeCharacteristic() {
2224:     public StreamGraph getStreamGraph() {
2238:     public StreamGraph getStreamGraph(boolean clearTransformations) {
2246:     private StreamGraph getStreamGraph(List<Transformation<?>> transformations) {
2275:     public StreamGraph generateStreamGraph(List<Transformation<?>> transformations) {
2279:     private StreamGraphGenerator getStreamGraphGenerator(List<Transformation<?>> transformations) {
1599:                         "Read File Stream source");
1707:                 new SocketTextStreamFunction(hostname, port, delimiter, maxRetry), "Socket Stream");
81: import org.apache.flink.streaming.api.datastream.DataStream;
98: import org.apache.flink.streaming.api.graph.StreamGraph;
99: import org.apache.flink.streaming.api.graph.StreamGraphGenerator;
100: import org.apache.flink.streaming.api.operators.StreamSource;
138:  * The StreamExecutionEnvironment is the context in which a streaming program is executed. A {@link
165:     public static final String DEFAULT_JOB_NAME = StreamGraphGenerator.DEFAULT_STREAMING_JOB_NAME;
174:     private static StreamExecutionEnvironmentFactory contextEnvironmentFactory = null;
176:     /** The ThreadLocal used to store {@link StreamExecutionEnvironmentFactory}. */
177:     private static final ThreadLocal<StreamExecutionEnvironmentFactory>
222:      * newly added {@link ConfigOption}s that are relevant for DataStream API. Make sure to also
240:         // unfortunately, StreamExecutionEnvironment always (implicitly) had a public constructor.
246:      * Creates a new {@link StreamExecutionEnvironment} that will use the given {@link
255:      * Creates a new {@link StreamExecutionEnvironment} that will use the given {@link
267:      * Creates a new {@link StreamExecutionEnvironment} that will use the given {@link
329:     public StreamExecutionEnvironment setParallelism(int parallelism) {
348:     public StreamExecutionEnvironment setRuntimeMode(final RuntimeExecutionMode executionMode) {
364:     public StreamExecutionEnvironment setMaxParallelism(int maxParallelism) {
388:     public StreamExecutionEnvironment registerSlotSharingGroup(SlotSharingGroup slotSharingGroup) {
436:     public StreamExecutionEnvironment setBufferTimeout(long timeoutMillis) {
460:      * @return StreamExecutionEnvironment with chaining disabled.
463:     public StreamExecutionEnvironment disableOperatorChaining() {
508:     public StreamExecutionEnvironment enableCheckpointing(long interval) {
531:     public StreamExecutionEnvironment enableCheckpointing(long interval, CheckpointingMode mode) {
558:     public StreamExecutionEnvironment enableCheckpointing(
584:     public StreamExecutionEnvironment enableCheckpointing() {
640:      * org.apache.flink.streaming.api.datastream.KeyedStream keyed streams}, as well as state
657:      * @return This StreamExecutionEnvironment itself, to allow chaining of function calls.
662:     public StreamExecutionEnvironment setStateBackend(StateBackend backend) {
704:      * @return This StreamExecutionEnvironment itself, to allow chaining of function calls.
708:     public StreamExecutionEnvironment enableChangelogStateBackend(boolean enabled) {
730:      * @return This StreamExecutionEnvironment itself, to allow chaining of function calls.
734:     public StreamExecutionEnvironment setDefaultSavepointDirectory(String savepointDirectory) {
743:      * @return This StreamExecutionEnvironment itself, to allow chaining of function calls.
747:     public StreamExecutionEnvironment setDefaultSavepointDirectory(URI savepointDirectory) {
756:      * @return This StreamExecutionEnvironment itself, to allow chaining of function calls.
760:     public StreamExecutionEnvironment setDefaultSavepointDirectory(Path savepointDirectory) {
927:      *     org.apache.flink.streaming.api.datastream.KeyedStream#timeWindow(org.apache.flink.streaming.api.windowing.time.Time)}
956:      * StreamPipelineOptions#TIME_CHARACTERISTIC}. It will reconfigure {@link
957:      * StreamExecutionEnvironment}, {@link ExecutionConfig} and {@link CheckpointConfig}.
971:      * StreamPipelineOptions#TIME_CHARACTERISTIC}. It will reconfigure {@link
972:      * StreamExecutionEnvironment}, {@link ExecutionConfig} and {@link CheckpointConfig}.
983:                 .getOptional(StreamPipelineOptions.TIME_CHARACTERISTIC)
1165:                             + "StreamExecutionEnvironment#fromElements(Collection, TypeInformation)",
1198:                             + "StreamExecutionEnvironment#fromElements(Collection, TypeInformation)",
1238:                             + "StreamExecutionEnvironment#fromElements(Collection, TypeInformation)",
1486:      *     {@link StreamExecutionEnvironment#readFile(FileInputFormat, String, FileProcessingMode,
1589:      * @return The DataStream containing the given directory.
1596:         DataStream<Tuple3<String, Long, Long>> source =
1677:      * @deprecated Use {@link #socketTextStream(String, int, String, long)} instead.
1682:         return socketTextStream(hostname, port, String.valueOf(delimiter), maxRetry);
1720:      * @deprecated Use {@link #socketTextStream(String, int, String)} instead.
1725:         return socketTextStream(hostname, port, delimiter, 0);
1741:         return socketTextStream(hostname, port, delimiter, 0);
1756:         return socketTextStream(hostname, port, "\n");
1898:      * Adds a data source with a custom type information thus opening a {@link DataStream}. Only in
1912:      * Ads a data source with a custom type information thus opening a {@link DataStream}. Only in
1927:      * Ads a data source with a custom type information thus opening a {@link DataStream}. Only in
1958:         final StreamSource<OUT, ?> sourceOperator = new StreamSource<>(function);
1964:      * Adds a data {@link Source} to the environment to get a {@link DataStream}.
1990:      * Adds a data {@link Source} to the environment to get a {@link DataStream}.
2052:         StreamGraph streamGraph = getStreamGraph();
2083:     public JobExecutionResult execute(StreamGraph streamGraph) throws Exception {
2175:         Preconditions.checkNotNull(jobName, "Streaming Job name should not be null.");
2176:         final StreamGraph streamGraph = getStreamGraph();
2192:     public JobClient executeAsync(StreamGraph streamGraph) throws Exception {
2193:         checkNotNull(streamGraph, "StreamGraph cannot be null.");
2218:      * Getter of the {@link StreamGraph} of the streaming job. This call clears previously
2229:      * Getter of the {@link StreamGraph} of the streaming job with the option to clear previously
2239:         final StreamGraph streamGraph = getStreamGraph(transformations);
2266:      * Generates a {@link StreamGraph} that consists of the given {@link Transformation
2287:         return new StreamGraphGenerator(
2343:      * have initialized the environment via {@link #StreamExecutionEnvironment(Configuration)} or
2381:     public static StreamExecutionEnvironment getExecutionEnvironment() {
2397:     public static StreamExecutionEnvironment getExecutionEnvironment(Configuration configuration) {
2400:                 .orElseGet(() -> StreamExecutionEnvironment.createLocalEnvironment(configuration));
2474:     public static StreamExecutionEnvironment createLocalEnvironmentWithWebUI(Configuration conf) {
2499:     public static StreamExecutionEnvironment createRemoteEnvironment(
2518:     public static StreamExecutionEnvironment createRemoteEnvironment(
2539:     public static StreamExecutionEnvironment createRemoteEnvironment(
2570:     protected static void initializeContextEnvironment(StreamExecutionEnvironmentFactory ctx) {
82: import org.apache.flink.streaming.api.datastream.DataStreamSource;
83: import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
94: import org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction;
139:  * LocalStreamEnvironment} will cause execution in the current JVM, a {@link
140:  * RemoteStreamEnvironment} will cause execution on a remote setup.
146:  * @see org.apache.flink.streaming.api.environment.LocalStreamEnvironment
147:  * @see org.apache.flink.streaming.api.environment.RemoteStreamEnvironment
285:         // SingleOutputStreamOperator.setParallelism().
323:      * LocalStreamEnvironment} uses by default a value equal to the number of hardware contexts (CPU
945:      * @deprecated See {@link #setStreamTimeCharacteristic(TimeCharacteristic)} for deprecation
984:                 .ifPresent(this::setStreamTimeCharacteristic);
1087:      * org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator#setParallelism(int)})
1097:     public DataStreamSource<Long> generateSequence(long from, long to) {
1124:     public DataStreamSource<Long> fromSequence(long from, long to) {
1151:     public final <OUT> DataStreamSource<OUT> fromElements(OUT... data) {
1184:     public final <OUT> DataStreamSource<OUT> fromElements(Class<OUT> type, OUT... data) {
1219:     public <OUT> DataStreamSource<OUT> fromCollection(Collection<OUT> data) {
1255:     public <OUT> DataStreamSource<OUT> fromCollection(
1284:     public <OUT> DataStreamSource<OUT> fromCollection(Iterator<OUT> data, Class<OUT> type) {
1305:     public <OUT> DataStreamSource<OUT> fromCollection(
1327:     public <OUT> DataStreamSource<OUT> fromParallelCollection(
1349:     public <OUT> DataStreamSource<OUT> fromParallelCollection(
1355:     private <OUT> DataStreamSource<OUT> fromParallelCollection(
1378:      *     FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead}. An
1382:      *        FileSource.forRecordStreamFormat(
1388:     public DataStreamSource<String> readTextFile(String filePath) {
1408:      *     FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead}. An
1412:      *        FileSource.forRecordStreamFormat(
1418:     public DataStreamSource<String> readTextFile(String filePath, String charsetName) {
1455:      *     FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead}. An
1459:      *        FileSource.forRecordStreamFormat(
1465:     public <OUT> DataStreamSource<OUT> readFile(FileInputFormat<OUT> inputFormat, String filePath) {
1491:     public <OUT> DataStreamSource<OUT> readFile(
1545:      *     FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead}. An
1549:      *        FileSource.forRecordStreamFormat(
1557:     public <OUT> DataStreamSource<OUT> readFile(
1631:      *     FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead}. An
1635:      *        FileSource.forRecordStreamFormat(
1643:     public <OUT> DataStreamSource<OUT> readFile(
1783:     public <OUT> DataStreamSource<OUT> createInput(InputFormat<OUT, ?> inputFormat) {
1808:     public <OUT> DataStreamSource<OUT> createInput(
1810:         DataStreamSource<OUT> source;
1829:     private <OUT> DataStreamSource<OUT> createInput(
1837:     private <OUT> DataStreamSource<OUT> createFileInput(
1868:         SingleOutputStreamOperator<OUT> source =
1876:         return new DataStreamSource<>(source);
1887:      * call {@link org.apache.flink.streaming.api.datastream.DataStreamSource#setParallelism(int)}
1893:     public <OUT> DataStreamSource<OUT> addSource(SourceFunction<OUT> function) {
1907:     public <OUT> DataStreamSource<OUT> addSource(SourceFunction<OUT> function, String sourceName) {
1921:     public <OUT> DataStreamSource<OUT> addSource(
1937:     public <OUT> DataStreamSource<OUT> addSource(
1942:     private <OUT> DataStreamSource<OUT> addSource(
1959:         return new DataStreamSource<>(
1982:     public <OUT> DataStreamSource<OUT> fromSource(
2008:     public <OUT> DataStreamSource<OUT> fromSource(
2017:         return new DataStreamSource<>(
2068:             streamGraph = getStreamGraph(originalTransformations);
2158:         return executeAsync(getStreamGraph());
2225:         return getStreamGraph(true);
2248:         return getStreamGraphGenerator(transformations).generate();
2276:         return getStreamGraphGenerator(transformations).generate();
2307:         return getStreamGraph(false).getStreamingPlanAsJSON();
2404:      * Creates a {@link LocalStreamEnvironment}. The local execution environment will run the
2411:     public static LocalStreamEnvironment createLocalEnvironment() {
2416:      * Creates a {@link LocalStreamEnvironment}. The local execution environment will run the
2423:     public static LocalStreamEnvironment createLocalEnvironment(int parallelism) {
2428:      * Creates a {@link LocalStreamEnvironment}. The local execution environment will run the
2436:     public static LocalStreamEnvironment createLocalEnvironment(
2445:      * Creates a {@link LocalStreamEnvironment}. The local execution environment will run the
2451:     public static LocalStreamEnvironment createLocalEnvironment(Configuration configuration) {
2453:             return new LocalStreamEnvironment(configuration);
2458:             return new LocalStreamEnvironment(copyOfConfiguration);
2463:      * Creates a {@link LocalStreamEnvironment} for local program execution that also starts the web
2486:      * Creates a {@link RemoteStreamEnvironment}. The remote environment sends (parts of) the
2501:         return new RemoteStreamEnvironment(host, port, jarFiles);
2505:      * Creates a {@link RemoteStreamEnvironment}. The remote environment sends (parts of) the
2520:         RemoteStreamEnvironment env = new RemoteStreamEnvironment(host, port, jarFiles);
2526:      * Creates a {@link RemoteStreamEnvironment}. The remote environment sends (parts of) the
2541:         return new RemoteStreamEnvironment(host, port, clientConfig, jarFiles);
github.com/apache/spark:streaming/src/main/java/org/apache/spark/streaming/StreamingContextState.java: [ master, ]
28: public enum StreamingContextState {
25:  * Represents the state of a StreamingContext.
31:    * Input DStreams, transformations and output operations can be created on the context.
37:    * Input DStreams, transformations and output operations cannot be created on the context.
github.com/google/oss-fuzz:projects/spring-framework/spring-oxm/XStreamMarshallerFuzzer.java: [ master, ]
31: 	private static final PrintStream noopStream = new PrintStream(new OutputStream() {
27: public class XStreamMarshallerFuzzer {
18: import com.thoughtworks.xstream.io.StreamException;
22: import javax.xml.transform.stream.StreamResult;
23: import javax.xml.transform.stream.StreamSource;
37: 		System.setErr(noopStream);
38: 		System.setOut(noopStream);
67: 			marshaller.marshal(buffer, new StreamResult(writer));
68: 			marshaller.unmarshal(new StreamSource(reader));
69: 		} catch (IOException | StreamException e) {}
17: import com.thoughtworks.xstream.XStreamException;
20: import org.springframework.oxm.xstream.XStreamMarshaller;
42: 		XStreamMarshaller marshaller = new XStreamMarshaller();
github.com/apache/opennlp:opennlp-tools/src/main/java/opennlp/tools/formats/ad/ADSentenceStream.java: [ master, ]
47: public class ADSentenceStream extends FilterObjectStream<String, ADSentenceStream.Sentence> {
504:   public ADSentenceStream(ObjectStream<String> lineStream) {
34:  * Stream filter which merges text lines into sentences, following the Arvores
29: import opennlp.tools.formats.ad.ADSentenceStream.SentenceParser.Node;
30: import opennlp.tools.util.FilterObjectStream;
31: import opennlp.tools.util.ObjectStream;
505:     super(lineStream);
github.com/google/live-transcribe-speech-engine:app/src/main/java/com/google/audio/StreamingAudioEncoder.java: [ master, ]
44: public class StreamingAudioEncoder {
76:   public StreamingAudioEncoder(boolean useDeprecatedEncoder) {
80:   public StreamingAudioEncoder() {
84:   private interface StreamingAudioInternalEncoder {
28: import java.io.ByteArrayOutputStream;
73:   private StreamingAudioInternalEncoder impl;
234:   private static class AndroidSystemEncoder implements StreamingAudioInternalEncoder {
306:       ByteArrayOutputStream outputBytes = new ByteArrayOutputStream();
327:       ByteArrayOutputStream outputBytes = new ByteArrayOutputStream();
340:         byte[] input, int offset, int length, boolean flush, ByteArrayOutputStream outputBytes) {
473:   private static class OggOpusEncoder implements StreamingAudioInternalEncoder {
277:     // Note that VBR is not currently supported for the AndroidStreamingEncoder.
github.com/apache/dolphinscheduler:dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/StreamTaskExecuteRunnable.java: [ dev, ]
84: public class StreamTaskExecuteRunnable implements Runnable {
115:     public StreamTaskExecuteRunnable(TaskDefinition taskDefinition, TaskExecuteStartMessage taskExecuteStartMessage) ...(1 bytes skipped)...
75: import java.util.stream.Stream;
390:                 Stream<Integer> resourceIdStream = projectResourceFiles.stream().map(ResourceInfo::getId);
50: import org.apache.dolphinscheduler.server.master.cache.StreamTaskInstanceExecCacheManager;
98:     private StreamTaskInstanceExecCacheManager streamTaskInstanceExecCacheManager;
123:                 SpringApplicationContext.getBean(StreamTaskInstanceExecCacheManager.class);
391:                 Set<Integer> resourceIdsSet = resourceIdStream.collect(Collectors.toSet());
github.com/apache/metron:metron-platform/metron-parsing/metron-parsers/src/main/java/org/apache/metron/parsers/ise/JavaCharStream.java: [ master, ]
29: class JavaCharStream
95:   protected java.io.Reader inputStream;
415:   public JavaCharStream(java.io.Reader dstream,
430:   public JavaCharStream(java.io.Reader dstream,
437:   public JavaCharStream(java.io.Reader dstream)
475:   public JavaCharStream(java.io.InputStream dstream, String encoding, int startline,
482:   public JavaCharStream(java.io.InputStream dstream, int startline,
489:   public JavaCharStream(java.io.InputStream dstream, String encoding, int startline,
496:   public JavaCharStream(java.io.InputStream dstream, int startline,
503:   public JavaCharStream(java.io.InputStream dstream, String encoding) throws java.io.UnsupportedEncodingException
509:   public JavaCharStream(java.io.InputStream dstream)
18: /* Generated By:JavaCC: Do not edit this line. JavaCharStream.java Version 5.0 */
25:  * An implementation of interface CharStream, where the stream is assumed to
161:       if ((i = inputStream.read(nextCharBuf, maxNextCharInd,
164:         inputStream.close();
418:     inputStream = dstream;
445:     inputStream = dstream;
515:   public void ReInit(java.io.InputStream dstream, String encoding, int startline,
522:   public void ReInit(java.io.InputStream dstream, int startline,
528:   public void ReInit(java.io.InputStream dstream, String encoding, int startline,
534:   public void ReInit(java.io.InputStream dstream, int startline,
540:   public void ReInit(java.io.InputStream dstream, String encoding) throws java.io.UnsupportedEncodingException
546:   public void ReInit(java.io.InputStream dstream)
478:     this(encoding == null ? new java.io.InputStreamReader(dstream, StandardCharsets.UTF_8) : new java.io.InputStreamReader(dstream, encoding), startline, startcolumn, buffersize);
485:     this(new java.io.InputStreamReader(dstream, StandardCharsets.UTF_8), startline, startcolumn, buffersize);
518:     ReInit(encoding == null ? new java.io.InputStreamReader(dstream, StandardCharsets.UTF_8) : new java.io.InputStreamReader(dstream, encoding), startline, startcolumn, buffersize);
525:     ReInit(new java.io.InputStreamReader(dstream, StandardCharsets.UTF_8), startline, startcolumn, buffersize);
github.com/GoogleCloudPlatform/training-data-analyst:quests/dataflow/7_Advanced_Streaming_Analytics/solution/src/main/java/com/mypackage/pipeline/StreamingMinuteTrafficPipeline.java: [ master, ]
71: public class StreamingMinuteTrafficPipeline {
39:  * The {@link StreamingMinuteTrafficPipeline} is a sample pipeline which can be used as a base for creating a real
81:     private static final Logger LOG = LoggerFactory.getLogger(StreamingMinuteTrafficPipeline.class);
153:      * StreamingMinuteTrafficPipeline#run(Options)} method to start the pipeline and invoke
github.com/GoogleCloudPlatform/training-data-analyst:quests/dataflow/7_Advanced_Streaming_Analytics/labs/src/main/java/com/mypackage/pipeline/StreamingMinuteTrafficPipeline.java: [ master, ]
45: public class StreamingMinuteTrafficPipeline {
50:     private static final Logger LOG = LoggerFactory.getLogger(StreamingMinuteTrafficPipeline.class);
82:      * execution is required, use the {@link StreamingMinuteTrafficPipeline#run(Options)} method to
171:                 // Streaming insert of aggregate data
github.com/apache/commons-lang:src/main/java/org/apache/commons/lang3/stream/Streams.java: [ master, ]
82: public class Streams {
177:     public static class FailableStream<T> {
187:         public FailableStream(final Stream<T> stream) {
534:     public static <T> FailableStream<T> failableStream(final Collection<T> stream) {
578:     public static <T> FailableStream<T> failableStream(final Stream<T> stream) {
38: import java.util.stream.Stream;
78:  * @see Stream
173:      * A reduced, and simplified version of a {@link Stream} with failable method signatures.
179:         private Stream<T> stream;
489:         public Stream<T> stream() {
496:      * of the {@link Stream} class, with the same underlying element stream, except that failable objects, like
539:      * Converts the given {@link Stream stream} into a {@link FailableStream}. This is basically a simplified, reduced
540:      * version of the {@link Stream} class, with the same underlying element stream, except that failable objects, like
588:      * {@code (Stream<E>) Streams.toStream(collection).filter(collection, SomeClass.class::isInstance);}
597:     public static <E> Stream<E> instancesOf(final Class<? super E> clazz, final Collection<? super E> collection) {
602:     private static <E> Stream<E> instancesOf(final Class<? super E> clazz, final Stream<?> stream) {
603:         return (Stream<E>) of(stream).filter(clazz::isInstance);
614:     public static <E> Stream<E> nonNull(final Collection<E> collection) {
627:     public static <E> Stream<E> nonNull(final E... array) {
639:     public static <E> Stream<E> nonNull(final Stream<E> stream) {
644:      * Delegates to {@link Collection#stream()} or returns {@link Stream#empty()} if the collection is null.
648:      * @return {@link Collection#stream()} or {@link Stream#empty()} if the collection is null.
651:     public static <E> Stream<E> of(final Collection<E> collection) {
652:         return collection == null ? Stream.empty() : collection.stream();
663:     public static <E> Stream<E> of(final Enumeration<E> enumeration) {
672:      * @return a new Stream or {@link Stream#empty()} if the Iterable is null.
675:     public static <E> Stream<E> of(final Iterable<E> iterable) {
676:         return iterable == null ? Stream.empty() : StreamSupport.stream(iterable.spliterator(), false);
684:      * @return a new Stream or {@link Stream#empty()} if the Iterator is null.
687:     public static <E> Stream<E> of(final Iterator<E> iterator) {
688:         return iterator == null ? Stream.empty() : StreamSupport.stream(Spliterators.spliteratorUnknownSize(iterator, Spliterator.ORDERED), false);
692:      * Returns the stream or {@link Stream#empty()} if the stream is null.
696:      * @return the stream or {@link Stream#empty()} if the stream is null.
699:     private static <E> Stream<E> of(final Stream<E> stream) {
700:         return stream == null ? Stream.empty() : stream;
704:      * Null-safe version of {@link Stream#of(Object[])}.
708:      * @return the new stream on {@code values} or {@link Stream#empty()}.
712:     public static <T> Stream<T> of(final T... values) {
713:         return values == null ? Stream.empty() : Stream.of(values);
718:      * of the {@link Stream} class, with the same underlying element stream, except that failable objects, like
762:      * Converts the given {@link Stream stream} into a {@link FailableStream}. This is basically a simplified, reduced
763:      * version of the {@link Stream} class, with the same underlying element stream, except that failable objects, like
799:      * @deprecated Use {@link #failableStream(Stream)}.
802:     public static <T> FailableStream<T> stream(final Stream<T> stream) {
39: import java.util.stream.StreamSupport;
66:  * Using a {@link FailableStream}, this can be rewritten as follows:
71:  * Streams.failable(stream).forEach((m) -> m.invoke(o, args));
132:      * Helps implement {@link Streams#of(Enumeration)}.
269:          *     List<String> asList = stringStream.collect(Collectors.toList());
279:          *     Map<String, List<Person>> peopleByCity = personStream.collect(Collectors.groupingBy(Person::getCity));
289:          *     Map<String, Map<String, List<Person>>> peopleByStateAndCity = personStream
307:          * Performs a mutable reduction operation on the elements of this FailableStream. A mutable reduction is one in which
334:          *     List<String> asList = stringStream.collect(ArrayList::new, ArrayList::add, ArrayList::addAll);
344:          *     String concat = stringStream.collect(StringBuilder::new, StringBuilder::append, StringBuilder::append).toString();
364:          * Returns a FailableStream consisting of the elements of this stream that match the given FailablePredicate.
374:         public FailableStream<T> filter(final FailablePredicate<T, ?> predicate) {
422:         public <R> FailableStream<R> map(final FailableFunction<T, R, ?> mapper) {
424:             return new FailableStream<>(stream.map(Failable.asFunction(mapper)));
485:          * Converts the FailableStream into an equivalent stream.
487:          * @return A stream, which will return the same elements, which this FailableStream would return.
495:      * Converts the given {@link Collection} into a {@link FailableStream}. This is basically a simplified, reduced version
526:      * intermediate objects, of type FailableStream), it is much more concise, and readable, and meets the spirit of Lambdas
531:      * @return The {@link FailableStream}, which has been created by converting the stream.
535:         return failableStream(of(stream));
570:      * intermediate objects, of type FailableStream), it is much more concise, and readable, and meets the spirit of Lambdas
575:      * @return The {@link FailableStream}, which has been created by converting the stream.
579:         return new FailableStream<>(stream);
583:      * Streams only instances of the give Class in a collection.
607:      * Streams the non-null elements of a collection.
619:      * Streams the non-null elements of an array.
632:      * Streams the non-null elements of a stream.
656:      * Streams the elements of the given enumeration in order.
664:         return StreamSupport.stream(new EnumerationSpliterator<>(Long.MAX_VALUE, Spliterator.ORDERED, enumeration), false...(2 bytes skipped)...
717:      * Converts the given {@link Collection} into a {@link FailableStream}. This is basically a simplified, reduced version
748:      * intermediate objects, of type FailableStream), it is much more concise, and readable, and meets the spirit of Lambdas
753:      * @return The {@link FailableStream}, which has been created by converting the stream.
754:      * @deprecated Use {@link #failableStream(Collection)}.
757:     public static <E> FailableStream<E> stream(final Collection<E> collection) {
758:         return failableStream(collection);
793:      * intermediate objects, of type FailableStream), it is much more concise, and readable, and meets the spirit of Lambdas
798:      * @return The {@link FailableStream}, which has been created by converting the stream.
803:         return failableStream(stream);
github.com/junit-team/junit5:junit-platform-launcher/src/main/java/org/junit/platform/launcher/core/StreamInterceptor.java: [ master, ]
23: class StreamInterceptor extends PrintStream {
25: 	private final PrintStream originalStream;
50: 	private StreamInterceptor(PrintStream originalStream, Consumer<PrintStream> unregisterAction,
96: 	class RewindableByteArrayOutputStream extends ByteArrayOutputStream {
13: import java.io.ByteArrayOutputStream;
14: import java.io.PrintStream;
26: 	private final Consumer<PrintStream> unregisterAction;
29: 	private final ThreadLocal<RewindableByteArrayOutputStream> output = ThreadLocal.withInitial(
30: 		RewindableByteArrayOutputStream::new);
32: 	static Optional<StreamInterceptor> registerStdout(int maxNumberOfBytesPerThread) {
36: 	static Optional<StreamInterceptor> registerStderr(int maxNumberOfBytesPerThread) {
40: 	static Optional<StreamInterceptor> register(PrintStream originalStream, Consumer<PrintStream> streamSetter,
42: 		if (originalStream instanceof StreamInterceptor) {
45: 		StreamInterceptor interceptor = new StreamInterceptor(originalStream, streamSetter, maxNumberOfBytesPerThread);
52: 		super(originalStream);
53: 		this.originalStream = originalStream;
67: 		unregisterAction.accept(originalStream);
72: 		RewindableByteArrayOutputStream out = output.get();
86: 		RewindableByteArrayOutputStream out = output.get();
github.com/apache/flume:flume-ng-core/src/main/java/org/apache/flume/serialization/ResettableFileInputStream.java: [ trunk, ]
87: public class ResettableFileInputStream extends ResettableInputStream
140:   public ResettableFileInputStream(File file, PositionTracker tracker)
168:   public ResettableFileInputStream(File file, PositionTracker tracker,
28: import java.io.FileInputStream;
79:  * and a new instance of ResettableFileInputStream is used to resume reading,
90:   Logger logger = LoggerFactory.getLogger(ResettableFileInputStream.class);
104:   private final FileInputStream in;
173:     this.in = new FileInputStream(file);
github.com/apache/commons-lang:src/main/java/org/apache/commons/lang3/Streams.java: [ master, ]
67: public class Streams {
76:     public static class FailableStream<O> {
85:         public FailableStream(final Stream<O> stream) {
32: import java.util.stream.Stream;
61:  * @see Stream
70:      * A reduced, and simplified version of a {@link Stream} with
78:         private Stream<O> stream;
349:         public Stream<O> stream() {
407:      * Converts the given {@link Stream stream} into a {@link FailableStream}.
408:      * This is basically a simplified, reduced version of the {@link Stream}
444:     public static <O> FailableStream<O> stream(final Stream<O> stream) {
450:      * This is basically a simplified, reduced version of the {@link Stream}
54:  * Using a {@link FailableStream}, this can be rewritten as follows:
56:  *     Streams.failable(stream).forEach((m) -&gt; m.invoke(o, args));
64:  * @deprecated Use {@link org.apache.commons.lang3.stream.Streams}.
73:      * @deprecated Use {@link org.apache.commons.lang3.stream.Streams.FailableStream}.
111:          * Returns a FailableStream consisting of the elements of this stream that match
122:         public FailableStream<O> filter(final FailablePredicate<O, ?> predicate){
183:          *     List<String> asList = stringStream.collect(Collectors.toList());
191:          *         = personStream.collect(Collectors.groupingBy(Person::getCity));
200:          *         = personStream.collect(Collectors.groupingBy(Person::getState,
217:          * Performs a mutable reduction operation on the elements of this FailableStream.
243:          *     List<String> asList = stringStream.collect(ArrayList::new, ArrayList::add,
252:          *     String concat = stringStream.collect(StringBuilder::new, StringBuilder::append,
340:         public <R> FailableStream<R> map(final FailableFunction<O, R, ?> mapper) {
342:             return new FailableStream<>(stream.map(Functions.asFunction(mapper)));
346:          * Converts the FailableStream into an equivalent stream.
347:          * @return A stream, which will return the same elements, which this FailableStream would return.
436:      *  intermediate objects, of type FailableStream), it is much more
441:      * @return The {@link FailableStream}, which has been created by
445:         return new FailableStream<>(stream);
449:      * Converts the given {@link Collection} into a {@link FailableStream}.
478:      *  intermediate objects, of type FailableStream), it is much more
483:      * @return The {@link FailableStream}, which has been created by
486:     public static <O> FailableStream<O> stream(final Collection<O> stream) {
494:      * @deprecated Use {@link org.apache.commons.lang3.stream.Streams.ArrayCollector}.
github.com/apache/log4j:contribs/JimMoore/LoggingOutputStream.java: [ trunk, ]
40: public class LoggingOutputStream extends OutputStream {
85:   private LoggingOutputStream() {
100:   public LoggingOutputStream(Category cat, Priority priority)
24:  * An OutputStream that flushes out to a Category.<p>
31:  * System.setErr(new PrintStream(new LoggingOutputStream(Category.getRoot(), Priority.WARN), true));
34:  * System.setOut(new PrintStream(new LoggingOutputStream(Category.getRoot(), Priority.INFO), true));
91:    * Creates the LoggingOutputStream to flush to the given Category.
183:     // don't print out blank lines; flushing from PrintStream puts out these