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

Side by Side Diff: base/sync_socket_win.cc

Issue 2809673002: Fix double close in MojoAudioOutputStream. (Closed)
Patch Set: Fix Win complie. Created 3 years, 8 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
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 #include "base/sync_socket.h" 5 #include "base/sync_socket.h"
6 6
7 #include <limits.h> 7 #include <limits.h>
8 #include <stddef.h> 8 #include <stddef.h>
9 9
10 #include "base/logging.h" 10 #include "base/logging.h"
(...skipping 275 matching lines...) Expand 10 before | Expand all | Expand 10 after
286 } 286 }
287 return count; 287 return count;
288 } 288 }
289 289
290 size_t SyncSocket::Peek() { 290 size_t SyncSocket::Peek() {
291 DWORD available = 0; 291 DWORD available = 0;
292 PeekNamedPipe(handle_, NULL, 0, NULL, &available, NULL); 292 PeekNamedPipe(handle_, NULL, 0, NULL, &available, NULL);
293 return available; 293 return available;
294 } 294 }
295 295
296 SyncSocket::Handle SyncSocket::Release() {
297 Handle r = handle_;
298 handle_ = kInvalidHandle;
299 return r;
300 }
301
296 CancelableSyncSocket::CancelableSyncSocket() 302 CancelableSyncSocket::CancelableSyncSocket()
297 : shutdown_event_(base::WaitableEvent::ResetPolicy::MANUAL, 303 : shutdown_event_(base::WaitableEvent::ResetPolicy::MANUAL,
298 base::WaitableEvent::InitialState::NOT_SIGNALED), 304 base::WaitableEvent::InitialState::NOT_SIGNALED),
299 file_operation_(base::WaitableEvent::ResetPolicy::MANUAL, 305 file_operation_(base::WaitableEvent::ResetPolicy::MANUAL,
300 base::WaitableEvent::InitialState::NOT_SIGNALED) {} 306 base::WaitableEvent::InitialState::NOT_SIGNALED) {}
301 307
302 CancelableSyncSocket::CancelableSyncSocket(Handle handle) 308 CancelableSyncSocket::CancelableSyncSocket(Handle handle)
303 : SyncSocket(handle), 309 : SyncSocket(handle),
304 shutdown_event_(base::WaitableEvent::ResetPolicy::MANUAL, 310 shutdown_event_(base::WaitableEvent::ResetPolicy::MANUAL,
305 base::WaitableEvent::InitialState::NOT_SIGNALED), 311 base::WaitableEvent::InitialState::NOT_SIGNALED),
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after
341 static_cast<DWORD>(timeout.InMilliseconds())); 347 static_cast<DWORD>(timeout.InMilliseconds()));
342 } 348 }
343 349
344 // static 350 // static
345 bool CancelableSyncSocket::CreatePair(CancelableSyncSocket* socket_a, 351 bool CancelableSyncSocket::CreatePair(CancelableSyncSocket* socket_a,
346 CancelableSyncSocket* socket_b) { 352 CancelableSyncSocket* socket_b) {
347 return CreatePairImpl(&socket_a->handle_, &socket_b->handle_, true); 353 return CreatePairImpl(&socket_a->handle_, &socket_b->handle_, true);
348 } 354 }
349 355
350 } // namespace base 356 } // namespace base
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698