| /external/chromium_org/remoting/protocol/ |
| D | buffered_socket_writer.cc | 19 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()
|
| D | channel_multiplexer.cc | 29 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::__anon4daa9f710111::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 …]
|
| D | message_reader_unittest.cc | 111 base::Closure done_task; in TEST_F() local
117 .WillOnce(SaveArg<0>(&done_task)); in TEST_F()
131 done_task.Run(); in TEST_F()
237 base::Closure done_task; in TEST_F() local
243 .WillOnce(SaveArg<0>(&done_task)); in TEST_F()
257 done_task.Run(); in TEST_F()
265 .WillOnce(SaveArg<0>(&done_task)); in TEST_F()
275 done_task.Run(); in TEST_F()
|
| D | message_reader.h | 88 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()
|
| D | audio_reader.cc | 39 const base::Closure& done_task) { in OnNewData() argument
40 audio_stub_->ProcessAudioPacket(packet.Pass(), done_task); in OnNewData()
|
| D | host_event_dispatcher.cc | 31 scoped_ptr<EventMessage> message, const base::Closure& done_task) { in OnMessageReceived() argument
34 base::ScopedClosureRunner done_runner(done_task); in OnMessageReceived()
|
| D | protobuf_video_reader.cc | 58 const base::Closure& done_task) { in OnNewData() argument
59 video_stub_->ProcessVideoPacket(packet.Pass(), done_task); in OnNewData()
|
| D | channel_multiplexer.h | 58 const base::Closure& done_task);
62 const base::Closure& done_task);
|
| D | host_control_dispatcher.cc | 71 scoped_ptr<ControlMessage> message, const base::Closure& done_task) { in OnMessageReceived() argument
75 base::ScopedClosureRunner done_runner(done_task); in OnMessageReceived()
|
| D | client_control_dispatcher.cc | 126 scoped_ptr<ControlMessage> message, const base::Closure& done_task) { in OnMessageReceived() argument
129 base::ScopedClosureRunner done_runner(done_task); in OnMessageReceived()
|
| D | host_event_dispatcher.h | 43 const base::Closure& done_task);
|
| D | audio_reader.h | 40 const base::Closure& done_task);
|
| D | protobuf_video_reader.h | 37 const base::Closure& done_task);
|
| D | host_control_dispatcher.h | 65 const base::Closure& done_task);
|
| D | client_control_dispatcher.h | 61 const base::Closure& done_task);
|
| D | buffered_socket_writer.h | 48 const base::Closure& done_task);
|
| /external/chromium/chrome/browser/remoting/ |
| D | setup_flow_get_status_step.cc | 57 Task* done_task = task_factory_.NewRunnableMethod( in LaunchServiceProcess() local
59 process_control_->Launch(done_task, done_task); in LaunchServiceProcess()
|