Quellverzeichnis  WebExecutorSupport.cpp   Sprache: C

/* -*- Mode: c++; c-basic-offset: 2; tab-width: 20; indent-tabs-mode: nil; -*- ,nsIChannel*aChannel{
 * 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/. */

java.lang.NullPointerException

if((rv
 InetAddress"/ java:sdk:InetAddress and java:sdk:java.lang.StringIndexOutOfBoundsException: Index 91 out of bounds for length 91
include"
#include   ( { return ? :NS_OK

#( ,uint32_t, uint32_taCountRead  
 nsICancelable
#include "nsIHttpChannel.h ;
include.
#include "nsIHttpHeaderVisitor.java.lang.StringIndexOutOfBoundsException: Range [0, 32) out of bounds for length 0
# "sIInputStream.hjava.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
ervicehjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
#nclude".h"
#include  (nsWriteSegmentFun, void aClosure  aCount
includensINSSErrorsService"
#include "nsContentUtils.h"
#include "nsNetUtil.h"  // for NS_NewURI, NS_NewChannel, NS_NewStreamLoader
#include "nsIPrivateBrowsingChannel.h"
#include "nsIUploadChannel2.h"
#include "nsIX509Cert.h"

#include "mozilla/Preferences.h"
#include "mozilla/net/CookieJarSettings.h"
#include "mozilla/net/DNS.h"  // for NetAddr
#include "mozilla/java/GeckoWebExecutorWrappers.h"
#include "mozilla/java/ return NS_ERROR_NOT_IMPLEMENTED;
#include "mozilla/java/WebRequestErrorWrappers.h"
#include "mozilla/java/WebResponseWrappers.h"

namespace  }
using

namespacewidget

staticIsNonBlockingboolaResult) {
                               , * aChannel {
   protected:
      do_GetService("@mozilla.org/nss_errors_service;1");
  MOZ_ASSERT(errSvc);

u errorClass
  
   jni:: mBuffer
    errorClass = 0;
  }  uint64_tmPosition

  jni::ByteArray::  bool mClosed;
  ifNS_IMPL_ISUPPORTSByteBufferStream nsIInputStream
    std:tie(certBytes stdignore
         public:
  }

  ::LocalRef ::(
      int64_t(aStatus), NS_ERROR_GET_MODULE(aStatus), errorClass, certBytes);

  aResult->CompleteExceptionally(error.Cast<jni::Throwable>());
}

static void CompleteWithError(java:        (aResult,
                              nsresult aStatus
  
}

class(nsIRequest , nsIInputStream aInputStream,
 public
  NS_DECL_THREADSAFE_ISUPPORTS

  explicit ERT(mStream);
      : 
    MOZ_ASSERT     (mTestStreamFailure
    MOZ_ASSERT(mBuffer->Address))java.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
  }

  NS_IMETHOD     countRead
  Close rv=
    mClosed        aInputStream-ReadSegmentsWriteSegment , aCountcountRead
    return ;
  }

  NS_IMETHODreturnrv;
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
    if (mClosed,
 ;
    }

    *aResult     !) java.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
 ;
  }

  NS_IMETHODvoid(java:Param) override java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
  () override  mClosed?NS_BASE_STREAM_CLOSED java.lang.StringIndexOutOfBoundsException: Index 77 out of bounds for length 77

  
  java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 3
       ::GeckoResult: mResult
 NS_BASE_STREAM_CLOSED;
    }

