michael@0: /* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
michael@0: /* vim: set ts=2 et sw=2 tw=80: */
michael@0: /* This Source Code Form is subject to the terms of the Mozilla Public
michael@0:  * License, v. 2.0. If a copy of the MPL was not distributed with this file,
michael@0:  * You can obtain one at http://mozilla.org/MPL/2.0/. */
michael@0: 
michael@0: #include "AsyncHelper.h"
michael@0: 
michael@0: #include "nsIRequestObserver.h"
michael@0: 
michael@0: #include "nsNetUtil.h"
michael@0: 
michael@0: #include "FileService.h"
michael@0: 
michael@0: USING_FILE_NAMESPACE
michael@0: 
michael@0: NS_IMPL_ISUPPORTS(AsyncHelper, nsIRunnable, nsIRequest)
michael@0: 
michael@0: nsresult
michael@0: AsyncHelper::AsyncWork(nsIRequestObserver* aObserver, nsISupports* aCtxt)
michael@0: {
michael@0:   nsresult rv;
michael@0: 
michael@0:   if (aObserver) {
michael@0:     // build proxy for observer events
michael@0:     rv = NS_NewRequestObserverProxy(getter_AddRefs(mObserver), aObserver, aCtxt);
michael@0:     NS_ENSURE_SUCCESS(rv, rv);
michael@0:   }
michael@0: 
michael@0:   FileService* service = FileService::GetOrCreate();
michael@0:   NS_ENSURE_TRUE(service, NS_ERROR_FAILURE);
michael@0: 
michael@0:   nsIEventTarget* target = service->StreamTransportTarget();
michael@0: 
michael@0:   rv = target->Dispatch(this, NS_DISPATCH_NORMAL);
michael@0:   NS_ENSURE_SUCCESS(rv, rv);
michael@0: 
michael@0:   return NS_OK;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::Run()
michael@0: {
michael@0:   NS_ASSERTION(!NS_IsMainThread(), "Wrong thread!");
michael@0: 
michael@0:   if (mObserver) {
michael@0:     mObserver->OnStartRequest(this, nullptr);
michael@0:   }
michael@0: 
michael@0:   mStatus = DoStreamWork(mStream);
michael@0: 
michael@0:   if (mObserver) {
michael@0:     mObserver->OnStopRequest(this, nullptr, mStatus);
michael@0:   }
michael@0: 
michael@0:   return NS_OK;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::GetName(nsACString& aName)
michael@0: {
michael@0:   NS_WARNING("Shouldn't be called!");
michael@0:   return NS_ERROR_NOT_IMPLEMENTED;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::IsPending(bool* _retval)
michael@0: {
michael@0:   NS_WARNING("Shouldn't be called!");
michael@0:   return NS_ERROR_NOT_IMPLEMENTED;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::GetStatus(nsresult* aStatus)
michael@0: {
michael@0:   *aStatus = mStatus;
michael@0:   return NS_OK;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::Cancel(nsresult aStatus)
michael@0: {
michael@0:   return NS_OK;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::Suspend()
michael@0: {
michael@0:   NS_WARNING("Shouldn't be called!");
michael@0:   return NS_ERROR_NOT_IMPLEMENTED;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::Resume()
michael@0: {
michael@0:   NS_WARNING("Shouldn't be called!");
michael@0:   return NS_ERROR_NOT_IMPLEMENTED;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::GetLoadGroup(nsILoadGroup** aLoadGroup)
michael@0: {
michael@0:   NS_WARNING("Shouldn't be called!");
michael@0:   return NS_ERROR_NOT_IMPLEMENTED;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::SetLoadGroup(nsILoadGroup* aLoadGroup)
michael@0: {
michael@0:   NS_WARNING("Shouldn't be called!");
michael@0:   return NS_ERROR_NOT_IMPLEMENTED;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::GetLoadFlags(nsLoadFlags* aLoadFlags)
michael@0: {
michael@0:   NS_WARNING("Shouldn't be called!");
michael@0:   return NS_ERROR_NOT_IMPLEMENTED;
michael@0: }
michael@0: 
michael@0: NS_IMETHODIMP
michael@0: AsyncHelper::SetLoadFlags(nsLoadFlags aLoadFlags)
michael@0: {
michael@0:   NS_WARNING("Shouldn't be called!");
michael@0:   return NS_ERROR_NOT_IMPLEMENTED;
michael@0: }