зеркало из https://github.com/mozilla/gecko-dev.git
83 строки
2.2 KiB
C++
83 строки
2.2 KiB
C++
|
/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
|
||
|
|
/* vim: set ts=2 et sw=2 tw=80: */
|
||
|
|
/* This Source Code Form is subject to the terms of the Mozilla Public
|
||
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
|
||
|
|
* You can obtain one at http://mozilla.org/MPL/2.0/. */
|
||
|
|
|
||
|
|
// Original author: ekr@rtfm.com
|
||
|
|
#include <deque>
|
||
|
|
|
||
|
|
#include "transportflow.h"
|
||
|
|
#include "transportlayer.h"
|
||
|
|
|
||
|
|
namespace mozilla {
|
||
|
|
|
||
|
|
TransportFlow::~TransportFlow() {
|
||
|
|
for (std::deque<TransportLayer *>::iterator it = layers_.begin();
|
||
|
|
it != layers_.end(); ++it) {
|
||
|
|
delete *it;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
nsresult TransportFlow::PushLayer(TransportLayer *layer) {
|
||
|
|
nsresult rv = layer->Init();
|
||
|
|
if (!NS_SUCCEEDED(rv))
|
||
|
|
return rv;
|
||
|
|
|
||
|
|
|
||
|
|
TransportLayer *old_layer = layers_.empty() ? nullptr : layers_.front();
|
||
|
|
|
||
|
|
// Re-target my signals to the new layer
|
||
|
|
if (old_layer) {
|
||
|
|
old_layer->SignalStateChange.disconnect(this);
|
||
|
|
old_layer->SignalPacketReceived.disconnect(this);
|
||
|
|
}
|
||
|
|
layer->SignalStateChange.connect(this, &TransportFlow::StateChange);
|
||
|
|
layer->SignalPacketReceived.connect(this, &TransportFlow::PacketReceived);
|
||
|
|
|
||
|
|
layers_.push_front(layer);
|
||
|
|
layer->Inserted(this, old_layer);
|
||
|
|
return NS_OK;
|
||
|
|
}
|
||
|
|
|
||
|
|
TransportLayer *TransportFlow::top() const {
|
||
|
|
return layers_.empty() ? nullptr : layers_.front();
|
||
|
|
}
|
||
|
|
|
||
|
|
TransportLayer *TransportFlow::GetLayer(const std::string& id) const {
|
||
|
|
for (std::deque<TransportLayer *>::const_iterator it = layers_.begin();
|
||
|
|
it != layers_.end(); ++it) {
|
||
|
|
if ((*it)->id() == id)
|
||
|
|
return *it;
|
||
|
|
}
|
||
|
|
|
||
|
|
return nullptr;
|
||
|
|
}
|
||
|
|
|
||
|
|
TransportLayer::State TransportFlow::state() {
|
||
|
|
return top() ? top()->state() : TransportLayer::TS_NONE;
|
||
|
|
}
|
||
|
|
|
||
|
|
TransportResult TransportFlow::SendPacket(const unsigned char *data,
|
||
|
|
size_t len) {
|
||
|
|
return top() ? top()->SendPacket(data, len) : TE_ERROR;
|
||
|
|
}
|
||
|
|
|
||
|
|
void TransportFlow::StateChange(TransportLayer *layer,
|
||
|
|
TransportLayer::State state) {
|
||
|
|
SignalStateChange(this, state);
|
||
|
|
}
|
||
|
|
|
||
|
|
void TransportFlow::PacketReceived(TransportLayer* layer,
|
||
|
|
const unsigned char *data,
|
||
|
|
size_t len) {
|
||
|
|
SignalPacketReceived(this, data, len);
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
} // close namespace
|