Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(844)

Unified Diff: net/udp/udp_socket_libevent.h

Issue 992733002: Remove //net (except for Android test stuff) and sdch (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/udp/udp_socket.h ('k') | net/udp/udp_socket_libevent.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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_
« no previous file with comments | « net/udp/udp_socket.h ('k') | net/udp/udp_socket_libevent.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698