blob: 897ae621367011fff68f2ed6210434c0d6f7b4d8 (
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
|
// 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/browser_connection_handler.h"
#include "base/logging.h"
#include "base/macros.h"
#include "blimp/net/blimp_connection.h"
#include "blimp/net/blimp_message_demultiplexer.h"
#include "blimp/net/blimp_message_multiplexer.h"
#include "blimp/net/blimp_message_output_buffer.h"
#include "blimp/net/blimp_message_processor.h"
namespace blimp {
namespace {
// Maximum footprint of the output buffer.
// TODO(kmarshall): Use a value that's computed from the platform.
const int kMaxBufferSizeBytes = 1 << 24;
} // namespace
BrowserConnectionHandler::BrowserConnectionHandler()
: demultiplexer_(new BlimpMessageDemultiplexer),
output_buffer_(new BlimpMessageOutputBuffer(kMaxBufferSizeBytes)),
multiplexer_(new BlimpMessageMultiplexer(output_buffer_.get())) {}
BrowserConnectionHandler::~BrowserConnectionHandler() {}
scoped_ptr<BlimpMessageProcessor> BrowserConnectionHandler::RegisterFeature(
BlimpMessage::Type type,
BlimpMessageProcessor* incoming_processor) {
demultiplexer_->AddProcessor(type, incoming_processor);
return multiplexer_->CreateSenderForType(type);
}
void BrowserConnectionHandler::HandleConnection(
scoped_ptr<BlimpConnection> connection) {
// Since there is only a single Client, assume a newer connection should
// replace an existing one.
DropCurrentConnection();
connection_ = connection.Pass();
// Connect the incoming & outgoing message streams.
connection_->SetIncomingMessageProcessor(demultiplexer_.get());
output_buffer_->SetOutputProcessor(
connection_->GetOutgoingMessageProcessor());
}
void BrowserConnectionHandler::DropCurrentConnection() {
if (!connection_)
return;
connection_->SetIncomingMessageProcessor(nullptr);
output_buffer_->SetOutputProcessor(nullptr);
connection_.reset();
}
void BrowserConnectionHandler::OnConnectionError(int error) {
LOG(WARNING) << "Connection error " << error;
DropCurrentConnection();
}
} // namespace blimp
|
