ReplayingInputCursor.cpp [plain text]
#include "config.h"
#include "ReplayingInputCursor.h"
#if ENABLE(WEB_REPLAY)
#include "EventLoopInputDispatcher.h"
#include "SegmentedInputStorage.h"
#include "SerializationMethods.h"
#include "WebReplayInputs.h"
#include <wtf/text/CString.h>
namespace WebCore {
ReplayingInputCursor::ReplayingInputCursor(SegmentedInputStorage& storage, Page& page, EventLoopInputDispatcherClient* client)
: m_storage(storage)
, 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()
{
}
PassRefPtr<ReplayingInputCursor> ReplayingInputCursor::create(SegmentedInputStorage& storage, Page& page, EventLoopInputDispatcherClient* client)
{
return adoptRef(new ReplayingInputCursor(storage, page, client));
}
void ReplayingInputCursor::storeInput(std::unique_ptr<NondeterministicInputBase>)
{
ASSERT_NOT_REACHED();
}
NondeterministicInputBase* ReplayingInputCursor::loadInput(InputQueue queue, const AtomicString& 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.string().ascii().data(), input->type().string().ascii().data());
return nullptr;
}
return input;
}
NondeterministicInputBase* ReplayingInputCursor::uncheckedLoadInput(InputQueue queue)
{
if (m_positions[static_cast<size_t>(queue)] >= m_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_storage.load(queue, m_positions[static_cast<size_t>(queue)]++);
}
};
#endif // ENABLE(WEB_REPLAY)