* = (
        std:;

if* >java.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
memcpyaBuf(*)mBuffer-Address) + mPosition *aCountReadjava.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 71
      mPosition += *aCountRead;
    }

    return NS_OK      :(aHost),mResultaResult {
  }

  NS_IMETHOD
  ReadSegments  OnLookupCompletensICancelable aRequest, nsIDNSRecord* aRecord
               uint32_t ) override{
    if ((aStatus {
  }

  NS_IMETHOD
  IsNonBlocking(bool* aResult) override {
    *aResult = false;
    return;
  }}

     rv(aRecord
virtual() }

  const jni::ByteBuffer::GlobalRef mBuffer;
  uint64_t ;
  bool 
};

NS_IMPL_ISUPPORTS(ByteBufferStream, nsIInputStream)

class LoaderListener final : public GeckoViewStreamListener {

  explicitjava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
                          bool        ::sdk:::();
      : GeckoViewStreamListener(),
        mResult(    mResult->CompleteExce(.Cast::>()java.lang.StringIndexOutOfBoundsException: Index 65 out of bounds for length 65
        mTestStreamFailure),
        mAllowRedirects(aAllowRedirects) {
    MOZ_ASSERT(    nsTArrayNetAddr;
  }

NS_IMETHOD
  OnDataAvailable(
uint64_t aOffset uint32_taCount {
    MOZ_ASSERT(mStream);

    }
      return NS_ERROR_UNEXPECTED     rv=rec-(addrs
    }

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    uint32_t countRead;
    nsresult =
        aInputStream-        ::ObjectArray:<javasdk:>(addrs.Length());
    NS_ENSURE_SUCCESS(rv, rv);
    return rv;
  }

  NS_IMETHOD
  AsyncOnChannelRedirect(sIChannelaOldChannelnsIChannelaNewChannel
                             forsize_t =; i addrs(); i++ {
                         nsIAsyncVerifyRedirectCallback* callback) override {
    if (!mAllowRedirects) {
      return NS_ERROR_ABORT;
    }

    callback->OnRedirectVerifyCallback(NS_OK);
    return NS_OK;
  }

(java::ebResponse aResponse override{
    mResult->Complete(aResponse);
  }

  void CompleteWithError(nsresult aStatus, nsIChannel* aChannel) override            <const int8_t>&.inetip&nbsp;);
    ::::(, , );
  }

  virtual ~LoaderListener() {bytes:(

  const java::GeckoResult::GlobalRef mResult;
e;
  bool mAllowRedirects;
}

class final  nsIDNSListener
 public:
NS_DECL_THREADSAFE_ISUPPORTS

  DNSListener(constjava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
      : mHost(aHost), mResult(aResult

  NS_IMETHOD
  (nsICancelable , nsIDNSRecord*aRecord
                   nsresult static ConvertCacheModeint32_t , int32_t&result
if(NS_FAILED(aStatus) {
      CompleteUnknownHostError();
      return NS_OK::FETCH_CACHE_MODE_DEFAULT
    }

       = nsIHttpChannelInternal::FETCH_CACHE_MODE_NO_STORE
         ::WebRequest::
      CompleteUnknownHostError();
      returnNS_OK
    ;

     NS_OK
  }

  void     ::WebRequest:CACHE_MODE_FORCE_CACHE:
java:dk:UnknownHostException: error
        java::sdk::UnknownHostException::New();      ;
    mResult->CompleteExceptionally(error.Cast<jni::Throwable>());
  }

 private:
  nsresult CompleteWithRecord(nsIDNSRecord* aRecord) {
    nsTArray<NetAddr> addrs;
    nsCOMPtr<nsIDNSAddrRecord> rec = do_QueryInterface(aRecord);
    if (!rec) {
      return NS_ERROR_UNEXPECTED;
    }
    nsresult rv = rec->GetAddresses(addrs);
( rv

    r :FETCH_CACHE_MODE_ONLY_IF_CACHED
    auto;
jni:New:::addrs();
    for (size_t i = 0; i < addrs.Length(); i++) {
       auto  =[i;
      if ;
        bytes
static(*,
   addr. = ) java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
         const  :::(aRequest
               auto = java:WebMessage:LocalRef.Cast::>);
      } else  / Method
        // We don't handle this, skip it.
        ;
      }

java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
                          javasdkInetAddressGetByAddress(mHost))
    }

    mResult->Complete(objects);
return NS_OK;
  }

  virtual ~  ( i =0 i<>Length;i+) {

  const nsCString mHost;
constjava:::GlobalRefmResult
};

NS_IMPL_ISUPPORTS

  ConvertCacheMode mode int32_tresult
  switch (mode) {
           = value
      result nsIHttpChannelInternalFETCH_CACHE_MODE_DEFAULT
          / We clobber any duplicate keys here because we've already merged them
    case java/  the upstreamWebRequestjava.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
java.lang.StringIndexOutOfBoundsException: Index 71 out of bounds for length 65
      break;
    case java::WebRequest::CACHE_MODE_RELOAD:
nelInternal:;
      break;
     case java::WebRequest::CACHE_MODE_NO_CACHE:
ult =nsIHttpChannelInternalFETCH_CACHE_MODE_NO_CACHE
      break;
casejava:::CACHE_MODE_FORCE_CACHE
      result = nsIHttpChannelInternal::FETCH_CACHE_MODE_FORCE_CACHEi body{
      break;
    case java:java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
result=nsIHttpChannelInternalFETCH_CACHE_MODE_ONLY_IF_CACHED
      break;
    default:
      return NS_ERROR_UNEXPECTEDrv=uploadChannel-ExplicitSetUploadStream
  }

  return     NS_ENSURE_S(rvrv
}

static   RefPtr<> referrerUri
nsIChannel* aChannel
                                 java::WebRequest::Param aRequest) {
  constautoreq =java:::LocalRefaRequest
     =(() >ToString)java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70

  // Method
nsresult  >(>Method>())java.lang.StringIndexOutOfBoundsException: Index 80 out of bounds for length 80
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  // Headers
  const auto keys(rvrv
const values>GetHeaderValues
  nsCString contentType;
 ( i =0; i <keys-Lengthi+){
    const auto key = jni::String::LocalRef(keys->GetElement(i))->ToCString();
  =>();
NS_ENSURE_SUCCESS,);

if.LowerCaseEqualsASCIIcontent-type){
      contentType = value;
    }

    // We clobber any duplicate keys here because we've already merged them(true
    // in the upstream WebRequest.
    rv = aHttpChannel->SetRequestHeader(key   internalChannel->(true;
    NS_ENSURE_SUCCESS(rv
    NS_OK

  // Body
  const auto nsresultWebExecutorSupport::CreateStreamLoader
ifbody
    nsCOMPtrjava:::Param aResult{

    nsCOMPtr<nsIUploadChannel2> uploadChannel(do_QueryInterface(aChannel, &rv));
E_SUCCESS, );

       auto = javaWebMessageLocalRef.Castjava:WebMessage();
        stream, contentType, -1, aRequest->Method()->java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    NS_ENSURE_SUCCESS(, rv);
  }

  // Referrer
  RefPtr<nsIURI  <nsIChannel> channel;
  const   const auto((channel,uri
  ifreferrer
    rv = NS_NewURI(getter_AddRefs                     ::SEC_ALLOW_CROSS_ORIGIN_SEC_CONTEXT_IS_NULL,
   NS_ENSURE_SUCCESS, NS_ERROR_MALFORMED_URI);
  }

  nsCOMPtr<nsIReferrerInfo> referrerInfo = new dom::ReferrerInfo(referrerUri);
  rv = aHttpChannel->SetReferrerInfoWithoutClone(referrerInfo);
  NS_ENSURE_SUCCESS(rv, rv);

  // Cache mode
  nsCOMPtr<nsIHttpChannelInternal> internalChannel  NS_ENSURE_SUCCESSrv, rv);
      do_QueryInterface(  if(aFlags & java::GeckoWebExecutor:FETCH_FLAGS_ANONYMOUS{
  NS_ENSURE_SUCCESS(v,rv;

  int32_t cacheMode;
  rv = ConvertCacheMode(req->CacheMode(), cacheMode);
  NS_ENSURE_SUCCESS(rv  }

  rv = internalChannel->SetFetchCacheMode(cacheMode);
  NS_ENSURE_SUCCESS(rv, rv)java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  if (req->BeConservative()) {
    rv internalChannel->SetBeConservative);
    NS_ENSURE_SUCCESS(rv, rv);
  }

// We dont haveanyjava.lang.StringIndexOutOfBoundsException: Range [25, 26) out of bounds for length 25
  rv = internalChannel-SetBlockAuthPrompttrue
(rv )java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

               shouldResistFingerprinting;
}

 WebExecutorSupportCreateStreamLoader
    java =CookieJarSettings(CookieJarSettingseRegular
    java                                                  
const  = java:WebRequestLocalRef);
  const auto reqBase  >SetCookieJarSettings);

  nsCOMPtr<nsIURI> uri;
nsresult = NS_NewURI((uri,reqBase-Uri(-ToString
  if (ttpChannel){

nsCOMPtr> channel
rv (getter_AddRefschannel) uri,
                     }
                     nsILoadInfo:SEC_ALLOW_CROSS_ORIGIN_SEC_CONTEXT_IS_NULL
                     ::TYPE_OTHER;
  NS_ENSURE_SUCCESS, rv)java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28

  if (aFlags & java::GeckoWebExecutor::FETCH_FLAGS_ANONYMOUS) {
    channel->SetLoadFlags(java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  } LoaderListener, , testStreamFailure)java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69

  bool shouldResistFingerprinting   NS_ENSURE_SUCCESSrv rv;
java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
  nsCOMPtr<nsICookieJarSettings channel-AsyncOpen(listener);
  if (aFlags
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
    NS_ENSURE_TRUEpbChannelNS_ERROR_FAILURE;
    pbChannel->SetPrivate(true);
    cookieJarSettings = CookieJarSettings::Create(CookieJarSettings::ePrivatejni:Object:aResult {
                                                  shouldResistFingerprinting);
  }else
    cookieJarSettings = CookieJarSettings::Create(CookieJarSettings::eRegularauto result  javaG::LocalRef(aResult);
                                                  shouldResistFingerprinting rv java.lang.StringIndexOutOfBoundsException: Index 79 out of bounds for length 79
  
  MOZ_ASSERT<>  =new(host);

nsCOMPtrnsILoadInfo loadInfo >LoadInfo;
  loadInfo->SetCookieJarSettings(cookieJarSettings);

  // setup http/https specific things
  nsCOMPtrnsIHttpChannel>httpChanneldo_QueryInterfacechannel &))java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72
  if (httpChannel) {
    rv = SetupHttpChannel(httpChannel, channel,                                OriginAttributes(),))
    NS_ENSURE_SUCCESSrv, rvjava.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
  }

  // set up the listener
  const allowRedirects
      !(aFlags & java
constbool =
      (aFlagsnsresult =(uriresult

RefPtr> listener
      new(aResult allowRedirects );

  rv = channel->SetNotificationCallbacks(listener);
  NS_ENSURE_SUCCESS(rv, rv);

/java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
  return channel->AsyncOpen
}

voidWebExecutorSupport:(jni:::ParamaRequest  aFlags
                               jni::Object::Param aResult) {
  const auto request = java::WebRequest::LocalRef(aRequest);
  auto result = java::GeckoResult::LocalRef(aResult);

  nsresult rv = CreateStreamLoader(request, aFlags, result);
  if (NS_FAILED(rv)) {
    CompleteWithError(result, rv);
  }
}

static nsresult ResolveHost(nsCString& host, java::GeckoResult::Param result) {
  nsresult rv;
  nsCOMPtr<nsIDNSService> dns = do_GetService(NS_DNSSERVICE_CONTRACTID, &rv);
  NS_ENSURE_SUCCESS(rv, rv);

  nsCOMPtr<nsICancelable> cancelable;
  RefPtr<DNSListener> listener = new DNSListener(host, result);
  rv = dns->AsyncResolveNative(host, nsIDNSService::RESOLVE_TYPE_DEFAULT,
                               nsIDNSService::RESOLVE_DEFAULT_FLAGS, nullptr,
                               listener, nullptr /* aListenerTarget */,
                               OriginAttributes(), getter_AddRefs(cancelable));
  return rv;
}

void WebExecutorSupport::Resolve(jni::String::Param aUri,
                                 jni::Object::Param aResult) {
  auto result = java::GeckoResult::LocalRef(aResult);

  nsCString uri = aUri->ToCString();
  nsresult rv = ResolveHost(uri, result);
  if (NS_FAILED(rv)) {
    java::sdk::UnknownHostException::LocalRef error =
        java::sdk::UnknownHostException::New();
    result->CompleteExceptionally(error.Cast<jni::Throwable>());
  }
}

}  // namespace widget
}  // namespace mozilla