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
3 // found in the LICENSE file.
5 #include "base/sync_socket.h"
10 #include <sys/types.h>
12 #include "base/logging.h"
16 const SyncSocket::Handle SyncSocket::kInvalidHandle = -1;
18 SyncSocket::SyncSocket() : handle_(kInvalidHandle) {
21 SyncSocket::~SyncSocket() {
26 bool SyncSocket::CreatePair(SyncSocket* socket_a, SyncSocket* socket_b) {
30 bool SyncSocket::Close() {
31 if (handle_ != kInvalidHandle) {
32 if (close(handle_) < 0)
33 DPLOG(ERROR) << "close";
34 handle_ = kInvalidHandle;
39 size_t SyncSocket::Send(const void* buffer, size_t length) {
40 const ssize_t bytes_written = write(handle_, buffer, length);
41 return bytes_written > 0 ? bytes_written : 0;
44 size_t SyncSocket::Receive(void* buffer, size_t length) {
45 const ssize_t bytes_read = read(handle_, buffer, length);
46 return bytes_read > 0 ? bytes_read : 0;
49 size_t SyncSocket::ReceiveWithTimeout(void* buffer, size_t length, TimeDelta) {
54 size_t SyncSocket::Peek() {
59 CancelableSyncSocket::CancelableSyncSocket() {
62 CancelableSyncSocket::CancelableSyncSocket(Handle handle)
63 : SyncSocket(handle) {
66 size_t CancelableSyncSocket::Send(const void* buffer, size_t length) {
67 return SyncSocket::Send(buffer, length);
70 bool CancelableSyncSocket::Shutdown() {
71 return SyncSocket::Close();
75 bool CancelableSyncSocket::CreatePair(CancelableSyncSocket* socket_a,
76 CancelableSyncSocket* socket_b) {
77 return SyncSocket::CreatePair(socket_a, socket_b);