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

Unified Diff: remoting/protocol/buffered_socket_writer.cc

Issue 6142009: Upating the app, ceee, chrome, ipc, media, and net directories to use the correct lock.h file. (Closed) Base URL: http://git.chromium.org/git/chromium.git@trunk
Patch Set: Unified patch updating all references to the new base/synchronization/lock.h Created 9 years, 11 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « remoting/protocol/buffered_socket_writer.h ('k') | remoting/protocol/jingle_session.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: remoting/protocol/buffered_socket_writer.cc
diff --git a/remoting/protocol/buffered_socket_writer.cc b/remoting/protocol/buffered_socket_writer.cc
index 11b8395a18235920871b90ffe7777780b007c4f1..db069b2ef8c3c8b500ad22f77199566b4ffdd6f7 100644
--- a/remoting/protocol/buffered_socket_writer.cc
+++ b/remoting/protocol/buffered_socket_writer.cc
@@ -48,7 +48,7 @@ BufferedSocketWriterBase::~BufferedSocketWriterBase() { }
void BufferedSocketWriterBase::Init(net::Socket* socket,
WriteFailedCallback* callback) {
// TODO(garykac) Save copy of WriteFailedCallback.
- AutoLock auto_lock(lock_);
+ base::AutoLock auto_lock(lock_);
message_loop_ = MessageLoop::current();
socket_ = socket;
DCHECK(socket_);
@@ -56,7 +56,7 @@ void BufferedSocketWriterBase::Init(net::Socket* socket,
bool BufferedSocketWriterBase::Write(
scoped_refptr<net::IOBufferWithSize> data, Task* done_task) {
- AutoLock auto_lock(lock_);
+ base::AutoLock auto_lock(lock_);
if (!socket_)
return false;
queue_.push_back(new PendingPacket(data, done_task));
@@ -76,7 +76,7 @@ void BufferedSocketWriterBase::DoWrite() {
// Don't write after Close().
{
- AutoLock auto_lock(lock_);
+ base::AutoLock auto_lock(lock_);
if (closed_)
return;
}
@@ -85,7 +85,7 @@ void BufferedSocketWriterBase::DoWrite() {
net::IOBuffer* current_packet;
int current_packet_size;
{
- AutoLock auto_lock(lock_);
+ base::AutoLock auto_lock(lock_);
GetNextPacket_Locked(&current_packet, &current_packet_size);
}
@@ -96,7 +96,7 @@ void BufferedSocketWriterBase::DoWrite() {
int result = socket_->Write(current_packet, current_packet_size,
&written_callback_);
if (result >= 0) {
- AutoLock auto_lock(lock_);
+ base::AutoLock auto_lock(lock_);
AdvanceBufferPosition_Locked(result);
} else {
if (result == net::ERR_IO_PENDING) {
@@ -123,7 +123,7 @@ void BufferedSocketWriterBase::OnWritten(int result) {
}
{
- AutoLock auto_lock(lock_);
+ base::AutoLock auto_lock(lock_);
AdvanceBufferPosition_Locked(result);
}
@@ -133,7 +133,7 @@ void BufferedSocketWriterBase::OnWritten(int result) {
}
void BufferedSocketWriterBase::HandleError(int result) {
- AutoLock auto_lock(lock_);
+ base::AutoLock auto_lock(lock_);
closed_ = true;
STLDeleteElements(&queue_);
@@ -142,17 +142,17 @@ void BufferedSocketWriterBase::HandleError(int result) {
}
int BufferedSocketWriterBase::GetBufferSize() {
- AutoLock auto_lock(lock_);
+ base::AutoLock auto_lock(lock_);
return buffer_size_;
}
int BufferedSocketWriterBase::GetBufferChunks() {
- AutoLock auto_lock(lock_);
+ base::AutoLock auto_lock(lock_);
return queue_.size();
}
void BufferedSocketWriterBase::Close() {
- AutoLock auto_lock(lock_);
+ base::AutoLock auto_lock(lock_);
closed_ = true;
}
« no previous file with comments | « remoting/protocol/buffered_socket_writer.h ('k') | remoting/protocol/jingle_session.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698