From ad18d877ddd2a44d98fa12ccd3dbbcf4d0ac4299 Mon Sep 17 00:00:00 2001 From: "Matt A. Tobin" Date: Fri, 2 Feb 2018 04:16:08 -0500 Subject: Add m-esr52 at 52.6.0 --- netwerk/protocol/http/ASpdySession.cpp | 127 +++++++++++++++++++++++++++++++++ 1 file changed, 127 insertions(+) create mode 100644 netwerk/protocol/http/ASpdySession.cpp (limited to 'netwerk/protocol/http/ASpdySession.cpp') diff --git a/netwerk/protocol/http/ASpdySession.cpp b/netwerk/protocol/http/ASpdySession.cpp new file mode 100644 index 0000000000..6bd54c7c0f --- /dev/null +++ b/netwerk/protocol/http/ASpdySession.cpp @@ -0,0 +1,127 @@ +/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ +/* vim: set sw=2 ts=8 et 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/. */ + +// HttpLog.h should generally be included first +#include "HttpLog.h" + +/* + Currently supported is h2 +*/ + +#include "nsHttp.h" +#include "nsHttpHandler.h" + +#include "ASpdySession.h" +#include "PSpdyPush.h" +#include "Http2Push.h" +#include "Http2Session.h" + +#include "mozilla/Telemetry.h" + +namespace mozilla { +namespace net { + +ASpdySession::ASpdySession() +{ +} + +ASpdySession::~ASpdySession() = default; + +ASpdySession * +ASpdySession::NewSpdySession(uint32_t version, + nsISocketTransport *aTransport) +{ + // This is a necko only interface, so we can enforce version + // requests as a precondition + MOZ_ASSERT(version == HTTP_VERSION_2, + "Unsupported spdy version"); + + // Don't do a runtime check of IsSpdyV?Enabled() here because pref value + // may have changed since starting negotiation. The selected protocol comes + // from a list provided in the SERVER HELLO filtered by our acceptable + // versions, so there is no risk of the server ignoring our prefs. + + Telemetry::Accumulate(Telemetry::SPDY_VERSION2, version); + + return new Http2Session(aTransport, version); +} + +SpdyInformation::SpdyInformation() +{ + // highest index of enabled protocols is the + // most preferred for ALPN negotiaton + Version[0] = HTTP_VERSION_2; + VersionString[0] = NS_LITERAL_CSTRING("h2"); + ALPNCallbacks[0] = Http2Session::ALPNCallback; +} + +bool +SpdyInformation::ProtocolEnabled(uint32_t index) const +{ + MOZ_ASSERT(index < kCount, "index out of range"); + + return gHttpHandler->IsHttp2Enabled(); +} + +nsresult +SpdyInformation::GetNPNIndex(const nsACString &npnString, + uint32_t *result) const +{ + if (npnString.IsEmpty()) + return NS_ERROR_FAILURE; + + for (uint32_t index = 0; index < kCount; ++index) { + if (npnString.Equals(VersionString[index])) { + *result = index; + return NS_OK; + } + } + + return NS_ERROR_FAILURE; +} + +////////////////////////////////////////// +// SpdyPushCache +////////////////////////////////////////// + +SpdyPushCache::SpdyPushCache() +{ +} + +SpdyPushCache::~SpdyPushCache() +{ + mHashHttp2.Clear(); +} + +bool +SpdyPushCache::RegisterPushedStreamHttp2(nsCString key, + Http2PushedStream *stream) +{ + LOG3(("SpdyPushCache::RegisterPushedStreamHttp2 %s 0x%X\n", + key.get(), stream->StreamID())); + if(mHashHttp2.Get(key)) { + LOG3(("SpdyPushCache::RegisterPushedStreamHttp2 %s 0x%X duplicate key\n", + key.get(), stream->StreamID())); + return false; + } + mHashHttp2.Put(key, stream); + return true; +} + +Http2PushedStream * +SpdyPushCache::RemovePushedStreamHttp2(nsCString key) +{ + Http2PushedStream *rv = mHashHttp2.Get(key); + LOG3(("SpdyPushCache::RemovePushedStreamHttp2 %s 0x%X\n", + key.get(), rv ? rv->StreamID() : 0)); + if (rv) + mHashHttp2.Remove(key); + return rv; +} + +} // namespace net +} // namespace mozilla + -- cgit v1.2.3