ReplayingInputCursor.cpp [plain text]
#include "config.h"
#include "ReplayingInputCursor.h"
#if ENABLE(WEB_REPLAY)
#include "EventLoopInputDispatcher.h"
#include "ReplaySessionSegment.h"
#include "SegmentedInputStorage.h"
#include "SerializationMethods.h"
#include "WebReplayInputs.h"
#include <wtf/text/CString.h>
namespace WebCore {
ReplayingInputCursor::ReplayingInputCursor(RefPtr<ReplaySessionSegment>&& segment, Page& page, EventLoopInputDispatcherClient* client)
: m_segment(WTFMove(segment))
, m_dispatcher(std::make_unique<EventLoopInputDispatcher>(page, *this, client))
{
for (size_t i = 0; i < static_cast<size_t>(InputQueue::Count); i++)
m_positions.append(0);
}
ReplayingInputCursor::~ReplayingInputCursor()
{
}
Ref<ReplayingInputCursor> ReplayingInputCursor::create(RefPtr<ReplaySessionSegment>&& segment, Page& page, EventLoopInputDispatcherClient* client)
{
return adoptRef(*new ReplayingInputCursor(WTFMove(segment), page, client));
}
void ReplayingInputCursor::storeInput(std::unique_ptr<NondeterministicInputBase>)
{
ASSERT_NOT_REACHED();
}
NondeterministicInputBase* ReplayingInputCursor::loadInput(InputQueue queue, const String& type)
{
NondeterministicInputBase* input = uncheckedLoadInput(queue);
if (input->type() != type) {
LOG_ERROR("%-25s ERROR: Expected replay input of type %s, but got type %s\n", "[ReplayingInputCursor]", type.ascii().data(), input->type().ascii().data());
return nullptr;
}
return input;
}
NondeterministicInputBase* ReplayingInputCursor::uncheckedLoadInput(InputQueue queue)
{
if (m_positions[static_cast<size_t>(queue)] >= m_segment->storage().queueSize(queue)) {
String queueString = EncodingTraits<InputQueue>::encodeValue(queue).convertTo<String>();
LOG_ERROR("%-30s ERROR No more inputs remain for determinism queue %s, but one was requested.", "[ReplayingInputCursor]", queueString.ascii().data());
return nullptr;
}
return m_segment->storage().load(queue, m_positions[static_cast<size_t>(queue)]++);
}
EventLoopInputData ReplayingInputCursor::loadEventLoopInput()
{
ASSERT(m_segment);
size_t offset = m_positions.at(static_cast<size_t>(InputQueue::EventLoopInput));
ASSERT(offset < m_segment->eventLoopTimings().size());
EventLoopInputData data;
data.timestamp = m_segment->eventLoopTimings().at(offset);
data.input = static_cast<EventLoopInputBase*>(uncheckedLoadInput(InputQueue::EventLoopInput));
return data;
}
};
#endif // ENABLE(WEB_REPLAY)