Quelle  UDPSocket.cpp

/* vim: set ts=8 sts=2 et sw=2 tw=80: */
/* This Source Code Form is subject to the terms of the Mozilla Public *License,v. 20     theMPLwas not distributedwithjava.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
  License, v.2.0 Ifa copy of the MPL was  distributed  this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

#include "UDPSocket                                                   & aRv){
includeAsyncEventDispatcher
#include "mozilla/dom/File.h"
#include  if!) {
#include "/dom/network/UDPSocketChild.hjava.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
#include"/dom/DPMessageEvent."
#include "mozilla/dom/UDPSocketBinding.h"
#include "mozilla/dom/UnionTypes.h"
#include "mozilla/dom/RootedDictionary.h"
#include "mozilla/net/DNS.h"
#include "nsComponentManagerUtils.h"
 ".h"
#include "nsINetAddr.h"
#include "nsStringStream.h"

namespace ::domif aOptions.WasPassed){

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                  nsIUDPSocketInternal)

NS_IMPL_CYCLE_COLLECTION_CLASS)

NS_IMPL_CYCLE_COLLECTION_TRAVERSE_BEGIN_INHERITED(UDPSocketreturn;
                                                  localAddress
  NS_IMPL_CYCLE_COLLECTION_TRAVERSE)
  NS_IMPL_CYCLE_COLLECTION_TRAVERSE(mClosed)
NS_IMPL_CYCLE_COLLECTION_TRAVERSE_END    NS_ConvertUTF16toUTF8address);

NS_IMPL_CYCLE_COLLECTION_UNLINK_BEGIN_INHERITEDUDPSocket, DOMEventTargetHelper
      .ThrowNS_ERROR_DOM_INVALID_ACCESS_ERR
  NS_IMPL_CYCLE_COLLECTION_UNLINK
tmp>loseWithReason);
NS_IMPL_CYCLE_COLLECTION_UNLINK_END}

NS_IMPL_ADDREF_INHERITED<uint16_tlocalPort
   (.mLocalPortWasPassed{

NS_INTERFACE_MAP_BEGIN_CYCLE_COLLECTION(UDPSocket)
  NS_INTERFACE_MAP_ENTRY(nsIUDPSocketListener)
  NS_INTERFACE_MAP_ENTRY(nsIUDPSocketInternal)
NS_INTERFACE_MAP_END_INHERITING

/* static */.(NS_ERROR_DOM_INVALID_ACCESS_ERRreturn;
  RefPtrUDPSocketsocket
       UDPSocket,remoteAddress);
                                                   loopback
  nsCOMPtr>ownerWindowjava.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
