blob: 0d630e1ae5dfe309627886c2368c74f045728136 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
// Copyright 2015 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 REMOTING_PROTOCOL_PSEUDOTCP_ADAPTER_H_
#define REMOTING_PROTOCOL_PSEUDOTCP_ADAPTER_H_
#include <stdint.h>
#include "base/compiler_specific.h"
#include "base/macros.h"
#include "base/memory/ref_counted.h"
#include "base/memory/scoped_ptr.h"
#include "base/threading/non_thread_safe.h"
#include "net/log/net_log.h"
#include "remoting/protocol/p2p_stream_socket.h"
#include "third_party/webrtc/p2p/base/pseudotcp.h"
namespace remoting {
namespace protocol {
class P2PDatagramSocket;
// PseudoTcpAdapter adapts a P2PDatagramSocket to P2PStreamSocket using
// PseudoTcp. Because P2PStreamSockets can be deleted during callbacks,
// while PseudoTcp cannot, the core of the PseudoTcpAdapter is reference
// counted, with a reference held by the adapter, and an additional reference
// held on the stack during callbacks.
class PseudoTcpAdapter : public P2PStreamSocket, base::NonThreadSafe {
public:
explicit PseudoTcpAdapter(scoped_ptr<P2PDatagramSocket> socket);
~PseudoTcpAdapter() override;
// P2PStreamSocket implementation.
int Read(const scoped_refptr<net::IOBuffer>& buffer, int buffer_size,
const net::CompletionCallback& callback) override;
int Write(const scoped_refptr<net::IOBuffer>& buffer, int buffer_size,
const net::CompletionCallback& callback) override;
int Connect(const net::CompletionCallback& callback);
// Set receive and send buffer sizes.
int SetReceiveBufferSize(int32_t size);
int SetSendBufferSize(int32_t size);
// Set the delay for sending ACK.
void SetAckDelay(int delay_ms);
// Set whether Nagle's algorithm is enabled.
void SetNoDelay(bool no_delay);
// When write_waits_for_send flag is set to true the Write() method
// will wait until the data is sent to the remote end before the
// write completes (it still doesn't wait until the data is received
// and acknowledged by the remote end). Otherwise write completes
// after the data has been copied to the send buffer.
//
// This flag is useful in cases when the sender needs to get
// feedback from the connection when it is congested. E.g. remoting
// host uses this feature to adjust screen capturing rate according
// to the available bandwidth. In the same time it may negatively
// impact performance in some cases. E.g. when the sender writes one
// byte at a time then each byte will always be sent in a separate
// packet.
//
// TODO(sergeyu): Remove this flag once remoting has a better
// flow-control solution.
void SetWriteWaitsForSend(bool write_waits_for_send);
private:
class Core;
scoped_refptr<Core> core_;
net::BoundNetLog net_log_;
DISALLOW_COPY_AND_ASSIGN(PseudoTcpAdapter);
};
} // namespace protocol
} // namespace remoting
#endif // REMOTING_PROTOCOL_PSEUDOTCP_ADAPTER_H_
|
