| /external/chromium_org/net/tools/quic/ |
| quic_packet_writer_wrapper.cc | 15 : writer_(writer) {}
24 return writer_->WritePacket(buffer, buf_len, self_address, peer_address);
28 return writer_->IsWriteBlockedDataBuffered();
32 return writer_->IsWriteBlocked();
36 writer_->SetWritable();
40 writer_.reset(writer);
44 return writer_.release();
|
| quic_packet_writer_wrapper.h | 25 // to |writer_|.
38 // Releases ownership of |writer_|.
42 scoped_ptr<QuicPacketWriter> writer_; member in class:net::tools::QuicPacketWriterWrapper
|
| quic_time_wait_list_manager_test.cc | 92 : time_wait_list_manager_(&writer_, &visitor_,
102 EXPECT_CALL(writer_, IsWriteBlocked())
104 EXPECT_CALL(writer_, IsWriteBlockedDataBuffered())
164 StrictMock<MockPacketWriter> writer_; member in class:net::tools::test::__anon13783::QuicTimeWaitListManagerTest
232 EXPECT_CALL(writer_, WritePacket(_, kConnectionCloseLength,
243 EXPECT_CALL(writer_, WritePacket(_, _,
257 EXPECT_CALL(writer_, WritePacket(_, _, _, _))
322 EXPECT_CALL(writer_, WritePacket(_, _,
331 EXPECT_CALL(writer_, WritePacket(_, _,
352 EXPECT_CALL(writer_, WritePacket(_, _, _, _)
[all...] |
| /external/chromium_org/net/url_request/ |
| url_fetcher_response_writer_unittest.cc | 27 writer_.reset(new URLFetcherStringWriter);
31 scoped_ptr<URLFetcherStringWriter> writer_; member in class:net::URLFetcherStringWriterTest
39 rv = writer_->Initialize(callback.callback());
41 rv = writer_->Write(buf_.get(), buf_->size(), callback.callback());
43 rv = writer_->Finish(callback.callback());
47 EXPECT_EQ(kData, writer_->data());
50 rv = writer_->Initialize(callback.callback());
52 EXPECT_TRUE(writer_->data().empty());
60 writer_.reset(new URLFetcherFileWriter(
67 scoped_ptr<URLFetcherFileWriter> writer_; member in class:net::URLFetcherFileWriterTest
153 scoped_ptr<URLFetcherFileWriter> writer_; member in class:net::URLFetcherFileWriterTemporaryFileTest
[all...] |
| /external/chromium_org/third_party/libxml/chromium/ |
| libxml_utils.cc | 106 : writer_(NULL),
110 if (writer_)
111 xmlFreeTextWriter(writer_);
118 writer_ = xmlNewTextWriterMemory(buffer_, 0);
119 xmlTextWriterSetIndent(writer_, 1);
120 xmlTextWriterStartDocument(writer_, NULL, NULL, NULL);
124 xmlTextWriterEndDocument(writer_);
125 xmlFreeTextWriter(writer_);
126 writer_ = NULL;
|
| libxml_utils.h | 122 void StartIndenting() { xmlTextWriterSetIndent(writer_, 1); }
125 void StopIndenting() { xmlTextWriterSetIndent(writer_, 0); }
130 return xmlTextWriterStartElement(writer_,
136 return xmlTextWriterEndElement(writer_) >= 0;
141 return xmlTextWriterWriteString(writer_,
148 return xmlTextWriterWriteAttribute(writer_,
158 return xmlTextWriterWriteElement(writer_,
174 xmlTextWriterPtr writer_; member in class:XmlWriter
|
| /external/chromium_org/chrome/browser/diagnostics/ |
| diagnostics_controller.cc | 29 DiagnosticsController::DiagnosticsController() : writer_(NULL) {}
63 writer_ = writer;
66 model_->RunAll(writer_);
97 writer_ = writer;
99 model_->RecoverAll(writer_);
|
| diagnostics_controller.h | 56 DiagnosticsWriter* writer_; member in class:diagnostics::DiagnosticsController
|
| diagnostics_controller_unittest.cc | 52 writer_.reset();
54 // writer_.reset(new DiagnosticsWriter(DiagnosticsWriter::MACHINE));
75 scoped_ptr<DiagnosticsWriter> writer_; member in class:diagnostics::DiagnosticsControllerTest
86 DiagnosticsController::GetInstance()->Run(cmdline_, writer_.get());
100 DiagnosticsController::GetInstance()->Run(cmdline_, writer_.get());
101 DiagnosticsController::GetInstance()->RunRecovery(cmdline_, writer_.get());
119 DiagnosticsController::GetInstance()->Run(cmdline_, writer_.get());
132 DiagnosticsController::GetInstance()->RunRecovery(cmdline_, writer_.get());
141 DiagnosticsController::GetInstance()->Run(cmdline_, writer_.get());
154 DiagnosticsController::GetInstance()->RunRecovery(cmdline_, writer_.get())
[all...] |
| /external/chromium_org/remoting/protocol/ |
| client_event_dispatcher.cc | 23 writer_.Close();
28 writer_.Init(channel(),
38 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
46 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
53 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
|
| client_event_dispatcher.h | 33 BufferedSocketWriter writer_; member in class:remoting::protocol::ClientEventDispatcher
|
| host_control_dispatcher.cc | 27 writer_.Close();
33 writer_.Init(channel(), BufferedSocketWriter::WriteFailedCallback());
40 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
47 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
54 writer_.Write(SerializeAndFrameMessage(control_message), base::Closure());
60 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
67 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
|
| client_control_dispatcher.cc | 68 writer_.Close();
73 writer_.Init(channel(), BufferedSocketWriter::WriteFailedCallback());
82 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
89 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
95 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
101 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
108 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
115 writer_.Write(SerializeAndFrameMessage(message), base::Closure());
122 writer_.Write(SerializeAndFrameMessage(control_message), base::Closure());
|
| buffered_socket_writer_unittest.cc | 39 writer_.reset();
52 writer_.reset(new BufferedSocketWriter());
53 writer_->Init(socket_.get(), base::Bind(
68 writer_->Write(test_buffer_, base::Bind(&BufferedSocketWriterTest::OnDone,
70 writer_->Write(test_buffer_2_, base::Bind(&BufferedSocketWriterTest::OnDone,
84 writer_->Write(test_buffer_, base::Bind(
86 base::Unretained(writer_.get()), test_buffer_2_,
102 scoped_ptr<BufferedSocketWriter> writer_; member in class:remoting::protocol::BufferedSocketWriterTest
142 writer_->Write(test_buffer_, base::Bind(
145 writer_->Write(test_buffer_2_, base::Bind
[all...] |
| /external/chromium_org/net/tools/quic/test_tools/ |
| quic_dispatcher_peer.cc | 24 writer->set_writer(dispatcher->writer_.release());
25 dispatcher->writer_.reset(writer);
30 return dispatcher->writer_.get();
|
| quic_test_utils.cc | 27 writer_(QuicConnectionPeer::GetWriter(this)),
37 writer_(QuicConnectionPeer::GetWriter(this)),
48 writer_(QuicConnectionPeer::GetWriter(this)),
59 writer_(QuicConnectionPeer::GetWriter(this)),
|
| /external/chromium_org/remoting/host/native_messaging/ |
| native_messaging_writer_unittest.cc | 25 scoped_ptr<NativeMessagingWriter> writer_; member in class:remoting::NativeMessagingWriterTest
36 writer_.reset(new NativeMessagingWriter(write_file_.Pass()));
42 EXPECT_TRUE(writer_->WriteMessage(message));
58 writer_.reset(NULL);
68 EXPECT_TRUE(writer_->WriteMessage(message1));
69 EXPECT_TRUE(writer_->WriteMessage(message2));
70 writer_.reset(NULL);
94 EXPECT_FALSE(writer_->WriteMessage(message));
|
| /external/chromium_org/content/browser/loader/ |
| redirect_to_file_resource_handler.cc | 136 writer_(NULL),
145 if (writer_) {
146 writer_->Close();
147 writer_ = NULL;
162 DCHECK(writer_);
163 response->head.download_file_path = writer_->path();
169 DCHECK(!writer_);
234 if (writer_ && writer_->is_writing()) {
249 DCHECK(!writer_);
[all...] |
| /external/chromium_org/content/browser/streams/ |
| stream.cc | 41 &writer_, local
45 writer_->RegisterCallback(base::Bind(&Stream::OnSpaceAvailable,
76 writer_.reset();
84 if (!writer_.get())
87 size_t current_buffered_bytes = writer_->GetTotalBufferedBytes();
99 can_add_data_ = writer_->Write(buffer, size);
103 if (!writer_.get())
112 if (!writer_.get())
115 writer_->Close(0);
116 writer_.reset()
[all...] |
| /external/chromium_org/chrome/browser/media/ |
| webrtc_rtp_dump_writer_unittest.cc | 57 writer_.reset(new WebRtcRtpDumpWriter(
225 scoped_ptr<WebRtcRtpDumpWriter> writer_; member in class:WebRtcRtpDumpWriterTest
234 writer_->EndDump(RTP_DUMP_BOTH,
251 writer_->WriteRtpPacket(
253 writer_->WriteRtpPacket(
261 writer_->EndDump(RTP_DUMP_BOTH,
276 writer_.reset(new WebRtcRtpDumpWriter(
294 writer_->WriteRtpPacket(
297 writer_->WriteRtpPacket(
303 writer_->EndDump(RTP_DUMP_BOTH
[all...] |
| /external/chromium_org/chrome/browser/ui/app_list/search/common/ |
| dictionary_data_store.cc | 32 writer_.reset(
43 if (writer_->HasPendingWrite())
44 writer_->DoScheduledWrite();
63 writer_->ScheduleWrite(this);
|
| /external/chromium_org/components/bookmarks/browser/ |
| bookmark_storage.cc | 148 writer_(profile_path.Append(bookmarks::kBookmarksFileName),
151 writer_.set_commit_interval(base::TimeDelta::FromMilliseconds(kSaveDelayMS));
153 base::Bind(&BackupCallback, writer_.path()));
157 if (writer_.HasPendingWrite())
158 writer_.DoScheduledWrite();
169 writer_.path(),
176 writer_.ScheduleWrite(this);
182 if (writer_.HasPendingWrite())
213 writer_.WriteNow(data);
|
| /external/chromium_org/content/browser/appcache/ |
| appcache_response_unittest.cc | 114 writer_.reset();
182 EXPECT_FALSE(writer_->IsWritePending());
185 writer_->WriteInfo(write_info_buffer_.get(),
191 EXPECT_FALSE(writer_->IsWritePending());
194 writer_->WriteData(write_buffer_.get(),
213 EXPECT_FALSE(writer_->IsWritePending());
219 EXPECT_FALSE(writer_->IsWritePending());
224 writer_.reset();
358 writer_.reset(service_->storage()->CreateResponseWriter(GURL(), 0));
359 written_response_id_ = writer_->response_id()
676 scoped_ptr<AppCacheResponseWriter> writer_; member in class:content::AppCacheResponseTest
[all...] |
| /external/chromium_org/net/quic/ |
| quic_connection_test.cc | 420 writer_(writer) {
424 writer_->set_is_server(is_server);
536 writer_->SetSupportedVersions(versions);
540 writer_->set_is_server(is_server);
577 TestPacketWriter* writer_; member in class:net::test::__anon13480::TestConnection
609 writer_(new TestPacketWriter(version())),
611 writer_.get(), false, version()),
657 if (writer_->ack_frames().empty()) {
660 return writer_->ack_frames()[0].sent_info.least_unacked;
662 if (writer_->stop_waiting_frames().empty())
965 scoped_ptr<TestPacketWriter> writer_; member in class:net::test::__anon13480::QuicConnectionTest
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/session/media/ |
| mediarecorder.cc | 65 if (recording_ && !writer_) {
69 writer_.reset(new RtpDumpWriter(stream_.get()));
70 writer_->set_packet_filter(packet_filter_);
80 if (recording_ && writer_) {
82 if (writer_->GetDumpSize(¤t_size) &&
85 writer_->WriteRtpPacket(data, size);
96 if (writer_) {
97 writer_->set_packet_filter(packet_filter_);
|
