Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(6)

Side by Side Diff: remoting/protocol/buffered_socket_writer.h

Issue 7508044: Remove video_channel() from Session interface (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: - Created 9 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « remoting/base/constants.cc ('k') | remoting/protocol/connection_to_client.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef REMOTING_PROTOCOL_BUFFERED_SOCKET_WRITER_H_ 5 #ifndef REMOTING_PROTOCOL_BUFFERED_SOCKET_WRITER_H_
6 #define REMOTING_PROTOCOL_BUFFERED_SOCKET_WRITER_H_ 6 #define REMOTING_PROTOCOL_BUFFERED_SOCKET_WRITER_H_
7 7
8 #include <list> 8 #include <list>
9 9
10 #include "base/memory/ref_counted.h" 10 #include "base/memory/ref_counted.h"
(...skipping 23 matching lines...) Expand all
34 class BufferedSocketWriterBase 34 class BufferedSocketWriterBase
35 : public base::RefCountedThreadSafe<BufferedSocketWriterBase> { 35 : public base::RefCountedThreadSafe<BufferedSocketWriterBase> {
36 public: 36 public:
37 typedef Callback1<int>::Type WriteFailedCallback; 37 typedef Callback1<int>::Type WriteFailedCallback;
38 38
39 explicit BufferedSocketWriterBase(); 39 explicit BufferedSocketWriterBase();
40 virtual ~BufferedSocketWriterBase(); 40 virtual ~BufferedSocketWriterBase();
41 41
42 // Initializes the writer. Must be called on the thread that will be used 42 // Initializes the writer. Must be called on the thread that will be used
43 // to access the socket in the future. |callback| will be called after each 43 // to access the socket in the future. |callback| will be called after each
44 // failed write. 44 // failed write. Caller retains ownership of |socket|.
45 // TODO(sergeyu): Change it so that it take ownership of |socket|.
45 void Init(net::Socket* socket, WriteFailedCallback* callback); 46 void Init(net::Socket* socket, WriteFailedCallback* callback);
46 47
47 // Puts a new data chunk in the buffer. Returns false and doesn't enqueue 48 // Puts a new data chunk in the buffer. Returns false and doesn't enqueue
48 // the data if called before Init(). Can be called on any thread. 49 // the data if called before Init(). Can be called on any thread.
49 bool Write(scoped_refptr<net::IOBufferWithSize> buffer, Task* done_task); 50 bool Write(scoped_refptr<net::IOBufferWithSize> buffer, Task* done_task);
50 51
51 // Returns current size of the buffer. Can be called on any thread. 52 // Returns current size of the buffer. Can be called on any thread.
52 int GetBufferSize(); 53 int GetBufferSize();
53 54
54 // Returns number of chunks that are currently in the buffer waiting 55 // Returns number of chunks that are currently in the buffer waiting
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after
122 protected: 123 protected:
123 virtual void GetNextPacket_Locked(net::IOBuffer** buffer, int* size); 124 virtual void GetNextPacket_Locked(net::IOBuffer** buffer, int* size);
124 virtual void AdvanceBufferPosition_Locked(int written); 125 virtual void AdvanceBufferPosition_Locked(int written);
125 virtual void OnError_Locked(int result); 126 virtual void OnError_Locked(int result);
126 }; 127 };
127 128
128 } // namespace protocol 129 } // namespace protocol
129 } // namespace remoting 130 } // namespace remoting
130 131
131 #endif // REMOTING_PROTOCOL_BUFFERED_SOCKET_WRITER_H_ 132 #endif // REMOTING_PROTOCOL_BUFFERED_SOCKET_WRITER_H_
OLDNEW
« no previous file with comments | « remoting/base/constants.cc ('k') | remoting/protocol/connection_to_client.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698