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

Unified Diff: mojo/services/network/public/cpp/udp_socket_wrapper.h

Issue 1873463003: Remove mojo network service. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 8 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 | « mojo/services/network/public/cpp/DEPS ('k') | mojo/services/network/public/cpp/udp_socket_wrapper.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: mojo/services/network/public/cpp/udp_socket_wrapper.h
diff --git a/mojo/services/network/public/cpp/udp_socket_wrapper.h b/mojo/services/network/public/cpp/udp_socket_wrapper.h
deleted file mode 100644
index cf3266e8d755d6158695807af18e25d7782bb113..0000000000000000000000000000000000000000
--- a/mojo/services/network/public/cpp/udp_socket_wrapper.h
+++ /dev/null
@@ -1,184 +0,0 @@
-// Copyright 2014 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 MOJO_SERVICES_NETWORK_PUBLIC_CPP_UDP_SOCKET_WRAPPER_H_
-#define MOJO_SERVICES_NETWORK_PUBLIC_CPP_UDP_SOCKET_WRAPPER_H_
-
-#include <stdint.h>
-
-#include <queue>
-
-#include "mojo/public/cpp/bindings/binding.h"
-#include "network/public/interfaces/udp_socket.mojom.h"
-
-namespace mojo {
-
-// This class is a wrapper around the UDPSocket interface. It provides local
-// cache for received datagrams as well as for (excessive) send requests:
-// - You call ReceiveFrom() to retrieve one datagram. If there is already cached
-// data, the operation completes synchronously.
-// - You don't need to worry about the max-pending-send-requests restriction
-// imposed by the service side. If you make many SendTo() calls in a short
-// period of time, it caches excessive requests and sends them later.
-class UDPSocketWrapper : public UDPSocketReceiver {
- public:
- using ReceiveCallback =
- Callback<void(NetworkErrorPtr, NetAddressPtr, Array<uint8_t>)>;
- using ErrorCallback = Callback<void(NetworkErrorPtr)>;
- using BindOrConnectCallback =
- Callback<void(NetworkErrorPtr,
- NetAddressPtr,
- InterfaceRequest<UDPSocketReceiver>)>;
-
- explicit UDPSocketWrapper(UDPSocketPtr socket);
-
- // |receive_queue_slots| determines the size (in datagrams) of the local
- // receive queue, which caches incoming datagrams.
- // |requested_max_pending_sends| is used to call
- // NegotiateMaxPendingSendRequests() on |socket|.
- // The two numbers should be greater than 0. If you would like to use default
- // values, please use the other constructor.
- UDPSocketWrapper(UDPSocketPtr socket,
- uint32_t receive_queue_slots,
- uint32_t requested_max_pending_sends);
-
- ~UDPSocketWrapper() override;
-
- void AllowAddressReuse(const ErrorCallback& callback);
-
- void Bind(NetAddressPtr addr,
- const Callback<void(NetworkErrorPtr, NetAddressPtr)>& callback);
-
- void Connect(NetAddressPtr remote_addr,
- const Callback<void(NetworkErrorPtr, NetAddressPtr)>& callback);
-
- void SetSendBufferSize(uint32_t size, const ErrorCallback& callback);
-
- void SetReceiveBufferSize(uint32_t size, const ErrorCallback& callback);
-
- // If there are already incoming datagrams cached locally, this method runs
- // |callback| before it returns, and the return value is set to true.
- // Otherwise, the return value is set to false and the callback will be run
- // asynchronously.
- // If the socket is connected, the net address pointer passed into the
- // callback is set to null.
- bool ReceiveFrom(const ReceiveCallback& callback);
-
- // This method is aware of the max pending send requests allowed by the
- // service, and caches send requests locally if necessary.
- // |dest_addr| is allowed to be null if the socket is connected.
- void SendTo(NetAddressPtr dest_addr,
- Array<uint8_t> data,
- const ErrorCallback& callback);
-
- private:
- class NegotiateCallbackHandler : public Callback<void(uint32_t)>::Runnable {
- public:
- explicit NegotiateCallbackHandler(UDPSocketWrapper* delegate);
- ~NegotiateCallbackHandler() override;
-
- // Callback<void(uint32_t)>::Runnable implementation:
- void Run(uint32_t actual_size) const override;
-
- private:
- // Because this callback is passed to a method of |socket_|, and |socket_|
- // is owned by |delegate_|, it should be safe to assume that |delegate_| is
- // valid if/when Run() is called.
- UDPSocketWrapper* delegate_;
- };
-
- class SendCallbackHandler : public ErrorCallback::Runnable {
- public:
- explicit SendCallbackHandler(UDPSocketWrapper* delegate,
- const ErrorCallback& forward_callback);
- ~SendCallbackHandler() override;
-
- // ErrorCallback::Runnable implementation:
- void Run(NetworkErrorPtr result) const override;
-
- private:
- // Because this callback is passed to a method of |socket_|, and |socket_|
- // is owned by |delegate_|, it should be safe to assume that |delegate_| is
- // valid if/when Run() is called.
- UDPSocketWrapper* delegate_;
- ErrorCallback forward_callback_;
- };
-
- class ReceiverBindingCallback : public BindOrConnectCallback::Runnable {
- public:
- ReceiverBindingCallback(
- UDPSocketWrapper* delegate,
- const Callback<void(NetworkErrorPtr, NetAddressPtr)>& wrapper_callback);
- ~ReceiverBindingCallback() override;
-
- // BindOrConnectCallback::Runnable implementation:
- void Run(NetworkErrorPtr result,
- NetAddressPtr addr,
- InterfaceRequest<UDPSocketReceiver> request) const override;
-
- private:
- // Because this callback is passed to a method of |socket_|, and |socket_|
- // is owned by |delegate_|, it should be safe to assume that |delegate_| is
- // valid if/when Run() is called.
- UDPSocketWrapper* delegate_;
- const Callback<void(NetworkErrorPtr, NetAddressPtr)> wrapper_callback_;
- };
-
- struct ReceivedData {
- ReceivedData();
- ~ReceivedData();
-
- NetworkErrorPtr result;
- NetAddressPtr src_addr;
- Array<uint8_t> data;
- };
-
- struct SendRequest {
- SendRequest();
- ~SendRequest();
-
- NetAddressPtr dest_addr;
- Array<uint8_t> data;
- ErrorCallback callback;
- };
-
- // UDPSocketReceiver implementation:
- void OnReceived(NetworkErrorPtr result,
- NetAddressPtr src_addr,
- Array<uint8_t> data) override;
-
- void Initialize(uint32_t requested_max_pending_sends);
- void OnNegotiateMaxPendingSendRequestsCompleted(uint32_t actual_size);
-
- void OnSendToCompleted(NetworkErrorPtr result,
- const ErrorCallback& forward_callback);
-
- // Returns true if a send request in |send_requests_| has been processed.
- bool ProcessNextSendRequest();
-
- // Binds to a UDPSocketReceiver request and notifies |socket_| that we're
- // ready to start receiving data.
- void StartReceivingData(InterfaceRequest<UDPSocketReceiver> request);
-
- Binding<UDPSocketReceiver> binding_;
-
- UDPSocketPtr socket_;
-
- uint32_t max_receive_queue_size_;
-
- // Owns all the objects that its elements point to.
- std::queue<ReceivedData*> receive_queue_;
-
- std::queue<ReceiveCallback> receive_requests_;
-
- uint32_t max_pending_sends_;
- uint32_t current_pending_sends_;
-
- // Owns all the objects that its elements point to.
- std::queue<SendRequest*> send_requests_;
-};
-
-} // namespace mojo
-
-#endif // MOJO_SERVICES_NETWORK_PUBLIC_CPP_UDP_SOCKET_WRAPPER_H_
« no previous file with comments | « mojo/services/network/public/cpp/DEPS ('k') | mojo/services/network/public/cpp/udp_socket_wrapper.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698