/external/webrtc/talk/app/webrtc/ |
mediastream_unittest.cc | 73 stream_ = MediaStream::Create(kStreamLabel1); 74 ASSERT_TRUE(stream_.get() != NULL); 85 EXPECT_TRUE(stream_->AddTrack(video_track_)); 86 EXPECT_FALSE(stream_->AddTrack(video_track_)); 87 EXPECT_TRUE(stream_->AddTrack(audio_track_)); 88 EXPECT_FALSE(stream_->AddTrack(audio_track_)); 105 scoped_refptr<MediaStreamInterface> stream_; member in class:webrtc::MediaStreamTest 111 ASSERT_EQ(1u, stream_->GetVideoTracks().size()); 112 ASSERT_EQ(1u, stream_->GetAudioTracks().size()); 116 stream_->GetVideoTracks()[0]) [all...] |
mediastreamobserver.cc | 35 : stream_(stream), 38 stream_->RegisterObserver(this); 42 stream_->UnregisterObserver(this); 46 AudioTrackVector new_audio_tracks = stream_->GetAudioTracks(); 47 VideoTrackVector new_video_tracks = stream_->GetVideoTracks(); 57 SignalAudioTrackRemoved(cached_track.get(), stream_); 69 SignalAudioTrackAdded(new_track.get(), stream_); 81 SignalVideoTrackRemoved(cached_track.get(), stream_); 93 SignalVideoTrackAdded(new_track.get(), stream_);
|
/external/bsdiff/ |
bz2_decompressor.cc | 23 stream_.next_in = reinterpret_cast<char*>(const_cast<uint8_t*>(input_data)); 24 stream_.avail_in = size; 25 stream_.bzalloc = nullptr; 26 stream_.bzfree = nullptr; 27 stream_.opaque = nullptr; 28 int bz2err = BZ2_bzDecompressInit(&stream_, 0, 0); 37 stream_.next_out = reinterpret_cast<char*>(output_data); 41 stream_.avail_out = output_size; 43 int bz2err = BZ2_bzDecompress(&stream_); 49 bytes_to_output -= (output_size - stream_.avail_out) [all...] |
logging.cc | 24 stream_ << severity << " " << timestamp << " " << file << ":" << line << ": "; 29 stream_ << ": " << strerror(error_); 31 std::cerr << stream_.str() << std::endl;
|
logging.h | 33 std::ostream& stream() { return stream_; } 36 std::ostringstream stream_; member in class:LogMessage
|
/external/google-breakpad/src/processor/ |
binarystream.h | 50 : stream_(which) {} 53 : stream_(str, which) {} 56 : stream_(string(str, size), which) {} 72 bool eof() const { return stream_.eof(); } 73 void clear() { stream_.clear(); } 74 string str() const { return stream_.str(); } 75 void str(const string &s) { stream_.str(s); } 79 stream_.seekg (0, ios::beg); 80 stream_.seekp (0, ios::beg); 83 stream_.clear() 87 std::stringstream stream_; member in class:google_breakpad::binarystream [all...] |
binarystream.cc | 52 stream_.read(&buffer[0], length); 59 stream_.read((char *)&u8, 1); 65 stream_.read((char *)&temp, 2); 73 stream_.read((char *)&temp, 4); 91 stream_.write(str.c_str(), USHRT_MAX); 94 stream_.write(str.c_str(), str.length()); 100 stream_.write((const char*)&u8, 1); 106 stream_.write((const char*)&u16, 2); 112 stream_.write((const char*)&u32, 4);
|
/external/sfntly/cpp/src/sfntly/data/ |
font_input_stream.cc | 24 : stream_(is), position_(0), length_(0), bounded_(false) { 28 : stream_(is), position_(0), length_(length), bounded_(true) { 36 if (stream_) { 37 return stream_->Available(); 43 if (stream_) { 44 stream_->Close(); 49 if (stream_) { 50 stream_->Mark(readlimit); 55 if (stream_) { 56 return stream_->MarkSupported() [all...] |
font_output_stream.cc | 24 : stream_(os), 33 if (stream_) { 34 stream_->Write(b); 48 assert(stream_); 58 stream_->Write(b, off, len); 64 assert(stream_); 73 stream_->Write(b, off, len); 117 if (stream_) { 118 stream_->Flush(); 123 if (stream_) { [all...] |
/system/update_engine/payload_consumer/ |
bzip_extent_writer.cc | 31 int rc = BZ2_bzDecompressInit(&stream_, 53 stream_.next_in = reinterpret_cast<char*>(const_cast<uint8_t*>(input)); 54 stream_.avail_in = input_end - input; 57 stream_.next_out = reinterpret_cast<char*>(output_buffer.data()); 58 stream_.avail_out = output_buffer.size(); 60 int rc = BZ2_bzDecompress(&stream_); 63 if (stream_.avail_out == output_buffer.size()) 68 output_buffer.size() - stream_.avail_out)); 71 CHECK_EQ(stream_.avail_in, 0u); 72 if (stream_.avail_in == 0 [all...] |
bzip_extent_writer.h | 39 memset(&stream_, 0, sizeof(stream_)); 51 bz_stream stream_; // the libbz2 stream member in class:chromeos_update_engine::BzipExtentWriter
|
/external/libbrillo/brillo/streams/ |
fake_stream_unittest.cc | 31 stream_.reset(new FakeStream{mode, &clock_}); 42 bool ok = stream_->ReadNonBlocking(data.data(), data.size(), &size_read, 56 if (!stream_->WriteNonBlocking(data.data(), data.size(), &written, nullptr)) 64 std::unique_ptr<FakeStream> stream_; member in class:brillo::FakeStreamTest 70 EXPECT_TRUE(stream_->IsOpen()); 71 EXPECT_TRUE(stream_->CanRead()); 72 EXPECT_FALSE(stream_->CanWrite()); 73 EXPECT_FALSE(stream_->CanSeek()); 74 EXPECT_FALSE(stream_->CanGetSize()); 75 EXPECT_EQ(0, stream_->GetSize()) [all...] |
input_stream_set_unittest.cc | 28 stream_.reset(new InputStreamSet({itf1_.get(), itf2_.get()}, {}, 100)); 32 stream_.reset(); 39 std::unique_ptr<InputStreamSet> stream_; member in class:brillo::InputStreamSetTest 48 EXPECT_TRUE(stream_->CanRead()); 49 EXPECT_FALSE(stream_->CanWrite()); 50 EXPECT_FALSE(stream_->CanSeek()); 51 EXPECT_EQ(100, stream_->GetSize()); 52 EXPECT_FALSE(stream_->SetSizeBlocking(0, nullptr)); 53 EXPECT_FALSE(stream_->GetPosition()); 54 EXPECT_FALSE(stream_->Seek(0, Stream::Whence::FROM_BEGIN, nullptr, nullptr)) [all...] |
openssl_stream_bio_unittests.cc | 25 stream_.reset(new StrictMock<MockStream>{}); 26 bio_ = BIO_new_stream(stream_.get()); 32 stream_.reset(); 35 std::unique_ptr<StrictMock<MockStream>> stream_; member in class:brillo::StreamBIOTest 41 EXPECT_CALL(*stream_, ReadNonBlocking(buffer, 10, _, _, _)) 50 EXPECT_CALL(*stream_, ReadNonBlocking(buffer, 10, _, _, _)) 59 EXPECT_CALL(*stream_, ReadNonBlocking(buffer, 10, _, _, _)) 69 EXPECT_CALL(*stream_, ReadNonBlocking(buffer, 10, _, _, _)) 79 EXPECT_CALL(*stream_, ReadNonBlocking(buffer, 10, _, _, _)) 87 EXPECT_CALL(*stream_, WriteNonBlocking(buffer, 10, _, _) [all...] |
/external/antlr/antlr-3.4/tool/src/main/resources/org/antlr/codegen/templates/C/ |
AST.stg | 80 :{it | pANTLR3_REWRITE_RULE_<rewriteElementType>_STREAM stream_<it>;}; separator="\n"> 82 :{it | pANTLR3_REWRITE_RULE_SUBTREE_STREAM stream_<it>;}; separator="\n"> 97 :{it | stream_<it> = NULL; 98 #define CREATE_stream_<it> if (stream_<it> == NULL) {stream_<it> = antlr3RewriteRule<rewriteElementType>StreamNewAE(ADAPTOR, RECOGNIZER, (pANTLR3_UINT8)"token <it>"); \} }; separator="\n"> 100 :{it | stream_<it> = NULL; 101 #define CREATE_stream_<it> if (stream_<it> == NULL) {stream_<it> = antlr3RewriteRuleSubtreeStreamNewAE(ADAPTOR, RECOGNIZER, (pANTLR3_UINT8)"rule <it>"); \}}; separator="\n"> 143 <if(backtracking)>if ( <actions.(actionScope).synpredgate> ) { <endif>CREATE_stream_<token>; stream_<token>->add(stream_<token>, <label>, NULL);<if(backtracking)> }<endif><\n [all...] |
/external/webrtc/webrtc/base/ |
logsinks.cc | 31 : stream_(stream) { 39 if (stream_->GetState() != SS_OPEN) { 43 stream_->WriteAll(message.c_str(), message.size(), nullptr, nullptr); 47 return stream_->Open(); 51 return stream_->DisableBuffering();
|
filerotatingstream_unittest.cc | 36 stream_.reset(new FileRotatingStream(dir_path_, file_prefix, max_file_size, 41 stream_.reset(); 50 EXPECT_EQ(SR_SUCCESS, stream_->WriteAll(data, data_len, nullptr, nullptr)); 51 EXPECT_TRUE(stream_->Flush()); 91 scoped_ptr<FileRotatingStream> stream_; member in class:rtc::FileRotatingStreamTest 102 EXPECT_EQ(SS_CLOSED, stream_->GetState()); 103 ASSERT_TRUE(stream_->Open()); 104 EXPECT_EQ(SS_OPEN, stream_->GetState()); 105 stream_->Close(); 106 EXPECT_EQ(SS_CLOSED, stream_->GetState()) 232 scoped_ptr<CallSessionFileRotatingStream> stream_; member in class:rtc::CallSessionFileRotatingStreamTest [all...] |
/external/v8/src/libplatform/tracing/ |
trace-writer.cc | 62 stream_ << (value.as_bool ? "true" : "false"); 65 stream_ << value.as_uint; 68 stream_ << value.as_int; 94 stream_ << real; 100 stream_ << "\"" << value.as_pointer << "\""; 105 stream_ << "\"NULL\""; 107 WriteJSONStringToStream(value.as_string, stream_); 119 stream_ << arg_stringified; 122 JSONTraceWriter::JSONTraceWriter(std::ostream& stream) : stream_(stream) { 123 stream_ << "{\"traceEvents\":[" [all...] |
/external/adhd/cras/src/tests/ |
cras_client_unittest.cc | 73 memset(&stream_, 0, sizeof(stream_)); 74 stream_.id = FIRST_STREAM_ID; 80 stream_.config = config; 84 if (stream_.config) { 85 free(stream_.config); 86 stream_.config = NULL; 94 struct client_stream stream_; member in class:__anon14135::CrasClientTestSuite 123 struct cras_audio_shm *shm = &stream_.capture_shm; 125 stream_.direction = CRAS_STREAM_INPUT [all...] |
/external/eigen/unsupported/Eigen/CXX11/src/Tensor/ |
TensorDeviceCuda.h | 102 CudaStreamDevice() : stream_(&default_stream), scratch_(NULL), semaphore_(NULL) { 107 CudaStreamDevice(int device) : stream_(&default_stream), device_(device), scratch_(NULL), semaphore_(NULL) { 115 : stream_(stream), device_(device), scratch_(NULL), semaphore_(NULL) { 135 const cudaStream_t& stream() const { return *stream_; } 169 cudaError_t err = cudaMemsetAsync(semaphore_, 0, sizeof(unsigned int), *stream_); 177 const cudaStream_t* stream_; 186 explicit GpuDevice(const StreamInterface* stream) : stream_(stream), max_blocks_(INT_MAX) { 189 explicit GpuDevice(const StreamInterface* stream, int num_blocks) : stream_(stream), max_blocks_(num_blocks) { 194 return stream_->stream(); 198 return stream_->allocate(num_bytes) 313 const StreamInterface* stream_; local [all...] |
/prebuilts/ndk/r16/sources/third_party/shaderc/third_party/spirv-tools/source/ |
diagnostic.h | 37 : stream_(other.stream_.str()), 47 stream_ << val; 55 std::stringstream stream_; member in class:libspirv::DiagnosticStream
|
disassemble.cpp | 55 stream_(out_.get()), 120 std::ostream& stream_; // The output std::stream. member in class:__anon777::Disassembler 136 stream_ << "; SPIR-V\n" 142 stream_ << "(" << SPV_GENERATOR_TOOL_PART(generator) << ")"; 146 stream_ << "; " << SPV_GENERATOR_MISC_PART(generator) << "\n" 163 stream_ << std::setw(std::max(0, indent_ - 3 - int(id_name.size()))); 164 stream_ << "%" << id_name; 166 stream_ << " = "; 168 stream_ << std::string(indent_, ' '); 171 stream_ << "Op" << spvOpcodeString(static_cast<SpvOp>(inst.opcode)) [all...] |
/system/extras/perfprofd/ |
perfprofd_io.cc | 88 z_stream* stream_; member in class:android::perfprofd::__anon3002::GzipOutputStream 99 stream_(stream), 105 if (stream_ != nullptr) { 106 deflateEnd(stream_); 107 delete stream_; 108 stream_ = nullptr; 122 return stream_->total_in + stream_->avail_in; 169 stream_->next_out = static_cast<Bytef*>(next_data_); 170 stream_->avail_out = next_size_ [all...] |
/external/libtextclassifier/util/base/ |
logging.cc | 56 stream_ << JumpToBasename(file_name) << ":" << line_number << ": "; 60 LowLevelLogging(severity_, /* tag = */ "txtClsf", stream_.message);
|
/external/protobuf/src/google/protobuf/util/internal/ |
protostream_objectsource.cc | 118 : stream_(stream), 131 : stream_(stream), 186 uint32 tag = stream_->ReadTag(), last_tag = tag + 1; 202 WireFormat::SkipField(stream_, tag, NULL); 203 tag = stream_->ReadTag(); 221 tag = stream_->ReadTag(); 242 tag_to_return = stream_->ReadTag(); 246 } while ((tag_to_return = stream_->ReadTag()) == list_tag); 261 stream_->ReadVarint32(&buffer32); // message length 262 int old_limit = stream_->PushLimit(buffer32) [all...] |