The Tor Browser: netwerk/base/src/nsRequestObserverProxy.cpp@b8a032363ba2 (annotated)

netwerk/base/src/nsRequestObserverProxy.cpp@b8a032363ba2 (annotated)

netwerk/base/src/nsRequestObserverProxy.cpp

Thu, 22 Jan 2015 13:21:57 +0100

author: Michael Schloh von Bennewitz <michael@schloh.com>
date: Thu, 22 Jan 2015 13:21:57 +0100
branch: TOR_BUG_9701
changeset 15: b8a032363ba2
permissions: -rw-r--r--

Incorporate requested changes from Mozilla in review:
https://bugzilla.mozilla.org/show_bug.cgi?id=1123480#c6

 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
 /* 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 "mozilla/DebugOnly.h"
 #include "nscore.h"
 #include "nsRequestObserverProxy.h"
 #include "nsIRequest.h"
 #include "nsAutoPtr.h"
 #include "prlog.h"
 using namespace mozilla;
 #if defined(PR_LOGGING)
 static PRLogModuleInfo *gRequestObserverProxyLog;
 #endif
 #undef LOG
 #define LOG(args) PR_LOG(gRequestObserverProxyLog, PR_LOG_DEBUG, args)
 //-----------------------------------------------------------------------------
 // nsARequestObserverEvent internal class...
 //-----------------------------------------------------------------------------
 nsARequestObserverEvent::nsARequestObserverEvent(nsIRequest *request)
     : mRequest(request)
 {
     NS_PRECONDITION(mRequest, "null pointer");
 }
 //-----------------------------------------------------------------------------
 // nsOnStartRequestEvent internal class...
 //-----------------------------------------------------------------------------
 class nsOnStartRequestEvent : public nsARequestObserverEvent
 {
     nsRefPtr<nsRequestObserverProxy> mProxy;
 public:
     nsOnStartRequestEvent(nsRequestObserverProxy *proxy,
                           nsIRequest *request)
         : nsARequestObserverEvent(request)
         , mProxy(proxy)
     {
         NS_PRECONDITION(mProxy, "null pointer");
     }
     virtual ~nsOnStartRequestEvent() {}
     NS_IMETHOD Run()
     {
         LOG(("nsOnStartRequestEvent::HandleEvent [req=%x]\n", mRequest.get()));
         if (!mProxy->mObserver) {
             NS_NOTREACHED("already handled onStopRequest event (observer is null)");
             return NS_OK;
         }
         LOG(("handle startevent=%p\n", this));
         nsresult rv = mProxy->mObserver->OnStartRequest(mRequest, mProxy->mContext);
         if (NS_FAILED(rv)) {
             LOG(("OnStartRequest failed [rv=%x] canceling request!\n", rv));
             rv = mRequest->Cancel(rv);
             NS_ASSERTION(NS_SUCCEEDED(rv), "Cancel failed for request!");
         }
         return NS_OK;
     }
 };
 //-----------------------------------------------------------------------------
 // nsOnStopRequestEvent internal class...
 //-----------------------------------------------------------------------------
 class nsOnStopRequestEvent : public nsARequestObserverEvent
 {
     nsRefPtr<nsRequestObserverProxy> mProxy;
 public:
     nsOnStopRequestEvent(nsRequestObserverProxy *proxy,
                          nsIRequest *request)
         : nsARequestObserverEvent(request)
         , mProxy(proxy)
     {
         NS_PRECONDITION(mProxy, "null pointer");
     }
     virtual ~nsOnStopRequestEvent() {}
     NS_IMETHOD Run()
     {
         LOG(("nsOnStopRequestEvent::HandleEvent [req=%x]\n", mRequest.get()));
         nsMainThreadPtrHandle<nsIRequestObserver> observer = mProxy->mObserver;
         if (!observer) {
             NS_NOTREACHED("already handled onStopRequest event (observer is null)");
             return NS_OK;
         }
         // Do not allow any more events to be handled after OnStopRequest
         mProxy->mObserver = 0;
         nsresult status = NS_OK;
         DebugOnly<nsresult> rv = mRequest->GetStatus(&status);
         NS_ASSERTION(NS_SUCCEEDED(rv), "GetStatus failed for request!");
         LOG(("handle stopevent=%p\n", this));
         (void) observer->OnStopRequest(mRequest, mProxy->mContext, status);
         return NS_OK;
     }
 };
 //-----------------------------------------------------------------------------
 // nsRequestObserverProxy::nsISupports implementation...
 //-----------------------------------------------------------------------------
 NS_IMPL_ISUPPORTS(nsRequestObserverProxy,
                   nsIRequestObserver,
                   nsIRequestObserverProxy)
 //-----------------------------------------------------------------------------
 // nsRequestObserverProxy::nsIRequestObserver implementation...
 //-----------------------------------------------------------------------------
 NS_IMETHODIMP
 nsRequestObserverProxy::OnStartRequest(nsIRequest *request,
                                        nsISupports *context)
 {
     MOZ_ASSERT(!context || context == mContext);
     LOG(("nsRequestObserverProxy::OnStartRequest [this=%p req=%x]\n", this, request));
     nsOnStartRequestEvent *ev =
         new nsOnStartRequestEvent(this, request);
     if (!ev)
         return NS_ERROR_OUT_OF_MEMORY;
     LOG(("post startevent=%p\n", ev));
     nsresult rv = FireEvent(ev);
     if (NS_FAILED(rv))
         delete ev;
     return rv;
 }
 NS_IMETHODIMP
 nsRequestObserverProxy::OnStopRequest(nsIRequest *request,
                                       nsISupports *context,
                                       nsresult status)
 {
     MOZ_ASSERT(!context || context == mContext);
     LOG(("nsRequestObserverProxy: OnStopRequest [this=%p req=%x status=%x]\n",
         this, request, status));
     // The status argument is ignored because, by the time the OnStopRequestEvent
     // is actually processed, the status of the request may have changed :-(
     // To make sure that an accurate status code is always used, GetStatus() is
     // called when the OnStopRequestEvent is actually processed (see above).
     nsOnStopRequestEvent *ev =
         new nsOnStopRequestEvent(this, request);
     if (!ev)
         return NS_ERROR_OUT_OF_MEMORY;
     LOG(("post stopevent=%p\n", ev));
     nsresult rv = FireEvent(ev);
     if (NS_FAILED(rv))
         delete ev;
     return rv;
 }
 //-----------------------------------------------------------------------------
 // nsRequestObserverProxy::nsIRequestObserverProxy implementation...
 //-----------------------------------------------------------------------------
 NS_IMETHODIMP
 nsRequestObserverProxy::Init(nsIRequestObserver *observer, nsISupports *context)
 {
     NS_ENSURE_ARG_POINTER(observer);
 #if defined(PR_LOGGING)
     if (!gRequestObserverProxyLog)
         gRequestObserverProxyLog = PR_NewLogModule("nsRequestObserverProxy");
 #endif
     mObserver = new nsMainThreadPtrHolder<nsIRequestObserver>(observer);
     mContext = new nsMainThreadPtrHolder<nsISupports>(context);
     return NS_OK;
 }
 //-----------------------------------------------------------------------------
 // nsRequestObserverProxy implementation...
 //-----------------------------------------------------------------------------
 nsresult
 nsRequestObserverProxy::FireEvent(nsARequestObserverEvent *event)
 {
     nsCOMPtr<nsIEventTarget> mainThread(do_GetMainThread());
     return mainThread->Dispatch(event, NS_DISPATCH_NORMAL);
 }

The Tor Browser / annotate

netwerk/base/src/nsRequestObserverProxy.cpp@b8a032363ba2 (annotated)

netwerk/base/src/nsRequestObserverProxy.cpp