blob: a5a1fcbde78fd1ac5293ba55417243aebdd48e91 [file] [log] [blame]
/*
* Copyright (C) 2016 The Android Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef ANDROID_FENCE_TIME_H
#define ANDROID_FENCE_TIME_H
#include <ui/Fence.h>
#include <utils/Flattenable.h>
#include <utils/Timers.h>
#include <atomic>
#include <mutex>
#include <queue>
#include <unordered_map>
namespace android {
class FenceToFenceTimeMap;
// A wrapper around fence that only implements isValid and getSignalTime.
// It automatically closes the fence in a thread-safe manner once the signal
// time is known.
class FenceTime {
friend class FenceToFenceTimeMap;
public:
// An atomic snapshot of the FenceTime that is flattenable.
//
// This class is needed because the FenceTime class may not stay
// consistent for all steps of the flattening process.
//
// Not thread safe.
struct Snapshot : public Flattenable<Snapshot> {
enum class State {
EMPTY,
FENCE,
SIGNAL_TIME,
};
Snapshot() = default; // Creates an empty snapshot.
explicit Snapshot(const sp<Fence>& fence);
explicit Snapshot(nsecs_t signalTime);
// Movable.
Snapshot(Snapshot&& src) = default;
Snapshot& operator=(Snapshot&& src) = default;
// Not copyable.
Snapshot(const Snapshot& src) = delete;
Snapshot& operator=(const Snapshot&& src) = delete;
// Flattenable implementation.
size_t getFlattenedSize() const;
size_t getFdCount() const;
status_t flatten(void*& buffer, size_t& size, int*& fds,
size_t& count) const;
status_t unflatten(void const*& buffer, size_t& size, int const*& fds,
size_t& count);
State state{State::EMPTY};
sp<Fence> fence{Fence::NO_FENCE};
nsecs_t signalTime{Fence::SIGNAL_TIME_INVALID};
};
static const std::shared_ptr<FenceTime> NO_FENCE;
explicit FenceTime(const sp<Fence>& fence);
explicit FenceTime(sp<Fence>&& fence);
// Passing in Fence::SIGNAL_TIME_PENDING is not allowed.
// Doing so will convert the signalTime to Fence::SIGNAL_TIME_INVALID.
explicit FenceTime(nsecs_t signalTime);
// Do not allow default construction. Share NO_FENCE or explicitly construct
// with Fence::SIGNAL_TIME_INVALID instead.
FenceTime() = delete;
// Do not allow copy, assign, or move. Use a shared_ptr to share the
// signalTime result. Or use getSnapshot() if a thread-safe copy is really
// needed.
FenceTime(const FenceTime&) = delete;
FenceTime(FenceTime&&) = delete;
FenceTime& operator=(const FenceTime&) = delete;
FenceTime& operator=(FenceTime&&) = delete;
// This method should only be called when replacing the fence with
// a signalTime. Since this is an indirect way of setting the signal time
// of a fence, the snapshot should come from a trusted source.
void applyTrustedSnapshot(const Snapshot& src);
bool isValid() const;
// Attempts to get the timestamp from the Fence if the timestamp isn't
// already cached. Otherwise, it returns the cached value.
nsecs_t getSignalTime();
// Gets the cached timestamp without attempting to query the Fence.
nsecs_t getCachedSignalTime() const;
// Returns a snapshot of the FenceTime in its current state.
Snapshot getSnapshot() const;
void signalForTest(nsecs_t signalTime);
private:
// For tests only. If forceValidForTest is true, then getSignalTime will
// never return SIGNAL_TIME_INVALID and isValid will always return true.
FenceTime(const sp<Fence>& fence, bool forceValidForTest);
enum class State {
VALID,
INVALID,
FORCED_VALID_FOR_TEST,
};
const State mState{State::INVALID};
// mMutex guards mFence and mSignalTime.
// mSignalTime is also atomic since it is sometimes read outside the lock
// for quick checks.
mutable std::mutex mMutex;
sp<Fence> mFence{Fence::NO_FENCE};
std::atomic<nsecs_t> mSignalTime{Fence::SIGNAL_TIME_INVALID};
};
// A queue of FenceTimes that are expected to signal in FIFO order.
// Only maintains a queue of weak pointers so it doesn't keep references
// to Fences on its own.
//
// Can be used to get the signal time of a fence and close its file descriptor
// without making a syscall for every fence later in the timeline.
// Additionally, since the FenceTime caches the timestamp internally,
// other timelines that reference the same FenceTime can avoid the syscall.
//
// FenceTimeline only keeps track of a limited number of entries to avoid
// growing unbounded. Users of FenceTime must make sure they can work even
// if FenceTimeline did nothing. i.e. they should eventually call
// Fence::getSignalTime(), not only Fence::getCachedSignalTime().
//
// push() and updateSignalTimes() are safe to call simultaneously from
// different threads.
class FenceTimeline {
public:
static constexpr size_t MAX_ENTRIES = 64;
void push(const std::shared_ptr<FenceTime>& fence);
void updateSignalTimes();
private:
mutable std::mutex mMutex;
std::queue<std::weak_ptr<FenceTime>> mQueue;
};
// Used by test code to create or get FenceTimes for a given Fence.
//
// By design, Fences cannot be signaled from user space. However, this class
// allows test code to set the apparent signalTime of a Fence and
// have it be visible to all FenceTimes. Release code should not use
// FenceToFenceTimeMap.
//
// FenceToFenceTimeMap keeps a weak reference to the FenceTime and automatically
// garbage collects entries every time a new FenceTime is created to avoid
// leaks. This prevents us from having to make the Fence destructor
// automatically notify that the underlying fence has been destroyed, which
// would affect release code paths. Garbage collecting so often is inefficient,
// but acceptable for testing.
//
// Since FenceTimes maintain a strong reference to underlying Fences, there
// should not be any aliasing issues where a new Fence happens to have the same
// address as a previous Fence; the previous entry will be garbage collected
// before the new one is added.
class FenceToFenceTimeMap {
public:
// Create a new FenceTime with that wraps the provided Fence.
std::shared_ptr<FenceTime> createFenceTimeForTest(const sp<Fence>& fence);
// Signals all FenceTimes created through this class that are wrappers
// around |fence|.
void signalAllForTest(const sp<Fence>& fence, nsecs_t signalTime);
private:
// Cleans up the entries that no longer have a strong reference.
void garbageCollectLocked();
mutable std::mutex mMutex;
std::unordered_map<Fence*, std::vector<std::weak_ptr<FenceTime>>> mMap;
};
}; // namespace android
#endif // ANDROID_FENCE_TIME_H