Searched defs:done_task (Results 1 - 8 of 8) sorted by last modified time
/external/chromium_org/remoting/protocol/ |
H A D | audio_reader.cc | 39 const base::Closure& done_task) { 40 audio_stub_->ProcessAudioPacket(packet.Pass(), done_task); 38 OnNewData(scoped_ptr<AudioPacket> packet, const base::Closure& done_task) argument
|
H A D | 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; 18 PendingPacket(scoped_refptr<net::IOBufferWithSize> data, const base::Closure& done_task) argument 44 Write( scoped_refptr<net::IOBufferWithSize> data, const base::Closure& done_task) argument [all...] |
H A D | 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::__anon10497::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) { 28 PendingPacket(scoped_ptr<MultiplexPacket> packet, const base::Closure& done_task) argument 220 OnIncomingPacket( scoped_ptr<MultiplexPacket> packet, const base::Closure& done_task) argument 243 DoWrite( scoped_ptr<MultiplexPacket> packet, const base::Closure& done_task) argument 475 OnIncomingPacket(scoped_ptr<MultiplexPacket> packet, const base::Closure& done_task) argument 506 DoWrite(scoped_ptr<MultiplexPacket> packet, const base::Closure& done_task) argument [all...] |
H A D | client_control_dispatcher.cc | 126 scoped_ptr<ControlMessage> message, const base::Closure& done_task) { 129 base::ScopedClosureRunner done_runner(done_task); 125 OnMessageReceived( scoped_ptr<ControlMessage> message, const base::Closure& done_task) argument
|
H A D | host_control_dispatcher.cc | 71 scoped_ptr<ControlMessage> message, const base::Closure& done_task) { 75 base::ScopedClosureRunner done_runner(done_task); 70 OnMessageReceived( scoped_ptr<ControlMessage> message, const base::Closure& done_task) argument
|
H A D | host_event_dispatcher.cc | 31 scoped_ptr<EventMessage> message, const base::Closure& done_task) { 34 base::ScopedClosureRunner done_runner(done_task); 30 OnMessageReceived( scoped_ptr<EventMessage> message, const base::Closure& done_task) argument
|
H A D | 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); 104 OnNewData(scoped_ptr<CompoundBuffer> buffer, const base::Closure& done_task) argument
|
H A D | 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();
|
Completed in 127 milliseconds