Home
last modified time | relevance | path

Searched refs:done_task (Results 1 – 14 of 14) sorted by relevance

/external/chromium_org/remoting/protocol/
Dbuffered_socket_writer.cc19 const base::Closure& done_task) in PendingPacket()
21 done_task(done_task) { in PendingPacket()
25 base::Closure done_task; member
45 scoped_refptr<net::IOBufferWithSize> data, const base::Closure& done_task) { in Write() argument
54 queue_.push_back(new PendingPacket(data, done_task)); in Write()
109 base::Closure done_task = AdvanceBufferPosition(result); in HandleWriteResult() local
110 if (!done_task.is_null()) { in HandleWriteResult()
113 done_task.Run(); in HandleWriteResult()
167 base::Closure result = queue_.front()->done_task; in PopQueue()
Dchannel_multiplexer.cc29 const base::Closure& done_task) in PendingPacket() argument
31 done_task(done_task), in PendingPacket()
35 done_task.Run(); in ~PendingPacket()
49 base::Closure done_task; member in remoting::protocol::__anon8ac392be0111::PendingPacket
81 const base::Closure& done_task);
87 const base::Closure& done_task);
222 const base::Closure& done_task) { in OnIncomingPacket() argument
225 pending_packets_.push_back(new PendingPacket(packet.Pass(), done_task)); in OnIncomingPacket()
245 const base::Closure& done_task) { in DoWrite() argument
251 return multiplexer_->DoWrite(packet.Pass(), done_task); in DoWrite()
[all …]
Dmessage_reader_unittest.cc112 base::Closure done_task; in TEST_F() local
118 .WillOnce(SaveArg<0>(&done_task)); in TEST_F()
132 done_task.Run(); in TEST_F()
238 base::Closure done_task; in TEST_F() local
244 .WillOnce(SaveArg<0>(&done_task)); in TEST_F()
258 done_task.Run(); in TEST_F()
266 .WillOnce(SaveArg<0>(&done_task)); in TEST_F()
276 done_task.Run(); in TEST_F()
Dmessage_reader.h88 const base::Closure& done_task)>
105 const base::Closure& done_task) { in OnNewData() argument
113 message_received_callback_.Run(message.Pass(), done_task); in OnNewData()
Daudio_reader.cc39 const base::Closure& done_task) { in OnNewData() argument
40 audio_stub_->ProcessAudioPacket(packet.Pass(), done_task); in OnNewData()
Dhost_event_dispatcher.cc31 scoped_ptr<EventMessage> message, const base::Closure& done_task) { in OnMessageReceived() argument
34 base::ScopedClosureRunner done_runner(done_task); in OnMessageReceived()
Dchannel_multiplexer.h54 const base::Closure& done_task);
58 const base::Closure& done_task);
Dhost_control_dispatcher.cc71 scoped_ptr<ControlMessage> message, const base::Closure& done_task) { in OnMessageReceived() argument
75 base::ScopedClosureRunner done_runner(done_task); in OnMessageReceived()
Dclient_control_dispatcher.cc126 scoped_ptr<ControlMessage> message, const base::Closure& done_task) { in OnMessageReceived() argument
129 base::ScopedClosureRunner done_runner(done_task); in OnMessageReceived()
Dhost_event_dispatcher.h43 const base::Closure& done_task);
Daudio_reader.h40 const base::Closure& done_task);
Dhost_control_dispatcher.h65 const base::Closure& done_task);
Dclient_control_dispatcher.h61 const base::Closure& done_task);
Dbuffered_socket_writer.h48 const base::Closure& done_task);