File: stream_socket.h

package info (click to toggle)
android-platform-tools 34.0.5-12
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid, trixie
  • size: 150,900 kB
  • sloc: cpp: 805,786; java: 293,500; ansic: 128,288; xml: 127,491; python: 41,481; sh: 14,245; javascript: 9,665; cs: 3,846; asm: 2,049; makefile: 1,917; yacc: 440; awk: 368; ruby: 183; sql: 140; perl: 88; lex: 67
file content (72 lines) | stat: -rw-r--r-- 2,496 bytes parent folder | download | duplicates (5)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
// Copyright 2019 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#ifndef PLATFORM_IMPL_STREAM_SOCKET_H_
#define PLATFORM_IMPL_STREAM_SOCKET_H_

#include <cstdint>
#include <memory>
#include <string>

#include "platform/api/network_interface.h"
#include "platform/base/error.h"
#include "platform/base/ip_address.h"
#include "platform/base/macros.h"
#include "platform/impl/socket_handle.h"
#include "platform/impl/socket_state.h"

namespace openscreen {

// StreamSocket is an incomplete abstraction of synchronous platform methods for
// creating, initializing, and closing stream sockets. Callers can use this
// class to define complete TCP and TLS socket classes, both synchronous and
// asynchronous.
class StreamSocket {
 public:
  StreamSocket() = default;
  StreamSocket(const StreamSocket& other) = delete;
  StreamSocket(StreamSocket&& other) noexcept = default;
  virtual ~StreamSocket() = default;

  StreamSocket& operator=(const StreamSocket& other) = delete;
  StreamSocket& operator=(StreamSocket&& other) = default;

  // Used by passive/server sockets to accept connection requests
  // from a client.
  virtual ErrorOr<std::unique_ptr<StreamSocket>> Accept() = 0;

  // Bind to the address provided on socket construction. Socket should be
  // unbound and not connected.
  virtual Error Bind() = 0;

  // Closes the socket. Socket must be opened before this method is called.
  virtual Error Close() = 0;

  // Connects the socket to a specified remote address. Socket should be
  // initialized and bound, but not connected.
  virtual Error Connect(const IPEndpoint& remote_endpoint) = 0;

  // Marks the socket as passive, to receive incoming connections.
  virtual Error Listen() = 0;
  virtual Error Listen(int max_backlog_size) = 0;

  // Returns the file descriptor (e.g. fd or HANDLE pointer) for this socket.
  virtual const SocketHandle& socket_handle() const = 0;

  // Returns the connected remote address, if socket is connected.
  virtual absl::optional<IPEndpoint> remote_address() const = 0;

  // Returns the local address, if one is assigned.
  virtual absl::optional<IPEndpoint> local_address() const = 0;

  // Returns the state of the socket.
  virtual TcpSocketState state() const = 0;

  // Returns the IP version of the socket.
  virtual IPAddress::Version version() const = 0;
};

}  // namespace openscreen

#endif  // PLATFORM_IMPL_STREAM_SOCKET_H_