Backed out 2 changesets (bug 1487100) for XPCShell failures in netwerk/test/unit_ipc/test_alt-data_simple_wrap.js

Backed out changeset 7f9d03c29a6f (bug 1487100)
Backed out changeset dd1c31ea78c2 (bug 1487100)

dom/fetch/FetchDriver.cpp

@@ -734,7 +734,7 @@ FetchDriver::HttpFetch(const nsACString& aPreferredAlternativeDataType)
   if (!aPreferredAlternativeDataType.IsEmpty()) {
     nsCOMPtr<nsICacheInfoChannel> cic = do_QueryInterface(chan);
     if (cic) {
-      cic->PreferAlternativeDataType(aPreferredAlternativeDataType, EmptyCString());
+      cic->PreferAlternativeDataType(aPreferredAlternativeDataType);
       MOZ_ASSERT(!mAltDataListener);
       mAltDataListener =
         new AlternativeDataStreamListener(this, chan, aPreferredAlternativeDataType);

dom/script/ScriptLoader.cpp

@@ -1109,7 +1109,7 @@ ScriptLoader::StartLoad(ScriptLoadRequest* aRequest)
       // Inform the HTTP cache that we prefer to have information coming from the
       // bytecode cache instead of the sources, if such entry is already registered.
       LOG(("ScriptLoadRequest (%p): Maybe request bytecode", aRequest));
-      cic->PreferAlternativeDataType(nsContentUtils::JSBytecodeMimeType(), EmptyCString());
+      cic->PreferAlternativeDataType(nsContentUtils::JSBytecodeMimeType());
     } else {
       // If we are explicitly loading from the sources, such as after a
       // restarted request, we might still want to save the bytecode after.
@@ -1118,7 +1118,7 @@ ScriptLoader::StartLoad(ScriptLoadRequest* aRequest)
       // does not exist, such that we can later save the bytecode with a
       // different alternative data type.
       LOG(("ScriptLoadRequest (%p): Request saving bytecode later", aRequest));
-      cic->PreferAlternativeDataType(kNullMimeType, EmptyCString());
+      cic->PreferAlternativeDataType(kNullMimeType);
     }
   }
 

dom/serviceworkers/ServiceWorkerEvents.cpp

@@ -343,9 +343,8 @@ public:
     // Get the preferred alternative data type of outter channel
     nsAutoCString preferredAltDataType(EmptyCString());
     nsCOMPtr<nsICacheInfoChannel> outerChannel = do_QueryInterface(underlyingChannel);
