1 // Copyright 2012 The Chromium Authors
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "base/sync_socket.h"
6
7 #include <errno.h>
8 #include <limits.h>
9 #include <stddef.h>
10 #include <stdio.h>
11 #include <sys/types.h>
12 #include <unistd.h>
13
14 #include "base/containers/span.h"
15 #include "base/notimplemented.h"
16
17 namespace base {
18
19 // static
CreatePair(SyncSocket * socket_a,SyncSocket * socket_b)20 bool SyncSocket::CreatePair(SyncSocket* socket_a, SyncSocket* socket_b) {
21 return false;
22 }
23
Close()24 void SyncSocket::Close() {
25 handle_.reset();
26 }
27
Send(span<const uint8_t> data)28 size_t SyncSocket::Send(span<const uint8_t> data) {
29 const ssize_t bytes_written = write(handle(), data.data(), data.size());
30 return bytes_written > 0 ? static_cast<size_t>(bytes_written) : 0;
31 }
32
Send(const void * buffer,size_t length)33 size_t SyncSocket::Send(const void* buffer, size_t length) {
34 return Send(make_span(static_cast<const uint8_t*>(buffer), length));
35 }
36
Receive(span<uint8_t> buffer)37 size_t SyncSocket::Receive(span<uint8_t> buffer) {
38 const ssize_t bytes_read = read(handle(), buffer.data(), buffer.size());
39 return bytes_read > 0 ? static_cast<size_t>(bytes_read) : 0;
40 }
41
Receive(void * buffer,size_t length)42 size_t SyncSocket::Receive(void* buffer, size_t length) {
43 return Receive(make_span(static_cast<uint8_t*>(buffer), length));
44 }
45
ReceiveWithTimeout(span<uint8_t> buffer,TimeDelta timeout)46 size_t SyncSocket::ReceiveWithTimeout(span<uint8_t> buffer, TimeDelta timeout) {
47 NOTIMPLEMENTED();
48 return 0;
49 }
50
ReceiveWithTimeout(void * buffer,size_t length,TimeDelta timeout)51 size_t SyncSocket::ReceiveWithTimeout(void* buffer,
52 size_t length,
53 TimeDelta timeout) {
54 NOTIMPLEMENTED();
55 return 0;
56 }
57
Peek()58 size_t SyncSocket::Peek() {
59 NOTIMPLEMENTED();
60 return 0;
61 }
62
IsValid() const63 bool SyncSocket::IsValid() const {
64 return handle_.is_valid();
65 }
66
handle() const67 SyncSocket::Handle SyncSocket::handle() const {
68 return handle_.get();
69 }
70
Release()71 SyncSocket::Handle SyncSocket::Release() {
72 return handle_.release();
73 }
74
Send(span<const uint8_t> data)75 size_t CancelableSyncSocket::Send(span<const uint8_t> data) {
76 return SyncSocket::Send(data);
77 }
78
Send(const void * buffer,size_t length)79 size_t CancelableSyncSocket::Send(const void* buffer, size_t length) {
80 return Send(make_span(static_cast<const uint8_t*>(buffer), length));
81 }
82
Shutdown()83 bool CancelableSyncSocket::Shutdown() {
84 Close();
85 return true;
86 }
87
88 // static
CreatePair(CancelableSyncSocket * socket_a,CancelableSyncSocket * socket_b)89 bool CancelableSyncSocket::CreatePair(CancelableSyncSocket* socket_a,
90 CancelableSyncSocket* socket_b) {
91 return SyncSocket::CreatePair(socket_a, socket_b);
92 }
93
94 } // namespace base
95