The Tor Browser: netwerk/protocol/rtsp/RtspChannelChild.cpp@a63d609f5ebe (annotated)

netwerk/protocol/rtsp/RtspChannelChild.cpp@a63d609f5ebe (annotated)

netwerk/protocol/rtsp/RtspChannelChild.cpp

Thu, 15 Jan 2015 15:55:04 +0100

author: Michael Schloh von Bennewitz <michael@schloh.com>
date: Thu, 15 Jan 2015 15:55:04 +0100
branch: TOR_BUG_9701
changeset 9: a63d609f5ebe
permissions: -rw-r--r--

Back out 97036ab72558 which inappropriately compared turds to third parties.

 /* -*- 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/. */
 #include "RtspChannelChild.h"
 #include "mozilla/ipc/URIUtils.h"
 using namespace mozilla::ipc;
 namespace mozilla {
 namespace net {
 //-----------------------------------------------------------------------------
 // RtspChannelChild
 //-----------------------------------------------------------------------------
 RtspChannelChild::RtspChannelChild(nsIURI *aUri)
   : mIPCOpen(false)
   , mCanceled(false)
 {
   nsBaseChannel::SetURI(aUri);
 }
 RtspChannelChild::~RtspChannelChild()
 {
 }
 nsIStreamingProtocolController*
 RtspChannelChild::GetController()
 {
   return mMediaStreamController;
 }
 void
 RtspChannelChild::ReleaseController()
 {
   if (mMediaStreamController) {
     mMediaStreamController = nullptr;
   }
 }
 //-----------------------------------------------------------------------------
 // IPDL
 //-----------------------------------------------------------------------------
 void
 RtspChannelChild::AddIPDLReference()
 {
   NS_ABORT_IF_FALSE(!mIPCOpen,
                     "Attempt to retain more than one IPDL reference");
   mIPCOpen = true;
   AddRef();
 }
 void
 RtspChannelChild::ReleaseIPDLReference()
 {
   NS_ABORT_IF_FALSE(mIPCOpen, "Attempt to release nonexistent IPDL reference");
   mIPCOpen = false;
   Release();
 }
 //-----------------------------------------------------------------------------
 // nsISupports
 //-----------------------------------------------------------------------------
 NS_IMPL_ISUPPORTS_INHERITED(RtspChannelChild,
                             nsBaseChannel,
                             nsIChannel,
                             nsIChildChannel)
 //-----------------------------------------------------------------------------
 // nsBaseChannel::nsIChannel
 //-----------------------------------------------------------------------------
 NS_IMETHODIMP
 RtspChannelChild::GetContentType(nsACString& aContentType)
 {
   aContentType.AssignLiteral("RTSP");
   return NS_OK;
 }
 class CallListenerOnStartRequestEvent : public nsRunnable
 {
 public:
   CallListenerOnStartRequestEvent(nsIStreamListener *aListener,
                                   nsIRequest *aRequest, nsISupports *aContext)
     : mListener(aListener)
     , mRequest(aRequest)
     , mContext(aContext)
   {
     MOZ_RELEASE_ASSERT(aListener);
   }
   NS_IMETHOD Run()
   {
     MOZ_ASSERT(NS_IsMainThread());
     mListener->OnStartRequest(mRequest, mContext);
     return NS_OK;
   }
 private:
   nsRefPtr<nsIStreamListener> mListener;
   nsRefPtr<nsIRequest> mRequest;
   nsRefPtr<nsISupports> mContext;
 };
 NS_IMETHODIMP
 RtspChannelChild::AsyncOpen(nsIStreamListener *aListener, nsISupports *aContext)
 {
   // Precondition checks.
   MOZ_ASSERT(aListener);
   nsCOMPtr<nsIURI> uri = nsBaseChannel::URI();
   NS_ENSURE_TRUE(uri, NS_ERROR_ILLEGAL_VALUE);
   // Create RtspController.
   nsCOMPtr<nsIStreamingProtocolControllerService> mediaControllerService =
     do_GetService(MEDIASTREAMCONTROLLERSERVICE_CONTRACTID);
   MOZ_RELEASE_ASSERT(mediaControllerService,
     "Cannot proceed if media controller service is unavailable!");
   mediaControllerService->Create(this, getter_AddRefs(mMediaStreamController));
   MOZ_ASSERT(mMediaStreamController);
   // Add ourselves to the load group.
   if (mLoadGroup) {
     mLoadGroup->AddRequest(this, nullptr);
   }
   // Dispatch mListener's OnStartRequest directly. mListener is expected to
   // create an RtspMediaResource and use the RtspController we just created to
   // manage the control and data streams to and from the network.
   mListener = aListener;
   mListenerContext = aContext;
   NS_DispatchToMainThread(
     new CallListenerOnStartRequestEvent(mListener, this, mListenerContext));
   return NS_OK;
 }
 //-----------------------------------------------------------------------------
 // nsBaseChannel::nsIStreamListener::nsIRequestObserver
 //-----------------------------------------------------------------------------
 NS_IMETHODIMP
 RtspChannelChild::OnStartRequest(nsIRequest *aRequest, nsISupports *aContext)
 {
   MOZ_CRASH("Should never be called");
 }
 NS_IMETHODIMP
 RtspChannelChild::OnStopRequest(nsIRequest *aRequest, nsISupports *aContext,
                                 nsresult aStatusCode)
 {
   MOZ_CRASH("Should never be called");
 }
 //-----------------------------------------------------------------------------
 // nsBaseChannel::nsIStreamListener
 //-----------------------------------------------------------------------------
 NS_IMETHODIMP
 RtspChannelChild::OnDataAvailable(nsIRequest *aRequest,
                                   nsISupports *aContext,
                                   nsIInputStream *aInputStream,
                                   uint64_t aOffset,
                                   uint32_t aCount)
 {
   MOZ_CRASH("Should never be called");
 }
 //-----------------------------------------------------------------------------
 // nsBaseChannel::nsIChannel::nsIRequest
 //-----------------------------------------------------------------------------
 class CallListenerOnStopRequestEvent : public nsRunnable
 {
 public:
   CallListenerOnStopRequestEvent(nsIStreamListener *aListener,
                                  nsIRequest *aRequest,
                                  nsISupports *aContext, nsresult aStatus)
     : mListener(aListener)
     , mRequest(aRequest)
     , mContext(aContext)
     , mStatus(aStatus)
   {
     MOZ_RELEASE_ASSERT(aListener);
   }
   NS_IMETHOD Run()
   {
     MOZ_ASSERT(NS_IsMainThread());
     mListener->OnStopRequest(mRequest, mContext, mStatus);
     return NS_OK;
   }
 private:
   nsRefPtr<nsIStreamListener> mListener;
   nsRefPtr<nsIRequest> mRequest;
   nsRefPtr<nsISupports> mContext;
   nsresult mStatus;
 };
 NS_IMETHODIMP
 RtspChannelChild::Cancel(nsresult status)
 {
   if (mCanceled) {
     return NS_OK;
   }
   mCanceled = true;
   // Stop RtspController.
   if (mMediaStreamController) {
     mMediaStreamController->Stop();
   }
   // Call mListener's OnStopRequest to do clean up.
   NS_DispatchToMainThread(
     new CallListenerOnStopRequestEvent(mListener, this,
                                        mListenerContext, status));
   mListener = nullptr;
   mListenerContext = nullptr;
   // Remove ourselves from the load group.
   if (mLoadGroup) {
     mLoadGroup->RemoveRequest(this, nullptr, status);
   }
   return NS_OK;
 }
 NS_IMETHODIMP
 RtspChannelChild::Suspend()
 {
   MOZ_CRASH("Should never be called");
 }
 NS_IMETHODIMP
 RtspChannelChild::Resume()
 {
   MOZ_CRASH("Should never be called");
 }
 //-----------------------------------------------------------------------------
 // nsBaseChannel
 //-----------------------------------------------------------------------------
 NS_IMETHODIMP
 RtspChannelChild::OpenContentStream(bool aAsync,
                                     nsIInputStream **aStream,
                                     nsIChannel **aChannel)
 {
   MOZ_CRASH("Should never be called");
 }
 //-----------------------------------------------------------------------------
 // nsIChildChannel
 //-----------------------------------------------------------------------------
 NS_IMETHODIMP
 RtspChannelChild::ConnectParent(uint32_t id)
 {
   // Create RtspChannelParent for redirection.
   AddIPDLReference();
   RtspChannelConnectArgs connectArgs;
   SerializeURI(nsBaseChannel::URI(), connectArgs.uri());
   connectArgs.channelId() = id;
   if (!gNeckoChild->SendPRtspChannelConstructor(this, connectArgs)) {
     return NS_ERROR_FAILURE;
   }
   return NS_OK;
 }
 NS_IMETHODIMP
 RtspChannelChild::CompleteRedirectSetup(nsIStreamListener *aListener,
                                         nsISupports *aContext)
 {
   return AsyncOpen(aListener, aContext);
 }
 } // namespace net
 } // namespace mozilla

The Tor Browser / annotate

netwerk/protocol/rtsp/RtspChannelChild.cpp@a63d609f5ebe (annotated)

netwerk/protocol/rtsp/RtspChannelChild.cpp