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 "content/renderer/p2p/ipc_socket_factory.h" | 5 #include "content/renderer/p2p/ipc_socket_factory.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <deque> | 8 #include <deque> |
9 | 9 |
10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
54 case rtc::Socket::OPT_RTP_SENDTIME_EXTN_ID: | 54 case rtc::Socket::OPT_RTP_SENDTIME_EXTN_ID: |
55 return false; // Not supported by the chrome sockets. | 55 return false; // Not supported by the chrome sockets. |
56 default: | 56 default: |
57 NOTREACHED(); | 57 NOTREACHED(); |
58 return false; | 58 return false; |
59 } | 59 } |
60 return true; | 60 return true; |
61 } | 61 } |
62 | 62 |
63 // TODO(miu): This needs tuning. http://crbug.com/237960 | 63 // TODO(miu): This needs tuning. http://crbug.com/237960 |
64 const size_t kMaximumInFlightBytes = 64 * 1024; // 64 KB | 64 // http://crbug.com/427555 |
| 65 const size_t kMaximumInFlightBytes = 256 * 1024; // 256 KB |
65 | 66 |
66 // IpcPacketSocket implements rtc::AsyncPacketSocket interface | 67 // IpcPacketSocket implements rtc::AsyncPacketSocket interface |
67 // using P2PSocketClient that works over IPC-channel. It must be used | 68 // using P2PSocketClient that works over IPC-channel. It must be used |
68 // on the thread it was created. | 69 // on the thread it was created. |
69 class IpcPacketSocket : public rtc::AsyncPacketSocket, | 70 class IpcPacketSocket : public rtc::AsyncPacketSocket, |
70 public P2PSocketClientDelegate { | 71 public P2PSocketClientDelegate { |
71 public: | 72 public: |
72 IpcPacketSocket(); | 73 IpcPacketSocket(); |
73 ~IpcPacketSocket() override; | 74 ~IpcPacketSocket() override; |
74 | 75 |
(...skipping 595 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
670 } | 671 } |
671 | 672 |
672 rtc::AsyncResolverInterface* | 673 rtc::AsyncResolverInterface* |
673 IpcPacketSocketFactory::CreateAsyncResolver() { | 674 IpcPacketSocketFactory::CreateAsyncResolver() { |
674 scoped_ptr<AsyncAddressResolverImpl> resolver( | 675 scoped_ptr<AsyncAddressResolverImpl> resolver( |
675 new AsyncAddressResolverImpl(socket_dispatcher_)); | 676 new AsyncAddressResolverImpl(socket_dispatcher_)); |
676 return resolver.release(); | 677 return resolver.release(); |
677 } | 678 } |
678 | 679 |
679 } // namespace content | 680 } // namespace content |
OLD | NEW |