Lines Matching refs:stream_
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_;
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());
113 ASSERT_TRUE(stream_->Open());
116 std::string logfile_path = stream_->GetFilePath(0);
128 ASSERT_TRUE(stream_->Open());
138 stream_->GetFilePath(1));
142 EXPECT_TRUE(Filesystem::IsFile(stream_->GetFilePath(i)));
147 EXPECT_TRUE(Filesystem::IsFile(stream_->GetFilePath(i)));
162 ASSERT_TRUE(stream_->Open());
169 expected_file_contents.size(), stream_->GetFilePath(0));
179 Pathname path(stream_->GetFilePath(i));
195 stream_.reset(
200 stream_.reset();
209 EXPECT_EQ(SR_SUCCESS, stream_->WriteAll(data, data_len, nullptr, nullptr));
210 EXPECT_TRUE(stream_->Flush());
232 scoped_ptr<CallSessionFileRotatingStream> stream_;
241 ASSERT_TRUE(stream_->Open());
254 ASSERT_TRUE(stream_->Open());
267 ASSERT_TRUE(stream_->Open());
273 stream_->WriteAll(buffer.get(), buffer_size, nullptr, nullptr));
276 stream_.reset(new CallSessionFileRotatingStream(dir_path_));
277 ASSERT_TRUE(stream_->Open());
283 stream_->ReadAll(buffer.get(), buffer_size, nullptr, nullptr));
286 EXPECT_EQ(SR_EOS, stream_->ReadAll(buffer.get(), 1, nullptr, nullptr));
294 ASSERT_TRUE(stream_->Open());
300 stream_->WriteAll(buffer.get(), buffer_size, nullptr, nullptr));
303 stream_.reset(new CallSessionFileRotatingStream(dir_path_));
304 ASSERT_TRUE(stream_->Open());
310 stream_->ReadAll(buffer.get(), buffer_size, nullptr, nullptr));
313 EXPECT_EQ(SR_EOS, stream_->ReadAll(buffer.get(), 1, nullptr, nullptr));
