Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 9 of 9) sorted by relevance

/rocksdb-6.9/third-party/gtest-1.8.1/fused-src/gtest/
Dgtest-all.cc5115 stream->write( in OutputXmlCDataSection()
5124 *stream << "]]>"; in OutputXmlCDataSection()
5229 *stream << ">\n"; in PrintXmlTestCase()
5266 *stream << ">\n"; in PrintXmlUnitTest()
5289 *stream << ">\n"; in PrintXmlTestsList()
5325 *stream << "/>\n"; in OutputXmlTestProperties()
5489 *stream << ",\n"; in OutputJsonKey()
5509 *stream << ",\n"; in OutputJsonKey()
5613 *stream << "{\n"; in PrintJsonUnitTest()
5658 *stream << "{\n"; in PrintJsonTestList()
[all …]
Dgtest.h3770 inline FILE *FReopen(const char* path, const char* mode, FILE* stream) {
3771 return freopen(path, mode, stream);
4433 GTEST_API_ std::string StringStreamToString(::std::stringstream* stream);
19748 ::std::ostream& (*basic_manipulator)(::std::ostream& stream)) {
/rocksdb-6.9/db/
Dflush_job.cc257 auto stream = event_logger_->LogToBuffer(log_buffer_, 1024); in Run() local
258 stream << "job" << job_context_->job_id << "event" in Run()
260 stream << "output_compression" in Run()
262 stream << "lsm_state"; in Run()
263 stream.StartArray(); in Run()
266 stream << vstorage->NumLevelFiles(level); in Run()
268 stream.EndArray(); in Run()
276 stream << "file_range_sync_nanos" in Run()
279 stream << "file_prepare_write_nanos" in Run()
281 stream << "file_cpu_write_nanos" in Run()
[all …]
Dexternal_sst_file_ingestion_job.cc273 EventLoggerStream stream = event_logger_->Log(); in UpdateStats() local
274 stream << "event" in UpdateStats()
276 stream << "files_ingested"; in UpdateStats()
277 stream.StartArray(); in UpdateStats()
306 stream << "file" << f.internal_file_path << "level" << f.picked_level; in UpdateStats()
308 stream.EndArray(); in UpdateStats()
310 stream << "lsm_state"; in UpdateStats()
311 stream.StartArray(); in UpdateStats()
314 stream << vstorage->NumLevelFiles(level); in UpdateStats()
316 stream.EndArray(); in UpdateStats()
/rocksdb-6.9/env/
Denv_encryption.cc411 std::unique_ptr<BlockAccessCipherStream> stream; in NewSequentialFile() local
412 status = provider_->CreateCipherStream(fname, options, prefixSlice, &stream); in NewSequentialFile()
449 std::unique_ptr<BlockAccessCipherStream> stream; in NewRandomAccessFile() local
450 status = provider_->CreateCipherStream(fname, options, prefixSlice, &stream); in NewRandomAccessFile()
490 std::unique_ptr<BlockAccessCipherStream> stream; in NewWritableFile() local
491 status = provider_->CreateCipherStream(fname, options, prefixSlice, &stream); in NewWritableFile()
537 std::unique_ptr<BlockAccessCipherStream> stream; in ReopenWritableFile() local
538 status = provider_->CreateCipherStream(fname, options, prefixSlice, &stream); in ReopenWritableFile()
579 std::unique_ptr<BlockAccessCipherStream> stream; in ReuseWritableFile() local
580 status = provider_->CreateCipherStream(fname, options, prefixSlice, &stream); in ReuseWritableFile()
[all …]
/rocksdb-6.9/util/
Dcompression.h1034 LZ4_stream_t* stream = LZ4_createStream(); in LZ4_Compress() local
1037 LZ4_loadDict(stream, compression_dict.data(), in LZ4_Compress()
1049 LZ4_freeStream(stream); in LZ4_Compress()
1103 LZ4_streamDecode_t* stream = LZ4_createStreamDecode(); variable
1106 LZ4_setStreamDecode(stream, compression_dict.data(),
1110 stream, input_data, output.get(), static_cast<int>(input_length),
1112 LZ4_freeStreamDecode(stream);
1174 LZ4_streamHC_t* stream = LZ4_createStreamHC(); in LZ4HC_Compress() local
1175 LZ4_resetStreamHC(stream, level); in LZ4HC_Compress()
1180 LZ4_loadDictHC(stream, compression_dict_data, in LZ4HC_Compress()
[all …]
/rocksdb-6.9/db/compaction/
Dcompaction_job.cc774 stream << "job" << job_id_ << "event" in Install()
795 stream << "file_range_sync_nanos" in Install()
798 stream << "file_prepare_write_nanos" in Install()
802 stream << "lsm_state"; in Install()
803 stream.StartArray(); in Install()
807 stream.EndArray(); in Install()
1701 auto stream = event_logger_->Log(); in LogCompaction() local
1702 stream << "job" << job_id_ << "event" in LogCompaction()
1708 stream.StartArray(); in LogCompaction()
1710 stream << f->fd.GetNumber(); in LogCompaction()
[all …]
/rocksdb-6.9/db/db_impl/
Ddb_impl_open.cc723 auto stream = event_logger_.Log(); in RecoverLogFiles() local
724 stream << "job" << job_id << "event" in RecoverLogFiles()
726 stream << "log_files"; in RecoverLogFiles()
727 stream.StartArray(); in RecoverLogFiles()
729 stream << log_number; in RecoverLogFiles()
731 stream.EndArray(); in RecoverLogFiles()
/rocksdb-6.9/
DUSERS.md11 5. Stylus -- a low-level stream processing framework writtenin C++.[1]
22 2. Apache Samza, open source framework for stream processing