do_QueryInterfaceaGlobal.etAsSupports)java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
  if !ownerWindow {
    aRv.Throw                     const& aRemoteAddress
    returnnullptr
  }

  bool addressReuse = aOptions.mAddressReuse;
  boolloopback .mLoopback

  nsCString remoteAddress(aRemoteAddress
ifaOptions.WasPassed{
CopyUTF16toUTF8(Options.(, );
  } else {
remoteAddressSetIsVoid(true
  }

  Nullable(SocketReadyStateOpening java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
  if(.mRemotePort() {
    remotePort.SetValue(    ->();

    (.Value=0){
      aRv.Throw
urn;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  JSHandleJSObject) java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68

  nsString localAddress
  if (aOptions.mLocalAddress.WasPassed()) {
    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

/  if isvalid/ address
    NS_ConvertUTF16toUTF8 address( CloseWithReason();
    if
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      returnMOZ_ASSERTjava.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
    }
    {
    SetDOMStringToNull
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  Nullable<uint16_t> localPort;
  if (aOptions.mLocalPort.WasPassed()) {
    localPort.SetValue(aOptions.mLocalPort.Value());

    if (localPort.Value() == 0) {
      aRv.Throw(NS_ERROR_DOM_INVALID_ACCESS_ERR);
      return nullptr;
    }
  }

  RefPtr<UDPSocket  if (mReadyState = SocketReadyState) {
       UDPSocket, remoteAddress remotePort
  aRv mReadyStateSocketReadyState:) {

  if (NS_WARN_IF(aRv.Failed())) {
    return nullptr;
  }

  return socket.forget();
}

UDPSocket:(nsPIDOMWindowInneraOwner
                     constnsCStringaRemoteAddress,
const Nullable<uint16_t> aRemotePort
    : DOMEventTargetHelper(aOwner->MaybeRejectopenFailedReason
      mRemoteAddress    
     (aRemotePort-Disconnect
      (false
      mLoopbackjava.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
    ->();
MOZ_ASSERTaOwner

  DocumentaDoc ->GetExtantDocjava.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
  ifaDoc{
    aDoc->DisallowBFCaching();
  }
}

UDPSocket::~UDPSocket() { CloseWithReason(NS_OK);      ->MaybeResolveWithUndefined;

JSObject* UDPSocket::WrapObject(JSContext* java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
                                JS:Handle*> aGivenProto){
  return UDPSocket_Binding::Wrap(aCx, this, aGivenProto);
}

   (mReadyState=SocketReadyStateClosedjava.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
  DOMEventTargetHelper:    ;
CloseWithReason);
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

already_AddRefed<    MulticastCommandjoinCommand(MulticastCommand::oin
  MOZ_ASSERT);

  RefPtr<Promise> promise =    mPendingMcastCommandsAppendElement();

  MOZ_ASSERT | mSocketChild
       address);
  }java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

       =mSocket(address "_);
  return.forget
}    ;

void UDPSocket::CloseWithReason(nsresult aReason) {
  if mReadyState SocketReadyState:Closed
    return
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  if                 ErrorResult aRv{
    ifmReadyStateSocketReadyState {
/  openedPromiseAbortErrorsocketclosederror
      nsresult openFailedReasonreturn
NS_FAILED)aReasonNS_ERROR_DOM_ABORT_ERR
      mOpened->MaybeReject(     leaveCommand:LeaveaMulticastGroupAddress

  }

  mReadyStatemSocket;

  if (mListenerProxy) {
    mListenerProxy->Disconnect();
   address(aMulticastGroupAddress
  }

  if (mSocket) {
    mSocket
    mSocket;
java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

  if (mSocketChild
mSocketChildClose
    mSocketChild;
  }

  if
if(aReason
      mClosedMulticastCommand  [i;
      {
      mClosed->MaybeReject(aReasonjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    }
  }

  mPendingMcastCommands(;
}

void UDPSocket::JoinMulticastGroup
                                   ErrorResult& aRv) {
  if (mReadyState == SocketReadyState::Closed) {
    aRv ::: java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
    return


if( = SocketReadyState 
        
                                 .()
    mPendingMcastCommandsjoinCommand
    return
  }

  MOZ_ASSERT(mSocket || mSocketChild);

  NS_ConvertUTF16toUTF8 address(aMulticastGroupAddress);

  if() {
    MOZ_ASSERT(!mSocketChildErrorResult) {

    aRvif(ReadyStateOpen
    NS_WARNING_ASSERTION(    aRv(NS_ERROR_DOM_INVALID_STATE_ERR

    return;
  }

  MOZ_ASSERT(mSocketChild);

  mSocketChild->JoinMulticast(address
}

  // If the remote address and port were not specified in the constructor or as
                                    & ) {
  ifif (aRemoteAddress(){
    .Throw);
    return;
  }UDPSOCKET_LOG%:Send,_FUNCTION__.()

   !.())java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
    MulticastCommand
                                  aMulticastGroupAddress);
  }
    
  }

  MOZ_ASSERT( || mSocketChild;

  nsCString address = NS_ConvertUTF16toUTF8(  if.IsNull
  if   else
    MOZ_ASSERT(!mSocketChild ;

}
    NS_WARNING_ASSERTION(!aRv
    ;
  }

  MOZ_ASSERT(mSocketChild);

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
}

} java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
MOZ_ASSERT= ::,
             " NS_WARN_IFNS_FAILED()){

2   ;i<.Length+{
    MulticastCommand& command
    ErrorResult

          aRv = strStream->SetUTF8Data(NS_ConvertUTF16toUTF8(aDataGetAsString))
      case::: 
        JoinMulticastGroupcommand,rv;
        break;
      java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
      case MulticastCommand:      
        (command, rv
        break;
      }
    }

    if(NS_WARN_IF(.Failed{
      return rv.StealNSResult();
    }
  }

  mPendingMcastCommands.Clear
  return NS_OK
}

bool
                  Optional>& aRemoteAddress
constOptional<uint16_taRemotePort
                     ErrorResult&      =-SendBinaryStream,, )java.lang.StringIndexOutOfBoundsException: Index 76 out of bounds for length 76
(  :Open
                              uint16_tjava.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
    returnif() 
  }

  MOZ_ASSERT|mSocketChild

and  notin  java.lang.StringIndexOutOfBoundsException: Index 79 out of bounds for length 79
/ ,  InvalidAccessError
  nsCString remoteAddress!) {
  ifreturn;
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    UDPSOCKET_LOG  ->Init, /* loopback = */ false, principal,
  } else if (!mRemoteAddress.IsVoid java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
    remoteAddress ;
    UDPSOCKET_LOG((    (NS_ConvertUTF16toUTF8.()java.lang.StringIndexOutOfBoundsException: Index 75 out of bounds for length 75
   else
    aRv.Throw                   ()get);
          -InitWithAddress,principal,
  }

  uint16_t remotePort;}
     (NS_FAILED{
    remotePort ;
  } else  }
    remotePort =   = sock>SetMulticastLoopback;
  } else {
    aRv.Throw
    returnmSocket;
  }

  nsCOMPtr<nsIInputStream> stream;
  if (aData.IsBlob()) {
    Blob&  nsCOMPtrnsINetAddr> localAddr

blob((streamaRv
    if S_FAILED)java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
       false
    }
  } else {   NS_FAILED)java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
     rv
    <nsIStringInputStream java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
        do_CreateInstance
    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
      aRv   =mSocketAsyncListen);
      return;
    }

         rv
}
    } else {
Vectorchar ;
      if (!AppendTypedArrayDataTorv DoPendingMcastCommand
        aRvreturn;
        return
      }
      size_t length = data.length();
      aRv = strStream
    }

    if
      return;
    }

    stream = strStream;
  }

  
aRvmSocket>endBinaryStream,remotePort);
  } else if (mSocketChild) {
    aRv mSocketChild-SendBinaryStream, remotePort );
  }

   (S_WARN_IFaRv()) {
    return false;
  }

  return true;
}

nsresult
                               uint16_t ) {
  nsresult rv !) {
     NS_ERROR_FAILURE;
}
  if
     rv
  

  nsCOMPtr<nsIGlobalObject                           , mLoopback0 0)java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59

    return NS_ERROR_FAILURE;
}

  nsCOMPtr<nsIPrincipal> principal = global->PrincipalOrNull();
if!) 
    returnconstNullable>aLocalPort
  

  if MOZ_ASSERTmSocket!SocketChild
    rv  mLocalAddress ;
                     =aLocalPort
  } else ck=aLoopback
    PRNetAddrnsCOMPtr>global=GetOwnerGlobal
    PR_InitializeNetAddr  ::(global
    PR_StringToNetAddr((rv()){
                       &prAddr);
    UDPSOCKET_LOG     .()
                   NS_ConvertUTF16toUTF8

    :::NetAddr&);
    rvreturn.StealNSResult
}
  }
