123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134 |
- /*
- * Copyright 2004 The WebRTC Project Authors. All rights reserved.
- *
- * Use of this source code is governed by a BSD-style license
- * that can be found in the LICENSE file in the root of the source
- * tree. An additional intellectual property rights grant can be found
- * in the file PATENTS. All contributing project authors may
- * be found in the AUTHORS file in the root of the source tree.
- */
- #ifndef RTC_BASE_SOCKET_H_
- #define RTC_BASE_SOCKET_H_
- #include <errno.h>
- #if defined(WEBRTC_POSIX)
- #include <arpa/inet.h>
- #include <netinet/in.h>
- #include <sys/socket.h>
- #include <sys/types.h>
- #define SOCKET_EACCES EACCES
- #endif
- #if defined(WEBRTC_WIN)
- #include "rtc_base/win32.h"
- #endif
- #include "rtc_base/constructor_magic.h"
- #include "rtc_base/socket_address.h"
- // Rather than converting errors into a private namespace,
- // Reuse the POSIX socket api errors. Note this depends on
- // Win32 compatibility.
- #if defined(WEBRTC_WIN)
- #undef EWOULDBLOCK // Remove errno.h's definition for each macro below.
- #define EWOULDBLOCK WSAEWOULDBLOCK
- #undef EINPROGRESS
- #define EINPROGRESS WSAEINPROGRESS
- #undef EALREADY
- #define EALREADY WSAEALREADY
- #undef EMSGSIZE
- #define EMSGSIZE WSAEMSGSIZE
- #undef EADDRINUSE
- #define EADDRINUSE WSAEADDRINUSE
- #undef EADDRNOTAVAIL
- #define EADDRNOTAVAIL WSAEADDRNOTAVAIL
- #undef ENETDOWN
- #define ENETDOWN WSAENETDOWN
- #undef ECONNABORTED
- #define ECONNABORTED WSAECONNABORTED
- #undef ENOBUFS
- #define ENOBUFS WSAENOBUFS
- #undef EISCONN
- #define EISCONN WSAEISCONN
- #undef ENOTCONN
- #define ENOTCONN WSAENOTCONN
- #undef ECONNREFUSED
- #define ECONNREFUSED WSAECONNREFUSED
- #undef EHOSTUNREACH
- #define EHOSTUNREACH WSAEHOSTUNREACH
- #define SOCKET_EACCES WSAEACCES
- #endif // WEBRTC_WIN
- #if defined(WEBRTC_POSIX)
- #define INVALID_SOCKET (-1)
- #define SOCKET_ERROR (-1)
- #define closesocket(s) close(s)
- #endif // WEBRTC_POSIX
- namespace rtc {
- inline bool IsBlockingError(int e) {
- return (e == EWOULDBLOCK) || (e == EAGAIN) || (e == EINPROGRESS);
- }
- // General interface for the socket implementations of various networks. The
- // methods match those of normal UNIX sockets very closely.
- class Socket {
- public:
- virtual ~Socket() {}
- // Returns the address to which the socket is bound. If the socket is not
- // bound, then the any-address is returned.
- virtual SocketAddress GetLocalAddress() const = 0;
- // Returns the address to which the socket is connected. If the socket is
- // not connected, then the any-address is returned.
- virtual SocketAddress GetRemoteAddress() const = 0;
- virtual int Bind(const SocketAddress& addr) = 0;
- virtual int Connect(const SocketAddress& addr) = 0;
- virtual int Send(const void* pv, size_t cb) = 0;
- virtual int SendTo(const void* pv, size_t cb, const SocketAddress& addr) = 0;
- // |timestamp| is in units of microseconds.
- virtual int Recv(void* pv, size_t cb, int64_t* timestamp) = 0;
- virtual int RecvFrom(void* pv,
- size_t cb,
- SocketAddress* paddr,
- int64_t* timestamp) = 0;
- virtual int Listen(int backlog) = 0;
- virtual Socket* Accept(SocketAddress* paddr) = 0;
- virtual int Close() = 0;
- virtual int GetError() const = 0;
- virtual void SetError(int error) = 0;
- inline bool IsBlocking() const { return IsBlockingError(GetError()); }
- enum ConnState { CS_CLOSED, CS_CONNECTING, CS_CONNECTED };
- virtual ConnState GetState() const = 0;
- enum Option {
- OPT_DONTFRAGMENT,
- OPT_RCVBUF, // receive buffer size
- OPT_SNDBUF, // send buffer size
- OPT_NODELAY, // whether Nagle algorithm is enabled
- OPT_IPV6_V6ONLY, // Whether the socket is IPv6 only.
- OPT_DSCP, // DSCP code
- OPT_RTP_SENDTIME_EXTN_ID, // This is a non-traditional socket option param.
- // This is specific to libjingle and will be used
- // if SendTime option is needed at socket level.
- };
- virtual int GetOption(Option opt, int* value) = 0;
- virtual int SetOption(Option opt, int value) = 0;
- protected:
- Socket() {}
- private:
- RTC_DISALLOW_COPY_AND_ASSIGN(Socket);
- };
- } // namespace rtc
- #endif // RTC_BASE_SOCKET_H_
|