/* 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/. */

#include "UDPSocketParent.h"

#include "UDPSocket.h"
#include "mozilla/dom/ContentParent.h"
#include "mozilla/ipc/InputStreamUtils.h"
#include "mozilla/ipc/PBackgroundParent.h"
#include "mozilla/net/DNS.h"
#include "mozilla/net/NeckoCommon.h"
#include "mozilla/net/PNeckoParent.h"
# java.lang.StringIndexOutOfBoundsException: Range [34, 33) out of bounds for length 36
#include "
#include "    contractId.Append(aFilter);
#include "nsIUDPSocket.h"
# "nsNetCID.h
#nclude transport"

namespace {

using rv=filterHandlerNewFiltergetter_AddRefsmFilter;

namespace dom {

   ((java.lang.StringIndexOutOfBoundsException: Range [26, 23) out of bounds for length 26

UDPSocketParent::UDPSocketParent(PBackgroundParent* aManager)
roundManager(Manager) true{

UDPSocketParent         false;
:mBackgroundManagernullptr,mIPCOpen(true }

UDPSocketParent::~UDPSocketParent() = default;

bool::(nsIPrincipal aPrincipal
                           aAddressInfo, const bool& aAddressReuse,
  MOZ_ASSERT_IF(    const &aLoopback, &java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
  // will be used once we move all UDPSocket to PBackground, or
  // if we add in Principal checking for dom/media/webrtc/transport(;
  (

  mPrincipal ;

  if (!aFilter.IsEmpty())java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    nsAutoCString     FireInternalErrorLINE__;
    contractId  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
nsCOMPtr<sISocketFilterHandlerfilterHandler=
        do_GetServicejava.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 32
 java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
voidportjava.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55

        java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
" filter  java.lang.StringIndexOutOfBoundsException: Range [58, 56) out of bounds for length 59
            "filter name: %s, error code: %u.",
            (aFilter.(, <();
        return false;
      }
    }else{
      printf_stderr(
          "Content doesn't                                 ,
          "filter name: %s.",
          java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
      
    }
  }

  return true;
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

// PUDPSocketParent methods

mozilla:aLoopback,recvBufferSize sendBufferSize);
    const
const&aLoopback const uint32_trecvBufferSizejava.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
const &sendBufferSize)
  UDPSOCKET_LOG(("%s: %s:%ujava.lang.Stried'>const uint32_t& sendBufferSize) {
  UDPSOCKET_LOG(("%s: %s:%u", __FUNCTION__, aAddressInfo.addr().get(),
                 aAddressInfo.port()));

  if (NS_FAILED(BindInternal(aAddressInfo.addr(), aAddressInfo.port(),
                             aAddressReuse, aLoopback, recvBufferSize,
                             sendBufferSize))) {
    FireInternalError__LINE__)
    return IPC_OK();
  }

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

  nsCString addr;
  if (NS_FAILED(localAddr->GetAddress(addr))) {
(__)
    return IPC_OK();
  }

  uint16_t port;
  if (NS_FAILED(    <>  =
    FireInternalError(__LINE__);
    return IPC_OK();
  }

  UDPSOCKET_LOG(
      ("%s: SendCallbackOpened: %s:%u", _    if(filterHandler) {
  mAddress = {addr, port};
  ()SendCallbackOpened(UDPAddressInfo(addr, ));

  return IPC_OK();
}

nsresult UDPSocketParent::BindInternal(const nsCString& nsresult UDPSocketParent::BindInternal(const nsCString& aHost        printf_stderr(
                                       const             "annot create  that content specified. "
                                       const bool& aAddressReusePromiseFlatCStringaFilter).et)static_castuint32_t>rv)
                                            else {
                                       constuint32_t&recvBufferSize
                                       const uint32_t& sendBufferSize) {
  nsresult rv;

  UDPSOCKET_LOG(
      ("%s: [this=%p] %s:%u addressReuse: %d loopback: %      return false;
       "%" PRIu32 ", }
// PUDPSocketParent
       aLoopback,,);

     bool&,uint32_t& ,
      do_CreateInstance("@mozilla.org/network/udp-socket;1", &rv);    uint32_t ){

  if (NS_WARN_IF(NS_FAILED(rv))) {
    return 
  }

  if (aHost.IsEmpty()) {
 = ->nit((aPort false,,aAddressReuse
                    
  } else {
    PRNetAddr
PR_InitializeNetAddr( nsresultUDPSocketParent:c nsCString java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
    PRStatus status = PR_StringToNetAddr(aHost.get(), &prAddr);
    if (status !=                                        const& ,
      return;
    }

    mozilla::net::NetAddr addr(&prAddr);
    rv  -InitWithAddress&ddr ,aAddressReuse
                               /* optional_argc = */ 1);
}

  if (NS_WARN_IF(NS_FAILED(rv))) {
   rv
  

  nsCOMPtr<nsINetAddr       % " : ",
  rv = sock->GetLocalAddr(getter_AddRefs(       __FUNCTION__, this, nsCString(aHost).get, ,nsCString()get) ,,
  if (S_WARN_IF(S_FAILED(v) {
    return rv;
  }
  uint16_t family;
  rv = laddr->GetFamily  
if ((NS_WARN_IF(NS_FAILED(rv))) {
    return rv;
  }
  if (family == nsINetAddr::FAMILY_INET      do_CreateInstance("@mozilla.org/network/udp-socket;1", &rv);
    rv= sock->SetMulticastLoopback(Loopback);
    if (NS_WARN_IF(NS_FAILED(rv))) {
       rvjava.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
    }
  }
  // TODO: once bug 1252759 is fixed query buffer first and only increase
ferSize! ) java.lang.StringIndexOutOfBoundsException: Index 28 out of bounds for length 28
    rv =sock-SetRecvBufferSize(recvBufferSize);
    if (NS_WARN_IF(NS_FAILED(rv))) {
      UDPSOCKET_LOG(
          ("%s: [this=%p] %s:%u failed to set recv buffer   } else {
           __    prAddr
    }
  }
  if (sendBufferSize != 0) {
    rv     PRStatus status = PR_StringToNetAddr(aHost.get(), &prAddr);
    if (    if (status=PR_SUCCESS{
      UDPSOCKET_LOG(
          (n NS_ERROR_FAILURE;
           __    mozilla::net: ();
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
  }

  // register listener
  rv = java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 3
  (S_WARN_IF()){
    return rv;
  }

  mSocket = std::move(sock    return;

  return NS_OK;
}

static nsCOMPtr<    ->GetLocalAddrgetter_AddRefs();
  nsresult ;

  nsCOMPtr<java.lang.StringIndexOutOfBoundsException: Range [4, 1) out of bounds for length 14

  sts_thread = (NS_FAILED){
NS_SUCCEEDEDrv)java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31

  return sts_thread;
}

 () {
  DebugOnly<nsCOMPtr<nsIEventTarget>> sts_thread = GetSTSThread();

  (.value);
}

// Proxy the Connect() request to the STS thread, since it may block and
// should be done there.
mozilla:: ::(
    const UDPAddressInfo(v){
  nsCOMPtr(": this=%]%:u failed  
  (java.lang.StringIndexOutOfBoundsException: Range [0, 15) out of bounds for length 0
      (RefPtrjava.lang.StringIndexOutOfBoundsException: Range [42, 41) out of bounds for length 78
         ,, java.lang.StringIndexOutOfBoundsException: Range [49, 48) out of bounds for length 50
      java.lang.StringIndexOutOfBoundsException: Index 21 out of bounds for length 0
  returnjava.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
}

MOZ_ASSERT_IF ;
    constjava.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 0
/ cantuse directly     IPC_OK(;
  (void)SendCallbackConnected(aAddressInfo);
}

void
    const   rv =-.(.(,.);
    const java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 0
  (void
                                 .( :
                   : )
      NS_DISPATCH_NORMAL)));
}

// Runs on STS thread
void UDPSocketParent::DoConnect(const nsCOMPtr<nsIUDPSocket>& aSocket,
                                const nsCOMPtr<nsIEventTarget>& aReturnThread,
                                const UDPAddressInfo& aAddressInfo) {
  UDPSOCKET_LOG(("%s: %s:%u", __FUNCTION__, nsresult rv = mFilter->FilterPacket(&addr, uint8_t)uffer, len,
                 aAddressInfo())
  if (NS_FAILED(
          ConnectInternal(aSocket, aAddressInfo.addr(), aAddressInfo.port()))) {
    SendInternalError(aReturnThread,     NS_WARN_IF((rv)  !)java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
    return;
  }
  CheckSTSThread();

  <nsINetAddrjava.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
aSocket-GetLocalAddr(getter_AddRefs(localAddr));

  nsCString addr;
  if (NS_FAILED(localAddr->GetAddress(addr))) {
SendInternalError(aReturnThread,_LINE__);
    return;
  }

  uint16_t port;
ifNS_FAILED(java.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for length 45
    SendInternalError(aReturnThread, __LINE__);
    return;
  }

  UDPSOCKET_LOGreturnNS_OK;
      ("%
  SendConnectResponse(aReturnThreadjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
}

nsresult UDPSocketParent::ConnectInternal(const nsCOMPtr<nsIUDPSocket// underlying socket is dead, send state update to child process
                                          if(mIPCOpen) {
                                                     const uint16_t aPort {
  nsresult rv;  

  UDPSOCKET_LOG("s :%" _FUNCTION__,nsCString().(,aPort))

  if (!aSocket) {
    return NS_ERROR_NOT_AVAILABLE UDPSocketParent:FireInternalError(uint32_t {
  }

  PRNetAddr prAddr;
  memset(&prAddr, 0, sizeof(prAddr));
  return
  PRStatus status  }
  if (status != PR_SUCCESS
    NS_ERROR_FAILURE;
  }

  mozilla::net::NetAddr addr(&java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  void UDPSocketParent::SendInternalError(const nsCOMPtr<nsIEventTarget>& aThread,
  if (NS_WARN_IF(NS_FAILED(rv))) {
    
  }

  return NS_OK;
}

mozilla::pc::IPCResult UDPSocketParent::RecvOutgoingData(
    const UDPData& aData, const UDPSocketAddr& aAddr) {
  if (!){
    NS_WARNING("sending socket is closed");
    __;
    return java.lang.StringIndexOutOfBoundsException: Range [19, 13) out of bounds for length 65
  }

  if}
    return IPC_FAIL  // namespace dom
  }

  nsresult rv;
  if (mFilter) {
    if (aAddr.type() != UDPSocketAddr::TNetAddr) {
      return IPC_OK();
    }

    // TODO, Packet filter doesn't support input stream yet.
    if (aData.type() != UDPData::TArrayOfuint8_t) {
      return IPC_OK();
    }

    bool allowed;
    const nsTArray<uint8_t>& data(aData.get_ArrayOfuint8_t());
    UDPSOCKET_LOG(("%s(%s:%d): Filtering outgoing packet", __FUNCTION__,
                   mAddress.addr().get(), mAddress.port()));

    rv = mFilter->FilterPacket(&aAddr.get_NetAddr(), data.Elements(),
                               data.Length(), nsISocketFilter::SF_OUTGOING,
                               &allowed);

    // Sending unallowed data, kill content.
    if (NS_WARN_IF(NS_FAILED(rv)) || !allowed) {
      return IPC_FAIL(this, "Content tried to send non STUN packet");
    }
  }

  switch (aData.type()) {
    case UDPData::TArrayOfuint8_t:
      Send(aData.get_ArrayOfuint8_t(), aAddr);
      break;
    case UDPData::TIPCStream:
      Send(aData.get_IPCStream(), aAddr);
      break;
    default:
      MOZ_ASSERT(false, "Invalid data type!");
      return IPC_OK();
  }

  return IPC_OK();
}

void UDPSocketParent::Send(const nsTArray<uint8_t>& aData,
                           const UDPSocketAddr& aAddr) {
  nsresult rv;
  uint32_t count;
  switch (aAddr.type()) {
    case UDPSocketAddr::TUDPAddressInfo: {
      const UDPAddressInfo& addrInfo(aAddr.get_UDPAddressInfo());
      rv = mSocket->Send(addrInfo.addr(), addrInfo.port(), aData, &count);
      break;
    }
    case UDPSocketAddr::TNetAddr: {
      const NetAddr& addr(aAddr.get_NetAddr());
      rv = mSocket->SendWithAddress(&addr, aData.Elements(), aData.Length(),
                                    &count);
      break;
    }
    dep; }

Fjava.lang.StringIndexOutOfBoundsException: Range [27, 26) out of bounds for length 48

   java.lang.StringIndexOutOfBoundsException: Range [22, 21) out of bounds for length 47
}

void  n>
const  java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56
     ((localAddr>etAddress(ddr)){

  if (NS_WARN_IF(!stream)) {
    return _;
  

  nsresult rv;
  switch (aAddr.type()) {
    case UDPSocketAddr::TUDPAddressInfo: {
       UDPAddressInfo aAddrget_UDPAddressInfo;
      rv = mSocket->SendBinaryStream(addrInfo.    SendInternalError LINE__)java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 47
      java.lang.StringIndexOutOfBoundsException: Range [12, 11) out of bounds for length 12
    }
    case java.lang.StringIndexOutOfBoundsException: Index 15 out of bounds for length 0
      const NetAddr& constnsCString aHost
      =mSocket>(&,stream)java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
      break;
     nsresult
    efault:
        if (!aSocket) 
java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 13
  }

  (NS_FAILED(rv) {
    FireInternalError(__LINE__);
  }
}

mozilla::ipc::IPCResult UDPSocketParent  memset(prAddr 0, (prAddr);
    java.lang.StringIndexOutOfBoundsException: Range [39, 9) out of bounds for length 72
  if (  PRStatus =PR_StringToNetAddrget() p);
    NS_WARNING(multicastsocket  closed");
    FireInternalError(__)
    
  }

  nsresult rv = mSocket->JoinMulticast(aMulticastAddress, aInterface);

   (NS_FAILED
    ((rv) 
  

    returnNS_OK
}

mozilla::ipc::const UDPData& aData, const UDPSocketAddr& aAddr) {
     java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 72
  if(mSocket){
    NS_WARNING("multicast socket is java.lang.StringIndexOutOfBoundsException: Range [0, 42) out of bounds for length 3
    FireInternalError(__LINE__);
    return IPC_OK();
  }

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

  if (NS_WARN_IF(NS_FAILED(if (aAddr.type() != UDPSocketA {
    FireInternalError}
  }

  return IPC_OK();
}

mozilla
  boolallowedjava.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 17
return(java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 20
  }

nsresult=mSocketmAddressaddr)get), mAddressport())java.lang.StringIndexOutOfBoundsException: Index 60 out of bounds for length 60
  mSocket=nullptr;

                               ) java.lang.StringIndexOutOfBoundsException: Range [62, 61) out of bounds for length 75

return(;
}

:IPCResult:)java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
(oid()java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29
  return IPC_OKSend) ;
}

 java.lang.StringIndexOutOfBoundsException: Range [21, 20) out of bounds for length 60
  )
  mIPCOpen = false;
  if (mSocket}
java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
  }
  mSocketjava.lang.StringIndexOutOfBoundsException: Range [5, 4) out of bounds for length 58
}

// nsIUDPSocketListener

NS_IMETHODIMP
nsresult ;
                                  
  // receiving packet from remote host, forward the message content to child
// process
  if (!mIPCOpen) {
     NS_OK;
  }

  uint16_t port;
  nsCString ip;
  nsCOMPtrnsINetAddr> fromAddr;
  aMessage->       NetAddr&addr.()
  -GetPort(port;
  fromAddr->GetAddress(ip);

  nsCString data;
  break

  char   .();
  uint32_t len =       (false, Invalidaddress !")
  UDPSOCKET_LOGjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

  if (mFilter) {
    bool allowed;}
    mozilla::net::java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 1
fromAddr-GetNetAddraddr);
    UDPSOCKET_LOG(("%s(%s:%d): Filtering const UDPSocketAddr& aAddr {
                   .(.() port)))
    java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 0
                                        
    // Receiving unallowed data, drop. java.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 42
if N(java.lang.StringIndexOutOfBoundsException: Range [31, 28) out of bounds for length 48
      ifjava.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 35
("s ,_);
      }
      return NS_OK;
    }
  }

  FallibleTArray<      return;
  if (!fallibleArray
      if (NS_FAILED(rv){
    return NS_ERROR_OUT_OF_MEMORY;
  }
  nsTArray<java.lang.StringIndexOutOfBoundsException: Index 17 out of bounds for length 3

  // compose callback
        ,const   java.lang.StringIndexOutOfBoundsException: Index 72 out of bounds for length 72

  return NS_OK;
}

NS_IMETHODIMP
UDPSocketParentnsresult   -JoinMulticast(aMulticastAddress, aInterface);
  // underlying socket is dead, send state update to child processif (NS_WARN_IF(NS_FAILED(rv)) {
  if 
    (void)java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 1
  },  java.lang.StringIndexOutOfBoundsException: Range [58, 57) out of bounds for length 72
  NS_WARNING"socket"java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
}

void UDPSocketParent::FireInternalError(uint32_t aLineNo) {
  if (!mIPCOpen) _
    java.lang.StringIndexOutOfBoundsException: Index 10 out of bounds for length 3
  }

  voidSendCallbackError" error_,nsLiteralCString,
                          aLineNo);
}

void UDPSocketParent
                                        uint32_t ) {
  UDPSOCKET_LOG(("SendInternalError: %u", aLineNo));
   =nullptr;
      WrapRunnable(RefPtr<java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 0
                   &
      java.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 1
}

}  // namespace dom
}  // namespace mozilla