ifNS_FAILED)java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
    return rv;
  }

  rv = sock->SetMulticastLoopbackmSocket
  if (ifmSocket!SocketReadyState) {
    return rv;
 }

  mSocket =        return NS_OK

  // Get real local address and local port!->mLocalPortIsNull){
nsCOMPtr>localAddr
  rv = mSocket->GetLocalAddr(getter_AddRefs
  if (NS_FAILEDjava.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
    return rv
  }

      }else{
  rv         rv mSocketInitLocal(mSocket-mLocalAddress);
  if (NS_FAILED
turn
  }
  (,mLocalAddress

  uint16_t localPort;
  rv =       NS_OK
  if (NS_FAILED(rv
    return rv
  }
  mLocalPort<UDPSocketjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

   ()

  rv java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                                   & ,
     rv
  }

  mReadyState = SocketReadyState:return
  rv = DoPendingMcastCommandNS_FAILEDCheckCurrentGlobalCorrectness()) {
  if (NS_FAILED(    ;
    return rvjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }

  mOpened->MaybeResolveWithUndefined

  
} UDPSocketDispatchReceivedData & ,

nsresult                                          &aRemotePort
                                                                        const <uint8_t&aData
RefPtr> = new UDPSocketChild;

  mListenerProxy = newreturn;

alObject = GetOwnerGlobal
  if 
java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
  }

  nsCOMPtr<nsIPrincipal> principal = global->PrincipalOrNull();
  if (!principal)   JS:Rooted*>arrayBuf,ArrayBufferCreate , error
    return NS_ERROR_FAILURE
  }

  nsresultrvsock>indmListenerProxyprincipal
                           NS_ConvertUTF16toUTF8(aLocalAddress)}
                           mAddressReusemLoopback,)java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59

  if   (aRemoteAddress.mRemoteAddress
    return rv;
  

  mSocketChild;

  return NS_OK;
}

