/external/chromium_org/remoting/protocol/ |
buffered_socket_writer.cc | 19 const base::Closure& done_task) 21 done_task(done_task) { 25 base::Closure done_task; member in struct:remoting::protocol::BufferedSocketWriterBase::PendingPacket 45 scoped_refptr<net::IOBufferWithSize> data, const base::Closure& done_task) { 54 queue_.push_back(new PendingPacket(data, done_task)); 109 base::Closure done_task = AdvanceBufferPosition(result); local 110 if (!done_task.is_null()) { 113 done_task.Run(); 167 base::Closure result = queue_.front()->done_task; [all...] |
message_reader.h | 32 // processed by the receiver (|done_task| is called for each message). 63 // processing yet, i.e. |done_task| hasn't been called for these 85 // The callback that is called when a new message is received. |done_task| 88 const base::Closure& done_task)> 105 const base::Closure& done_task) { 113 message_received_callback_.Run(message.Pass(), done_task);
|
audio_reader.cc | 39 const base::Closure& done_task) { 40 audio_stub_->ProcessAudioPacket(packet.Pass(), done_task);
|
host_event_dispatcher.cc | 31 scoped_ptr<EventMessage> message, const base::Closure& done_task) { 34 base::ScopedClosureRunner done_runner(done_task);
|
channel_multiplexer.cc | 29 const base::Closure& done_task) 31 done_task(done_task), 35 done_task.Run(); 49 base::Closure done_task; member in class:remoting::protocol::__anon15122::PendingPacket 81 const base::Closure& done_task); 87 const base::Closure& done_task); 222 const base::Closure& done_task) { 225 pending_packets_.push_back(new PendingPacket(packet.Pass(), done_task)); 245 const base::Closure& done_task) { [all...] |
message_reader_unittest.cc | 112 base::Closure done_task; local 118 .WillOnce(SaveArg<0>(&done_task)); 132 done_task.Run(); 238 base::Closure done_task; local 244 .WillOnce(SaveArg<0>(&done_task)); 258 done_task.Run(); 266 .WillOnce(SaveArg<0>(&done_task)); 276 done_task.Run();
|
channel_multiplexer.h | 54 const base::Closure& done_task); 58 const base::Closure& done_task);
|
host_control_dispatcher.cc | 71 scoped_ptr<ControlMessage> message, const base::Closure& done_task) { 75 base::ScopedClosureRunner done_runner(done_task);
|
audio_reader.h | 40 const base::Closure& done_task);
|
host_event_dispatcher.h | 43 const base::Closure& done_task);
|
buffered_socket_writer.h | 48 const base::Closure& done_task); 68 // Removes element from the front of the queue and returns |done_task| for
|
client_control_dispatcher.cc | 126 scoped_ptr<ControlMessage> message, const base::Closure& done_task) { 129 base::ScopedClosureRunner done_runner(done_task);
|
client_control_dispatcher.h | 61 const base::Closure& done_task);
|
host_control_dispatcher.h | 65 const base::Closure& done_task);
|