OLD | NEW |
---|---|
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 #include "net/udp/udp_socket_posix.h" | 5 #include "net/udp/udp_socket_posix.h" |
6 | 6 |
7 #include <errno.h> | 7 #include <errno.h> |
8 #include <fcntl.h> | 8 #include <fcntl.h> |
9 #include <net/if.h> | 9 #include <net/if.h> |
10 #include <netdb.h> | 10 #include <netdb.h> |
(...skipping 407 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
418 } | 418 } |
419 | 419 |
420 int UDPSocketPosix::SetSendBufferSize(int32_t size) { | 420 int UDPSocketPosix::SetSendBufferSize(int32_t size) { |
421 DCHECK_NE(socket_, kInvalidSocket); | 421 DCHECK_NE(socket_, kInvalidSocket); |
422 DCHECK(CalledOnValidThread()); | 422 DCHECK(CalledOnValidThread()); |
423 int rv = setsockopt(socket_, SOL_SOCKET, SO_SNDBUF, | 423 int rv = setsockopt(socket_, SOL_SOCKET, SO_SNDBUF, |
424 reinterpret_cast<const char*>(&size), sizeof(size)); | 424 reinterpret_cast<const char*>(&size), sizeof(size)); |
425 return rv == 0 ? OK : MapSystemError(errno); | 425 return rv == 0 ? OK : MapSystemError(errno); |
426 } | 426 } |
427 | 427 |
428 int UDPSocketPosix::SetDoNotFragment() { | |
429 DCHECK_NE(socket_, kInvalidSocket); | |
430 DCHECK(CalledOnValidThread()); | |
431 | |
432 #if !defined(IP_PMTUDISC_DO) | |
433 return OK; | |
mmenke
2016/08/12 19:46:05
It's considered a success if we can't set this? I
Ryan Hamilton
2016/08/12 21:46:02
Good point. Changed it to return NOT_IMPLEMENTED.
| |
434 #else | |
435 int v6_only = false; | |
436 if (addr_family_ == AF_INET6) { | |
437 socklen_t v6_only_len = sizeof(v6_only); | |
438 getsockopt(socket_, IPPROTO_IPV6, IPV6_V6ONLY, &v6_only, &v6_only_len); | |
mmenke
2016/08/12 19:46:05
What if getsockopt fails? Do we care?
Ryan Hamilton
2016/08/12 21:46:02
Good point. I don't think we *really* care, but mi
| |
439 } | |
440 | |
441 int rv; | |
442 if (addr_family_ == AF_INET6) { | |
mmenke
2016/08/12 19:46:05
Should this be merged with the above if block? Co
Ryan Hamilton
2016/08/12 21:46:02
Ah, yes. This code moved around so I missed that.
| |
443 int val = IPV6_PMTUDISC_DO; | |
mmenke
2016/08/12 19:46:05
IP_PMTUDISC_DO being defined guarantees IPV6_PMTUD
Ryan Hamilton
2016/08/12 21:46:02
As far as I can tell. It's true for all our trybot
| |
444 rv = | |
445 setsockopt(socket_, IPPROTO_IPV6, IPV6_MTU_DISCOVER, &val, sizeof(val)); | |
446 if (rv != 0) | |
447 return MapSystemError(errno); | |
448 } | |
449 if (!v6_only) { | |
450 int val = IP_PMTUDISC_DO; | |
451 rv = setsockopt(socket_, IPPROTO_IP, IP_MTU_DISCOVER, &val, sizeof(val)); | |
452 } | |
453 return rv == 0 ? OK : MapSystemError(errno); | |
454 #endif | |
455 } | |
456 | |
428 int UDPSocketPosix::AllowAddressReuse() { | 457 int UDPSocketPosix::AllowAddressReuse() { |
429 DCHECK_NE(socket_, kInvalidSocket); | 458 DCHECK_NE(socket_, kInvalidSocket); |
430 DCHECK(CalledOnValidThread()); | 459 DCHECK(CalledOnValidThread()); |
431 DCHECK(!is_connected()); | 460 DCHECK(!is_connected()); |
432 int true_value = 1; | 461 int true_value = 1; |
433 int rv = setsockopt( | 462 int rv = setsockopt( |
434 socket_, SOL_SOCKET, SO_REUSEADDR, &true_value, sizeof(true_value)); | 463 socket_, SOL_SOCKET, SO_REUSEADDR, &true_value, sizeof(true_value)); |
435 return rv == 0 ? OK : MapSystemError(errno); | 464 return rv == 0 ? OK : MapSystemError(errno); |
436 } | 465 } |
437 | 466 |
(...skipping 403 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
841 return MapSystemError(errno); | 870 return MapSystemError(errno); |
842 | 871 |
843 return OK; | 872 return OK; |
844 } | 873 } |
845 | 874 |
846 void UDPSocketPosix::DetachFromThread() { | 875 void UDPSocketPosix::DetachFromThread() { |
847 base::NonThreadSafe::DetachFromThread(); | 876 base::NonThreadSafe::DetachFromThread(); |
848 } | 877 } |
849 | 878 |
850 } // namespace net | 879 } // namespace net |
OLD | NEW |