123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457 |
- #pragma once
- #include <string>
- #include <vector>
- #include "il2cpp-config.h"
- #include "os/ErrorCodes.h"
- #include "os/Atomic.h"
- #include "os/Mutex.h"
- #include "os/WaitStatus.h"
- #include "utils/NonCopyable.h"
- namespace il2cpp
- {
- namespace os
- {
- class SocketImpl;
- enum AddressFamily
- {
- kAddressFamilyError = -1,
- kAddressFamilyUnspecified = 0,// AF_UNSPEC
- kAddressFamilyUnix = 1,// AF_UNIX
- kAddressFamilyInterNetwork = 2,// AF_INET
- kAddressFamilyIpx = 3,// AF_IPX
- kAddressFamilySna = 4,// AF_SNA
- kAddressFamilyDecNet = 5,// AF_DECnet
- kAddressFamilyAppleTalk = 6,// AF_APPLETALK
- kAddressFamilyInterNetworkV6 = 7,// AF_INET6
- kAddressFamilyIrda = 8,// AF_IRDA
- };
- enum SocketType
- {
- kSocketTypeError = -1,
- kSocketTypeStream = 0,// SOCK_STREAM
- kSocketTypeDgram = 1,// SOCK_DGRAM
- kSocketTypeRaw = 2,// SOCK_RAW
- kSocketTypeRdm = 3,// SOCK_RDM
- kSocketTypeSeqpacket = 4,// SOCK_SEQPACKET
- };
- enum ProtocolType
- {
- kProtocolTypeUnknown = -1,
- kProtocolTypeIP = 0,
- kProtocolTypeIcmp = 1,
- kProtocolTypeIgmp = 2,
- kProtocolTypeGgp = 3,
- kProtocolTypeTcp = 6,
- kProtocolTypePup = 12,
- kProtocolTypeUdp = 17,
- kProtocolTypeIdp = 22,
- kProtocolTypeND = 77,
- kProtocolTypeRaw = 255,
- kProtocolTypeUnspecified = 0,
- kProtocolTypeIpx = 1000,
- kProtocolTypeSpx = 1256,
- kProtocolTypeSpxII = 1257,
- // #if NET_1_1
- kProtocolTypeIPv6 = 41,
- // #endif
- // #if NET_2_0
- kProtocolTypeIPv4 = 4,
- kProtocolTypeIPv6RoutingHeader = 43,
- kProtocolTypeIPv6FragmentHeader = 44,
- kProtocolTypeIPSecEncapsulatingSecurityPayload = 50,
- kProtocolTypeIPSecAuthenticationHeader = 51,
- kProtocolTypeIcmpV6 = 58,
- kProtocolTypeIPv6NoNextHeader = 59,
- kProtocolTypeIPv6DestinationOptions = 60,
- kProtocolTypeIPv6HopByHopOptions = 0,
- // #endif
- };
- enum SocketFlags
- {
- kSocketFlagsNone = 0x00000000,
- kSocketFlagsOutOfBand = 0x00000001,
- kSocketFlagsPeek = 0x00000002,
- kSocketFlagsDontRoute = 0x00000004,
- kSocketFlagsMaxIOVectorLength = 0x00000010,
- // #if NET_2_0
- kSocketFlagsTruncated = 0x00000100,
- kSocketFlagsControlDataTruncated = 0x00000200,
- kSocketFlagsBroadcast = 0x00000400,
- kSocketFlagsMulticast = 0x00000800,
- // #endif
- kSocketFlagsPartial = 0x00008000,
- };
- enum SocketOptionLevel
- {
- kSocketOptionLevelSocket = 65535,
- kSocketOptionLevelIP = 0,
- kSocketOptionLevelTcp = 6,
- kSocketOptionLevelUdp = 17,
- //#if NET_1_1
- kSocketOptionLevelIPv6 = 41,
- //#endif
- };
- enum SocketOptionName
- {
- kSocketOptionNameDebug = 1,
- kSocketOptionNameAcceptConnection = 2,
- kSocketOptionNameReuseAddress = 4,
- kSocketOptionNameKeepAlive = 8,
- kSocketOptionNameDontRoute = 16,
- kSocketOptionNameBroadcast = 32,
- kSocketOptionNameUseLoopback = 64,
- kSocketOptionNameLinger = 128,
- kSocketOptionNameOutOfBandInline = 256,
- kSocketOptionNameDontLinger = -129,
- kSocketOptionNameExclusiveAddressUse = -5,
- kSocketOptionNameSendBuffer = 4097,
- kSocketOptionNameReceiveBuffer = 4098,
- kSocketOptionNameSendLowWater = 4099,
- kSocketOptionNameReceiveLowWater = 4100,
- kSocketOptionNameSendTimeout = 4101,
- kSocketOptionNameReceiveTimeout = 4102,
- kSocketOptionNameError = 4103,
- kSocketOptionNameType = 4104,
- kSocketOptionNameMaxConnections = 2147483647,
- kSocketOptionNameIPOptions = 1,
- kSocketOptionNameHeaderIncluded = 2,
- kSocketOptionNameTypeOfService = 3,
- kSocketOptionNameIpTimeToLive = 4,
- kSocketOptionNameMulticastInterface = 9,
- kSocketOptionNameMulticastTimeToLive = 10,
- kSocketOptionNameMulticastLoopback = 11,
- kSocketOptionNameAddMembership = 12,
- kSocketOptionNameDropMembership = 13,
- kSocketOptionNameDontFragment = 14,
- kSocketOptionNameAddSourceMembership = 15,
- kSocketOptionNameDropSourceMembership = 16,
- kSocketOptionNameBlockSource = 17,
- kSocketOptionNameUnblockSource = 18,
- kSocketOptionNamePacketInformation = 19,
- kSocketOptionNameNoDelay = 1,
- kSocketOptionNameBsdUrgent = 2,
- kSocketOptionNameExpedited = 2,
- kSocketOptionNameNoChecksum = 1,
- kSocketOptionNameChecksumCoverage = 20,
- kSocketOptionNameIPv6Only = 27,
- // #if NET_2_0
- kSocketOptionNameHopLimit = 21,
- kSocketOptionNameUpdateAcceptContext = 28683,
- kSocketOptionNameUpdateConnectContext = 28688,
- // #endif
- };
- enum PollFlags
- {
- kPollFlagsNone = 0,
- kPollFlagsIn = 1,
- kPollFlagsPri = 2,
- kPollFlagsOut = 4,
- kPollFlagsErr = 8,
- kPollFlagsHup = 0x10,
- kPollFlagsNVal = 0x20,
- kPollFlagsAny = 0xffffffff
- };
- enum SocketError
- {
- kInterrupted = 4,// EINTR on POSIX and WSAEINTR on Windows
- kInvalidHandle = 9 // EBADF on POSIX and WSAEBADF on Windows
- };
- inline void operator|=(PollFlags& left, PollFlags right)
- {
- left = static_cast<PollFlags>(static_cast<int>(left) | static_cast<int>(right));
- }
- enum TransmitFileOptions
- {
- kTransmitFileOptionsUseDefaultWorkerThread = 0x00000000,
- kTransmitFileOptionsDisconnect = 0x00000001,
- kTransmitFileOptionsReuseSocket = 0x00000002,
- kTransmitFileOptionsWriteBehind = 0x00000004,
- kTransmitFileOptionsUseSystemThread = 0x00000010,
- kTransmitFileOptionsUseKernelApc = 0x00000020,
- };
- class Socket;
- struct PollRequest
- {
- PollRequest()
- : fd(-1)
- , events(kPollFlagsNone)
- , revents(kPollFlagsNone)
- {}
- PollRequest(int64_t value)
- : fd(value)
- , events(kPollFlagsNone)
- , revents(kPollFlagsNone)
- {}
- int64_t fd;
- PollFlags events;
- PollFlags revents;
- };
- #if IL2CPP_SUPPORT_IPV6
- struct IPv6Address
- {
- uint8_t addr[16];
- };
- #endif
- // TODO: this should really be UNIX_PATH_MAX or SUN_LEN(n)
- #define END_POINT_MAX_PATH_LEN 255
- #if IL2CPP_COMPILER_MSVC
- #pragma warning( push )
- #pragma warning( disable : 4200 )
- #endif
- struct EndPointInfo
- {
- AddressFamily family;
- union
- {
- struct
- {
- uint32_t port;
- uint32_t address;
- } inet;
- char path[END_POINT_MAX_PATH_LEN];
- uint8_t raw[IL2CPP_ZERO_LEN_ARRAY];
- } data;
- };
- #if IL2CPP_COMPILER_MSVC
- #pragma warning( pop )
- #endif
- // NOTE(gab): this must be binary compatible with Windows's WSABUF
- struct WSABuf
- {
- uint32_t length;
- void *buffer;
- };
- // NOTE(gab): this must be binary compatible with Window's TRANSMIT_FILE_BUFFERS
- struct TransmitFileBuffers
- {
- void *head;
- uint32_t head_length;
- void *tail;
- uint32_t tail_length;
- };
- // Note: this callback can be invoked by the os-specific implementation when an
- // interrupt is received or when the native code is looping in a potentially long
- // loop.
- // If the callback retun false, the executiong of the os-specific method is
- // gracefully interrupted, and an error is supposed to be returned by the
- // os-specific implementation.
- // The callback is allowed to throw exceptions (for example a ThreadAborted exception):
- // in this case, it is up to the os-specific implementation to properly deal with
- // cleaning up the temporarely allocated memory (if any).
- typedef bool (*ThreadStatusCallback)();
- class Socket : public il2cpp::utils::NonCopyable
- {
- public:
- Socket(ThreadStatusCallback thread_status_callback);
- ~Socket();
- // Note: this Create is only used internally
- WaitStatus Create(int64_t fd, int32_t family, int32_t type, int32_t protocol);
- WaitStatus Create(AddressFamily family, SocketType type, ProtocolType protocol);
- bool IsClosed();
- void Close();
- int64_t GetDescriptor();
- ErrorCode GetLastError() const;
- WaitStatus SetBlocking(bool blocking);
- WaitStatus Listen(int32_t blacklog);
- WaitStatus Bind(const char *path);
- WaitStatus Bind(uint32_t address, uint16_t port);
- WaitStatus Bind(const char *address, uint16_t port);
- WaitStatus Bind(uint8_t address[ipv6AddressSize], uint32_t scope, uint16_t port);
- WaitStatus Connect(const char *path);
- WaitStatus Connect(uint32_t address, uint16_t port);
- WaitStatus Connect(uint8_t address[ipv6AddressSize], uint32_t scope, uint16_t port);
- WaitStatus Disconnect(bool reuse);
- WaitStatus Shutdown(int32_t how);
- WaitStatus GetLocalEndPointInfo(EndPointInfo &info);
- WaitStatus GetRemoteEndPointInfo(EndPointInfo &info);
- WaitStatus Receive(const uint8_t *data, int32_t count, os::SocketFlags flags, int32_t *len);
- WaitStatus Send(const uint8_t *data, int32_t count, os::SocketFlags flags, int32_t *len);
- WaitStatus SendArray(WSABuf *wsabufs, int32_t count, int32_t *sent, SocketFlags c_flags);
- WaitStatus ReceiveArray(WSABuf *wsabufs, int32_t count, int32_t *len, SocketFlags c_flags);
- WaitStatus SendTo(uint32_t address, uint16_t port, const uint8_t *data, int32_t count, os::SocketFlags flags, int32_t *len);
- WaitStatus SendTo(const char *path, const uint8_t *data, int32_t count, os::SocketFlags flags, int32_t *len);
- WaitStatus SendTo(uint8_t address[ipv6AddressSize], uint32_t scope, uint16_t port, const uint8_t *data, int32_t count, os::SocketFlags flags, int32_t *len);
- WaitStatus RecvFrom(uint32_t address, uint16_t port, const uint8_t *data, int32_t count, os::SocketFlags flags, int32_t *len, os::EndPointInfo &ep);
- WaitStatus RecvFrom(const char *path, const uint8_t *data, int32_t count, os::SocketFlags flags, int32_t *len, os::EndPointInfo &ep);
- WaitStatus RecvFrom(uint8_t address[ipv6AddressSize], uint32_t scope, uint16_t port, const uint8_t *data, int32_t count, os::SocketFlags flags, int32_t *len, os::EndPointInfo &ep);
- WaitStatus Available(int32_t *amount);
- WaitStatus Accept(Socket **socket);
- WaitStatus Ioctl(int32_t command, const uint8_t *in_data, int32_t in_len, uint8_t *out_data, int32_t out_len, int32_t *written);
- WaitStatus GetSocketOption(SocketOptionLevel level, SocketOptionName name, uint8_t *buffer, int32_t *length);
- WaitStatus GetSocketOptionFull(SocketOptionLevel level, SocketOptionName name, int32_t *first, int32_t *second);
- WaitStatus SetSocketOption(SocketOptionLevel level, SocketOptionName name, int32_t value);
- WaitStatus SetSocketOptionLinger(SocketOptionLevel level, SocketOptionName name, bool enabled, int32_t seconds);
- WaitStatus SetSocketOptionArray(SocketOptionLevel level, SocketOptionName name, const uint8_t *buffer, int32_t length);
- WaitStatus SetSocketOptionMembership(SocketOptionLevel level, SocketOptionName name, uint32_t group_address, uint32_t local_address);
- #if IL2CPP_SUPPORT_IPV6
- WaitStatus SetSocketOptionMembership(SocketOptionLevel level, SocketOptionName name, IPv6Address ipv6, uint64_t interfaceOffset);
- #endif
- WaitStatus SendFile(const char *filename, TransmitFileBuffers *buffers, TransmitFileOptions options);
- #if IL2CPP_SUPPORT_IPV6_SUPPORT_QUERY
- static bool IsIPv6Supported();
- #endif
- static WaitStatus Poll(std::vector<PollRequest> &requests, int32_t count, int32_t timeout, int32_t *result, int32_t *error);
- static WaitStatus Poll(std::vector<PollRequest> &requests, int32_t timeout, int32_t *result, int32_t *error);
- static WaitStatus Poll(PollRequest &request, int32_t timeout, int32_t *result, int32_t *error);
- static WaitStatus GetHostName(std::string &name);
- static WaitStatus GetHostByName(const std::string &host, std::string &name, std::vector<std::string> &aliases, std::vector<std::string> &addresses);
- // The pointers in addr_list are allocated with the il2cpp::utils::Memory::Malloc method. They should he freed by the caller using il2cpp::utils::Memory::Free.
- static WaitStatus GetHostByName(const std::string &host, std::string &name, int32_t &family, std::vector<std::string> &aliases, std::vector<void*> &addr_list, int32_t &addr_size);
- static WaitStatus GetHostByAddr(const std::string &address, std::string &name, std::vector<std::string> &aliases, std::vector<std::string> &addr_list);
- static void Startup();
- static void Cleanup();
- private:
- SocketImpl* m_Socket;
- };
- /// Sockets should generally be referenced through SocketHandles for thread-safety.
- /// Handles are stored in a table and can be safely used even when the socket has already
- /// been deleted.
- typedef uint32_t SocketHandle;
- enum
- {
- kInvalidSocketHandle = 0
- };
- SocketHandle CreateSocketHandle(Socket* socket);
- Socket* AcquireSocketHandle(SocketHandle handle);
- void ReleaseSocketHandle(SocketHandle handle);
- inline SocketHandle PointerToSocketHandle(void* ptr)
- {
- // Double cast to avoid warnings.
- return static_cast<SocketHandle>(reinterpret_cast<size_t>(ptr));
- }
- /// Helper to automatically acquire and release a Socket within a scope.
- struct SocketHandleWrapper
- {
- SocketHandleWrapper()
- : m_Handle(kInvalidSocketHandle)
- , m_Socket(NULL) {}
- SocketHandleWrapper(SocketHandle handle)
- : m_Handle(handle)
- {
- m_Socket = AcquireSocketHandle(handle);
- }
- SocketHandleWrapper(const SocketHandleWrapper& other)
- {
- m_Handle = other.m_Handle;
- if (m_Handle != kInvalidSocketHandle)
- m_Socket = AcquireSocketHandle(m_Handle);
- else
- m_Socket = NULL;
- }
- ~SocketHandleWrapper()
- {
- Release();
- }
- void Acquire(SocketHandle handle)
- {
- Release();
- m_Handle = handle;
- m_Socket = AcquireSocketHandle(handle);
- }
- void Release()
- {
- if (m_Socket)
- ReleaseSocketHandle(m_Handle);
- m_Socket = NULL;
- m_Handle = kInvalidSocketHandle;
- }
- bool IsValid() const
- {
- return (m_Socket != NULL);
- }
- SocketHandle GetHandle() const
- {
- return m_Handle;
- }
- Socket* GetSocket() const
- {
- return m_Socket;
- }
- Socket* operator->() const
- {
- return GetSocket();
- }
- SocketHandleWrapper& operator=(const SocketHandleWrapper& other)
- {
- Acquire(other.GetHandle());
- return *this;
- }
- private:
- SocketHandle m_Handle;
- Socket* m_Socket;
- };
- }
- }
|