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: 
|
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"} (<application.id>) - 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><client.id>-StreamThread-<threadSequenceNumber$gt;-<consumer|producer|restore-consumer></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) -> 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
|