Searched defs:done_task (Results 1 - 8 of 8) sorted by last modified time

/external/chromium_org/remoting/protocol/
H A Daudio_reader.cc39 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 Dbuffered_socket_writer.cc19 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 Dchannel_multiplexer.cc29 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 Dclient_control_dispatcher.cc126 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 Dhost_control_dispatcher.cc71 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 Dhost_event_dispatcher.cc31 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 Dmessage_reader.h32 // 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 Dmessage_reader_unittest.cc112 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