blob: 92a951d17ab3b1f398182b04c2eb8023e9eef1c2 (
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
|
// 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.
#include "blimp/net/test_common.h"
#include <string>
#include "base/sys_byteorder.h"
#include "blimp/common/proto/blimp_message.pb.h"
#include "blimp/net/blimp_connection.h"
#include "blimp/net/common.h"
#include "net/base/io_buffer.h"
namespace blimp {
MockStreamSocket::MockStreamSocket() {}
MockStreamSocket::~MockStreamSocket() {}
MockTransport::MockTransport() {}
MockTransport::~MockTransport() {}
scoped_ptr<BlimpConnection> MockTransport::TakeConnection() {
return make_scoped_ptr(TakeConnectionPtr());
}
const char* MockTransport::GetName() const {
return "mock";
}
MockConnectionHandler::MockConnectionHandler() {}
MockConnectionHandler::~MockConnectionHandler() {}
void MockConnectionHandler::HandleConnection(
scoped_ptr<BlimpConnection> connection) {
HandleConnectionPtr(connection.get());
}
MockPacketReader::MockPacketReader() {}
MockPacketReader::~MockPacketReader() {}
MockPacketWriter::MockPacketWriter() {}
MockPacketWriter::~MockPacketWriter() {}
MockBlimpConnection::MockBlimpConnection() {}
MockBlimpConnection::~MockBlimpConnection() {}
MockConnectionErrorObserver::MockConnectionErrorObserver() {}
MockConnectionErrorObserver::~MockConnectionErrorObserver() {}
MockBlimpMessageProcessor::MockBlimpMessageProcessor() {}
MockBlimpMessageProcessor::~MockBlimpMessageProcessor() {}
void MockBlimpMessageProcessor::ProcessMessage(
scoped_ptr<BlimpMessage> message,
const net::CompletionCallback& callback) {
MockableProcessMessage(*message, callback);
}
std::string EncodeHeader(size_t size) {
scoped_ptr<char[]> serialized(new char[kPacketHeaderSizeBytes]);
uint32_t net_size = base::HostToNet32(size);
memcpy(serialized.get(), &net_size, sizeof(net_size));
return std::string(serialized.get(), kPacketHeaderSizeBytes);
}
bool BufferStartsWith(net::GrowableIOBuffer* buf, const std::string& str) {
return (static_cast<size_t>(buf->capacity()) > str.size() &&
str == std::string(buf->StartOfBuffer(), str.size()));
}
} // namespace blimp
|