-    if (outerChannel && !outerChannel->PreferredAlternativeDataTypes().IsEmpty()) {
-      // TODO: handle multiple types properly.
-      preferredAltDataType.Assign(mozilla::Get<0>(outerChannel->PreferredAlternativeDataTypes()[0]));
+    if (outerChannel) {
+      outerChannel->GetPreferredAlternativeDataType(preferredAltDataType);
     }
 
     // Get the alternative data type saved in the InternalResponse

dom/serviceworkers/ServiceWorkerPrivate.cpp

@@ -1587,11 +1587,11 @@ private:
     nsresult rv = mInterceptedChannel->GetChannel(getter_AddRefs(channel));
     NS_ENSURE_SUCCESS(rv, false);
 
+    nsAutoCString alternativeDataType;
     nsCOMPtr<nsICacheInfoChannel> cic = do_QueryInterface(channel);
-    if (cic && !cic->PreferredAlternativeDataTypes().IsEmpty()) {
-      // TODO: the internal request probably needs all the preferred types.
-      nsAutoCString alternativeDataType;
-      alternativeDataType.Assign(mozilla::Get<0>(cic->PreferredAlternativeDataTypes()[0]));
+    if (cic &&
+        NS_SUCCEEDED(cic->GetPreferredAlternativeDataType(alternativeDataType)) &&
+        !alternativeDataType.IsEmpty()) {
       internalReq->SetPreferredAlternativeDataType(alternativeDataType);
     }
 

netwerk/base/nsICacheInfoChannel.idl

@@ -5,21 +5,6 @@
 #include "nsISupports.idl"
 
 interface nsIOutputStream;
-interface nsIInputStream;
-
-%{C++
-namespace mozilla {
-template<typename... Elements> class Tuple;
-} // namespace mozilla
-%}
-
-[ref] native ConstPreferenceArray(const nsTArray<mozilla::Tuple<nsCString, nsCString>>);
-
-[scriptable, uuid(1fb8ccf2-5fa5-45ec-bc57-8c8022a5d0d3)]
-interface nsIInputStreamReceiver : nsISupports
-{
-  void onInputStreamReady(in nsIInputStream aStream);
-};
 
 [scriptable, uuid(72c34415-c6eb-48af-851f-772fa9ee5972)]
 interface nsICacheInfoChannel : nsISupports
@@ -94,25 +79,16 @@ interface nsICacheInfoChannel : nsISupports
    * Calling this method instructs the channel to serve the alternative data
    * if that was previously saved in the cache, otherwise it will serve the
    * real data.
-   * @param type
-   *        a string identifying the alt-data format
-   * @param contentType
-   *        the contentType for which the preference applies.
-   *        an empty contentType means the preference applies for ANY contentType
-   *
-   * The method may be called several times, with different type and contentType.
-   *
    * Must be called before AsyncOpen.
    */
-  void preferAlternativeDataType(in ACString type, in ACString contentType);
+  void preferAlternativeDataType(in ACString type);
 
   /**
    * Get the preferred alternative data type set by preferAlternativeDataType().
-   * The returned types stand for the desired data type instead of the type of the
+   * This attribute stands for the desired data type instead of the type of the
    * information retrieved from the network stack.
    */
-  [noscript, notxpcom, nostdcall]
-  ConstPreferenceArray preferredAlternativeDataTypes();
+  readonly attribute ACString preferredAlternativeDataType;
 
   /**
    * Holds the type of the alternative data representation that the channel
@@ -123,13 +99,6 @@ interface nsICacheInfoChannel : nsISupports
    */
   readonly attribute ACString alternativeDataType;
 
-  /**
-   * Sometimes when the channel is delivering alt-data, we may want to somehow
-   * access the original content too. This method asynchronously opens the
-   * input stream and delivers it to the receiver.
-   */
-  void getOriginalInputStream(in nsIInputStreamReceiver aReceiver);
-
   /**
    * Opens and returns an output stream that a consumer may use to save an
    * alternate representation of the data.

netwerk/cache2/CacheEntry.cpp

@@ -1275,11 +1275,6 @@ nsresult CacheEntry::OpenAlternativeOutputStream(const nsACString & type, int64_
 
   nsresult rv;
 
-  if (type.IsEmpty()) {
-    // The empty string is reserved to mean no alt-data available.
-    return NS_ERROR_INVALID_ARG;
-  }
-
   mozilla::MutexAutoLock lock(mLock);
 
   if (!mHasData || mState < READY || mOutputStream || mIsDoomed) {
@@ -1559,6 +1554,7 @@ nsresult CacheEntry::GetDataSize(int64_t *aDataSize)
   return NS_OK;
 }
 
+
 nsresult CacheEntry::GetAltDataSize(int64_t *aDataSize)
 {
   LOG(("CacheEntry::GetAltDataSize [this=%p]", this));
@@ -1568,14 +1564,6 @@ nsresult CacheEntry::GetAltDataSize(int64_t *aDataSize)
   return mFile->GetAltDataSize(aDataSize);
 }
 
-nsresult CacheEntry::GetAltDataType(nsACString &aType)
-{
-  LOG(("CacheEntry::GetAltDataType [this=%p]", this));
-  if (NS_FAILED(mFileStatus)) {
-    return mFileStatus;
-  }
-  return mFile->GetAltDataType(aType);
-}
 
 nsresult CacheEntry::MarkValid()
 {

netwerk/cache2/CacheEntry.h

@@ -93,7 +93,6 @@ public:
   nsresult Recreate(bool aMemoryOnly, nsICacheEntry * *_retval);
   nsresult GetDataSize(int64_t *aDataSize);
   nsresult GetAltDataSize(int64_t *aAltDataSize);
-  nsresult GetAltDataType(nsACString &aAltDataType);
   nsresult OpenAlternativeOutputStream(const nsACString & type, int64_t predictedSize, nsIOutputStream * *_retval);
   nsresult OpenAlternativeInputStream(const nsACString & type, nsIInputStream * *_retval);
   nsresult GetLoadContextInfo(nsILoadContextInfo * *aLoadContextInfo);
@@ -462,7 +461,6 @@ public:
   NS_IMETHOD Recreate(bool aMemoryOnly, nsICacheEntry * *_retval) override { return mEntry->Recreate(aMemoryOnly, _retval); }
   NS_IMETHOD GetDataSize(int64_t *aDataSize) override { return mEntry->GetDataSize(aDataSize); }
   NS_IMETHOD GetAltDataSize(int64_t *aAltDataSize) override { return mEntry->GetAltDataSize(aAltDataSize); }
-  NS_IMETHOD GetAltDataType(nsACString &aType) override { return mEntry->GetAltDataType(aType); }
   NS_IMETHOD OpenAlternativeOutputStream(const nsACString & type, int64_t predictedSize, nsIOutputStream * *_retval) override { return mEntry->OpenAlternativeOutputStream(type, predictedSize, _retval); }
   NS_IMETHOD OpenAlternativeInputStream(const nsACString & type, nsIInputStream * *_retval) override { return mEntry->OpenAlternativeInputStream(type, _retval); }
   NS_IMETHOD GetLoadContextInfo(nsILoadContextInfo * *aLoadContextInfo) override { return mEntry->GetLoadContextInfo(aLoadContextInfo); }

netwerk/cache2/CacheFile.cpp

@@ -647,13 +647,12 @@ CacheFile::OnMetadataRead(nsresult aResult)
       const char *altData = mMetadata->GetElement(CacheFileUtils::kAltDataKey);
       if (altData &&
           (NS_FAILED(CacheFileUtils::ParseAlternativeDataInfo(
-            altData, &mAltDataOffset, &mAltDataType)) ||
+            altData, &mAltDataOffset, nullptr)) ||
           (mAltDataOffset > mDataSize))) {
         // alt-metadata cannot be parsed or alt-data offset is invalid
         mMetadata->InitEmptyMetadata();
         isNew = true;
         mAltDataOffset = -1;
-        mAltDataType.Truncate();
         mDataSize = 0;
       } else {
         CacheFileAutoLock lock(this);
@@ -802,6 +801,8 @@ CacheFile::OpenAlternativeInputStream(nsICacheEntry *aEntryHandle,
 
   MOZ_ASSERT(mHandle || mMemoryOnly || mOpeningFile);
 
+  nsresult rv;
+
   if (NS_WARN_IF(!mReady)) {
     LOG(("CacheFile::OpenAlternativeInputStream() - CacheFile is not ready "
          "[this=%p]", this));
@@ -827,13 +828,35 @@ CacheFile::OpenAlternativeInputStream(nsICacheEntry *aEntryHandle,
     return mStatus;
   }
 
-  if (mAltDataType != aAltDataType) {
-    LOG(("CacheFile::OpenAlternativeInputStream() - Alternative data is of a "
-         "different type than requested [this=%p, availableType=%s, "
-         "requestedType=%s]", this, mAltDataType.get(), aAltDataType));
+  const char *altData = mMetadata->GetElement(CacheFileUtils::kAltDataKey);
+  MOZ_ASSERT(altData, "alt-metadata should exist but was not found!");
+  if (NS_WARN_IF(!altData)) {
+    LOG(("CacheFile::OpenAlternativeInputStream() - alt-metadata not found but "
+         "alt-data exists according to mAltDataOffset! [this=%p, ]", this));
     return NS_ERROR_NOT_AVAILABLE;
   }
 
+  int64_t offset;
+  nsCString availableAltData;
+  rv = CacheFileUtils::ParseAlternativeDataInfo(altData, &offset,
+                                                &availableAltData);
+  if (NS_WARN_IF(NS_FAILED(rv))) {
+    MOZ_ASSERT(false, "alt-metadata unexpectedly failed to parse");
+    LOG(("CacheFile::OpenAlternativeInputStream() - Cannot parse alternative "
+         "metadata! [this=%p]", this));
+    return rv;
+  }
+
+  if (availableAltData != aAltDataType) {
+    LOG(("CacheFile::OpenAlternativeInputStream() - Alternative data is of a "
+         "different type than requested [this=%p, availableType=%s, "
+         "requestedType=%s]", this, availableAltData.get(), aAltDataType));
+    return NS_ERROR_NOT_AVAILABLE;
+  }
+
+  // mAltDataOffset must be in sync with what is stored in metadata
+  MOZ_ASSERT(mAltDataOffset == offset);
+
   // Once we open input stream we no longer allow preloading of chunks without
   // input stream, i.e. we will no longer keep first few chunks preloaded when
   // the last input stream is closed.
@@ -902,7 +925,6 @@ CacheFile::OpenOutputStream(CacheOutputCloseListener *aCloseListener, nsIOutputS
     }
     SetAltMetadata(nullptr);
     mAltDataOffset = -1;
-    mAltDataType.Truncate();
   }
 
   // Once we open output stream we no longer allow preloading of chunks without
@@ -997,7 +1019,6 @@ CacheFile::OpenAlternativeOutputStream(CacheOutputCloseListener *aCloseListener,
        "%p [this=%p]", mOutput, this));
 
   mDataAccessed = true;
-  mAltDataType = aAltDataType;
   NS_ADDREF(*_retval = mOutput);
   return NS_OK;
 }
@@ -1307,7 +1328,6 @@ CacheFile::SetAltMetadata(const char* aAltMetadata)
     mMetadata->SetElement(CacheFileUtils::kAltDataKey, nullptr);
 
     mAltDataOffset = -1;
-    mAltDataType.Truncate();
     hasAltData = false;
   }
 
@@ -2176,7 +2196,6 @@ CacheFile::RemoveOutput(CacheFileOutputStream *aOutput, nsresult aStatus)
         } else {
           SetAltMetadata(nullptr);
           mAltDataOffset = -1;
-          mAltDataType.Truncate();
         }
       }
     } else {
@@ -2362,19 +2381,6 @@ CacheFile::GetAltDataSize(int64_t *aSize)
   return NS_OK;
 }
 
-nsresult
-CacheFile::GetAltDataType(nsACString& aType)
-{
-  CacheFileAutoLock lock(this);
-
-  if (mAltDataOffset == -1) {
-    return NS_ERROR_NOT_AVAILABLE;
-  }
-
-  aType = mAltDataType;
-  return NS_OK;
-}
-
 bool
 CacheFile::IsDoomed()
 {

netwerk/cache2/CacheFile.h

@@ -92,7 +92,6 @@ public:
   nsresult   ThrowMemoryCachedData();
 
   nsresult GetAltDataSize(int64_t *aSize);
-  nsresult GetAltDataType(nsACString& aType);
 
   // metadata forwarders
   nsresult GetElement(const char *aKey, char **_retval);
@@ -216,7 +215,6 @@ private:
                                  // offset where alternative data starts.
                                  // Otherwise it is -1.
   nsCString      mKey;
-  nsCString      mAltDataType; // The type of the saved alt-data. May be empty.
 
   RefPtr<CacheFileHandle>      mHandle;
   RefPtr<CacheFileMetadata>    mMetadata;

netwerk/cache2/OldWrappers.cpp

@@ -396,11 +396,6 @@ NS_IMETHODIMP _OldCacheEntryWrapper::GetAltDataSize(int64_t *aSize)
   return NS_ERROR_NOT_IMPLEMENTED;
 }
 
-NS_IMETHODIMP _OldCacheEntryWrapper::GetAltDataType(nsACString &aType)
-{
-  return NS_ERROR_NOT_IMPLEMENTED;
-}
-
 NS_IMETHODIMP _OldCacheEntryWrapper::GetPersistent(bool *aPersistToDisk)
 {
   if (!mOldDesc) {

netwerk/cache2/OldWrappers.h

@@ -160,7 +160,6 @@ public:
   NS_IMETHOD Recreate(bool, nsICacheEntry**) override;
   NS_IMETHOD GetDataSize(int64_t *size) override;
   NS_IMETHOD GetAltDataSize(int64_t *size) override;
-  NS_IMETHOD GetAltDataType(nsACString &aType) override;
   NS_IMETHOD OpenInputStream(int64_t offset, nsIInputStream * *_retval) override;
   NS_IMETHOD OpenOutputStream(int64_t offset, int64_t predictedSize, nsIOutputStream * *_retval) override;
   NS_IMETHOD MaybeMarkValid() override;

netwerk/cache2/nsICacheEntry.idl

@@ -239,13 +239,6 @@ interface nsICacheEntry : nsISupports
   */
   readonly attribute long long altDataSize;
 
-  /**
-  * Returns the type of the saved alt data.
-  * @throws
-  *    - NS_ERROR_NOT_AVAILABLE if alt data does not exist.
-  */
-  readonly attribute ACString altDataType;
-
   /**
    * Opens and returns an output stream that a consumer may use to save an
    * alternate representation of the data.

netwerk/ipc/NeckoChannelParams.ipdlh

@@ -18,7 +18,6 @@ include PBackgroundSharedTypes;
 using mozilla::OriginAttributes from "mozilla/ipc/BackgroundUtils.h";
 using struct mozilla::void_t from "ipc/IPCMessageUtils.h";
 using RequestHeaderTuples from "mozilla/net/PHttpChannelParams.h";
-using ArrayOfStringPairs from "mozilla/net/PHttpChannelParams.h";
 using struct nsHttpAtom from "nsHttp.h";
 using class mozilla::net::nsHttpResponseHead from "nsHttpResponseHead.h";
 using class mozilla::TimeStamp from "mozilla/TimeStamp.h";
@@ -246,7 +245,7 @@ struct HttpChannelOpenArgs
   uint64_t                    channelId;
   nsString                    integrityMetadata;
   uint64_t                    contentWindowId;
-  ArrayOfStringPairs          preferredAlternativeTypes;
+  nsCString                   preferredAlternativeType;
   uint64_t                    topLevelOuterContentWindowId;
   TimeStamp                   launchServiceWorkerStart;
   TimeStamp                   launchServiceWorkerEnd;

netwerk/protocol/http/HttpBaseChannel.cpp

@@ -3909,9 +3909,7 @@ HttpBaseChannel::SetupReplacementChannel(nsIURI       *newURI,
   // Pass the preferred alt-data type on to the new channel.
   nsCOMPtr<nsICacheInfoChannel> cacheInfoChan(do_QueryInterface(newChannel));
   if (cacheInfoChan) {
-    for (auto& pair : mPreferredCachedAltDataTypes) {
-      cacheInfoChan->PreferAlternativeDataType(mozilla::Get<0>(pair), mozilla::Get<1>(pair));
-    }
+    cacheInfoChan->PreferAlternativeDataType(mPreferredCachedAltDataType);
   }
 
   if (redirectFlags & (nsIChannelEventSink::REDIRECT_INTERNAL |

netwerk/protocol/http/HttpBaseChannel.h

@@ -46,7 +46,6 @@
 #include "nsCOMArray.h"
 #include "mozilla/net/ChannelEventQueue.h"
 #include "mozilla/Move.h"
-#include "mozilla/Tuple.h"
 #include "nsIThrottledInputChannel.h"
 #include "nsTArray.h"
 #include "nsCOMPtr.h"
@@ -72,8 +71,6 @@ class LogCollector;
 namespace net {
 extern mozilla::LazyLogModule gHttpLog;
 
-typedef nsTArray<Tuple<nsCString, nsCString>> ArrayOfStringPairs;
-
 /*
  * This class is a partial implementation of nsIHttpChannel.  It contains code
  * shared by nsHttpChannel and HttpChannelChild.
@@ -556,8 +553,8 @@ protected:
   // The initiator type (for this resource) - how was the resource referenced in
   // the HTML file.
   nsString mInitiatorType;
-  // Holds the name of the preferred alt-data type for each contentType.
-  ArrayOfStringPairs mPreferredCachedAltDataTypes;
+  // Holds the name of the preferred alt-data type.
+  nsCString mPreferredCachedAltDataType;
   // Holds the name of the alternative data type the channel returned.
   nsCString mAvailableCachedAltDataType;
   nsString mIntegrityMetadata;

netwerk/protocol/http/HttpChannelChild.cpp

@@ -1267,7 +1267,7 @@ HttpChannelChild::OnStopRequest(const nsresult& channelStatus,
   // message but request the cache entry to be kept by the parent.
   // If the channel has failed, the cache entry is in a non-writtable state and
   // we want to release it to not block following consumers.
-  if (NS_SUCCEEDED(channelStatus) && !mPreferredCachedAltDataTypes.IsEmpty()) {
+  if (NS_SUCCEEDED(channelStatus) && !mPreferredCachedAltDataType.IsEmpty()) {
     mKeptAlive = true;
     SendDocumentChannelCleanup(false); // don't clear cache entry
     return;
@@ -1374,7 +1374,7 @@ HttpChannelChild::DoOnStopRequest(nsIRequest* aRequest, nsresult aChannelStatus,
   // If a preferred alt-data type was set, the parent would hold a reference to
   // the cache entry in case the child calls openAlternativeOutputStream().
   // (see nsHttpChannel::OnStopRequest)
-  if (!mPreferredCachedAltDataTypes.IsEmpty()) {
+  if (!mPreferredCachedAltDataType.IsEmpty()) {
     mAltDataCacheEntryAvailable = mCacheEntryAvailable;
   }
   mCacheEntryAvailable = false;
@@ -2874,7 +2874,7 @@ HttpChannelChild::ContinueAsyncOpen()
   openArgs.loadFlags() = mLoadFlags;
   openArgs.requestHeaders() = mClientSetRequestHeaders;
   mRequestHead.Method(openArgs.requestMethod());
-  openArgs.preferredAlternativeTypes() = mPreferredCachedAltDataTypes;
+  openArgs.preferredAlternativeType() = mPreferredCachedAltDataType;
 
   AutoIPCStream autoStream(openArgs.uploadStream());
   if (mUploadStream) {
@@ -3271,23 +3271,23 @@ HttpChannelChild::GetAllowStaleCacheContent(bool *aAllowStaleCacheContent)
 }
 
 NS_IMETHODIMP
-HttpChannelChild::PreferAlternativeDataType(const nsACString& aType,
-                                            const nsACString& aContentType)
+HttpChannelChild::PreferAlternativeDataType(const nsACString & aType)
 {
   ENSURE_CALLED_BEFORE_ASYNC_OPEN();
 
   if (mSynthesizedCacheInfo) {
-    return mSynthesizedCacheInfo->PreferAlternativeDataType(aType, aContentType);
+    return mSynthesizedCacheInfo->PreferAlternativeDataType(aType);
   }
 
-  mPreferredCachedAltDataTypes.AppendElement(MakePair(nsCString(aType), nsCString(aContentType)));
+  mPreferredCachedAltDataType = aType;
   return NS_OK;
 }
 
-const nsTArray<mozilla::Tuple<nsCString, nsCString>>&
-HttpChannelChild::PreferredAlternativeDataTypes()
+NS_IMETHODIMP
+HttpChannelChild::GetPreferredAlternativeDataType(nsACString & aType)
 {
-  return mPreferredCachedAltDataTypes;
+  aType = mPreferredCachedAltDataType;
+  return NS_OK;
 }
 
 NS_IMETHODIMP
@@ -3341,36 +3341,6 @@ HttpChannelChild::OpenAlternativeOutputStream(const nsACString & aType, int64_t
   return NS_OK;
 }
 
-NS_IMETHODIMP
-HttpChannelChild::GetOriginalInputStream(nsIInputStreamReceiver *aReceiver)
-{
-  if (aReceiver == nullptr) {
-    return NS_ERROR_INVALID_ARG;
-  }
-
-  if (!mIPCOpen) {
-    return NS_ERROR_NOT_AVAILABLE;
-  }
-
-  mInputStreamReceiver = aReceiver;
-  Unused << SendOpenOriginalCacheInputStream();
-
-  return NS_OK;
-}
-
-mozilla::ipc::IPCResult
-HttpChannelChild::RecvOriginalCacheInputStreamAvailable(const OptionalIPCStream& aStream)
-{
-  nsCOMPtr<nsIInputStream> stream = DeserializeIPCStream(aStream);
-  nsCOMPtr<nsIInputStreamReceiver> receiver;
-  receiver.swap(mInputStreamReceiver);
-  if (receiver) {
-    receiver->OnInputStreamReady(stream);
-  }
-
-  return IPC_OK();
-}
-
 //-----------------------------------------------------------------------------
 // HttpChannelChild::nsIResumableChannel
 //-----------------------------------------------------------------------------

netwerk/protocol/http/HttpChannelChild.h

@@ -182,8 +182,6 @@ protected:
 
   mozilla::ipc::IPCResult RecvCancelRedirected() override;
 
-  mozilla::ipc::IPCResult RecvOriginalCacheInputStreamAvailable(const OptionalIPCStream& aStream) override;
-
   virtual void ActorDestroy(ActorDestroyReason aWhy) override;
 
   virtual void DoNotifyListenerCleanup() override;
@@ -329,8 +327,6 @@ private:
   nsCOMPtr<nsICacheInfoChannel> mSynthesizedCacheInfo;
   RefPtr<ChannelEventQueue> mEventQ;
 
-  nsCOMPtr<nsIInputStreamReceiver> mInputStreamReceiver;
-
   // Used to ensure atomicity of mBgChild and mBgInitFailCallback
   Mutex mBgChildMutex;
 

netwerk/protocol/http/HttpChannelParent.cpp

@@ -153,7 +153,7 @@ HttpChannelParent::Init(const HttpChannelCreationArgs& aArgs)
                        a.allowStaleCacheContent(), a.contentTypeHint(),
                        a.corsMode(), a.redirectMode(),
                        a.channelId(), a.integrityMetadata(),
-                       a.contentWindowId(), a.preferredAlternativeTypes(),
+                       a.contentWindowId(), a.preferredAlternativeType(),
                        a.topLevelOuterContentWindowId(),
                        a.launchServiceWorkerStart(),
                        a.launchServiceWorkerEnd(),
@@ -455,7 +455,7 @@ HttpChannelParent::DoAsyncOpen(  const URIParams&           aURI,
                                  const uint64_t&            aChannelId,
                                  const nsString&            aIntegrityMetadata,
                                  const uint64_t&            aContentWindowId,
-                                 const ArrayOfStringPairs&  aPreferredAlternativeTypes,
+                                 const nsCString&           aPreferredAlternativeType,
                                  const uint64_t&            aTopLevelOuterContentWindowId,
                                  const TimeStamp&           aLaunchServiceWorkerStart,
                                  const TimeStamp&           aLaunchServiceWorkerEnd,
@@ -614,9 +614,7 @@ HttpChannelParent::DoAsyncOpen(  const URIParams&           aURI,
     do_QueryInterface(static_cast<nsIChannel*>(httpChannel.get()));
   if (cacheChannel) {
     cacheChannel->SetCacheKey(aCacheKey);
-    for (auto& pair : aPreferredAlternativeTypes) {
-      cacheChannel->PreferAlternativeDataType(mozilla::Get<0>(pair), mozilla::Get<1>(pair));
-    }
+    cacheChannel->PreferAlternativeDataType(aPreferredAlternativeType);
 
     cacheChannel->SetAllowStaleCacheContent(aAllowStaleCacheContent);
 
@@ -1773,26 +1771,6 @@ HttpChannelParent::RecvBytesRead(const int32_t& aCount)
   return IPC_OK();
 }
 
-mozilla::ipc::IPCResult
-HttpChannelParent::RecvOpenOriginalCacheInputStream()
-{
-  if (mIPCClosed) {
-    return IPC_OK();
-  }
-  AutoIPCStream autoStream;
-  if (mCacheEntry) {
-    nsCOMPtr<nsIInputStream> inputStream;
-    nsresult rv = mCacheEntry->OpenInputStream(0, getter_AddRefs(inputStream));
-    if (NS_SUCCEEDED(rv)) {
-      PContentParent* pcp = Manager()->Manager();
-      Unused << autoStream.Serialize(inputStream, static_cast<ContentParent*>(pcp));
-    }
-  }
-
-  Unused << SendOriginalCacheInputStreamAvailable(autoStream.TakeOptionalValue());
-  return IPC_OK();
-}
-
 //-----------------------------------------------------------------------------
 // HttpChannelParent::nsIProgressEventSink
 //-----------------------------------------------------------------------------

netwerk/protocol/http/HttpChannelParent.h

@@ -173,7 +173,7 @@ protected:
               const uint64_t&            aChannelId,
               const nsString&            aIntegrityMetadata,
               const uint64_t&            aContentWindowId,
-              const ArrayOfStringPairs&  aPreferredAlternativeTypes,
+              const nsCString&           aPreferredAlternativeType,
               const uint64_t&            aTopLevelOuterContentWindowId,
               const TimeStamp&           aLaunchServiceWorkerStart,
               const TimeStamp&           aLaunchServiceWorkerEnd,
@@ -210,7 +210,6 @@ protected:
   virtual mozilla::ipc::IPCResult RecvRemoveCorsPreflightCacheEntry(const URIParams& uri,
                                                                     const mozilla::ipc::PrincipalInfo& requestingPrincipal) override;
   virtual mozilla::ipc::IPCResult RecvBytesRead(const int32_t& aCount) override;
-  virtual mozilla::ipc::IPCResult RecvOpenOriginalCacheInputStream() override;
   virtual void ActorDestroy(ActorDestroyReason why) override;
 
   // Supporting function for ADivertableParentChannel.

netwerk/protocol/http/InterceptedHttpChannel.cpp

@@ -1315,18 +1315,18 @@ InterceptedHttpChannel::GetAllowStaleCacheContent(bool *aAllowStaleCacheContent)
 }
 
 NS_IMETHODIMP
-InterceptedHttpChannel::PreferAlternativeDataType(const nsACString & aType,
-                                                  const nsACString& aContentType)
+InterceptedHttpChannel::PreferAlternativeDataType(const nsACString & aType)
 {
   ENSURE_CALLED_BEFORE_ASYNC_OPEN();
-  mPreferredCachedAltDataTypes.AppendElement(MakePair(nsCString(aType), nsCString(aContentType)));
+  mPreferredCachedAltDataType = aType;
   return NS_OK;
 }
 
-const nsTArray<mozilla::Tuple<nsCString, nsCString>>&
-InterceptedHttpChannel::PreferredAlternativeDataTypes()
+NS_IMETHODIMP
+InterceptedHttpChannel::GetPreferredAlternativeDataType(nsACString & aType)
 {
-  return mPreferredCachedAltDataTypes;
+  aType = mPreferredCachedAltDataType;
+  return NS_OK;
 }
 
 NS_IMETHODIMP
@@ -1347,15 +1347,6 @@ InterceptedHttpChannel::OpenAlternativeOutputStream(const nsACString & type, int
   return NS_ERROR_NOT_AVAILABLE;
 }
 
-NS_IMETHODIMP
-InterceptedHttpChannel::GetOriginalInputStream(nsIInputStreamReceiver *aReceiver)
-{
-  if (mSynthesizedCacheInfo) {
-    return mSynthesizedCacheInfo->GetOriginalInputStream(aReceiver);
-  }
-  return NS_ERROR_NOT_AVAILABLE;
-}
-
 NS_IMETHODIMP
 InterceptedHttpChannel::GetCacheKey(uint32_t* key)
 {

netwerk/protocol/http/PHttpChannel.ipdl

@@ -12,7 +12,6 @@ include URIParams;
 include PBackgroundSharedTypes;
 include NeckoChannelParams;
 include IPCServiceWorkerDescriptor;
-include IPCStream;
 
 include "mozilla/net/NeckoMessageUtils.h";
 
@@ -94,9 +93,6 @@ parent:
   // sure not to send any more messages after that.
   async DeletingChannel();
 
-  // Called to get the input stream when altData was delivered.
-  async OpenOriginalCacheInputStream();
-
   // Tell the parent the amount bytes read by child for the e10s back pressure
   // flow control
   async BytesRead(int32_t count);
@@ -174,7 +170,6 @@ child:
   // See ADivertableParentChannel::CancelDiversion
   async CancelDiversion();
 
-  async OriginalCacheInputStreamAvailable(OptionalIPCStream stream);
 both:
   // After receiving this message, the parent also calls
   // SendFinishInterceptedRedirect, and makes sure not to send any more messages

netwerk/protocol/http/PHttpChannelParams.h

@@ -14,7 +14,6 @@
 #include "nsHttp.h"
 #include "nsHttpHeaderArray.h"
 #include "nsHttpResponseHead.h"
-#include "mozilla/Tuple.h"
 
 #include "nsIClassInfo.h"
 
@@ -37,37 +36,11 @@ struct RequestHeaderTuple {
 
 typedef nsTArray<RequestHeaderTuple> RequestHeaderTuples;
 
-typedef nsTArray<Tuple<nsCString, nsCString>> ArrayOfStringPairs;
-
 } // namespace net
 } // namespace mozilla
 
 namespace IPC {
 
-template<>
-struct ParamTraits<mozilla::Tuple<nsCString, nsCString>>
-{
-  typedef mozilla::Tuple<nsCString, nsCString> paramType;
-
-  static void Write(Message* aMsg, const paramType& aParam)
-  {
-    WriteParam(aMsg, mozilla::Get<0>(aParam));
-    WriteParam(aMsg, mozilla::Get<1>(aParam));
-  }
-
-  static bool Read(const Message* aMsg, PickleIterator* aIter, paramType* aResult)
-  {
-    nsCString first;
-    nsCString second;
-    if (!ReadParam(aMsg, aIter, &first) ||
-        !ReadParam(aMsg, aIter, &second))
-      return false;
-
-    *aResult = mozilla::MakeTuple(first, second);
-    return true;
-  }
-};
-
 template<>
 struct ParamTraits<mozilla::net::RequestHeaderTuple>
 {

netwerk/protocol/http/nsHttpChannel.cpp

@@ -5003,31 +5003,12 @@ nsHttpChannel::OpenCacheInputStream(nsICacheEntry* cacheEntry, bool startBufferi
         altDataFromChild = !value.IsEmpty();
     }
 
-    nsAutoCString altDataType;
-    Unused << cacheEntry->GetAltDataType(altDataType);
-
-    nsAutoCString contentType;
-    mCachedResponseHead->ContentType(contentType);
-
-    bool foundAltData = false;
-    if (!altDataType.IsEmpty() &&
-        !mPreferredCachedAltDataTypes.IsEmpty() &&
-        altDataFromChild == mAltDataForChild) {
-        for (auto& pref : mPreferredCachedAltDataTypes) {
-            if (mozilla::Get<0>(pref) == altDataType &&
-                (mozilla::Get<1>(pref).IsEmpty() || mozilla::Get<1>(pref) == contentType)) {
-                foundAltData = true;
-                break;
-            }
-        }
-    }
-    if (foundAltData) {
-        rv = cacheEntry->OpenAlternativeInputStream(altDataType,
+    if (!mPreferredCachedAltDataType.IsEmpty() && (altDataFromChild == mAltDataForChild)) {
+        rv = cacheEntry->OpenAlternativeInputStream(mPreferredCachedAltDataType,
                                                     getter_AddRefs(stream));
         if (NS_SUCCEEDED(rv)) {
-            LOG(("Opened alt-data input stream type=%s", altDataType.get()));
             // We have succeeded.
-            mAvailableCachedAltDataType = altDataType;
+            mAvailableCachedAltDataType = mPreferredCachedAltDataType;
             // Set the correct data size on the channel.
             int64_t altDataSize;
             if (NS_SUCCEEDED(cacheEntry->GetAltDataSize(&altDataSize))) {
@@ -5036,7 +5017,6 @@ nsHttpChannel::OpenCacheInputStream(nsICacheEntry* cacheEntry, bool startBufferi
         }
     }
 
-
     if (!stream) {
         rv = cacheEntry->OpenInputStream(0, getter_AddRefs(stream));
     }
@@ -7884,7 +7864,7 @@ nsHttpChannel::OnStopRequest(nsIRequest *request, nsISupports *ctxt, nsresult st
     // interested in reading and/or writing the alt-data representation.
     // We need to hold a reference to the cache entry in case the listener calls
     // openAlternativeOutputStream() after CloseCacheEntry() clears mCacheEntry.
-    if (!mPreferredCachedAltDataTypes.IsEmpty()) {
+    if (!mPreferredCachedAltDataType.IsEmpty()) {
         mAltDataCacheEntry = mCacheEntry;
     }
 
@@ -8306,18 +8286,18 @@ nsHttpChannel::GetAllowStaleCacheContent(bool *aAllowStaleCacheContent)
 }
 
 NS_IMETHODIMP
-nsHttpChannel::PreferAlternativeDataType(const nsACString& aType,
-                                         const nsACString& aContentType)
+nsHttpChannel::PreferAlternativeDataType(const nsACString & aType)
 {
     ENSURE_CALLED_BEFORE_ASYNC_OPEN();
-    mPreferredCachedAltDataTypes.AppendElement(MakePair(nsCString(aType), nsCString(aContentType)));
+    mPreferredCachedAltDataType = aType;
     return NS_OK;
 }
 
-const nsTArray<mozilla::Tuple<nsCString, nsCString>>&
-nsHttpChannel::PreferredAlternativeDataTypes()
+NS_IMETHODIMP
+nsHttpChannel::GetPreferredAlternativeDataType(nsACString & aType)
 {
-    return mPreferredCachedAltDataTypes;
+  aType = mPreferredCachedAltDataType;
+  return NS_OK;
 }
 
 NS_IMETHODIMP
@@ -8349,23 +8329,6 @@ nsHttpChannel::OpenAlternativeOutputStream(const nsACString & type, int64_t pred
     return rv;
 }
 
-NS_IMETHODIMP
-nsHttpChannel::GetOriginalInputStream(nsIInputStreamReceiver *aReceiver)
-{
-    if (aReceiver == nullptr) {
-        return NS_ERROR_INVALID_ARG;
-    }
-    nsCOMPtr<nsIInputStream> inputStream;
-
-    nsCOMPtr<nsICacheEntry> cacheEntry = mCacheEntry ? mCacheEntry
-                                                     : mAltDataCacheEntry;
-    if (cacheEntry) {
-        cacheEntry->OpenInputStream(0, getter_AddRefs(inputStream));
-    }
-    aReceiver->OnInputStreamReady(inputStream);
-    return NS_OK;
-}
-
 //-----------------------------------------------------------------------------
 // nsHttpChannel::nsICachingChannel
 //-----------------------------------------------------------------------------

netwerk/protocol/viewsource/nsViewSourceChannel.cpp

@@ -1146,12 +1146,3 @@ nsViewSourceChannel::LogBlockedCORSRequest(const nsAString& aMessage,
   }
   return mHttpChannel->LogBlockedCORSRequest(aMessage, aCategory);
 }
-
-const nsTArray<mozilla::Tuple<nsCString, nsCString>>&
-nsViewSourceChannel::PreferredAlternativeDataTypes()
-{
-    if (mCacheInfoChannel) {
-        return mCacheInfoChannel->PreferredAlternativeDataTypes();
-    }
-    return mEmptyArray;
-}

netwerk/protocol/viewsource/nsViewSourceChannel.h

@@ -65,7 +65,6 @@ public:
 
 protected:
     ~nsViewSourceChannel() = default;
-    nsTArray<mozilla::Tuple<nsCString, nsCString>> mEmptyArray;
 
     // Clones aURI and prefixes it with "view-source:" schema,
     nsresult BuildViewSourceURI(nsIURI* aURI, nsIURI** aResult);

netwerk/test/unit/test_alt-data_cross_process.js

@@ -85,7 +85,7 @@ function asyncOpen()
   var chan = make_channel(URL);
 
   var cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-  cc.preferAlternativeDataType(altContentType, "");
+  cc.preferAlternativeDataType(altContentType);
 
   chan.asyncOpen2(new ChannelListener(readServerContent, null));
 }
@@ -120,7 +120,7 @@ function flushAndOpenAltChannel()
 function openAltChannel() {
   var chan = make_channel(URL);
   var cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-  cc.preferAlternativeDataType(altContentType, "");
+  cc.preferAlternativeDataType(altContentType);
 
   chan.asyncOpen2(new ChannelListener(readAltContent, null));
 }

netwerk/test/unit/test_alt-data_overwrite.js

@@ -26,7 +26,7 @@ function make_and_open_channel(url, altContentType, callback) {
   let chan = NetUtil.newChannel({uri: url, loadUsingSystemPrincipal: true});
   if (altContentType) {
     let cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-    cc.preferAlternativeDataType(altContentType, "");
+    cc.preferAlternativeDataType(altContentType);
   }
   chan.asyncOpen2(new ChannelListener(callback, null));
 }

netwerk/test/unit/test_alt-data_simple.js

@@ -91,7 +91,7 @@ function asyncOpen()
   var chan = make_channel(URL);
 
   var cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-  cc.preferAlternativeDataType(altContentType, "");
+  cc.preferAlternativeDataType(altContentType);
 
   chan.asyncOpen2(new ChannelListener(readServerContent, null));
 }
@@ -136,9 +136,7 @@ function flushAndOpenAltChannel()
 function openAltChannel() {
   var chan = make_channel(URL);
   var cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-  cc.preferAlternativeDataType("dummy1", "text/javascript");
-  cc.preferAlternativeDataType(altContentType, "text/plain");
-  cc.preferAlternativeDataType("dummy2", "");
+  cc.preferAlternativeDataType(altContentType);
 
   chan.asyncOpen2(new ChannelListener(readAltContent, null));
 }
@@ -152,15 +150,7 @@ function readAltContent(request, buffer)
   Assert.equal(buffer, altContent);
   check_has_alt_data_in_index(true);
 
-  cc.getOriginalInputStream({
-    onInputStreamReady: function(aInputStream) {
-      executeSoon(function() {
-        let originalData = read_stream(aInputStream, aInputStream.available());
-        Assert.equal(originalData, responseContent);
-        requestAgain();
-      });
-    }
-  });
+  requestAgain();
 }
 
 function requestAgain()
@@ -168,7 +158,7 @@ function requestAgain()
   shouldPassRevalidation = false;
   var chan = make_channel(URL);
   var cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-  cc.preferAlternativeDataType(altContentType, "");
+  cc.preferAlternativeDataType(altContentType);
   chan.asyncOpen2(new ChannelListener(readEmptyAltContent, null));
 }
 

netwerk/test/unit/test_alt-data_stream.js

@@ -60,7 +60,7 @@ function run_test()
   var chan = make_channel(URL);
 
   var cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-  cc.preferAlternativeDataType(altContentType, "");
+  cc.preferAlternativeDataType(altContentType);
 
   chan.asyncOpen2(new ChannelListener(readServerContent, null));
   do_test_pending();
@@ -89,7 +89,7 @@ function openAltChannel()
 {
   var chan = make_channel(URL);
   var cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-  cc.preferAlternativeDataType(altContentType, "");
+  cc.preferAlternativeDataType(altContentType);
 
   chan.asyncOpen2(listener);
 }

netwerk/test/unit/test_cache-entry-id.js

@@ -53,7 +53,7 @@ function fetch(preferredDataType = null)
 
     if (preferredDataType) {
       var cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-      cc.preferAlternativeDataType(altContentType, "");
+      cc.preferAlternativeDataType(altContentType);
     }
 
     chan.asyncOpen2(new ChannelListener((request,

netwerk/test/unit_ipc/test_alt-data_cross_process_wrap.js

@@ -32,7 +32,7 @@ function load_channel(url) {
   URL = url; // save this to open the alt data channel later
   var chan = make_channel(url);
   var cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-  cc.preferAlternativeDataType("text/binary", "");
+  cc.preferAlternativeDataType("text/binary");
   chan.asyncOpen2(new ChannelListener(readTextData, null));
 }
 
@@ -64,7 +64,7 @@ function readTextData(request, buffer)
 function openAltChannel() {
   var chan = make_channel(URL);
   var cc = chan.QueryInterface(Ci.nsICacheInfoChannel);
-  cc.preferAlternativeDataType("text/parent-binary", "");
+  cc.preferAlternativeDataType("text/parent-binary");
   chan.asyncOpen2(new ChannelListener(readAltData, null));
 }