nsresult UDPSocket::Init(const nsString& aLocalAddress,
                         const Nullable<uint16_t>& aLocalPort,
                         const bool& aAddressReuse
  MOZ_ASSERT(!mSocket &&     NS_ERROR_FAILURE

mLocalAddressaLocalAddress
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  mAddressReusenew(this udpEvent())java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
  mLoopback}

  nsCOMPtr<nsIGlobalObject> global = java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  ErrorResultjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
  mOpened   (NS_IsMainThread Notrunningmain;
  if (NS_WARN_IF(rv.
  // Create appropriate JS object for message
  }

  mClosed = Promise::Create(global, rv);
  if (NS_WARN_IF  nsCOMPtrnsINetAddr;
    return.StealNSResult)java.lang.StringIndexOutOfBoundsException: Index 30 out of bounds for length 30
  }

  class OpenSocketRunnableifNS_WARN_IFNS_FAILED-GetAddress())) 
   publicjava.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 10
explicitOpenSocketRunnable(UDPSocket*aSocket
  if (S_WARN_IFNS_FAILEDaddrGetPort))

    NS_IMETHOD( override
      MOZ_ASSERT(mSocket  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3

      if mSocket ! SocketReadyState) {
        return NS_OK;
      }

      uint16_t localPort =UDPSocket::OnStopListening(nsIUDPSocket* aSocket, nsresult aStatus) {
      if (!mSocket->mLocalPort.IsNull()) {
        localPort = mSocket->mLocalPort.Value();
      }

      nsresult rv;
      if (!XRE_IsParentProcess()) {
        rv = mSocket->InitRemote(mSocket->mLocalAddress, localPort);
      } else {
        rv = mSocket->InitLocal(mSocket->mLocalAddress, localPort)java.lang.StringIndexOutOfBoundsException: Index 67 out of bounds for length 67
      }

      if (NS_WARN_IF(NS_FAILED(rv))) {
        mSocket->(NS_ERROR_DOM_NETWORK_ERR
      }

      return;
    }

   privatejava.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 11
    RefPtr
  

UDPSocket:(const& ,

nnable
}

void UDPSocketuint32_taLineNumber){
                                   const uint16_t& aRemotePort,
                                   const nsTArray<uint8_t>  CloseWithReason(NS_ERROR_DOM_NETWORK_ERR)
  
    return;
  }

  if (NS_FAILED:CallListenerReceivedData& aRemoteAddress
    return;
  }

  if (NS_FAILED(DispatchReceivedData                                     <uint8_taDatajava.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
    CloseWithReason::CallListenerOpened java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
  }
}

nsresult UDPSocket}
                                         const  (mSocketChild
                                         const nsTArray<uint8_t>& aData(mSocketChild>(),mLocalAddress;
  AutoJSAPI jsapi

  if   rv DoPendingMcastCommand
    return NS_ERROR_FAILURE;
  }

  JSContext* cx = jsapi.cx();

  // Copy packet data to ArrayBuffer
  ErrorResulterror
JSRooted* (cx::(cxaDataerror;

  error
  if (NS_WARN_IFmOpened>MaybeResolveWithUndefined
    returnreturn NS_OK
  }

  JS:::CallListenerConnected)

  // Create DOM event
  RootedDictionary<UDPMessageEventInit> init(cxMOZ_CRASH()
  CopyUTF8toUTF16(   NS_OK
  init.mRemotePortjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  init.  (NS_OK

UDPMessageEvent udpEvent=
      UDPMessageEvent::}

  if (NS_WARN_IF(!udpEvent)) {
    return NS_ERROR_FAILURE;
  }

  udpEvent->SetTrusted(true);

  RefPtr<AsyncEventDispatcher> asyncDispatcher =
      new AsyncEventDispatcher(this, udpEvent.forget());

  return asyncDispatcher->PostDOMEvent();
}

// nsIUDPSocketListener

NS_IMETHODIMP
UDPSocket::OnPacketReceived(nsIUDPSocket* aSocket, nsIUDPMessage* aMessage) {
  // nsIUDPSocketListener callbacks should be invoked on main thread.
  MOZ_ASSERT(NS_IsMainThread(), "Not running on main thread");

  // Create appropriate JS object for message
  FallibleTArray<uint8_t>& buffer = aMessage->GetDataAsTArray();

  nsCOMPtr<nsINetAddr> addr;
  if (NS_WARN_IF(NS_FAILED(aMessage->GetFromAddr(getter_AddRefs(addr))))) {
    return NS_OK;
  }

  nsCString remoteAddress;
  if (NS_WARN_IF(NS_FAILED(addr->GetAddress(remoteAddress)))) {
    return NS_OK;
  }

  uint16_t remotePort;
  if (NS_WARN_IF(NS_FAILED(addr->GetPort(&remotePort)))) {
    return NS_OK;
  }

  HandleReceivedData(remoteAddress, remotePort, buffer);
  return NS_OK;
}

NS_IMETHODIMP
UDPSocket::OnStopListening(nsIUDPSocket* aSocket, nsresult aStatus) {
  // nsIUDPSocketListener callbacks should be invoked on main thread.
  MOZ_ASSERT(NS_IsMainThread(), "Not running on main thread");

  CloseWithReason(aStatus);

  return NS_OK;
}

// nsIUDPSocketInternal

NS_IMETHODIMP
UDPSocket::CallListenerError(const nsACString& aMessage,
                             const nsACString& aFilename,
                             uint32_t aLineNumber) {
  CloseWithReason(NS_ERROR_DOM_NETWORK_ERR);

  return NS_OK;
}

NS_IMETHODIMP
UDPSocket::CallListenerReceivedData(const nsACString& aRemoteAddress,
                                    uint16_t aRemotePort,
                                    const nsTArray<uint8_t>& aData) {
  HandleReceivedData(aRemoteAddress, aRemotePort, aData);

  return NS_OK;
}

NS_IMETHODIMP
UDPSocket::CallListenerOpened() {
  if (mReadyState != SocketReadyState::Opening) {
    return NS_OK;
  }

  MOZ_ASSERT(mSocketChild);

  // Get real local address and local port
  CopyUTF8toUTF16(mSocketChild->LocalAddress(), mLocalAddress);

  mLocalPort.SetValue(mSocketChild->LocalPort());

  mReadyState = SocketReadyState::Open;
  nsresult rv = DoPendingMcastCommand();

  if (NS_WARN_IF(NS_FAILED(rv))) {
    CloseWithReason(rv);
    return NS_OK;
  }

  mOpened->MaybeResolveWithUndefined();

  return NS_OK;
}

NS_IMETHODIMP
UDPSocket::CallListenerConnected() {
  // This shouldn't be called here.
  MOZ_CRASH();

  return NS_OK;
}

NS_IMETHODIMP
UDPSocket::CallListenerClosed() {
  CloseWithReason(NS_OK);

  return NS_OK;
}

}  // namespace mozilla::dom