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

Side by Side Diff: mojo/services/network/udp_socket_impl.h

Issue 1725353003: Eliminate mojo::Shell client lib class (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@15connector
Patch Set: . Created 4 years, 10 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 unified diff | Download patch
« no previous file with comments | « mojo/services/network/udp_socket_apptest.cc ('k') | mojo/services/network/udp_socket_impl.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef MOJO_SERVICES_NETWORK_UDP_SOCKET_IMPL_H_ 5 #ifndef MOJO_SERVICES_NETWORK_UDP_SOCKET_IMPL_H_
6 #define MOJO_SERVICES_NETWORK_UDP_SOCKET_IMPL_H_ 6 #define MOJO_SERVICES_NETWORK_UDP_SOCKET_IMPL_H_
7 7
8 #include <stddef.h> 8 #include <stddef.h>
9 #include <stdint.h> 9 #include <stdint.h>
10 10
11 #include <deque> 11 #include <deque>
12 12
13 #include "base/macros.h" 13 #include "base/macros.h"
14 #include "base/memory/ref_counted.h" 14 #include "base/memory/ref_counted.h"
15 #include "mojo/public/cpp/bindings/strong_binding.h" 15 #include "mojo/public/cpp/bindings/strong_binding.h"
16 #include "mojo/services/network/public/interfaces/udp_socket.mojom.h" 16 #include "mojo/services/network/public/interfaces/udp_socket.mojom.h"
17 #include "mojo/shell/public/cpp/shell.h" 17 #include "mojo/shell/public/cpp/message_loop_ref.h"
18 #include "net/base/ip_endpoint.h" 18 #include "net/base/ip_endpoint.h"
19 #include "net/udp/udp_socket.h" 19 #include "net/udp/udp_socket.h"
20 20
21 namespace net { 21 namespace net {
22 class IOBuffer; 22 class IOBuffer;
23 class IOBufferWithSize; 23 class IOBufferWithSize;
24 } 24 }
25 25
26 namespace mojo { 26 namespace mojo {
27 27
28 class UDPSocketImpl : public UDPSocket { 28 class UDPSocketImpl : public UDPSocket {
29 public: 29 public:
30 // The lifetime of a new UDPSocketImpl is bound to the connection associated 30 // The lifetime of a new UDPSocketImpl is bound to the connection associated
31 // with |request|. 31 // with |request|.
32 UDPSocketImpl(InterfaceRequest<UDPSocket> request, 32 UDPSocketImpl(InterfaceRequest<UDPSocket> request,
33 scoped_ptr<mojo::AppRefCount> app_refcount); 33 scoped_ptr<mojo::MessageLoopRef> app_refcount);
34 ~UDPSocketImpl() override; 34 ~UDPSocketImpl() override;
35 35
36 // UDPSocket implementation. 36 // UDPSocket implementation.
37 void AllowAddressReuse( 37 void AllowAddressReuse(
38 const Callback<void(NetworkErrorPtr)>& callback) override; 38 const Callback<void(NetworkErrorPtr)>& callback) override;
39 39
40 void Bind(NetAddressPtr addr, 40 void Bind(NetAddressPtr addr,
41 const Callback<void(NetworkErrorPtr, 41 const Callback<void(NetworkErrorPtr,
42 NetAddressPtr, 42 NetAddressPtr,
43 InterfaceRequest<UDPSocketReceiver>)>& callback) 43 InterfaceRequest<UDPSocketReceiver>)>& callback)
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after
116 UDPSocketReceiverPtr receiver_; 116 UDPSocketReceiverPtr receiver_;
117 117
118 // How many more packets the client side expects to receive. 118 // How many more packets the client side expects to receive.
119 size_t remaining_recv_slots_; 119 size_t remaining_recv_slots_;
120 120
121 // The queue owns the PendingSendRequest instances. 121 // The queue owns the PendingSendRequest instances.
122 std::deque<PendingSendRequest*> pending_send_requests_; 122 std::deque<PendingSendRequest*> pending_send_requests_;
123 // The maximum size of the |pending_send_requests_| queue. 123 // The maximum size of the |pending_send_requests_| queue.
124 size_t max_pending_send_requests_; 124 size_t max_pending_send_requests_;
125 125
126 scoped_ptr<mojo::AppRefCount> app_refcount_; 126 scoped_ptr<mojo::MessageLoopRef> app_refcount_;
127 127
128 DISALLOW_COPY_AND_ASSIGN(UDPSocketImpl); 128 DISALLOW_COPY_AND_ASSIGN(UDPSocketImpl);
129 }; 129 };
130 130
131 } // namespace mojo 131 } // namespace mojo
132 132
133 #endif // MOJO_SERVICES_NETWORK_UDP_SOCKET_IMPL_H_ 133 #endif // MOJO_SERVICES_NETWORK_UDP_SOCKET_IMPL_H_
OLDNEW
« no previous file with comments | « mojo/services/network/udp_socket_apptest.cc ('k') | mojo/services/network/udp_socket_impl.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698