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

Side by Side Diff: net/udp/udp_socket_win.h

Issue 721273002: Remove timing limitation to set Broadcast, ReceiveBuffer, and SendBuffer options from UDPSocket. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 6 years, 1 month 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
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 NET_UDP_UDP_SOCKET_WIN_H_ 5 #ifndef NET_UDP_UDP_SOCKET_WIN_H_
6 #define NET_UDP_UDP_SOCKET_WIN_H_ 6 #define NET_UDP_UDP_SOCKET_WIN_H_
7 7
8 #include <qos2.h> 8 #include <qos2.h>
9 #include <winsock2.h> 9 #include <winsock2.h>
10 10
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after
106 // Returns true if the socket is already connected or bound. 106 // Returns true if the socket is already connected or bound.
107 bool is_connected() const { return socket_ != INVALID_SOCKET; } 107 bool is_connected() const { return socket_ != INVALID_SOCKET; }
108 108
109 const BoundNetLog& NetLog() const { return net_log_; } 109 const BoundNetLog& NetLog() const { return net_log_; }
110 110
111 // Sets corresponding flags in |socket_options_| to allow the socket 111 // Sets corresponding flags in |socket_options_| to allow the socket
112 // to share the local address to which the socket will be bound with 112 // to share the local address to which the socket will be bound with
113 // other processes. Should be called before Bind(). 113 // other processes. Should be called before Bind().
114 void AllowAddressReuse(); 114 void AllowAddressReuse();
115 115
116 // Sets corresponding flags in |socket_options_| to allow sending 116 // Sets corresponding flags in |socket_options_| to allow or disallow
117 // and receiving packets to and from broadcast addresses. Should be 117 // sending and receiving packets to and from broadcast addresses.
118 // called before Bind(). 118 // Returns a net error code.
119 void AllowBroadcast(); 119 int SetBroadcast(bool broadcast);
120 120
121 // Join the multicast group. 121 // Join the multicast group.
122 // |group_address| is the group address to join, could be either 122 // |group_address| is the group address to join, could be either
123 // an IPv4 or IPv6 address. 123 // an IPv4 or IPv6 address.
124 // Return a network error code. 124 // Return a network error code.
125 int JoinGroup(const IPAddressNumber& group_address) const; 125 int JoinGroup(const IPAddressNumber& group_address) const;
126 126
127 // Leave the multicast group. 127 // Leave the multicast group.
128 // |group_address| is the group address to leave, could be either 128 // |group_address| is the group address to leave, could be either
129 // an IPv4 or IPv6 address. If the socket hasn't joined the group, 129 // an IPv4 or IPv6 address. If the socket hasn't joined the group,
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after
164 // do anything on some platforms. 164 // do anything on some platforms.
165 int SetDiffServCodePoint(DiffServCodePoint dscp); 165 int SetDiffServCodePoint(DiffServCodePoint dscp);
166 166
167 // Resets the thread to be used for thread-safety checks. 167 // Resets the thread to be used for thread-safety checks.
168 void DetachFromThread(); 168 void DetachFromThread();
169 169
170 private: 170 private:
171 enum SocketOptions { 171 enum SocketOptions {
172 SOCKET_OPTION_REUSE_ADDRESS = 1 << 0, 172 SOCKET_OPTION_REUSE_ADDRESS = 1 << 0,
173 SOCKET_OPTION_BROADCAST = 1 << 1, 173 SOCKET_OPTION_BROADCAST = 1 << 1,
174 SOCKET_OPTION_MULTICAST_LOOP = 1 << 2 174 SOCKET_OPTION_MULTICAST_LOOP = 1 << 2,
175 SOCKET_OPTION_RCVBUF_SIZE = 1 << 3,
176 SOCKET_OPTION_SNDBUF_SIZE = 1 << 4
175 }; 177 };
176 178
177 class Core; 179 class Core;
178 180
179 void DoReadCallback(int rv); 181 void DoReadCallback(int rv);
180 void DoWriteCallback(int rv); 182 void DoWriteCallback(int rv);
181 void DidCompleteRead(); 183 void DidCompleteRead();
182 void DidCompleteWrite(); 184 void DidCompleteWrite();
183 185
184 // Handles stats and logging. |result| is the number of bytes transferred, on 186 // Handles stats and logging. |result| is the number of bytes transferred, on
(...skipping 11 matching lines...) Expand all
196 int SendToOrWrite(IOBuffer* buf, 198 int SendToOrWrite(IOBuffer* buf,
197 int buf_len, 199 int buf_len,
198 const IPEndPoint* address, 200 const IPEndPoint* address,
199 const CompletionCallback& callback); 201 const CompletionCallback& callback);
200 202
201 int InternalConnect(const IPEndPoint& address); 203 int InternalConnect(const IPEndPoint& address);
202 int InternalRecvFrom(IOBuffer* buf, int buf_len, IPEndPoint* address); 204 int InternalRecvFrom(IOBuffer* buf, int buf_len, IPEndPoint* address);
203 int InternalSendTo(IOBuffer* buf, int buf_len, const IPEndPoint* address); 205 int InternalSendTo(IOBuffer* buf, int buf_len, const IPEndPoint* address);
204 206
205 // Applies |socket_options_| to |socket_|. Should be called before 207 // Applies |socket_options_| to |socket_|. Should be called before
206 // Bind(). 208 // DoBind().
207 int SetSocketOptions(); 209 int SetSocketOptions();
210 int AllowAddressReuseInternal();
211 int SetBroadcastInternal(bool broadcast);
212 int SetReceiveBufferSizeInternal(int32 size);
213 int SetSendBufferSizeInternal(int32 size);
208 int DoBind(const IPEndPoint& address); 214 int DoBind(const IPEndPoint& address);
209 // Binds to a random port on |address|. 215 // Binds to a random port on |address|.
210 int RandomBind(const IPAddressNumber& address); 216 int RandomBind(const IPAddressNumber& address);
211 217
212 // Attempts to convert the data in |recv_addr_storage_| and |recv_addr_len_| 218 // Attempts to convert the data in |recv_addr_storage_| and |recv_addr_len_|
213 // to an IPEndPoint and writes it to |address|. Returns true on success. 219 // to an IPEndPoint and writes it to |address|. Returns true on success.
214 bool ReceiveAddressToIPEndpoint(IPEndPoint* address) const; 220 bool ReceiveAddressToIPEndpoint(IPEndPoint* address) const;
215 221
216 SOCKET socket_; 222 SOCKET socket_;
217 int addr_family_; 223 int addr_family_;
218 224
219 // Bitwise-or'd combination of SocketOptions. Specifies the set of 225 // Bitwise-or'd combination of SocketOptions. Specifies the set of
220 // options that should be applied to |socket_| before Bind(). 226 // options that should be applied to |socket_| before Bind().
221 int socket_options_; 227 int socket_options_;
222 228
229 // Locally cacned value of buffer size. These are automatically applied
230 // when SetSocketOptions() is called.
231 int32 rcvbuf_size_;
232 int32 sndbuf_size_;
233
223 // Multicast interface. 234 // Multicast interface.
224 uint32 multicast_interface_; 235 uint32 multicast_interface_;
225 236
226 // Multicast socket options cached for SetSocketOption. 237 // Multicast socket options cached for SetSocketOption.
227 // Cannot be used after Bind(). 238 // Cannot be used after Bind().
228 int multicast_time_to_live_; 239 int multicast_time_to_live_;
229 240
230 // How to do source port binding, used only when UDPSocket is part of 241 // How to do source port binding, used only when UDPSocket is part of
231 // UDPClientSocket, since UDPServerSocket provides Bind. 242 // UDPClientSocket, since UDPServerSocket provides Bind.
232 DatagramSocket::BindType bind_type_; 243 DatagramSocket::BindType bind_type_;
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after
318 SetFlowFn set_flow_func_; 329 SetFlowFn set_flow_func_;
319 330
320 FRIEND_TEST_ALL_PREFIXES(UDPSocketTest, SetDSCPFake); 331 FRIEND_TEST_ALL_PREFIXES(UDPSocketTest, SetDSCPFake);
321 DISALLOW_COPY_AND_ASSIGN(QwaveAPI); 332 DISALLOW_COPY_AND_ASSIGN(QwaveAPI);
322 }; 333 };
323 334
324 335
325 } // namespace net 336 } // namespace net
326 337
327 #endif // NET_UDP_UDP_SOCKET_WIN_H_ 338 #endif // NET_UDP_UDP_SOCKET_WIN_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698