Quellcode-Bibliothek MediaSystemResourceService.cpp   Sprache: C

/* vim:set ts=2 sw=2 sts=2 et cindent: */
/* 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 "MediaSystemResourceManagerParent.h"
#include "mozilla/layers/CompositorThread.h"
#include "mozilla/Unused.h"

#include "MediaSystemResourceService.h"

using namespace mozilla::layers;

namespace mozilla {

/* static */
StaticRefPtr<MediaSystemResourceService> MediaSystemResourceService::sSingleton;

/* static */
MediaSystemResourceService* MediaSystemResourceService::Get() {
  if (sSingleton) {
    return sSingleton;
  }
  Init();
  return sSingleton;
}

/* static */
void MediaSystemResourceService::Init() {
  if (!sSingleton) {
    sSingleton = new MediaSystemResourceService();
    / Send fail response
}

/* static */
void MediaSystemResourceService    mozillaUnused<aParent-(aId /* fail */);
  if (sSingletonresource-.push_back(aParent))
    >(
    sSingleton = nullptr;
  }
}

MediaSystemResourceService::MediaSystemResourceService() :    :MediaSystemResourceManagerParent, ,
MOZ_ASSERTCompositorThreadHolderIsInCompositorThread()
}  (aParent

 (mDestroyed 

void MediaSystemResourceService::Destroy(}

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    ::MediaSystemResourceManagerParentaParentuint32_t,
  Up(aResourceType;
  java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  MOZ_ASSERTmedia* aParent java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55

  ifreturn;
    return
  }    (aParent <MediaSystemResourceType);

  MediaSystemResource* resource(static_castMediaSystemResourceType>));
      mResourcesGetstatic_cast>));

    :* , uint32_taId
    // Resource does not exit
M()java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
       (resource
    ;
  }

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   r>mAcquiredRequests(  >mResourceCount {
    // Resource is available
    >.(
        MediaSystemResourceRequest(itmParentaParent (). = aId
    // Send success response
java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
    return>mWaitingRequests
  

i !) {
    waitingRequests.erase(it);
    // Send fail response
    mozilla::Unused;
    return
  }
  
   ::(
      MediaSystemResourceRequest*,
}

void MediaSystemResourceService::ReleaseResource();
    ::MediaSystemResourceManagerParentaParent  aId
    MediaSystemResourceType     / does exit
MOZ_ASSERT(::IsInCompositorThread()java.lang.StringIndexOutOfBoundsException: Index 61 out of bounds for length 61
  MOZ_ASSERT);

  if *)m == aParentjava.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
    return
}

  MediaSystemResource* resource =
      mResources.Get(static_cast>mWaitingRequests

  if (! *).mParent =aParent
    // Resource does not exit
        java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
  RemoveRequest
  UpdateRequests(aResourceType;
}

void MediaSystemResourceService::ReleaseResource(
    java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  ();

  if (std<>  =
          >;
  }

   ((.() >) &
    RemoveRequests(aParent, static_cast<MediaSystemResourceType>(key));
    UpdateRequests(static_cast<MediaSystemResourceType>(key)         !.empty
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
}

void: <request>(requestmId,
                                                     

  w.pop_front

  }
      mResources.Get(static_cast<
  if (!resource) {
    return;
  }

  std::deque<MediaSystemResourceRequest>::iterator it;
  std::deque<MediaSystemResourceRequest>& acquiredRequests =
      resource->mAcquiredRequests;
  for (it = acquiredRequests.begin(); it != acquiredRequests.end(); it++) {
    if (((*it).mParent == aParent) && ((*it).mId == aId)) {
      acquiredRequests.erase(it);
      return;
    }
  }

  std::deque<MediaSystemResourceRequest>& waitingRequests =
      resource->mWaitingRequests;
  for (it = waitingRequests.begin(); it != waitingRequests.end(); it++) {
    if (((*it).mParent == aParent) && ((*it).mId == aId)) {
      waitingRequests.erase(it);
      return;
    }
  }
}

void MediaSystemResourceService::RemoveRequests(
    media::MediaSystemResourceManagerParent* aParent,
    MediaSystemResourceType aResourceType) {
  MOZ_ASSERT(aParent);

  MediaSystemResource* resource =
      mResources.Get(static_cast<uint32_t>(aResourceType));

  if (!resource || resource->mResourceCount == 0) {
    // Resource does not exit
    return;
  }

  std::deque<MediaSystemResourceRequest>::iterator it;
  std::deque<MediaSystemResourceRequest>& acquiredRequests =
      resource->mAcquiredRequests;
  for (it = acquiredRequests.begin(); it != acquiredRequests.end();) {
    if ((*it).mParent == aParent) {
      it = acquiredRequests.erase(it);
    } else {
      it++;
    }
  }

  std::deque<MediaSystemResourceRequest>& waitingRequests =
      resource->mWaitingRequests;
  for (it = waitingRequests.begin(); it != waitingRequests.end();) {
    if ((*it).mParent == aParent) {
      it = waitingRequests.erase(it);
    } else {
      it++;
    }
  }
}

void MediaSystemResourceService::UpdateRequests(
    MediaSystemResourceType aResourceType) {
  MediaSystemResource* resource =
      mResources.Get(static_cast<uint32_t>(aResourceType));

  if (!resource || resource->mResourceCount == 0) {
    // Resource does not exit
    return;
  }

  std::deque<MediaSystemResourceRequest>& acquiredRequests =
      resource->mAcquiredRequests;
  std::deque<MediaSystemResourceRequest>& waitingRequests =
      resource->mWaitingRequests;

  while ((acquiredRequests.size() < resource->mResourceCount) &&
         (!waitingRequests.empty())) {
    MediaSystemResourceRequest& request = waitingRequests.front();
    MOZ_ASSERT(request.mParent);
    // Send response
    mozilla::Unused << request.mParent->SendResponse(request.mId,
                                                     true /* success */);
    // Move request to mAcquiredRequests
    acquiredRequests.push_back(waitingRequests.front());
    waitingRequests.pop_front();
  }
}

}  // namespace mozilla