| /external/chromium_org/remoting/protocol/ |
| audio_reader.cc | 39 const base::Closure& done_task) {
40 audio_stub_->ProcessAudioPacket(packet.Pass(), done_task);
|
| 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...] |
| 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::__anon14498::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.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.h | 40 const base::Closure& done_task);
|
| host_event_dispatcher.h | 43 const base::Closure& done_task);
|
| protobuf_video_reader.h | 37 const base::Closure& done_task);
|
| channel_multiplexer.h | 58 const base::Closure& done_task);
62 const base::Closure& done_task);
|
| 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();
|
| protobuf_video_reader.cc | 58 const base::Closure& done_task) {
59 video_stub_->ProcessVideoPacket(packet.Pass(), done_task);
|
| client_control_dispatcher.h | 61 const base::Closure& done_task);
|
| host_control_dispatcher.h | 65 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);
|
| 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);
|
