| Index: net/udp/udp_socket_libevent.h
|
| diff --git a/net/udp/udp_socket_libevent.h b/net/udp/udp_socket_libevent.h
|
| deleted file mode 100644
|
| index a434bb96a06d47dd959d5fa43b6919fb030814bf..0000000000000000000000000000000000000000
|
| --- a/net/udp/udp_socket_libevent.h
|
| +++ /dev/null
|
| @@ -1,306 +0,0 @@
|
| -// Copyright (c) 2012 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 NET_UDP_UDP_SOCKET_LIBEVENT_H_
|
| -#define NET_UDP_UDP_SOCKET_LIBEVENT_H_
|
| -
|
| -#include "base/memory/ref_counted.h"
|
| -#include "base/memory/scoped_ptr.h"
|
| -#include "base/message_loop/message_loop.h"
|
| -#include "base/threading/non_thread_safe.h"
|
| -#include "net/base/address_family.h"
|
| -#include "net/base/completion_callback.h"
|
| -#include "net/base/io_buffer.h"
|
| -#include "net/base/ip_endpoint.h"
|
| -#include "net/base/net_export.h"
|
| -#include "net/base/net_log.h"
|
| -#include "net/base/rand_callback.h"
|
| -#include "net/socket/socket_descriptor.h"
|
| -#include "net/udp/datagram_socket.h"
|
| -
|
| -namespace net {
|
| -
|
| -class NET_EXPORT UDPSocketLibevent : public base::NonThreadSafe {
|
| - public:
|
| - UDPSocketLibevent(DatagramSocket::BindType bind_type,
|
| - const RandIntCallback& rand_int_cb,
|
| - net::NetLog* net_log,
|
| - const net::NetLog::Source& source);
|
| - virtual ~UDPSocketLibevent();
|
| -
|
| - // Opens the socket.
|
| - // Returns a net error code.
|
| - int Open(AddressFamily address_family);
|
| -
|
| - // Connects the socket to connect with a certain |address|.
|
| - // Should be called after Open().
|
| - // Returns a net error code.
|
| - int Connect(const IPEndPoint& address);
|
| -
|
| - // Binds the address/port for this socket to |address|. This is generally
|
| - // only used on a server. Should be called after Open().
|
| - // Returns a net error code.
|
| - int Bind(const IPEndPoint& address);
|
| -
|
| - // Closes the socket.
|
| - // TODO(rvargas, hidehiko): Disallow re-Open() after Close().
|
| - void Close();
|
| -
|
| - // Copies the remote udp address into |address| and returns a net error code.
|
| - int GetPeerAddress(IPEndPoint* address) const;
|
| -
|
| - // Copies the local udp address into |address| and returns a net error code.
|
| - // (similar to getsockname)
|
| - int GetLocalAddress(IPEndPoint* address) const;
|
| -
|
| - // IO:
|
| - // Multiple outstanding read requests are not supported.
|
| - // Full duplex mode (reading and writing at the same time) is supported
|
| -
|
| - // Reads from the socket.
|
| - // Only usable from the client-side of a UDP socket, after the socket
|
| - // has been connected.
|
| - int Read(IOBuffer* buf, int buf_len, const CompletionCallback& callback);
|
| -
|
| - // Writes to the socket.
|
| - // Only usable from the client-side of a UDP socket, after the socket
|
| - // has been connected.
|
| - int Write(IOBuffer* buf, int buf_len, const CompletionCallback& callback);
|
| -
|
| - // Reads from a socket and receive sender address information.
|
| - // |buf| is the buffer to read data into.
|
| - // |buf_len| is the maximum amount of data to read.
|
| - // |address| is a buffer provided by the caller for receiving the sender
|
| - // address information about the received data. This buffer must be kept
|
| - // alive by the caller until the callback is placed.
|
| - // |address_length| is a ptr to the length of the |address| buffer. This
|
| - // is an input parameter containing the maximum size |address| can hold
|
| - // and also an output parameter for the size of |address| upon completion.
|
| - // |callback| is the callback on completion of the RecvFrom.
|
| - // Returns a net error code, or ERR_IO_PENDING if the IO is in progress.
|
| - // If ERR_IO_PENDING is returned, the caller must keep |buf|, |address|,
|
| - // and |address_length| alive until the callback is called.
|
| - int RecvFrom(IOBuffer* buf,
|
| - int buf_len,
|
| - IPEndPoint* address,
|
| - const CompletionCallback& callback);
|
| -
|
| - // Sends to a socket with a particular destination.
|
| - // |buf| is the buffer to send
|
| - // |buf_len| is the number of bytes to send
|
| - // |address| is the recipient address.
|
| - // |address_length| is the size of the recipient address
|
| - // |callback| is the user callback function to call on complete.
|
| - // Returns a net error code, or ERR_IO_PENDING if the IO is in progress.
|
| - // If ERR_IO_PENDING is returned, the caller must keep |buf| and |address|
|
| - // alive until the callback is called.
|
| - int SendTo(IOBuffer* buf,
|
| - int buf_len,
|
| - const IPEndPoint& address,
|
| - const CompletionCallback& callback);
|
| -
|
| - // Sets the receive buffer size (in bytes) for the socket.
|
| - // Returns a net error code.
|
| - int SetReceiveBufferSize(int32 size);
|
| -
|
| - // Sets the send buffer size (in bytes) for the socket.
|
| - // Returns a net error code.
|
| - int SetSendBufferSize(int32 size);
|
| -
|
| - // Returns true if the socket is already connected or bound.
|
| - bool is_connected() const { return is_connected_; }
|
| -
|
| - const BoundNetLog& NetLog() const { return net_log_; }
|
| -
|
| - // Sets corresponding flags in |socket_options_| to allow the socket
|
| - // to share the local address to which the socket will be bound with
|
| - // other processes. Should be called between Open() and Bind().
|
| - // Returns a net error code.
|
| - int AllowAddressReuse();
|
| -
|
| - // Sets corresponding flags in |socket_options_| to allow or disallow sending
|
| - // and receiving packets to and from broadcast addresses.
|
| - // Returns a net error code.
|
| - int SetBroadcast(bool broadcast);
|
| -
|
| - // Joins the multicast group.
|
| - // |group_address| is the group address to join, could be either
|
| - // an IPv4 or IPv6 address.
|
| - // Returns a net error code.
|
| - int JoinGroup(const IPAddressNumber& group_address) const;
|
| -
|
| - // Leaves the multicast group.
|
| - // |group_address| is the group address to leave, could be either
|
| - // an IPv4 or IPv6 address. If the socket hasn't joined the group,
|
| - // it will be ignored.
|
| - // It's optional to leave the multicast group before destroying
|
| - // the socket. It will be done by the OS.
|
| - // Returns a net error code.
|
| - int LeaveGroup(const IPAddressNumber& group_address) const;
|
| -
|
| - // Sets interface to use for multicast. If |interface_index| set to 0,
|
| - // default interface is used.
|
| - // Should be called before Bind().
|
| - // Returns a net error code.
|
| - int SetMulticastInterface(uint32 interface_index);
|
| -
|
| - // Sets the time-to-live option for UDP packets sent to the multicast
|
| - // group address. The default value of this option is 1.
|
| - // Cannot be negative or more than 255.
|
| - // Should be called before Bind().
|
| - // Returns a net error code.
|
| - int SetMulticastTimeToLive(int time_to_live);
|
| -
|
| - // Sets the loopback flag for UDP socket. If this flag is true, the host
|
| - // will receive packets sent to the joined group from itself.
|
| - // The default value of this option is true.
|
| - // Should be called before Bind().
|
| - // Returns a net error code.
|
| - //
|
| - // Note: the behavior of |SetMulticastLoopbackMode| is slightly
|
| - // different between Windows and Unix-like systems. The inconsistency only
|
| - // happens when there are more than one applications on the same host
|
| - // joined to the same multicast group while having different settings on
|
| - // multicast loopback mode. On Windows, the applications with loopback off
|
| - // will not RECEIVE the loopback packets; while on Unix-like systems, the
|
| - // applications with loopback off will not SEND the loopback packets to
|
| - // other applications on the same host. See MSDN: http://goo.gl/6vqbj
|
| - int SetMulticastLoopbackMode(bool loopback);
|
| -
|
| - // Sets the differentiated services flags on outgoing packets. May not
|
| - // do anything on some platforms.
|
| - // Returns a net error code.
|
| - int SetDiffServCodePoint(DiffServCodePoint dscp);
|
| -
|
| - // Resets the thread to be used for thread-safety checks.
|
| - void DetachFromThread();
|
| -
|
| - private:
|
| - enum SocketOptions {
|
| - SOCKET_OPTION_MULTICAST_LOOP = 1 << 0
|
| - };
|
| -
|
| - class ReadWatcher : public base::MessageLoopForIO::Watcher {
|
| - public:
|
| - explicit ReadWatcher(UDPSocketLibevent* socket) : socket_(socket) {}
|
| -
|
| - // MessageLoopForIO::Watcher methods
|
| -
|
| - void OnFileCanReadWithoutBlocking(int /* fd */) override;
|
| -
|
| - void OnFileCanWriteWithoutBlocking(int /* fd */) override {}
|
| -
|
| - private:
|
| - UDPSocketLibevent* const socket_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(ReadWatcher);
|
| - };
|
| -
|
| - class WriteWatcher : public base::MessageLoopForIO::Watcher {
|
| - public:
|
| - explicit WriteWatcher(UDPSocketLibevent* socket) : socket_(socket) {}
|
| -
|
| - // MessageLoopForIO::Watcher methods
|
| -
|
| - void OnFileCanReadWithoutBlocking(int /* fd */) override {}
|
| -
|
| - void OnFileCanWriteWithoutBlocking(int /* fd */) override;
|
| -
|
| - private:
|
| - UDPSocketLibevent* const socket_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(WriteWatcher);
|
| - };
|
| -
|
| - void DoReadCallback(int rv);
|
| - void DoWriteCallback(int rv);
|
| - void DidCompleteRead();
|
| - void DidCompleteWrite();
|
| -
|
| - // Handles stats and logging. |result| is the number of bytes transferred, on
|
| - // success, or the net error code on failure. On success, LogRead takes in a
|
| - // sockaddr and its length, which are mandatory, while LogWrite takes in an
|
| - // optional IPEndPoint.
|
| - void LogRead(int result, const char* bytes, socklen_t addr_len,
|
| - const sockaddr* addr) const;
|
| - void LogWrite(int result, const char* bytes, const IPEndPoint* address) const;
|
| -
|
| - // Same as SendTo(), except that address is passed by pointer
|
| - // instead of by reference. It is called from Write() with |address|
|
| - // set to NULL.
|
| - int SendToOrWrite(IOBuffer* buf,
|
| - int buf_len,
|
| - const IPEndPoint* address,
|
| - const CompletionCallback& callback);
|
| -
|
| - int InternalConnect(const IPEndPoint& address);
|
| - int InternalRecvFrom(IOBuffer* buf, int buf_len, IPEndPoint* address);
|
| - int InternalSendTo(IOBuffer* buf, int buf_len, const IPEndPoint* address);
|
| -
|
| - // Applies |socket_options_| to |socket_|. Should be called before
|
| - // Bind().
|
| - int SetMulticastOptions();
|
| - int DoBind(const IPEndPoint& address);
|
| - // Binds to a random port on |address|.
|
| - int RandomBind(const IPAddressNumber& address);
|
| -
|
| - int socket_;
|
| - int addr_family_;
|
| - bool is_connected_;
|
| -
|
| - // Bitwise-or'd combination of SocketOptions. Specifies the set of
|
| - // options that should be applied to |socket_| before Bind().
|
| - int socket_options_;
|
| -
|
| - // Multicast interface.
|
| - uint32 multicast_interface_;
|
| -
|
| - // Multicast socket options cached for SetMulticastOption.
|
| - // Cannot be used after Bind().
|
| - int multicast_time_to_live_;
|
| -
|
| - // How to do source port binding, used only when UDPSocket is part of
|
| - // UDPClientSocket, since UDPServerSocket provides Bind.
|
| - DatagramSocket::BindType bind_type_;
|
| -
|
| - // PRNG function for generating port numbers.
|
| - RandIntCallback rand_int_cb_;
|
| -
|
| - // These are mutable since they're just cached copies to make
|
| - // GetPeerAddress/GetLocalAddress smarter.
|
| - mutable scoped_ptr<IPEndPoint> local_address_;
|
| - mutable scoped_ptr<IPEndPoint> remote_address_;
|
| -
|
| - // The socket's libevent wrappers
|
| - base::MessageLoopForIO::FileDescriptorWatcher read_socket_watcher_;
|
| - base::MessageLoopForIO::FileDescriptorWatcher write_socket_watcher_;
|
| -
|
| - // The corresponding watchers for reads and writes.
|
| - ReadWatcher read_watcher_;
|
| - WriteWatcher write_watcher_;
|
| -
|
| - // The buffer used by InternalRead() to retry Read requests
|
| - scoped_refptr<IOBuffer> read_buf_;
|
| - int read_buf_len_;
|
| - IPEndPoint* recv_from_address_;
|
| -
|
| - // The buffer used by InternalWrite() to retry Write requests
|
| - scoped_refptr<IOBuffer> write_buf_;
|
| - int write_buf_len_;
|
| - scoped_ptr<IPEndPoint> send_to_address_;
|
| -
|
| - // External callback; called when read is complete.
|
| - CompletionCallback read_callback_;
|
| -
|
| - // External callback; called when write is complete.
|
| - CompletionCallback write_callback_;
|
| -
|
| - BoundNetLog net_log_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(UDPSocketLibevent);
|
| -};
|
| -
|
| -} // namespace net
|
| -
|
| -#endif // NET_UDP_UDP_SOCKET_LIBEVENT_H_
|
|
|