blob: 19ba1a1cbee371834b1dc84724ee283d386afb46 (
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
84
|
// Copyright (c) 2011 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.
// Implement a secure P2P socket according to the W3C spec
//
// "Video conferencing and peer-to-peer communication"
// http://www.whatwg.org/specs/web-apps/current-work/complete/video-conferencing-and-peer-to-peer-communication.html#peer-to-peer-connections
//
// This class operates on an establish socket to perform encryption for P2P
// connection. This class does not perform chunking for outgoing buffers, all
// outgoing buffers have to be 44 bytes smaller than MTU to allow space for
// header to support encryption.
#ifndef REMOTING_PROTOCOL_SECURE_P2P_SOCKET_H_
#define REMOTING_PROTOCOL_SOCKET_P2P_SOCKET_H_
#include <string>
#include "base/memory/ref_counted.h"
#include "base/memory/scoped_ptr.h"
#include "crypto/encryptor.h"
#include "crypto/hmac.h"
#include "net/socket/socket.h"
namespace crypto {
class SymmetricKey;
} // namespace crypto
namespace net {
class IOBufferWithSize;
} // namespace net
namespace remoting {
namespace protocol {
class SecureP2PSocket : public net::Socket {
public:
// Construct a secured P2P socket using |socket| as the underlying
// socket. Ownership of |socket| is transfered to this object.
SecureP2PSocket(net::Socket* socket, const std::string& ice_key);
// Socket implementation.
virtual int Read(net::IOBuffer* buf, int buf_len,
net::CompletionCallback* callback);
virtual int Write(net::IOBuffer* buf, int buf_len,
net::CompletionCallback* callback);
virtual bool SetReceiveBufferSize(int32 size);
virtual bool SetSendBufferSize(int32 size);
private:
int ReadInternal();
void ReadDone(int err);
void WriteDone(int err);
int DecryptBuffer(int size);
scoped_ptr<net::Socket> socket_;
uint64 write_seq_;
uint64 read_seq_;
net::CompletionCallback* user_read_callback_;
scoped_refptr<net::IOBuffer> user_read_buf_;
int user_read_buf_len_;
net::CompletionCallback* user_write_callback_;
int user_write_buf_len_;
scoped_ptr<net::CompletionCallback> read_callback_;
scoped_refptr<net::IOBufferWithSize> read_buf_;
scoped_ptr<net::CompletionCallback> write_callback_;
scoped_ptr<crypto::SymmetricKey> mask_key_;
crypto::HMAC msg_hasher_;
crypto::Encryptor encryptor_;
DISALLOW_COPY_AND_ASSIGN(SecureP2PSocket);
};
} // namespace protocol
} // namespace remoting
#endif // REMOTING_PROTOCOL_SOCKET_P2P_SOCKET_H_
|
